${escapeHtml(title)}

Something went wrong

${escapeHtml(error.message)}

Return to dashboard

`,\n }), 500);\n});\n\nasync function postAction(c: any, handler: () => Promise) {\n const auth = await requireAdmin(c);\n if (auth.response) return auth.response;\n assertSameOrigin(c);\n await migrate();\n try {\n const notice = await handler();\n return redirectWithNotice(c, notice, \"ok\");\n } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n return redirectWithNotice(c, message, \"error\");\n }\n}\n\nasync function requireAdmin(c: any): Promise<{ username: string; response?: Response }> {\n const session = await getOAuthUserData(c.req.raw);\n if (!session?.user) return { username: \"\", response: c.redirect(\"/auth/login\") };\n\n const username = session.user.username;\n const allowed = adminUsernames();\n if (!allowed.length || !allowed.includes(username)) {\n return {\n username,\n response: c.html(renderShell({\n title: \"YNAB Importer\",\n body: `

Access denied

Logged in as ${escapeHtml(username)}, but this Val only allows usernames listed in ADMIN_USERNAMES.

`,\n }), 403),\n };\n }\n\n return { username };\n}\n\nfunction assertSameOrigin(c: any) {\n const origin = c.req.header(\"origin\");\n if (origin && origin !== new URL(c.req.url).origin) {\n throw new Error(\"Cross-origin form submissions are not accepted.\");\n }\n}\n\nfunction redirectWithNotice(c: any, notice: string, type: \"ok\" | \"error\") {\n const params = new URLSearchParams({ notice, type });\n return c.redirect(`/?${params.toString()}`, 303);\n}\n\nasync function renderDashboard(c: any, username: string) {\n const url = new URL(c.req.url);\n const status = normalizeStatus(url.searchParams.get(\"status\"));\n const notice = url.searchParams.get(\"notice\");\n const noticeType = url.searchParams.get(\"type\") === \"error\" ? \"error\" : \"ok\";\n const settings = await getSettings();\n const counts = await getCounts();\n const plans = await listYnabPlans();\n const ynabAccounts = await listYnabAccounts();\n const akahuAccounts = await listAkahuAccounts();\n const mappings = await listMappings();\n const transactions = await listTransactions(status, 100);\n const syncRuns = await listRecentSyncRuns(5);\n\n const mappingByAkahu = new Map(mappings.map((mapping: any) => [mapping.akahu_account_id, mapping]));\n const transactionAccounts = akahuAccounts.filter((account: any) => Number(account.has_transactions));\n const mappedCount = transactionAccounts.filter((account: any) => {\n const mapping: any = mappingByAkahu.get(account.id);\n return mapping?.ignored || mapping?.ynab_account_id;\n }).length;\n\n const body = `\n ${notice ? `

${escapeHtml(notice)}

` : \"\"}\n \n\n ${renderSetup({ settings, plans, akahuAccounts, ynabAccounts, mappedCount, transactionAccounts })}\n ${renderActions(settings)}\n ${renderMappings({ akahuAccounts, ynabAccounts, mappingByAkahu })}\n ${renderTransactions({ transactions, counts, status })}\n ${renderSyncRuns(syncRuns)}\n `;\n\n return renderShell({ title: \"YNAB Importer\", body });\n}\n\nfunction renderSetup(data: any) {\n const env = {\n admin: adminUsernames().length > 0,\n akahu: hasAkahuCredentials(),\n ynab: hasYnabCredentials(),\n };\n const selectedPlanId = data.settings.ynab_plan_id ?? \"\";\n const selectedPlanName = data.settings.ynab_plan_name ?? \"\";\n const initialSyncDone = Boolean(data.settings.last_successful_akahu_sync_at);\n const checks = [\n [\"Admin allowlist\", env.admin],\n [\"Akahu tokens\", env.akahu],\n [\"YNAB token\", env.ynab],\n [\"YNAB plan selected\", Boolean(selectedPlanId)],\n [\"Accounts loaded\", data.akahuAccounts.length > 0 && data.ynabAccounts.length > 0],\n [\"Mappings complete\", data.transactionAccounts.length > 0 && data.mappedCount === data.transactionAccounts.length],\n [\"Initial sync run\", initialSyncDone],\n ];\n\n return `

Setup

${checks.filter(([, ok]) => ok).length}/${checks.length}

\n ${checks.map(([label, ok]) => `

${ok ? \"OK\" : \"Todo\"}${escapeHtml(label)}

`).join(\"\")}\n

\n \n \n \n

`;\n}\n\nfunction renderActions(settings: Record) {\n return `

\n \n \n

Last sync: ${settings.last_successful_akahu_sync_at ? escapeHtml(formatDateTime(settings.last_successful_akahu_sync_at)) : \"Never\"}

`;\n}\n\nfunction renderMappings(data: any) {\n if (!data.akahuAccounts.length) {\n return `

Account Mapping

Refresh accounts after adding credentials.

`;\n }\n\n return `

Account Mapping

${data.akahuAccounts.length} Akahu accounts

\n \n

`;\n}\n\nfunction renderTransactions(data: any) {\n const statusLinks = [\"ready\", \"needs_mapping\", \"failed\", \"imported\", \"ignored\", \"all\"];\n return `

Transactions

${data.transactions.length} shown

\n \n

\n \n \n \n

\n \n \n \n ${data.transactions.length ? data.transactions.map(renderTransactionRow).join(\"\") : ``}\n \n

	Date	Account	Payee	Amount	Status
No transactions in this view.

`;\n}\n\nfunction renderTransactionRow(tx: any) {\n const canSelect = tx.status !== \"imported\";\n const payee = tx.merchant_name || tx.description;\n return `\n ${canSelect ? `` : \"\"}\n ${escapeHtml(String(tx.date).slice(0, 10))}\n ${escapeHtml(tx.akahu_account_name ?? tx.akahu_account_id)}${escapeHtml(tx.ynab_account_name ?? \"No YNAB mapping\")}\n ${escapeHtml(payee)}${escapeHtml(tx.description)}${tx.error ? `${escapeHtml(tx.error)}` : \"\"}\n ${formatAmount(Number(tx.amount))}\n ${labelForStatus(tx.status)}\n `;\n}\n\nfunction renderSyncRuns(runs: any[]) {\n return `

Sync Runs

${runs.length}

\n ${runs.length ? `

${runs.map((run) => `

${escapeHtml(run.trigger_name)}${escapeHtml(formatDateTime(run.started_at))}${Number(run.ok) ? `${run.fetched_count} fetched` : escapeHtml(run.message ?? \"Failed\")}

`).join(\"\")}

` : `

No sync runs yet.

`}\n

`;\n}\n\nfunction renderShell({ title, body }: { title: string; body: string }) {\n return `\n\n\n \n \n ${escapeHtml(title)}\n \n\n\n

${body}

\n \n\n`;\n}\n\nfunction adminUsernames() {\n return (Deno.env.get(\"ADMIN_USERNAMES\") ?? \"\")\n .split(\",\")\n .map((value) => value.trim())\n .filter(Boolean);\n}\n\nfunction labelForStatus(status: string) {\n const labels: Record = {\n all: \"All\",\n needs_mapping: \"Needs mapping\",\n ready: \"Ready\",\n imported: \"Imported\",\n ignored: \"Ignored\",\n failed: \"Failed\",\n };\n return labels[status] ?? status;\n}\n\nfunction formatAmount(amount: number) {\n return new Intl.NumberFormat(\"en-NZ\", { style: \"currency\", currency: \"NZD\" }).format(amount);\n}\n\nfunction formatDateTime(value: string) {\n if (!value) return \"\";\n return new Intl.DateTimeFormat(\"en-NZ\", { dateStyle: \"medium\", timeStyle: \"short\" }).format(new Date(value));\n}\n\nfunction escapeHtml(value: unknown) {\n return String(value ?? \"\")\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\")\n .replaceAll('\"', \""\")\n .replaceAll(\"'\", \"'\");\n}\n\nfunction escapeAttr(value: unknown) {\n return escapeHtml(value);\n}\n\nexport default oauthMiddleware(app.fetch);\n",[147],"3cd65512-5cdb-11f1-b305-1607ee4eb77e","README.md","3cd655da-5cdb-11f1-b305-1607ee4eb77e",9,["D",1780223211338],"# Akahu to YNAB Importer\n\nA forkable Val Town app that imports settled Akahu transactions into a local SQLite review queue, then lets you manually import selected transactions into YNAB.\n\n## What v1 does\n\n- Uses Akahu Personal App tokens, so each fork is for one person's own Akahu account.\n- Uses a YNAB Personal Access Token.\n- Stores state in the val-scoped Val Town SQLite database.\n- Protects the dashboard with Val Town login plus `ADMIN_USERNAMES`.\n- Syncs settled Akahu transactions only. Pending transactions are intentionally out of scope.\n- Lets scheduled syncs fetch from Akahu into SQLite only. YNAB writes happen only from the web UI.\n- Imports YNAB transactions as cleared, unapproved, uncategorized transactions with a stable `import_id`.\n\n## Required env vars\n\nSet these on your fork:\n\n- `ADMIN_USERNAMES`: comma-separated Val Town usernames allowed to open the dashboard.\n- `AKAHU_USER_TOKEN`: your Akahu User Access Token.\n- `AKAHU_APP_TOKEN`: your Akahu App ID Token.\n- `YNAB_ACCESS_TOKEN`: your YNAB Personal Access Token.\n\nFor this val:\n\n👉 Add ADMIN_USERNAMES here: https://www.val.town/x/jonpdw/ynab-import/environment-variables?key=ADMIN_USERNAMES\n\n👉 Add AKAHU_USER_TOKEN here: https://www.val.town/x/jonpdw/ynab-import/environment-variables?key=AKAHU_USER_TOKEN\n\n👉 Add AKAHU_APP_TOKEN here: https://www.val.town/x/jonpdw/ynab-import/environment-variables?key=AKAHU_APP_TOKEN\n\n👉 Add YNAB_ACCESS_TOKEN here: https://www.val.town/x/jonpdw/ynab-import/environment-variables?key=YNAB_ACCESS_TOKEN\n\n## Getting credentials\n\nAkahu:\n\n1. Sign in at https://my.akahu.nz/.\n2. Go to Developers.\n3. Create or open your Personal App.\n4. Copy the User Access Token and App ID Token into Val Town env vars.\n\nYNAB:\n\n1. Sign in to https://app.ynab.com/.\n2. Go to Account Settings, then Developer Settings.\n3. Create a Personal Access Token.\n4. Copy it into `YNAB_ACCESS_TOKEN`.\n\n## First run\n\n1. Open the dashboard.\n2. Log in with Val Town.\n3. Click Refresh accounts.\n4. Select one YNAB plan.\n5. Map each Akahu account to a YNAB account or choose Ignore this account.\n6. Pick a backfill window. The default is 30 days.\n7. Run backfill.\n8. Review ready transactions and click Import selected.\n\n## Scheduled sync\n\nThe `sync.ts` interval runs daily at `0 18 * * *` UTC. It only fetches settled Akahu transactions into SQLite. It does not write to YNAB.\n\nAfter the first successful sync, future syncs use the last successful sync timestamp with a 7-day overlap so late changes can be seen again.\n\n## Forking notes\n\nWhen someone remixes or forks the val, they should set their own env vars and keep their own val-scoped SQLite database. Do not share personal access tokens with other users.\n\nAkahu Personal Apps are free but limited to your own Akahu account and do not support webhooks. YNAB Personal Access Tokens are intended for individual usage. A multi-user hosted version would need Akahu OAuth and YNAB OAuth instead.\n",[155],"a6213a4c-5cda-11f1-85d8-1607ee4eb77e","lib","a6213ae2-5cda-11f1-85d8-1607ee4eb77e",2,["D",1780222958493],"directory",[162],"pulls","branches","forks","envVars",{"_175":164,"_177":61},"connections",{"_175":61,"_176":61},"count","unfilledCount","emptyCount",{"_42":161,"_32":162,"_30":163,"_135":-5,"_40":41,"_39":164,"_137":24,"_37":232,"_13":61,"_33":166,"_35":-5,"_23":26,"_141":-5,"_188":233,"_27":234},{"_42":224,"_32":225,"_30":226,"_135":163,"_40":41,"_39":227,"_137":26,"_37":228,"_13":61,"_33":34,"_35":229,"_23":26,"_141":-5,"_188":230,"_27":231},{"_42":216,"_32":217,"_30":218,"_135":163,"_40":41,"_39":219,"_137":24,"_37":220,"_13":61,"_33":34,"_35":221,"_23":26,"_141":-5,"_188":222,"_27":223},{"_42":208,"_32":209,"_30":210,"_135":163,"_40":41,"_39":211,"_137":24,"_37":212,"_13":61,"_33":34,"_35":213,"_23":26,"_141":-5,"_188":214,"_27":215},{"_42":200,"_32":201,"_30":202,"_135":163,"_40":41,"_39":203,"_137":26,"_37":204,"_13":61,"_33":34,"_35":205,"_23":26,"_141":-5,"_188":206,"_27":207},{"_42":154,"_32":155,"_30":156,"_135":-5,"_40":41,"_39":157,"_137":26,"_37":197,"_13":61,"_33":20,"_35":159,"_23":26,"_141":-5,"_188":198,"_27":199},{"_42":146,"_32":147,"_30":56,"_135":-5,"_40":41,"_39":148,"_137":26,"_37":194,"_13":150,"_33":151,"_35":152,"_23":26,"_141":-5,"_188":195,"_27":196},{"_42":143,"_32":28,"_30":31,"_135":-5,"_40":41,"_39":14,"_137":26,"_37":191,"_13":61,"_33":34,"_35":36,"_23":26,"_141":-5,"_188":192,"_27":193},{"_42":132,"_32":133,"_30":134,"_135":-5,"_40":41,"_39":136,"_137":24,"_37":187,"_13":61,"_33":139,"_35":140,"_23":26,"_141":-5,"_188":189,"_27":190},["D",1780223085121],"children",[],[133],["D",1780223563547],[],[28],["D",1780223191498],[],[147],["D",1780223211338],[],[155],"d611a6a6-5cda-11f1-b61e-1607ee4eb77e","ynab.ts","d611a78c-5cda-11f1-b61e-1607ee4eb77e",5,["D",1780223038919],"const YNAB_BASE_URL = \"https://api.ynab.com/v1\";\n\nexport class YnabError extends Error {\n status: number;\n body: unknown;\n\n constructor(status: number, message: string, body: unknown) {\n super(message);\n this.name = \"YnabError\";\n this.status = status;\n this.body = body;\n }\n}\n\nexport function hasYnabCredentials() {\n return Boolean(Deno.env.get(\"YNAB_ACCESS_TOKEN\"));\n}\n\nfunction token() {\n const accessToken = Deno.env.get(\"YNAB_ACCESS_TOKEN\");\n if (!accessToken) throw new Error(\"Missing YNAB_ACCESS_TOKEN.\");\n return accessToken;\n}\n\nasync function ynabFetch(path: string, init: RequestInit = {}) {\n const response = await fetch(`${YNAB_BASE_URL}${path}`, {\n ...init,\n headers: {\n Authorization: `Bearer ${token()}`,\n Accept: \"application/json\",\n ...(init.body ? { \"Content-Type\": \"application/json\" } : {}),\n ...(init.headers ?? {}),\n },\n });\n\n const text = await response.text();\n let body: any = null;\n try {\n body = text ? JSON.parse(text) : null;\n } catch {\n body = text;\n }\n\n if (!response.ok) {\n const detail = body?.error?.detail ?? body?.error?.name ?? text ?? response.statusText;\n throw new YnabError(response.status, `YNAB ${response.status}: ${detail}`, body);\n }\n\n return body;\n}\n\nexport async function listPlans() {\n const body = await ynabFetch(\"/plans?include_accounts=true\");\n return body.data?.plans ?? [];\n}\n\nexport async function listPlanAccounts(planId: string) {\n const body = await ynabFetch(`/plans/${encodeURIComponent(planId)}/accounts`);\n return body.data?.accounts ?? [];\n}\n\nexport async function createTransactions(planId: string, transactions: any[]) {\n return await ynabFetch(`/plans/${encodeURIComponent(planId)}/transactions`, {\n method: \"POST\",\n body: JSON.stringify({ transactions }),\n });\n}\n",[],[162,201],"eee2408c-5cda-11f1-89fb-1607ee4eb77e","jobs.ts","eee2414a-5cda-11f1-89fb-1607ee4eb77e",6,["D",1780223080556],"import {\n getImportableTransactions,\n getSetting,\n markTransactionFailed,\n markTransactionImported,\n migrate,\n recordSyncRun,\n setSetting,\n upsertAkahuAccounts,\n upsertAkahuTransactions,\n upsertYnabAccounts,\n upsertYnabPlans,\n type NormalizedAkahuTransaction,\n} from \"./db.ts\";\nimport { hasAkahuCredentials, listAkahuAccounts, listSettledTransactions } from \"./akahu.ts\";\nimport { createTransactions, hasYnabCredentials, listPlanAccounts, listPlans, YnabError } from \"./ynab.ts\";\n\nconst DAY_MS = 24 * 60 * 60 * 1000;\n\nexport type CatalogRefreshResult = {\n akahuAccounts: number;\n ynabPlans: number;\n ynabAccounts: number;\n selectedPlanId: string | null;\n};\n\nexport type SyncResult = {\n fetched: number;\n stored: number;\n startIso: string;\n endIso: string;\n};\n\nexport type ImportResult = {\n requested: number;\n imported: number;\n failed: number;\n duplicates: number;\n};\n\nexport async function refreshCatalog(): Promise {\n await migrate();\n let akahuAccounts = 0;\n let ynabPlans = 0;\n let ynabAccounts = 0;\n let selectedPlanId = await getSetting(\"ynab_plan_id\");\n\n if (hasAkahuCredentials()) {\n const accounts = await listAkahuAccounts();\n akahuAccounts = await upsertAkahuAccounts(accounts);\n }\n\n if (hasYnabCredentials()) {\n const plans = await listPlans();\n ynabPlans = await upsertYnabPlans(plans);\n\n if (!selectedPlanId && plans.length === 1) {\n selectedPlanId = plans[0].id;\n await setSetting(\"ynab_plan_id\", plans[0].id);\n await setSetting(\"ynab_plan_name\", plans[0].name ?? \"Unnamed plan\");\n }\n\n if (selectedPlanId) {\n const accounts = await listPlanAccounts(selectedPlanId);\n ynabAccounts = await upsertYnabAccounts(accounts);\n }\n }\n\n await setSetting(\"last_catalog_refresh_at\", new Date().toISOString());\n return { akahuAccounts, ynabPlans, ynabAccounts, selectedPlanId };\n}\n\nexport async function runAkahuSync(options: {\n triggerName: string;\n forceBackfill?: boolean;\n backfillDays?: number;\n overlapDays?: number;\n}): Promise {\n await migrate();\n const startedAt = new Date().toISOString();\n const endDate = new Date();\n const endIso = endDate.toISOString();\n const overlapDays = options.overlapDays ?? 7;\n const configuredBackfillDays = Number(await getSetting(\"backfill_days\")) || 30;\n const backfillDays = options.backfillDays ?? configuredBackfillDays;\n const lastSyncAt = await getSetting(\"last_successful_akahu_sync_at\");\n\n let startDate: Date;\n if (options.forceBackfill || !lastSyncAt) {\n startDate = new Date(endDate.getTime() - backfillDays * DAY_MS);\n } else {\n startDate = new Date(Date.parse(lastSyncAt) - overlapDays * DAY_MS);\n }\n const startIso = startDate.toISOString();\n\n try {\n const accounts = await listAkahuAccounts();\n await upsertAkahuAccounts(accounts);\n\n const rawTransactions = await listSettledTransactions(startIso, endIso);\n const normalized = await Promise.all(rawTransactions.map(normalizeAkahuTransaction));\n const stored = await upsertAkahuTransactions(normalized);\n\n await setSetting(\"last_successful_akahu_sync_at\", endIso);\n await recordSyncRun({\n trigger_name: options.triggerName,\n started_at: startedAt,\n finished_at: new Date().toISOString(),\n ok: true,\n message: null,\n fetched_count: rawTransactions.length,\n stored_count: stored,\n start_iso: startIso,\n end_iso: endIso,\n });\n\n return { fetched: rawTransactions.length, stored, startIso, endIso };\n } catch (error) {\n await recordSyncRun({\n trigger_name: options.triggerName,\n started_at: startedAt,\n finished_at: new Date().toISOString(),\n ok: false,\n message: error instanceof Error ? error.message : String(error),\n fetched_count: 0,\n stored_count: 0,\n start_iso: startIso,\n end_iso: endIso,\n });\n throw error;\n }\n}\n\nexport async function importReadyTransactions(ids: string[]): Promise {\n await migrate();\n const uniqueIds = [...new Set(ids)].filter(Boolean);\n const planId = await getSetting(\"ynab_plan_id\");\n if (!planId) throw new Error(\"Select a YNAB plan before importing.\");\n\n const rows = await getImportableTransactions(uniqueIds);\n const result: ImportResult = { requested: uniqueIds.length, imported: 0, failed: 0, duplicates: 0 };\n if (!rows.length) return result;\n\n if (rows.length === 1) {\n await importOne(planId, rows[0], result);\n return result;\n }\n\n try {\n const response = await createTransactions(planId, rows.map(toYnabTransaction));\n await applyYnabImportResponse(rows, response, result);\n } catch (error) {\n for (const row of rows) {\n await importOne(planId, row, result);\n }\n }\n\n return result;\n}\n\nasync function importOne(planId: string, row: any, result: ImportResult) {\n try {\n const response = await createTransactions(planId, [toYnabTransaction(row)]);\n await applyYnabImportResponse([row], response, result);\n } catch (error) {\n if (error instanceof YnabError && error.status === 409) {\n await markTransactionImported(row.akahu_id, null, \"Duplicate import_id already existed in YNAB.\");\n result.imported += 1;\n result.duplicates += 1;\n return;\n }\n const message = error instanceof Error ? error.message : String(error);\n await markTransactionFailed(row.akahu_id, message);\n result.failed += 1;\n }\n}\n\nasync function applyYnabImportResponse(rows: any[], response: any, result: ImportResult) {\n const saved = response?.data?.transactions ?? (response?.data?.transaction ? [response.data.transaction] : []);\n const duplicateImportIds = new Set(response?.data?.duplicate_import_ids ?? []);\n const savedByImportId = new Map();\n for (const transaction of saved) {\n if (transaction.import_id) savedByImportId.set(transaction.import_id, transaction);\n }\n\n for (const row of rows) {\n const savedTransaction = savedByImportId.get(row.import_id);\n if (savedTransaction) {\n await markTransactionImported(row.akahu_id, savedTransaction.id, null);\n result.imported += 1;\n } else if (duplicateImportIds.has(row.import_id)) {\n await markTransactionImported(row.akahu_id, null, \"Duplicate import_id already existed in YNAB.\");\n result.imported += 1;\n result.duplicates += 1;\n } else {\n await markTransactionFailed(row.akahu_id, \"YNAB did not return this transaction in the import response.\");\n result.failed += 1;\n }\n }\n}\n\nasync function normalizeAkahuTransaction(tx: any): Promise {\n return {\n akahu_id: tx._id,\n akahu_account_id: tx._account,\n date: tx.date,\n description: tx.description ?? \"\",\n amount: Number(tx.amount),\n type: tx.type ?? null,\n merchant_name: tx.merchant?.name ?? null,\n raw_json: JSON.stringify(tx),\n import_id: await ynabImportId(tx._id),\n };\n}\n\nasync function ynabImportId(akahuId: string) {\n const bytes = new TextEncoder().encode(akahuId);\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n const hex = [...new Uint8Array(digest)].map((byte) => byte.toString(16).padStart(2, \"0\")).join(\"\");\n return `AKAHU:${hex.slice(0, 28)}`;\n}\n\nfunction toYnabTransaction(row: any) {\n return {\n account_id: row.mapped_ynab_account_id,\n date: String(row.date).slice(0, 10),\n amount: Math.round(Number(row.amount) * 1000),\n payee_name: cleanText(row.merchant_name || row.description || \"Unknown payee\", 200),\n memo: cleanText(`Akahu: ${row.akahu_id} | ${row.description ?? \"\"}`, 500),\n cleared: \"cleared\",\n approved: false,\n import_id: row.import_id,\n };\n}\n\nfunction cleanText(value: string, maxLength: number) {\n return value.replace(/\\s+/g, \" \").trim().slice(0, maxLength) || null;\n}\n",[],[162,209],"c8296132-5cda-11f1-b894-1607ee4eb77e","db.ts","c8296222-5cda-11f1-b894-1607ee4eb77e",3,["D",1780223015588],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type TransactionStatus = \"needs_mapping\" | \"ready\" | \"imported\" | \"ignored\" | \"failed\";\n\nexport type NormalizedAkahuTransaction = {\n akahu_id: string;\n akahu_account_id: string;\n date: string;\n description: string;\n amount: number;\n type: string | null;\n merchant_name: string | null;\n raw_json: string;\n import_id: string;\n};\n\nexport type AccountMappingInput = {\n akahu_account_id: string;\n ynab_account_id: string | null;\n ignored: boolean;\n};\n\nconst STATUSES = new Set([\"needs_mapping\", \"ready\", \"imported\", \"ignored\", \"failed\"]);\n\nfunction nowIso() {\n return new Date().toISOString();\n}\n\nexport function normalizeStatus(value: string | null): TransactionStatus | \"all\" {\n if (value === \"all\") return \"all\";\n if (value && STATUSES.has(value)) return value as TransactionStatus;\n return \"ready\";\n}\n\nexport async function migrate() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS ynab_plans (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n last_modified_on TEXT,\n raw_json TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS ynab_accounts (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n type TEXT,\n closed INTEGER NOT NULL DEFAULT 0,\n on_budget INTEGER NOT NULL DEFAULT 0,\n transfer_payee_id TEXT,\n raw_json TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS akahu_accounts (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n type TEXT,\n status TEXT,\n connection_id TEXT,\n connection_name TEXT,\n formatted_account TEXT,\n has_transactions INTEGER NOT NULL DEFAULT 0,\n attributes_json TEXT NOT NULL,\n raw_json TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS account_mappings (\n akahu_account_id TEXT PRIMARY KEY,\n ynab_account_id TEXT,\n ignored INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS akahu_transactions (\n akahu_id TEXT PRIMARY KEY,\n akahu_account_id TEXT NOT NULL,\n date TEXT NOT NULL,\n description TEXT NOT NULL,\n amount REAL NOT NULL,\n type TEXT,\n merchant_name TEXT,\n import_id TEXT NOT NULL UNIQUE,\n status TEXT NOT NULL,\n ynab_account_id TEXT,\n ynab_transaction_id TEXT,\n error TEXT,\n raw_json TEXT NOT NULL,\n first_seen_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n imported_at TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS sync_runs (\n id TEXT PRIMARY KEY,\n trigger_name TEXT NOT NULL,\n started_at TEXT NOT NULL,\n finished_at TEXT NOT NULL,\n ok INTEGER NOT NULL,\n message TEXT,\n fetched_count INTEGER NOT NULL DEFAULT 0,\n stored_count INTEGER NOT NULL DEFAULT 0,\n start_iso TEXT,\n end_iso TEXT\n )`,\n `CREATE INDEX IF NOT EXISTS idx_akahu_transactions_status ON akahu_transactions(status)`,\n `CREATE INDEX IF NOT EXISTS idx_akahu_transactions_date ON akahu_transactions(date)`,\n `CREATE INDEX IF NOT EXISTS idx_akahu_transactions_account ON akahu_transactions(akahu_account_id)`,\n `CREATE INDEX IF NOT EXISTS idx_sync_runs_started ON sync_runs(started_at)`\n ]);\n}\n\nexport async function getSettings(): Promise> {\n const result = await sqlite.execute(\"SELECT key, value FROM settings\");\n return Object.fromEntries((result.rows as any[]).map((row) => [row.key, row.value]));\n}\n\nexport async function getSetting(key: string): Promise {\n const result = await sqlite.execute({ sql: \"SELECT value FROM settings WHERE key = ?\", args: [key] });\n return ((result.rows as any[])[0]?.value as string | undefined) ?? null;\n}\n\nexport async function setSetting(key: string, value: string) {\n await sqlite.execute({\n sql: `INSERT INTO settings (key, value, updated_at)\n VALUES (?, ?, ?)\n ON CONFLICT(key) DO UPDATE SET value = excluded.value, updated_at = excluded.updated_at`,\n args: [key, value, nowIso()],\n });\n}\n\nexport async function upsertYnabPlans(plans: any[]) {\n if (!plans.length) return 0;\n const updatedAt = nowIso();\n await sqlite.batch(plans.map((plan) => ({\n sql: `INSERT INTO ynab_plans (id, name, last_modified_on, raw_json, updated_at)\n VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n name = excluded.name,\n last_modified_on = excluded.last_modified_on,\n raw_json = excluded.raw_json,\n updated_at = excluded.updated_at`,\n args: [plan.id, plan.name ?? \"Unnamed plan\", plan.last_modified_on ?? null, JSON.stringify(plan), updatedAt],\n })));\n return plans.length;\n}\n\nexport async function upsertYnabAccounts(accounts: any[]) {\n if (!accounts.length) return 0;\n const updatedAt = nowIso();\n await sqlite.batch(accounts.map((account) => ({\n sql: `INSERT INTO ynab_accounts (id, name, type, closed, on_budget, transfer_payee_id, raw_json, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n name = excluded.name,\n type = excluded.type,\n closed = excluded.closed,\n on_budget = excluded.on_budget,\n transfer_payee_id = excluded.transfer_payee_id,\n raw_json = excluded.raw_json,\n updated_at = excluded.updated_at`,\n args: [\n account.id,\n account.name ?? \"Unnamed account\",\n account.type ?? null,\n account.closed ? 1 : 0,\n account.on_budget ? 1 : 0,\n account.transfer_payee_id ?? null,\n JSON.stringify(account),\n updatedAt,\n ],\n })));\n return accounts.length;\n}\n\nexport async function upsertAkahuAccounts(accounts: any[]) {\n if (!accounts.length) return 0;\n const updatedAt = nowIso();\n await sqlite.batch(accounts.map((account) => {\n const attributes = Array.isArray(account.attributes) ? account.attributes : [];\n return {\n sql: `INSERT INTO akahu_accounts (\n id, name, type, status, connection_id, connection_name, formatted_account,\n has_transactions, attributes_json, raw_json, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n name = excluded.name,\n type = excluded.type,\n status = excluded.status,\n connection_id = excluded.connection_id,\n connection_name = excluded.connection_name,\n formatted_account = excluded.formatted_account,\n has_transactions = excluded.has_transactions,\n attributes_json = excluded.attributes_json,\n raw_json = excluded.raw_json,\n updated_at = excluded.updated_at`,\n args: [\n account._id,\n account.name ?? \"Unnamed Akahu account\",\n account.type ?? null,\n account.status ?? null,\n account.connection?._id ?? account._connection ?? null,\n account.connection?.name ?? null,\n account.formatted_account ?? null,\n attributes.includes(\"TRANSACTIONS\") ? 1 : 0,\n JSON.stringify(attributes),\n JSON.stringify(account),\n updatedAt,\n ],\n };\n }));\n return accounts.length;\n}\n\nexport async function listYnabPlans() {\n const result = await sqlite.execute(\"SELECT * FROM ynab_plans ORDER BY name COLLATE NOCASE\");\n return result.rows as any[];\n}\n\nexport async function listYnabAccounts() {\n const result = await sqlite.execute(\n \"SELECT * FROM ynab_accounts WHERE closed = 0 ORDER BY on_budget DESC, name COLLATE NOCASE\",\n );\n return result.rows as any[];\n}\n\nexport async function listAkahuAccounts() {\n const result = await sqlite.execute(\n \"SELECT * FROM akahu_accounts ORDER BY has_transactions DESC, connection_name COLLATE NOCASE, name COLLATE NOCASE\",\n );\n return result.rows as any[];\n}\n\nexport async function listMappings() {\n const result = await sqlite.execute(\"SELECT * FROM account_mappings\");\n return result.rows as any[];\n}\n\nexport async function saveAccountMappings(mappings: AccountMappingInput[]) {\n const updatedAt = nowIso();\n const statements: any[] = [];\n for (const mapping of mappings) {\n if (mapping.ignored) {\n statements.push({\n sql: `INSERT INTO account_mappings (akahu_account_id, ynab_account_id, ignored, updated_at)\n VALUES (?, NULL, 1, ?)\n ON CONFLICT(akahu_account_id) DO UPDATE SET\n ynab_account_id = NULL, ignored = 1, updated_at = excluded.updated_at`,\n args: [mapping.akahu_account_id, updatedAt],\n });\n statements.push({\n sql: `UPDATE akahu_transactions\n SET status = 'ignored', ynab_account_id = NULL, error = NULL, updated_at = ?\n WHERE akahu_account_id = ? AND status != 'imported'`,\n args: [updatedAt, mapping.akahu_account_id],\n });\n } else if (mapping.ynab_account_id) {\n statements.push({\n sql: `INSERT INTO account_mappings (akahu_account_id, ynab_account_id, ignored, updated_at)\n VALUES (?, ?, 0, ?)\n ON CONFLICT(akahu_account_id) DO UPDATE SET\n ynab_account_id = excluded.ynab_account_id, ignored = 0, updated_at = excluded.updated_at`,\n args: [mapping.akahu_account_id, mapping.ynab_account_id, updatedAt],\n });\n statements.push({\n sql: `UPDATE akahu_transactions\n SET status = 'ready', ynab_account_id = ?, error = NULL, updated_at = ?\n WHERE akahu_account_id = ? AND status IN ('needs_mapping', 'ignored', 'failed')`,\n args: [mapping.ynab_account_id, updatedAt, mapping.akahu_account_id],\n });\n } else {\n statements.push({ sql: \"DELETE FROM account_mappings WHERE akahu_account_id = ?\", args: [mapping.akahu_account_id] });\n statements.push({\n sql: `UPDATE akahu_transactions\n SET status = 'needs_mapping', ynab_account_id = NULL, error = NULL, updated_at = ?\n WHERE akahu_account_id = ? AND status IN ('ready', 'ignored', 'failed')`,\n args: [updatedAt, mapping.akahu_account_id],\n });\n }\n }\n if (statements.length) await sqlite.batch(statements);\n}\n\nexport async function upsertAkahuTransactions(transactions: NormalizedAkahuTransaction[]) {\n if (!transactions.length) return 0;\n const mappings = await listMappings();\n const mappingByAccount = new Map(mappings.map((mapping: any) => [mapping.akahu_account_id, mapping]));\n const updatedAt = nowIso();\n await sqlite.batch(transactions.map((tx) => {\n const mapping: any = mappingByAccount.get(tx.akahu_account_id);\n const status = mapping?.ignored ? \"ignored\" : mapping?.ynab_account_id ? \"ready\" : \"needs_mapping\";\n const ynabAccountId = mapping?.ignored ? null : mapping?.ynab_account_id ?? null;\n return {\n sql: `INSERT INTO akahu_transactions (\n akahu_id, akahu_account_id, date, description, amount, type, merchant_name,\n import_id, status, ynab_account_id, raw_json, first_seen_at, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(akahu_id) DO UPDATE SET\n akahu_account_id = excluded.akahu_account_id,\n date = excluded.date,\n description = excluded.description,\n amount = excluded.amount,\n type = excluded.type,\n merchant_name = excluded.merchant_name,\n import_id = excluded.import_id,\n status = CASE\n WHEN akahu_transactions.status IN ('imported', 'ignored', 'failed') THEN akahu_transactions.status\n ELSE excluded.status\n END,\n ynab_account_id = CASE\n WHEN akahu_transactions.status = 'imported' THEN akahu_transactions.ynab_account_id\n ELSE excluded.ynab_account_id\n END,\n raw_json = excluded.raw_json,\n updated_at = excluded.updated_at`,\n args: [\n tx.akahu_id,\n tx.akahu_account_id,\n tx.date,\n tx.description,\n tx.amount,\n tx.type,\n tx.merchant_name,\n tx.import_id,\n status,\n ynabAccountId,\n tx.raw_json,\n updatedAt,\n updatedAt,\n ],\n };\n }));\n return transactions.length;\n}\n\nexport async function getCounts() {\n const result = await sqlite.execute(\"SELECT status, COUNT(*) AS count FROM akahu_transactions GROUP BY status\");\n const counts: Record = { needs_mapping: 0, ready: 0, imported: 0, ignored: 0, failed: 0 };\n for (const row of result.rows as any[]) counts[row.status] = Number(row.count);\n return counts;\n}\n\nexport async function listTransactions(status: TransactionStatus | \"all\", limit = 100) {\n const where = status === \"all\" ? \"\" : \"WHERE t.status = ?\";\n const args: any[] = status === \"all\" ? [limit] : [status, limit];\n const result = await sqlite.execute({\n sql: `SELECT\n t.*,\n aa.name AS akahu_account_name,\n aa.connection_name AS akahu_connection_name,\n ya.name AS ynab_account_name\n FROM akahu_transactions t\n LEFT JOIN akahu_accounts aa ON aa.id = t.akahu_account_id\n LEFT JOIN account_mappings m ON m.akahu_account_id = t.akahu_account_id\n LEFT JOIN ynab_accounts ya ON ya.id = COALESCE(t.ynab_account_id, m.ynab_account_id)\n ${where}\n ORDER BY t.date DESC, t.updated_at DESC\n LIMIT ?`,\n args,\n });\n return result.rows as any[];\n}\n\nexport async function getImportableTransactions(ids: string[]) {\n if (!ids.length) return [];\n const placeholders = ids.map(() => \"?\").join(\", \");\n const result = await sqlite.execute({\n sql: `SELECT\n t.*,\n COALESCE(t.ynab_account_id, m.ynab_account_id) AS mapped_ynab_account_id\n FROM akahu_transactions t\n JOIN account_mappings m ON m.akahu_account_id = t.akahu_account_id AND m.ignored = 0\n WHERE t.status = 'ready'\n AND m.ynab_account_id IS NOT NULL\n AND t.akahu_id IN (${placeholders})\n ORDER BY t.date ASC`,\n args: ids,\n });\n return result.rows as any[];\n}\n\nexport async function markTransactionsIgnored(ids: string[]) {\n if (!ids.length) return 0;\n const placeholders = ids.map(() => \"?\").join(\", \");\n await sqlite.execute({\n sql: `UPDATE akahu_transactions\n SET status = 'ignored', error = NULL, updated_at = ?\n WHERE akahu_id IN (${placeholders}) AND status != 'imported'`,\n args: [nowIso(), ...ids],\n });\n return ids.length;\n}\n\nexport async function resetFailedTransactions(ids: string[]) {\n if (!ids.length) return 0;\n const placeholders = ids.map(() => \"?\").join(\", \");\n await sqlite.execute({\n sql: `UPDATE akahu_transactions\n SET status = 'ready', error = NULL, updated_at = ?\n WHERE akahu_id IN (${placeholders}) AND status = 'failed'`,\n args: [nowIso(), ...ids],\n });\n return ids.length;\n}\n\nexport async function markTransactionImported(akahuId: string, ynabTransactionId: string | null, message: string | null = null) {\n const timestamp = nowIso();\n await sqlite.execute({\n sql: `UPDATE akahu_transactions\n SET status = 'imported', ynab_transaction_id = COALESCE(?, ynab_transaction_id), error = ?, imported_at = ?, updated_at = ?\n WHERE akahu_id = ?`,\n args: [ynabTransactionId, message, timestamp, timestamp, akahuId],\n });\n}\n\nexport async function markTransactionFailed(akahuId: string, error: string) {\n await sqlite.execute({\n sql: `UPDATE akahu_transactions SET status = 'failed', error = ?, updated_at = ? WHERE akahu_id = ?`,\n args: [error.slice(0, 1000), nowIso(), akahuId],\n });\n}\n\nexport async function recordSyncRun(run: {\n trigger_name: string;\n started_at: string;\n finished_at: string;\n ok: boolean;\n message: string | null;\n fetched_count: number;\n stored_count: number;\n start_iso: string | null;\n end_iso: string | null;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO sync_runs (\n id, trigger_name, started_at, finished_at, ok, message, fetched_count, stored_count, start_iso, end_iso\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n crypto.randomUUID(),\n run.trigger_name,\n run.started_at,\n run.finished_at,\n run.ok ? 1 : 0,\n run.message,\n run.fetched_count,\n run.stored_count,\n run.start_iso,\n run.end_iso,\n ],\n });\n}\n\nexport async function listRecentSyncRuns(limit = 5) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM sync_runs ORDER BY started_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as any[];\n}\n",[],[162,217],"cf051fd2-5cda-11f1-916e-1607ee4eb77e","akahu.ts","cf05209a-5cda-11f1-916e-1607ee4eb77e",4,["D",1780223027095],"const AKAHU_BASE_URL = \"https://api.akahu.io/v1\";\n\nexport class AkahuError extends Error {\n status: number;\n body: unknown;\n\n constructor(status: number, message: string, body: unknown) {\n super(message);\n this.name = \"AkahuError\";\n this.status = status;\n this.body = body;\n }\n}\n\nexport function hasAkahuCredentials() {\n return Boolean(Deno.env.get(\"AKAHU_USER_TOKEN\") && Deno.env.get(\"AKAHU_APP_TOKEN\"));\n}\n\nfunction credentials() {\n const userToken = Deno.env.get(\"AKAHU_USER_TOKEN\");\n const appToken = Deno.env.get(\"AKAHU_APP_TOKEN\");\n if (!userToken || !appToken) {\n throw new Error(\"Missing AKAHU_USER_TOKEN or AKAHU_APP_TOKEN.\");\n }\n return { userToken, appToken };\n}\n\nasync function akahuFetch(path: string, query: Record = {}) {\n const { userToken, appToken } = credentials();\n const url = new URL(`${AKAHU_BASE_URL}${path}`);\n for (const [key, value] of Object.entries(query)) {\n if (value) url.searchParams.set(key, value);\n }\n\n const response = await fetch(url, {\n headers: {\n Authorization: `Bearer ${userToken}`,\n \"X-Akahu-Id\": appToken,\n Accept: \"application/json\",\n },\n });\n\n const text = await response.text();\n let body: any = null;\n try {\n body = text ? JSON.parse(text) : null;\n } catch {\n body = text;\n }\n\n if (!response.ok || body?.success === false) {\n const detail = body?.message ?? body?.error_description ?? body?.error ?? text ?? response.statusText;\n throw new AkahuError(response.status, `Akahu ${response.status}: ${detail}`, body);\n }\n\n return body;\n}\n\nexport async function getAkahuMe() {\n return await akahuFetch(\"/me\");\n}\n\nexport async function listAkahuAccounts() {\n const body = await akahuFetch(\"/accounts\");\n return body.items ?? [];\n}\n\nexport async function listSettledTransactions(startIso: string, endIso: string) {\n const transactions: any[] = [];\n let cursor: string | null | undefined = undefined;\n\n do {\n const body = await akahuFetch(\"/transactions\", { start: startIso, end: endIso, cursor });\n transactions.push(...(body.items ?? []));\n cursor = body.cursor?.next ?? null;\n } while (cursor);\n\n return transactions;\n}\n",[],[162,225],["D",1780222958493],[179,180,181,182],[162],["D",1780222890810],["D",1789556471789],{"_98":97,"_105":100},{"_98":97,"_99":100,"_101":100,"_18":54,"_102":103,"_104":26},{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_124":273,"_274":275,"_276":277,"_278":26,"_279":26,"_280":26,"_281":24,"_282":-5,"_283":-7,"_284":-7,"_285":61,"_286":26,"_287":26,"_288":-5,"_289":26,"_290":26,"_291":26,"_292":-5},"ENV",{"_244":245,"_246":247,"_248":88,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Something went wrong

Access denied

YNAB Importer

Setup

Connections

YNAB plan

Backfill

Account Mapping

Account Mapping

Transactions

Sync Runs

Diff · v12