[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","joaquinrubio","name","predmarket-monitor","path","smartmoney.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_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":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/joaquinrubio/predmarket-monitor/code/smartmoney.ts","extension","id","a26eaad1-02b3-4f2d-80e7-3ed5909e74a1","fileId","82953332-b21e-11f1-afc2-1607ee4eb77e","parentId","branchId","f1c2802b-7a05-402a-8e59-0a360e509b53","branchVersion",12,"latest",true,"createdAt",["D",1789602393690],"version",3,"fileType","script","content","// 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","deleted",false,"label",[14],"7b98160e-759a-451e-ac63-bac16ce91a02",["D",1789595019450],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Live Kalshi/Polymarket arbitrage monitor (detect-only)","imageUrl","userId","5a6bd924-f7ef-46ed-95a2-11ef633bd193","pinnedFileId","01a0ac2c-e909-715a-acf6-adfd5fd204b2","pinPreview","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",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_55":56,"_103":104,"_105":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",60,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Joaquin Rubio","avatar","https://lh3.googleusercontent.com/a/ACg8ocKu9e2FTAA0T_eao8qJSdToUv1ioGcVQUV0-zlGd4zBo0YpRA=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":42,"_147":42,"_148":42,"_149":32,"_150":-5,"_151":-7,"_152":-7,"_153":63,"_154":42,"_155":42,"_156":-5,"_157":42,"_158":42,"_159":42,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]