[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_150":151,"_152":153},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_87":-7,"_88":89,"_29":-7,"_90":-5,"_15":91,"_92":93,"_94":95,"_96":97,"_98":99,"_100":-5,"_101":-5,"_102":-5,"_103":38,"_104":105,"_106":107,"_108":-5,"_109":-5,"_110":111},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","eldiablo","name","Research-Relay","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_60":59,"_61":62,"_63":62,"_64":62,"_65":59,"_66":59,"_67":68,"_69":70,"_71":72,"_73":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","f94a36b9-7957-4e7e-bf91-4861857e76a3","createdAt",["D",1784013657233],"updatedAt",["D",1784969048206],"main","projectId","a3b99a40-98e8-4ff3-9092-fd2d2d4df007","version",11,"forkedBranchId","forkedBranchVersion","lockfileKey","1784969048654-esm.town_v_eldiablo_Research-Relay@11-main","deletedAt",["D",1784013657228],"legacyEnvVars",false,"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",{"_11":12,"_86":82},"org",{"_11":12,"_79":80,"_81":82,"_44":45,"_83":84,"_85":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","El Diablo","avatar","https://lh3.googleusercontent.com/a/ACg8ocI-0uTtZqiyglualMQAA4_Mb-Fyf50cPQxTypBBMiaPeGkhcUQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":146,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_60":59,"_61":62,"_63":62,"_64":62,"_65":59,"_66":59,"_67":147,"_69":148,"_71":149,"_73":38},"tree",[141],"files",[141],"counts",{"_130":51,"_17":131,"_132":51,"_133":134,"_135":136},"contents",[112],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":113,"_13":114,"_115":116,"_117":-5,"_118":21,"_119":30,"_120":107,"_22":121,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_88":129},"d800d652-0e45-484e-af1a-7694b3e1e096","main.ts","fileId","8ea7b926-7f54-11f1-bc37-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1784969048206],10,"fileType","http","content","// research-relay v1.9 (2026-07-25) MINIFIED build — readable source: research_relay_v19.ts in BackTest Research. Same behavior; deploy as Research-Relay Val.\nimport { strFromU8, unzipSync } from \"https://esm.sh/fflate@0.8.2\";\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 },\n 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.9\",\n },\n BX_BASE = \"https://fapi.bitunix.com/api/v1/futures/market/\",\n CZ_BASE = \"https://api.coinalyze.net/v1\",\n CG_BASE = \"https://open-api-v4.coinglass.com\",\n BV_BASE = \"https://data.binance.vision/data/futures/um/daily\",\n KIVMS = { \"5m\": 3e5, \"15m\": 9e5, \"1h\": 36e5, \"4h\": 144e5 },\n BX_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" },\n CZ_IV = { \"5m\": \"5min\", \"15m\": \"15min\", \"1h\": \"1hour\", \"4h\": \"4hour\" },\n CG_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" },\n BV_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" },\n DAYMS = 864e5,\n CZ_MKT_TTL = 36e5,\n CZ_MAX_VENUES = 12,\n CZ_QUOTES = [\"USDT\"];\nlet czMkt = null;\nconst GK_DEMO_BASE = \"https://api.coingecko.com/api/v3\",\n GK_PRO_BASE = \"https://pro-api.coingecko.com/api/v3\",\n GK_ID_TTL = 864e5,\n gkIds = new Map();\nfunction gkCfg(key) {\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, coin) {\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 { j } = await jget(base + \"/search?query=\" + encodeURIComponent(coin), hdr),\n coins = (j && j.coins) || [],\n m =\n coins.filter((c) => (c.symbol || \"\").toUpperCase() === coin).sort((\n a,\n b,\n ) => (a.market_cap_rank ?? 1e9) - (b.market_cap_rank ?? 1e9))[0] ||\n 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 return (gkIds.set(coin, rec), rec);\n}\nasync function geckoRange(key, id, from, to) {\n if (!canHit(\"gk\")) {\n return { complete: !1, prices: [], volumes: [], mcaps: [], err: \"budget\" };\n }\n mark(\"gk\");\n const { base, hdr } = gkCfg(key),\n url = base + \"/coins/\" + id + \"/market_chart/range?vs_currency=usd&from=\" +\n Math.floor(from / 1e3) + \"&to=\" + Math.floor(to / 1e3),\n { status, j } = await jget(url, hdr);\n if (status === 401) {\n return {\n complete: !0,\n prices: [],\n volumes: [],\n mcaps: [],\n err: \"unauthorized\",\n };\n }\n const win = (arr) =>\n (Array.isArray(arr) ? arr : []).map((p) => [Math.round(p[0]), p[1]]).filter(\n (p) => p[0] >= from && p[0] <= to\n );\n return {\n complete: !0,\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}\nconst hits = { bx: [], cz: [], cg: [], gk: [], bv: [], ex: [] };\nfunction cap(src) {\n const env =\n {\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 def = { bx: 40, cz: 10, cg: 10, gk: 10, bv: 40, ex: 90 }[src],\n v = parseInt(Deno.env.get(env) || \"\", 10);\n return v > 0 ? v : def;\n}\nfunction used(src) {\n const now = Date.now();\n return ((hits[src] = hits[src].filter((t) => now - t < 6e4)),\n hits[src].length);\n}\nfunction canHit(src) {\n return used(src) < cap(src);\n}\nfunction mark(src) {\n hits[src].push(Date.now());\n}\nfunction retryIn(src) {\n const now = Date.now();\n return ((hits[src] = hits[src].filter((t) => now - t < 6e4)),\n hits[src].length ? Math.ceil((6e4 - (now - hits[src][0])) / 1e3) : 1);\n}\nfunction resp(body, status = 200, auth = \"open\") {\n return new Response(body, {\n status,\n headers: { ...CORS, \"x-relay-auth\": auth },\n });\n}\nfunction bad(msg, status = 400, auth = \"open\") {\n return resp(JSON.stringify({ error: msg }), status, auth);\n}\nasync function jget(url, headers) {\n const r = await fetch(url, { headers });\n return { status: r.status, j: await r.json().catch(() => null) };\n}\nfunction coverage(rows, from, to, step) {\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],\n last = rows[rows.length - 1][0],\n gaps = [];\n for (let i = 1; i < rows.length; i++) {\n const d = rows[i][0] - rows[i - 1][0];\n 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,\n id,\n src,\n iv,\n rows,\n from,\n to,\n complete,\n resumeWin,\n note,\n srcKey,\n extra = {},\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}\nasync function bxPrice(sym, iv, from, to) {\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 = !0;\n for (; hi >= from;) {\n if (!canHit(\"bx\")) {\n complete = !1;\n break;\n }\n mark(\"bx\");\n let rows2 = [];\n try {\n const url = BX_BASE + \"kline?symbol=\" + sym + \"&interval=\" + BX_IV[iv] +\n \"&startTime=\" + from + \"&endTime=\" + hi +\n \"&limit=200&type=LAST_PRICE\",\n { j } = await jget(url, HDRS);\n rows2 = (j && j.data && (j.data.list || j.data)) || [];\n } catch {\n rows2 = [];\n }\n if (!Array.isArray(rows2) || !rows2.length) break;\n let oldest = 1 / 0,\n added = 0;\n for (const kk of rows2) {\n const t = parseInt(kk.time ?? kk.ts ?? kk.t ?? 0),\n o = parseFloat(kk.open ?? kk.o),\n h = parseFloat(kk.high ?? kk.h),\n l = parseFloat(kk.low ?? kk.l),\n c = parseFloat(kk.close ?? kk.c),\n uv = parseFloat(kk.baseVol ?? kk.quoteVolume ?? kk.turnover ?? 0),\n cv = parseFloat(\n kk.quoteVol ?? kk.baseVolume ?? kk.volume ?? kk.vol ?? 0,\n );\n t > 0 && o > 0 && h > 0 && l > 0 && c > 0 && l <= h &&\n (t < oldest && (oldest = t),\n 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 if (!isFinite(oldest)) break;\n const nxt = oldest - 1;\n if (nxt >= hi || ((hi = nxt), oldest <= from && added === 0)) break;\n await new Promise((r) => setTimeout(r, 200));\n }\n const rows = [...seen.keys()]\n .filter((t) => t >= from && t <= to)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t));\n return {\n rows,\n complete: complete && (rows.length ? rows[0][0] <= from + bms : !0),\n resume: { from, to: hi },\n };\n}\nasync function cgPaged(path, key, from, to, bms, map) {\n const seen = new Map();\n let cur = from,\n complete = !0,\n diag = null;\n for (; cur <= to;) {\n if (!canHit(\"cg\")) {\n complete = !1;\n break;\n }\n mark(\"cg\");\n const end = Math.min(cur + 1e3 * bms, to);\n let data = [];\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: !0,\n resume: { from: cur, to },\n err: \"unauthorized(401)\",\n };\n }\n const okCode = j && (String(j.code) === \"0\" || j.code === void 0),\n arr = j &&\n (Array.isArray(j.data)\n ? j.data\n : j.data && Array.isArray(j.data.list)\n ? j.data.list\n : null);\n okCode && Array.isArray(arr)\n ? (data = arr)\n : diag ||\n (diag = \"cg http=\" + status + \" code=\" + (j && j.code) + \" msg=\" +\n (j && (j.msg ?? j.message ?? \"?\")));\n } catch {\n (diag || (diag = \"cg fetch_err\"), (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 t < from || t > to ||\n (seen.has(t) || seen.set(t, row), t > maxt && (maxt = t));\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 200)));\n }\n const now = Date.now(),\n curOpen = Math.floor(now / bms) * bms,\n rows = [...seen.keys()]\n .filter((t) => t < curOpen)\n .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}\nasync function ensureCzMkt(czKey) {\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 = {};\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 e && e.code && (exCode[e.code] = String(e.name || \"\").toLowerCase());\n }\n }\n }\n } catch {}\n const map = {};\n for (const m of j) {\n if (\n !m || !m.is_perpetual || CZ_QUOTES.indexOf(m.quote_asset) < 0 ||\n (m.oi_lq_vol_denominated_in || \"\").toUpperCase() !== \"BASE_ASSET\"\n ) continue;\n const ba = (m.base_asset || \"\").toUpperCase();\n ba &&\n (map[ba] = map[ba] || []).push({\n s: m.symbol,\n ex: m.exchange,\n exn: exCode[m.exchange] || \"\",\n });\n }\n return ((czMkt = { ts: Date.now(), map, exCode }), czMkt);\n}\nasync function czOI(czKey, coin, iv, from, to, venue) {\n let picks = (await ensureCzMkt(czKey)).map[coin] || [];\n if (\n (venue && (picks = picks.filter((mm) => mm.exn === venue)),\n (picks = picks.slice(0, CZ_MAX_VENUES)),\n !picks.length)\n ) {\n return {\n rows: [],\n complete: !0,\n resume: { from, to },\n note: \"no_cz_venue\",\n };\n }\n const bms = KIVMS[iv],\n syms = picks.map((mm) => mm.s),\n acc = {},\n chunkMs = 800 * bms;\n let cur = from,\n complete = !0;\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 = !1;\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] + \"&from=\" +\n Math.floor(cur / 1e3) + \"&to=\" + Math.floor(b / 1e3) +\n \"&convert_to_usd=false\",\n { 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 * 1e3;\n t < from || t > to ||\n (acc[t] = (acc[t] || 0) + (parseFloat(cnd.c) || 0));\n }\n }\n }\n } catch {}\n await new Promise((r) => setTimeout(r, 200));\n }\n }\n const curOpen = Math.floor(Date.now() / bms) * bms;\n return {\n rows: Object.keys(acc)\n .map(Number)\n .filter((t) => t < curOpen)\n .sort((a, b) => a - b)\n .map((t) => [t, Math.round(acc[t])]),\n complete,\n resume: { from: cur, to },\n note: venue\n ? \"venue:\" + venue + \" x\" + picks.length\n : \"agg x\" + picks.length,\n };\n}\nasync function czPrice(czKey, coin, iv, from, to) {\n const bx = ((await ensureCzMkt(czKey)).map[coin] || []).find((mm) =>\n mm.exn === \"bitunix\"\n );\n if (!bx) {\n return {\n rows: [],\n complete: !0,\n resume: { from, to },\n note: \"no_bitunix_market_on_coinalyze\",\n };\n }\n const bms = KIVMS[iv],\n chunkMs = 800 * bms,\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to; cur += chunkMs) {\n if (!canHit(\"cz\")) {\n complete = !1;\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] + \"&from=\" +\n Math.floor(cur / 1e3) + \"&to=\" + Math.floor(b / 1e3),\n { 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 * 1e3;\n t < from || t > to || seen.has(t) ||\n seen.set(t, [t, +h.o, +h.h, +h.l, +h.c, +(h.v ?? 0), null]);\n }\n }\n }\n } catch {}\n await new Promise((r) => setTimeout(r, 200));\n }\n const curOpen = Math.floor(Date.now() / bms) * bms;\n return {\n rows: [...seen.keys()]\n .filter((t) => t < curOpen)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: \"cz_market:\" + bx.s,\n };\n}\nfunction bvDates(from, to) {\n const out2 = [];\n let t = from - (from % DAYMS);\n const end = to + DAYMS;\n for (; t <= end;) {\n (out2.push(new Date(t).toISOString().slice(0, 10)), (t += DAYMS));\n }\n return out2;\n}\nasync function bvCsvLines(url) {\n let buf;\n try {\n const r = await fetch(url);\n if (!r.ok) return null;\n buf = await r.arrayBuffer();\n } catch {\n return null;\n }\n try {\n const files = unzipSync(new Uint8Array(buf)),\n name = Object.keys(files)[0];\n return name\n ? strFromU8(files[name]).trim().split(`\n`)\n : null;\n } catch {\n return null;\n }\n}\nfunction bvParseMs(s) {\n return Date.parse(s.slice(0, 19).replace(\" \", \"T\") + \"Z\");\n}\nasync function bvOI(coin, iv, from, to) {\n const sym = coin + \"USDT\",\n raw = new Map();\n let complete = !0,\n resumeFrom = from,\n hit = !1;\n for (const date of bvDates(from, to)) {\n if (!canHit(\"bv\")) {\n complete = !1;\n break;\n }\n mark(\"bv\");\n const lines = await bvCsvLines(\n BV_BASE + \"/metrics/\" + sym + \"/\" + sym + \"-metrics-\" + date + \".zip\",\n );\n if (((resumeFrom = Date.parse(date + \"T00:00:00Z\") + DAYMS), !!lines)) {\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]),\n oi = parseFloat(p[2]);\n !(t > 0) || !isFinite(oi) || oi <= 0 || t < from || t > to ||\n (raw.set(t, oi), (hit = !0));\n }\n }\n }\n const bms = KIVMS[iv];\n let rows;\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();\n for (const t of raw.keys()) {\n const b = Math.floor(t / bms) * bms,\n c = bkt.get(b);\n (!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}\nasync function bvPrice(sym, iv, from, to) {\n const seen = new Map();\n let complete = !0,\n resumeFrom = from,\n hit = !1;\n for (const date of bvDates(from, to)) {\n if (!canHit(\"bv\")) {\n complete = !1;\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 if (((resumeFrom = Date.parse(date + \"T00:00:00Z\") + DAYMS), !!lines)) {\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]),\n o = +p[1],\n h = +p[2],\n l = +p[3],\n c = +p[4],\n coinVol = +p[5],\n usdVol = +p[7];\n !(t > 0 && o > 0 && h > 0 && l > 0 && c > 0 && l <= h) || t < from ||\n t > to || seen.has(t) ||\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 = !0));\n }\n }\n }\n const bms = KIVMS[iv],\n curOpen = Math.floor(Date.now() / bms) * bms;\n return {\n rows: [...seen.keys()]\n .filter((t) => t < curOpen)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\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}\nfunction proxyUrl() {\n return (Deno.env.get(\"RR_PROXY_URL\") || \"\").trim();\n}\nfunction proxySecret() {\n return (Deno.env.get(\"RR_PROXY_SECRET\") || \"\").trim();\n}\nfunction proxyHosts() {\n return (Deno.env.get(\"RR_PROXY_HOSTS\") || \"api.bybit.com\")\n .split(\",\")\n .map((s) => s.trim().toLowerCase())\n .filter(Boolean);\n}\nfunction proxyHost(url) {\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, opt) {\n try {\n if (proxyHost(url)) {\n const r2 = 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) || void 0,\n body: (opt && opt.body) || void 0,\n }),\n }),\n upstream = parseInt(r2.headers.get(\"x-upstream-status\") || \"\", 10);\n return {\n status: isFinite(upstream) ? upstream : r2.status,\n j: await r2.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 {\n return { status: 0, j: null };\n }\n}\nconst curOpenOf = (bms) => Math.floor(Date.now() / bms) * bms,\n OKX_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1H\", \"4h\": \"4H\" };\nasync function okxPrice(coin, iv, from, to) {\n const inst = coin + \"-USDT-SWAP\",\n bms = KIVMS[iv],\n seen = new Map();\n let after = to + bms,\n complete = !0;\n for (; after > from;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 d = (j && j.data) || [];\n if (!d.length) break;\n let oldest = 1 / 0;\n for (const k of d) {\n const t = +k[0];\n (t < oldest && (oldest = t),\n 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 if (!isFinite(oldest) || oldest <= from) break;\n ((after = oldest), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from, to: after },\n note: \"OKX SWAP; usdVol=volCcyQuote,coinVol=volCcy\",\n };\n}\nconst GATE_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" };\nasync function gatePrice(coin, iv, from, to) {\n const c = coin + \"_USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 1999 * bms, to),\n { 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 / 1e3)}&to=${Math.floor(end / 1e3)}`,\n ),\n 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 * 1e3;\n t < from || t > to ||\n (seen.has(t) ||\n seen.set(t, [t, +k.o, +k.h, +k.l, +k.c, +k.sum || 0, +k.v || 0]),\n t > maxt && (maxt = t));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => 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, iv, from, to) {\n const c = coin + \"_USDT\",\n bms = KIVMS[iv],\n acc = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 / 1e3)}&limit=100`,\n ),\n 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 * 1e3;\n if (t < from || t > to) continue;\n const oi = +k.open_interest;\n (oi > 0 && acc.set(t, oi), t > maxt && (maxt = t));\n }\n if (maxt <= cur) break;\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...acc.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => [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 = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" };\nasync function hlPrice(coin, iv, from, to) {\n const bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 4999 * bms, to),\n { 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 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 t < from || t > to ||\n (seen.has(t) ||\n seen.set(t, [t, +k.o, +k.h, +k.l, +k.c, null, +k.v || 0]),\n t > maxt && (maxt = t));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: \"Hyperliquid perp; coinVol=v(base); no usdVol\",\n };\n}\nconst BITGET_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1H\", \"4h\": \"4H\" };\nasync function bitgetPrice(coin, iv, from, to) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let endT = to + bms,\n complete = !0;\n for (; endT > from;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 d = (j && j.data) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = 1 / 0;\n for (const k of d) {\n const t = +k[0];\n (t < oldest && (oldest = t),\n 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 if (!isFinite(oldest) || oldest <= from) break;\n ((endT = oldest), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from, to: endT },\n note: \"Bitget USDT-futures; usdVol=quoteVol,coinVol=baseVol\",\n };\n}\nconst MEXC_IV = { \"5m\": \"Min5\", \"15m\": \"Min15\", \"1h\": \"Min60\", \"4h\": \"Hour4\" };\nasync function mexcPrice(coin, iv, from, to) {\n const s = coin + \"_USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 1900 * bms, to),\n { j } = await exJson(\n `https://contract.mexc.com/api/v1/contract/kline/${s}?interval=${\n MEXC_IV[iv]\n }&start=${Math.floor(cur / 1e3)}&end=${Math.floor(end / 1e3)}`,\n ),\n d = (j && j.data) || {},\n 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] * 1e3;\n t < from || t > to ||\n (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 t > maxt && (maxt = t));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: \"MEXC perp; usdVol=amount,coinVol=vol(contracts)\",\n };\n}\nconst KUCOIN_IV = { \"5m\": 5, \"15m\": 15, \"1h\": 60, \"4h\": 240 };\nasync function kucoinPrice(coin, iv, from, to) {\n const s = (coin === \"BTC\" ? \"XBT\" : coin) + \"USDTM\",\n bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 200 * bms, to),\n { 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 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 t < from || t > to ||\n (seen.has(t) ||\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[6] || 0, +k[5] || 0]),\n t > maxt && (maxt = t));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: \"KuCoin perp; usdVol=turnover,coinVol=vol(base)\",\n };\n}\nconst DERIBIT_IV = { \"5m\": \"5\", \"15m\": \"15\", \"1h\": \"60\", \"4h\": \"240\" };\nasync function deribitPrice(coin, iv, from, to) {\n const inst = coin + \"-PERPETUAL\",\n bms = KIVMS[iv];\n if (!canHit(\"ex\")) {\n return { rows: [], complete: !1, 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 r = (j && j.result) || {},\n tt = r.ticks || [],\n co = curOpenOf(bms),\n seen = new Map();\n for (let i = 0; i < tt.length; i++) {\n const t = +tt[i];\n t < from || t > to || t >= co ||\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: !0,\n resume: null,\n note: \"Deribit \" + inst + \"; usdVol=cost,coinVol=volume (BTC/ETH-focused)\",\n };\n}\nconst BYBIT_IV = { \"5m\": \"5\", \"15m\": \"15\", \"1h\": \"60\", \"4h\": \"240\" },\n BYBIT_OIIV = { \"5m\": \"5min\", \"15m\": \"15min\", \"1h\": \"1h\", \"4h\": \"4h\" };\nasync function bybitPrice(coin, iv, from, to) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let endT = to,\n complete = !0;\n for (; endT > from;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 d = (j && j.result && j.result.list) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = 1 / 0;\n for (const k of d) {\n const t = +k[0];\n (t < oldest && (oldest = t),\n 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 if (!isFinite(oldest) || oldest <= from) break;\n ((endT = oldest - bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from, to: endT },\n note: \"Bybit linear (\" + (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, iv, from, to) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv];\n if (!canHit(\"ex\")) {\n return { rows: [], complete: !1, 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 d = (j && j.result && j.result.list) || [],\n co = curOpenOf(bms),\n acc = new Map();\n for (const k of d) {\n const t = +k.timestamp;\n t < from || t > to || t >= co || 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: !0,\n resume: null,\n note: \"Bybit OI (\" + (proxyHost(\"https://api.bybit.com/\")\n ? \"via UK proxy\"\n : \"GEO-BLOCKED from DC IPs?\") +\n \"); unit=contracts\",\n };\n}\nconst BINF_IV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" };\nasync function binanceLivePrice(coin, iv, from, to) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 1500 * bms, to),\n { 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 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 t < from || t > to ||\n (seen.has(t) ||\n seen.set(t, [t, +k[1], +k[2], +k[3], +k[4], +k[7] || 0, +k[5] || 0]),\n t > maxt && (maxt = t));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...seen.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: \"Binance LIVE fapi (\" + (proxyHost(\"https://fapi.binance.com/\")\n ? \"via UK proxy\"\n : \"DIRECT-likely-blocked\") +\n \"); usdVol=quoteVol,coinVol=base\",\n };\n}\nconst BINF_OIIV = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" };\nasync function binanceLiveOI(coin, iv, from, to) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv],\n acc = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 500 * bms, to),\n { 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 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 (oi > 0 && acc.set(t, oi), t > maxt && (maxt = t));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), await new Promise((r) => setTimeout(r, 120)));\n }\n const co = curOpenOf(bms);\n return {\n rows: [...acc.keys()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => [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 = {\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 },\n EXOI = {\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 STATP = { \"5m\": \"5m\", \"15m\": \"15m\", \"1h\": \"1h\", \"4h\": \"4h\" },\n G = (t, bms) => Math.floor(t / bms) * bms;\nasync function binStat(path, coin, iv, from, to, map, note) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 500 * bms, to),\n { 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 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 t < from || t > to ||\n (seen.has(t) || seen.set(t, [t, ...r.slice(1)]),\n r[0] > maxt && (maxt = r[0]));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), 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()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: note + px,\n };\n}\nconst binLSR = (kind) => (c, iv, f, t) =>\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 ),\n binTaker = (c, iv, f, t) =>\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 );\nasync function binBasis(coin, iv, from, to) {\n const s = coin + \"USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\n break;\n }\n mark(\"ex\");\n const end = Math.min(cur + 500 * bms, to),\n { j } = await exJson(\n `https://fapi.binance.com/futures/data/basis?pair=${s}&contractType=PERPETUAL&period=${\n STATP[iv]\n }&startTime=${cur}&endTime=${end}&limit=500`,\n ),\n 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 t0 = +it.timestamp,\n t = G(t0, bms);\n (t >= from && t <= to && !seen.has(t) &&\n seen.set(t, [\n t,\n +it.basisRate,\n +it.basis,\n +it.futuresPrice,\n +it.indexPrice,\n ]),\n t0 > maxt && (maxt = t0));\n }\n if (maxt <= cur) {\n cur = end + bms;\n continue;\n }\n ((cur = maxt + bms), 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()]\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) => seen.get(t)),\n complete,\n resume: { from: cur, to },\n note: \"Binance basis [basisRate,basis,futuresPrice,indexPrice]\" + px,\n };\n}\nasync function binFunding(c, from, to) {\n const s = c + \"USDT\",\n seen = new Map();\n let cur = from,\n complete = !0;\n for (; cur < to;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 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 t < from || t > to ||\n (seen.has(t) || seen.set(t, [t, +it.fundingRate]),\n t > maxt && (maxt = t));\n }\n if (maxt <= cur) break;\n ((cur = maxt + 1), 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, from, to) {\n const s = c + \"USDT\",\n seen = new Map();\n let endT = to,\n complete = !0;\n for (; endT > from;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 d = (j && j.result && j.result.list) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = 1 / 0;\n for (const k of d) {\n const t = +k.fundingRateTimestamp;\n (t < oldest && (oldest = t),\n t >= from && t <= to && !seen.has(t) &&\n seen.set(t, [t, +k.fundingRate]));\n }\n if (!isFinite(oldest) || oldest <= from) break;\n ((endT = oldest - 1), 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, from, to) {\n const inst = c + \"-USDT-SWAP\",\n seen = new Map();\n let before = to,\n complete = !0,\n guard = 0;\n for (; before > from && guard++ < 200;) {\n if (!canHit(\"ex\")) {\n complete = !1;\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 d = (j && j.data) || [];\n if (!Array.isArray(d) || !d.length) break;\n let oldest = 1 / 0;\n for (const k of d) {\n const t = +k.fundingTime;\n (t < oldest && (oldest = t),\n t >= from && t <= to && !seen.has(t) &&\n seen.set(t, [t, +k.fundingRate]));\n }\n if (!isFinite(oldest) || oldest <= from) break;\n ((before = oldest), 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, from, to) {\n const ct = c + \"_USDT\",\n seen = new Map();\n if (!canHit(\"ex\")) {\n return { rows: [], complete: !1, 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 d = Array.isArray(j) ? j : [];\n for (const k of d) {\n const t = +k.t * 1e3;\n 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: !0,\n resume: null,\n note: \"Gate funding (latest<=1000)\",\n };\n}\nasync function okxRubik(pathq, c, iv, from, to, map, note) {\n const bms = KIVMS[iv],\n seen = new Map();\n if (!canHit(\"ex\")) {\n return { rows: [], complete: !1, 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 d = (j && j.data) || [],\n 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 t < from || t > to || t >= co || seen.has(t) ||\n 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: !0,\n resume: null,\n note,\n };\n}\nconst okxLSR = (c, iv, f, t) =>\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 ),\n okxTaker = (c, iv, f, t) =>\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 BYB_LSIV = { \"5m\": \"5min\", \"15m\": \"15min\", \"1h\": \"1h\", \"4h\": \"4h\" };\nasync function bybitLSR(c, iv, from, to) {\n const s = c + \"USDT\",\n bms = KIVMS[iv],\n seen = new Map();\n if (!canHit(\"ex\")) {\n return { rows: [], complete: !1, 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 d = (j && j.result && j.result.list) || [],\n co = curOpenOf(bms);\n for (const k of d) {\n const t = G(+k.timestamp, bms);\n t < from || t > to || t >= co || seen.has(t) ||\n 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: !0,\n resume: null,\n note: \"Bybit L/S account [buyRatio,sellRatio]\" +\n (proxyHost(\"https://api.bybit.com/\") ? \" (via UK proxy)\" : \"\"),\n };\n}\nasync function czStatAvg(\n czKey,\n coin,\n endpoint,\n iv,\n from,\n to,\n pick,\n venue,\n note,\n) {\n let picks = (await ensureCzMkt(czKey)).map[coin] || [];\n if (\n (venue && (picks = picks.filter((mm) => mm.exn === venue)),\n (picks = picks.slice(0, CZ_MAX_VENUES)),\n !picks.length)\n ) {\n return {\n rows: [],\n complete: !0,\n resume: { from, to },\n note: venue ? \"no_cz_venue(\" + venue + \")\" : \"no_cz_venue\",\n };\n }\n const bms = KIVMS[iv],\n syms = picks.map((mm) => mm.s),\n sum = {},\n cnt = {},\n chunkMs = 800 * bms;\n let cur = from,\n complete = !0;\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 = !1;\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 / 1e3)}&to=${\n Math.floor(b / 1e3)\n }`,\n { 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 sum[t] ||\n ((sum[t] = [t, ...r.slice(1).map(() => 0)]), (cnt[t] = 0));\n for (let k = 1; k < r.length; k++) sum[t][k] += r[k];\n cnt[t]++;\n }\n }\n }\n }\n } catch {}\n await new Promise((r) => setTimeout(r, 200));\n }\n }\n const co = curOpenOf(bms);\n return {\n rows: Object.keys(sum)\n .map(Number)\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) =>\n sum[t].map((\n v,\n i,\n ) => (i === 0 ? v : Math.round((v / Math.max(cnt[t], 1)) * 1e8) / 1e8))\n ),\n complete,\n resume: { from: cur, to },\n note: note + \" (coinalyze \" +\n (venue ? \"venue:\" + venue : \"avg x\" + picks.length) + \")\",\n };\n}\nasync function czSeries(czKey, coin, endpoint, iv, from, to, pick, agg, note) {\n const picks = ((await ensureCzMkt(czKey)).map[coin] || []).slice(\n 0,\n CZ_MAX_VENUES,\n );\n if (!picks.length) {\n return {\n rows: [],\n complete: !0,\n resume: { from, to },\n note: \"no_cz_venue\",\n };\n }\n const bms = KIVMS[iv],\n syms = picks.map((m) => m.s),\n acc = {},\n chunkMs = 800 * bms;\n let cur = from,\n complete = !0;\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 = !1;\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 / 1e3)}&to=${\n Math.floor(b / 1e3)\n }&convert_to_usd=true`,\n { 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 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 }\n } catch {}\n await new Promise((r) => setTimeout(r, 200));\n }\n }\n const co = curOpenOf(bms);\n return {\n rows: Object.keys(acc)\n .map(Number)\n .filter((t) => t < co)\n .sort((a, b) => a - b)\n .map((t) =>\n acc[t].map((v, i) => (i === 0 ? v : Math.round(v * 1e6) / 1e6))\n ),\n complete,\n resume: { from: cur, to },\n note: note + \" (coinalyze agg x\" + picks.length + \")\",\n };\n}\nasync function research_relay_v19_default(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 (\n rk &&\n ((auth =\n (req.headers.get(\"x-relay-key\") || u.searchParams.get(\"k\") || \"\") === rk\n ? \"ok\"\n : \"miss\"),\n auth === \"miss\" && Deno.env.get(\"RELAY_ENFORCE\") === \"1\")\n ) {\n return bad(\"unauthorized_relay\", 403, auth);\n }\n if (u.searchParams.get(\"ping\")) {\n return resp(\n JSON.stringify({\n ver: \"rr-1.9\",\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 note:\n \"stay under these; ex is ONE shared pool for all public exchanges \\u2014 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: 2e3,\n bx: 2e3,\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: !0,\n honor_partial_resume: !0,\n slow_proxy_timeout_ms: 8e4,\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: !0,\n exchanges: !0,\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)\" +\n (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\" +\n (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\", \"coinalyze\"],\n kinds: [\"top_pos\", \"top_acct\", \"global\"],\n note:\n \"binance/bybit via UK proxy ~30d; coinalyze(v1.9) = [ratio,long%,short%] avg across venues (venue= filters), full universe, deep history, kind n/a\",\n },\n taker: {\n srcs: [\"binance\", \"okx\"],\n note: \"buy/sell aggression; ~30d\",\n },\n funding: {\n srcs: [\"binance\", \"bybit\", \"okx\", \"gate\", \"coinalyze\"],\n note:\n \"binance/bybit/okx/gate = native ~8h settle, deep; coinalyze(v1.9) = rate-OHLC close per iv bucket, avg across venues (venue=bitunix -> Bitunix own funding), kind=predicted supported\",\n },\n liq: {\n srcs: [\"coinalyze\"],\n note:\n \"long/short liq USD summed per bucket; binance/bybit are live-stream-only\",\n },\n basis: {\n srcs: [\"binance\"],\n note:\n \"(v1.9) perp-vs-index basis [basisRate,basis,futuresPrice,indexPrice] via UK proxy; ~30d\",\n },\n pairs: {\n srcs: [\"bitunix\"],\n note: \"(v1.9) trading_pairs universe meta, no from/to window\",\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 if (u.searchParams.get(\"pairs\")) {\n const psrc = (u.searchParams.get(\"pairs\") || \"\").toLowerCase();\n if (psrc !== \"bitunix\" && psrc !== \"1\") {\n return bad(\"bad_pairs (use pairs=bitunix)\", 400, auth);\n }\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 mark(\"bx\");\n try {\n const j =\n await (await fetch(BX_BASE + \"trading_pairs\", { headers: HDRS }))\n .json(),\n rows = ((j && j.data) || []).map((m) => ({\n symbol: m.symbol,\n base: m.base,\n quote: m.quote,\n isApiSupported: m.isApiSupported !== !1,\n status: m.status ?? null,\n }));\n return resp(\n JSON.stringify({\n ts: Date.now(),\n kind: \"pairs\",\n src: \"bitunix\",\n n: rows.length,\n rows,\n note:\n \"Bitunix trading_pairs; isApiSupported=false marks US-stock/commodity/hours-restricted perps\",\n }),\n 200,\n auth,\n );\n } catch {\n return bad(\"bitunix_pairs_fetch_failed\", 502, auth);\n }\n }\n if (u.searchParams.get(\"gecko\")) {\n const sym = (u.searchParams.get(\"gecko\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .slice(0, 20);\n if (!sym) return bad(\"no_symbol\", 400, auth);\n const coin = sym.replace(/USDT$/, \"\"),\n 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 gto = parseInt(u.searchParams.get(\"to\") || String(Date.now()), 10);\n if (!(gfrom > 15778368e5 && gto > gfrom)) {\n return bad(\"bad_window (from/to ms)\", 400, auth);\n }\n let idr;\n try {\n idr = await ensureGeckoId(key, coin);\n } catch {\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 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 to = parseInt(u.searchParams.get(\"to\") || String(Date.now()), 10);\n if (!(from > 15778368e5 && to > from)) {\n return bad(\"bad_window (from/to ms)\", 400, auth);\n }\n const bms = KIVMS[iv];\n if (u.searchParams.get(\"price\")) {\n const sym = (u.searchParams.get(\"price\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .slice(0, 20),\n src = (u.searchParams.get(\"src\") || \"bitunix\").toLowerCase();\n if (!sym) return bad(\"no_symbol\", 400, auth);\n const coin = sym.replace(/USDT$/, \"\");\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 + \"&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 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 ? [t, o, h, l, c, null, null] : 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;\n try {\n r = await czPrice(key, coin, iv, from, to);\n } catch {\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 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 if (u.searchParams.get(\"oi\")) {\n const coin = (u.searchParams.get(\"oi\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .replace(/USDT$/, \"\")\n .slice(0, 20),\n src = (u.searchParams.get(\"src\") || \"coinalyze\").toLowerCase(),\n venue = (u.searchParams.get(\"venue\") || \"\").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;\n try {\n r = await czOI(key, coin, iv, from, to, venue);\n } catch {\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 r = await cgPaged(\n isVenue\n ? (a, b) =>\n CG_BASE +\n \"/api/futures/open-interest/history?exchange=Bitunix&symbol=\" +\n coin + \"USDT&interval=\" + CG_IV[iv] +\n \"&limit=1000&unit=coin&start_time=\" + a + \"&end_time=\" + b\n : (a, b) =>\n CG_BASE +\n \"/api/futures/open-interest/aggregated-history?symbol=\" + coin +\n \"&interval=\" + CG_IV[iv] + \"&limit=1000&unit=coin&start_time=\" +\n a + \"&end_time=\" + b,\n key,\n from,\n to,\n bms,\n (d) => {\n const t = parseInt(d.time ?? d.t),\n c = parseFloat(d.close ?? d.c);\n return t > 0 && c > 0 ? [t, c] : null;\n },\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) \\u2014 historical OI: binance_vision, gate (coinalyze/coinglass); others current-only\",\n 400,\n auth,\n );\n }\n if (u.searchParams.get(\"lsr\")) {\n const coin = (u.searchParams.get(\"lsr\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .replace(/USDT$/, \"\")\n .slice(0, 20),\n 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 (src === \"coinalyze\") {\n const key = Deno.env.get(\"COINALYZE_KEY\");\n if (!key) return bad(\"no_key(COINALYZE_KEY)\", 503, auth);\n const venue = (u.searchParams.get(\"venue\") || \"\").toLowerCase();\n let rz;\n try {\n rz = await czStatAvg(\n key,\n coin,\n \"long-short-ratio-history\",\n iv,\n from,\n to,\n (h) => [h.t * 1e3, +h.r, +h.l, +h.s],\n venue,\n \"L/S [ratio,long%,short%]; kind n/a on coinalyze\",\n );\n } catch {\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 \"lsr\",\n { coin, kind: \"global\" },\n \"coinalyze\",\n iv,\n rz.rows,\n from,\n to,\n rz.complete,\n rz.resume,\n rz.note,\n \"cz\",\n );\n }\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;\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 if (u.searchParams.get(\"taker\")) {\n const coin = (u.searchParams.get(\"taker\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .replace(/USDT$/, \"\")\n .slice(0, 20),\n 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;\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 if (u.searchParams.get(\"basis\")) {\n const coin = (u.searchParams.get(\"basis\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .replace(/USDT$/, \"\")\n .slice(0, 20),\n src = (u.searchParams.get(\"src\") || \"binance\").toLowerCase();\n if (!coin) return bad(\"no_coin\", 400, auth);\n if (src !== \"binance\" && src !== \"binance_live\") {\n return bad(\"bad_src (binance)\", 400, auth);\n }\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 const r = await binBasis(coin, iv, from, to);\n return out(\n \"basis\",\n { coin },\n \"binance\",\n iv,\n r.rows,\n from,\n to,\n r.complete,\n r.resume,\n r.note,\n \"ex\",\n );\n }\n if (u.searchParams.get(\"funding\")) {\n const coin = (u.searchParams.get(\"funding\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .replace(/USDT$/, \"\")\n .slice(0, 20),\n src = (u.searchParams.get(\"src\") || \"binance\").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 const venue = (u.searchParams.get(\"venue\") || \"\").toLowerCase(),\n kindf = (u.searchParams.get(\"kind\") || \"\").toLowerCase(),\n ep = kindf === \"predicted\"\n ? \"predicted-funding-rate-history\"\n : \"funding-rate-history\";\n let rz;\n try {\n rz = await czStatAvg(\n key,\n coin,\n ep,\n iv,\n from,\n to,\n (h) => [h.t * 1e3, +h.c],\n venue,\n (kindf === \"predicted\" ? \"predicted \" : \"\") +\n \"funding rate [close of rate OHLC]\",\n );\n } catch {\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 \"funding\",\n { coin },\n \"coinalyze\",\n iv,\n rz.rows,\n from,\n to,\n rz.complete,\n rz.resume,\n rz.note,\n \"cz\",\n );\n }\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;\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 if (u.searchParams.get(\"liq\")) {\n const coin = (u.searchParams.get(\"liq\") || \"\")\n .toUpperCase()\n .replace(/[^A-Z0-9]/g, \"\")\n .replace(/USDT$/, \"\")\n .slice(0, 20),\n 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;\n try {\n r = await czSeries(\n key,\n coin,\n \"liquidation-history\",\n iv,\n from,\n to,\n (h) => [h.t * 1e3, +h.l || 0, +h.s || 0],\n !0,\n \"liquidations [longLiqUSD,shortLiqUSD]\",\n );\n } catch {\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) \\u2014 Binance/Bybit stream liquidations live only; use coinalyze for history\",\n 400,\n auth,\n );\n }\n return bad(\n \"no_mode: ?ping | ?pairs=bitunix | ?price= | ?oi= | ?lsr= | ?taker= | ?funding= | ?liq= | ?basis= | ?gecko= (all series &src=&iv=&from=&to=)\",\n 400,\n auth,\n );\n}\nexport { research_relay_v19_default as default };","deleted","label",[114],"pulls",1,"forks","envVars",{"_137":139,"_140":51},"connections",{"_137":51,"_138":51},"count","unfilledCount",6,"emptyCount",{"_20":113,"_13":114,"_115":116,"_117":-5,"_118":21,"_119":30,"_120":107,"_22":142,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_143":144,"_88":145},["D",1784969048206],"children",[],[114],["D",1784013657228],{"_11":12,"_86":82},{"_11":12,"_79":80,"_81":82,"_44":45,"_83":84,"_85":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"ctx",{"_67":-5,"_109":183,"_184":185,"_186":187,"_188":38,"_189":38,"_190":38,"_191":107,"_192":-5,"_193":-7,"_194":-7,"_195":51,"_196":38,"_197":38,"_198":-5,"_199":38,"_200":38,"_201":38,"_202":-5},"ENV",{"_154":155,"_156":157,"_158":26,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1