[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_215":216,"_217":218},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_106":88,"_26":100,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":57,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","sync.ts","latestPath","fileId","f19b4b66-5cda-11f1-84ef-1607ee4eb77e","name","fileType","interval","content","import { runAkahuSync } from \"./lib/jobs.ts\";\nimport { hasAkahuCredentials } from \"./lib/akahu.ts\";\n\nexport default async function (_interval: Interval) {\n if (!hasAkahuCredentials()) {\n console.log(\"Skipping scheduled sync: missing Akahu credentials.\");\n return { skipped: true, reason: \"missing_akahu_credentials\" };\n }\n\n const result = await runAkahuSync({ triggerName: \"interval\", overlapDays: 7 });\n console.log(`Synced ${result.fetched} settled Akahu transactions into the review queue.`);\n return result;\n}\n","createdAt",["D",1780223085121],"branchVersion","branchId","7dc9747e-5cda-11f1-83e7-1607ee4eb77e","id","7dc870d8-5cda-11f1-83e7-1607ee4eb77e","ynab-import",["D",1780222890810],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Forkable Akahu to YNAB importer with a review UI.","imageUrl","f0a197ec-9517-4b2a-bdcf-4f13ead4af98","pinnedFileId","7dcfb0e6-5cda-11f1-83e7-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e7d77-ed4e-710f-944e-eecb6671720e","tursoName","7dc870d85cda11f183e71607ee4eb77e","tursoHostname","7dc870d85cda11f183e71607ee4eb77e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789470042795],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":100},"org",{"_98":97,"_99":100,"_101":100,"_18":53,"_102":103,"_104":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",31,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jonpdw","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":210,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":211,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":212,"_82":213,"_84":214,"_86":24},"tree",[160,165,166],"files",[160,161,162,163,164,165,166],"counts",{"_150":61,"_151":138,"_152":61,"_153":154,"_155":156},"contents",[127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":143,"_31":144,"_29":145,"_131":-5,"_39":40,"_38":146,"_132":57,"_36":147,"_13":61,"_32":148,"_34":-5,"_23":24,"_134":-5,"_26":149},{"_41":136,"_31":137,"_29":55,"_131":-5,"_39":40,"_38":138,"_132":24,"_36":139,"_13":61,"_32":140,"_34":141,"_23":24,"_134":-5,"_26":142},{"_41":130,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_132":57,"_36":133,"_13":61,"_32":33,"_34":35,"_23":24,"_134":-5,"_26":135},"f19b4a9e-5cda-11f1-84ef-1607ee4eb77e","parentId","latest",["D",1780223085121],"label",[27],"7dcfb000-5cda-11f1-83e7-1607ee4eb77e","main.ts",1,["D",1780222890837],"http","export default function () {\n return new Response(\"Setting up YNAB importer...\");\n}\n",[137],"a6213a4c-5cda-11f1-85d8-1607ee4eb77e","lib","a6213ae2-5cda-11f1-85d8-1607ee4eb77e",2,["D",1780222958493],"directory",[144],"pulls","branches","forks","envVars",{"_157":146,"_159":61},"connections",{"_157":61,"_158":61},"count","unfilledCount","emptyCount",{"_41":143,"_31":144,"_29":145,"_131":-5,"_39":40,"_38":146,"_132":57,"_36":207,"_13":61,"_32":148,"_34":-5,"_23":24,"_134":-5,"_168":208,"_26":209},{"_41":199,"_31":200,"_29":201,"_131":145,"_39":40,"_38":202,"_132":24,"_36":203,"_13":61,"_32":179,"_34":204,"_23":24,"_134":-5,"_168":205,"_26":206},{"_41":191,"_31":192,"_29":193,"_131":145,"_39":40,"_38":194,"_132":57,"_36":195,"_13":61,"_32":179,"_34":196,"_23":24,"_134":-5,"_168":197,"_26":198},{"_41":183,"_31":184,"_29":185,"_131":145,"_39":40,"_38":186,"_132":57,"_36":187,"_13":61,"_32":179,"_34":188,"_23":24,"_134":-5,"_168":189,"_26":190},{"_41":174,"_31":175,"_29":176,"_131":145,"_39":40,"_38":177,"_132":24,"_36":178,"_13":61,"_32":179,"_34":180,"_23":24,"_134":-5,"_168":181,"_26":182},{"_41":136,"_31":137,"_29":55,"_131":-5,"_39":40,"_38":138,"_132":24,"_36":171,"_13":61,"_32":140,"_34":141,"_23":24,"_134":-5,"_168":172,"_26":173},{"_41":130,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_132":57,"_36":167,"_13":61,"_32":33,"_34":35,"_23":24,"_134":-5,"_168":169,"_26":170},["D",1780223085121],"children",[],[27],["D",1780222890837],[],[137],"d611a6a6-5cda-11f1-b61e-1607ee4eb77e","ynab.ts","d611a78c-5cda-11f1-b61e-1607ee4eb77e",5,["D",1780223038919],"script","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",[],[144,175],"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",[],[144,184],"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",[],[144,192],"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",[],[144,200],["D",1780222958493],[161,162,163,164],[144],["D",1780222890810],["D",1789470042795],{"_98":97,"_105":100},{"_98":97,"_99":100,"_101":100,"_18":53,"_102":103,"_104":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_124":248,"_249":250,"_251":252,"_253":24,"_254":24,"_255":24,"_256":57,"_257":-5,"_258":-7,"_259":-7,"_260":61,"_261":24,"_262":24,"_263":-5,"_264":24,"_265":24,"_266":24,"_267":-5},"ENV",{"_219":220,"_221":222,"_223":88,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v7