CortexCraft Voice Agent

# One Gemini Live session per phone call: audio in, audio out, text alongside.
while True:
    config = self._live_config(include_language_code=include_language_code)
    connected = False
    try:
        async with self.client.aio.live.connect(model=self.model, config=config) as session:
            connected = True
            await _maybe_call(session_open_callback)
            event_queue: asyncio.Queue = asyncio.Queue()
            tasks = [
                asyncio.create_task(self._send_audio_loop(session, audio_input_queue, event_queue)),
                asyncio.create_task(self._send_text_loop(session, text_input_queue, event_queue)),
                asyncio.create_task(self._receive_loop(session, event_queue, audio_output_callback, audio_interrupt_callback)),
            ]
            # ... stream events until the call ends, then cancel the tasks
    except Exception as exc:
        if not connected and include_language_code and _language_code_rejected(exc):
            # The 3.1 Live preview may refuse SpeechConfig.language_code:
            # retry once without it so the PSTN call still connects.
            include_language_code = False
            continue
        raise