Method recv_loop

web_demo/server/server.py:253–344

()

        audio_list = []

        async def recv_loop():
            nonlocal close, is_recording, turn_counter, opus_reader
            try:
                async for message in ws:
                    if message.type == aiohttp.WSMsgType.ERROR:
                        log("error", f"{ws.exception()}")
                        break
                    elif message.type == aiohttp.WSMsgType.CLOSED:
                        break
                    elif message.type != aiohttp.WSMsgType.BINARY:
                        log("error", f"unexpected message type {message.type}")
                        continue
                    message = message.data
                    if not isinstance(message, bytes):
                        log("error", f"unsupported message type {type(message)}")
                        continue
                    if len(message) == 0:
                        log("warning", "empty message")
                        continue
                    
                    try:
                        decoded = decode_message(message)
                        msg_type = decoded['type']
                        
                        if msg_type == 'audio':
                            if is_recording:
                                payload = decoded['data']
                                log("info", f"Received audio data: {len(payload)} bytes")
                                pcm = opus_reader.append_bytes(payload)
                                if pcm is not None and len(pcm) > 0:
                                    await pcm_queue.put(pcm)
                        
                        elif msg_type == 'control':
                            action = decoded['action']
                            if action == 'pause':
                                log("info", f"Received PAUSE signal")
                                is_recording = False
                                await save_audio_queue.put(('pause', None))
                            elif action == 'start':
                                log("info", f"Received START signal")
                                is_recording = True
                                turn_counter += 1
                                await save_audio_queue.put(('start', None))
                            elif action == 'endTurn':
                                log("info", f"Received END_TURN signal")
                                is_recording = False
                                await save_audio_queue.put(('pause', None))
                            else:
                                log("info", f"Received control: {action}")
                        
                        elif msg_type == 'ping':
                            log("info", "Received PING")
                        
                        elif msg_type == 'text':
                            log("info", f"Received text: {decoded['data']}")
                        
                        elif msg_type == 'metadata':
                            metadata = decoded['data']