BudgetApp

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_350":351,"_352":353},"routes/_app.x.$handle.$name",{"_100":99,"_32":46,"_108":90,"_27":54,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":60,"_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",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":25},"version",69,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","server/repository.ts","latestPath","fileId","c52d942c-af04-11f1-a256-1607ee4eb77e","name","repository.ts","fileType","script","content","import { addRecurrence, calculateDashboard, householdDate, requiredGoalContributionCents } from \"../shared/finance.ts\";\nimport {\n DEMO_CLEANUP_CONFIRMATION,\n type Account,\n type AccountReconciliation,\n type AppData,\n type DemoDataState,\n type PlannedCompletion,\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\";\nimport {\n completePlannedStatements,\n correctPlannedStatements,\n PLANNED_COMPLETIONS_QUERY,\n undoPlannedStatements,\n} from \"./planned-operations.ts\";\nimport { reconcileAccountStatements } from \"./reconciliation-operations.ts\";\nimport { updateReserveStatement } from \"./reserve-operations.ts\";\n\ntype Row = Record;\n\nexport async function getAppData(asOfDate = householdDate()): Promise {\n await ensureSchema();\n const monthStart = `${asOfDate.slice(0, 7)}-01`;\n const [accountResult, reconciliationResult, transactionResult, dashboardTransactionResult, plannedResult, completionResult, reserveResult, demoResult] = await Promise.all([\n db.execute(\"SELECT * FROM accounts ORDER BY is_active DESC, name COLLATE NOCASE\"),\n db.execute(\"SELECT * FROM account_reconciliations ORDER BY date DESC, created_at DESC LIMIT 500\"),\n db.execute(\"SELECT * FROM transactions WHERE voided_at IS NULL ORDER BY date DESC, created_at DESC LIMIT 500\"),\n db.execute({ sql: \"SELECT * FROM transactions WHERE voided_at IS NULL AND date BETWEEN ? AND ?\", args: [monthStart, asOfDate] }),\n db.execute(\"SELECT * FROM planned_transactions ORDER BY is_active DESC, next_date, description COLLATE NOCASE\"),\n db.execute(PLANNED_COMPLETIONS_QUERY),\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 accountReconciliations = reconciliationResult.rows.map(mapReconciliation);\n const transactions = transactionResult.rows.map(mapTransaction);\n const dashboardTransactions = dashboardTransactionResult.rows.map(mapTransaction);\n const plannedTransactions = plannedResult.rows.map(mapPlanned);\n const plannedCompletions = completionResult.rows.map(mapCompletion);\n const reserves = reserveResult.rows.map((row) => mapReserve(row, asOfDate));\n const demoDataState = demoStateFromRow(demoResult.rows[0] as Row | undefined);\n return {\n accounts,\n accountReconciliations,\n transactions,\n plannedTransactions,\n plannedCompletions,\n reserves,\n demoDataState,\n dashboard: calculateDashboard({ asOfDate, accounts, transactions: dashboardTransactions, 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 isActive: boolean;\n}): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `UPDATE accounts SET name = ?, type = ?, is_active = ?, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [input.name, input.type, Number(input.isActive), new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Account\");\n}\n\nexport async function reconcileAccount(id: string, input: {\n actualBalanceCents: number;\n date: string;\n note: string;\n}): Promise {\n await ensureSchema();\n const reconciliationId = crypto.randomUUID();\n await db.batch(reconcileAccountStatements({\n reconciliationId,\n accountId: id,\n actualBalanceCents: input.actualBalanceCents,\n date: input.date,\n note: input.note,\n now: new Date().toISOString(),\n }));\n const created = await one(\"SELECT id FROM account_reconciliations WHERE id = ?\", [reconciliationId]);\n if (created) return;\n const account = await one(\"SELECT is_active FROM accounts WHERE id = ?\", [id]);\n if (!account) throw notFound(\"Account\");\n throw conflict(\"Only active accounts can be reconciled\");\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 = ?, revision = revision + 1,\n latest_completion_id = NULL, 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 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 const completionId = crypto.randomUUID();\n await db.batch(completePlannedStatements({\n item: { ...item, revision: Number(row.revision ?? 0) }, completionId, transactionId: crypto.randomUUID(),\n targetAccountId, actualDate, nextDate: nextDate ?? item.nextDate, remainsActive, now,\n }));\n const created = await one(\"SELECT id FROM planned_completions WHERE id = ?\", [completionId]);\n if (!created) throw conflict(\"This occurrence was already completed; refresh and try again\");\n}\n\nexport async function undoPlannedCompletion(completionId: string, expectedEffectiveTransactionId: string): Promise {\n await ensureSchema();\n const token = crypto.randomUUID();\n await db.batch(undoPlannedStatements({ completionId, expectedEffectiveTransactionId, token, now: new Date().toISOString() }));\n await requireAdjustment(completionId, \"undone\", token);\n}\n\nexport async function correctPlannedCompletion(completionId: string, input: {\n accountId: string;\n date: string;\n amountCents: number;\n expectedEffectiveTransactionId: string;\n}): Promise {\n await ensureSchema();\n const token = crypto.randomUUID();\n await db.batch(correctPlannedStatements({\n completionId, expectedEffectiveTransactionId: input.expectedEffectiveTransactionId,\n correctionTransactionId: crypto.randomUUID(), token,\n accountId: input.accountId, date: input.date, amountCents: input.amountCents, now: new Date().toISOString(),\n }));\n await requireAdjustment(completionId, \"corrected\", token);\n}\n\nasync function requireAdjustment(id: string, expected: \"undone\" | \"corrected\", token: string): Promise {\n const row = await one(\"SELECT status, last_operation_token FROM planned_completions WHERE id = ?\", [id]);\n if (!row) throw notFound(\"Planned completion\");\n if (row.status !== expected || row.last_operation_token !== token) {\n throw conflict(\"Only the latest unchanged completion can be adjusted\");\n }\n}\n\nexport async function deletePlanned(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `DELETE FROM planned_transactions WHERE id = ?\n AND NOT EXISTS (SELECT 1 FROM planned_completions WHERE planned_transaction_id = ?)`,\n args: [id, id],\n });\n if (result.rowsAffected) return;\n const existing = await one(\"SELECT id FROM planned_transactions WHERE id = ?\", [id]);\n if (!existing) throw notFound(\"Planned transaction\");\n throw conflict(\"Completed planned items must be deactivated to preserve their audit history\");\n}\n\nexport async function deactivatePlanned(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `UPDATE planned_transactions SET is_active = 0, revision = revision + 1,\n latest_completion_id = NULL, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Planned transaction\");\n}\n\nexport async function createReserve(input: {\n name: string;\n fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n note: string;\n}): Promise {\n await ensureSchema();\n const now = new Date().toISOString();\n await db.execute({\n sql: `INSERT INTO reserves\n (id, name, amount_cents, target_amount_cents, target_date, contribution_month,\n contribution_cents, currency, note, is_active, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, 0, 'EUR', ?, 1, ?, ?)`,\n args: [crypto.randomUUID(), input.name, input.fundedAmountCents, input.targetAmountCents,\n input.targetDate, input.targetAmountCents == null ? null : householdDate().slice(0, 7), input.note, now, now],\n });\n}\n\nexport async function updateReserve(id: string, input: {\n name: string;\n fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n note: string;\n isActive: boolean;\n}): Promise {\n await ensureSchema();\n const result = await db.execute(updateReserveStatement({\n id,\n ...input,\n contributionMonth: householdDate().slice(0, 7),\n now: new Date().toISOString(),\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 mapReconciliation(row: Row): AccountReconciliation {\n return {\n id: String(row.id), accountId: String(row.account_id), date: String(row.date),\n previousBalanceCents: Number(row.previous_balance_cents),\n actualBalanceCents: Number(row.actual_balance_cents),\n differenceCents: Number(row.difference_cents), note: String(row.note),\n createdAt: String(row.created_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 correctedFromTransactionId: row.corrected_from_transaction_id == null ? null : String(row.corrected_from_transaction_id),\n voidedAt: row.voided_at == null ? null : String(row.voided_at),\n createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n}\n\nfunction mapCompletion(row: Row): PlannedCompletion {\n const originalTransaction = mapTransaction({\n id: row.original_id, account_id: row.original_account_id, date: row.original_date,\n amount_cents: row.original_amount_cents, currency: row.original_currency,\n description: row.original_description, kind: row.original_kind, status: row.original_status,\n source: row.original_source, transfer_group_id: row.original_transfer_group_id,\n planned_transaction_id: row.original_planned_transaction_id,\n corrected_from_transaction_id: row.original_corrected_from_transaction_id,\n voided_at: row.original_voided_at, created_at: row.original_created_at, updated_at: row.original_updated_at,\n });\n const effectiveTransaction = row.effective_id == null ? null : mapTransaction({\n id: row.effective_id, account_id: row.effective_account_id, date: row.effective_date,\n amount_cents: row.effective_amount_cents, currency: row.effective_currency,\n description: row.effective_description, kind: row.effective_kind, status: row.effective_status,\n source: row.effective_source, transfer_group_id: row.effective_transfer_group_id,\n planned_transaction_id: row.effective_planned_transaction_id,\n corrected_from_transaction_id: row.effective_corrected_from_transaction_id,\n voided_at: row.effective_voided_at, created_at: row.effective_created_at, updated_at: row.effective_updated_at,\n });\n return {\n id: String(row.id), plannedTransactionId: String(row.planned_transaction_id),\n originalTransactionId: String(row.transaction_id),\n correctionTransactionId: row.correction_transaction_id == null ? null : String(row.correction_transaction_id),\n occurrenceDate: String(row.occurrence_date), completedAt: String(row.created_at),\n adjustedAt: row.adjusted_at == null ? null : String(row.adjusted_at),\n status: row.status as PlannedCompletion[\"status\"], adjustable: Boolean(row.adjustable),\n originalTransaction, effectiveTransaction,\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, asOfDate: string): Reserve {\n const reserve: Reserve = {\n id: String(row.id), name: String(row.name), fundedAmountCents: Number(row.amount_cents),\n targetAmountCents: row.target_amount_cents == null ? null : Number(row.target_amount_cents),\n targetDate: row.target_date == null ? null : String(row.target_date),\n contributionMonth: row.contribution_month == null ? null : String(row.contribution_month),\n contributedThisMonthCents: Number(row.contribution_cents), requiredContributionCents: 0,\n currency: String(row.currency), note: String(row.note), isActive: Boolean(row.is_active),\n createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n reserve.requiredContributionCents = requiredGoalContributionCents(reserve, asOfDate);\n return reserve;\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","import { addRecurrence, calculateDashboard, householdDate, requiredGoalContributionCents } from \"../shared/finance.ts\";\nimport {\n DEMO_CLEANUP_CONFIRMATION,\n type Account,\n type AccountReconciliation,\n type AppData,\n type DemoDataState,\n type PlannedCompletion,\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\";\nimport {\n completePlannedStatements,\n correctPlannedStatements,\n PLANNED_COMPLETIONS_QUERY,\n undoPlannedStatements,\n} from \"./planned-operations.ts\";\nimport { reconcileAccountStatements } from \"./reconciliation-operations.ts\";\nimport { createReserveStatement, updateReserveStatement } from \"./reserve-operations.ts\";\n\ntype Row = Record;\n\nexport async function getAppData(asOfDate = householdDate()): Promise {\n await ensureSchema();\n const monthStart = `${asOfDate.slice(0, 7)}-01`;\n const [accountResult, reconciliationResult, transactionResult, dashboardTransactionResult, plannedResult, completionResult, reserveResult, demoResult] = await Promise.all([\n db.execute(\"SELECT * FROM accounts ORDER BY is_active DESC, name COLLATE NOCASE\"),\n db.execute(\"SELECT * FROM account_reconciliations ORDER BY date DESC, created_at DESC LIMIT 500\"),\n db.execute(\"SELECT * FROM transactions WHERE voided_at IS NULL ORDER BY date DESC, created_at DESC LIMIT 500\"),\n db.execute({ sql: \"SELECT * FROM transactions WHERE voided_at IS NULL AND date BETWEEN ? AND ?\", args: [monthStart, asOfDate] }),\n db.execute(\"SELECT * FROM planned_transactions ORDER BY is_active DESC, next_date, description COLLATE NOCASE\"),\n db.execute(PLANNED_COMPLETIONS_QUERY),\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 accountReconciliations = reconciliationResult.rows.map(mapReconciliation);\n const transactions = transactionResult.rows.map(mapTransaction);\n const dashboardTransactions = dashboardTransactionResult.rows.map(mapTransaction);\n const plannedTransactions = plannedResult.rows.map(mapPlanned);\n const plannedCompletions = completionResult.rows.map(mapCompletion);\n const reserves = reserveResult.rows.map((row) => mapReserve(row, asOfDate));\n const demoDataState = demoStateFromRow(demoResult.rows[0] as Row | undefined);\n return {\n accounts,\n accountReconciliations,\n transactions,\n plannedTransactions,\n plannedCompletions,\n reserves,\n demoDataState,\n dashboard: calculateDashboard({ asOfDate, accounts, transactions: dashboardTransactions, 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 isActive: boolean;\n}): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `UPDATE accounts SET name = ?, type = ?, is_active = ?, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [input.name, input.type, Number(input.isActive), new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Account\");\n}\n\nexport async function reconcileAccount(id: string, input: {\n actualBalanceCents: number;\n date: string;\n note: string;\n}): Promise {\n await ensureSchema();\n const reconciliationId = crypto.randomUUID();\n await db.batch(reconcileAccountStatements({\n reconciliationId,\n accountId: id,\n actualBalanceCents: input.actualBalanceCents,\n date: input.date,\n note: input.note,\n now: new Date().toISOString(),\n }));\n const created = await one(\"SELECT id FROM account_reconciliations WHERE id = ?\", [reconciliationId]);\n if (created) return;\n const account = await one(\"SELECT is_active FROM accounts WHERE id = ?\", [id]);\n if (!account) throw notFound(\"Account\");\n throw conflict(\"Only active accounts can be reconciled\");\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 now = new Date().toISOString();\n await db.batch([\n {\n sql: `UPDATE planned_transactions SET account_id = ?, description = ?, kind = ?, amount_cents = ?, recurrence = ?,\n interval_count = ?, next_date = ?, end_date = ?, is_active = ?, revision = revision + 1,\n latest_completion_id = NULL, 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), now, id],\n },\n {\n sql: `UPDATE reserves SET linked_planned_transaction_id = NULL, updated_at = ?\n WHERE linked_planned_transaction_id = ? AND (? <> 'expense' OR ? <> 'once')`,\n args: [now, id, input.kind, input.recurrence],\n },\n ]);\n if (!await one(\"SELECT id FROM planned_transactions WHERE id = ?\", [id])) throw notFound(\"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 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 const completionId = crypto.randomUUID();\n await db.batch(completePlannedStatements({\n item: { ...item, revision: Number(row.revision ?? 0) }, completionId, transactionId: crypto.randomUUID(),\n targetAccountId, actualDate, nextDate: nextDate ?? item.nextDate, remainsActive, now,\n }));\n const created = await one(\"SELECT id FROM planned_completions WHERE id = ?\", [completionId]);\n if (!created) throw conflict(\"This occurrence was already completed; refresh and try again\");\n}\n\nexport async function undoPlannedCompletion(completionId: string, expectedEffectiveTransactionId: string): Promise {\n await ensureSchema();\n const token = crypto.randomUUID();\n await db.batch(undoPlannedStatements({ completionId, expectedEffectiveTransactionId, token, now: new Date().toISOString() }));\n await requireAdjustment(completionId, \"undone\", token);\n}\n\nexport async function correctPlannedCompletion(completionId: string, input: {\n accountId: string;\n date: string;\n amountCents: number;\n expectedEffectiveTransactionId: string;\n}): Promise {\n await ensureSchema();\n const token = crypto.randomUUID();\n await db.batch(correctPlannedStatements({\n completionId, expectedEffectiveTransactionId: input.expectedEffectiveTransactionId,\n correctionTransactionId: crypto.randomUUID(), token,\n accountId: input.accountId, date: input.date, amountCents: input.amountCents, now: new Date().toISOString(),\n }));\n await requireAdjustment(completionId, \"corrected\", token);\n}\n\nasync function requireAdjustment(id: string, expected: \"undone\" | \"corrected\", token: string): Promise {\n const row = await one(\"SELECT status, last_operation_token FROM planned_completions WHERE id = ?\", [id]);\n if (!row) throw notFound(\"Planned completion\");\n if (row.status !== expected || row.last_operation_token !== token) {\n throw conflict(\"Only the latest unchanged completion can be adjusted\");\n }\n}\n\nexport async function deletePlanned(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `DELETE FROM planned_transactions WHERE id = ?\n AND NOT EXISTS (SELECT 1 FROM planned_completions WHERE planned_transaction_id = ?)`,\n args: [id, id],\n });\n if (result.rowsAffected) return;\n const existing = await one(\"SELECT id FROM planned_transactions WHERE id = ?\", [id]);\n if (!existing) throw notFound(\"Planned transaction\");\n throw conflict(\"Completed planned items must be deactivated to preserve their audit history\");\n}\n\nexport async function deactivatePlanned(id: string): Promise {\n await ensureSchema();\n const result = await db.execute({\n sql: `UPDATE planned_transactions SET is_active = 0, revision = revision + 1,\n latest_completion_id = NULL, updated_at = ?, is_demo = 0 WHERE id = ?`,\n args: [new Date().toISOString(), id],\n });\n requireChanged(result.rowsAffected, \"Planned transaction\");\n}\n\nexport async function createReserve(input: {\n name: string;\n fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n linkedPlannedTransactionId: string | null;\n note: string;\n}): Promise {\n await ensureSchema();\n const now = new Date().toISOString();\n const result = await executeReserveWrite(createReserveStatement({\n id: crypto.randomUUID(),\n ...input,\n contributionMonth: householdDate().slice(0, 7),\n now,\n }), input.linkedPlannedTransactionId);\n if (!result.rowsAffected) throw invalidReserveLink();\n}\n\nexport async function updateReserve(id: string, input: {\n name: string;\n fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n linkedPlannedTransactionId: string | null;\n note: string;\n isActive: boolean;\n}): Promise {\n await ensureSchema();\n const result = await executeReserveWrite(updateReserveStatement({\n id,\n ...input,\n contributionMonth: householdDate().slice(0, 7),\n now: new Date().toISOString(),\n }), input.linkedPlannedTransactionId);\n if (result.rowsAffected) return;\n if (!await one(\"SELECT id FROM reserves WHERE id = ?\", [id])) throw notFound(\"Reserve\");\n throw invalidReserveLink();\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 mapReconciliation(row: Row): AccountReconciliation {\n return {\n id: String(row.id), accountId: String(row.account_id), date: String(row.date),\n previousBalanceCents: Number(row.previous_balance_cents),\n actualBalanceCents: Number(row.actual_balance_cents),\n differenceCents: Number(row.difference_cents), note: String(row.note),\n createdAt: String(row.created_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 correctedFromTransactionId: row.corrected_from_transaction_id == null ? null : String(row.corrected_from_transaction_id),\n voidedAt: row.voided_at == null ? null : String(row.voided_at),\n createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n}\n\nfunction mapCompletion(row: Row): PlannedCompletion {\n const originalTransaction = mapTransaction({\n id: row.original_id, account_id: row.original_account_id, date: row.original_date,\n amount_cents: row.original_amount_cents, currency: row.original_currency,\n description: row.original_description, kind: row.original_kind, status: row.original_status,\n source: row.original_source, transfer_group_id: row.original_transfer_group_id,\n planned_transaction_id: row.original_planned_transaction_id,\n corrected_from_transaction_id: row.original_corrected_from_transaction_id,\n voided_at: row.original_voided_at, created_at: row.original_created_at, updated_at: row.original_updated_at,\n });\n const effectiveTransaction = row.effective_id == null ? null : mapTransaction({\n id: row.effective_id, account_id: row.effective_account_id, date: row.effective_date,\n amount_cents: row.effective_amount_cents, currency: row.effective_currency,\n description: row.effective_description, kind: row.effective_kind, status: row.effective_status,\n source: row.effective_source, transfer_group_id: row.effective_transfer_group_id,\n planned_transaction_id: row.effective_planned_transaction_id,\n corrected_from_transaction_id: row.effective_corrected_from_transaction_id,\n voided_at: row.effective_voided_at, created_at: row.effective_created_at, updated_at: row.effective_updated_at,\n });\n return {\n id: String(row.id), plannedTransactionId: String(row.planned_transaction_id),\n originalTransactionId: String(row.transaction_id),\n correctionTransactionId: row.correction_transaction_id == null ? null : String(row.correction_transaction_id),\n occurrenceDate: String(row.occurrence_date), completedAt: String(row.created_at),\n adjustedAt: row.adjusted_at == null ? null : String(row.adjusted_at),\n status: row.status as PlannedCompletion[\"status\"], adjustable: Boolean(row.adjustable),\n originalTransaction, effectiveTransaction,\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, asOfDate: string): Reserve {\n const reserve: Reserve = {\n id: String(row.id), name: String(row.name), fundedAmountCents: Number(row.amount_cents),\n targetAmountCents: row.target_amount_cents == null ? null : Number(row.target_amount_cents),\n targetDate: row.target_date == null ? null : String(row.target_date),\n contributionMonth: row.contribution_month == null ? null : String(row.contribution_month),\n contributedThisMonthCents: Number(row.contribution_cents), requiredContributionCents: 0,\n linkedPlannedTransactionId: row.linked_planned_transaction_id == null\n ? null\n : String(row.linked_planned_transaction_id),\n currency: String(row.currency), note: String(row.note), isActive: Boolean(row.is_active),\n createdAt: String(row.created_at), updatedAt: String(row.updated_at),\n };\n reserve.requiredContributionCents = requiredGoalContributionCents(reserve, asOfDate);\n return reserve;\n}\n\nasync function executeReserveWrite(statement: { sql: string; args: (string | number | null)[] }, linkedId: string | null) {\n try {\n return await db.execute(statement);\n } catch (error) {\n if (linkedId && error instanceof Error && /constraint|unique/i.test(error.message)) throw invalidReserveLink();\n throw error;\n }\n}\n\nfunction invalidReserveLink(): Error {\n return conflict(\"Choose an active, one-off planned expense that is not linked to another goal\");\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","createdAt",["D",1789567272584],"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",{"_100":99,"_107":103},"org",{"_100":99,"_101":-5,"_102":103,"_18":56,"_104":105,"_106":25},"branch",{"_13":14,"_32":90,"_44":43,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":46,"_98":99},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lehmann","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zOE1CeERUd200ZFR6UURGWVJMalVQejNuWDMifQ","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_44":45,"_32":46,"_39":345,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":346,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":347,"_85":348,"_87":349,"_89":25},"tree",[189,195,204,207,208,209],"files",[189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207,208,209],"counts",{"_179":64,"_180":151,"_181":64,"_182":183,"_184":185},"contents",[129,130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":173,"_32":174,"_30":175,"_137":-5,"_42":43,"_41":176,"_139":60,"_39":177,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_27":178},{"_44":167,"_32":168,"_30":169,"_137":-5,"_42":43,"_41":170,"_139":60,"_39":171,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_27":172},{"_44":161,"_32":162,"_30":163,"_137":-5,"_42":43,"_41":151,"_139":60,"_39":164,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_27":166},{"_44":154,"_32":155,"_30":156,"_137":-5,"_42":43,"_41":157,"_139":60,"_39":158,"_13":151,"_34":20,"_36":159,"_24":25,"_144":-5,"_27":160},{"_44":146,"_32":147,"_30":148,"_137":-5,"_42":43,"_41":149,"_139":60,"_39":150,"_13":151,"_34":20,"_36":152,"_24":25,"_144":-5,"_27":153},{"_44":135,"_32":136,"_30":58,"_137":-5,"_42":43,"_41":138,"_139":60,"_39":140,"_13":141,"_34":142,"_36":143,"_24":25,"_144":-5,"_27":145},"4e7ebbc1-f340-4d29-bd43-8b7ee2741be9","index.http.ts","parentId",68,"latest",["D",1789567272539],8,"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 correctPlannedCompletion,\n createAccount,\n createPlanned,\n createReserve,\n createTransaction,\n deleteAccount,\n deletePlanned,\n deleteReserve,\n deleteTransaction,\n deactivatePlanned,\n getAppData,\n reconcileAccount,\n seedDemoData,\n updateAccount,\n updatePlanned,\n updateReserve,\n updateTransaction,\n undoPlannedCompletion,\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 uuidField,\n ValidationError,\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 isActive: booleanField(body, \"isActive\", true),\n });\n return c.json({ ok: true });\n});\n\napp.post(\"/api/accounts/:id/reconcile\", async (c) => {\n const body = await readBody(c.req.raw);\n await reconcileAccount(safeId(c.req.param(\"id\")), {\n actualBalanceCents: signedCentsField(body, \"actualBalanceCents\"),\n date: dateField(body, \"date\"),\n note: optionalString(body, \"note\", 300) ?? \"\",\n });\n return c.json({ ok: true }, 201);\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.post(\"/api/planned-completions/:id/undo\", async (c) => {\n const body = await readBody(c.req.raw);\n await undoPlannedCompletion(\n safeId(c.req.param(\"id\")),\n safeId(stringField(body, \"expectedEffectiveTransactionId\", 64)),\n );\n return c.json({ ok: true });\n});\n\napp.post(\"/api/planned-completions/:id/correct\", async (c) => {\n const body = await readBody(c.req.raw);\n await correctPlannedCompletion(safeId(c.req.param(\"id\")), {\n accountId: safeId(stringField(body, \"accountId\", 64)),\n date: dateField(body, \"date\"),\n amountCents: centsField(body),\n expectedEffectiveTransactionId: safeId(stringField(body, \"expectedEffectiveTransactionId\", 64)),\n });\n return c.json({ ok: true });\n});\n\napp.post(\"/api/planned/:id/deactivate\", async (c) => {\n await deactivatePlanned(safeId(c.req.param(\"id\")));\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(reserveInput(body));\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 ...reserveInput(body),\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 return uuidField(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 try {\n assertDateOnly(endDate);\n } catch (error) {\n throw new ValidationError(error instanceof Error ? error.message : \"endDate is invalid\");\n }\n if (endDate < nextDate) throw new ValidationError(\"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\nfunction reserveInput(body: Record) {\n const targetAmount = body.targetAmountCents;\n const targetDate = body.targetDate;\n const hasTargetAmount = targetAmount != null;\n const hasTargetDate = targetDate != null && targetDate !== \"\";\n if (hasTargetAmount !== hasTargetDate) {\n throw new ValidationError(\"targetAmountCents and targetDate must be provided together\");\n }\n const linkedPlannedTransactionId = optionalString(body, \"linkedPlannedTransactionId\", 64);\n if (linkedPlannedTransactionId && !hasTargetAmount) {\n throw new ValidationError(\"Only a target-date reserve can link a planned expense\");\n }\n return {\n name: stringField(body, \"name\", 80),\n // Continue accepting the original field so existing API clients can keep\n // creating simple reserves after the database field gains goal semantics.\n fundedAmountCents: body.fundedAmountCents == null && body.amountCents != null\n ? centsField(body, \"amountCents\", true)\n : centsField(body, \"fundedAmountCents\", true),\n targetAmountCents: hasTargetAmount ? centsField(body, \"targetAmountCents\") : null,\n targetDate: hasTargetDate ? dateField(body, \"targetDate\") : null,\n linkedPlannedTransactionId: linkedPlannedTransactionId ? safeId(linkedPlannedTransactionId) : null,\n note: optionalString(body, \"note\", 300) ?? \"\",\n };\n}\n\nexport default oauthMiddleware(app.fetch);\n","label",[136],"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",[147],"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",[155],"65021267-97d2-46c5-a1f1-8e3430d2e5b8","shared","c42952fa-af04-11f1-83ee-1607ee4eb77e",["D",1789257043083],"directory",[162],"ccf57a66-c3e0-4a52-9c44-82a68ddbe0ec","server","c448cf40-af04-11f1-9abb-1607ee4eb77e",3,["D",1789257043295],[168],"e62562cf-b974-4924-a7ea-327aaca48cfe","frontend","c43a05aa-af04-11f1-9abb-1607ee4eb77e",2,["D",1789257043196],[174],"pulls","branches","forks","envVars",{"_186":64,"_188":64},"connections",{"_186":64,"_187":64},"count","unfilledCount","emptyCount",{"_44":173,"_32":174,"_30":175,"_137":-5,"_42":43,"_41":176,"_139":60,"_39":342,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_211":343,"_27":344},{"_44":338,"_32":337,"_30":330,"_137":175,"_42":43,"_41":225,"_139":60,"_39":339,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_211":340,"_27":341},{"_44":327,"_32":328,"_30":329,"_137":330,"_42":43,"_41":331,"_139":60,"_39":332,"_13":333,"_34":35,"_36":334,"_24":25,"_144":-5,"_211":335,"_27":336},{"_44":319,"_32":320,"_30":321,"_137":175,"_42":43,"_41":322,"_139":60,"_39":323,"_13":64,"_34":20,"_36":324,"_24":25,"_144":-5,"_211":325,"_27":326},{"_44":311,"_32":312,"_30":313,"_137":175,"_42":43,"_41":314,"_139":60,"_39":315,"_13":64,"_34":35,"_36":316,"_24":25,"_144":-5,"_211":317,"_27":318},{"_44":303,"_32":304,"_30":305,"_137":175,"_42":43,"_41":306,"_139":60,"_39":307,"_13":64,"_34":35,"_36":308,"_24":25,"_144":-5,"_211":309,"_27":310},{"_44":167,"_32":168,"_30":169,"_137":-5,"_42":43,"_41":170,"_139":60,"_39":300,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_211":301,"_27":302},{"_44":292,"_32":293,"_30":294,"_137":169,"_42":43,"_41":295,"_139":60,"_39":296,"_13":170,"_34":35,"_36":297,"_24":25,"_144":-5,"_211":298,"_27":299},{"_44":284,"_32":285,"_30":286,"_137":169,"_42":43,"_41":287,"_139":60,"_39":288,"_13":64,"_34":35,"_36":289,"_24":25,"_144":-5,"_211":290,"_27":291},{"_44":276,"_32":277,"_30":278,"_137":169,"_42":43,"_41":279,"_139":60,"_39":280,"_13":170,"_34":35,"_36":281,"_24":25,"_144":-5,"_211":282,"_27":283},{"_44":268,"_32":269,"_30":270,"_137":169,"_42":43,"_41":271,"_139":60,"_39":272,"_13":64,"_34":35,"_36":273,"_24":25,"_144":-5,"_211":274,"_27":275},{"_44":260,"_32":261,"_30":262,"_137":169,"_42":43,"_41":263,"_139":60,"_39":264,"_13":64,"_34":35,"_36":265,"_24":25,"_144":-5,"_211":266,"_27":267},{"_44":256,"_32":33,"_30":31,"_137":169,"_42":43,"_41":14,"_139":60,"_39":257,"_13":225,"_34":35,"_36":38,"_24":25,"_144":-5,"_211":258,"_27":259},{"_44":248,"_32":249,"_30":250,"_137":169,"_42":43,"_41":251,"_139":60,"_39":252,"_13":151,"_34":35,"_36":253,"_24":25,"_144":-5,"_211":254,"_27":255},{"_44":240,"_32":241,"_30":242,"_137":169,"_42":43,"_41":243,"_139":60,"_39":244,"_13":176,"_34":35,"_36":245,"_24":25,"_144":-5,"_211":246,"_27":247},{"_44":161,"_32":162,"_30":163,"_137":-5,"_42":43,"_41":151,"_139":60,"_39":237,"_13":64,"_34":165,"_36":-5,"_24":25,"_144":-5,"_211":238,"_27":239},{"_44":229,"_32":230,"_30":231,"_137":163,"_42":43,"_41":232,"_139":60,"_39":233,"_13":176,"_34":35,"_36":234,"_24":25,"_144":-5,"_211":235,"_27":236},{"_44":220,"_32":221,"_30":222,"_137":163,"_42":43,"_41":223,"_139":60,"_39":224,"_13":225,"_34":35,"_36":226,"_24":25,"_144":-5,"_211":227,"_27":228},{"_44":154,"_32":155,"_30":156,"_137":-5,"_42":43,"_41":157,"_139":60,"_39":217,"_13":151,"_34":20,"_36":159,"_24":25,"_144":-5,"_211":218,"_27":219},{"_44":146,"_32":147,"_30":148,"_137":-5,"_42":43,"_41":149,"_139":60,"_39":214,"_13":151,"_34":20,"_36":152,"_24":25,"_144":-5,"_211":215,"_27":216},{"_44":135,"_32":136,"_30":58,"_137":-5,"_42":43,"_41":138,"_139":60,"_39":210,"_13":141,"_34":142,"_36":143,"_24":25,"_144":-5,"_211":212,"_27":213},["D",1789567272539],"children",[],[136],["D",1789259984492],[],[147],["D",1789257283542],[],[155],"a254aca0-af6d-4245-99a4-b07954f93f4a","types.ts","c482b91c-af04-11f1-bb78-1607ee4eb77e",66,["D",1789567272491],5,"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 AccountReconciliation {\n id: string;\n accountId: string;\n date: string;\n previousBalanceCents: number;\n actualBalanceCents: number;\n differenceCents: number;\n note: string;\n createdAt: 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 correctedFromTransactionId: string | null;\n voidedAt: string | null;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface PlannedCompletion {\n id: string;\n plannedTransactionId: string;\n originalTransactionId: string;\n correctionTransactionId: string | null;\n occurrenceDate: string;\n completedAt: string;\n adjustedAt: string | null;\n status: \"completed\" | \"undone\" | \"corrected\";\n adjustable: boolean;\n originalTransaction: Transaction;\n effectiveTransaction: Transaction | null;\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 fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n contributionMonth: string | null;\n contributedThisMonthCents: number;\n requiredContributionCents: number;\n linkedPlannedTransactionId: string | null;\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 linkedReserveId: string | null;\n linkedReserveName: string | null;\n linkedGoalCoverageCents: number;\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 fundedReservesCents: number;\n requiredGoalContributionsCents: number;\n linkedGoalCoverageCents: 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 accountReconciliations: AccountReconciliation[];\n transactions: Transaction[];\n plannedTransactions: PlannedTransaction[];\n plannedCompletions: PlannedCompletion[];\n reserves: Reserve[];\n demoDataState: DemoDataState;\n}\n",[],[162,221],"5b78fb21-8ce5-4800-8479-aed194305fa1","finance.ts","c4dbe0aa-af04-11f1-800c-1607ee4eb77e",64,["D",1789567272410],"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 linkedReserveId: null,\n linkedReserveName: null,\n linkedGoalCoverageCents: 0,\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 rawUpcoming = 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 activeReserves = input.reserves.filter((reserve) => reserve.isActive);\n const linkedReserves = new Map(activeReserves\n .filter((reserve) => reserve.targetAmountCents != null && reserve.linkedPlannedTransactionId != null)\n .map((reserve) => [reserve.linkedPlannedTransactionId!, reserve]));\n const eligiblePlannedIds = new Set(input.plannedTransactions\n .filter((item) => item.isActive && item.kind === \"expense\" && item.recurrence === \"once\")\n .map((item) => item.id));\n const upcoming = rawUpcoming.map((occurrence) => {\n const reserve = occurrence.kind === \"expense\" && eligiblePlannedIds.has(occurrence.plannedTransactionId)\n ? linkedReserves.get(occurrence.plannedTransactionId)\n : undefined;\n if (!reserve) return occurrence;\n const protectedForGoal = reserve.fundedAmountCents + requiredGoalContributionCents(reserve, input.asOfDate);\n return {\n ...occurrence,\n linkedReserveId: reserve.id,\n linkedReserveName: reserve.name,\n linkedGoalCoverageCents: Math.min(occurrence.amountCents, protectedForGoal),\n };\n });\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 fundedReservesCents = sum(activeReserves, (reserve) => reserve.fundedAmountCents);\n const requiredGoalContributionsCents = sum(\n activeReserves,\n (reserve) => requiredGoalContributionCents(reserve, input.asOfDate),\n );\n const linkedGoalCoverageCents = sum(upcoming, (occurrence) => occurrence.linkedGoalCoverageCents);\n const protectedReservesCents = fundedReservesCents + requiredGoalContributionsCents - linkedGoalCoverageCents;\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 fundedReservesCents,\n requiredGoalContributionsCents,\n linkedGoalCoverageCents,\n protectedReservesCents,\n projectedMonthEndCents,\n safeToSpendCents,\n upcoming,\n };\n}\n\nexport function requiredGoalContributionCents(\n reserve: Pick,\n asOfDate: string,\n): number {\n if (!reserve.isActive || reserve.targetAmountCents == null || reserve.targetDate == null) return 0;\n assertDateOnly(asOfDate);\n assertDateOnly(reserve.targetDate);\n const [asOfYear, asOfMonth] = asOfDate.split(\"-\").map(Number);\n const [targetYear, targetMonth] = reserve.targetDate.split(\"-\").map(Number);\n const currentMonth = asOfDate.slice(0, 7);\n const contributedThisMonth = reserve.contributionMonth === currentMonth\n ? reserve.contributedThisMonthCents\n : 0;\n const fundedBeforeThisMonth = reserve.fundedAmountCents - contributedThisMonth;\n const shortfallAtMonthStart = Math.max(0, reserve.targetAmountCents - fundedBeforeThisMonth);\n if (shortfallAtMonthStart === 0) return 0;\n\n const monthDistance = (targetYear - asOfYear) * 12 + targetMonth - asOfMonth;\n const contributionMonths = Math.max(1, monthDistance + 1);\n const scheduledContribution = Math.ceil(shortfallAtMonthStart / contributionMonths);\n return Math.max(0, scheduledContribution - contributedThisMonth);\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",[],[162,230],["D",1789257043083],[205,206],[162],"149ba247-b20d-4a6d-979f-323d325d567b","validation.ts","c4bc29f4-af04-11f1-8508-1607ee4eb77e",46,["D",1789542467521],"import { assertDateOnly } from \"../shared/finance.ts\";\n\nexport class ValidationError extends Error {\n readonly status = 400;\n\n constructor(message: string) {\n super(message);\n this.name = \"ValidationError\";\n }\n}\n\nexport function uuidField(value: string, key = \"id\"): string {\n if (!/^[0-9a-f]{8}-[0-9a-f]{4}-[1-8][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(value)) {\n throw new ValidationError(`${key} must be a UUID`);\n }\n return value;\n}\n\nexport function objectBody(value: unknown): Record {\n if (!value || typeof value !== \"object\" || Array.isArray(value)) throw new ValidationError(\"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 ValidationError(`${key} is required`);\n const normalized = value.trim();\n if (normalized.length > max) throw new ValidationError(`${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 ValidationError(`${key} is required`);\n if (value.length > max) throw new ValidationError(`${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 ValidationError(`${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 ValidationError(`${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 ValidationError(`${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 ValidationError(`${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 ValidationError(`${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 try {\n assertDateOnly(value);\n } catch (error) {\n throw new ValidationError(error instanceof Error ? error.message : `${key} is invalid`);\n }\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 ValidationError(`${key} is invalid`);\n return value;\n}\n",[],[168,241],"2db69053-fb7d-4e8b-88b5-cdc488d7974c","reserve-operations.ts","e0468a5e-b1d2-11f1-8a8f-1607ee4eb77e",63,["D",1789567272383],"export interface SqlStatement {\n sql: string;\n args: (string | number | null)[];\n}\n\ninterface ReserveWriteInput {\n id: string;\n name: string;\n fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n linkedPlannedTransactionId: string | null;\n note: string;\n now: string;\n}\n\nexport function createReserveStatement(input: ReserveWriteInput & { contributionMonth: string }): SqlStatement {\n return {\n sql: `INSERT INTO reserves\n (id, name, amount_cents, target_amount_cents, target_date, contribution_month,\n contribution_cents, linked_planned_transaction_id, currency, note, is_active, created_at, updated_at)\n SELECT ?, ?, ?, ?, ?, ?, 0, ?, 'EUR', ?, 1, ?, ?\n WHERE ? IS NULL OR (\n ? IS NOT NULL AND ? IS NOT NULL\n AND EXISTS (\n SELECT 1 FROM planned_transactions\n WHERE id = ? AND kind = 'expense' AND recurrence = 'once' AND is_active = 1\n )\n AND NOT EXISTS (\n SELECT 1 FROM reserves WHERE linked_planned_transaction_id = ?\n )\n )`,\n args: [\n input.id,\n input.name,\n input.fundedAmountCents,\n input.targetAmountCents,\n input.targetDate,\n input.targetAmountCents == null ? null : input.contributionMonth,\n input.linkedPlannedTransactionId,\n input.note,\n input.now,\n input.now,\n input.linkedPlannedTransactionId,\n input.targetAmountCents,\n input.targetDate,\n input.linkedPlannedTransactionId,\n input.linkedPlannedTransactionId,\n ],\n };\n}\n\n/**\n * Updates a reserve and atomically records the net funded increase for the\n * current household month. Existing funded money becomes the baseline when a\n * simple reserve is first converted to a goal.\n */\nexport function updateReserveStatement(input: {\n id: string;\n name: string;\n fundedAmountCents: number;\n targetAmountCents: number | null;\n targetDate: string | null;\n linkedPlannedTransactionId: string | null;\n note: string;\n isActive: boolean;\n contributionMonth: string;\n now: string;\n}): SqlStatement {\n return {\n sql: `UPDATE reserves SET\n name = ?,\n contribution_cents = CASE\n WHEN ? IS NULL OR ? IS NULL THEN 0\n WHEN target_amount_cents IS NULL OR target_date IS NULL THEN 0\n ELSE MAX(0,\n CASE WHEN contribution_month = ? THEN contribution_cents ELSE 0 END\n + (? - amount_cents)\n )\n END,\n contribution_month = CASE WHEN ? IS NULL OR ? IS NULL THEN NULL ELSE ? END,\n amount_cents = ?, target_amount_cents = ?, target_date = ?, linked_planned_transaction_id = ?, note = ?,\n is_active = ?, updated_at = ?, is_demo = 0\n WHERE id = ? AND (\n ? IS NULL OR (\n ? IS NOT NULL AND ? IS NOT NULL\n AND (\n linked_planned_transaction_id = ?\n OR (\n EXISTS (\n SELECT 1 FROM planned_transactions\n WHERE id = ? AND kind = 'expense' AND recurrence = 'once' AND is_active = 1\n )\n AND NOT EXISTS (\n SELECT 1 FROM reserves\n WHERE linked_planned_transaction_id = ? AND id <> ?\n )\n )\n )\n )\n )`,\n args: [\n input.name,\n input.targetAmountCents,\n input.targetDate,\n input.contributionMonth,\n input.fundedAmountCents,\n input.targetAmountCents,\n input.targetDate,\n input.contributionMonth,\n input.fundedAmountCents,\n input.targetAmountCents,\n input.targetDate,\n input.linkedPlannedTransactionId,\n input.note,\n Number(input.isActive),\n input.now,\n input.id,\n input.linkedPlannedTransactionId,\n input.targetAmountCents,\n input.targetDate,\n input.linkedPlannedTransactionId,\n input.linkedPlannedTransactionId,\n input.id,\n ],\n };\n}\n",[],[168,249],"33e90acd-c536-459f-803d-0a0a0a39b781",["D",1789567272584],[],[168,33],"5ab7a1fe-3426-49d7-b7ec-228f3cc8002e","reconciliation-operations.ts","e932f304-b1ba-11f1-9d12-1607ee4eb77e",53,["D",1789555175542],"export interface SqlStatement {\n sql: string;\n args: (string | number | null)[];\n}\n\nexport function reconcileAccountStatements(input: {\n reconciliationId: string;\n accountId: string;\n actualBalanceCents: number;\n date: string;\n note: string;\n now: string;\n}): SqlStatement[] {\n return [\n {\n sql: `INSERT INTO account_reconciliations\n (id, account_id, date, previous_balance_cents, actual_balance_cents,\n difference_cents, note, created_at)\n SELECT ?, id, ?, balance_cents, ?, ? - balance_cents, ?, ?\n FROM accounts\n WHERE id = ? AND is_active = 1`,\n args: [\n input.reconciliationId,\n input.date,\n input.actualBalanceCents,\n input.actualBalanceCents,\n input.note,\n input.now,\n input.accountId,\n ],\n },\n {\n sql: `UPDATE accounts\n SET balance_cents = ?, updated_at = ?, is_demo = 0\n WHERE id = ? AND is_active = 1\n AND EXISTS (\n SELECT 1 FROM account_reconciliations\n WHERE id = ? AND account_id = accounts.id\n AND previous_balance_cents = accounts.balance_cents\n )`,\n args: [\n input.actualBalanceCents,\n input.now,\n input.accountId,\n input.reconciliationId,\n ],\n },\n ];\n}\n",[],[168,261],"fde40f78-6d30-4615-9a3f-19f36773e469","planned-operations.ts","52108102-b19d-11f1-8032-1607ee4eb77e",41,["D",1789542466987],"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",[],[168,269],"cc388801-7f38-4033-85fe-378292ee7284","migrations.ts","06b6de9c-b1b4-11f1-ab38-1607ee4eb77e",67,["D",1789567272606],"export type MigrationValue = string | number | null;\n\nexport type MigrationStatement = string | { sql: string; args: MigrationValue[] };\n\nexport interface MigrationResult {\n rows: Array>;\n}\n\nexport interface MigrationDatabase {\n execute(statement: MigrationStatement): Promise;\n batch(statements: MigrationStatement[]): Promise;\n}\n\nexport interface Migration {\n version: number;\n name: string;\n statements: MigrationStatement[];\n}\n\nconst initialSchema: MigrationStatement[] = [\n `CREATE TABLE 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 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 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 transactions_import_identity_idx\n ON transactions(import_identity) WHERE import_identity IS NOT NULL`,\n `CREATE INDEX transactions_date_idx ON transactions(date)`,\n `CREATE TABLE 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 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 app_metadata (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n];\n\nexport const migrations: readonly Migration[] = [\n { version: 1, name: \"initial schema\", statements: initialSchema },\n {\n version: 2,\n name: \"demo data provenance\",\n statements: [\n \"ALTER TABLE accounts ADD COLUMN is_demo INTEGER NOT NULL DEFAULT 0 CHECK (is_demo IN (0, 1))\",\n \"ALTER TABLE transactions ADD COLUMN is_demo INTEGER NOT NULL DEFAULT 0 CHECK (is_demo IN (0, 1))\",\n \"ALTER TABLE planned_transactions ADD COLUMN is_demo INTEGER NOT NULL DEFAULT 0 CHECK (is_demo IN (0, 1))\",\n \"ALTER TABLE reserves ADD COLUMN is_demo INTEGER NOT NULL DEFAULT 0 CHECK (is_demo IN (0, 1))\",\n ],\n },\n {\n version: 3,\n name: \"planned completion audit\",\n statements: [\n \"ALTER TABLE planned_transactions ADD COLUMN revision INTEGER NOT NULL DEFAULT 0\",\n \"ALTER TABLE planned_transactions ADD COLUMN latest_completion_id TEXT\",\n \"ALTER TABLE transactions ADD COLUMN corrected_from_transaction_id TEXT REFERENCES transactions(id) ON DELETE RESTRICT\",\n \"ALTER TABLE transactions ADD COLUMN voided_at TEXT\",\n `CREATE TABLE planned_completions (\n id TEXT PRIMARY KEY,\n planned_transaction_id TEXT NOT NULL REFERENCES planned_transactions(id) ON DELETE RESTRICT,\n transaction_id TEXT NOT NULL UNIQUE REFERENCES transactions(id) ON DELETE RESTRICT,\n correction_transaction_id TEXT UNIQUE REFERENCES transactions(id) ON DELETE RESTRICT,\n occurrence_date TEXT NOT NULL,\n previous_next_date TEXT NOT NULL,\n previous_is_active INTEGER NOT NULL CHECK (previous_is_active IN (0, 1)),\n completed_next_date TEXT NOT NULL,\n completed_is_active INTEGER NOT NULL CHECK (completed_is_active IN (0, 1)),\n completed_revision INTEGER NOT NULL,\n status TEXT NOT NULL CHECK (status IN ('completed', 'undone', 'corrected')),\n operation_token TEXT,\n last_operation_token TEXT,\n created_at TEXT NOT NULL,\n adjusted_at TEXT\n )`,\n \"CREATE INDEX planned_completions_plan_idx ON planned_completions(planned_transaction_id, created_at DESC)\",\n ],\n },\n {\n version: 4,\n name: \"account balance reconciliation\",\n statements: [\n `CREATE TABLE account_reconciliations (\n id TEXT PRIMARY KEY,\n account_id TEXT NOT NULL REFERENCES accounts(id) ON DELETE RESTRICT,\n date TEXT NOT NULL,\n previous_balance_cents INTEGER NOT NULL,\n actual_balance_cents INTEGER NOT NULL,\n difference_cents INTEGER NOT NULL,\n note TEXT NOT NULL DEFAULT '',\n created_at TEXT NOT NULL\n )`,\n \"CREATE INDEX account_reconciliations_account_date_idx ON account_reconciliations(account_id, date DESC, created_at DESC)\",\n ],\n },\n {\n version: 5,\n name: \"reserve goals\",\n statements: [\n \"ALTER TABLE reserves ADD COLUMN target_amount_cents INTEGER CHECK (target_amount_cents IS NULL OR target_amount_cents > 0)\",\n \"ALTER TABLE reserves ADD COLUMN target_date TEXT CHECK ((target_amount_cents IS NULL) = (target_date IS NULL))\",\n ],\n },\n {\n version: 6,\n name: \"reserve monthly contribution progress\",\n statements: [\n \"ALTER TABLE reserves ADD COLUMN contribution_month TEXT CHECK (contribution_month IS NULL OR length(contribution_month) = 7)\",\n \"ALTER TABLE reserves ADD COLUMN contribution_cents INTEGER NOT NULL DEFAULT 0 CHECK (contribution_cents >= 0)\",\n ],\n },\n {\n version: 7,\n name: \"reserve planned obligation links\",\n statements: [\n \"ALTER TABLE reserves ADD COLUMN linked_planned_transaction_id TEXT REFERENCES planned_transactions(id) ON DELETE SET NULL\",\n `CREATE UNIQUE INDEX reserves_linked_planned_idx\n ON reserves(linked_planned_transaction_id) WHERE linked_planned_transaction_id IS NOT NULL`,\n ],\n },\n];\n\nexport async function migrateDatabase(\n database: MigrationDatabase,\n orderedMigrations: readonly Migration[] = migrations,\n now: () => string = () => new Date().toISOString(),\n): Promise {\n validateMigrationOrder(orderedMigrations);\n await database.execute(`CREATE TABLE IF NOT EXISTS schema_migrations (\n version INTEGER PRIMARY KEY,\n applied_at TEXT NOT NULL\n )`);\n\n for (const migration of orderedMigrations) {\n const applied = await database.execute({\n sql: \"SELECT 1 FROM schema_migrations WHERE version = ?\",\n args: [migration.version],\n });\n if (applied.rows.length) continue;\n\n const record: MigrationStatement = {\n sql: \"INSERT INTO schema_migrations (version, applied_at) VALUES (?, ?)\",\n args: [migration.version, now()],\n };\n try {\n // Val Town SQLite batches are transactional. Keeping the marker in the\n // same batch prevents a failed migration from appearing as applied.\n await database.batch([...migration.statements, record]);\n } catch (error) {\n // Another cold start may have committed while this request was waiting.\n // Version numbers are immutable, so its committed marker is authoritative.\n const concurrent = await database.execute({\n sql: \"SELECT 1 FROM schema_migrations WHERE version = ?\",\n args: [migration.version],\n });\n if (concurrent.rows.length) continue;\n throw new Error(`Database migration ${migration.version} (${migration.name}) failed`, { cause: error });\n }\n }\n}\n\nfunction validateMigrationOrder(orderedMigrations: readonly Migration[]): void {\n let previous = 0;\n for (const migration of orderedMigrations) {\n if (!Number.isSafeInteger(migration.version) || migration.version <= previous) {\n throw new Error(\"Database migrations must have unique ascending positive integer versions\");\n }\n if (!migration.name.trim() || migration.statements.length === 0) {\n throw new Error(`Database migration ${migration.version} must have a name and statements`);\n }\n previous = migration.version;\n }\n}\n",[],[168,277],"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",[],[168,285],"a4c2a8a4-8bf5-4a5a-8ff6-306eeeeca892","db.ts","c4b5efd0-af04-11f1-bb78-1607ee4eb77e",48,["D",1789552218922],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { migrateDatabase, type MigrationDatabase } from \"./migrations.ts\";\n\nexport const db = sqlite;\n\nlet initialized: Promise | null = null;\n\nexport function ensureSchema(): Promise {\n initialized ??= migrateDatabase(db as unknown as MigrationDatabase).catch((error) => {\n initialized = null;\n throw error;\n });\n return initialized;\n}\n",[],[168,293],["D",1789257043295],[196,197,198,199,200,201,202,203],[168],"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 · v69