用 400 行核心代码打造一个极简的 MoltBot（OpenClaw），这货现在叫 tele-code

Telegram 用户(手机)  <-->  Bridge Server(本地)  <-->  OpenCode(本地)

// 创建会话
const session = await client.session.create();

// 发送消息（异步，不阻塞）
await client.session.promptAsync({
path: { id: sessionId },
body: { parts: [{ type: 'text', text: '帮我修复这个 bug' }] }
});

// 订阅事件流（SSE）
const { stream } = await client.event.subscribe();
forawait (const event of stream) {
// 实时接收 AI 的输出
}

openCodeService.on('message.part.updated', async (event) => {
// 只处理文本类型的 part
if (event.part?.type !== 'text') return;

// 累积内容
const newContent = event.delta
    ? currentContent + event.delta
    : event.content;

// 编辑 Telegram 消息
await telegramService.editMessage(chatId, messageId, newContent);
});

const EDIT_THROTTLE_MS = 1000; // 每秒最多编辑一次

functionshouldThrottle(chatId: number): boolean {
const now = Date.now();
const lastTime = lastEditTime.get(chatId) || 0;
if (now - lastTime < EDIT_THROTTLE_MS) {
    returntrue; // 跳过这次编辑，内容已经累积了，下次一起更新
  }
  lastEditTime.set(chatId, now);
returnfalse;
}

export functionsplitMessage(text: string, maxLength = 4096): string[] {
if (text.length <= maxLength) return [text];

constmessages: string[] = [];
let remaining = text;

while (remaining.length > 0) {
    if (remaining.length <= maxLength) {
      messages.push(remaining);
      break;
    }

    let splitIndex = maxLength - TRUNCATION_SUFFIX.length;

    // 尽量在换行符处分割，而不是暴力截断
    const lastNewline = remaining.lastIndexOf('\n', splitIndex);
    if (lastNewline > splitIndex * 0.5) {
      splitIndex = lastNewline;
    }

    messages.push(remaining.slice(0, splitIndex) + '\n\n... (message truncated)');
    remaining = remaining.slice(splitIndex).trim();
  }

return messages;
}

opencode  63724  TCP localhost:4096   (LISTEN)
opencode  64736  TCP localhost:60123  (LISTEN)
opencode  99508  TCP localhost:57194  (LISTEN)

async initialize(): Promise<void> {
if (config.opencode.port) {
    // 如果用户明确指定了端口，直接连
    this.client = createOpencodeClient({ baseUrl: `http://127.0.0.1:${port}` });
  } else {
    // 否则，逐个探测常见端口
    const commonPorts = [4096, 60123, 57194, 8080, 3000];
    for (const port of commonPorts) {
      const testClient = createOpencodeClient({ baseUrl: `http://127.0.0.1:${port}` });
      try {
        const response = await testClient.session.list();
        if (!response.error) {
          this.client = testClient; // 找到了！
          return;
        }
      } catch {
        // 这个端口不行，试下一个
      }
    }
    // 都找不到？那就自己启动一个
    const result = awaitcreateOpencode({ hostname: '127.0.0.1' });
    this.client = result.client;
  }
}

"High concurrency usage of this API, please reduce concurrency..."

/models          -- 查看可用模型
/model 1         -- 快速切换到 DeepSeek Chat
/model google gemini-2.0-flash  -- 指定任意模型

await client.session.promptAsync({
  path: { id: sessionId },
  body: {
    parts: [{ type: 'text', text }],
    ...(model && { model }), // 有指定模型就用，没有就用默认
  },
});

tele-code/
├── src/
│   ├── index.ts              # 入口：编排所有服务的启动顺序
│   ├── config.ts             # 配置：类型安全的环境变量加载
│   ├── services/
│   │   ├── telegram.ts       # Telegram Bot 封装（Telegraf）
│   │   ├── opencode.ts       # OpenCode SDK 封装 + SSE 事件流
│   │   └── session.ts        # 会话状态管理（chatId <-> sessionId）
│   ├── handlers/
│   │   └── message.ts        # 消息处理：命令、文本、事件回调
│   └── utils/
│       └── formatter.ts      # 消息格式化和分割
├── .env                      # 配置（Bot Token、代理等）
├── package.json
└── tsconfig.json