BudgetApp

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_321":322,"_323":324},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_107":89,"_26":52,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":24,"_121":122,"_123":58,"_124":-5,"_125":-5,"_126":127},"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",41,"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","server/planned-operations.ts","latestPath","fileId","52108102-b19d-11f1-8032-1607ee4eb77e","name","planned-operations.ts","fileType","script","content","export interface SqlStatement {\n sql: string;\n args: (string | number | null)[];\n}\n\nexport interface PlannedSnapshot {\n id: string;\n revision: number;\n accountId: string | null;\n description: string;\n kind: \"income\" | \"expense\";\n amountCents: number;\n recurrence: \"once\" | \"weekly\" | \"monthly\" | \"yearly\";\n intervalCount: number;\n nextDate: string;\n endDate: string | null;\n isActive: boolean;\n}\n\nexport const PLANNED_COMPLETIONS_QUERY = `SELECT c.*,\n t.id AS effective_id, t.account_id AS effective_account_id, t.date AS effective_date,\n t.amount_cents AS effective_amount_cents, t.currency AS effective_currency,\n t.description AS effective_description, t.kind AS effective_kind, t.status AS effective_status,\n t.source AS effective_source, t.transfer_group_id AS effective_transfer_group_id,\n t.planned_transaction_id AS effective_planned_transaction_id,\n t.corrected_from_transaction_id AS effective_corrected_from_transaction_id,\n t.voided_at AS effective_voided_at, t.created_at AS effective_created_at, t.updated_at AS effective_updated_at,\n original.id AS original_id, original.account_id AS original_account_id, original.date AS original_date,\n original.amount_cents AS original_amount_cents, original.currency AS original_currency,\n original.description AS original_description, original.kind AS original_kind, original.status AS original_status,\n original.source AS original_source, original.transfer_group_id AS original_transfer_group_id,\n original.planned_transaction_id AS original_planned_transaction_id,\n original.corrected_from_transaction_id AS original_corrected_from_transaction_id,\n original.voided_at AS original_voided_at, original.created_at AS original_created_at,\n original.updated_at AS original_updated_at,\n CASE WHEN c.status IN ('completed', 'corrected') AND p.latest_completion_id = c.id\n AND p.revision = c.completed_revision AND p.next_date = c.completed_next_date\n AND p.is_active = c.completed_is_active AND t.id IS NOT NULL THEN 1 ELSE 0 END AS adjustable\n FROM planned_completions c\n JOIN planned_transactions p ON p.id = c.planned_transaction_id\n JOIN transactions original ON original.id = c.transaction_id\n LEFT JOIN transactions t ON t.id = COALESCE(c.correction_transaction_id, c.transaction_id)\n AND t.voided_at IS NULL\n ORDER BY c.created_at DESC`;\n\nexport function completePlannedStatements(input: {\n item: PlannedSnapshot;\n completionId: string;\n transactionId: string;\n targetAccountId: string;\n actualDate: string;\n nextDate: string;\n remainsActive: boolean;\n now: string;\n}): SqlStatement[] {\n const { item, completionId, transactionId, targetAccountId, actualDate, nextDate, remainsActive, now } = input;\n const signedAmount = item.kind === \"expense\" ? -item.amountCents : item.amountCents;\n const completedRevision = item.revision + 1;\n return [\n {\n sql: `UPDATE planned_transactions SET next_date = ?, is_active = ?, revision = revision + 1,\n latest_completion_id = ?, updated_at = ?, is_demo = 0\n WHERE id = ? AND revision = ? AND next_date = ? AND is_active = 1`,\n args: [nextDate, Number(remainsActive), completionId, now, item.id, item.revision, item.nextDate],\n },\n {\n sql: `INSERT INTO transactions\n (id, account_id, date, amount_cents, currency, description, kind, status, source,\n planned_transaction_id, created_at, updated_at)\n SELECT ?, ?, ?, ?, 'EUR', ?, ?, 'cleared', 'planned', ?, ?, ?\n WHERE EXISTS (SELECT 1 FROM planned_transactions WHERE id = ? AND latest_completion_id = ? AND revision = ?)`,\n args: [transactionId, targetAccountId, actualDate, signedAmount, item.description, item.kind, item.id, now, now,\n item.id, completionId, completedRevision],\n },\n {\n sql: `INSERT INTO planned_completions\n (id, planned_transaction_id, transaction_id, occurrence_date, previous_next_date, previous_is_active,\n completed_next_date, completed_is_active, completed_revision, status, created_at)\n SELECT ?, ?, ?, ?, ?, ?, ?, ?, ?, 'completed', ?\n WHERE EXISTS (SELECT 1 FROM planned_transactions WHERE id = ? AND latest_completion_id = ? AND revision = ?)\n AND EXISTS (SELECT 1 FROM transactions WHERE id = ?)`,\n args: [completionId, item.id, transactionId, item.nextDate, item.nextDate, Number(item.isActive), nextDate,\n Number(remainsActive), completedRevision, now, item.id, completionId, completedRevision, transactionId],\n },\n {\n sql: `UPDATE accounts SET balance_cents = balance_cents + ?, updated_at = ?, is_demo = 0\n WHERE id = ? AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ?)`,\n args: [signedAmount, now, targetAccountId, completionId],\n },\n ];\n}\n\nconst claimSql = `UPDATE planned_completions SET operation_token = ?\n WHERE id = ? AND COALESCE(correction_transaction_id, transaction_id) = ?\n AND status IN ('completed', 'corrected') AND operation_token IS NULL\n AND EXISTS (\n SELECT 1 FROM planned_transactions p\n WHERE p.id = planned_completions.planned_transaction_id\n AND p.latest_completion_id = planned_completions.id\n AND p.revision = planned_completions.completed_revision\n AND p.next_date = planned_completions.completed_next_date\n AND p.is_active = planned_completions.completed_is_active\n )\n AND EXISTS (SELECT 1 FROM transactions t\n WHERE t.id = COALESCE(planned_completions.correction_transaction_id, planned_completions.transaction_id)\n AND t.voided_at IS NULL)`;\n\nexport function undoPlannedStatements(input: { completionId: string; expectedEffectiveTransactionId: string; token: string; now: string }): SqlStatement[] {\n const { completionId, expectedEffectiveTransactionId, token, now } = input;\n return [\n { sql: claimSql, args: [token, completionId, expectedEffectiveTransactionId] },\n {\n sql: `UPDATE accounts SET balance_cents = balance_cents -\n (SELECT amount_cents FROM transactions WHERE id = (SELECT COALESCE(correction_transaction_id, transaction_id) FROM planned_completions WHERE id = ?)) , updated_at = ?, is_demo = 0\n WHERE id = (SELECT account_id FROM transactions WHERE id = (SELECT COALESCE(correction_transaction_id, transaction_id) FROM planned_completions WHERE id = ?))\n AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ? AND operation_token = ?)`,\n args: [completionId, now, completionId, completionId, token],\n },\n {\n sql: `UPDATE transactions SET voided_at = ?, updated_at = ?, is_demo = 0\n WHERE id = (SELECT COALESCE(correction_transaction_id, transaction_id) FROM planned_completions WHERE id = ?)\n AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ? AND operation_token = ?)`,\n args: [now, now, completionId, completionId, token],\n },\n {\n sql: `UPDATE planned_transactions SET\n next_date = (SELECT previous_next_date FROM planned_completions WHERE id = ?),\n is_active = (SELECT previous_is_active FROM planned_completions WHERE id = ?),\n revision = revision + 1, latest_completion_id = NULL, updated_at = ?, is_demo = 0\n WHERE id = (SELECT planned_transaction_id FROM planned_completions WHERE id = ?)\n AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ? AND operation_token = ?)`,\n args: [completionId, completionId, now, completionId, completionId, token],\n },\n {\n sql: `UPDATE planned_completions SET status = 'undone', adjusted_at = ?, last_operation_token = ?, operation_token = NULL\n WHERE id = ? AND operation_token = ?`,\n args: [now, token, completionId, token],\n },\n ];\n}\n\nexport function correctPlannedStatements(input: {\n completionId: string;\n expectedEffectiveTransactionId: string;\n correctionTransactionId: string;\n token: string;\n accountId: string;\n date: string;\n amountCents: number;\n now: string;\n}): SqlStatement[] {\n const { completionId, expectedEffectiveTransactionId, correctionTransactionId, token, accountId, date, amountCents, now } = input;\n return [\n { sql: claimSql, args: [token, completionId, expectedEffectiveTransactionId] },\n {\n sql: `UPDATE accounts SET balance_cents = balance_cents -\n (SELECT amount_cents FROM transactions WHERE id = (SELECT COALESCE(correction_transaction_id, transaction_id) FROM planned_completions WHERE id = ?)), updated_at = ?, is_demo = 0\n WHERE id = (SELECT account_id FROM transactions WHERE id = (SELECT COALESCE(correction_transaction_id, transaction_id) FROM planned_completions WHERE id = ?))\n AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ? AND operation_token = ?)`,\n args: [completionId, now, completionId, completionId, token],\n },\n {\n sql: `UPDATE transactions SET voided_at = ?, updated_at = ?, is_demo = 0\n WHERE id = (SELECT COALESCE(correction_transaction_id, transaction_id) FROM planned_completions WHERE id = ?)\n AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ? AND operation_token = ?)`,\n args: [now, now, completionId, completionId, token],\n },\n {\n sql: `INSERT INTO transactions\n (id, account_id, date, amount_cents, currency, description, kind, status, source,\n planned_transaction_id, corrected_from_transaction_id, created_at, updated_at)\n SELECT ?, ?, ?, CASE WHEN t.kind = 'expense' THEN -? ELSE ? END, t.currency, t.description, t.kind,\n 'cleared', 'planned', t.planned_transaction_id, t.id, ?, ?\n FROM planned_completions c JOIN transactions t\n ON t.id = COALESCE(c.correction_transaction_id, c.transaction_id)\n WHERE c.id = ? AND c.operation_token = ?`,\n args: [correctionTransactionId, accountId, date, amountCents, amountCents, now, now, completionId, token],\n },\n {\n sql: `UPDATE accounts SET balance_cents = balance_cents +\n (SELECT amount_cents FROM transactions WHERE id = ?), updated_at = ?, is_demo = 0\n WHERE id = ? AND EXISTS (SELECT 1 FROM planned_completions WHERE id = ? AND operation_token = ?)\n AND EXISTS (SELECT 1 FROM transactions WHERE id = ?)`,\n args: [correctionTransactionId, now, accountId, completionId, token, correctionTransactionId],\n },\n {\n sql: `UPDATE planned_completions SET status = 'corrected', correction_transaction_id = ?, adjusted_at = ?,\n last_operation_token = ?, operation_token = NULL\n WHERE id = ? AND operation_token = ?`,\n args: [correctionTransactionId, now, token, completionId, token],\n },\n ];\n}\n","createdAt",["D",1789542466987],"branchVersion","branchId","037d44a6-73d2-4260-bb85-513aa40dbefe","id","bc270bf3-6831-493b-a6bf-e8bca9c639c8","budget-app",["D",1789257041201],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","019bc8c8-8bb9-72ff-96b5-3323d5278042","pinnedFileId","c47a5506-af04-11f1-b536-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019bc8c8-8bba-72f3-b7c5-f4447a4e9cc4","tursoName","bc270bf36831493ba6bfe8bca9c639c8","tursoHostname","bc270bf36831493ba6bfe8bca9c639c8-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789545036283],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":102},"org",{"_99":98,"_100":-5,"_101":102,"_18":54,"_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",69,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lehmann","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zOE1CeERUd200ZFR6UURGWVJMalVQejNuWDMifQ","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_31":44,"_37":316,"_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":317,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":318,"_83":319,"_85":320,"_87":24},"tree",[188,194,200,203,204,205],"files",[188,189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205],"counts",{"_178":62,"_179":150,"_180":62,"_181":182,"_183":184},"contents",[128,129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":172,"_31":173,"_29":174,"_136":-5,"_40":41,"_39":175,"_138":58,"_37":176,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_26":177},{"_42":166,"_31":167,"_29":168,"_136":-5,"_40":41,"_39":169,"_138":58,"_37":170,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_26":171},{"_42":160,"_31":161,"_29":162,"_136":-5,"_40":41,"_39":150,"_138":58,"_37":163,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_26":165},{"_42":153,"_31":154,"_29":155,"_136":-5,"_40":41,"_39":156,"_138":58,"_37":157,"_13":150,"_33":20,"_35":158,"_23":24,"_143":-5,"_26":159},{"_42":145,"_31":146,"_29":147,"_136":-5,"_40":41,"_39":148,"_138":58,"_37":149,"_13":150,"_33":20,"_35":151,"_23":24,"_143":-5,"_26":152},{"_42":134,"_31":135,"_29":56,"_136":-5,"_40":41,"_39":137,"_138":24,"_37":139,"_13":140,"_33":141,"_35":142,"_23":24,"_143":-5,"_26":144},"df5c9601-3cd4-4ae2-a384-23a244b24255","index.http.ts","parentId",34,"latest",["D",1789505541595],4,"http","// Val Town infers the HTTP trigger from the `.http.ts` filename.\nimport { Hono } from \"npm:hono@4.13.7\";\nimport { getOAuthUserData, oauthMiddleware } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { parseVal, serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { assertDateOnly, householdDate } from \"./shared/finance.ts\";\nimport { Root } from \"./frontend/root.tsx\";\nimport {\n completePlanned,\n cleanupDemoData,\n createAccount,\n createPlanned,\n createReserve,\n createTransaction,\n deleteAccount,\n deletePlanned,\n deleteReserve,\n deleteTransaction,\n getAppData,\n seedDemoData,\n updateAccount,\n updatePlanned,\n updateReserve,\n updateTransaction,\n} from \"./server/repository.ts\";\nimport { DEMO_CLEANUP_CONFIRMATION } from \"./shared/types.ts\";\nimport {\n booleanField,\n centsField,\n dateField,\n enumField,\n exactStringField,\n integerField,\n objectBody,\n optionalString,\n signedCentsField,\n stringField,\n} from \"./server/validation.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.html(Root()));\napp.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal(import.meta.url).links.self.val));\n\napp.get(\"/api/session\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n if (!session?.user) return c.json({ authenticated: false, authorized: false });\n return c.json({\n authenticated: true,\n authorized: isAuthorized(session.user.username),\n username: session.user.username,\n });\n});\n\napp.use(\"/api/*\", async (c, next) => {\n const session = await getOAuthUserData(c.req.raw);\n if (!session?.user) return c.json({ error: \"Authentication required\" }, 401);\n if (!isAuthorized(session.user.username)) return c.json({ error: \"This Val Town account is not allowed\" }, 403);\n if (![\"GET\", \"HEAD\", \"OPTIONS\"].includes(c.req.method)) {\n const origin = c.req.header(\"Origin\");\n const expectedOrigin = new URL(c.req.url).origin;\n if (origin !== expectedOrigin || c.req.header(\"X-BudgetApp-Request\") !== \"1\") {\n return c.json({ error: \"Invalid request origin\" }, 403);\n }\n }\n await next();\n});\n\napp.get(\"/api/data\", async (c) => {\n const asOf = c.req.query(\"asOf\") || householdDate();\n assertDateOnly(asOf);\n return c.json(await getAppData(asOf));\n});\n\napp.post(\"/api/accounts\", async (c) => {\n const body = await readBody(c.req.raw);\n await createAccount({\n name: stringField(body, \"name\", 80),\n type: enumField(body, \"type\", [\"checking\", \"savings\", \"cash\"] as const),\n balanceCents: signedCentsField(body, \"balanceCents\"),\n });\n return c.json({ ok: true }, 201);\n});\n\napp.put(\"/api/accounts/:id\", async (c) => {\n const body = await readBody(c.req.raw);\n await updateAccount(safeId(c.req.param(\"id\")), {\n name: stringField(body, \"name\", 80),\n type: enumField(body, \"type\", [\"checking\", \"savings\", \"cash\"] as const),\n balanceCents: signedCentsField(body, \"balanceCents\"),\n isActive: booleanField(body, \"isActive\", true),\n });\n return c.json({ ok: true });\n});\n\napp.delete(\"/api/accounts/:id\", async (c) => {\n await deleteAccount(safeId(c.req.param(\"id\")));\n return c.body(null, 204);\n});\n\napp.post(\"/api/transactions\", async (c) => {\n const body = await readBody(c.req.raw);\n await createTransaction({\n accountId: safeId(stringField(body, \"accountId\", 64)),\n date: dateField(body, \"date\"),\n amountCents: centsField(body),\n description: stringField(body, \"description\", 160),\n kind: enumField(body, \"kind\", [\"income\", \"expense\"] as const),\n });\n return c.json({ ok: true }, 201);\n});\n\napp.put(\"/api/transactions/:id\", async (c) => {\n const body = await readBody(c.req.raw);\n await updateTransaction(safeId(c.req.param(\"id\")), {\n accountId: safeId(stringField(body, \"accountId\", 64)),\n date: dateField(body, \"date\"),\n amountCents: centsField(body),\n description: stringField(body, \"description\", 160),\n kind: enumField(body, \"kind\", [\"income\", \"expense\"] as const),\n });\n return c.json({ ok: true });\n});\n\napp.delete(\"/api/transactions/:id\", async (c) => {\n await deleteTransaction(safeId(c.req.param(\"id\")));\n return c.body(null, 204);\n});\n\napp.post(\"/api/planned\", async (c) => {\n const body = await readBody(c.req.raw);\n await createPlanned(plannedInput(body));\n return c.json({ ok: true }, 201);\n});\n\napp.put(\"/api/planned/:id\", async (c) => {\n await updatePlanned(safeId(c.req.param(\"id\")), plannedInput(await readBody(c.req.raw)));\n return c.json({ ok: true });\n});\n\napp.post(\"/api/planned/:id/complete\", async (c) => {\n const body = await readBody(c.req.raw);\n const accountId = optionalString(body, \"accountId\", 64);\n await completePlanned(\n safeId(c.req.param(\"id\")),\n dateField(body, \"date\"),\n accountId ? safeId(accountId) : null,\n );\n return c.json({ ok: true });\n});\n\napp.delete(\"/api/planned/:id\", async (c) => {\n await deletePlanned(safeId(c.req.param(\"id\")));\n return c.body(null, 204);\n});\n\napp.post(\"/api/reserves\", async (c) => {\n const body = await readBody(c.req.raw);\n await createReserve({\n name: stringField(body, \"name\", 80),\n amountCents: centsField(body, \"amountCents\", true),\n note: optionalString(body, \"note\", 300) ?? \"\",\n });\n return c.json({ ok: true }, 201);\n});\n\napp.put(\"/api/reserves/:id\", async (c) => {\n const body = await readBody(c.req.raw);\n await updateReserve(safeId(c.req.param(\"id\")), {\n name: stringField(body, \"name\", 80),\n amountCents: centsField(body, \"amountCents\", true),\n note: optionalString(body, \"note\", 300) ?? \"\",\n isActive: booleanField(body, \"isActive\", true),\n });\n return c.json({ ok: true });\n});\n\napp.delete(\"/api/reserves/:id\", async (c) => {\n await deleteReserve(safeId(c.req.param(\"id\")));\n return c.body(null, 204);\n});\n\napp.post(\"/api/demo\", async (c) => c.json({ seeded: await seedDemoData() }));\n\napp.delete(\"/api/demo\", async (c) => {\n const body = await readBody(c.req.raw);\n const confirmation = exactStringField(body, \"confirmation\", DEMO_CLEANUP_CONFIRMATION.length);\n return c.json({ cleaned: await cleanupDemoData(confirmation) });\n});\n\napp.notFound((c) => c.json({ error: \"Not found\" }, 404));\napp.onError((error, c) => {\n const status = Number((error as Error & { status?: number }).status) ||\n (/constraint/i.test(error.message) ? 409 : error instanceof SyntaxError ? 400 : 500);\n if (status >= 500) console.error(\"BudgetApp request failed\", error.name, error.message);\n return c.json({ error: status >= 500 ? \"Unexpected server error\" : error.message }, status as 400);\n});\n\nfunction isAuthorized(username: string | null): boolean {\n if (!username) return false;\n const owner = parseVal(import.meta.url).username.toLowerCase();\n const extras = (Deno.env.get(\"BUDGET_APP_ALLOWED_USERS\") ?? \"\")\n .split(\",\")\n .map((value) => value.trim().toLowerCase())\n .filter(Boolean);\n return username.toLowerCase() === owner || extras.includes(username.toLowerCase());\n}\n\nasync function readBody(request: Request): Promise> {\n const length = Number(request.headers.get(\"content-length\") ?? 0);\n if (length > 32_000) throw Object.assign(new Error(\"Request body is too large\"), { status: 413 });\n return objectBody(await request.json());\n}\n\nfunction safeId(value: string): string {\n if (!/^[0-9a-f-]{36}$/i.test(value)) throw new Error(\"Invalid id\");\n return value;\n}\n\nfunction plannedInput(body: Record) {\n const accountId = optionalString(body, \"accountId\", 64);\n const nextDate = dateField(body, \"nextDate\");\n const endDate = optionalString(body, \"endDate\", 10);\n if (endDate) {\n assertDateOnly(endDate);\n if (endDate < nextDate) throw new Error(\"endDate cannot be before nextDate\");\n }\n return {\n accountId: accountId ? safeId(accountId) : null,\n description: stringField(body, \"description\", 160),\n kind: enumField(body, \"kind\", [\"income\", \"expense\"] as const),\n amountCents: centsField(body),\n recurrence: enumField(body, \"recurrence\", [\"once\", \"weekly\", \"monthly\", \"yearly\"] as const),\n intervalCount: integerField(body, \"intervalCount\"),\n nextDate,\n endDate,\n isActive: booleanField(body, \"isActive\", true),\n };\n}\n\nexport default oauthMiddleware(app.fetch);\n","label",[135],"239448e8-060b-40bd-b861-76e6e3429268","deno.json","c4748054-af04-11f1-9abb-1607ee4eb77e",32,["D",1789259984492],1,"{\n \"nodeModulesDir\": \"auto\",\n \"compilerOptions\": {\n \"strict\": true,\n \"noImplicitOverride\": true\n },\n \"imports\": {\n \"hono\": \"npm:hono@4.13.7\"\n },\n \"exclude\": [\"node_modules\", \"tests\"]\n}\n",[146],"d927bf8f-079f-4da8-aa1e-3549a8149d4f",".vtignore","c498fea2-af04-11f1-9d2b-1607ee4eb77e",23,["D",1789257283542],".git/\n.github/\n.gitignore\nnode_modules/\ntests/\ntypes/\npackage-lock.json\npackage.json\ntsconfig.json\ndeno.lock\ndocs/\nREADME.md\nROADMAP.md\n.env*\n",[154],"65021267-97d2-46c5-a1f1-8e3430d2e5b8","shared","c42952fa-af04-11f1-83ee-1607ee4eb77e",["D",1789257043083],"directory",[161],"ccf57a66-c3e0-4a52-9c44-82a68ddbe0ec","server","c448cf40-af04-11f1-9abb-1607ee4eb77e",3,["D",1789257043295],[167],"e62562cf-b974-4924-a7ea-327aaca48cfe","frontend","c43a05aa-af04-11f1-9abb-1607ee4eb77e",2,["D",1789257043196],[173],"pulls","branches","forks","envVars",{"_185":62,"_187":62},"connections",{"_185":62,"_186":62},"count","unfilledCount","emptyCount",{"_42":172,"_31":173,"_29":174,"_136":-5,"_40":41,"_39":175,"_138":58,"_37":313,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_207":314,"_26":315},{"_42":308,"_31":307,"_29":301,"_136":174,"_40":41,"_39":309,"_138":58,"_37":310,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_207":311,"_26":312},{"_42":298,"_31":299,"_29":300,"_136":301,"_40":41,"_39":302,"_138":24,"_37":303,"_13":175,"_33":34,"_35":304,"_23":24,"_143":-5,"_207":305,"_26":306},{"_42":290,"_31":291,"_29":292,"_136":174,"_40":41,"_39":293,"_138":58,"_37":294,"_13":62,"_33":20,"_35":295,"_23":24,"_143":-5,"_207":296,"_26":297},{"_42":282,"_31":283,"_29":284,"_136":174,"_40":41,"_39":285,"_138":58,"_37":286,"_13":62,"_33":34,"_35":287,"_23":24,"_143":-5,"_207":288,"_26":289},{"_42":274,"_31":275,"_29":276,"_136":174,"_40":41,"_39":277,"_138":58,"_37":278,"_13":62,"_33":34,"_35":279,"_23":24,"_143":-5,"_207":280,"_26":281},{"_42":166,"_31":167,"_29":168,"_136":-5,"_40":41,"_39":169,"_138":58,"_37":271,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_207":272,"_26":273},{"_42":263,"_31":264,"_29":265,"_136":168,"_40":41,"_39":266,"_138":24,"_37":267,"_13":150,"_33":34,"_35":268,"_23":24,"_143":-5,"_207":269,"_26":270},{"_42":255,"_31":256,"_29":257,"_136":168,"_40":41,"_39":258,"_138":58,"_37":259,"_13":62,"_33":34,"_35":260,"_23":24,"_143":-5,"_207":261,"_26":262},{"_42":251,"_31":32,"_29":30,"_136":168,"_40":41,"_39":14,"_138":58,"_37":252,"_13":62,"_33":34,"_35":36,"_23":24,"_143":-5,"_207":253,"_26":254},{"_42":243,"_31":244,"_29":245,"_136":168,"_40":41,"_39":246,"_138":24,"_37":247,"_13":150,"_33":34,"_35":248,"_23":24,"_143":-5,"_207":249,"_26":250},{"_42":235,"_31":236,"_29":237,"_136":168,"_40":41,"_39":238,"_138":24,"_37":239,"_13":150,"_33":34,"_35":240,"_23":24,"_143":-5,"_207":241,"_26":242},{"_42":160,"_31":161,"_29":162,"_136":-5,"_40":41,"_39":150,"_138":58,"_37":232,"_13":62,"_33":164,"_35":-5,"_23":24,"_143":-5,"_207":233,"_26":234},{"_42":224,"_31":225,"_29":226,"_136":162,"_40":41,"_39":227,"_138":24,"_37":228,"_13":62,"_33":34,"_35":229,"_23":24,"_143":-5,"_207":230,"_26":231},{"_42":216,"_31":217,"_29":218,"_136":162,"_40":41,"_39":219,"_138":24,"_37":220,"_13":150,"_33":34,"_35":221,"_23":24,"_143":-5,"_207":222,"_26":223},{"_42":153,"_31":154,"_29":155,"_136":-5,"_40":41,"_39":156,"_138":58,"_37":213,"_13":150,"_33":20,"_35":158,"_23":24,"_143":-5,"_207":214,"_26":215},{"_42":145,"_31":146,"_29":147,"_136":-5,"_40":41,"_39":148,"_138":58,"_37":210,"_13":150,"_33":20,"_35":151,"_23":24,"_143":-5,"_207":211,"_26":212},{"_42":134,"_31":135,"_29":56,"_136":-5,"_40":41,"_39":137,"_138":24,"_37":206,"_13":140,"_33":141,"_35":142,"_23":24,"_143":-5,"_207":208,"_26":209},["D",1789505541595],"children",[],[135],["D",1789259984492],[],[146],["D",1789257283542],[],[154],"98af08e2-ee76-4566-9b92-affc015d631c","types.ts","c482b91c-af04-11f1-bb78-1607ee4eb77e",37,["D",1789505541703],"export type AccountType = \"checking\" | \"savings\" | \"cash\";\nexport type TransactionKind = \"income\" | \"expense\" | \"refund\" | \"transfer\";\nexport type TransactionStatus = \"cleared\" | \"pending\";\nexport type Recurrence = \"once\" | \"weekly\" | \"monthly\" | \"yearly\";\nexport type PlannedKind = \"income\" | \"expense\";\nexport type DemoDataState = \"empty\" | \"demo-only\" | \"real-or-mixed\";\nexport const DEMO_CLEANUP_CONFIRMATION = \"DELETE DEMO DATA\";\n\nexport function canCleanupDemoData(state: DemoDataState): boolean {\n return state === \"demo-only\";\n}\n\nexport interface Account {\n id: string;\n name: string;\n type: AccountType;\n currency: string;\n balanceCents: number;\n isActive: boolean;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface Transaction {\n id: string;\n accountId: string;\n date: string;\n amountCents: number;\n currency: string;\n description: string;\n kind: TransactionKind;\n status: TransactionStatus;\n source: \"manual\" | \"import\" | \"planned\";\n transferGroupId: string | null;\n plannedTransactionId: string | null;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface PlannedTransaction {\n id: string;\n accountId: string | null;\n description: string;\n kind: PlannedKind;\n amountCents: number;\n currency: string;\n recurrence: Recurrence;\n intervalCount: number;\n nextDate: string;\n endDate: string | null;\n isActive: boolean;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface Reserve {\n id: string;\n name: string;\n amountCents: number;\n currency: string;\n note: string;\n isActive: boolean;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface PlannedOccurrence {\n plannedTransactionId: string;\n description: string;\n kind: PlannedKind;\n amountCents: number;\n date: string;\n}\n\nexport interface DashboardSummary {\n asOfDate: string;\n monthStart: string;\n monthEnd: string;\n currentCashCents: number;\n spentThisMonthCents: number;\n remainingIncomeCents: number;\n remainingExpensesCents: number;\n protectedReservesCents: number;\n projectedMonthEndCents: number;\n safeToSpendCents: number;\n upcoming: PlannedOccurrence[];\n}\n\nexport interface AppData {\n dashboard: DashboardSummary;\n accounts: Account[];\n transactions: Transaction[];\n plannedTransactions: PlannedTransaction[];\n reserves: Reserve[];\n demoDataState: DemoDataState;\n}\n",[],[161,217],"b2a40611-5738-4b92-8324-d42002a33263","finance.ts","c4dbe0aa-af04-11f1-800c-1607ee4eb77e",18,["D",1789257043587],"import type {\n Account,\n DashboardSummary,\n PlannedOccurrence,\n PlannedTransaction,\n Reserve,\n Transaction,\n} from \"./types.ts\";\n\nconst DATE_RE = /^\\d{4}-\\d{2}-\\d{2}$/;\n\nexport function assertDateOnly(value: string): void {\n if (!DATE_RE.test(value)) throw new Error(\"Date must use YYYY-MM-DD\");\n const [year, month, day] = value.split(\"-\").map(Number);\n const parsed = new Date(Date.UTC(year, month - 1, day));\n if (\n parsed.getUTCFullYear() !== year ||\n parsed.getUTCMonth() !== month - 1 ||\n parsed.getUTCDate() !== day\n ) throw new Error(\"Date is invalid\");\n}\n\nexport function householdDate(now = new Date(), timeZone = \"Europe/Rome\"): string {\n return new Intl.DateTimeFormat(\"en-CA\", {\n timeZone,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).format(now);\n}\n\nexport function monthBounds(date: string): { start: string; end: string } {\n assertDateOnly(date);\n const [year, month] = date.split(\"-\").map(Number);\n return {\n start: `${year}-${String(month).padStart(2, \"0\")}-01`,\n end: formatUtcDate(new Date(Date.UTC(year, month, 0))),\n };\n}\n\nexport function addRecurrence(\n date: string,\n recurrence: PlannedTransaction[\"recurrence\"],\n intervalCount: number,\n): string | null {\n assertDateOnly(date);\n if (recurrence === \"once\") return null;\n if (!Number.isInteger(intervalCount) || intervalCount < 1) throw new Error(\"Interval must be a positive integer\");\n const [year, month, day] = date.split(\"-\").map(Number);\n if (recurrence === \"weekly\") {\n return formatUtcDate(new Date(Date.UTC(year, month - 1, day + 7 * intervalCount)));\n }\n if (recurrence === \"monthly\") {\n const targetMonthStart = new Date(Date.UTC(year, month - 1 + intervalCount, 1));\n const targetYear = targetMonthStart.getUTCFullYear();\n const targetMonth = targetMonthStart.getUTCMonth();\n const lastDay = new Date(Date.UTC(targetYear, targetMonth + 1, 0)).getUTCDate();\n return formatUtcDate(new Date(Date.UTC(targetYear, targetMonth, Math.min(day, lastDay))));\n }\n const targetYear = year + intervalCount;\n const lastDay = new Date(Date.UTC(targetYear, month, 0)).getUTCDate();\n return formatUtcDate(new Date(Date.UTC(targetYear, month - 1, Math.min(day, lastDay))));\n}\n\nexport function occurrencesBetween(\n item: PlannedTransaction,\n fromDate: string,\n toDate: string,\n): PlannedOccurrence[] {\n if (!item.isActive || item.nextDate > toDate || (item.endDate && item.nextDate > item.endDate)) return [];\n const occurrences: PlannedOccurrence[] = [];\n let cursor: string | null = item.nextDate;\n let guard = 0;\n while (cursor && cursor <= toDate && (!item.endDate || cursor <= item.endDate)) {\n if (cursor >= fromDate) {\n occurrences.push({\n plannedTransactionId: item.id,\n description: item.description,\n kind: item.kind,\n amountCents: item.amountCents,\n date: cursor,\n });\n }\n cursor = addRecurrence(cursor, item.recurrence, item.intervalCount);\n if (++guard > 400) throw new Error(\"Recurrence produced too many occurrences\");\n }\n return occurrences;\n}\n\nexport function calculateDashboard(input: {\n asOfDate: string;\n accounts: Account[];\n transactions: Transaction[];\n plannedTransactions: PlannedTransaction[];\n reserves: Reserve[];\n}): DashboardSummary {\n const { start, end } = monthBounds(input.asOfDate);\n const currentCashCents = sum(input.accounts.filter((a) => a.isActive), (a) => a.balanceCents);\n const monthTransactions = input.transactions.filter(\n (t) => t.status === \"cleared\" && t.date >= start && t.date <= input.asOfDate && t.kind !== \"transfer\",\n );\n const grossExpenses = sum(monthTransactions.filter((t) => t.kind === \"expense\"), (t) => Math.abs(t.amountCents));\n const refunds = sum(monthTransactions.filter((t) => t.kind === \"refund\"), (t) => Math.abs(t.amountCents));\n const spentThisMonthCents = Math.max(0, grossExpenses - refunds);\n const upcoming = input.plannedTransactions\n // nextDate is the earliest unpaid occurrence, so overdue items remain\n // committed until explicitly completed rather than disappearing at midnight.\n .flatMap((item) => occurrencesBetween(item, item.nextDate, end))\n .sort((a, b) => a.date.localeCompare(b.date) || a.description.localeCompare(b.description));\n const remainingIncomeCents = sum(upcoming.filter((o) => o.kind === \"income\"), (o) => o.amountCents);\n const remainingExpensesCents = sum(upcoming.filter((o) => o.kind === \"expense\"), (o) => o.amountCents);\n const protectedReservesCents = sum(input.reserves.filter((r) => r.isActive), (r) => r.amountCents);\n const projectedMonthEndCents = currentCashCents + remainingIncomeCents - remainingExpensesCents;\n const safeToSpendCents = projectedMonthEndCents - protectedReservesCents;\n\n return {\n asOfDate: input.asOfDate,\n monthStart: start,\n monthEnd: end,\n currentCashCents,\n spentThisMonthCents,\n remainingIncomeCents,\n remainingExpensesCents,\n protectedReservesCents,\n projectedMonthEndCents,\n safeToSpendCents,\n upcoming,\n };\n}\n\nfunction sum(items: T[], value: (item: T) => number): number {\n return items.reduce((total, item) => total + value(item), 0);\n}\n\nfunction formatUtcDate(date: Date): string {\n return date.toISOString().slice(0, 10);\n}\n",[],[161,225],["D",1789257043083],[201,202],[161],"7d6e0f36-e605-4124-bb4c-aa1f98028d39","validation.ts","c4bc29f4-af04-11f1-8508-1607ee4eb77e",39,["D",1789505541788],"import { assertDateOnly } from \"../shared/finance.ts\";\n\nexport function objectBody(value: unknown): Record {\n if (!value || typeof value !== \"object\" || Array.isArray(value)) throw new Error(\"A JSON object is required\");\n return value as Record;\n}\n\nexport function stringField(body: Record, key: string, max = 120): string {\n const value = body[key];\n if (typeof value !== \"string\" || !value.trim()) throw new Error(`${key} is required`);\n const normalized = value.trim();\n if (normalized.length > max) throw new Error(`${key} is too long`);\n return normalized;\n}\n\nexport function exactStringField(body: Record, key: string, max = 120): string {\n const value = body[key];\n if (typeof value !== \"string\" || !value) throw new Error(`${key} is required`);\n if (value.length > max) throw new Error(`${key} is too long`);\n return value;\n}\n\nexport function optionalString(body: Record, key: string, max = 500): string | null {\n const value = body[key];\n if (value == null || value === \"\") return null;\n if (typeof value !== \"string\" || value.length > max) throw new Error(`${key} is invalid`);\n return value.trim();\n}\n\nexport function enumField(body: Record, key: string, allowed: readonly T[]): T {\n const value = body[key];\n if (typeof value !== \"string\" || !allowed.includes(value as T)) throw new Error(`${key} is invalid`);\n return value as T;\n}\n\nexport function centsField(body: Record, key = \"amountCents\", allowZero = false): number {\n const value = body[key];\n if (!Number.isSafeInteger(value) || (allowZero ? (value as number) < 0 : (value as number) <= 0)) {\n throw new Error(`${key} must be a safe integer number of cents${allowZero ? \"\" : \" greater than zero\"}`);\n }\n return value as number;\n}\n\nexport function signedCentsField(body: Record, key: string): number {\n const value = body[key];\n if (!Number.isSafeInteger(value)) throw new Error(`${key} must be a safe integer number of cents`);\n return value as number;\n}\n\nexport function integerField(body: Record, key: string, min = 1): number {\n const value = body[key];\n if (!Number.isSafeInteger(value) || (value as number) < min) throw new Error(`${key} is invalid`);\n return value as number;\n}\n\nexport function dateField(body: Record, key: string): string {\n const value = stringField(body, key, 10);\n assertDateOnly(value);\n return value;\n}\n\nexport function booleanField(body: Record, key: string, fallback: boolean): boolean {\n const value = body[key];\n if (value == null) return fallback;\n if (typeof value !== \"boolean\") throw new Error(`${key} is invalid`);\n return value;\n}\n",[],[167,236],"a956394f-5108-4ee7-b66d-3a3b3b664079","repository.ts","c52d942c-af04-11f1-a256-1607ee4eb77e",35,["D",1789505541601],"import { addRecurrence, calculateDashboard, householdDate } from \"../shared/finance.ts\";\nimport {\n DEMO_CLEANUP_CONFIRMATION,\n type Account,\n type AppData,\n type DemoDataState,\n type PlannedTransaction,\n type Reserve,\n type Transaction,\n} from \"../shared/types.ts\";\nimport { db, ensureSchema } from \"./db.ts\";\nimport {\n classifyDemoData,\n demoCleanupStatements,\n demoSeedStatements,\n demoStateQuery,\n} from \"./demo-data.ts\";\n\ntype Row = Record;\n\nexport async function getAppData(asOfDate = householdDate()): Promise {\n await ensureSchema();\n const [accountResult, transactionResult, plannedResult, reserveResult, demoResult] = await Promise.all([\n db.execute(\"SELECT * FROM accounts ORDER BY is_active DESC, name COLLATE NOCASE\"),\n db.execute(\"SELECT * FROM transactions ORDER BY date DESC, created_at DESC LIMIT 500\"),\n db.execute(\"SELECT * FROM planned_transactions ORDER BY is_active DESC, next_date, description COLLATE NOCASE\"),\n db.execute(\"SELECT * FROM reserves ORDER BY is_active DESC, name COLLATE NOCASE\"),\n db.execute(demoStateQuery()),\n ]);\n const accounts = accountResult.rows.map(mapAccount);\n const transactions = transactionResult.rows.map(mapTransaction);\n const plannedTransactions = plannedResult.rows.map(mapPlanned);\n const reserves = reserveResult.rows.map(mapReserve);\n const demoDataState = demoStateFromRow(demoResult.rows[0] as Row | undefined);\n return {\n accounts,\n transactions,\n plannedTransactions,\n reserves,\n demoDataState,\n dashboard: calculateDashboard({ asOfDate, accounts, transactions, plannedTransactions, reserves }),\n };\n}\n\nexport async function createAccount(input: {\n name: string;\n type: Account[\"type\"];\n balanceCents: number;\n}): Promise {\n await ensureSchema();\n const now = new Date().toISOString();\n await db.execute({\n sql: `INSERT INTO accounts (id, name, type, currency, balance_cents, is_active, created_at, updated_at)\n VALUES (?, ?, ?, 'EUR', ?, 1, ?, ?)`,\n args: [crypto.randomUUID(), input.name, input.type, input.balanceCents, now, now],\n });\n}\n\nexport async function updateAccount(id: string, input: {\n name: string;\n type: Account[\"type\"];\n balanceCents: number;\n isActive: boolean;\n}): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `UPDATE accounts SET name = ?, type = ?, balance_cents = ?, is_active = ?, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [input.name, input.type, input.balanceCents, Number(input.isActive), new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Account\");\n}\n\nexport async function deleteAccount(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({ sql: \"DELETE FROM accounts WHERE id = ?\", args: [id] });\n requireChanged(result.rowsAffected, \"Account\");\n}\n\nexport async function createTransaction(input: {\n accountId: string;\n date: string;\n amountCents: number;\n description: string;\n kind: \"income\" | \"expense\";\n source?: \"manual\" | \"planned\";\n plannedTransactionId?: string | null;\n}): Promise {\n await ensureSchema();\n const signedAmount = input.kind === \"expense\" ? -input.amountCents : input.amountCents;\n const now = new Date().toISOString();\n await db.batch([\n {\n sql: `INSERT INTO transactions\n (id, account_id, date, amount_cents, currency, description, kind, status, source, planned_transaction_id, created_at, updated_at)\n VALUES (?, ?, ?, ?, 'EUR', ?, ?, 'cleared', ?, ?, ?, ?)`,\n args: [crypto.randomUUID(), input.accountId, input.date, signedAmount, input.description, input.kind,\n input.source ?? \"manual\", input.plannedTransactionId ?? null, now, now],\n },\n { sql: \"UPDATE accounts SET balance_cents = balance_cents + ?, updated_at = ?, is_demo = 0 WHERE id = ?\", args: [signedAmount, now, input.accountId] },\n ]);\n}\n\nexport async function updateTransaction(id: string, input: {\n accountId: string;\n date: string;\n amountCents: number;\n description: string;\n kind: \"income\" | \"expense\";\n}): Promise {\n await ensureSchema();\n const existing = await one(\"SELECT * FROM transactions WHERE id = ?\", [id]);\n if (!existing) throw notFound(\"Transaction\");\n if (existing.source !== \"manual\") throw conflict(\"Only manual transactions can be edited\");\n const oldAmount = Number(existing.amount_cents);\n const newAmount = input.kind === \"expense\" ? -input.amountCents : input.amountCents;\n const oldAccountId = String(existing.account_id);\n const now = new Date().toISOString();\n await db.batch([\n { sql: \"UPDATE accounts SET balance_cents = balance_cents - ?, updated_at = ?, is_demo = 0 WHERE id = ?\", args: [oldAmount, now, oldAccountId] },\n { sql: \"UPDATE accounts SET balance_cents = balance_cents + ?, updated_at = ?, is_demo = 0 WHERE id = ?\", args: [newAmount, now, input.accountId] },\n {\n sql: `UPDATE transactions SET account_id = ?, date = ?, amount_cents = ?, description = ?, kind = ?, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [input.accountId, input.date, newAmount, input.description, input.kind, now, id],\n },\n ]);\n}\n\nexport async function deleteTransaction(id: string): Promise {\n await ensureSchema();\n const existing = await one(\"SELECT * FROM transactions WHERE id = ?\", [id]);\n if (!existing) throw notFound(\"Transaction\");\n if (existing.source !== \"manual\") throw conflict(\"Only manual transactions can be deleted directly\");\n await db.batch([\n {\n sql: \"UPDATE accounts SET balance_cents = balance_cents - ?, updated_at = ?, is_demo = 0 WHERE id = ?\",\n args: [Number(existing.amount_cents), new Date().toISOString(), String(existing.account_id)],\n },\n { sql: \"DELETE FROM transactions WHERE id = ?\", args: [id] },\n ]);\n}\n\nexport async function createPlanned(input: Omit): Promise {\n await ensureSchema();\n const now = new Date().toISOString();\n await db.execute({\n sql: `INSERT INTO planned_transactions\n (id, account_id, description, kind, amount_cents, currency, recurrence, interval_count, next_date, end_date, is_active, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, 'EUR', ?, ?, ?, ?, ?, ?, ?)`,\n args: [crypto.randomUUID(), input.accountId, input.description, input.kind, input.amountCents, input.recurrence,\n input.intervalCount, input.nextDate, input.endDate, Number(input.isActive), now, now],\n });\n}\n\nexport async function updatePlanned(id: string, input: Omit): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `UPDATE planned_transactions SET account_id = ?, description = ?, kind = ?, amount_cents = ?, recurrence = ?,\n interval_count = ?, next_date = ?, end_date = ?, is_active = ?, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [input.accountId, input.description, input.kind, input.amountCents, input.recurrence, input.intervalCount,\n input.nextDate, input.endDate, Number(input.isActive), new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Planned transaction\");\n}\n\nexport async function completePlanned(id: string, actualDate: string, accountId?: string | null): Promise {\n await ensureSchema();\n const row = await one(\"SELECT * FROM planned_transactions WHERE id = ?\", [id]);\n if (!row) throw notFound(\"Planned transaction\");\n const item = mapPlanned(row);\n if (!item.isActive) throw conflict(\"Planned transaction is inactive\");\n const targetAccountId = accountId || item.accountId;\n if (!targetAccountId) throw conflict(\"Choose an account before marking this item paid\");\n const signedAmount = item.kind === \"expense\" ? -item.amountCents : item.amountCents;\n const nextDate = addRecurrence(item.nextDate, item.recurrence, item.intervalCount);\n const remainsActive = Boolean(nextDate && (!item.endDate || nextDate <= item.endDate));\n const now = new Date().toISOString();\n await db.batch([\n {\n sql: `INSERT INTO transactions\n (id, account_id, date, amount_cents, currency, description, kind, status, source, planned_transaction_id, created_at, updated_at)\n VALUES (?, ?, ?, ?, 'EUR', ?, ?, 'cleared', 'planned', ?, ?, ?)`,\n args: [crypto.randomUUID(), targetAccountId, actualDate, signedAmount, item.description, item.kind, id, now, now],\n },\n { sql: \"UPDATE accounts SET balance_cents = balance_cents + ?, updated_at = ?, is_demo = 0 WHERE id = ?\", args: [signedAmount, now, targetAccountId] },\n {\n sql: \"UPDATE planned_transactions SET next_date = ?, is_active = ?, updated_at = ?, is_demo = 0 WHERE id = ?\",\n args: [nextDate ?? item.nextDate, Number(remainsActive), now, id],\n },\n ]);\n}\n\nexport async function deletePlanned(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({ sql: \"DELETE FROM planned_transactions WHERE id = ?\", args: [id] });\n requireChanged(result.rowsAffected, \"Planned transaction\");\n}\n\nexport async function createReserve(input: { name: string; amountCents: number; note: string }): Promise {\n await ensureSchema();\n const now = new Date().toISOString();\n await db.execute({\n sql: `INSERT INTO reserves (id, name, amount_cents, currency, note, is_active, created_at, updated_at)\n VALUES (?, ?, ?, 'EUR', ?, 1, ?, ?)`,\n args: [crypto.randomUUID(), input.name, input.amountCents, input.note, now, now],\n });\n}\n\nexport async function updateReserve(id: string, input: { name: string; amountCents: number; note: string; isActive: boolean }): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: \"UPDATE reserves SET name = ?, amount_cents = ?, note = ?, is_active = ?, updated_at = ?, is_demo = 0 WHERE id = ?\",\n args: [input.name, input.amountCents, input.note, Number(input.isActive), new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Reserve\");\n}\n\nexport async function deleteReserve(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({ sql: \"DELETE FROM reserves WHERE id = ?\", args: [id] });\n requireChanged(result.rowsAffected, \"Reserve\");\n}\n\nexport async function seedDemoData(today = householdDate()): Promise {\n await ensureSchema();\n const now = new Date().toISOString();\n const claimToken = crypto.randomUUID();\n const { start } = (() => {\n const month = today.slice(0, 7);\n return { start: `${month}-01` };\n })();\n const day = (value: number) => `${today.slice(0, 8)}${String(value).padStart(2, \"0\")}`;\n const futureDay = Math.min(28, Number(today.slice(8, 10)) + 2);\n const checkingId = crypto.randomUUID();\n await db.batch(demoSeedStatements({\n claimToken,\n checkingId,\n savingsId: crypto.randomUUID(),\n transactionId: crypto.randomUUID(),\n salaryId: crypto.randomUUID(),\n mortgageId: crypto.randomUUID(),\n reserveId: crypto.randomUUID(),\n now,\n monthStart: start,\n salaryDate: day(futureDay),\n mortgageDate: day(Math.min(28, futureDay + 2)),\n }));\n const claim = await one(\"SELECT value FROM app_metadata WHERE key = 'demo_seed_claim'\", []);\n return claim?.value === claimToken;\n}\n\nexport async function cleanupDemoData(confirmation: string): Promise {\n if (confirmation !== DEMO_CLEANUP_CONFIRMATION) throw conflict(`Type ${DEMO_CLEANUP_CONFIRMATION} exactly to remove demo data`);\n await ensureSchema();\n const initialState = await getDemoDataState();\n if (initialState === \"empty\") return false;\n if (initialState !== \"demo-only\") throw conflict(\"Demo cleanup is blocked because this dataset contains real or unmarked data\");\n\n const claimToken = crypto.randomUUID();\n await db.batch(demoCleanupStatements(claimToken, new Date().toISOString()));\n const finalState = await getDemoDataState();\n if (finalState !== \"empty\") throw conflict(\"Demo cleanup was blocked because the dataset changed\");\n return true;\n}\n\nasync function getDemoDataState(): Promise {\n const result = await db.execute(demoStateQuery());\n return demoStateFromRow(result.rows[0] as Row | undefined);\n}\n\nfunction demoStateFromRow(row: Row | undefined): DemoDataState {\n return classifyDemoData(Number(row?.total_count ?? 0), Number(row?.demo_count ?? 0));\n}\n\nasync function one(sql: string, args: (string | number | null)[]): Promise {\n const result = await db.execute({ sql, args });\n return (result.rows[0] as Row | undefined) ?? null;\n}\n\nfunction mapAccount(row: Row): Account {\n return {\n id: String(row.id), name: String(row.name), type: row.type as Account[\"type\"], currency: String(row.currency),\n balanceCents: Number(row.balance_cents), isActive: Boolean(row.is_active), createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n}\n\nfunction mapTransaction(row: Row): Transaction {\n return {\n id: String(row.id), accountId: String(row.account_id), date: String(row.date), amountCents: Number(row.amount_cents),\n currency: String(row.currency), description: String(row.description), kind: row.kind as Transaction[\"kind\"],\n status: row.status as Transaction[\"status\"], source: row.source as Transaction[\"source\"],\n transferGroupId: row.transfer_group_id == null ? null : String(row.transfer_group_id),\n plannedTransactionId: row.planned_transaction_id == null ? null : String(row.planned_transaction_id),\n createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n}\n\nfunction mapPlanned(row: Row): PlannedTransaction {\n return {\n id: String(row.id), accountId: row.account_id == null ? null : String(row.account_id), description: String(row.description),\n kind: row.kind as PlannedTransaction[\"kind\"], amountCents: Number(row.amount_cents), currency: String(row.currency),\n recurrence: row.recurrence as PlannedTransaction[\"recurrence\"], intervalCount: Number(row.interval_count), nextDate: String(row.next_date),\n endDate: row.end_date == null ? null : String(row.end_date), isActive: Boolean(row.is_active),\n createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n}\n\nfunction mapReserve(row: Row): Reserve {\n return {\n id: String(row.id), name: String(row.name), amountCents: Number(row.amount_cents), currency: String(row.currency),\n note: String(row.note), isActive: Boolean(row.is_active), createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n}\n\nfunction requireChanged(rowsAffected: number, entity: string): void {\n if (!rowsAffected) throw notFound(entity);\n}\n\nfunction notFound(entity: string): Error {\n return Object.assign(new Error(`${entity} not found`), { status: 404 });\n}\n\nfunction conflict(message: string): Error {\n return Object.assign(new Error(message), { status: 409 });\n}\n",[],[167,244],"fde40f78-6d30-4615-9a3f-19f36773e469",["D",1789542466987],[],[167,32],"cccd28dd-ae71-4d72-ba95-4eb63564cefc","demo-data.ts","58dd70ae-b147-11f1-a9c6-1607ee4eb77e",36,["D",1789505541602],"import type { DemoDataState } from \"../shared/types.ts\";\n\nexport interface SqlStatement {\n sql: string;\n args?: (string | number | null)[];\n}\n\nexport const demoEntityTables = [\"accounts\", \"transactions\", \"planned_transactions\", \"reserves\"] as const;\nexport type DemoEntityTable = typeof demoEntityTables[number];\n\nexport function demoProvenanceMigrationSql(table: DemoEntityTable): string {\n return `ALTER TABLE ${table} ADD COLUMN is_demo INTEGER NOT NULL DEFAULT 0 CHECK (is_demo IN (0, 1))`;\n}\n\nexport function demoStateQuery(): string {\n return `SELECT\n (${demoEntityTables.map((table) => `(SELECT COUNT(*) FROM ${table})`).join(\" + \")}) AS total_count,\n (${demoEntityTables.map((table) => `(SELECT COUNT(*) FROM ${table} WHERE is_demo = 1)`).join(\" + \")}) AS demo_count`;\n}\n\nexport function classifyDemoData(totalCount: number, demoCount: number): DemoDataState {\n if (totalCount === 0) return \"empty\";\n return totalCount === demoCount ? \"demo-only\" : \"real-or-mixed\";\n}\n\nexport function isDuplicateIsDemoColumnError(error: unknown): boolean {\n return error instanceof Error && /duplicate column name:\\s*is_demo/i.test(error.message);\n}\n\nexport function demoSeedStatements(input: {\n claimToken: string;\n checkingId: string;\n savingsId: string;\n transactionId: string;\n salaryId: string;\n mortgageId: string;\n reserveId: string;\n now: string;\n monthStart: string;\n salaryDate: string;\n mortgageDate: string;\n}): SqlStatement[] {\n const ownsClaim = `EXISTS (\n SELECT 1 FROM app_metadata WHERE key = 'demo_seed_claim' AND value = ?\n )`;\n const allEntitiesEmpty = demoEntityTables.map((table) => `NOT EXISTS (SELECT 1 FROM ${table})`).join(\" AND \");\n return [\n {\n sql: `DELETE FROM app_metadata WHERE key = 'demo_seed_claim' AND ${allEntitiesEmpty}`,\n },\n {\n sql: `INSERT OR IGNORE INTO app_metadata (key, value, updated_at)\n SELECT 'demo_seed_claim', ?, ?\n WHERE ${allEntitiesEmpty}`,\n args: [input.claimToken, input.now],\n },\n {\n sql: `INSERT INTO accounts\n (id, name, type, currency, balance_cents, is_active, created_at, updated_at, is_demo)\n SELECT ?, 'Main account', 'checking', 'EUR', 284500, 1, ?, ?, 1 WHERE ${ownsClaim}`,\n args: [input.checkingId, input.now, input.now, input.claimToken],\n },\n {\n sql: `INSERT INTO accounts\n (id, name, type, currency, balance_cents, is_active, created_at, updated_at, is_demo)\n SELECT ?, 'Savings', 'savings', 'EUR', 620000, 1, ?, ?, 1 WHERE ${ownsClaim}`,\n args: [input.savingsId, input.now, input.now, input.claimToken],\n },\n {\n sql: `INSERT INTO transactions\n (id, account_id, date, amount_cents, currency, description, kind, status, source,\n transfer_group_id, planned_transaction_id, created_at, updated_at, is_demo)\n SELECT ?, ?, ?, -8650, 'EUR', 'Synthetic household shop', 'expense', 'cleared', 'manual',\n NULL, NULL, ?, ?, 1 WHERE ${ownsClaim}`,\n args: [input.transactionId, input.checkingId, input.monthStart, input.now, input.now, input.claimToken],\n },\n {\n sql: `INSERT INTO planned_transactions\n (id, account_id, description, kind, amount_cents, currency, recurrence, interval_count,\n next_date, end_date, is_active, created_at, updated_at, is_demo)\n SELECT ?, ?, 'Synthetic salary', 'income', 280000, 'EUR', 'monthly', 1,\n ?, NULL, 1, ?, ?, 1 WHERE ${ownsClaim}`,\n args: [input.salaryId, input.checkingId, input.salaryDate, input.now, input.now, input.claimToken],\n },\n {\n sql: `INSERT INTO planned_transactions\n (id, account_id, description, kind, amount_cents, currency, recurrence, interval_count,\n next_date, end_date, is_active, created_at, updated_at, is_demo)\n SELECT ?, ?, 'Mortgage', 'expense', 58100, 'EUR', 'monthly', 1,\n ?, NULL, 1, ?, ?, 1 WHERE ${ownsClaim}`,\n args: [input.mortgageId, input.checkingId, input.mortgageDate, input.now, input.now, input.claimToken],\n },\n {\n sql: `INSERT INTO reserves\n (id, name, amount_cents, currency, note, is_active, created_at, updated_at, is_demo)\n SELECT ?, 'Emergency buffer', 300000, 'EUR', 'Protected from normal spending', 1, ?, ?, 1\n WHERE ${ownsClaim}`,\n args: [input.reserveId, input.now, input.now, input.claimToken],\n },\n ];\n}\n\nexport function demoCleanupStatements(claimToken: string, now: string): SqlStatement[] {\n const hasAnyRows = demoEntityTables.map((table) => `EXISTS (SELECT 1 FROM ${table})`).join(\" OR \");\n const hasRealRows = demoEntityTables.map((table) => `EXISTS (SELECT 1 FROM ${table} WHERE is_demo = 0)`).join(\" OR \");\n const ownsClaim = `EXISTS (\n SELECT 1 FROM app_metadata WHERE key = 'demo_cleanup_claim' AND value = ?\n )`;\n return [\n {\n sql: `INSERT OR IGNORE INTO app_metadata (key, value, updated_at)\n SELECT 'demo_cleanup_claim', ?, ?\n WHERE (${hasAnyRows}) AND NOT (${hasRealRows})`,\n args: [claimToken, now],\n },\n { sql: `DELETE FROM transactions WHERE is_demo = 1 AND ${ownsClaim}`, args: [claimToken] },\n { sql: `DELETE FROM planned_transactions WHERE is_demo = 1 AND ${ownsClaim}`, args: [claimToken] },\n { sql: `DELETE FROM reserves WHERE is_demo = 1 AND ${ownsClaim}`, args: [claimToken] },\n { sql: `DELETE FROM accounts WHERE is_demo = 1 AND ${ownsClaim}`, args: [claimToken] },\n {\n sql: `DELETE FROM app_metadata\n WHERE key = 'demo_seed_claim' AND ${ownsClaim}`,\n args: [claimToken],\n },\n {\n sql: \"DELETE FROM app_metadata WHERE key = 'demo_cleanup_claim' AND value = ?\",\n args: [claimToken],\n },\n ];\n}\n",[],[167,256],"93fa8c79-7292-4243-a7cc-b98d2b4f6c6c","db.ts","c4b5efd0-af04-11f1-bb78-1607ee4eb77e",38,["D",1789505541741],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { demoEntityTables, demoProvenanceMigrationSql, isDuplicateIsDemoColumnError } from \"./demo-data.ts\";\n\nexport const db = sqlite;\n\nlet initialized: Promise | null = null;\n\nexport function ensureSchema(): Promise {\n initialized ??= migrate().catch((error) => {\n initialized = null;\n throw error;\n });\n return initialized;\n}\n\nasync function migrate(): Promise {\n await db.batch([\n `CREATE TABLE IF NOT EXISTS schema_migrations (\n version INTEGER PRIMARY KEY,\n applied_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS accounts (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n type TEXT NOT NULL CHECK (type IN ('checking', 'savings', 'cash')),\n currency TEXT NOT NULL DEFAULT 'EUR',\n balance_cents INTEGER NOT NULL,\n is_active INTEGER NOT NULL DEFAULT 1 CHECK (is_active IN (0, 1)),\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS planned_transactions (\n id TEXT PRIMARY KEY,\n account_id TEXT REFERENCES accounts(id) ON DELETE SET NULL,\n description TEXT NOT NULL,\n kind TEXT NOT NULL CHECK (kind IN ('income', 'expense')),\n amount_cents INTEGER NOT NULL CHECK (amount_cents > 0),\n currency TEXT NOT NULL DEFAULT 'EUR',\n recurrence TEXT NOT NULL CHECK (recurrence IN ('once', 'weekly', 'monthly', 'yearly')),\n interval_count INTEGER NOT NULL DEFAULT 1 CHECK (interval_count > 0),\n next_date TEXT NOT NULL,\n end_date TEXT,\n is_active INTEGER NOT NULL DEFAULT 1 CHECK (is_active IN (0, 1)),\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS transactions (\n id TEXT PRIMARY KEY,\n account_id TEXT NOT NULL REFERENCES accounts(id) ON DELETE RESTRICT,\n date TEXT NOT NULL,\n amount_cents INTEGER NOT NULL CHECK (amount_cents != 0),\n currency TEXT NOT NULL DEFAULT 'EUR',\n description TEXT NOT NULL,\n kind TEXT NOT NULL CHECK (kind IN ('income', 'expense', 'refund', 'transfer')),\n status TEXT NOT NULL CHECK (status IN ('cleared', 'pending')),\n source TEXT NOT NULL CHECK (source IN ('manual', 'import', 'planned')),\n external_id TEXT,\n import_identity TEXT,\n transfer_group_id TEXT,\n planned_transaction_id TEXT REFERENCES planned_transactions(id) ON DELETE SET NULL,\n raw_metadata TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE UNIQUE INDEX IF NOT EXISTS transactions_import_identity_idx\n ON transactions(import_identity) WHERE import_identity IS NOT NULL`,\n `CREATE INDEX IF NOT EXISTS transactions_date_idx ON transactions(date)`,\n `CREATE TABLE IF NOT EXISTS reserves (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n amount_cents INTEGER NOT NULL CHECK (amount_cents >= 0),\n currency TEXT NOT NULL DEFAULT 'EUR',\n note TEXT NOT NULL DEFAULT '',\n is_active INTEGER NOT NULL DEFAULT 1 CHECK (is_active IN (0, 1)),\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS imports (\n id TEXT PRIMARY KEY,\n filename TEXT NOT NULL,\n status TEXT NOT NULL CHECK (status IN ('processing', 'completed', 'failed')),\n row_count INTEGER NOT NULL DEFAULT 0,\n imported_count INTEGER NOT NULL DEFAULT 0,\n duplicate_count INTEGER NOT NULL DEFAULT 0,\n error_summary TEXT,\n created_at TEXT NOT NULL,\n completed_at TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS app_metadata (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n {\n sql: `INSERT OR IGNORE INTO schema_migrations (version, applied_at) VALUES (?, ?)`,\n args: [1, new Date().toISOString()],\n },\n ]);\n\n await applyDemoProvenanceMigration();\n}\n\nasync function applyDemoProvenanceMigration(): Promise {\n const applied = await db.execute(\"SELECT 1 FROM schema_migrations WHERE version = 2\");\n if (applied.rows.length) return;\n\n for (const table of demoEntityTables) {\n try {\n await db.execute(demoProvenanceMigrationSql(table));\n } catch (error) {\n // Concurrent cold starts can both observe an unapplied migration. Only the\n // exact, recoverable duplicate-column outcome is safe to accept.\n if (!isDuplicateIsDemoColumnError(error)) throw error;\n }\n }\n\n await db.execute({\n sql: \"INSERT OR IGNORE INTO schema_migrations (version, applied_at) VALUES (2, ?)\",\n args: [new Date().toISOString()],\n });\n}\n",[],[167,264],["D",1789257043295],[195,196,197,198,199],[167],"1861c029-4d6f-4028-b4c9-d7f27ae9b711","root.tsx","c489761c-af04-11f1-9abb-1607ee4eb77e",9,["D",1789257043718],"/** @jsxImportSource npm:hono@4/jsx */\nimport { raw } from \"npm:hono@4/html\";\nimport { immutableFileUrl } from \"https://esm.town/v/std/utils/index.ts\";\n\nexport function Root() {\n return (\n <>\n {raw(\"\")}\n \n \n \n \n \n \n BudgetApp\n

Diff · v41