{children}

\n );\n}\n\n// ── 登录 ─────────────────────────────────────────────────────────\n\nfunction Login({ onDone }: { onDone: () => void }) {\n const [email, setEmail] = useState(\"\");\n const [code, setCode] = useState(\"\");\n const [sent, setSent] = useState(false);\n const [devCode, setDevCode] = useState(null);\n const [busy, setBusy] = useState(false);\n const [err, setErr] = useState(null);\n\n const sendCode = async () => {\n setBusy(true);\n setErr(null);\n try {\n const r = await api<{ devCode: string | null }>(\"/api/auth/code\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email }),\n });\n setSent(true);\n setDevCode(r.devCode);\n } catch (e) {\n setErr((e as Error).message);\n } finally {\n setBusy(false);\n }\n };\n\n const login = async () => {\n setBusy(true);\n setErr(null);\n try {\n await api(\"/api/auth/login\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email, code }),\n });\n onDone();\n } catch (e) {\n setErr((e as Error).message);\n } finally {\n setBusy(false);\n }\n };\n\n return (\n

AI 创作平台

邮箱验证码登录，首次自动注册并赠送 500 积分

\n\n \n 邮箱\n setEmail((e.target as HTMLInputElement).value)}\n placeholder=\"you@example.com\"\n class=\"w-full mt-1 px-3 py-2 text-sm border border-gray-300 rounded-lg outline-none focus:border-blue-400\"\n />\n\n {sent && (\n <>\n 验证码\n setCode((e.target as HTMLInputElement).value)}\n placeholder=\"6 位数字\"\n class=\"w-full mt-1 px-3 py-2 text-sm border border-gray-300 rounded-lg outline-none focus:border-blue-400\"\n />\n \n )}\n\n {devCode && (\n

\n 开发模式（未配置 RESEND_API_KEY），验证码是 {devCode}\n

\n )}\n\n {err &&

{err}

}\n\n \n {busy ? \"处理中…\" : sent ? \"登录\" : \"获取验证码\"}\n \n \n

\n );\n}\n\n// ── 主界面 ───────────────────────────────────────────────────────\n\nexport function App() {\n const [me, setMe] = useState(null);\n const [loading, setLoading] = useState(true);\n const [tab, setTab] = useState<\"create\" | \"works\" | \"points\" | \"admin\">(\"create\");\n const [gens, setGens] = useState([]);\n const [ledger, setLedger] = useState([]);\n const [kind, setKind] = useState(\"image\");\n const [prompt, setPrompt] = useState(\"\");\n const [busy, setBusy] = useState(false);\n const [msg, setMsg] = useState<{ text: string; bad?: boolean } | null>(null);\n const [adminUsers, setAdminUsers] = useState([]);\n const [adminStats, setAdminStats] = useState<\n { users: number; generations: number; pointsSpent: number } | null\n >(null);\n\n const refresh = async () => {\n const m = await api(\"/api/me\");\n setMe(m);\n if (m.user) {\n setGens(await api(\"/api/generations\"));\n setLedger(await api(\"/api/points\"));\n }\n };\n\n useEffect(() => {\n refresh().finally(() => setLoading(false));\n }, []);\n\n useEffect(() => {\n if (tab === \"admin\" && me?.user?.role === \"admin\") {\n api(\"/api/admin/users\").then(setAdminUsers).catch(() => {});\n api<{ users: number; generations: number; pointsSpent: number }>(\"/api/admin/stats\")\n .then(setAdminStats).catch(() => {});\n }\n }, [tab, me?.user?.role]);\n\n const generate = async () => {\n setBusy(true);\n setMsg(null);\n try {\n const r = await api<{ charged: number; note: string }>(\"/api/generations\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ kind, prompt }),\n });\n setMsg({\n text: r.note ? `完成（未扣分）：${r.note}` : `完成，消耗 ${r.charged} 积分`,\n });\n setPrompt(\"\");\n await refresh();\n } catch (e) {\n setMsg({ text: (e as Error).message, bad: true });\n } finally {\n setBusy(false);\n }\n };\n\n const logout = async () => {\n await api(\"/api/auth/logout\", { method: \"POST\" });\n setMe({ user: null, costs: {} });\n };\n\n const adjust = async (userId: number) => {\n const raw = globalThis.prompt(\"调整积分（可填负数）：\");\n if (!raw) return;\n const delta = Number(raw);\n if (!delta) return;\n await api(\"/api/admin/points\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ userId, delta, reason: \"管理员调整\" }),\n });\n setAdminUsers(await api(\"/api/admin/users\"));\n };\n\n if (loading) {\n return

