// ==UserScript==
// @name         Zotero GPT Connector
// @description  Zotero GPT Pro: Supports virtually all the AI platforms you know.
// @namespace    http://tampermonkey.net/
// @icon         https://github.com/MuiseDestiny/zotero-gpt/blob/bootstrap/addon/chrome/content/icons/favicon.png?raw=true
// @noframes
// @author       Polygon
// @version      5.0.4
// @match        https://chatgpt.com/*
// @match        https://gemini.google.com/*
// @match        https://poe.com/*
// @match        https://kimi.moonshot.cn/*
// @match        https://chatglm.cn/*
// @match        https://yiyan.baidu.com/*
// @match        https://qianwen.aliyun.com/*
// @match        https://claude.ai/*
// @match        https://mytan.maiseed.com.cn/*
// @match        https://mychandler.bet/*
// @match        https://chat.deepseek.com/*
// @match        https://www.doubao.com/chat/*
// @match        https://*.chatshare.biz/*
// @match        https://chat.kelaode.ai/*
// @match        https://chat.rawchat.cn/*
// @match        https://node.dawuai.buzz/*
// @match        https://aistudio.google.com/*
// @match        https://claude.ai0.cn/*
// @match        https://grok.com/*
// @match        https://china.aikeji.vip/*
// @match        https://chatgtp.chat/*
// @match        https://iai.aichatos8.com.cn/*
// @match        https://share.mosha.cloud/*
// @match        https://node.leadyven.com/*
// @match        https://gpt.bestaistore.com/*
// @include      /.+gpt2share.+/
// @include      /.+rawchat.+/
// @include      /.+sharedchat.+/
// @include      /.+kimi.+/
// @include      /.+freeoai.+/
// @include      /.+sharesai.+/
// @include      /.+chatgpt.+/
// @include      /.+claude.+/
// @include      /.+qwen.+/
// @include      /.+coze.+/
// @include      /.+grok.+/
// @include      /.+tongyi.+/
// @include      /.+qianwen.+/
// @include      /.+chatopens.+/
// @include      /.+kelaode.+/
// @include      /.+askmany.+/
// @include      /.+4399ai.+/
// @include      /.+minimaxi.+/
// @match        https://github.com/copilot/*
// @match        https://shareai.cfd/*
// @match        https://lmarena.ai/*
// @match        https://arena.ai/*
// @match        https://*.mjpic.cc/*
// @match        https://www.zaiwen.top/chat/*
// @match        https://chat.aite.lol/*
// @match        https://yuanbao.tencent.com/chat/*
// @match        https://chatgptup.com/*
// @match        https://ihe5u7.aitianhu2.top/*
// @match        https://cc01.plusai.io/*
// @match        https://arc.aizex.me/*
// @match        https://www.chatwb.com/*
// @match        https://www.xixichat.top/*
// @match        https://zchat.tech/*
// @match        https://*.sorryios.*/*
// @match        https://monica.im/*
// @match        https://copilot.microsoft.com/*
// @match        https://gptsdd.com/*
// @match        https://max.bpjgpt.top/*
// @match        https://nbai.tech/
// @match        https://x.liaobots.work/*
// @match        https://x.liaox.ai/*
// @match        https://chat.qwenlm.ai/*
// @match        https://lke.cloud.tencent.com/*
// @match        https://dazi.co/*
// @match        https://www.wenxiaobai.com/*
// @match        https://www.techopens.com/*
// @match        https://xiaoyi.huawei.com/*
// @match        https://chat.baidu.com/*
// @match        https://qrms.com/*
// @match        https://www.perplexity.ai/*
// @match        https://sider.ai/*
// @match        https://saas.ai1.bar/*
// @match        https://sx.xiaoai.shop/*
// @match        https://oai.liuliangbang.vip/*
// @match        https://*.dftianyi.com/*
// @match        https://notebooklm.google.com/notebook/*
// @match        https://chat.bpjgpt.top/*
// @match        https://*.plusai.io/*
// @match        https://*.plusai.me/*
// @match        https://*.yrai.cc/*
// @match        https://aistudio.xiaomimimo.com/*
// @match        https://next-three.soruxnet.com/*
// @connect      127.0.0.1
// @grant        GM_xmlhttpRequest
// @grant        GM_setValue
// @grant        GM_getValue
// @grant        GM_registerMenuCommand
// @grant        GM_addValueChangeListener
// @grant        unsafeWindow
// @run-at       document-start
// ==/UserScript==

