javascript:(function(){var s=document.createElement('script');s.src='http://localhost:9100/bridge.js?t='+Date.now();document.head.appendChild(s)})()

const http = require('http');
const fs = require('fs');
const path = require('path');
const WebSocket = require('ws');

const REST_PORT = 9100;
const WS_PORT = 9101;

let browserWs = null;
let cmdId = 0;
const pending = new Map();

const wss = new WebSocket.Server({ port: WS_PORT });
wss.on('connection', (ws) => {
  browserWs = ws;
  console.log('browser connected');
  ws.on('message', (raw) => {
    try {
      const msg = JSON.parse(raw.toString());
      if (msg.type === 'result' && pending.has(msg.id)) {
        const { resolve, reject, timer } = pending.get(msg.id);
        clearTimeout(timer);
        pending.delete(msg.id);
        msg.status === 'error'
          ? reject(new Error(msg.error || 'unknown'))
          : resolve(msg.result);
      }
    } catch {}
  });
  ws.on('close', () => {
    if (ws === browserWs) browserWs = null;
  });
});

function sendCommand(command, params = {}, timeout = 60000) {
  return new Promise((resolve, reject) => {
    if (!browserWs || browserWs.readyState !== WebSocket.OPEN) {
      return reject(new Error('NO_BROWSER: 请打开目标页并点击书签'));
    }
    const id = ++cmdId;
    const timer = setTimeout(() => {
      pending.delete(id);
      reject(new Error('TIMEOUT'));
    }, timeout);
    pending.set(id, { resolve, reject, timer });
    browserWs.send(JSON.stringify({ id, command, params }));
  });
}

function json(res, data, status = 200) {
  res.writeHead(status, {
    'Content-Type': 'application/json',
    'Access-Control-Allow-Origin': '*',
  });
  res.end(JSON.stringify(data));
}

const server = http.createServer(async (req, res) => {
  const url = new URL(req.url, `http://localhost:${REST_PORT}`);
  const p = url.pathname;

  if (req.method === 'OPTIONS') {
    res.writeHead(204, {
      'Access-Control-Allow-Origin': '*',
      'Access-Control-Allow-Methods': 'GET,POST,OPTIONS',
      'Access-Control-Allow-Headers': 'Content-Type',
    });
    return res.end();
  }

  try {
    if (p === '/api/status') {
      return json(res, { ok: true, browser: browserWs !== null });
    }
    if (p === '/api/ping') {
      return json(res, await sendCommand('ping', {}));
    }
    // 在此按业务加 REST → sendCommand(...)
  } catch (e) {
    return json(
      res,
      { error: e.message },
      e.message.startsWith('NO_BROWSER') ? 503 : 500
    );
  }

  // 静态提供 bridge.js
  const file = path.join(__dirname, p === '/' ? 'bridge.js' : p.split('?')[0]);
  try {
    const data = fs.readFileSync(file);
    res.writeHead(200, {
      'Content-Type': 'application/javascript',
      'Access-Control-Allow-Origin': '*',
    });
    res.end(data);
  } catch {
    res.writeHead(404);
    res.end('Not found');
  }
});

server.listen(REST_PORT, () => {
  console.log(`REST  http://localhost:${REST_PORT}`);
  console.log(`WS    ws://localhost:${WS_PORT}`);
});

;(function () {
  'use strict';
  if (window.__genericBridgeReady) return;
  window.__genericBridgeReady = true;

  const BASE = location.origin; // 目标站同源
  const WS_URL = 'ws://localhost:9101';

  async function api(path, opts = {}) {
    const res = await fetch(BASE + path, {
      credentials: 'include', // 带上当前登录 cookie
      headers: {
        'Content-Type': 'application/json',
        Accept: 'application/json',
        ...(opts.headers || {}),
      },
      ...opts,
    });
    if (res.status === 401 || res.status === 403) {
      throw new Error('认证失败，请重新登录目标站');
    }
    if (!res.ok) {
      const text = await res.text().catch(() => '');
      throw new Error(`HTTP ${res.status}: ${text.slice(0, 200)}`);
    }
    const text = await res.text().catch(() => '');
    if (!text) return {};
    try {
      return JSON.parse(text);
    } catch {
      return { raw: text };
    }
  }

  function connect() {
    const ws = new WebSocket(WS_URL);
    ws.onopen = () => console.log('[bridge] connected');
    ws.onclose = () => setTimeout(connect, 3000); // 断线重连
    ws.onmessage = async (e) => {
      try {
        const { id, command, params } = JSON.parse(e.data);
        let result;
        try {
          switch (command) {
            case 'ping':
              result = { pong: true, portal: location.origin };
              break;
            // case 'yourCommand':
            //   result = await api('/your/api/path', { method: 'GET' });
            //   break;
            default:
              throw new Error('Unknown command: ' + command);
          }
          ws.send(JSON.stringify({ id, type: 'result', status: 'ok', result }));
        } catch (err) {
          ws.send(
            JSON.stringify({
              id,
              type: 'result',
              status: 'error',
              error: err.message,
            })
          );
        }
      } catch {}
    };
  }

  connect();
})();