pi-agent-core

通用的 agent 运行时逻辑,不含 UI 或 CLI 交互,主要包括 Agent、agentLoop、AgentState、AgentHarness、SessionRepository 等核心实体

pi-coding-agent(CLI 应用)

pi-ai = 大脑接口（LLM 能力） pi-agent-core = Agent 引擎（循环、状态、消息、工具编排） pi-coding-agent = 一个具体产品形态（像 Claude Code / Cursor CLI）

                         User
                          |
                          |
                    pi-coding-agent
                    (CLI/TUI 产品层)
                          |
        +-----------------+----------------+
        |                                  |
        |                                  |
  Session Management                 Interactive UI
        |                                  |
        |
        v
+--------------------------------+
|        pi-agent-core            |
|                                |
|  Agent Loop                    |
|                                |
|  1. Receive message            |
|  2. Build context              |
|  3. Call LLM                   |
|  4. Execute tools              |
|  5. Update state               |
|  6. Repeat                     |
+--------------------------------+
              |
              |
              |
       +------+------+
       |             |
       v             v

   pi-ai          Tools
   LLM Layer      filesystem
                  bash
                  edit
                  browser
                  ...


       |
       v

 OpenAI
 Anthropic
 Gemini
 Bedrock

pi-ai 负责：

• provider 管理
• API 调用
• streaming
• token
• model catalog
• OAuth

pi-agent-core 负责

agent loop

思考：我可以把智能工厂和finwork的对接工程发包成sdk给大家，

比如说可以把他们封装成类似pi-ai的东西

pi-ai里面涉及到的核心概念

1.compat—对不同模型的备用处理方案，默认使用openAi的处理方式，其他的定制化方案都叫compat

models.ts(Models 运行时)、compat.ts(兼容层)、auth/(认证)、api/(各 provider 的 API 实现)、providers/(具体 provider 工厂 + 生成的 catalog)

核心运行时 Models/createProvider、具体 provider 工厂如何组装、API 实现层的懒加载机制、faux 测试 provider,以及上层 pi-agent-core 和 pi-coding-agent 如何消费这套 API

PI里面写得好的函数

/**
 * Stop waiting for an operation when its signal aborts while continuing to
 * observe the abandoned promise so a later rejection is always handled.
 */
export function raceWithAbortSignal<T>(operation: Promise<T>, signal: AbortSignal): Promise<T> {
	if (signal.aborted) {
		void operation.catch(() => {});
		return Promise.reject(abortReason(signal));
	}

	return new Promise<T>((resolve, reject) => {
		let settled = false;
		const cleanup = () => signal.removeEventListener("abort", onAbort);
		const onAbort = () => {
			if (settled) return;
			settled = true;
			cleanup();
			reject(abortReason(signal));
		};

		signal.addEventListener("abort", onAbort, { once: true });
		void operation.then(
			(value) => {
				if (settled) return;
				settled = true;
				cleanup();
				resolve(value);
			},
			(error: unknown) => {
				if (settled) return;
				settled = true;
				cleanup();
				reject(error);
			},
		);
		if (signal.aborted) onAbort();
	});
}