[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_93":92,"_32":44,"_102":83,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":25,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":25},"version",9,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","8ea7b926-7f54-11f1-bc37-1607ee4eb77e","name","fileType","http","content","// research-relay v1.8 — v1.7 + a machine-readable `limits` block in /?ping so clients\n// self-pace and never hit the 429 wall (governors + the client min-interval pacing that\n// measured ~0x 429 over a 40-min all-source backtest, 2026-07-24). No fetch behavior change.\n// research-relay v1.7 — STANDALONE research-only data layer for SIMPLE-mode\n// v1.6 adds Binance LIVE fapi as a source (src=binance_live) for real-time price + recent OI\n// (openInterestHist, ~30d). fapi.binance.com is DC-blocked, so it only works when routed\n// through the UK forwarder (add fapi.binance.com to RR_PROXY_HOSTS). Deep history: binance_vision.\n// (base) research-relay v1.5 — STANDALONE research-only data layer for SIMPLE-mode\n// backtesting. Deploy as a NEW Val.town HTTP val (Deno runtime). It does NOT replace\n// or touch the live screener-data-relay or the screener. Symbols are NEVER hardcoded —\n// they are query parameters supplied at run time.\n//\n// v1.3 added BINANCE VISION (data.binance.vision), FREE + KEYLESS, in-Val (fetch daily\n// .zip + unzip via esm.sh fflate): OI native 5m (metrics sum_open_interest, contracts,\n// downsampled for coarser iv) + price/volume from Binance USD-M daily klines.\n// v1.4 adds public EXCHANGE APIs as sources (keyless, shared \"ex\" governor RR_EX_MAX):\n// PRICE: okx, gate, hyperliquid, bitget, mexc, kucoin, deribit, bybit; `binance` is\n// aliased to binance_vision (live fapi is geo-blocked from DC IPs). OI (historical):\n// gate (contract_stats open_interest, deep). Current-only OI venues are NOT served\n// (would be single points, useless for backtest). Bybit is geo-blocked from DC IPs\n// (kept best-effort). Each source stays single-venue + separately logged (no stitch).\n// v1.5 adds an optional egress-proxy hook (RR_PROXY_URL) so geo-blocked hosts (Bybit, and\n// optionally Binance live fapi) can be routed through a small UK forwarder while ALL other\n// sources stay direct. Inert unless RR_PROXY_URL is set -> deploying v1.5 without it is\n// byte-for-byte the same behavior as v1.4. Only hosts in RR_PROXY_HOSTS are proxied\n// (default: api.bybit.com). The forwarder authenticates with a shared secret (RR_PROXY_SECRET\n// here == RR_FWD_SECRET on the VM) and is host-allow-listed, i.e. NOT an open proxy.\n//\n// DESIGN RULES (per operator El):\n// * No source-switching / no stitching across sources. Each call targets ONE source\n// and ONE data type over ONE window. The caller pulls every source separately and\n// logs each, because Price/Volume/OI will not match across sources.\n// * Historical windows: explicit from/to (ms). Paginates past each upstream's page cap.\n// If a call would exceed the per-source per-minute budget, it returns what it has\n// with partial=true and a `resume` sub-window so the caller can continue the SAME\n// source later (pagination within a source is allowed; switching sources is not).\n// * Rate limits: per-source rolling-60s governors (env-tunable) so the live screener\n// keeps its API budget. Bitunix is keyless; CoinGlass/Coinalyze read keys from env.\n// * Intervals: 5m / 15m / 1h / 4h only (caller's ladder; never above 4h).\n//\n// Env secrets (Val.town env vars ONLY, never in source): COINALYZE_KEY, CG_KEY,\n// optional RELAY_KEY / RELAY_ENFORCE. Budget caps: RR_BX_MAX(40), RR_CZ_MAX(10),\n// RR_CG_MAX(10), RR_BV_MAX(40, Binance Vision = keyless CDN) upstream calls / 60s.\n// (One BV \"call\" = one daily file fetched; a wide window fans out over resume windows.)\n// Egress proxy (optional): RR_PROXY_URL (UK forwarder base URL; empty = disabled),\n// RR_PROXY_SECRET (shared secret == the VM's RR_FWD_SECRET), RR_PROXY_HOSTS (CSV of\n// upstream hosts to route via the proxy; default \"api.bybit.com\").\n//\n// Endpoints:\n// /?ping=1\n// /?price=SYMBOL&src=bitunix|coinglass|coinalyze|binance_vision&iv=5m&from=MS&to=MS\n// rows: [[t, o, h, l, c, usdVol|null, coinVol|null], ...] ASCENDING, CLOSED\n// Bitunix native = venue truth (usdVol=baseVol, coinVol=quoteVol). CoinGlass =\n// exchange=Bitunix price (no volume). Coinalyze = the coin's Bitunix perp OHLCV\n// (v=coinalyze volume), if Coinalyze lists it. binance_vision = BINANCE USD-M\n// daily klines (usdVol=quote_volume, coinVol=base volume) — NOT Bitunix.\n// /?oi=COIN&src=coinalyze|coinglass|binance_vision&iv=5m&from=MS&to=MS&venue=(opt bitunix)\n// rows: [[t, oi_contracts], ...] ASCENDING, CLOSED. unit = CONTRACTS (coins).\n// Coinalyze = sum of USDT-perp venues (convert_to_usd=false). CoinGlass =\n// aggregated-history unit=coin (close). venue=bitunix = that single exchange.\n// binance_vision = BINANCE single-venue OI (metrics sum_open_interest), native\n// 5m, downsampled (last sample per bucket) for coarser iv — NOT Bitunix.\n//\n// Every response: {ts, kind, ...id, src, iv, unit?, n, rows, coverage:{first,last,\n// step_ms,expected,got,gaps}, partial, resume:{from,to}|null, note, budget:{used,cap}}\n\nimport { strFromU8, unzipSync } from \"https://esm.sh/fflate@0.8.2\";\n\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\": \"rr-1.8\",\n};\nconst BX_BASE = \"https://fapi.bitunix.com/api/v1/futures/market/\";\nconst CZ_BASE = \"https://api.coinalyze.net/v1\";\nconst CG_BASE = \"https://open-api-v4.coinglass.com\";\nconst BV_BASE = \"https://data.binance.vision/data/futures/um/daily\"; // Binance Vision USD-M\n\nconst KIVMS: Record = {\n \"5m\": 300000,\n \"15m\": 900000,\n \"1h\": 3600000,\n \"4h\": 14400000,\n};\nconst BX_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nconst CZ_IV: Record = {\n \"5m\": \"5min\",\n \"15m\": \"15min\",\n \"1h\": \"1hour\",\n \"4h\": \"4hour\",\n};\nconst CG_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nconst BV_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n}; // native kline intervals\nconst DAYMS = 86400000;\n\nconst CZ_MKT_TTL = 3600000, CZ_MAX_VENUES = 12, CZ_QUOTES = [\"USDT\"];\nlet czMkt: any = null;\n\n// CoinGecko (CG_GECKO_KEY) — spot-aggregated price/volume/mcap, deep history, NO OI.\nconst GK_DEMO_BASE = \"https://api.coingecko.com/api/v3\";\nconst GK_PRO_BASE = \"https://pro-api.coingecko.com/api/v3\";\nconst GK_ID_TTL = 86400000;\nconst gkIds = new Map(); // COIN -> {id,name,rank,ts}\nfunction gkCfg(key: string) {\n const pro = Deno.env.get(\"RR_GECKO_PRO\") === \"1\";\n return {\n base: pro ? GK_PRO_BASE : GK_DEMO_BASE,\n hdr: {\n accept: \"application/json\",\n ...(pro ? { \"x-cg-pro-api-key\": key } : { \"x-cg-demo-api-key\": key }),\n },\n };\n}\nasync function ensureGeckoId(key: string, coin: string) {\n const hit = gkIds.get(coin);\n if (hit && Date.now() - hit.ts < GK_ID_TTL) return hit;\n if (!canHit(\"gk\")) throw new Error(\"budget\");\n mark(\"gk\");\n const { base, hdr } = gkCfg(key);\n const { j } = await jget(\n base + \"/search?query=\" + encodeURIComponent(coin),\n hdr,\n );\n const coins = (j && j.coins) || [];\n const exact = coins.filter((c: any) =>\n (c.symbol || \"\").toUpperCase() === coin\n )\n .sort((a: any, b: any) =>\n (a.market_cap_rank ?? 1e9) - (b.market_cap_rank ?? 1e9)\n );\n const m = exact[0] || coins[0];\n if (!m) return null;\n const rec = {\n id: m.id,\n name: m.name,\n rank: m.market_cap_rank ?? null,\n ts: Date.now(),\n };\n gkIds.set(coin, rec);\n return rec;\n}\nasync function geckoRange(key: string, id: string, from: number, to: number) {\n if (!canHit(\"gk\")) {\n return {\n complete: false,\n prices: [],\n volumes: [],\n mcaps: [],\n err: \"budget\",\n };\n }\n mark(\"gk\");\n const { base, hdr } = gkCfg(key);\n const url = base + \"/coins/\" + id +\n \"/market_chart/range?vs_currency=usd&from=\" +\n Math.floor(from / 1000) + \"&to=\" + Math.floor(to / 1000);\n const { status, j } = await jget(url, hdr);\n if (status === 401) {\n return {\n complete: true,\n prices: [],\n volumes: [],\n mcaps: [],\n err: \"unauthorized\",\n };\n }\n const win = (arr: any) =>\n (Array.isArray(arr) ? arr : []).map((p: any) => [Math.round(p[0]), p[1]])\n .filter((p: any[]) => p[0] >= from && p[0] <= to);\n return {\n complete: true,\n prices: win(j && j.prices),\n volumes: win(j && j.total_volumes),\n mcaps: win(j && j.market_caps),\n err: null,\n };\n}\n\n// ---- per-source rolling-60s budget -----------------------------------------\nconst hits: Record = {\n bx: [],\n cz: [],\n cg: [],\n gk: [],\n bv: [],\n ex: [],\n};\nfunction cap(src: string): number {\n const env = {\n bx: \"RR_BX_MAX\",\n cz: \"RR_CZ_MAX\",\n cg: \"RR_CG_MAX\",\n gk: \"RR_GK_MAX\",\n bv: \"RR_BV_MAX\",\n ex: \"RR_EX_MAX\",\n }[src]!;\n const def = { bx: 40, cz: 10, cg: 10, gk: 10, bv: 40, ex: 90 }[src]!; // ex = shared governor for public exchange APIs\n const v = parseInt(Deno.env.get(env) || \"\", 10);\n return v > 0 ? v : def;\n}\nfunction used(src: string): number {\n const now = Date.now();\n hits[src] = hits[src].filter((t) => now - t < 60000);\n return hits[src].length;\n}\nfunction canHit(src: string): boolean {\n return used(src) < cap(src);\n}\nfunction mark(src: string) {\n hits[src].push(Date.now());\n}\nfunction retryIn(src: string): number {\n const now = Date.now();\n hits[src] = hits[src].filter((t) => now - t < 60000);\n return hits[src].length\n ? Math.ceil((60000 - (now - hits[src][0])) / 1000)\n : 1;\n}\n\nfunction resp(body: string, status = 200, auth = \"open\") {\n return new Response(body, {\n status,\n headers: { ...CORS, \"x-relay-auth\": auth },\n });\n}\nfunction bad(msg: string, status = 400, auth = \"open\") {\n return resp(JSON.stringify({ error: msg }), status, auth);\n}\nasync function jget(url: string, headers: Record) {\n const r = await fetch(url, { headers });\n return { status: r.status, j: await r.json().catch(() => null) };\n}\nfunction coverage(rows: number[][], from: number, to: number, step: number) {\n if (!rows.length) {\n return {\n first: null,\n last: null,\n step_ms: step,\n expected: Math.floor((to - from) / step),\n got: 0,\n gaps: [],\n };\n }\n const first = rows[0][0], last = rows[rows.length - 1][0];\n const gaps: number[][] = [];\n for (let i = 1; i < rows.length; i++) {\n const d = rows[i][0] - rows[i - 1][0];\n if (d !== step) gaps.push([rows[i - 1][0], Math.round(d / step) - 1]);\n }\n return {\n first,\n last,\n step_ms: step,\n expected: Math.floor((to - from) / step) + 1,\n got: rows.length,\n gaps,\n };\n}\nfunction out(\n kind: string,\n id: any,\n src: string,\n iv: string,\n rows: number[][],\n from: number,\n to: number,\n complete: boolean,\n resumeWin: any,\n note: string,\n srcKey: string,\n extra: any = {},\n) {\n return resp(\n JSON.stringify({\n ts: Date.now(),\n kind,\n ...id,\n src,\n iv,\n n: rows.length,\n rows,\n coverage: coverage(rows, from, to, KIVMS[iv]),\n partial: !complete,\n resume: complete ? null : resumeWin,\n note,\n budget: { used: used(srcKey), cap: cap(srcKey) },\n ...extra,\n }),\n 200,\n );\n}\n\n// ---- Bitunix native klines (keyless), newest-first, paged endTime backward ---\nasync function bxPrice(sym: string, iv: string, from: number, to: number) {\n const bms = KIVMS[iv],\n now = Date.now(),\n curOpen = Math.floor(now / bms) * bms;\n let hi = Math.min(to, curOpen - 1);\n const seen = new Map();\n let complete = true;\n while (hi >= from) {\n if (!canHit(\"bx\")) {\n complete = false;\n break;\n }\n mark(\"bx\");\n let rows: any[] = [];\n try {\n const url = BX_BASE + \"kline?symbol=\" + sym + \"&interval=\" + BX_IV[iv] +\n \"&startTime=\" + from + \"&endTime=\" + hi + \"&limit=200&type=LAST_PRICE\";\n const { j } = await jget(url, HDRS);\n rows = (j && (j.data && (j.data.list || j.data))) || [];\n } catch (_e) {\n rows = [];\n }\n if (!Array.isArray(rows) || !rows.length) break;\n let oldest = Infinity, added = 0;\n for (const kk of rows) {\n const t = parseInt(kk.time ?? kk.ts ?? kk.t ?? 0);\n const o = parseFloat(kk.open ?? kk.o), h = parseFloat(kk.high ?? kk.h);\n const l = parseFloat(kk.low ?? kk.l), c = parseFloat(kk.close ?? kk.c);\n const uv = parseFloat(kk.baseVol ?? kk.quoteVolume ?? kk.turnover ?? 0); // USD vol\n const cv = parseFloat(\n kk.quoteVol ?? kk.baseVolume ?? kk.volume ?? kk.vol ?? 0,\n ); // coin vol\n if (!(t > 0 && o > 0 && h > 0 && l > 0 && c > 0 && l <= h)) continue;\n if (t < oldest) oldest = t;\n if (t < curOpen && !seen.has(t)) {\n seen.set(t, [t, o, h, l, c, uv > 0 ? uv : 0, cv > 0 ? cv : 0]);\n added++;\n }\n }\n if (!isFinite(oldest)) break;\n const nxt = oldest - 1;\n if (nxt >= hi) break;\n hi = nxt;\n if (oldest <= from && added === 0) break;\n await new Promise((r) => setTimeout(r, 200));\n }\n const rows = [...seen.keys()].filter((t) => t >= from && t <= to).sort((\n a,\n b,\n ) => a - b).map((t) => seen.get(t)!);\n return {\n rows,\n complete: complete && (rows.length ? rows[0][0] <= from + bms : true),\n resume: { from, to: hi },\n };\n}\n\n// ---- CoinGlass paged fetch (ms times, limit 1000, ascending windows) ---------\nasync function cgPaged(\n path: (a: number, b: number) => string,\n key: string,\n from: number,\n to: number,\n bms: number,\n map: (d: any) => number[] | null,\n) {\n const seen = new Map();\n let cur = from, complete = true, diag: string | null = null;\n while (cur <= to) {\n if (!canHit(\"cg\")) {\n complete = false;\n break;\n }\n mark(\"cg\");\n const end = Math.min(cur + 1000 * bms, to);\n let data: any[] = [];\n try {\n const { status, j } = await jget(path(cur, end), {\n \"CG-API-KEY\": key,\n \"accept\": \"application/json\",\n });\n if (status === 401) {\n return {\n rows: [],\n complete: true,\n resume: { from: cur, to },\n err: \"unauthorized(401)\",\n };\n }\n // CoinGlass may return code as string \"0\" or numeric 0; data may be array or {list:[]}\n const okCode = j && (String(j.code) === \"0\" || j.code === undefined);\n const arr = j &&\n (Array.isArray(j.data)\n ? j.data\n : (j.data && Array.isArray(j.data.list) ? j.data.list : null));\n if (okCode && Array.isArray(arr)) data = arr;\n else if (!diag) {\n diag = \"cg http=\" + status + \" code=\" + (j && j.code) + \" msg=\" +\n (j && (j.msg ?? j.message ?? \"?\"));\n }\n } catch (_e) {\n if (!diag) diag = \"cg fetch_err\";\n data = [];\n }\n if (!data.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const d of data) {\n const row = map(d);\n if (!row) continue;\n const t = row[0];\n if (t < from || t > to) continue;\n if (!seen.has(t)) seen.set(t, row);\n if (t > maxt) maxt = t;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 200));\n }\n const now = Date.now(), curOpen = Math.floor(now / bms) * bms;\n const rows = [...seen.keys()].filter((t) => t < curOpen).sort((a, b) => a - b)\n .map((t) => seen.get(t)!);\n return {\n rows,\n complete,\n resume: { from: cur, to },\n err: rows.length ? null : diag,\n };\n}\n\n// ---- Coinalyze market map (perp, USDT, base-asset denominated) ---------------\nasync function ensureCzMkt(czKey: string) {\n if (czMkt && Date.now() - czMkt.ts < CZ_MKT_TTL) return czMkt;\n if (!canHit(\"cz\")) throw new Error(\"budget\");\n mark(\"cz\");\n const { j } = await jget(CZ_BASE + \"/future-markets\", { \"api_key\": czKey });\n if (!Array.isArray(j) || !j.length) throw new Error(\"cz_market_map\");\n const exCode: Record = {}; // exchange code -> lowercased name\n try {\n if (canHit(\"cz\")) {\n mark(\"cz\");\n const ex = await jget(CZ_BASE + \"/exchanges\", { \"api_key\": czKey });\n if (Array.isArray(ex.j)) {\n for (const e of ex.j) {\n if (e && e.code) {\n exCode[e.code] = String(e.name || \"\").toLowerCase();\n }\n }\n }\n }\n } catch (_e) { /* */ }\n const map: Record = {};\n for (const m of j) {\n if (!m || !m.is_perpetual) continue;\n if (CZ_QUOTES.indexOf(m.quote_asset) < 0) continue;\n if ((m.oi_lq_vol_denominated_in || \"\").toUpperCase() !== \"BASE_ASSET\") {\n continue;\n }\n const ba = (m.base_asset || \"\").toUpperCase();\n if (!ba) continue;\n (map[ba] = map[ba] || []).push({\n s: m.symbol,\n ex: m.exchange,\n exn: exCode[m.exchange] || \"\",\n });\n }\n czMkt = { ts: Date.now(), map, exCode };\n return czMkt;\n}\n\n// ---- Coinalyze aggregated OI (contracts), paged by time ----------------------\nasync function czOI(\n czKey: string,\n coin: string,\n iv: string,\n from: number,\n to: number,\n venue: string,\n) {\n const mkt = await ensureCzMkt(czKey);\n let picks = mkt.map[coin] || [];\n if (venue) picks = picks.filter((mm: any) => mm.exn === venue);\n picks = picks.slice(0, CZ_MAX_VENUES);\n if (!picks.length) {\n return {\n rows: [],\n complete: true,\n resume: { from, to },\n note: \"no_cz_venue\",\n };\n }\n const bms = KIVMS[iv], syms = picks.map((mm: any) => mm.s);\n const acc: Record = {};\n const chunkMs = 800 * bms;\n let cur = from, complete = true;\n outer:\n for (; cur < to; cur += chunkMs) {\n const b = Math.min(cur + chunkMs, to);\n for (let i = 0; i < syms.length; i += 20) {\n if (!canHit(\"cz\")) {\n complete = false;\n break outer;\n }\n mark(\"cz\");\n const chunk = syms.slice(i, i + 20);\n try {\n const url = CZ_BASE + \"/open-interest-history?symbols=\" +\n chunk.join(\",\") + \"&interval=\" + CZ_IV[iv] +\n \"&from=\" + Math.floor(cur / 1000) + \"&to=\" + Math.floor(b / 1000) +\n \"&convert_to_usd=false\";\n const { j } = await jget(url, { \"api_key\": czKey });\n if (Array.isArray(j)) {\n for (const row of j) {\n for (const cnd of (row.history || [])) {\n const t = cnd.t * 1000;\n if (t < from || t > to) continue;\n acc[t] = (acc[t] || 0) + (parseFloat(cnd.c) || 0);\n }\n }\n }\n } catch (_e) { /* */ }\n await new Promise((r) => setTimeout(r, 200));\n }\n }\n const curOpen = Math.floor(Date.now() / bms) * bms;\n const rows = Object.keys(acc).map(Number).filter((t) => t < curOpen).sort((\n a,\n b,\n ) => a - b).map((t) => [t, Math.round(acc[t])]);\n return {\n rows,\n complete,\n resume: { from: cur, to },\n note: venue\n ? (\"venue:\" + venue + \" x\" + picks.length)\n : (\"agg x\" + picks.length),\n };\n}\n\n// ---- Coinalyze OHLCV for the coin's Bitunix perp market ----------------------\nasync function czPrice(\n czKey: string,\n coin: string,\n iv: string,\n from: number,\n to: number,\n) {\n const mkt = await ensureCzMkt(czKey);\n const bx = (mkt.map[coin] || []).find((mm: any) => mm.exn === \"bitunix\");\n if (!bx) {\n return {\n rows: [],\n complete: true,\n resume: { from, to },\n note: \"no_bitunix_market_on_coinalyze\",\n };\n }\n const bms = KIVMS[iv], chunkMs = 800 * bms;\n const seen = new Map();\n let cur = from, complete = true;\n for (; cur < to; cur += chunkMs) {\n if (!canHit(\"cz\")) {\n complete = false;\n break;\n }\n mark(\"cz\");\n const b = Math.min(cur + chunkMs, to);\n try {\n const url = CZ_BASE + \"/ohlcv-history?symbols=\" +\n encodeURIComponent(bx.s) + \"&interval=\" + CZ_IV[iv] +\n \"&from=\" + Math.floor(cur / 1000) + \"&to=\" + Math.floor(b / 1000);\n const { j } = await jget(url, { \"api_key\": czKey });\n if (Array.isArray(j)) {\n for (const row of j) {\n for (const h of (row.history || [])) {\n const t = h.t * 1000;\n if (t < from || t > to || seen.has(t)) continue;\n seen.set(t, [t, +h.o, +h.h, +h.l, +h.c, +(h.v ?? 0), null as any]); // v = coinalyze volume\n }\n }\n }\n } catch (_e) { /* */ }\n await new Promise((r) => setTimeout(r, 200));\n }\n const curOpen = Math.floor(Date.now() / bms) * bms;\n const rows = [...seen.keys()].filter((t) => t < curOpen).sort((a, b) => a - b)\n .map((t) => seen.get(t)!);\n return {\n rows,\n complete,\n resume: { from: cur, to },\n note: \"cz_market:\" + bx.s,\n };\n}\n\n// ---- Binance Vision (data.binance.vision) — free, keyless, in-Val zip+parse -------\nfunction bvDates(from: number, to: number): string[] {\n const out: string[] = [];\n let t = from - (from % DAYMS); // start of the from-day (UTC)\n const end = to + DAYMS; // +1 day margin\n while (t <= end) {\n out.push(new Date(t).toISOString().slice(0, 10));\n t += DAYMS;\n }\n return out;\n}\nasync function bvCsvLines(url: string): Promise {\n // fetch a daily .zip, unzip its single CSV, return trimmed lines (null on miss/err).\n let buf: ArrayBuffer;\n try {\n const r = await fetch(url);\n if (!r.ok) return null;\n buf = await r.arrayBuffer();\n } catch (_e) {\n return null;\n }\n try {\n const files = unzipSync(new Uint8Array(buf));\n const name = Object.keys(files)[0];\n return name ? strFromU8(files[name]).trim().split(\"\\n\") : null;\n } catch (_e) {\n return null;\n }\n}\nfunction bvParseMs(s: string): number {\n return Date.parse(s.slice(0, 19).replace(\" \", \"T\") + \"Z\");\n}\n\n// Binance USD-M 'metrics' OI (native 5m; downsample last-per-bucket for coarser iv).\nasync function bvOI(coin: string, iv: string, from: number, to: number) {\n const sym = coin + \"USDT\";\n const raw = new Map(); // 5m create_time ms -> sum_open_interest\n let complete = true, resumeFrom = from, hit = false;\n for (const date of bvDates(from, to)) {\n if (!canHit(\"bv\")) {\n complete = false;\n break;\n }\n mark(\"bv\");\n const lines = await bvCsvLines(\n BV_BASE + \"/metrics/\" + sym + \"/\" + sym + \"-metrics-\" + date + \".zip\",\n );\n resumeFrom = Date.parse(date + \"T00:00:00Z\") + DAYMS;\n if (!lines) continue;\n for (const ln of lines) {\n const p = ln.split(\",\");\n if (p.length < 3 || p[0] === \"create_time\") continue;\n const t = bvParseMs(p[0]), oi = parseFloat(p[2]); // sum_open_interest (contracts)\n if (!(t > 0) || !isFinite(oi) || oi <= 0 || t < from || t > to) continue;\n raw.set(t, oi);\n hit = true;\n }\n }\n const bms = KIVMS[iv];\n let rows: number[][];\n if (iv === \"5m\") {\n rows = [...raw.keys()].sort((a, b) => a - b).map((\n t,\n ) => [t, Math.round(raw.get(t)!)]);\n } else {\n const bkt = new Map(); // iv-bucketStart -> [sampleTs, oi] (keep latest)\n for (const t of raw.keys()) {\n const b = Math.floor(t / bms) * bms;\n const c = bkt.get(b);\n if (!c || t > c[0]) bkt.set(b, [t, raw.get(t)!]);\n }\n rows = [...bkt.keys()].sort((a, b) => a - b).map((\n b,\n ) => [b, Math.round(bkt.get(b)![1])]);\n }\n const curOpen = Math.floor(Date.now() / bms) * bms;\n rows = rows.filter((r) => r[0] < curOpen);\n const note = \"binance_vision metrics; single-venue BINANCE; unit=contracts\" +\n (iv === \"5m\" ? \"; native 5m\" : \"; downsampled 5m->last-per-bucket\") +\n (hit ? \"\" : \"; no_data(pre-listing / not on binance-futures?)\");\n return { rows, complete, resume: { from: resumeFrom, to }, note };\n}\n\n// Binance USD-M daily klines (native per-interval). usdVol=quote_volume, coinVol=base.\nasync function bvPrice(sym: string, iv: string, from: number, to: number) {\n const seen = new Map();\n let complete = true, resumeFrom = from, hit = false;\n for (const date of bvDates(from, to)) {\n if (!canHit(\"bv\")) {\n complete = false;\n break;\n }\n mark(\"bv\");\n const lines = await bvCsvLines(\n BV_BASE + \"/klines/\" + sym + \"/\" + BV_IV[iv] + \"/\" + sym + \"-\" +\n BV_IV[iv] + \"-\" + date + \".zip\",\n );\n resumeFrom = Date.parse(date + \"T00:00:00Z\") + DAYMS;\n if (!lines) continue;\n for (const ln of lines) {\n const p = ln.split(\",\");\n if (p.length < 8 || p[0] === \"open_time\") continue;\n const t = parseInt(p[0]), o = +p[1], h = +p[2], l = +p[3], c = +p[4];\n const coinVol = +p[5], usdVol = +p[7]; // volume(base), quote_volume(USD)\n if (\n !(t > 0 && o > 0 && h > 0 && l > 0 && c > 0 && l <= h) || t < from ||\n t > to || seen.has(t)\n ) continue;\n seen.set(t, [\n t,\n o,\n h,\n l,\n c,\n usdVol > 0 ? usdVol : 0,\n coinVol > 0 ? coinVol : 0,\n ]);\n hit = true;\n }\n }\n const bms = KIVMS[iv], curOpen = Math.floor(Date.now() / bms) * bms;\n const rows = [...seen.keys()].filter((t) => t < curOpen).sort((a, b) => a - b)\n .map((t) => seen.get(t)!);\n return {\n rows,\n complete,\n resume: { from: resumeFrom, to },\n note:\n \"binance_vision klines; single-venue BINANCE; usdVol=quote_volume,coinVol=base\" +\n (hit ? \"\" : \"; no_data(pre-listing / not on binance-futures?)\"),\n };\n}\n\n// ============ PUBLIC EXCHANGE APIs (single-venue, keyless) ===========================\n// Each returns {rows, complete, resume, note}; pagination bounded by the shared \"ex\"\n// governor (RR_EX_MAX). GEO NOTE: Binance live fapi & Bybit are geo-blocked from many\n// datacenter IPs (observed 451/403 from the build sandbox). Binance is aliased to\n// binance_vision (Binance's own CDN, not blocked); Bybit is kept best-effort.\n// ---- optional egress proxy (v1.5): route ONLY geo-blocked hosts via a UK forwarder ----\n// If RR_PROXY_URL is set, any upstream whose host is in RR_PROXY_HOSTS (default api.bybit.com)\n// is fetched by POSTing {url,method,headers,body} to the forwarder with the shared secret.\n// Everything else stays a direct fetch. Empty RR_PROXY_URL => this whole path is dead (== v1.4).\n// NB: read PER-REQUEST (like the rest of the relay) so setting the env vars takes effect\n// without a redeploy.\nfunction proxyUrl(): string {\n return (Deno.env.get(\"RR_PROXY_URL\") || \"\").trim();\n}\nfunction proxySecret(): string {\n return (Deno.env.get(\"RR_PROXY_SECRET\") || \"\").trim();\n}\nfunction proxyHosts(): string[] {\n return (Deno.env.get(\"RR_PROXY_HOSTS\") || \"api.bybit.com\")\n .split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\n}\nfunction proxyHost(url: string): string {\n if (!proxyUrl()) return \"\";\n let host = \"\";\n try {\n host = new URL(url).host.toLowerCase();\n } catch {\n return \"\";\n }\n return proxyHosts().some((h) => host === h || host.endsWith(\".\" + h))\n ? host\n : \"\";\n}\nasync function exJson(url: string, opt?: any) {\n try {\n if (proxyHost(url)) {\n const r = await fetch(proxyUrl(), {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-fwd-secret\": proxySecret(),\n },\n body: JSON.stringify({\n url,\n method: (opt && opt.method) || \"GET\",\n headers: (opt && opt.headers) || undefined,\n body: (opt && opt.body) || undefined,\n }),\n });\n const upstream = parseInt(r.headers.get(\"x-upstream-status\") || \"\", 10);\n return {\n status: isFinite(upstream) ? upstream : r.status,\n j: await r.json().catch(() => null),\n };\n }\n const r = await fetch(url, opt);\n return { status: r.status, j: await r.json().catch(() => null) };\n } catch (_e) {\n return { status: 0, j: null };\n }\n}\nconst curOpenOf = (bms: number) => Math.floor(Date.now() / bms) * bms;\n\nconst OKX_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1H\",\n \"4h\": \"4H\",\n};\nasync function okxPrice(coin: string, iv: string, from: number, to: number) {\n const inst = coin + \"-USDT-SWAP\", bms = KIVMS[iv];\n const seen = new Map();\n let after = to + bms, complete = true;\n while (after > from) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://www.okx.com/api/v5/market/history-candles?instId=${inst}&bar=${\n OKX_IV[iv]\n }&after=${after}&limit=100`,\n );\n const d = (j && j.data) || [];\n if (!d.length) break;\n let oldest = Infinity;\n for (const k of d) {\n const t = +k[0];\n if (t < oldest) oldest = t;\n if (t >= from && t <= to && !seen.has(t)) {\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[7] || 0, +k[6] || 0]);\n }\n }\n if (!isFinite(oldest) || oldest <= from) break;\n after = oldest;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from, to: after },\n note: \"OKX SWAP; usdVol=volCcyQuote,coinVol=volCcy\",\n };\n}\nconst GATE_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nasync function gatePrice(coin: string, iv: string, from: number, to: number) {\n const c = coin + \"_USDT\", bms = KIVMS[iv];\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 1999 * bms, to);\n const { j } = await exJson(\n `https://api.gateio.ws/api/v4/futures/usdt/candlesticks?contract=${c}&interval=${\n GATE_IV[iv]\n }&from=${Math.floor(cur / 1000)}&to=${Math.floor(end / 1000)}`,\n );\n const d = Array.isArray(j) ? j : [];\n if (!d.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const k of d) {\n const t = k.t * 1000;\n if (t < from || t > to) continue;\n if (!seen.has(t)) {\n seen.set(t, [t, +k.o, +k.h, +k.l, +k.c, +k.sum || 0, +k.v || 0]);\n }\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: \"Gate USDT-perp; usdVol=sum(quote),coinVol=v(contracts)\",\n };\n}\nasync function gateOI(coin: string, iv: string, from: number, to: number) {\n const c = coin + \"_USDT\", bms = KIVMS[iv];\n const acc = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.gateio.ws/api/v4/futures/usdt/contract_stats?contract=${c}&interval=${\n GATE_IV[iv]\n }&from=${Math.floor(cur / 1000)}&limit=100`,\n );\n const d = Array.isArray(j) ? j : [];\n if (!d.length) break;\n let maxt = cur;\n for (const k of d) {\n const t = k.time * 1000;\n if (t < from || t > to) continue;\n const oi = +k.open_interest;\n if (oi > 0) acc.set(t, oi);\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) break;\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...acc.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => [t, Math.round(acc.get(t)!)]),\n complete,\n resume: { from: cur, to },\n note:\n \"Gate contract_stats open_interest; single-venue GATE; unit=contracts\",\n };\n}\nconst HL_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nasync function hlPrice(coin: string, iv: string, from: number, to: number) {\n const bms = KIVMS[iv];\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 4999 * bms, to);\n const { j } = await exJson(\"https://api.hyperliquid.xyz/info\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n type: \"candleSnapshot\",\n req: { coin, interval: HL_IV[iv], startTime: cur, endTime: end },\n }),\n });\n const d = Array.isArray(j) ? j : [];\n if (!d.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const k of d) {\n const t = +k.t;\n if (t < from || t > to) continue;\n if (!seen.has(t)) {\n seen.set(t, [t, +k.o, +k.h, +k.l, +k.c, null as any, +k.v || 0]);\n }\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: \"Hyperliquid perp; coinVol=v(base); no usdVol\",\n };\n}\nconst BITGET_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1H\",\n \"4h\": \"4H\",\n};\nasync function bitgetPrice(coin: string, iv: string, from: number, to: number) {\n const s = coin + \"USDT\", bms = KIVMS[iv];\n const seen = new Map();\n let endT = to + bms, complete = true;\n while (endT > from) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.bitget.com/api/v2/mix/market/history-candles?symbol=${s}&productType=usdt-futures&granularity=${\n BITGET_IV[iv]\n }&limit=200&endTime=${endT}`,\n );\n const d = (j && j.data) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = Infinity;\n for (const k of d) {\n const t = +k[0];\n if (t < oldest) oldest = t;\n if (t >= from && t <= to && !seen.has(t)) {\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[6] || 0, +k[5] || 0]);\n }\n }\n if (!isFinite(oldest) || oldest <= from) break;\n endT = oldest;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from, to: endT },\n note: \"Bitget USDT-futures; usdVol=quoteVol,coinVol=baseVol\",\n };\n}\nconst MEXC_IV: Record = {\n \"5m\": \"Min5\",\n \"15m\": \"Min15\",\n \"1h\": \"Min60\",\n \"4h\": \"Hour4\",\n};\nasync function mexcPrice(coin: string, iv: string, from: number, to: number) {\n const s = coin + \"_USDT\", bms = KIVMS[iv];\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 1900 * bms, to);\n const { j } = await exJson(\n `https://contract.mexc.com/api/v1/contract/kline/${s}?interval=${\n MEXC_IV[iv]\n }&start=${Math.floor(cur / 1000)}&end=${Math.floor(end / 1000)}`,\n );\n const d = (j && j.data) || {};\n const tt = d.time || [];\n if (!tt.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (let i = 0; i < tt.length; i++) {\n const t = tt[i] * 1000;\n if (t < from || t > to) continue;\n if (!seen.has(t)) {\n seen.set(t, [\n t,\n +d.open[i],\n +d.high[i],\n +d.low[i],\n +d.close[i],\n +d.amount[i] || 0,\n +d.vol[i] || 0,\n ]);\n }\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: \"MEXC perp; usdVol=amount,coinVol=vol(contracts)\",\n };\n}\nconst KUCOIN_IV: Record = {\n \"5m\": 5,\n \"15m\": 15,\n \"1h\": 60,\n \"4h\": 240,\n};\nasync function kucoinPrice(coin: string, iv: string, from: number, to: number) {\n const s = (coin === \"BTC\" ? \"XBT\" : coin) + \"USDTM\", bms = KIVMS[iv];\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 200 * bms, to);\n const { j } = await exJson(\n `https://api-futures.kucoin.com/api/v1/kline/query?symbol=${s}&granularity=${\n KUCOIN_IV[iv]\n }&from=${cur}&to=${end}`,\n );\n const d = (j && j.data) || [];\n if (!Array.isArray(d) || !d.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const k of d) {\n const t = +k[0];\n if (t < from || t > to) continue;\n if (!seen.has(t)) {\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[6] || 0, +k[5] || 0]);\n }\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: \"KuCoin perp; usdVol=turnover,coinVol=vol(base)\",\n };\n}\nconst DERIBIT_IV: Record = {\n \"5m\": \"5\",\n \"15m\": \"15\",\n \"1h\": \"60\",\n \"4h\": \"240\",\n};\nasync function deribitPrice(\n coin: string,\n iv: string,\n from: number,\n to: number,\n) {\n const inst = coin + \"-PERPETUAL\", bms = KIVMS[iv];\n if (!canHit(\"ex\")) {\n return { rows: [], complete: false, resume: { from, to }, note: \"budget\" };\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://www.deribit.com/api/v2/public/get_tradingview_chart_data?instrument_name=${inst}&resolution=${\n DERIBIT_IV[iv]\n }&start_timestamp=${from}&end_timestamp=${to}`,\n );\n const r = (j && j.result) || {};\n const tt = r.ticks || [];\n const co = curOpenOf(bms);\n const seen = new Map();\n for (let i = 0; i < tt.length; i++) {\n const t = +tt[i];\n if (t < from || t > to || t >= co) continue;\n seen.set(t, [\n t,\n +r.open[i],\n +r.high[i],\n +r.low[i],\n +r.close[i],\n +r.cost[i] || 0,\n +r.volume[i] || 0,\n ]);\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete: true,\n resume: null,\n note: \"Deribit \" + inst + \"; usdVol=cost,coinVol=volume (BTC/ETH-focused)\",\n };\n}\nconst BYBIT_IV: Record = {\n \"5m\": \"5\",\n \"15m\": \"15\",\n \"1h\": \"60\",\n \"4h\": \"240\",\n};\nconst BYBIT_OIIV: Record = {\n \"5m\": \"5min\",\n \"15m\": \"15min\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nasync function bybitPrice(coin: string, iv: string, from: number, to: number) {\n const s = coin + \"USDT\", bms = KIVMS[iv];\n const seen = new Map();\n let endT = to, complete = true;\n while (endT > from) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.bybit.com/v5/market/kline?category=linear&symbol=${s}&interval=${\n BYBIT_IV[iv]\n }&end=${endT}&limit=1000`,\n );\n const d = (j && j.result && j.result.list) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = Infinity;\n for (const k of d) {\n const t = +k[0];\n if (t < oldest) oldest = t;\n if (t >= from && t <= to && !seen.has(t)) {\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[6] || 0, +k[5] || 0]);\n }\n }\n if (!isFinite(oldest) || oldest <= from) break;\n endT = oldest - bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from, to: endT },\n note: \"Bybit linear (\" +\n (proxyHost(\"https://api.bybit.com/\")\n ? \"via UK proxy\"\n : \"GEO-BLOCKED from DC IPs?\") +\n \"); usdVol=turnover,coinVol=vol\",\n };\n}\nasync function bybitOI(coin: string, iv: string, from: number, to: number) {\n const s = coin + \"USDT\", bms = KIVMS[iv];\n if (!canHit(\"ex\")) {\n return { rows: [], complete: false, resume: { from, to }, note: \"budget\" };\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.bybit.com/v5/market/open-interest?category=linear&symbol=${s}&intervalTime=${\n BYBIT_OIIV[iv]\n }&startTime=${from}&endTime=${to}&limit=200`,\n );\n const d = (j && j.result && j.result.list) || [];\n const co = curOpenOf(bms);\n const acc = new Map();\n for (const k of d) {\n const t = +k.timestamp;\n if (t < from || t > to || t >= co) continue;\n acc.set(t, +k.openInterest);\n }\n return {\n rows: [...acc.keys()].sort((a, b) => a - b).map((\n t,\n ) => [t, Math.round(acc.get(t)!)]),\n complete: true,\n resume: null,\n note: \"Bybit OI (\" +\n (proxyHost(\"https://api.bybit.com/\")\n ? \"via UK proxy\"\n : \"GEO-BLOCKED from DC IPs?\") +\n \"); unit=contracts\",\n };\n}\n// ---- Binance LIVE USD-M fapi (v1.6): real-time price + recent OI, via UK proxy ----\n// fapi.binance.com is geo/DC-blocked, so this is only useful when routed through the UK\n// forwarder (add fapi.binance.com to RR_PROXY_HOSTS). For deep history use src=binance_vision.\nconst BINF_IV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nasync function binanceLivePrice(\n coin: string,\n iv: string,\n from: number,\n to: number,\n) {\n const s = coin + \"USDT\", bms = KIVMS[iv];\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 1500 * bms, to);\n const { j } = await exJson(\n `https://fapi.binance.com/fapi/v1/klines?symbol=${s}&interval=${\n BINF_IV[iv]\n }&startTime=${cur}&endTime=${end}&limit=1500`,\n );\n const d = Array.isArray(j) ? j : [];\n if (!d.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const k of d) {\n const t = +k[0];\n if (t < from || t > to) continue; // [openTime,o,h,l,c,vol,closeTime,quoteVol,...]\n if (!seen.has(t)) {\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[7] || 0, +k[5] || 0]);\n }\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: \"Binance LIVE fapi (\" +\n (proxyHost(\"https://fapi.binance.com/\")\n ? \"via UK proxy\"\n : \"DIRECT-likely-blocked\") +\n \"); usdVol=quoteVol,coinVol=base\",\n };\n}\nconst BINF_OIIV: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nasync function binanceLiveOI(\n coin: string,\n iv: string,\n from: number,\n to: number,\n) {\n const s = coin + \"USDT\", bms = KIVMS[iv];\n const acc = new Map();\n let cur = from, complete = true; // openInterestHist: <=500/call, ~30d retention\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 500 * bms, to);\n const { j } = await exJson(\n `https://fapi.binance.com/futures/data/openInterestHist?symbol=${s}&period=${\n BINF_OIIV[iv]\n }&startTime=${cur}&endTime=${end}&limit=500`,\n );\n const d = Array.isArray(j) ? j : [];\n if (!d.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const k of d) {\n const t = +k.timestamp;\n if (t < from || t > to) continue;\n const oi = parseFloat(k.sumOpenInterest);\n if (oi > 0) acc.set(t, oi);\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...acc.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => [t, Math.round(acc.get(t)!)]),\n complete,\n resume: { from: cur, to },\n note: \"Binance LIVE openInterestHist (\" +\n (proxyHost(\"https://fapi.binance.com/\")\n ? \"via UK proxy\"\n : \"DIRECT-likely-blocked\") +\n \"); unit=contracts(sumOpenInterest); ~30d retention\",\n };\n}\nconst EXPRICE: Record = {\n okx: okxPrice,\n gate: gatePrice,\n gateio: gatePrice,\n \"gate.io\": gatePrice,\n hyperliquid: hlPrice,\n hl: hlPrice,\n bitget: bitgetPrice,\n mexc: mexcPrice,\n kucoin: kucoinPrice,\n deribit: deribitPrice,\n bybit: bybitPrice,\n binance_live: binanceLivePrice,\n binancelive: binanceLivePrice,\n \"binance-live\": binanceLivePrice,\n};\nconst EXOI: Record = {\n gate: gateOI,\n gateio: gateOI,\n \"gate.io\": gateOI,\n bybit: bybitOI,\n binance_live: binanceLiveOI,\n binancelive: binanceLiveOI,\n \"binance-live\": binanceLiveOI,\n};\n\n// ================= DERIVATIVES STATS (v1.7): long/short, taker, funding, liquidations ==========\n// TIME SYNC (per CANDLE_TIME_MODEL.md): every timestamp is floored to the iv grid\n// G(t) = Math.floor(t/bms)*bms -> the bucket-OPEN mark. All series therefore share the\n// identical 5m/15m/1h/4h grid, whether fetched direct or via the UK proxy (the proxy is\n// transport-only; data always carries the exchange's own server timestamp). Funding is kept\n// at its native settle time (already grid-aligned). Liquidations are summed into grid buckets.\n// Every response carries coverage{first,last,step_ms,expected,got,gaps} on that grid.\n// DST-SAFE: ALL math is UTC epoch-ms and UTC has no DST, so the grid never shifts across the\n// NY spring-forward (2nd Sun Mar) / fall-back (1st Sun Nov). No fixed UTC-4/UTC-5 offset is\n// ever used anywhere in this relay. Convert to ET only at the DISPLAY/input edge, with IANA\n// \"America/New_York\" (e.g. Intl.DateTimeFormat tz), which switches EST/EDT automatically.\nconst STATP: Record = {\n \"5m\": \"5m\",\n \"15m\": \"15m\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nconst G = (t: number, bms: number) => Math.floor(t / bms) * bms;\n\n// ---- Binance futures/data (period, <=500/call, ~30d retention) via UK proxy ----\nasync function binStat(\n path: string,\n coin: string,\n iv: string,\n from: number,\n to: number,\n map: (d: any) => number[] | null,\n note: string,\n) {\n const s = coin + \"USDT\", bms = KIVMS[iv];\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 500 * bms, to);\n const { j } = await exJson(\n `https://fapi.binance.com/futures/data/${path}?symbol=${s}&period=${\n STATP[iv]\n }&startTime=${cur}&endTime=${end}&limit=500`,\n );\n const d = Array.isArray(j) ? j : [];\n if (!d.length) {\n if (end >= to) break;\n cur = end + bms;\n continue;\n }\n let maxt = cur;\n for (const it of d) {\n const r = map(it);\n if (!r) continue;\n const t = G(r[0], bms);\n if (t < from || t > to) continue;\n if (!seen.has(t)) seen.set(t, [t, ...r.slice(1)]);\n if (r[0] > maxt) maxt = r[0];\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n cur = maxt + bms;\n await new Promise((r) => setTimeout(r, 120));\n }\n const co = curOpenOf(bms),\n px = proxyHost(\"https://fapi.binance.com/\")\n ? \" (via UK proxy)\"\n : \" (DIRECT-likely-blocked)\";\n return {\n rows: [...seen.keys()].filter((t) => t < co).sort((a, b) => a - b).map((\n t,\n ) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: note + px,\n };\n}\nconst binLSR =\n (kind: string) => (c: string, iv: string, f: number, t: number) =>\n binStat(\n kind === \"global\"\n ? \"globalLongShortAccountRatio\"\n : kind === \"top_pos\"\n ? \"topLongShortPositionRatio\"\n : \"topLongShortAccountRatio\",\n c,\n iv,\n f,\n t,\n (d) => [+d.timestamp, +d.longShortRatio, +d.longAccount, +d.shortAccount],\n \"Binance L/S \" + kind + \" [ratio,long,short]\",\n );\nconst binTaker = (c: string, iv: string, f: number, t: number) =>\n binStat(\n \"takerlongshortRatio\",\n c,\n iv,\n f,\n t,\n (d) => [+d.timestamp, +d.buySellRatio, +d.buyVol, +d.sellVol],\n \"Binance taker buy/sell [ratio,buyVol,sellVol]\",\n );\n\n// ---- Funding-rate history (native settle cadence, already grid-aligned) ----\nasync function binFunding(c: string, from: number, to: number) {\n const s = c + \"USDT\";\n const seen = new Map();\n let cur = from, complete = true;\n while (cur < to) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://fapi.binance.com/fapi/v1/fundingRate?symbol=${s}&startTime=${cur}&endTime=${to}&limit=1000`,\n );\n const d = Array.isArray(j) ? j : [];\n if (!d.length) break;\n let maxt = cur;\n for (const it of d) {\n const t = +it.fundingTime;\n if (t < from || t > to) continue;\n if (!seen.has(t)) seen.set(t, [t, +it.fundingRate]);\n if (t > maxt) maxt = t;\n }\n if (maxt <= cur) break;\n cur = maxt + 1;\n await new Promise((r) => setTimeout(r, 120));\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete,\n resume: { from: cur, to },\n note: \"Binance funding (8h settle)\" +\n (proxyHost(\"https://fapi.binance.com/\") ? \" (via UK proxy)\" : \"\"),\n };\n}\nasync function bybitFunding(c: string, from: number, to: number) {\n const s = c + \"USDT\";\n const seen = new Map();\n let endT = to, complete = true;\n while (endT > from) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.bybit.com/v5/market/funding/history?category=linear&symbol=${s}&startTime=${from}&endTime=${endT}&limit=200`,\n );\n const d = (j && j.result && j.result.list) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = Infinity;\n for (const k of d) {\n const t = +k.fundingRateTimestamp;\n if (t < oldest) oldest = t;\n if (t >= from && t <= to && !seen.has(t)) {\n seen.set(t, [t, +k.fundingRate]);\n }\n }\n if (!isFinite(oldest) || oldest <= from) break;\n endT = oldest - 1;\n await new Promise((r) => setTimeout(r, 120));\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete,\n resume: { from, to: endT },\n note: \"Bybit funding\" +\n (proxyHost(\"https://api.bybit.com/\") ? \" (via UK proxy)\" : \"\"),\n };\n}\nasync function okxFunding(c: string, from: number, to: number) {\n const inst = c + \"-USDT-SWAP\";\n const seen = new Map();\n let before = to, complete = true, guard = 0;\n while (before > from && guard++ < 200) {\n if (!canHit(\"ex\")) {\n complete = false;\n break;\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://www.okx.com/api/v5/public/funding-rate-history?instId=${inst}&before=${from}&after=${before}&limit=100`,\n );\n const d = (j && j.data) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = Infinity;\n for (const k of d) {\n const t = +k.fundingTime;\n if (t < oldest) oldest = t;\n if (t >= from && t <= to && !seen.has(t)) {\n seen.set(t, [t, +k.fundingRate]);\n }\n }\n if (!isFinite(oldest) || oldest <= from) break;\n before = oldest;\n await new Promise((r) => setTimeout(r, 120));\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete,\n resume: { from, to: before },\n note: \"OKX funding\",\n };\n}\nasync function gateFunding(c: string, from: number, to: number) {\n const ct = c + \"_USDT\";\n const seen = new Map();\n if (!canHit(\"ex\")) {\n return { rows: [], complete: false, resume: { from, to }, note: \"budget\" };\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.gateio.ws/api/v4/futures/usdt/funding_rate?contract=${ct}&limit=1000`,\n );\n const d = Array.isArray(j) ? j : [];\n for (const k of d) {\n const t = (+k.t) * 1000;\n if (t >= from && t <= to && !seen.has(t)) seen.set(t, [t, +k.r]);\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete: true,\n resume: null,\n note: \"Gate funding (latest<=1000)\",\n };\n}\n\n// ---- OKX rubik stats (5m/1h grid, recent history) ----\nasync function okxRubik(\n pathq: string,\n c: string,\n iv: string,\n from: number,\n to: number,\n map: (a: any) => number[] | null,\n note: string,\n) {\n const bms = KIVMS[iv];\n const seen = new Map();\n if (!canHit(\"ex\")) {\n return { rows: [], complete: false, resume: { from, to }, note: \"budget\" };\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://www.okx.com/api/v5/rubik/stat/${pathq}&period=${\n STATP[iv]\n }&begin=${from}&end=${to}`,\n );\n const d = (j && j.data) || [];\n const co = curOpenOf(bms);\n for (const a of d) {\n const r = map(a);\n if (!r) continue;\n const t = G(r[0], bms);\n if (t < from || t > to || t >= co) continue;\n if (!seen.has(t)) seen.set(t, [t, ...r.slice(1)]);\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete: true,\n resume: null,\n note,\n };\n}\nconst okxLSR = (c: string, iv: string, f: number, t: number) =>\n okxRubik(\n `contracts/long-short-account-ratio?ccy=${c}`,\n c,\n iv,\n f,\n t,\n (a) => [+a[0], +a[1]],\n \"OKX L/S account ratio\",\n );\nconst okxTaker = (c: string, iv: string, f: number, t: number) =>\n okxRubik(\n `taker-volume?ccy=${c}&instType=CONTRACTS`,\n c,\n iv,\n f,\n t,\n (a) => [+a[0], +a[2], +a[1]],\n \"OKX taker [buyVol,sellVol]\",\n );\n\n// ---- Bybit long/short account ratio (via UK proxy) ----\nconst BYB_LSIV: Record = {\n \"5m\": \"5min\",\n \"15m\": \"15min\",\n \"1h\": \"1h\",\n \"4h\": \"4h\",\n};\nasync function bybitLSR(c: string, iv: string, from: number, to: number) {\n const s = c + \"USDT\", bms = KIVMS[iv];\n const seen = new Map();\n if (!canHit(\"ex\")) {\n return { rows: [], complete: false, resume: { from, to }, note: \"budget\" };\n }\n mark(\"ex\");\n const { j } = await exJson(\n `https://api.bybit.com/v5/market/account-ratio?category=linear&symbol=${s}&period=${\n BYB_LSIV[iv]\n }&limit=500`,\n );\n const d = (j && j.result && j.result.list) || [];\n const co = curOpenOf(bms);\n for (const k of d) {\n const t = G(+k.timestamp, bms);\n if (t < from || t > to || t >= co) continue;\n if (!seen.has(t)) seen.set(t, [t, +k.buyRatio, +k.sellRatio]);\n }\n return {\n rows: [...seen.keys()].sort((a, b) => a - b).map((t) => seen.get(t)!),\n complete: true,\n resume: null,\n note: \"Bybit L/S account [buyRatio,sellRatio]\" +\n (proxyHost(\"https://api.bybit.com/\") ? \" (via UK proxy)\" : \"\"),\n };\n}\n\n// ---- Coinalyze aggregated liquidations + funding + L/S (deep history; keyed by key) ----\nasync function czSeries(\n czKey: string,\n coin: string,\n endpoint: string,\n iv: string,\n from: number,\n to: number,\n pick: (h: any) => number[] | null,\n agg: boolean,\n note: string,\n) {\n const mkt = await ensureCzMkt(czKey);\n const picks = (mkt.map[coin] || []).slice(0, CZ_MAX_VENUES);\n if (!picks.length) {\n return {\n rows: [],\n complete: true,\n resume: { from, to },\n note: \"no_cz_venue\",\n };\n }\n const bms = KIVMS[iv], syms = picks.map((m: any) => m.s);\n const acc: Record = {};\n const chunkMs = 800 * bms;\n let cur = from, complete = true;\n outer: for (; cur < to; cur += chunkMs) {\n const b = Math.min(cur + chunkMs, to);\n for (let i = 0; i < syms.length; i += 20) {\n if (!canHit(\"cz\")) {\n complete = false;\n break outer;\n }\n mark(\"cz\");\n const chunk = syms.slice(i, i + 20);\n try {\n const url = `${CZ_BASE}/${endpoint}?symbols=${\n chunk.join(\",\")\n }&interval=${CZ_IV[iv]}&from=${Math.floor(cur / 1000)}&to=${\n Math.floor(b / 1000)\n }&convert_to_usd=true`;\n const { j } = await jget(url, { \"api_key\": czKey });\n if (Array.isArray(j)) {\n for (const row of j) {\n for (const h of (row.history || [])) {\n const r = pick(h);\n if (!r) continue;\n const t = G(r[0], bms);\n if (t < from || t > to) {\n continue;\n }\n if (!acc[t]) acc[t] = [t, ...r.slice(1).map(() => 0)];\n for (let k = 1; k < r.length; k++) {\n acc[t][k] = agg\n ? acc[t][k] + r[k]\n : r[k];\n }\n }\n }\n }\n } catch (_e) { /* */ }\n await new Promise((r) => setTimeout(r, 200));\n }\n }\n const co = curOpenOf(bms);\n const rows = Object.keys(acc).map(Number).filter((t) => t < co).sort((a, b) =>\n a - b\n )\n .map((t) => acc[t].map((v, i) => i === 0 ? v : Math.round(v * 1e6) / 1e6));\n return {\n rows,\n complete,\n resume: { from: cur, to },\n note: note + \" (coinalyze agg x\" + picks.length + \")\",\n };\n}\n\nexport default async function (req: Request) {\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 bad(\"unauthorized_relay\", 403, auth);\n }\n }\n\n if (u.searchParams.get(\"ping\")) {\n return resp(\n JSON.stringify({\n ver: \"rr-1.8\",\n ok: 1,\n caps: {\n bx: cap(\"bx\"),\n cz: cap(\"cz\"),\n cg: cap(\"cg\"),\n gk: cap(\"gk\"),\n bv: cap(\"bv\"),\n ex: cap(\"ex\"),\n },\n limits: {\n // Pacing that measured ~0x 429 over a 40-min all-source backtest (2026-07-24). `ex` is a\n // SHARED rolling-60s pool for EVERY public exchange API (incl. binance_live/bybit via UK proxy).\n note:\n \"stay under these; ex is ONE shared pool for all public exchanges — pace per group + a global floor\",\n per_60s: {\n bx: cap(\"bx\"),\n cz: cap(\"cz\"),\n cg: cap(\"cg\"),\n gk: cap(\"gk\"),\n bv: cap(\"bv\"),\n ex: cap(\"ex\"),\n },\n min_interval_ms: {\n ex: 950,\n bv: 2000,\n bx: 2000,\n cz: 6500,\n cg: 6500,\n gk: 6500,\n },\n global_min_ms: 700,\n ex_shared: [\n \"okx\",\n \"gate\",\n \"hyperliquid\",\n \"bitget\",\n \"mexc\",\n \"kucoin\",\n \"deribit\",\n \"bybit\",\n \"binance_live\",\n \"bybit_proxy\",\n ],\n tips: {\n probe_first: true,\n honor_partial_resume: true,\n slow_proxy_timeout_ms: 80000,\n },\n },\n keys: {\n coinalyze: !!Deno.env.get(\"COINALYZE_KEY\"),\n coinglass: !!Deno.env.get(\"CG_KEY\"),\n coingecko: !!Deno.env.get(\"CG_GECKO_KEY\"),\n binance_vision: true,\n exchanges: true,\n },\n proxy: {\n configured: !!proxyUrl(),\n secret_set: !!proxySecret(),\n hosts: proxyUrl() ? proxyHosts() : [],\n },\n sources: {\n price: [\n \"bitunix\",\n \"coinglass\",\n \"coinalyze\",\n \"binance_vision\",\n \"binance\",\n \"okx\",\n \"gate\",\n \"hyperliquid\",\n \"bitget\",\n \"mexc\",\n \"kucoin\",\n \"deribit\",\n \"bybit\",\n \"binance_live\",\n ],\n oi: [\n \"coinalyze\",\n \"coinglass\",\n \"binance_vision\",\n \"binance\",\n \"gate\",\n \"bybit\",\n \"binance_live\",\n ],\n oi_historical: [\n \"coinalyze\",\n \"coinglass\",\n \"binance_vision/binance\",\n \"gate\",\n ],\n oi_current_only_not_served: [\n \"okx(recent-rubik)\",\n \"hyperliquid\",\n \"bitget\",\n \"mexc\",\n \"kucoin\",\n \"deribit\",\n ],\n geo_blocked_from_dc_ips: [\n \"binance_live(fapi)\" + (proxyHost(\"https://fapi.binance.com/\")\n ? \"(routed via UK proxy)\"\n : \"(add fapi.binance.com to RR_PROXY_HOSTS; else use binance_vision)\"),\n \"bybit\" + (proxyHost(\"https://api.bybit.com/\")\n ? \"(routed via UK proxy)\"\n : \"(set RR_PROXY_URL to route via UK proxy)\"),\n ],\n },\n stats: {\n lsr: {\n srcs: [\"binance\", \"bybit\", \"okx\"],\n kinds: [\"top_pos\", \"top_acct\", \"global\"],\n note: \"binance/bybit via UK proxy; ~30d\",\n },\n taker: {\n srcs: [\"binance\", \"okx\"],\n note: \"buy/sell aggression; ~30d\",\n },\n funding: {\n srcs: [\"binance\", \"bybit\", \"okx\", \"gate\"],\n note: \"native ~8h settle cadence, deep history\",\n },\n liq: {\n srcs: [\"coinalyze\"],\n note:\n \"long/short liq USD summed per bucket; binance/bybit are live-stream-only\",\n },\n },\n time_model:\n \"all UTC epoch-ms, floored to bucket-OPEN grid; DST-safe (no fixed ET offset); convert to ET at display only via America/New_York\",\n }),\n 200,\n auth,\n );\n }\n\n // ---------------- COINGECKO (spot price/volume/mcap, deep history, no OI) ----------------\n if (u.searchParams.get(\"gecko\")) {\n const sym = (u.searchParams.get(\"gecko\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).slice(0, 20);\n if (!sym) return bad(\"no_symbol\", 400, auth);\n const coin = sym.replace(/USDT$/, \"\");\n const key = Deno.env.get(\"CG_GECKO_KEY\");\n if (!key) return bad(\"no_key(CG_GECKO_KEY)\", 503, auth);\n const gfrom = parseInt(u.searchParams.get(\"from\") || \"0\", 10);\n const gto = parseInt(u.searchParams.get(\"to\") || String(Date.now()), 10);\n if (!(gfrom > 1577836800000 && gto > gfrom)) {\n return bad(\"bad_window (from/to ms)\", 400, auth);\n }\n let idr: any;\n try {\n idr = await ensureGeckoId(key, coin);\n } catch (_e) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"coingecko\",\n retry_in: retryIn(\"gk\"),\n }),\n 429,\n auth,\n );\n }\n if (!idr) {\n return resp(\n JSON.stringify({\n ts: Date.now(),\n kind: \"gecko\",\n symbol: sym,\n coin,\n id: null,\n n: 0,\n prices: [],\n volumes: [],\n mcaps: [],\n note: \"no_gecko_match\",\n budget: { used: used(\"gk\"), cap: cap(\"gk\") },\n }),\n 200,\n );\n }\n const r = await geckoRange(key, idr.id, gfrom, gto);\n return resp(\n JSON.stringify({\n ts: Date.now(),\n kind: \"gecko\",\n symbol: sym,\n coin,\n id: idr.id,\n name: idr.name,\n rank: idr.rank,\n n: r.prices.length,\n prices: r.prices,\n volumes: r.volumes,\n mcaps: r.mcaps,\n partial: !r.complete,\n note: (r.err ? r.err + \";\" : \"\") +\n \"spot_aggregated;price=line;volume=24h_rolling;mcap=usd;granularity=auto(gecko:<=1d~5m,<=90d~1h,>90d~1d)\",\n resume: r.complete ? null : { from: gfrom, to: gto },\n budget: { used: used(\"gk\"), cap: cap(\"gk\") },\n }),\n 200,\n );\n }\n\n const iv = (u.searchParams.get(\"iv\") || \"5m\").toLowerCase();\n if (!KIVMS[iv]) return bad(\"bad_interval (use 5m/15m/1h/4h)\", 400, auth);\n const from = parseInt(u.searchParams.get(\"from\") || \"0\", 10);\n const to = parseInt(u.searchParams.get(\"to\") || String(Date.now()), 10);\n if (!(from > 1577836800000 && to > from)) {\n return bad(\"bad_window (from/to ms)\", 400, auth);\n }\n const bms = KIVMS[iv];\n\n // ---------------- PRICE + VOLUME ----------------\n if (u.searchParams.get(\"price\")) {\n const sym = (u.searchParams.get(\"price\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).slice(0, 20);\n const src = (u.searchParams.get(\"src\") || \"bitunix\").toLowerCase();\n if (!sym) return bad(\"no_symbol\", 400, auth);\n const coin = sym.replace(/USDT$/, \"\");\n\n if (src === \"bitunix\") {\n if (!canHit(\"bx\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"bitunix\",\n retry_in: retryIn(\"bx\"),\n }),\n 429,\n auth,\n );\n }\n const r = await bxPrice(sym, iv, from, to);\n return out(\n \"price\",\n { symbol: sym },\n \"bitunix\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n \"usdVol=baseVol,coinVol=quoteVol\",\n \"bx\",\n );\n }\n if (src === \"coinglass\") {\n const key = Deno.env.get(\"CG_KEY\");\n if (!key) return bad(\"no_key(CG_KEY)\", 503, auth);\n if (!canHit(\"cg\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"coinglass\",\n retry_in: retryIn(\"cg\"),\n }),\n 429,\n auth,\n );\n }\n const r = await cgPaged(\n (a, b) =>\n CG_BASE + \"/api/futures/price/history?exchange=Bitunix&symbol=\" +\n sym +\n \"&interval=\" + CG_IV[iv] + \"&limit=1000&start_time=\" + a +\n \"&end_time=\" + b,\n key,\n from,\n to,\n bms,\n (d) => {\n const t = parseInt(d.time ?? d.t);\n const o = +(d.open ?? d.o),\n h = +(d.high ?? d.h),\n l = +(d.low ?? d.l),\n c = +(d.close ?? d.c);\n return (t > 0 && o > 0 && c > 0)\n ? [t, o, h, l, c, null as any, null as any]\n : null;\n },\n );\n return out(\n \"price\",\n { symbol: sym },\n \"coinglass\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.err || \"exchange=Bitunix,no_volume\",\n \"cg\",\n );\n }\n if (src === \"coinalyze\") {\n const key = Deno.env.get(\"COINALYZE_KEY\");\n if (!key) return bad(\"no_key(COINALYZE_KEY)\", 503, auth);\n let r: any;\n try {\n r = await czPrice(key, coin, iv, from, to);\n } catch (_e) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"coinalyze\",\n retry_in: retryIn(\"cz\"),\n }),\n 429,\n auth,\n );\n }\n return out(\n \"price\",\n { symbol: sym },\n \"coinalyze\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"cz\",\n );\n }\n if (\n src === \"binance_vision\" || src === \"binance-vision\" || src === \"bv\" ||\n src === \"binance\" || src === \"binance-futures\" ||\n src === \"binance_futures\"\n ) {\n // Binance live fapi is geo-blocked from DC IPs -> serve Binance's own CDN (Vision).\n if (!canHit(\"bv\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"binance_vision\",\n retry_in: retryIn(\"bv\"),\n }),\n 429,\n auth,\n );\n }\n const r = await bvPrice(sym, iv, from, to);\n return out(\n \"price\",\n { symbol: sym },\n \"binance_vision\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"bv\",\n );\n }\n const exf = EXPRICE[src];\n if (exf) {\n if (!canHit(\"ex\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src,\n retry_in: retryIn(\"ex\"),\n }),\n 429,\n auth,\n );\n }\n const r = await exf(coin, iv, from, to);\n return out(\n \"price\",\n { symbol: sym },\n src,\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"ex\",\n );\n }\n return bad(\n \"bad_src (bitunix|coinglass|coinalyze|binance_vision|okx|gate|hyperliquid|bitget|mexc|kucoin|deribit|bybit)\",\n 400,\n auth,\n );\n }\n\n // ---------------- OPEN INTEREST (contracts) ----------------\n if (u.searchParams.get(\"oi\")) {\n const coin = (u.searchParams.get(\"oi\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).replace(/USDT$/, \"\").slice(0, 20);\n const src = (u.searchParams.get(\"src\") || \"coinalyze\").toLowerCase();\n const venue = (u.searchParams.get(\"venue\") || \"\").toLowerCase();\n if (!coin) return bad(\"no_coin\", 400, auth);\n\n if (src === \"coinalyze\") {\n const key = Deno.env.get(\"COINALYZE_KEY\");\n if (!key) return bad(\"no_key(COINALYZE_KEY)\", 503, auth);\n let r: any;\n try {\n r = await czOI(key, coin, iv, from, to, venue);\n } catch (_e) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"coinalyze\",\n retry_in: retryIn(\"cz\"),\n }),\n 429,\n auth,\n );\n }\n return out(\n \"oi\",\n { coin },\n \"coinalyze\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"cz\",\n { unit: \"contracts\" },\n );\n }\n if (src === \"coinglass\") {\n const key = Deno.env.get(\"CG_KEY\");\n if (!key) return bad(\"no_key(CG_KEY)\", 503, auth);\n if (!canHit(\"cg\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"coinglass\",\n retry_in: retryIn(\"cg\"),\n }),\n 429,\n auth,\n );\n }\n const isVenue = venue === \"bitunix\";\n const path = isVenue\n ? (a: number, b: number) =>\n CG_BASE +\n \"/api/futures/open-interest/history?exchange=Bitunix&symbol=\" + coin +\n \"USDT\" +\n \"&interval=\" + CG_IV[iv] + \"&limit=1000&unit=coin&start_time=\" + a +\n \"&end_time=\" + b\n : (a: number, b: number) =>\n CG_BASE + \"/api/futures/open-interest/aggregated-history?symbol=\" +\n coin +\n \"&interval=\" + CG_IV[iv] + \"&limit=1000&unit=coin&start_time=\" + a +\n \"&end_time=\" + b;\n const r = await cgPaged(path, key, from, to, bms, (d) => {\n const t = parseInt(d.time ?? d.t);\n const c = parseFloat(d.close ?? d.c);\n return (t > 0 && c > 0) ? [t, c] : null;\n });\n return out(\n \"oi\",\n { coin },\n \"coinglass\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n (r.err || (isVenue ? \"venue:bitunix\" : \"aggregated\")) + \",unit=coin\",\n \"cg\",\n { unit: \"contracts\" },\n );\n }\n if (\n src === \"binance_vision\" || src === \"binance-vision\" || src === \"bv\" ||\n src === \"binance\" || src === \"binance-futures\" ||\n src === \"binance_futures\"\n ) {\n if (!canHit(\"bv\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"binance_vision\",\n retry_in: retryIn(\"bv\"),\n }),\n 429,\n auth,\n );\n }\n const r = await bvOI(coin, iv, from, to);\n return out(\n \"oi\",\n { coin },\n \"binance_vision\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"bv\",\n { unit: \"contracts\" },\n );\n }\n const exf = EXOI[src];\n if (exf) {\n if (!canHit(\"ex\")) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src,\n retry_in: retryIn(\"ex\"),\n }),\n 429,\n auth,\n );\n }\n const r = await exf(coin, iv, from, to);\n return out(\n \"oi\",\n { coin },\n src,\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"ex\",\n { unit: \"contracts\" },\n );\n }\n return bad(\n \"bad_src (coinalyze|coinglass|binance_vision|gate|bybit) — historical OI: binance_vision, gate (coinalyze/coinglass); others current-only\",\n 400,\n auth,\n );\n }\n\n // ---------------- LONG/SHORT RATIO ---------------- ?lsr=COIN&src=binance|bybit|okx&kind=top_pos|top_acct|global\n if (u.searchParams.get(\"lsr\")) {\n const coin = (u.searchParams.get(\"lsr\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).replace(/USDT$/, \"\").slice(0, 20);\n const src = (u.searchParams.get(\"src\") || \"binance\").toLowerCase(),\n kind = (u.searchParams.get(\"kind\") || \"top_pos\").toLowerCase();\n if (!coin) return bad(\"no_coin\", 400, auth);\n if (!canHit(\"ex\")) {\n return resp(\n JSON.stringify({ error: \"over_budget\", src, retry_in: retryIn(\"ex\") }),\n 429,\n auth,\n );\n }\n let r: any;\n if (src === \"binance\" || src === \"binance_live\") {\n r = await binLSR(kind)(coin, iv, from, to);\n } else if (src === \"bybit\") r = await bybitLSR(coin, iv, from, to);\n else if (src === \"okx\") r = await okxLSR(coin, iv, from, to);\n else return bad(\"bad_src (binance|bybit|okx)\", 400, auth);\n return out(\n \"lsr\",\n { coin, kind },\n src,\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"ex\",\n );\n }\n\n // ---------------- TAKER BUY/SELL ---------------- ?taker=COIN&src=binance|okx\n if (u.searchParams.get(\"taker\")) {\n const coin = (u.searchParams.get(\"taker\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).replace(/USDT$/, \"\").slice(0, 20);\n const src = (u.searchParams.get(\"src\") || \"binance\").toLowerCase();\n if (!coin) return bad(\"no_coin\", 400, auth);\n if (!canHit(\"ex\")) {\n return resp(\n JSON.stringify({ error: \"over_budget\", src, retry_in: retryIn(\"ex\") }),\n 429,\n auth,\n );\n }\n let r: any;\n if (src === \"binance\" || src === \"binance_live\") {\n r = await binTaker(coin, iv, from, to);\n } else if (src === \"okx\") r = await okxTaker(coin, iv, from, to);\n else return bad(\"bad_src (binance|okx)\", 400, auth);\n return out(\n \"taker\",\n { coin },\n src,\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"ex\",\n );\n }\n\n // ---------------- FUNDING RATE ---------------- ?funding=COIN&src=binance|bybit|okx|gate (native settle cadence)\n if (u.searchParams.get(\"funding\")) {\n const coin = (u.searchParams.get(\"funding\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).replace(/USDT$/, \"\").slice(0, 20);\n const src = (u.searchParams.get(\"src\") || \"binance\").toLowerCase();\n if (!coin) return bad(\"no_coin\", 400, auth);\n if (!canHit(\"ex\")) {\n return resp(\n JSON.stringify({ error: \"over_budget\", src, retry_in: retryIn(\"ex\") }),\n 429,\n auth,\n );\n }\n let r: any;\n if (src === \"binance\" || src === \"binance_live\") {\n r = await binFunding(coin, from, to);\n } else if (src === \"bybit\") r = await bybitFunding(coin, from, to);\n else if (src === \"okx\") r = await okxFunding(coin, from, to);\n else if (src === \"gate\") r = await gateFunding(coin, from, to);\n else return bad(\"bad_src (binance|bybit|okx|gate)\", 400, auth);\n return out(\n \"funding\",\n { coin },\n src,\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"ex\",\n );\n }\n\n // ---------------- LIQUIDATIONS ---------------- ?liq=COIN&src=coinalyze (long,short summed per bucket)\n if (u.searchParams.get(\"liq\")) {\n const coin = (u.searchParams.get(\"liq\") || \"\").toUpperCase().replace(\n /[^A-Z0-9]/g,\n \"\",\n ).replace(/USDT$/, \"\").slice(0, 20);\n const src = (u.searchParams.get(\"src\") || \"coinalyze\").toLowerCase();\n if (!coin) return bad(\"no_coin\", 400, auth);\n if (src === \"coinalyze\") {\n const key = Deno.env.get(\"COINALYZE_KEY\");\n if (!key) return bad(\"no_key(COINALYZE_KEY)\", 503, auth);\n let r: any;\n try {\n r = await czSeries(\n key,\n coin,\n \"liquidation-history\",\n iv,\n from,\n to,\n (h) => [h.t * 1000, +h.l || 0, +h.s || 0],\n true,\n \"liquidations [longLiqUSD,shortLiqUSD]\",\n );\n } catch (_e) {\n return resp(\n JSON.stringify({\n error: \"over_budget\",\n src: \"coinalyze\",\n retry_in: retryIn(\"cz\"),\n }),\n 429,\n auth,\n );\n }\n return out(\n \"liq\",\n { coin },\n \"coinalyze\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"cz\",\n { unit: \"usd\" },\n );\n }\n return bad(\n \"bad_src (coinalyze) — Binance/Bybit stream liquidations live only; use coinalyze for history\",\n 400,\n auth,\n );\n }\n\n return bad(\n \"no_mode: ?ping | ?price= | ?oi= | ?lsr= | ?taker= | ?funding= | ?liq= (all &src=&iv=&from=&to=)\",\n 400,\n auth,\n );\n}","createdAt",["D",1784968633550],"branchVersion","branchId","f94a36b9-7957-4e7e-bf91-4861857e76a3","id","a3b99a40-98e8-4ff3-9092-fd2d2d4df007","Research-Relay",["D",1784013657228],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","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",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":25},"branch",{"_13":82,"_32":83,"_42":41,"_84":43,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":44,"_91":92},"isOwned",11,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","eldiablo","handle","displayName","El Diablo","avatar","https://lh3.googleusercontent.com/a/ACg8ocI-0uTtZqiyglualMQAA4_Mb-Fyf50cPQxTypBBMiaPeGkhcUQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":150,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":25,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":151,"_77":152,"_79":153,"_81":25},"tree",[145],"files",[145],"counts",{"_133":59,"_134":135,"_136":59,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":126,"_32":28,"_30":31,"_127":-5,"_40":41,"_39":14,"_128":25,"_37":129,"_13":130,"_33":34,"_35":36,"_24":25,"_131":-5,"_27":132},"abab60d4-6112-40ce-bed5-153e9b9efe04","parentId","latest",["D",1784968633550],8,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":59},"connections",{"_141":59,"_142":59},"count","unfilledCount",6,"emptyCount",{"_42":126,"_32":28,"_30":31,"_127":-5,"_40":41,"_39":14,"_128":25,"_37":146,"_13":130,"_33":34,"_35":36,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1784968633550],"children",[],[28],["D",1784013657228],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":25},{"_13":82,"_32":83,"_42":41,"_84":43,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":44,"_91":92},"ctx",{"_75":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":120,"_196":-5,"_197":-7,"_198":-7,"_199":59,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":83,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v9