[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_396":397,"_398":399},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",53,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","overlap.tsx","latestPath","fileId","0772291c-b241-11f1-ba18-1607ee4eb77e","name","fileType","http","content","import { collectSnapshot } from \"./confluence.tsx\";\nimport { buildIndex, fetchKalshiMarkets, matchOne, shortlist } from \"./matcher.ts\";\nimport { defaultProvider, hasAnthropicKey, judge, type Provider } from \"./llm-match.ts\";\n\n// Executability + venue comparison (the VALUE pillar).\n//\n// Two tiers:\n// 1. DETERMINISTIC (matcher.ts) — scans ~27k Kalshi markets for free, applies\n// hard contradiction guards, produces a candidate shortlist.\n// 2. LLM JUDGE (llm-match.ts) — classifies the relationship as\n// same / nested / proxy / unrelated, and reports side alignment.\n// Provider: \"valtown\" (built-in proxy, free, no key, ~10 req/min) or\n// \"anthropic\" (Haiku, needs ANTHROPIC_API_KEY). `?provider=` to A/B them.\n//\n// The relationship is GRADED on purpose: a Kalshi market that isn't identical\n// can still inform the decision. \"same\" and \"nested\" get a real side-aligned\n// price gap; \"proxy\" is corroboration only and deliberately carries NO gap.\n//\n// Any model failure falls back to deterministic-only matching for that row.\n//\n// Params: ?cat= &top= &llm=0 &provider=valtown|anthropic &fresh=1 &conc=\n\nasync function mapPool(items: T[], limit: number, fn: (x: T) => Promise): Promise {\n const out: R[] = new Array(items.length);\n let i = 0;\n const workers = Array.from({ length: Math.max(1, Math.min(limit, items.length)) }, async () => {\n while (true) {\n const idx = i++;\n if (idx >= items.length) return;\n out[idx] = await fn(items[idx]);\n }\n });\n await Promise.all(workers);\n return out;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const top = Number(url.searchParams.get(\"top\") ?? 12);\n const cat = url.searchParams.get(\"cat\") ?? \"ECONOMICS\";\n const useLlm = url.searchParams.get(\"llm\") !== \"0\";\n const fresh = url.searchParams.get(\"fresh\") === \"1\"; // bypass the judgment cache\n const conc = Number(url.searchParams.get(\"conc\") ?? 3); // keep under the proxy rate limit\n const pv = url.searchParams.get(\"provider\");\n const provider: Provider = pv === \"anthropic\" || pv === \"valtown\" ? pv : defaultProvider();\n\n const [snap, kf] = await Promise.all([\n collectSnapshot(new URL(`https://x/?cat=${cat}&top=${Math.max(top, 8)}&dust=500`)),\n fetchKalshiMarkets(15),\n ]);\n const kmarkets = kf.markets;\n\n // Never let a failed catalog fetch masquerade as \"nothing matched\".\n if (kmarkets.length === 0) {\n return Response.json({\n category: cat,\n ok: false,\n error: \"Kalshi catalog unavailable — no matching attempted\",\n kalshiFetchError: kf.error,\n pagesFetched: kf.pagesFetched,\n hint: \"Kalshi rate-limits heavy paging. Wait a minute and retry.\",\n }, { status: 503 });\n }\n\n const rows = (snap.confluence as any[]).slice(0, top);\n\n const results = await mapPool(rows, conc, async (c: any) => {\n const polyCents = typeof c.currentPrice === \"number\" ? c.currentPrice : null;\n const sideIsYes = String(c.side ?? \"\").toLowerCase() === \"yes\";\n const cands = shortlist(c.market, kmarkets, 5);\n\n let k: any = null;\n let relation = \"unrelated\";\n let confidence: number | null = null;\n let aligned: boolean | null = null;\n let reason = \"\";\n let tier = \"deterministic\";\n let cached = false;\n\n const v = useLlm ? await judge(c.market, cands, { useCache: !fresh, provider }) : null;\n if (v) {\n tier = `llm:${v.provider}`;\n cached = Boolean(v.cached);\n relation = v.relation;\n confidence = v.confidence;\n aligned = v.aligned;\n reason = v.reason;\n if (v.best != null && v.relation !== \"unrelated\") k = cands[v.best - 1];\n } else {\n // Fallback: a strict deterministic match implies the same question.\n const m = matchOne(c.market, kmarkets, 0.5);\n if (m.ok && m.k) {\n k = m.k;\n relation = \"same\";\n confidence = m.score;\n reason = \"deterministic strict match\";\n } else {\n reason = m.reason;\n }\n }\n\n // Price gap, side-aligned. Only meaningful for same/nested — a proxy market\n // is a different question, so a literal gap would mislead.\n let kalshiSideCents: number | null = null;\n let gapCents: number | null = null;\n if (k && (relation === \"same\" || relation === \"nested\")) {\n const useKalshiYes = aligned === false ? !sideIsYes : sideIsYes;\n kalshiSideCents = +((useKalshiYes ? k.yesAsk : k.noAsk) * 100).toFixed(1);\n if (polyCents != null) gapCents = +(polyCents - kalshiSideCents).toFixed(1);\n }\n\n return {\n market: c.market,\n side: c.side,\n holders: c.holders,\n coHold: c.coHold,\n polyCents,\n relation,\n confidence,\n aligned,\n tier,\n cached,\n reason,\n candidatesConsidered: cands.length,\n kalshiEvent: k ? k.text : null,\n kalshiTicker: k ? k.ticker : null,\n kalshiYesCents: k ? +(k.yesAsk * 100).toFixed(1) : null,\n kalshiNoCents: k ? +(k.noAsk * 100).toFixed(1) : null,\n kalshiSideCents,\n kalshiVol: k ? k.vol : null,\n gapCents,\n };\n });\n\n const tally = (r: string) => results.filter((x) => x.relation === r).length;\n const llmRows = results.filter((x) => x.tier.startsWith(\"llm\")).length;\n return Response.json({\n category: cat,\n provider: useLlm ? provider : \"off (llm=0)\",\n anthropicKey: hasAnthropicKey(),\n llmJudgedRows: llmRows,\n deterministicFallbackRows: results.length - llmRows,\n kalshiMarketsScanned: kmarkets.length,\n kalshiCatalogComplete: kf.error === null,\n kalshiFetchError: kf.error,\n topConfluenceChecked: results.length,\n same: tally(\"same\"),\n nested: tally(\"nested\"),\n proxy: tally(\"proxy\"),\n unrelated: tally(\"unrelated\"),\n note:\n \"relation: same = economically equivalent (tradeable 1:1) | nested = sub-option/threshold of the same question (directly informative) | \" +\n \"proxy = correlated but different question (corroboration only, no gap shown) | unrelated = dropped. \" +\n \"gapCents = polyCents - kalshiSideCents, side-aligned; positive = the confluence side is cheaper on Kalshi than the informed Polymarket price. \" +\n \"Confirm liquidity and exact resolution before acting.\",\n results,\n });\n}\n","import { collectSnapshot } from \"./confluence.tsx\";\nimport { buildIndex, fetchKalshiMarkets, matchOne, shortlist } from \"./matcher.ts\";\nimport { defaultProvider, hasAnthropicKey, judge, type Provider } from \"./llm-match.ts\";\n\n// Executability + venue comparison (the VALUE pillar).\n//\n// Two tiers:\n// 1. DETERMINISTIC (matcher.ts) — scans ~27k Kalshi markets for free, applies\n// hard contradiction guards, produces a candidate shortlist.\n// 2. LLM JUDGE (llm-match.ts) — classifies the relationship as\n// same / nested / proxy / unrelated, and reports side alignment.\n// Provider: \"valtown\" (built-in proxy, free, no key, ~10 req/min) or\n// \"anthropic\" (Haiku, needs ANTHROPIC_API_KEY). `?provider=` to A/B them.\n//\n// The relationship is GRADED on purpose: a Kalshi market that isn't identical\n// can still inform the decision. \"same\" and \"nested\" get a real side-aligned\n// price gap; \"proxy\" is corroboration only and deliberately carries NO gap.\n//\n// Any model failure falls back to deterministic-only matching for that row.\n//\n// Params: ?cat= &top= &llm=0 &provider=valtown|anthropic &fresh=1 &conc=\n\nasync function mapPool(items: T[], limit: number, fn: (x: T) => Promise): Promise {\n const out: R[] = new Array(items.length);\n let i = 0;\n const workers = Array.from({ length: Math.max(1, Math.min(limit, items.length)) }, async () => {\n while (true) {\n const idx = i++;\n if (idx >= items.length) return;\n out[idx] = await fn(items[idx]);\n }\n });\n await Promise.all(workers);\n return out;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const top = Number(url.searchParams.get(\"top\") ?? 12);\n const cat = url.searchParams.get(\"cat\") ?? \"ECONOMICS\";\n const useLlm = url.searchParams.get(\"llm\") !== \"0\";\n const fresh = url.searchParams.get(\"fresh\") === \"1\"; // bypass the judgment cache\n const conc = Number(url.searchParams.get(\"conc\") ?? 3); // keep under the proxy rate limit\n const pv = url.searchParams.get(\"provider\");\n const provider: Provider = pv === \"anthropic\" || pv === \"valtown\" ? pv : defaultProvider();\n\n const [snap, kf] = await Promise.all([\n collectSnapshot(new URL(`https://x/?cat=${cat}&top=${Math.max(top, 8)}&dust=500`)),\n fetchKalshiMarkets(15),\n ]);\n const kmarkets = kf.markets;\n\n // Never let a failed catalog fetch masquerade as \"nothing matched\".\n if (kmarkets.length === 0) {\n return Response.json({\n category: cat,\n ok: false,\n error: \"Kalshi catalog unavailable — no matching attempted\",\n kalshiFetchError: kf.error,\n pagesFetched: kf.pagesFetched,\n hint: \"Kalshi rate-limits heavy paging. Wait a minute and retry.\",\n }, { status: 503 });\n }\n\n const index = buildIndex(kmarkets);\n const rows = (snap.confluence as any[]).slice(0, top);\n\n const results = await mapPool(rows, conc, async (c: any) => {\n const polyCents = typeof c.currentPrice === \"number\" ? c.currentPrice : null;\n const sideIsYes = String(c.side ?? \"\").toLowerCase() === \"yes\";\n const cands = shortlist(c.market, kmarkets, 5);\n\n let k: any = null;\n let relation = \"unrelated\";\n let confidence: number | null = null;\n let aligned: boolean | null = null;\n let reason = \"\";\n let tier = \"deterministic\";\n let cached = false;\n\n const v = useLlm ? await judge(c.market, cands, { useCache: !fresh, provider }) : null;\n if (v) {\n tier = `llm:${v.provider}`;\n cached = Boolean(v.cached);\n relation = v.relation;\n confidence = v.confidence;\n aligned = v.aligned;\n reason = v.reason;\n if (v.best != null && v.relation !== \"unrelated\") k = cands[v.best - 1];\n } else {\n // Fallback: a strict deterministic match implies the same question.\n const m = matchOne(c.market, kmarkets, 0.5);\n if (m.ok && m.k) {\n k = m.k;\n relation = \"same\";\n confidence = m.score;\n reason = \"deterministic strict match\";\n } else {\n reason = m.reason;\n }\n }\n\n // Price gap, side-aligned. Only meaningful for same/nested — a proxy market\n // is a different question, so a literal gap would mislead.\n let kalshiSideCents: number | null = null;\n let gapCents: number | null = null;\n if (k && (relation === \"same\" || relation === \"nested\")) {\n const useKalshiYes = aligned === false ? !sideIsYes : sideIsYes;\n kalshiSideCents = +((useKalshiYes ? k.yesAsk : k.noAsk) * 100).toFixed(1);\n if (polyCents != null) gapCents = +(polyCents - kalshiSideCents).toFixed(1);\n }\n\n return {\n market: c.market,\n side: c.side,\n holders: c.holders,\n coHold: c.coHold,\n polyCents,\n relation,\n confidence,\n aligned,\n tier,\n cached,\n reason,\n candidatesConsidered: cands.length,\n kalshiEvent: k ? k.text : null,\n kalshiTicker: k ? k.ticker : null,\n kalshiYesCents: k ? +(k.yesAsk * 100).toFixed(1) : null,\n kalshiNoCents: k ? +(k.noAsk * 100).toFixed(1) : null,\n kalshiSideCents,\n kalshiVol: k ? k.vol : null,\n gapCents,\n };\n });\n\n const tally = (r: string) => results.filter((x) => x.relation === r).length;\n const llmRows = results.filter((x) => x.tier.startsWith(\"llm\")).length;\n return Response.json({\n category: cat,\n provider: useLlm ? provider : \"off (llm=0)\",\n anthropicKey: hasAnthropicKey(),\n llmJudgedRows: llmRows,\n deterministicFallbackRows: results.length - llmRows,\n kalshiMarketsScanned: kmarkets.length,\n kalshiCatalogComplete: kf.error === null,\n kalshiFetchError: kf.error,\n topConfluenceChecked: results.length,\n same: tally(\"same\"),\n nested: tally(\"nested\"),\n proxy: tally(\"proxy\"),\n unrelated: tally(\"unrelated\"),\n note:\n \"relation: same = economically equivalent (tradeable 1:1) | nested = sub-option/threshold of the same question (directly informative) | \" +\n \"proxy = correlated but different question (corroboration only, no gap shown) | unrelated = dropped. \" +\n \"gapCents = polyCents - kalshiSideCents, side-aligned; positive = the confluence side is cheaper on Kalshi than the informed Polymarket price. \" +\n \"Confirm liquidity and exact resolution before acting.\",\n results,\n });\n}\n","createdAt",["D",1789623414648],"branchVersion","branchId","f1c2802b-7a05-402a-8e59-0a360e509b53","id","7b98160e-759a-451e-ac63-bac16ce91a02","predmarket-monitor",["D",1789595019450],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Live Kalshi/Polymarket arbitrage monitor (detect-only)","imageUrl","5a6bd924-f7ef-46ed-95a2-11ef633bd193","pinnedFileId","01a0ac2c-e909-715a-acf6-adfd5fd204b2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0ac28-941c-777f-a124-9765c1807b9c","tursoName","7b98160e759a451eac63bac16ce91a02","tursoHostname","7b98160e759a451eac63bac16ce91a02-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789596070409],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",60,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","joaquinrubio","handle","displayName","Joaquin Rubio","avatar","https://lh3.googleusercontent.com/a/ACg8ocKu9e2FTAA0T_eao8qJSdToUv1ioGcVQUV0-zlGd4zBo0YpRA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":391,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":392,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":393,"_84":394,"_86":395,"_88":25},"tree",[306,307,308,309,310,311,312,313,314,315,316,317,318,319,320,321,322,323,324,325,326],"files",[306,307,308,309,310,311,312,313,314,315,316,317,318,319,320,321,322,323,324,325,326],"counts",{"_296":63,"_297":173,"_298":63,"_299":300,"_301":302},"contents",[131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":290,"_32":291,"_30":292,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":293,"_13":63,"_33":20,"_35":294,"_24":25,"_161":-5,"_27":295},{"_43":283,"_32":284,"_30":285,"_155":-5,"_41":42,"_40":286,"_157":59,"_38":287,"_13":197,"_33":34,"_35":288,"_24":25,"_161":-5,"_27":289},{"_43":276,"_32":277,"_30":278,"_155":-5,"_41":42,"_40":279,"_157":59,"_38":280,"_13":63,"_33":182,"_35":281,"_24":25,"_161":-5,"_27":282},{"_43":269,"_32":270,"_30":271,"_155":-5,"_41":42,"_40":272,"_157":59,"_38":273,"_13":173,"_33":198,"_35":274,"_24":25,"_161":-5,"_27":275},{"_43":262,"_32":263,"_30":264,"_155":-5,"_41":42,"_40":265,"_157":59,"_38":266,"_13":173,"_33":34,"_35":267,"_24":25,"_161":-5,"_27":268},{"_43":256,"_32":257,"_30":258,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":259,"_13":63,"_33":20,"_35":260,"_24":25,"_161":-5,"_27":261},{"_43":250,"_32":251,"_30":252,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":253,"_13":63,"_33":20,"_35":254,"_24":25,"_161":-5,"_27":255},{"_43":244,"_32":245,"_30":246,"_155":-5,"_41":42,"_40":159,"_157":59,"_38":247,"_13":63,"_33":198,"_35":248,"_24":25,"_161":-5,"_27":249},{"_43":237,"_32":238,"_30":239,"_155":-5,"_41":42,"_40":240,"_157":59,"_38":241,"_13":173,"_33":198,"_35":242,"_24":25,"_161":-5,"_27":243},{"_43":232,"_32":233,"_30":57,"_155":-5,"_41":42,"_40":197,"_157":59,"_38":234,"_13":173,"_33":34,"_35":235,"_24":25,"_161":-5,"_27":236},{"_43":225,"_32":226,"_30":227,"_155":-5,"_41":42,"_40":228,"_157":25,"_38":229,"_13":188,"_33":198,"_35":230,"_24":25,"_161":-5,"_27":231},{"_43":221,"_32":28,"_30":31,"_155":-5,"_41":42,"_40":14,"_157":25,"_38":222,"_13":223,"_33":34,"_35":37,"_24":25,"_161":-5,"_27":224},{"_43":214,"_32":215,"_30":216,"_155":-5,"_41":42,"_40":217,"_157":59,"_38":218,"_13":173,"_33":182,"_35":219,"_24":25,"_161":-5,"_27":220},{"_43":207,"_32":208,"_30":209,"_155":-5,"_41":42,"_40":210,"_157":59,"_38":211,"_13":159,"_33":34,"_35":212,"_24":25,"_161":-5,"_27":213},{"_43":201,"_32":202,"_30":203,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":204,"_13":63,"_33":198,"_35":205,"_24":25,"_161":-5,"_27":206},{"_43":192,"_32":193,"_30":194,"_155":-5,"_41":42,"_40":195,"_157":59,"_38":196,"_13":197,"_33":198,"_35":199,"_24":25,"_161":-5,"_27":200},{"_43":185,"_32":186,"_30":187,"_155":-5,"_41":42,"_40":188,"_157":59,"_38":189,"_13":173,"_33":34,"_35":190,"_24":25,"_161":-5,"_27":191},{"_43":177,"_32":178,"_30":179,"_155":-5,"_41":42,"_40":180,"_157":59,"_38":181,"_13":159,"_33":182,"_35":183,"_24":25,"_161":-5,"_27":184},{"_43":170,"_32":171,"_30":172,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":174,"_13":63,"_33":20,"_35":175,"_24":25,"_161":-5,"_27":176},{"_43":163,"_32":164,"_30":165,"_155":-5,"_41":42,"_40":166,"_157":59,"_38":167,"_13":63,"_33":34,"_35":168,"_24":25,"_161":-5,"_27":169},{"_43":152,"_32":153,"_30":154,"_155":-5,"_41":42,"_40":156,"_157":59,"_38":158,"_13":159,"_33":34,"_35":160,"_24":25,"_161":-5,"_27":162},"9c1ac5f4-fdbe-4b98-b542-c62a3957adba","winloss.tsx","f113fe64-b224-11f1-8d96-1607ee4eb77e","parentId",13,"latest",["D",1789602419939],2,"import { leaderboard, reconstruct } from \"./smartmoney.ts\";\n\nfunction money(n: number) {\n const a = Math.abs(n);\n if (a >= 1e6) return `$${(n / 1e6).toFixed(2)}M`;\n if (a >= 1e3) return `$${(n / 1e3).toFixed(1)}K`;\n return `$${n.toFixed(0)}`;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const days = Number(url.searchParams.get(\"days\") ?? \"45\");\n const wallet = url.searchParams.get(\"wallet\");\n\n // Single-wallet detail mode: validate one trader deeply.\n if (wallet) {\n const r = await reconstruct(wallet, { sinceDays: days, maxPages: 40 });\n return Response.json({\n ...r,\n realizedWindowFmt: money(r.realizedWindow),\n topMarkets: r.topMarkets.map((m) => ({ ...m, realized: money(m.realized) })),\n });\n }\n\n // Shortlist mode: rank RECENTLY-ACTIVE politics traders (month board) by\n // recent-window win rate. Sequential to stay under rate limits.\n const minDecided = Number(url.searchParams.get(\"min\") ?? \"8\");\n const top = Number(url.searchParams.get(\"top\") ?? \"8\");\n const board = await leaderboard(\"POLITICS\", 1, \"MONTH\");\n const cands = board.slice(0, top);\n\n const rows: any[] = [];\n for (const c of cands) {\n try {\n const r = await reconstruct(c.proxyWallet, { sinceDays: days, maxPages: 30 });\n rows.push({\n name: c.userName || c.proxyWallet.slice(0, 10),\n monthPnl: money(c.pnl),\n decided: r.decidedMarkets,\n wins: r.wins,\n losses: r.losses,\n winRatePct: +(r.winRate * 100).toFixed(1),\n realizedWindow: money(r.realizedWindow),\n excluded: { open: r.openSkipped, spanning: r.spanning, complex: r.complexSkipped },\n coverage: r.coverageNote,\n });\n } catch (e) {\n rows.push({ name: c.userName, error: String(e) });\n }\n }\n const ranked = rows\n .filter((r) => !r.error && r.decided >= minDecided)\n .sort((a, b) => b.winRatePct - a.winRatePct);\n\n return Response.json({\n params: { windowDays: days, minDecided, source: \"POLITICS month leaderboard\" },\n leaderByWinRate: ranked[0]?.name ?? null,\n ranked,\n all: rows,\n });\n}\n","label",[153],"39a2628e-96da-42fb-b73b-e4df9be19241","vet.tsx","aac4dd02-b229-11f1-bcc0-1607ee4eb77e",14,["D",1789602745352],"import { leaderboard } from \"./smartmoney.ts\";\n\nconst DATA = \"https://data-api.polymarket.com\";\n\ntype Row = { proxyWallet: string; userName: string; pnl: number; vol: number };\n\nasync function walletWindow(category: string, timePeriod: string, wallet: string): Promise {\n const r = await fetch(`${DATA}/v1/leaderboard?category=${category}&timePeriod=${timePeriod}&user=${wallet}`);\n if (!r.ok) return null;\n const rows = (await r.json()) as Row[];\n return rows[0] ?? null;\n}\n\nfunction money(n: number) {\n const a = Math.abs(n);\n if (a >= 1e6) return `$${(n / 1e6).toFixed(2)}M`;\n if (a >= 1e3) return `$${(n / 1e3).toFixed(1)}K`;\n return `$${n.toFixed(0)}`;\n}\nconst eff = (r: { pnl: number; vol: number }) => (r.vol > 0 ? r.pnl / r.vol : 0);\n\n// Vet currently-active politics traders using Polymarket's OWN authoritative\n// P&L across time windows. Skill proxy = consistently profitable (this month AND\n// all-time) with real volume, ranked by all-time efficiency (return per $ traded).\n// No fragile negRisk reconstruction; we trust the venue's computed numbers.\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const top = Number(url.searchParams.get(\"top\") ?? \"15\");\n const minAllVol = Number(url.searchParams.get(\"minvol\") ?? \"250000\");\n const cat = url.searchParams.get(\"cat\") ?? \"POLITICS\";\n\n const month = await leaderboard(cat, 1, \"MONTH\"); // active now\n const cands = month.slice(0, top);\n\n const rows: any[] = [];\n for (const c of cands) {\n const all = await walletWindow(cat, \"ALL\", c.proxyWallet);\n const week = await walletWindow(cat, \"WEEK\", c.proxyWallet);\n const consistent = !!all && all.pnl > 0 && c.pnl > 0;\n rows.push({\n name: c.userName || c.proxyWallet.slice(0, 10),\n wallet: c.proxyWallet,\n week: week ? { pnl: money(week.pnl), effPct: +(eff(week) * 100).toFixed(1) } : null,\n month: { pnl: money(c.pnl), effPct: +(eff(c) * 100).toFixed(1) },\n allTime: all ? { pnl: money(all.pnl), vol: money(all.vol), effPct: +(eff(all) * 100).toFixed(1), rawVol: all.vol, rawEff: eff(all) } : null,\n consistent,\n });\n }\n\n const ranked = rows\n .filter((r) => r.consistent && r.allTime && r.allTime.rawVol >= minAllVol)\n .sort((a, b) => b.allTime.rawEff - a.allTime.rawEff)\n .map(({ allTime, ...r }) => ({ ...r, allTime: { pnl: allTime.pnl, vol: allTime.vol, effPct: allTime.effPct } }));\n\n return Response.json({\n params: { category: cat, activeFrom: \"MONTH board\", minAllVol, ranked: ranked.length, of: rows.length },\n note: \"Ranked: currently active + profitable this month AND all-time, real volume, by all-time efficiency. Polymarket's own P&L; no reconstruction.\",\n vetted: ranked,\n });\n}\n",[164],"4b37291a-f047-460e-9713-84fb7c2c5057","style.css","01a0ac2c-e909-715a-acf6-b5799b58f170",1,["D",1789595019450],"/* CSS files add styling rules to your content */\n\nbody {\n font-family: Arial, sans-serif;\n margin: 2em;\n}\n\nh1 {\n font-style: italic;\n color: #373fff;\n}",[171],"7c19f8f8-3f6c-47b2-9229-c7bf6da36416","snapshot.ts","48abc34e-b240-11f1-ac31-1607ee4eb77e",27,["D",1789613287298],"interval","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { collectSnapshot } from \"./confluence.tsx\";\n\n// Backtest data collector. Every few hours it records the current confluence\n// signals so that later we can score them against how the markets resolved:\n// \"if you had followed these, would you have made money?\" This is the go/no-go\n// evidence base — it only accrues over time, so we start it now.\n// Log both: POLITICS (mostly foreign elections, untradeable on Kalshi — kept as a\n// control) and ECONOMICS (US macro: Fed, midterms, IPOs — Kalshi-tradeable). The\n// backtest can then compare whether the tradeable lane's signal actually pays.\nconst CATEGORIES = [\"POLITICS\", \"ECONOMICS\"];\n\nexport default async function () {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS confluence_log (\n ts TEXT, category TEXT, complete INTEGER, vetted INTEGER,\n asset TEXT, conditionId TEXT, market TEXT, side TEXT, endDate TEXT,\n holders INTEGER, minConviction REAL, coHold INTEGER,\n price REAL, exposure REAL, who TEXT\n )`);\n for (const cat of CATEGORIES) {\n const snap = await collectSnapshot(new URL(`https://x/?cat=${cat}&top=8&dust=500`));\n for (const c of snap.confluence as any[]) {\n await sqlite.execute({\n sql: `INSERT INTO confluence_log\n (ts,category,complete,vetted,asset,conditionId,market,side,endDate,holders,minConviction,coHold,price,exposure,who)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [snap.completedAt, cat, snap.complete ? 1 : 0, snap.params.vettedTraders,\n c.asset, c.conditionId, c.market, c.side, c.endDate, c.holders,\n c.minConvictionPct, c.coHold, c.currentPrice, c.totalExposureValue, c.who.join(\" | \")],\n });\n }\n console.log(`logged ${cat}: ${snap.confluence.length} signals (complete=${snap.complete}, vetted=${snap.params.vettedTraders})`);\n }\n}\n",[178],"5cee6815-1091-4677-ad37-79652a513134","smartmoney_http.tsx","a4a49238-b21e-11f1-873d-1607ee4eb77e",8,["D",1789598025051],"import { analyze } from \"./smartmoney.ts\";\n\nfunction eff(r: { pnl: number; vol: number }) {\n return r.vol > 0 ? r.pnl / r.vol : 0;\n}\nfunction money(n: number) {\n const a = Math.abs(n);\n if (a >= 1e9) return `$${(n / 1e9).toFixed(2)}B`;\n if (a >= 1e6) return `$${(n / 1e6).toFixed(2)}M`;\n if (a >= 1e3) return `$${(n / 1e3).toFixed(1)}K`;\n return `$${n.toFixed(0)}`;\n}\n\nexport default async function (req: Request): Promise {\n const cats = [\"OVERALL\", \"POLITICS\"];\n const out: any = {};\n for (const c of cats) {\n const a = await analyze(c);\n const shape = (r: any) => ({\n name: r.userName || r.proxyWallet.slice(0, 10),\n wallet: r.proxyWallet,\n pnl: money(r.pnl),\n vol: money(r.vol),\n effPct: +(eff(r) * 100).toFixed(2),\n });\n out[c] = {\n pulled: a.count,\n byRawPnl: a.byPnl.slice(0, 8).map(shape),\n byEfficiency: a.byEff.slice(0, 8).map(shape),\n };\n }\n return Response.json(out);\n}\n",[186],"a26eaad1-02b3-4f2d-80e7-3ed5909e74a1","smartmoney.ts","82953332-b21e-11f1-afc2-1607ee4eb77e",12,["D",1789602393690],3,"script","// Smart-money signal engine — module 1.\n// Detect-only. Reads Polymarket's PUBLIC data API (global, on-chain).\n// v2: recent-window win/loss reconstruction (paged one wallet at a time,\n// rate-limit aware), so numbers are trustworthy and reflect CURRENT form —\n// which is what a live-following signal needs. Lifetime reconstruction of\n// high-volume wallets is thousands of paged events + rate limits; a bounded\n// recent window sidesteps that and is the right question anyway.\n\nconst DATA = \"https://data-api.polymarket.com\";\n\ntype Row = {\n rank: string;\n proxyWallet: string;\n userName: string;\n pnl: number;\n vol: number;\n};\n\nexport async function leaderboard(\n category: string,\n pages = 2,\n timePeriod = \"ALL\",\n): Promise {\n const out: Row[] = [];\n for (let p = 0; p < pages; p++) {\n const url =\n `${DATA}/v1/leaderboard?category=${category}&timePeriod=${timePeriod}` +\n `&orderBy=PNL&limit=50&offset=${p * 50}`;\n const r = await fetch(url);\n if (!r.ok) break;\n const rows = (await r.json()) as Row[];\n if (!rows.length) break;\n out.push(...rows);\n }\n return out;\n}\n\nfunction eff(r: Row): number {\n return r.vol > 0 ? r.pnl / r.vol : 0;\n}\n\nexport async function analyze(category: string, minVol = 250_000) {\n const rows = await leaderboard(category);\n const byPnl = [...rows].sort((a, b) => b.pnl - a.pnl);\n const eligible = rows.filter((r) => r.vol >= minVol && r.pnl > 0);\n const byEff = [...eligible].sort((a, b) => eff(b) - eff(a));\n return { category, count: rows.length, byPnl, byEff };\n}\n\n// ---- recent-window win/loss reconstruction -----------------------------------\n\ntype Act = {\n type: string; // TRADE | REDEEM | MERGE | SPLIT | CONVERSION | REWARD | ...\n side: string; // BUY | SELL | \"\"\n size: number;\n usdcSize: number;\n conditionId: string;\n timestamp: number;\n title?: string;\n transactionHash?: string;\n asset?: string;\n};\n\nasync function pageActivitySince(\n wallet: string,\n cutoff: number,\n maxPages: number,\n): Promise<{ acts: Act[]; hitCutoff: boolean; rateLimited: boolean; pages: number }> {\n const acts: Act[] = [];\n const seen = new Set();\n let hitCutoff = false, rateLimited = false, pages = 0;\n for (let p = 0; p < maxPages; p++) {\n pages++;\n let r: Response;\n try {\n r = await fetch(`${DATA}/activity?user=${wallet}&limit=500&offset=${p * 500}`);\n } catch {\n rateLimited = true;\n break;\n }\n if (r.status === 429) { rateLimited = true; break; }\n if (!r.ok) break;\n const rows = (await r.json()) as Act[];\n if (!rows.length) break;\n for (const row of rows) {\n const k = `${row.transactionHash}-${row.asset}-${row.type}`;\n if (seen.has(k)) continue;\n seen.add(k);\n if (row.timestamp >= cutoff) acts.push(row);\n }\n // rows are newest-first; once the last row on a page predates the cutoff,\n // everything beyond is older too.\n if (rows[rows.length - 1].timestamp < cutoff) { hitCutoff = true; break; }\n if (rows.length < 500) break;\n await new Promise((res) => setTimeout(res, 120)); // be gentle on the API\n }\n return { acts, hitCutoff, rateLimited, pages };\n}\n\nasync function openConditions(wallet: string): Promise> {\n const open = new Set();\n for (let p = 0; p < 6; p++) {\n const r = await fetch(`${DATA}/positions?user=${wallet}&limit=500&offset=${p * 500}`);\n if (!r.ok) break;\n const rows = (await r.json()) as any[];\n if (!rows.length) break;\n for (const pos of rows) open.add(pos.conditionId);\n if (rows.length < 500) break;\n }\n return open;\n}\n\n// A market counts toward win/loss only when it is cleanly reconstructable in the\n// window: fully contained (first event >= cutoff so no buys were missed), closed\n// (no open position), and free of MERGE/SPLIT/CONVERSION events (whose share\n// accounting we don't model). Excluded markets are counted, not silently dropped.\nexport async function reconstruct(\n wallet: string,\n opts: { sinceDays?: number; maxPages?: number } = {},\n) {\n const sinceDays = opts.sinceDays ?? 45;\n const maxPages = opts.maxPages ?? 30;\n const cutoff = Math.floor(Date.now() / 1000) - sinceDays * 86400;\n\n const { acts, hitCutoff, rateLimited, pages } = await pageActivitySince(wallet, cutoff, maxPages);\n const openSet = await openConditions(wallet);\n\n type M = { buy: number; sell: number; redeem: number; first: number; last: number; complex: boolean; title: string };\n const mkt = new Map();\n for (const a of acts) {\n if (!a.conditionId) continue;\n let m = mkt.get(a.conditionId);\n if (!m) { m = { buy: 0, sell: 0, redeem: 0, first: a.timestamp, last: a.timestamp, complex: false, title: a.title || \"\" }; mkt.set(a.conditionId, m); }\n m.first = Math.min(m.first, a.timestamp);\n m.last = Math.max(m.last, a.timestamp);\n if (a.type === \"TRADE\" && a.side === \"BUY\") m.buy += a.usdcSize || 0;\n else if (a.type === \"TRADE\" && a.side === \"SELL\") m.sell += a.usdcSize || 0;\n else if (a.type === \"REDEEM\") m.redeem += a.usdcSize || 0;\n else if (a.type === \"MERGE\" || a.type === \"SPLIT\" || a.type === \"CONVERSION\") m.complex = true;\n }\n\n let wins = 0, losses = 0, scratch = 0, realized = 0;\n let openSkipped = 0, spanning = 0, complexSkipped = 0;\n const details: { title: string; realized: number; win: boolean }[] = [];\n for (const [cid, m] of mkt) {\n if (openSet.has(cid)) { openSkipped++; continue; }\n if (m.first < cutoff) { spanning++; continue; }\n if (m.complex) { complexSkipped++; continue; }\n const pnl = m.sell + m.redeem - m.buy;\n if (Math.abs(pnl) < 1) { scratch++; continue; }\n realized += pnl;\n const win = pnl > 0;\n if (win) wins++; else losses++;\n details.push({ title: m.title, realized: pnl, win });\n }\n const decided = wins + losses;\n details.sort((a, b) => Math.abs(b.realized) - Math.abs(a.realized));\n return {\n wallet, sinceDays, decidedMarkets: decided, wins, losses, scratch,\n winRate: decided ? wins / decided : 0, realizedWindow: realized,\n openSkipped, spanning, complexSkipped,\n coverageNote: hitCutoff ? \"window fully covered\" : rateLimited ? \"TRUNCATED (rate-limited)\" : \"reached page cap\",\n eventsInWindow: acts.length, pages,\n topMarkets: details.slice(0, 5),\n };\n}\n",[193],"053a1954-ce24-412f-a90b-5f8fc194f0d2","script.js","01a0ac2c-e909-715a-acf6-b3202819cddd",["D",1789595019450],"/* If you're feeling fancy you can add interactivity\n to your site with Javascript.\n Note: TypeScript won't work in this file. */\n\n// prints \"hi\" in the browser's dev tools console\nconsole.log(\"hi\");",[202],"27661edd-ad37-4b94-a0d6-087c255828b4","scorer.tsx","a1b8dd34-b243-11f1-985e-1607ee4eb77e",30,["D",1789613994930],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// BACKTEST SCORER. For each confluence signal, take the price at the moment it\n// FIRST appeared (entry), look up how that market resolved, and compute what\n// following it would have returned. Aggregate by category so we can see whether\n// the tradeable (economics / US-macro) lane actually pays vs the politics control.\n// Gross of fees; entry = observed mid price, not an executable quote (first-pass).\nconst GAMMA = \"https://gamma-api.polymarket.com\";\n\nasync function resolutions(conditionIds: string[]) {\n const out = new Map();\n for (let i = 0; i < conditionIds.length; i += 20) {\n const qs = conditionIds.slice(i, i + 20).map((c) => `condition_ids=${c}`).join(\"&\");\n const r = await fetch(`${GAMMA}/markets?${qs}&limit=100`, { signal: AbortSignal.timeout(15000) });\n if (!r.ok) continue;\n for (const m of (await r.json()) as any[]) {\n try {\n out.set(m.conditionId, {\n closed: !!m.closed,\n outcomes: JSON.parse(m.outcomes ?? \"[]\"),\n prices: JSON.parse(m.outcomePrices ?? \"[]\").map(Number),\n });\n } catch { /* skip malformed */ }\n }\n }\n return out;\n}\n\nexport default async function (req: Request): Promise {\n // entry = earliest logged row per asset (SQLite: bare columns follow MIN(ts))\n const entries = (await sqlite.execute(`\n SELECT asset, conditionId, category, market, side, endDate, holders, coHold, minConviction, price, MIN(ts) AS ts\n FROM confluence_log GROUP BY asset\n `)).rows as any[];\n\n const cids = [...new Set(entries.map((r) => String(r.conditionId)))];\n const res = await resolutions(cids);\n\n const signals = entries.map((r) => {\n const entry = Number(r.price) / 100;\n const m = res.get(String(r.conditionId));\n let status = \"unresolved\", roi: number | null = null, settled = false;\n if (m && m.outcomes.length) {\n const idx = m.outcomes.findIndex((o) => o.toLowerCase() === String(r.side).toLowerCase());\n if (idx >= 0 && Number.isFinite(m.prices[idx])) {\n const p = m.prices[idx];\n const past = new Date(r.endDate).getTime() < Date.now();\n let won: boolean | null = null;\n if (m.closed) { won = p >= 0.5; settled = true; } // official settlement\n else if (past && p >= 0.9) won = true; // date passed + price decided\n else if (past && p <= 0.1) won = false;\n if (won !== null) {\n status = won ? \"won\" : \"lost\";\n roi = entry > 0 ? +(((won ? 1 : 0) - entry) / entry * 100).toFixed(1) : null;\n }\n }\n }\n return {\n category: r.category, market: r.market, side: r.side, endDate: r.endDate,\n entryPricePct: Number(r.price), holders: r.holders, coHold: r.coHold,\n minConvictionPct: r.minConviction, firstSeen: r.ts, status, settled, roiPct: roi,\n };\n });\n\n const byCat: Record = {};\n for (const s of signals) {\n if (s.status === \"won\" || s.status === \"lost\") {\n const c = byCat[s.category] ??= { resolved: 0, wins: 0, sumRoi: 0 };\n c.resolved++;\n if (s.status === \"won\") c.wins++;\n if (s.roiPct != null) c.sumRoi += s.roiPct;\n }\n }\n const summaryByCategory = Object.entries(byCat).map(([category, v]) => ({\n category, resolvedSignals: v.resolved,\n hitRatePct: +(v.wins / v.resolved * 100).toFixed(0),\n avgReturnPct: +(v.sumRoi / v.resolved).toFixed(1),\n }));\n\n const resolved = signals.filter((s) => s.status !== \"unresolved\").length;\n return Response.json({\n note: \"Backtest of following confluence signals from first appearance to resolution. Gross of fees; entry = observed mid, not executable. Data accrues over time via snapshot.ts (every 6h).\",\n totalSignals: signals.length, resolved,\n summaryByCategory,\n signals: signals.sort((a, b) => (a.status === \"unresolved\" ? 1 : 0) - (b.status === \"unresolved\" ? 1 : 0) || (b.roiPct ?? -999) - (a.roiPct ?? -999)),\n });\n}\n",[208],"f9c5586f-c6b3-416e-9685-77060af79b94","paper.ts","110cc392-b246-11f1-b10b-1607ee4eb77e",33,["D",1789615033707],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\n// Always-on PAPER trading engine. No real money. Reads the confluence signals\n// logged by snapshot.ts, opens a fixed-stake paper position on each qualifying\n// signal (once), holds to resolution, books P&L, and emails when it opens\n// positions. This is the earned-autonomy track: a live, self-executing bot on\n// paper that must prove an edge before any real capital is wired in.\nconst DESK = \"https://joaquinrubio--f9d09f46b24511f1bd951607ee4eb77e.web.val.run\";\nconst GAMMA = \"https://gamma-api.polymarket.com\";\nconst STAKE = 100;\n// Quality gate: real 2+ trader agreement, reasonably independent (low coHold),\n// entered at a genuinely uncertain price (not already decided).\nconst GATE = { minHolders: 2, maxCoHold: 5, minPrice: 12, maxPrice: 88 };\n\nasync function resolutions(cids: string[]) {\n const out = new Map();\n for (let i = 0; i < cids.length; i += 20) {\n const qs = cids.slice(i, i + 20).map((c) => `condition_ids=${c}`).join(\"&\");\n const r = await fetch(`${GAMMA}/markets?${qs}&limit=100`, { signal: AbortSignal.timeout(15000) });\n if (!r.ok) continue;\n for (const m of (await r.json()) as any[]) {\n try {\n out.set(m.conditionId, { closed: !!m.closed, outcomes: JSON.parse(m.outcomes ?? \"[]\"), prices: JSON.parse(m.outcomePrices ?? \"[]\").map(Number) });\n } catch { /* skip */ }\n }\n }\n return out;\n}\n\nexport default async function () {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS paper_trades (\n asset TEXT PRIMARY KEY, opened_ts TEXT, category TEXT, market TEXT, side TEXT,\n conditionId TEXT, endDate TEXT, entry REAL, holders INTEGER, coHold INTEGER, conviction REAL,\n stake REAL, status TEXT, resolved_ts TEXT, won INTEGER, pnl REAL, roi REAL, settled INTEGER)`);\n\n // 1) OPEN: qualifying signals from the log not already traded (entry = first-seen price)\n const cands = (await sqlite.execute(`\n SELECT asset, conditionId, category, market, side, endDate, holders, coHold, minConviction AS conviction, price, MIN(ts) AS ts\n FROM confluence_log\n WHERE holders >= ${GATE.minHolders} AND coHold <= ${GATE.maxCoHold} AND price >= ${GATE.minPrice} AND price <= ${GATE.maxPrice}\n GROUP BY asset`)).rows as any[];\n const existing = new Set(((await sqlite.execute(`SELECT asset FROM paper_trades`)).rows as any[]).map((r) => r.asset));\n const opened: any[] = [];\n for (const c of cands) {\n if (existing.has(c.asset)) continue;\n await sqlite.execute({\n sql: `INSERT INTO paper_trades (asset,opened_ts,category,market,side,conditionId,endDate,entry,holders,coHold,conviction,stake,status)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?, 'open')`,\n args: [c.asset, c.ts, c.category, c.market, c.side, c.conditionId, c.endDate, Number(c.price) / 100, c.holders, c.coHold, c.conviction, STAKE],\n });\n opened.push(c);\n }\n\n // 2) RESOLVE open trades\n const open = (await sqlite.execute(`SELECT asset, conditionId, side, endDate, entry FROM paper_trades WHERE status='open'`)).rows as any[];\n const res = await resolutions([...new Set(open.map((t) => String(t.conditionId)))]);\n let closed = 0;\n const now = Date.now();\n for (const t of open) {\n const m = res.get(String(t.conditionId));\n if (!m || !m.outcomes.length) continue;\n const idx = m.outcomes.findIndex((o: string) => o.toLowerCase() === String(t.side).toLowerCase());\n if (idx < 0 || !Number.isFinite(m.prices[idx])) continue;\n const p = m.prices[idx], past = new Date(t.endDate).getTime() < now;\n let won: boolean | null = null, settled = false;\n if (m.closed) { won = p >= 0.5; settled = true; }\n else if (past && p >= 0.9) won = true;\n else if (past && p <= 0.1) won = false;\n if (won === null) continue;\n const entry = Number(t.entry);\n const pnl = won ? STAKE * (1 - entry) / entry : -STAKE;\n await sqlite.execute({\n sql: `UPDATE paper_trades SET status=?, resolved_ts=?, won=?, pnl=?, roi=?, settled=? WHERE asset=?`,\n args: [won ? \"won\" : \"lost\", new Date().toISOString(), won ? 1 : 0, +pnl.toFixed(2), +(pnl / STAKE * 100).toFixed(1), settled ? 1 : 0, t.asset],\n });\n closed++;\n }\n\n // 3) alert on new opens\n if (opened.length) {\n const lines = opened.map((c) => `- ${c.market} | ${c.side} @ ${Math.round(Number(c.price))}c (${c.category}, ${c.holders} traders, coHold ${c.coHold})`);\n try {\n await email({ subject: `[predbot] opened ${opened.length} paper position(s)`, text: `The paper-trading bot opened:\\n\\n${lines.join(\"\\n\")}\\n\\nLive desk: ${DESK}` });\n } catch (_) { /* email best-effort */ }\n }\n console.log(`paper: opened=${opened.length} closed=${closed} openNow=${open.length - closed}`);\n}\n",[215],"5c88ca29-2823-4b61-b6f9-48c18389feb4",["D",1789623414648],11,[28],"d635f0ed-1600-4d58-b8c5-a1b2ab24763b","matcher.ts","f8124868-b253-11f1-859c-1607ee4eb77e",51,["D",1789623405851],"// matcher.ts — shared, guarded Polymarket <-> Kalshi market matcher.\n//\n// Ports the arb matcher's predicate/subject/year guards out of the (shelved)\n// lib.ts into a reusable module, and adds number/month awareness for the\n// US-macro lane (Fed bps, crypto price levels, expiry months). This is the\n// shared foundation for the VALUE pillar (venue mispricing) and, later, for\n// mapping a news/disclosure event to the market it moves.\n//\n// It reads public Kalshi data only. No keys, no orders.\n\nconst KALSHI = \"https://external-api.kalshi.com/trade-api/v2\";\n\nconst STOP = new Set(\n \"a an the of to in on for and or is are be will who what which when where by at as this that it whos then do does did have has had not no s with more over under most between valid than then into out up down\"\n .split(\" \"),\n);\n// Generic words shared across many markets — present but NOT distinctive.\nconst GENERIC = new Set(\n \"democratic democrat republican gop presidential president vice vp nomination nominee nominated election elect electoral senate senator house congress governor gubernatorial mayor mayoral party primary race win wins winner won run runs running candidate candidacy next control chamber seat seats margin victory popular vote votes general ticket secretary attorney prime minister chancellor premier king queen pope ceo chairman chair leader head monarch state states us united year record decision\"\n .split(\" \"),\n);\nconst WIN = new Set([\"win\", \"wins\", \"winner\", \"won\"]);\nconst RUN = new Set([\"run\", \"runs\", \"running\", \"candidate\", \"candidacy\", \"enter\", \"declare\", \"announce\", \"launch\"]);\nconst RETIRE = new Set([\"retire\", \"retires\", \"retirement\", \"resign\", \"resigns\", \"step\", \"steps\"]);\nconst SELECTION = new Set([\"nominee\", \"nominated\", \"nomination\", \"winner\", \"win\", \"wins\", \"won\", \"election\", \"elected\"]);\n// \"advance to the runoff / next round\" is a DIFFERENT bet than \"win\" — guard it.\nconst ADVANCE = new Set([\"advance\", \"advances\", \"advancing\", \"runoff\", \"qualify\", \"qualifies\", \"qualified\"]);\nconst MONTHS = new Set([\n \"january\", \"february\", \"march\", \"april\", \"may\", \"june\", \"july\",\n \"august\", \"september\", \"october\", \"november\", \"december\",\n \"jan\", \"feb\", \"mar\", \"apr\", \"jun\", \"jul\", \"aug\", \"sep\", \"sept\", \"oct\", \"nov\", \"dec\",\n]);\nconst MONTH_CANON: Record = {\n jan: \"january\", feb: \"february\", mar: \"march\", apr: \"april\", jun: \"june\",\n jul: \"july\", aug: \"august\", sep: \"september\", sept: \"september\", oct: \"october\",\n nov: \"november\", dec: \"december\",\n};\n\nfunction fnum(x: unknown): number {\n const n = parseFloat(String(x));\n return Number.isFinite(n) ? n : 0;\n}\n// Naive singularization so \"rates\"/\"rate\", \"elections\"/\"election\",\n// \"republicans\"/\"republican\" unify across venues that phrase things differently.\nfunction stem(w: string): string {\n return w.length > 3 && w.endsWith(\"s\") && !w.endsWith(\"ss\") && !w.endsWith(\"us\") ? w.slice(0, -1) : w;\n}\nfunction tok(text: string): string[] {\n return (text || \"\").toLowerCase().match(/[a-z0-9]+/g)?.filter((w) => !STOP.has(w) && w.length >= 2).map(stem) ?? [];\n}\nfunction subjects(toks: string[]): Set {\n return new Set(toks.filter((w) => !GENERIC.has(w) && w.length >= 3 && !/^(19|20)\\d\\d$/.test(w) && !MONTHS.has(w)));\n}\nfunction years(toks: string[]): Set {\n return new Set(toks.filter((w) => /^(19|20)\\d\\d$/.test(w)));\n}\nfunction months(toks: string[]): Set {\n return new Set(toks.filter((w) => MONTHS.has(w)).map((w) => MONTH_CANON[w] ?? w));\n}\nfunction action(toks: string[]): string {\n const s = new Set(toks);\n const has = (g: Set) => [...g].some((w) => s.has(w));\n if (has(ADVANCE)) return \"ADVANCE\";\n if (has(RETIRE)) return \"RETIRE\";\n if (has(WIN) && !has(RUN)) return \"WIN\";\n if (has(RUN) && !has(WIN)) return \"RUN\";\n return \"UNKNOWN\";\n}\n// Distinctive numbers: price levels, bps, percentages, counts. Normalizes\n// $120k -> 120000, 2.5% -> 2.5, \"25 bps\" -> 25. Used to catch same-topic\n// markets betting on DIFFERENT thresholds (Fed 25 vs 50 bps; BTC 120k vs 130k).\nfunction numbers(text: string): Set {\n const out = new Set();\n const re = /\\$?\\s*([0-9][0-9,]*(?:\\.[0-9]+)?)\\s*(k|m|bn|b|billion|million|trillion|t|bps|%)?/gi;\n let mm: RegExpExecArray | null;\n while ((mm = re.exec(text)) !== null) {\n let v = parseFloat(mm[1].replace(/,/g, \"\"));\n if (!Number.isFinite(v)) continue;\n const suf = (mm[2] ?? \"\").toLowerCase();\n if (suf === \"k\") v *= 1e3;\n else if (suf === \"m\" || suf === \"million\") v *= 1e6;\n else if (suf === \"bn\" || suf === \"b\" || suf === \"billion\") v *= 1e9;\n else if (suf === \"t\" || suf === \"trillion\") v *= 1e12;\n // bps and % kept as-is; a bare 2026 is dropped as a year, handled separately\n if (/^(19|20)\\d\\d$/.test(mm[1]) && !suf) continue;\n out.add(String(v));\n }\n return out;\n}\nfunction inter(a: Set, b: Set): number {\n let n = 0;\n for (const x of a) if (b.has(x)) n++;\n return n;\n}\nfunction overlapRatio(a: string[], b: string[]): number {\n const A = new Set(a), B = new Set(b);\n const m = Math.min(A.size, B.size);\n return m ? inter(A, B) / m : 0;\n}\n\nexport interface Parsed {\n text: string;\n tok: string[];\n subj: Set;\n yr: Set;\n mo: Set;\n num: Set;\n act: string;\n}\nexport function parse(text: string): Parsed {\n const t = tok(text);\n return { text, tok: t, subj: subjects(t), yr: years(t), mo: months(t), num: numbers(text), act: action(t) };\n}\n\nexport interface KMarket {\n eventTitle: string;\n subtitle: string;\n ticker: string;\n text: string;\n yesAsk: number; // dollars, 0..1\n noAsk: number;\n vol: number;\n p: Parsed;\n}\n\nasync function getJson(url: string): Promise {\n const r = await fetch(url, {\n headers: { \"User-Agent\": \"Mozilla/5.0\", \"Accept\": \"application/json\" },\n signal: AbortSignal.timeout(15000),\n });\n if (!r.ok) throw new Error(`${url} -> ${r.status}`);\n return r.json();\n}\n\nexport interface KalshiFetch {\n markets: KMarket[];\n pagesFetched: number;\n error: string | null; // non-null = the catalog is INCOMPLETE; do not read\n // an empty/short result as \"no matching markets exist\".\n}\n\n// One KMarket per tradeable (priced) Kalshi outcome, carrying its ticker and\n// executable-ish asks so the caller can compute a venue price gap.\n// Fails LOUDLY: Kalshi rate-limits heavy paging, and a silent empty catalog\n// would masquerade as \"nothing matched\". Retries each page once with a pause.\nexport async function fetchKalshiMarkets(pages = 15): Promise {\n const out: KMarket[] = [];\n let cursor = \"\";\n let error: string | null = null;\n let fetched = 0;\n for (let i = 0; i < pages; i++) {\n let j: any;\n try {\n j = await getJson(`${KALSHI}/events?status=open&limit=200&with_nested_markets=true${cursor ? `&cursor=${cursor}` : \"\"}`);\n } catch (e1) {\n await new Promise((r) => setTimeout(r, 1200)); // back off, then one retry\n try {\n j = await getJson(`${KALSHI}/events?status=open&limit=200&with_nested_markets=true${cursor ? `&cursor=${cursor}` : \"\"}`);\n } catch (e2) {\n error = `page ${i + 1}: ${String((e2 as Error)?.message ?? e2)}`;\n break;\n }\n }\n fetched++;\n for (const ev of j.events ?? []) {\n const title: string = ev.title ?? \"\";\n for (const m of ev.markets ?? []) {\n const ya = fnum(m.yes_ask_dollars ?? (m.yes_ask != null ? m.yes_ask / 100 : 0));\n const na = fnum(m.no_ask_dollars ?? (m.no_ask != null ? m.no_ask / 100 : 0));\n const vol = fnum(m.volume_fp ?? m.volume);\n const sub = m.yes_sub_title || m.subtitle || \"\";\n const text = (title + \" \" + sub).trim();\n out.push({\n eventTitle: title, subtitle: sub, ticker: m.ticker ?? ev.event_ticker ?? \"\",\n text, yesAsk: ya, noAsk: na, vol, p: parse(text),\n });\n }\n }\n cursor = j.cursor ?? \"\";\n if (!cursor) break;\n }\n return { markets: out, pagesFetched: fetched, error };\n}\n\nexport interface MatchResult {\n ok: boolean;\n score: number;\n reason: string;\n k: KMarket | null;\n}\n\n// Guarded match of one Polymarket question against Kalshi candidates.\n// Rejects: <2 shared distinctive subjects; win/run/retire action conflict;\n// year conflict; month (expiry) conflict; distinct-number (threshold) conflict;\n// a WIN question against a non-selection market. Requires token overlap >= minScore.\nexport function matchOne(polyText: string, cands: KMarket[], minScore = 0.5): MatchResult {\n const p = parse(polyText);\n if (p.subj.size < 2) return { ok: false, score: 0, reason: \"too few distinctive words\", k: null };\n\n let best: KMarket | null = null, bestScore = 0, bestReason = \"no candidate cleared the guards\";\n for (const k of cands) {\n if (inter(p.subj, k.p.subj) < 2) continue; // >=2 shared distinctive subjects\n if ([\"WIN\", \"RUN\", \"RETIRE\", \"ADVANCE\"].includes(p.act) && [\"WIN\", \"RUN\", \"RETIRE\", \"ADVANCE\"].includes(k.p.act) && p.act !== k.p.act) continue;\n if (p.yr.size && k.p.yr.size && inter(p.yr, k.p.yr) === 0) continue; // different year\n if (p.mo.size && k.p.mo.size && inter(p.mo, k.p.mo) === 0) continue; // different month/expiry\n if (p.num.size && k.p.num.size && inter(p.num, k.p.num) === 0) continue; // different threshold/level\n if (p.act === \"WIN\" && !k.p.tok.some((w) => SELECTION.has(w))) continue; // WIN must match a selection market\n const sc = overlapRatio(p.tok, k.p.tok);\n if (sc > bestScore) { best = k; bestScore = sc; bestReason = \"matched\"; }\n }\n if (best && bestScore >= minScore) return { ok: true, score: bestScore, reason: \"matched\", k: best };\n return { ok: false, score: bestScore, reason: best ? `best candidate below threshold (${bestScore.toFixed(2)})` : bestReason, k: best };\n}\n\n// RETRIEVAL INDEX for the shortlist. Inverse document frequency over the whole\n// Kalshi catalog, so a shared rare word (\"bps\", \"midterm\", \"Ocasio\") counts for\n// far more than a shared common one (\"rate\", \"market\", \"price\"). Without this,\n// a short unrelated title that happens to share one generic word outranks the\n// real match — that is exactly how Fed markets ended up matched against\n// \"Monday.com customer retention rate\".\nexport interface KIndex {\n markets: KMarket[];\n idf: Map;\n}\nexport function buildIndex(markets: KMarket[]): KIndex {\n const df = new Map();\n for (const m of markets) {\n for (const t of new Set(m.p.tok)) df.set(t, (df.get(t) ?? 0) + 1);\n }\n const N = Math.max(1, markets.length);\n const idf = new Map();\n for (const [t, d] of df) idf.set(t, Math.log(N / (1 + d)));\n return { markets, idf };\n}\n\n// Permissive CANDIDATE SHORTLIST for the LLM judge tier.\n// Optimizes RECALL, not precision — the model now does the precision work, so\n// the only job here is to make sure the true match is somewhere in the list.\n// Keeps just the high-precision contradiction guards (year conflict,\n// win/run/retire/advance conflict) and drops the subject rule, the score\n// threshold and the number guard. Ranked by summed IDF of shared tokens.\nexport function shortlist(polyText: string, index: KIndex, n = 8): KMarket[] {\n const p = parse(polyText);\n const ptoks = new Set(p.tok);\n if (ptoks.size === 0) return [];\n const scored: { k: KMarket; s: number }[] = [];\n for (const k of index.markets) {\n if ([\"WIN\", \"RUN\", \"RETIRE\", \"ADVANCE\"].includes(p.act) && [\"WIN\", \"RUN\", \"RETIRE\", \"ADVANCE\"].includes(k.p.act) && p.act !== k.p.act) continue;\n if (p.yr.size && k.p.yr.size && inter(p.yr, k.p.yr) === 0) continue;\n let s = 0, shared = 0;\n for (const t of new Set(k.p.tok)) {\n if (ptoks.has(t)) { s += index.idf.get(t) ?? 0; shared++; }\n }\n if (shared >= 2 && s > 0) scored.push({ k, s });\n }\n scored.sort((a, b) => b.s - a.s);\n return scored.slice(0, n).map((x) => x.k);\n}\n",[226],"e9be5703-5d68-41ca-ac63-2020a3413468","main.tsx",["D",1789595133283],"import { compute, renderDashboard } from \"./lib.ts\";\n\n// Live dashboard. Recomputes fresh on each view (the page auto-refreshes),\n// so what you see is always current. Detect-only: reads public prices only.\nexport default async function (req: Request): Promise {\n try {\n const data = await compute(3);\n return new Response(renderDashboard(data, 60), {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n } catch (e) {\n return new Response(`

