[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","RT_Brandt","name","throne-gelt-ledger","path","main.tsx","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/RT_Brandt/throne-gelt-ledger/code/main.tsx","extension","id","d1ee42f7-535c-47d0-9ba8-9b64991c25e1","fileId","9c51ffec-b00e-11f1-bc3a-1607ee4eb77e","parentId","branchId","bb0b67fb-350e-4d2b-8d6f-3c56dcf88f85","branchVersion",4,"latest",true,"createdAt",["D",1789371391103],"version",1,"fileType","http","content","/**\n * Throne Gelt Ledger — server.\n *\n * Every rule that matters is enforced here, not in the browser:\n * - betting closes at closes_at, checked against server time\n * - stake must be <= server-held balance\n * - admin routes check is_admin from the session, not a client flag\n * - balance changes happen in atomic batches with an audit row\n */\nimport { Hono } from \"npm:hono\";\nimport { getCookie, setCookie, deleteCookie } from \"npm:hono/cookie\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sqlite, initDb, nowIso, creditStatements, STARTING_BALANCE } from \"./db.ts\";\nimport {\n hashPassword,\n verifyPassword,\n dummyVerify,\n newSessionToken,\n digestToken,\n SESSION_COOKIE,\n SESSION_TTL_DAYS,\n} from \"./auth.ts\";\nimport { PAGE } from \"./ui.ts\";\n\nconst app = new Hono();\n\nawait initDb();\n\n// ── helpers ──────────────────────────────────────────────────────────\ntype Viewer = { id: number; username: string; balance: number; isAdmin: boolean };\n\nasync function getViewer(c: any): Promise {\n const token = getCookie(c, SESSION_COOKIE);\n if (!token) return null;\n const digest = await digestToken(token);\n const res = await sqlite.execute({\n sql: `SELECT u.id, u.username, u.balance, u.is_admin, s.expires_at\n FROM sessions s JOIN users u ON u.id = s.user_id\n WHERE s.token_digest = ?`,\n args: [digest],\n });\n if (res.rows.length === 0) return null;\n const r = res.rows[0] as any;\n if (new Date(r.expires_at as string) < new Date()) {\n await sqlite.execute({ sql: \"DELETE FROM sessions WHERE token_digest = ?\", args: [digest] });\n return null;\n }\n return {\n id: r.id as number,\n username: r.username as string,\n balance: r.balance as number,\n isAdmin: (r.is_admin as number) === 1,\n };\n}\n\n/** Reject cross-site posts. Cookies are SameSite=Lax; this is belt and braces. */\nfunction originOk(c: any): boolean {\n const origin = c.req.header(\"origin\");\n if (!origin) return true; // same-origin fetch often omits it\n try {\n return new URL(origin).host === new URL(c.req.url).host;\n } catch {\n return false;\n }\n}\n\nconst bad = (c: any, msg: string, code = 400) => c.json({ error: msg }, code);\n\nasync function requireUser(c: any): Promise {\n const v = await getViewer(c);\n if (!v) return bad(c, \"Not signed in.\", 401);\n return v;\n}\n\nasync function requireAdmin(c: any): Promise {\n const v = await getViewer(c);\n if (!v) return bad(c, \"Not signed in.\", 401);\n if (!v.isAdmin) return bad(c, \"Overseer clearance required.\", 403);\n return v;\n}\n\n// Mutating routes must be same-origin.\napp.use(\"/api/*\", async (c, next) => {\n if (c.req.method !== \"GET\" && !originOk(c)) return bad(c, \"Bad origin.\", 403);\n await next();\n});\n\n// ── page ─────────────────────────────────────────────────────────────\napp.get(\"/\", (c) => c.html(PAGE));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ── auth ─────────────────────────────────────────────────────────────\napp.post(\"/api/register\", async (c) => {\n const { username, password } = await c.req.json().catch(() => ({}));\n const name = String(username ?? \"\").trim();\n const pass = String(password ?? \"\");\n\n if (!/^[A-Za-z0-9_\\-]{3,24}$/.test(name)) {\n return bad(c, \"Handle must be 3-24 characters: letters, numbers, _ or - only.\");\n }\n if (pass.length < 8) return bad(c, \"Passphrase must be at least 8 characters.\");\n if (pass.length > 200) return bad(c, \"Passphrase too long.\");\n\n const dupe = await sqlite.execute({\n sql: \"SELECT id FROM users WHERE username = ?\",\n args: [name],\n });\n if (dupe.rows.length) return bad(c, \"That handle is already registered.\", 409);\n\n const hash = await hashPassword(pass);\n const now = nowIso();\n await sqlite.execute({\n sql: `INSERT INTO users (username, password_hash, balance, is_admin, created_at)\n VALUES (?, ?, ?, 0, ?)`,\n args: [name, hash, STARTING_BALANCE, now],\n });\n const created = await sqlite.execute({\n sql: \"SELECT id FROM users WHERE username = ?\",\n args: [name],\n });\n const userId = created.rows[0].id as number;\n\n await sqlite.execute({\n sql: `INSERT INTO ledger (user_id, delta, reason, ref, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [userId, STARTING_BALANCE, \"sign-on stipend\", null, now],\n });\n\n await startSession(c, userId);\n return c.json({ ok: true });\n});\n\napp.post(\"/api/login\", async (c) => {\n const { username, password } = await c.req.json().catch(() => ({}));\n const name = String(username ?? \"\").trim();\n const pass = String(password ?? \"\");\n if (!name || !pass) return bad(c, \"Handle and passphrase required.\");\n\n // Throttle: 10 failures per handle per 15 minutes.\n const since = new Date(Date.now() - 15 * 60_000).toISOString();\n const fails = await sqlite.execute({\n sql: \"SELECT COUNT(*) AS n FROM login_attempts WHERE username = ? AND at > ?\",\n args: [name, since],\n });\n if (((fails.rows[0] as any).n as number) >= 10) {\n return bad(c, \"Too many failed attempts. Wait 15 minutes.\", 429);\n }\n\n const res = await sqlite.execute({\n sql: \"SELECT id, password_hash FROM users WHERE username = ?\",\n args: [name],\n });\n\n let ok = false;\n let userId = 0;\n if (res.rows.length === 0) {\n await dummyVerify(); // equalise timing\n } else {\n const row = res.rows[0] as any;\n ok = await verifyPassword(pass, row.password_hash as string);\n userId = row.id as number;\n }\n\n if (!ok) {\n await sqlite.execute({\n sql: \"INSERT INTO login_attempts (username, at) VALUES (?, ?)\",\n args: [name, nowIso()],\n });\n // Same message whether or not the handle exists.\n return bad(c, \"Handle or passphrase incorrect.\", 401);\n }\n\n await sqlite.execute({ sql: \"DELETE FROM login_attempts WHERE username = ?\", args: [name] });\n await startSession(c, userId);\n return c.json({ ok: true });\n});\n\nasync function startSession(c: any, userId: number) {\n const { token, digest } = await newSessionToken();\n const expires = new Date(Date.now() + SESSION_TTL_DAYS * 86400_000);\n await sqlite.execute({\n sql: `INSERT INTO sessions (token_digest, user_id, created_at, expires_at)\n VALUES (?, ?, ?, ?)`,\n args: [digest, userId, nowIso(), expires.toISOString()],\n });\n setCookie(c, SESSION_COOKIE, token, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n path: \"/\",\n expires,\n });\n}\n\napp.post(\"/api/logout\", async (c) => {\n const token = getCookie(c, SESSION_COOKIE);\n if (token) {\n await sqlite.execute({\n sql: \"DELETE FROM sessions WHERE token_digest = ?\",\n args: [await digestToken(token)],\n });\n }\n deleteCookie(c, SESSION_COOKIE, { path: \"/\" });\n return c.json({ ok: true });\n});\n\napp.get(\"/api/me\", async (c) => {\n const v = await getViewer(c);\n return c.json({ user: v });\n});\n\n// ── bets ─────────────────────────────────────────────────────────────\napp.get(\"/api/bets\", async (c) => {\n const v = await getViewer(c);\n\n const bets = await sqlite.execute(\n `SELECT id, title, description, closes_at, status, winning_option_id, created_at, resolved_at\n FROM bets ORDER BY (status = 'open') DESC, closes_at DESC, id DESC`,\n );\n const options = await sqlite.execute(\n `SELECT o.id, o.bet_id, o.label, o.payout_rate,\n COALESCE(SUM(w.stake), 0) AS pool,\n COUNT(w.id) AS backers\n FROM bet_options o\n LEFT JOIN wagers w ON w.option_id = o.id\n GROUP BY o.id ORDER BY o.sort_order, o.id`,\n );\n\n let mine: any[] = [];\n if (v) {\n const res = await sqlite.execute({\n sql: `SELECT id, bet_id, option_id, stake, payout_rate, status, payout, created_at\n FROM wagers WHERE user_id = ? ORDER BY id DESC`,\n args: [v.id],\n });\n mine = res.rows;\n }\n\n const byBet = new Map();\n for (const o of options.rows as any[]) {\n if (!byBet.has(o.bet_id)) byBet.set(o.bet_id, []);\n byBet.get(o.bet_id)!.push(o);\n }\n\n const now = Date.now();\n const payload = (bets.rows as any[]).map((b) => ({\n ...b,\n isClosed: b.status !== \"open\" || new Date(b.closes_at).getTime() <= now,\n options: byBet.get(b.id) ?? [],\n }));\n\n return c.json({ bets: payload, myWagers: mine, serverTime: nowIso() });\n});\n\napp.get(\"/api/leaderboard\", async (c) => {\n const res = await sqlite.execute(\n `SELECT u.username, u.balance,\n COALESCE(SUM(CASE WHEN w.status = 'won' THEN 1 ELSE 0 END), 0) AS wins,\n COALESCE(SUM(CASE WHEN w.status = 'lost' THEN 1 ELSE 0 END), 0) AS losses\n FROM users u LEFT JOIN wagers w ON w.user_id = u.id\n WHERE u.is_admin = 0\n GROUP BY u.id ORDER BY u.balance DESC, u.username`,\n );\n return c.json({ standings: res.rows });\n});\n\n// ── placing a wager ──────────────────────────────────────────────────\napp.post(\"/api/wagers\", async (c) => {\n const v = await requireUser(c);\n if (v instanceof Response) return v;\n\n const { optionId, stake } = await c.req.json().catch(() => ({}));\n const optId = Number(optionId);\n const amount = Math.floor(Number(stake));\n\n if (!Number.isInteger(optId) || optId <= 0) return bad(c, \"Pick an outcome.\");\n if (!Number.isFinite(amount) || amount <= 0) {\n return bad(c, \"Stake must be a positive whole number.\");\n }\n\n const res = await sqlite.execute({\n sql: `SELECT o.id AS option_id, o.payout_rate, o.bet_id,\n b.status, b.closes_at\n FROM bet_options o JOIN bets b ON b.id = o.bet_id\n WHERE o.id = ?`,\n args: [optId],\n });\n if (res.rows.length === 0) return bad(c, \"No such outcome.\", 404);\n const row = res.rows[0] as any;\n\n // Server time decides. A stale page cannot sneak a late wager through.\n if (row.status !== \"open\") return bad(c, \"This wager has been resolved.\", 409);\n if (new Date(row.closes_at as string).getTime() <= Date.now()) {\n return bad(c, \"Betting has closed on this wager.\", 409);\n }\n\n // Re-read balance in the write path rather than trusting the session copy.\n const bal = await sqlite.execute({ sql: \"SELECT balance FROM users WHERE id = ?\", args: [v.id] });\n const balance = (bal.rows[0] as any).balance as number;\n if (amount > balance) return bad(c, \"Insufficient thrones.\", 409);\n\n await sqlite.batch(\n [\n ...creditStatements(v.id, -amount, \"wager placed\", `option:${optId}`),\n {\n sql: `INSERT INTO wagers (user_id, bet_id, option_id, stake, payout_rate, status, payout, created_at)\n VALUES (?, ?, ?, ?, ?, 'pending', 0, ?)`,\n args: [v.id, row.bet_id, optId, amount, row.payout_rate, nowIso()],\n },\n ],\n \"write\",\n );\n\n return c.json({ ok: true });\n});\n\n// ── admin ────────────────────────────────────────────────────────────\napp.get(\"/api/admin/users\", async (c) => {\n const v = await requireAdmin(c);\n if (v instanceof Response) return v;\n const res = await sqlite.execute(\n `SELECT u.id, u.username, u.balance, u.is_admin, u.created_at,\n COUNT(w.id) AS wager_count\n FROM users u LEFT JOIN wagers w ON w.user_id = u.id\n GROUP BY u.id ORDER BY u.is_admin DESC, u.balance DESC`,\n );\n return c.json({ users: res.rows });\n});\n\napp.post(\"/api/admin/bets\", async (c) => {\n const v = await requireAdmin(c);\n if (v instanceof Response) return v;\n\n const body = await c.req.json().catch(() => ({}));\n const title = String(body.title ?? \"\").trim();\n const description = String(body.description ?? \"\").trim();\n const closesAt = String(body.closesAt ?? \"\");\n const options = Array.isArray(body.options) ? body.options : [];\n\n if (title.length < 3) return bad(c, \"Title required.\");\n if (title.length > 200) return bad(c, \"Title too long.\");\n if (description.length > 2000) return bad(c, \"Description too long.\");\n\n const closes = new Date(closesAt);\n if (isNaN(closes.getTime())) return bad(c, \"Valid closing time required.\");\n if (closes.getTime() <= Date.now()) return bad(c, \"Closing time must be in the future.\");\n\n if (options.length < 2 || options.length > 8) return bad(c, \"Between 2 and 8 outcomes.\");\n const clean = options.map((o: any) => ({\n label: String(o.label ?? \"\").trim(),\n rate: Number(o.payoutRate),\n }));\n for (const o of clean) {\n if (!o.label) return bad(c, \"Every outcome needs a label.\");\n if (o.label.length > 120) return bad(c, \"Outcome label too long.\");\n if (!Number.isFinite(o.rate) || o.rate <= 1 || o.rate > 100) {\n return bad(c, \"Payout rate must be between 1.01 and 100.\");\n }\n }\n\n await sqlite.execute({\n sql: `INSERT INTO bets (title, description, closes_at, status, created_by, created_at)\n VALUES (?, ?, ?, 'open', ?, ?)`,\n args: [title, description, closes.toISOString(), v.id, nowIso()],\n });\n const idRes = await sqlite.execute(\"SELECT last_insert_rowid() AS id\");\n const betId = (idRes.rows[0] as any).id as number;\n\n await sqlite.batch(\n clean.map((o, i) => ({\n sql: `INSERT INTO bet_options (bet_id, label, payout_rate, sort_order) VALUES (?, ?, ?, ?)`,\n args: [betId, o.label, o.rate, i],\n })),\n \"write\",\n );\n\n return c.json({ ok: true, betId });\n});\n\napp.post(\"/api/admin/bets/:id/resolve\", async (c) => {\n const v = await requireAdmin(c);\n if (v instanceof Response) return v;\n\n const betId = Number(c.req.param(\"id\"));\n const { winningOptionId } = await c.req.json().catch(() => ({}));\n const winId = Number(winningOptionId);\n\n const betRes = await sqlite.execute({\n sql: \"SELECT id, status FROM bets WHERE id = ?\",\n args: [betId],\n });\n if (betRes.rows.length === 0) return bad(c, \"No such wager.\", 404);\n if ((betRes.rows[0] as any).status !== \"open\") return bad(c, \"Already resolved.\", 409);\n\n const optRes = await sqlite.execute({\n sql: \"SELECT id FROM bet_options WHERE id = ? AND bet_id = ?\",\n args: [winId, betId],\n });\n if (optRes.rows.length === 0) return bad(c, \"That outcome is not on this wager.\", 400);\n\n const wagers = await sqlite.execute({\n sql: `SELECT id, user_id, option_id, stake, payout_rate\n FROM wagers WHERE bet_id = ? AND status = 'pending'`,\n args: [betId],\n });\n\n const stmts: any[] = [\n {\n sql: `UPDATE bets SET status = 'resolved', winning_option_id = ?, resolved_at = ? WHERE id = ?`,\n args: [winId, nowIso(), betId],\n },\n ];\n\n let paidOut = 0;\n let winners = 0;\n for (const w of wagers.rows as any[]) {\n if ((w.option_id as number) === winId) {\n // Gross return: stake x rate. Losing stakes are not returned.\n const payout = Math.floor((w.stake as number) * (w.payout_rate as number));\n paidOut += payout;\n winners += 1;\n stmts.push({\n sql: \"UPDATE wagers SET status = 'won', payout = ? WHERE id = ?\",\n args: [payout, w.id],\n });\n stmts.push(...creditStatements(w.user_id as number, payout, \"wager won\", `bet:${betId}`));\n } else {\n stmts.push({\n sql: \"UPDATE wagers SET status = 'lost', payout = 0 WHERE id = ?\",\n args: [w.id],\n });\n }\n }\n\n await sqlite.batch(stmts, \"write\");\n return c.json({ ok: true, winners, paidOut, settled: wagers.rows.length });\n});\n\napp.post(\"/api/admin/fund\", async (c) => {\n const v = await requireAdmin(c);\n if (v instanceof Response) return v;\n\n const { amount } = await c.req.json().catch(() => ({}));\n const delta = Math.floor(Number(amount));\n if (!Number.isFinite(delta) || delta === 0) return bad(c, \"Amount required.\");\n if (Math.abs(delta) > 1_000_000) return bad(c, \"Amount out of range.\");\n\n const users = await sqlite.execute(\"SELECT id FROM users WHERE is_admin = 0\");\n const stmts: any[] = [];\n for (const u of users.rows as any[]) {\n stmts.push(...creditStatements(u.id as number, delta, \"overseer tithe\", null));\n }\n if (stmts.length === 0) return c.json({ ok: true, funded: 0 });\n\n await sqlite.batch(stmts, \"write\");\n return c.json({ ok: true, funded: users.rows.length, amount: delta });\n});\n\napp.delete(\"/api/admin/users/:id\", async (c) => {\n const v = await requireAdmin(c);\n if (v instanceof Response) return v;\n\n const userId = Number(c.req.param(\"id\"));\n const target = await sqlite.execute({\n sql: \"SELECT id, username, is_admin FROM users WHERE id = ?\",\n args: [userId],\n });\n if (target.rows.length === 0) return bad(c, \"No such account.\", 404);\n const t = target.rows[0] as any;\n\n if ((t.is_admin as number) === 1) {\n return bad(c, \"Admin accounts cannot be deleted here. Change the env var instead.\", 403);\n }\n\n await sqlite.batch(\n [\n { sql: \"DELETE FROM wagers WHERE user_id = ?\", args: [userId] },\n { sql: \"DELETE FROM sessions WHERE user_id = ?\", args: [userId] },\n { sql: \"DELETE FROM ledger WHERE user_id = ?\", args: [userId] },\n { sql: \"DELETE FROM users WHERE id = ?\", args: [userId] },\n ],\n \"write\",\n );\n\n return c.json({ ok: true, deleted: t.username });\n});\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n","deleted",false,"label",[14],"bfa39e45-7092-4aeb-b689-37287ba7acba",["D",1789371222313],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Imperial wager ledger — accounts, bets, payouts","imageUrl","userId","28c534b6-beee-40a1-be9c-43985b36185d","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a09ecc-b888-773d-b822-8340b04163b7","tursoName","bfa39e4570924aebb68937287ba7acba","tursoHostname","bfa39e4570924aebb68937287ba7acba-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789545678485],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",6,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Garrick W","avatar","https://lh3.googleusercontent.com/a/ACg8ocIFL4o68YPM3Sv8WlUCusFPkUPZWiKW0FtIuul8fl9ATqyk3Xw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]