[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_334":335,"_336":337},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_107":89,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":24,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",20,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/email/reply.ts","latestPath","fileId","5543b84e-a63a-11f1-b417-1607ee4eb77e","name","reply.ts","fileType","script","content","/**\n * Plain-text email bodies.\n *\n * Deliberately plain: these are read on a phone, in a mail client, often in a\n * notification preview. Fixed-width columns and a single leading number beat any\n * amount of formatting.\n */\nimport type { Currency, ProjectedCharge, ReviewItem, Summary, SubscriptionView } from \"../../shared/types.ts\";\nimport { isLive } from \"../../shared/types.ts\";\nimport type { Forecast, Saving } from \"../analytics.ts\";\nimport { bandLabel } from \"../../shared/grade.ts\";\nimport { formatMoney } from \"../../shared/money.ts\";\nimport { linkLine } from \"../links.ts\";\n\nconst RULE = \"-\".repeat(52);\n\nexport function formatList(views: SubscriptionView[], base: Currency): string {\n const live = views.filter((s) => isLive(s.status));\n if (live.length === 0) return \"No active subscriptions tracked yet.\";\n\n const sorted = [...live].sort((a, b) => b.monthlyBaseMinor - a.monthlyBaseMinor);\n const lines = sorted.map((s) => {\n const cost = formatMoney(s.amountMinor, s.currency);\n const perMonth = formatMoney(s.monthlyBaseMinor, base);\n const cycle = s.billingCycle === \"yearly\" ? \"yr\" : \"mo\";\n const verdict = s.verdict.score == null ? \"unrated\" : `${bandLabel(s.verdict.band)} ${s.verdict.score}`;\n return `${pad(s.serviceName, 22)} ${pad(`${cost}/${cycle}`, 16)} ${pad(`≈${perMonth}/mo`, 16)} ${verdict}`;\n });\n\n const total = sorted.reduce((sum, s) => sum + s.monthlyBaseMinor, 0);\n return [\n `${live.length} active subscriptions`,\n RULE,\n ...lines,\n RULE,\n `Run rate: ${formatMoney(total, base)}/month · ${formatMoney(total * 12, base)}/year`,\n linkLine(\"Dashboard\"),\n ].filter(Boolean).join(\"\\n\");\n}\n\nexport function formatSummary(s: Summary): string {\n const b = s.baseCurrency;\n return [\n `Monthly run rate ${formatMoney(s.monthlyRunRateBaseMinor, b)}`,\n `Yearly run rate ${formatMoney(s.yearlyRunRateBaseMinor, b)}`,\n `Next 30 days ${formatMoney(s.next30DaysBaseMinor, b)}`,\n `Next 12 months ${formatMoney(s.next12MonthsBaseMinor, b)}`,\n `Active ${s.activeCount} (${s.monthlyCount} monthly, ${s.yearlyCount} yearly)`,\n `Saved by cancels ${formatMoney(s.savedToDateBaseMinor, b)} so far, ${formatMoney(s.savedPerMonthBaseMinor, b)}/mo ongoing`,\n ].join(\"\\n\");\n}\n\nexport function formatForecast(f: Forecast): string {\n const max = Math.max(1, ...f.months.map((m) => m.baseMinor));\n const lines = f.months.map((m) => {\n const bar = \"█\".repeat(Math.round((m.baseMinor / max) * 24));\n const yearly = m.charges.filter((c) => c.billingCycle === \"yearly\");\n const note = yearly.length ? ` ← ${yearly.map((c) => c.serviceName).join(\", \")}` : \"\";\n return `${m.period} ${pad(formatMoney(m.baseMinor, f.baseCurrency), 13)} ${bar}${note}`;\n });\n return [\n `Next ${f.months.length} months — ${formatMoney(f.totalBaseMinor, f.baseCurrency)} total`,\n RULE,\n ...lines,\n \"\",\n \"Yearly renewals are marked so they do not surprise you.\",\n linkLine(\"Dashboard\"),\n ].filter(Boolean).join(\"\\n\");\n}\n\nexport function formatUpcoming(charges: ProjectedCharge[], base: Currency, days: number): string {\n if (charges.length === 0) return `Nothing due in the next ${days} days.`;\n const total = charges.reduce((sum, c) => sum + c.baseMinor, 0);\n const lines = charges.map((c) =>\n `${c.date} ${pad(c.serviceName, 24)} ${pad(formatMoney(c.amountMinor, c.currency), 14)}${c.billingCycle === \"yearly\" ? \" (yearly)\" : \"\"}`\n );\n return [\n `Due in the next ${days} days — ${formatMoney(total, base)}`,\n RULE,\n ...lines,\n linkLine(\"Dashboard\"),\n ].filter(Boolean).join(\"\\n\");\n}\n\nexport function formatSavings(\n savings: { items: Saving[]; totalBaseMinor: number; perMonthBaseMinor: number },\n base: Currency,\n): string {\n if (savings.items.length === 0) return \"Nothing cancelled yet — no savings to report.\";\n const lines = savings.items.map((s) =>\n `${pad(s.serviceName, 22)} ${pad(formatMoney(s.savedBaseMinor, base), 14)} since ${s.cancelledOn} (${formatMoney(s.monthlyBaseMinor, base)}/mo)`\n );\n return [\n `Saved by cancelling — ${formatMoney(savings.totalBaseMinor, base)} to date`,\n RULE,\n ...lines,\n RULE,\n `Ongoing: ${formatMoney(savings.perMonthBaseMinor, base)}/month you are no longer paying.`,\n ].join(\"\\n\");\n}\n\nexport function formatReview(items: ReviewItem[]): string {\n if (items.length === 0) return \"Nothing to decide — the inbox is empty.\";\n const lines = items.map((i) => {\n const due = i.dueOn ? ` (by ${i.dueOn})` : \"\";\n return `• ${i.title}${due}${i.detail ? `\\n ${i.detail}` : \"\"}`;\n });\n return [\n `${items.length} thing${items.length === 1 ? \"\" : \"s\"} to decide`,\n RULE,\n ...lines,\n \"\",\n \"Reply with: cancel · keep · rate 4 2\",\n linkLine(\"Dashboard\"),\n ].filter(Boolean).join(\"\\n\");\n}\n\nexport function formatHelp(): string {\n return [\n \"Subscription tracker — what you can send me\",\n RULE,\n \"Forward a receipt with no comment → I add it and ask you to confirm\",\n \"Forward a receipt with a question → I answer the question\",\n \"\",\n \"Commands (first line of the email):\",\n \" list active subscriptions and run rate\",\n \" forecast [months] calendar forecast, yearly renewals marked\",\n \" upcoming [days] what is due soon\",\n \" savings what cancelling has saved you\",\n \" review the decisions waiting on you\",\n \" rate 4 2 quality 4, usage 2 for this month\",\n \" cancel [because …]\",\n \" keep clear the open decisions for it\",\n \" add 49.99 PLN monthly\",\n \"\",\n \"Anything else is treated as a question and answered from your data.\",\n linkLine(\"Dashboard\"),\n ].filter(Boolean).join(\"\\n\");\n}\n\nfunction pad(s: string, width: number): string {\n return s.length >= width ? s.slice(0, width) : s + \" \".repeat(width - s.length);\n}\n","createdAt",["D",1788290489391],"branchVersion","branchId","723ee93a-6b67-428c-b3cc-6f9491011d78","id","5588f200-1c41-400f-bf66-81f9f6ac0211","subscriptions",["D",1788290256185],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Track subscriptions, forecast spend, decide what to cancel","imageUrl","5f1525c6-51a0-4c57-858d-f94f1e686d46","pinnedFileId","c177e026-a63a-11f1-bee9-1607ee4eb77e","pinPreview",true,"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",{"_99":98,"_106":-5},"org",{"_99":98,"_100":101,"_102":-5,"_18":-5,"_103":104,"_105":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",92,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","xdv","handle","displayName","xd.ventures","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":329,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":330,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":331,"_83":332,"_85":333,"_87":24},"tree",[180,191,193,198,199],"files",[180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199],"counts",{"_169":62,"_170":138,"_171":138,"_172":173,"_174":175},"contents",[129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":163,"_31":164,"_29":165,"_137":-5,"_40":41,"_39":166,"_139":58,"_37":167,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":168},{"_42":157,"_31":158,"_29":159,"_137":-5,"_40":41,"_39":160,"_139":58,"_37":161,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":162},{"_42":151,"_31":152,"_29":153,"_137":-5,"_40":41,"_39":154,"_139":58,"_37":155,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":156},{"_42":144,"_31":145,"_29":146,"_137":-5,"_40":41,"_39":147,"_139":58,"_37":148,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":150},{"_42":134,"_31":135,"_29":136,"_137":-5,"_40":41,"_39":138,"_139":24,"_37":140,"_13":62,"_33":20,"_35":141,"_23":24,"_142":-5,"_26":143},"67d40d33-d63e-42a4-848c-c79f3182920a","PLACEHOLDER.md","ca49b9d2-a639-11f1-bb59-1607ee4eb77e","parentId",1,"latest",["D",1788290256221],"Bootstrapping.","label",[135],"44ac6418-79af-44cf-ad45-03919cf85518","tests","daa22ada-a639-11f1-a090-1607ee4eb77e",7,["D",1788290283645],"directory",[145],"3b062db2-506c-4dab-8eea-bbf72b699f28","shared","cd4c23cc-a639-11f1-9263-1607ee4eb77e",2,["D",1788290261270],[152],"7a1a8cc2-5f5e-41d8-b0dc-6a886fbbfd83","frontend","d62582e0-a639-11f1-8486-1607ee4eb77e",5,["D",1788290276120],[158],"8e3a3793-994f-4922-93a3-91669c779f58","backend","cfb9f800-a639-11f1-ae2f-1607ee4eb77e",3,["D",1788290265322],[164],"pulls","branches","forks","envVars",{"_176":178,"_179":62},"connections",{"_176":62,"_177":62},"count","unfilledCount",6,"emptyCount",{"_42":163,"_31":164,"_29":165,"_137":-5,"_40":41,"_39":166,"_139":58,"_37":326,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_201":327,"_26":328},{"_42":321,"_31":312,"_29":308,"_137":165,"_40":41,"_39":322,"_139":58,"_37":323,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_201":324,"_26":325},{"_42":313,"_31":314,"_29":315,"_137":308,"_40":41,"_39":316,"_139":24,"_37":317,"_13":62,"_33":34,"_35":318,"_23":24,"_142":-5,"_201":319,"_26":320},{"_42":307,"_31":32,"_29":30,"_137":308,"_40":41,"_39":14,"_139":58,"_37":309,"_13":62,"_33":34,"_35":36,"_23":24,"_142":-5,"_201":310,"_26":311},{"_42":299,"_31":300,"_29":301,"_137":165,"_40":41,"_39":302,"_139":58,"_37":303,"_13":62,"_33":34,"_35":304,"_23":24,"_142":-5,"_201":305,"_26":306},{"_42":291,"_31":292,"_29":293,"_137":165,"_40":41,"_39":294,"_139":24,"_37":295,"_13":62,"_33":34,"_35":296,"_23":24,"_142":-5,"_201":297,"_26":298},{"_42":283,"_31":284,"_29":285,"_137":165,"_40":41,"_39":286,"_139":58,"_37":287,"_13":62,"_33":34,"_35":288,"_23":24,"_142":-5,"_201":289,"_26":290},{"_42":275,"_31":276,"_29":277,"_137":165,"_40":41,"_39":278,"_139":24,"_37":279,"_13":62,"_33":34,"_35":280,"_23":24,"_142":-5,"_201":281,"_26":282},{"_42":267,"_31":268,"_29":269,"_137":165,"_40":41,"_39":270,"_139":24,"_37":271,"_13":62,"_33":34,"_35":272,"_23":24,"_142":-5,"_201":273,"_26":274},{"_42":259,"_31":260,"_29":261,"_137":165,"_40":41,"_39":262,"_139":58,"_37":263,"_13":62,"_33":34,"_35":264,"_23":24,"_142":-5,"_201":265,"_26":266},{"_42":251,"_31":252,"_29":253,"_137":165,"_40":41,"_39":254,"_139":24,"_37":255,"_13":62,"_33":34,"_35":256,"_23":24,"_142":-5,"_201":257,"_26":258},{"_42":157,"_31":158,"_29":159,"_137":-5,"_40":41,"_39":160,"_139":58,"_37":248,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_201":249,"_26":250},{"_42":242,"_31":243,"_29":244,"_137":159,"_40":41,"_39":178,"_139":58,"_37":245,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_201":246,"_26":247},{"_42":151,"_31":152,"_29":153,"_137":-5,"_40":41,"_39":154,"_139":58,"_37":239,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_201":240,"_26":241},{"_42":231,"_31":232,"_29":233,"_137":153,"_40":41,"_39":234,"_139":58,"_37":235,"_13":62,"_33":34,"_35":236,"_23":24,"_142":-5,"_201":237,"_26":238},{"_42":223,"_31":224,"_29":225,"_137":153,"_40":41,"_39":226,"_139":58,"_37":227,"_13":62,"_33":34,"_35":228,"_23":24,"_142":-5,"_201":229,"_26":230},{"_42":215,"_31":216,"_29":217,"_137":153,"_40":41,"_39":218,"_139":58,"_37":219,"_13":62,"_33":34,"_35":220,"_23":24,"_142":-5,"_201":221,"_26":222},{"_42":207,"_31":208,"_29":209,"_137":153,"_40":41,"_39":210,"_139":24,"_37":211,"_13":62,"_33":34,"_35":212,"_23":24,"_142":-5,"_201":213,"_26":214},{"_42":144,"_31":145,"_29":146,"_137":-5,"_40":41,"_39":147,"_139":58,"_37":204,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_201":205,"_26":206},{"_42":134,"_31":135,"_29":136,"_137":-5,"_40":41,"_39":138,"_139":24,"_37":200,"_13":62,"_33":20,"_35":141,"_23":24,"_142":-5,"_201":202,"_26":203},["D",1788290256221],"children",[],[135],["D",1788290283645],[],[145],"e4d4dca2-b850-4197-9596-43f83839fc12","types.ts","fad95512-a639-11f1-8af0-1607ee4eb77e",8,["D",1788290337678],"/** Shared types used by both the backend and the browser bundle. */\n\nexport type Currency = \"PLN\" | \"USD\" | \"EUR\";\nexport const CURRENCIES: Currency[] = [\"PLN\", \"USD\", \"EUR\"];\n\nexport type BillingCycle = \"monthly\" | \"yearly\";\nexport const BILLING_CYCLES: BillingCycle[] = [\"monthly\", \"yearly\"];\n\nexport type SubscriptionStatus = \"active\" | \"trial\" | \"paused\" | \"cancelled\";\n\n/** Statuses that still cost money and still get forecast, rated and reminded about. */\nexport const LIVE_STATUSES: SubscriptionStatus[] = [\"active\", \"trial\"];\n\nexport function isLive(status: SubscriptionStatus): boolean {\n return status === \"active\" || status === \"trial\";\n}\n\nexport interface Service {\n id: number;\n name: string;\n /** Sender domain of confirmation mail, used to match forwarded email to a service. */\n vendorDomain: string | null;\n category: string | null;\n notes: string | null;\n createdAt: string;\n}\n\nexport interface Subscription {\n id: number;\n serviceId: number;\n serviceName: string;\n category: string | null;\n planName: string | null;\n /** Native amount in minor units (grosze / cents). Never a float. */\n amountMinor: number;\n currency: Currency;\n billingCycle: BillingCycle;\n startedOn: string | null;\n /** ISO date of the next expected charge. Drives forecasts and reminders. */\n nextChargeOn: string | null;\n status: SubscriptionStatus;\n cancelledOn: string | null;\n cancelReason: string | null;\n paymentMethod: string | null;\n autoRenew: boolean;\n /** Where the row came from: typed in by hand, or extracted from a forwarded email. */\n source: \"manual\" | \"email\";\n notes: string | null;\n createdAt: string;\n updatedAt: string;\n}\n\n/** A real payment that happened, as opposed to a projected one. */\nexport interface Charge {\n id: number;\n subscriptionId: number;\n chargedOn: string;\n amountMinor: number;\n currency: Currency;\n /** Value in base currency at the time of the charge, so history is not re-rated by later FX moves. */\n baseMinor: number;\n fxRate: number;\n source: \"manual\" | \"email\" | \"projected\";\n inboundEmailId: number | null;\n createdAt: string;\n}\n\n/** One month's worth of \"how good is this, really\". */\nexport interface Rating {\n id: number;\n subscriptionId: number;\n /** YYYY-MM */\n period: string;\n /** 1..5 — how happy am I with the quality of the service. */\n quality: number;\n /** 1..5 — how often do I actually use it. */\n usage: number;\n note: string | null;\n createdAt: string;\n}\n\nexport type ReviewKind =\n | \"confirm_new\"\n | \"renewal_soon\"\n | \"yearly_upcoming\"\n | \"rating_due\"\n | \"cancel_candidate\";\n\nexport type ReviewStatus = \"open\" | \"done\" | \"dismissed\";\n\n/** The actionable inbox: the thing that stops a \"I meant to cancel that\" from evaporating. */\nexport interface ReviewItem {\n id: number;\n subscriptionId: number | null;\n kind: ReviewKind;\n status: ReviewStatus;\n title: string;\n detail: string | null;\n dueOn: string | null;\n createdAt: string;\n resolvedAt: string | null;\n}\n\nexport type EmailIntent = \"ingest\" | \"question\" | \"command\" | \"unknown\";\n\nexport interface InboundEmail {\n id: number;\n messageId: string | null;\n fromAddr: string;\n subject: string | null;\n intent: EmailIntent;\n handled: boolean;\n result: string | null;\n createdAt: string;\n}\n\n/** Verdict for a single subscription, computed from its recent ratings and its cost. */\nexport interface Verdict {\n /** Recency-weighted quality, 1..5, or null when never rated. */\n quality: number | null;\n usage: number | null;\n /** Harmonic mean of quality and usage — punishes \"great but unused\" and \"used but bad\". */\n score: number | null;\n ratedMonths: number;\n band: \"keep\" | \"watch\" | \"cancel_candidate\" | \"unrated\";\n reason: string;\n}\n\n/** A subscription plus everything the dashboard needs to render a row. */\nexport interface SubscriptionView extends Subscription {\n /** Native cost normalised to a month, in minor units of the native currency. */\n monthlyMinor: number;\n yearlyMinor: number;\n /** Same, converted to the base currency. */\n monthlyBaseMinor: number;\n yearlyBaseMinor: number;\n /** Units of base currency per unit of this subscription's currency, at render time. */\n fxRate: number;\n verdict: Verdict;\n latestRating: Rating | null;\n /** True when this month has no rating yet and the subscription is live. */\n ratingDue: boolean;\n}\n\n/** One projected (not yet charged) payment. */\nexport interface ProjectedCharge {\n subscriptionId: number;\n serviceName: string;\n date: string;\n amountMinor: number;\n currency: Currency;\n baseMinor: number;\n billingCycle: BillingCycle;\n}\n\nexport interface MonthBucket {\n /** YYYY-MM */\n period: string;\n baseMinor: number;\n charges: ProjectedCharge[];\n}\n\nexport interface Summary {\n baseCurrency: Currency;\n /** Sum of monthly-equivalents of everything live — the steady-state burn. */\n monthlyRunRateBaseMinor: number;\n yearlyRunRateBaseMinor: number;\n /** What the next 30 days will actually cost, on the calendar. */\n next30DaysBaseMinor: number;\n /** Calendar-accurate 12-month projection, so yearly renewals land in their real month. */\n next12MonthsBaseMinor: number;\n activeCount: number;\n monthlyCount: number;\n yearlyCount: number;\n /** Cumulative monthly-equivalent not spent since each cancellation. */\n savedToDateBaseMinor: number;\n /** Monthly-equivalent of everything cancelled — the ongoing saving. */\n savedPerMonthBaseMinor: number;\n openReviewCount: number;\n ratingDueCount: number;\n}\n",[],[152,208],"7e542ab3-108c-44d6-8108-02d6e5e4f01f","money.ts","09979014-a63a-11f1-83e6-1607ee4eb77e",9,["D",1788290362431],"/**\n * Money and billing-cycle maths. Pure — no imports, runs on both sides.\n *\n * Amounts are integer minor units (grosze / cents) everywhere. PLN, USD and EUR\n * all have two decimal places, so one constant covers every supported currency.\n */\nimport type { BillingCycle, Currency } from \"./types.ts\";\n\nexport const MINOR = 100;\n\nexport function toMinor(amount: number): number {\n return Math.round(amount * MINOR);\n}\n\nexport function fromMinor(minor: number): number {\n return minor / MINOR;\n}\n\nconst SYMBOLS: Record = { PLN: \"zł\", USD: \"$\", EUR: \"€\" };\n\n/** \"1 234,56 zł\" for PLN, \"$1,234.56\" for USD/EUR — matches where each symbol normally sits. */\nexport function formatMoney(minor: number, currency: Currency, opts?: { compact?: boolean }): string {\n const value = fromMinor(minor);\n const locale = currency === \"PLN\" ? \"pl-PL\" : \"en-US\";\n const body = value.toLocaleString(locale, {\n minimumFractionDigits: opts?.compact ? 0 : 2,\n maximumFractionDigits: opts?.compact ? 0 : 2,\n });\n return currency === \"PLN\" ? `${body} ${SYMBOLS.PLN}` : `${SYMBOLS[currency]}${body}`;\n}\n\n/**\n * Cost of one cycle expressed as a month.\n *\n * A yearly subscription is divided by twelve — this is the \"average monthly cost\"\n * that makes a 600 zł/year plan comparable to a 49 zł/month one. It is a run-rate,\n * not a cash-flow figure; the calendar projection below is what tells you when the\n * money actually leaves.\n */\nexport function monthlyEquivalentMinor(amountMinor: number, cycle: BillingCycle): number {\n return cycle === \"yearly\" ? Math.round(amountMinor / 12) : amountMinor;\n}\n\nexport function yearlyEquivalentMinor(amountMinor: number, cycle: BillingCycle): number {\n return cycle === \"yearly\" ? amountMinor : amountMinor * 12;\n}\n\n// ---------------------------------------------------------------------------\n// Dates. Stored as YYYY-MM-DD strings and manipulated in UTC so that a server in\n// one timezone and a browser in another agree on which day a charge lands.\n// ---------------------------------------------------------------------------\n\nexport function today(now: Date = new Date()): string {\n return toISODate(now);\n}\n\nexport function toISODate(d: Date): string {\n return d.toISOString().slice(0, 10);\n}\n\nexport function parseISODate(s: string): Date {\n const [y, m, d] = s.split(\"-\").map(Number);\n return new Date(Date.UTC(y, m - 1, d));\n}\n\n/** YYYY-MM for a date string. */\nexport function periodOf(isoDate: string): string {\n return isoDate.slice(0, 7);\n}\n\nexport function currentPeriod(now: Date = new Date()): string {\n return toISODate(now).slice(0, 7);\n}\n\n/** Previous period, e.g. \"2026-01\" -> \"2025-12\". */\nexport function shiftPeriod(period: string, months: number): string {\n const [y, m] = period.split(\"-\").map(Number);\n const d = new Date(Date.UTC(y, m - 1 + months, 1));\n return toISODate(d).slice(0, 7);\n}\n\n/**\n * Add months, clamping the day to the end of the target month.\n * 31 Jan + 1 month is 28/29 Feb, which is how card renewals actually behave.\n */\nexport function addMonths(isoDate: string, months: number): string {\n const d = parseISODate(isoDate);\n const day = d.getUTCDate();\n const target = new Date(Date.UTC(d.getUTCFullYear(), d.getUTCMonth() + months, 1));\n const lastDay = new Date(Date.UTC(target.getUTCFullYear(), target.getUTCMonth() + 1, 0)).getUTCDate();\n target.setUTCDate(Math.min(day, lastDay));\n return toISODate(target);\n}\n\nexport function addDays(isoDate: string, days: number): string {\n const d = parseISODate(isoDate);\n d.setUTCDate(d.getUTCDate() + days);\n return toISODate(d);\n}\n\nexport function advanceByCycle(isoDate: string, cycle: BillingCycle): string {\n return addMonths(isoDate, cycle === \"yearly\" ? 12 : 1);\n}\n\nexport function daysBetween(from: string, to: string): number {\n return Math.round((parseISODate(to).getTime() - parseISODate(from).getTime()) / 86_400_000);\n}\n\n/**\n * Roll a stale next-charge date forward until it is in the future.\n * Cheaper than a backfill job: a subscription whose date was never updated still\n * forecasts correctly, and the loop is bounded so bad data cannot hang a request.\n */\nexport function normaliseNextCharge(nextChargeOn: string, cycle: BillingCycle, from: string): string {\n let next = nextChargeOn;\n for (let i = 0; i < 240 && next < from; i++) {\n next = advanceByCycle(next, cycle);\n }\n return next;\n}\n",[],[152,216],"9353e38a-fea3-4c76-a556-ccfc0c7b0461","grade.ts","24db9dfc-a63a-11f1-9b8b-1607ee4eb77e",10,["D",1788290408143],"/**\n * Turning two monthly grades into a keep/cancel verdict.\n *\n * Each month you give a subscription two scores out of five: how good it is\n * (quality) and how much you actually reach for it (usage). Neither alone is a\n * decision — a brilliant tool you opened twice is still money leaving, and a\n * mediocre one you live in is worth keeping. So the two are combined with a\n * harmonic mean, which collapses toward whichever score is *worse*: 5 and 1 give\n * 1.7, not 3. Lopsided pairs are exactly the ones worth surfacing.\n */\nimport type { Rating, Verdict } from \"./types.ts\";\nimport { shiftPeriod } from \"./money.ts\";\n\n/** How many months of history feed a verdict. */\nexport const WINDOW_MONTHS = 6;\n/** Each month back counts for three quarters of the one after it. */\nconst DECAY = 0.75;\n\nexport const KEEP_THRESHOLD = 3.5;\nexport const WATCH_THRESHOLD = 2.5;\n\nexport function harmonicMean(a: number, b: number): number {\n if (a <= 0 || b <= 0) return 0;\n return (2 * a * b) / (a + b);\n}\n\nexport interface VerdictInput {\n ratings: Rating[];\n currentPeriod: string;\n /** Monthly cost in base currency, used to escalate an expensive middling service. */\n monthlyBaseMinor?: number;\n /** Cost above which \"watch\" becomes \"cancel candidate\". Typically the portfolio median. */\n expensiveThresholdMinor?: number;\n}\n\nexport function computeVerdict(input: VerdictInput): Verdict {\n const { ratings, currentPeriod, monthlyBaseMinor, expensiveThresholdMinor } = input;\n\n // Index the window by period so gaps (months you skipped) simply carry no weight.\n const windowPeriods = new Map();\n for (let i = 0; i < WINDOW_MONTHS; i++) {\n windowPeriods.set(shiftPeriod(currentPeriod, -i), Math.pow(DECAY, i));\n }\n\n let qSum = 0, uSum = 0, wSum = 0, months = 0;\n for (const r of ratings) {\n const w = windowPeriods.get(r.period);\n if (w === undefined) continue;\n qSum += r.quality * w;\n uSum += r.usage * w;\n wSum += w;\n months++;\n }\n\n if (wSum === 0) {\n return {\n quality: null,\n usage: null,\n score: null,\n ratedMonths: 0,\n band: \"unrated\",\n reason: \"No ratings yet — rate it once to get a verdict.\",\n };\n }\n\n const quality = round1(qSum / wSum);\n const usage = round1(uSum / wSum);\n const score = round1(harmonicMean(quality, usage));\n\n let band: Verdict[\"band\"] = score >= KEEP_THRESHOLD ? \"keep\" : score >= WATCH_THRESHOLD ? \"watch\" : \"cancel_candidate\";\n\n const expensive = monthlyBaseMinor !== undefined\n && expensiveThresholdMinor !== undefined\n && monthlyBaseMinor > expensiveThresholdMinor;\n\n // An above-median cost only has to be middling, not bad, to deserve a decision.\n if (band === \"watch\" && expensive) band = \"cancel_candidate\";\n\n return { quality, usage, score, ratedMonths: months, band, reason: explain(quality, usage, score, band, expensive) };\n}\n\nfunction explain(quality: number, usage: number, score: number, band: Verdict[\"band\"], expensive: boolean): string {\n const gap = quality - usage;\n if (gap >= 1.5) {\n return `Good service (${quality}) you barely use (${usage}) — the usual cancel candidate.`;\n }\n if (gap <= -1.5) {\n return `You use it (${usage}) despite rating it ${quality} — look for a better alternative.`;\n }\n if (band === \"keep\") return `Solid on both axes (${quality} quality, ${usage} usage).`;\n if (band === \"cancel_candidate\" && expensive) {\n return `Middling (${score}) and above your median cost — decide on it.`;\n }\n if (band === \"cancel_candidate\") return `Low on both axes (${quality} quality, ${usage} usage).`;\n return `Neither good nor bad (${score}) — worth a conscious decision.`;\n}\n\nfunction round1(n: number): number {\n return Math.round(n * 10) / 10;\n}\n\nexport function bandLabel(band: Verdict[\"band\"]): string {\n return { keep: \"Keep\", watch: \"Watch\", cancel_candidate: \"Cancel?\", unrated: \"Unrated\" }[band];\n}\n\n/** Median of the live monthly costs — the reference point for \"expensive\". */\nexport function medianMinor(values: number[]): number | undefined {\n if (values.length === 0) return undefined;\n const sorted = [...values].sort((a, b) => a - b);\n const mid = Math.floor(sorted.length / 2);\n return sorted.length % 2 ? sorted[mid] : Math.round((sorted[mid - 1] + sorted[mid]) / 2);\n}\n",[],[152,224],"1b189923-25e4-4258-a3c4-af249248f555","forecast.ts","27a1da2e-a63a-11f1-9ce3-1607ee4eb77e",11,["D",1788290412822],"/**\n * Projecting charges forward. Pure — the calendar maths that turns a set of\n * subscriptions into \"what leaves the account, and when\".\n *\n * Kept out of the backend so it can be tested without a database, and so the\n * browser could run the same projection if it ever needed to.\n */\nimport type { MonthBucket, ProjectedCharge, SubscriptionView } from \"./types.ts\";\nimport { isLive } from \"./types.ts\";\nimport { advanceByCycle, normaliseNextCharge, periodOf, shiftPeriod, today } from \"./money.ts\";\n\n/** Bound on how many charges one subscription can contribute — 20 years of monthly. */\nconst MAX_ITERATIONS = 240;\n\nexport function projectCharges(\n subs: SubscriptionView[],\n opts: { from?: string; until: string },\n): ProjectedCharge[] {\n const from = opts.from ?? today();\n const out: ProjectedCharge[] = [];\n\n for (const s of subs) {\n if (!isLive(s.status) || !s.nextChargeOn) continue;\n // A stale next-charge date rolls forward to the first one still ahead of us,\n // so a row nobody has touched in months still forecasts correctly.\n let date = normaliseNextCharge(s.nextChargeOn, s.billingCycle, from);\n for (let i = 0; i < MAX_ITERATIONS && date <= opts.until; i++) {\n out.push({\n subscriptionId: s.id,\n serviceName: s.serviceName,\n date,\n amountMinor: s.amountMinor,\n currency: s.currency,\n baseMinor: Math.round(s.amountMinor * s.fxRate),\n billingCycle: s.billingCycle,\n });\n // Auto-renew off means the charge already scheduled happens and nothing after it.\n if (!s.autoRenew) break;\n date = advanceByCycle(date, s.billingCycle);\n }\n }\n return out.sort((a, b) => a.date.localeCompare(b.date) || a.serviceName.localeCompare(b.serviceName));\n}\n\n/** Group into calendar months, keeping empty months so the chart has a continuous axis. */\nexport function bucketByMonth(charges: ProjectedCharge[], startPeriod: string, months: number): MonthBucket[] {\n const buckets: MonthBucket[] = [];\n const index = new Map();\n for (let i = 0; i < months; i++) {\n const period = shiftPeriod(startPeriod, i);\n const bucket: MonthBucket = { period, baseMinor: 0, charges: [] };\n buckets.push(bucket);\n index.set(period, bucket);\n }\n for (const c of charges) {\n const bucket = index.get(periodOf(c.date));\n if (!bucket) continue;\n bucket.baseMinor += c.baseMinor;\n bucket.charges.push(c);\n }\n return buckets;\n}\n",[],[152,232],["D",1788290261270],[194,195,196,197],[152],"a1f202f4-c83f-4267-8b6a-bd8cd99fe46f","components","d850bc88-a639-11f1-af8b-1607ee4eb77e",["D",1788290279752],[],[158,243],["D",1788290276120],[192],[158],"9521b9dd-29f1-4c95-9b69-8ec7599ce341","subscriptions.ts","4a6ca638-a63a-11f1-9792-1607ee4eb77e",16,["D",1788290471203],"/** CRUD for services, subscriptions, charges and ratings, plus the row -> view mapping. */\nimport type {\n BillingCycle,\n Charge,\n Currency,\n Rating,\n Subscription,\n SubscriptionStatus,\n SubscriptionView,\n} from \"../shared/types.ts\";\nimport { isLive, LIVE_STATUSES } from \"../shared/types.ts\";\nimport { computeVerdict, medianMinor } from \"../shared/grade.ts\";\nimport {\n currentPeriod,\n monthlyEquivalentMinor,\n normaliseNextCharge,\n today,\n yearlyEquivalentMinor,\n} from \"../shared/money.ts\";\nimport { bool, exec, nameKey, num, query, queryOne, Row, str } from \"./db.ts\";\nimport { convertMinor, getRates, rateFor, type RateTable } from \"./fx.ts\";\n\nconst SUB_SELECT = `\n SELECT s.*, sv.name AS service_name, sv.category AS category\n FROM subscriptions s\n JOIN services sv ON sv.id = s.service_id\n`;\n\nexport { LIVE_STATUSES };\n\nfunction mapSubscription(r: Row): Subscription {\n return {\n id: num(r.id),\n serviceId: num(r.service_id),\n serviceName: str(r.service_name) ?? \"(unknown)\",\n category: str(r.category),\n planName: str(r.plan_name),\n amountMinor: num(r.amount_minor),\n currency: (str(r.currency) ?? \"PLN\") as Currency,\n billingCycle: (str(r.billing_cycle) ?? \"monthly\") as BillingCycle,\n startedOn: str(r.started_on),\n nextChargeOn: str(r.next_charge_on),\n status: (str(r.status) ?? \"active\") as SubscriptionStatus,\n cancelledOn: str(r.cancelled_on),\n cancelReason: str(r.cancel_reason),\n paymentMethod: str(r.payment_method),\n autoRenew: bool(r.auto_renew),\n source: (str(r.source) ?? \"manual\") as \"manual\" | \"email\",\n notes: str(r.notes),\n createdAt: str(r.created_at) ?? \"\",\n updatedAt: str(r.updated_at) ?? \"\",\n };\n}\n\nfunction mapRating(r: Row): Rating {\n return {\n id: num(r.id),\n subscriptionId: num(r.subscription_id),\n period: str(r.period) ?? \"\",\n quality: num(r.quality),\n usage: num(r.usage),\n note: str(r.note),\n createdAt: str(r.created_at) ?? \"\",\n };\n}\n\nfunction mapCharge(r: Row): Charge {\n return {\n id: num(r.id),\n subscriptionId: num(r.subscription_id),\n chargedOn: str(r.charged_on) ?? \"\",\n amountMinor: num(r.amount_minor),\n currency: (str(r.currency) ?? \"PLN\") as Currency,\n baseMinor: num(r.base_minor),\n fxRate: num(r.fx_rate),\n source: (str(r.source) ?? \"manual\") as Charge[\"source\"],\n inboundEmailId: r.inbound_email_id == null ? null : num(r.inbound_email_id),\n createdAt: str(r.created_at) ?? \"\",\n };\n}\n\nexport async function listRaw(includeCancelled = true): Promise {\n const sql = includeCancelled\n ? `${SUB_SELECT} ORDER BY s.status = 'cancelled', sv.name COLLATE NOCASE`\n : `${SUB_SELECT} WHERE s.status IN ('active','trial') ORDER BY sv.name COLLATE NOCASE`;\n return (await query(sql)).map(mapSubscription);\n}\n\nexport async function getSubscription(id: number): Promise {\n const row = await queryOne(`${SUB_SELECT} WHERE s.id = ?`, [id]);\n return row ? mapSubscription(row) : null;\n}\n\nexport async function allRatings(): Promise> {\n const rows = await query(`SELECT * FROM ratings ORDER BY period DESC`);\n const bySub = new Map();\n for (const r of rows) {\n const rating = mapRating(r);\n const list = bySub.get(rating.subscriptionId) ?? [];\n list.push(rating);\n bySub.set(rating.subscriptionId, list);\n }\n return bySub;\n}\n\nexport async function ratingsFor(subscriptionId: number): Promise {\n const rows = await query(\n `SELECT * FROM ratings WHERE subscription_id = ? ORDER BY period DESC`,\n [subscriptionId],\n );\n return rows.map(mapRating);\n}\n\nexport async function chargesFor(subscriptionId: number): Promise {\n const rows = await query(\n `SELECT * FROM charges WHERE subscription_id = ? ORDER BY charged_on DESC`,\n [subscriptionId],\n );\n return rows.map(mapCharge);\n}\n\n/**\n * Everything the dashboard renders, in one pass: costs normalised to month and\n * year in both native and base currency, plus a verdict from recent ratings.\n * The \"expensive\" threshold is the median live monthly cost, so it adapts to the\n * portfolio instead of hard-coding what counts as a lot of money.\n */\nexport async function listViews(includeCancelled = true): Promise {\n const [subs, ratings, rates] = await Promise.all([listRaw(includeCancelled), allRatings(), getRates()]);\n const period = currentPeriod();\n\n const liveMonthly = subs\n .filter((s) => isLive(s.status))\n .map((s) => convertMinor(monthlyEquivalentMinor(s.amountMinor, s.billingCycle), s.currency, rates));\n const threshold = medianMinor(liveMonthly);\n\n return subs.map((s) => toView(s, ratings.get(s.id) ?? [], rates, period, threshold));\n}\n\nexport function toView(\n s: Subscription,\n ratings: Rating[],\n rates: RateTable,\n period: string,\n expensiveThresholdMinor?: number,\n): SubscriptionView {\n const monthlyMinor = monthlyEquivalentMinor(s.amountMinor, s.billingCycle);\n const yearlyMinor = yearlyEquivalentMinor(s.amountMinor, s.billingCycle);\n const monthlyBaseMinor = convertMinor(monthlyMinor, s.currency, rates);\n const verdict = computeVerdict({\n ratings,\n currentPeriod: period,\n monthlyBaseMinor,\n expensiveThresholdMinor,\n });\n const live = isLive(s.status);\n return {\n ...s,\n monthlyMinor,\n yearlyMinor,\n monthlyBaseMinor,\n yearlyBaseMinor: convertMinor(yearlyMinor, s.currency, rates),\n fxRate: rateFor(s.currency, rates),\n verdict,\n latestRating: ratings[0] ?? null,\n ratingDue: live && !ratings.some((r) => r.period === period),\n };\n}\n\n// --- writes -----------------------------------------------------------------\n\nexport async function findServiceId(name: string): Promise {\n const row = await queryOne(\"SELECT id FROM services WHERE name_key = ?\", [nameKey(name)]);\n return row ? num(row.id) : null;\n}\n\nexport async function findServiceByDomain(domain: string): Promise {\n const row = await queryOne(\"SELECT id FROM services WHERE vendor_domain = ?\", [domain.toLowerCase()]);\n return row ? num(row.id) : null;\n}\n\nexport async function upsertService(\n name: string,\n opts: { vendorDomain?: string | null; category?: string | null } = {},\n): Promise {\n const existing = await findServiceId(name);\n if (existing) {\n // Fill in blanks we learn later (e.g. the domain of a forwarded receipt).\n if (opts.vendorDomain) {\n await exec(\"UPDATE services SET vendor_domain = COALESCE(vendor_domain, ?) WHERE id = ?\", [\n opts.vendorDomain.toLowerCase(),\n existing,\n ]);\n }\n if (opts.category) {\n await exec(\"UPDATE services SET category = COALESCE(category, ?) WHERE id = ?\", [opts.category, existing]);\n }\n return existing;\n }\n const res = await exec(\n \"INSERT INTO services (name, name_key, vendor_domain, category) VALUES (?, ?, ?, ?)\",\n [name.trim(), nameKey(name), opts.vendorDomain?.toLowerCase() ?? null, opts.category ?? null],\n );\n return res.lastInsertRowid!;\n}\n\nexport interface SubscriptionInput {\n serviceName: string;\n planName?: string | null;\n amountMinor: number;\n currency: Currency;\n billingCycle: BillingCycle;\n startedOn?: string | null;\n nextChargeOn?: string | null;\n status?: SubscriptionStatus;\n paymentMethod?: string | null;\n category?: string | null;\n vendorDomain?: string | null;\n notes?: string | null;\n source?: \"manual\" | \"email\";\n}\n\nexport async function createSubscription(input: SubscriptionInput): Promise {\n const serviceId = await upsertService(input.serviceName, {\n vendorDomain: input.vendorDomain,\n category: input.category,\n });\n const started = input.startedOn ?? today();\n const next = input.nextChargeOn\n ? normaliseNextCharge(input.nextChargeOn, input.billingCycle, today())\n : normaliseNextCharge(started, input.billingCycle, today());\n\n const res = await exec(\n `INSERT INTO subscriptions\n (service_id, plan_name, amount_minor, currency, billing_cycle, started_on,\n next_charge_on, status, payment_method, notes, source)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n serviceId,\n input.planName ?? null,\n input.amountMinor,\n input.currency,\n input.billingCycle,\n started,\n next,\n input.status ?? \"active\",\n input.paymentMethod ?? null,\n input.notes ?? null,\n input.source ?? \"manual\",\n ],\n );\n return res.lastInsertRowid!;\n}\n\nconst PATCHABLE: Record = {\n planName: \"plan_name\",\n amountMinor: \"amount_minor\",\n currency: \"currency\",\n billingCycle: \"billing_cycle\",\n startedOn: \"started_on\",\n nextChargeOn: \"next_charge_on\",\n status: \"status\",\n paymentMethod: \"payment_method\",\n notes: \"notes\",\n autoRenew: \"auto_renew\",\n cancelledOn: \"cancelled_on\",\n cancelReason: \"cancel_reason\",\n};\n\nexport async function updateSubscription(id: number, patch: Record): Promise {\n const sets: string[] = [];\n const args: unknown[] = [];\n for (const [key, column] of Object.entries(PATCHABLE)) {\n if (!(key in patch)) continue;\n let value = patch[key];\n if (key === \"autoRenew\") value = value ? 1 : 0;\n sets.push(`${column} = ?`);\n args.push(value ?? null);\n }\n if (sets.length === 0) return;\n sets.push(\"updated_at = datetime('now')\");\n args.push(id);\n await exec(`UPDATE subscriptions SET ${sets.join(\", \")} WHERE id = ?`, args);\n}\n\n/**\n * Cancelling keeps the row. The whole point of tracking cancellations is to be\n * able to say what they saved, which needs the price and the date they stopped.\n */\nexport async function cancelSubscription(id: number, opts: { on?: string; reason?: string } = {}): Promise {\n await exec(\n `UPDATE subscriptions\n SET status = 'cancelled', cancelled_on = ?, cancel_reason = ?, next_charge_on = NULL,\n updated_at = datetime('now')\n WHERE id = ?`,\n [opts.on ?? today(), opts.reason ?? null, id],\n );\n}\n\nexport async function reactivateSubscription(id: number, nextChargeOn?: string): Promise {\n const sub = await getSubscription(id);\n if (!sub) return;\n const next = normaliseNextCharge(nextChargeOn ?? today(), sub.billingCycle, today());\n await exec(\n `UPDATE subscriptions\n SET status = 'active', cancelled_on = NULL, cancel_reason = NULL, next_charge_on = ?,\n updated_at = datetime('now')\n WHERE id = ?`,\n [next, id],\n );\n}\n\n/**\n * Hard delete, for a row that should never have existed — a misread receipt, say.\n * To stop paying for something real, cancel it instead: the history is what the\n * savings figure is made of.\n *\n * The dependent rows go explicitly rather than through ON DELETE CASCADE, which\n * only fires when foreign key enforcement happens to be enabled.\n */\nexport async function deleteSubscription(id: number): Promise {\n await exec(\"DELETE FROM ratings WHERE subscription_id = ?\", [id]);\n await exec(\"DELETE FROM charges WHERE subscription_id = ?\", [id]);\n await exec(\"DELETE FROM review_items WHERE subscription_id = ?\", [id]);\n await exec(\"DELETE FROM subscriptions WHERE id = ?\", [id]);\n}\n\nexport async function saveRating(\n subscriptionId: number,\n period: string,\n quality: number,\n usage: number,\n note?: string | null,\n): Promise {\n const clamp = (n: number) => Math.max(1, Math.min(5, Math.round(n)));\n await exec(\n `INSERT INTO ratings (subscription_id, period, quality, \"usage\", note)\n VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(subscription_id, period) DO UPDATE\n SET quality = excluded.quality, \"usage\" = excluded.\"usage\", note = excluded.note`,\n [subscriptionId, period, clamp(quality), clamp(usage), note ?? null],\n );\n}\n\n/** Records a payment that actually happened, pinning the FX rate used at the time. */\nexport async function recordCharge(opts: {\n subscriptionId: number;\n chargedOn: string;\n amountMinor: number;\n currency: Currency;\n source?: Charge[\"source\"];\n inboundEmailId?: number | null;\n}): Promise {\n const rates = await getRates();\n const rate = rateFor(opts.currency, rates);\n await exec(\n `INSERT INTO charges (subscription_id, charged_on, amount_minor, currency, base_minor, fx_rate, source, inbound_email_id)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT (subscription_id, charged_on, amount_minor) DO NOTHING`,\n [\n opts.subscriptionId,\n opts.chargedOn,\n opts.amountMinor,\n opts.currency,\n Math.round(opts.amountMinor * rate),\n rate,\n opts.source ?? \"manual\",\n opts.inboundEmailId ?? null,\n ],\n );\n}\n",[],[164,252],"96fa00f0-6f0a-4d7c-822c-ab545c6c2492","review.ts","4fc74e44-a63a-11f1-8d2b-1607ee4eb77e",18,["D",1788290480183],"/**\n * The actionable inbox.\n *\n * A subscription tracker that only tracks is a spreadsheet. What actually saves\n * money is a short list of decisions that will not go away until you make them.\n * Four things land here:\n *\n * confirm_new a forwarded receipt created a row — check we read it right\n * yearly_upcoming a yearly renewal is close enough to still cancel\n * rating_due a live subscription has no grade for this month\n * cancel_candidate the grades say this one is not earning its cost\n *\n * Every item carries a dedupe key, so the daily cron can run as often as it likes\n * without breeding duplicates, and dismissing an item makes it stay dismissed.\n */\nimport type { ReviewItem, ReviewKind, ReviewStatus, SubscriptionView } from \"../shared/types.ts\";\nimport { isLive } from \"../shared/types.ts\";\nimport { currentPeriod, daysBetween, formatMoney, today } from \"../shared/money.ts\";\nimport { exec, num, query, str } from \"./db.ts\";\nimport { listViews } from \"./subscriptions.ts\";\nimport { upcoming } from \"./analytics.ts\";\nimport { baseCurrency } from \"./fx.ts\";\n\n/** How far ahead a yearly renewal starts asking to be looked at. */\nexport const YEARLY_LEAD_DAYS = 30;\n\nfunction mapItem(r: Record): ReviewItem {\n return {\n id: num(r.id),\n subscriptionId: r.subscription_id == null ? null : num(r.subscription_id),\n kind: (str(r.kind) ?? \"confirm_new\") as ReviewKind,\n status: (str(r.status) ?? \"open\") as ReviewStatus,\n title: str(r.title) ?? \"\",\n detail: str(r.detail),\n dueOn: str(r.due_on),\n createdAt: str(r.created_at) ?? \"\",\n resolvedAt: str(r.resolved_at),\n };\n}\n\nexport async function listReviewItems(status: ReviewStatus | \"all\" = \"open\"): Promise {\n const sql = status === \"all\"\n ? `SELECT * FROM review_items ORDER BY status = 'open' DESC, due_on IS NULL, due_on, created_at DESC`\n : `SELECT * FROM review_items WHERE status = ? ORDER BY due_on IS NULL, due_on, created_at DESC`;\n const rows = status === \"all\" ? await query(sql) : await query(sql, [status]);\n return rows.map(mapItem);\n}\n\nexport interface NewReviewItem {\n subscriptionId?: number | null;\n kind: ReviewKind;\n title: string;\n detail?: string | null;\n dueOn?: string | null;\n dedupeKey: string;\n}\n\n/** Returns true when a genuinely new item was created. */\nexport async function addReviewItem(item: NewReviewItem): Promise {\n const res = await exec(\n `INSERT INTO review_items (subscription_id, kind, title, detail, due_on, dedupe_key)\n VALUES (?, ?, ?, ?, ?, ?)\n ON CONFLICT(dedupe_key) DO NOTHING`,\n [item.subscriptionId ?? null, item.kind, item.title, item.detail ?? null, item.dueOn ?? null, item.dedupeKey],\n );\n return res.rowsAffected > 0;\n}\n\nexport async function resolveReviewItem(id: number, status: Exclude): Promise {\n await exec(\n `UPDATE review_items SET status = ?, resolved_at = datetime('now') WHERE id = ?`,\n [status, id],\n );\n}\n\n/** Close anything still open for a subscription — used when it is cancelled or deleted. */\nexport async function closeItemsFor(subscriptionId: number, kinds?: ReviewKind[]): Promise {\n if (kinds?.length) {\n const placeholders = kinds.map(() => \"?\").join(\",\");\n await exec(\n `UPDATE review_items SET status = 'done', resolved_at = datetime('now')\n WHERE subscription_id = ? AND status = 'open' AND kind IN (${placeholders})`,\n [subscriptionId, ...kinds],\n );\n return;\n }\n await exec(\n `UPDATE review_items SET status = 'done', resolved_at = datetime('now')\n WHERE subscription_id = ? AND status = 'open'`,\n [subscriptionId],\n );\n}\n\n/**\n * Rebuild the inbox from current state. Safe to run on every cron tick.\n * Returns the items it newly created, so the digest can lead with what changed.\n */\nexport async function generateReviewItems(): Promise {\n const views = await listViews(true);\n const live = views.filter((s) => isLive(s.status));\n const base = await baseCurrency();\n const period = currentPeriod();\n const now = today();\n const createdKeys: string[] = [];\n\n // 1. Yearly renewals close enough that cancelling is still on the table.\n const soon = await upcoming(YEARLY_LEAD_DAYS, live);\n for (const charge of soon) {\n const sub = live.find((s) => s.id === charge.subscriptionId);\n if (!sub || sub.billingCycle !== \"yearly\") continue;\n const days = daysBetween(now, charge.date);\n const key = `yearly_upcoming:${sub.id}:${charge.date}`;\n const created = await addReviewItem({\n subscriptionId: sub.id,\n kind: \"yearly_upcoming\",\n title: `${sub.serviceName} renews in ${days} day${days === 1 ? \"\" : \"s\"} — ${formatMoney(sub.amountMinor, sub.currency)}`,\n detail: `Yearly renewal on ${charge.date}. That is ${formatMoney(sub.monthlyBaseMinor, base)}/month equivalent. Cancel before this date if you are not using it.`,\n dueOn: charge.date,\n dedupeKey: key,\n });\n if (created) createdKeys.push(key);\n }\n\n // 2. This month's grades, once per subscription per month.\n for (const sub of live) {\n if (!sub.ratingDue) continue;\n const key = `rating_due:${sub.id}:${period}`;\n const created = await addReviewItem({\n subscriptionId: sub.id,\n kind: \"rating_due\",\n title: `Rate ${sub.serviceName} for ${period}`,\n detail: `How good is it, and how much did you use it? ${formatMoney(sub.monthlyBaseMinor, base)}/month.`,\n dueOn: null,\n dedupeKey: key,\n });\n if (created) createdKeys.push(key);\n }\n\n // 3. Subscriptions the grades say are not worth their cost. Raised once a month\n // so a persistent low score nags again rather than being silently dismissed forever.\n for (const sub of live) {\n if (sub.verdict.band !== \"cancel_candidate\") continue;\n const key = `cancel_candidate:${sub.id}:${period}`;\n const created = await addReviewItem({\n subscriptionId: sub.id,\n kind: \"cancel_candidate\",\n title: `Decide on ${sub.serviceName} — ${formatMoney(sub.monthlyBaseMinor, base)}/month`,\n detail: sub.verdict.reason,\n dueOn: null,\n dedupeKey: key,\n });\n if (created) createdKeys.push(key);\n }\n\n // Anything raised for a subscription that has since been cancelled is moot.\n for (const sub of views) {\n if (sub.status === \"cancelled\") await closeItemsFor(sub.id);\n }\n\n if (createdKeys.length === 0) return [];\n const placeholders = createdKeys.map(() => \"?\").join(\",\");\n const rows = await query(\n `SELECT * FROM review_items WHERE dedupe_key IN (${placeholders}) ORDER BY due_on IS NULL, due_on`,\n createdKeys,\n );\n return rows.map(mapItem);\n}\n\n/**\n * Raised when a forwarded receipt creates or changes a row without being asked to.\n *\n * `variant` scopes the dedupe key: a subscription is only ever confirmed once as\n * new, but each price change is its own decision and must not be swallowed by the\n * key of an earlier, already-resolved confirmation.\n */\nexport async function flagNewFromEmail(\n sub: SubscriptionView | { id: number; serviceName: string },\n detail: string,\n variant = \"new\",\n): Promise {\n await addReviewItem({\n subscriptionId: sub.id,\n kind: \"confirm_new\",\n title: variant === \"new\"\n ? `Confirm ${sub.serviceName} — added from a forwarded email`\n : `Confirm ${sub.serviceName} — its price changed`,\n detail,\n dueOn: null,\n dedupeKey: `confirm_new:${sub.id}:${variant}`,\n });\n}\n",[],[164,260],"96090942-2bbd-4ac2-a82e-620655f04c89","llm.ts","339aa39c-a63a-11f1-a04e-1607ee4eb77e",15,["D",1788290432914],"/**\n * The language-model side of the email assistant.\n *\n * Two jobs, deliberately kept separate:\n * extractSubscription — turn a forwarded receipt into structured fields\n * answerQuestion — answer a question about the portfolio in prose\n *\n * Routing between them is done in code, not by the model (see email/handle.ts):\n * a forward with no comment of your own is an ingest, a forward with a question\n * is a question. That keeps the common path predictable and cheap.\n *\n * Extraction uses a strict tool rather than forced tool choice, so a receipt the\n * model cannot read comes back as \"no tool call\" instead of a confidently wrong\n * row. Nothing is written to the database without a review item to confirm it.\n */\nimport Anthropic from \"npm:@anthropic-ai/sdk@^0.123.0\";\nimport type { BillingCycle, Currency } from \"../shared/types.ts\";\n\nconst MODEL = \"claude-opus-5\";\n\nlet client: Anthropic | null = null;\n\nexport function apiKey(): string | undefined {\n return Deno.env.get(\"ANTHROPIC_API_KEY\") ?? undefined;\n}\n\nexport function isConfigured(): boolean {\n return Boolean(apiKey());\n}\n\nfunction getClient(): Anthropic {\n const key = apiKey();\n if (!key) throw new Error(\"ANTHROPIC_API_KEY is not set\");\n client ??= new Anthropic({ apiKey: key });\n return client;\n}\n\nexport interface ExtractedSubscription {\n serviceName: string;\n planName: string | null;\n amount: number;\n currency: Currency;\n billingCycle: BillingCycle;\n chargedOn: string | null;\n nextChargeOn: string | null;\n category: string | null;\n /** 0..1 — how sure the model is that this really is a subscription receipt. */\n confidence: number;\n notes: string | null;\n}\n\nconst EXTRACT_TOOL: Anthropic.Tool = {\n name: \"record_subscription\",\n description:\n \"Record the subscription described by a payment confirmation, invoice or renewal notice. \" +\n \"Call this only when the email really is about a recurring paid subscription.\",\n strict: true,\n input_schema: {\n type: \"object\",\n properties: {\n service_name: {\n type: \"string\",\n description: \"The product or vendor being paid for, e.g. 'Netflix', 'Figma', 'iCloud+'. No plan or tier.\",\n },\n plan_name: {\n type: [\"string\", \"null\"],\n description: \"The tier or plan, e.g. 'Professional', 'Family', '2TB'. Null if not stated.\",\n },\n amount: {\n type: \"number\",\n description: \"The amount charged, in major units (e.g. 49.99). Use the total actually paid, including tax.\",\n },\n currency: { type: \"string\", enum: [\"PLN\", \"USD\", \"EUR\"] },\n billing_cycle: {\n type: \"string\",\n enum: [\"monthly\", \"yearly\"],\n description: \"Infer from wording like 'per month', 'annual', 'renews yearly'. Guess monthly if truly unclear.\",\n },\n charged_on: {\n type: [\"string\", \"null\"],\n description: \"ISO date (YYYY-MM-DD) this payment was taken, if the email states it. Null otherwise.\",\n },\n next_charge_on: {\n type: [\"string\", \"null\"],\n description: \"ISO date (YYYY-MM-DD) of the next renewal, if the email states it. Null otherwise.\",\n },\n category: {\n type: [\"string\", \"null\"],\n description: \"One short category, e.g. 'Entertainment', 'Software', 'Cloud', 'Health', 'News'.\",\n },\n confidence: {\n type: \"number\",\n description: \"0 to 1. How confident you are that this email is a real subscription charge.\",\n },\n notes: {\n type: [\"string\", \"null\"],\n description: \"Anything useful that does not fit the fields above, in one short sentence.\",\n },\n },\n required: [\n \"service_name\",\n \"plan_name\",\n \"amount\",\n \"currency\",\n \"billing_cycle\",\n \"charged_on\",\n \"next_charge_on\",\n \"category\",\n \"confidence\",\n \"notes\",\n ],\n additionalProperties: false,\n },\n};\n\nconst EXTRACT_SYSTEM = `You read forwarded emails and pull out subscription payment details.\n\nRules:\n- Call record_subscription only for a genuine recurring paid subscription: a receipt,\n invoice, renewal notice, trial-converting-to-paid notice, or price-change notice.\n- Do NOT call it for marketing mail, one-off purchases, shipping notifications,\n password resets, or free-plan signups. Say so in plain text instead.\n- The amount is what was actually charged, including tax, in the currency shown.\n- Dates must be ISO YYYY-MM-DD. If the email gives a date without a year, use the\n year that makes it closest to the email's own date.\n- Never invent a price or a date. Use null where the email does not say.`;\n\n/** Returns null when the email is not a subscription receipt, or the model declined to say. */\nexport async function extractSubscription(\n emailText: string,\n context: { subject?: string | null; from?: string; receivedOn: string },\n): Promise {\n const res = await getClient().messages.create({\n model: MODEL,\n max_tokens: 4000,\n system: EXTRACT_SYSTEM,\n output_config: { effort: \"low\" },\n tools: [EXTRACT_TOOL],\n messages: [{\n role: \"user\",\n content: [\n `Email received on ${context.receivedOn}.`,\n `From: ${context.from ?? \"(unknown)\"}`,\n `Subject: ${context.subject ?? \"(none)\"}`,\n \"\",\n emailText.slice(0, 40_000),\n ].join(\"\\n\"),\n }],\n });\n\n const call = res.content.find((b): b is Anthropic.ToolUseBlock => b.type === \"tool_use\");\n if (!call) return null;\n\n const raw = call.input as Record;\n const amount = Number(raw.amount);\n if (!Number.isFinite(amount) || amount <= 0) return null;\n\n return {\n serviceName: String(raw.service_name ?? \"\").trim(),\n planName: nullableString(raw.plan_name),\n amount,\n currency: (String(raw.currency ?? \"PLN\").toUpperCase() as Currency),\n billingCycle: (raw.billing_cycle === \"yearly\" ? \"yearly\" : \"monthly\") as BillingCycle,\n chargedOn: isoOrNull(raw.charged_on),\n nextChargeOn: isoOrNull(raw.next_charge_on),\n category: nullableString(raw.category),\n confidence: clamp01(Number(raw.confidence ?? 0.5)),\n notes: nullableString(raw.notes),\n };\n}\n\nconst ANSWER_SYSTEM = `You are a subscription assistant answering by email. You are given the\nuser's full subscription data as JSON and one question.\n\n- Answer only from the data given. If it does not contain the answer, say so.\n- Money: state the currency. Amounts in the JSON are in minor units (grosze/cents),\n so divide by 100 before quoting them. \"base\" figures are already converted to the\n user's base currency.\n- Be direct and short — this is an email reply, not a report. A few sentences, or a\n compact list. No preamble, no sign-off, no markdown tables.\n- When the question is about whether to keep something, use the quality and usage\n grades and say what the numbers imply, plainly.`;\n\n/** Free-text answer to a question about the portfolio. `data` is serialised for the model. */\nexport async function answerQuestion(question: string, data: unknown): Promise {\n const res = await getClient().messages.create({\n model: MODEL,\n max_tokens: 4000,\n system: ANSWER_SYSTEM,\n output_config: { effort: \"medium\" },\n messages: [{\n role: \"user\",\n content: [\n \"Here is the current subscription data:\",\n \"```json\",\n JSON.stringify(data),\n \"```\",\n \"\",\n `Question: ${question}`,\n ].join(\"\\n\"),\n }],\n });\n\n return res.content\n .filter((b): b is Anthropic.TextBlock => b.type === \"text\")\n .map((b) => b.text)\n .join(\"\\n\")\n .trim();\n}\n\nfunction nullableString(v: unknown): string | null {\n if (v == null) return null;\n const s = String(v).trim();\n return s === \"\" || s.toLowerCase() === \"null\" ? null : s;\n}\n\nfunction isoOrNull(v: unknown): string | null {\n const s = nullableString(v);\n return s && /^\\d{4}-\\d{2}-\\d{2}$/.test(s) ? s : null;\n}\n\nfunction clamp01(n: number): number {\n return Number.isFinite(n) ? Math.max(0, Math.min(1, n)) : 0.5;\n}\n",[],[164,268],"bf058df2-d80c-4014-8b09-6de809d41230","links.ts","307888b4-a63a-11f1-9502-1607ee4eb77e",14,["D",1788290427631],"/**\n * Where the dashboard lives.\n *\n * Val Town assigns the endpoint URL, so it is not knowable at authoring time.\n * `APP_URL` is set once after the first deploy (the create/list-files response\n * carries `links.endpoint`); until then, emails simply omit their links rather\n * than pointing somewhere wrong.\n */\nexport function dashboardUrl(path = \"\"): string | null {\n const base = Deno.env.get(\"APP_URL\")?.replace(/\\/+$/, \"\");\n if (!base) return null;\n return path ? `${base}${path.startsWith(\"/\") ? path : `/${path}`}` : base;\n}\n\n/** A \"→ open the dashboard\" line, or nothing when the URL is not configured yet. */\nexport function linkLine(label: string, path = \"\"): string {\n const url = dashboardUrl(path);\n return url ? `${label}: ${url}` : \"\";\n}\n",[],[164,276],"9581af13-d37b-4ddf-9fdd-16951baa2f9d","fx.ts","2d738448-a63a-11f1-b6f5-1607ee4eb77e",13,["D",1788290422584],"/**\n * Currency conversion.\n *\n * Everything is stored in the currency it is actually billed in; conversion is a\n * presentation concern, applied when we roll costs up into one number. Rates come\n * from Frankfurter (ECB reference rates, no API key), are cached in `fx_rates` for\n * the day, and fall back to the last cached value if the fetch fails — a stale\n * rate is a far better answer than a broken dashboard.\n *\n * Historical charges store the rate that applied on the day they were recorded,\n * so past spending is never silently re-priced when the zloty moves.\n */\nimport type { Currency } from \"../shared/types.ts\";\nimport { CURRENCIES } from \"../shared/types.ts\";\nimport { today } from \"../shared/money.ts\";\nimport { exec, getSetting, num, query, str } from \"./db.ts\";\n\nconst API = \"https://api.frankfurter.app/latest\";\n\n/** Last-resort rates so a first run with no network still renders something sane. */\nconst FALLBACK: Record> = {\n PLN: { PLN: 1, USD: 4.0, EUR: 4.3 },\n USD: { PLN: 0.25, USD: 1, EUR: 1.08 },\n EUR: { PLN: 0.23, USD: 0.93, EUR: 1 },\n};\n\nexport async function baseCurrency(): Promise {\n const fromEnv = Deno.env.get(\"BASE_CURRENCY\");\n const stored = fromEnv ?? (await getSetting(\"base_currency\"));\n const candidate = (stored ?? \"PLN\").toUpperCase() as Currency;\n return CURRENCIES.includes(candidate) ? candidate : \"PLN\";\n}\n\n/** How many units of `base` one unit of each currency is worth. */\nexport type RateTable = Record;\n\nlet memo: { base: Currency; day: string; table: RateTable } | null = null;\n\nexport async function getRates(base?: Currency): Promise {\n const target = base ?? (await baseCurrency());\n const day = today();\n if (memo && memo.base === target && memo.day === day) return memo.table;\n\n const cached = await readCache(target);\n if (cached && cached.asOf === day) {\n memo = { base: target, day, table: cached.table };\n return cached.table;\n }\n\n let table: RateTable;\n try {\n table = await fetchRates(target);\n await writeCache(target, table, day);\n } catch (err) {\n console.error(\"fx: falling back to cached/static rates:\", err);\n table = cached?.table ?? { ...FALLBACK[target] };\n }\n\n memo = { base: target, day, table };\n return table;\n}\n\nasync function fetchRates(base: Currency): Promise {\n const others = CURRENCIES.filter((c) => c !== base);\n // Frankfurter answers \"1 base = N quote\"; we want the inverse, \"1 quote = N base\".\n const res = await fetch(`${API}?base=${base}&symbols=${others.join(\",\")}`);\n if (!res.ok) throw new Error(`frankfurter ${res.status}`);\n const body = await res.json() as { rates?: Record };\n const table = { [base]: 1 } as RateTable;\n for (const c of others) {\n const perBase = body.rates?.[c];\n if (!perBase || perBase <= 0) throw new Error(`missing rate for ${c}`);\n table[c] = 1 / perBase;\n }\n return table;\n}\n\nasync function readCache(base: Currency): Promise<{ table: RateTable; asOf: string } | null> {\n const rows = await query(\"SELECT quote, rate, as_of FROM fx_rates WHERE base = ?\", [base]);\n if (rows.length === 0) return null;\n const table = { [base]: 1 } as RateTable;\n let asOf = \"\";\n for (const r of rows) {\n table[str(r.quote) as Currency] = num(r.rate);\n const rowDate = str(r.as_of) ?? \"\";\n if (!asOf || rowDate < asOf) asOf = rowDate; // oldest row decides freshness\n }\n for (const c of CURRENCIES) if (table[c] === undefined) return null;\n return { table, asOf };\n}\n\nasync function writeCache(base: Currency, table: RateTable, asOf: string): Promise {\n for (const quote of CURRENCIES) {\n await exec(\n `INSERT INTO fx_rates (quote, base, rate, as_of) VALUES (?, ?, ?, ?)\n ON CONFLICT(quote, base) DO UPDATE SET rate = excluded.rate, as_of = excluded.as_of`,\n [quote, base, table[quote], asOf],\n );\n }\n}\n\n/** Convert minor units between currencies using a table keyed to the base. */\nexport function convertMinor(amountMinor: number, from: Currency, table: RateTable): number {\n return Math.round(amountMinor * (table[from] ?? 1));\n}\n\nexport function rateFor(from: Currency, table: RateTable): number {\n return table[from] ?? 1;\n}\n\n/** Called by the daily cron so the dashboard's first hit of the day is already warm. */\nexport async function refreshRates(): Promise {\n memo = null;\n const base = await baseCurrency();\n const table = await fetchRates(base);\n await writeCache(base, table, today());\n memo = { base, day: today(), table };\n return table;\n}\n",[],[164,284],"a39cdcec-6a39-4209-8d1c-252792a079bf","db.ts","2a7cf6de-a63a-11f1-a04e-1607ee4eb77e",12,["D",1788290417591],"/**\n * Schema and connection for the subscription tracker.\n *\n * Shape of the model, in one paragraph: a `service` is the thing you buy from\n * (Netflix, Figma). A `subscription` is one billing arrangement for that service\n * — its price, currency, cycle and status. Prices change and plans get switched,\n * so a service can own several subscriptions over time while only one is live.\n * `charges` are payments that really happened; everything in the future is\n * projected on the fly from `next_charge_on` rather than stored, so a price\n * change never leaves stale rows behind. `ratings` hold the two monthly grades,\n * `review_items` is the actionable inbox, and `inbound_emails` is the audit log\n * that also gives us idempotency against a mail server delivering twice.\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport { sqlite };\n\nexport type Row = Record;\n\nconst SCHEMA = [\n `CREATE TABLE IF NOT EXISTS services (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n name_key TEXT NOT NULL UNIQUE,\n vendor_domain TEXT,\n category TEXT,\n notes TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n\n `CREATE TABLE IF NOT EXISTS subscriptions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n service_id INTEGER NOT NULL REFERENCES services(id) ON DELETE CASCADE,\n plan_name TEXT,\n amount_minor INTEGER NOT NULL CHECK (amount_minor >= 0),\n currency TEXT NOT NULL CHECK (currency IN ('PLN','USD','EUR')),\n billing_cycle TEXT NOT NULL CHECK (billing_cycle IN ('monthly','yearly')),\n started_on TEXT,\n next_charge_on TEXT,\n status TEXT NOT NULL DEFAULT 'active'\n CHECK (status IN ('active','trial','paused','cancelled')),\n cancelled_on TEXT,\n cancel_reason TEXT,\n payment_method TEXT,\n auto_renew INTEGER NOT NULL DEFAULT 1,\n source TEXT NOT NULL DEFAULT 'manual' CHECK (source IN ('manual','email')),\n notes TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n\n `CREATE TABLE IF NOT EXISTS ratings (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n subscription_id INTEGER NOT NULL REFERENCES subscriptions(id) ON DELETE CASCADE,\n period TEXT NOT NULL,\n quality INTEGER NOT NULL CHECK (quality BETWEEN 1 AND 5),\n usage INTEGER NOT NULL CHECK (usage BETWEEN 1 AND 5),\n note TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n UNIQUE (subscription_id, period)\n )`,\n\n `CREATE TABLE IF NOT EXISTS review_items (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n subscription_id INTEGER REFERENCES subscriptions(id) ON DELETE CASCADE,\n kind TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'open' CHECK (status IN ('open','done','dismissed')),\n title TEXT NOT NULL,\n detail TEXT,\n due_on TEXT,\n dedupe_key TEXT UNIQUE,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n resolved_at TEXT\n )`,\n\n `CREATE TABLE IF NOT EXISTS inbound_emails (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT UNIQUE,\n from_addr TEXT NOT NULL,\n subject TEXT,\n body TEXT,\n intent TEXT NOT NULL DEFAULT 'unknown',\n handled INTEGER NOT NULL DEFAULT 0,\n result TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n\n `CREATE TABLE IF NOT EXISTS charges (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n subscription_id INTEGER NOT NULL REFERENCES subscriptions(id) ON DELETE CASCADE,\n charged_on TEXT NOT NULL,\n amount_minor INTEGER NOT NULL,\n currency TEXT NOT NULL,\n base_minor INTEGER NOT NULL,\n fx_rate REAL NOT NULL DEFAULT 1,\n source TEXT NOT NULL DEFAULT 'manual',\n inbound_email_id INTEGER REFERENCES inbound_emails(id),\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n UNIQUE (subscription_id, charged_on, amount_minor)\n )`,\n\n `CREATE TABLE IF NOT EXISTS fx_rates (\n quote TEXT NOT NULL,\n base TEXT NOT NULL,\n rate REAL NOT NULL,\n as_of TEXT NOT NULL,\n PRIMARY KEY (quote, base)\n )`,\n\n `CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )`,\n\n `CREATE INDEX IF NOT EXISTS idx_sub_status ON subscriptions(status)`,\n `CREATE INDEX IF NOT EXISTS idx_sub_service ON subscriptions(service_id)`,\n `CREATE INDEX IF NOT EXISTS idx_sub_next ON subscriptions(next_charge_on)`,\n `CREATE INDEX IF NOT EXISTS idx_charge_sub ON charges(subscription_id, charged_on)`,\n `CREATE INDEX IF NOT EXISTS idx_charge_date ON charges(charged_on)`,\n `CREATE INDEX IF NOT EXISTS idx_rating_sub ON ratings(subscription_id, period)`,\n `CREATE INDEX IF NOT EXISTS idx_review_status ON review_items(status, due_on)`,\n];\n\n/**\n * Columns added after the first release. Each runs on its own and swallows the\n * \"duplicate column\" error, so a fresh database (which already has them from\n * SCHEMA) and an existing one both end up in the same shape.\n */\nconst MIGRATIONS: string[] = [];\n\nlet schemaReady: Promise | null = null;\n\n/** Idempotent, and memoised per isolate so a burst of requests sets up once. */\nexport function ensureSchema(): Promise {\n schemaReady ??= (async () => {\n for (const stmt of SCHEMA) await sqlite.execute(stmt);\n for (const stmt of MIGRATIONS) {\n try {\n await sqlite.execute(stmt);\n } catch (err) {\n const msg = String(err);\n if (!msg.includes(\"duplicate column\") && !msg.includes(\"already exists\")) throw err;\n }\n }\n })().catch((err) => {\n schemaReady = null; // let the next caller retry rather than caching a failure\n throw err;\n });\n return schemaReady;\n}\n\n/** Run a query, making sure the schema exists first. */\nexport async function query(sql: string, args: unknown[] = []): Promise {\n await ensureSchema();\n const res = await sqlite.execute({ sql, args: args as never });\n return res.rows as unknown as Row[];\n}\n\nexport async function exec(sql: string, args: unknown[] = []): Promise<{ rowsAffected: number; lastInsertRowid: number | null }> {\n await ensureSchema();\n const res = await sqlite.execute({ sql, args: args as never });\n return {\n rowsAffected: Number(res.rowsAffected ?? 0),\n lastInsertRowid: res.lastInsertRowid == null ? null : Number(res.lastInsertRowid),\n };\n}\n\nexport async function queryOne(sql: string, args: unknown[] = []): Promise {\n const rows = await query(sql, args);\n return rows[0] ?? null;\n}\n\n// --- small coercions, because libsql hands back `unknown` -------------------\n\nexport function str(v: unknown): string | null {\n return v == null ? null : String(v);\n}\n\nexport function num(v: unknown): number {\n return Number(v ?? 0);\n}\n\nexport function bool(v: unknown): boolean {\n return Number(v ?? 0) !== 0;\n}\n\n/** Normalised key used to match \"Netflix \", \"netflix\" and \"NETFLIX\" to one service. */\nexport function nameKey(name: string): string {\n return name.trim().toLowerCase().replace(/\\s+/g, \" \");\n}\n\n// --- settings ---------------------------------------------------------------\n\nexport async function getSetting(key: string): Promise {\n const row = await queryOne(\"SELECT value FROM settings WHERE key = ?\", [key]);\n return row ? str(row.value) : null;\n}\n\nexport async function setSetting(key: string, value: string): Promise {\n await exec(\n \"INSERT INTO settings (key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value\",\n [key, value],\n );\n}\n",[],[164,292],"528c8e8b-fc85-479f-a0b5-8bda69bf1d53","analytics.ts","4d38434a-a63a-11f1-81dd-1607ee4eb77e",17,["D",1788290475855],"/**\n * Forecasts, history and savings.\n *\n * Two different questions get two different numbers, and conflating them is the\n * usual reason subscription trackers feel wrong:\n *\n * run rate — every live subscription reduced to a monthly average (a yearly\n * plan divided by twelve). Answers \"what does my current set of\n * subscriptions cost me a month\".\n * calendar — each subscription's real charge dates walked forward. Answers\n * \"what leaves my account in March\", which is where the yearly\n * renewals you did not see coming actually show up.\n */\nimport type { Currency, MonthBucket, ProjectedCharge, Summary, SubscriptionView } from \"../shared/types.ts\";\nimport { isLive } from \"../shared/types.ts\";\nimport { bucketByMonth, projectCharges } from \"../shared/forecast.ts\";\nimport { addDays, daysBetween, monthlyEquivalentMinor, periodOf, shiftPeriod, today } from \"../shared/money.ts\";\nimport { listViews } from \"./subscriptions.ts\";\nimport { baseCurrency, convertMinor, getRates } from \"./fx.ts\";\nimport { num, query, str } from \"./db.ts\";\n\n/** Average days in a month — used to prorate a partial month of savings. */\nconst DAYS_PER_MONTH = 30.4375;\n\nexport { bucketByMonth, projectCharges };\n\nexport interface Forecast {\n baseCurrency: Currency;\n months: MonthBucket[];\n totalBaseMinor: number;\n}\n\nexport async function forecast(months = 12, subs?: SubscriptionView[]): Promise {\n const views = subs ?? (await listViews(false));\n const start = today();\n // Last day of the final month in the window, so a charge on the 31st still counts.\n const until = addDays(shiftPeriod(periodOf(start), months) + \"-01\", -1);\n const charges = projectCharges(views, { from: start, until });\n const buckets = bucketByMonth(charges, periodOf(start), months);\n return {\n baseCurrency: await baseCurrency(),\n months: buckets,\n totalBaseMinor: buckets.reduce((sum, b) => sum + b.baseMinor, 0),\n };\n}\n\n/** Charges that already happened, grouped by month — the historical counterpart to forecast(). */\nexport async function history(months = 12): Promise<{ period: string; baseMinor: number; count: number }[]> {\n const from = shiftPeriod(periodOf(today()), -(months - 1)) + \"-01\";\n const rows = await query(\n `SELECT substr(charged_on, 1, 7) AS period,\n SUM(base_minor) AS total,\n COUNT(*) AS n\n FROM charges\n WHERE charged_on >= ?\n GROUP BY period\n ORDER BY period`,\n [from],\n );\n const found = new Map(rows.map((r) => [str(r.period) ?? \"\", { total: num(r.total), n: num(r.n) }]));\n const out: { period: string; baseMinor: number; count: number }[] = [];\n for (let i = months - 1; i >= 0; i--) {\n const period = shiftPeriod(periodOf(today()), -i);\n const hit = found.get(period);\n out.push({ period, baseMinor: hit?.total ?? 0, count: hit?.n ?? 0 });\n }\n return out;\n}\n\nexport interface Saving {\n subscriptionId: number;\n serviceName: string;\n cancelledOn: string;\n monthlyBaseMinor: number;\n monthsSince: number;\n savedBaseMinor: number;\n reason: string | null;\n}\n\n/**\n * What cancelling bought you. Each cancelled subscription keeps counting from the\n * day it stopped: its monthly equivalent times the months since. That is money not\n * spent, which is the only honest way to score a cancellation.\n */\nexport async function savings(): Promise<{ items: Saving[]; totalBaseMinor: number; perMonthBaseMinor: number }> {\n const [views, rates] = await Promise.all([listViews(true), getRates()]);\n const now = today();\n const items: Saving[] = [];\n\n for (const s of views) {\n if (s.status !== \"cancelled\" || !s.cancelledOn) continue;\n const monthlyBase = convertMinor(monthlyEquivalentMinor(s.amountMinor, s.billingCycle), s.currency, rates);\n const monthsSince = Math.max(0, daysBetween(s.cancelledOn, now) / DAYS_PER_MONTH);\n items.push({\n subscriptionId: s.id,\n serviceName: s.serviceName,\n cancelledOn: s.cancelledOn,\n monthlyBaseMinor: monthlyBase,\n monthsSince: Math.round(monthsSince * 10) / 10,\n savedBaseMinor: Math.round(monthlyBase * monthsSince),\n reason: s.cancelReason,\n });\n }\n\n items.sort((a, b) => b.savedBaseMinor - a.savedBaseMinor);\n return {\n items,\n totalBaseMinor: items.reduce((sum, i) => sum + i.savedBaseMinor, 0),\n perMonthBaseMinor: items.reduce((sum, i) => sum + i.monthlyBaseMinor, 0),\n };\n}\n\nexport async function summary(subs?: SubscriptionView[]): Promise