monitor error: ${String(e)}

`, {\n status: 500,\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n}\n",[233],"78c94703-df83-49a7-a1c8-0f3b8f7a1bea","llm-match.ts","ee9eef84-b258-11f1-9951-1607ee4eb77e",44,["D",1789623249708],"// llm-match.ts — the LLM judge tier of the market matcher.\n//\n// The deterministic layer (matcher.ts) scans ~27k Kalshi markets for free and\n// hands over a short candidate list. This module asks a small, cheap model one\n// narrow question per Polymarket market: which candidate refers to the same\n// real-world event, and what KIND of relationship is it?\n//\n// Design notes:\n// - PROVIDER-AGNOSTIC. \"valtown\" uses Val Town's built-in OpenAI proxy: no API\n// key, no billing, nano-class model, ~10 requests/min. \"anthropic\" uses\n// Claude Haiku and needs ANTHROPIC_API_KEY. Default is valtown (free); if the\n// key exists, anthropic is preferred. Set explicitly to A/B the two.\n// - GRADED, not binary. A Kalshi market that isn't identical can still inform\n// us. \"same\" = tradeable 1:1. \"nested\" = a sub-option or threshold inside the\n// same question, still directly informative. \"proxy\" = correlated but\n// materially different, corroboration only, never a literal price\n// comparison. \"unrelated\" = drop.\n// - Reports SIDE ALIGNMENT (does Kalshi YES mean the same thing as Polymarket\n// YES), which is what lets us compute an honest price gap.\n// - It NEVER decides a trade. It classifies markets. The deterministic layer\n// still owns every trading decision.\n// - Degrades safely: any failure returns null and the caller falls back to\n// deterministic-only matching.\n// - Judgments are cached in SQLite (keyed by provider) so repeated 6h runs\n// don't re-pay, and so the two providers can be compared on the same pairs.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { KMarket } from \"./matcher.ts\";\n\nconst HAIKU = \"claude-haiku-4-5-20251001\";\nconst NANO = \"gpt-4.5-nano\";\nconst ANTHROPIC_API = \"https://api.anthropic.com/v1/messages\";\nconst CACHE_TABLE = \"match_cache\";\n\nexport type Provider = \"valtown\" | \"anthropic\";\nexport type Relation = \"same\" | \"nested\" | \"proxy\" | \"unrelated\";\n\nexport interface Judgment {\n best: number | null; // 1-based index into the candidate list, or null\n relation: Relation;\n confidence: number; // 0..1\n aligned: boolean | null; // does Kalshi YES == Polymarket YES?\n reason: string;\n provider?: Provider;\n cached?: boolean;\n}\n\nconst SYSTEM = `You match prediction markets across two venues (Polymarket and Kalshi).\nGiven one Polymarket question and numbered Kalshi candidate markets, pick the candidate that refers to the same underlying real-world event and classify the relationship.\n\nRelations:\n- \"same\": identical question AND resolution criteria. A position in one is economically equivalent to a position in the other.\n- \"nested\": the same broader question, but one side is a specific sub-option, threshold, bracket, or component of the other (e.g. a specific rate band inside a rate decision, or one party's outcome inside a control-of-chamber market). Directly informative.\n- \"proxy\": correlated but materially different question — different entity, different bar, different mechanism, or a comparative/\"which happens first\" framing. Useful only as soft corroboration, never as a literal price comparison.\n- \"unrelated\": no useful relationship.\n\nAlso report side alignment: does the Kalshi market's YES outcome mean the same real-world outcome as the Polymarket question's YES? true if yes, false if it is inverted, null if unclear or unrelated.\n\nBe strict about \"same\". If resolution criteria or dates could differ, use \"nested\" or \"proxy\".\n\nRespond with ONLY a JSON object, no prose, no code fences:\n{\"best\": <1-based number or null>, \"relation\": \"same\"|\"nested\"|\"proxy\"|\"unrelated\", \"confidence\": <0..1>, \"aligned\": true|false|null, \"reason\": \"\"}`;\n\nfunction hash(s: string): string {\n let h = 5381;\n for (let i = 0; i < s.length; i++) h = ((h << 5) + h + s.charCodeAt(i)) | 0;\n return (h >>> 0).toString(36);\n}\n\nexport function hasAnthropicKey(): boolean {\n return Boolean(Deno.env.get(\"ANTHROPIC_API_KEY\"));\n}\n\n// Free built-in proxy by default; upgrade to Haiku automatically if a key exists.\nexport function defaultProvider(): Provider {\n return hasAnthropicKey() ? \"anthropic\" : \"valtown\";\n}\n\nasync function ensureCache(): Promise {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${CACHE_TABLE} (k TEXT PRIMARY KEY, json TEXT NOT NULL, ts TEXT NOT NULL)`,\n );\n}\n\nfunction parseJudgment(text: string): Judgment | null {\n const m = text.match(/\\{[\\s\\S]*\\}/); // tolerate stray prose or code fences\n if (!m) return null;\n try {\n const o = JSON.parse(m[0]);\n const rel = [\"same\", \"nested\", \"proxy\", \"unrelated\"].includes(o.relation) ? o.relation as Relation : \"unrelated\";\n return {\n best: typeof o.best === \"number\" ? o.best : null,\n relation: rel,\n confidence: typeof o.confidence === \"number\" ? Math.max(0, Math.min(1, o.confidence)) : 0,\n aligned: o.aligned === true ? true : o.aligned === false ? false : null,\n reason: typeof o.reason === \"string\" ? o.reason.slice(0, 200) : \"\",\n };\n } catch {\n return null;\n }\n}\n\nasync function callAnthropic(user: string): Promise {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) return null;\n try {\n const res = await fetch(ANTHROPIC_API, {\n method: \"POST\",\n headers: { \"x-api-key\": key, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({\n model: HAIKU,\n max_tokens: 300,\n temperature: 0,\n system: SYSTEM,\n messages: [{ role: \"user\", content: user }],\n }),\n signal: AbortSignal.timeout(20000),\n });\n if (!res.ok) return null;\n const j = await res.json();\n return (j.content ?? []).map((b: any) => b?.text ?? \"\").join(\"\");\n } catch {\n return null;\n }\n}\n\n// Val Town's built-in OpenAI proxy: no API key required.\n// Rate limited (~10 req/min), so callers should throttle and lean on the cache.\nasync function callValtown(user: string): Promise {\n try {\n const { OpenAI } = await import(\"https://esm.town/v/std/openai/main.ts\");\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: NANO,\n max_completion_tokens: 300,\n messages: [\n { role: \"system\", content: SYSTEM },\n { role: \"user\", content: user },\n ],\n });\n return completion.choices?.[0]?.message?.content ?? null;\n } catch {\n return null;\n }\n}\n\n// Judge one Polymarket market against its candidate shortlist.\n// Returns null if the model is unavailable or the call fails — callers must\n// fall back to deterministic matching rather than treating null as \"unrelated\".\nexport async function judge(\n polyText: string,\n cands: KMarket[],\n opts: { useCache?: boolean; provider?: Provider } = {},\n): Promise {\n if (cands.length === 0) return null;\n const provider = opts.provider ?? defaultProvider();\n const useCache = opts.useCache !== false;\n\n const listing = cands.map((k, i) => `${i + 1}. ${k.text}`).join(\"\\n\");\n const user = `Polymarket question:\\n${polyText}\\n\\nKalshi candidates:\\n${listing}`;\n const cacheKey = provider + \":\" + hash(polyText + \"||\" + cands.map((c) => c.ticker).join(\",\"));\n\n if (useCache) {\n try {\n await ensureCache();\n const r = await sqlite.execute({ sql: `SELECT json FROM ${CACHE_TABLE} WHERE k = ?`, args: [cacheKey] });\n const row = r.rows?.[0] as any;\n if (row) {\n const raw = typeof row === \"object\" && \"json\" in row ? row.json : row[0];\n return { ...JSON.parse(raw), provider, cached: true };\n }\n } catch {\n // cache is best-effort\n }\n }\n\n const text = provider === \"anthropic\" ? await callAnthropic(user) : await callValtown(user);\n if (!text) return null;\n\n const verdict = parseJudgment(text);\n if (!verdict) return null;\n if (verdict.best != null && (verdict.best < 1 || verdict.best > cands.length)) verdict.best = null;\n verdict.provider = provider;\n\n if (useCache) {\n try {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO ${CACHE_TABLE} (k, json, ts) VALUES (?, ?, ?)`,\n args: [cacheKey, JSON.stringify(verdict), new Date().toISOString()],\n });\n } catch {\n // best-effort\n }\n }\n return verdict;\n}\n",[238],"7c479c6c-2ac5-49b5-9a73-7f27336a3447","lib.ts","e740e4c2-b217-11f1-aacd-1607ee4eb77e",["D",1789595115886],"// lib.ts — shared logic for the live prediction-market monitor (detect-only).\n// Fetches public Kalshi + Polymarket data, runs fee-aware detection and a\n// predicate/subject/year-aware cross-venue matcher, and renders the dashboard.\n// No account, no keys, no orders. Reads public prices only.\n\nconst STOP = new Set(\n \"a an the of to in on for and or is are be will who what which when where by at as this that it who's whos then do does did have has had not no s\"\n .split(\" \"),\n);\n// Generic words shared across many markets — NOT distinctive. Includes role\n// words (prime minister, chancellor, ceo, ...) so \"next Prime Minister of X\"\n// only matches on the country/person, never on the shared role.\nconst GENERIC = new Set(\n \"democratic democrat republican gop presidential president vice vp nomination nominee nominated election elect electoral senate senator house congress governor gubernatorial mayor mayoral party primary race win wins winner won run runs running candidate candidacy next control chamber seat margin victory popular vote general ticket secretary attorney prime minister chancellor premier king queen pope ceo chairman chair leader head monarch state states us united 2024 2025 2026 2027 2028 2029 2030 before after during term season game match team cup league\"\n .split(\" \"),\n);\nconst WIN = new Set([\"win\", \"wins\", \"winner\", \"won\"]);\nconst RUN = new Set([\"run\", \"runs\", \"running\", \"candidate\", \"candidacy\", \"enter\", \"declare\", \"announce\", \"launch\"]);\nconst RETIRE = new Set([\"retire\", \"retires\", \"retirement\"]);\n// If a Polymarket \"will X WIN\" question is matched to Kalshi, the Kalshi side\n// must be a selection market (contain one of these), else it's a different bet.\nconst SELECTION = new Set([\"nominee\", \"nominated\", \"nomination\", \"winner\", \"win\", \"wins\", \"won\", \"election\", \"elected\"]);\n\nconst KALSHI_EVENTS = \"https://external-api.kalshi.com/trade-api/v2/events?limit=200&status=open&with_nested_markets=true\";\n\nfunction fnum(x: unknown): number {\n const n = parseFloat(String(x));\n return Number.isFinite(n) ? n : 0;\n}\nfunction fee(p: number): number {\n return p > 0 && p < 1 ? 0.07 * p * (1 - p) : 0;\n}\nfunction tok(text: string): string[] {\n return (text || \"\").toLowerCase().match(/[a-z0-9]+/g)?.filter((w) => !STOP.has(w) && w.length >= 2) ?? [];\n}\nfunction subjects(toks: string[]): Set {\n return new Set(toks.filter((w) => !GENERIC.has(w) && w.length >= 3 && !/^(19|20)\\d\\d$/.test(w)));\n}\nfunction years(toks: string[]): Set {\n return new Set(toks.filter((w) => /^(19|20)\\d\\d$/.test(w)));\n}\nfunction action(toks: string[]): string {\n const s = new Set(toks);\n const has = (g: Set) => [...g].some((w) => s.has(w));\n if (has(RETIRE)) return \"RETIRE\";\n if (has(WIN) && !has(RUN)) return \"WIN\";\n if (has(RUN) && !has(WIN)) return \"RUN\";\n return \"UNKNOWN\";\n}\nfunction inter(a: Set, b: Set): number {\n let n = 0;\n for (const x of a) if (b.has(x)) n++;\n return n;\n}\nfunction overlap(a: string[], b: string[]): number {\n const A = new Set(a), B = new Set(b);\n const m = Math.min(A.size, B.size);\n return m ? inter(A, B) / m : 0;\n}\n\nasync function getJson(url: string): Promise {\n const r = await fetch(url, { headers: { \"User-Agent\": \"predmarket-monitor/1.0\" } });\n if (!r.ok) throw new Error(`${url} -> ${r.status}`);\n return r.json();\n}\n\nexport interface KBinary {\n text: string; tok: string[]; subj: Set; yr: Set; act: string;\n yes_ask: number; no_ask: number; vol: number;\n}\nexport interface NetLock { title: string; n: number; lock_net: number; vol: number; }\nexport interface PolyMkt { q: string; subj: Set; yr: Set; act: string; tok: string[]; yes: number; no: number; }\nexport interface Lead { q: string; k: string; score: number; net: number; side: string; }\n\nasync function fetchKalshi(pages: number): Promise<{ binaries: KBinary[]; netLocks: NetLock[] }> {\n const binaries: KBinary[] = [];\n const netLocks: NetLock[] = [];\n let cursor: string | undefined;\n for (let p = 0; p < pages; p++) {\n const data = await getJson(KALSHI_EVENTS + (cursor ? \"&cursor=\" + cursor : \"\"));\n for (const ev of data.events ?? []) {\n const title: string = ev.title ?? \"\";\n const me = Boolean(ev.mutually_exclusive);\n const outs: { ya: number; na: number }[] = [];\n for (const m of ev.markets ?? []) {\n const ya = fnum(m.yes_ask_dollars), na = fnum(m.no_ask_dollars), mv = fnum(m.volume_fp);\n if (me && ya > 0 && ya < 1 && na > 0 && na < 1) outs.push({ ya, na });\n if (mv > 0 && ya > 0 && ya < 1 && na > 0 && na < 1) {\n const sub = m.yes_sub_title || m.subtitle || \"\";\n const text = (title + \" \" + sub).trim();\n const t = tok(text);\n binaries.push({ text, tok: t, subj: subjects(t), yr: years(t), act: action(t), yes_ask: ya, no_ask: na, vol: mv });\n }\n }\n if (me && outs.length >= 2) {\n const n = outs.length;\n const lockGross = (n - 1) - outs.reduce((s, o) => s + o.na, 0);\n const lockNet = lockGross - outs.reduce((s, o) => s + fee(o.na), 0);\n if (lockNet > 0) netLocks.push({ title, n, lock_net: lockNet, vol: ev.markets?.reduce((s: number, m: any) => s + fnum(m.volume_fp), 0) ?? 0 });\n }\n }\n cursor = data.cursor;\n if (!cursor) break;\n }\n netLocks.sort((a, b) => b.lock_net - a.lock_net);\n return { binaries, netLocks };\n}\n\nasync function fetchPoly(): Promise {\n const url = \"https://gamma-api.polymarket.com/markets?limit=250&active=true&closed=false&order=volumeNum&ascending=false\";\n const rows = await getJson(url);\n const list = Array.isArray(rows) ? rows : (rows.data ?? []);\n const out: PolyMkt[] = [];\n for (const m of list) {\n let outs: string[], prices: number[];\n try { outs = JSON.parse(m.outcomes ?? \"[]\"); prices = (JSON.parse(m.outcomePrices ?? \"[]\") as string[]).map(Number); }\n catch { continue; }\n const low = outs.map((o) => String(o).toLowerCase());\n if (low.includes(\"yes\") && low.includes(\"no\") && prices.length === outs.length) {\n const q = m.question ?? \"\";\n const t = tok(q);\n out.push({ q, subj: subjects(t), yr: years(t), act: action(t), tok: t, yes: prices[low.indexOf(\"yes\")], no: prices[low.indexOf(\"no\")] });\n }\n }\n return out;\n}\n\nfunction crossMatch(binaries: KBinary[], poly: PolyMkt[]): Lead[] {\n const index = new Map();\n for (const k of binaries) for (const s of k.subj) (index.get(s) ?? index.set(s, []).get(s)!).push(k);\n const leads: Lead[] = [];\n for (const p of poly) {\n if (p.subj.size < 2) continue;\n const seen = new Set();\n const cands: KBinary[] = [];\n for (const s of p.subj) for (const k of index.get(s) ?? []) if (!seen.has(k)) { seen.add(k); cands.push(k); }\n let best: KBinary | null = null, bestScore = 0;\n for (const k of cands) {\n if (inter(p.subj, k.subj) < 2) continue; // >=2 shared distinctive words\n if ([\"WIN\", \"RUN\", \"RETIRE\"].includes(p.act) && [\"WIN\", \"RUN\", \"RETIRE\"].includes(k.act) && p.act !== k.act) continue;\n if (p.yr.size && k.yr.size && inter(p.yr, k.yr) === 0) continue; // year conflict\n if (p.act === \"WIN\" && !k.tok.some((w) => SELECTION.has(w))) continue; // WIN must match a selection market\n const sc = overlap(p.tok, k.tok);\n if (sc > bestScore) { best = k; bestScore = sc; }\n }\n if (best && bestScore >= 0.5) {\n const netA = 1 - (best.yes_ask + p.no) - fee(best.yes_ask);\n const netB = 1 - (p.yes + best.no_ask) - fee(best.no_ask);\n const [net, side] = netA >= netB ? [netA, \"Kalshi YES + Poly NO\"] : [netB, \"Poly YES + Kalshi NO\"];\n leads.push({ q: p.q, k: best.text, score: bestScore, net, side });\n }\n }\n return leads.sort((a, b) => b.net - a.net);\n}\n\nexport interface MonitorData {\n stamp: string; kalshiCount: number; polyCount: number; netLocks: NetLock[]; leads: Lead[];\n}\n\nexport async function compute(pages = 4): Promise {\n const [{ binaries, netLocks }, poly] = await Promise.all([fetchKalshi(pages), fetchPoly()]);\n const leads = crossMatch(binaries, poly);\n return {\n stamp: new Date().toISOString().replace(\"T\", \" \").slice(0, 19) + \" UTC\",\n kalshiCount: binaries.length, polyCount: poly.length, netLocks, leads,\n };\n}\n\n// Leads worth an email alert: net edge above threshold. Conservative to avoid spam.\nexport function strongLeads(d: MonitorData, minNet = 0.03): Lead[] {\n return d.leads.filter((l) => l.net >= minNet);\n}\n\nconst esc = (s: string) => String(s).replace(/[&<>\"]/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[c]!));\nconst c = (x: number) => (x >= 0 ? \"+\" : \"\") + (x * 100).toFixed(1) + \"c\";\n\nexport function renderDashboard(d: MonitorData, refresh = 60): string {\n const posLeads = d.leads.filter((l) => l.net > 0);\n const tiles = [\n [d.kalshiCount, \"Kalshi markets\"], [d.polyCount, \"Polymarket markets\"],\n [d.leads.length, \"cross-venue matches\"], [posLeads.length, \"net-positive leads\"],\n ].map(([n, l]) => `

