Class AIAgentExecutor

examples/a2a/src/server.ts:88–167

// Agent executor that calls Workers AI
class AIAgentExecutor implements AgentExecutor {
  constructor(private getEnv: () => Env) {}

  async execute(
    requestContext: RequestContext,
    eventBus: ExecutionEventBus
  ): Promise<void> {
    const { taskId, contextId, userMessage, task } = requestContext;

    // Publish initial task if new
    if (!task) {
      const initialTask: Task = {
        contextId,
        history: [userMessage],
        id: taskId,
        kind: "task",
        status: {
          state: "submitted",
          timestamp: new Date().toISOString()
        }
      };
      eventBus.publish(initialTask);
    }

    // Working status
    eventBus.publish({
      contextId,
      final: false,
      kind: "status-update",
      status: {
        state: "working",
        timestamp: new Date().toISOString()
      },
      taskId
    } as TaskStatusUpdateEvent);

    // Extract user text
    const userText = userMessage.parts
      .filter((p) => p.kind === "text")
      .map((p) => (p as { kind: "text"; text: string }).text)
      .join("");

    // Call Workers AI
    const workersai = createWorkersAI({ binding: this.getEnv().AI });
    const result = await generateText({
      model: workersai("@cf/moonshotai/kimi-k2.6"),
      system:
        "You are a helpful AI assistant. Keep responses concise and clear.",
      messages: [{ role: "user", content: userText }]
    });

    // Publish agent response
    const responseMessage: Message = {
      contextId,
      kind: "message",
      messageId: crypto.randomUUID(),
      parts: [{ kind: "text", text: result.text }],
      role: "agent",