(function () {
  'use strict';

  const TAB_ID = Math.random().toString(36).substr(2, 9);
  const LOCK_KEY = 'gpt_connector_running';
  const ENDPOINT = "http://127.0.0.1:23119/zoterogpt";
  const IS_IFRAME = window.self !== window.top;

  // 🎨 日志工具
  const log = {
    info: (...msg) => console.log(`%c[INFO]`, 'color: #2196F3', ...msg),
    warn: (...msg) => console.log(`%c[WARN]`, 'color: #FF9800; font-weight: bold', ...msg),
    err: (...msg) => console.log(`%c[ERR]`, 'color: #F44336; font-weight: bold', ...msg),
    poll: (...msg) => console.log(`%c[POLL]`, 'color: #9E9E9E', ...msg),
    upd: (...msg) => console.log(`%c[SEND]`, 'color: #9C27B0; font-weight: bold', ...msg),
    dom: (...msg) => console.log(`%c[DOM]`, 'color: #E91E63; font-weight: bold', ...msg),
    ui: (...msg) => console.log(`%c[UI]`, 'color: #00BCD4; font-weight: bold', ...msg),
  };

  const getOutputText = (resp = "", think = "") => {
    let text = ""
    if (think) {
      text += ("<think>" + think)
      if (resp) { text += "</think>\n" }
    }
    text += resp
    return text
  }

  // =================================================================================================
  // 1. 网络请求封装
  // =================================================================================================
  const gmRequest = (payload, timeout = 10000) => {
    let abortFn = null;
    const promise = new Promise((resolve, reject) => {
      const ts = Date.now().toString().slice(-4);
      const action = payload.action.toUpperCase();

      const req = GM_xmlhttpRequest({
        method: "POST",
        url: ENDPOINT,
        headers: { "Content-Type": "application/json" },
        data: JSON.stringify(payload),
        timeout: timeout,
        onload: (res) => {
          if (res.status >= 200 && res.status < 300) {
            try {
              const json = JSON.parse(res.responseText);
              resolve(json);
            } catch (e) {
              log.err(`[${ts}] ${action} JSON解析失败`);
              reject(e);
            }
          } else {
            log.err(`[${ts}] ${action} HTTP ${res.status}`);
            reject(new Error(res.statusText));
          }
        },
        onerror: (e) => { reject(e); },
        ontimeout: () => {
          if (action === "POLL") resolve({});
          else reject(new Error("Timeout"));
        }
      });
      abortFn = () => {
        req.abort();
        reject(new DOMException("Aborted", "AbortError"));
      };
    });
    return { abort: abortFn, promise };
  };

  // =================================================================================================
  // 2. 站点配置 (SITES)
  // =================================================================================================
  // =================================================================================================
  // 2. 站点配置 (SITES) - 策略模式重构版
  // =================================================================================================
  const SITES = {
    // --- 1. ChatGPT (Network) --- ✅
    ChatGPT: {
      host: ['chatgpt.com'],
      input: {
        text: { selector: '#prompt-textarea', method: "paste" },
        file: { selector: "input[type=file]", method: "paste" },
        send: '[data-testid="send-button"]',
        message: 'article[data-testid^="conversation-turn"]',
      },
      output: {
        type: "network",
        regex: /conversation$/,
        parser: (text, allText) => {
          let resp = "";
          for (let line of text.split("\n")) {
            if (line.startsWith('data: {"message')) {
              try {
                const data = JSON.parse(line.split("data: ")[1])
                if (data.message.content.content_type == "text") resp = data.message.content.parts[0]
              } catch { continue }
            } else if (line.startsWith("data: {")) {
              try {
                let data = JSON.parse(line.split("data: ")[1])
                if (Array.isArray(data.v)) data = data.v.find(i => i.p == "/message/content/parts/0")
                if (data && typeof (data.v) == "string") resp += data.v;
              } catch { continue }
            }
          }
          return resp.replace(/\ue200entity\ue202\[[^\]]*,\s*"([^"]+)",[^\]]*\]\ue201/g, '$1');
        }
      }
    },

    // --- 2. Kimi (Network -> 建议改DOM但此处保留Network配置) --- ✅
    Kimi: {
      host: ['kimi.moonshot.cn', 'www.kimi.com'],
      input: {
        text: { selector: '[contenteditable="true"]', method: "lexical" }, // 新版Kimi是Lexical
        file: { selector: '.chat-input-editor-container', method: "paste" },
        send: '.send-button-container',
        message: '.chat-content-item',
      },
      output: {
        type: "network",
        regex: /ChatService\/Chat/,
        parser: (text, allText) => {
          let think = "", resp = ""
          const arr = allText.split(/\x00+[^\{]+/).filter(Boolean).map(i => {
            try { return JSON.parse(i.replace(/^{{/, "{")) } catch { return {} }
          })
          for (let data of arr) {
            if (!data.mask) { continue }
            if (data.mask.startsWith("block.think")) think += data.block.think.content || ""
            else if (data.mask.startsWith("block.text")) resp += data.block.text.content || ""
          }
          return getOutputText(resp.replace(/-\| /g, "-|\n|"), think)
        }
      }
    },

    // --- 3. Tongyi (Network) --- ✅
    Tongyi: {
      host: ['www.qianwen.com'],
      input: {
        text: { selector: '[role=textbox]', method: "paste" },
        file: { selector: "[class^=chatInput]", method: "drag" },
        send: '.operateBtn-JsB9e2',
        message: '[class^=questionItem]',
      },
      output: {
        type: "network",
        regex: /qianwen.com\/api\/v2\/chat/,
        parser: (text, allText) => {
          let think = "", resp = ""
          for (let s of allText.split("\n")) {
            try {
              if (!s || !s.startsWith("data:{")) continue
              const data = JSON.parse(s.slice(5))
              const content = data.data.messages.at(-1).content
              if (!content) continue
              resp = content.replace(/^\[\(deep_think\)\]/, "")
              if (content.startsWith("[(deep_think)]")) {
                think = data.data.messages.at(-1).meta_data.multi_load[0].content.think_content
              }
            } catch (e) { }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 4. Claude (Network) ---
    Claude: {
      host: ['claude.ai', 'claude.ai0.cn', 'chat.kelaode.ai'],
      input: {
        text: { selector: '[contenteditable="true"]', method: "div" },
        file: { selector: "input[type=file]", method: "input" },
        send: 'button[aria-label="Send message"], button[aria-label="發送訊息"]',
        message: '[data-test-render-count]',
      },
      output: {
        type: "network",
        regex: /chat_conversations\/.+\/completion/,
        parser: (text, allText) => {
          let resp = "";
          for (let line of text.split("\n")) {
            if (line.startsWith("data: {")) {
              try {
                const data = JSON.parse(line.split("data: ")[1])
                if (data.type && data.type == "completion") resp += data.completion || ""
                else if (data.type && data.type == "content_block_delta") resp += data.delta.text || ""
              } catch { continue }
            }
          }
          return resp;
        }
      }
    },

    // --- 5. Gemini (Network) --- ✅
    Gemini: {
      host: ['gemini.google.com'],
      input: {
        text: { selector: 'rich-textarea .textarea', method: "gemini" },
        file: { selector: '.text-input-field_textarea-wrapper', method: "paste", timeout: 5000 },
        send: '.send-button',
        message: '.conversation-container',
      },
      output: {
        type: "network",
        regex: /BardFrontendService\/StreamGenerate/,
        parser: (text) => {
          let think = "", resp = ""
          for (let line of text.split(/\n\d+\n/)) {
            try {
              const data = JSON.parse(line)
              if (data[0][0] == "wrb.fr") {
                const data1 = JSON.parse(data[0][2])[4][0]
                resp = data1[1][0]
                think = data1[37][0][0]
              }
            } catch { }
          }
          return getOutputText(resp.replace(/\[cite.+?\]/g, ""), think)
        }
      }
    },

    // --- 6. Poe (DOM) --- ✅
    Poe: {
      host: ['poe.com'],
      input: {
        text: { selector: 'textarea[class*=GrowingTextArea_textArea]', method: "textarea" },
        file: { selector: ".ChatDragDropTarget_dropTarget__1WrAL", method: "drag" },
        send: '[data-button-send=true]',
        message: '[class^=LeftSideMessageHeader]', // Note: check if this selector is stable for counting
      },
      output: {
        type: "dom",
        parser: () => {
          try {
            const lastNode = [...document.querySelectorAll("[class^=ChatMessage_chatMessage] [class^=Message_selectableText]")].slice(-1)[0];
            if (!lastNode) return null;
            const props = lastNode[Object.keys(lastNode)[0]].alternate.child.memoizedProps;
            const text = props.text;
            const isDone = Boolean(lastNode.closest("[class^=ChatMessagesView_messageTuple]").querySelector("[class^=ChatMessageActionBar_actionBar]"));
            return { text: text, isDone: isDone };
          } catch (e) { return null; }
        }
      }
    },

    // --- 7. Doubao (DOM) --- ✅
    Doubao: {
      host: ['www.doubao.com'],
      input: {
        text: { selector: '[data-testid="chat_input_input"]', method: "textarea" },
        file: { selector: "input[type=file]", method: "input" },
        send: 'button#flow-end-msg-send',
        message: '[class^=message-block-container]',
      },
      output: {
        type: "dom",
        parser: () => {
          try {
            const divs = document.querySelectorAll('[data-testid=message_content]');
            if (divs.length === 0) return null;
            const div = divs[divs.length - 1];
            const reactKey = Object.keys(div).find(k => k.startsWith('__reactProps') || k.startsWith('__reactFiber'));
            if (!reactKey) return null;
            const fiber = div[reactKey];
            let message;
            try {
              if (fiber.pendingProps?.children?.[0]) message = fiber.pendingProps.children[0].props.message;
              if (!message && fiber.children?.[0]) message = fiber.children[0].props.message;
            } catch (e) { }
            if (!message) return null;
            const blocks = message.content_blocks_v2;
            if (!blocks) return null;
            let resp = "", think = "";
            if (blocks[0].block_type == 10040 && blocks.length >= 2) {
              think = blocks[1]?.content?.text_block?.text || "";
              if (blocks.length == 3) resp = blocks[2]?.content?.text_block?.text || "";
            } else {
              resp = blocks[0]?.content?.text_block?.text || "";
            }
            return { text: getOutputText(resp, think), isDone: message.status === 1 };
          } catch (e) { return null; }
        }
      }
    },

    // --- 8. DeepSeek (Network) --- ✅
    DeepSeek: {
      host: ['chat.deepseek.com'],
      input: {
        text: { selector: 'textarea', method: "react" },
        file: { selector: ".bf38813a", method: "drag" },
        send: '._7436101',
        message: '._4f9bf79',
      },
      output: {
        type: "network",
        regex: /completion$/,
        parser: (text, allText) => {
          let resp = "", think = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data: {")) {
              try {
                const data = JSON.parse(line.split("data: ")[1])
                let block = {}
                if (data.v && data.v.response) {
                  block = data.v.response.fragments[0]
                } else if (Array.isArray(data.v)) {
                  block = data.v[0]
                } else if (typeof (data.v) == "string"){
                  block = {
                    content: data.v
                  }
                }
                if (block.type) {
                  window.responseType = block.type
                }
                if (!block.content) {
                  window.responseType = "system"
                }

                if (window.responseType == "RESPONSE") {
                  resp += (block.content || "")
                } else if (window.responseType == "THINK") {
                  think += (block.content || "")
                }
              } catch (e) {
                console.log(e)
              }
            }
          
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 9. Yuanbao (Network) --- ✅
    Yuanbao: {
      host: ['yuanbao.tencent.com'],
      input: {
        text: { selector: '.chat-input-editor .ql-editor', method: "div" }, // Quills editor usually div
        file: { selector: ".agent-chat__input-box", method: "drag" },
        send: '.icon-send',
        message: '.agent-chat__bubble__content',
      },
      output: {
        type: "network",
        regex: /api\/chat\/.+/,
        parser: (text, allText) => {
          let think = "", resp = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data: {")) {
              try {
                const data = JSON.parse(line.split("data: ")[1])
                if (data.type == "text") resp += (data.msg || "")
                else if (data.type == "think" || data.type == "deepSearch") think += (data.contents[0].msg || "")
                else if (data.type == "replace") resp += `![](${data.replace.multimedias[0].url})\n${data.replace.multimedias[0].desc}`
              } catch (e) { }
            }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 10. AIStudio (Network) --- ✅
    AIStudio: {
      host: ['aistudio.google.com'],
      input: {
        text: { selector: '.text-wrapper textarea', method: "standard" },
        file: { selector: ".text-wrapper", method: "drag" },
        send: 'ms-run-button button',
        message: 'ms-chat-turn',
      },
      output: {
        type: "network",
        regex: /GenerateContent$/,
        parser: (text) => {
          let data
          while (!data) {
            try {
              data = JSON.parse(text)
            } catch {
              text += "]"
            }
          }
          console.log(data)
          let think = "", resp = ""
          for (let i of data[0]) {
            try {
              let s = i[0][0][0][0][0][1]
              if (i[0][0][0][0][0][12]) {
                think += s
              } else {
                resp += s
              }
            } catch { }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 11. ChatGLM (Network) --- ✅
    ChatGLM: {
      host: ['chatglm.cn'],
      input: {
        text: { selector: '.input-box-inner textarea', method: "standard" },
        file: { selector: "input[type=file]", method: "input" },
        send: '.enter div',
        message: '.answer',
      },
      output: {
        type: "network",
        regex: /backend-api\/assistant\/stream/,
        parser: (text) => {
          let resp = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.parts && data.parts[0] && data.parts[0].content[0].type == "text") {
                  resp = data.parts[0].content[0].text
                }
              } catch { }
            }
          }
          return resp;
        }
      }
    },

    // --- 12. Yiyan (Network) --- 不打算适配
    Yiyan: {
      host: ['yiyan.baidu.com'],
      input: {
        text: { selector: '.yc-editor', method: "standard" }, // Might need textarea or div check
        file: { selector: ".UxLYHqhv", method: "drag" },
        send: '[class^=sendInner]',
        message: '[data-chat-id]',
      },
      output: {
        type: "network",
        regex: /chat\/conversation\/v2$/,
        parser: (text, allText) => {
          let think = "", resp = ""
          for (let line of allText.split(/\n+/)) {
            if (line.startsWith("data:{")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.thoughts) think += data.thoughts.replace(/<nickname-start>(.+?)<nickname-end>/, "$1") || ""
                else if (data.data) resp += data.data.content || ""
              } catch { }
            }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 13. Zaiwen (Network) ---
    Zaiwen: {
      host: ['www.zaiwen.top'],
      input: {
        text: { selector: 'textarea.arco-textarea', method: "standard" },
        file: { selector: ".arco-upload-draggable", method: "drag" },
        send: 'img.send',
        message: '.sessions .item',
      },
      output: {
        type: "network",
        regex: /admin\/chatbot$/,
        parser: (text) => text
      }
    },

    // --- 14. ChanlderAi (Network) ---
    ChanlderAi: {
      host: ['mychandler.bet'],
      input: {
        text: { selector: '.chandler-content_input-area', method: "standard" },
        file: { selector: "input[type=file]", method: "input" },
        send: '.send',
        message: '.chandler-ext-content_communication-group',
      },
      output: {
        type: "network",
        regex: /api\/chat\/Chat$/,
        parser: (text) => {
          let resp = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:{")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                resp += data.delta
              } catch { }
            }
          }
          return resp
        }
      }
    },

    // --- 15. MyTan (Network) ---
    MyTan: {
      host: ['mytan.maiseed.com.cn'],
      input: {
        text: { selector: '.talk-textarea', method: "standard" },
        file: { selector: 'input[type=file]', method: "input" }, // Assumed
        send: '.send-icon',
        message: '.message-container .mytan-model-avatar',
      },
      output: {
        type: "network",
        regex: /messages$/,
        parser: (text) => {
          let resp = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                resp += data.choices[0].delta.content
              } catch { }
            }
          }
          return resp
        }
      }
    },

    // --- 16. Coze (Network) ---
    Coze: {
      host: ['coze'],
      input: {
        text: { selector: 'textarea.rc-textarea', method: "react" },
        file: { selector: "input[type=file]", method: "input" },
        send: 'button[data-testid="bot-home-chart-send-button"]',
        message: '[data-message-id]',
      },
      output: {
        type: "network",
        regex: /conversation\/chat/,
        parser: (text) => {
          let resp = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:{")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.message.type == "answer") resp += data.message.content || ""
              } catch { }
            }
          }
          return resp
        }
      }
    },

    // --- 17. Grok (Network) --- ✅
    Grok: {
      host: ['grok.com'],
      input: {
        text: { selector: 'div[contenteditable="true"]', method: "paste" }, // Fallback to div/paste often needed
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: 'button[type="submit"]',
        message: '[id^=response-]',
      },
      output: {
        type: "network",
        regex: /\/responses$/,
        parser: (text, allText) => {
          let resp = "", think = ""
          for (let t of allText.split("\n")) {
            try {
              let data = JSON.parse(t).result
              if (data.response) data = data.response
              if (data.isThinking) think += data.token || ""
              else resp += data.token || ""
            } catch (e) {
              // log.info(e)
            }
          }
          // console.log({resp, think})
          return getOutputText(resp, think)
        }
      }
    },

    // --- 18. Baidu Chat (Network) ---
    Baidu: {
      host: ['chat.baidu.com'],
      input: {
        text: { selector: '#chat-input-box', method: "standard" }, // innerText set
        file: { selector: "[class^=chat-bottom-wrapper]", method: "drag" },
        send: '.send-icon',
        message: '[class^=index_answer-container]',
      },
      output: {
        type: "network",
        regex: /conversation$/,
        parser: (text, allText) => {
          let resp = "", think = ""
          for (let t of allText.split("\n")) {
            if (!t.startsWith("data:")) continue
            try {
              const data = JSON.parse(t.slice(5)).data
              if (!data) continue
              if (data.message.metaData.state == "generating-resp") {
                if (data.message.content.generator.component == "reasoningContent") think += data.message.content.generator.data.value || ""
                else if (data.message.content.generator.component == "markdown-yiyan") resp += data.message.content.generator.data.value || ""
              }
            } catch { }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 19. Perplexity (Network) --- ✅
    Perplexity: {
      host: ['www.perplexity.ai'],
      input: {
        text: { selector: '[id=ask-input]', method: "lexical" }, // Likely lexical/paste
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: '.ml-2 button',
        message: '.-inset-md',
      },
      output: {
        type: "network",
        regex: /perplexity_ask$/,
        parser: (text) => {
          let resp = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.blocks) {
                  for (let block of data.blocks) {
                    if (block.intended_usage == "ask_text") {
                      if (block.markdown_block && block.markdown_block.answer) 
                        resp = block.markdown_block.answer || ""
                      else if (block.diff_block && block.diff_block.field == "markdown_block") {
                        for (let patch of block.diff_block.patches) {
                          if (patch.op == "replace" && patch.path == "/answer") {
                            resp = patch.value || ""
                          }
                          else if (patch.op == "add") {
                            resp += patch.value || ""
                          }
                        }
                      }
                    }
                  }
                }
              } catch (e) {
                log.err(e)
              }
            }
          }
          return resp
        }
      }
    },

    // --- 20. Sider (Network) ---
    Sider: {
      host: ['sider.ai'],
      input: {
        text: { selector: 'textarea.chatBox-input', method: "textarea" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: '.send-btn',
        message: '.message-item',
      },
      output: {
        type: "network",
        regex: /(completions|chat\/wisebase)/,
        parser: (text, allText) => {
          let think = "", resp = ""
          for (let line of allText.split("\n")) {
            if (line.startsWith("data:")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.data.type == "reasoning_content") think += data.data.reasoning_content.text || ""
                else if (data.data.type == "text") resp += data.data.text || ""
              } catch { }
            }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 21. Qwen (Network) --- ✅
    Qwen: {
      host: ['chat.qwen.ai'],
      input: {
        text: { selector: '.message-input-container-area textarea', method: "textarea" },
        file: { selector: ".message-input-container-area", method: "drag" },
        send: 'button.send-button',
        message: '.qwen-chat-message',
      },
      output: {
        type: "network",
        regex: /chat\/completions/,
        parser: (text, allText) => {
          let think = "", resp = ""
          for (let line of allText.split("\n")) {
            if (line.startsWith("data: {")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.choices[0].delta.phase == "think") think += data.choices[0].delta.content
                else if (data.choices[0].delta.phase == "answer") resp += data.choices[0].delta.content
              } catch { }
            }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 22. AskManyAI (Network) --- ✅
    AskManyAI: {
      host: ['askmany.cn'],
      input: {
        text: { selector: '.editor', method: "paste" },
        file: { selector: "input[type=file]", method: "input" },
        send: '.fs_button',
        message: '.main-chat-view .bubble-ai',
      },
      output: {
        type: "network",
        regex: /engine\/sseQuery/,
        parser: (text, allText) => {
          let think = "", resp = ""
          for (let line of allText.split("\n")) {
            if (line.startsWith("data: {")) {
              try {
                const data = JSON.parse(line.split("data:")[1])
                if (data.content.startsWith("[HIT-REF]")) continue
                if (data.event == "thinking") think += data.content
                else if (data.event == "resp") resp += data.content
              } catch { }
            }
          }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 23. Wenxiaobai (Network) --- ✅
    Wenxiaobai: {
      host: ['www.wenxiaobai.com'],
      input: {
        text: { selector: '[class^=MsgInput_input_box] textarea', method: "textarea" },
        file: { selector: "[class^=botChatPage_input_content_container]", method: "drag" },
        send: '#j-input-send-msg',
        message: '#chat_turn_container',
      },
      output: {
        type: "network",
        regex: /conversation\/chat\/v\d$/,
        parser: (text, allText) => {
          if (!allText) return ""
          let resp = ""
          for (let line of allText.replace(/event:message\ndata/g, "message").split("\n")) {
            if (line.startsWith("message:{")) {
              try {
                const data = JSON.parse(line.split("message:")[1])
                resp += data.content || ""
              } catch { }
            }
          }
          resp = resp.replace(/^```ys_think[\s\S]+?\n\n```\n/, "").replace(/[\s\S]+?```ys_think/, "```ys_think")
          if (resp.includes("```ys_think")) {
            resp = ">" + resp.split("\n").slice(3).join("\n>")
          }
          return resp
        }
      }
    },

    // --- 24. GoogleNotebookLM (Network) ---
    GoogleNotebookLM: {
      host: ['notebooklm.google.com'],
      input: {
        text: { selector: 'textarea.query-box-input', method: "standard" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: 'button[type="submit"]',
        message: 'chat-message',
      },
      output: {
        type: "network",
        regex: /GenerateFreeFormStreamed/,
        parser: (text) => {
          let resp = ""
          for (let line of text.split(/\n\d+\n/)) {
            try {
              const data = JSON.parse(line)
              if (data[0][0] == "wrb.fr") {
                const data1 = JSON.parse(data[0][2])
                resp = data1[0][0]
              }
            } catch { }
          }
          return resp
        }
      }
    },

    // --- 25. MinMax (Network) --- 不太适合联动使用，不好适配
    MinMax: {
      host: ['minimaxi'],
      input: {
        text: { selector: '.chat-input-container [contenteditable]', method: "paste" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: '#input-send-icon div',
        message: '.mb-4 ',
      },
      output: {
        type: "network",
        regex: /v1\/chat\/get_chat_detail/,
        parser: (text) => {
          let resp = "", think = ""
          try {
            const s = text.split("\n").find(i => i.startsWith("data:"))
            const data = JSON.parse(s.slice(5))
            const content = data.data.messageResult.content
            if (content.startsWith("<think>")) {
              if (content.includes("</think>")) {
                const res = content.match(/<think>([\s\S]*?)<\/think>([\s\S]*)/)
                think = res[1] || ""; resp = res[2] || ""
              } else {
                think = content.replace(/^<think>/, "")
              }
            } else {
              resp = content
            }
          } catch { }
          return getOutputText(resp, think)
        }
      }
    },

    // --- 26. LMArena (Network) --- ✅
    LMArena: {
      host: ['arena'],
      input: {
        text: { selector: 'form textarea', method: "textarea" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: 'button[type="submit"]',
        message: 'main ol div',
      },
      output: {
        type: "network",
        regex: /stream\/post-to-evaluation/,
        parser: (text) => {
          let res = "", think = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("ag:")) think += JSON.parse(line.slice(3))
            if (line.startsWith("a0:")) res += JSON.parse(line.slice(3))
          }
          return getOutputText(res, think)
        }
      }
    },

    // --- 27. GitHubCopilot (Network) ---
    GitHubCopilot: {
      host: ['github.com'],
      input: {
        text: { selector: 'textarea#copilot-chat-textarea', method: "copilot" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: '[class^=ChatInput-module__toolbarButtons] button',
        message: '.message-container',
      },
      output: {
        type: "network",
        regex: /github\/chat\/threads\/.+\/messages/,
        parser: (text) => {
          let res = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:")) {
              const data = JSON.parse(line.slice(5))
              if (data.type == "content") res += data.body
            }
          }
          return res
        }
      }
    },

    // --- 28. MIMO (Network) --- ✅
    MIMO: {
      host: ['aistudio.xiaomimimo.com'],
      input: {
        text: { selector: 'textarea', method: "textarea" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: '.dialogue-container>div:nth-child(2) button:nth-child(3)',
        message: '.markdown-prose',
      },
      output: {
        type: "network",
        regex: /open-apis\/bot\/chat/,
        parser: (text) => {
          let res = ""
          for (let line of text.split("\n")) {
            if (line.startsWith("data:")) {
              try {
                const data = JSON.parse(line.slice(5))
                if (data.type == "text") res += data.content.replace("\u0000", "") || ''
              } catch (e) {

              }
            }
          }
          return res
        }
      }
    },

    // --- 29. TencentDeepSeek (DOM) ---
    TencentDeepSeek: {
      host: ['lke.cloud.tencent.com'],
      input: {
        text: { selector: '.question-input-inner__textarea', method: "vue" },
        file: { selector: "input[type=file]", method: "input" },
        send: '.question-input', // Handled by vue method side effect or generic click
        message: '.client-chat',
      },
      output: {
        type: "dom",
        parser: () => {
          try {
            const div = document.querySelector(".client-chat");
            const msg = div.__vue__.msgList.slice(-1)[0];
            const isDone = msg.is_final;
            let text = msg.content;
            if (!text && msg.agent_thought) {
              text = "> " + msg.agent_thought.procedures[0].debugging.content.trim().replace(/\n+/g, "\n");
            }
            return { text: text, isDone: isDone };
          } catch (e) { return null; }
        }
      }
    },

    // --- 30. Xiaoyi (DOM) ---
    Xiaoyi: {
      host: ['xiaoyi.huawei.com'],
      input: {
        text: { selector: 'textarea', method: "standard" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: '.send-button',
        message: '.receive-box',
      },
      output: {
        type: "dom",
        parser: () => {
          try {
            const div = [...document.querySelectorAll(".receive-box")].slice(-1)[0];
            const isDone = Boolean(div.closest(".msg-content") && div.closest(".msg-content").querySelector(".tool-bar"));
            const text = div.querySelector(".answer-cont").innerHTML;
            return { text: text, isDone: isDone };
          } catch (e) { return null; }
        }
      }
    },

    // --- 31. Copilot (DOM) ---
    Copilot: {
      host: ['copilot.microsoft.com'],
      input: {
        text: { selector: 'textarea#userInput', method: "standard" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: 'button[type="submit"]',
        message: '[data-content=ai-message]',
      },
      output: {
        type: "dom",
        parser: () => {
          try {
            const lastAnwser = [...document.querySelectorAll('[data-content=ai-message]')].slice(-1)[0];
            const props = lastAnwser[Object.keys(lastAnwser)[0]].pendingProps.children[1][0].props;
            return { text: props.item.text, isDone: props.isStreamingComplete };
          } catch (e) { return null; }
        }
      }
    },

    // --- 32. Microsoft (DOM - Old Style) ---
    Microsoft: {
      // NOTE: Host duplicate with Copilot, might need manual merge or strict host check
      host: ['copilot.microsoft.com'],
      input: {
        text: { selector: '[id^=chatMessageResponser]', method: "lexical" },
        file: { selector: "input[type=file]", method: "input" }, // Assumed
        send: 'button[type="submit"]',
        message: '[id^=chatMessageResponser]',
      },
      output: {
        type: "dom",
        parser: () => {
          try {
            const div = document.querySelector('[id^=chatMessageResponser]');
            const text = div[Object.keys(div)[1]].children[0].props.text;
            const isDone = div.closest('[role="article"]').querySelector(".fai-CopilotMessage__footnote");
            return { text: text, isDone: isDone };
          } catch (e) { return null; }
        }
      }
    }
  };


  // =================================================================================================
  // 3. Network Proxy (类结构，但极速启动)
  // =================================================================================================
  class NetworkProxy {
    constructor(connector) {
      this.connector = connector;
      this.setupFetch();
      this.setupXHR();
      log.info("⚡️ NetworkProxy 已挂载 (Document Start)");
    }

    setupFetch() {
      const originalFetch = unsafeWindow.fetch;
      const self = this;

      const proxy = new Proxy(originalFetch, {
        apply: function (target, thisArg, args) {
          const fetchPromise = Reflect.apply(target, thisArg, args);

          const input = args[0];
          const urlStr = (typeof input === 'string') ? input : (input instanceof URL ? input.href : (input?.url || ''));

          // 1. 自身请求放行
          if (urlStr.includes('zoterogpt')) return fetchPromise;

          // 2. 检查配置 (此时 DOM 可能未加载，但 Config 已在 Constructor 中读取)
          const outputConfig = self.connector.config?.output;

          if (self.connector.isConnected && self.connector.isRunning && self.connector.hasLock()) {
            if (outputConfig && outputConfig.type === 'network' && outputConfig.regex && outputConfig.regex.test(urlStr)) {
              log.info(`🎯 [Fetch] 捕获流: ${urlStr}`);

              fetchPromise.then(response => {
                if (!response.ok) return;
                try {
                  const cloned = response.clone();
                  setTimeout(() => self.readStream(cloned.body), 0);
                } catch (e) { /* ignore */ }
              }).catch(() => { });
            }
          }
          return fetchPromise;
        }
      });

      // 隐形伪装
      proxy.toString = () => 'function fetch() { [native code] }';
      unsafeWindow.fetch = proxy;
    }

    async readStream(stream) {
      const reader = stream.getReader();
      const decoder = new TextDecoder();
      let allText = "";
      const outputConfig = this.connector.config.output;

      try {
        while (true) {
          const { done, value } = await reader.read();
          if (done) break;
          const chunk = decoder.decode(value, { stream: true });
          allText += chunk;

          if (outputConfig && outputConfig.parser) {
            // 解析并传输
            const parsed = outputConfig.parser(allText, allText);
            // console.log("readStream", { parsed })
            if (parsed) this.connector.onNewData(parsed, false);
          }
        }
        if (outputConfig && outputConfig.parser) {
          this.connector.onNewData(this.connector.accumulatedText, true);
        }
      } catch (e) { 
        if (e?.name === "AbortError") {
          this.connector.onNewData(this.connector.accumulatedText, true);
        } else {
          console.log("readStream error", e)
        }
      }
    }

    setupXHR() {
      const originalOpen = XMLHttpRequest.prototype.open;
      const self = this;

      XMLHttpRequest.prototype.open = function (method, url) {
        const urlStr = (typeof url === 'string') ? url : (url instanceof URL ? url.href : String(url));

        if (urlStr.includes('zoterogpt')) return originalOpen.apply(this, arguments);

        const outputConfig = self.connector.config?.output;

        if (self.connector.isConnected && self.connector.isRunning && self.connector.hasLock()) {
          if (outputConfig && outputConfig.type === 'network' && outputConfig.regex && outputConfig.regex.test(urlStr)) {
            log.info(`🎯 [XHR] 捕获流: ${urlStr}`);
            this.addEventListener('readystatechange', function () {
              if ([0, 3, 4].includes(this.readyState)) {
                try {
                  if (outputConfig.parser) {
                    if ([0].includes(this.readyState)) {
                      self.connector.isDoneSignal = true
                      self.connector.performUpdate()
                    } else {
                      const parsed = outputConfig.parser(this.responseText, this.responseText);
                      // console.log("XMLHttpRequest", { parsed })

                      if (parsed) self.connector.onNewData(parsed, [0, 4].includes(this.readyState));
                    }
                  }
                } catch (e) {console.log(e) }
              }
            });
          }
        }
        return originalOpen.apply(this, arguments);
      };
      // 隐形伪装
      XMLHttpRequest.prototype.open.toString = () => 'function open() { [native code] }';
    }
  }

  // =================================================================================================
  // 4. Connector (构造函数立即初始化 Proxy)
  // =================================================================================================
  class Connector {
    constructor() {
      // 1. 获取配置 (location.host 在 document-start 阶段可用)
      this.config = this.getSiteConfig();
      if (!this.config) return;

      // 2. 🔥🔥🔥 立即初始化 NetworkProxy (关键！不等待 DOM)
      //    只要配置里要求用 network，马上挂载钩子，抢在 Kimi 之前
      if (this.config.output && this.config.output.type === 'network') {
        this.proxy = new NetworkProxy(this);
      }

      // 3. 初始化状态
      this.mySessionSecret = Math.random().toString(36).substring(2);
      this.isConnected = false;
      this.isRunning = false;
      this.currentTaskId = null;
      this.lastTaskId = null;
      this.accumulatedText = "";
      this.isDoneSignal = false;
      this.isSendingUpdate = false;
      this.hasPendingData = false;
      this.pollReq = null;
      this.pollDelayTimer = null;
      this.domWatchInterval = null;

      // 4. 延迟初始化 DOM 依赖项 (菜单、监听器、自动连接)
      //    因为此时 body 可能还不存在
      if (document.readyState === 'loading') {
        document.addEventListener('DOMContentLoaded', () => this.initDomDependent());
      } else {
        this.initDomDependent();
      }

      // 监听卸载
      window.addEventListener('beforeunload', () => {
        this.disconnect();
      });
    }

    // DOM 准备好后才执行的逻辑
    initDomDependent() {
      this.initMenu();
      this.setupCrossTabListener();
      this.tryAutoConnect();
    }

    getSiteConfig() {
      const host = location.host;
      for (const [name, conf] of Object.entries(SITES)) {
        if (conf.host.some(h => host.includes(h))) return { name, ...conf };
      }
      return {name: "ChatGPT", ...SITES.ChatGPT};
    }

    // --- 通用工具 ---
    acquireLock() { let lockInfo = {}; try { lockInfo = JSON.parse(GM_getValue(LOCK_KEY, "{}")); } catch (e) { } if (lockInfo && lockInfo.isLocked) { return lockInfo.tabId === TAB_ID; } else { GM_setValue(LOCK_KEY, JSON.stringify({ isLocked: true, tabId: TAB_ID })); return true; } }
    forceAcquireLock() { GM_setValue(LOCK_KEY, JSON.stringify({ isLocked: true, tabId: TAB_ID })); return true; }
    releaseLock() { 
      let lockInfo = {}; try { 
        lockInfo = JSON.parse(GM_getValue(LOCK_KEY, "{}")); 
      } catch (e) { } 
      if (lockInfo.tabId === TAB_ID) { 
        GM_setValue(LOCK_KEY, JSON.stringify({ isLocked: false, tabId: null }));
        } 
    }
    hasLock() { let lockInfo = {}; try { lockInfo = JSON.parse(GM_getValue(LOCK_KEY, "{}")); } catch (e) { } return lockInfo.isLocked && lockInfo.tabId === TAB_ID; }
    setupCrossTabListener() { GM_addValueChangeListener(LOCK_KEY, (name, oldVal, newVal, remote) => { if (remote) { const newLock = JSON.parse(newVal); if (newLock.isLocked && newLock.tabId !== TAB_ID) { if (this.isRunning) { log.warn("被其他标签页抢占"); this.isRunning = false; this.isConnected = false; this.killPoll(); } } } }); }

    initMenu() {
      const suffix = IS_IFRAME ? ' (Frame)' : '';
      GM_registerMenuCommand(`⭐️ 优先${suffix}`, () => { this.isRunning = true; this.forceAcquireLock(); this.handshake(); });
      GM_registerMenuCommand(`🔗 运行${suffix}`, () => { if (this.acquireLock()) { this.isRunning = true; this.handshake(); } });
      GM_registerMenuCommand(`🎊 断开${suffix}`, async () => {
        this.disconnect()
      });
    }

    tryAutoConnect() {
      if (this.acquireLock()) {
        log.info("自动连接中...");
        this.isRunning = true;
        this.handshake();
      }
    }

    disconnect() {
      // 如果本来就没有运行，直接跳过
      if (!this.isRunning && !this.isConnected) {
        this.releaseLock();
        return;
      }

      log.info("执行断开清理程序...");
      this.isRunning = false;
      this.isConnected = false;

      // 1. 掐断所有正在进行的网络请求和定时器
      this.killPoll();

      // 2. 只有当前持有控制权的页面，才有资格通知 Zotero 改名字
      if (this.hasLock()) {
        // 注意：页面关闭时不能用 await，直接发出去就行 (Fire-and-forget)
        gmRequest({
          action: "connect",
          ai: "Disconnected",
          sessionSecret: "offline_" + Date.now()
        }, 2000).promise.catch(() => { }); // 捕获错误防止控制台飘红

        log.info("已向 Zotero 发送断开状态");
      }

      // 3. 释放锁，把控制权交还给大自然
      this.releaseLock();
    }

    async handshake() {
      console.log("handshake is called")
      if (!this.isRunning) {return};
      this.killPoll();
      try {
        const res = await gmRequest({ 
          action: "connect", 
          ai: this.config.name, 
          icon: document.querySelector("link[rel*=icon]")?.href || "", 
          url: location.href, 
          sessionSecret: this.mySessionSecret,
          version: GM_info.script.version
        }, 5000).promise;
        if (res.status === "connected") {
          this.isConnected = true;
          console.log("握手成功");
          notify.message({
            text: "Zotero: 联动成功", type: "success", duration: 3e3, timeout: 200
          })
          this.start();
        }
      } catch (e) { 
        console.log(e)
        notify.message({
          text: "⚠️ Zotero: 联动失败", type: "fail", duration: 3e3, timeout: 200
        })
        log.err("握手失败"); 
      }
    }

    start() {
      const outputConfig = this.config.output;
      log.info(`模式启动: ${outputConfig?.type || 'unknown'}`);
      this.startPolling();
    }

    // --- DOM Watcher ---
    startDomWatcher() {
      if (this.domWatchInterval) clearInterval(this.domWatchInterval);
      const outputConfig = this.config.output;
      if (!outputConfig || outputConfig.type !== 'dom' || !outputConfig.parser) return;

      log.dom("启动 DOM 监听器");
      let lastTextLen = 0;
      let stableCycles = 0;

      this.domWatchInterval = setInterval(async () => {
        if (!this.isRunning || !this.currentTaskId) { this.stopDomWatcher(); return; }

        const result = outputConfig.parser();
        if (result && typeof result.text === 'string') {
          const currentLen = result.text.length;
          if (result.isDone) {
            if (currentLen > lastTextLen) {
              stableCycles = 0;
              this.onNewData(result.text, false);
            } else {
              stableCycles++;
              if (stableCycles >= 5) {
                this.onNewData(result.text, true);
                this.stopDomWatcher();
              } else { this.onNewData(result.text, false); }
            }
          } else {
            stableCycles = 0;
            this.onNewData(result.text, false);
          }
          lastTextLen = currentLen;
        }
      }, 200);
    }

    stopDomWatcher() {
      if (this.domWatchInterval) {
        clearInterval(this.domWatchInterval);
        this.domWatchInterval = null;
        log.dom("停止 DOM 监听器");
      }
    }

    // --- Data Transmission ---
    onNewData(text, isDone) { 
      if (!this.isRunning) return; 
      this.accumulatedText = text; 
      if (isDone) this.isDoneSignal = true; 
      this.hasPendingData = true; 
      this.tryFlushData(); 
    }
    tryFlushData() {
      if (this.isSendingUpdate) return;
      if (!this.hasPendingData) return;

      // 🔥 2. 只要有新数据要发，立即清除冷却定时器
      if (this.pollDelayTimer) {
        clearTimeout(this.pollDelayTimer);
        this.pollDelayTimer = null;
      }

      if (this.pollReq) {
        log.warn("🔥 为发送Update，强制掐断Poll...");
        this.killPoll();
      }
      this.performUpdate();
    }
    async performUpdate() {
      const tid = this.currentTaskId || this.lastTaskId;
      if (!tid) {
        log.info("performUpdate: no tid")
        return
      };
      this.isSendingUpdate = true;
      this.hasPendingData = false;
      const textToSend = this.accumulatedText;
      const isDoneToSend = this.isDoneSignal;
      log.upd(`>>> 发送: ${textToSend.length} chars (Done: ${isDoneToSend})`);
      try {
        const { promise } = await gmRequest({ action: "update", id: tid, text: textToSend || "", isDone: isDoneToSend, sessionSecret: this.mySessionSecret }, 8000);
        await promise;
        this.lastSentText = textToSend;
        log.upd(`<<< 发送成功`);
        this.isSendingUpdate = false;
        if (isDoneToSend) {
          log.info("任务结束");
          this.resetTaskState();
          this.startPolling();
        } else {
          if (this.hasPendingData) { log.info("递归发送"); this.performUpdate(); }
          else { this.schedulePolling(); }
        }
      } catch (e) {
        log.err("发送失败，重试");
        console.log(e)
        this.isSendingUpdate = false;
        setTimeout(() => this.tryFlushData(), 500);
      }
    }

    killPoll() { if (this.pollReq) { this.pollReq.abort(); this.pollReq = null; } if (this.pollDelayTimer) { clearTimeout(this.pollDelayTimer); this.pollDelayTimer = null; } }
    schedulePolling() { if (this.pollDelayTimer) clearTimeout(this.pollDelayTimer); this.pollDelayTimer = setTimeout(() => { this.pollDelayTimer = null; if (!this.isSendingUpdate) { log.poll("冷却结束，恢复 Poll"); this.startPolling(); } }, 3000); }

    async startPolling() {
      if (this.isSendingUpdate || this.pollReq || !this.isConnected || !this.isRunning || !this.hasLock()) return;
      this.pollReq = gmRequest({ action: "poll", sessionSecret: this.mySessionSecret }, 30e3);
      try {
        const res = await this.pollReq.promise;
        this.pollReq = null;
        if (res.error === "SESSION_EXPIRED") { log.warn("Session过期"); this.isConnected = false; return; }
        if (res.task) { log.info(`收到任务: ${res.task.id}`); this.executeTask(res.task); }
        this.startPolling();
      } catch (e) {
        log.err(e)
        this.pollReq = null;
        if (e && e.name === "AbortError") return;
        if (this.isSendingUpdate) return;
        if (this.isConnected && this.isRunning) setTimeout(() => this.startPolling(), 1000);
      }
    }

    resetTaskState() {
      this.currentTaskId = null;
      this.isDoneSignal = false;
      this.accumulatedText = "";
      this.lastSentText = "";
      this.hasPendingData = false;
      this.stopDomWatcher();
    }

    // --- Task Execution ---
    async executeTask(task) {
      try {
        log.info(`执行任务: ${task.id}`);
        console.log(task)
        this.killPoll(); // 立即静默
        this.isSendingUpdate = true;
        this.currentTaskId = task.id;
        this.lastTaskId = task.id;
        this.resetTaskState();
        this.currentTaskId = task.id;
        console.log(task.messages)
        if (task.messages && this.config.input.file) {
          for (let message of task.messages) {
            if (message.type == "file") {
              await this.uploadFile(message.base64String, message.name);
              await this.sleep(1000);
            }
          }
        }
  
        const prompt = task.messages.filter(m => m.type !== "file").map(m => m.text).join("\n\n");
        if (prompt) {
          const inputConfig = this.config.input.text; // 使用 input.text 配置
    
          let success = await this.fillInput(inputConfig, prompt);
          if (!success) { log.warn("重试填充..."); success = await this.fillInput(inputConfig, prompt); }
    
          if (success ) {
            log.ui("输入完成，发送...");
            const sent = await this.clickSend(this.config.input.send, this.config.input.message);
    
            if (sent) {
              log.ui("已发送");
              if (this.config.output && this.config.output.type === 'dom') {
                this.startDomWatcher();
              }
              this.isSendingUpdate = false;
            } else {
              log.err("发送失败");
              this.isSendingUpdate = false;
              this.schedulePolling();
            }
          } else {
            log.err("填充失败");
            this.isSendingUpdate = false;
            this.schedulePolling();
          }
        } else {
          log.info("<prompt is empty>")
          this.isSendingUpdate = false;
          this.schedulePolling();
        }
      } catch (e) {
        log.err(e)
      }
    }

    // --- Input Strategies ---
    async fillInput(inputConfig, text) {
      log.info("fillInput is called")
      if (!inputConfig) return false;
      const { selector, method } = inputConfig;
      const el = document.querySelector(selector);
      if (!el) { log.err(`输入框未找到: ${selector}`); return false; }
      el.focus();

      try {
        switch (method) {
          case 'react': await this.setInputReact(el, text); break;
          case 'lexical': await this.setInputPaste(el, text); break;
          case 'div': el.innerHTML = text.split("\n").map(i => `<p>${this.escapeHtml(i)}</p>`).join(""); el.dispatchEvent(new InputEvent('input', { bubbles: true })); break;
          case 'paste': await this.setInputPaste(el, text); break;
          case 'gemini': el.textContent = text; el.dispatchEvent(new InputEvent('input', { bubbles: true })); break;
          case 'textarea': await this.setInputTextarea(el, text); break;
          case 'vue': await this.setInputVue(el, text); break;
          case 'standard': default: await this.setInputStandard(el, text); break;
        }
        await this.sleep(100);
        el.dispatchEvent(new Event('input', { bubbles: true }));
        return true;
      } catch (e) { log.err(`填充错误 ${method}`, e); return false; }
    }

    // Input Helpers
    escapeHtml(str) { return str.replace(/[&<>"']/g, m => ({ '&': '&amp;', '<': '&lt;', '>': '&gt;', '"': '&quot;', "'": '&#39;' })[m]); }
    
    async setInputStandard(el, text) { 
      // 获取 input 输入框的dom对象
      var inputNode = el
      if (!inputNode) { return }
      inputNode.value = text;
      // plus
      try {
        inputNode.innerHTML = text.split("\n").map(i => `<p>${escapeHtml(i)}</p>`).join("\n");
      } catch { }
      // 设置输入框的 input 事件
      var event = new InputEvent('input', {
        'bubbles': true,
        'cancelable': true,
      });
      inputNode.dispatchEvent(event);
    }

    async setInputTextarea(el, text) {
      const textarea = el
      const props = Object.values(textarea)[1]

      // 获取目标 DOM 节点（假设 temp2 是 DOM 元素引用）
      const targetElement = textarea;

      // 创建伪事件对象
      const e = {
        target: targetElement,
        currentTarget: targetElement,
        type: 'change',
      };

      // 手动设置值（需同时更新 DOM 和 React 状态）
      targetElement.value = text;

      // 触发 React 的 onChange 处理
      await props.onChange(e);
    }

    async setInputReact(el, text) {
      const key = Object.keys(el).find(k => k.startsWith('__reactProps'));
      if (key) {
        const props = el[key];
        // Try standard onChange or value tracker
        if (props.onChange) {
          props.onChange({ target: { value: text }, currentTarget: { value: text } });
        }
        // Fallback for some Ant Design or specific wrappers (like Monica)
        if (props.children && props.children.props && props.children.props.onChange) {
          props.children.props.onChange({ target: { value: text } });
        }
      } else {
        // Fallback to standard if React props not found
        await this.setInputStandard(el, text);
      }
    }

    async setInputPaste(el, text) { const dt = new DataTransfer(); dt.setData('text/plain', text); el.dispatchEvent(new ClipboardEvent('paste', { bubbles: true, cancelable: true, clipboardData: dt })); }
    async setInputVue(el, text) { try { document.querySelector(".question-input")?.__vue__?.onStopStream(); if (el.__vue__?.onChange) await el.__vue__.onChange(text.slice(0, 10000)); } catch (e) { } }

    async clickSend(sendSelector, messageSelector) {
      const btn = document.querySelector(sendSelector);
      if (!btn) return false;

      // 🔥🔥🔥 核心修改：在点击之前，必须无条件掐断所有连接！
      // 只有这样才能腾出浏览器的网络线程给 ChatGPT 主请求
      this.killPoll();

      // 标记为正在发送，防止 schedulePolling 中的定时器意外启动 Poll
      this.isSendingUpdate = true;

      const getCount = () => document.querySelectorAll(messageSelector).length;
      const initialCount = getCount();
      const maxRetries = 20;

      log.ui(`准备发送，当前消息数: ${initialCount}`);

      // 点击操作
      btn.click();
      btn.dispatchEvent(new MouseEvent('mousedown', { bubbles: true }));
      btn.dispatchEvent(new MouseEvent('mouseup', { bubbles: true }));

      // 循环检查
      for (let i = 0; i < maxRetries; i++) {
        const currentCount = getCount();
        log.ui(`检测状态 ${initialCount} -> ${currentCount}`);
        if (currentCount > initialCount) {
          log.ui(`发送成功 ${initialCount} -> ${currentCount}`);
          this.isSendingUpdate = false;
          this.schedulePolling();
          return true;
        }
        if (i === 5) {
          log.warn("尝试补刀点击");
          btn.click();
        }
        await this.sleep(500);
      }

      log.err("发送失败 (DOM 未变化)");
      // 即使失败也要解除静默，否则脚本就死锁了
      this.isSendingUpdate = false;
      this.schedulePolling();
      return false;
    }

    async uploadFile(base64String, fileName) {
      try {
        const fileConfig = this.config.input.file || { method: "input", selector: "input[type=file]" };
        console.log(fileConfig)
        const { method, selector, timeout } = fileConfig;
        const fileType = this.getFileType(fileName);
        const fileContent = this.base64ToArrayBuffer(base64String);
        const file = new File([fileContent], fileName, { type: fileType });
        log.info(`上传文件: ${fileName} (${method})`);
        if (method === "input") {
          const dataTransfer = new DataTransfer();
          dataTransfer.items.add(file);
          let fileInput;
          const fileInputs = document.querySelectorAll(selector);
          if (fileInputs.length === 1) fileInput = fileInputs[0];
          else fileInput = [...fileInputs].find(i => i.accept.includes(fileType) || i.multiple) || fileInputs[0];
          if (fileInput) {
            fileInput.files = dataTransfer.files;
            fileInput.dispatchEvent(new Event('change', { bubbles: true }));
          }
        } else if (method === "drag") {
          const dataTransfer = new DataTransfer();
          dataTransfer.items.add(file);

          const dropZone = document.querySelector(selector); // 使用提供的选择器查找拖放区域
          const dragStartEvent = new DragEvent("dragstart", {
            bubbles: true,
            dataTransfer: dataTransfer,
            cancelable: true
          });
          const dropEvent = new DragEvent("drop", {
            bubbles: true,
            dataTransfer: dataTransfer,
            cancelable: true
          });

          dropZone.dispatchEvent(dragStartEvent);
          dropZone.dispatchEvent(dropEvent);
        } else if (method === "paste") {
          const dt = new DataTransfer();
          dt.items.add(file);
          const pasteEvent = new ClipboardEvent("paste", { bubbles: true, cancelable: true });
          Object.defineProperty(pasteEvent, "clipboardData", { value: dt });
          const target = document.querySelector(selector);
          if (target) { target.focus(); target.dispatchEvent(pasteEvent); }
        }
        if (timeout) await this.sleep(timeout);
      } catch (e) { log.err("文件上传失败", e); }
    }

    sleep(ms) { return new Promise(r => setTimeout(r, ms)); }

    getFileType(fileName) {
      if (fileName.endsWith("pdf")) return "application/pdf";
      if (fileName.endsWith("png")) return "image/png";
      if (fileName.endsWith("jpg") || fileName.endsWith("jpeg")) return "image/jpeg";
      if (fileName.endsWith("txt") || fileName.endsWith("md")) return "text/plain";
      if (fileName.endsWith("html")) return "text/html";
      return "application/octet-stream";
    }

    base64ToArrayBuffer(base64) {
      const binaryString = window.atob(base64);
      const len = binaryString.length;
      const bytes = new Uint8Array(len);
      for (let i = 0; i < len; i++) { bytes[i] = binaryString.charCodeAt(i); }
      return bytes.buffer;
    }
  }

  class NoticeManager {
    constructor() {
      this.overlay = null;
      this.box = null;
      this.contentWrap = null;

      this.itv = null;          // 保存倒计时定时器
      this.closeTimer = null;   // 保存关闭定时器
      this.resolveActive = null;// 保存当前处于活跃状态的 Promise resolve 函数

      this._injectStyle();
    }

    // 1. 注入 CSS 样式 (仅首次运行)
    _injectStyle() {
      const styleId = 'custom-confirm-style';
      if (document.getElementById(styleId)) return;

      const style = document.createElement('style');
      style.id = styleId;
      style.innerHTML = `
            .conf-overlay { 
                position: fixed; top: 20px; left: 50%; transform: translateX(-50%); 
                z-index: 2147483647; pointer-events: none;
            }
            .conf-box { 
                pointer-events: auto; background: #fff; padding: 8px 16px; 
                border-radius: 50px; display: flex; align-items: center; justify-content: center;
                box-shadow: 0 8px 24px rgba(0, 0, 0, 0.12); 
                border: 1px solid rgba(0, 0, 0, 0.06);
                animation: slideInTop 0.5s cubic-bezier(0.175, 0.885, 0.32, 1.15) forwards;
                transition: width 0.35s cubic-bezier(0.4, 0, 0.2, 1);
                box-sizing: border-box; overflow: hidden;
                white-space: nowrap; 
            }
            .conf-box.exit {
                animation: slideOutTop 0.4s cubic-bezier(0.6, -0.28, 0.735, 0.045) forwards;
            }
            @keyframes slideInTop { from { transform: translateY(-100px); opacity: 0; } to { transform: translateY(0); opacity: 1; } }
            @keyframes slideOutTop { from { transform: translateY(0); opacity: 1; } to { transform: translateY(-100px); opacity: 0; } }
            @keyframes fadeIn { from { opacity: 0; transform: scale(0.95); } to { opacity: 1; transform: scale(1); } }
            
            .conf-content { display: flex; align-items: center; gap: 14px; width: max-content; }
            .conf-text { color: #1f2937; font-size: 14px; font-weight: 500; }
            .conf-btns { display: flex; gap: 8px; align-items: center; }
            
            .conf-btn { 
                cursor: pointer; border: none; height: 32px; border-radius: 16px;
                display: flex; align-items: center; justify-content: center;
                transition: all 0.2s; font-size: 13px; font-weight: 500; gap: 4px;
            }
            .conf-cancel { background: #f3f4f6; color: #4b5563; padding: 0 14px; }
            .conf-cancel:hover { background: #e5e7eb; color: #111827; }
            .conf-ok { background: #ef4444; color: #fff; padding: 0 14px; }
            .conf-ok:hover { background: #dc2626; transform: scale(1.02); box-shadow: 0 4px 10px rgba(239, 68, 68, 0.3); }
            .t-val { font-size: 11px; opacity: 0.8; margin-left: 2px; }
        `;
      document.head.appendChild(style);
    }

    // 2. 清理历史状态 (防止多次调用造成冲突)
    _clearState() {
      clearInterval(this.itv);
      clearTimeout(this.closeTimer);
      if (this.resolveActive) {
        this.resolveActive(false); // 如果有未完成的交互，默认作废并返回 false
        this.resolveActive = null;
      }
    }

    // 3. 核心：处理 DOM 复用与宽度过渡动画
    _renderContent(html) {
      if (!this.overlay || !document.body.contains(this.overlay)) {
        // -- 首次创建 DOM --
        this.overlay = document.createElement('div');
        this.overlay.className = 'conf-overlay';
        this.overlay.innerHTML = `
                <div class="conf-box">
                    <div class="conf-content">${html}</div>
                </div>`;
        document.body.appendChild(this.overlay);

        this.box = this.overlay.querySelector('.conf-box');
        this.contentWrap = this.overlay.querySelector('.conf-content');
      } else {
        // -- 复用 DOM 并触发宽度过渡动画 --
        this.box.classList.remove('exit'); // 取消可能正在进行的退出动画

        const oldWidth = this.box.offsetWidth;
        this.box.style.width = oldWidth + 'px'; // 锁死旧宽度

        this.contentWrap.innerHTML = html; // 注入新内容

        this.box.style.width = 'auto';
        const newWidth = this.box.offsetWidth; // 获取新内容的自然宽度

        this.box.style.width = oldWidth + 'px';
        this.box.offsetHeight; // 强制重绘
        this.box.style.width = newWidth + 'px'; // 设置新宽度，触发 CSS transition

        // 动画结束后解除宽度硬编码，以防万一
        setTimeout(() => { if (this.box) this.box.style.width = 'auto'; }, 350);
      }
    }

    // 4. 关闭动画
    close() {
      if (this.overlay && this.box) {
        this.box.classList.add('exit');
        setTimeout(() => {
          if (this.overlay && this.overlay.parentNode) {
            this.overlay.parentNode.removeChild(this.overlay);
          }
          this.overlay = null;
        }, 400);
      }
    }

    // ================= 公开方法 =================

    /**
     * 单纯消息弹窗 (Info/Success/Error)
     * @param {Object} options 
     */
    message(options = {}) {
      this._clearState();
      console.log("message", options)
      return new Promise(resolve => {
        const { text = "操作成功", type = "success", duration = 1500, timeout = 0 } = options;
        const isSuccess = type === 'success';

        let svgIcon = ""
        if (type === 'success') {
          svgIcon = `<svg width="20" height="20" viewBox="0 0 24 24" fill="none" stroke="#10b981" stroke-width="2.5" stroke-linecap="round" stroke-linejoin="round"><polyline points="20 6 9 17 4 12"></polyline></svg>`
        } else if (type == "fail") {
          svgIcon = `<svg width="20" height="20" viewBox="0 0 24 24" fill="none" stroke="#ef4444" stroke-width="2.5" stroke-linecap="round" stroke-linejoin="round"><circle cx="12" cy="12" r="10"></circle><line x1="15" y1="9" x2="9" y2="15"></line><line x1="9" y1="9" x2="15" y2="15"></line></svg>`;
        } else if (type == "waiting") {
          svgIcon = `<svg viewBox="0 0 1024 1024" version="1.1" xmlns="http://www.w3.org/2000/svg" p-id="4830" width="20" height="20"><path d="M329.3 513.2c0-20-16.2-36.2-36.2-36.2H121.6c-20 0-36.2 16.2-36.2 36.2 0 20 16.2 36.2 36.2 36.2h171.5c20 0 36.2-16.2 36.2-36.2zM902.4 477H730.9c-20 0-36.2 16.2-36.2 36.2 0 20 16.2 36.2 36.2 36.2h171.5c20 0 36.2-16.2 36.2-36.2 0.1-20-16.2-36.2-36.2-36.2zM512.4 706.4c-20 0-36.2 16.2-36.2 36.2V902c0 20 16.2 36.2 36.2 36.2 20 0 36.2-16.2 36.2-36.2V742.7c0-20-16.2-36.3-36.2-36.3zM512.4 85.7c-20 0-36.2 16.2-36.2 36.2v171.5c0 20 16.2 36.2 36.2 36.2 20 0 36.2-16.2 36.2-36.2V121.9c0-20-16.2-36.2-36.2-36.2zM330.8 640.6L209.6 761.8c-14.1 14.1-14.1 37.1 0 51.2 7.1 7.1 16.3 10.6 25.6 10.6s18.5-3.5 25.6-10.6l121.3-121.3c14.1-14.1 14.1-37.1 0-51.2-14.2-14.1-37.1-14.1-51.3 0.1zM665.4 393.4c9.3 0 18.5-3.5 25.6-10.6l121.3-121.3c14.1-14.1 14.1-37.1 0-51.2-14.1-14.1-37.1-14.1-51.2 0L639.8 331.5c-14.1 14.1-14.1 37.1 0 51.2 7.1 7.1 16.3 10.7 25.6 10.7zM700.5 649c-14.1-14.1-37.1-14.1-51.2 0-14.1 14.1-14.1 37.1 0 51.2L762 813c7.1 7.1 16.3 10.6 25.6 10.6s18.5-3.5 25.6-10.6c14.1-14.1 14.1-37.1 0-51.2L700.5 649zM260.8 211.3c-14.1-14.1-37.1-14.1-51.2 0-14.1 14.1-14.1 37.1 0 51.2l121.3 121.3c7.1 7.1 16.3 10.6 25.6 10.6s18.5-3.5 25.6-10.6c14.1-14.1 14.1-37.1 0-51.2L260.8 211.3z" fill="#666666"></path></svg>`
        }
        const html = `
                <div style="display:flex; align-items:center; gap:8px; animation: fadeIn 0.3s ease forwards; padding: 2px 6px;">
                    ${svgIcon}
                    <span style="color:#374151; font-size:15px; font-weight:600;">${text}</span>
                </div>`;
        setTimeout(() => {
          this._renderContent(html);

          // 倒计时后自动关闭
          this.closeTimer = setTimeout(() => {
            this.close();
            resolve(true);
          }, duration);
        }, timeout)
      });
    }

    /**
     * 确认弹窗消息
     * @param {Object} options 
     */
    confirm(options = {}) {
      this._clearState();

      return new Promise(resolve => {
        this.resolveActive = resolve; // 记录当前的 resolve

        const {
          text = "确认执行此操作？",
          okBtnText = "确认",
          cancelBtnText = "取消",
          msgOk = "操作成功",
          msgCancel = "已取消操作",
          msgTimeout = "已自动确认",
          timeout = 5
        } = options;

        const html = `
                <div class="conf-text">${text}</div>
                <div class="conf-btns">
                    <button class="conf-btn conf-cancel">${cancelBtnText}</button>
                    <button class="conf-btn conf-ok">
                        <svg width="14" height="14" viewBox="0 0 1024 1024"><path d="M939.36 218.912a32 32 0 0 1 45.856 44.672l-538.016 552a32 32 0 0 1-43.776 1.92L63.872 526.048a32 32 0 1 1 41.696-48.544l316.768 271.936L939.36 218.88z" fill="currentColor"></path></svg>
                        ${okBtnText} <span class="t-val">${timeout}s</span>
                    </button>
                </div>`;

        this._renderContent(html);

        // 绑定事件
        const btnOk = this.contentWrap.querySelector('.conf-ok');
        const btnCancel = this.contentWrap.querySelector('.conf-cancel');
        const timerText = this.contentWrap.querySelector('.t-val');
        let timeLeft = timeout;

        // 处理确认/取消逻辑 (重点：直接复用自身的 message 方法)
        const handleResult = (type) => {
          clearInterval(this.itv); // 1. 停止倒计时 (不要调用 this._clearState())

          this.resolveActive = null; // 2. 核心修复：解除绑定，防止被后续的 _clearState 误杀

          let isSuccess = false;
          let resultMsg = "";

          if (type === 'ok') { resultMsg = msgOk; isSuccess = true; }
          else if (type === 'cancel') { resultMsg = msgCancel; isSuccess = false; }
          else if (type === 'timeout') { resultMsg = msgTimeout; isSuccess = true; }

          // 3. 调用 message 时，它内部的 _clearState 就不会影响当前的 resolve 了
          this.message({ text: resultMsg, type: type == "ok" ? "waiting" : "fail", duration: 1500, timeout: 0 })
            .then(() => resolve(isSuccess));
        };

        this.itv = setInterval(() => {
          timeLeft--;
          if (timeLeft <= 0) handleResult('timeout');
          else if (timerText) timerText.innerText = `${timeLeft}s`;
        }, 1000);

        if (btnOk) btnOk.onclick = () => handleResult('ok');
        if (btnCancel) btnCancel.onclick = () => handleResult('cancel');
      });
    }
  }

  // 导出单例，确保全局共用同一个弹窗实例
  const notify = new NoticeManager();

  const connector = new Connector();

  document.addEventListener("DOMContentLoaded", async () => {

    // 假设 connector 对象存在
    if (!(await connector.acquireLock())) {
      const result = await notify.confirm({
        text: `Connector: 是否连接到 ${connector.config.name}`,
        okBtnText: "连接",
        cancelBtnText: "暂不",
        msgOk: "连接中...",
        msgCancel: "未连接",
        msgTimeout: "自动连接成功",
        timeout: 5
      });
      if (result) {
        console.log("执行联动操作...");
        connector.forceAcquireLock();
        connector.isRunning = true;
        await connector.handshake();
      }
    }
  })
})();