mirror of
https://github.com/justLV/onju-v2
synced 2026-04-21 15:47:55 +00:00
dd42fdb668
Replace callActive/sendDisconnect with deviceEnabled toggle — device starts enabled on boot, double-tap disables, single-tap re-enables. Removes 0xFF disconnect packets (bridge detects via silence + refused audio). Generates unique hostname from MAC suffix (onju-A1B2C3). Restructure onjuino TCP handling to persistent connection loop (500ms header timeout) so LED blinks reuse one connection per VAD session instead of opening 4-10 connections/sec. Pipeline tracks VAD recording transitions, opens/closes LED TCP accordingly. Remove send_stop_listening from pipeline — mic stays active during ASR/LLM/TTS for better interrupt detection, eliminates zombie-state failure mode. greet_device always sends 0xCC LED pulse for IP registration. Fix config chunk_size 480→512 to match device.
83 lines
2.7 KiB
Python
83 lines
2.7 KiB
Python
import asyncio
|
|
import logging
|
|
import struct
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
|
|
async def send_tcp(ip: str, port: int, header: bytes, data: bytes | None = None, timeout: float = 5):
|
|
try:
|
|
reader, writer = await asyncio.wait_for(
|
|
asyncio.open_connection(ip, port), timeout=timeout
|
|
)
|
|
writer.write(header)
|
|
if data:
|
|
writer.write(data)
|
|
await writer.drain()
|
|
writer.close()
|
|
await writer.wait_closed()
|
|
except (asyncio.TimeoutError, ConnectionError, OSError):
|
|
pass # non-critical, device may be busy
|
|
|
|
|
|
async def send_audio(ip: str, port: int, opus_payload: bytes, mic_timeout: int = 60, volume: int = 14, fade: int = 6):
|
|
# header[0] 0xAA for audio
|
|
# header[1:2] mic timeout in seconds (big-endian)
|
|
# header[3] volume
|
|
# header[4] fade rate
|
|
# header[5] compression type (2 = Opus)
|
|
header = bytes([
|
|
0xAA,
|
|
(mic_timeout >> 8) & 0xFF,
|
|
mic_timeout & 0xFF,
|
|
volume,
|
|
fade,
|
|
2, # Opus
|
|
])
|
|
await send_tcp(ip, port, header, opus_payload)
|
|
|
|
|
|
async def send_led_blink(ip: str, port: int, intensity: int, r: int = 255, g: int = 255, b: int = 255, fade: int = 6):
|
|
# header[0] 0xCC for LED blink
|
|
# header[1] starting intensity
|
|
# header[2:4] RGB
|
|
# header[5] fade rate
|
|
header = bytes([0xCC, intensity, r, g, b, fade])
|
|
await send_tcp(ip, port, header, timeout=0.1)
|
|
|
|
|
|
async def send_stop_listening(ip: str, port: int, hold_s: int = 0):
|
|
"""Unused by pipeline — kept for sesame-esp32-bridge compatibility."""
|
|
header = bytes([0xDD, (hold_s >> 8) & 0xFF, hold_s & 0xFF, 0, 0, 0])
|
|
await send_tcp(ip, port, header, timeout=0.2)
|
|
|
|
|
|
async def open_led_connection(ip: str, port: int, timeout: float = 1) -> asyncio.StreamWriter | None:
|
|
"""Open a persistent TCP connection for streaming LED blink commands."""
|
|
try:
|
|
_, writer = await asyncio.wait_for(
|
|
asyncio.open_connection(ip, port), timeout=timeout
|
|
)
|
|
return writer
|
|
except (asyncio.TimeoutError, ConnectionError, OSError):
|
|
return None
|
|
|
|
|
|
def write_led_blink(writer: asyncio.StreamWriter, intensity: int,
|
|
r: int = 255, g: int = 255, b: int = 255, fade: int = 6) -> bool:
|
|
"""Write a LED blink command to an open connection. Non-async (6-byte buffer write)."""
|
|
header = bytes([0xCC, intensity, r, g, b, fade])
|
|
try:
|
|
writer.write(header)
|
|
return True
|
|
except (ConnectionError, OSError):
|
|
return False
|
|
|
|
|
|
async def close_led_connection(writer: asyncio.StreamWriter):
|
|
"""Close a persistent LED connection."""
|
|
try:
|
|
writer.close()
|
|
await writer.wait_closed()
|
|
except (ConnectionError, OSError):
|
|
pass
|