fix(pwa): 修复逻辑审查三处问题（尾段丢失/暂停未接、视频上传401/429、剪藏截断）

Author: Aparencia

client/src/features/classroom/capture/WebCaptureAdapter.ts

@@ -28,7 +28,6 @@ export class WebCaptureAdapter {
   private stream: MediaStream | null = null;
   private recorder: MediaRecorder | null = null;
   private audioCtx: AudioContext | null = null;
-  private sessionId: string | null = null;
   private segmentStartAt = 0;
 
   /** 是否正在录制 */
@@ -41,7 +40,6 @@ export class WebCaptureAdapter {
    * @param sessionId - 会话 ID（emit 音频段时透传，供下游校验会话一致性）
    */
   async start(sessionId: string): Promise<void> {
-    this.sessionId = sessionId;
     this.stream = await navigator.mediaDevices.getUserMedia({
       audio: { channelCount: 1, echoCancellation: true, noiseSuppression: true },
     });
@@ -50,8 +48,9 @@ export class WebCaptureAdapter {
     const mimeType = pickSupportedMimeType();
     this.recorder = new MediaRecorder(this.stream, mimeType ? { mimeType } : undefined);
     this.segmentStartAt = Date.now();
+    const sid = sessionId;
     this.recorder.ondataavailable = (ev) => {
-      if (ev.data.size > 0) void this.handleChunk(ev.data);
+      if (ev.data.size > 0) void this.handleChunk(ev.data, sid);
     };
     this.recorder.start(SEGMENT_MS);
   }
@@ -64,13 +63,24 @@ export class WebCaptureAdapter {
     this.recorder = null;
     this.stream = null;
     this.audioCtx = null;
-    this.sessionId = null;
   }
 
-  /** 解码单个分段 → 重采样 → 编码 → 广播音频段（失败静默，不影响采集） */
-  private async handleChunk(blob: Blob): Promise<void> {
-    const sid = this.sessionId;
-    if (!sid || !this.audioCtx) return;
+  /** 暂停录制（flush 当前分段后暂停，恢复后继续下一分段） */
+  pause(): void {
+    try { this.recorder?.pause(); } catch { /* 已停止 */ }
+  }
+
+  /** 恢复录制 */
+  resume(): void {
+    try { this.recorder?.resume(); } catch { /* 已停止 */ }
+  }
+
+  /** 解码单个分段 → 重采样 → 编码 → 广播音频段（失败静默，不影响采集）
+   * @ai-context: sessionId 由 ondataavailable 闭包捕获传入——stop() 清空
+   * 实例字段不影响已在队列中的尾段（修复停止时 <5s 尾段丢失，TD-005）。
+   */
+  private async handleChunk(blob: Blob, sessionId: string): Promise<void> {
+    if (!sessionId || !this.audioCtx) return;
     try {
       const arrayBuffer = await blob.arrayBuffer();
       const audioBuffer = await this.audioCtx.decodeAudioData(arrayBuffer);
@@ -85,7 +95,7 @@ export class WebCaptureAdapter {
         energy: computeRms(pcm),
       };
       this.segmentStartAt = Date.now();
-      captureEventBus.emit('smart:audio_segment_ready', { sessionId: sid, segment });
+      captureEventBus.emit('smart:audio_segment_ready', { sessionId, segment });
     } catch (err) {
       console.warn('[WebCaptureAdapter] 分段解码失败（已跳过该段）:', err);
     }

client/src/features/classroom/hooks/useSessionControl.ts

@@ -213,6 +213,17 @@ export function useSessionControl({
   }, [selectedWindow, setStatus, session, capturePath, captureManager, config, mode, courseMeta, onAudioSourceResolved, setStreamingAsrActive]);
 
   const handlePause = useCallback(() => {
+    // PWA：暂停/恢复麦克风采集（Electron 走 captureManager 会话暂停）
+    if (!window.electronAPI) {
+      if (status === 'capturing') {
+        setStatus('paused');
+        webCaptureAdapter.pause();
+      } else if (status === 'paused') {
+        setStatus('capturing');
+        webCaptureAdapter.resume();
+      }
+      return;
+    }
     if (status === 'capturing') {
       setStatus('paused');
       captureManager.pauseSession();

client/src/features/classroom/lib/uploadVideoAnalysis.ts

@@ -13,8 +13,7 @@
  * IPC ai_video_analyze path; this function only serves PWA/browser File upload.
  * Includes Douyin link detection to guide "save to album then import" (plan A).
  */
-import { supabase } from '@/lib/auth/supabaseClient';
-import { requireGatewayUrl } from '@/lib/ai/config';
+import { aiClient } from '@/lib/http/apiClient';
 import { classroomNoteStore } from '@/lib/storage/classroomNoteStore';
 import type { AnalyzeResult } from '@/lib/ai/sessionAnalyzer';
 
@@ -40,61 +39,39 @@ export async function analyzeVideoFile(
   file: File,
   options?: { duration?: number; language?: string },
 ): Promise<AnalyzeResult> {
-  const { data: { session } } = await supabase.auth.getSession();
-  const token = session?.access_token;
-  const baseUrl = requireGatewayUrl();
-
   const formData = new FormData();
   formData.append('video_file', file, file.name);
   if (options?.duration !== undefined) formData.append('duration', String(options.duration));
   if (options?.language) formData.append('language', options.language);
 
-  const headers = new Headers();
-  if (token) headers.set('Authorization', `Bearer ${token}`);
-  headers.set('X-Request-ID', crypto.randomUUID());
-  // 不显式设置 Content-Type：由浏览器为 FormData 自动生成 multipart boundary
+  // 复用 aiClient.post：自动注入 Authorization + 401 刷新 + 429 配额提示（TD-006）
+  const data = await aiClient.post<{
+    content: string;
+    keyframes_analyzed: number;
+    model_used: string;
+  }>('/api/v1/multimodal/analyze-video', formData, { timeout: 300000 });
 
-  const controller = new AbortController();
-  const timeoutId = setTimeout(() => controller.abort(), 300000); // 与网关 300s 超时对齐
+  const analyzeResult: AnalyzeResult = {
+    content: data.content,
+    keyframesAnalyzed: data.keyframes_analyzed,
+    modelUsed: data.model_used,
+    source: 'remote',
+  };
 
+  // 自动持久化（Dexie，PWA/Electron 通用）
   try {
-    const resp = await fetch(`${baseUrl}/api/v1/multimodal/analyze-video`, {
-      method: 'POST',
-      headers,
-      body: formData,
-      signal: controller.signal,
+    await classroomNoteStore.create({
+      sessionId: crypto.randomUUID(),
+      title: `视频笔记 ${new Date().toLocaleString('zh-CN')}`,
+      content: analyzeResult.content,
+      keyframesAnalyzed: analyzeResult.keyframesAnalyzed,
+      modelUsed: analyzeResult.modelUsed,
+      sourceType: 'video',
+      duration: options?.duration ?? 0,
     });
-    if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
-    const data = await resp.json() as {
-      content: string;
-      keyframes_analyzed: number;
-      model_used: string;
-    };
-
-    const analyzeResult: AnalyzeResult = {
-      content: data.content,
-      keyframesAnalyzed: data.keyframes_analyzed,
-      modelUsed: data.model_used,
-      source: 'remote',
-    };
-
-    // 自动持久化（Dexie，PWA/Electron 通用）
-    try {
-      await classroomNoteStore.create({
-        sessionId: crypto.randomUUID(),
-        title: `视频笔记 ${new Date().toLocaleString('zh-CN')}`,
-        content: analyzeResult.content,
-        keyframesAnalyzed: analyzeResult.keyframesAnalyzed,
-        modelUsed: analyzeResult.modelUsed,
-        sourceType: 'video',
-        duration: options?.duration ?? 0,
-      });
-    } catch (e) {
-      console.warn('[uploadVideoAnalysis] 视频笔记持久化失败:', e);
-    }
-
-    return analyzeResult;
-  } finally {
-    clearTimeout(timeoutId);
+  } catch (e) {
+    console.warn('[uploadVideoAnalysis] 视频笔记持久化失败:', e);
   }
+
+  return analyzeResult;
 }

client/src/features/notes/hooks/useClipImport.ts

@@ -9,6 +9,9 @@ import { useCallback, useState } from 'react';
 import { useToast } from '@/components/ui';
 import { useNoteStore } from '../store/useNoteStore';
 
+/** 浏览器剪藏正文截断上限（字符）：防超大网页 innerText 数 MB 入内存/IndexedDB（TD-007） */
+const MAX_CLIP_TEXT_CHARS = 100_000;
+
 export function useClipImport() {
   const createNote = useNoteStore((s) => s.createNote);
   const selectedFolderId = useNoteStore((s) => s.selectedFolderId);
@@ -40,7 +43,7 @@ export function useClipImport() {
         const html = await resp.text();
         const doc = new DOMParser().parseFromString(html, 'text/html');
         title = doc.title || new URL(clipUrl.trim()).hostname;
-        text = doc.body?.innerText?.trim() ?? '';
+        text = (doc.body?.innerText ?? '').trim().slice(0, MAX_CLIP_TEXT_CHARS);
         if (!text) throw new Error('empty page');
       }
       await createNote({ title: title.slice(0, 100) || '未命名剪藏', content: text, template: 'blank', folderId: selectedFolderId ?? undefined });

client/src/lib/http/apiClient.ts

@@ -11,9 +11,9 @@ interface RequestOptions extends RequestInit {
  * 共享的 token 刷新 Promise —— 并发请求同时命中 401 时只触发一次 refreshSession。
  * 否则多次并发刷新会因 Supabase 的 refresh token 轮换而互相失效，
  * 让本来有效的会话被误判为过期，从而偶发地强制用户重新登录。
- *
- * @ai-context: 日志/错误前缀统一为 [EntropyDecrease]。VITE_API_BASE_URL
- * 由环境文件注入，代码内零硬编码。
+ *
+ * @ai-context: 日志/错误前缀统一为 [EntropyDecrease]。VITE_API_BASE_URL
+ * 由环境文件注入，代码内零硬编码。
  */
 let sharedRefresh: ReturnType<typeof supabase.auth.refreshSession> | null = null;
 function refreshSessionShared() {
@@ -54,7 +54,10 @@ function createClient(baseUrlOrGetter: string | (() => string)) {
 
     const headers = new Headers(customHeaders as HeadersInit);
     if (token) headers.set('Authorization', `Bearer ${token}`);
-    headers.set('Content-Type', 'application/json');
+    // multipart（FormData body）不设 Content-Type，由浏览器自动生成 boundary；
+    // 其余请求统一 JSON
+    const isFormData = typeof FormData !== 'undefined' && rest.body instanceof FormData;
+    if (!isFormData) headers.set('Content-Type', 'application/json');
 
     // 生成请求追踪 ID，便于 ai-gateway 端链路追踪
     const requestId = crypto.randomUUID();
@@ -127,8 +130,15 @@ function createClient(baseUrlOrGetter: string | (() => string)) {
 
   return {
     get: <T = unknown>(url: string) => request<T>(url, { method: 'GET' }),
-    post: <T = unknown>(url: string, body?: unknown, options?: RequestOptions) =>
-      request<T>(url, { method: 'POST', body: JSON.stringify(body), ...options }),
+    post: <T = unknown>(url: string, body?: unknown, options?: RequestOptions) => {
+      // FormData body 直接透传（multipart 上传），其余 JSON 序列化
+      const isFormData = typeof FormData !== 'undefined' && body instanceof FormData;
+      return request<T>(url, {
+        method: 'POST',
+        body: isFormData ? body : JSON.stringify(body),
+        ...options,
+      });
+    },
     put: <T = unknown>(url: string, body?: unknown) =>
       request<T>(url, { method: 'PUT', body: JSON.stringify(body) }),
     delete: <T = unknown>(url: string) => request<T>(url, { method: 'DELETE' }),