Drumbeat

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_158":-5,"_20":159,"_22":160,"_161":162,"_163":164,"_26":165,"_24":166,"_167":-5,"_168":-5,"_169":54,"_170":171,"_172":45,"_173":-5,"_174":-5,"_175":176},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","quincyh","name","drumbeat-proxy","branchName","main","version","path","client/drumbeat.tsx","project",{"_33":103,"_13":14,"_46":104,"_105":-5,"_106":54,"_107":108,"_109":108,"_110":111,"_112":-5,"_113":114,"_115":-5,"_116":54,"_117":-5,"_118":-5,"_119":48,"_120":121,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_135":136,"_137":138,"_139":140,"_141":54},"tree",[58,59,60],"file",{"_33":34,"_13":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":56},"contents",[],"upstream","pull","ahead","behind","envVars","id","90997dc2-7827-4aac-a897-aae606e7a0b3","drumbeat.tsx","fileId","5df178ec-ab16-11f1-8389-1607ee4eb77e","parentId","5d2195c9-723b-4189-8771-7c756bf386af","branchId","90ee1d7d-21ec-407a-ba52-c38082fe2bcb","branchVersion",6,"latest",true,"createdAt",["D",1788824797881],0,"fileType","script","content","/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useEffect, useRef, useCallback } from \"https://esm.sh/react@18.2.0\";\n\n/* ============================================================================\n DRUMBEAT — pre-drop chatter and intent scanner\n ----------------------------------------------------------------------------\n Catches the warm-up: who is about to push a coin, what the thesis is, and\n whether anyone else is saying it yet.\n\n WHAT THIS CAN AND CANNOT REACH — read once, then trust the code:\n\n X/Twitter and TikTok are not reachable from a browser. They require paid\n API keys and send no CORS headers, so no client-side app can touch them.\n Anything claiming otherwise runs a server you don't control. The CUSTOM\n adapter at the bottom is the slot for those — point it at your own proxy\n or key-holding endpoint and it folds straight into the scoring.\n\n What IS open, no key, CORS-clean:\n · DEX Screener token profiles — a project's own description + socials,\n published when they start marketing. This is the thesis, in their words.\n · DEX Screener boosts — money spent to be seen, with amounts.\n · DEX Screener orders — marketing purchase history per token.\n · DEX Screener pairs — used to answer \"has it dropped yet?\"\n · 4chan /biz/ — raw forum chatter, free JSON.\n · Telegram Bot API — any channel/group your bot is in.\n\n The core idea: paid promotion is INTENT, and intent precedes the push.\n A token with a fresh profile, a boost purchased, socials attached, and no\n real liquidity yet is someone loading the cannon.\n ========================================================================== */\n\n/* --- Endpoints ----------------------------------------------------------- */\nconst DS = \"https://api.dexscreener.com\";\nconst BIZ = \"https://a.4cdn.org/biz/catalog.json\";\nconst TG = \"https://api.telegram.org\";\n\n/* --- Tunables ------------------------------------------------------------ */\nconst SCAN_INTERVAL_MS = 60000;\nconst REQ_DELAY_MS = 350; // profile/boost endpoints allow 60/min\nconst PAIR_BATCH = 30; // DS pairs endpoint accepts up to 30 addrs\nconst ORDER_LOOKUPS = 8; // deepest, slowest call — top N only\nconst MAX_ROWS = 24;\nconst HISTORY_CAP = 20;\n\n/* --- Text mining --------------------------------------------------------- */\nconst RE_TICKER = /\\$([A-Za-z][A-Za-z0-9]{1,9})\\b/g;\nconst RE_SOL = /\\b[1-9A-HJ-NP-Za-km-z]{32,44}\\b/g;\nconst RE_EVM = /\\b0x[a-fA-F0-9]{40}\\b/g;\n\nconst STOP_TICKERS = new Set([\n \"USD\", \"USDT\", \"USDC\", \"SOL\", \"ETH\", \"BTC\", \"BNB\", \"WETH\", \"DAI\", \"EUR\",\n \"GBP\", \"JPY\", \"MC\", \"ATH\", \"FDV\", \"LP\", \"TP\", \"SL\", \"PNL\", \"APY\", \"USDE\",\n]);\n\nconst stripHtml = (s = \"\") =>\n s.replace(//gi, \" \")\n .replace(/<[^>]+>/g, \"\")\n .replace(/"/g, '\"').replace(/'/g, \"'\")\n .replace(/>/g, \">\").replace(/</g, \"<\").replace(/&/g, \"&\")\n .replace(/\\s+/g, \" \")\n .trim();\n\n/* Relay bots post formatted cards for tokens that have ALREADY migrated —\n the opposite of this app's lane. They're not worthless (they confirm a\n token exists) but four bot cards must never outweigh four humans talking.\n Detected on template markers plus zero engagement, then heavily discounted. */\nconst BOT_MARKERS = [\n /migration/i, /risk check/i, /risk board/i, /trade routes/i,\n /mint authority/i, /freeze authority/i, /check events/i, /all events/i,\n /quick swap/i, /dyor/i, /signal card/i, /context trail/i, /market path/i,\n];\n\nfunction botLikelihood(text, engagement = 0) {\n const hits = BOT_MARKERS.filter((re) => re.test(text)).length;\n if (hits >= 3) return engagement > 3 ? 0.6 : 1;\n if (hits === 2) return engagement > 3 ? 0.3 : 0.75;\n return 0;\n}\n\nfunction mineText(text) {\n const out = { tickers: [], addrs: [] };\n if (!text) return out;\n let m;\n RE_TICKER.lastIndex = 0;\n while ((m = RE_TICKER.exec(text))) {\n const t = m[1].toUpperCase();\n if (!STOP_TICKERS.has(t) && t.length >= 2) out.tickers.push(t);\n }\n RE_EVM.lastIndex = 0;\n while ((m = RE_EVM.exec(text))) out.addrs.push({ chain: \"evm\", addr: m[0] });\n RE_SOL.lastIndex = 0;\n while ((m = RE_SOL.exec(text))) {\n if (!/^0x/.test(m[0])) out.addrs.push({ chain: \"solana\", addr: m[0] });\n }\n return out;\n}\n\n/* --- Math ---------------------------------------------------------------- */\nconst clamp = (v, lo = 0, hi = 1) => Math.min(hi, Math.max(lo, v));\nconst num = (v) => { const n = typeof v === \"string\" ? parseFloat(v) : v; return Number.isFinite(n) ? n : 0; };\nconst mean = (a) => (a.length ? a.reduce((x, y) => x + y, 0) / a.length : 0);\n\nfunction logRamp(x, zero, full) {\n if (!Number.isFinite(x) || x <= 0) return 0;\n return clamp(Math.log(Math.max(x, zero) / zero) / Math.log(full / zero));\n}\n\n/** Weighted geometric mean — one dead family caps the whole score. */\nfunction geoMean(pairs) {\n let ls = 0, ws = 0;\n for (const [v, w] of pairs) { ls += Math.log(Math.max(v, 0.001)) * w; ws += w; }\n return ws ? Math.exp(ls / ws) : 0;\n}\n\nconst fmtUsd = (v) => {\n const n = num(v);\n if (n >= 1e9) return \"$\" + (n / 1e9).toFixed(2) + \"B\";\n if (n >= 1e6) return \"$\" + (n / 1e6).toFixed(2) + \"M\";\n if (n >= 1e3) return \"$\" + (n / 1e3).toFixed(1) + \"K\";\n return \"$\" + n.toFixed(0);\n};\n\nconst fmtAgo = (ts) => {\n if (!ts) return \"—\";\n const m = (Date.now() - ts) / 60000;\n if (m < 1) return \"just now\";\n if (m < 60) return Math.round(m) + \"m ago\";\n if (m < 60 * 36) return (m / 60).toFixed(1) + \"h ago\";\n return (m / 1440).toFixed(1) + \"d ago\";\n};\n\nconst shorten = (a = \"\") => (a.length > 12 ? a.slice(0, 5) + \"…\" + a.slice(-4) : a);\n\n/* ============================ IndexedDB ==================================\n Blocked in some sandboxes (Claude artifacts among them). Falls back to an\n in-memory store so velocity still has a baseline to measure against for the\n life of the session — it just doesn't survive a reload. */\nconst DB_NAME = \"drumbeat\";\n\nconst memStore = { subjects: new Map(), alerts: new Map() };\nlet idbUsable = null; // null = untested, false = unavailable\n\nfunction openDb() {\n return new Promise((res, rej) => {\n if (typeof indexedDB === \"undefined\") return rej(new Error(\"no indexedDB\"));\n const r = indexedDB.open(DB_NAME, 1);\n r.onupgradeneeded = () => {\n const db = r.result;\n if (!db.objectStoreNames.contains(\"subjects\")) db.createObjectStore(\"subjects\", { keyPath: \"id\" });\n if (!db.objectStoreNames.contains(\"alerts\")) db.createObjectStore(\"alerts\", { keyPath: \"id\" });\n };\n r.onsuccess = () => res(r.result);\n r.onerror = () => rej(r.error);\n r.onblocked = () => rej(new Error(\"blocked\"));\n });\n}\n\nasync function dbAll(store) {\n if (idbUsable === false) return [...memStore[store].values()];\n try {\n const db = await openDb();\n const rows = await new Promise((res, rej) => {\n const req = db.transaction(store, \"readonly\").objectStore(store).getAll();\n req.onsuccess = () => res(req.result || []);\n req.onerror = () => rej(req.error);\n });\n idbUsable = true;\n return rows;\n } catch {\n idbUsable = false;\n return [...memStore[store].values()];\n }\n}\n\nasync function dbPutMany(store, rows) {\n rows.forEach((r) => memStore[store].set(r.id, r)); // always mirror\n if (idbUsable === false) return;\n try {\n const db = await openDb();\n await new Promise((res, rej) => {\n const tx = db.transaction(store, \"readwrite\");\n const os = tx.objectStore(store);\n rows.forEach((r) => os.put(r));\n tx.oncomplete = () => res();\n tx.onerror = () => rej(tx.error);\n });\n idbUsable = true;\n } catch {\n idbUsable = false;\n }\n}\n\nasync function dbClear(store) {\n memStore[store].clear();\n if (idbUsable === false) return;\n try {\n const db = await openDb();\n await new Promise((res) => {\n const tx = db.transaction(store, \"readwrite\");\n tx.objectStore(store).clear();\n tx.oncomplete = () => res();\n tx.onerror = () => res();\n });\n } catch { /* memory copy is already cleared */ }\n}\n\n/* ============================== Fetch ==================================== */\nconst sleep = (ms) => new Promise((r) => setTimeout(r, ms));\n\nasync function getJson(url, signal) {\n const res = await fetch(url, { signal, headers: { Accept: \"application/json\" } });\n if (res.status === 429) throw new Error(\"rate-limited\");\n if (!res.ok) throw new Error(\"HTTP \" + res.status);\n return res.json();\n}\n\n/* ============================== Adapters =================================\n Every adapter returns a flat list of Signals:\n { source, kind, chain, addr, ticker, title, text, links, ts, weight, boost }\n ======================================================================== */\n\nasync function pullDexProfiles(signal) {\n const rows = await getJson(`${DS}/token-profiles/latest/v1`, signal);\n const list = Array.isArray(rows) ? rows : rows?.data || [];\n return list.map((r) => ({\n source: \"profile\",\n kind: \"intent\",\n chain: r.chainId,\n addr: r.tokenAddress,\n ticker: null,\n title: \"New token profile\",\n text: (r.description || \"\").slice(0, 600),\n links: (r.links || []).map((l) => ({ type: l.type || l.label, url: l.url })),\n url: r.url,\n icon: r.icon,\n ts: Date.now(),\n weight: 1,\n boost: 0,\n }));\n}\n\nasync function pullDexBoosts(signal, top = false) {\n const path = top ? \"/token-boosts/top/v1\" : \"/token-boosts/latest/v1\";\n const rows = await getJson(DS + path, signal);\n const list = Array.isArray(rows) ? rows : rows?.data || [];\n return list.map((r) => ({\n source: top ? \"boost-top\" : \"boost-new\",\n kind: \"intent\",\n chain: r.chainId,\n addr: r.tokenAddress,\n ticker: null,\n title: top ? \"Sustained boost spend\" : \"Boost purchased\",\n text: (r.description || \"\").slice(0, 600),\n links: (r.links || []).map((l) => ({ type: l.type || l.label, url: l.url })),\n url: r.url,\n icon: r.icon,\n ts: Date.now(),\n weight: top ? 1.1 : 1.35,\n boost: num(r.totalAmount) || num(r.amount),\n }));\n}\n\nasync function pullBiz(signal, proxyUrl) {\n /* 4chan sends no CORS headers, so the direct URL only works from a\n non-browser context. Point this at the Worker's /biz route. */\n const pages = await getJson(proxyUrl || BIZ, signal);\n const out = [];\n const cutoff = Date.now() / 1000 - 60 * 60 * 8;\n (Array.isArray(pages) ? pages : []).forEach((pg) => {\n (pg.threads || []).forEach((th) => {\n if ((th.last_modified || 0) < cutoff) return;\n const text = stripHtml((th.sub || \"\") + \" \" + (th.com || \"\"));\n const mined = mineText(text);\n if (!mined.tickers.length && !mined.addrs.length) return;\n const heat = clamp(logRamp(num(th.replies) + 1, 2, 250), 0.15, 1);\n const seen = new Set();\n const push = (ticker, chain, addr) => {\n const key = (addr || ticker || \"\").toLowerCase();\n if (seen.has(key)) return;\n seen.add(key);\n out.push({\n source: \"biz\",\n kind: \"chatter\",\n chain: chain || null,\n addr: addr || null,\n ticker: ticker || null,\n title: stripHtml(th.sub || \"\").slice(0, 90) || \"thread\",\n text: text.slice(0, 400),\n links: [],\n url: `https://boards.4chan.org/biz/thread/${th.no}`,\n ts: (th.last_modified || 0) * 1000,\n author: \"thread-\" + th.no,\n engagement: num(th.replies),\n bot: false,\n weight: 0.55 + 0.65 * heat,\n boost: 0,\n replies: num(th.replies),\n });\n };\n mined.addrs.forEach((a) => push(null, a.chain, a.addr));\n mined.tickers.slice(0, 3).forEach((t) => push(t, null, null));\n });\n });\n return out;\n}\n\nasync function pullTelegram(signal, token, offsetRef) {\n if (!token) return [];\n const url = `${TG}/bot${token}/getUpdates?limit=100&allowed_updates=[\"message\",\"channel_post\"]` +\n (offsetRef.current ? `&offset=${offsetRef.current}` : \"\");\n const json = await getJson(url, signal);\n if (!json.ok) throw new Error(json.description || \"telegram rejected the token\");\n const out = [];\n (json.result || []).forEach((u) => {\n offsetRef.current = Math.max(offsetRef.current || 0, (u.update_id || 0) + 1);\n const msg = u.message || u.channel_post;\n if (!msg) return;\n const text = msg.text || msg.caption || \"\";\n const mined = mineText(text);\n const where = msg.chat?.title || msg.chat?.username || \"chat\";\n const who = msg.from?.username || msg.from?.first_name || msg.author_signature || where;\n const bot = botLikelihood(text, 0);\n const seen = new Set();\n const push = (ticker, chain, addr) => {\n const key = (addr || ticker || \"\").toLowerCase();\n if (seen.has(key)) return;\n seen.add(key);\n out.push({\n source: \"telegram\",\n kind: \"chatter\",\n chain: chain || null,\n addr: addr || null,\n ticker: ticker || null,\n title: where,\n text: text.slice(0, 400),\n links: [],\n url: null,\n ts: (msg.date || 0) * 1000 || Date.now(),\n author: String(who).toLowerCase(),\n engagement: 0,\n bot: bot >= 0.7,\n weight: 1.15 * (1 - bot * 0.8),\n });\n };\n mined.addrs.forEach((a) => push(null, a.chain, a.addr));\n mined.tickers.slice(0, 3).forEach((t) => push(t, null, null));\n if (!seen.size && text.length > 40 && bot < 0.7) {\n out.push({\n source: \"telegram\", kind: \"chatter\", chain: null, addr: null, ticker: null,\n title: where, text: text.slice(0, 400), links: [], url: null,\n ts: (msg.date || 0) * 1000 || Date.now(),\n author: String(who).toLowerCase(), engagement: 0, bot: false, weight: 1.15,\n });\n }\n });\n return out;\n}\n\n/** Generic adapter for anything you host yourself — an X proxy, Fomoscope,\n an RSS-to-JSON bridge. Expects an array, or {data:[...]} / {items:[...]}.\n Each entry is mined for tickers and addresses from `field`. */\nasync function pullCustom(signal, url, field) {\n if (!url) return [];\n const json = await getJson(url, signal);\n const list = Array.isArray(json) ? json : json.data || json.items || json.results || [];\n const out = [];\n list.forEach((row) => {\n const text = String(\n (field && row[field]) || row.text || row.content || row.thesis ||\n row.description || row.title || \"\"\n );\n const mined = mineText(text);\n const addr = row.tokenAddress || row.address || row.mint || null;\n const chain = row.chainId || row.chain || null;\n const author = row.author || row.trader || row.username || row.name || null;\n const engagement = num(row.likes) + num(row.replies) + num(row.retweets);\n const bot = botLikelihood(text, engagement);\n\n const base = {\n source: \"custom\",\n kind: \"chatter\",\n title: author || \"custom feed\",\n text: text.slice(0, 400),\n links: [],\n url: row.url || row.link || null,\n ts: row.timestamp ? new Date(row.timestamp).getTime() : Date.now(),\n author: author ? String(author).toLowerCase() : null,\n engagement,\n bot: bot >= 0.7,\n weight: 1.2 * (1 - bot * 0.8), // a bot card is worth ~a fifth of a human\n };\n\n const seen = new Set();\n const push = (ticker, ch, ad) => {\n const key = (ad || ticker || \"\").toLowerCase();\n if (!key || seen.has(key)) return;\n seen.add(key);\n out.push({ ...base, chain: ch || null, addr: ad || null, ticker: ticker || null });\n };\n\n if (addr) push(row.symbol || null, chain, addr);\n mined.addrs.forEach((a) => push(null, a.chain, a.addr));\n mined.tickers.slice(0, 3).forEach((t) => push(t, null, null));\n\n /* Nothing to key on — a post like \"a dev is cooking something, monitor\n when they launch\". Emitted keyless so assemble() can attach it to a\n watchlist narrative instead of throwing it away. */\n if (!seen.size && text.length > 40 && !bot) {\n out.push({ ...base, chain: null, addr: null, ticker: null });\n }\n });\n return out;\n}\n\n/* ========================= Subject assembly ============================== */\nfunction subjectKey(sig, watchWords = []) {\n if (sig.addr) return (sig.chain ? sig.chain + \":\" : \"\") + sig.addr.toLowerCase();\n if (sig.ticker) return \"$\" + sig.ticker.toUpperCase();\n /* No ticker and no contract — the \"a dev is cooking something\" case. Keyed\n to one of your narrative words if it mentions one, otherwise dropped. */\n const hay = (sig.text || \"\").toLowerCase();\n const hit = watchWords.find((w) => w && hay.includes(w.toLowerCase()));\n return hit ? \"~\" + hit.toLowerCase() : null;\n}\n\nfunction assemble(signals, watchWords = []) {\n const map = new Map();\n for (const s of signals) {\n const key = subjectKey(s, watchWords);\n if (!key) continue;\n if (!map.has(key)) {\n map.set(key, {\n id: key,\n addr: s.addr || null,\n chain: s.chain || null,\n ticker: s.ticker || null,\n narrative: key.startsWith(\"~\") ? key.slice(1) : null,\n signals: [],\n links: [],\n boost: 0,\n firstSeen: s.ts,\n lastSeen: s.ts,\n });\n }\n const sub = map.get(key);\n sub.signals.push(s);\n sub.addr = sub.addr || s.addr;\n sub.chain = sub.chain || s.chain;\n sub.ticker = sub.ticker || s.ticker;\n sub.boost = Math.max(sub.boost, s.boost || 0);\n sub.firstSeen = Math.min(sub.firstSeen, s.ts);\n sub.lastSeen = Math.max(sub.lastSeen, s.ts);\n (s.links || []).forEach((l) => {\n if (l.url && !sub.links.find((x) => x.url === l.url)) sub.links.push(l);\n });\n if (!sub.icon && s.icon) sub.icon = s.icon;\n if (!sub.dsUrl && s.url && s.source.startsWith(\"boost\")) sub.dsUrl = s.url;\n if (!sub.dsUrl && s.url && s.source === \"profile\") sub.dsUrl = s.url;\n }\n return [...map.values()];\n}\n\n/* ============================== Scoring ================================== */\nconst SOCIAL_TYPES = [\"twitter\", \"telegram\", \"discord\", \"website\", \"tiktok\", \"youtube\"];\n\nfunction scoreSubject(sub, hist, watchWords) {\n const sources = new Set(sub.signals.map((s) => s.source));\n\n /* Reach — how many independent voices are saying this. Two axes, because\n either one alone is gameable: five bot cards from one relay account is\n not five sources, and five humans in one feed is not one source. */\n const distinctSources = sources.size;\n const humanSignals = sub.signals.filter((s) => !s.bot);\n const authors = new Set(humanSignals.map((s) => s.author).filter(Boolean));\n const botOnly = sub.signals.length > 0 && humanSignals.length === 0;\n\n const sourceReach = clamp((distinctSources - 1) / 3 + 0.18);\n const authorReach = authors.size ? clamp((authors.size - 1) / 4 + 0.15) : 0;\n const hi = Math.max(sourceReach, authorReach);\n const lo = Math.min(sourceReach, authorReach);\n const reach = clamp(hi * 0.75 + lo * 0.25) * (botOnly ? 0.4 : 1);\n\n const distinct = Math.max(distinctSources, authors.size);\n\n /* Velocity — acceleration against this subject's own baseline, not raw\n volume. A coin mentioned 40 times an hour for a day is not news. */\n const samples = hist?.samples || [];\n const now = humanSignals.length + (sub.signals.length - humanSignals.length) * 0.2;\n const baseline = samples.length ? mean(samples.slice(-5).map((s) => s.count)) : 0;\n const growth = baseline > 0 ? now / baseline : now > 1 ? 1.6 : 1.0;\n const velocity = clamp(logRamp(growth, 0.9, 4.5) * 0.75 + logRamp(now, 1, 12) * 0.25);\n\n /* Commitment — money and effort. Boost spend, socials attached, a real\n description rather than three emojis. */\n const spend = logRamp(sub.boost, 1, 500);\n const socialTypes = new Set(\n sub.links.map((l) => String(l.type || \"\").toLowerCase())\n .filter((t) => SOCIAL_TYPES.some((s) => t.includes(s)))\n );\n const socials = clamp(socialTypes.size / 3);\n const desc = sub.signals.map((s) => s.text || \"\").sort((a, b) => b.length - a.length)[0] || \"\";\n const thesis = clamp(desc.replace(/\\s+/g, \" \").trim().length / 220);\n const orders = clamp((sub.orderCount || 0) / 3);\n const commitment = clamp(spend * 0.4 + socials * 0.25 + thesis * 0.2 + orders * 0.15);\n\n /* Freshness — first heard recently, and still arriving. */\n const ageMin = (Date.now() - sub.firstSeen) / 60000;\n const quietMin = (Date.now() - sub.lastSeen) / 60000;\n const fresh = clamp(1 - ageMin / (60 * 12));\n const alive = clamp(1 - quietMin / 90);\n const freshness = clamp(fresh * 0.55 + alive * 0.45);\n\n /* Watchlist crossover — your own narrative keywords. */\n const hay = (desc + \" \" + sub.signals.map((s) => s.title).join(\" \")).toLowerCase();\n const hits = watchWords.filter((w) => w && hay.includes(w.toLowerCase()));\n const watchBoost = hits.length ? clamp(0.08 + hits.length * 0.05, 0, 0.2) : 0;\n\n /* Confidence — thin evidence gets suppressed rather than trusted. */\n const evidence = clamp(now / 5);\n const identified = sub.addr ? 1 : sub.narrative ? 0.4 : 0.55;\n const confidence = 0.5 + 0.5 * mean([evidence, identified, clamp(distinct / 3)]);\n\n const raw = geoMean([\n [reach, 0.3],\n [velocity, 0.25],\n [commitment, 0.28],\n [freshness, 0.17],\n ]);\n\n const heat = Math.round(clamp(raw * confidence + watchBoost, 0, 1) * 100);\n\n return {\n ...sub,\n fam: { reach, velocity, commitment, freshness },\n confidence, heat, distinct, watchHits: hits, thesisText: desc,\n mentions: now, rawCount: sub.signals.length, voices: authors.size,\n botOnly, growth,\n };\n}\n\n/* Lane: where in the lifecycle this is. Pre-launch is the whole point. */\nfunction laneFor(sub) {\n if (!sub.pairChecked) return \"unknown\";\n if (!sub.hasPair) return \"prelaunch\";\n if (sub.pairAgeMin != null && sub.pairAgeMin < 90) return \"dropped\";\n return \"live\";\n}\n\nconst LANE_COPY = {\n prelaunch: \"No pair yet\",\n dropped: \"Just dropped\",\n live: \"Already trading\",\n unknown: \"Unchecked\",\n};\n\n/* =============================== Scan =================================== */\nasync function runScan({ signal, onProgress, cfg, tgOffset }) {\n const signals = [];\n const stats = { calls: 0, bySource: {}, errors: [] };\n\n const step = async (name, fn) => {\n onProgress(name);\n try {\n const rows = await fn();\n stats.calls++;\n stats.bySource[name] = rows.length;\n signals.push(...rows);\n } catch (e) {\n if (signal.aborted) throw new Error(\"aborted\");\n stats.errors.push(`${name}: ${e.message}`);\n }\n await sleep(REQ_DELAY_MS);\n };\n\n await step(\"token profiles\", () => pullDexProfiles(signal));\n await step(\"new boosts\", () => pullDexBoosts(signal, false));\n await step(\"top boosts\", () => pullDexBoosts(signal, true));\n if (cfg.useBiz) await step(\"/biz/ threads\", () => pullBiz(signal, cfg.bizProxy));\n if (cfg.tgToken) await step(\"telegram\", () => pullTelegram(signal, cfg.tgToken, tgOffset));\n if (cfg.customUrl) await step(\"custom feed\", () => pullCustom(signal, cfg.customUrl, cfg.customField));\n\n const watchWords = cfg.watchlist.split(/[,\\n]/).map((w) => w.trim()).filter(Boolean);\n let subjects = assemble(signals, watchWords);\n\n /* ---- launch-state cross reference: has the talk turned into a token? */\n const withAddr = subjects.filter((s) => s.addr && s.chain && s.chain !== \"evm\");\n const batches = [];\n for (let i = 0; i < withAddr.length; i += PAIR_BATCH) batches.push(withAddr.slice(i, i + PAIR_BATCH));\n\n for (let i = 0; i < batches.length && i < 3; i++) {\n if (signal.aborted) throw new Error(\"aborted\");\n onProgress(`checking launch state ${i + 1}/${Math.min(batches.length, 3)}`);\n const addrs = batches[i].map((s) => s.addr).join(\",\");\n try {\n const json = await getJson(`${DS}/latest/dex/tokens/${addrs}`, signal);\n stats.calls++;\n const pairs = json?.pairs || [];\n batches[i].forEach((s) => {\n const mine = pairs.filter(\n (p) => p.baseToken?.address?.toLowerCase() === s.addr.toLowerCase()\n );\n s.pairChecked = true;\n s.hasPair = mine.length > 0;\n if (mine.length) {\n const best = mine.sort((a, b) => num(b.liquidity?.usd) - num(a.liquidity?.usd))[0];\n s.liq = num(best.liquidity?.usd);\n s.mcap = num(best.marketCap) || num(best.fdv);\n s.priceChange = num(best.priceChange?.h1);\n s.pairAddress = best.pairAddress;\n s.pairAgeMin = best.pairCreatedAt ? (Date.now() - best.pairCreatedAt) / 60000 : null;\n s.vol24 = num(best.volume?.h24);\n }\n });\n } catch (e) {\n if (signal.aborted) throw e;\n stats.errors.push(\"launch check: \" + e.message);\n }\n await sleep(REQ_DELAY_MS);\n }\n subjects.forEach((s) => { if (s.pairChecked === undefined) s.pairChecked = false; });\n\n /* ---- score, then deepen the best pre-launch names with order history */\n const histRows = await dbAll(\"subjects\");\n const histMap = new Map(histRows.map((h) => [h.id, h]));\n\n let scored = subjects.map((s) => scoreSubject(s, histMap.get(s.id), watchWords));\n scored.sort((a, b) => b.heat - a.heat);\n\n const deep = scored\n .filter((s) => s.addr && s.chain && s.chain !== \"evm\")\n .slice(0, ORDER_LOOKUPS);\n\n for (let i = 0; i < deep.length; i++) {\n if (signal.aborted) throw new Error(\"aborted\");\n onProgress(`marketing orders ${i + 1}/${deep.length}`);\n try {\n const orders = await getJson(`${DS}/orders/v1/${deep[i].chain}/${deep[i].addr}`, signal);\n stats.calls++;\n const list = Array.isArray(orders) ? orders : orders?.data || [];\n deep[i].orderCount = list.length;\n deep[i].orderTypes = [...new Set(list.map((o) => o.type).filter(Boolean))];\n const paid = list.map((o) => num(o.paymentTimestamp)).filter(Boolean);\n deep[i].firstPaid = paid.length ? Math.min(...paid) : null;\n } catch (e) {\n if (signal.aborted) throw e;\n }\n await sleep(REQ_DELAY_MS);\n }\n\n // rescore the deepened ones so order history actually counts\n scored = scored.map((s) =>\n deep.find((d) => d.id === s.id) ? scoreSubject(s, histMap.get(s.id), watchWords) : s\n );\n scored.sort((a, b) => b.heat - a.heat);\n\n /* ---- persist for next scan's velocity baseline */\n const now = Date.now();\n await dbPutMany(\"subjects\", scored.slice(0, 200).map((s) => {\n const prev = histMap.get(s.id)?.samples || [];\n return {\n id: s.id,\n ticker: s.ticker,\n addr: s.addr,\n samples: [...prev, { t: now, count: s.mentions, heat: s.heat }].slice(-HISTORY_CAP),\n };\n }));\n\n return { scored, stats };\n}\n\n/* =========================== Telegram alerts ============================= */\nasync function sendAlert(token, chatId, sub) {\n if (!token || !chatId) return;\n const lines = [\n `DRUMBEAT ${sub.heat} — ${sub.ticker ? \"$\" + sub.ticker : shorten(sub.addr)}`,\n `${LANE_COPY[laneFor(sub)]} · ${sub.distinct} sources · ${sub.mentions} mentions`,\n sub.boost ? `Boost spend ${sub.boost}` : null,\n sub.addr ? sub.addr : null,\n sub.thesisText ? sub.thesisText.slice(0, 220) : null,\n ].filter(Boolean);\n try {\n await fetch(`${TG}/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text: lines.join(\"\\n\"), disable_web_page_preview: true }),\n });\n } catch { /* alerting is best-effort */ }\n}\n\n/* ================================= UI ==================================== */\nconst LANES = [\n { id: \"prelaunch\", label: \"No pair yet\" },\n { id: \"dropped\", label: \"Just dropped\" },\n { id: \"live\", label: \"Trading\" },\n { id: \"all\", label: \"Everything\" },\n];\n\nexport default function Drumbeat() {\n const [rows, setRows] = useState([]);\n const [stats, setStats] = useState(null);\n const [status, setStatus] = useState(\"idle\");\n const [progress, setProgress] = useState(\"\");\n const [error, setError] = useState(null);\n const [lastRun, setLastRun] = useState(null);\n const [auto, setAuto] = useState(false);\n const [lane, setLane] = useState(\"prelaunch\");\n const [floor, setFloor] = useState(45);\n const [open, setOpen] = useState(null);\n const [showSetup, setShowSetup] = useState(false);\n\n const [useBiz, setUseBiz] = useState(true);\n const [bizProxy, setBizProxy] = useState(\"\");\n const [watchlist, setWatchlist] = useState(\"\");\n const [tgToken, setTgToken] = useState(\"\");\n const [tgChat, setTgChat] = useState(\"\");\n const [alertAt, setAlertAt] = useState(72);\n const [customUrl, setCustomUrl] = useState(\"\");\n const [customField, setCustomField] = useState(\"\");\n\n const abortRef = useRef(null);\n const timerRef = useRef(null);\n const tgOffset = useRef(0);\n const alerted = useRef(new Set());\n\n const scan = useCallback(async () => {\n abortRef.current?.abort();\n const ctrl = new AbortController();\n abortRef.current = ctrl;\n setStatus(\"scanning\");\n setError(null);\n try {\n const { scored, stats } = await runScan({\n signal: ctrl.signal,\n onProgress: setProgress,\n cfg: { useBiz, bizProxy, watchlist, tgToken, customUrl, customField },\n tgOffset,\n });\n setRows(scored);\n setStats(stats);\n setLastRun(Date.now());\n setStatus(\"idle\");\n setProgress(\"\");\n\n scored.filter((s) => s.heat >= alertAt && !alerted.current.has(s.id))\n .slice(0, 4)\n .forEach((s) => { alerted.current.add(s.id); sendAlert(tgToken, tgChat, s); });\n } catch (e) {\n if (e.message !== \"aborted\") { setError(e.message || \"scan failed\"); setStatus(\"idle\"); }\n }\n }, [useBiz, bizProxy, watchlist, tgToken, tgChat, customUrl, customField, alertAt]);\n\n useEffect(() => {\n if (!auto) { clearInterval(timerRef.current); return; }\n timerRef.current = setInterval(() => { if (status === \"idle\") scan(); }, SCAN_INTERVAL_MS);\n return () => clearInterval(timerRef.current);\n }, [auto, scan, status]);\n\n useEffect(() => () => abortRef.current?.abort(), []);\n\n const visible = rows\n .filter((r) => r.heat >= floor)\n .filter((r) => (lane === \"all\" ? true : laneFor(r) === lane))\n .slice(0, MAX_ROWS);\n\n const laneCounts = LANES.reduce((acc, l) => {\n acc[l.id] = l.id === \"all\"\n ? rows.filter((r) => r.heat >= floor).length\n : rows.filter((r) => r.heat >= floor && laneFor(r) === l.id).length;\n return acc;\n }, {});\n\n return (\n

\n \n\n

\n \n
\n
Drumbeat
\n
Who is warming up to push a coin
\n
\n

\n
\n \n Heat floor {floor}\n setFloor(+e.target.value)} />\n \n \n \n \n
\n

