[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_151":152,"_153":154},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_102":85,"_27":53,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":25,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","ecdb374a-7679-11f1-966e-1607ee4eb77e","name","fileType","interval","content","// BiB Earnings Calendar Fetcher\n// Trigger type: CRON — set schedule to 05:45 UTC daily (or Mon–Fri)\n//\n// Fetches the Alpha Vantage earnings calendar (free key, 25 req/day — this\n// uses 1/day) and stores the next 14 days of US-listed earnings in SQLite\n// for earningsServer to serve.\n//\n// Before saving this val, set env var (left sidebar):\n// ALPHAVANTAGE_API_KEY = \n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// Minimal CSV line parser that respects double quotes (company names can\n// contain commas, e.g. \"Smucker (J.M.) Company\").\nfunction splitCsvLine(line: string): string[] {\n const out: string[] = [];\n let cur = \"\";\n let inQuotes = false;\n for (let i = 0; i < line.length; i++) {\n const ch = line[i];\n if (ch === '\"') {\n if (inQuotes && line[i + 1] === '\"') {\n cur += '\"';\n i++;\n } else {\n inQuotes = !inQuotes;\n }\n } else if (ch === \",\" && !inQuotes) {\n out.push(cur);\n cur = \"\";\n } else {\n cur += ch;\n }\n }\n out.push(cur);\n return out.map((s) => s.trim());\n}\n\nexport default async function () {\n const key = Deno.env.get(\"ALPHAVANTAGE_API_KEY\") ?? \"\";\n if (!key) throw new Error(\"ALPHAVANTAGE_API_KEY env var not set\");\n\n const url =\n `https://www.alphavantage.co/query?function=EARNINGS_CALENDAR&horizon=3month&apikey=${key}`;\n const resp = await fetch(url);\n if (!resp.ok) throw new Error(`Alpha Vantage HTTP ${resp.status}`);\n const csv = await resp.text();\n\n // AV returns JSON (not CSV) for error/rate-limit messages — detect that.\n if (!csv.toLowerCase().includes(\"symbol\") || csv.trim().startsWith(\"{\")) {\n throw new Error(`Alpha Vantage unexpected payload: ${csv.slice(0, 200)}`);\n }\n\n // v2 guard (2026-07-08): AV can also send its \"Information\"/\"Note\" notice\n // AFTER a valid-looking CSV header, which slipped past the check above and\n // silently stored zero rows. Treat a tiny payload containing a notice as an\n // error, and always log the raw start of the payload for diagnosis.\n const lineCount =\n csv.split(/\\r?\\n/).filter((l) => l.trim().length > 0).length;\n if (lineCount < 5 && /information|note|premium|thank you/i.test(csv)) {\n console.log(\"RAW PAYLOAD (first 400 chars):\", csv.slice(0, 400));\n throw new Error(\n `Alpha Vantage returned a notice instead of data: ${csv.slice(0, 300)}`,\n );\n }\n\n const lines = csv.split(/\\r?\\n/).filter((l) => l.trim().length > 0);\n const header = splitCsvLine(lines[0]).map((h) => h.toLowerCase());\n const iSym = header.indexOf(\"symbol\");\n const iName = header.indexOf(\"name\");\n const iDate = header.indexOf(\"reportdate\");\n const iEst = header.indexOf(\"estimate\");\n const iCur = header.indexOf(\"currency\");\n if (iSym < 0 || iDate < 0) {\n throw new Error(`Alpha Vantage header changed: ${lines[0]}`);\n }\n\n const todayISO = new Date().toISOString().slice(0, 10);\n const horizonISO = new Date(Date.now() + 14 * 86400_000).toISOString().slice(\n 0,\n 10,\n );\n\n const inserts: { sql: string; args: (string | null)[] }[] = [];\n for (let i = 1; i < lines.length; i++) {\n const cols = splitCsvLine(lines[i]);\n const reportDate = cols[iDate] ?? \"\";\n if (reportDate < todayISO || reportDate > horizonISO) continue;\n inserts.push({\n sql:\n `INSERT INTO bib_earnings (report_date, symbol, name, estimate, currency) VALUES (?, ?, ?, ?, ?)`,\n args: [\n reportDate,\n cols[iSym] ?? \"\",\n (iName >= 0 ? cols[iName] : \"\") ?? \"\",\n (iEst >= 0 ? cols[iEst] : null) || null,\n (iCur >= 0 ? cols[iCur] : \"USD\") || \"USD\",\n ],\n });\n }\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS bib_earnings (\n report_date TEXT NOT NULL,\n symbol TEXT NOT NULL,\n name TEXT,\n estimate TEXT,\n currency TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS bib_earnings_meta (\n k TEXT PRIMARY KEY,\n v TEXT\n )\n `);\n\n // Replace wholesale each run — the feed is a snapshot, not an archive.\n await sqlite.execute(`DELETE FROM bib_earnings`);\n // Batch in chunks to stay under statement limits.\n for (let i = 0; i < inserts.length; i += 50) {\n await sqlite.batch(inserts.slice(i, i + 50));\n }\n await sqlite.execute({\n sql: `INSERT INTO bib_earnings_meta (k, v) VALUES ('fetched_at', ?)\n ON CONFLICT(k) DO UPDATE SET v = excluded.v`,\n args: [new Date().toISOString()],\n });\n\n console.log(\n `Stored ${inserts.length} earnings rows (${todayISO} → ${horizonISO})`,\n );\n\n // Diagnostics — zero stored rows is almost never right on a weekday.\n if (inserts.length === 0) {\n console.log(`DIAG: CSV had ${lines.length} non-empty lines (incl. header)`);\n console.log(`DIAG: header = ${lines[0]}`);\n console.log(`DIAG: line 1 = ${lines[1] ?? \"(none)\"}`);\n console.log(`DIAG: line 2 = ${lines[2] ?? \"(none)\"}`);\n // Show the date range actually present in the payload\n const dates = new Set();\n for (let i = 1; i < lines.length; i++) {\n const d = splitCsvLine(lines[i])[iDate];\n if (d) dates.add(d);\n }\n const sorted = [...dates].sort();\n console.log(\n `DIAG: payload contains ${dates.size} distinct reportDates, ` +\n `earliest ${sorted[0] ?? \"n/a\"}, latest ${\n sorted[sorted.length - 1] ?? \"n/a\"\n }`,\n );\n }\n\n return { stored: inserts.length, from: todayISO, to: horizonISO };\n}","// BiB Earnings Calendar Fetcher\n// Trigger type: CRON — set schedule to 05:45 UTC daily (or Mon–Fri)\n//\n// Fetches the Alpha Vantage earnings calendar (free key, 25 req/day — this\n// uses 1/day) and stores the next 14 days of US-listed earnings in SQLite\n// for earningsServer to serve.\n//\n// Before saving this val, set env var (left sidebar):\n// ALPHAVANTAGE_API_KEY = \n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// Minimal CSV line parser that respects double quotes (company names can\n// contain commas, e.g. \"Smucker (J.M.) Company\").\nfunction splitCsvLine(line: string): string[] {\n const out: string[] = [];\n let cur = \"\";\n let inQuotes = false;\n for (let i = 0; i < line.length; i++) {\n const ch = line[i];\n if (ch === '\"') {\n if (inQuotes && line[i + 1] === '\"') {\n cur += '\"';\n i++;\n } else {\n inQuotes = !inQuotes;\n }\n } else if (ch === \",\" && !inQuotes) {\n out.push(cur);\n cur = \"\";\n } else {\n cur += ch;\n }\n }\n out.push(cur);\n return out.map((s) => s.trim());\n}\n\nexport default async function () {\n const key = Deno.env.get(\"ALPHAVANTAGE_API_KEY\") ?? \"\";\n if (!key) throw new Error(\"ALPHAVANTAGE_API_KEY env var not set\");\n\n const url =\n `https://www.alphavantage.co/query?function=EARNINGS_CALENDAR&horizon=3month&apikey=${key}`;\n const resp = await fetch(url);\n if (!resp.ok) throw new Error(`Alpha Vantage HTTP ${resp.status}`);\n const csv = await resp.text();\n\n // AV returns JSON (not CSV) for error/rate-limit messages — detect that.\n if (!csv.toLowerCase().includes(\"symbol\") || csv.trim().startsWith(\"{\")) {\n throw new Error(`Alpha Vantage unexpected payload: ${csv.slice(0, 200)}`);\n }\n\n // v2 guard (2026-07-08): AV can also send its \"Information\"/\"Note\" notice\n // AFTER a valid-looking CSV header, which slipped past the check above and\n // silently stored zero rows. Treat a tiny payload containing a notice as an\n // error, and always log the raw start of the payload for diagnosis.\n const lineCount =\n csv.split(/\\r?\\n/).filter((l) => l.trim().length > 0).length;\n // AV mangles its notices into CSV: one character per column (\"I,n,f,o,r,m,a\").\n // Strip commas/quotes before testing, and always dump the raw payload when\n // the response is suspiciously small.\n const deCommaed = csv.replace(/[\",]/g, \"\");\n if (lineCount < 5) {\n console.log(\n \"RAW PAYLOAD (first 400 chars):\",\n JSON.stringify(csv.slice(0, 400)),\n );\n }\n if (\n lineCount < 5 &&\n /informa|note|premium|thank you|rate limit/i.test(deCommaed)\n ) {\n throw new Error(\n `Alpha Vantage returned a notice instead of data (de-mangled): ${\n deCommaed.slice(0, 300)\n }`,\n );\n }\n\n const lines = csv.split(/\\r?\\n/).filter((l) => l.trim().length > 0);\n const header = splitCsvLine(lines[0]).map((h) => h.toLowerCase());\n const iSym = header.indexOf(\"symbol\");\n const iName = header.indexOf(\"name\");\n const iDate = header.indexOf(\"reportdate\");\n const iEst = header.indexOf(\"estimate\");\n const iCur = header.indexOf(\"currency\");\n if (iSym < 0 || iDate < 0) {\n throw new Error(`Alpha Vantage header changed: ${lines[0]}`);\n }\n\n const todayISO = new Date().toISOString().slice(0, 10);\n const horizonISO = new Date(Date.now() + 14 * 86400_000).toISOString().slice(\n 0,\n 10,\n );\n\n const inserts: { sql: string; args: (string | null)[] }[] = [];\n for (let i = 1; i < lines.length; i++) {\n const cols = splitCsvLine(lines[i]);\n const reportDate = cols[iDate] ?? \"\";\n if (reportDate < todayISO || reportDate > horizonISO) continue;\n inserts.push({\n sql:\n `INSERT INTO bib_earnings (report_date, symbol, name, estimate, currency) VALUES (?, ?, ?, ?, ?)`,\n args: [\n reportDate,\n cols[iSym] ?? \"\",\n (iName >= 0 ? cols[iName] : \"\") ?? \"\",\n (iEst >= 0 ? cols[iEst] : null) || null,\n (iCur >= 0 ? cols[iCur] : \"USD\") || \"USD\",\n ],\n });\n }\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS bib_earnings (\n report_date TEXT NOT NULL,\n symbol TEXT NOT NULL,\n name TEXT,\n estimate TEXT,\n currency TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS bib_earnings_meta (\n k TEXT PRIMARY KEY,\n v TEXT\n )\n `);\n\n // Replace wholesale each run — the feed is a snapshot, not an archive.\n await sqlite.execute(`DELETE FROM bib_earnings`);\n // Batch in chunks to stay under statement limits.\n for (let i = 0; i < inserts.length; i += 50) {\n await sqlite.batch(inserts.slice(i, i + 50));\n }\n await sqlite.execute({\n sql: `INSERT INTO bib_earnings_meta (k, v) VALUES ('fetched_at', ?)\n ON CONFLICT(k) DO UPDATE SET v = excluded.v`,\n args: [new Date().toISOString()],\n });\n\n console.log(\n `Stored ${inserts.length} earnings rows (${todayISO} → ${horizonISO})`,\n );\n\n // Diagnostics — zero stored rows is almost never right on a weekday.\n if (inserts.length === 0) {\n console.log(`DIAG: CSV had ${lines.length} non-empty lines (incl. header)`);\n console.log(`DIAG: header = ${lines[0]}`);\n console.log(`DIAG: line 1 = ${lines[1] ?? \"(none)\"}`);\n console.log(`DIAG: line 2 = ${lines[2] ?? \"(none)\"}`);\n // Show the date range actually present in the payload\n const dates = new Set();\n for (let i = 1; i < lines.length; i++) {\n const d = splitCsvLine(lines[i])[iDate];\n if (d) dates.add(d);\n }\n const sorted = [...dates].sort();\n console.log(\n `DIAG: payload contains ${dates.size} distinct reportDates, ` +\n `earliest ${sorted[0] ?? \"n/a\"}, latest ${\n sorted[sorted.length - 1] ?? \"n/a\"\n }`,\n );\n }\n\n return { stored: inserts.length, from: todayISO, to: horizonISO };\n}","createdAt",["D",1783493432963],"branchVersion","branchId","055f928d-2135-4ba7-bc7d-61fb2f4d0c9a","id","c6b6cbf5-fd40-445d-96e7-9173ff61bf5c","earnings-cron",["D",1783040146190],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","4f3e5766-db71-43ab-8d6b-8959207c9f91","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ec05c-5d19-7488-b0d3-0c6697faad30","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_101":53},"org",{"_95":94,"_96":53,"_97":53,"_18":55,"_98":99,"_100":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","bibtool","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":147,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":148,"_79":149,"_81":150,"_83":25},"tree",[142],"files",[142],"counts",{"_131":61,"_132":133,"_134":61,"_135":136,"_137":138},"contents",[123],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":124,"_32":28,"_30":31,"_125":-5,"_41":42,"_40":14,"_126":25,"_38":127,"_13":128,"_33":34,"_35":37,"_24":25,"_129":-5,"_27":130},"597da899-3eef-4d2d-9105-0166aabbec8d","parentId","latest",["D",1783493432963],7,"label",[28],"pulls","branches",1,"forks","envVars",{"_139":133,"_141":61},"connections",{"_139":61,"_140":61},"count","unfilledCount","emptyCount",{"_43":124,"_32":28,"_30":31,"_125":-5,"_41":42,"_40":14,"_126":25,"_38":143,"_13":128,"_33":34,"_35":37,"_24":25,"_129":-5,"_144":145,"_27":146},["D",1783493432963],"children",[],[28],["D",1783040146190],{"_95":94,"_101":53},{"_95":94,"_96":53,"_97":53,"_18":55,"_98":99,"_100":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_120":184,"_185":186,"_187":188,"_189":25,"_190":25,"_191":25,"_192":193,"_194":-5,"_195":-7,"_196":-7,"_197":61,"_198":25,"_199":25,"_200":-5,"_201":25,"_202":25,"_203":25,"_204":-5},"ENV",{"_155":156,"_157":158,"_159":85,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8