portfolio dns

portfolio dns

\n \n

\n\n

\n \n \n \n

\n\n \n

\n\n

progress

\n\n

results

click a summary to open attribution.

markdown list

\n \n

\n\n

news selection

\n\n

\n \n

\n\n \n\n`;\n}\n",[],[253,260],{"_104":269,"_97":270,"_160":271,"_162":254,"_163":145,"_164":272,"_166":167,"_106":273,"_101":274,"_170":275,"_172":276,"_173":22,"_174":-5,"_175":277,"_100":278},"e6e4d7bc-06c4-11f1-98c8-42dde27851f2","appJs.ts","d700961c-0613-11f1-871c-42dde27851f2",58,["D",1770757818211],8,"file","export function appJs(): string {\n // External JS served at /api/app.js.\n // Parser-safe: avoid backticks and backslash-escaped HTML.\n // Features: login/logout, load portfolios, prepare (fetch news), summarize selected, render markdown + attribution modal.\n return [\n \"(function(){\",\n \" function el(id){ return document.getElementById(id); }\",\n \" function setText(id, v){ var e = el(id); if (e) e.textContent = v || ''; }\",\n \" function setVal(id, v){ var e = el(id); if (e) e.value = v || ''; }\",\n \" function show(id, yes){ var e = el(id); if (e) e.style.display = yes ? 'block' : 'none'; }\",\n \" function showFlex(id, yes){ var e = el(id); if (e) e.style.display = yes ? 'flex' : 'none'; }\",\n \" function showInline(id, yes){ var e = el(id); if (e) e.style.display = yes ? 'inline-block' : 'none'; }\",\n \" function setStatus(s){ setText('status', s || ''); }\",\n \"\",\n \" var PALETTE = ['#ffd54f','#81c784','#64b5f6','#e57373','#ba68c8','#4db6ac','#ffb74d','#90a4ae'];\",\n \" function colorFor(i){ return PALETTE[i % PALETTE.length]; }\",\n \"\",\n \" var state = { token: localStorage.getItem('dns_token') || '', prepareRunId: '', summarizeRunId: '', lastEventTs: 0, lastPrepared: null };\",\n \"\",\n \" function renderAuth(){\",\n \" setText('authState', state.token ? 'logged in' : 'logged out');\",\n \" showFlex('loginRow', !state.token);\",\n \" show('controls', !!state.token);\",\n \" showInline('logoutBtn', !!state.token);\",\n \" }\",\n \" function renderRunIds(){\",\n \" var parts = [];\",\n \" if (state.prepareRunId) parts.push('prepare: ' + state.prepareRunId.slice(0,8));\",\n \" if (state.summarizeRunId) parts.push('summarize: ' + state.summarizeRunId.slice(0,8));\",\n \" setText('runIds', parts.join(' | '));\",\n \" }\",\n \"\",\n \" function api(path, opts){\",\n \" opts = opts || {};\",\n \" opts.headers = opts.headers || {};\",\n \" if (state.token) opts.headers['authorization'] = 'Bearer ' + state.token;\",\n \" return fetch(path, opts).then(function(res){\",\n \" return res.text().then(function(txt){\",\n \" var j = null;\",\n \" try { j = txt ? JSON.parse(txt) : null; } catch(e) { j = null; }\",\n \" if (!res.ok) { throw new Error((j && j.error) ? j.error : ('http ' + res.status)); }\",\n \" return j;\",\n \" });\",\n \" });\",\n \" }\",\n \"\",\n \" function appendEvents(events){\",\n \" if (!events || !events.length) return;\",\n \" var box = el('events'); if (!box) return;\",\n \" var lines = [];\",\n \" for (var i=0;i cur) frag.appendChild(document.createTextNode(text.slice(cur, start)));\",\n \" var mk = document.createElement('mark');\",\n \" mk.textContent = text.slice(start, end);\",\n \" mk.style.background = colorFor(s.colorIndex || 0);\",\n \" if (s.notes) mk.title = s.notes;\",\n \" var idx = countByGroup[s.groupId] || 0;\",\n \" countByGroup[s.groupId] = idx + 1;\",\n \" mk.id = s.groupId + ':' + side + ':' + idx;\",\n \" (function(groupId, thisSide){\",\n \" mk.addEventListener('click', function(){\",\n \" var other = (thisSide === 'source') ? 'summary' : 'source';\",\n \" var target = document.getElementById(groupId + ':' + other + ':0');\",\n \" if (target) target.scrollIntoView({ behavior: 'smooth', block: 'center' });\",\n \" });\",\n \" })(s.groupId, side);\",\n \" frag.appendChild(mk);\",\n \" cur = end;\",\n \" }\",\n \" if (cur < text.length) frag.appendChild(document.createTextNode(text.slice(cur)));\",\n \" container.appendChild(frag);\",\n \" }\",\n \"\",\n \" // modal close handlers\",\n \" (function(){\",\n \" var bg = el('modalBg'); var closeBtn = el('modalClose');\",\n \" if (closeBtn) closeBtn.addEventListener('click', function(){ if (bg) bg.style.display = 'none'; });\",\n \" if (bg) bg.addEventListener('click', function(e){ if (e.target === bg) bg.style.display = 'none'; });\",\n \" })();\",\n \"\",\n \" // wire buttons\",\n \" var loginBtn = el('loginBtn'); if (loginBtn) loginBtn.addEventListener('click', function(){ doLogin(); });\",\n \" var logoutBtn = el('logoutBtn'); if (logoutBtn) logoutBtn.addEventListener('click', function(){ doLogout(); });\",\n \" var fetchBtn = el('fetchNewsBtn'); if (fetchBtn) fetchBtn.addEventListener('click', function(){ startPrepare(); });\",\n \" var sumBtn = el('summarizeBtn'); if (sumBtn) sumBtn.addEventListener('click', function(){ startSummarize(); });\",\n \"\",\n \" renderAuth();\",\n \" renderRunIds();\",\n \" if (state.token) loadPortfolios();\",\n \"})();\",\n \"\"\n ].join(\"\\n\");\n}",[],[253,270],[253],{"_104":281,"_97":282,"_160":283,"_162":-5,"_163":145,"_164":284,"_166":167,"_106":285,"_101":286,"_170":287,"_172":288,"_173":22,"_174":-5,"_175":289,"_100":290},"107d4170-06cc-11f1-88fe-42dde27851f2","index.ts","0ff5c3b2-060e-11f1-b9bd-42dde27851f2",65,["D",1770760894480],15,"http","import { appHtml } from \"./web/appHtml.ts\";\nimport { appJs } from \"./web/appJs.ts\";\n\nimport {\n badRequest,\n corsPreflight,\n html,\n json,\n unauthorized,\n} from \"./lib/http.ts\";\nimport { handleLogin, requireAuth, requireWorker } from \"./lib/auth.ts\";\nimport {\n clearRunNews,\n createRun,\n ensureSchema,\n getLastSeenDay,\n getPreparedNews,\n getRun,\n getRunHoldings,\n getRunNewsMeta,\n getSeenUrlSet,\n getSelections,\n getSummaries,\n getSummaryRow,\n insertRunNews,\n listEvents,\n logEvent,\n setLastSeenDay,\n storeSelections,\n updateRun,\n upsertRunHolding,\n upsertSeen,\n upsertSummary,\n} from \"./lib/db.ts\";\nimport {\n findHoldingByTicker,\n holdingsForPortfolio,\n listPortfolios,\n loadHoldingsFromEnv,\n} from \"./lib/portfolio.ts\";\nimport { fetchFinvizNews, toDayKey } from \"./lib/news.ts\";\nimport { firecrawlScrape } from \"./lib/firecrawl.ts\";\nimport { alignTexts, type BundleItem, summarizeWithGuards } from \"./lib/llm.ts\";\nimport { clampInt, getEnv, upperTicker } from \"./lib/util.ts\";\n\nasync function handlePortfolios(req: Request): Promise {\n await requireAuth(req);\n const holdings = loadHoldingsFromEnv();\n return json({ portfolios: listPortfolios(holdings) });\n}\n\nasync function handleRunEvents(req: Request): Promise {\n await requireAuth(req);\n const url = new URL(req.url);\n const runId = url.searchParams.get(\"runId\") || \"\";\n const after = Number(url.searchParams.get(\"after\") || \"0\") || 0;\n if (!runId) return badRequest(\"missing runId\");\n return json({ events: await listEvents(runId, after) });\n}\n\n\nasync function handlePortfolioDiag(req: Request): Promise {\n await requireAuth(req);\n\n const raw = Deno.env.get(\"PORTFOLIOS_CSV\") || \"\";\n const newlineCount = (raw.match(/\\n/g) || []).length;\n const crlfCount = (raw.match(/\\r\\n/g) || []).length;\n const firstLine = (raw.split(/\\r?\\n/)[0] || \"\").slice(0, 200);\n\n const holdings = loadHoldingsFromEnv();\n const portfolios = listPortfolios(holdings);\n\n return json({\n env_present: !!Deno.env.get(\"PORTFOLIOS_CSV\"),\n csv_char_len: raw.length,\n newline_count: newlineCount,\n crlf_count: crlfCount,\n first_line_preview: firstLine,\n holdings_count: holdings.length,\n portfolios,\n });\n}\n\n\nfunction coerceBool(v: any): boolean {\n return v === true || v === 1 || v === \"1\" || v === \"true\" || v === \"TRUE\";\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((res) => setTimeout(res, ms));\n}\n\n// prepare\nasync function prepareStart(req: Request): Promise {\n await requireAuth(req);\n const body = await req.json().catch(() => ({} as any));\n\n const portfolio = typeof body?.portfolio === \"string\" ? body.portfolio : \"\";\n const ignoreSeen = coerceBool((body as any)?.ignoreSeen);\n const topK = clampInt(body?.topK, 1, 20, 5);\n\n if (!portfolio) return badRequest(\"missing portfolio\");\n\n const holdings = loadHoldingsFromEnv();\n const selected = holdingsForPortfolio(holdings, portfolio);\n if (!selected.length) return badRequest(\"unknown/empty portfolio\");\n\n const runId = await createRun(\n \"prepare\",\n { portfolio, ignoreSeen, topK },\n null,\n );\n await logEvent(runId, \"prepare\", null, \"prepare started\", {\n portfolio,\n ignoreSeen,\n topK,\n });\n\n for (const h of selected) {\n await upsertRunHolding(runId, portfolio, h.ticker, h.buy_below);\n }\n\n // early return: trigger /process without awaiting :contentReference[oaicite:4]{index=4}\n const origin = new URL(req.url).origin;\n fetch(`${origin}/api/prepare/process`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-worker-secret\": getEnv(\"WORKER_SECRET\"),\n },\n body: JSON.stringify({ runId }),\n });\n\n return json({ runId });\n}\n\nasync function prepareProcess(req: Request): Promise {\n requireWorker(req);\n const body = await req.json().catch(() => ({} as any));\n const runId = typeof body?.runId === \"string\" ? body.runId : \"\";\n if (!runId) return badRequest(\"missing runId\");\n\n const run = await getRun(runId);\n if (!run) return json({ error: \"run not found\" }, { status: 404 });\n\n try {\n const params = run.params_json ? JSON.parse(String(run.params_json)) : {};\n const ignoreSeen = coerceBool((params as any).ignoreSeen);\n const topK = clampInt(params.topK, 1, 20, 5);\n\n await clearRunNews(runId);\n\n const holdings = await getRunHoldings(runId);\n\n await logEvent(runId, \"prepare\", null, `params: ignoreSeen=${ignoreSeen} topK=${topK}`);\n\n await logEvent(\n runId,\n \"prepare\",\n null,\n `processing ${holdings.length} tickers`,\n );\n\n for (const h of holdings) {\n const ticker = h.ticker;\n await logEvent(runId, \"prepare\", ticker, \"fetch finviz news\");\n\n let rows = await fetchFinvizNews(ticker);\n await logEvent(runId, \"prepare\", ticker, `fetched ${rows.length} rows`);\n\n let cutoff: string | null = null;\n let seen = new Set();\n\n if (!ignoreSeen) {\n cutoff = await getLastSeenDay(ticker);\n seen = await getSeenUrlSet(ticker, 5000);\n\n if (cutoff) {\n rows = rows.filter((r) => {\n const d = toDayKey(r.Date);\n if (!d) return false;\n return d > cutoff!;\n });\n }\n\n rows = rows.filter((r) => {\n const u = String(r.Url || \"\").trim();\n if (!u) return false;\n if (seen.has(u)) return false;\n\n if (cutoff) {\n const d = toDayKey(r.Date);\n if (!d) return false;\n if (d <= cutoff) return false;\n }\n return true;\n });\n }\n\n if (!rows.length) {\n await logEvent(runId, \"prepare\", ticker, \"no new rows\");\n await sleep(1200);\n continue;\n }\n\n const limited = rows.slice(0, topK);\n for (let i = 0; i < limited.length; i++) {\n const r = limited[i];\n const row = {\n title: String(r.Title || \"\"),\n source: String(r.Source || \"\"),\n date: String(r.Date || \"\"),\n url: String(r.Url || \"\"),\n };\n await insertRunNews(runId, ticker, i + 1, row);\n\n // Only mutate \"seen\" state in normal mode.\n if (!ignoreSeen) {\n await upsertSeen(ticker, row);\n }\n }\n\n const newestDay = toDayKey(limited[0].Date);\n\n // Only advance last_seen watermark in normal mode.\n if (!ignoreSeen) {\n if (newestDay) {\n const prev = await getLastSeenDay(ticker);\n if (!prev || newestDay > prev) await setLastSeenDay(ticker, newestDay);\n }\n }\n\n await logEvent(\n runId,\n \"prepare\",\n ticker,\n `prepared ${limited.length} items`,\n { newestDay },\n );\n\n // Throttle Finviz requests to reduce rate limiting.\n await sleep(1200);\n }\n\n await updateRun(runId, { status: \"done\", error: null });\n await logEvent(runId, \"prepare\", null, \"prepare done\");\n return json({ ok: true });\n } catch (e: any) {\n await updateRun(runId, {\n status: \"error\",\n error: e?.message || \"prepare failed\",\n });\n await logEvent(runId, \"prepare\", null, \"prepare error\", {\n error: e?.message || String(e),\n });\n return json({ ok: false, error: e?.message || \"prepare failed\" }, {\n status: 500,\n });\n }\n}\n\nasync function prepareResult(req: Request): Promise {\n await requireAuth(req);\n const url = new URL(req.url);\n const runId = url.searchParams.get(\"runId\") || \"\";\n if (!runId) return badRequest(\"missing runId\");\n\n const run = await getRun(runId);\n if (!run) return json({ error: \"run not found\" }, { status: 404 });\n\n const holdings = await getRunHoldings(runId);\n const buyMap = new Map(holdings.map((h) => [h.ticker, h.buy_below]));\n\n const grouped = await getPreparedNews(runId);\n const tickers = Object.keys(grouped).sort((a, b) => a.localeCompare(b)).map((\n t,\n ) => ({\n ticker: t,\n buy_below: buyMap.get(t) || \"\",\n items: grouped[t],\n }));\n\n return json({\n run: {\n run_id: String(run.run_id),\n kind: String(run.kind),\n status: String(run.status),\n error: run.error ? String(run.error) : null,\n },\n prepared: { run_id: runId, tickers },\n });\n}\n\n// summarize selected\nasync function summarizeStart(req: Request): Promise {\n await requireAuth(req);\n const body = await req.json().catch(() => ({} as any));\n const prepareRunId = typeof body?.prepareRunId === \"string\"\n ? body.prepareRunId\n : \"\";\n const selections = body?.selections && typeof body.selections === \"object\"\n ? body.selections\n : null;\n if (!prepareRunId) return badRequest(\"missing prepareRunId\");\n if (!selections) return badRequest(\"missing selections\");\n\n const runId = await createRun(\"summarize\", { prepareRunId }, prepareRunId);\n await logEvent(runId, \"summarize\", null, \"summarize started\", {\n prepareRunId,\n });\n\n // normalize selections into {TICKER: [url]}\n const norm: Record = {};\n for (const [t, urls] of Object.entries(selections)) {\n const tick = upperTicker(t);\n if (!Array.isArray(urls)) continue;\n norm[tick] = urls.map((u: any) => String(u || \"\").trim()).filter(Boolean);\n }\n await storeSelections(runId, norm);\n\n const origin = new URL(req.url).origin;\n fetch(`${origin}/api/summarize/process`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-worker-secret\": getEnv(\"WORKER_SECRET\"),\n },\n body: JSON.stringify({ runId }),\n });\n\n return json({ runId });\n}\n\nasync function summarizeProcess(req: Request): Promise {\n requireWorker(req);\n const body = await req.json().catch(() => ({} as any));\n const runId = typeof body?.runId === \"string\" ? body.runId : \"\";\n if (!runId) return badRequest(\"missing runId\");\n\n const run = await getRun(runId);\n if (!run) return json({ error: \"run not found\" }, { status: 404 });\n\n try {\n const params = run.params_json ? JSON.parse(String(run.params_json)) : {};\n const prepareRunId = String(params.prepareRunId || \"\");\n if (!prepareRunId) throw new Error(\"missing prepareRunId in run params\");\n\n const sel = await getSelections(runId);\n if (!sel.size) {\n await updateRun(runId, { status: \"done\", error: null });\n await logEvent(runId, \"summarize\", null, \"no selections; done\");\n return json({ ok: true });\n }\n\n const buyMap = new Map(\n (await getRunHoldings(prepareRunId)).map((h) => [h.ticker, h.buy_below]),\n );\n await logEvent(runId, \"summarize\", null, `processing ${sel.size} tickers`);\n\n for (const [ticker, urls] of sel.entries()) {\n const buyBelow = buyMap.get(ticker) || \"\";\n if (!buyBelow) {\n await logEvent(\n runId,\n \"summarize\",\n ticker,\n \"missing buy_below (skipping)\",\n );\n continue;\n }\n\n await logEvent(runId, \"scrape\", ticker, `scraping ${urls.length} urls`);\n\n const scraped: BundleItem[] = [];\n for (let i = 0; i < urls.length; i++) {\n const u = urls[i];\n await logEvent(\n runId,\n \"scrape\",\n ticker,\n `firecrawl ${i + 1}/${urls.length}`,\n { url: u },\n );\n\n const { markdown } = await firecrawlScrape(u, { forceFresh: true });\n if ((markdown || \"\").length <= 300) {\n await logEvent(\n runId,\n \"scrape\",\n ticker,\n \"article too short; dropped\",\n { url: u },\n );\n continue;\n }\n\n const meta = await getRunNewsMeta(prepareRunId, ticker, u);\n\n scraped.push({\n idx: scraped.length + 1,\n title: meta?.title || \"\",\n source: meta?.source || \"\",\n date: meta?.date || \"\",\n url: u,\n article_text: markdown,\n });\n }\n\n if (!scraped.length) {\n await logEvent(\n runId,\n \"summarize\",\n ticker,\n \"no usable articles after scraping\",\n );\n continue;\n }\n\n await logEvent(runId, \"summarize\", ticker, \"running summary + audit\");\n const res = await summarizeWithGuards({\n ticker,\n buy_below: buyBelow,\n items: scraped,\n });\n\n await upsertSummary(runId, {\n ticker,\n summary: res.summary,\n body_only: res.body_only,\n buy_below: buyBelow,\n urls_json: JSON.stringify(res.urls),\n sources_text: res.sources_text,\n local_validation_json: res.local_validation_json,\n audit_json: res.audit_json,\n });\n\n await logEvent(runId, \"summarize\", ticker, \"saved summary\", {\n attempts: res.attempts_used,\n urls: res.urls.length,\n });\n }\n\n await updateRun(runId, { status: \"done\", error: null });\n await logEvent(runId, \"summarize\", null, \"summarize done\");\n return json({ ok: true });\n } catch (e: any) {\n await updateRun(runId, {\n status: \"error\",\n error: e?.message || \"summarize failed\",\n });\n await logEvent(runId, \"summarize\", null, \"summarize error\", {\n error: e?.message || String(e),\n });\n return json({ ok: false, error: e?.message || \"summarize failed\" }, {\n status: 500,\n });\n }\n}\n\nasync function summarizeResult(req: Request): Promise {\n await requireAuth(req);\n const url = new URL(req.url);\n const runId = url.searchParams.get(\"runId\") || \"\";\n if (!runId) return badRequest(\"missing runId\");\n\n const run = await getRun(runId);\n if (!run) return json({ error: \"run not found\" }, { status: 404 });\n\n const items = (await getSummaries(runId)).map((x) => ({\n ticker: x.ticker,\n summary: x.summary,\n buy_below: x.buy_below,\n }));\n\n const markdown = items.length\n ? items.map((it) => {\n const lines = it.summary.split(\"\\n\");\n const first = `- ${lines[0] || \"\"}`.trimEnd();\n const rest = lines.slice(1).map((l) => ` ${l}`).join(\"\\n\");\n return rest ? `${first}\\n${rest}` : first;\n }).join(\"\\n\\n\")\n : \"no summaries were selected in this run.\";\n\n return json({\n run: {\n run_id: String(run.run_id),\n kind: String(run.kind),\n status: String(run.status),\n error: run.error ? String(run.error) : null,\n },\n summaries: { run_id: runId, items, markdown },\n });\n}\n\n// single ticker auto\nasync function tickerAutoStart(req: Request): Promise {\n await requireAuth(req);\n const body = await req.json().catch(() => ({} as any));\n\n const ticker = upperTicker(body?.ticker || \"\");\n const ignoreSeen = !!body?.ignoreSeen;\n const maxItems = clampInt(body?.maxItems, 1, 20, 6);\n if (!ticker) return badRequest(\"missing ticker\");\n\n const holdings = loadHoldingsFromEnv();\n const holding = findHoldingByTicker(holdings, ticker);\n if (!holding) {\n return badRequest(\n `ticker ${ticker} not found in PORTFOLIOS_CSV (needed for buy_below)`,\n );\n }\n\n const runId = await createRun(\n \"ticker_auto\",\n { ticker, ignoreSeen, maxItems },\n null,\n );\n await logEvent(runId, \"ticker_auto\", ticker, \"ticker auto started\", {\n ignoreSeen,\n maxItems,\n });\n\n const origin = new URL(req.url).origin;\n fetch(`${origin}/api/ticker/auto/process`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-worker-secret\": getEnv(\"WORKER_SECRET\"),\n },\n body: JSON.stringify({ runId }),\n });\n\n return json({ runId });\n}\n\nasync function tickerAutoProcess(req: Request): Promise {\n requireWorker(req);\n const body = await req.json().catch(() => ({} as any));\n const runId = typeof body?.runId === \"string\" ? body.runId : \"\";\n if (!runId) return badRequest(\"missing runId\");\n\n const run = await getRun(runId);\n if (!run) return json({ error: \"run not found\" }, { status: 404 });\n\n try {\n const params = run.params_json ? JSON.parse(String(run.params_json)) : {};\n const ticker = upperTicker(params.ticker || \"\");\n const ignoreSeen = !!params.ignoreSeen;\n const maxItems = clampInt(params.maxItems, 1, 20, 6);\n if (!ticker) throw new Error(\"missing ticker in params\");\n\n const holdings = loadHoldingsFromEnv();\n const holding = findHoldingByTicker(holdings, ticker);\n if (!holding) {\n throw new Error(`ticker ${ticker} not found in PORTFOLIOS_CSV`);\n }\n\n await logEvent(runId, \"prepare\", ticker, \"fetch finviz news\");\n let rows = await fetchFinvizNews(ticker);\n\n if (!ignoreSeen) {\n const cutoff = await getLastSeenDay(ticker);\n const seen = await getSeenUrlSet(ticker, 5000);\n\n if (cutoff) {\n rows = rows.filter((r) => {\n const d = toDayKey(r.Date);\n if (!d) return false;\n return d > cutoff;\n });\n }\n\n rows = rows.filter((r) => {\n const u = String(r.Url || \"\").trim();\n if (!u) return false;\n if (seen.has(u)) return false;\n\n if (cutoff) {\n const d = toDayKey(r.Date);\n if (!d) return false;\n if (d <= cutoff) return false;\n }\n return true;\n });\n }\n\n if (!rows.length) {\n await updateRun(runId, { status: \"done\", error: null });\n await logEvent(runId, \"ticker_auto\", ticker, \"no items to summarize\");\n return json({ ok: true });\n }\n\n const picked = rows.slice(0, maxItems);\n\n // mark seen + update last_seen_day\n for (const r of picked) {\n await upsertSeen(ticker, {\n title: String(r.Title || \"\"),\n source: String(r.Source || \"\"),\n date: String(r.Date || \"\"),\n url: String(r.Url || \"\"),\n });\n }\n const newestDay = toDayKey(picked[0].Date);\n if (newestDay) {\n const prev = await getLastSeenDay(ticker);\n if (!prev || newestDay > prev) await setLastSeenDay(ticker, newestDay);\n }\n\n const scraped: BundleItem[] = [];\n for (let i = 0; i < picked.length; i++) {\n const r = picked[i];\n const u = String(r.Url || \"\").trim();\n if (!u) continue;\n\n await logEvent(\n runId,\n \"scrape\",\n ticker,\n `firecrawl ${i + 1}/${picked.length}`,\n { url: u },\n );\n const { markdown } = await firecrawlScrape(u, { forceFresh: true });\n if ((markdown || \"\").length <= 300) continue;\n\n scraped.push({\n idx: scraped.length + 1,\n title: String(r.Title || \"\"),\n source: String(r.Source || \"\"),\n date: String(r.Date || \"\"),\n url: u,\n article_text: markdown,\n });\n }\n\n if (!scraped.length) {\n await updateRun(runId, { status: \"done\", error: null });\n await logEvent(\n runId,\n \"ticker_auto\",\n ticker,\n \"no usable articles after scraping\",\n );\n return json({ ok: true });\n }\n\n await logEvent(runId, \"summarize\", ticker, \"running summary + audit\");\n const res = await summarizeWithGuards({\n ticker,\n buy_below: holding.buy_below,\n items: scraped,\n });\n\n await upsertSummary(runId, {\n ticker,\n summary: res.summary,\n body_only: res.body_only,\n buy_below: holding.buy_below,\n urls_json: JSON.stringify(res.urls),\n sources_text: res.sources_text,\n local_validation_json: res.local_validation_json,\n audit_json: res.audit_json,\n });\n\n await updateRun(runId, { status: \"done\", error: null });\n await logEvent(runId, \"ticker_auto\", ticker, \"ticker auto done\");\n return json({ ok: true });\n } catch (e: any) {\n await updateRun(runId, {\n status: \"error\",\n error: e?.message || \"ticker auto failed\",\n });\n await logEvent(runId, \"ticker_auto\", null, \"ticker auto error\", {\n error: e?.message || String(e),\n });\n return json({ ok: false, error: e?.message || \"ticker auto failed\" }, {\n status: 500,\n });\n }\n}\n\n// alignment endpoint (body-only)\nasync function summaryAlign(req: Request): Promise {\n await requireAuth(req);\n const body = await req.json().catch(() => ({} as any));\n const runId = typeof body?.runId === \"string\" ? body.runId : \"\";\n const ticker = upperTicker(body?.ticker || \"\");\n if (!runId || !ticker) return badRequest(\"missing runId or ticker\");\n\n const row = await getSummaryRow(runId, ticker);\n if (!row) return json({ error: \"summary not found\" }, { status: 404 });\n\n const summaryText = String(row.body_only || \"\");\n let sourceText = String(row.sources_text || \"\");\n\n const maxSourceChars = 60000;\n if (sourceText.length > maxSourceChars) {\n sourceText = sourceText.slice(0, maxSourceChars);\n }\n\n const alignments = await alignTexts({ sourceText, summaryText });\n return json({ sourceText, summaryText, alignments });\n}\n\n// router\nexport default async function (req: Request): Promise {\n await ensureSchema();\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (req.method === \"OPTIONS\" && path.startsWith(\"/api/\")) {\n return corsPreflight();\n }\n\n if (req.method === \"GET\" && path === \"/api/app.js\") {\n return new Response(appJs(), {\n headers: {\n \"content-type\": \"application/javascript; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n }\n\n\n try {\n if (req.method === \"GET\" && path === \"/api/portfolio-diag\") {\n return await handlePortfolioDiag(req);\n }\n\n\n if (req.method === \"GET\" && path === \"/\") return html(appHtml());\n\n if (req.method === \"POST\" && path === \"/api/login\") {\n return await handleLogin(req);\n }\n if (req.method === \"GET\" && path === \"/api/portfolios\") {\n return await handlePortfolios(req);\n }\n if (req.method === \"GET\" && path === \"/api/run/events\") {\n return await handleRunEvents(req);\n }\n\n if (req.method === \"POST\" && path === \"/api/prepare/start\") {\n return await prepareStart(req);\n }\n if (req.method === \"POST\" && path === \"/api/prepare/process\") {\n return await prepareProcess(req);\n }\n if (req.method === \"GET\" && path === \"/api/prepare/result\") {\n return await prepareResult(req);\n }\n\n if (req.method === \"POST\" && path === \"/api/summarize/start\") {\n return await summarizeStart(req);\n }\n if (req.method === \"POST\" && path === \"/api/summarize/process\") {\n return await summarizeProcess(req);\n }\n if (req.method === \"GET\" && path === \"/api/summarize/result\") {\n return await summarizeResult(req);\n }\n\n if (req.method === \"POST\" && path === \"/api/ticker/auto/start\") {\n return await tickerAutoStart(req);\n }\n if (req.method === \"POST\" && path === \"/api/ticker/auto/process\") {\n return await tickerAutoProcess(req);\n }\n\n if (req.method === \"POST\" && path === \"/api/summary/align\") {\n return await summaryAlign(req);\n }\n\n return new Response(\"not found\", {\n status: 404,\n headers: { \"cache-control\": \"no-store\" },\n });\n } catch (e: any) {\n const msg = e?.message || String(e);\n if (msg === \"unauthorized\" || msg === \"unauthorized_worker\") {\n return unauthorized();\n }\n return json({ error: msg }, { status: 500 });\n }\n}",[],[282],"files",[157,177,188,197,205,214,223,232,241,251,258,268,280],"counts",{"_295":33,"_296":169,"_297":33,"_298":299,"_302":303},"pulls","branches","forks","envVars",{"_300":264,"_301":33},"count","emptyCount","connections",{"_300":33,"_304":33},"unfilledCount","contents",[307,310,313],{"_104":158,"_97":159,"_160":161,"_162":-5,"_163":145,"_164":165,"_166":167,"_106":308,"_101":169,"_170":171,"_172":-5,"_173":22,"_174":-5,"_100":309},["D",1770680212697],[159],{"_104":252,"_97":253,"_160":254,"_162":-5,"_163":145,"_164":255,"_166":167,"_106":311,"_101":169,"_170":171,"_172":-5,"_173":22,"_174":-5,"_100":312},["D",1770680261243],[253],{"_104":281,"_97":282,"_160":283,"_162":-5,"_163":145,"_164":284,"_166":167,"_106":314,"_101":286,"_170":287,"_172":288,"_173":22,"_174":-5,"_100":315},["D",1770760894480],[282],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_95":96,"_97":98,"_102":324,"_298":329,"_368":22},{"_104":105,"_97":98,"_106":325,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":-5,"_119":33,"_16":120,"_121":122,"_123":124,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":326,"_137":327,"_142":328,"_154":22},["D",1770679289177],{"_95":96,"_135":136},{"_95":96,"_139":136,"_14":114,"_140":141},{"_101":144,"_97":45,"_104":145,"_146":105,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},[330,336,340,344,348,352,356,360,364],{"_331":332,"_106":333,"_334":-5,"_112":74,"_335":22},"key","TAVILY_API_KEY",["D",1770755971913],"updatedAt","isEmpty",{"_331":337,"_106":338,"_334":339,"_112":74,"_335":22},"NOUS_MODEL",["D",1770680740665],["D",1770753774700],{"_331":341,"_106":342,"_334":343,"_112":74,"_335":22},"NOUS_API_KEY",["D",1770680736469],["D",1770753782042],{"_331":345,"_106":346,"_334":347,"_112":74,"_335":22},"FIRECRAWL_API_KEY",["D",1770680680121],["D",1770753788227],{"_331":349,"_106":350,"_334":351,"_112":74,"_335":22},"FINVIZ_API_KEY",["D",1770680627914],["D",1770753794049],{"_331":353,"_106":354,"_334":355,"_112":74,"_335":22},"PORTFOLIOS_CSV",["D",1770680591372],["D",1770755353835],{"_331":357,"_106":358,"_334":359,"_112":74,"_335":22},"WORKER_SECRET",["D",1770680524237],["D",1770753805226],{"_331":361,"_106":362,"_334":363,"_112":74,"_335":22},"SITE_TOKEN_SECRET",["D",1770680510234],["D",1770753812695],{"_331":365,"_106":366,"_334":367,"_112":74,"_335":22},"SITE_PASSWORD",["D",1770680475938],["D",1770753818026],"isTeamOrg","actionData","errors"]

Key	Description
TAVILY_API_KEY
NOUS_MODEL
NOUS_API_KEY
FIRECRAWL_API_KEY
FINVIZ_API_KEY
PORTFOLIOS_CSV
WORKER_SECRET
SITE_TOKEN_SECRET
SITE_PASSWORD

vvampa

dns

Environment variables