ADK Reference

from terminaluse.lib import adk

from terminaluse.lib import adk
from terminaluse.lib import TextPart, DataPart

# Simple text message (recommended)
await adk.messages.send(
    task_id="task-123",
    content="Hello, world!"
)

# Explicit TextPart
await adk.messages.send(
    task_id="task-123",
    content=TextPart(text="**Bold** and *italic*")
)

# Structured data (for generative UIs)
await adk.messages.send(
    task_id="task-123",
    content=DataPart(data={"temperature": 72, "unit": "fahrenheit"})
)

messages = await adk.messages.list(task_id="task-123")
for msg in messages:
    print(msg.content)

await adk.state.create(
    task_id="task-123",
    agent_id="agent-456",
    state={
        "user_preferences": {},
        "message_count": 0,
        "initialized_at": "2024-01-01T00:00:00Z"
    }
)

state = await adk.state.get(
    task_id="task-123",
    agent_id="agent-456"
)
print(state.get("message_count"))

await adk.state.update(
    task_id="task-123",
    agent_id="agent-456",
    state={
        "message_count": 5,
        "last_activity": "2024-01-01T12:00:00Z"
    }
)

await adk.state.delete(
    task_id="task-123",
    agent_id="agent-456"
)

# By ID
task = await adk.tasks.get(task_id="task-123")

# By name
task = await adk.tasks.get(task_name="my-task")

print(task.id, task.status)

await adk.tasks.delete(task_id="task-123")

events = await adk.events.list(task_id="task-123")
for event in events:
    print(event.content)

event = await adk.events.get(event_id="event-789")

# By ID
agent = await adk.agents.get(agent_id="agent-456")

# By name
agent = await adk.agents.get(agent_name="my-agent")

print(agent.name, agent.status)

agents = await adk.agents.list()
for agent in agents:
    print(agent.name)

task = await adk.acp.create_task(
    agent_id="agent-456",
    params={"user_id": "user-123", "mode": "interactive"}
)
print(task.id)

await adk.acp.send_event(
    task_id="task-123",
    content=TextPart(text="User input")
)

await adk.acp.cancel_task(task_id="task-123")

result = await adk.filesystem.sync_down(
    filesystem_id="fs-123",
    local_path="/workspace/files"
)
print(f"Downloaded {result.files_changed} files")

result = await adk.filesystem.sync_up(
    filesystem_id="fs-123",
    local_path="/workspace/files"
)
print(f"Uploaded {result.files_changed} files")

await adk.task.sync_down_system_folder(
    task_id="task-123",
    folder_type="dot_claude",
)

await adk.task.sync_up_system_folder(
    task_id="task-123",
    folder_type="dot_claude",
)

tracker = await adk.agent_task_tracker.get(task_id="task-123")
print(tracker.status, tracker.progress)

trackers = await adk.agent_task_tracker.list()

await adk.agent_task_tracker.update(
    task_id="task-123",
    progress=75,
    status_message="Processing step 3 of 4"
)

from terminaluse.lib import AgentServer, TaskContext, Event

server = AgentServer()

@server.on_event
async def handle_event(ctx: TaskContext, event: Event):
    # Using ctx (pre-bound to current task/agent)
    await ctx.messages.send("Hello")
    await ctx.state.update({"count": 1})

    # Equivalent using adk (requires explicit IDs)
    from terminaluse.lib import adk
    await adk.messages.send(task_id=ctx.task.id, content="Hello")
    await adk.state.update(
        task_id=ctx.task.id,
        agent_id=ctx.agent.id,
        state={"count": 1}
    )