\n\n {showSetup && (\n
\n
\n
\n
Always on
\n
\n DEX Screener token profiles, new boosts and top boosts. No key, no limits worth\n worrying about. This is the intent layer — projects publishing a thesis and paying\n to be seen, usually before the push lands.\n
\n \n setUseBiz(e.target.checked)} />\n Also read 4chan /biz/ threads from the last 8 hours\n \n
\n 4chan sends no CORS headers, so a browser can’t read it directly — leave this\n blank and the source will fail. Point it at your Worker’s /biz route.\n
\n setBizProxy(e.target.value.trim())}\n />\n
\n\n
\n
Your narrative words
\n
Comma separated. Matches lift the heat score, same crossover idea as NarrativeWatch.
\n setWatchlist(e.target.value)}\n />\n
\n\n
\n
Telegram
\n
\n Your bot reads any group or channel it has been added to, and sends alerts above the\n threshold. Groups need privacy mode off; channels need the bot as admin.\n
\n setTgToken(e.target.value)} />\n setTgChat(e.target.value)} />\n \n Alert above {alertAt}\n setAlertAt(+e.target.value)} />\n \n
\n\n
\n
Custom feed
\n
\n The slot for anything you host or hold a key for — an X proxy, Fomoscope, an\n RSS bridge. Any JSON array. Entries get mined for tickers and contract addresses\n and folded into the same scoring.\n
\n setCustomUrl(e.target.value)} />\n setCustomField(e.target.value)} />\n
\n
\n
\n )}\n\n {status === \"scanning\" && (\n
{progress || \"starting\"}
\n )}\n {error &&
Scan failed: {error}
}\n {stats?.errors?.length > 0 && (\n
\n {stats.errors.length} source{stats.errors.length > 1 ? \"s\" : \"\"} unreachable this pass: {stats.errors.join(\" · \")}\n
\n )}\n\n
\n {LANES.map((l) => (\n setLane(l.id)}\n >\n {l.label} {laneCounts[l.id] ?? 0}\n \n ))}\n
\n\n
\n {visible.length === 0 && status !== \"scanning\" && (\n
\n
{rows.length === 0 ? \"Nothing heard yet.\" : \"Quiet in this lane.\"}
\n
\n {rows.length === 0\n ? \"Run a scan. The first pass has no baseline to measure acceleration against, so scores will read low — the second pass is where velocity starts working.\"\n : \"Nothing above the floor here right now. Try another lane or drop the floor.\"}\n
\n
\n )}\n\n {visible.map((r) => {\n const ln = laneFor(r);\n const isOpen = open === r.id;\n const hot = r.heat >= 72;\n return (\n
\n
\n {r.heat}\n \n
\n\n
\n
\n
{r.narrative ? r.narrative : r.ticker ? \"$\" + r.ticker : shorten(r.addr)}
\n {r.narrative\n ? narrative, no ticker\n : {LANE_COPY[ln]}}\n {r.chain && {r.chain}}\n {r.boost > 0 && boost {r.boost}}\n {r.botOnly && relay bots only}\n {r.watchHits.length > 0 && {r.watchHits.join(\", \")}}\n
\n\n
\n {r.voices > 0\n ? `${r.voices} distinct voice${r.voices > 1 ? \"s\" : \"\"} across ${r.distinct} source${r.distinct > 1 ? \"s\" : \"\"}`\n : `${r.distinct} source${r.distinct > 1 ? \"s\" : \"\"}`}\n , {r.rawCount} post{r.rawCount > 1 ? \"s\" : \"\"}\n {r.growth > 1.4 ? `, running ${r.growth.toFixed(1)}× its own baseline` : \"\"}.\n First heard {fmtAgo(r.firstSeen)}.\n {r.liq ? ` Liquidity ${fmtUsd(r.liq)}.` : \"\"}\n
\n\n {r.thesisText && (\n
{r.thesisText.slice(0, 240)}{r.thesisText.length > 240 ? \"…\" : \"\"}
\n )}\n\n
\n \n {r.addr && (\n \n DEX Screener\n \n )}\n {r.links.slice(0, 4).map((l, i) => (\n \n {String(l.type || \"link\").toLowerCase()}\n \n ))}\n {r.addr && (\n \n )}\n
\n\n {isOpen && (\n
\n
\n {[[\"reach\", \"distinct voices\"], [\"velocity\", \"acceleration\"],\n [\"commitment\", \"money and effort\"], [\"freshness\", \"still arriving\"]].map(([k, copy]) => (\n
\n {copy}\n \n {Math.round(r.fam[k] * 100)}\n
\n ))}\n
\n
\n Combined as a weighted geometric mean, then scaled by confidence\n ({Math.round(r.confidence * 100)}%). A bare ticker with no contract address\n is capped low on purpose — it can't be verified.\n {r.orderCount ? ` ${r.orderCount} marketing order${r.orderCount > 1 ? \"s\" : \"\"} on file${r.orderTypes?.length ? ` (${r.orderTypes.join(\", \")})` : \"\"}.` : \"\"}\n
\n
\n {r.signals.slice(0, 6).map((s, i) => (\n
\n {s.source}\n \n {s.url ? {s.title} : s.title}\n {s.text ? \" — \" + s.text.slice(0, 130) : \"\"}\n \n {fmtAgo(s.ts)}\n
\n ))}\n
\n
\n )}\n
\n
\n );\n })}\n
\n\n
\n \n {stats ? `${Object.values(stats.bySource).reduce((a, b) => a + b, 0)} signals · ${rows.length} subjects · ${stats.calls} calls` : \"no scan yet\"}\n \n {lastRun && last scan {new Date(lastRun).toLocaleTimeString()}}\n \n
\n

\n );\n}\n\n/* ================================ Style ================================== */\nconst CSS = `\n@import url('https://fonts.googleapis.com/css2?family=Archivo:wght@400;500;600;800&display=swap');\n\n.db-root {\n --ink: #141B24; --ink-2: #1B242F; --line: #2A3745; --bone: #E9E4D8;\n --mute: #7D8B99; --gold: #DFA53F; --teal: #4FA89B; --rust: #C4584C;\n --violet: #8E7BC4;\n font-family: Archivo, 'Helvetica Neue', Helvetica, Arial, sans-serif;\n font-variant-numeric: tabular-nums;\n background: var(--ink); color: var(--bone); min-height: 100vh;\n padding: 28px 22px 60px; box-sizing: border-box;\n}\n.db-root * { box-sizing: border-box; }\n\n.db-head { display: flex; flex-wrap: wrap; gap: 20px; justify-content: space-between; align-items: flex-end; border-bottom: 1px solid var(--line); padding-bottom: 18px; }\n.db-brand { display: flex; gap: 14px; align-items: center; }\n.db-mark { display: flex; align-items: flex-end; gap: 3px; height: 26px; }\n.db-mark i { width: 4px; background: var(--gold); display: block; }\n.db-mark i:nth-child(1) { height: 10px; }\n.db-mark i:nth-child(2) { height: 22px; }\n.db-mark i:nth-child(3) { height: 15px; }\n.db-brand h1 { margin: 0; font-size: 26px; font-weight: 800; letter-spacing: -0.02em; }\n.db-brand p { margin: 2px 0 0; font-size: 13px; color: var(--mute); }\n\n.db-controls { display: flex; flex-wrap: wrap; gap: 12px; align-items: flex-end; }\n.db-field { display: flex; flex-direction: column; gap: 5px; font-size: 12px; color: var(--mute); }\n.db-field.db-inline { margin-top: 10px; }\n.db-field input[type=range] { width: 140px; accent-color: var(--gold); }\n.db-btn { background: transparent; border: 1px solid var(--line); color: var(--bone); padding: 8px 16px; border-radius: 3px; font: inherit; font-size: 13px; font-weight: 500; cursor: pointer; }\n.db-btn:hover { border-color: var(--mute); }\n.db-btn:focus-visible { outline: 2px solid var(--gold); outline-offset: 2px; }\n.db-primary { background: var(--gold); border-color: var(--gold); color: #16202B; font-weight: 600; }\n.db-primary:disabled { opacity: .5; cursor: default; }\n.db-btn.db-on { border-color: var(--teal); color: var(--teal); }\n\n.db-setup { margin-top: 20px; padding: 20px; background: var(--ink-2); border-radius: 3px; }\n.db-setup-grid { display: grid; grid-template-columns: repeat(auto-fit, minmax(240px, 1fr)); gap: 26px; }\n.db-setup h3 { margin: 0 0 6px; font-size: 14px; font-weight: 600; }\n.db-setup input, .db-setup textarea { display: block; width: 100%; margin-top: 8px; background: var(--ink); border: 1px solid var(--line); color: var(--bone); padding: 7px 10px; border-radius: 3px; font: inherit; font-size: 13px; resize: vertical; }\n.db-setup input[type=range] { padding: 0; border: none; background: none; }\n.db-check { display: flex; gap: 8px; align-items: flex-start; margin-top: 12px; font-size: 13px; color: var(--bone); cursor: pointer; }\n.db-check input { width: auto; margin: 2px 0 0; accent-color: var(--gold); }\n.db-note { margin: 0; font-size: 12px; line-height: 1.6; color: var(--mute); max-width: 56ch; }\n\n.db-progress { display: flex; align-items: center; gap: 9px; font-size: 13px; color: var(--mute); padding: 14px 2px 0; }\n.db-pulse { width: 7px; height: 7px; border-radius: 50%; background: var(--gold); animation: dbp 1.1s ease-in-out infinite; }\n@keyframes dbp { 0%,100% { opacity: .25; } 50% { opacity: 1; } }\n@media (prefers-reduced-motion: reduce) { .db-pulse { animation: none; opacity: .8; } }\n.db-error { margin-top: 16px; padding: 12px 14px; border-left: 3px solid var(--rust); background: rgba(196,88,76,.09); font-size: 13px; }\n.db-warn { margin-top: 12px; padding: 10px 14px; border-left: 3px solid var(--gold); background: rgba(223,165,63,.07); font-size: 12px; color: var(--mute); }\n\n.db-lanes { display: flex; flex-wrap: wrap; gap: 22px; margin-top: 24px; border-bottom: 1px solid var(--line); padding-bottom: 12px; }\n.db-lane { background: none; border: none; padding: 0 0 4px; font: inherit; font-size: 14px; color: var(--mute); cursor: pointer; border-bottom: 2px solid transparent; margin-bottom: -14px; }\n.db-lane em { font-style: normal; font-size: 11px; color: var(--mute); margin-left: 4px; }\n.db-lane:hover { color: var(--bone); }\n.db-lane.db-on { color: var(--bone); border-bottom-color: var(--gold); }\n.db-lane:focus-visible { outline: 2px solid var(--gold); outline-offset: 3px; }\n\n.db-list { margin-top: 8px; }\n.db-empty { padding: 56px 0 40px; max-width: 58ch; }\n.db-empty-h { margin: 0 0 8px; font-size: 20px; font-weight: 600; }\n.db-empty-b { margin: 0; font-size: 14px; line-height: 1.6; color: var(--mute); }\n\n.db-row { display: grid; grid-template-columns: 76px 1fr; gap: 20px; padding: 22px 0; border-bottom: 1px solid var(--line); align-items: start; }\n.db-heat-num { font-size: 38px; font-weight: 800; line-height: .9; letter-spacing: -0.03em; display: block; }\n.db-hot .db-heat-num { color: var(--gold); }\n.db-heat-bar { display: block; height: 3px; background: var(--line); margin-top: 9px; }\n.db-heat-bar i { display: block; height: 100%; background: var(--teal); }\n.db-hot .db-heat-bar i { background: var(--gold); box-shadow: 0 0 10px rgba(223,165,63,.6); }\n\n.db-title { display: flex; flex-wrap: wrap; gap: 9px; align-items: baseline; }\n.db-title h2 { margin: 0; font-size: 21px; font-weight: 600; letter-spacing: -0.01em; }\n.db-tag, .db-lane-tag { font-size: 11px; padding: 3px 8px; border: 1px solid var(--line); border-radius: 2px; color: var(--mute); }\n.db-lane-tag.db-prelaunch { color: var(--violet); border-color: rgba(142,123,196,.45); }\n.db-lane-tag.db-dropped { color: var(--gold); border-color: rgba(223,165,63,.45); }\n.db-lane-tag.db-live { color: var(--teal); border-color: rgba(79,168,155,.35); }\n.db-tag.db-spend { color: var(--gold); border-color: rgba(223,165,63,.35); }\n.db-tag.db-watch { color: var(--teal); border-color: rgba(79,168,155,.35); }\n.db-tag.db-bot { color: var(--rust); border-color: rgba(196,88,76,.35); }\n\n.db-read { margin: 9px 0 8px; font-size: 14px; line-height: 1.55; max-width: 66ch; }\n.db-thesis { margin: 0 0 12px; font-size: 13px; line-height: 1.6; color: var(--mute); max-width: 68ch; border-left: 2px solid var(--line); padding-left: 12px; }\n\n.db-links { display: flex; flex-wrap: wrap; gap: 16px; }\n.db-link { background: none; border: none; padding: 0; font: inherit; font-size: 13px; color: var(--mute); cursor: pointer; text-decoration: none; border-bottom: 1px solid transparent; }\n.db-link:hover { color: var(--bone); border-bottom-color: var(--line); }\n.db-link:focus-visible { outline: 2px solid var(--gold); outline-offset: 3px; }\n.db-danger { color: var(--rust); }\n\n.db-detail { margin-top: 16px; padding: 16px 18px; background: var(--ink-2); border-radius: 3px; }\n.db-fams { display: grid; gap: 6px; }\n.db-fam { display: grid; grid-template-columns: 170px 1fr 34px; gap: 12px; align-items: center; font-size: 13px; }\n.db-fam-name { color: var(--mute); }\n.db-fam-bar { height: 3px; background: var(--line); }\n.db-fam-bar i { display: block; height: 100%; background: var(--teal); }\n.db-fam-val { text-align: right; font-weight: 600; }\n\n.db-sigs { margin-top: 14px; display: grid; gap: 7px; }\n.db-sig { display: grid; grid-template-columns: 78px 1fr 72px; gap: 12px; font-size: 12px; color: var(--mute); align-items: baseline; }\n.db-sig-src { color: var(--bone); }\n.db-sig-txt a { color: var(--mute); }\n.db-sig-txt a:hover { color: var(--bone); }\n.db-sig-ts { text-align: right; }\n\n.db-foot { margin-top: 30px; padding-top: 16px; border-top: 1px solid var(--line); display: flex; flex-wrap: wrap; gap: 18px; justify-content: space-between; font-size: 12px; color: var(--mute); }\n\n@media (max-width: 700px) {\n .db-root { padding: 20px 14px 48px; }\n .db-row { grid-template-columns: 58px 1fr; gap: 14px; }\n .db-heat-num { font-size: 30px; }\n .db-fam { grid-template-columns: 120px 1fr 30px; }\n .db-sig { grid-template-columns: 62px 1fr; }\n .db-sig-ts { display: none; }\n}\n`;\n","deleted",false,"label",[57,35],"client",{"_33":87,"_13":57,"_36":39,"_38":-5,"_40":41,"_42":88,"_44":45,"_46":89,"_17":48,"_49":76,"_51":-5,"_53":54,"_55":-5,"_68":90,"_18":91},{"_33":71,"_13":72,"_36":73,"_38":-5,"_40":41,"_42":74,"_44":45,"_46":75,"_17":48,"_49":76,"_51":-5,"_53":54,"_55":-5,"_68":77,"_18":78},{"_33":61,"_13":62,"_36":63,"_38":-5,"_40":41,"_42":64,"_44":45,"_46":65,"_17":48,"_49":66,"_51":67,"_53":54,"_55":14,"_68":69,"_18":70},"349b1e00-f502-4ee3-af35-bafd2286b4da","main.tsx","1ccc3852-ab16-11f1-8acc-1607ee4eb77e",4,["D",1788824688585],"http","import { serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\n/* ============================================================================\n DRUMBEAT PROXY — serves the Drumbeat UI plus the keyed data routes.\n The UI is public. /biz and /x are guarded by SHARED_SECRET and read the\n upstream (twitterapi.io) with PROVIDER_KEY.\n ========================================================================== */\n\nconst CACHE_TTL_MS = 180000; // 3 min between real X calls — this is your bill\nconst BIZ_TTL_MS = 90000;\nconst MAX_POSTS = 40;\n\n/* Queries run on each pull. Every entry costs money — keep this short. */\nconst QUERIES = [\n \"(launching OR launch OR deploying OR presale) (memecoin OR token) -is:retweet\",\n \"(CA OR contract) soon (dropping OR launching) -is:retweet\",\n \"$SOL (stealth OR fair launch) -is:retweet\",\n];\n\n/* Warm instances keep this between requests. A cold start = one extra call. */\nconst cache = new Map();\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, OPTIONS\",\n \"Content-Type\": \"application/json\",\n};\n\nfunction cached(key: string, ttl: number) {\n const hit = cache.get(key);\n if (hit && Date.now() - hit.at < ttl) return hit.body;\n return null;\n}\n\nfunction store(key: string, body: string) {\n cache.set(key, { at: Date.now(), body });\n return body;\n}\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n\n const url = new URL(req.url);\n const p = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n\n /* ---------- UI and client modules (public) ---------- */\n if (p === \"/\") return serveFile(\"frontend/index.html\");\n if (p.startsWith(\"/client/\")) return serveFile(url.pathname);\n\n /* ---------- data routes are keyed ---------- */\n const secret = Deno.env.get(\"SHARED_SECRET\");\n if (secret && url.searchParams.get(\"k\") !== secret) {\n return new Response(JSON.stringify({ error: \"bad key\" }), { status: 401, headers: CORS });\n }\n\n /* ---------- /biz: 4chan catalog ---------- */\n if (p.endsWith(\"/biz\")) {\n const hit = cached(\"biz\", BIZ_TTL_MS);\n if (hit) return new Response(hit, { headers: CORS });\n try {\n const res = await fetch(\"https://a.4cdn.org/biz/catalog.json\", {\n headers: { \"User-Agent\": \"drumbeat/1.0\" },\n });\n if (!res.ok) throw new Error(\"upstream \" + res.status);\n return new Response(store(\"biz\", await res.text()), { headers: CORS });\n } catch (e) {\n return new Response(JSON.stringify({ error: String(e) }), { status: 502, headers: CORS });\n }\n }\n\n /* ---------- /x: X search via twitterapi.io ---------- */\n if (p.endsWith(\"/x\")) {\n const custom = url.searchParams.get(\"q\");\n const queries = custom ? [custom] : QUERIES;\n const key = \"x:\" + queries.join(\"|\");\n\n const hit = cached(key, CACHE_TTL_MS);\n if (hit) return new Response(hit, { headers: CORS });\n\n const apiKey = Deno.env.get(\"PROVIDER_KEY\");\n if (!apiKey) {\n return new Response(JSON.stringify({ error: \"PROVIDER_KEY not set\" }), { status: 500, headers: CORS });\n }\n\n const out: any[] = [];\n const errors: string[] = [];\n\n for (const q of queries) {\n try {\n const u = new URL(\"https://api.twitterapi.io/twitter/tweet/advanced_search\");\n u.searchParams.set(\"query\", q);\n u.searchParams.set(\"queryType\", \"Latest\");\n\n const res = await fetch(u, { headers: { \"X-API-Key\": apiKey } });\n if (!res.ok) throw new Error(\"upstream \" + res.status);\n\n const body = await res.json();\n const tweets = body.tweets || body.data || [];\n\n for (const t of tweets.slice(0, MAX_POSTS)) {\n const author = t.author?.userName || t.author?.screen_name || t.username || \"unknown\";\n const id = String(t.id || t.id_str || Math.random());\n out.push({\n id,\n text: String(t.text || t.full_text || \"\").replace(/\\s+/g, \" \").trim(),\n author,\n url: `https://x.com/${author}/status/${id}`,\n timestamp: t.createdAt || t.created_at\n ? new Date(t.createdAt || t.created_at).toISOString()\n : new Date().toISOString(),\n likes: t.likeCount ?? t.favorite_count ?? 0,\n replies: t.replyCount ?? t.reply_count ?? 0,\n });\n }\n } catch (e) {\n errors.push(`${q.slice(0, 30)}: ${String(e)}`);\n }\n }\n\n const seen = new Set();\n const items = out\n .filter((r) => (seen.has(r.id) ? false : (seen.add(r.id), true)))\n .sort((a, b) => +new Date(b.timestamp) - +new Date(a.timestamp));\n\n const payload = JSON.stringify(items.length ? items : { data: [], errors });\n return new Response(store(key, payload), { headers: CORS });\n }\n\n return new Response(JSON.stringify({ error: \"not found\" }), { status: 404, headers: CORS });\n}\n","children",[],[62],"b65bdd00-7363-4db8-ae28-a6e540e38472","frontend","bfda586b-4e1d-455e-88e6-68c60be2ff47",2,["D",1788824688482],"directory",[79],[72],{"_33":80,"_13":81,"_36":82,"_38":73,"_40":41,"_42":74,"_44":45,"_46":83,"_17":48,"_49":24,"_51":84,"_53":54,"_55":-5,"_68":85,"_18":86},"a39aea4e-2dd5-4065-8c57-c631f5063824","index.html","1cbd08dc-ab16-11f1-8acc-1607ee4eb77e",["D",1788824688482],"\n\n\n\n\nDrumbeat\n\n\n\n
\n\n\n\n",[],[72,81],"f905e11e-7fb2-4c98-8ce3-7f4e3ef87d46",3,["D",1788824688530],[92,93],[57],{"_33":34,"_13":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":100,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_68":101,"_18":102},{"_33":94,"_13":62,"_36":95,"_38":39,"_40":41,"_42":88,"_44":45,"_46":96,"_17":48,"_49":50,"_51":97,"_53":54,"_55":-5,"_68":98,"_18":99},"b37fe936-fa19-465e-8fff-c009414c2255","1cc3ffb6-ab16-11f1-8acc-1607ee4eb77e",["D",1788824688530],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport Drumbeat from \"./drumbeat.tsx\";\n\ncreateRoot(document.getElementById(\"root\")!).render();\n",[],[57,62],["D",1788824797881],[],[57,35],"8cf30feb-6123-4bb6-aacd-24bcd4d0a088",["D",1788822962794],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Drumbeat proxy: X search via twitterapi.io + /biz 4chan catalog","imageUrl","userId","e409430f-34f8-407d-8ffc-b8c83720e72f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a07e27-8a01-7708-ba10-0ada3e884453","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_157":153},"org",{"_11":12,"_150":151,"_152":153,"_113":114,"_154":155,"_156":54},"branch",{"_17":43,"_13":16,"_33":41,"_142":103,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":14,"_149":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Quincy H","avatar","https://lh3.googleusercontent.com/a/ACg8ocK0wQ6K8WEBlgt-Xo5V60n7n5pL9le5iP-CoVk5AaKCmJuM7w=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":103,"_13":14,"_46":206,"_105":-5,"_106":54,"_107":108,"_109":108,"_110":111,"_112":-5,"_113":114,"_115":-5,"_116":54,"_117":-5,"_118":-5,"_119":48,"_120":121,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_135":207,"_137":208,"_139":209,"_141":54},[188,191,193],"files",[188,189,190,191,192,193],"counts",{"_178":48,"_179":180,"_181":48,"_32":182,"_183":184},[],{"_33":34,"_13":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":177},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[57,35],"pulls","branches",1,"forks",{"_185":74,"_187":48},"connections",{"_185":48,"_186":48},"count","unfilledCount","emptyCount",{"_33":87,"_13":57,"_36":39,"_38":-5,"_40":41,"_42":88,"_44":45,"_46":89,"_17":48,"_49":76,"_51":-5,"_53":54,"_55":-5,"_68":204,"_18":205},{"_33":34,"_13":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":100,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_68":202,"_18":203},{"_33":94,"_13":62,"_36":95,"_38":39,"_40":41,"_42":88,"_44":45,"_46":96,"_17":48,"_49":50,"_51":97,"_53":54,"_55":-5,"_68":200,"_18":201},{"_33":71,"_13":72,"_36":73,"_38":-5,"_40":41,"_42":74,"_44":45,"_46":75,"_17":48,"_49":76,"_51":-5,"_53":54,"_55":-5,"_68":198,"_18":199},{"_33":80,"_13":81,"_36":82,"_38":73,"_40":41,"_42":74,"_44":45,"_46":83,"_17":48,"_49":24,"_51":84,"_53":54,"_55":-5,"_68":196,"_18":197},{"_33":61,"_13":62,"_36":63,"_38":-5,"_40":41,"_42":64,"_44":45,"_46":65,"_17":48,"_49":66,"_51":67,"_53":54,"_55":14,"_68":194,"_18":195},[],[62],[],[72,81],[192],[72],[],[57,62],[],[57,35],[189,190],[57],["D",1788822962794],{"_11":12,"_157":153},{"_11":12,"_150":151,"_152":153,"_113":114,"_154":155,"_156":54},{"_17":43,"_13":16,"_33":41,"_142":103,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":14,"_149":12},"ctx",{"_135":-5,"_174":243,"_244":245,"_246":247,"_248":54,"_249":54,"_250":54,"_251":45,"_252":-5,"_253":-7,"_254":-7,"_255":48,"_256":54,"_257":54,"_258":-5,"_259":54,"_260":54,"_261":54,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":16,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]