核心部分代码展示

Feishu message / card action
  → FeishuWebSocket (WebSocket 长连接)
  → MessageRouter / CardDispatcher (路由分发)
  → SessionStore + SessionHistoryStore (会话绑定)
  → invokeClaudeChat / invokeClaudeTask (AI 执行)
  → CardKit streaming update (实时卡片)
  → Feishu result card (结果回传)

const args = process.argv.slice(2);
const command = args[0];

if (!command) {
  // 无参数时启动交互式 TUI
  await import('./index.js');
  return;
}

if (command === 'session') {
  const action = args[1] as SessionCommandOptions['action'];
  const opts: SessionCommandOptions = { action };
  if (action === 'new' && subArgs[0]) {
    opts.directory = subArgs[0];
  }
  await handleSessionCommand(opts);
  return;
}

if (command === 'web-monitor') {
  await handleWebMonitorCommand(parseWebMonitorArgs(args.slice(1)));
  return;
}

// 1. 先检查交互流程（如目录输入）
const session = this.sessionStore.get(chatId);
if (session.flow !== 'none') {
  await this.handleFlowInput(chatId, text, senderOpenId, session.flow);
  return;
}

// 2. 再检查 slash command
const commandMatch = text.match(/^(\/\S+)(?:\s+(.*))?$/s);
if (commandMatch) {
  const command = commandMatch[1];
  const args = commandMatch[2]?.trim().split(/\s+/) || [];
  await this.handleCommand(command, args, chatId, chatType, senderOpenId, messageId);
  return;
}

// 3. 默认进入 Claude 对话
await this.handleChat(chatId, chatType, text, senderOpenId, messageId);

// 获取目录下已有的 Claude Code sessions
const sessions = await listSessions(trimmedDir);

if (sessions.length > 0) {
  // 已有历史会话，让用户选择
  return {
    card: createDirectorySessionSelectCard(trimmedDir, sessions).card,
    toast: '请选择要连接的 Claude Code 会话',
  };
} else {
  // 首次绑定，直接创建新会话
  await this.completeSession(chatId, trimmedDir, null);
  return {
    card: createDirectorySessionSuccessCard(trimmedDir, null).card,
    toast: '目录会话已创建',
  };
}

// 确定工作目录
const cwd = context.directory
  ? resolve(context.directory)
  : resolve(env.REPO_ROOT, 'workspace');

// 构建飞书上下文环境变量
const contextEnv = buildFeishuContextEnv(context);

// 生成稳定的 session ID
const sessionId = context.sessionId || chatIdToSessionId(context.chatId);

// 构建 Claude CLI 参数
const claudeArgs: string[] = [
  '-p',
  '--dangerously-skip-permissions',
  '--output-format', 'stream-json',
  '--include-partial-messages',
  '--verbose',
  '--resume', sessionId,
  prompt
];

// 节流更新，避免 API 过载
const scheduleTextFlush = () => {
  if (textFlushTimer) return;
  textFlushTimer = setTimeout(async () => {
    textFlushTimer = null;
    await doFlushText().catch(() => {});
    // 如果还有待处理的 delta，继续调度
    if (pendingTextDeltas.length > 0) scheduleTextFlush();
  }, 120); // 120ms 节流
};

// 处理文本增量
for (const delta of pendingTextDeltas) {
  accumulatedText += delta;
}
// 更新卡片内容
await this.cardKitManager.updateCardContent(
  cardId,
  'streaming-content',
  accumulatedText,
  sequence++
);

async run(event: GatewayEvent): Promise<GatewayResult> {
  // 根据 event type 匹配 feature
  const feature = this.options.registry.match(event);
  if (!feature) {
    return {
      success: false,
      message: `No Gateway feature matched event "${event.type}"`,
    };
  }

  try {
    // 执行 feature handler
    return await feature.handle(event, this.options.runtime);
  } catch (error) {
    const message = error instanceof Error ? error.message : String(error);
    // 异常兜底，返回统一错误结构
    return { success: false, message };
  }
}

function extractLatestTraceback(
  content: string,
  urlType: 'json' | 'text' | 'html'
): { traceback: string; hash: string } | null {
  if (urlType === 'json') {
    try {
      const parsed = JSON.parse(content);
      const entries = Array.isArray(parsed) ? parsed : parsed.logs ?? [parsed];

      // 反向遍历找最新的 traceback
      for (let i = entries.length - 1; i >= 0; i--) {
        const entry = entries[i];
        const tracebackText = entry.traceback ?? entry.error ?? entry.message;

        if (tracebackText && typeof tracebackText === 'string') {
          const trimmed = tracebackText.trim();
          if (trimmed) {
            return {
              traceback: trimmed,
              hash: hashTracebackContent(trimmed), // SHA-256
            };
          }
        }
      }
    } catch { /* fall through */ }
  }
  // text/html 格式处理...
}

## 核心规则

当用户只是普通聊天（提问、编程帮助、分析讨论、闲聊等），
直接将回复内容输出到 stdout。

当用户请求涉及飞书平台操作（发消息、查日程、创建文档、管理群聊等），
使用对应的 lark 技能通过 lark-cli 执行操作，
然后通过 lark-cli im +messages-send 将操作结果发送给用户。

## 安全约束

- 永远不要在回复中暴露 app_id、app_secret 或用户敏感信息
- 群操作前检查 bot 是否在群内
- 文档操作前检查是否有读写权限