feat：add streaming API interceptor for background tab compatibility and add plugin link

README.md

@@ -208,6 +208,7 @@ opencli plugin uninstall my-tool
 | [opencli-plugin-github-trending](https://github.com/ByteYue/opencli-plugin-github-trending) | YAML | GitHub Trending repositories |
 | [opencli-plugin-hot-digest](https://github.com/ByteYue/opencli-plugin-hot-digest) | TS | Multi-platform trending aggregator |
 | [opencli-plugin-juejin](https://github.com/Astro-Han/opencli-plugin-juejin) | YAML | 稀土掘金 (Juejin) hot articles |
+| [opencli-plugin-gemini-web](https://github.com/AstaTus/opencli-plugin-gemini-web) | — | Web端Gemini交互 |
 
 See [Plugins Guide](./docs/guide/plugins.md) for creating your own plugin.
 

README.zh-CN.md

@@ -314,6 +314,7 @@ opencli plugin uninstall my-tool                            # 卸载
 | [opencli-plugin-github-trending](https://github.com/ByteYue/opencli-plugin-github-trending) | YAML | GitHub Trending 仓库 |
 | [opencli-plugin-hot-digest](https://github.com/ByteYue/opencli-plugin-hot-digest) | TS | 多平台热榜聚合 |
 | [opencli-plugin-juejin](https://github.com/Astro-Han/opencli-plugin-juejin) | YAML | 稀土掘金热门文章 |
+| [opencli-plugin-gemini-web](https://github.com/AstaTus/opencli-plugin-gemini-web) | — | Web端Gemini交互 |
 
 详见 [插件指南](./docs/zh/guide/plugins.md) 了解如何创建自己的插件。
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@jackwener/opencli",
-  "version": "1.5.5",
+  "version": "1.5.6",
   "publishConfig": {
     "access": "public"
   },

src/browser/cdp.ts

@@ -27,6 +27,7 @@ import {
   waitForDomStableJs,
   waitForCaptureJs,
   waitForSelectorJs,
+  waitForStreamCaptureJs,
 } from './dom-helpers.js';
 import { isRecord, saveBase64ToFile } from '../utils.js';
 
@@ -347,6 +348,21 @@ class CDPPage implements IPage {
     const maxMs = timeout * 1000;
     await this.evaluate(waitForCaptureJs(maxMs));
   }
+
+  async installStreamingInterceptor(pattern: string): Promise<void> {
+    const { generateStreamingInterceptorJs } = await import('../interceptor.js');
+    await this.evaluate(generateStreamingInterceptorJs(JSON.stringify(pattern)));
+  }
+
+  async getStreamedResponses(): Promise<{ text: string; events: any[]; done: boolean; errors: any[] }> {
+    const { generateReadStreamJs } = await import('../interceptor.js');
+    return (await this.evaluate(generateReadStreamJs())) as { text: string; events: any[]; done: boolean; errors: any[] };
+  }
+
+  async waitForStreamCapture(timeout: number = 30, opts?: { minChars?: number; waitForDone?: boolean }): Promise<void> {
+    const maxMs = timeout * 1000;
+    await this.evaluate(waitForStreamCaptureJs(maxMs, opts));
+  }
 }
 
 function isCookie(value: unknown): value is BrowserCookie {

src/browser/daemon-client.ts

@@ -85,6 +85,7 @@ export async function isExtensionConnected(): Promise<boolean> {
 export async function sendCommand(
   action: DaemonCommand['action'],
   params: Omit<DaemonCommand, 'id' | 'action'> = {},
+  timeoutMs: number = 30000,
 ): Promise<unknown> {
   const maxRetries = 4;
 
@@ -94,7 +95,7 @@ export async function sendCommand(
     const command: DaemonCommand = { id, action, ...params };
     try {
       const controller = new AbortController();
-      const timer = setTimeout(() => controller.abort(), 30000);
+      const timer = setTimeout(() => controller.abort(), timeoutMs);
 
       const res = await fetch(`${DAEMON_URL}/command`, {
         method: 'POST',

src/browser/dom-helpers.ts

@@ -199,6 +199,35 @@ export function waitForCaptureJs(maxMs: number): string {
   `;
 }
 
+/**
+ * Generate JS to wait until the streaming interceptor has captured data.
+ * Polls window.__opencli_stream_text length. Optionally waits for stream completion.
+ * 50ms interval, rejects after maxMs.
+ */
+export function waitForStreamCaptureJs(
+  maxMs: number,
+  opts: { minChars?: number; waitForDone?: boolean; prefix?: string } = {},
+): string {
+  const minChars = opts.minChars ?? 1;
+  const waitForDone = opts.waitForDone ?? false;
+  const prefix = opts.prefix ?? '__opencli_stream';
+  return `
+    new Promise((resolve, reject) => {
+      const deadline = Date.now() + ${maxMs};
+      const check = () => {
+        const text = window.${prefix}_text || '';
+        const done = window.${prefix}_done || false;
+        if (text.length >= ${minChars} && (${waitForDone} ? done : true)) {
+          return resolve('captured');
+        }
+        if (Date.now() > deadline) return reject(new Error('Stream capture timeout'));
+        setTimeout(check, 50);
+      };
+      check();
+    })
+  `;
+}
+
 /**
  * Generate JS to wait until document.querySelector(selector) returns a match.
  * Uses MutationObserver for near-instant resolution; falls back to reject after timeoutMs.

src/browser/page.ts

@@ -24,6 +24,7 @@ import {
   waitForTextJs,
   waitForCaptureJs,
   waitForSelectorJs,
+  waitForStreamCaptureJs,
   scrollJs,
   autoScrollJs,
   networkRequestsJs,
@@ -346,6 +347,24 @@ export class Page implements IPage {
       ...this._cmdOpts(),
     });
   }
+
+  async installStreamingInterceptor(pattern: string): Promise<void> {
+    const { generateStreamingInterceptorJs } = await import('../interceptor.js');
+    await this.evaluate(generateStreamingInterceptorJs(JSON.stringify(pattern)));
+  }
+
+  async getStreamedResponses(): Promise<{ text: string; events: any[]; done: boolean; errors: any[] }> {
+    const { generateReadStreamJs } = await import('../interceptor.js');
+    return (await this.evaluate(generateReadStreamJs())) as { text: string; events: any[]; done: boolean; errors: any[] };
+  }
+
+  async waitForStreamCapture(timeout: number = 30, opts?: { minChars?: number; waitForDone?: boolean }): Promise<void> {
+    const maxMs = timeout * 1000;
+    await sendCommand('exec', {
+      code: waitForStreamCaptureJs(maxMs, opts),
+      ...this._cmdOpts(),
+    }, maxMs + 10000); // HTTP timeout = browser timeout + 10s buffer
+  }
 }
 
 // (End of file)

src/clis/xiaohongshu/comments.test.ts

@@ -27,6 +27,9 @@ function createPageMock(evaluateResult: any): IPage {
     getCookies: vi.fn().mockResolvedValue([]),
     screenshot: vi.fn().mockResolvedValue(''),
     waitForCapture: vi.fn().mockResolvedValue(undefined),
+    installStreamingInterceptor: vi.fn().mockResolvedValue(undefined),
+    getStreamedResponses: vi.fn().mockResolvedValue({ text: '', events: [], done: false, errors: [] }),
+    waitForStreamCapture: vi.fn().mockResolvedValue(undefined),
   };
 }
 

src/clis/xiaohongshu/creator-note-detail.test.ts

@@ -34,6 +34,9 @@ function createPageMock(evaluateResult: any): IPage {
     getCookies: vi.fn().mockResolvedValue([]),
     screenshot: vi.fn().mockResolvedValue(''),
     waitForCapture: vi.fn().mockResolvedValue(undefined),
+    installStreamingInterceptor: vi.fn().mockResolvedValue(undefined),
+    getStreamedResponses: vi.fn().mockResolvedValue({ text: '', events: [], done: false, errors: [] }),
+    waitForStreamCapture: vi.fn().mockResolvedValue(undefined),
   };
 }
 

src/clis/xiaohongshu/creator-notes.test.ts

@@ -38,6 +38,9 @@ function createPageMock(evaluateResult: any, interceptedRequests: any[] = []): I
     getCookies: vi.fn().mockResolvedValue([]),
     screenshot: vi.fn().mockResolvedValue(''),
     waitForCapture: vi.fn().mockResolvedValue(undefined),
+    installStreamingInterceptor: vi.fn().mockResolvedValue(undefined),
+    getStreamedResponses: vi.fn().mockResolvedValue({ text: '', events: [], done: false, errors: [] }),
+    waitForStreamCapture: vi.fn().mockResolvedValue(undefined),
   };
 }
 

src/clis/xiaohongshu/publish.test.ts

@@ -37,6 +37,9 @@ function createPageMock(evaluateResults: any[]): IPage {
     getCookies: vi.fn().mockResolvedValue([]),
     screenshot: vi.fn().mockResolvedValue(''),
     waitForCapture: vi.fn().mockResolvedValue(undefined),
+    installStreamingInterceptor: vi.fn().mockResolvedValue(undefined),
+    getStreamedResponses: vi.fn().mockResolvedValue({ text: '', events: [], done: false, errors: [] }),
+    waitForStreamCapture: vi.fn().mockResolvedValue(undefined),
   };
 }
 

src/clis/xiaohongshu/search.test.ts

@@ -32,6 +32,9 @@ function createPageMock(evaluateResults: any[]): IPage {
     getCookies: vi.fn().mockResolvedValue([]),
     screenshot: vi.fn().mockResolvedValue(''),
     waitForCapture: vi.fn().mockResolvedValue(undefined),
+    installStreamingInterceptor: vi.fn().mockResolvedValue(undefined),
+    getStreamedResponses: vi.fn().mockResolvedValue({ text: '', events: [], done: false, errors: [] }),
+    waitForStreamCapture: vi.fn().mockResolvedValue(undefined),
   };
 }