[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":57,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",17,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","a3cee3d6-5ed7-11f0-9b27-0224a6c84d84","name","fileType","http","content","// @ts-ignore\nimport { Hono } from \"npm:hono@4.4.12\";\n// @ts-ignore\nimport { bearerAuth } from \"npm:hono@4.4.12/bearer-auth\";\n// @ts-ignore\nimport { getCookie, setCookie } from \"npm:hono@4.4.12/cookie\";\n// @ts-ignore\nimport { sqlite } from \"https://esm.town/v/std/sqlite?v=4\";\n// @ts-ignore\nimport { email as sendEmail } from \"https://esm.town/v/std/email?v=9\";\n// @ts-ignore\nimport { OpenAI } from \"https://esm.town/v/std/openai?v=4\";\n\n// --- CONSTANTS & CONFIGURATION ---\nconst STYLES = {\n normal: [\"dots\", \"hash\", \"vertical\", \"horizontal\", \"diagonal\", \"stairs\", \"chevron\", \"circles\", \"plus\", \"triangles\"],\n premium: [\n \"argyle\",\n \"plaid\",\n \"sunburst\",\n \"target\",\n \"scales\",\n \"bricks\",\n \"woven\",\n \"zigzag\",\n \"crosshatch\",\n \"checkerboard\",\n ],\n};\nconst ALL_STYLES = [...STYLES.normal, ...STYLES.premium];\nconst MICRO_INTERACTIONS = [\"glow\", \"pulse\", \"shake\"];\nconst COSTS = { POST: 10, PREMIUM_BG: 20, MICRO_INTERACTION: 50, CONTRIBUTE_CLEAR: 5 };\nconst POT_GOALS = { CLEAR: 100, DISSENT: 1000 };\nconst DISSENT_DURATION_MS = 60 * 1000;\n\n// --- TYPE DEFINITIONS ---\ninterface User {\n id: number;\n username: string;\n credits: number;\n}\ninterface Message {\n id: number;\n username: string;\n text: string;\n style: string;\n micro_interaction: string | null;\n post_tier: string;\n}\ninterface BoardState {\n clear_pot: number;\n dissent_pot: number;\n dissent_active_until: number | null;\n last_announcement: { type: string; text: string; user: string } | null;\n}\n\n// --- DATABASE SETUP & HELPERS ---\nasync function initializeDatabase() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT, username TEXT NOT NULL UNIQUE, email TEXT NOT NULL UNIQUE,\n credits INTEGER NOT NULL DEFAULT 100, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, last_login_claim TIMESTAMP\n )`,\n `CREATE TABLE IF NOT EXISTS login_tokens (\n token TEXT PRIMARY KEY, user_id INTEGER NOT NULL, expires_at TIMESTAMP NOT NULL,\n FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE\n )`,\n `CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER NOT NULL, text TEXT NOT NULL, style TEXT NOT NULL,\n micro_interaction TEXT, post_number INTEGER, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE\n )`,\n `CREATE TABLE IF NOT EXISTS clear_attempts (\n id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER NOT NULL, timestamp TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE\n )`,\n `CREATE TABLE IF NOT EXISTS app_state (key TEXT PRIMARY KEY, value TEXT NOT NULL)`,\n ]);\n await sqlite.execute(\n `INSERT OR IGNORE INTO app_state (key, value) VALUES \n ('clear_pot', '0'), ('dissent_pot', '0'), ('global_post_count', '0'),\n ('dissent_active_until', 'null'), ('last_announcement', 'null')`,\n );\n}\n\nasync function getAppState(): Promise {\n const { results } = await sqlite.execute(\"SELECT key, value FROM app_state\");\n return results.reduce((acc, row) => {\n try {\n acc[row.key] = JSON.parse(row.value);\n }\n catch {\n acc[row.key] = row.value;\n }\n return acc;\n }, {});\n}\n\nasync function runTransaction(callback: (tx: any) => Promise) {\n const tx = sqlite.transaction();\n try {\n const result = await callback(tx);\n await tx.commit();\n return result;\n } catch (error) {\n await tx.rollback();\n throw error;\n }\n}\n\n// --- AI VIBE CHECK ---\nconst VIBE_CHECK_PROMPT =\n `You are the Vibe Guardian. Analyze the submission for hate speech, spam, or abuse. Respond ONLY with a minified JSON object: {\"approved\": boolean, \"reason\": \"string\"}.`;\n\n// --- AUTHENTICATION & MIDDLEWARE ---\nconst app = new Hono<{ Variables: { user: User } }>();\nawait initializeDatabase();\n\nconst authMiddleware = bearerAuth({\n verifyToken: async (token, c) => {\n if (!token) return null;\n const { results } = await sqlite.execute({\n sql: `SELECT u.id, u.username, u.credits FROM users u \n JOIN login_tokens t ON u.id = t.user_id \n WHERE t.token = ? AND t.expires_at > datetime('now')`,\n args: [token],\n });\n return results.length > 0 ? results[0] as User : null;\n },\n});\n\n// --- GAME LOGIC MIDDLEWARE ---\nconst resolutionMiddleware = async (c, next) => {\n const state = await getAppState();\n if (state.dissent_active_until && new Date() > new Date(state.dissent_active_until)) {\n // Dissent period is over, resolve it.\n const dissentGoalMet = state.dissent_pot >= POT_GOALS.DISSENT;\n if (!dissentGoalMet) {\n // Veto failed, clear the board.\n await sqlite.execute(\"DELETE FROM messages\");\n }\n // Reset all pots and timers\n await sqlite.batch([\n `UPDATE app_state SET value = '0' WHERE key = 'clear_pot'`,\n `UPDATE app_state SET value = '0' WHERE key = 'dissent_pot'`,\n `UPDATE app_state SET value = 'null' WHERE key = 'dissent_active_until'`,\n ]);\n }\n await next();\n};\n\n// --- API ENDPOINTS ---\n\n// PUBLIC ROUTES\napp.get(\"/\", (c) => c.html(generateHtml(new URL(c.req.url).origin)));\napp.get(\"/messages\", resolutionMiddleware, async (c) => {\n const { results } = await sqlite.execute(`\n SELECT m.id, u.username, m.text, m.style, m.micro_interaction, m.post_number\n FROM messages m JOIN users u ON m.user_id = u.id\n ORDER BY m.created_at DESC LIMIT 50\n `);\n const messages = (results as any[]).map(msg => {\n let post_tier = \"normal\";\n if (msg.post_number % 1000 === 0) post_tier = \"super\";\n else if (msg.post_number % 100 === 0) post_tier = \"mega\";\n else if (msg.post_number % 10 === 0) post_tier = \"big\";\n return { ...msg, post_tier };\n });\n return c.json(messages);\n});\n\napp.get(\"/board_state\", resolutionMiddleware, async (c) => {\n const state = await getAppState();\n if (state.last_announcement) {\n // Clear announcement after sending it once\n await sqlite.execute(\"UPDATE app_state SET value = 'null' WHERE key = 'last_announcement'\");\n }\n return c.json({\n clear_pot: state.clear_pot,\n dissent_pot: state.dissent_pot,\n dissent_active_until: state.dissent_active_until,\n last_announcement: state.last_announcement,\n });\n});\n\napp.post(\"/register\", async (c) => {\n try {\n const { email, username } = await c.req.json();\n if (!email || !username) return c.json({ error: \"Email and username are required.\" }, 400);\n await sqlite.execute({\n sql: \"INSERT INTO users (email, username, credits) VALUES (?, ?, 100)\",\n args: [email, username],\n });\n return c.json({ success: true, message: \"Registration successful. Please check your email to log in.\" });\n } catch (e) {\n return c.json({ error: \"Username or email may already be taken.\" }, 409);\n }\n});\n\napp.post(\"/login\", async (c) => {\n const { email } = await c.req.json();\n const { results } = await sqlite.execute({ sql: \"SELECT id FROM users WHERE email = ?\", args: [email] });\n if (results.length === 0) return c.json({ error: \"User not found.\" }, 404);\n const userId = (results[0] as { id: number }).id;\n const token = crypto.randomUUID();\n await sqlite.execute({\n sql: \"INSERT INTO login_tokens (token, user_id, expires_at) VALUES (?, ?, datetime('now', '+15 minutes'))\",\n args: [token, userId],\n });\n await sendEmail({\n to: email,\n subject: \"Your Vibe Board Login Link\",\n html: `Welcome back! Click here to log in. This link expires in 15 minutes.`,\n });\n return c.json({ success: true, message: \"Login link sent.\" });\n});\n\napp.get(\"/verify_login\", async (c) => {\n const token = c.req.query(\"token\");\n if (!token) return c.text(\"Invalid token.\", 400);\n\n const user = await runTransaction(async (tx) => {\n const { results } = await tx.execute({\n sql: \"SELECT user_id FROM login_tokens WHERE token = ? AND expires_at > datetime('now')\",\n args: [token],\n });\n if (results.length === 0) return null;\n const userId = (results[0] as { user_id: number }).user_id;\n\n await tx.execute({\n sql: `UPDATE users SET credits = credits + 10, last_login_claim = CURRENT_TIMESTAMP \n WHERE id = ? AND (last_login_claim IS NULL OR last_login_claim <= datetime('now', '-8 hours'))`,\n args: [userId],\n });\n return userId;\n });\n\n if (!user) return c.text(\"Login link is invalid or has expired.\", 401);\n\n setCookie(c, \"auth_token\", token, {\n path: \"/\",\n maxAge: 60 * 60 * 24 * 7,\n secure: true,\n httpOnly: true,\n sameSite: \"Lax\",\n });\n return c.redirect(\"/\");\n});\n\n// AUTHENTICATED ROUTES\napp.use(\"/me\", authMiddleware);\napp.get(\"/me\", (c) => c.json(c.get(\"user\")));\n\napp.use(\"/messages\", authMiddleware);\napp.post(\"/messages\", async (c) => {\n const user = c.get(\"user\");\n const { text, style, micro_interaction } = await c.req.json();\n\n if (!text || !style) return c.json({ error: \"Text and style are required\" }, 400);\n if (!ALL_STYLES.includes(style)) return c.json({ error: \"Invalid style\" }, 400);\n\n let totalCost = COSTS.POST;\n if (STYLES.premium.includes(style)) totalCost += COSTS.PREMIUM_BG;\n if (micro_interaction && MICRO_INTERACTIONS.includes(micro_interaction)) totalCost += COSTS.MICRO_INTERACTION;\n\n if (user.credits < totalCost) return c.json({ error: \"Not enough credits.\" }, 402);\n\n // Vibe Check with OpenAI\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [{ role: \"system\", content: VIBE_CHECK_PROMPT }, { role: \"user\", content: text }],\n response_format: { type: \"json_object\" },\n });\n const vibe = JSON.parse(completion.choices[0].message.content);\n if (!vibe.approved) return c.json({ error: `Post rejected by Vibe Guardian: ${vibe.reason}` }, 400);\n\n // Transaction to post message\n const newState = await runTransaction(async (tx) => {\n await tx.execute({ sql: \"UPDATE users SET credits = credits - ? WHERE id = ?\", args: [totalCost, user.id] });\n const { results } = await tx.execute(\"SELECT value FROM app_state WHERE key = 'global_post_count'\");\n const postCount = parseInt(results[0].value as string) + 1;\n await tx.execute({\n sql: \"UPDATE app_state SET value = ? WHERE key = 'global_post_count'\",\n args: [postCount.toString()],\n });\n\n let announcement = null;\n if (postCount % 1000 === 0)\n announcement = { type: \"super\", text: `SUPER POST #${postCount}!`, user: user.username };\n else if (postCount % 100 === 0)\n announcement = { type: \"mega\", text: `MEGA POST #${postCount}!`, user: user.username };\n else if (postCount % 10 === 0) announcement = { type: \"big\", text: `BIG POST #${postCount}!`, user: user.username };\n\n if (announcement) {\n await tx.execute({\n sql: \"UPDATE app_state SET value = ? WHERE key = 'last_announcement'\",\n args: [JSON.stringify(announcement)],\n });\n }\n\n await tx.execute({\n sql: \"INSERT INTO messages (user_id, text, style, micro_interaction, post_number) VALUES (?, ?, ?, ?, ?)\",\n args: [user.id, text, style, micro_interaction, postCount],\n });\n const { results: userResults } = await tx.execute({\n sql: \"SELECT credits FROM users WHERE id = ?\",\n args: [user.id],\n });\n return { newCredits: (userResults[0] as any).credits };\n });\n\n return c.json({ success: true, ...newState });\n});\n\napp.use(\"/contribute_*\", resolutionMiddleware, authMiddleware);\napp.post(\"/contribute_clear\", async (c) => {\n const user = c.get(\"user\");\n if (user.credits < COSTS.CONTRIBUTE_CLEAR) return c.json({ error: \"Not enough credits.\" }, 402);\n\n const { results: attempts } = await sqlite.execute({\n sql: \"SELECT COUNT(*) as count FROM clear_attempts WHERE user_id = ? AND timestamp > datetime('now', '-24 hours')\",\n args: [user.id],\n });\n if ((attempts[0] as any).count >= 2) return c.json({ error: \"You can only contribute twice every 24 hours.\" }, 429);\n\n const state = await runTransaction(async (tx) => {\n await tx.execute({\n sql: \"UPDATE users SET credits = credits - ? WHERE id = ?\",\n args: [COSTS.CONTRIBUTE_CLEAR, user.id],\n });\n await tx.execute({ sql: \"INSERT INTO clear_attempts (user_id) VALUES (?)\", args: [user.id] });\n\n const { results } = await tx.execute(\"SELECT value FROM app_state WHERE key = 'clear_pot'\");\n const newPotValue = parseInt(results[0].value as string) + COSTS.CONTRIBUTE_CLEAR;\n await tx.execute({ sql: \"UPDATE app_state SET value = ? WHERE key = 'clear_pot'\", args: [newPotValue.toString()] });\n\n if (newPotValue >= POT_GOALS.CLEAR) {\n const dissentUntil = new Date(Date.now() + DISSENT_DURATION_MS).toISOString();\n await tx.execute({\n sql: \"UPDATE app_state SET value = ? WHERE key = 'dissent_active_until'\",\n args: [JSON.stringify(dissentUntil)],\n });\n }\n return getAppState();\n });\n\n return c.json({ success: true, state });\n});\n\napp.post(\"/contribute_dissent\", async (c) => {\n const user = c.get(\"user\");\n const state = await getAppState();\n\n if (!state.dissent_active_until || new Date() > new Date(state.dissent_active_until)) {\n return c.json({ error: \"The dissent period is not active.\" }, 400);\n }\n if (user.credits < COSTS.CONTRIBUTE_CLEAR) return c.json({ error: \"Not enough credits.\" }, 402);\n\n const newState = await runTransaction(async (tx) => {\n await tx.execute({\n sql: \"UPDATE users SET credits = credits - ? WHERE id = ?\",\n args: [COSTS.CONTRIBUTE_CLEAR, user.id],\n });\n const newPotValue = state.dissent_pot + COSTS.CONTRIBUTE_CLEAR;\n await tx.execute({\n sql: \"UPDATE app_state SET value = ? WHERE key = 'dissent_pot'\",\n args: [newPotValue.toString()],\n });\n return getAppState();\n });\n\n return c.json({ success: true, state: newState });\n});\n\nexport default app.fetch;\n\n// --- HTML & Frontend Generation ---\nfunction generateHtml(sourceUrl: string) {\n return `\n\n\n Vibe Board Deluxe\n \n \n \n\n\n \n\n

Vibe Board Deluxe

...

\n \n

...

\n\n \n\n`;\n}","// @ts-ignore\nimport { Hono } from \"npm:hono@4.4.12\";\n// @ts-ignore\nimport { bearerAuth } from \"npm:hono@4.4.12/bearer-auth\";\n// @ts-ignore\nimport { getCookie, setCookie } from \"npm:hono@4.4.12/cookie\";\n// @ts-ignore\nimport { sqlite } from \"https://esm.town/v/std/sqlite?v=4\";\n// @ts-ignore\nimport { email as sendEmail } from \"https://esm.town/v/std/email?v=9\";\n// @ts-ignore\nimport { OpenAI } from \"https://esm.town/v/std/openai?v=4\";\n\n// --- CONSTANTS & CONFIGURATION ---\nconst STYLES = {\n normal: [\"dots\", \"hash\", \"vertical\", \"horizontal\", \"diagonal\", \"stairs\", \"chevron\", \"circles\", \"plus\", \"triangles\"],\n premium: [\"argyle\", \"plaid\", \"sunburst\", \"target\", \"scales\", \"bricks\", \"woven\", \"zigzag\", \"crosshatch\", \"checkerboard\"],\n};\nconst ALL_STYLES = [...STYLES.normal, ...STYLES.premium];\nconst MICRO_INTERACTIONS = [\"glow\", \"pulse\", \"shake\"];\nconst COSTS = { POST: 10, PREMIUM_BG: 20, MICRO_INTERACTION: 50, CONTRIBUTE_CLEAR: 5 };\nconst POT_GOALS = { CLEAR: 100, DISSENT: 1000 };\nconst DISSENT_DURATION_MS = 60 * 1000;\n\n// --- TYPE DEFINITIONS ---\ninterface User { id: number; username: string; credits: number; }\ninterface Message { id: number; username: string; text: string; style: string; micro_interaction: string | null; post_tier: string; }\ninterface BoardState { clear_pot: number; dissent_pot: number; dissent_active_until: number | null; last_announcement: { type: string, text: string, user: string } | null; }\n\n// --- DATABASE SETUP & HELPERS ---\nasync function initializeDatabase() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT, username TEXT NOT NULL UNIQUE, email TEXT NOT NULL UNIQUE,\n credits INTEGER NOT NULL DEFAULT 100, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, last_login_claim TIMESTAMP\n )`,\n `CREATE TABLE IF NOT EXISTS login_tokens (\n token TEXT PRIMARY KEY, user_id INTEGER NOT NULL, expires_at TIMESTAMP NOT NULL,\n FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE\n )`,\n `CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER NOT NULL, text TEXT NOT NULL, style TEXT NOT NULL,\n micro_interaction TEXT, post_number INTEGER, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE\n )`,\n `CREATE TABLE IF NOT EXISTS clear_attempts (\n id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER NOT NULL, timestamp TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE\n )`,\n `CREATE TABLE IF NOT EXISTS app_state (key TEXT PRIMARY KEY, value TEXT NOT NULL)`,\n ]);\n await sqlite.execute(\n `INSERT OR IGNORE INTO app_state (key, value) VALUES \n ('clear_pot', '0'), ('dissent_pot', '0'), ('global_post_count', '0'),\n ('dissent_active_until', 'null'), ('last_announcement', 'null')`\n );\n}\n\nasync function getAppState(): Promise {\n const queryResult = await sqlite.execute(\"SELECT key, value FROM app_state\");\n // ✨ FIX: Safeguard against the query result not having a `results` property.\n const results = queryResult?.results || [];\n return results.reduce((acc, row: any) => {\n try { acc[row.key] = JSON.parse(row.value); } \n catch { acc[row.key] = row.value; }\n return acc;\n }, {});\n}\n\n\nasync function runTransaction(callback) {\n const tx = sqlite.transaction();\n try {\n const result = await callback(tx);\n await tx.commit();\n return result;\n } catch (error) {\n await tx.rollback();\n throw error;\n }\n}\n\n// --- AI VIBE CHECK ---\nconst VIBE_CHECK_PROMPT = `You are the Vibe Guardian. Analyze the submission for hate speech, spam, or abuse. Respond ONLY with a minified JSON object: {\"approved\": boolean, \"reason\": \"string\"}.`;\n\n// --- AUTHENTICATION & MIDDLEWARE ---\nconst app = new Hono<{ Variables: { user: User } }>();\nawait initializeDatabase();\n\nconst authMiddleware = bearerAuth({\n verifyToken: async (token, c) => {\n if (!token) return null;\n const { results } = await sqlite.execute({\n sql: `SELECT u.id, u.username, u.credits FROM users u \n JOIN login_tokens t ON u.id = t.user_id \n WHERE t.token = ? AND t.expires_at > datetime('now')`,\n args: [token],\n });\n return results && results.length > 0 ? results[0] as User : null;\n },\n});\n\n// --- GAME LOGIC MIDDLEWARE ---\nconst resolutionMiddleware = async (c, next) => {\n const state = await getAppState();\n if (state.dissent_active_until && new Date() > new Date(state.dissent_active_until)) {\n const dissentGoalMet = state.dissent_pot >= POT_GOALS.DISSENT;\n if (!dissentGoalMet) {\n await sqlite.execute(\"DELETE FROM messages\");\n }\n await sqlite.batch([\n `UPDATE app_state SET value = '0' WHERE key = 'clear_pot'`,\n `UPDATE app_state SET value = '0' WHERE key = 'dissent_pot'`,\n `UPDATE app_state SET value = 'null' WHERE key = 'dissent_active_until'`,\n ]);\n }\n await next();\n};\n\n// --- API ENDPOINTS ---\n\napp.get(\"/\", (c) => c.html(generateHtml(new URL(c.req.url).origin)));\n\napp.get(\"/messages\", resolutionMiddleware, async (c) => {\n const { results } = await sqlite.execute(`\n SELECT m.id, u.username, m.text, m.style, m.micro_interaction, m.post_number\n FROM messages m JOIN users u ON m.user_id = u.id\n ORDER BY m.created_at DESC LIMIT 50\n `);\n const messages = (results as any[] || []).map(msg => {\n let post_tier = \"normal\";\n if (msg.post_number % 1000 === 0) post_tier = \"super\";\n else if (msg.post_number % 100 === 0) post_tier = \"mega\";\n else if (msg.post_number % 10 === 0) post_tier = \"big\";\n return { ...msg, post_tier };\n });\n return c.json(messages);\n});\n\napp.get(\"/board_state\", resolutionMiddleware, async (c) => {\n const state = await getAppState();\n if (state.last_announcement) {\n await sqlite.execute(\"UPDATE app_state SET value = 'null' WHERE key = 'last_announcement'\");\n }\n return c.json({\n clear_pot: state.clear_pot,\n dissent_pot: state.dissent_pot,\n dissent_active_until: state.dissent_active_until,\n last_announcement: state.last_announcement,\n });\n});\n\napp.post(\"/register\", async (c) => {\n try {\n const { email, username } = await c.req.json();\n if (!email || !username) return c.json({ error: \"Email and username are required.\" }, 400);\n await sqlite.execute({\n sql: \"INSERT INTO users (email, username, credits) VALUES (?, ?, 100)\",\n args: [email, username],\n });\n return c.json({ success: true, message: \"Registration successful. Please check your email to log in.\" });\n } catch (e) {\n return c.json({ error: \"Username or email may already be taken.\" }, 409);\n }\n});\n\napp.post(\"/login\", async (c) => {\n const { email } = await c.req.json();\n const { results } = await sqlite.execute({ sql: \"SELECT id FROM users WHERE email = ?\", args: [email] });\n if (!results || results.length === 0) return c.json({ error: \"User not found.\" }, 404);\n const userId = (results[0] as { id: number }).id;\n const token = crypto.randomUUID();\n await sqlite.execute({\n sql: \"INSERT INTO login_tokens (token, user_id, expires_at) VALUES (?, ?, datetime('now', '+15 minutes'))\",\n args: [token, userId],\n });\n await sendEmail({\n to: email, subject: \"Your Vibe Board Login Link\",\n html: `Welcome back! Click here to log in. This link expires in 15 minutes.`,\n });\n return c.json({ success: true, message: \"Login link sent.\" });\n});\n\napp.get(\"/verify_login\", async (c) => {\n const token = c.req.query(\"token\");\n if (!token) return c.text(\"Invalid token.\", 400);\n\n const user = await runTransaction(async (tx) => {\n const { results } = await tx.execute({\n sql: \"SELECT user_id FROM login_tokens WHERE token = ? AND expires_at > datetime('now')\",\n args: [token],\n });\n if (!results || results.length === 0) return null;\n const userId = (results[0] as { user_id: number }).user_id;\n\n await tx.execute({\n sql: `UPDATE users SET credits = credits + 10, last_login_claim = CURRENT_TIMESTAMP \n WHERE id = ? AND (last_login_claim IS NULL OR last_login_claim <= datetime('now', '-8 hours'))`,\n args: [userId],\n });\n return userId;\n });\n\n if (!user) return c.text(\"Login link is invalid or has expired.\", 401);\n \n setCookie(c, \"auth_token\", token, { path: \"/\", maxAge: 60 * 60 * 24 * 7, secure: true, httpOnly: true, sameSite: 'Lax' });\n return c.redirect(\"/\");\n});\n\napp.use(\"/me/*\", authMiddleware);\napp.get(\"/me\", (c) => c.json(c.get(\"user\")));\n\napp.use(\"/messages\", authMiddleware);\napp.post(\"/messages\", async (c) => {\n const user = c.get(\"user\");\n const { text, style, micro_interaction } = await c.req.json();\n\n if (!text || !style) return c.json({ error: \"Text and style are required\" }, 400);\n if (!ALL_STYLES.includes(style)) return c.json({ error: \"Invalid style\" }, 400);\n\n let totalCost = COSTS.POST;\n if (STYLES.premium.includes(style)) totalCost += COSTS.PREMIUM_BG;\n if (micro_interaction && MICRO_INTERACTIONS.includes(micro_interaction)) totalCost += COSTS.MICRO_INTERACTION;\n\n const { results: userCreditsRes } = await sqlite.execute({ sql: \"SELECT credits FROM users WHERE id = ?\", args: [user.id]});\n if (!userCreditsRes || (userCreditsRes[0] as any).credits < totalCost) return c.json({ error: \"Not enough credits.\" }, 402);\n \n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({ model: \"gpt-4o\", messages: [{ role: \"system\", content: VIBE_CHECK_PROMPT }, { role: \"user\", content: text }], response_format: { type: \"json_object\" } });\n const vibe = JSON.parse(completion.choices[0].message.content);\n if (!vibe.approved) return c.json({ error: `Post rejected by Vibe Guardian: ${vibe.reason}`}, 400);\n\n const newState = await runTransaction(async (tx) => {\n await tx.execute({ sql: \"UPDATE users SET credits = credits - ? WHERE id = ?\", args: [totalCost, user.id] });\n const { results } = await tx.execute(\"SELECT value FROM app_state WHERE key = 'global_post_count'\");\n const postCount = parseInt(results[0].value as string) + 1;\n await tx.execute({ sql: \"UPDATE app_state SET value = ? WHERE key = 'global_post_count'\", args: [postCount.toString()] });\n\n let announcement = null;\n if (postCount % 1000 === 0) announcement = { type: \"super\", text: `SUPER POST #${postCount}!`, user: user.username };\n else if (postCount % 100 === 0) announcement = { type: \"mega\", text: `MEGA POST #${postCount}!`, user: user.username };\n else if (postCount % 10 === 0) announcement = { type: \"big\", text: `BIG POST #${postCount}!`, user: user.username };\n \n if (announcement) {\n await tx.execute({ sql: \"UPDATE app_state SET value = ? WHERE key = 'last_announcement'\", args: [JSON.stringify(announcement)] });\n }\n\n await tx.execute({\n sql: \"INSERT INTO messages (user_id, text, style, micro_interaction, post_number) VALUES (?, ?, ?, ?, ?)\",\n args: [user.id, text, style, micro_interaction || null, postCount],\n });\n const { results: userResults } = await tx.execute({ sql: \"SELECT credits FROM users WHERE id = ?\", args: [user.id] });\n return { newCredits: (userResults[0] as any).credits };\n });\n\n return c.json({ success: true, ...newState });\n});\n\napp.use(\"/contribute_*\", resolutionMiddleware, authMiddleware);\napp.post(\"/contribute_clear\", async (c) => {\n const user = c.get(\"user\");\n \n const { results: userCreditsRes } = await sqlite.execute({ sql: \"SELECT credits FROM users WHERE id = ?\", args: [user.id]});\n if (!userCreditsRes || (userCreditsRes[0] as any).credits < COSTS.CONTRIBUTE_CLEAR) return c.json({ error: \"Not enough credits.\" }, 402);\n\n const { results: attempts } = await sqlite.execute({\n sql: \"SELECT COUNT(*) as count FROM clear_attempts WHERE user_id = ? AND timestamp > datetime('now', '-24 hours')\",\n args: [user.id],\n });\n if ((attempts[0] as any).count >= 2) return c.json({ error: \"You can only contribute twice every 24 hours.\" }, 429);\n\n const state = await runTransaction(async (tx) => {\n await tx.execute({ sql: \"UPDATE users SET credits = credits - ? WHERE id = ?\", args: [COSTS.CONTRIBUTE_CLEAR, user.id] });\n await tx.execute({ sql: \"INSERT INTO clear_attempts (user_id) VALUES (?)\", args: [user.id] });\n \n const { results } = await tx.execute(\"SELECT value FROM app_state WHERE key = 'clear_pot'\");\n const newPotValue = parseInt(results[0].value as string) + COSTS.CONTRIBUTE_CLEAR;\n await tx.execute({ sql: \"UPDATE app_state SET value = ? WHERE key = 'clear_pot'\", args: [newPotValue.toString()] });\n\n if (newPotValue >= POT_GOALS.CLEAR) {\n const dissentUntil = new Date(Date.now() + DISSENT_DURATION_MS).toISOString();\n await tx.execute({ sql: \"UPDATE app_state SET value = ? WHERE key = 'dissent_active_until'\", args: [JSON.stringify(dissentUntil)] });\n }\n return getAppState();\n });\n\n return c.json({ success: true, state });\n});\n\napp.post(\"/contribute_dissent\", async (c) => {\n const user = c.get(\"user\");\n const state = await getAppState();\n\n if (!state.dissent_active_until || new Date() > new Date(state.dissent_active_until)) {\n return c.json({ error: \"The dissent period is not active.\" }, 400);\n }\n const { results: userCreditsRes } = await sqlite.execute({ sql: \"SELECT credits FROM users WHERE id = ?\", args: [user.id]});\n if (!userCreditsRes || (userCreditsRes[0] as any).credits < COSTS.CONTRIBUTE_CLEAR) return c.json({ error: \"Not enough credits.\" }, 402);\n\n\n const newState = await runTransaction(async (tx) => {\n await tx.execute({ sql: \"UPDATE users SET credits = credits - ? WHERE id = ?\", args: [COSTS.CONTRIBUTE_CLEAR, user.id] });\n const { results } = await tx.execute(\"SELECT value FROM app_state WHERE key = 'dissent_pot'\");\n const newPotValue = parseInt(results[0].value as string) + COSTS.CONTRIBUTE_CLEAR;\n await tx.execute({ sql: \"UPDATE app_state SET value = ? WHERE key = 'dissent_pot'\", args: [newPotValue.toString()] });\n return getAppState();\n });\n\n return c.json({ success: true, state: newState });\n});\n\nexport default app.fetch;\n\n// This HTML and JS is a simplified client to demonstrate the functionality.\nfunction generateHtml(sourceUrl: string) {\n return ` \nVibe Board Deluxe

Diff · v17