${n}

${l}

`).join(\"\");\n\n const leadRows = d.leads.slice(0, 25).map((l) => {\n const cls = l.net > 0 ? \"pos\" : \"neg\";\n const pill = l.net > 0 ? 'lead' : \"\";\n return `${esc(l.q.slice(0, 62))}
${esc(l.k.slice(0, 62))}` +\n `${l.score.toFixed(2)}${c(l.net)}${esc(l.side)}${pill}`;\n }).join(\"\");\n const leadsHtml = d.leads.length\n ? `${leadRows}

Matched pair (Polymarket / Kalshi)	Match	Net edge	Construction

`\n : '

No confident cross-venue matches this cycle.

';\n\n const locksHtml = d.netLocks.length\n ? `${d.netLocks.slice(0, 10).map((m) => ``).join(\"\")}

Event	Outcomes	Net edge
${esc(m.title.slice(0, 60))}	${m.n}	${c(m.lock_net)}

`\n : '

No single-venue lock clears fees this cycle. Normal and expected.

';\n\n return `\n\n\nLive Prediction Market Monitor

Live Prediction Market Monitor

Detect-only, hosted on Val Town. Auto-refreshing every ${refresh}s. Last updated ${esc(d.stamp)}.

${tiles}

Cross-venue leads (Kalshi vs Polymarket)

Same-bet matches with a positive net-of-fees edge. UNVERIFIED leads: confirm identical resolution + date, use executable order-book prices, and check you can trade the Polymarket side as a US resident before trusting any of these.

\n${leadsHtml}

Single-venue locks (Kalshi, fee-aware)

Mutually-exclusive events whose sell-side edge survives estimated fees.

\n${locksHtml}

Live public-data monitor. It only reads; it never trades. Cross-venue edges use indicative Polymarket prices, not executable order-book asks.

`;\n}\n",[245],"6291d64b-3984-4a40-b237-f0e762ebdd04","index.html","01a0ac2c-e909-715a-acf6-aa3cf4df43c1",["D",1789595019450],"\n\n \n Hi there!\n \n \n \n\n \n \n\n \n \n\n \n \n \n \n

Hi there!

\n\n

\n I'm your cool new webpage. Made with Val Town!\n

\n \n",[251],"f8da3c4c-9065-4a06-824d-4611e8553309","favicon.svg","01a0ac2c-e909-715a-acf6-a42e3b3ec658",["D",1789595019450],"",[257],"326700fa-866e-432e-8078-bc797834eb0d","desk.tsx","f9d09f46-b245-11f1-bd95-1607ee4eb77e",34,["D",1789617448415],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst GAMMA = \"https://gamma-api.polymarket.com\";\nconst STAKE = 100;\nconst esc = (s: any) => String(s ?? \"\").replace(/[&<>]/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\" }[c]!));\nconst money = (n: number) => (n < 0 ? \"-$\" : \"$\") + Math.abs(n).toFixed(0);\nconst pct = (n: number) => (n >= 0 ? \"+\" : \"\") + n.toFixed(1) + \"%\";\nconst cls = (n: number) => (n >= 0 ? \"pos\" : \"neg\");\n\nasync function currentPrices(cids: string[]) {\n const out = new Map();\n for (let i = 0; i < cids.length; i += 20) {\n const qs = cids.slice(i, i + 20).map((c) => `condition_ids=${c}`).join(\"&\");\n try {\n const r = await fetch(`${GAMMA}/markets?${qs}&limit=100`, { signal: AbortSignal.timeout(12000) });\n if (!r.ok) continue;\n for (const m of (await r.json()) as any[]) {\n try { out.set(m.conditionId, { outcomes: JSON.parse(m.outcomes ?? \"[]\"), prices: JSON.parse(m.outcomePrices ?? \"[]\").map(Number) }); } catch { /* skip */ }\n }\n } catch { /* skip */ }\n }\n return out;\n}\n\n// Cumulative realized-P&L equity curve as a simple inline SVG.\nfunction curve(vals: number[]): string {\n if (vals.length < 2) return `

The equity curve draws itself once a couple of positions resolve.

`;\n const W = 900, H = 120, pad = 8;\n const lo = Math.min(0, ...vals), hi = Math.max(0, ...vals), span = hi - lo || 1;\n const x = (i: number) => pad + (i / (vals.length - 1)) * (W - 2 * pad);\n const y = (v: number) => H - pad - ((v - lo) / span) * (H - 2 * pad);\n const pts = vals.map((v, i) => `${x(i).toFixed(1)},${y(v).toFixed(1)}`).join(\" \");\n const zeroY = y(0).toFixed(1);\n const last = vals[vals.length - 1];\n return ``;\n}\n\nexport default async function (): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS paper_trades (\n asset TEXT PRIMARY KEY, opened_ts TEXT, category TEXT, market TEXT, side TEXT,\n conditionId TEXT, endDate TEXT, entry REAL, holders INTEGER, coHold INTEGER, conviction REAL,\n stake REAL, status TEXT, resolved_ts TEXT, won INTEGER, pnl REAL, roi REAL, settled INTEGER)`);\n const rows = (await sqlite.execute(`SELECT * FROM paper_trades`)).rows as any[];\n const open = rows.filter((r) => r.status === \"open\");\n const closed = rows.filter((r) => r.status !== \"open\").sort((a, b) => (b.resolved_ts > a.resolved_ts ? 1 : -1));\n\n // mark open positions to current market price\n const mk = await currentPrices([...new Set(open.map((r) => String(r.conditionId)))]);\n for (const r of open) {\n const m = mk.get(String(r.conditionId));\n r._cur = null; r._unreal = null;\n if (m) {\n const i = m.outcomes.findIndex((o) => o.toLowerCase() === String(r.side).toLowerCase());\n if (i >= 0 && Number.isFinite(m.prices[i]) && r.entry > 0) { r._cur = m.prices[i]; r._unreal = STAKE * (m.prices[i] / r.entry - 1); }\n }\n }\n open.sort((a, b) => (b._unreal ?? -1e9) - (a._unreal ?? -1e9));\n\n const wins = closed.filter((r) => r.won === 1).length;\n const realized = closed.reduce((a, r) => a + (Number(r.pnl) || 0), 0);\n const unrealized = open.reduce((a, r) => a + (r._unreal ?? 0), 0);\n const net = realized + unrealized;\n const hit = closed.length ? (wins / closed.length * 100) : 0;\n\n // category scoreboard (economics vs politics), realized + current open exposure\n const cat: Record = {};\n for (const r of rows) {\n const c = cat[r.category] ??= { open: 0, openUnreal: 0, closed: 0, wins: 0, realized: 0, sumRoi: 0 };\n if (r.status === \"open\") { c.open++; c.openUnreal += r._unreal ?? 0; }\n else { c.closed++; if (r.won === 1) c.wins++; c.realized += Number(r.pnl) || 0; c.sumRoi += Number(r.roi) || 0; }\n }\n const scoreRows = Object.entries(cat).sort((a, b) => b[1].realized - a[1].realized).map(([name, c]) =>\n `${esc(name)}${c.open}${money(c.openUnreal)}${c.closed}${c.closed ? (c.wins / c.closed * 100).toFixed(0) + \"%\" : \"—\"}${c.closed ? pct(c.sumRoi / c.closed) : \"—\"}${money(c.realized)}`\n ).join(\"\") || `No positions yet.`;\n\n // equity curve values (cumulative realized over resolution order)\n const curveVals: number[] = [];\n let acc = 0;\n for (const r of [...closed].reverse()) { acc += Number(r.pnl) || 0; curveVals.push(acc); }\n\n const openRows = open.map((r) => {\n const cur = r._cur != null ? Math.round(r._cur * 100) + \"c\" : \"—\";\n const u = r._unreal;\n return `${esc(r.market)}${esc(r.side)}${Math.round(r.entry * 100)}c${cur}${u == null ? \"—\" : money(u)}${r.holders}${r.coHold}${esc(r.category)}`;\n }).join(\"\") || `No open paper positions yet.`;\n\n const closedRows = closed.map((r) =>\n `${esc(r.market)}${esc(r.side)}${Math.round(r.entry * 100)}c${r.won ? \"WON\" : \"LOST\"}${r.settled ? \"\" : \"*\"}${money(Number(r.pnl))}${pct(Number(r.roi))}${esc(r.category)}`\n ).join(\"\") || `Nothing resolved yet.`;\n\n const html = `\n\nSmart-Money Paper Desk

Smart-Money Paper Desk

Paper trading only — no real money. $${STAKE}/position. Open bets are marked to the live market price. Auto-refresh 60s. ${esc(new Date().toISOString().slice(0, 16).replace(\"T\", \" \"))} UTC.

${money(net)}

Net P&L (real + unreal)

${money(realized)}

Realized (closed)

${money(unrealized)}

Unrealized (open)

${hit.toFixed(0)}%

Win rate (${wins}/${closed.length})

${open.length}

Open positions

Equity curve

Cumulative realized profit and loss as positions settle.

${curve(curveVals)}

Scoreboard by category

The question that decides everything: does the tradeable ECONOMICS lane (US macro) beat the POLITICS control (mostly foreign elections)?

\n${scoreRows}

Category	Open	Open P&L	Closed	Win %	Avg ROI	Realized

Open positions

Live bets, marked to the current market price.

\n${openRows}

Market	Side	Entry	Now	Unreal.	Traders	coHold	Cat.

Closed positions

Resolved bets. * = decided by price, not yet officially settled.

\n${closedRows}

Market	Side	Entry	Result	P&L	ROI	Cat.

Detect + paper-execute only. Never places real trades. Entry and mark are observed mid prices, gross of fees, not executable quotes. Earned-autonomy track: prove an edge on paper before any real capital.

`;\n return new Response(html, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n}\n",[263],"30ebd3cb-34da-4150-957c-fa652cd92580","data-api.ts","47307b60-b23e-11f1-b0d1-1607ee4eb77e",18,["D",1789611973733],"const DATA = \"https://data-api.polymarket.com\";\n\nexport async function readRows(path: string, params: Record) {\n const url = new URL(path, DATA);\n for (const [key, value] of Object.entries(params)) url.searchParams.set(key, String(value));\n const response = await fetch(url, { signal: AbortSignal.timeout(15000) });\n if (!response.ok) throw new Error(`${path}: HTTP ${response.status}`);\n const rows: unknown = await response.json();\n if (!Array.isArray(rows) || rows.some((r) => !r || typeof r !== \"object\" || Array.isArray(r))) {\n throw new Error(`${path}: expected an array of records`);\n }\n return rows as Record[];\n}\n\n// Authoritative total portfolio value (Polymarket's own computed number), used as\n// the conviction denominator so it includes the long tail of dust we don't page.\nexport async function readValue(wallet: string): Promise {\n const rows = await readRows(\"/value\", { user: wallet });\n const v = rows[0]?.value;\n if (!Number.isFinite(v) || v < 0) throw new Error(\"/value: missing or invalid portfolio value\");\n return v as number;\n}\n\n// MEANINGFUL current positions, largest-value first, stopping once below minValue.\n// Server-side sort (sortBy=CURRENT desc) means even a wallet holding thousands of\n// dust positions returns in a page or two, because we never page past the\n// positions large enough to matter. Still validates identifiers/prices.\nexport async function readPositions(wallet: string, minValue = 0) {\n const rows: Record[] = [];\n const seen = new Set();\n for (let offset = 0; offset <= 20000; offset += 500) {\n const page = await readRows(\"/positions\", {\n user: wallet, limit: 500, offset, sizeThreshold: 0, sortBy: \"CURRENT\", sortDirection: \"DESC\",\n });\n for (const p of page) {\n if (typeof p.asset !== \"string\" || !p.asset || typeof p.conditionId !== \"string\" || !p.conditionId ||\n !Number.isFinite(p.currentValue) || p.currentValue < 0 ||\n !Number.isFinite(p.curPrice) || p.curPrice < 0 || p.curPrice > 1) {\n throw new Error(\"/positions: invalid identifiers or prices\");\n }\n if (p.currentValue < minValue) return rows; // sorted desc: everything after is smaller\n if (seen.has(p.asset)) throw new Error(\"/positions: duplicate asset; unstable pagination\");\n seen.add(p.asset);\n rows.push(p);\n }\n if (page.length < 500) return rows;\n }\n throw new Error(\"/positions: pagination limit reached; incomplete portfolio\");\n}\n",[270],"fbc1fba8-f6a4-436d-ab86-93e11db412d6","cron.ts","144328e0-b218-11f1-bc6e-1607ee4eb77e",4,["D",1789595191397],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { compute } from \"./lib.ts\";\n\n// Runs on a schedule (every 15 min on Val Town free tier) and records one row\n// per cycle, so over days we build the evidence base to answer the real\n// question: does a genuine net-positive edge ever appear, how large, how often?\n// Email alerts are intentionally NOT wired yet — they come with the automated\n// LLM verification step, so we only ever alert on verified leads, never the\n// residual false ones.\nexport default async function (interval: Interval) {\n const d = await compute(5);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS history (\n ts TEXT, kalshi INTEGER, poly INTEGER, matches INTEGER, pos INTEGER, best_net REAL\n )`);\n const pos = d.leads.filter((l) => l.net > 0);\n const best = d.leads.length ? d.leads[0].net : 0;\n await sqlite.execute({\n sql: \"INSERT INTO history (ts, kalshi, poly, matches, pos, best_net) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [d.stamp, d.kalshiCount, d.polyCount, d.leads.length, pos.length, best],\n });\n console.log(\n `stored ${d.stamp}: kalshi=${d.kalshiCount} poly=${d.polyCount} matches=${d.leads.length} pos=${pos.length} best=${(best * 100).toFixed(1)}c`,\n );\n}\n",[277],"8ef4f237-c489-4f18-b4b8-ff70d96ec5c5","confluence.tsx","0a0ca204-b22a-11f1-ab9a-1607ee4eb77e",20,["D",1789612429205],"import { leaderboard } from \"./smartmoney.ts\";\nimport { readRows, readValue, readPositions } from \"./data-api.ts\";\n\n// v2.2: integrity-hardened (from Codex's data-integrity pass) + signal-quality\n// refinements (Claude).\n// - Meaningful CURRENT holdings only (>= dust), largest-first; even wallets with\n// thousands of dust positions return fast, so no trader is dropped.\n// - Conviction denominator = authoritative /value portfolio total.\n// - Per-wallet errors are reported, not fatal (partial flag; no blanking).\n// - BOTH-SIDES NETTING: a trader hedged on both outcomes of a market is netted\n// out of it (market-making, not a directional view).\n// - CONVICTION: each holder's position as % of their live book.\n// - INDEPENDENCE: coHold = how many markets a confluence's holders ALL share; a\n// high number means they hold a bit of everything, so the agreement is cheap.\nexport const COLLECTOR_VERSION = \"2.2.0\";\nconst categories = new Set([\"OVERALL\", \"POLITICS\", \"SPORTS\", \"ESPORTS\", \"CRYPTO\", \"CULTURE\", \"MENTIONS\", \"WEATHER\", \"ECONOMICS\", \"TECH\", \"FINANCE\"]);\n\nfunction parameters(url: URL) {\n const category = url.searchParams.get(\"cat\") ?? \"POLITICS\";\n const top = Number(url.searchParams.get(\"top\") ?? 8);\n const minvol = Number(url.searchParams.get(\"minvol\") ?? 250000);\n const dust = Number(url.searchParams.get(\"dust\") ?? 500);\n if (!categories.has(category) || !Number.isInteger(top) || top < 1 || top > 50 ||\n !Number.isFinite(minvol) || minvol < 0 || !Number.isFinite(dust) || dust < 0) {\n throw new Error(\"Invalid parameters: category, top (1-50), minvol or dust\");\n }\n return { category, top, minvol, dust };\n}\n\nconst tradeable = (p: any) => p.redeemable !== true && p.curPrice > 0 && p.curPrice < 1;\n\nexport async function collectSnapshot(url: URL) {\n const params = parameters(url);\n const startedAt = new Date().toISOString();\n const candidates = (await leaderboard(params.category, 1, \"MONTH\")).slice(0, params.top);\n if (new Set(candidates.map((c) => c.proxyWallet.toLowerCase())).size !== candidates.length) {\n throw new Error(\"Duplicate wallet in candidate leaderboard\");\n }\n\n const observations: any[] = [];\n const errors: { wallet: string; message: string }[] = [];\n for (const candidate of candidates) {\n const wallet = candidate.proxyWallet;\n try {\n const all = (await readRows(\"/v1/leaderboard\", { category: params.category, timePeriod: \"ALL\", user: wallet }))[0];\n if (!all || typeof all.proxyWallet !== \"string\" || all.proxyWallet.toLowerCase() !== wallet.toLowerCase() ||\n !Number.isFinite(all.pnl) || !Number.isFinite(all.vol) || all.vol < 0) {\n throw new Error(\"Missing or invalid all-time trader record\");\n }\n const qualified = candidate.pnl > 0 && all.pnl > 0 && all.vol >= params.minvol;\n const bookValue = qualified ? await readValue(wallet) : 0;\n const positions = qualified ? await readPositions(wallet, params.dust) : [];\n observations.push({ wallet, name: candidate.userName || wallet, qualified, month: candidate, allTime: all, bookValue, positions, observedAt: new Date().toISOString() });\n } catch (error) {\n errors.push({ wallet, message: String(error) });\n }\n }\n const qualified = observations.filter((o) => o.qualified);\n\n const sides = new Map();\n for (const trader of qualified) {\n // both-sides netting: drop any market where this trader holds >1 outcome\n const outcomes = new Map>();\n for (const p of trader.positions) {\n if (!tradeable(p)) continue;\n const set = outcomes.get(p.conditionId) ?? new Set();\n set.add(p.asset);\n outcomes.set(p.conditionId, set);\n }\n const hedged = new Set([...outcomes].filter(([, s]) => s.size > 1).map(([cid]) => cid));\n\n for (const p of trader.positions) {\n if (!tradeable(p) || hedged.has(p.conditionId)) continue;\n let side = sides.get(p.asset);\n if (!side) {\n side = { asset: p.asset, conditionId: p.conditionId, market: p.title, side: p.outcome, endDate: p.endDate, holders: [] as any[] };\n sides.set(p.asset, side);\n }\n if (side.conditionId !== p.conditionId || side.side !== p.outcome) {\n throw new Error(\"Inconsistent market identifiers across portfolios\");\n }\n const convictionPct = trader.bookValue > 0 ? +((p.currentValue / trader.bookValue) * 100).toFixed(1) : 0;\n side.holders.push({ name: trader.name, value: p.currentValue, avgPrice: p.avgPrice ?? null, observedPrice: p.curPrice, convictionPct });\n }\n }\n\n // independence: which markets each trader is in, to measure shared breadth\n const heldByTrader = new Map>();\n for (const [asset, s] of sides) {\n for (const h of s.holders) {\n let set = heldByTrader.get(h.name);\n if (!set) { set = new Set(); heldByTrader.set(h.name, set); }\n set.add(asset);\n }\n }\n\n const confluence = [...sides.values()].filter((s) => s.holders.length >= 2).map((s) => {\n const total = s.holders.reduce((a: number, h: any) => a + h.value, 0);\n const minConvictionPct = Math.min(...s.holders.map((h: any) => h.convictionPct));\n const sets = s.holders.map((h: any) => heldByTrader.get(h.name)!);\n let inter = new Set(sets[0]);\n for (const st of sets.slice(1)) inter = new Set([...inter].filter((a) => st.has(a)));\n const coHold = inter.size; // markets ALL these holders share (>=1, this one)\n s.holders.sort((a: any, b: any) => b.value - a.value);\n return {\n asset: s.asset, conditionId: s.conditionId,\n market: s.market, side: s.side, endDate: s.endDate,\n holders: s.holders.length,\n minConvictionPct, coHold,\n currentPrice: +(s.holders[0].observedPrice * 100).toFixed(1),\n totalExposure: \"$\" + Math.round(total), totalExposureValue: Math.round(total),\n who: s.holders.map((h: any) => `${h.name} ($${Math.round(h.value)}, ${h.convictionPct}% of book @ ${h.avgPrice != null ? Math.round(h.avgPrice * 100) : \"?\"}c)`),\n };\n }).sort((a, b) =>\n b.holders - a.holders ||\n a.coHold - b.coHold || // prefer distinct pairs over hold-everything grinders\n b.minConvictionPct - a.minConvictionPct ||\n Number(b.totalExposure.slice(1)) - Number(a.totalExposure.slice(1)));\n\n const complete = errors.length === 0;\n return {\n schemaVersion: 3, collectorVersion: COLLECTOR_VERSION, startedAt, completedAt: new Date().toISOString(),\n complete, partial: !complete,\n params: { ...params, vettedTraders: qualified.length, dustFloor: params.dust },\n vetted: qualified.map((o) => o.name), errors,\n confluenceCount: confluence.length, confluence,\n note: \"Confluence = same market+side held now by 2+ vetted traders, after netting out both-sides hedgers. convictionPct = position as % of that trader's live book. coHold = number of markets these same holders ALL share (higher = cheaper, hold-everything overlap). Gross overlap, NOT a trade recommendation; prices are observations, not executable quotes; positions are paged, not an atomic snapshot.\",\n };\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"GET\") return Response.json({ error: \"GET required\" }, { status: 405 });\n const url = new URL(req.url);\n try { parameters(url); } catch (error) { return Response.json({ error: String(error) }, { status: 400 }); }\n try {\n const snapshot = await collectSnapshot(url);\n return Response.json(snapshot, { status: 200 });\n } catch (error) {\n return Response.json({ complete: false, error: String(error), collectorVersion: COLLECTOR_VERSION }, { status: 502 });\n }\n}\n",[284],"f788f521-22ac-4929-be66-0cf60d3aef91","README.md","01a0ac2c-e909-715a-acf6-a11d788c48c7",["D",1789595019450],"# Welcome to Val Town\n\nVal Town is the simplest way to get code running in the cloud.\n\nThis is a basic HTML starter template.\n\n## Picking a starter\n\n| Starter | When to pick it |\n| --- | --- |\n| **[`basic-html-starter`](https://www.val.town/x/templates/basic-html-starter)** *(you're here)* | Static HTML pages. Sprinkle of vanilla JS. No server-side rendering. |\n| [`hono-jsx-starter`](https://www.val.town/x/templates/hono-jsx-starter) | Dynamic server-rendered HTML with JSX. API routes. No React, no SPA. |\n| [`react-hono-starter`](https://www.val.town/x/templates/react-hono-starter) | Client-side React SPA with a Hono API backend. |\n\n## Getting started\n\n1. Click `Remix` on this val to get a copy of it\n2. Click `main.tsx` to view the website\n3. Saves to any file will instantly deploy\n\n### ← main.tsx\n\nThis HTTP server hosts all of the other files in this val.\n\nTo view your site in a new tab, click on the `...` menu of `main.tsx` to copy\nyour live HTTP endpoint.\n\n### ← README.md\n\nThat's this file, where you can tell people what your cool website does and how\nyou built it.\n\n### ← index.html\n\nWhere you'll write the content of your website.\n\n### ← style.css\n\nCSS files add styling rules to your content.\n\n### ← script.js\n\nIf you're feeling fancy you can add interactivity to your site with JavaScript.\n\n### ← favicon.svg\n\nThe icon that shows up in the brower tab. Tip: AIs are pretty good at writing\nSVG favicons.\n\n---\n\nThis template was inspired by https://glitch.new/blank.\n",[291],"pulls","branches","forks","envVars",{"_303":63,"_305":63},"connections",{"_303":63,"_304":63},"count","unfilledCount","emptyCount",{"_43":290,"_32":291,"_30":292,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":388,"_13":63,"_33":20,"_35":294,"_24":25,"_161":-5,"_328":389,"_27":390},{"_43":283,"_32":284,"_30":285,"_155":-5,"_41":42,"_40":286,"_157":59,"_38":385,"_13":197,"_33":34,"_35":288,"_24":25,"_161":-5,"_328":386,"_27":387},{"_43":276,"_32":277,"_30":278,"_155":-5,"_41":42,"_40":279,"_157":59,"_38":382,"_13":63,"_33":182,"_35":281,"_24":25,"_161":-5,"_328":383,"_27":384},{"_43":269,"_32":270,"_30":271,"_155":-5,"_41":42,"_40":272,"_157":59,"_38":379,"_13":173,"_33":198,"_35":274,"_24":25,"_161":-5,"_328":380,"_27":381},{"_43":262,"_32":263,"_30":264,"_155":-5,"_41":42,"_40":265,"_157":59,"_38":376,"_13":173,"_33":34,"_35":267,"_24":25,"_161":-5,"_328":377,"_27":378},{"_43":256,"_32":257,"_30":258,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":373,"_13":63,"_33":20,"_35":260,"_24":25,"_161":-5,"_328":374,"_27":375},{"_43":250,"_32":251,"_30":252,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":370,"_13":63,"_33":20,"_35":254,"_24":25,"_161":-5,"_328":371,"_27":372},{"_43":244,"_32":245,"_30":246,"_155":-5,"_41":42,"_40":159,"_157":59,"_38":367,"_13":63,"_33":198,"_35":248,"_24":25,"_161":-5,"_328":368,"_27":369},{"_43":237,"_32":238,"_30":239,"_155":-5,"_41":42,"_40":240,"_157":59,"_38":364,"_13":173,"_33":198,"_35":242,"_24":25,"_161":-5,"_328":365,"_27":366},{"_43":232,"_32":233,"_30":57,"_155":-5,"_41":42,"_40":197,"_157":59,"_38":361,"_13":173,"_33":34,"_35":235,"_24":25,"_161":-5,"_328":362,"_27":363},{"_43":225,"_32":226,"_30":227,"_155":-5,"_41":42,"_40":228,"_157":25,"_38":358,"_13":188,"_33":198,"_35":230,"_24":25,"_161":-5,"_328":359,"_27":360},{"_43":221,"_32":28,"_30":31,"_155":-5,"_41":42,"_40":14,"_157":25,"_38":355,"_13":223,"_33":34,"_35":37,"_24":25,"_161":-5,"_328":356,"_27":357},{"_43":214,"_32":215,"_30":216,"_155":-5,"_41":42,"_40":217,"_157":59,"_38":352,"_13":173,"_33":182,"_35":219,"_24":25,"_161":-5,"_328":353,"_27":354},{"_43":207,"_32":208,"_30":209,"_155":-5,"_41":42,"_40":210,"_157":59,"_38":349,"_13":159,"_33":34,"_35":212,"_24":25,"_161":-5,"_328":350,"_27":351},{"_43":201,"_32":202,"_30":203,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":346,"_13":63,"_33":198,"_35":205,"_24":25,"_161":-5,"_328":347,"_27":348},{"_43":192,"_32":193,"_30":194,"_155":-5,"_41":42,"_40":195,"_157":59,"_38":343,"_13":197,"_33":198,"_35":199,"_24":25,"_161":-5,"_328":344,"_27":345},{"_43":185,"_32":186,"_30":187,"_155":-5,"_41":42,"_40":188,"_157":59,"_38":340,"_13":173,"_33":34,"_35":190,"_24":25,"_161":-5,"_328":341,"_27":342},{"_43":177,"_32":178,"_30":179,"_155":-5,"_41":42,"_40":180,"_157":59,"_38":337,"_13":159,"_33":182,"_35":183,"_24":25,"_161":-5,"_328":338,"_27":339},{"_43":170,"_32":171,"_30":172,"_155":-5,"_41":42,"_40":173,"_157":59,"_38":334,"_13":63,"_33":20,"_35":175,"_24":25,"_161":-5,"_328":335,"_27":336},{"_43":163,"_32":164,"_30":165,"_155":-5,"_41":42,"_40":166,"_157":59,"_38":331,"_13":63,"_33":34,"_35":168,"_24":25,"_161":-5,"_328":332,"_27":333},{"_43":152,"_32":153,"_30":154,"_155":-5,"_41":42,"_40":156,"_157":59,"_38":327,"_13":159,"_33":34,"_35":160,"_24":25,"_161":-5,"_328":329,"_27":330},["D",1789602419939],"children",[],[153],["D",1789602745352],[],[164],["D",1789595019450],[],[171],["D",1789613287298],[],[178],["D",1789598025051],[],[186],["D",1789602393690],[],[193],["D",1789595019450],[],[202],["D",1789613994930],[],[208],["D",1789615033707],[],[215],["D",1789623414648],[],[28],["D",1789623405851],[],[226],["D",1789595133283],[],[233],["D",1789623249708],[],[238],["D",1789595115886],[],[245],["D",1789595019450],[],[251],["D",1789595019450],[],[257],["D",1789617448415],[],[263],["D",1789611973733],[],[270],["D",1789595191397],[],[277],["D",1789612429205],[],[284],["D",1789595019450],[],[291],["D",1789595019450],["D",1789596070409],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":429,"_430":431,"_432":433,"_434":25,"_435":25,"_436":25,"_437":59,"_438":-5,"_439":-7,"_440":-7,"_441":63,"_442":25,"_443":25,"_444":-5,"_445":25,"_446":25,"_447":25,"_448":-5},"ENV",{"_400":401,"_402":403,"_404":90,"_405":406,"_407":408,"_409":410,"_411":412,"_413":414,"_415":416,"_417":418,"_419":420,"_421":422,"_423":424,"_425":426,"_427":428},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v53