/* BiDi probe #5 — sideloaded extension: is the content script alive, does the
   interceptor match feed fetches, does the message reach the content script? */
const ws = new WebSocket("ws://localhost:9222/session");
let seq = 0;
const pending = new Map();
const events = [];
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

function send(method, params = {}, sessionId = null, timeoutMs = 25000) {
  const id = ++seq;
  const msg = { id, method, params };
  if (sessionId) msg.sessionId = sessionId;
  ws.send(JSON.stringify(msg));
  return new Promise((resolve, reject) => {
    const t = setTimeout(() => { pending.delete(id); reject(new Error("timeout " + method)); }, timeoutMs);
    pending.set(id, { resolve, reject, t });
  });
}
await new Promise((res, rej) => { ws.onopen = res; ws.onerror = () => rej(new Error("no ws")); });
ws.onmessage = (ev) => {
  const m = JSON.parse(ev.data);
  if (m.id && pending.has(m.id)) {
    const p = pending.get(m.id); pending.delete(m.id); clearTimeout(p.t);
    m.type === "success" ? p.resolve(m.result) : p.reject(new Error(JSON.stringify(m.error)));
  } else if (m.type === "event") {
    events.push(m);
  }
};

const { sessionId } = await send("session.new", { capabilities: {} });
await send("session.subscribe", { events: ["log.entryAdded"] }, sessionId).catch(() => {});
const tree = await send("browsingContext.getTree", {}, sessionId);
let ctx = tree.contexts.find((c) => (c.url || "").includes("bsky.app"));
if (!ctx) {
  ctx = await send("browsingContext.create", { type: "tab" }, sessionId);
  console.log("created tab", ctx.context);
}
await send("browsingContext.navigate", { context: ctx.context, url: "https://bsky.app/" }, sessionId).catch((e) => console.log("nav err:", e.message));
console.log("navigated, waiting for load…");
await sleep(20000);

async function val(expression) {
  try {
    const r = await send("script.evaluate", { expression, target: { context: ctx.context }, awaitPromise: true, resultOwnership: "none" }, sessionId);
    if (!r || !r.result) return "NO-RESULT";
    return "value" in r.result ? String(r.result.value) : JSON.stringify(r.result);
  } catch (e) { return "ERR:" + e.message; }
}

console.log("url:           ", await val("location.href"));
console.log("interceptor:   ", await val("String(!!window.__suxInterceptor)"));
console.log("diag:          ", await val("window.__suxDiag ? JSON.stringify(window.__suxDiag) : 'NONE'"));
console.log("anchors:       ", await val("document.querySelectorAll('a[href*=\"/post/\"]').length"));

await sleep(2000);
console.log("--- console (sux lines) ---");
events
  .filter((e) => e.method === "log.entryAdded")
  .map((e) => e.params)
  .filter((p) => p.text && p.text.toLowerCase().includes("sux"))
  .forEach((p) => console.log(`[${p.level}] ${p.text}`));
try { await send("session.end", {}, sessionId, 5000); } catch {}
ws.close();
process.exit(0);