Google ADK (Agent Development Kit)

1
import asyncio
2
import os
3
from google.adk.agents import Agent
4
from google.adk.runners import Runner
5
from google.adk.sessions import InMemorySessionService
6
from google.adk.agents.live_request_queue import LiveRequestQueue
7
from google.adk.agents.run_config import RunConfig, StreamingMode
8
from google.genai import types
9
from agentao_sdk import AgenTaoClient, AgenTaoClientConfig, ActiveCall
10
import agentao_sdk.events as events
11
12
agent = Agent(
13
    name="agentao_agent",
14
    model="gemini-2.5-flash-native-audio-preview-12-2025",
15
    instruction="You are a helpful AI assistant talking over a phone call.",
16
)
17
session_service = InMemorySessionService()
18
runner = Runner(
19
    app_name="agentao_app", agent=agent, session_service=session_service
20
)
21
22
async def start_adk_session(call: ActiveCall):
23
    await call.answer()
24
25
    live_request_queue = LiveRequestQueue()
26
27
    async def stream_to_adk():
28
        async for audio_chunk in call.audio_stream():
29
            audio_blob = types.Blob(
30
                data=audio_chunk, mime_type="audio/pcm;rate=24000"
31
            )
32
            live_request_queue.send_realtime(audio_blob)
33
34
    async def receive_from_adk():
35
        run_config = RunConfig(
36
            streaming_mode=StreamingMode.BIDI,
37
            response_modalities=["AUDIO"],
38
        )
39
        async for event in runner.run_live(
40
            user_id="default_user",
41
            session_id=call.call_id,
42
            live_request_queue=live_request_queue,
43
            run_config=run_config,
44
        ):
45
            if event.interrupted:
46
                await call.clear_send_audio_buffer()
47
48
            if event.content and event.content.parts[0].inline_data:
49
                await call.send_audio(
50
                    event.content.parts[0].inline_data.data
51
                )
52
53
    await asyncio.gather(stream_to_adk(), receive_from_adk())
54
55
async def main():
56
    config = AgenTaoClientConfig.sandbox(
57
        api_key=os.getenv("WSS_API_KEY"),
58
        connector_uuid=os.getenv("WSS_CONNECTOR_UUID"),
59
        sample_rate=24000,
60
    )
61
62
    async with AgenTaoClient(config) as client:
63
        @client.on(events.INCOMING_CALL)
64
        async def handle_call(call: ActiveCall):
65
            await start_adk_session(call)
66
67
        await client.run_forever()
68
69
if __name__ == "__main__":
70
    asyncio.run(main())