OpenClaw 项目分析

openclaw/
├── src/                    # 核心源码
│   ├── agents/             # AI Agent 运行时（Pi embedded runner）
│   ├── auto-reply/         # 消息调度与回复处理
│   ├── channels/           # 渠道定义（dock/registry/plugin types）
│   │   └── plugins/        # 渠道插件类型定义
│   ├── cli/                # CLI 入口与命令
│   ├── commands/           # 各CLI子命令实现
│   ├── config/             # 配置加载/校验/迁移（JSON5）
│   ├── gateway/            # WebSocket/HTTP 网关服务器
│   ├── infra/              # 基础设施（日志/事件/更新检查等）
│   ├── media/              # 媒体处理管道
│   ├── provider-web.ts     # Web Provider
│   └── routing/            # 消息路由
├── extensions/             # 渠道扩展插件（35+个 workspace packages）
├── apps/                   # 原生客户端（macOS/iOS/Android）
├── ui/                     # Control UI 前端
├── docs/                   # 文档
└── skills/                 # Agent Skills

用户消息 ─→ Channel Plugin (inbound)
              │
              ▼
         MsgContext (envelope 封装)
              │  [channel, from, body, timestamp, chatType, sessionKey]
              ▼
    dispatchInboundMessage()          ← src/auto-reply/dispatch.ts
              │
              ▼
      getReplyFromConfig()            ← src/auto-reply/reply/get-reply.ts
         │  1. 解析 agent/session (resolveSessionAgentId)
         │  2. 解析 model/provider (resolveDefaultModel)
         │  3. 应用 media/link understanding
         │  4. 校验命令权限 (resolveCommandAuthorization)
         │  5. 初始化 session state
         │  6. 处理 directives (model切换/think/verbose/elevated)
         │  7. 处理 inline actions (status/reset/compact 等命令)
         │
         ▼
    runPreparedReply()                ← 调用 Pi embedded runner
         │
         ▼
    subscribeEmbeddedPiSession()      ← src/agents/pi-embedded-subscribe.ts
         │  - 订阅 LLM provider stream
         │  - strip thinking/final tags
         │  - block chunking (分块回复)
         │  - reasoning stream 处理
         │  - tool output 格式化
         │  - compaction retry 管理
         │
         ▼
    ReplyDispatcher (回复分发)
         │  - onBlockReply: 分块发送
         │  - onToolResult: 工具结果
         │  - typing indicator 管理
         │
         ▼
    Channel Plugin (outbound)  ─→  用户收到回复

type ChannelPlugin<ResolvedAccount, Probe, Audit> = {
  id: ChannelId;
  meta: ChannelMeta; // label, docs, image 等
  capabilities: ChannelCapabilities; // outbound, streaming, groups, mentions
  config: ChannelConfigAdapter; // 配置解析
  setup?: ChannelSetupAdapter; // 初始化
  pairing?: ChannelPairingAdapter; // 配对连接
  security?: ChannelSecurityAdapter; // DM策略/权限
  groups?: ChannelGroupAdapter; // 群组处理
  mentions?: ChannelMentionAdapter; // @提及处理
  outbound?: ChannelOutboundAdapter; // 发送消息
  streaming?: ChannelStreamingAdapter; // 流式回复
  threading?: ChannelThreadingAdapter; // 线程回复
  messaging?: ChannelMessagingAdapter; // 消息格式化
  gateway?: ChannelGatewayAdapter; // 网关集成
  heartbeat?: ChannelHeartbeatAdapter; // 心跳检测
  agentTools?: ChannelAgentToolFactory; // 渠道专属工具
  // ... 更多适配器
};

优先级 (从高到低):
  1. peer binding    → 特定联系人绑定
  2. guild binding   → 群组/服务器绑定
  3. team binding    → 团队绑定
  4. account binding → 账号级绑定
  5. channel binding → 渠道级绑定
  6. default agent   → 全局默认

Gateway Server (默认端口 18789)
│
├── WebSocket Server (attachGatewayWsHandlers)
│   ├── 客户端管理 (clients, broadcast)
│   ├── Node Registry (远程节点)
│   ├── 方法注册 (coreGatewayHandlers + plugin handlers)
│   └── Agent Event 订阅 (createAgentEventHandler)
│
├── HTTP Endpoints
│   ├── Control UI (SPA 前端)
│   ├── POST /v1/chat/completions (OpenAI 兼容)
│   └── POST /v1/responses (OpenResponses API)
│
├── Channel Manager (createChannelManager)
│   ├── 渠道运行时管理 (start/stop/status)
│   └── Runtime Snapshot (监控)
│
├── Discovery Service (mDNS/Bonjour + Wide Area)
├── Cron Service (定时任务)
├── Heartbeat Runner (心跳)
├── Config Reloader (配置热重载)
├── TLS Runtime (可选)
├── Tailscale Exposure (可选)
├── Canvas Host (可选, 代码执行沙箱)
└── Browser Control (可选)

[Channel From +elapsed Timestamp] body

OpenClawConfig = {
  agents: { defaults, bindings },  // Agent 配置
  channels: { ... },               // 渠道配置
  session: { ... },                // Session 配置
  gateway: {                       // Gateway 配置
    http: { endpoints },
    tls, controlUi, auth
  },
  discovery: { mdns, wideArea },   // 发现服务
  commands: { ... },               // 命令配置
}