[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_110":111,"_112":113},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","efrenlin","name","x-trader-consensus","path","lib/eulerpool.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/efrenlin/x-trader-consensus/code/lib/eulerpool.ts","extension","id","7d9e251e-80a0-4227-b89f-7042350e1018","eulerpool.ts","fileId","3668ab18-acf8-11f1-869b-1607ee4eb77e","parentId","8dccd4ba-aa00-11f1-906c-1607ee4eb77e","branchId","012dced4-9569-4aa1-b4df-043c162f1aa5","branchVersion",141,"latest",true,"createdAt",["D",1789039225650],"version",2,"fileType","script","content","// lib/eulerpool.ts — Controlled, single-ticker (NVDA-only) validation of\n// Eulerpool as a candidate replacement for Alpha Vantage on Price /\n// Historical Price / Price Momentum ONLY. Explicitly out of scope: FMP,\n// AnySearch, X, Anthropic, cron, the full Discovery pipeline/universe, and\n// any ticker other than NVDA.\n//\n// MINIMUM-CALLS DESIGN: a single request to the OHLCV charting endpoint\n// (resolution=D, ~110 calendar days back) returns enough daily closes to\n// derive latest price AND 1D/5D/20D/50D returns in ONE call — no separate\n// \"latest quote\" call is needed, since the most recent daily close in the\n// OHLCV series already serves as \"latest available price\".\n//\n// Docs consulted before writing this (2026-09-10): https://eulerpool.com/developers,\n// https://eulerpool.com/developers/api/market/quotes/latest, and\n// https://eulerpool.com/developers/api/charting/ohlcv. Per those pages:\n// - Base host: https://api.eulerpool.com\n// - OHLCV endpoint: GET /api/1/charting/ohlcv/{identifier}?resolution=D&from=&to=\n// (identifier accepts a plain ticker, e.g. NVDA). Response shape shown in\n// docs: { t: number[], o: number[], h: number[], l: number[], c: number[], v: number[] }.\n// - Auth: \"Authenticate with a query parameter (?token=YOUR_API_KEY) or an\n// Authorization: Bearer header.\" This file uses the Bearer header. Per\n// the minimum-calls instruction, if the Bearer header is rejected this\n// test does NOT retry with the query-param form in the same run — it\n// stops and reports the auth failure.\n// - The docs pages did not show a populated example response (only an\n// empty-array placeholder), so array ordering (ascending vs descending\n// by time) is NOT assumed — this code detects and normalizes it from\n// the returned timestamps themselves.\n//\n// market_data SCHEMA NOTE: the existing table (lib/marketData.ts) has\n// columns for price_change_1d / _1w / _1m only — there is no _20d or _50d\n// column. Per \"do not modify database schema\", this file does NOT add one.\n// 5D and 20D returns are stored into the existing _1w/_1m columns (the\n// closest existing approximation) and clearly labeled as such in the\n// report. 50D return has NO schema column to persist into — it is\n// computed and reported here as informational only, never stored, exactly\n// like the eps_growth_pct precedent in lib/alphavantage.ts.\n//\n// PERSISTENCE IS GENUINELY MERGE-SAFE: unlike persistMarketData() in\n// lib/marketData.ts (which overwrites every column, nulling out anything\n// not passed in), this file reads the existing NVDA row first and issues\n// an UPDATE that touches ONLY price, price_change_1d, price_change_1w,\n// price_change_1m, source, and fetched_at — every other column (pe_ratio,\n// pb_ratio, market_cap, ev, revenue_growth, gross_margin, roe,\n// debt_to_equity, avg_volume, flow) is left completely untouched by the\n// SQL statement itself, so any existing Alpha Vantage fundamental/\n// valuation values survive unconditionally.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureMarketDataSchema, scoreMarketDimensions, type MarketData } from \"./marketData.ts\";\n\nconst EULERPOOL_BASE = \"https://api.eulerpool.com\";\n\nfunction getKey(): string | null {\n const k = Deno.env.get(\"EULERPOOL_API_KEY\");\n return k && k.length > 0 ? k : null;\n}\n\nfunction noteForStatus(status: number | null): string {\n if (status === null) return \"network_error\";\n if (status >= 200 && status < 300) return \"ok\";\n if (status === 401) return \"authentication_failed\";\n if (status === 403) return \"plan_restricted\";\n return `error_${status}`;\n}\n\nexport interface EulerpoolReturnResult {\n label: string; // \"1D\" | \"5D\" | \"20D\" | \"50D\"\n pct: number | null;\n bars_back: number;\n available: boolean;\n note: string;\n}\n\nexport interface EulerpoolTestReport {\n ticker: \"NVDA\";\n provider: \"eulerpool\";\n provider_configured: boolean;\n auth: { header_used: string; status: number | null; ok: boolean; result: string } | null;\n api_calls: { endpoint: string; status: number | null; ok: boolean; note: string }[];\n bars_returned: number;\n earliest_bar_date: string | null;\n latest_bar_date: string | null;\n latest_price: number | null;\n returns: EulerpoolReturnResult[];\n momentum_dimension_score: number | null; // via existing scoreMarketDimensions(), reporting-only\n dimensions_reliably_supplied: string[];\n dimensions_not_supplied: string[];\n merge_safe_write: {\n attempted: boolean;\n row_existed_before: boolean;\n before: Record | null;\n after: Record | null;\n columns_written: string[];\n columns_preserved_unchanged: string[];\n };\n errors: string[];\n}\n\nfunction computeReturn(closes: number[], barsBack: number, label: string): EulerpoolReturnResult {\n const n = closes.length;\n const idxNow = n - 1;\n const idxThen = n - 1 - barsBack;\n if (idxThen < 0) {\n return { label, pct: null, bars_back: barsBack, available: false, note: `insufficient history: need ${barsBack + 1} daily bars, got ${n}` };\n }\n const now = closes[idxNow];\n const then = closes[idxThen];\n if (typeof now !== \"number\" || typeof then !== \"number\" || !Number.isFinite(now) || !Number.isFinite(then) || then === 0) {\n return { label, pct: null, bars_back: barsBack, available: false, note: \"non-numeric or zero close in series\" };\n }\n return { label, pct: Math.round(((now - then) / then) * 100 * 100) / 100, bars_back: barsBack, available: true, note: \"ok\" };\n}\n\nexport async function runNvdaEulerpoolTest(): Promise {\n const ticker = \"NVDA\";\n const key = getKey();\n const report: EulerpoolTestReport = {\n ticker, provider: \"eulerpool\", provider_configured: !!key,\n auth: null, api_calls: [], bars_returned: 0,\n earliest_bar_date: null, latest_bar_date: null, latest_price: null,\n returns: [], momentum_dimension_score: null,\n dimensions_reliably_supplied: [], dimensions_not_supplied: [],\n merge_safe_write: { attempted: false, row_existed_before: false, before: null, after: null, columns_written: [], columns_preserved_unchanged: [] },\n errors: [],\n };\n if (!key) {\n report.errors.push(\"EULERPOOL_API_KEY is not configured with a non-empty value; no request made.\");\n return report;\n }\n\n // Single call: ~110 calendar days of daily OHLCV, comfortably covering\n // 50+ trading days plus buffer for weekends/holidays.\n const toTs = Math.floor(Date.now() / 1000);\n const fromTs = toTs - 110 * 24 * 3600;\n const endpointLabel = `GET /api/1/charting/ohlcv/${ticker} (resolution=D)`;\n const requestUrl = `${EULERPOOL_BASE}/api/1/charting/ohlcv/${ticker}?resolution=D&from=${fromTs}&to=${toTs}`;\n\n let json: any = null;\n try {\n const res = await fetch(requestUrl, {\n headers: { Authorization: `Bearer ${key}`, Accept: \"application/json\" },\n });\n const note = noteForStatus(res.status);\n report.api_calls.push({ endpoint: endpointLabel, status: res.status, ok: res.ok, note });\n report.auth = { header_used: \"Authorization: Bearer\", status: res.status, ok: res.ok, result: note };\n if (!res.ok) {\n report.errors.push(\n note === \"authentication_failed\"\n ? \"Authentication FAILED (401) — EULERPOOL_API_KEY was rejected via the Authorization: Bearer header. Stopped after 1 call; the ?token= query-param form was not tried in this run.\"\n : note === \"plan_restricted\"\n ? \"Authenticated, but the OHLCV endpoint returned 403 — not available on this Eulerpool plan/key tier. Stopped after 1 call.\"\n : `Unexpected status ${res.status} on the single OHLCV request. Stopped after 1 call.`,\n );\n return report;\n }\n try {\n json = await res.json();\n } catch {\n report.errors.push(\"HTTP 200 but response body was not valid JSON.\");\n return report;\n }\n } catch (err) {\n report.api_calls.push({ endpoint: endpointLabel, status: null, ok: false, note: \"network_error\" });\n report.auth = { header_used: \"Authorization: Bearer\", status: null, ok: false, result: \"network_error\" };\n report.errors.push(`${endpointLabel}: ${(err as Error).message}`);\n return report;\n }\n\n if (json && typeof json === \"object\" && \"s\" in json && json.s !== \"ok\") {\n report.errors.push(`Response body reported status \"${json.s}\" (not \"ok\") — treated as no usable data, not zero.`);\n return report;\n }\n\n let t: number[] = Array.isArray(json?.t) ? json.t.filter((x: unknown) => typeof x === \"number\") : [];\n let c: number[] = Array.isArray(json?.c) ? json.c.filter((x: unknown) => typeof x === \"number\") : [];\n if (t.length === 0 || c.length === 0 || t.length !== c.length) {\n report.errors.push(`Response did not contain a usable, equal-length t[]/c[] series (t.length=${t.length}, c.length=${c.length}).`);\n return report;\n }\n\n // Normalize to ascending-by-time; do not assume the API's native order.\n if (t[0] > t[t.length - 1]) {\n t = [...t].reverse();\n c = [...c].reverse();\n }\n\n report.bars_returned = c.length;\n report.earliest_bar_date = new Date(t[0] * 1000).toISOString().slice(0, 10);\n report.latest_bar_date = new Date(t[t.length - 1] * 1000).toISOString().slice(0, 10);\n report.latest_price = c[c.length - 1];\n\n const r1d = computeReturn(c, 1, \"1D\");\n const r5d = computeReturn(c, 5, \"5D\");\n const r20d = computeReturn(c, 20, \"20D\");\n const r50d = computeReturn(c, 50, \"50D\");\n report.returns = [r1d, r5d, r20d, r50d];\n\n for (const r of report.returns) {\n if (r.available) report.dimensions_reliably_supplied.push(`${r.label} return`);\n else report.dimensions_not_supplied.push(`${r.label} return (${r.note})`);\n }\n report.dimensions_reliably_supplied.unshift(\"Latest available price\");\n\n // ---- Merge-safe persistence (price/momentum columns only) ----\n await ensureMarketDataSchema();\n const existingRes = await sqlite.execute({ sql: `SELECT * FROM market_data WHERE ticker = ?`, args: [ticker] });\n const before = (existingRes.rows[0] as Record | undefined) ?? null;\n report.merge_safe_write.attempted = true;\n report.merge_safe_write.row_existed_before = !!before;\n report.merge_safe_write.before = before;\n\n const sourceNote = before\n ? \"eulerpool (price/momentum only — merged); prior fundamentals/valuation source preserved\"\n : \"eulerpool (price/momentum only)\";\n const fetchedAt = new Date().toISOString();\n // Schema mapping note: price_change_1w and price_change_1m are the\n // closest existing columns to \"5D\" and \"20D\" — 50D has no column and is\n // NOT persisted (reported above as informational only).\n const priceChange1d = r1d.available ? r1d.pct : null;\n const priceChange5dInto1wCol = r5d.available ? r5d.pct : null;\n const priceChange20dInto1mCol = r20d.available ? r20d.pct : null;\n\n if (before) {\n await sqlite.execute({\n sql: `UPDATE market_data SET price = ?, price_change_1d = ?, price_change_1w = ?, price_change_1m = ?, source = ?, fetched_at = ? WHERE ticker = ?`,\n args: [report.latest_price, priceChange1d, priceChange5dInto1wCol, priceChange20dInto1mCol, sourceNote, fetchedAt, ticker],\n });\n report.merge_safe_write.columns_preserved_unchanged = [\n \"pe_ratio\", \"pb_ratio\", \"market_cap\", \"ev\", \"revenue_growth\", \"gross_margin\", \"roe\", \"debt_to_equity\", \"avg_volume\", \"flow\",\n ];\n } else {\n await sqlite.execute({\n sql: `INSERT INTO market_data (ticker, price, price_change_1d, price_change_1w, price_change_1m, source, fetched_at) VALUES (?,?,?,?,?,?,?)`,\n args: [ticker, report.latest_price, priceChange1d, priceChange5dInto1wCol, priceChange20dInto1mCol, sourceNote, fetchedAt],\n });\n report.merge_safe_write.columns_preserved_unchanged = []; // no prior row to preserve\n }\n report.merge_safe_write.columns_written = [\"price\", \"price_change_1d\", \"price_change_1w (holds 5D%)\", \"price_change_1m (holds 20D%)\", \"source\", \"fetched_at\"];\n\n const afterRes = await sqlite.execute({ sql: `SELECT * FROM market_data WHERE ticker = ?`, args: [ticker] });\n const after = (afterRes.rows[0] as Record | undefined) ?? null;\n report.merge_safe_write.after = after;\n\n // Reporting-only: run the EXISTING, unmodified scorer against the merged\n // row so we can say whether Eulerpool-sourced inputs plug cleanly into\n // Discovery V2's priceMomentum dimension. No write, no other ticker, no\n // discovery_candidates/discovery_runs table touched.\n const dims = scoreMarketDimensions(after as unknown as MarketData | null);\n report.momentum_dimension_score = Number.isNaN(dims.priceMomentum) ? null : dims.priceMomentum;\n\n report.dimensions_not_supplied.push(\n \"Market Capitalization, Valuation metrics, other fundamentals — not requested/tested in this run (Alpha Vantage remains the source for those; not touched here)\",\n );\n\n return report;\n}\n\n// ---------------------------------------------------------------------------\n// FOLLOW-UP, READ-ONLY diagnostic: exactly ONE more OHLCV request for NVDA,\n// requesting a much deeper lookback window (400 calendar days instead of\n// 110) to determine whether the 8-bar result from runNvdaEulerpoolTest()\n// was a hard depth cap on this key/plan, or an artifact of the smaller\n// window. Makes NO database writes of any kind (no market_data read, no\n// market_data write, no other table touched) — purely diagnostic. Never\n// calls computeDiscovery, never touches any ticker other than NVDA, never\n// touches cron/collector/Anthropic/FMP/AnySearch/X.\n// ---------------------------------------------------------------------------\nexport interface EulerpoolDepthDiagnosticReport {\n ticker: \"NVDA\";\n provider: \"eulerpool\";\n provider_configured: boolean;\n requested_from_date: string | null;\n requested_to_date: string | null;\n requested_days_back: number;\n api_calls: { endpoint: string; status: number | null; ok: boolean; note: string }[];\n bars_returned: number;\n earliest_bar_date: string | null;\n latest_bar_date: string | null;\n actual_trading_days_span: number | null;\n comparison_to_prior_run: { prior_bars_returned: number; prior_days_requested: number };\n conclusion: string;\n errors: string[];\n}\n\nexport async function runNvdaEulerpoolDepthDiagnostic(): Promise {\n const ticker = \"NVDA\";\n const key = getKey();\n const daysBack = 400;\n const report: EulerpoolDepthDiagnosticReport = {\n ticker, provider: \"eulerpool\", provider_configured: !!key,\n requested_from_date: null, requested_to_date: null, requested_days_back: daysBack,\n api_calls: [], bars_returned: 0, earliest_bar_date: null, latest_bar_date: null,\n actual_trading_days_span: null,\n comparison_to_prior_run: { prior_bars_returned: 8, prior_days_requested: 110 },\n conclusion: \"\",\n errors: [],\n };\n if (!key) {\n report.errors.push(\"EULERPOOL_API_KEY is not configured with a non-empty value; no request made.\");\n report.conclusion = \"Cannot diagnose — no API key configured.\";\n return report;\n }\n\n const toTs = Math.floor(Date.now() / 1000);\n const fromTs = toTs - daysBack * 24 * 3600;\n report.requested_from_date = new Date(fromTs * 1000).toISOString().slice(0, 10);\n report.requested_to_date = new Date(toTs * 1000).toISOString().slice(0, 10);\n const endpointLabel = `GET /api/1/charting/ohlcv/${ticker} (resolution=D, ${daysBack}d lookback)`;\n const requestUrl = `${EULERPOOL_BASE}/api/1/charting/ohlcv/${ticker}?resolution=D&from=${fromTs}&to=${toTs}`;\n\n let json: any = null;\n try {\n const res = await fetch(requestUrl, { headers: { Authorization: `Bearer ${key}`, Accept: \"application/json\" } });\n const note = noteForStatus(res.status);\n report.api_calls.push({ endpoint: endpointLabel, status: res.status, ok: res.ok, note });\n if (!res.ok) {\n report.errors.push(`Request failed: HTTP ${res.status} (${note}). Stopped after 1 call.`);\n report.conclusion = \"Inconclusive — the diagnostic request itself failed; unable to determine depth-cap vs. parameter issue.\";\n return report;\n }\n try {\n json = await res.json();\n } catch {\n report.errors.push(\"HTTP 200 but response body was not valid JSON.\");\n report.conclusion = \"Inconclusive — response body unparseable.\";\n return report;\n }\n } catch (err) {\n report.api_calls.push({ endpoint: endpointLabel, status: null, ok: false, note: \"network_error\" });\n report.errors.push(`${endpointLabel}: ${(err as Error).message}`);\n report.conclusion = \"Inconclusive — network error on the diagnostic request.\";\n return report;\n }\n\n if (json && typeof json === \"object\" && \"s\" in json && json.s !== \"ok\") {\n report.errors.push(`Response body reported status \"${json.s}\" (not \"ok\").`);\n report.conclusion = `Inconclusive — API returned a non-\"ok\" status (\"${json.s}\") rather than data.`;\n return report;\n }\n\n let t: number[] = Array.isArray(json?.t) ? json.t.filter((x: unknown) => typeof x === \"number\") : [];\n if (t.length === 0) {\n report.errors.push(\"Response contained no usable t[] timestamp series.\");\n report.conclusion = \"Inconclusive — no bars returned at all for the deeper window (unexpected given the prior run returned 8).\";\n return report;\n }\n if (t[0] > t[t.length - 1]) t = [...t].reverse();\n\n report.bars_returned = t.length;\n report.earliest_bar_date = new Date(t[0] * 1000).toISOString().slice(0, 10);\n report.latest_bar_date = new Date(t[t.length - 1] * 1000).toISOString().slice(0, 10);\n report.actual_trading_days_span = Math.round((t[t.length - 1] - t[0]) / 86400);\n\n if (report.bars_returned > report.comparison_to_prior_run.prior_bars_returned + 3) {\n report.conclusion =\n `RESOLVED: from/to IS respected — requesting ${daysBack}d back returned ${report.bars_returned} bars ` +\n `(vs. 8 bars for a 110d request), spanning ${report.earliest_bar_date} to ${report.latest_bar_date}. ` +\n `The original 8-bar result was NOT a hard cap; it was specific to how that smaller window was computed. ` +\n (report.bars_returned >= 51\n ? \"This deeper window comfortably covers 50+ trading days — 20D and 50D returns ARE computable from a properly sized request.\"\n : `This deeper window still covers only ${report.bars_returned} bars, which is ${report.bars_returned >= 21 ? \"enough for 20D but not yet 50D\" : \"not yet enough for either 20D or 50D\"} — a still-larger lookback window would likely be needed.`);\n } else {\n report.conclusion =\n `RESOLVED: this is a HARD DEPTH CAP, not a parameter issue — requesting ${daysBack}d back (vs. 110d previously) still returned only ` +\n `${report.bars_returned} bars (spanning ${report.earliest_bar_date} to ${report.latest_bar_date}), effectively unchanged from the prior 8-bar result. ` +\n `The from/to range is not the limiting factor; this Eulerpool key/plan appears to cap OHLCV daily history depth at ~${report.bars_returned} bars regardless of the requested window. ` +\n `20D and 50D returns are NOT reliably obtainable from this endpoint under the current key/plan.`;\n }\n\n return report;\n}\n\n\n// ---------------------------------------------------------------------------\n// PRODUCTION: multi-ticker Latest Price / 1D / 5D refresher, generalized\n// from the validated NVDA-only test above. PRICE/SHORT-TERM MOMENTUM ONLY.\n// Confirmed by runNvdaEulerpoolDepthDiagnostic() that this key/plan caps\n// daily OHLCV history at ~8-9 bars regardless of the requested window, so\n// this function deliberately requests only a short (20 calendar day) lookback\n// — enough for 1D/5D, and does NOT attempt 20D/50D (no column exists for\n// 20D anyway beyond the existing price_change_1m re-purposing, and 50D has\n// no column at all — both are intentionally left NULL per the approved\n// production architecture). Does NOT parse or store the response's volume\n// (v[]) array — avg_volume/flow stay NULL, keeping the Capital Flow\n// dimension NULL as instructed, not silently populated as a side effect.\n// Genuinely merge-safe: reads the existing row first and UPDATEs ONLY\n// price/price_change_1d/price_change_1w, so Alpha Vantage's fundamentals/\n// valuation fields on that row are never touched by this function.\n// ---------------------------------------------------------------------------\nconst sleep = (ms: number): Promise => new Promise((resolve) => setTimeout(resolve, ms));\nconst EULERPOOL_HARD_CALL_CAP = 40;\n\nasync function mergeSafeWritePriceMomentum(\n ticker: string,\n row: { price: number | null; price_change_1d: number | null; price_change_1w: number | null },\n): Promise {\n await ensureMarketDataSchema();\n const existingRes = await sqlite.execute({ sql: `SELECT * FROM market_data WHERE ticker = ?`, args: [ticker] });\n const before = existingRes.rows[0] as Record | undefined;\n const fetchedAt = new Date().toISOString();\n const hasAlphaVantage = !!(before && typeof before.source === \"string\" && (before.source as string).toLowerCase().includes(\"alphavantage\"));\n const source = hasAlphaVantage\n ? \"eulerpool (price/momentum); alphavantage (fundamentals/valuation)\"\n : \"eulerpool (price/momentum)\";\n\n if (before) {\n await sqlite.execute({\n sql: `UPDATE market_data SET price = ?, price_change_1d = ?, price_change_1w = ?, source = ?, fetched_at = ? WHERE ticker = ?`,\n args: [row.price, row.price_change_1d, row.price_change_1w, source, fetchedAt, ticker],\n });\n } else {\n await sqlite.execute({\n sql: `INSERT INTO market_data (ticker, price, price_change_1d, price_change_1w, source, fetched_at) VALUES (?,?,?,?,?,?)`,\n args: [ticker, row.price, row.price_change_1d, row.price_change_1w, source, fetchedAt],\n });\n }\n}\n\nexport interface EulerpoolRefreshResult {\n succeeded: string[];\n failed: { ticker: string; reason: string }[];\n callsUsed: number;\n errors: string[];\n}\n\nexport async function refreshEulerpoolPriceMomentum(tickers: string[]): Promise {\n const key = getKey();\n const result: EulerpoolRefreshResult = { succeeded: [], failed: [], callsUsed: 0, errors: [] };\n if (!key) {\n result.errors.push(\"EULERPOOL_API_KEY is not configured with a non-empty value; no requests made.\");\n return result;\n }\n\n const bounded = [...new Set(tickers.map((t) => t.toUpperCase()))].slice(0, EULERPOOL_HARD_CALL_CAP);\n const toTs = Math.floor(Date.now() / 1000);\n const fromTs = toTs - 20 * 24 * 3600; // short window — only 1D/5D are needed; 20D/50D intentionally not attempted (see file header)\n\n for (const ticker of bounded) {\n if (result.callsUsed >= EULERPOOL_HARD_CALL_CAP) break;\n if (result.callsUsed > 0) await sleep(150); // light pacing; be a good citizen even though docs claim sub-10ms CDN responses\n\n try {\n const res = await fetch(`${EULERPOOL_BASE}/api/1/charting/ohlcv/${ticker}?resolution=D&from=${fromTs}&to=${toTs}`, {\n headers: { Authorization: `Bearer ${key}`, Accept: \"application/json\" },\n });\n result.callsUsed++;\n if (!res.ok) {\n result.failed.push({ ticker, reason: `http_${res.status}` });\n continue;\n }\n let json: any;\n try {\n json = await res.json();\n } catch {\n result.failed.push({ ticker, reason: \"invalid_json\" });\n continue;\n }\n if (json && typeof json === \"object\" && \"s\" in json && json.s !== \"ok\") {\n result.failed.push({ ticker, reason: `status_${json.s}` });\n continue;\n }\n let t: number[] = Array.isArray(json?.t) ? json.t.filter((x: unknown) => typeof x === \"number\") : [];\n let c: number[] = Array.isArray(json?.c) ? json.c.filter((x: unknown) => typeof x === \"number\") : [];\n if (t.length === 0 || c.length === 0 || t.length !== c.length) {\n result.failed.push({ ticker, reason: \"no_usable_series\" });\n continue;\n }\n if (t[0] > t[t.length - 1]) c = [...c].reverse();\n\n const n = c.length;\n const latest = c[n - 1];\n const r1d = n >= 2 && c[n - 2] !== 0 ? Math.round(((c[n - 1] - c[n - 2]) / c[n - 2]) * 10000) / 100 : null;\n const r5d = n >= 6 && c[n - 6] !== 0 ? Math.round(((c[n - 1] - c[n - 6]) / c[n - 6]) * 10000) / 100 : null;\n\n await mergeSafeWritePriceMomentum(ticker, { price: latest, price_change_1d: r1d, price_change_1w: r5d });\n result.succeeded.push(ticker);\n } catch (err) {\n result.errors.push(`${ticker}: ${(err as Error).message}`);\n }\n }\n\n return result;\n}\n","deleted",false,"label",[47,24],"lib","5c601043-49d8-4da3-8595-d21725bb7d55",["D",1788705462303],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","X account collector: normalized posts into SQLite","imageUrl","userId","8f36435b-4ee1-42d7-a52e-11508b5c71b0","pinnedFileId","b9b4c5ce-aa00-11f1-b6d1-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a07719-4bcc-778e-997b-14b67712b6b9","tursoName","5c60104349d84da38595d21725bb7d55","tursoHostname","5c60104349d84da38595d21725bb7d55-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789485645684],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_109":105},"org",{"_9":10,"_102":103,"_104":105,"_58":59,"_106":107,"_108":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",146,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Efren Lin","avatar","https://lh3.googleusercontent.com/a/ACg8ocITAXmIR316-M-ReEEDUIUESLjIDNnYnCPqoEpOrKLJExkkkWU=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_143":144,"_145":146,"_147":148,"_149":44,"_150":44,"_151":44,"_152":34,"_153":-5,"_154":-7,"_155":-7,"_156":66,"_157":44,"_158":44,"_159":-5,"_160":44,"_161":44,"_162":44,"_163":-5},"ENV",{"_114":115,"_116":117,"_118":93,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140,"_141":142},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]