加载中…

;\n }\n\n if (!me?.user) {\n return refresh().then(() => setLoading(false))} />;\n }\n\n const user = me.user;\n const costs = me.costs;\n\n const tabs = [\n [\"create\", \"创作\"],\n [\"works\", `作品库 (${gens.length})`],\n [\"points\", \"积分流水\"],\n ...(user.role === \"admin\" ? [[\"admin\", \"管理后台\"]] : []),\n ] as const;\n\n return (\n

AI 创作平台

\n {user.nickname} · {user.email}\n {user.role === \"admin\" && \" · 管理员\"}\n

积分

{user.points}

\n \n 退出\n \n

\n\n

\n {tabs.map(([key, label]) => (\n setTab(key as typeof tab)}\n class={`px-4 py-2 text-sm font-medium -mb-px border-b-2 cursor-pointer ${\n tab === key\n ? \"border-blue-500 text-blue-600\"\n : \"border-transparent text-gray-500 hover:text-gray-800\"\n }`}\n >\n {label}\n \n ))}\n

\n\n {tab === \"create\" && (\n \n 类型\n

\n {Object.keys(costs).map((k) => (\n setKind(k)}\n class={`text-sm px-3 py-1.5 rounded-lg border cursor-pointer ${\n kind === k\n ? \"border-blue-500 bg-blue-50 text-blue-700\"\n : \"border-gray-200 text-gray-600 hover:border-gray-400\"\n }`}\n >\n {KIND_LABEL[k] ?? k} · {costs[k]} 分\n \n ))}\n

\n\n 提示词\n setPrompt((e.target as HTMLTextAreaElement).value)}\n rows={3}\n placeholder=\"描述你想要的画面…\"\n class=\"w-full mt-1 px-3 py-2 text-sm border border-gray-300 rounded-lg outline-none focus:border-blue-400\"\n />\n\n \n {busy ? \"生成中…\" : \"开始生成\"}\n \n\n {msg && (\n

\n {msg.text}\n

\n )}\n \n )}\n\n {tab === \"works\" && (\n

\n {gens.map((g) => (\n \n

\n #{g.id}\n {KIND_LABEL[g.kind] ?? g.kind}\n \n {g.status}\n \n {g.cost > 0 ? `-${g.cost} 分` : \"未扣分\"}\n {g.created_at}\n

{g.prompt}

\n {g.result_url && (\n $\"\"$ \n )}\n {g.error &&

{g.error}

}\n \n ))}\n {!gens.length && (\n

还没有作品

\n )}\n

\n )}\n\n {tab === \"points\" && (\n \n

\n {ledger.map((l) => (\n

\n 0 ? \"text-emerald-600\" : \"text-rose-600\"}>\n {l.delta > 0 ? \"+\" : \"\"}{l.delta}\n \n {l.reason}\n {l.created_at}\n

\n ))}\n {!ledger.length && (\n

还没有流水

\n )}\n

\n \n )}\n\n {tab === \"admin\" && (\n

\n {adminStats && (\n

\n \n

用户

{adminStats.users}

\n \n \n

生成次数

{adminStats.generations}

\n \n \n

消耗积分

{adminStats.pointsSpent}

\n \n

\n )}\n\n \n

\n {adminUsers.map((u) => (\n

\n #{u.id}\n {u.email}\n {u.gens} 次生成\n {u.points}\n {u.role === \"admin\" && (\n \n 管理员\n \n )}\n adjust(u.id)}\n class=\"text-xs text-blue-600 hover:underline cursor-pointer\"\n >\n 调分\n \n

\n ))}\n

\n \n

\n )}\n\n

\n 查看源码\n

