[{"_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","xdv","name","subscriptions","path","backend/email/handle.ts","project",{"_22":49,"_11":12,"_35":50,"_51":-5,"_52":44,"_53":54,"_55":54,"_56":57,"_58":-5,"_59":60,"_61":62,"_63":34,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":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/xdv/subscriptions/code/backend/email/handle.ts","extension","id","51b4391b-2fba-406b-91cf-36ef58bd809b","handle.ts","fileId","58336e96-a63a-11f1-b329-1607ee4eb77e","parentId","d1f39aa4-a639-11f1-b6a1-1607ee4eb77e","branchId","723ee93a-6b67-428c-b3cc-6f9491011d78","branchVersion",84,"latest",true,"createdAt",["D",1788302798411],"version",3,"fileType","script","content","/**\n * What happens when mail arrives.\n *\n * Routing, in order — the cheap deterministic checks come first so the common\n * paths never depend on the model:\n *\n * 1. Seen this message id before? → do nothing (mail servers retry)\n * 2. First line parses as a command? → run it, reply\n * 3. Quoted section looks like a receipt? → extract, record, ask to confirm\n * 4. Anything the sender wrote themselves? → answer it from their data\n *\n * Steps 3 and 4 can both fire: forwarding a receipt with \"is this worth it?\" on\n * top records the charge *and* answers the question. Every automatic write leaves\n * a confirm item behind, so nothing enters the database unreviewed.\n */\nimport type { BillingCycle, Currency, SubscriptionView } from \"../../shared/types.ts\";\nimport { isLive } from \"../../shared/types.ts\";\nimport {\n advanceByCycle,\n currentPeriod,\n formatMoney,\n monthlyEquivalentMinor,\n today,\n toMinor,\n} from \"../../shared/money.ts\";\nimport { reconcile } from \"../../shared/reconcile.ts\";\nimport { exec, nameKey, num, queryOne } from \"../db.ts\";\nimport { baseCurrency } from \"../fx.ts\";\nimport {\n cancelSubscription,\n createSubscription,\n listViews,\n recordCharge,\n saveRating,\n updateSubscription,\n} from \"../subscriptions.ts\";\nimport { forecast, savings, summary, upcoming } from \"../analytics.ts\";\nimport { closeItemsFor, flagNewFromEmail, listReviewItems } from \"../review.ts\";\nimport { primeLinks } from \"../links.ts\";\nimport * as llm from \"../llm.ts\";\nimport {\n cleanSubject,\n type Command,\n heuristicAmount,\n heuristicCycle,\n parseCommand,\n senderDomain,\n splitEmail,\n} from \"./parse.ts\";\nimport {\n formatForecast,\n formatHelp,\n formatList,\n formatReview,\n formatSavings,\n formatSummary,\n formatUpcoming,\n} from \"./reply.ts\";\n\nexport interface InboundMessage {\n from: string;\n subject?: string | null;\n text?: string | null;\n html?: string | null;\n messageId?: string | null;\n}\n\nexport interface HandledEmail {\n subject: string;\n body: string;\n /** False when the message was a duplicate and nothing was done. */\n replied: boolean;\n}\n\nexport async function handleInbound(msg: InboundMessage): Promise {\n await primeLinks();\n const body = msg.text?.trim() || stripHtml(msg.html ?? \"\");\n const subject = cleanSubject(msg.subject);\n const messageId = msg.messageId ?? null;\n\n if (messageId && (await seenBefore(messageId))) {\n return { subject: `Re: ${subject}`, body: \"\", replied: false };\n }\n\n const split = splitEmail(body);\n const emailId = await logEmail(msg, body, \"unknown\");\n const parts: string[] = [];\n let intent = \"unknown\";\n\n // 2. A command wins outright — it is unambiguous and free.\n const command = split.hasComment ? parseCommand(split.comment) : null;\n if (command) {\n intent = \"command\";\n parts.push(await runCommand(command));\n } else {\n // 3. Does the forwarded part look like a receipt worth recording?\n const receipt = split.quoted || (!split.hasComment ? body : \"\");\n if (receipt.trim().length > 0) {\n const ingested = await ingestReceipt(receipt, {\n from: msg.from,\n subject,\n emailId,\n fullBody: body,\n });\n if (ingested) {\n intent = \"ingest\";\n parts.push(ingested);\n }\n }\n\n // 4. Anything the sender wrote is a question.\n if (split.hasComment) {\n intent = intent === \"ingest\" ? \"ingest\" : \"question\";\n parts.push(await answer(split.comment));\n } else if (parts.length === 0) {\n parts.push(\n \"I could not find a subscription charge in that email, and there was no question to answer.\\n\\n\" +\n formatHelp(),\n );\n }\n }\n\n const replyBody = parts.filter(Boolean).join(`\\n\\n${\"=\".repeat(52)}\\n\\n`);\n await exec(\"UPDATE inbound_emails SET intent = ?, handled = 1, result = ? WHERE id = ?\", [\n intent,\n replyBody.slice(0, 2000),\n emailId,\n ]);\n\n return { subject: `Re: ${subject || \"your subscriptions\"}`, body: replyBody, replied: true };\n}\n\n// --- ingest -----------------------------------------------------------------\n\nasync function ingestReceipt(\n receipt: string,\n ctx: { from: string; subject: string; emailId: number; fullBody: string },\n): Promise {\n const receivedOn = today();\n let extracted: llm.ExtractedSubscription | null = null;\n\n if (llm.isConfigured()) {\n try {\n extracted = await llm.extractSubscription(receipt, {\n subject: ctx.subject,\n from: ctx.from,\n receivedOn,\n });\n } catch (err) {\n console.error(\"llm extraction failed, falling back to heuristics:\", err);\n }\n }\n\n // Without a key — or when the model declines — fall back to reading the biggest\n // money amount out of the text. Good enough to capture the charge; the confirm\n // item is what makes it safe.\n if (!extracted) {\n const hit = heuristicAmount(receipt);\n if (!hit) return null;\n const guessedName = guessServiceName(ctx.subject, ctx.from);\n if (!guessedName) return null;\n extracted = {\n serviceName: guessedName,\n planName: null,\n amount: hit.amount,\n currency: hit.currency,\n billingCycle: hit.cycle ?? heuristicCycle(ctx.fullBody),\n chargedOn: receivedOn,\n nextChargeOn: null,\n category: null,\n // A text scan has no reliable way to tell an order number from any other\n // long identifier on a receipt, so it does not try.\n orderReference: null,\n confidence: llm.isConfigured() ? 0.3 : 0.4,\n notes: llm.isConfigured() ? null : \"Read without an LLM — check the details.\",\n };\n }\n\n if (!extracted.serviceName || extracted.confidence < 0.35) return null;\n\n const amountMinor = toMinor(extracted.amount);\n const domain = senderDomain(ctx.from);\n const existing = await findLiveByName(extracted.serviceName);\n // Only a stated date is evidence of a payment. An instruction like \"change this to\n // yearly\" carries a price but no charge — dating it today would invent one, and\n // that is how the same annual payment came to be counted twice.\n const paymentDated = extracted.chargedOn !== null;\n const chargedOn = extracted.chargedOn ?? receivedOn;\n const base = await baseCurrency();\n\n if (existing) {\n // Work out the whole change, not just the price. A plan moving from monthly to\n // yearly has to move its cycle and its next charge date with it, or the yearly\n // amount sits on a monthly cadence and the run rate reads twelve times too high.\n const change = reconcile(existing, extracted, chargedOn, receivedOn);\n\n const charge = paymentDated\n ? await recordCharge({\n subscriptionId: existing.id,\n chargedOn,\n amountMinor,\n currency: extracted.currency,\n source: \"email\",\n orderRef: extracted.orderReference,\n inboundEmailId: ctx.emailId,\n })\n : { recorded: false, reason: \"the email gave no payment date, so nothing was added to history\" };\n await updateSubscription(existing.id, change.patch);\n\n if (change.priceChanged || change.cycleChanged) {\n await flagNewFromEmail(\n existing,\n `Changed from ${describePlan(change.previous.amountMinor, change.previous.currency, change.previous.billingCycle)} ` +\n `to ${describePlan(change.next.amountMinor, change.next.currency, change.next.billingCycle)} on ${chargedOn}. ` +\n `Confirm this is right.`,\n `change:${chargedOn}`,\n );\n }\n\n const monthly = monthlyEquivalentMinor(amountMinor, change.next.billingCycle);\n return [\n `Updated ${existing.serviceName}.`,\n ` Amount ${describePlan(amountMinor, extracted.currency, change.next.billingCycle)}` +\n `${change.priceChanged ? \" (price changed)\" : \"\"}${change.cycleChanged ? \" (cycle changed)\" : \"\"}`,\n change.cycleChanged\n ? ` Was ${describePlan(change.previous.amountMinor, change.previous.currency, change.previous.billingCycle)}`\n : \"\",\n ` ≈ /month ${formatMoney(monthly, extracted.currency)}`,\n charge.recorded ? ` Charged ${chargedOn}` : \"\",\n ` Next ${change.patch.nextChargeOn}`,\n extracted.orderReference ? ` Order ${extracted.orderReference}` : \"\",\n charge.recorded ? \"\" : ` History not touched — ${charge.reason}`,\n change.priceChanged || change.cycleChanged\n ? \"\\nThat is a change to an existing subscription, so I flagged it for you to confirm.\"\n : \"\",\n ].filter(Boolean).join(\"\\n\");\n }\n\n const cycle = extracted.billingCycle ?? heuristicCycle(receipt) ?? \"monthly\";\n const id = await createSubscription({\n serviceName: extracted.serviceName,\n planName: extracted.planName,\n amountMinor,\n currency: extracted.currency,\n billingCycle: cycle,\n startedOn: chargedOn,\n nextChargeOn: extracted.nextChargeOn ?? advanceByCycle(chargedOn, cycle),\n category: extracted.category,\n vendorDomain: domain,\n notes: extracted.notes,\n source: \"email\",\n });\n if (paymentDated) {\n await recordCharge({\n subscriptionId: id,\n chargedOn,\n amountMinor,\n currency: extracted.currency,\n source: \"email\",\n orderRef: extracted.orderReference,\n inboundEmailId: ctx.emailId,\n });\n }\n await flagNewFromEmail(\n { id, serviceName: extracted.serviceName },\n `Added from ${ctx.from} on ${receivedOn}: ${formatMoney(amountMinor, extracted.currency)} ` +\n `${extracted.billingCycle}. Check the amount, cycle and next charge date.`,\n );\n\n const monthly = monthlyEquivalentMinor(amountMinor, cycle);\n return [\n `Added ${extracted.serviceName}${extracted.planName ? ` (${extracted.planName})` : \"\"} to the tracker.`,\n ` Amount ${describePlan(amountMinor, extracted.currency, cycle)}`,\n ` ≈ /month ${formatMoney(monthly, extracted.currency)}`,\n ` Next ${extracted.nextChargeOn ?? advanceByCycle(chargedOn, cycle)}`,\n extracted.category ? ` Category ${extracted.category}` : \"\",\n extracted.orderReference ? ` Order ${extracted.orderReference}` : \"\",\n \"\",\n `It is flagged for you to confirm. Reply \"cancel ${extracted.serviceName}\" if you do not want it,`,\n `or \"rate ${extracted.serviceName} 4 2\" to grade it (quality, then usage).`,\n base === extracted.currency ? \"\" : `Converted into ${base} on the dashboard.`,\n ].filter(Boolean).join(\"\\n\");\n}\n\n/** \"469,99 zł yearly\" — the two facts that are meaningless apart. */\nfunction describePlan(amountMinor: number, currency: Currency, cycle: BillingCycle): string {\n return `${formatMoney(amountMinor, currency)} ${cycle}`;\n}\n\n// --- questions --------------------------------------------------------------\n\nasync function answer(question: string): Promise {\n if (!llm.isConfigured()) {\n return [\n \"I cannot answer questions yet — no LLM key is configured.\",\n \"\",\n \"Add an Anthropic API key as the ANTHROPIC_API_KEY environment variable on this val,\",\n \"and I will answer questions about your subscriptions from then on.\",\n \"\",\n \"Commands still work without a key:\",\n formatHelp(),\n ].join(\"\\n\");\n }\n try {\n const snapshot = await portfolioSnapshot();\n const reply = await llm.answerQuestion(question, snapshot);\n return reply || \"I could not come up with an answer to that one.\";\n } catch (err) {\n console.error(\"llm question failed:\", err);\n return `I could not answer that: ${err instanceof Error ? err.message : String(err)}`;\n }\n}\n\n/** The compact view of everything, handed to the model as JSON. */\nexport async function portfolioSnapshot() {\n const views = await listViews(true);\n const [sum, fc, sv, soon, review] = await Promise.all([\n summary(views),\n forecast(12, views.filter((s) => isLive(s.status))),\n savings(),\n upcoming(60, views),\n listReviewItems(\"open\"),\n ]);\n\n return {\n today: today(),\n baseCurrency: sum.baseCurrency,\n note: \"All *Minor fields are integer minor units — divide by 100.\",\n summary: sum,\n subscriptions: views.map((s) => ({\n name: s.serviceName,\n plan: s.planName,\n category: s.category,\n amountMinor: s.amountMinor,\n currency: s.currency,\n cycle: s.billingCycle,\n monthlyBaseMinor: s.monthlyBaseMinor,\n yearlyBaseMinor: s.yearlyBaseMinor,\n status: s.status,\n nextChargeOn: s.nextChargeOn,\n cancelledOn: s.cancelledOn,\n quality: s.verdict.quality,\n usage: s.verdict.usage,\n score: s.verdict.score,\n verdict: s.verdict.band,\n })),\n upcoming60Days: soon,\n monthlyForecast: fc.months.map((m) => ({ period: m.period, baseMinor: m.baseMinor })),\n savings: sv.items,\n openDecisions: review.map((r) => ({ title: r.title, kind: r.kind, dueOn: r.dueOn })),\n };\n}\n\n// --- commands ---------------------------------------------------------------\n\nasync function runCommand(cmd: Command): Promise {\n const base = await baseCurrency();\n\n switch (cmd.kind) {\n case \"help\":\n return formatHelp();\n\n case \"list\": {\n const views = await listViews(false);\n return `${formatList(views, base)}\\n\\n${formatSummary(await summary())}`;\n }\n\n case \"forecast\":\n return formatForecast(await forecast(cmd.months));\n\n case \"upcoming\":\n return formatUpcoming(await upcoming(cmd.days), base, cmd.days);\n\n case \"savings\":\n return formatSavings(await savings(), base);\n\n case \"review\":\n return formatReview(await listReviewItems(\"open\"));\n\n case \"cancel\": {\n const sub = await findLiveByName(cmd.service);\n if (!sub) return `I could not find an active subscription matching \"${cmd.service}\".`;\n await cancelSubscription(sub.id, { reason: cmd.reason ?? \"Cancelled by email\" });\n await closeItemsFor(sub.id);\n return [\n `Cancelled ${sub.serviceName}.`,\n `That is ${formatMoney(sub.monthlyBaseMinor, base)}/month you stop paying ` +\n `(${formatMoney(sub.monthlyBaseMinor * 12, base)}/year).`,\n cmd.reason ? `Reason recorded: ${cmd.reason}` : \"\",\n \"\",\n \"It stays in the history so the savings keep counting.\",\n ].filter(Boolean).join(\"\\n\");\n }\n\n case \"keep\": {\n const sub = await findLiveByName(cmd.service);\n if (!sub) return `I could not find an active subscription matching \"${cmd.service}\".`;\n await closeItemsFor(sub.id, [\"cancel_candidate\", \"confirm_new\", \"yearly_upcoming\"]);\n return `Keeping ${sub.serviceName}. Cleared its open decisions — I will ask again next month.`;\n }\n\n case \"rate\": {\n const sub = await findLiveByName(cmd.service);\n if (!sub) return `I could not find an active subscription matching \"${cmd.service}\".`;\n const period = currentPeriod();\n await saveRating(sub.id, period, cmd.quality, cmd.usage, cmd.note);\n await closeItemsFor(sub.id, [\"rating_due\"]);\n const score = Math.round((2 * cmd.quality * cmd.usage) / (cmd.quality + cmd.usage) * 10) / 10;\n return [\n `Rated ${sub.serviceName} for ${period}: quality ${cmd.quality}, usage ${cmd.usage}.`,\n `Score ${score}/5 — ${score >= 3.5 ? \"worth keeping\" : score >= 2.5 ? \"worth a look\" : \"a cancel candidate\"}.`,\n `It costs ${formatMoney(sub.monthlyBaseMinor, base)}/month.`,\n ].join(\"\\n\");\n }\n\n case \"add\": {\n const id = await createSubscription({\n serviceName: cmd.service,\n amountMinor: toMinor(cmd.amount),\n currency: cmd.currency,\n billingCycle: cmd.cycle,\n source: \"email\",\n });\n const sub = (await listViews(true)).find((s) => s.id === id);\n return [\n `Added ${cmd.service}: ${formatMoney(toMinor(cmd.amount), cmd.currency)} ${cmd.cycle}.`,\n sub ? `≈ ${formatMoney(sub.monthlyBaseMinor, base)}/month.` : \"\",\n ].filter(Boolean).join(\"\\n\");\n }\n }\n}\n\n// --- helpers ----------------------------------------------------------------\n\n/** Match on exact key first, then a containment match, so \"netflix\" finds \"Netflix\". */\nasync function findLiveByName(name: string): Promise {\n const views = await listViews(true);\n const key = nameKey(name);\n const live = views.filter((s) => isLive(s.status));\n return (\n live.find((s) => nameKey(s.serviceName) === key) ??\n live.find((s) => nameKey(s.serviceName).includes(key) || key.includes(nameKey(s.serviceName))) ??\n views.find((s) => nameKey(s.serviceName) === key) ??\n null\n );\n}\n\n/** Last-ditch service name when the model is unavailable: the sender's domain. */\nfunction guessServiceName(subject: string, from: string): string | null {\n const domain = senderDomain(from);\n if (domain) {\n const label = domain.split(\".\")[0];\n if (label && label.length > 2) return label.charAt(0).toUpperCase() + label.slice(1);\n }\n const word = /^([A-Z][\\w&.-]{2,20})\\b/.exec(subject);\n return word ? word[1] : null;\n}\n\nasync function seenBefore(messageId: string): Promise {\n const row = await queryOne(\"SELECT id FROM inbound_emails WHERE message_id = ?\", [messageId]);\n return row != null;\n}\n\nasync function logEmail(msg: InboundMessage, body: string, intent: string): Promise {\n const res = await exec(\n `INSERT INTO inbound_emails (message_id, from_addr, subject, body, intent) VALUES (?, ?, ?, ?, ?)`,\n [msg.messageId ?? null, msg.from, msg.subject ?? null, body.slice(0, 20_000), intent],\n );\n if (res.lastInsertRowid) return res.lastInsertRowid;\n const row = await queryOne(\"SELECT id FROM inbound_emails WHERE message_id = ?\", [msg.messageId ?? \"\"]);\n return row ? num(row.id) : 0;\n}\n\nfunction stripHtml(html: string): string {\n return html\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(//gi, \"\\n\")\n .replace(/<\\/(p|div|tr|li|h[1-6])>/gi, \"\\n\")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /gi, \" \")\n .replace(/&/gi, \"&\")\n .replace(/</gi, \"<\")\n .replace(/>/gi, \">\")\n .replace(/&#(\\d+);/g, (_, d) => String.fromCharCode(Number(d)))\n .replace(/[ \\t]+/g, \" \")\n .replace(/\\n{3,}/g, \"\\n\\n\")\n .trim();\n}\n","deleted",false,"label",[47,48,24],"backend","email","5588f200-1c41-400f-bf66-81f9f6ac0211",["D",1788290256185],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Track subscriptions, forecast spend, decide what to cancel","imageUrl","userId","5f1525c6-51a0-4c57-858d-f94f1e686d46","pinnedFileId","c177e026-a63a-11f1-bee9-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a05e29-777a-77c1-a910-e4a1d8102a40","tursoName","5588f2001c41400fbf6681f9f6ac0211","tursoHostname","5588f2001c41400fbf6681f9f6ac0211-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789509043237],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_109":-5},"org",{"_9":10,"_103":104,"_105":-5,"_59":-5,"_106":107,"_108":44},"branch",{"_37":93,"_11":94,"_22":30,"_95":49,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":12,"_102":10},"isOwned",92,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","xd.ventures","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_86":-5,"_143":144,"_145":146,"_147":148,"_149":44,"_150":44,"_151":44,"_152":34,"_153":-5,"_154":-7,"_155":-7,"_156":67,"_157":44,"_158":44,"_159":-5,"_160":44,"_161":44,"_162":44,"_163":-5},"ENV",{"_114":115,"_116":117,"_118":94,"_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"]