@cicctencent/agent-core

内部库，仅供项目内部使用，不对外发布。

AI Agent 核心引擎，提供 ReAct 循环编排、多 LLM 供应商抽象、工具注册与执行、MCP 协议集成、Skill 路由、安全守卫、渐进式记忆管道、A2A 协议互操作（流式事件透传），以及工具风险评估、审批管理、运行注册表、引擎复用池、JSON 存储、可观测性日志等应用级能力。

文档

• 完整 API 文档 — 所有模块的接口说明和使用示例
• v0.2 升级指南 — 新增 12 个下沉模块的集成指南
• Runtime 下沉与迁移指南 — Runtime Builder、RunController、默认沙箱、A2A Server Helper 与使用方迁移边界

快速开始

pnpm add @cicctencent/agent-core

import { AgentEngine, createLLMProvider, ToolRegistry, ContextManager } from '@cicctencent/agent-core';

const llm = createLLMProvider({ provider: 'openai', model: 'gpt-4o', apiKey: process.env.OPENAI_API_KEY! });
const toolRegistry = new ToolRegistry();
const engine = new AgentEngine({ llmProvider: llm, toolRegistry, contextManager: new ContextManager(), maxIterations: 10 });

for await (const event of engine.run({ sessionId: 'session-001', message: 'Hello' })) {
  if (event.type === 'message') process.stdout.write(event.content);
  if (event.type === 'done') console.log('\nDone:', event.content);
}

A2A 协议集成

支持将远程 A2A Agent 包装为 SubAgentRunner，与本地 Specialist 并列注册到 delegate_task：

import { A2AClient, createA2ARemoteRunner, createDelegateTool } from '@cicctencent/agent-core';

const client = new A2AClient();
const card = await client.discoverAgent('https://remote-agent.example.com');

const remoteRunner = createA2ARemoteRunner({
  agentUrl: card.url,
  name: `[Remote] ${card.name}`,
  description: card.description,
  streaming: card.capabilities.streaming,
  client,
  skillId: 'specialist_123',  // 可选，供服务端路由到对应的 specialist
});

const delegateTool = createDelegateTool([localSpecialist, remoteRunner]);
if (delegateTool) registry.register(delegateTool);

核心特性：

• 事件透传：Core 不对 A2A SSE 事件做过滤，服务端发的所有事件均透传给调用方
• 流式自动降级：远程不支持流式时自动回退到同步模式
• 取消支持：流式传输支持 AbortSignal 外部取消
• 心跳重置超时：逐次读取超时，心跳可重置计时器，适合长时间任务

详见 A2A 协议文档。

构建

pnpm typecheck   # 类型检查
pnpm build       # 生成 .d.ts

运行时要求

Node.js >= 22