[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_101":102,"_103":104},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","eldiablo","name","Screener-Data-Relay-2","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":-5,"_53":-5,"_54":55,"_56":25,"_57":32,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":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/eldiablo/Screener-Data-Relay-2/code/main.ts","extension","id","4a630e88-cd71-4281-9fe6-a462e1b64533","fileId","fec063fa-815e-11f1-bbb7-1607ee4eb77e","parentId","branchId","e8725e6b-67ae-4377-b4bf-3616b602f14b","branchVersion",4,"latest",true,"createdAt",["D",1784313350889],"version",3,"fileType","http","content","// Screener Data Relay V1.4.3 — 2026-07-13 (screener-data-relay)\n// URL: https://eldiablo--7085fd4c7d0e11f1af9e1607ee4eb77e.web.val.run\n// Mode A: /?tickers=1 -> {ts,n,t:[[symbol,last,chg24h%,quoteVol24h,isStock01],...],f:{sym:[maxFR,minFR]}}\n// V1.4: SHARED 5s cache — dedupes cross-device polling against Bitunix REST.\n// Mode B: /?symbols=A,B -> {ts,d:{sym:[h,l,h,l,... newest-first, up to 31 days]}} (max 20/call)\n// V1.4: &bars=N (2-200) -> {ts,d3:{sym:[h,l,c,h,l,c,... newest-first, CLOSED days only]}}.\n// The current (partial) UTC day is dropped relay-side. Without &bars, byte-identical to V1.3\n// (pairs under d) so v10.83 keeps working — deploy order between val and worker doesn't matter.\n// Mode C: /?funding=1 -> {ts,data:[{s,fr,iv,nft},...]} (30s cache + stale fallback)\n// Mode D: /?cg=SYMBOL -> {ts,symbol,aoi,btx,exp} — CoinGlass pairs-markets proxy.\n// SHARED 45s cache; stale fallback on upstream FAILURE only (El-ratified: within CG cadence).\n// V1.4 GLOBAL GOVERNOR: rolling 60s count of UPSTREAM CG fetches (cache hits free).\n// >= HARD 30/min -> 429 {error:\"over_budget\",retry_in} for everyone.\n// >= SOFT 25/min -> 429 for requests without &pri=1 (armed polls send pri=1; headroom for cgPing).\n// over_budget NEVER serves stale — explicit refusal per no-stale law.\n// Mode E (V1.4): /?mcap=1 -> {ts,pages,m:{SYMBOL:[market_cap,rank,collision]}}\n// CoinGecko /coins/markets top 1500 (6x250), SHARED 1h cache. Keyed by UPPERCASE symbol;\n// ticker collisions keep the highest-cap coin with collision=1; unresolved symbols absent.\n// Partial page failures: serves pages fetched so far (pages<6 tells the client; V1.4.1: partial cached 5 min only);\n// total failure with no cache -> explicit {error:\"mcap_failed\"} — page renders dashes.\n// RELAY KEY (V1.4, permissive): env RELAY_KEY unset -> open (V1.3 behavior).\n// Set -> requests carrying X-Relay-Key header or &k= matching it get \"x-relay-auth: ok\",\n// others \"x-relay-auth: miss\" BUT ARE STILL SERVED. env RELAY_ENFORCE=\"1\" flips misses to\n// 403 {error:\"unauthorized_relay\"}. Key lives ONLY in Val.town env vars — never in source.\n// Secrets: CG_KEY (required for Mode D), COINALYZE_KEY (required for Mode I), CG_EXPIRES, RELAY_KEY, RELAY_ENFORCE — all env vars.\n// V1.4 = V1.3 + Mode A cache + Mode B bars + Mode E + CG governor + relay key.\n// V1.4.1 (mcap hardening): PARTIAL results (pages<6) cached only 5 min (full = 1h) so a\n// throttled cold populate self-heals instead of pinning a shallow map for the hour;\n// per-page single retry after 2.5s on throttle; inter-page gap 250ms -> 1200ms\n// (6 pages in 1.5s tripped CoinGecko free-tier throttling); DEPTH GUARD: a fresh\n// shallower populate never overwrites a deeper cached map younger than 1h\n// (caps move on week scale — depth beats freshness inside the hour).\n// V1.4.2: (1) CG_GECKO_KEY env var (CoinGecko free Demo API key) — when set, mcap fetches\n// send x-cg-demo-api-key; authenticated requests bypass CoinGecko's anonymous datacenter-IP\n// throttling (which fully blocked Val.town's IPs 2026-07-13 while other IPs worked).\n// Unset = anonymous fallback, prior behavior. Key lives ONLY in Val.town env vars.\n// (2) mcap total-failure now returns HTTP 200 + {error:\"mcap_failed\"} — Cloudflare fronts\n// Val.town and REPLACES 502 bodies with its own \"error code: 502\" page, which masked our\n// honest JSON and cost diagnostic time; clients validate the m field, not the status.\n// (3) Every response carries x-relay-ver so the deployed version is curl-checkable.\n// Mode F (V1.4.3): /?kline=SYMBOL&t=MS -> {ts,symbol,p,kt} — 1m fire-price lookup for the\n// screener's SINCE ALERT fallback. The worker /api/fireprice proxies here because Bitunix\n// returns EMPTY kline responses to Cloudflare Workers egress IPs (live-proven 2026-07-13 ET;\n// Val.town is accepted — Mode B daily bars prove it). Window t-60min..t+1min, limit 200;\n// picks the candle CONTAINING t, else the NEWEST candle at-or-before t (= last trade before\n// fire), else nearest. Candles are immutable -> permanent shared cache, capped 500.\n// V1.4.3 = V1.4.2 + Mode F. All other modes byte-identical to V1.4.2.\n// Mode G (V1.5): /?backfill=A,B,C&iv=5m&n=48 -> {ts,iv,n,k:{SYMBOL:[[t,o,h,l,c,q,b],... newest-first, CLOSED only]}}\n// Bulk official closed-candle backfill for the NO-FABRICATED-CANDLES data layer (worker v10.151 §A).\n// iv in 1m/5m/15m/1h/4h/1d; n 2-200 CLOSED candles (fetches n+1, drops the still-forming candle via\n// floor(now/ivms) bucket). Tuple = [openTime_ms, open, high, low, close, usdVol, coinVol].\n// NOTE: Bitunix REST kline inverts vol field names (baseVol=USD vol, quoteVol=coin vol); mapped\n// correctly here so tuple[5]=USD volume (spec A2), tuple[6]=coin volume.\n// <=20 syms/call, fetched in batches of 8 with 900ms gaps (within Bitunix 10 req/s); worker chunks the\n// pool across calls. Bitunix REST kline is relay-only (Worker egress IPs get empty — v10.124 law).\n// Mode H (V1.5): /?cglist=1 -> {ts,n,coins:[SYMBOL,...]} — CoinGlass supported-coins list, SHARED 1h cache,\n// uppercased+deduped. Feeds the OI-COVERAGE eligibility gate (three-data-points law, worker §B2). Uses\n// CG_KEY. Stale fallback on upstream failure; error+no-cache -> client keeps its last-known list.\n// Outside the Mode D 30/min OI governor (1 upstream fetch/hour).\n// V1.5 = V1.4.3 + Mode G (bulk kline backfill) + Mode H (CoinGlass supported-coins cache).\n// All modes A-F byte-identical to V1.4.3.\n// Mode I (V1.6): /?coi=A,B,C&n=6 -> {ts,iv:\"5m\",n,src:\"coinalyze\",oi:{COIN:[[bucketStart_ms,closeOI_usd],... newest-first, CLOSED only]},miss:[...],over:bool}\n// PRIMARY aggregated-OI source (El-ratified 2026-07-15). Per coin: sums Coinalyze per-exchange perp OI\n// (USDT-margined, convert_to_usd) across venues into CLOSED 5m OI candles. The value at index t is the\n// aggregated OI at bucketStart+5m = that candle's CLOSE; align OI candle t to the price candle closing at\n// t+300000. Forming bucket (floor(now/5m)) is dropped. Coin->venue map from Coinalyze /future-markets\n// (1h cache), direct base-asset match; unmapped/empty coins returned in `miss` so the worker falls back to\n// CoinGlass Mode D (aoi). Coinalyze has its OWN 40/min budget: a GOVERNOR counts per-symbol upstream\n// fetches, HARD 35/min -> stops fetching and flags `over` (those coins -> CoinGlass fallback too). Per-coin\n// series cached to the current 5m bucket (CZ_TTL); <=CZ_MAX_VENUES venues/coin; <=20 syms/upstream call.\n// Direction is truth — absolute levels differ from CoinGlass by design (different venue set), proven\n// equivalent on real moves in the 2026-07-15 live A/B (disagreements only on sub-noise flat candles).\n// V1.6 = V1.5 + Mode I (Coinalyze aggregated-OI, PRIMARY). CoinGlass Mode D (aoi) is the FALLBACK.\n// All modes A-H byte-identical to V1.5.\n// Mode I venue filter (V1.7): /?coi=A,B&venue=binance -> per coin, sums ONLY the Binance perp OI instead of\n// all venues. Binance's Coinalyze exchange code is resolved from /exchanges (code->name, cached with the\n// market map). Coins Binance does not list fall back to the full aggregate for that coin. Response gains\n// vsrc:{COIN:\"binance\"|\"aggfb\"|\"agg\"} so the worker can record which source actually fed each confirm.\n// No venue param = V1.6 behavior byte-identical. czCache is keyed per (coin|venue-tag).\n// V1.7 = V1.6 + Mode I venue=binance filter. All other modes byte-identical to V1.6.\n// Mode I OI DENOMINATION (V1.8): Mode I now requests convert_to_usd=FALSE -> OI in CONTRACTS (coins), not\n// USD, so the rise check reflects real positioning rather than price x OI (a price pump was inflating\n// USD-OI while contracts fell). Only base-coin-denominated markets are summed\n// (m.oi_lq_vol_denominated_in === base_asset) so the coins sum is one coherent unit. Mode D (?cg=) also\n// returns aoic = aggregated OI in CONTRACTS (sum of CoinGlass open_interest_quantity) alongside aoi (USD);\n// btx unchanged (USD).\n// V1.8 = V1.7 + Mode I contracts + Mode D aoic. All other modes byte-identical to V1.7.\n// Mode I FILTER FIX (V1.9): Coinalyze /future-markets returns oi_lq_vol_denominated_in as an ENUM\n// (\"BASE_ASSET\" | \"QUOTE_ASSET\" | \"CONTRACTS\"), NOT the asset symbol. V1.8 compared it to the base\n// coin symbol (e.g. \"BTC\"), so EVERY market was excluded -> empty venue map -> every coin in miss[]\n// -> worker /api/cg-oi 502 oi_unavailable -> \"COINALYZE FAILED\" (live-diagnosed 2026-07-16). Fix:\n// compare to literal \"BASE_ASSET\". Verified: 3397 USDT perps pass; all major venues incl. Binance\n// report BASE_ASSET for BTC/ETH/SOL. Intent unchanged (base-coin-denominated only; coherent coins sum).\n// V1.9 = V1.8 with the Mode I denomination filter fixed. All modes otherwise byte-identical to V1.8.\n// STOCK/TRADFI FLAG (V2.0): Mode A rows gain a 5th element isStock (1/0). isStock = the Bitunix futures\n// contract has isApiSupported===false (all US-stock + commodity/metal perps) OR the symbol is in a small\n// deny-list (MUUUSDT/SOXLUSDT/SPCXUSDT/SKHYUSDT - hours-restricted TradFi Bitunix left API-enabled).\n// Source: BASE/trading_pairs, 1h cache (tpCache); lets the worker LIVE ONLY filter hide NYSE-hours,\n// US-restricted, largely-untradable stock perps. Absent 5th element (older worker) -> falsy = no filter.\n// V2.0 = V1.9 + Mode A isStock flag + trading_pairs stock-set cache. All other modes byte-identical to V1.9.\n// Claude sandbox curl CAN test these endpoints (query strings preserved, unlike web_fetch).\nconst HDRS = {\n \"accept\": \"application/json, text/plain, */*\",\n \"accept-language\": \"en-US,en;q=0.9\",\n \"user-agent\":\n \"Mozilla/5.0 (iPhone; CPU iPhone OS 17_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.5 Mobile/15E148 Safari/604.1\",\n \"referer\": \"https://www.bitunix.com/\",\n \"origin\": \"https://www.bitunix.com\",\n};\nconst CORS = {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-headers\": \"x-relay-key, content-type\",\n \"content-type\": \"application/json\",\n \"cache-control\": \"no-store\",\n \"x-relay-ver\": \"2.0\",\n};\nconst BASE = \"https://fapi.bitunix.com/api/v1/futures/market/\";\nconst CG_HARD = 30, CG_SOFT = 25;\nconst MCAP_PAGES = 6,\n MCAP_TTL = 3600000,\n MCAP_TTL_PART = 300000,\n MCAP_GAP = 1200,\n MCAP_RETRY_MS = 2500;\nconst KIVMS = {\n \"1m\": 60000,\n \"5m\": 300000,\n \"15m\": 900000,\n \"1h\": 3600000,\n \"4h\": 14400000,\n \"1d\": 86400000,\n};\nconst BF_MAX_SYMS = 20, BF_BATCH = 8, BF_GAP = 900;\nconst CGL_TTL = 3600000;\nconst CZ_BASE = \"https://api.coinalyze.net/v1\";\nconst CZ_HARD = 35, CZ_SOFT = 30;\nconst CZ_TTL = 120000, CZ_MKT_TTL = 3600000;\nconst CZ_MAX_VENUES = 10, CZ_QUOTES = [\"USDT\"];\nconst CZ_N_DEF = 6, CZ_N_MAX = 50;\nlet fCache = null;\nlet tCache = null;\nlet mCache = null;\nconst cgCache = new Map();\nconst kCache = new Map();\nlet cgHits = [];\nlet cglCache = null;\nlet czHits = [];\nlet czMkt = null;\nconst czCache = new Map();\nconst TP_TTL = 3600000;\nconst STOCK_DENY = new Set([\"MUUUSDT\", \"SOXLUSDT\", \"SPCXUSDT\", \"SKHYUSDT\"]);\nlet tpCache = null;\nasync function ensureStockSet() {\n if (tpCache && Date.now() - tpCache.ts < TP_TTL) {\n return tpCache.stock;\n }\n try {\n const r = await fetch(BASE + \"trading_pairs\", { headers: HDRS });\n const j = await r.json();\n const rows = (j && j.data) || [];\n if (Array.isArray(rows) && rows.length) {\n const stset = new Set();\n for (const m of rows) {\n const sy = m && m.symbol;\n if (!sy) {\n continue;\n }\n if (m.isApiSupported === false || STOCK_DENY.has(sy)) {\n stset.add(sy);\n }\n }\n tpCache = { ts: Date.now(), stock: stset };\n }\n } catch (_e) {}\n return tpCache ? tpCache.stock : STOCK_DENY;\n}\nfunction resp(body, status, auth) {\n return new Response(body, {\n status,\n headers: { ...CORS, \"x-relay-auth\": auth },\n });\n}\nexport default async function (req) {\n const u = new URL(req.url);\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS });\n }\n const rk = Deno.env.get(\"RELAY_KEY\");\n let auth = \"open\";\n if (rk) {\n const got = req.headers.get(\"x-relay-key\") || u.searchParams.get(\"k\") || \"\";\n auth = got === rk ? \"ok\" : \"miss\";\n if (auth === \"miss\" && Deno.env.get(\"RELAY_ENFORCE\") === \"1\") {\n return resp(JSON.stringify({ error: \"unauthorized_relay\" }), 403, auth);\n }\n }\n if (u.searchParams.get(\"backfill\")) {\n const iv = (u.searchParams.get(\"iv\") || \"5m\").toLowerCase();\n const bms = KIVMS[iv];\n if (!bms) {\n return resp(JSON.stringify({ error: \"bad_interval\" }), 400, auth);\n }\n let n = parseInt(u.searchParams.get(\"n\") || \"48\", 10);\n if (!(n >= 2)) {\n n = 2;\n }\n if (n > 200) {\n n = 200;\n }\n const syms = (u.searchParams.get(\"backfill\") || \"\")\n .split(\",\").map((s) => s.trim().toUpperCase())\n .filter((s) => /^[A-Z0-9]{2,20}$/.test(s)).slice(0, BF_MAX_SYMS);\n if (!syms.length) {\n return resp(JSON.stringify({ error: \"no_symbols\" }), 400, auth);\n }\n const now = Date.now();\n const curOpen = Math.floor(now / bms) * bms;\n const lim = Math.min(200, n + 1);\n const k = {};\n for (let i = 0; i < syms.length; i += BF_BATCH) {\n const chunk = syms.slice(i, i + BF_BATCH);\n await Promise.all(chunk.map(async (s) => {\n try {\n const r = await fetch(\n BASE + \"kline?symbol=\" + s + \"&interval=\" + iv + \"&limit=\" + lim,\n { headers: HDRS },\n );\n const j = await r.json();\n const rows = (j && (j.data && (j.data.list || j.data))) || [];\n if (!Array.isArray(rows)) {\n return;\n }\n const cc = [];\n for (const kk of rows) {\n const t2 = parseInt(kk.time ?? kk.ts ?? kk.t ?? 0);\n const o = parseFloat(kk.open ?? kk.o);\n const h = parseFloat(kk.high ?? kk.h);\n const l = parseFloat(kk.low ?? kk.l);\n const c = parseFloat(kk.close ?? kk.c);\n // Bitunix REST kline INVERTS vol naming (live-verified 2026-07-15, BTCUSDT):\n // field baseVol carries USD (quote) volume; field quoteVol carries coin (base) volume.\n // q = USD volume (spec A2: k5 volume = official per-candle USD); b = coin volume.\n const q = parseFloat(\n kk.baseVol ?? kk.quoteVolume ?? kk.turnover ?? 0,\n );\n const b = parseFloat(\n kk.quoteVol ?? kk.baseVolume ?? kk.volume ?? kk.vol ?? 0,\n );\n if (t2 > 0 && o > 0 && h > 0 && l > 0 && c > 0 && l <= h) {\n cc.push([t2, o, h, l, c, q > 0 ? q : 0, b > 0 ? b : 0]);\n }\n }\n if (!cc.length) {\n return;\n }\n cc.sort((a, b2) => b2[0] - a[0]);\n const closed = cc.filter((x) => x[0] < curOpen);\n if (!closed.length) {\n return;\n }\n k[s] = closed.slice(0, n);\n } catch (_e) {}\n }));\n if (i + BF_BATCH < syms.length) {\n await new Promise((res) => setTimeout(res, BF_GAP));\n }\n }\n return resp(JSON.stringify({ ts: Date.now(), iv, n, k }), 200, auth);\n }\n if (u.searchParams.get(\"cglist\")) {\n if (cglCache && Date.now() - cglCache.ts < CGL_TTL) {\n return resp(cglCache.body, 200, auth);\n }\n const key = Deno.env.get(\"CG_KEY\");\n if (!key) {\n return resp(JSON.stringify({ error: \"no_key\" }), 503, auth);\n }\n try {\n const r = await fetch(\n \"https://open-api-v4.coinglass.com/api/futures/supported-coins\",\n {\n headers: { \"CG-API-KEY\": key, \"accept\": \"application/json\" },\n },\n );\n if (r.status === 401) {\n return resp(JSON.stringify({ error: \"unauthorized\" }), 401, auth);\n }\n const j = await r.json();\n const raw = (j && j.data) || [];\n if (j.code !== \"0\" || !Array.isArray(raw) || !raw.length) {\n if (cglCache) {\n return resp(cglCache.body, 200, auth);\n }\n return resp(\n JSON.stringify({ error: \"bad_upstream\", code: j.code || null }),\n 502,\n auth,\n );\n }\n const seen = {};\n const coins = [];\n for (const it of raw) {\n const s = (typeof it === \"string\"\n ? it\n : (it && (it.symbol ?? it.coin ?? it.name)) || \"\")\n .toUpperCase().replace(/[^A-Z0-9]/g, \"\");\n if (s && !seen[s]) {\n seen[s] = 1;\n coins.push(s);\n }\n }\n if (!coins.length) {\n if (cglCache) {\n return resp(cglCache.body, 200, auth);\n }\n return resp(JSON.stringify({ error: \"empty_list\" }), 502, auth);\n }\n const body = JSON.stringify({ ts: Date.now(), n: coins.length, coins });\n cglCache = { ts: Date.now(), body };\n return resp(body, 200, auth);\n } catch (_e) {\n if (cglCache) {\n return resp(cglCache.body, 200, auth);\n }\n return resp(JSON.stringify({ error: \"fetch_failed\" }), 502, auth);\n }\n }\n if (u.searchParams.get(\"coi\")) {\n const czKey = Deno.env.get(\"COINALYZE_KEY\");\n if (!czKey) {\n return resp(JSON.stringify({ error: \"no_key\" }), 503, auth);\n }\n const coins = (u.searchParams.get(\"coi\") || \"\")\n .split(\",\").map((s) => s.trim().toUpperCase())\n .filter((s) => /^[A-Z0-9]{2,20}$/.test(s)).slice(0, 30);\n if (!coins.length) {\n return resp(JSON.stringify({ error: \"no_symbols\" }), 400, auth);\n }\n let n = parseInt(u.searchParams.get(\"n\") || String(CZ_N_DEF), 10);\n if (!(n >= 2)) {\n n = 2;\n }\n if (n > CZ_N_MAX) {\n n = CZ_N_MAX;\n }\n const now = Date.now();\n czHits = czHits.filter((t) => now - t < 60000);\n // ensure Coinalyze coin->venues map (perpetual, selected margin quotes), 1h cache\n if (!czMkt || now - czMkt.ts > CZ_MKT_TTL) {\n try {\n czHits.push(now);\n const r = await fetch(CZ_BASE + \"/future-markets\", {\n headers: { \"api_key\": czKey },\n });\n if (r.status === 401) {\n return resp(JSON.stringify({ error: \"unauthorized\" }), 401, auth);\n }\n const arr = await r.json();\n if (!Array.isArray(arr) || !arr.length) {\n throw 0;\n }\n // resolve Binance exchange code(s) via /exchanges (code->name), for the venue=binance filter\n const binCodes = {};\n try {\n czHits.push(now);\n const er = await fetch(CZ_BASE + \"/exchanges\", {\n headers: { \"api_key\": czKey },\n });\n const exArr = await er.json();\n if (Array.isArray(exArr)) {\n for (const ex of exArr) {\n if (\n ex && ex.code &&\n String(ex.name || \"\").toLowerCase() === \"binance\"\n ) {\n binCodes[ex.code] = 1;\n }\n }\n }\n } catch (_e2) {}\n const map = {};\n for (const m of arr) {\n if (!m || !m.is_perpetual) {\n continue;\n }\n if (CZ_QUOTES.indexOf(m.quote_asset) < 0) {\n continue;\n }\n const ba = (m.base_asset || \"\").toUpperCase();\n if (!ba) {\n continue;\n }\n // V1.9: coins-denominated only. oi_lq_vol_denominated_in is the ENUM \"BASE_ASSET\"\n // (NOT the coin symbol); v1.8 compared it to the symbol -> matched nothing -> empty map.\n // Summing convert_to_usd=false BASE_ASSET markets keeps the coins sum one coherent unit.\n if (\n (m.oi_lq_vol_denominated_in || \"\").toUpperCase() !== \"BASE_ASSET\"\n ) {\n continue;\n }\n (map[ba] = map[ba] || []).push({ s: m.symbol, ex: m.exchange });\n }\n czMkt = { ts: now, map, binCodes };\n } catch (_e) {\n if (!czMkt) {\n return resp(\n JSON.stringify({ error: \"market_map_failed\" }),\n 502,\n auth,\n );\n }\n }\n }\n const curOpen = Math.floor(now / 300000) * 300000;\n const from = Math.floor((now - (n + 3) * 300000) / 1000);\n const to = Math.floor(now / 1000);\n const venue = (u.searchParams.get(\"venue\") || \"\").toLowerCase();\n const binOnly = venue === \"binance\";\n const binCodes = (czMkt && czMkt.binCodes) || {};\n const oi = {};\n const vsrc = {};\n const miss = [];\n const need = [];\n for (const coin of coins) {\n const all = czMkt.map[coin] || [];\n if (!all.length) {\n miss.push(coin);\n continue;\n }\n let picks = all;\n let vtag = \"agg\";\n if (binOnly) {\n const bin = all.filter((mm) => binCodes[mm.ex]);\n if (bin.length) {\n picks = bin;\n vtag = \"binance\";\n } else {\n vtag = \"aggfb\";\n }\n }\n vsrc[coin] = vtag;\n const ck = coin + \"|\" + vtag;\n const cc = czCache.get(ck);\n if (cc && cc.bucket === curOpen && now - cc.ts < CZ_TTL) {\n oi[coin] = cc.series;\n continue;\n }\n need.push({\n coin,\n ck,\n syms: picks.slice(0, CZ_MAX_VENUES).map((mm) => mm.s),\n });\n }\n const rev = {};\n const flat = [];\n const sumByCoin = {};\n for (const nd of need) {\n sumByCoin[nd.coin] = {};\n for (const s of nd.syms) {\n rev[s] = nd.coin;\n flat.push(s);\n }\n }\n let over = false;\n for (let i = 0; i < flat.length; i += 20) {\n const chunk = flat.slice(i, i + 20);\n if (czHits.length + chunk.length > CZ_HARD) {\n over = true;\n break;\n }\n const t0 = Date.now();\n for (let j = 0; j < chunk.length; j++) {\n czHits.push(t0);\n }\n try {\n const r = await fetch(\n CZ_BASE + \"/open-interest-history?symbols=\" + chunk.join(\",\") +\n \"&interval=5min&from=\" + from + \"&to=\" + to +\n \"&convert_to_usd=false\",\n { headers: { \"api_key\": czKey } },\n );\n if (r.status === 429) {\n over = true;\n break;\n }\n const arr = await r.json();\n if (Array.isArray(arr)) {\n for (const row of arr) {\n const coin = rev[row.symbol];\n if (!coin) {\n continue;\n }\n const acc = sumByCoin[coin];\n for (const cnd of (row.history || [])) {\n if (cnd.t * 1000 >= curOpen) {\n continue;\n }\n acc[cnd.t] = (acc[cnd.t] || 0) + (parseFloat(cnd.c) || 0);\n }\n }\n }\n } catch (_e) {}\n }\n for (const nd of need) {\n const acc = sumByCoin[nd.coin];\n const tks = Object.keys(acc).map(Number).sort((a, b) => b - a).slice(\n 0,\n n,\n );\n if (!tks.length) {\n miss.push(nd.coin);\n continue;\n }\n oi[nd.coin] = tks.map((t) => [t * 1000, Math.round(acc[t])]);\n czCache.set(nd.ck, {\n ts: Date.now(),\n bucket: curOpen,\n series: oi[nd.coin],\n });\n }\n if (czCache.size > 400) {\n czCache.clear();\n }\n return resp(\n JSON.stringify({\n ts: Date.now(),\n iv: \"5m\",\n n,\n src: \"coinalyze\",\n oi,\n miss,\n vsrc,\n over,\n }),\n 200,\n auth,\n );\n }\n if (u.searchParams.get(\"kline\")) {\n const sym = (u.searchParams.get(\"kline\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).slice(0, 20);\n const t = parseInt(u.searchParams.get(\"t\") || \"0\", 10);\n if (!sym) {\n return resp(JSON.stringify({ error: \"no_symbol\" }), 400, auth);\n }\n if (!(t > 1577836800000 && t < Date.now() + 60000)) {\n return resp(JSON.stringify({ error: \"bad_time\" }), 400, auth);\n }\n const ck = sym + \":\" + Math.floor(t / 60000);\n const khit = kCache.get(ck);\n if (khit) {\n return resp(khit, 200, auth);\n }\n try {\n const r = await fetch(\n BASE + \"kline?symbol=\" + sym + \"&interval=1m&startTime=\" +\n (t - 3600000) +\n \"&endTime=\" + (t + 60000) + \"&limit=200&type=LAST_PRICE\",\n { headers: HDRS },\n );\n const j = await r.json();\n const rows = (j && (j.data && (j.data.list || j.data))) || [];\n if (!Array.isArray(rows) || !rows.length) {\n return resp(JSON.stringify({ error: \"no_kline\" }), 502, auth);\n }\n const kt0 = (k) => parseInt(k.time ?? k.ts ?? k.t ?? 0);\n let best = null;\n for (const k of rows) {\n const kt = kt0(k);\n if (!(kt > 0)) {\n continue;\n }\n if (kt <= t && t < kt + 60000) {\n best = k;\n break;\n }\n if (kt <= t && (!best || kt > kt0(best))) {\n best = k;\n }\n }\n if (!best) {\n for (const k of rows) {\n const kt = kt0(k);\n if (!(kt > 0)) {\n continue;\n }\n if (!best || Math.abs(kt - t) < Math.abs(kt0(best) - t)) {\n best = k;\n }\n }\n }\n const p = best ? parseFloat(best.close ?? best.c) : 0;\n if (!(p > 0)) {\n return resp(JSON.stringify({ error: \"no_price\" }), 502, auth);\n }\n const body = JSON.stringify({\n ts: Date.now(),\n symbol: sym,\n p,\n kt: kt0(best),\n });\n kCache.set(ck, body);\n if (kCache.size > 500) {\n kCache.clear();\n }\n return resp(body, 200, auth);\n } catch (_e) {\n return resp(JSON.stringify({ error: \"fetch_failed\" }), 502, auth);\n }\n }\n if (u.searchParams.get(\"cg\")) {\n const sym = (u.searchParams.get(\"cg\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).slice(0, 15);\n if (!sym) {\n return resp(JSON.stringify({ error: \"no_symbol\" }), 400, auth);\n }\n const key = Deno.env.get(\"CG_KEY\");\n if (!key) {\n return resp(JSON.stringify({ error: \"no_key\" }), 503, auth);\n }\n const hit = cgCache.get(sym);\n if (hit && Date.now() - hit.ts < 45000) {\n return resp(hit.body, 200, auth);\n }\n const now = Date.now();\n cgHits = cgHits.filter((t) => now - t < 60000);\n const pri = u.searchParams.get(\"pri\") === \"1\";\n if (cgHits.length >= CG_HARD || (cgHits.length >= CG_SOFT && !pri)) {\n const retry = cgHits.length\n ? Math.ceil((60000 - (now - cgHits[0])) / 1000)\n : 5;\n return resp(\n JSON.stringify({ error: \"over_budget\", retry_in: retry }),\n 429,\n auth,\n );\n }\n cgHits.push(now);\n try {\n const r = await fetch(\n \"https://open-api-v4.coinglass.com/api/futures/pairs-markets?symbol=\" +\n sym,\n {\n headers: { \"CG-API-KEY\": key, \"accept\": \"application/json\" },\n },\n );\n if (r.status === 401) {\n return resp(JSON.stringify({ error: \"unauthorized\" }), 401, auth);\n }\n const j = await r.json();\n if (j.code !== \"0\" || !Array.isArray(j.data)) {\n if (hit) {\n return resp(hit.body, 200, auth);\n }\n return resp(\n JSON.stringify({ error: \"bad_upstream\", code: j.code || null }),\n 502,\n auth,\n );\n }\n let aoi = 0;\n let aoic = 0;\n let btx = null;\n for (const p of j.data) {\n const v = parseFloat(p.open_interest_usd);\n if (v > 0) {\n aoi += v;\n }\n const q = parseFloat(p.open_interest_quantity);\n if (q > 0) {\n aoic += q;\n }\n if (p.exchange_name === \"Bitunix\" && v > 0) {\n btx = (btx || 0) + v;\n }\n }\n const body = JSON.stringify({\n ts: Date.now(),\n symbol: sym,\n aoi,\n aoic,\n btx,\n exp: Deno.env.get(\"CG_EXPIRES\") || null,\n });\n cgCache.set(sym, { ts: Date.now(), body });\n if (cgCache.size > 200) {\n cgCache.clear();\n }\n return resp(body, 200, auth);\n } catch (_e) {\n if (hit) {\n return resp(hit.body, 200, auth);\n }\n return resp(JSON.stringify({ error: \"fetch_failed\" }), 502, auth);\n }\n }\n if (u.searchParams.get(\"mcap\")) {\n if (\n mCache &&\n Date.now() - mCache.ts <\n (mCache.pages >= MCAP_PAGES ? MCAP_TTL : MCAP_TTL_PART)\n ) {\n return resp(mCache.body, 200, auth);\n }\n const m = {};\n let pages = 0;\n for (let pg = 1; pg <= MCAP_PAGES; pg++) {\n let ok = false;\n for (let att = 0; att < 2 && !ok; att++) {\n if (att) {\n await new Promise((res) => setTimeout(res, MCAP_RETRY_MS));\n }\n try {\n const gk = Deno.env.get(\"CG_GECKO_KEY\");\n const gh = { \"accept\": \"application/json\" };\n if (gk) {\n gh[\"x-cg-demo-api-key\"] = gk;\n }\n const r = await fetch(\n \"https://api.coingecko.com/api/v3/coins/markets?vs_currency=usd&order=market_cap_desc&per_page=250&page=\" +\n pg,\n { headers: gh },\n );\n if (!r.ok) {\n continue;\n }\n const j = await r.json();\n if (!Array.isArray(j) || !j.length) {\n continue;\n }\n for (const c of j) {\n const sym = (c.symbol || \"\").toUpperCase();\n const cap = c.market_cap;\n if (!sym || !(cap > 0)) {\n continue;\n }\n if (m[sym]) {\n m[sym][2] = 1;\n continue;\n }\n m[sym] = [cap, c.market_cap_rank || 0, 0];\n }\n ok = true;\n } catch (_e) {}\n }\n if (!ok) {\n break;\n }\n pages = pg;\n if (pg < MCAP_PAGES) {\n await new Promise((res) => setTimeout(res, MCAP_GAP));\n }\n }\n if (!pages) {\n if (mCache) {\n return resp(mCache.body, 200, auth);\n }\n return resp(JSON.stringify({ error: \"mcap_failed\" }), 200, auth);\n }\n if (mCache && mCache.pages > pages && Date.now() - mCache.ts < MCAP_TTL) {\n return resp(mCache.body, 200, auth);\n }\n const body = JSON.stringify({ ts: Date.now(), pages, m });\n mCache = { ts: Date.now(), body, pages };\n return resp(body, 200, auth);\n }\n if (u.searchParams.get(\"funding\")) {\n if (fCache && Date.now() - fCache.ts < 30000) {\n return resp(fCache.body, 200, auth);\n }\n try {\n const r = await fetch(BASE + \"funding_rate/batch\", { headers: HDRS });\n const j = await r.json();\n const data = ((j && j.data) || []).map((d) => ({\n s: d.symbol ?? d.s,\n fr: parseFloat(d.fundingRate ?? d.fr),\n iv: d.fundingInterval ? parseInt(d.fundingInterval) : 0,\n nft: d.nextFundingTime ? parseInt(d.nextFundingTime) : 0,\n })).filter((d) => d.s && isFinite(d.fr));\n if (!data.length) {\n throw 0;\n }\n const body = JSON.stringify({ ts: Date.now(), data });\n fCache = { ts: Date.now(), body };\n return resp(body, 200, auth);\n } catch (_e) {\n if (fCache) {\n return resp(fCache.body, 200, auth);\n }\n return resp(JSON.stringify({ error: \"funding_failed\" }), 502, auth);\n }\n }\n if (u.searchParams.get(\"tickers\")) {\n if (tCache && Date.now() - tCache.ts < 5000) {\n return resp(tCache.body, 200, auth);\n }\n try {\n const [tr, fr] = await Promise.all([\n fetch(BASE + \"tickers\", { headers: HDRS }).then((r) => r.json()).catch(\n () => null\n ),\n fetch(BASE + \"funding_rate/batch\", { headers: HDRS }).then((r) =>\n r.json()\n ).catch(() => null),\n ]);\n const rows = (tr && tr.data) || [];\n const stockSet = await ensureStockSet();\n const t = [];\n for (const k of rows) {\n const s = k.symbol ?? k.s;\n const p = parseFloat(k.lastPrice ?? k.last ?? k.la ?? k.close ?? k.c);\n const o = parseFloat(k.open ?? k.o);\n const qv = parseFloat(k.quoteVol ?? k.quoteVolume ?? k.qv ?? k.q ?? 0);\n if (!s || !(p > 0)) {\n continue;\n }\n const chg = (o > 0) ? ((p / o - 1) * 100) : null;\n t.push([\n s,\n p,\n chg === null ? null : Math.round(chg * 100) / 100,\n qv > 0 ? qv : 0,\n stockSet.has(s) ? 1 : 0,\n ]);\n }\n const f = {};\n for (const k of ((fr && fr.data) || [])) {\n const s = k.symbol ?? k.s;\n if (!s) {\n continue;\n }\n const mx = parseFloat(k.maxFundingRate ?? k.max ?? k.mx);\n const mn = parseFloat(k.minFundingRate ?? k.min ?? k.mn);\n if (isFinite(mx) || isFinite(mn)) {\n f[s] = [isFinite(mx) ? mx : 0, isFinite(mn) ? mn : 0];\n }\n }\n if (!t.length) {\n throw 0;\n }\n const body = JSON.stringify({ ts: Date.now(), n: t.length, t, f });\n tCache = { ts: Date.now(), body };\n return resp(body, 200, auth);\n } catch (_e) {\n if (tCache) {\n return resp(tCache.body, 200, auth);\n }\n return resp(JSON.stringify({ error: \"tickers_failed\" }), 502, auth);\n }\n }\n const syms = (u.searchParams.get(\"symbols\") || \"\")\n .split(\",\").map((s) => s.trim().toUpperCase())\n .filter((s) => /^[A-Z0-9]{2,20}$/.test(s)).slice(0, 20);\n if (!syms.length) {\n return resp(JSON.stringify({ error: \"no_symbols\" }), 400, auth);\n }\n const barsRaw = parseInt(u.searchParams.get(\"bars\") || \"0\");\n const bars = barsRaw ? Math.max(2, Math.min(200, barsRaw)) : 0;\n if (bars) {\n const d3 = {};\n const dayStart = Math.floor(Date.now() / 86400000) * 86400000;\n await Promise.all(syms.map(async (s) => {\n try {\n const r = await fetch(\n BASE + \"kline?symbol=\" + s + \"&interval=1d&limit=\" + bars,\n { headers: HDRS },\n );\n const j = await r.json();\n const rows = (j && (j.data && (j.data.list || j.data))) || [];\n if (!Array.isArray(rows)) {\n return;\n }\n const cc = [];\n for (const k of rows) {\n const h = parseFloat(k.high ?? k.h),\n l = parseFloat(k.low ?? k.l),\n c = parseFloat(k.close ?? k.c);\n const t2 = parseInt(k.time ?? k.ts ?? k.t ?? 0);\n if (h > 0 && l > 0 && c > 0 && l <= h) {\n cc.push({ t: t2 || 0, h, l, c });\n }\n }\n if (cc.length < 2) {\n return;\n }\n cc.sort((a, b) => b.t - a.t);\n const closed = cc.filter((x) => x.t < dayStart);\n if (closed.length < 2) {\n return;\n }\n const flat = [];\n for (const x of closed.slice(0, bars)) {\n flat.push(x.h, x.l, x.c);\n }\n d3[s] = flat;\n } catch (_e) {}\n }));\n return resp(JSON.stringify({ ts: Date.now(), d3 }), 200, auth);\n }\n const d = {};\n await Promise.all(syms.map(async (s) => {\n try {\n const r = await fetch(\n BASE + \"kline?symbol=\" + s + \"&interval=1d&limit=31\",\n { headers: HDRS },\n );\n const j = await r.json();\n const rows = (j && (j.data && (j.data.list || j.data))) || [];\n if (!Array.isArray(rows)) {\n return;\n }\n const cc = [];\n for (const k of rows) {\n const h = parseFloat(k.high ?? k.h), l = parseFloat(k.low ?? k.l);\n const t2 = parseInt(k.time ?? k.ts ?? k.t ?? 0);\n if (h > 0 && l > 0 && l <= h) {\n cc.push({ t: t2 || 0, h, l });\n }\n }\n if (cc.length < 2) {\n return;\n }\n cc.sort((a, b) => b.t - a.t);\n const flat = [];\n for (const c of cc.slice(0, 31)) {\n flat.push(c.h, c.l);\n }\n d[s] = flat;\n } catch (_e) {}\n }));\n return resp(JSON.stringify({ ts: Date.now(), d }), 200, auth);\n}","deleted",false,"label",[14],"9eedf4a0-9b34-438a-be16-3b828eb4aeb7",["D",1784238042594],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","ad16a056-6f87-4d01-a6be-825ea3bb0537","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f4d92-406e-75fb-bc5b-cc42f27db9db","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_100":96},"org",{"_9":10,"_93":94,"_95":96,"_54":55,"_97":98,"_99":42},"branch",{"_35":30,"_11":84,"_22":28,"_85":45,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":12,"_92":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","El Diablo","avatar","https://lh3.googleusercontent.com/a/ACg8ocI-0uTtZqiyglualMQAA4_Mb-Fyf50cPQxTypBBMiaPeGkhcUQ=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_77":-5,"_134":135,"_136":137,"_138":139,"_140":42,"_141":42,"_142":42,"_143":32,"_144":-5,"_145":-7,"_146":-7,"_147":61,"_148":42,"_149":42,"_150":-5,"_151":42,"_152":42,"_153":42,"_154":-5},"ENV",{"_105":106,"_107":108,"_109":84,"_110":111,"_112":113,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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"]