fix: 修复插件fetch failed+WebSocket进度丢失+L2诊断JSON截断

三个关键问题一次性修复：

1. HTTP fetch failed (5分钟断开)
   - engineClient.ts: 用Node.js原生http模块替代fetch
   - 设置socket.setTimeout(0)+setKeepAlive(true,30s)
   - 彻底解决undici bodyTimeout 300s导致长测试中途断开

2. WebSocket进度推送不到WebView (步骤日志全部丢失)
   - engineClient.ts: 新增ensureWsConnected()方法
   - sidebarProvider.ts: 所有测试入口开始前主动确保WS已连接
   - engineClient.ts: connectWs()增加残留连接清理

3. WebSocket完整报告后备机制 (双保险)
   - websocket.py: send_test_done增加full_report参数
   - routes.py: Web蓝本测试完成后通过WS推送完整报告dict
   - sidebarProvider.ts: onProgress收到test_done+report时直接渲染
   - 即使HTTP断开，WebView也能通过WS拿到完整测试结果

4. L2诊断JSON解析截断
   - ai_hub.py: 正则从非贪婪.*?改为贪婪.*
   - 修复recover_selector含CSS选择器时被截断
   - L1/L2统一中文引号容错，去掉破坏CSS选择器的replace

Author: zcj220

extension/src/engineClient.ts