\n );\n}","01a0aa69-97a0-72fb-98d4-cfd92c4259c3",["D",1789565480301],"branchVersion","label",[166,167,69],"frontend","components","pulls","branches","forks","envVars",{"_175":26,"_177":26},"connections",{"_175":26,"_176":26},"count","unfilledCount","emptyCount",{"_33":267,"_13":166,"_67":233,"_43":-5,"_35":36,"_163":40,"_193":98,"_37":268,"_39":26,"_70":264,"_159":-5,"_72":24,"_164":-5,"_197":269,"_17":270},{"_33":262,"_13":167,"_67":161,"_43":233,"_35":36,"_163":40,"_193":98,"_37":263,"_39":26,"_70":264,"_159":-5,"_72":24,"_164":-5,"_197":265,"_17":266},{"_33":158,"_13":69,"_67":68,"_43":161,"_35":36,"_163":78,"_193":98,"_37":259,"_39":40,"_70":71,"_159":160,"_72":24,"_164":-5,"_197":260,"_17":261},{"_33":252,"_13":253,"_67":254,"_43":161,"_35":36,"_163":40,"_193":98,"_37":255,"_39":26,"_70":71,"_159":256,"_72":24,"_164":-5,"_197":257,"_17":258},{"_33":245,"_13":246,"_67":247,"_43":233,"_35":36,"_163":40,"_193":98,"_37":248,"_39":26,"_70":21,"_159":249,"_72":24,"_164":-5,"_197":250,"_17":251},{"_33":238,"_13":239,"_67":240,"_43":233,"_35":36,"_163":40,"_193":98,"_37":241,"_39":26,"_70":71,"_159":242,"_72":24,"_164":-5,"_197":243,"_17":244},{"_33":230,"_13":231,"_67":232,"_43":233,"_35":36,"_163":40,"_193":98,"_37":234,"_39":26,"_70":71,"_159":235,"_72":24,"_164":-5,"_197":236,"_17":237},{"_33":223,"_13":224,"_67":225,"_43":-5,"_35":36,"_163":40,"_193":98,"_37":226,"_39":26,"_70":21,"_159":227,"_72":24,"_164":-5,"_197":228,"_17":229},{"_33":216,"_13":217,"_67":218,"_43":-5,"_35":36,"_163":40,"_193":98,"_37":219,"_39":26,"_70":21,"_159":220,"_72":24,"_164":-5,"_197":221,"_17":222},{"_33":208,"_13":209,"_67":210,"_43":-5,"_35":36,"_163":211,"_193":98,"_37":212,"_39":26,"_70":71,"_159":213,"_72":24,"_164":-5,"_197":214,"_17":215},{"_33":200,"_13":201,"_67":202,"_43":-5,"_35":36,"_163":203,"_193":98,"_37":204,"_39":26,"_70":71,"_159":205,"_72":24,"_164":-5,"_197":206,"_17":207},{"_33":190,"_13":191,"_67":96,"_43":-5,"_35":36,"_163":192,"_193":98,"_37":194,"_39":40,"_70":195,"_159":196,"_72":24,"_164":-5,"_197":198,"_17":199},"33aa653c-6549-48d3-8f49-bf8bce178039","index.ts",4,"latest",["D",1789565468611],"http","import { parseVal, serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";\nimport { Root } from \"./frontend/root.tsx\";\nimport { one, q } from \"./db.ts\";\nimport {\n COST,\n createCode,\n deliverCode,\n grantPoints,\n loginWithCode,\n logout,\n spendPoints,\n userFromToken,\n type Kind,\n type User,\n} from \"./auth.ts\";\n\nconst app = new Hono();\n\nconst COOKIE = \"session\";\nconst cookieOpts = {\n httpOnly: true,\n sameSite: \"Lax\" as const,\n path: \"/\",\n maxAge: 30 * 24 * 60 * 60,\n};\n\n// ── 前端 ─────────────────────────────────────────────────────────\n\napp.get(\"/\", (c) => c.html(Root()));\napp.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ── 小工具 ───────────────────────────────────────────────────────\n\nconst EMAIL_RE = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n\n/** 从 cookie 取当前用户，没有就抛错（由下面的 catch 转成 401） */\nasync function requireUser(c: { req: { header: (k: string) => string | undefined } }) {\n const user = await userFromToken(getCookie(c as never, COOKIE));\n if (!user) throw Object.assign(new Error(\"请先登录\"), { status: 401 });\n return user;\n}\n\nasync function requireAdmin(c: { req: { header: (k: string) => string | undefined } }) {\n const user = await requireUser(c);\n if (user.role !== \"admin\") {\n throw Object.assign(new Error(\"需要管理员权限\"), { status: 403 });\n }\n return user;\n}\n\n// ── 认证 ─────────────────────────────────────────────────────────\n\n/** 发送邮箱验证码 */\napp.post(\"/api/auth/code\", async (c) => {\n const { email } = await c.req.json<{ email?: string }>();\n if (!email || !EMAIL_RE.test(email)) {\n return c.json({ error: \"邮箱格式不对\" }, 400);\n }\n const code = await createCode(email);\n const devCode = await deliverCode(email, code);\n // devCode 非 null 说明没配邮件服务，直接把验证码给前端方便调试\n return c.json({ ok: true, devCode });\n});\n\n/** 验证码登录（首次自动注册） */\napp.post(\"/api/auth/login\", async (c) => {\n const { email, code } = await c.req.json<{ email?: string; code?: string }>();\n if (!email || !code) return c.json({ error: \"邮箱和验证码都要填\" }, 400);\n\n const { token, user } = await loginWithCode(email, code);\n\n // 第一个注册的人自动成为管理员\n const count = await one(\"SELECT COUNT(*) AS n FROM users\");\n if (Number(count?.n ?? 0) === 1) {\n await q(\"UPDATE users SET role = 'admin' WHERE id = ?\", [user.id]);\n user.role = \"admin\";\n }\n\n setCookie(c, COOKIE, token, cookieOpts);\n return c.json({ ok: true, user });\n});\n\napp.post(\"/api/auth/logout\", async (c) => {\n await logout(getCookie(c, COOKIE));\n deleteCookie(c, COOKIE, { path: \"/\" });\n return c.json({ ok: true });\n});\n\n/** 当前用户 + 价目表 */\napp.get(\"/api/me\", async (c) => {\n const user = await userFromToken(getCookie(c, COOKIE));\n return c.json({ user, costs: COST });\n});\n\n// ── 生成 ─────────────────────────────────────────────────────────\n\n/**\n * 真正调用模型的地方。\n *\n * 现在接了 SiliconFlow（OpenAI 兼容的图片生成接口）。\n * 配上 SILICONFLOW_API_KEY 就走真生成；没配就返回一个占位结果，\n * 并且**不收积分** —— 免得白扣你分。\n *\n * 想换成别的厂商，改这个函数即可：\n * OpenAI → https://api.openai.com/v1/images/generations\n * 火山方舟 → https://ark.cn-beijing.volces.com/api/v3/images/generations\n * fal.ai → https://fal.run/fal-ai/...\n */\nasync function runGeneration(\n kind: Kind,\n prompt: string,\n): Promise<{ resultUrl: string | null; note: string }> {\n const key = Deno.env.get(\"SILICONFLOW_API_KEY\");\n\n if (kind === \"image\" && key) {\n const res = await fetch(\"https://api.siliconflow.cn/v1/images/generations\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: Deno.env.get(\"IMAGE_MODEL\") ?? \"Kwai-Kolors/Kolors\",\n prompt,\n image_size: \"1024x1024\",\n }),\n });\n if (!res.ok) throw new Error(`模型接口报错：${res.status} ${await res.text()}`);\n const data = await res.json() as { images?: { url?: string }[] };\n const url = data.images?.[0]?.url ?? null;\n if (!url) throw new Error(\"模型没返回图片地址\");\n return { resultUrl: url, note: \"\" };\n }\n\n // 没配 key（或视频/短剧还没接）—— 不扣分，只留一条记录\n return {\n resultUrl: null,\n note: kind === \"image\"\n ? \"未配置 SILICONFLOW_API_KEY，本次为占位结果，未扣积分\"\n : `${kind} 还没接模型 API —— 在 index.ts 的 runGeneration() 里接上你自己的`,\n };\n}\n\napp.get(\"/api/generations\", async (c) => {\n const user = await requireUser(c);\n const rows = await q(\n \"SELECT * FROM generations WHERE user_id = ? ORDER BY id DESC LIMIT 50\",\n [user.id],\n );\n return c.json(rows);\n});\n\napp.post(\"/api/generations\", async (c) => {\n const user = await requireUser(c);\n const { kind, prompt } = await c.req.json<{ kind?: string; prompt?: string }>();\n\n if (!kind || !(kind in COST)) {\n return c.json({ error: `kind 必须是 ${Object.keys(COST).join(\" / \")}` }, 400);\n }\n if (!prompt?.trim()) return c.json({ error: \"提示词不能为空\" }, 400);\n\n const k = kind as Kind;\n const cost = COST[k];\n\n // 先落一条 queued 记录，再扣分 —— 这样即使扣分失败也有痕迹\n await q(\n \"INSERT INTO generations (user_id, kind, prompt, status, cost) VALUES (?, ?, ?, 'queued', ?)\",\n [user.id, k, prompt.trim(), cost],\n );\n const row = await one(\"SELECT last_insert_rowid() AS id\");\n const id = Number(row?.id);\n\n try {\n const { resultUrl, note } = await runGeneration(k, prompt.trim());\n const charged = note ? 0 : cost;\n\n if (charged > 0) {\n await spendPoints(user.id, charged, `${k} 生成 #${id}`);\n }\n\n await q(\n \"UPDATE generations SET status = 'completed', result_url = ?, cost = ?, error = ? WHERE id = ?\",\n [resultUrl, charged, note || null, id],\n );\n return c.json({ ok: true, id, resultUrl, charged, note });\n } catch (e) {\n const message = (e as Error).message;\n await q(\"UPDATE generations SET status = 'failed', error = ? WHERE id = ?\", [\n message,\n id,\n ]);\n return c.json({ error: message }, 400);\n }\n});\n\n// ── 积分流水 ─────────────────────────────────────────────────────\n\napp.get(\"/api/points\", async (c) => {\n const user = await requireUser(c);\n const rows = await q(\n \"SELECT * FROM points_ledger WHERE user_id = ? ORDER BY id DESC LIMIT 50\",\n [user.id],\n );\n return c.json(rows);\n});\n\n// ── 管理后台 ─────────────────────────────────────────────────────\n\napp.get(\"/api/admin/users\", async (c) => {\n await requireAdmin(c);\n const rows = await q(\n `SELECT u.id, u.email, u.nickname, u.points, u.role, u.created_at,\n (SELECT COUNT(*) FROM generations g WHERE g.user_id = u.id) AS gens\n FROM users u ORDER BY u.id DESC LIMIT 100`,\n );\n return c.json(rows);\n});\n\napp.post(\"/api/admin/points\", async (c) => {\n await requireAdmin(c);\n const { userId, delta, reason } = await c.req.json<{\n userId?: number;\n delta?: number;\n reason?: string;\n }>();\n if (!userId || !delta) return c.json({ error: \"userId 和 delta 必填\" }, 400);\n await grantPoints(Number(userId), Number(delta), reason?.trim() || \"管理员调整\");\n return c.json({ ok: true });\n});\n\napp.get(\"/api/admin/stats\", async (c) => {\n await requireAdmin(c);\n const [users, gens, spent] = await Promise.all([\n one(\"SELECT COUNT(*) AS n FROM users\"),\n one(\"SELECT COUNT(*) AS n FROM generations\"),\n one(\"SELECT COALESCE(SUM(-delta), 0) AS n FROM points_ledger WHERE delta < 0\"),\n ]);\n return c.json({\n users: Number(users?.n ?? 0),\n generations: Number(gens?.n ?? 0),\n pointsSpent: Number(spent?.n ?? 0),\n });\n});\n\n// ── 错误处理 ─────────────────────────────────────────────────────\n\napp.onError((err, c) => {\n const status = (err as { status?: number }).status ?? 500;\n if (status >= 500) return Promise.reject(err);\n return c.json({ error: err.message }, status as 400);\n});\n\nexport default app.fetch;\n\nexport type { User };","children",[],[191],"d267576f-16ae-4df3-9f2c-79432398d5a1","db.ts","d896f122-b1d2-11f1-a287-1607ee4eb77e",2,["D",1789565455988],"/**\n * 数据层：建表 + 查询助手。\n *\n * 表结构（对标薪火那套的功能，但字段自己设计）：\n * users 用户：邮箱、昵称、积分、角色\n * login_codes 邮箱验证码（10 分钟有效，一次性）\n * sessions 登录会话（30 天）\n * generations 生成记录：类型、提示词、状态、结果、消耗积分\n * points_ledger 积分流水（每次增减都记一笔，可对账）\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type Row = Record;\ntype Arg = string | number | null;\n\nlet ready: Promise | null = null;\n\n/** 建表，幂等。第一次查询时自动跑一次。 */\nexport function initDb(): Promise {\n ready ??= (async () => {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL UNIQUE,\n nickname TEXT NOT NULL DEFAULT '',\n points INTEGER NOT NULL DEFAULT 0,\n role TEXT NOT NULL DEFAULT 'user',\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n `CREATE TABLE IF NOT EXISTS login_codes (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL,\n code TEXT NOT NULL,\n expires_at INTEGER NOT NULL,\n consumed INTEGER NOT NULL DEFAULT 0,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n `CREATE INDEX IF NOT EXISTS idx_login_codes_email ON login_codes(email)`,\n `CREATE TABLE IF NOT EXISTS sessions (\n token TEXT PRIMARY KEY,\n user_id INTEGER NOT NULL,\n expires_at INTEGER NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n `CREATE TABLE IF NOT EXISTS generations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n kind TEXT NOT NULL,\n prompt TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'queued',\n result_url TEXT,\n cost INTEGER NOT NULL DEFAULT 0,\n error TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n `CREATE INDEX IF NOT EXISTS idx_generations_user ON generations(user_id, id DESC)`,\n `CREATE TABLE IF NOT EXISTS points_ledger (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n delta INTEGER NOT NULL,\n reason TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n `CREATE INDEX IF NOT EXISTS idx_ledger_user ON points_ledger(user_id, id DESC)`,\n ]);\n })();\n return ready;\n}\n\n/** 执行查询，返回行数组。所有用户输入都必须走 args 占位符。 */\nexport async function q(sql: string, args: Arg[] = []): Promise {\n await initDb();\n const res = await sqlite.execute({ sql, args });\n return res.rows as Row[];\n}\n\n/** 取第一行，没有则返回 null */\nexport async function one(sql: string, args: Arg[] = []): Promise {\n const rows = await q(sql, args);\n return rows[0] ?? null;\n}\n\nexport { sqlite };",[],[201],"f0951bb4-2d98-413e-b335-c37d4d929e6b","auth.ts","d8a268ea-b1d2-11f1-a287-1607ee4eb77e",3,["D",1789565456077],"/**\n * 认证 + 积分。\n *\n * 登录方式：邮箱验证码（不需要密码）。\n * 验证码默认打到 console，同时返回给前端 —— 这是**开发模式**，\n * 方便你不配邮件服务就能跑通。配上 RESEND_API_KEY 后自动改成真发邮件。\n */\nimport { randomBytes, randomInt } from \"node:crypto\";\nimport { one, q, sqlite, type Row } from \"./db.ts\";\n\n/** 注册赠送的积分 */\nexport const SIGNUP_BONUS = 500;\n\n/** 各类生成消耗的积分 */\nexport const COST = {\n image: 20,\n video: 100,\n drama: 200,\n} as const;\n\nexport type Kind = keyof typeof COST;\n\nconst CODE_TTL_MS = 10 * 60 * 1000;\nconst SESSION_TTL_MS = 30 * 24 * 60 * 60 * 1000;\n\nexport type User = {\n id: number;\n email: string;\n nickname: string;\n points: number;\n role: string;\n};\n\nfunction toUser(row: Row): User {\n return {\n id: Number(row.id),\n email: String(row.email),\n nickname: String(row.nickname),\n points: Number(row.points),\n role: String(row.role),\n };\n}\n\n/** 生成 6 位验证码并存库，返回验证码本身（交给调用方决定怎么送达） */\nexport async function createCode(email: string): Promise {\n const code = String(randomInt(100000, 1000000));\n await q(\n \"INSERT INTO login_codes (email, code, expires_at) VALUES (?, ?, ?)\",\n [email, code, Date.now() + CODE_TTL_MS],\n );\n return code;\n}\n\n/**\n * 校验验证码并登录。首次登录自动注册，送 SIGNUP_BONUS 积分。\n * 返回会话 token。\n */\nexport async function loginWithCode(\n email: string,\n code: string,\n): Promise<{ token: string; user: User }> {\n const row = await one(\n `SELECT id, expires_at FROM login_codes\n WHERE email = ? AND code = ? AND consumed = 0\n ORDER BY id DESC LIMIT 1`,\n [email, code],\n );\n if (!row) throw new Error(\"验证码不正确\");\n if (Number(row.expires_at) < Date.now()) throw new Error(\"验证码已过期，请重新获取\");\n\n // 一次性：立刻作废，防止重放\n await q(\"UPDATE login_codes SET consumed = 1 WHERE id = ?\", [Number(row.id)]);\n\n let userRow = await one(\"SELECT * FROM users WHERE email = ?\", [email]);\n if (!userRow) {\n await q(\n \"INSERT INTO users (email, nickname, points) VALUES (?, ?, ?)\",\n [email, email.split(\"@\")[0], SIGNUP_BONUS],\n );\n userRow = await one(\"SELECT * FROM users WHERE email = ?\", [email]);\n if (!userRow) throw new Error(\"创建用户失败\");\n await q(\n \"INSERT INTO points_ledger (user_id, delta, reason) VALUES (?, ?, ?)\",\n [Number(userRow.id), SIGNUP_BONUS, \"注册赠送\"],\n );\n }\n\n const token = randomBytes(24).toString(\"hex\");\n await q(\n \"INSERT INTO sessions (token, user_id, expires_at) VALUES (?, ?, ?)\",\n [token, Number(userRow.id), Date.now() + SESSION_TTL_MS],\n );\n\n return { token, user: toUser(userRow) };\n}\n\n/** 用 token 换用户，过期或无效返回 null */\nexport async function userFromToken(token: string | undefined): Promise {\n if (!token) return null;\n const row = await one(\n `SELECT u.* FROM sessions s\n JOIN users u ON u.id = s.user_id\n WHERE s.token = ? AND s.expires_at > ?`,\n [token, Date.now()],\n );\n return row ? toUser(row) : null;\n}\n\nexport async function logout(token: string | undefined): Promise {\n if (!token) return;\n await q(\"DELETE FROM sessions WHERE token = ?\", [token]);\n}\n\n/**\n * 扣积分。用 batch 保证「扣分 + 记流水」要么都成功要么都回滚，\n * 避免出现扣了分没记录、或记了流水没扣分的脏数据。\n */\nexport async function spendPoints(\n userId: number,\n amount: number,\n reason: string,\n): Promise {\n const row = await one(\"SELECT points FROM users WHERE id = ?\", [userId]);\n if (!row) throw new Error(\"用户不存在\");\n if (Number(row.points) < amount) {\n throw new Error(`积分不足：需要 ${amount}，当前 ${Number(row.points)}`);\n }\n await sqlite.batch([\n {\n sql: \"UPDATE users SET points = points - ? WHERE id = ?\",\n args: [amount, userId],\n },\n {\n sql: \"INSERT INTO points_ledger (user_id, delta, reason) VALUES (?, ?, ?)\",\n args: [userId, -amount, reason],\n },\n ]);\n}\n\n/** 加积分（管理员调整、活动赠送等） */\nexport async function grantPoints(\n userId: number,\n amount: number,\n reason: string,\n): Promise {\n await sqlite.batch([\n {\n sql: \"UPDATE users SET points = points + ? WHERE id = ?\",\n args: [amount, userId],\n },\n {\n sql: \"INSERT INTO points_ledger (user_id, delta, reason) VALUES (?, ?, ?)\",\n args: [userId, amount, reason],\n },\n ]);\n}\n\n/**\n * 送验证码。有 RESEND_API_KEY 就真发邮件，没有就返回明文（开发模式）。\n * 返回 null 表示已通过邮件送达。\n */\nexport async function deliverCode(email: string, code: string): Promise {\n const key = Deno.env.get(\"RESEND_API_KEY\");\n if (!key) {\n console.log(`[开发模式] ${email} 的验证码是 ${code}`);\n return code;\n }\n const res = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: Deno.env.get(\"RESEND_FROM\") ?? \"onboarding@resend.dev\",\n to: email,\n subject: \"你的登录验证码\",\n text: `验证码：${code}\\n10 分钟内有效。`,\n }),\n });\n if (!res.ok) throw new Error(`邮件发送失败：${res.status} ${await res.text()}`);\n return null;\n}",[],[209],"da974dc1-fece-4968-ac7e-082a8fa72cf7","README.md","01a0aa69-97a0-72fb-98d4-e7927f9d5074",["D",1789565441882],"# React + Hono Starter\n\nA minimal starter template for building client-side React apps with a Hono\nbackend on Val Town. Click **Remix** to get your own copy.\n\n## Picking a starter\n\n| Starter | When to pick it |\n| --- | --- |\n| [`basic-html-starter`](https://www.val.town/x/templates/basic-html-starter) | Static HTML pages. Sprinkle of vanilla JS. No server-side rendering. |\n| [`hono-jsx-starter`](https://www.val.town/x/templates/hono-jsx-starter) | Dynamic server-rendered HTML with JSX. API routes. No React, no SPA. |\n| **[`react-hono-starter`](https://www.val.town/x/templates/react-hono-starter)** *(you're here)* | Client-side React SPA with a Hono API backend. |\n\n**Want to build UI?** Start writing React components in\n[`frontend/components/`](/frontend/components/). Import them into `App.tsx` and\nyou're good to go. Styling is [Twind](https://twind.style/) — just use Tailwind\nutility classes, zero config.\n\n**Want to add an API?** Add routes in [`index.ts`](/index.ts) (there's a\ncommented-out example). Fetch them from your React components.\n\n## Architecture\n\n```mermaid\ngraph LR\n Browser -->|\"GET /\"| Hono[\"index.ts
(Hono server)\"]\n Hono -->|serves| HTML[\"root.tsx\"]\n HTML -->|loads| Entry[\"index.tsx\"]\n Entry -->|renders| App[\"App.tsx\"]\n App -->|renders| Counter[\"Counter.tsx\"]\n```\n\n## File structure\n\n```\nindex.ts ← Hono backend (serves frontend + API routes)\nfrontend/\n root.tsx ← HTML shell (stamps immutable asset URLs)\n index.tsx ← React entrypoint (mounts )\n favicon.svg ← App icon\n components/\n App.tsx ← Root component (layout + view source link)\n Counter.tsx ← Example component with state\n```\n\n## How it works\n\n1. **`index.ts`** is the HTTP entrypoint — a Hono server that serves the\n frontend and any API routes you add.\n2. **`frontend/root.tsx`** is the HTML shell — it loads Twind and stamps\n immutable asset URLs for the favicon and React entrypoint.\n3. **`frontend/index.tsx`** mounts the React app.\n4. **`frontend/components/App.tsx`** is the root layout — add new components\n alongside it.\n5. **`frontend/components/Counter.tsx`** is an example stateful component —\n replace it with your own!\n\n## Next steps\n\n- Add API routes in `index.ts`\n- Add new components in `frontend/components/`\n- Add a SQLite database — see the\n [React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) for\n a full-stack example with database, queries, and shared types\n\nTemplate updates and upgrade paths for existing remixes: [CHANGELOG.md](/CHANGELOG.md)\n",[],[217],"239d12c5-865e-47fa-82ed-b364434b68ae","CHANGELOG.md","01a0aa69-97a0-72fb-98d4-e02dbec7365d",["D",1789565441882],"# Changelog\n\n## 2026-07-30 — Immutable asset caching\n\nFrontend files are now served at version-addressed URLs\n(`/__immutable/45/frontend/index.tsx`) with\n`Cache-Control: public, max-age=31536000, immutable`, so repeat visits load the\nwhole client graph from the browser cache — roughly 3× faster (~665ms → ~157ms\nmeasured). Publishing your val bumps its version, which changes every URL, so\ncaches invalidate automatically. Old-version URLs return 404 after a publish\n(like Next.js build assets); a reload picks up the new version.\n\nWhat changed in the template:\n\n- `frontend/index.html` → [`frontend/root.tsx`](/frontend/root.tsx): the HTML\n shell is now JSX and stamps asset URLs with `immutableFileUrl()`\n- [`index.ts`](/index.ts): serves `Root()` at `/`, and one\n `app.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path))` route\n serves all frontend files\n\n### Upgrading an existing remix\n\nYour copy of this template doesn't update automatically. Two options:\n\n**Minimal (most of the benefit):** point both routes at `serveImmutableFile` —\nyour existing bare URLs redirect into versioned space, the new route serves\nthem, and the whole module graph gets cached (costs one redirect per page view):\n\n```ts\nimport { serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\n\napp.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path));\napp.get(\"/frontend/**/*\", (c) => serveImmutableFile(c.req.path)); // was serveFile\n```\n\n**Full upgrade (also removes the redirect):** three self-contained steps —\nno other files needed. Adjust the ``, favicon, and body of `Root()` to\nmatch your app's existing `index.html`, and stamp anything else your shell\nreferences directly (images, css) with `immutableFileUrl()`.\n\n1. Create `frontend/root.tsx`:\n\n```tsx\n/** @jsxImportSource npm:hono@4/jsx */\nimport { raw } from \"npm:hono@4/html\";\nimport { immutableFileUrl } from \"https://esm.town/v/std/utils/index.ts\";\n\n// The HTML shell for the app. It is never cached, so immutableFileUrl can stamp\n// the current val version into each asset URL — the browser caches those\n// immutably, and publishing the val changes the URLs, refetching exactly once.\nexport function Root() {\n return (\n <>\n {raw(\"<!DOCTYPE html>\")}\n <html lang=\"en\">\n <head>\n <meta charSet=\"UTF-8\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" />\n <title>React Hono Val Town Starter\n

History · App.tsx