Function receive_transcripts

api/transcriptions.py:120–142

Deepgram → Browser: relay transcript events.

()

                        pass

            async def receive_transcripts():
                """Deepgram → Browser: relay transcript events."""
                nonlocal dg_dropped
                try:
                    async for raw in dg_ws:
                        msg = json.loads(raw)
                        if msg.get("type") != "Results":
                            continue
                        transcript = (
                            msg.get("channel", {})
                            .get("alternatives", [{}])[0]
                            .get("transcript", "")
                        )
                        if transcript:
                            is_final = msg.get("is_final", False)
                            await websocket.send_json({"text": transcript, "is_final": is_final})

                except websockets.exceptions.ConnectionClosed as e:
                    logger.info(f"Deepgram connection closed: {e}")
                    dg_dropped = True
                except Exception as e:
                    logger.error(f"Transcript receive error: {e}")
                    dg_dropped = True

            fwd = asyncio.create_task(forward_audio())
            rcv = asyncio.create_task(receive_transcripts())