test: 新增导出、MCP 工具、动态时间线与报表服务的单元测试

实现导出功能测试，覆盖 CSV、JSON、Markdown 格式
新增 MCP 工具注册与执行测试，确保元数据与异常处理正常
创建动态时间线获取测试，验证数据标准化与异常场景
新增报表生成测试，覆盖多维度范围、消息聚合与关键词提取

Author: ILoveBingLu

CipherTalk-CLI/package-lock.json

@@ -36,6 +36,7 @@
     "sync:upstream": "tsx scripts/sync-from-upstream.ts"
   },
   "dependencies": {
+    "@modelcontextprotocol/sdk": "^1.27.1",
     "chalk": "^5.6.2",
     "cli-table3": "^0.6.5",
     "commander": "^14.0.2",

CipherTalk-CLI/package.json

@@ -5,9 +5,27 @@ export function registerMomentsCommand(program: Command, context: CommandContext
   const moments = program
     .command('moments')
     .description('朋友圈数据')
-    .option('--from <date>', '开始日期')
-    .option('--to <date>', '结束日期')
+    .option('--limit <n>', '返回条数（默认 20，上限 200）', '20')
+    .option('--user <wxid>', '只查指定 wxid 的朋友圈')
+    .option('--from <date>', '开始时间（ISO 字符串或 Unix 秒）')
+    .option('--to <date>', '结束时间（ISO 字符串或 Unix 秒）')
     .action(async () => {
-      await runCommand(moments, context, async () => context.services.advanced.moments())
+      await runCommand(moments, context, async (config, options) => {
+        const limit = typeof options.limit === 'string' ? Number(options.limit) : undefined
+        const result = await context.services.advanced.moments(config, {
+          limit: Number.isFinite(limit) ? limit : undefined,
+          user: typeof options.user === 'string' ? options.user : undefined,
+          from: typeof options.from === 'string' ? options.from : undefined,
+          to: typeof options.to === 'string' ? options.to : undefined
+        })
+        return {
+          data: { entries: result.entries },
+          meta: {
+            total: result.total,
+            limit: result.limit,
+            ...(result.meta || {})
+          }
+        }
+      })
     })
 }

CipherTalk-CLI/src/commands/moments.ts

@@ -5,9 +5,32 @@ export function registerReportCommand(program: Command, context: CommandContext)
   const report = program
     .command('report')
     .description('年度报告数据')
-    .option('--year <year>', '年份')
+    .option('--year <year>', '年份（默认当前年）')
     .option('--all-time', '全时间范围')
+    .option('--session <id>', '只统计指定会话')
+    .option('--top-contacts <n>', '联系人榜数量')
+    .option('--top-keywords <n>', '关键词榜数量')
     .action(async () => {
-      await runCommand(report, context, async () => context.services.advanced.report())
+      await runCommand(report, context, async (config, options) => {
+        const year = typeof options.year === 'string' ? Number(options.year) : undefined
+        const topContacts = typeof options.topContacts === 'string' ? Number(options.topContacts) : undefined
+        const topKeywords = typeof options.topKeywords === 'string' ? Number(options.topKeywords) : undefined
+        const result = await context.services.advanced.report(config, {
+          year: Number.isFinite(year) ? year : undefined,
+          allTime: options.allTime === true,
+          session: typeof options.session === 'string' ? options.session : undefined,
+          topContacts: Number.isFinite(topContacts) ? topContacts : undefined,
+          topKeywords: Number.isFinite(topKeywords) ? topKeywords : undefined
+        })
+        return {
+          data: result,
+          meta: {
+            scope: result.scope,
+            year: result.year,
+            sessionId: result.sessionId,
+            ...(result.meta || {})
+          }
+        }
+      })
     })
 }

CipherTalk-CLI/src/commands/report.ts

@@ -414,12 +414,41 @@ async function runShellCommand(line: string, context: CommandContext, globals: G
         writeEnvelope(context.output, successEnvelope(result), format)
         return true
       }
