server-channels.ts —— OpenClaw 渠道插件生命周期管理器

// types/channel-plugin.ts
export interface ChannelPlugin {
  readonly id: string;          // 如 "whatsapp", "telegram"
  readonly name: string;        // 人类可读名

  // 初始化：加载配置、建立连接
  initialize(config: ChannelConfig): Promise<void>;

  // 启动：开始监听消息
  start(): Promise<void>;

  // 停止：优雅关闭连接
  stop(): Promise<void>;

  // 发送消息到该渠道
  sendMessage(sessionKey: string, message: ACPMessage): Promise<void>;

  // 获取会话元数据（如用户头像、昵称）
  getSessionMeta(sessionKey: string): Promise<SessionMeta>;
}

// channels/whatsapp.plugin.ts
class WhatsAppPlugin implements ChannelPlugin {
  async initialize(config) {
    this.client = new Twilio(config.accountSid, config.authToken);
    this.webhookPath = `/webhooks/whatsapp/${config.id}`;
  }

  // 将 Twilio Webhook 转为 ACP
  handleIncoming(req) {
    const sessionKey = `wa:${req.From}`;
    const content = req.Body;
    emitACPEvent('chat.sendMessage', { sessionKey, content });
  }

  async sendMessage(sessionKey, acpMsg) {
    const to = sessionKey.replace('wa:', '');
    await this.client.messages.create({ to, from: this.number, body: formatForWhatsApp(acpMsg) });
  }
}

// channels/web.plugin.ts
class WebPlugin implements ChannelPlugin {
  private wss: WebSocket.Server;

  async start() {
    this.wss = new WebSocket.Server({ port: 8080 });
    this.wss.on('connection', (ws, req) => {
      const sessionKey = req.url?.split('/').pop() || generateSessionId();
      ws.on('message', (data) => {
        const acp = JSON.parse(data.toString());
        routeACPMessage(sessionKey, acp); // 转发至核心
      });
    });
  }

  async sendMessage(sessionKey, acpMsg) {
    const ws = findWebSocketBySession(sessionKey);
    ws?.send(JSON.stringify(acpMsg));
  }
}

// channels/cli.plugin.ts
process.stdin.on('data', (chunk) => {
  const content = chunk.toString().trim();
  emitACPEvent('chat.sendMessage', { 
    sessionKey: 'cli:local', 
    content 
  });
});

// server-channels.ts
const plugins = new Map<string, ChannelPlugin>();

export function registerChannel(plugin: ChannelPlugin) {
  plugins.set(plugin.id, plugin);
}

// 自动扫描 ./channels/*.plugin.ts（开发模式）
if (devMode) autoLoadPlugins('./channels');

export async function startAllChannels(config: ServerConfig) {
  for (const [id, plugin] of plugins) {
    try {
      await plugin.initialize(config.channels[id]);
      await plugin.start();
      logger.info(`Channel '${id}' started`);
    } catch (err) {
      logger.error(`Failed to start channel '${id}':`, err.message);
    }
  }
}

[WhatsApp] 
   ↓ (Webhook)
WhatsAppPlugin.handleIncoming()
   ↓ (emit ACP event)
ACP Bus → Agent Core → Tool Execution
   ↓ (ACP response)
ACP Bus → WhatsAppPlugin.sendMessage()
   ↓ (Twilio API)
[User's Phone]

// WhatsAppPlugin
const sessionKey = `wa:${phoneNumber}`;

// TelegramPlugin
const sessionKey = `tg:${userId}`;

// WebPlugin
const sessionKey = `web:${randomId}`;

// channels/discord.plugin.ts
export class DiscordPlugin implements ChannelPlugin { ... }

registerChannel(new DiscordPlugin());

# config.yaml
channels:
  discord:
    enabled: true
    botToken: "your-token"
    guildId: "123456789"

// Prometheus 指标
openclaw_channel_active{channel="whatsapp"} 1
openclaw_channel_messages_total{channel="web", direction="in"} 142

{
  "event": "channel.message.in",
  "channel": "telegram",
  "sessionKey": "tg:123456789",
  "content": "重启服务"
}