[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_284":285,"_286":287},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_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":57,"_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",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",48,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","test-boot.ts","latestPath","fileId","2bbe4f86-9f17-11f1-b2f6-1607ee4eb77e","name","fileType","script","content","// Smoke test: import the HTTP app (catches syntax/import errors) and hit each\n// route unauthenticated — every one should redirect to login, none should 500.\nimport handler from \"./main.ts\";\n\nconst routes = [\n \"/\", \"/ocbc\", \"/dbs\", \"/cash\", \"/all\",\n \"/ocbc/add\", \"/ocbc/review\", \"/ocbc/transactions\", \"/ocbc/import\",\n \"/dbs/add\", \"/dbs/review\", \"/dbs/transactions\", \"/dbs/import\",\n \"/bogus\", \"/bogus/review\",\n];\n\nconst out: any[] = [];\nfor (const path of routes) {\n try {\n const res = await handler(new Request(`https://x.val.run${path}`));\n out.push({ path, status: res.status, to: res.headers.get(\"location\") ?? \"\" });\n } catch (e) {\n out.push({ path, ERROR: String(e) });\n }\n}\nconsole.log(JSON.stringify(out, null, 1));\n","createdAt",["D",1787505729186],"branchVersion","branchId","8dada7df-82cd-483c-b8c3-97f8f7061b3f","id","5882322f-5326-4d08-a671-0dfe32c6ecb1","spendings-tracker",["D",1783925871877],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Personal spending tracker (SG) — email-alert capture + mobile UI","imageUrl","23bb1bdf-86c6-4322-9537-f748ea9d33ae","pinnedFileId","8a53d0a2-7e88-11f1-9f2e-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f5a3b-3cf5-77c9-ae50-24a4edd5903f","tursoName","5882322f53264d08a6710dfe32c6ecb1","tursoHostname","5882322f53264d08a6710dfe32c6ecb1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789524079207],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",50,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sherwynchan","handle","displayName","Sherwyn Chan","avatar","https://lh3.googleusercontent.com/a/ACg8ocLBaSEPUgLpRxKWEU-dXRA-hGCPXcSQNK_NaBdHdD-_sGPJQw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":279,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":280,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":281,"_82":282,"_84":283,"_86":24},"tree",[234,235,236,237,238,239,240,241,242,243,244],"files",[234,235,236,237,238,239,240,241,242,243,244],"counts",{"_223":61,"_224":225,"_226":61,"_227":228,"_229":230},"contents",[129,130,131,132,133,134,135,136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":216,"_31":217,"_29":218,"_143":-5,"_39":40,"_38":219,"_145":57,"_36":220,"_13":61,"_32":33,"_34":221,"_23":24,"_149":-5,"_26":222},{"_41":209,"_31":210,"_29":211,"_143":-5,"_39":40,"_38":212,"_145":57,"_36":213,"_13":61,"_32":33,"_34":214,"_23":24,"_149":-5,"_26":215},{"_41":201,"_31":202,"_29":203,"_143":-5,"_39":40,"_38":204,"_145":57,"_36":205,"_13":206,"_32":33,"_34":207,"_23":24,"_149":-5,"_26":208},{"_41":192,"_31":193,"_29":194,"_143":-5,"_39":40,"_38":195,"_145":57,"_36":196,"_13":197,"_32":198,"_34":199,"_23":24,"_149":-5,"_26":200},{"_41":183,"_31":184,"_29":55,"_143":-5,"_39":40,"_38":185,"_145":24,"_36":186,"_13":187,"_32":188,"_34":189,"_23":24,"_149":190,"_26":191},{"_41":175,"_31":176,"_29":177,"_143":-5,"_39":40,"_38":178,"_145":57,"_36":179,"_13":180,"_32":33,"_34":181,"_23":24,"_149":-5,"_26":182},{"_41":168,"_31":169,"_29":170,"_143":-5,"_39":40,"_38":171,"_145":57,"_36":172,"_13":61,"_32":33,"_34":173,"_23":24,"_149":-5,"_26":174},{"_41":165,"_31":27,"_29":30,"_143":-5,"_39":40,"_38":14,"_145":57,"_36":166,"_13":61,"_32":33,"_34":35,"_23":24,"_149":-5,"_26":167},{"_41":158,"_31":159,"_29":160,"_143":-5,"_39":40,"_38":161,"_145":57,"_36":162,"_13":61,"_32":33,"_34":163,"_23":24,"_149":-5,"_26":164},{"_41":151,"_31":152,"_29":153,"_143":-5,"_39":40,"_38":154,"_145":57,"_36":155,"_13":61,"_32":33,"_34":156,"_23":24,"_149":-5,"_26":157},{"_41":140,"_31":141,"_29":142,"_143":-5,"_39":40,"_38":144,"_145":57,"_36":146,"_13":147,"_32":33,"_34":148,"_23":24,"_149":-5,"_26":150},"d3769e85-7977-424c-9386-1cede683597d","test.ts","9d3410ce-7e88-11f1-be9d-1607ee4eb77e","parentId",28,"latest",["D",1787504287071],4,"// Regression harness: replays REAL stored emails through the parser.\n// Run after any parser/ingester change. No writes — read-only check.\nimport { parseAlert } from \"./parser.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst NON_TRANSACTIONAL = [\n /added to wallet/i, /digital wallet/i, /\\bPIN\\b.*(setup|reset|authenticate)/i,\n /here is a pin/i, /card (activation|activated|is on its way|delivery|replacement)/i,\n /e-?statement/i, /statement.*ready/i, /security (alert|advisory)/i,\n /password|access code|one-?time password|\\botp\\b/i,\n /profile (update|change)/i, /contact details/i, /welcome/i, /payee/i,\n];\nconst RELEVANT = [\"paynow\", \"nets qr\", \"card\", \"purchase\", \"transaction\", \"payment\", \"transfer\"];\n\nconst rows = (await sqlite.execute(\n `SELECT subject, raw_body FROM email_alerts WHERE raw_body IS NOT NULL AND raw_body != ''`,\n)).rows as any[];\n\nconst out: any[] = [];\nfor (const r of rows) {\n const subject = String(r.subject ?? \"\");\n const notice = NON_TRANSACTIONAL.some((rx) => rx.test(subject));\n const relevant = RELEVANT.some((k) => subject.toLowerCase().includes(k));\n if (notice || !relevant) {\n out.push({ subject, verdict: \"notice → skipped (correct)\" });\n continue;\n }\n try {\n const p = parseAlert(subject, String(r.raw_body));\n out.push({ subject, verdict: \"PARSED\", ...p });\n } catch (e) {\n out.push({ subject, verdict: \"FAILED\", error: String(e) });\n }\n}\nconsole.log(JSON.stringify(out, null, 1));\n","label",[141],"30912b9a-e727-4b62-9cfc-563fbf94bd4f","test-scopes.ts","1963f7c8-9f17-11f1-a2f5-1607ee4eb77e",47,["D",1787505698413],"// Verifies the account-picker scoping: every scope's queries run, and the\n// per-bank totals add up to the \"all\" total (no leaks, no double counting).\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initDb } from \"./db.ts\";\n\nawait initDb();\n\nconst SCOPES: Record = {\n all: null, ocbc: \"OCBC\", dbs: \"DBS\", cash: \"CASH\",\n};\nconst month = \"2026-08\";\nconst start = `${month}-01`, end = \"2026-09-01\";\n\nconst out: any = { accounts: [], scopes: {}, checks: [] };\nout.accounts = (await sqlite.execute(\"SELECT id, name, bank FROM accounts ORDER BY id\")).rows;\n\nlet sum = 0;\nfor (const [scope, bank] of Object.entries(SCOPES)) {\n const f = bank ? \" AND account_id IN (SELECT id FROM accounts WHERE bank=?)\" : \"\";\n const args = bank ? [start, end, bank] : [start, end];\n const spend = Number((await sqlite.execute({\n sql: `SELECT COALESCE(SUM(amount_cents),0) s FROM transactions\n WHERE direction='withdrawal' AND status='confirmed' AND txn_date>=? AND txn_date=? AND t.txn_date = {\n JAN: \"01\", FEB: \"02\", MAR: \"03\", APR: \"04\", MAY: \"05\", JUN: \"06\",\n JUL: \"07\", AUG: \"08\", SEP: \"09\", OCT: \"10\", NOV: \"11\", DEC: \"12\",\n};\n\nconst TXN_RE = /^(\\d{2}) ([A-Z]{3}) ([\\d,]+\\.\\d{2}) ([\\d,]+\\.\\d{2})(\\d{2} [A-Z]{3}) (.+)$/;\n\nconst NOISE = [\n /^OCBC Bank$/, /^65 Chulia/, /^Singapore \\d{6}$/, /^Oversea-Chinese/,\n /^Co\\. Reg/, /^Singapore dollar deposits/, /^for up to S\\$/, /^and separately insured/,\n /^Foreign currency/, /^Deposit Insurance Scheme/, /^\\d( \\d)+$/, /^STATEMENT OF ACCOUNT$/,\n /^Page \\d+ of \\d+$/, /^For enquiries/, /^our Customer Service/, /^OCBC .*Branch$/,\n /^Information$/, /^As part of our efforts/, /^statements will now be printed/,\n /^RNB/, /^Transaction$/, /^Date Date Description/, /Withdrawal Deposit Balance/,\n /^Value$/, /^OCBC FRANK ACCOUNT$/, /^Account No\\./, /\\d{4} TO \\d{1,2} [A-Z]{3} \\d{4}$/,\n /^SHERWYN/, /^\\d+[A-Z]? .*Road$/, /^#\\d{2}-\\d{2}$/, /^SINGAPORE \\d{6}$/,\n /^CHECK YOUR STATEMENT$/, /^Please check this statement/, /^we will take this statement/,\n /^UPDATING YOUR/, /^You may update/, /^the Change of address/, /^OCBC PROMOTION/,\n];\n\nconst cents = (s: string) => Math.round(parseFloat(s.replace(/,/g, \"\")) * 100);\n\nfunction merchantOf(txnType: string, lines: string[]): string {\n const t = txnType.toUpperCase();\n if (t.includes(\"PURCHASE\")) {\n for (let i = 0; i < lines.length; i++) {\n const m = lines[i].match(/^xx-(\\d{4}) (.+?)( \\d{4,})?$/);\n if (m) {\n let name = m[2].trim();\n let j = i + 1;\n while (j < lines.length && lines[j] !== \"S\" && !lines[j].startsWith(\"xx-\") && !/^[\\d/]+$/.test(lines[j])) {\n name += \" \" + lines[j];\n j++;\n }\n return name.replace(/ \\d{4,}$/, \"\").trim();\n }\n }\n }\n if (t.includes(\"NETS QR\")) {\n const i = lines.findIndex((l) => l.includes(\"NETS QR PURCHASE\"));\n if (i >= 0 && lines[i + 1]) return lines[i + 1].trim();\n }\n for (const l of lines) {\n const m = l.match(/^to (.+)$/);\n if (m) return m[1].trim();\n }\n if (t.includes(\"INTEREST\")) return \"OCBC Interest\";\n if (t.includes(\"REBATE\")) return \"OCBC Rebate\";\n return (lines[0] ?? txnType).trim();\n}\n\nexport function parseStatementText(pages: string[]): StmtParse {\n const text = pages.join(\"\\n\");\n const out: StmtParse = {\n accountNo: text.match(/Account No\\. (\\d+)/)?.[1] ?? null,\n periodStart: null, periodEnd: null,\n balanceBf: null, balanceCf: null,\n statedWithdrawals: null, statedDeposits: null,\n txns: [], problems: [],\n };\n\n const period = text.match(/(\\d{1,2}) ([A-Z]{3}) (\\d{4}) TO (\\d{1,2}) ([A-Z]{3}) (\\d{4})/);\n if (period) {\n out.periodStart = `${period[3]}-${MONTHS[period[2]]}-${period[1].padStart(2, \"0\")}`;\n out.periodEnd = `${period[6]}-${MONTHS[period[5]]}-${period[4].padStart(2, \"0\")}`;\n }\n const bf = text.match(/([\\d,]+\\.\\d{2})BALANCE B\\/F/);\n const cf = text.match(/([\\d,]+\\.\\d{2})BALANCE C\\/F/);\n out.balanceBf = bf ? cents(bf[1]) : null;\n out.balanceCf = cf ? cents(cf[1]) : null;\n\n // Totals appear as two concatenated numbers after the C/F block, e.g. \"1,111.151,119.26\"\n const totIdx = text.indexOf(\"Total Withdrawals/Deposits\");\n if (totIdx >= 0) {\n const tm = text.slice(totIdx, totIdx + 300).match(/^([\\d,]+?\\.\\d{2})([\\d,]+\\.\\d{2})$/m);\n if (tm) {\n // order is ambiguous in the extracted layout — assign via the balance equation\n const a = cents(tm[1]), b = cents(tm[2]);\n if (out.balanceBf !== null && out.balanceCf !== null) {\n if (out.balanceBf - a + b === out.balanceCf) {\n out.statedWithdrawals = a; out.statedDeposits = b;\n } else {\n out.statedWithdrawals = b; out.statedDeposits = a;\n }\n }\n }\n }\n\n if (out.balanceBf === null) {\n out.problems.push(\"Opening balance not found — is this an OCBC deposit-account statement?\");\n return out;\n }\n\n const year = out.periodEnd ? out.periodEnd.slice(0, 4) : String(new Date().getFullYear());\n let prev = out.balanceBf;\n let current: (StmtTxn & { _lines: string[] }) | null = null;\n let done = false;\n\n for (let raw of text.split(\"\\n\")) {\n const line = raw.trim();\n if (!line || done) continue;\n if (line.includes(\"BALANCE C/F\") || line.startsWith(\"Total Withdrawals/Deposits\")) {\n done = true;\n continue;\n }\n const m = line.match(TXN_RE);\n if (m) {\n const amount = cents(m[3]), balance = cents(m[4]);\n let direction: \"withdrawal\" | \"deposit\";\n if (prev - amount === balance) direction = \"withdrawal\";\n else if (prev + amount === balance) direction = \"deposit\";\n else {\n out.problems.push(`Cannot classify row (balance jump): ${line}`);\n continue;\n }\n let txnDate = `${year}-${MONTHS[m[2]]}-${m[1]}`;\n if (out.periodStart && txnDate < out.periodStart) {\n txnDate = `${out.periodStart.slice(0, 4)}-${MONTHS[m[2]]}-${m[1]}`;\n }\n current = {\n txnDate, amountCents: amount, direction,\n txnType: m[6].trim(), merchant: \"\", description: \"\", _lines: [],\n };\n out.txns.push(current);\n prev = balance;\n continue;\n }\n if (current && !NOISE.some((rx) => rx.test(line)) && !line.includes(\"BALANCE B/F\")) {\n current._lines.push(line);\n }\n }\n\n for (const t of out.txns as (StmtTxn & { _lines: string[] })[]) {\n t.merchant = merchantOf(t.txnType, t._lines);\n t.description = [t.txnType, ...t._lines].join(\" | \").slice(0, 200);\n delete (t as any)._lines;\n }\n\n // verify against the statement's own totals\n const w = out.txns.filter((t) => t.direction === \"withdrawal\").reduce((s, t) => s + t.amountCents, 0);\n const d = out.txns.filter((t) => t.direction === \"deposit\").reduce((s, t) => s + t.amountCents, 0);\n if (out.statedWithdrawals !== null && w !== out.statedWithdrawals) {\n out.problems.push(`Parsed withdrawals ${w / 100} != statement total ${out.statedWithdrawals / 100}`);\n }\n if (out.statedDeposits !== null && d !== out.statedDeposits) {\n out.problems.push(`Parsed deposits ${d / 100} != statement total ${out.statedDeposits / 100}`);\n }\n if (out.balanceCf !== null && out.balanceBf - w + d !== out.balanceCf) {\n out.problems.push(\"Balance movement does not reconcile\");\n }\n return out;\n}\n\nexport async function parsePdf(bytes: Uint8Array): Promise {\n const { extractText, getDocumentProxy } = await import(\"npm:unpdf\");\n const pdf = await getDocumentProxy(bytes);\n const { text } = await extractText(pdf, { mergePages: false });\n return parseStatementText(text as string[]);\n}\n",[169],"110513c9-c98e-4613-8441-56a129e2b0d5","parser.ts","4856473e-7e88-11f1-af71-1607ee4eb77e",33,["D",1787504686800],8,"// Parser for OCBC transaction alert emails (PayNow, NETS QR, card).\n// Port of the Python parser validated against real alerts (July 2026).\n\nexport interface ParsedAlert {\n amountCents: number;\n txnDate: string; // ISO\n merchant: string;\n description: string;\n reference: string;\n cardLast4?: string; // card alerts — used for account routing\n accountHint?: string; // raw \"From\" text, e.g. \"DBS/POSB card ending 5946\"\n}\n\n/** DBS alerts print \"23 Aug\" with no year — infer it from the email's date. */\nfunction yearFor(dd: string, mon: string, receivedAt?: string): string {\n const base = receivedAt ? new Date(receivedAt) : new Date();\n const y = base.getUTCFullYear();\n const guess = new Date(`${y}-${MONTHS[mon.toLowerCase()]}-${dd.padStart(2, \"0\")}T00:00:00Z`);\n // e.g. mail received 2 Jan about a 31 Dec transaction → previous year\n return String(guess.getTime() - base.getTime() > 5 * 864e5 ? y - 1 : y);\n}\n\nconst MONTHS: Record = {\n jan: \"01\", feb: \"02\", mar: \"03\", apr: \"04\", may: \"05\", jun: \"06\",\n jul: \"07\", aug: \"08\", sep: \"09\", oct: \"10\", nov: \"11\", dec: \"12\",\n};\n\nexport function htmlToText(html: string): string {\n let t = html.replace(/<\\/td>\\s*]*>/gi, \" \");\n t = t.replace(/<\\/tr>||<\\/p>|<\\/table>/gi, \"\\n\");\n t = t.replace(/<[^>]+>/g, \"\");\n return t\n .replace(/ /g, \" \").replace(/&/g, \"&\").replace(/>/g, \">\")\n .replace(/</g, \"<\").replace(/'/g, \"'\").replace(/"/g, '\"');\n}\n\nexport function parseAlert(subject: string, body: string, receivedAt?: string): ParsedAlert {\n if (body.includes(\"<\") && body.includes(\">\")) body = htmlToText(body);\n body = body.replace(/\\r\\n/g, \"\\n\");\n\n // ---- DBS / POSB (PayLah!, card, iBanking) ----------------------------\n // One shared layout, whether pipe-delimited or run together on one line:\n // Date & Time: 18 Aug 18:13 (SGT) Amount: SGD500.00\n // From: DBS/POSB card ending 5946 To: SMP*DE HAIR ART\n const dbsDate = body.match(/Date\\s*&\\s*Time:\\s*\\|?\\s*(\\d{1,2})\\s+([A-Za-z]{3})\\s+(\\d{1,2}:\\d{2})/i);\n const dbsAmt = body.match(/Amount:\\s*\\|?\\s*SGD\\s?([\\d,]+\\.\\d{2})/i);\n if (dbsDate && dbsAmt && /DBS|POSB|PayLah/i.test(body)) {\n const from = body.match(/From:\\s*\\|?\\s*([\\s\\S]+?)\\s*(?:\\||\\n|To:)/i)?.[1]?.trim() ?? \"\";\n const to = body\n .match(/To:\\s*\\|?\\s*([\\s\\S]+?)\\s*(?:\\||\\n|If unauthori|To view|Please call|Thank you)/i)?.[1]\n ?.trim() ?? \"\";\n if (!to) throw new Error(\"DBS alert: no payee found\");\n const [, dd, mon, time] = dbsDate;\n const ref = body.match(/Transaction Ref:\\s*\\|?\\s*(\\S+)/i)?.[1] ?? \"\";\n const kind = /PayLah/i.test(from) ? \"PayLah!\"\n : /card ending/i.test(from) ? \"DBS card\"\n : \"DBS transfer\";\n return {\n amountCents: Math.round(parseFloat(dbsAmt[1].replace(/,/g, \"\")) * 100),\n txnDate: `${yearFor(dd, mon, receivedAt)}-${MONTHS[mon.toLowerCase()]}-${dd.padStart(2, \"0\")}`,\n merchant: to.replace(/\\s+/g, \" \"),\n description: [kind, time, ref ? `ref ${ref}` : \"\"].filter(Boolean).join(\" · \"),\n reference: ref,\n cardLast4: from.match(/ending\\s+(\\d{4})/i)?.[1],\n accountHint: from,\n };\n }\n\n // Card Transaction Alert format (noreply@notify.ocbc.com):\n // \"SGD5.62 was charged at 14:26 on 13-Jul-26 to your card (-8824) at NTUC FairPrice App Paymen.\"\n const card = body.match(\n /SGD\\s?([\\d,]+\\.?\\d{0,2})\\s+was charged at\\s+(\\d{1,2}:\\d{2})\\s+on\\s+(\\d{1,2})-([A-Za-z]{3})-(\\d{2,4})\\s+to\\s+your card\\s+\$(-?\\d{3,4})\$\\s+at\\s+([\\s\\S]+?)\\./,\n );\n if (card) {\n const [, amt, time, dd, mon, yy, last4, merchRaw] = card;\n const year = yy.length === 2 ? `20${yy}` : yy;\n return {\n amountCents: Math.round(parseFloat(amt.replace(/,/g, \"\")) * 100),\n txnDate: `${year}-${MONTHS[mon.toLowerCase()]}-${dd.padStart(2, \"0\")}`,\n merchant: merchRaw.replace(/\\s+/g, \" \").trim(),\n description: `Card ${last4.replace(\"-\", \"•\")} · ${time}`,\n reference: \"\",\n cardLast4: last4.replace(\"-\", \"\"),\n };\n }\n\n // Google Pay transfer format:\n // \"SGD5.70 was sent to KOX LIX OX using his/her mobile number (+XXXXXX0807)\n // from the account you linked to Google Pay.\" Date of transfer: 06-Aug-2026\n const gpay = body.match(\n /SGD\\s?([\\d,]+\\.?\\d{0,2})\\s+was sent to\\s+([\\s\\S]+?)\\s+using[\\s\\S]*?Date of transfer:\\s*(\\d{1,2})-([A-Za-z]{3})-(\\d{2,4})/i,\n );\n if (gpay) {\n const [, amt, payee, dd, mon, yy] = gpay;\n const time = body.match(/Time of transfer:\\s*([\\d.:]+\\s?[AP]M)/i)?.[1] ?? \"\";\n return {\n amountCents: Math.round(parseFloat(amt.replace(/,/g, \"\")) * 100),\n txnDate: `${yy.length === 2 ? `20${yy}` : yy}-${MONTHS[mon.toLowerCase()]}-${dd.padStart(2, \"0\")}`,\n merchant: payee.replace(/\\s+/g, \" \").trim(),\n description: [\"Google Pay\", time].filter(Boolean).join(\" · \"),\n reference: \"\",\n };\n }\n\n const fields: Record = {};\n for (const m of body.matchAll(\n /^\\s*(Date(?: of Transfer)?|Time(?: of Transfer)?|Amount|To(?: account)?|Description|Reference number|From your account)\\s*:\\s*(.+?)\\s*$/gm,\n )) fields[m[1]] = m[2].trim();\n // Funds-transfer alerts label the same fields differently\n fields[\"Date\"] ??= fields[\"Date of Transfer\"];\n fields[\"Time\"] ??= fields[\"Time of Transfer\"];\n\n const amtSrc = fields[\"Amount\"] ?? body;\n const am = amtSrc.match(/(?:SGD|S\\$)\\s*([\\d,]+\\.?\\d{0,2})/);\n if (!am) throw new Error(\"no amount found\");\n const amountCents = Math.round(parseFloat(am[1].replace(/,/g, \"\")) * 100);\n\n const dm = (fields[\"Date\"] ?? \"\").match(/^(\\d{1,2}) ([A-Za-z]{3}) (\\d{4})$/);\n if (!dm) throw new Error(\"no date found\");\n const txnDate = `${dm[3]}-${MONTHS[dm[2].toLowerCase()]}-${dm[1].padStart(2, \"0\")}`;\n\n const sub = subject.toLowerCase();\n let merchant = \"\", kind = \"\";\n if (sub.includes(\"paynow\")) {\n const pm = body.match(/has been made to\\s+([\\s\\S]+?)\\s+using\\s+(?:his\\/her|their)/);\n merchant = pm ? pm[1].replace(/\\s+/g, \" \").trim() : \"\";\n kind = \"PayNow\";\n } else if (sub.includes(\"nets\")) {\n merchant = fields[\"To\"] ?? \"\";\n kind = \"NETS QR\";\n } else if (sub.includes(\"transfer\")) {\n // \"We have processed your funds transfer request\" — internet-banking transfer\n merchant = fields[\"To account\"] ?? fields[\"To\"] ?? \"\";\n kind = \"Funds transfer\";\n } else {\n const cm = body.match(/transaction (?:was made )?at\\s+(.+?)[.\\n]/);\n merchant = cm ? cm[1].trim() : (fields[\"To\"] ?? \"\");\n kind = subject.trim() || \"Card\";\n }\n if (!merchant) throw new Error(\"no payee/merchant found\");\n\n const reference = fields[\"Reference number\"] ?? \"\";\n const description = [kind, fields[\"Time\"] ?? \"\", reference ? `ref ${reference}` : \"\"]\n .filter(Boolean).join(\" · \");\n return { amountCents, txnDate, merchant, description, reference };\n}\n",[176],"e6f464ee-4d78-4a39-977d-a1e6828ce297","main.ts",46,["D",1787505676513],7,"http","// Spending Tracker — mobile web UI. Login-gated to the owner's Val Town account.\n// \"/\" → account picker (no bottom nav)\n// \"/:scope/...\" → the app, scoped to all | ocbc | dbs | cash\nimport { Hono } from \"npm:hono\";\nimport { getOAuthUserData, oauthMiddleware } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initDb, OWNER_ID, suggestCategory, dedupHash } from \"./db.ts\";\nimport { parsePdf } from \"./stmt-parser.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst money = (c: number) => (c / 100).toLocaleString(\"en-SG\", { minimumFractionDigits: 2 });\nconst esc = (s: unknown) =>\n String(s ?? \"\").replace(/&/g, \"&\").replace(//g, \">\").replace(/\"/g, \""\");\nconst today = () => new Date(Date.now() + 8 * 3600e3).toISOString().slice(0, 10); // SGT\n\n// ---------- scopes ----------\nconst SCOPES: Record = {\n all: { label: \"All accounts\", icon: \"🌐\", bank: null, import: true },\n ocbc: { label: \"OCBC\", icon: \"🏦\", bank: \"OCBC\", import: true },\n dbs: { label: \"DBS\", icon: \"🏛️\", bank: \"DBS\", import: false },\n cash: { label: \"Cash & Other\", icon: \"💵\", bank: \"CASH\", import: false },\n};\nconst isScope = (s: string) => Object.prototype.hasOwnProperty.call(SCOPES, s);\n\n/** SQL fragment + args restricting transactions to the scope's bank. */\nfunction scopeSql(scope: string): { sql: string; args: string[] } {\n const bank = SCOPES[scope]?.bank;\n return bank\n ? { sql: \" AND account_id IN (SELECT id FROM accounts WHERE bank=?)\", args: [bank] }\n : { sql: \"\", args: [] };\n}\n\nconst CSS = `\n:root{--bg:#f4f6f8;--card:#fff;--ink:#17242b;--muted:#6b7a85;--accent:#1f4e5f;--accent2:#2e7d6b;--red:#c0392b;--green:#1e8e5a}\n*{box-sizing:border-box}body{margin:0;font-family:-apple-system,\"Segoe UI\",Roboto,sans-serif;background:var(--bg);color:var(--ink);font-size:16px}\nmain{max-width:560px;margin:0 auto;padding:16px 16px 96px}main.nonav{padding-bottom:24px}\nh1{font-size:1.3rem;margin:8px 0 14px}\nh2{font-size:.9rem;color:var(--muted);margin:0 0 10px;text-transform:uppercase;letter-spacing:.04em}\na{color:var(--accent);text-decoration:none}small{color:var(--muted)}\n.hero{background:linear-gradient(135deg,var(--accent),var(--accent2));color:#fff;border-radius:14px;padding:20px;text-align:center;margin-bottom:14px}\n.hero .big{font-size:2.1rem;font-weight:700;margin:4px 0}.hero .label{opacity:.85;font-size:.85rem}\n.delta{font-size:.85rem}.card{background:var(--card);border-radius:14px;padding:14px 16px;margin-bottom:14px;box-shadow:0 1px 3px rgba(0,0,0,.06)}\n.empty{color:var(--muted);padding:10px 0}\n.row{display:flex;justify-content:space-between;align-items:center;padding:6px 0}\n.bar{height:6px;background:#e8edf0;border-radius:3px;margin-top:4px}.bar div{height:100%;background:var(--accent2);border-radius:3px}\n.txn{display:flex;gap:10px;align-items:center;padding:9px 0;color:inherit;border-bottom:1px solid #eef2f4}.txn:last-child{border-bottom:0}\n.icon{font-size:1.3rem;width:32px;text-align:center;flex:none}.txnmain{flex:1;min-width:0}\n.txnmain div{white-space:nowrap;overflow:hidden;text-overflow:ellipsis}.txn b{flex:none}.credit{color:var(--green)}\n.bottomnav{position:fixed;bottom:0;left:0;right:0;display:flex;justify-content:space-around;align-items:center;background:var(--card);border-top:1px solid #e3e9ec;padding:6px 0 max(6px,env(safe-area-inset-bottom))}\n.bottomnav a{display:flex;flex-direction:column;align-items:center;font-size:1.15rem;color:var(--muted);min-width:58px;position:relative}\n.bottomnav a span{font-size:.65rem}.bottomnav a.active{color:var(--accent)}\n.badge{position:absolute;top:-4px;right:4px;background:var(--red);color:#fff;font-style:normal;font-size:.65rem;border-radius:999px;padding:1px 6px;font-weight:700}\nlabel{display:block;margin-bottom:12px;font-size:.9rem;color:var(--muted)}\ninput,select,button{font:inherit}\ninput[type=text],input[type=number],input[type=date],input[type=search],select{width:100%;padding:12px;border:1px solid #d6dee3;border-radius:10px;margin-top:4px;background:#fff;color:var(--ink)}\ninput[name=amount]{font-size:1.6rem;font-weight:700}\nbutton.primary{width:100%;padding:14px;background:var(--accent);color:#fff;border:0;border-radius:12px;font-weight:600;font-size:1.05rem}\nbutton.danger{width:100%;padding:12px;margin-top:10px;background:#fff;color:var(--red);border:1px solid var(--red);border-radius:12px}\n.chip{border:1px solid var(--accent);color:var(--accent);background:#fff;border-radius:999px;padding:7px 14px;font-size:.85rem}\n.quick{display:flex;gap:8px;flex-wrap:wrap;margin-bottom:14px}\n.filterrow{display:flex;gap:8px;margin-bottom:8px}\n.importrow{display:flex;gap:8px;align-items:center;padding:8px 0;border-bottom:1px solid #eef2f4}\n.importrow select{width:150px;flex:none;padding:8px}\n.skipbox{flex:none;font-size:.7rem;color:var(--muted);display:flex;flex-direction:column;align-items:center;margin:0}\n.alert{background:#fdecea;color:var(--red);border-radius:10px;padding:10px 12px;margin:8px 0;font-size:.9rem}\npre.raw{white-space:pre-wrap;font-size:.7rem;background:#f6f8f9;padding:8px;border-radius:8px}\n.checkline{display:flex;gap:8px;align-items:center;color:var(--ink)}.checkline input{width:auto}\n.monthnav{display:flex;align-items:center;justify-content:space-between}.monthnav a,.monthnav s{font-size:1.6rem;padding:0 14px;text-decoration:none}.monthnav s{opacity:.2}\nfooter{text-align:center;padding:10px;font-size:.7rem}\n/* --- account picker --- */\n.pickhead{text-align:center;padding:26px 0 18px}\n.pickhead h1{font-size:1.5rem;margin:0 0 4px}\n.tile{display:flex;align-items:center;gap:14px;background:var(--card);border-radius:14px;padding:18px 16px;margin-bottom:12px;color:inherit;box-shadow:0 1px 3px rgba(0,0,0,.06)}\n.tile .icon{font-size:1.9rem;width:44px}\n.tile .t-main{flex:1;min-width:0}\n.tile .t-name{font-weight:600;font-size:1.05rem}\n.tile .t-sub{color:var(--muted);font-size:.8rem}\n.tile .t-amt{font-weight:700;white-space:nowrap}\n.tile.pending .t-sub{color:var(--red)}\n.scopebar{display:flex;justify-content:space-between;align-items:center;margin-bottom:6px;font-size:.8rem;color:var(--muted)}`;\n\nasync function pendingCount(scope: string): Promise {\n const s = scopeSql(scope);\n const r = await sqlite.execute({\n sql: `SELECT (SELECT COUNT(*) FROM transactions WHERE status='pending_review'${s.sql})\n + (SELECT COUNT(*) FROM email_alerts WHERE parse_status='failed') c`,\n args: s.args,\n });\n return Number((r.rows[0] as any).c);\n}\n\nfunction layout(title: string, scope: string, path: string, badge: number, content: string): string {\n const base = `/${scope}`;\n const nav = (href: string, icon: string, label: string, b = 0) =>\n `${icon}${label}${b ? `${b}` : \"\"}`;\n const sc = SCOPES[scope];\n return `\n\n${esc(title)}\n\n

${sc.icon} ${esc(sc.label)}switch account ⇄

\n${content}

\n\n\n`;\n}\n\n// --- auth gate: every route requires the owner's session ---\napp.use(\"*\", async (c, next) => {\n const session = await getOAuthUserData(c.req.raw);\n if (!session?.user) return c.redirect(\"/auth/login\");\n if (session.user.id !== OWNER_ID) return c.text(\"This is a personal app. Access denied.\", 403);\n await initDb();\n await next();\n});\n\n// ---------- Account picker (landing page, no bottom nav) ----------\napp.get(\"/\", async (c) => {\n const month = today().slice(0, 7);\n const [y, m] = [parseInt(month.slice(0, 4)), parseInt(month.slice(5, 7))];\n const start = `${month}-01`;\n const end = `${m === 12 ? y + 1 : y}-${String((m % 12) + 1).padStart(2, \"0\")}-01`;\n\n const spend = await sqlite.execute({\n sql: `SELECT a.bank, COALESCE(SUM(t.amount_cents),0) s FROM transactions t\n JOIN accounts a ON a.id=t.account_id\n WHERE t.direction='withdrawal' AND t.status='confirmed' AND t.txn_date>=? AND t.txn_date = {};\n for (const r of spend.rows as any[]) byBank[String(r.bank)] = Number(r.s);\n const total = Object.values(byBank).reduce((a, b) => a + b, 0);\n\n const pend = await sqlite.execute(\n `SELECT a.bank, COUNT(*) n FROM transactions t JOIN accounts a ON a.id=t.account_id\n WHERE t.status='pending_review' GROUP BY a.bank`);\n const pendByBank: Record = {};\n for (const r of pend.rows as any[]) pendByBank[String(r.bank)] = Number(r.n);\n const pendTotal = Object.values(pendByBank).reduce((a, b) => a + b, 0);\n\n const tile = (key: string, amount: number, pending: number, sub: string) => {\n const s = SCOPES[key];\n return `\n ${s.icon}\n

${esc(s.label)}

${pending ? `${pending} to review` : sub}

S$ ${money(amount)}

`;\n };\n\n const html = `\n\nSpending Tracker\n\n

Spending Tracker

${month} · choose an account

\n${tile(\"all\", total, pendTotal, \"everything combined\")}\n${tile(\"ocbc\", byBank[\"OCBC\"] ?? 0, pendByBank[\"OCBC\"] ?? 0, \"FRANK account, card, PayNow, NETS\")}\n${tile(\"dbs\", byBank[\"DBS\"] ?? 0, pendByBank[\"DBS\"] ?? 0, \"DBS card + PayLah!\")}\n${tile(\"cash\", byBank[\"CASH\"] ?? 0, pendByBank[\"CASH\"] ?? 0, \"cash & manual entries\")}\n

Amounts are this month's confirmed spending.

`;\n return c.html(html);\n});\n\n// ---------- scope guard ----------\napp.use(\"/:scope/*\", async (c, next) => {\n if (!isScope(c.req.param(\"scope\"))) return c.redirect(\"/\");\n await next();\n});\n\n// ---------- Dashboard ----------\napp.get(\"/:scope\", async (c) => {\n const scope = c.req.param(\"scope\");\n if (!isScope(scope)) return c.redirect(\"/\");\n const sc = scopeSql(scope);\n const month = c.req.query(\"month\") ?? today().slice(0, 7);\n const [y, m] = [parseInt(month.slice(0, 4)), parseInt(month.slice(5, 7))];\n const start = `${month}-01`;\n const end = `${m === 12 ? y + 1 : y}-${String((m % 12) + 1).padStart(2, \"0\")}-01`;\n const pm = `${m === 1 ? y - 1 : y}-${String(m === 1 ? 12 : m - 1).padStart(2, \"0\")}`;\n const W = `direction='withdrawal' AND status='confirmed' AND txn_date>=? AND txn_date=? AND t.txn_date Number(r.s)));\n const delta = total - prev;\n const nextM = month < today().slice(0, 7)\n ? `${m === 12 ? y + 1 : y}-${String((m % 12) + 1).padStart(2, \"0\")}` : null;\n const lastDay = new Date(new Date(`${end}T00:00:00Z`).getTime() - 864e5).toISOString().slice(0, 10);\n const base = `/${scope}`;\n\n const content = `\n

‹

${month}

${nextM ? `›` : \"›\"}

Spent this month

S$ ${money(total)}

\n${prev ? `

${delta > 0 ? \"▲\" : \"▼\"} S$ ${money(Math.abs(delta))} vs last month

` : \"\"}

\n${byCat.rows.length\n ? `

By category — tap to see transactions

${byCat.rows.map((r: any) => `\n ${r.icon}

${esc(r.name)}S$ ${money(Number(r.s))} ›

`).join(\"\")}

By payment method

${byMethod.rows.map((r: any) => `

${esc(r.name)}S$ ${money(Number(r.s))}

`).join(\"\")}

`\n : `

No confirmed spending for ${month} yet.

`}\n

Recent

${recent.rows.length ? recent.rows.map((t: any) => `\n ${t.ci ?? \"❓\"}\n

${esc(t.merchant || t.description || \"—\")}${t.status === \"pending_review\" ? \" ⏳\" : \"\"}

${t.txn_date} · ${esc(t.an ?? \"\")}

\n ${t.direction === \"deposit\" ? \"+\" : \"\"}S$ ${money(t.amount_cents)}`).join(\"\") : `

Nothing yet.

`;\n return c.html(layout(\"Spending Tracker\", scope, \"\", await pendingCount(scope), content));\n});\n\n// ---------- Add / edit ----------\nasync function form(scope: string, t: any | null): Promise {\n const bank = SCOPES[scope].bank;\n const cats = await sqlite.execute(\"SELECT * FROM categories WHERE is_archived=0 ORDER BY id\");\n const accs = await sqlite.execute(\n bank\n ? { sql: \"SELECT * FROM accounts WHERE is_active=1 AND bank=? ORDER BY id\", args: [bank] }\n : \"SELECT * FROM accounts WHERE is_active=1 ORDER BY id\");\n const base = `/${scope}`;\n const quick = t ? { rows: [] } : await sqlite.execute(\n `SELECT merchant, category_id, account_id, COUNT(*) n FROM transactions WHERE source='manual' AND merchant!='' GROUP BY merchant, category_id, account_id ORDER BY n DESC LIMIT 6`);\n return `

${t ? \"Edit\" : \"Add expense\"}

\n${quick.rows.length ? `

${quick.rows.map((q: any) => ``).join(\"\")}

` : \"\"}\n\n${t ? `` : \"\"}`;\n}\n\napp.get(\"/:scope/add\", async (c) => {\n const scope = c.req.param(\"scope\");\n return c.html(layout(\"Add\", scope, \"/add\", await pendingCount(scope), await form(scope, null)));\n});\n\napp.post(\"/:scope/add\", async (c) => {\n const scope = c.req.param(\"scope\");\n const f = await c.req.parseBody();\n await sqlite.execute({\n sql: `INSERT INTO transactions(amount_cents, txn_date, merchant, description, category_id, account_id, source, status)\n VALUES(?,?,?,?,?,?, 'manual', 'confirmed')`,\n args: [Math.round(parseFloat(String(f.amount)) * 100), String(f.txn_date), String(f.merchant ?? \"\").trim(),\n String(f.note ?? \"\").trim(), Number(f.category_id), Number(f.account_id)],\n });\n return c.redirect(`/${scope}`);\n});\n\napp.get(\"/:scope/transactions/:id/edit\", async (c) => {\n const scope = c.req.param(\"scope\");\n const r = await sqlite.execute({ sql: \"SELECT * FROM transactions WHERE id=?\", args: [c.req.param(\"id\")] });\n if (!r.rows.length) return c.text(\"Not found\", 404);\n return c.html(layout(\"Edit\", scope, \"\", await pendingCount(scope), await form(scope, r.rows[0])));\n});\n\napp.post(\"/:scope/transactions/:id/edit\", async (c) => {\n const scope = c.req.param(\"scope\");\n const f = await c.req.parseBody();\n const merchant = String(f.merchant ?? \"\").trim();\n await sqlite.execute({\n sql: `UPDATE transactions SET amount_cents=?, txn_date=?, merchant=?, description=?, category_id=?, account_id=?, updated_at=datetime('now') WHERE id=?`,\n args: [Math.round(parseFloat(String(f.amount)) * 100), String(f.txn_date), merchant,\n String(f.note ?? \"\").trim(), Number(f.category_id), Number(f.account_id), c.req.param(\"id\")],\n });\n if (f.remember && merchant) {\n await sqlite.batch([\n { sql: \"DELETE FROM merchant_rules WHERE lower(pattern)=lower(?)\", args: [merchant] },\n { sql: \"INSERT INTO merchant_rules(pattern, category_id) VALUES(?,?)\", args: [merchant, Number(f.category_id)] },\n ]);\n }\n return c.redirect(`/${scope}/transactions`);\n});\n\napp.post(\"/:scope/transactions/:id/delete\", async (c) => {\n await sqlite.execute({ sql: \"DELETE FROM transactions WHERE id=?\", args: [c.req.param(\"id\")] });\n return c.redirect(`/${c.req.param(\"scope\")}/transactions`);\n});\n\n// ---------- Review queue ----------\napp.get(\"/:scope/review\", async (c) => {\n const scope = c.req.param(\"scope\");\n const sc = scopeSql(scope);\n const base = `/${scope}`;\n const cats = await sqlite.execute(\"SELECT * FROM categories WHERE is_archived=0 ORDER BY id\");\n const rows = await sqlite.execute({\n sql: `SELECT * FROM transactions WHERE status='pending_review'${sc.sql} ORDER BY txn_date DESC, id DESC`,\n args: sc.args,\n });\n const failed = await sqlite.execute(\n \"SELECT * FROM email_alerts WHERE parse_status='failed' ORDER BY id DESC LIMIT 20\");\n const content = `

Review captured transactions

\n${failed.rows.length ? `

⚠ ${failed.rows.length} alert(s) failed to parse

${failed.rows.map((a: any) => `\n

${esc(a.subject)}

${esc(a.received_at)} · ${esc(a.failure_reason)}\n

raw

${esc(a.raw_body)}

`).join(\"\")}

` : \"\"}\n${rows.rows.length ? ``\n : `

Nothing waiting for review. 🎉

`}`;\n return c.html(layout(\"Review\", scope, \"/review\", await pendingCount(scope), content));\n});\n\napp.post(\"/:scope/review/confirm\", async (c) => {\n const f = await c.req.parseBody();\n const stmts = [];\n for (const key of Object.keys(f)) {\n if (!key.startsWith(\"cat_\")) continue;\n const id = Number(key.slice(4));\n if (f[`dismiss_${id}`]) {\n stmts.push({ sql: \"DELETE FROM transactions WHERE id=? AND status='pending_review'\", args: [id] });\n } else {\n stmts.push({\n sql: \"UPDATE transactions SET status='confirmed', category_id=?, updated_at=datetime('now') WHERE id=? AND status='pending_review'\",\n args: [Number(f[key]), id],\n });\n }\n }\n if (stmts.length) await sqlite.batch(stmts as any);\n return c.redirect(`/${c.req.param(\"scope\")}/review`);\n});\n\napp.post(\"/:scope/review/alerts/:id/dismiss\", async (c) => {\n await sqlite.execute({ sql: \"UPDATE email_alerts SET parse_status='skipped' WHERE id=?\", args: [c.req.param(\"id\")] });\n return c.redirect(`/${c.req.param(\"scope\")}/review`);\n});\n\n// ---------- History ----------\napp.get(\"/:scope/transactions\", async (c) => {\n const scope = c.req.param(\"scope\");\n const sc = scopeSql(scope);\n const base = `/${scope}`;\n const q = c.req.query(\"q\") ?? \"\", cat = c.req.query(\"category\") ?? \"\", start = c.req.query(\"start\") ?? \"\", end = c.req.query(\"end\") ?? \"\";\n const where = [\"1=1\"]; const args: any[] = [];\n if (q) { where.push(\"(t.merchant LIKE ? OR t.description LIKE ?)\"); args.push(`%${q}%`, `%${q}%`); }\n if (cat) { where.push(\"t.category_id=?\"); args.push(Number(cat)); }\n if (start) { where.push(\"t.txn_date>=?\"); args.push(start); }\n if (end) { where.push(\"t.txn_date<=?\"); args.push(end); }\n const rows = await sqlite.execute({\n sql: `SELECT t.*, c.name cn, c.icon ci, a.name an FROM transactions t\n LEFT JOIN categories c ON c.id=t.category_id LEFT JOIN accounts a ON a.id=t.account_id\n WHERE ${where.join(\" AND \")}${sc.sql.replace(\"account_id\", \"t.account_id\")}\n ORDER BY t.txn_date DESC, t.id DESC LIMIT 500`,\n args: [...args, ...sc.args],\n });\n const cats = await sqlite.execute(\"SELECT * FROM categories WHERE is_archived=0 ORDER BY id\");\n const total = rows.rows.reduce((s: number, r: any) => r.direction === \"withdrawal\" && r.status === \"confirmed\" ? s + r.amount_cents : s, 0);\n const content = `

History

\n\n

${rows.rows.length} transactions · confirmed spend S$ ${money(total)}

${rows.rows.length ? rows.rows.map((t: any) => `\n ${t.ci ?? \"❓\"}\n

${esc(t.merchant || t.description || \"—\")}${t.status === \"pending_review\" ? \" ⏳\" : \"\"}

\n ${t.txn_date} · ${esc(t.cn ?? \"\")} · ${esc(t.an ?? \"\")}

\n ${t.direction === \"deposit\" ? \"+\" : \"\"}S$ ${money(t.amount_cents)}`).join(\"\") : `

No transactions match.

`;\n return c.html(layout(\"History\", scope, \"/transactions\", await pendingCount(scope), content));\n});\n\n// ---------- Statement import (OCBC only) ----------\nconst norm = (s: string) => s.toLowerCase().replace(/[^a-z0-9]/g, \"\");\nfunction sameMerchant(a: string, b: string): boolean {\n const x = norm(a), y = norm(b);\n if (!x || !y) return false;\n return x === y || x.includes(y.slice(0, 10)) || y.includes(x.slice(0, 10));\n}\nconst dayDiff = (a: string, b: string) =>\n Math.abs(new Date(a).getTime() - new Date(b).getTime()) / 864e5;\n\napp.get(\"/:scope/import\", async (c) => {\n const scope = c.req.param(\"scope\");\n if (!SCOPES[scope].import) return c.redirect(`/${scope}`);\n const base = `/${scope}`;\n const batches = await sqlite.execute(\n \"SELECT id, file_name, period_start, period_end, row_count, status, created_at FROM import_batches ORDER BY id DESC LIMIT 8\");\n const content = `

Import statement

Upload an OCBC account statement PDF. You'll see a preview first — rows already captured by email alerts are detected and skipped, so nothing double-counts. Re-uploading the same file is safe.

\n${batches.rows.length ? `

Previous imports

${batches.rows.map((b: any) => `\n

${esc(b.file_name)}
${b.period_start ?? \"?\"} → ${b.period_end ?? \"?\"} · ${b.status}${b.row_count} rows

`).join(\"\")}

` : \"\"}`;\n return c.html(layout(\"Import\", scope, \"/import\", await pendingCount(scope), content));\n});\n\napp.post(\"/:scope/import/upload\", async (c) => {\n const scope = c.req.param(\"scope\");\n const base = `/${scope}`;\n const f = await c.req.parseBody();\n const file = f.file as File;\n if (!file?.arrayBuffer) return c.text(\"No file received\", 400);\n const bytes = new Uint8Array(await file.arrayBuffer());\n const hashBuf = await crypto.subtle.digest(\"SHA-256\", bytes);\n const fileHash = [...new Uint8Array(hashBuf)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n\n const dup = await sqlite.execute({\n sql: \"SELECT created_at, row_count FROM import_batches WHERE file_hash=? AND status='committed'\",\n args: [fileHash],\n });\n if (dup.rows.length) {\n const d: any = dup.rows[0];\n return c.html(layout(\"Import\", scope, \"/import\", await pendingCount(scope),\n `

Import statement

This exact file was already imported on ${d.created_at} (${d.row_count} rows). Nothing to do.

Back

`));\n }\n\n let st;\n try {\n st = await parsePdf(bytes);\n } catch (err) {\n return c.html(layout(\"Import\", scope, \"/import\", await pendingCount(scope),\n `

Import statement

Could not parse this PDF: ${esc(String(err))}

Back

`));\n }\n if (!st.txns.length) {\n return c.html(layout(\"Import\", scope, \"/import\", await pendingCount(scope),\n `

Import statement

${esc(st.problems.join(\"; \") || \"No transactions found in this PDF.\")}

Back

`));\n }\n\n const lo = st.periodStart ?? st.txns[0].txnDate, hi = st.periodEnd ?? st.txns[st.txns.length - 1].txnDate;\n const existing = (await sqlite.execute({\n sql: \"SELECT id, amount_cents, txn_date, merchant, source, status FROM transactions WHERE txn_date>=date(?, '-4 days') AND txn_date<=date(?, '+4 days')\",\n args: [lo, hi],\n })).rows as any[];\n const claimed = new Set();\n const rows: any[] = [];\n for (const t of st.txns) {\n let dupOf: any = null;\n for (const e of existing) {\n if (claimed.has(e.id) || e.amount_cents !== t.amountCents) continue;\n if (e.source === \"statement_pdf\" ? e.txn_date !== t.txnDate : dayDiff(e.txn_date, t.txnDate) > 3) continue;\n if (e.source === \"statement_pdf\" || sameMerchant(e.merchant, t.merchant)) { dupOf = e; break; }\n }\n if (dupOf) claimed.add(dupOf.id);\n const cat = t.direction === \"deposit\" ? 11 : ((await suggestCategory(t.merchant, t.description)) ?? 12);\n rows.push({ ...t, catId: cat, dup: !!dupOf, dupSource: dupOf?.source ?? null });\n }\n const cur = await sqlite.execute({\n sql: `INSERT INTO import_batches(file_name, file_hash, period_start, period_end, row_count, rows_json)\n VALUES(?,?,?,?,?,?)\n ON CONFLICT(file_hash) DO UPDATE SET rows_json=excluded.rows_json, status='previewed' RETURNING id`,\n args: [file.name, fileHash, st.periodStart, st.periodEnd, rows.length, JSON.stringify(rows)],\n });\n const batchId = (cur.rows[0] as any).id;\n const cats = await sqlite.execute(\"SELECT * FROM categories WHERE is_archived=0 ORDER BY id\");\n const dups = rows.filter((r) => r.dup).length;\n const newSpend = rows.filter((r) => !r.dup && r.direction === \"withdrawal\").reduce((s, r) => s + r.amountCents, 0);\n\n const content = `

Preview: ${st.periodStart} → ${st.periodEnd}

${rows.length} rows · ${dups} already captured (pre-skipped) · S$ ${money(newSpend)} new spend

\n${st.problems.length ? `

⚠ ${esc(st.problems.join(\"; \"))}

` : `

✓ Parsed totals match the statement's own totals.

\n`;\n return c.html(layout(\"Preview\", scope, \"/import\", await pendingCount(scope), content));\n});\n\napp.post(\"/:scope/import/:id/commit\", async (c) => {\n const batchId = c.req.param(\"id\");\n const b = await sqlite.execute({ sql: \"SELECT rows_json FROM import_batches WHERE id=?\", args: [batchId] });\n if (!b.rows.length) return c.text(\"Batch not found\", 404);\n const rows = JSON.parse((b.rows[0] as any).rows_json);\n const f = await c.req.parseBody();\n let inserted = 0;\n const stmts: any[] = [];\n for (let i = 0; i < rows.length; i++) {\n if (f[`skip_${i}`]) continue;\n const r = rows[i];\n const dh = await dedupHash(2, r.txnDate, r.amountCents, r.description);\n stmts.push({\n sql: `INSERT OR IGNORE INTO transactions(amount_cents, direction, txn_date, merchant, description,\n category_id, account_id, source, status, dedup_hash)\n VALUES(?,?,?,?,?,?, 2, 'statement_pdf', 'confirmed', ?)`,\n args: [r.amountCents, r.direction, r.txnDate, r.merchant, r.description,\n Number(f[`cat_${i}`] ?? r.catId), dh],\n });\n inserted++;\n }\n if (stmts.length) await sqlite.batch(stmts);\n await sqlite.execute({\n sql: \"UPDATE import_batches SET status='committed', row_count=? WHERE id=?\",\n args: [inserted, batchId],\n });\n return c.redirect(`/${c.req.param(\"scope\")}/transactions`);\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\nexport default oauthMiddleware(app.fetch);\n","sherwyn-spendings",[184],"5ac7ef2b-1bd3-40e6-9f77-c3306d667299","ingest-email.ts","55052e50-7e88-11f1-bc08-1607ee4eb77e",38,["D",1787504734298],12,"email","// Email entrypoint: Gmail forwards OCBC alerts here; each becomes a\n// pending-review transaction. Idempotent by Message-ID.\n// Non-OCBC mail (e.g. Gmail's forwarding-verification email) is stored in\n// email_alerts with parse_status='skipped' so its content can be inspected.\nimport { dedupHash, initDb, suggestCategory } from \"./db.ts\";\nimport { parseAlert } from \"./parser.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst RELEVANT = [\n \"paynow\", \"nets qr\", \"card\", \"purchase\", \"transaction\", \"payment\", \"transfer\",\n \"transaction alerts\", \"paylah\", // DBS\n];\n\n// OCBC service notices that contain no transaction — card activation, PIN,\n// wallet provisioning, statements ready, etc. Marked 'skipped', not 'failed',\n// so they never clutter the review queue.\nconst NON_TRANSACTIONAL = [\n /added to wallet/i, /digital wallet/i, /\\bPIN\\b.*(setup|reset|authenticate)/i,\n /here is a pin/i, /card (activation|activated|is on its way|delivery|replacement)/i,\n /e-?statement/i, /statement.*ready/i, /security (alert|advisory)/i,\n /password|access code|one-?time password|\\botp\\b/i,\n /profile (update|change)/i, /contact details/i, /welcome/i,\n /payee/i, // \"funds transfer payee added\" — setup notice, no money moved\n // --- DBS / POSB service notices (no money moved) ---\n /limit (increase|increased|change)/i, /activation status/i,\n /payment controls/i, /mobile wallets/i, /edocument/i,\n /instructions received/i, /auto-debit/i, /linkage/i,\n /contact details/i, /digibot/i, /digibank mobile/i,\n // incoming money — not spending, and usually the other half of a transfer\n // already captured on the OCBC side\n /received a transfer/i,\n];\n\nexport default async function (e: Email) {\n await initDb();\n const messageId = e.headers[\"message-id\"] ?? e.headers[\"Message-Id\"] ??\n `${e.from}|${e.subject}|${(e.text ?? e.html ?? \"\").slice(0, 80)}`;\n const seen = await sqlite.execute({\n sql: \"SELECT 1 FROM email_alerts WHERE message_id=?\", args: [messageId],\n });\n if (seen.rows.length) return console.log(\"skip: already seen\", messageId);\n\n const subject = e.subject ?? \"\";\n const body = e.text || e.html || \"\";\n // Covers direct delivery, Gmail filter-forwards (original sender kept),\n // and manual \"Fwd:\" (sender becomes the user, so fall back to body markers).\n const from = e.from.toLowerCase();\n const isBank = /ocbc\\.com|dbs\\.com/.test(from) || /ocbc|dbs bank|posb|paylah/i.test(body);\n\n const isNotice = NON_TRANSACTIONAL.some((rx) => rx.test(subject));\n if (!isBank || isNotice || !RELEVANT.some((k) => subject.toLowerCase().includes(k))) {\n await sqlite.execute({\n sql: `INSERT INTO email_alerts(message_id, received_at, subject, from_addr, raw_body, parse_status)\n VALUES(?,?,?,?,?, 'skipped')`,\n args: [messageId, new Date().toISOString(), subject, e.from, body.slice(0, 4000)],\n });\n return console.log(\"skipped non-alert email:\", e.from, subject);\n }\n\n try {\n const p = parseAlert(subject, body, e.headers[\"date\"] ?? new Date().toISOString());\n // Route to the right account by card/wallet last-4 when present; default FRANK (id 2).\n let accId = 2;\n if (p.cardLast4) {\n const acc = await sqlite.execute({\n sql: \"SELECT id FROM accounts WHERE last4=? AND is_active=1\", args: [p.cardLast4],\n });\n if (acc.rows.length) accId = (acc.rows[0] as any).id;\n }\n const cat = (await suggestCategory(p.merchant, p.description)) ?? 12; // Uncategorised\n const dh = await dedupHash(accId, p.txnDate, p.amountCents, p.reference || messageId);\n await sqlite.batch([\n {\n sql: `INSERT INTO email_alerts(message_id, received_at, subject, from_addr, raw_body, parse_status)\n VALUES(?,?,?,?,?, 'parsed')`,\n args: [messageId, new Date().toISOString(), subject, e.from, body.slice(0, 4000)],\n },\n {\n sql: `INSERT OR IGNORE INTO transactions(amount_cents, direction, txn_date, merchant,\n description, category_id, account_id, source, status, dedup_hash)\n VALUES(?, 'withdrawal', ?,?,?,?,?, 'email_alert', 'pending_review', ?)`,\n args: [p.amountCents, p.txnDate, p.merchant, p.description, cat, accId, dh],\n },\n ]);\n console.log(\"captured:\", p.txnDate, p.merchant, p.amountCents / 100);\n } catch (err) {\n await sqlite.execute({\n sql: `INSERT INTO email_alerts(message_id, received_at, subject, from_addr, raw_body,\n parse_status, failure_reason) VALUES(?,?,?,?,?, 'failed', ?)`,\n args: [messageId, new Date().toISOString(), subject, e.from, body.slice(0, 4000), String(err)],\n });\n console.error(\"parse failed:\", String(err));\n }\n}\n",[193],"7f7738d6-235d-4654-8f59-f554b47d2ea3","db.ts","3b1f9f8e-7e88-11f1-a0c4-1607ee4eb77e",44,["D",1787505510848],6,"// Schema, seed data and helpers. Amounts stored as integer cents (SGD).\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Only this Val Town account may use the app (checked in main.ts).\nexport const OWNER_ID = \"23bb1bdf-86c6-4322-9537-f748ea9d33ae\"; // sherwynchan\n\nconst SCHEMA = [\n `CREATE TABLE IF NOT EXISTS categories (\n id INTEGER PRIMARY KEY, name TEXT NOT NULL UNIQUE,\n icon TEXT DEFAULT '', is_archived INTEGER DEFAULT 0)`,\n `CREATE TABLE IF NOT EXISTS accounts (\n id INTEGER PRIMARY KEY, name TEXT NOT NULL UNIQUE,\n type TEXT NOT NULL, last4 TEXT, bank TEXT, is_active INTEGER DEFAULT 1)`,\n `CREATE TABLE IF NOT EXISTS merchant_rules (\n id INTEGER PRIMARY KEY, pattern TEXT NOT NULL,\n category_id INTEGER, normalized_name TEXT)`,\n `CREATE TABLE IF NOT EXISTS transactions (\n id INTEGER PRIMARY KEY,\n amount_cents INTEGER NOT NULL,\n direction TEXT NOT NULL DEFAULT 'withdrawal',\n txn_date TEXT NOT NULL,\n merchant TEXT DEFAULT '',\n description TEXT DEFAULT '',\n category_id INTEGER,\n account_id INTEGER,\n source TEXT NOT NULL DEFAULT 'manual',\n status TEXT NOT NULL DEFAULT 'confirmed',\n dedup_hash TEXT UNIQUE,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')))`,\n `CREATE INDEX IF NOT EXISTS idx_txn_date ON transactions(txn_date)`,\n `CREATE TABLE IF NOT EXISTS import_batches (\n id INTEGER PRIMARY KEY,\n file_name TEXT, file_hash TEXT UNIQUE,\n period_start TEXT, period_end TEXT,\n row_count INTEGER DEFAULT 0,\n status TEXT DEFAULT 'previewed',\n rows_json TEXT,\n created_at TEXT DEFAULT (datetime('now')))`,\n `CREATE TABLE IF NOT EXISTS email_alerts (\n id INTEGER PRIMARY KEY,\n message_id TEXT UNIQUE NOT NULL,\n received_at TEXT, subject TEXT, from_addr TEXT, raw_body TEXT,\n parse_status TEXT DEFAULT 'parsed',\n failure_reason TEXT,\n created_at TEXT DEFAULT (datetime('now')))`,\n];\n\nconst CATEGORIES: [string, string][] = [\n [\"Food & Hawker\", \"🍜\"], [\"Groceries\", \"🛒\"], [\"Transport\", \"🚇\"],\n [\"Shopping\", \"🛍️\"], [\"Bills & Utilities\", \"🧾\"], [\"Subscriptions\", \"🔁\"],\n [\"Health\", \"💊\"], [\"Entertainment\", \"🎮\"], [\"Travel\", \"✈️\"],\n [\"Transfers & Others\", \"↔️\"], [\"Income & Rebates\", \"💰\"], [\"Uncategorised\", \"❓\"],\n];\n\n// name, type, last4, bank (\"OCBC\" | \"DBS\" | \"CASH\" — drives the account picker)\nconst ACCOUNTS: [string, string, string | null, string][] = [\n [\"Cash\", \"cash\", null, \"CASH\"],\n [\"OCBC FRANK Account\", \"debit_card\", \"2001\", \"OCBC\"],\n [\"Other\", \"other\", null, \"CASH\"],\n [\"DBS/POSB Card\", \"debit_card\", \"5946\", \"DBS\"],\n [\"DBS PayLah!\", \"other\", \"9706\", \"DBS\"],\n];\n\nconst RULES: [string, string][] = [\n [\"BUS/MRT\", \"Transport\"], [\"anywheel\", \"Transport\"], [\"Grab\", \"Transport\"],\n [\"McDonalds\", \"Food & Hawker\"], [\"CHICKEN RICE\", \"Food & Hawker\"],\n [\"BAN MIAN\", \"Food & Hawker\"], [\"MALA\", \"Food & Hawker\"],\n [\"WESTERN\", \"Food & Hawker\"], [\"MEE\", \"Food & Hawker\"],\n [\"THAI FO\", \"Food & Hawker\"], [\"FONG SENG\", \"Food & Hawker\"],\n [\"COLD STORAGE\", \"Groceries\"], [\"NTUC\", \"Groceries\"], [\"FairPrice\", \"Groceries\"],\n [\"Lazada\", \"Shopping\"], [\"Shopee\", \"Shopping\"], [\"Amazon\", \"Shopping\"],\n [\"Netflix\", \"Subscriptions\"], [\"Spotify\", \"Subscriptions\"],\n [\"MOOMOO\", \"Transfers & Others\"], [\"INTERACTIVE BR\", \"Transfers & Others\"],\n];\n\nexport async function initDb(): Promise {\n for (const s of SCHEMA) await sqlite.execute(s);\n // migration: accounts.bank (added 2026-08 for the account picker)\n try {\n await sqlite.execute(\"ALTER TABLE accounts ADD COLUMN bank TEXT\");\n } catch { /* column already exists */ }\n await sqlite.batch([\n { sql: \"UPDATE accounts SET bank='OCBC' WHERE bank IS NULL AND name LIKE 'OCBC%'\" },\n { sql: \"UPDATE accounts SET bank='DBS' WHERE bank IS NULL AND (name LIKE 'DBS%' OR name LIKE '%PayLah%')\" },\n { sql: \"UPDATE accounts SET bank='CASH' WHERE bank IS NULL\" },\n ]);\n const n = await sqlite.execute(\"SELECT COUNT(*) c FROM categories\");\n if ((n.rows[0] as any).c === 0) {\n const stmts = CATEGORIES.map((c) => ({\n sql: \"INSERT INTO categories(name, icon) VALUES(?,?)\", args: c as any,\n }));\n stmts.push(...ACCOUNTS.map((a) => ({\n sql: \"INSERT INTO accounts(name, type, last4, bank) VALUES(?,?,?,?)\", args: a as any,\n })));\n await sqlite.batch(stmts);\n const cats = await sqlite.execute(\"SELECT id, name FROM categories\");\n const byName = Object.fromEntries(cats.rows.map((r: any) => [r.name, r.id]));\n await sqlite.batch(RULES.map(([p, c]) => ({\n sql: \"INSERT INTO merchant_rules(pattern, category_id) VALUES(?,?)\",\n args: [p, byName[c]],\n })));\n }\n}\n\nexport async function suggestCategory(merchant: string, description = \"\"): Promise {\n const hay = `${merchant} ${description}`.toLowerCase();\n const rules = await sqlite.execute(\n \"SELECT pattern, category_id FROM merchant_rules ORDER BY LENGTH(pattern) DESC\");\n for (const r of rules.rows as any[]) {\n if (hay.includes(String(r.pattern).toLowerCase())) return r.category_id as number;\n }\n return null;\n}\n\nexport async function dedupHash(accountId: number, txnDate: string, amountCents: number, key: string): Promise {\n const raw = `${accountId}|${txnDate}|${amountCents}|${key}`;\n const buf = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(raw));\n return [...new Uint8Array(buf)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n",[202],"c124ca80-eb25-47a9-afb6-de52db3aba30","backfill.ts","fb249158-9f13-11f1-b3f3-1607ee4eb77e",30,["D",1787504359169],"// One-off utility: re-run the parser over stored alert emails that were\n// previously skipped/failed, and insert any real transactions found.\n// Safe to re-run — idempotent via dedup_hash.\nimport { dedupHash, suggestCategory } from \"./db.ts\";\nimport { parseAlert } from \"./parser.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst NON_TRANSACTIONAL = [\n /added to wallet/i, /digital wallet/i, /\\bPIN\\b.*(setup|reset|authenticate)/i,\n /here is a pin/i, /card (activation|activated|is on its way|delivery|replacement)/i,\n /e-?statement/i, /statement.*ready/i, /security (alert|advisory)/i,\n /password|access code|one-?time password|\\botp\\b/i,\n /profile (update|change)/i, /contact details/i, /welcome/i, /payee/i,\n];\nconst RELEVANT = [\"paynow\", \"nets qr\", \"card\", \"purchase\", \"transaction\", \"payment\", \"transfer\"];\n\nconst rows = (await sqlite.execute(\n `SELECT id, message_id, subject, raw_body FROM email_alerts\n WHERE parse_status IN ('skipped','failed') AND raw_body IS NOT NULL AND raw_body != ''`,\n)).rows as any[];\n\nconst report: any[] = [];\nfor (const r of rows) {\n const subject = String(r.subject ?? \"\");\n if (NON_TRANSACTIONAL.some((rx) => rx.test(subject))) continue;\n if (!RELEVANT.some((k) => subject.toLowerCase().includes(k))) continue;\n let p;\n try {\n p = parseAlert(subject, String(r.raw_body));\n } catch {\n continue;\n }\n const cat = (await suggestCategory(p.merchant, p.description)) ?? 12;\n const dh = await dedupHash(2, p.txnDate, p.amountCents, p.reference || String(r.message_id));\n const res = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO transactions(amount_cents, direction, txn_date, merchant,\n description, category_id, account_id, source, status, dedup_hash)\n VALUES(?, 'withdrawal', ?,?,?,?, 2, 'email_alert', 'pending_review', ?)`,\n args: [p.amountCents, p.txnDate, p.merchant, p.description, cat, dh],\n });\n await sqlite.execute({\n sql: \"UPDATE email_alerts SET parse_status='parsed', failure_reason=NULL WHERE id=?\",\n args: [r.id],\n });\n report.push({ date: p.txnDate, amount: p.amountCents / 100, merchant: p.merchant, inserted: res.rowsAffected });\n}\nconsole.log(JSON.stringify(report, null, 1));\n",[210],"de3a9d97-cbde-4bd0-bb22-a5ebe3d026eb","backfill-dbs.ts","26ef63c0-9f15-11f1-a92d-1607ee4eb77e",40,["D",1787504862135],"// One-off: backfill DBS PayLah!/card transactions (17–23 Aug 2026) captured\n// from Gmail before DBS forwarding was switched on. Idempotent via dedup_hash.\nimport { dedupHash, suggestCategory } from \"./db.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst PAYLAH = 5, CARD = 4;\n\n// [date, time, amount, payee, ref, accountId]\nconst rows: [string, string, number, string, string, number][] = [\n [\"2026-08-17\", \"14:16\", 4.50, \"BTC F&B PRIVATE LIMITED\", \"IPS78694737297202977\", PAYLAH],\n [\"2026-08-17\", \"23:04\", 6.00, \"KOO KEE YONG TOW FOO MEE\", \"PLPE4622920341189502\", PAYLAH],\n [\"2026-08-18\", \"13:26\", 4.50, \"BTC F&B PRIVATE LIMITED\", \"IPS78703078011172095\", PAYLAH],\n [\"2026-08-18\", \"18:13\", 500.00, \"SMP*DE HAIR ART\", \"623010574839\", CARD],\n [\"2026-08-18\", \"20:28\", 11.10, \"HUAJIE MALA KITCHEN PTE. LTD.\", \"IPS78705611078355716\", PAYLAH],\n [\"2026-08-19\", \"05:08\", 8.05, \"TIKTOK SHOP SELLER\", \"MT146230576933236539\", PAYLAH],\n [\"2026-08-19\", \"14:11\", 5.00, \"HAINANESE CHICKEN RICE\", \"PLPE4623111413541697\", PAYLAH],\n [\"2026-08-19\", \"22:49\", 7.90, \"BANGKOK JN THAIFOOD\", \"PLPE4623120192639264\", PAYLAH],\n [\"2026-08-20\", \"14:26\", 4.80, \"BTC F&B PRIVATE LIMITED\", \"IPS78720717588919390\", PAYLAH],\n [\"2026-08-21\", \"13:55\", 5.00, \"BTC F&B PRIVATE LIMITED\", \"IPS78729173786565469\", PAYLAH],\n [\"2026-08-21\", \"23:54\", 35.90, \"AL AMAAN RESTAURANT PTE. LTD.\", \"IPS78732766804869951\", PAYLAH],\n [\"2026-08-23\", \"00:43\", 17.30, \"Toots1234 (Mobile ending 5892)\", \"TF705061787417009049\", PAYLAH],\n [\"2026-08-23\", \"13:43\", 4.30, \"BTC F&B PRIVATE LIMITED\", \"IPS78746383821216673\", PAYLAH],\n];\n\nconst report: any[] = [];\nfor (const [date, time, amt, payee, ref, accId] of rows) {\n const cents = Math.round(amt * 100);\n const kind = accId === CARD ? \"DBS card\" : \"PayLah!\";\n const desc = `${kind} · ${time} · ref ${ref}`;\n const cat = (await suggestCategory(payee, desc)) ?? 12;\n const dh = await dedupHash(accId, date, cents, ref);\n const res = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO transactions(amount_cents, direction, txn_date, merchant,\n description, category_id, account_id, source, status, dedup_hash)\n VALUES(?, 'withdrawal', ?,?,?,?,?, 'email_alert', 'pending_review', ?)`,\n args: [cents, date, payee, desc, cat, accId, dh],\n });\n const catName = (await sqlite.execute({\n sql: \"SELECT name FROM categories WHERE id=?\", args: [cat],\n })).rows[0] as any;\n report.push({ date, amt, payee, category: catName?.name, inserted: res.rowsAffected });\n}\nconsole.log(JSON.stringify(report, null, 1));\n",[217],"pulls","branches",1,"forks","envVars",{"_231":61,"_233":61},"connections",{"_231":61,"_232":61},"count","unfilledCount","emptyCount",{"_41":216,"_31":217,"_29":218,"_143":-5,"_39":40,"_38":219,"_145":57,"_36":276,"_13":61,"_32":33,"_34":221,"_23":24,"_149":-5,"_246":277,"_26":278},{"_41":209,"_31":210,"_29":211,"_143":-5,"_39":40,"_38":212,"_145":57,"_36":273,"_13":61,"_32":33,"_34":214,"_23":24,"_149":-5,"_246":274,"_26":275},{"_41":201,"_31":202,"_29":203,"_143":-5,"_39":40,"_38":204,"_145":57,"_36":270,"_13":206,"_32":33,"_34":207,"_23":24,"_149":-5,"_246":271,"_26":272},{"_41":192,"_31":193,"_29":194,"_143":-5,"_39":40,"_38":195,"_145":57,"_36":267,"_13":197,"_32":198,"_34":199,"_23":24,"_149":-5,"_246":268,"_26":269},{"_41":183,"_31":184,"_29":55,"_143":-5,"_39":40,"_38":185,"_145":24,"_36":264,"_13":187,"_32":188,"_34":189,"_23":24,"_149":190,"_246":265,"_26":266},{"_41":175,"_31":176,"_29":177,"_143":-5,"_39":40,"_38":178,"_145":57,"_36":261,"_13":180,"_32":33,"_34":181,"_23":24,"_149":-5,"_246":262,"_26":263},{"_41":168,"_31":169,"_29":170,"_143":-5,"_39":40,"_38":171,"_145":57,"_36":258,"_13":61,"_32":33,"_34":173,"_23":24,"_149":-5,"_246":259,"_26":260},{"_41":165,"_31":27,"_29":30,"_143":-5,"_39":40,"_38":14,"_145":57,"_36":255,"_13":61,"_32":33,"_34":35,"_23":24,"_149":-5,"_246":256,"_26":257},{"_41":158,"_31":159,"_29":160,"_143":-5,"_39":40,"_38":161,"_145":57,"_36":252,"_13":61,"_32":33,"_34":163,"_23":24,"_149":-5,"_246":253,"_26":254},{"_41":151,"_31":152,"_29":153,"_143":-5,"_39":40,"_38":154,"_145":57,"_36":249,"_13":61,"_32":33,"_34":156,"_23":24,"_149":-5,"_246":250,"_26":251},{"_41":140,"_31":141,"_29":142,"_143":-5,"_39":40,"_38":144,"_145":57,"_36":245,"_13":147,"_32":33,"_34":148,"_23":24,"_149":-5,"_246":247,"_26":248},["D",1787504287071],"children",[],[141],["D",1787505698413],[],[152],["D",1787504766523],[],[159],["D",1787505729186],[],[27],["D",1783959977403],[],[169],["D",1787504686800],[],[176],["D",1787505676513],[],[184],["D",1787504734298],[],[193],["D",1787505510848],[],[202],["D",1787504359169],[],[210],["D",1787504862135],[],[217],["D",1783925871877],["D",1789524079207],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":317,"_318":319,"_320":321,"_322":24,"_323":24,"_324":24,"_325":57,"_326":-5,"_327":-7,"_328":-7,"_329":61,"_330":24,"_331":24,"_332":-5,"_333":24,"_334":24,"_335":24,"_336":-5},"ENV",{"_288":289,"_290":291,"_292":88,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v48