feat: 添加 Native Messaging 桥接，支持 CLI 和 AI Agent 控制扩展

src/entries/background/main.ts

@@ -8,6 +8,7 @@ import "./utils/contextMenus.ts";
 import "./utils/omnibox.ts";
 import "./utils/alarms.ts";
 import "./utils/webRequest.ts";
+import "./utils/nativeMessaging.ts";
 
 // 监听 点击图标 事件
 chrome.action.onClicked.addListener(async () => {

src/entries/background/utils/nativeMessaging.ts

@@ -0,0 +1,148 @@
+import { sendMessage } from "@/messages.ts";
+import { setupOffscreenDocument } from "./offscreen.ts";
+
+const NATIVE_HOST_NAME = "com.ptd.native";
+const INSTANCE_ID_KEY = "ptd_native_instance_id";
+const RECONNECT_BASE_MS = 1000;
+const RECONNECT_MAX_MS = 30000;
+
+/** Errors that indicate the native host is not installed — no point retrying. */
+const FATAL_ERRORS = [
+  "Specified native messaging host not found.",
+  "Access to the specified native messaging host is forbidden.",
+  "Native messaging host has exited.",
+];
+
+/** Methods the bridge will proxy to sendMessage(). Everything else is rejected. */
+const ALLOWED_METHODS = new Set([
+  // Storage and logging (read-only)
+  "getExtStorage",
+  "getLogger",
+  // Site config
+  "getSiteUserConfig",
+  "getSiteFavicon",
+  "clearSiteFaviconCache",
+  // Search
+  "getSiteSearchResult",
+  "getMediaServerSearchResult",
+  // Download and downloader
+  "getDownloaderConfig",
+  "getDownloaderVersion",
+  "getDownloaderStatus",
+  "getTorrentDownloadLink",
+  "getTorrentInfoForVerification",
+  "downloadTorrent",
+  "getDownloadHistory",
+  "getDownloadHistoryById",
+  "deleteDownloadHistoryById",
+  "clearDownloadHistory",
+  // User info
+  "getSiteUserInfoResult",
+  "cancelUserInfoQueue",
+  "getSiteUserInfo",
+  "removeSiteUserInfo",
+  // Keep-upload
+  "getKeepUploadTasks",
+  "getKeepUploadTaskById",
+  "createKeepUploadTask",
+  "updateKeepUploadTask",
+  "deleteKeepUploadTask",
+  "clearKeepUploadTasks",
+]);
+
+let reconnectAttempt = 0;
+
+async function getOrCreateInstanceId(): Promise<string> {
+  const stored = await chrome.storage.local.get(INSTANCE_ID_KEY);
+  if (stored[INSTANCE_ID_KEY]) {
+    return stored[INSTANCE_ID_KEY];
+  }
+  const id = crypto.randomUUID();
+  await chrome.storage.local.set({ [INSTANCE_ID_KEY]: id });
+  return id;
+}
+
+function connect() {
+  let port: chrome.runtime.Port;
+  try {
+    port = chrome.runtime.connectNative(NATIVE_HOST_NAME);
+  } catch {
+    // Native host not installed — silently skip
+    console.debug("[PTD] Native messaging host not available, CLI bridge disabled.");
+    return;
+  }
+
+  let disconnected = false;
+  reconnectAttempt = 0;
+
+  // Send hello handshake
+  getOrCreateInstanceId().then((instanceId) => {
+    if (disconnected) return;
+    const hello = {
+      type: "hello",
+      instanceId,
+      browser: __BROWSER__,
+      extensionId: chrome.runtime.id,
+      version: __EXT_VERSION__,
+      capabilities: ["bridge-v1"],
+    };
+    port.postMessage(hello);
+  });
+
+  port.onMessage.addListener(async (msg: any) => {
+    if (msg?.type !== "request" || !msg.id || !msg.method) {
+      return;
+    }
+
+    const { id, method, params } = msg;
+
+    if (!ALLOWED_METHODS.has(method)) {
+      port.postMessage({
+        type: "response",
+        id,
+        error: { code: "METHOD_NOT_ALLOWED", message: `Method '${method}' is not allowed` },
+      });
+      return;
+    }
+
+    try {
+      await setupOffscreenDocument();
+      const result = await sendMessage(method as any, params);
+      port.postMessage({ type: "response", id, result });
+    } catch (e: any) {
+      port.postMessage({
+        type: "response",
+        id,
+        error: { code: "EXTENSION_ERROR", message: e?.message ?? String(e) },
+      });
+    }
+  });
+
+  port.onDisconnect.addListener(() => {
+    disconnected = true;
+    const err = chrome.runtime.lastError;
+    if (err) {
+      console.debug("[PTD] Native messaging disconnected:", err.message);
+    }
+
+    const errMsg = err?.message ?? "";
+
+    // Don't retry if the host is not installed or access is denied —
+    // retrying just floods the console with errors. The user needs to
+    // install the native host and restart the browser.
+    if (FATAL_ERRORS.some((e) => errMsg.includes(e))) {
+      console.debug(
+        "[PTD] Native host not available, CLI bridge disabled. Install the host and restart the browser to enable.",
+      );
+      return;
+    }
+
+    // Reconnect with bounded exponential backoff for transient errors
+    // (e.g. host process crashed, browser restarted the service worker)
+    reconnectAttempt++;
+    const delay = Math.min(RECONNECT_BASE_MS * 2 ** reconnectAttempt, RECONNECT_MAX_MS);
+    setTimeout(connect, delay);
+  });
+}
+
+connect();

src/entries/offscreen/utils/search.ts

@@ -25,7 +25,7 @@ onMessage("getSiteSearchResult", async ({ data: { siteId, keyword = "", searchEn
 
   if (searchResult.data.length > 0) {
     let autoDetectOfficialGroupFromTitlePattern: TPatterns | undefined;
-    if (configStorage.searchEntity.autoDetectOfficialGroupFromTitle && site.metadata.officialGroupPattern?.length) {
+    if (configStorage?.searchEntity?.autoDetectOfficialGroupFromTitle && site.metadata.officialGroupPattern?.length) {
       autoDetectOfficialGroupFromTitlePattern = site.metadata.officialGroupPattern;
     }
 

vite.config.ts

@@ -29,6 +29,7 @@ const permissions = [
   "cookies",
   "downloads",
   "declarativeNetRequest",
+  "nativeMessaging",
   "storage",
   "unlimitedStorage",
   "notifications",