-      case '/moments':
-        context.output.stderr('朋友圈功能暂不支持。请使用桌面版密语查看朋友圈。')
+      case '/moments': {
+        const limit = commandLimit(options, 20)
+        const result = await context.services.advanced.moments(config, {
+          limit,
+          user: asString(options.user),
+          from: asString(options.from),
+          to: asString(options.to)
+        })
+        writeEnvelope(context.output, successEnvelope({ entries: result.entries }, {
+          total: result.total,
+          limit: result.limit,
+          ...(result.meta || {})
+        }), format)
         return true
-      case '/report':
-        context.output.stderr('年度报告功能暂不支持。请使用桌面版密语生成年度报告。')
+      }
+      case '/report': {
+        const yearRaw = asString(options.year)
+        const yearNum = yearRaw !== undefined ? Number(yearRaw) : undefined
+        const topContactsRaw = asString(options['top-contacts'])
+        const topKeywordsRaw = asString(options['top-keywords'])
+        const result = await context.services.advanced.report(config, {
+          year: Number.isFinite(yearNum) ? yearNum : undefined,
+          allTime: options['all-time'] === true,
+          session: asString(options.session),
+          topContacts: topContactsRaw !== undefined ? Number(topContactsRaw) : undefined,
+          topKeywords: topKeywordsRaw !== undefined ? Number(topKeywordsRaw) : undefined
+        })
+        writeEnvelope(context.output, successEnvelope(result, {
+          scope: result.scope,
+          year: result.year,
+          sessionId: result.sessionId,
+          ...(result.meta || {})
+        }), format)
         return true
+      }
       case '/mcp':
         if (positional[0] === 'serve') {
           await context.services.advanced.mcpServe()

CipherTalk-CLI/src/interactiveShell.ts

@@ -1,18 +1,22 @@
-import { notImplemented, dbError, MiyuError } from '../errors.js'
-import { wcdbService } from './db/wcdbService.js'
-import { dbAdapter } from './db/dbAdapter.js'
 import { searchMessages } from './searchService.js'
-import type { AdvancedService, SearchResult, StatsOptions, ExportOptions } from './types.js'
+import { exportChat as runExportChat } from './export/exportService.js'
+import { analyticsService } from './analytics/analyticsService.js'
+import { runMcpServe } from './mcp/runtime.js'
+import { getMomentsTimeline } from './sns/snsService.js'
+import { generateReport } from './report/reportService.js'
+import type {
+  AdvancedService,
+  SearchResult,
+  StatsOptions,
+  ExportOptions,
+  MomentsOptions,
+  MomentsResult,
+  ReportOptions,
+  ReportResult
+} from './types.js'
 import type { RuntimeConfig } from '../types.js'
 
-async function connect(config: RuntimeConfig): Promise<void> {
-  const ok = await wcdbService.open(config.dbPath!, config.keyHex!, config.wxid || '')
-  if (!ok) throw dbError('数据库连接失败，请检查 dbPath / keyHex / wxid')
-}
-
 export class RealAdvancedService implements AdvancedService {
-
-  // ── 搜索 ──
   async search(
     config: RuntimeConfig,
     keyword: string,
@@ -21,73 +25,24 @@ export class RealAdvancedService implements AdvancedService {
     return searchMessages(config, keyword, options || {})
   }
 
-  // ── 统计 ──
   async stats(config: RuntimeConfig, opts: StatsOptions): Promise<any> {
-    await connect(config)
-
-    switch (opts.type) {
-      case 'global': {
-        // 会话总数
-        let totalSessions = 0
-        try {
-          const r = await dbAdapter.get<{ cnt: number }>('session', '', 'SELECT COUNT(*) as cnt FROM SessionTable')
-          totalSessions = r?.cnt || 0
-        } catch { /**/ }
-        return { totalSessions }
-      }
-
-      case 'contacts': {
-        const top = opts.top || 20
-        // 从 session 表列出私聊
-        const sessions = await dbAdapter.all<{ username: string }>(
-          'session', '',
-          `SELECT username FROM SessionTable WHERE username NOT LIKE '%@chatroom%' AND username NOT LIKE 'gh_%' ORDER BY sort_timestamp DESC LIMIT ?`,
-          [top]
-        )
-        return { contacts: sessions.map(s => ({ wxid: s.username, displayName: s.username, messageCount: 0 })) }
-      }
-
-      case 'session': {
-        if (!opts.session) throw new Error('stats session 需要 --session 参数')
-        // 尝试查询该会话的 msg 表
-        return { totalMessages: 0, textMessages: 0, mediaMessages: 0, sentMessages: 0, receivedMessages: 0, activeDays: 0, firstMessageTime: null, lastMessageTime: null }
-      }
-
-      case 'time': {
-        return { distribution: {} }
-      }
-
-      case 'keywords': {
-        return { keywords: [] }
-      }
-
-      case 'group': {
-        return { totalMessages: 0, activeMembers: 0 }
-      }
-
-      default:
-        throw new Error(`未知统计类型: ${(opts as any).type}`)
-    }
+    return analyticsService.run(config, opts)
   }
 
-  // ── 导出 ──
   async exportChat(config: RuntimeConfig, opts: ExportOptions): Promise<{ path: string; count: number }> {
-    // 简单实现：查询消息后写入文件
-    await connect(config)
-    throw notImplemented('export')
+    return runExportChat(config, opts)
   }
 
-  // ── 未移植的功能 ──
-  async moments(): Promise<never> {
-    throw new MiyuError('NOT_IMPLEMENTED', '朋友圈数据：暂不支持。请使用桌面版密语查看朋友圈。')
+  async moments(config: RuntimeConfig, options: MomentsOptions = {}): Promise<MomentsResult> {
+    return getMomentsTimeline(config, options)
   }
 
-  async report(): Promise<never> {
-    throw new MiyuError('NOT_IMPLEMENTED', '年度报告：暂不支持。请使用桌面版密语生成年度报告。')
+  async report(config: RuntimeConfig, options: ReportOptions = {}): Promise<ReportResult> {
+    return generateReport(config, options)
   }
 
   async mcpServe(): Promise<never> {
-    throw new MiyuError('NOT_IMPLEMENTED', 'MCP Server：暂不支持。请使用桌面版密语的 MCP 功能。')
+    return runMcpServe()
   }
 }