@@ -244,6 +244,11 @@ export class EngineClient {
     if (this._ws && this._ws.readyState === WebSocket.OPEN) {
       return;
     }
+    // 清理残留连接
+    if (this._ws) {
+      try { this._ws.close(); } catch { /* ignore */ }
+      this._ws = null;
+    }
 
     try {
       this._ws = new WebSocket(this.wsUrl);
@@ -265,17 +270,33 @@ export class EngineClient {
 
       this._ws.on("close", () => {
         console.log("[TestPilot AI] WebSocket 断开，5秒后重连");
+        this._ws = null;
         this._scheduleReconnect();
       });
 
       this._ws.on("error", (err) => {
         console.error("[TestPilot AI] WebSocket 错误:", err.message);
+        // error后通常会触发close，但保险起见也清理
       });
     } catch {
+      this._ws = null;
       this._scheduleReconnect();
     }
   }
 
+  /** 确保 WebSocket 已连接（测试开始前调用） */
+  ensureWsConnected(): void {
+    if (this._ws && this._ws.readyState === WebSocket.OPEN) {
+      return;
+    }
+    // 取消定时重连，立即重连
+    if (this._reconnectTimer) {
+      clearTimeout(this._reconnectTimer);
+      this._reconnectTimer = null;
+    }
+    this.connectWs();
+  }
+
   /** 断开 WebSocket */
   disconnectWs(): void {
     if (this._reconnectTimer) {
@@ -321,16 +342,54 @@ export class EngineClient {
 
   private async _post<T>(path: string, body: unknown): Promise<T> {
     const url = `${this.httpUrl}${path}`;
-    const resp = await fetch(url, {
-      method: "POST",
-      headers: { "Content-Type": "application/json" },
-      body: JSON.stringify(body),
-      signal: AbortSignal.timeout(600_000),
+    const payload = JSON.stringify(body);
+
+    // 使用 Node.js http 模块替代 fetch，避免 undici 的 bodyTimeout (300s)
+    // 导致长时间测试（6分钟+）中途 "fetch failed"
+    return new Promise<T>((resolve, reject) => {
+      const parsed = new URL(url);
+      const http = require("http");
+      const req = http.request(
+        {
+          hostname: parsed.hostname,
+          port: parsed.port,
+          path: parsed.pathname + parsed.search,
+          method: "POST",
+          headers: {
+            "Content-Type": "application/json",
+            "Content-Length": Buffer.byteLength(payload),
+          },
+          timeout: 900_000, // 15分钟连接超时
+        },
+        (res: any) => {
+          const chunks: Buffer[] = [];
+          res.on("data", (chunk: Buffer) => chunks.push(chunk));
+          res.on("end", () => {
+            const text = Buffer.concat(chunks).toString("utf-8");
+            if (res.statusCode && res.statusCode >= 400) {
+              reject(new Error(`HTTP ${res.statusCode}: ${text}`));
+            } else {
+              try {
+                resolve(JSON.parse(text) as T);
+              } catch {
+                reject(new Error(`JSON解析失败: ${text.substring(0, 200)}`));
+              }
+            }
+          });
+        },
+      );
+      req.on("timeout", () => {
+        req.destroy();
+        reject(new Error("请求超时（15分钟）"));
+      });
+      req.on("error", (err: Error) => reject(err));
+      // 禁用 socket 空闲超时，防止长测试期间连接被断开
+      req.on("socket", (socket: any) => {
+        socket.setTimeout(0);
+        socket.setKeepAlive(true, 30_000);
+      });
+      req.write(payload);
+      req.end();
     });
-    if (!resp.ok) {
-      const text = await resp.text();
-      throw new Error(`HTTP ${resp.status}: ${text}`);
-    }
-    return resp.json() as Promise<T>;
   }
 }

extension/src/sidebarProvider.ts

@@ -132,6 +132,7 @@ export class SidebarProvider implements vscode.WebviewViewProvider {
     projectPath: string;
   }): Promise<void> {
     try {
+      this._client.ensureWsConnected();
       this._postMessage({ command: "testStarted" });
 
       const config = vscode.workspace.getConfiguration("testpilotAI");
@@ -160,6 +161,8 @@ export class SidebarProvider implements vscode.WebviewViewProvider {
     mobile_session_id?: string;
   }): Promise<void> {
     try {
+      // 测试前确保 WebSocket 已连接，保证步骤进度能实时推送到 WebView
+      this._client.ensureWsConnected();
       this._postMessage({ command: "testStarted" });
 
       const platform = (msg.platform || "web").toLowerCase();
@@ -209,6 +212,7 @@ export class SidebarProvider implements vscode.WebviewViewProvider {
     mobile_session_id?: string;
   }): Promise<void> {
     try {
+      this._client.ensureWsConnected();
       this._postMessage({ command: "testStarted" });
 
       // 依次执行每个蓝本，汇总结果（用户停止时中断后续蓝本）
@@ -2108,6 +2112,12 @@ ${commonRules}`;
         screenshotImg.src = "data:image/png;base64," + wsMsg.data.image;
         return;
       }
+      // test_done 含完整报告时，直接渲染结果（HTTP后备）
+      // 即使 HTTP fetch failed，WebView 也能通过 WS 拿到完整结果
+      if (wsMsg.type === "test_done" && wsMsg.data?.report) {
+        onTestResult(wsMsg.data.report);
+        return;
+      }
       const level = typeMap[wsMsg.type] || "info";
       const text = wsMsg.data?.message || wsMsg.type;
       addLog(text, level);

src/api/routes.py

@@ -506,10 +506,6 @@ async def _on_step(step: int, status: str, desc: str) -> None:
         try:
             await ws_manager.send_log(f"蓝本测试开始: {blueprint.app_name}")
             report = await runner.run(blueprint)
-            await ws_manager.send_test_done(
-                report.passed_steps / report.total_steps * 100 if report.total_steps > 0 else 0,
-                len(report.bugs),
-            )
 
             # v1.3：保存记忆（Bug模式提取）
             if memory_store and report.bugs:
@@ -524,14 +520,15 @@ async def _on_step(step: int, status: str, desc: str) -> None:
             stopped = test_controller.was_stopped
             if stopped:
                 test_controller.reset()
-            return TestReportResponse(
+            pass_rate = report.passed_steps / report.total_steps * 100 if report.total_steps > 0 else 0
+            response = TestReportResponse(
                 test_name=report.test_name,
                 url=report.url,
                 total_steps=report.total_steps,
                 passed_steps=report.passed_steps,
                 failed_steps=report.failed_steps,
                 bug_count=len(report.bugs),
-                pass_rate=report.passed_steps / report.total_steps * 100 if report.total_steps > 0 else 0,
+                pass_rate=pass_rate,
                 duration_seconds=report.duration_seconds,
                 report_markdown=report.report_markdown,
                 stopped=stopped,
@@ -560,6 +557,16 @@ async def _on_step(step: int, status: str, desc: str) -> None:
                     for b in report.bugs
                 ],
             )
+
+            # 通过 WebSocket 推送完整报告（作为 HTTP response 的后备）
+            # 即使 HTTP 连接中途断开，WebView 也能通过 WS 拿到结果
+            try:
+                report_dict = response.model_dump()
+            except AttributeError:
+                report_dict = response.dict()
+            await ws_manager.send_test_done(pass_rate, len(report.bugs), full_report=report_dict)
+
+            return response
         except Exception as e:
             logger.error("蓝本测试执行失败: {}", e)
             raise HTTPException(status_code=500, detail=f"蓝本测试执行失败: {e}")

src/api/websocket.py

@@ -146,13 +146,19 @@ async def send_repair_done(self, bug_title: str, success: bool) -> None:
             "message": f"修复{status_text}: {bug_title}",
         })
 
-    async def send_test_done(self, pass_rate: float, bug_count: int) -> None:
-        """发送测试完成通知。"""
-        await self.broadcast("test_done", {
+    async def send_test_done(
+        self, pass_rate: float, bug_count: int,
+        full_report: dict[str, Any] | None = None,
+    ) -> None:
+        """发送测试完成通知（含完整报告作为HTTP后备）。"""
+        data: dict[str, Any] = {
             "pass_rate": pass_rate,
             "bug_count": bug_count,
             "message": f"测试完成 | 通过率 {pass_rate:.0f}% | Bug {bug_count} 个",
-        })
+        }
+        if full_report is not None:
+            data["report"] = full_report
+        await self.broadcast("test_done", data)
 
     # ── v2.0 新增推送 ────────────────────────────────
 

src/testing/ai_hub.py

@@ -310,11 +310,14 @@ async def _try_l1_popup_heal(self, ctx: StepContext) -> HubDecision:
             logger.debug("AI中枢L1弹窗检测返回(前300字): {}", response[:300])
 
             # 3. 解析 JSON
-            json_match = re.search(r"\{.*?\}", response, re.DOTALL)
+            json_match = re.search(r"\{.*\}", response, re.DOTALL)
             if not json_match:
                 return HubDecision(action=HubAction.NONE, reason="AI返回无JSON", ai_cost_ms=cost_ms)
 
-            result = json.loads(json_match.group().replace("'", '"'))
+            raw_json = json_match.group()
+            raw_json = raw_json.replace("\u201c", '"').replace("\u201d", '"')
+            raw_json = raw_json.replace("\u2018", "'").replace("\u2019", "'")
+            result = json.loads(raw_json)
             if not result.get("popup"):
                 return HubDecision(action=HubAction.NONE, reason="未检测到弹窗", ai_cost_ms=cost_ms)
 
@@ -419,14 +422,14 @@ async def _try_l2_diagnose(self, ctx: StepContext) -> HubDecision:
             cost_ms = (time.time() - start) * 1000
             logger.info("  🧠 AI中枢L2诊断返回(前400字): {}", response[:400])
 
-            json_match = re.search(r"\{.*?\}", response, re.DOTALL)
+            json_match = re.search(r"\{.*\}", response, re.DOTALL)
             if not json_match:
                 return HubDecision(action=HubAction.NONE, reason="L2返回无JSON", ai_cost_ms=cost_ms)
 
             # 容错：去掉中文引号、修复常见JSON格式问题
             raw_json = json_match.group()
             raw_json = raw_json.replace("\u201c", '"').replace("\u201d", '"')  # 中文引号
-            raw_json = raw_json.replace("'", '"')
+            raw_json = raw_json.replace("\u2018", "'").replace("\u2019", "'")  # 中文单引号→英文单引号
             result = json.loads(raw_json)
             diagnosis = result.get("diagnosis", "")
             suggestion = result.get("suggestion", "none")