feat(analytics): log suggestion show/no_show decisions

Author: hhh2210

desktop/src/core/modules/ipc-handlers.js

@@ -5,12 +5,14 @@ import ASRModelManager from '../../asr/model-manager.js';
 import LLMSuggestionService from './llm-suggestion-service.js';
 import ReviewService from './review-service.js';
 import MemoryService from './memory-service.js';
+import TelemetryService from './telemetry-service.js';
 import { registerWindowHandlers } from './ipc-handlers/window-handlers.js';
 import { registerDatabaseHandlers } from './ipc-handlers/database-handlers.js';
 import { registerLLMHandlers } from './ipc-handlers/llm-handlers.js';
 import { registerSuggestionHandlers } from './ipc-handlers/suggestion-handlers.js';
 import { registerReviewHandlers } from './ipc-handlers/review-handlers.js';
 import { registerMemoryHandlers } from './ipc-handlers/memory-handlers.js';
+import { registerTelemetryHandlers } from './ipc-handlers/telemetry-handlers.js';
 import { registerASRModelHandlers } from './ipc-handlers/asr-model-handlers.js';
 import { registerASRAudioHandlers } from './ipc-handlers/asr-audio-handlers.js';
 import { registerMediaHandlers } from './ipc-handlers/media-handlers.js';
@@ -28,6 +30,7 @@ export class IPCManager {
     this.llmSuggestionService = null;
     this.reviewService = null;
     this.memoryService = null;
+    this.telemetryService = null;
     this.asrModelPreloading = false;
     this.asrModelPreloaded = false;
     this.asrServerCrashCallback = null;
@@ -82,6 +85,15 @@ export class IPCManager {
       this.memoryService = new MemoryService();
     }
   }
+
+  /**
+   * 初始化 Telemetry Service（本地训练信号 JSONL）
+   */
+  initTelemetryService() {
+    if (!this.telemetryService) {
+      this.telemetryService = new TelemetryService();
+    }
+  }
   /**
    * 初始化 Review Service
    */
@@ -102,13 +114,15 @@ export class IPCManager {
     this.initLLMSuggestionService();
     this.initReviewService();
     this.initMemoryService();
+    this.initTelemetryService();
     this.setupWindowHandlers();
     this.setupAppConfigHandlers();
     this.setupDatabaseHandlers();
     this.setupLLMHandlers();
     this.setupSuggestionHandlers();
     this.setupReviewHandlers();
     this.setupMemoryHandlers();
+    this.setupTelemetryHandlers();
     this.setupASRModelHandlers();
     this.setupASRAudioHandlers();
     this.setupMediaHandlers();
@@ -186,6 +200,14 @@ export class IPCManager {
     registerMemoryHandlers({ memoryService: this.memoryService });
   }
 
+  /**
+   * 设置 Telemetry 相关 IPC 处理器
+   */
+  setupTelemetryHandlers() {
+    this.initTelemetryService();
+    registerTelemetryHandlers({ telemetryService: this.telemetryService });
+  }
+
   /**
    * 设置 ASR 模型管理相关 IPC 处理器
    */

desktop/src/core/modules/ipc-handlers/telemetry-handlers.js

@@ -0,0 +1,22 @@
+import { ipcMain } from 'electron';
+
+/**
+ * 注册训练信号本地埋点写入 IPC 处理器
+ */
+export function registerTelemetryHandlers({ telemetryService }) {
+  if (!telemetryService) {
+    console.warn('[TelemetryHandlers] telemetryService not provided, skip registration');
+    return;
+  }
+
+  ipcMain.handle('telemetry-track', async (_event, payload = {}) => {
+    try {
+      return await telemetryService.appendEvent(payload);
+    } catch (error) {
+      console.error('[TelemetryHandlers] track failed', error);
+      throw error;
+    }
+  });
+
+  console.log('[TelemetryHandlers] Telemetry handlers registered');
+}

desktop/src/core/modules/telemetry-service.js

@@ -0,0 +1,71 @@
+import { app } from 'electron';
+import fs from 'fs/promises';
+import path from 'path';
+
+const DEFAULT_DIRNAME = 'telemetry';
+const DEFAULT_FILENAME = 'training-signals.jsonl';
+const MAX_RECORD_BYTES = 512 * 1024;
+
+export default class TelemetryService {
+  constructor(options = {}) {
+    const baseDir = options.baseDir || this.resolveBaseDir();
+    this.baseDir = baseDir;
+    this.fileName = options.fileName || DEFAULT_FILENAME;
+    this.maxRecordBytes = Number.isFinite(options.maxRecordBytes)
+      ? options.maxRecordBytes
+      : MAX_RECORD_BYTES;
+  }
+
+  resolveBaseDir() {
+    try {
+      const userDataDir = app?.getPath ? app.getPath('userData') : null;
+      if (!userDataDir) return null;
+      return path.join(userDataDir, DEFAULT_DIRNAME);
+    } catch (error) {
+      console.warn('[TelemetryService] Failed to resolve userData dir:', error);
+      return null;
+    }
+  }
+
+  get enabled() {
+    return Boolean(this.baseDir);
+  }
+
+  get filePath() {
+    if (!this.enabled) return null;
+    return path.join(this.baseDir, this.fileName);
+  }
+
+  normalizePayload(payload) {
+    if (!payload || typeof payload !== 'object') return null;
+    if (Array.isArray(payload)) return { items: payload };
+    return payload;
+  }
+
+  async appendEvent(payload = {}) {
+    if (!this.enabled) return { success: false, disabled: true };
+
+    const normalized = this.normalizePayload(payload);
+    if (!normalized) return { success: false, error: 'invalid_payload' };
+
+    const record = {
+      ...normalized,
+      recorded_at: Date.now()
+    };
+
+    let line = '';
+    try {
+      line = `${JSON.stringify(record)}\n`;
+    } catch (error) {
+      return { success: false, error: 'stringify_failed' };
+    }
+
+    if (this.maxRecordBytes && line.length > this.maxRecordBytes) {
+      return { success: false, error: 'payload_too_large' };
+    }
+
+    await fs.mkdir(this.baseDir, { recursive: true });
+    await fs.appendFile(this.filePath, line, 'utf8');
+    return { success: true, path: this.filePath };
+  }
+}

desktop/src/preload.js

@@ -184,6 +184,8 @@ contextBridge.exposeInMainWorld('electronAPI', {
   memoryQueryProfiles: (payload) => ipcRenderer.invoke('memory-query-profiles', payload),
   memoryQueryEvents: (payload) => ipcRenderer.invoke('memory-query-events', payload),
   memoryUpsertEvent: (payload) => ipcRenderer.invoke('memory-upsert-event', payload),
+  // Telemetry (本地训练信号 JSONL)
+  telemetryTrack: (payload) => ipcRenderer.invoke('telemetry-track', payload),
   onSuggestionStreamStart: (callback) => {
     const listener = (event, data) => callback(data);
     ipcRenderer.on('llm-suggestion-stream-start', listener);