WeFlow 技术架构全解析

// vite.config.ts（节选）
export default defineConfig({
  plugins: [
    react(),
    electron([
      { entry: 'electron/main.ts', onstart: handleElectronOnStart, ... },
      { entry: 'electron/wcdbWorker.ts',  output: { entryFileNames: 'wcdbWorker.js' } },
      { entry: 'electron/exportWorker.ts',
        plugins: [exportWorkerElectronShimPlugin()], ... },
      { entry: 'electron/preload.ts', ... },
      // annualReportWorker / dualReportWorker / transcribeWorker /
      // imageDecryptWorker / imageSearchWorker / apiMessageWorker ...
    ])
  ],
  resolve: { alias: { '@': resolve(__dirname, 'src') } }
})

// vite.config.ts — exportWorkerElectronShimPlugin
const next = code
  .replace(/from\s+(['"])electron\1/g, `from '${virtualId}'`)   // import … from 'electron'
  .replace(/require\s*\(\s*(['"])electron\1\s*\)/g, `require('${virtualId}')`)

// 生成的虚拟模块（示意）
export const app = {
  isPackaged: Boolean(process.resourcesPath && ...),
  getPath: (name) => name === 'userData'
      ? workerUserDataPath() || join(appDataPath(), 'WeFlow')
      : ...,
  on: () => app,   // Worker 中不存在 will-quit 等 App 生命周期事件
}

// electron/services/wcdbService.ts — 通用 RPC 客户端
private callWorker<T>(type: string, payload: any = {}): Promise<T> {
  if (!this.worker) this.initWorker()
  if (!this.worker) return Promise.reject(new Error('WCDB Worker 不可用'))
  return new Promise((resolve, reject) => {
    const id = ++this.messageId
    this.pending.set(id, { resolve, reject })
    this.worker!.postMessage({ id, type, payload })
  })
}

// Worker 端按 type 分发
case 'getMessages':
  result = await core.getMessages(payload.sessionId, payload.limit, payload.offset)
  break
case 'startMonitor':
  core.setMonitor((type, json) => parentPort!.postMessage({
      id: -1, type: 'monitor', payload: { type, json } }))
  break

// 主进程：注册
ipcMain.handle('chat:getMessages',
  async (_, sessionId, offset, limit, startTime, endTime, ascending) =>
    chatService.getMessages(sessionId, offset, limit, startTime, endTime, ascending))

// preload：转发
chat: {
  getMessages: (sessionId, offset, limit, startTime, endTime, ascending, cursor) =>
    ipcRenderer.invoke('chat:getMessages', sessionId, offset, limit, startTime, endTime, ascending, cursor)
}

// 渲染进程：再包一层薄 JS 门面
export const chat = { getMessages: (...) => window.electronAPI.chat.getMessages(...) }

// electron/services/wcdbCore.ts — FFI 绑定（节选）
this.wcdbInit           = this.lib.func('int32 wcdb_init()')
this.wcdbOpenAccount    = this.lib.func('... wcdb_open_account(...)')
this.wcdbGetSessions    = this.lib.func('... wcdb_get_sessions(...)')          // 会话列表
this.wcdbGetMessages    = this.lib.func('... wcdb_get_messages(...)')          // 消息分页
this.wcdbStartMonitorPipe = this.lib.func('int32 wcdb_start_monitor_pipe()')   // 文件监听
this.wcdbGetVoiceData   = this.lib.func(
  'int32 wcdb_get_voice_data(int64 handle, const char* sessionId, int32 createTime, int32 localId, int64 svrId, const char* candidatesJson, _Out_ void** outHex)')
this.wcdbInstallMessageAntiRevokeTrigger = this.lib.func(...)                  // 防撤回（SQL 触发器）

// src/stores/chatStore.ts — 关键去重逻辑
function buildMessageAliasKeys(message: Message): string[] {
  const sourceScope = String(message._db_path || '').trim()   // 来源分库
  const keys = [buildPrimaryMessageKey(message, sourceScope)]
  if (localId > 0) {
    if (sourceScope) keys.push(`lid:${sourceScope}:${localId}`)      // 跨 message_*.db 时 local_id 可能重复
    else keys.push(`lid_fallback:${localId}:${createTime}:${sender}:…`) // 保守组合防误去重
  }
  if (serverId > 0) {
    if (sourceScope) keys.push(`sid:${sourceScope}:${serverId}`)
    else keys.push(`sid_fallback:${serverId}:${...}`)
  }
  return keys
}

// electron/services/keyService.ts — 窗口就绪启发式
private hasReadyComponents(children) {
  const readyTexts = ['聊天', '登录', '账号']
  const readyClassMarkers = ['WeChat', 'Weixin', 'TXGuiFoundation', 'Qt5', 'ChatList', 'MainWnd', ...]
  // 满足「标题/类名」命中数、子窗数量 ≥14、类名总数 ≥3 等任意启发式即判"已登录"
}

// electron/services/keyService.ts
private deriveImageKeys(code: number, wxid: string): { xorKey: number; aesKey: string } {
  const cleanedWxid = this.cleanWxid(wxid)
  const xorKey  = code & 0xFF                                   // XOR 密钥 = code 低 8 位
  const md5Full = crypto.createHash('md5')
    .update(code.toString() + cleanedWxid)
    .digest('hex')
  const aesKey  = md5Full.substring(0, 16)                       // AES-128 key = MD5 前 16 字符
  return { xorKey, aesKey }
}

private verifyDerivedAesKey(aesKey: string, ciphertext: Buffer): boolean {
  const decipher = crypto.createDecipheriv('aes-128-ecb',
    Buffer.from(aesKey, 'ascii').subarray(0, 16), null)
  // 对 16 字节已知密文解密，解成功且产生合法明文 → 验证通过
}

// electron/services/wasmService.ts
mockGlobal.wasm_isaac_generate = (ptr: number, size: number) => {
  const buffer = new Uint8Array(mockGlobal.Module.HEAPU8.buffer, ptr, size)
  this.capturedKeystream = new Uint8Array(buffer)    // 拷贝 WASM 线性内存
}

public async getKeystream(key: string, size = 131072): Promise<Buffer> {
  const alignSize = Math.ceil(size / 8) * 8          // ISAAC-64 是 8 字节块，必须对齐
  const buffer = await this.getRawKeystream(key, alignSize)
  const reversed = new Uint8Array(buffer)
  reversed.reverse()                                 // 微信实现按"倒序读流"
  return Buffer.from(reversed).subarray(0, size)
}

// electron/services/nativeImageDecrypt.ts
function addonCandidates() {          // 按平台/arch/asar unpack 位置多路尝试
  roots = [cwd/resources/wedecrypt/$plat/$arch, process.resourcesPath/…]
}

export function decryptDatViaNative(
  inputPath: string, xorKey: number, aesKey?: string
): { data: Buffer; ext: string; isWxgf: boolean; meta: NativeDatMeta } | null {
  const addon = loadAddon()
  ...
  const result = addon.decryptDatNative(inputPath, xorKey, aesKey)
  ...
}

// electron/services/voiceTranscribeService.ts
const SENSEVOICE_MODEL = {
  model: 'model.int8.onnx',
  tokens: 'tokens.txt',
  model: 'https://modelscope.cn/models/pengzhendong/sherpa-onnx-sense-voice-zh-en-ja-ko-yue/resolve/master/model.int8.onnx',
  ...
}

// electron/transcribeWorker.ts
const RICH_TAG_MAP = {
  '<|HAPPY|>': '😊', '<|SAD|>': '😔', '<|BGM|>': '🎵', '<|Laughter|>': '😂', ...
}
function richTranscribePostProcess(text: string): string {
  let processed = text
  for (const [tag, replacement] of Object.entries(RICH_TAG_MAP)) {
    processed = processed.replace(new RegExp(tag.replace(/[|<>]/g, '\\$&'), 'gi'), replacement)
  }
  for (const tag of TECH_TAGS) { processed = processed.replace(..., '') }
  return processed.replace(/\s+/g, ' ').trim()
}

const normalizedChunk = rawChunk
  .replace(/\u0000/g, '\n')
  .replace(/}\s*{/g, '}\n{')
buffer += normalizedChunk
const lines = buffer.split(/\r?\n/)
buffer = lines.pop() || ''

// electron/services/export/core/ExportOrchestrator.ts
export class ExportOrchestrator {
    constructor(public context: ExportContext) {}

    async exportSessionToChatLab(sessionId, outputPath, options, onProgress, control) {
        const formatter = new ChatLabFormatter(this.context)
        return formatter.export(sessionId, outputPath, options, onProgress, control)
    }
    async exportSessionToExcel(...)   { return new ExcelFormatter(this.context).export(...) }
    async exportSessionToHtml(...)    { return new HtmlFormatter(this.context).export(...) }
    // Markdown / Json / Sql / Txt / WeCloneCsv 同结构
}

const CREATED_PATH_FLUSH_INTERVAL_MS = 200
const CREATED_PATH_BATCH_LIMIT = 256
const PROGRESS_POST_INTERVAL_MS = 180

function queueCreatedFile(filePath: string) {
  queuedCreatedFiles.push(normalized)
  if (queuedCreatedFiles.length + queuedCreatedDirs.length >= CREATED_PATH_BATCH_LIMIT) flush()
  else scheduleCreatedPathFlush()
}

// electron/services/weliveBridge.ts — welive 子进程 JSON 事件协议
export type WeliveExportEvent =
  | { type: 'ready'; total?: number; output_dir?: string }
  | { type: 'progress'; phase?: string; current?: number; total?: number; ... }
  | { type: 'created_file'; path?: string; session_id?: string }
  | { type: 'session_error'; session_id?: string; error?: string }
  | { type: 'result'; success?: boolean; success_count?: number; ... }

// electron/services/httpService.ts — 端点映射 /health /api/v1/*
if    (pathname === '/health' || pathname === '/api/v1/health')             handleHealth()
else if (pathname === '/api/v1/push/messages')    handleSse(res)
else if (pathname === '/api/v1/messages')         handleMessages(req, res)
else if (pathname === '/api/v1/sessions')         handleSessions(...)
else if (pathname.startsWith('/api/v1/sessions/') ...)                   // ChatLab Pull
else if (pathname === '/api/v1/contacts')         handleContacts(...)
else if (pathname === '/api/v1/group-members')    handleGroupMembers(...)
else if (pathname === '/api/v1/sns/timeline' ...) handleSns*(...)
else if (pathname.startsWith('/api/v1/media/'))   handleMedia(...)

this.server.listen(this.port, this.host, () => {
  void this.ensureDbReady().catch(...)              // 预热 wcdb
  try { this.getApiMapperPool().warmup() } catch {} // 预热映射 worker 池
  this.startMessagePushHeartbeat()
})

// 全部页面懒加载：主窗口首屏只解析 App 壳 + HomePage；
const ChatPage        = lazy(() => import('./pages/ChatPage'))
const SnsPage         = lazy(() => import('./pages/SnsPage'))
const NotificationWindow = lazy(() => import('./pages/NotificationWindow'))
// 独立窗口（可能是多 BrowserWindow 单 SPA）
const isNotificationWindow = location.pathname === '/notification-window'
const isAnnualReportWindow = location.pathname === '/annual-report/view'

src/pages/Export/
├── ExportPage.tsx        # 顶层编排
├── components/
│   ├── ExportDialog/index.tsx    # 导出弹窗
│   ├── SessionTable/index.tsx    # 会话表格 (react-virtuoso 虚拟滚动)
│   ├── TaskCenter/index.tsx      # 后台任务中心
│   └── Automation/…              # 定时导出
├── hooks/                # useExportConfig / useExportSessions / useAutomation…
├── utils/                # avatar.ts / format.ts / performance.ts
└── constants.ts

// electron/main.ts
app.commandLine.appendSwitch('webrtc-max-cpu-consumption-percentage', '100')
// 但回退采集只在通知展示的数秒内运行且分辨率已降为逻辑尺寸

mac:   extraResources: [ wcdb/macos/universal, wedecrypt/macos/$arch, key/macos/universal, welive/macos/$arch ]
win:   extraFiles:     [ MSVC 运行时 dll ]
       extraResources: [ wcdb/win32/$arch, wedecrypt/win32/$arch, key/win32, welive/win32/$arch ]
linux: extraResources: [ wcdb/linux/$arch, wedecrypt/linux/x64, key/linux, welive/linux/$arch ]
asarUnpack: [ silk-wasm, sherpa-onnx-*, ffmpeg-static, electron-liquid-glass, wedecrypt/**/*.node ]

// electron/main.ts — 更新通道推断
const inferUpdateTrackFromVersion = (version) => {
  if (/^0\.(\d{2})\.(\d+)$/.test(normalized)) return 'preview'       // 0.YY.N
  if (/^\d{2}(\.\d{1,2}){2}$/.test(normalized))   return 'dev'       // YY.M.D
  if (/(alpha|beta|rc)/i.test(version))           return 'dev'
  return 'stable'
}
autoUpdater.autoDownload = false
autoUpdater.autoInstallOnAppQuit = true
autoUpdater.disableDifferentialDownload = true   // 禁差分，强制全量