[{"_1":2,"_178":-5,"_179":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","6050acf0705e6826bb1b68e27572c5b8979c5bd9","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_155":156,"_175":176,"_177":-5},"handle","vvampa","name","dns","path","index.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":121,"_122":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_141":142,"_154":20},"id","0fef6ee0-060e-11f1-b9bd-42dde27851f2","createdAt",["D",1770679289177],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","4014c640-61ba-11f0-852d-15ceec715ebe","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","4014c641-61ba-11f0-852d-15ceec715ebe","tursoName","0fef6ee0060e11f1b9bd42dde27851f2","tursoHostname","0fef6ee0060e11f1b9bd42dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ6dlV1b1h4VzRxbTBVblhueldOUjc4R3N1ViJ9","org",{"_95":96,"_138":135,"_12":113,"_139":140},"avatar","tier","free","branch",{"_143":144,"_97":45,"_103":145,"_146":104,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},"version",67,"0ff07f1a-060e-11f1-b9bd-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":157,"_97":100,"_158":159,"_160":-5,"_161":145,"_162":163,"_164":165,"_105":166,"_143":167,"_168":169,"_170":171,"_172":20,"_173":-5,"_99":174},"107d4170-06cc-11f1-88fe-42dde27851f2","fileId","0ff5c3b2-060e-11f1-b9bd-42dde27851f2","parentId","branchId","branchVersion",65,"latest",true,["D",1770760894480],15,"fileType","http","content","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}","deleted","label",[100],"permalink","https://www.val.town/x/vvampa/dns/code/index.ts","extension","actionData","errors"]