A2A Client

import { A2AClient } from '@cogitator-ai/a2a';
import { Agent, Cogitator } from '@cogitator-ai/core';

const apiKey = process.env.GOOGLE_API_KEY;
if (!apiKey) throw new Error('Set GOOGLE_API_KEY');

const client = new A2AClient('http://localhost:3100');

const card = await client.agentCard();
console.log(`${card.name}: ${card.description} (streaming: ${card.capabilities.streaming})`);

const task = await client.sendMessage({
  role: 'user',
  parts: [{ type: 'text', text: 'Make this concise: "In my personal opinion, I think it is very cold today."' }],
});
console.log('Task', task.id, task.status.state);
const reply = task.artifacts[0]?.parts.find((part) => part.type === 'text');
if (reply?.type === 'text') console.log(reply.text);

const fetched = await client.getTask(task.id);
console.log('History length:', fetched.history.length);

const orchestrator = new Agent({
  name: 'orchestrator',
  model: 'google/gemini-3.5-flash-lite',
  instructions: 'Delegate writing tasks to the writing_assistant tool. Forward the request as-is.',
  tools: [
    client.asTool({
      name: 'writing_assistant',
      description: 'Remote writing assistant reachable over A2A',
    }),
  ],
  maxIterations: 3,
});

const cog = new Cogitator({ llm: { providers: { google: { apiKey } } } });
const result = await cog.run(orchestrator, {
  input: 'Fix the grammar: "Me and him goes to the store yesterday for buy some foods."',
});
console.log(result.output);

await cog.close();

pnpm add @cogitator-ai/a2a @cogitator-ai/core

GOOGLE_API_KEY=your-key npx tsx a2a-client.ts

npx tsx examples/a2a/02-a2a-client.ts