{\n const views = subs ?? (await listViews(true));\n const live = views.filter((s) => isLive(s.status));\n const base = await baseCurrency();\n\n const monthlyRunRate = live.reduce((sum, s) => sum + s.monthlyBaseMinor, 0);\n\n const start = today();\n const next30 = projectCharges(live, { from: start, until: addDays(start, 30) })\n .reduce((sum, c) => sum + c.baseMinor, 0);\n const next12 = (await forecast(12, live)).totalBaseMinor;\n\n const saved = await savings();\n const openReviews = await query(\"SELECT COUNT(*) AS n FROM review_items WHERE status = 'open'\");\n\n return {\n baseCurrency: base,\n monthlyRunRateBaseMinor: monthlyRunRate,\n yearlyRunRateBaseMinor: monthlyRunRate * 12,\n next30DaysBaseMinor: next30,\n next12MonthsBaseMinor: next12,\n activeCount: live.length,\n monthlyCount: live.filter((s) => s.billingCycle === \"monthly\").length,\n yearlyCount: live.filter((s) => s.billingCycle === \"yearly\").length,\n savedToDateBaseMinor: saved.totalBaseMinor,\n savedPerMonthBaseMinor: saved.perMonthBaseMinor,\n openReviewCount: num(openReviews[0]?.n),\n ratingDueCount: live.filter((s) => s.ratingDue).length,\n };\n}\n\n/** Live subscriptions charging within `days`, soonest first — drives reminders. */\nexport async function upcoming(days: number, subs?: SubscriptionView[]): Promise {\n const views = (subs ?? (await listViews(false))).filter((s) => isLive(s.status));\n const start = today();\n return projectCharges(views, { from: start, until: addDays(start, days) });\n}\n\n/** Spend split by category, for the \"what am I actually paying for\" question. */\nexport async function byCategory(subs?: SubscriptionView[]): Promise<{ category: string; baseMinor: number; count: number }[]> {\n const views = (subs ?? (await listViews(false))).filter((s) => isLive(s.status));\n const totals = new Map();\n for (const s of views) {\n const key = s.category ?? \"Uncategorised\";\n const hit = totals.get(key) ?? { baseMinor: 0, count: 0 };\n hit.baseMinor += s.monthlyBaseMinor;\n hit.count++;\n totals.set(key, hit);\n }\n return [...totals.entries()]\n .map(([category, v]) => ({ category, ...v }))\n .sort((a, b) => b.baseMinor - a.baseMinor);\n}\n",[],[164,300],"948b2484-ed32-432f-8737-34985463e663","d1f39aa4-a639-11f1-b6a1-1607ee4eb77e",["D",1788290489391],[],[164,312,32],"email","b50b9b6f-ee70-4912-97ec-9367306d6a43","parse.ts","526791b8-a63a-11f1-9057-1607ee4eb77e",19,["D",1788290484581],"/**\n * Reading an inbound email before the model sees it.\n *\n * The routing rule is the one from the brief: forward a confirmation with nothing\n * of your own on top and it gets tracked; add a line of your own and that line is\n * treated as an instruction or a question. So the first job here is separating\n * *your* words from the forwarded message underneath — quoting styles, \"On … wrote:\"\n * headers, and phone signatures all have to come off before \"did they write\n * anything?\" can be answered honestly.\n */\nimport type { BillingCycle, Currency } from \"../../shared/types.ts\";\n\n/** Markers that begin a quoted or forwarded section. Everything from here down is not yours. */\nconst FORWARD_MARKERS = [\n /^-{2,}\\s*Forwarded message\\s*-{2,}/im,\n /^Begin forwarded message:/im,\n /^-{2,}\\s*Original Message\\s*-{2,}/im,\n /^-{2,}\\s*Wiadomość oryginalna\\s*-{2,}/im,\n /^Przekazana wiadomość/im,\n /^On .{3,80}\\bwrote:$/im,\n /^W dniu .{3,80}\\bnapisał/im,\n /^From:\\s*.+$/im,\n /^Od:\\s*.+$/im,\n /^Sent:\\s*.+$/im,\n];\n\n/** Trailing noise that is not a comment even though it is text. */\nconst SIGNATURE_MARKERS = [\n /^--\\s*$/m,\n /^Sent from my \\w+/im,\n /^Wysłane z /im,\n /^Get Outlook for /im,\n /^Pozdrawiam[,!.]?\\s*$/im,\n /^Regards[,!.]?\\s*$/im,\n /^Best[,!.]?\\s*$/im,\n];\n\nexport interface SplitEmail {\n /** What the sender typed themselves, above the forward. May be empty. */\n comment: string;\n /** The forwarded/quoted body — the receipt itself. */\n quoted: string;\n /** True when the sender wrote something of their own worth acting on. */\n hasComment: boolean;\n}\n\nexport function splitEmail(bodyRaw: string): SplitEmail {\n const body = normalise(bodyRaw);\n\n // Earliest forward marker wins; text above it is the sender's own.\n let cut = body.length;\n for (const marker of FORWARD_MARKERS) {\n const m = marker.exec(body);\n if (m && m.index < cut) cut = m.index;\n }\n\n let comment = body.slice(0, cut);\n const quoted = body.slice(cut);\n\n comment = stripSignature(comment);\n // Quote-prefixed lines are part of the forward even above the marker.\n comment = comment.split(\"\\n\").filter((l) => !/^\\s*>/.test(l)).join(\"\\n\").trim();\n\n return { comment, quoted: quoted.trim(), hasComment: isMeaningful(comment) };\n}\n\nfunction normalise(s: string): string {\n return (s ?? \"\").replace(/\\r\\n/g, \"\\n\").replace(/ /g, \" \").trim();\n}\n\nfunction stripSignature(s: string): string {\n let out = s;\n for (const marker of SIGNATURE_MARKERS) {\n const m = marker.exec(out);\n if (m) out = out.slice(0, m.index);\n }\n return out.trim();\n}\n\n/**\n * Two characters of punctuation or a stray \"fyi\" is not an instruction. Require a\n * couple of real words before treating a forward as anything other than an ingest.\n */\nfunction isMeaningful(comment: string): boolean {\n const cleaned = comment.replace(/[^\\p{L}\\p{N}?]+/gu, \" \").trim();\n if (cleaned.length < 3) return false;\n const words = cleaned.split(/\\s+/).filter((w) => w.length > 1);\n if (words.length === 0) return false;\n // A single \"fyi\"/\"forwarding\" style word is noise, not a comment.\n const noise = new Set([\"fyi\", \"fw\", \"fwd\", \"forward\", \"forwarding\", \"przekazuję\", \"dzieki\", \"dzięki\", \"thanks\", \"ok\"]);\n return !(words.length === 1 && noise.has(words[0].toLowerCase()));\n}\n\n// ---------------------------------------------------------------------------\n// Commands — a small deterministic language so the frequent actions never cost an\n// API call and never depend on the model reading your intent correctly.\n// ---------------------------------------------------------------------------\n\nexport type Command =\n | { kind: \"list\" }\n | { kind: \"forecast\"; months: number }\n | { kind: \"upcoming\"; days: number }\n | { kind: \"savings\" }\n | { kind: \"review\" }\n | { kind: \"help\" }\n | { kind: \"cancel\"; service: string; reason: string | null }\n | { kind: \"keep\"; service: string }\n | { kind: \"rate\"; service: string; quality: number; usage: number; note: string | null }\n | { kind: \"add\"; service: string; amount: number; currency: Currency; cycle: BillingCycle };\n\nconst CURRENCY_WORDS: Record = {\n pln: \"PLN\", zł: \"PLN\", zl: \"PLN\", \"zł.\": \"PLN\",\n usd: \"USD\", $: \"USD\", dollar: \"USD\", dollars: \"USD\",\n eur: \"EUR\", \"€\": \"EUR\", euro: \"EUR\", euros: \"EUR\",\n};\n\nexport function parseCommand(text: string): Command | null {\n const line = text.trim().split(\"\\n\")[0]?.trim() ?? \"\";\n if (!line) return null;\n const lower = line.toLowerCase();\n\n if (/^(list|subs|subscriptions|lista)\\b/.test(lower)) return { kind: \"list\" };\n if (/^(savings|saved|oszczędności)\\b/.test(lower)) return { kind: \"savings\" };\n if (/^(review|inbox|todo|decisions)\\b/.test(lower)) return { kind: \"review\" };\n if (/^(help|pomoc|\\?)$/.test(lower)) return { kind: \"help\" };\n\n const forecast = /^(forecast|prognoza)(?:\\s+(\\d{1,2}))?\\b/.exec(lower);\n if (forecast) return { kind: \"forecast\", months: clampInt(forecast[2], 12, 1, 24) };\n\n const up = /^(upcoming|next)(?:\\s+(\\d{1,3}))?\\b/.exec(lower);\n if (up) return { kind: \"upcoming\", days: clampInt(up[2], 30, 1, 365) };\n\n const cancel = /^(?:cancel|anuluj|cancelled)\\s+(.+)$/i.exec(line);\n if (cancel) {\n const [service, reason] = splitOnce(cancel[1], /\\s+(?:because|bo|reason:)\\s+/i);\n return { kind: \"cancel\", service: service.trim(), reason: reason?.trim() ?? null };\n }\n\n const keep = /^(?:keep|zostaw)\\s+(.+)$/i.exec(line);\n if (keep) return { kind: \"keep\", service: keep[1].trim() };\n\n // rate [note]\n const rate = /^(?:rate|oceń|ocen)\\s+(.+?)\\s+([1-5])\\s*[\\/, ]\\s*([1-5])\\s*(.*)$/i.exec(line);\n if (rate) {\n return {\n kind: \"rate\",\n service: rate[1].trim(),\n quality: Number(rate[2]),\n usage: Number(rate[3]),\n note: rate[4]?.trim() || null,\n };\n }\n\n // add \n const add = /^(?:add|dodaj)\\s+(.+?)\\s+([\\d.,]+)\\s*([a-zA-Z€$złZŁ]+)\\s+(monthly|yearly|miesięcznie|rocznie|month|year)\\b/i.exec(line);\n if (add) {\n const currency = CURRENCY_WORDS[add[3].toLowerCase()] ?? \"PLN\";\n const cycle: BillingCycle = /^(yearly|rocznie|year)$/i.test(add[4]) ? \"yearly\" : \"monthly\";\n const amount = parseAmount(add[2]);\n if (amount != null) return { kind: \"add\", service: add[1].trim(), amount, currency, cycle };\n }\n\n return null;\n}\n\nfunction clampInt(raw: string | undefined, fallback: number, min: number, max: number): number {\n const n = raw ? Number(raw) : fallback;\n return Number.isFinite(n) ? Math.max(min, Math.min(max, Math.round(n))) : fallback;\n}\n\nfunction splitOnce(s: string, re: RegExp): [string, string | null] {\n const m = re.exec(s);\n if (!m) return [s, null];\n return [s.slice(0, m.index), s.slice(m.index + m[0].length)];\n}\n\n/** \"1 234,56\" and \"1,234.56\" both mean the same thing. Decide by the last separator. */\nexport function parseAmount(raw: string): number | null {\n const cleaned = raw.replace(/[^\\d.,]/g, \"\");\n if (!cleaned) return null;\n const lastComma = cleaned.lastIndexOf(\",\");\n const lastDot = cleaned.lastIndexOf(\".\");\n let normalised: string;\n if (lastComma > lastDot) {\n normalised = cleaned.replace(/\\./g, \"\").replace(\",\", \".\");\n } else {\n normalised = cleaned.replace(/,/g, \"\");\n }\n const n = Number(normalised);\n return Number.isFinite(n) && n > 0 ? n : null;\n}\n\n// ---------------------------------------------------------------------------\n// Heuristic extraction — used when no API key is configured, and as a sanity\n// check on what the model returns.\n// ---------------------------------------------------------------------------\n\nexport interface HeuristicHit {\n amount: number;\n currency: Currency;\n cycle: BillingCycle | null;\n}\n\nconst AMOUNT_RE =\n /(?:(PLN|USD|EUR|zł|\\$|€)\\s*([\\d][\\d\\s.,]{0,12}\\d|\\d))|(?:([\\d][\\d\\s.,]{0,12}\\d|\\d)\\s*(PLN|USD|EUR|zł|\\$|€))/gi;\n\n/** The largest plausible money amount in the text — receipts put the total last and biggest. */\nexport function heuristicAmount(text: string): HeuristicHit | null {\n let best: HeuristicHit | null = null;\n for (const m of text.matchAll(AMOUNT_RE)) {\n const symbol = (m[1] ?? m[4] ?? \"\").toLowerCase();\n const amount = parseAmount(m[2] ?? m[3] ?? \"\");\n if (amount == null) continue;\n const currency = CURRENCY_WORDS[symbol] ?? \"PLN\";\n if (!best || amount > best.amount) best = { amount, currency, cycle: heuristicCycle(text) };\n }\n return best;\n}\n\nexport function heuristicCycle(text: string): BillingCycle | null {\n if (/\\b(year|yearly|annual|annually|rok|rocznie|roczn\\w*)\\b/i.test(text)) return \"yearly\";\n if (/\\b(month|monthly|mo\\b|miesi\\w*)\\b/i.test(text)) return \"monthly\";\n return null;\n}\n\n/** Second-level domains that are really public suffixes, so the vendor is one label further up. */\nconst PUBLIC_SLDS = new Set([\"co\", \"com\", \"org\", \"net\", \"ac\", \"gov\", \"edu\"]);\n\n/**\n * The vendor's registrable domain, used to remember which service a receipt came\n * from. Receipts arrive from every imaginable sending subdomain — mailer.netflix.com,\n * email.figma.com, billing.stripe.com — so the labels above the registrable domain\n * are dropped rather than matched against a list that will always be incomplete.\n */\nexport function senderDomain(from: string): string | null {\n const m = /@([\\w.-]+)/.exec(from ?? \"\");\n if (!m) return null;\n const labels = m[1].toLowerCase().replace(/\\.$/, \"\").split(\".\").filter(Boolean);\n if (labels.length <= 2) return labels.join(\".\") || null;\n // \"example.co.uk\" keeps three labels; \"mailer.netflix.com\" keeps two.\n const keep = PUBLIC_SLDS.has(labels[labels.length - 2]) && labels[labels.length - 1].length <= 3 ? 3 : 2;\n return labels.slice(-keep).join(\".\");\n}\n\n/** Strip a \"Fwd:\"/\"FW:\" chain down to the underlying subject. */\nexport function cleanSubject(subject: string | null | undefined): string {\n return (subject ?? \"\").replace(/^(\\s*(re|fw|fwd|odp|pd)\\s*:\\s*)+/i, \"\").trim();\n}\n",[],[164,312,314],"fa5b6689-ec81-4372-b6f9-215fd851817c",4,["D",1788290269074],[182,183],[164,312],["D",1788290265322],[181,184,185,186,187,188,189,190],[164],["D",1788290256185],["D",1789509043237],{"_99":98,"_106":-5},{"_99":98,"_100":101,"_102":-5,"_18":-5,"_103":104,"_105":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_126":367,"_368":369,"_370":371,"_372":24,"_373":24,"_374":24,"_375":58,"_376":-5,"_377":-7,"_378":-7,"_379":62,"_380":24,"_381":24,"_382":-5,"_383":24,"_384":24,"_385":24,"_386":-5},"ENV",{"_338":339,"_340":341,"_342":89,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366},"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","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v20