A2A (Agent-to-Agent) 协议

import { Agent } from '@ag-kit/agents';
import { OpenAIProvider } from '@ag-kit/providers/openai';

const provider = new OpenAIProvider({
  apiKey: process.env.OPENAI_API_KEY,
  defaultModel: 'gpt-4'
});

const localAgent = new Agent({
  name: 'coordinator-agent',
  model: provider,
  instructions: 'You coordinate with other agents.'
});

// 通过 HTTP 请求进行 A2A 通信
async function delegateTask(task: any) {
  const response = await fetch('http://other-agent:3000/send-message', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      messages: [{
        role: 'user',
        content: `Agent task: ${JSON.stringify(task)}`
      }]
    })
  });
  return response.json();
}

// 注意：Agent 事件处理应在 Agent 的 run 方法中实现

// 通过注册服务发现 Agent
async function discoverAgents(capabilities: string[]) {
  const response = await fetch('http://agent-registry:8080/agents', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      capabilities,
      location: 'same_network'
    })
  });
  return response.json();
}

const agents = await discoverAgents(['data_processing', 'analysis']);

// 连接发现的 Agent
for (const agentInfo of agents) {
  console.log(`Found agent: ${agentInfo.name} at ${agentInfo.endpoint}`);
  // 使用 HTTP 请求与发现的 Agent 通信
}

import { run } from '@ag-kit/server';
import { Agent } from '@ag-kit/agents';
import { OpenAIProvider } from '@ag-kit/providers/openai';

const provider = new OpenAIProvider({
  apiKey: process.env.OPENAI_API_KEY,
  defaultModel: 'gpt-4'
});

const myAgent = new Agent({
  name: 'a2a-agent',
  model: provider,
  instructions: 'You are an A2A compatible agent.'
});

// 未来的 A2A 服务端实现
run({
  createAgent: () => ({ agent: myAgent }),
  port: 3001
});

// A2A 端点将在未来版本添加
// a2aServer.registerA2AEndpoint('/agents/discover', {
//   method: 'GET',
//   handler: async (req) => await discovery.findAgents(req.query)
// });