chore: update code

Author: suj1e

src/claude.ts

@@ -21,12 +21,14 @@
 import * as lark from "@larksuiteoapi/node-sdk";
 import { optimizeForCard, truncateSafely } from "../format/card-optimize.js";
 import { stripThinking } from "../format/thinking.js";
+import { replyMessage } from "./lark.js";
 import { STREAMING_TRUNCATE, FlushController } from "./flush.js";
 import type { FlushControllerOptions } from "./flush.js";
 import { buildCard, markdown, hr, buildThinkingPanel, buildToolPanels, buildHeader, buildFooterElement, buildStatsTags } from "../card/index.js";
 import type { ToolResultEntry } from "../card/index.js";
-import { replyFinalCard, prepareOverflowContext, createOverflowDocument, registerDocument, cleanupOldDocuments } from "./index.js";
-import type { ReplyContext, CompletionOptions } from "./index.js";
+import { replyFinalCard, prepareOverflowContext } from "./message.js";
+import type { ReplyContext, CompletionOptions } from "./message.js";
+import { createAndRegisterOverflowDoc, cleanupOldDocuments } from "./document.js";
 import { countTables } from "../format/index.js";
 
 // ── 常量 ──────────────────────────────────────────────────
@@ -386,12 +388,9 @@ export class CardKitController {
    * 通过 IM 消息 API 发送卡片到聊天
    */
   private async sendCardMessage(): Promise<void> {
-    await (this.client.im.message as any).reply({
-      path: { message_id: this.rootMsgId },
-      data: {
-        content: JSON.stringify({ type: "card", data: { card_id: this.cardId } }),
-        msg_type: "interactive",
-      },
+    await replyMessage(this.client, this.rootMsgId, {
+      content: JSON.stringify({ type: "card", data: { card_id: this.cardId } }),
+      msgType: "interactive",
     });
   }
 
@@ -458,9 +457,7 @@ export class CardKitController {
         this.client, this.rootMsgId, this.context,
       );
 
-      const { docUrl, docId } = await createOverflowDocument(token, title, rawContent, originalMessage, meta);
-
-      registerDocument(docId, this.context.profile);
+      const { docUrl, docId } = await createAndRegisterOverflowDoc(token, title, rawContent, originalMessage, meta, this.context.profile);
 
       let cardContent = `📝 内容较长，已写入云文档：[${title}](${docUrl})`;
 

src/client/cardkit.ts

@@ -45,6 +45,20 @@ export function registerDocument(docId: string, profile: string): void {
   saveDocRegistry(profile, records);
 }
 
+/** 创建 overflow 文档并注册到本地 */
+export async function createAndRegisterOverflowDoc(
+  token: string,
+  title: string,
+  markdown: string,
+  originalMessage: string,
+  meta: import("../format/index.js").DocumentMeta,
+  profile: string,
+) {
+  const result = await createOverflowDocument(token, title, markdown, originalMessage, meta);
+  registerDocument(result.docId, profile);
+  return result;
+}
+
 function getOldestDocuments(profile: string, keepCount: number): DocumentRecord[] {
   const records = loadDocRegistry(profile);
   const sortedDocs = [...records].sort((a, b) => a.createdAt - b.createdAt);

src/client/document.ts

@@ -151,10 +151,7 @@ export class FlushController {
 
 // ── 流式卡片接口 ──────────────────────────────────────────────
 
-import type { CompletionOptions } from "./index.js";
-
-/** @deprecated Import CompletionOptions from "./index.js" instead */
-export type CompleteOptions = CompletionOptions;
+import type { CompletionOptions } from "./message.js";
 
 export interface IStreamingCard {
   append(text: string): Promise<void>;

src/client/flush.ts

@@ -15,10 +15,6 @@ export {
 } from "./message.js";
 export type { ReplyContext, ReplyFinalOptions, CompletionOptions } from "./message.js";
 
-// 卡片构建（re-export from card/ directory）
-export { buildMarkdownCard } from "../card/index.js";
-export type { CardBuildOptions } from "../card/index.js";
-
 // 下载
 export { downloadImage, downloadFile } from "./download.js";
 export type { DownloadedFile } from "./download.js";

src/client/index.ts

@@ -74,3 +74,56 @@ export function checkTokenExpiry(): void {
     cachedToken = null;
   }
 }
+
+// ── 类型安全的 SDK wrapper ─────────────────────────────────────
+
+/** SDK 类型缺失 reply_in_thread，用 wrapper 补齐 */
+interface ReplyOptions {
+  content: string;
+  msgType: string;
+  replyInThread?: boolean;
+}
+
+export async function replyMessage(
+  client: lark.Client,
+  msgId: string,
+  options: ReplyOptions,
+): Promise<{ messageId: string }> {
+  const res = await (client.im.message as any).reply({
+    path: { message_id: msgId },
+    data: {
+      content: options.content,
+      msg_type: options.msgType,
+      reply_in_thread: options.replyInThread ?? false,
+    },
+  });
+  return { messageId: res?.data?.message_id ?? "" };
+}
+
+export async function patchMessage(
+  client: lark.Client,
+  msgId: string,
+  content: string,
+): Promise<void> {
+  await client.im.message.patch({
+    path: { message_id: msgId },
+    data: { content },
+  });
+}
+
+export async function sendMessage(
+  client: lark.Client,
+  chatId: string,
+  content: string,
+  msgType: string,
+): Promise<{ messageId: string }> {
+  const res = await client.im.message.create({
+    params: { receive_id_type: "chat_id" },
+    data: {
+      receive_id: chatId,
+      msg_type: msgType,
+      content,
+    },
+  });
+  return { messageId: (res.data as any)?.message_id ?? "" };
+}

src/client/lark.ts

@@ -1,10 +1,10 @@
 import * as lark from "@larksuiteoapi/node-sdk";
 import { OverflowConfig, CardTableConfig } from "../config.js";
 import { sanitizeContent, formatWarnings, countTables, optimizeForCard } from "../format/index.js";
-import { buildCard, buildSimpleCard, buildMarkdownCard, buildThinkingPanel, collapsiblePanel, markdown, hr, buildHeader, buildFooterElement, buildStatsTags } from "../card/index.js";
+import { buildCard, buildMarkdownCard, buildThinkingPanel, collapsiblePanel, markdown, hr, buildHeader, buildFooterElement, buildStatsTags } from "../card/index.js";
 import type { CardBuildOptions } from "../card/index.js";
-import { getTenantAccessToken, checkTokenExpiry } from "./lark.js";
-import { createOverflowDocument, registerDocument, cleanupOldDocuments } from "./document.js";
+import { getTenantAccessToken, checkTokenExpiry, replyMessage, patchMessage, sendMessage } from "./lark.js";
+import { createAndRegisterOverflowDoc, cleanupOldDocuments } from "./document.js";
 import type { DocumentMeta } from "../format/index.js";
 
 // ── 共享类型 ──────────────────────────────────────────────────
@@ -67,11 +67,11 @@ export async function replyText(
   text: string
 ): Promise<string> {
   const card = buildMarkdownCard(text);
-  const res = await (client.im.message as any).reply({
-    path: { message_id: rootMsgId },
-    data: { content: JSON.stringify(card), msg_type: "interactive", reply_in_thread: false },
+  const { messageId } = await replyMessage(client, rootMsgId, {
+    content: JSON.stringify(card),
+    msgType: "interactive",
   });
-  return res.data?.message_id ?? "";
+  return messageId;
 }
 
 export async function updateText(
@@ -250,14 +250,14 @@ async function sendMessageChunk(
   try {
     const optimizedContent = optimizeForCard(finalContent);
     const card = buildMarkdownCard(optimizedContent, [], { thinking, cardTitle });
-    await (client.im.message as any).reply({
-      path: { message_id: rootMsgId },
-      data: { content: JSON.stringify(card), msg_type: "interactive", reply_in_thread: false },
+    await replyMessage(client, rootMsgId, {
+      content: JSON.stringify(card),
+      msgType: "interactive",
     });
   } catch {
-    await (client.im.message as any).reply({
-      path: { message_id: rootMsgId },
-      data: { content: JSON.stringify({ text: finalContent }), msg_type: "text", reply_in_thread: false },
+    await replyMessage(client, rootMsgId, {
+      content: JSON.stringify({ text: finalContent }),
+      msgType: "text",
     });
   }
 }
@@ -314,10 +314,7 @@ async function patchOrCreateCard(
   if (waitingMsgId) {
     try {
       const card = buildMarkdownCard(content);
-      await (client.im.message as any).patch({
-        path: { message_id: waitingMsgId },
-        data: { content: JSON.stringify(card) },
-      });
+      await patchMessage(client, waitingMsgId, JSON.stringify(card));
       return true;
     } catch {}
   }
@@ -339,11 +336,11 @@ async function replyWithDocument(
   let waitingMsgId: string | undefined;
   try {
     const waitingCard = buildMarkdownCard("📝 内容较长，正在写入云文档...");
-    const waitRes = await (client.im.message as any).reply({
-      path: { message_id: rootMsgId },
-      data: { content: JSON.stringify(waitingCard), msg_type: "interactive", reply_in_thread: false },
+    const { messageId: waitId } = await replyMessage(client, rootMsgId, {
+      content: JSON.stringify(waitingCard),
+      msgType: "interactive",
     });
-    waitingMsgId = waitRes?.data?.message_id;
+    waitingMsgId = waitId || undefined;
   } catch {}
 
   try {
@@ -352,9 +349,7 @@ async function replyWithDocument(
     const cleanupConfig = context.overflow.document.cleanup;
     await cleanupOldDocuments(token, cleanupConfig.max_docs, context.profile);
 
-    const { docUrl, docId, warnings: docWarnings } = await createOverflowDocument(token, title, markdown, originalMessage, meta);
-
-    registerDocument(docId, context.profile);
+    const { docUrl, docId, warnings: docWarnings } = await createAndRegisterOverflowDoc(token, title, markdown, originalMessage, meta, context.profile);
 
     let replyMsg = `📝 内容较长，已写入云文档：${docUrl}`;
     if (docWarnings.length > 0) {
@@ -386,10 +381,7 @@ async function replyWithDocument(
 
     if (waitingMsgId) {
       try {
-        await (client.im.message as any).patch({
-          path: { message_id: waitingMsgId },
-          data: { content: JSON.stringify(docCard) },
-        });
+        await patchMessage(client, waitingMsgId, JSON.stringify(docCard));
         return;
       } catch {}
     }
@@ -444,11 +436,11 @@ export async function sendToolCard(
 
   const content = `${label}\n\`${detail}\`\n${statusIcon}`;
   const card = buildMarkdownCard(content);
-  const res = await (client.im.message as any).reply({
-    path: { message_id: rootMsgId },
-    data: { content: JSON.stringify(card), msg_type: "interactive", reply_in_thread: false },
+  const { messageId } = await replyMessage(client, rootMsgId, {
+    content: JSON.stringify(card),
+    msgType: "interactive",
   });
-  return res.data?.message_id ?? "";
+  return messageId;
 }
 
 export async function updateToolCard(
@@ -483,38 +475,4 @@ export async function updateToolCard(
 }
 
 // ── 卡片构建 ─────────────────────────────────────────────────
-// buildMarkdownCard 已迁移至 ../card/card.ts，通过 barrel re-export 使用
-
-// ── 发送辅助 ─────────────────────────────────────────────────
-
-export async function sendMarkdownCardMessage(
-  client: lark.Client,
-  chatId: string,
-  content: string,
-  options?: {
-    rootMsgId?: string;
-    reply?: boolean;
-  },
-): Promise<void> {
-  const { content: sanitizedContent, warnings } = sanitizeContent(content);
-  const card = buildSimpleCard(sanitizedContent, warnings);
-
-  if (options?.reply && options.rootMsgId) {
-    await client.im.message.reply({
-      path: { message_id: options.rootMsgId },
-      data: {
-        msg_type: "interactive",
-        content: JSON.stringify(card),
-      },
-    });
-  } else {
-    await client.im.message.create({
-      params: { receive_id_type: "chat_id" },
-      data: {
-        receive_id: chatId,
-        msg_type: "interactive",
-        content: JSON.stringify(card),
-      },
-    });
-  }
-}
+// buildMarkdownCard 已迁移至 ../card/compose.ts，通过 barrel re-export 使用

src/client/message.ts

@@ -8,6 +8,7 @@
 import * as lark from "@larksuiteoapi/node-sdk";
 import { buildTaskPanelCard } from "../card/index.js";
 import type { TaskPanelStatus, TaskPanelCardOptions } from "../card/index.js";
+import { replyMessage, patchMessage } from "./lark.js";
 import { logger } from "../logger.js";
 
 // Re-export types for consumers
@@ -23,11 +24,11 @@ export async function sendTaskCard(
   headerIconImgKey?: string,
 ): Promise<string> {
   const card = buildTaskPanelCard({ description, status: "running", headerIconImgKey });
-  const res = await (client.im.message as any).reply({
-    path: { message_id: rootMsgId },
-    data: { content: JSON.stringify(card), msg_type: "interactive", reply_in_thread: false },
+  const { messageId } = await replyMessage(client, rootMsgId, {
+    content: JSON.stringify(card),
+    msgType: "interactive",
   });
-  return res.data?.message_id ?? "";
+  return messageId;
 }
 
 export async function updateTaskCard(

src/client/task-panel-ctrl.ts

@@ -12,10 +12,12 @@ import { optimizeForCard, truncateSafely } from "../format/card-optimize.js";
 import { parseThinking, stripThinking } from "../format/thinking.js";
 import { STREAMING_TRUNCATE, FlushController } from "./flush.js";
 import type { IStreamingCard } from "./flush.js";
+import { replyMessage } from "./lark.js";
 import type { StreamingConfig } from "../config.js";
-import type { ReplyContext, CompletionOptions, CardBuildOptions } from "./index.js";
-import { replyFinalCard, buildMarkdownCard } from "./index.js";
-import { buildCard, markdown } from "../card/index.js";
+import type { ReplyContext, CompletionOptions } from "./message.js";
+import { replyFinalCard } from "./message.js";
+import { buildCard, markdown, buildMarkdownCard } from "../card/index.js";
+import type { CardBuildOptions } from "../card/index.js";
 
 const TRUNCATE_LIMIT = STREAMING_TRUNCATE;
 
@@ -78,15 +80,11 @@ class UpdateStreamingCard implements IStreamingCard {
           template: "blue",
         };
       }
-      const res = await (this.client.im.message as any).reply({
-        path: { message_id: this.rootMsgId },
-        data: {
-          content: JSON.stringify(card),
-          msg_type: "interactive",
-          reply_in_thread: false,
-        },
+      const res = await replyMessage(this.client, this.rootMsgId, {
+        content: JSON.stringify(card),
+        msgType: "interactive",
       });
-      this.msgId = res.data?.message_id ?? null;
+      this.msgId = res.messageId || null;
 
       if (this.msgId) {
         this.flushCtrl.start();

src/client/update.ts

@@ -58,7 +58,3 @@ export { optimizeForCard, truncateSafely } from "./card-optimize.js";
 // Thinking 解析
 export { parseThinking, stripThinking } from "./thinking.js";
 export type { ThinkingResult } from "./thinking.js";
-
-// 图片解析（已迁移至 ../feishu/image-resolver.ts）
-export { resolveImages } from "../client/image-resolver.js";
-export type { ImageResolveResult } from "../client/image-resolver.js";