[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_152":153,"_154":155},"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":25,"_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":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",5,"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.ts","latestPath","fileId","db2c3594-33a3-11f1-ac5c-42b51c65c3df","name","fileType","script","content","/**\n * Val Town HTTP handler — personal screenshot → triple-LLM → TTS backend.\n *\n * Required environment variables (Val Town secrets / Deno.env):\n * ANTHROPIC_API_KEY — Anthropic API key\n * OPENAI_API_KEY — OpenAI API key (chat + TTS)\n * GOOGLE_API_KEY — Google AI (Gemini) API key\n * SHARED_SECRET — must match X-Key header on all requests\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst USER_PROMPT = \"Please solve fully and to the best of your ability.\";\n\ntype ActiveLlm = \"claude\" | \"openai\" | \"gemini\";\n\ntype ClaudeContentBlock =\n | { type: \"text\"; text: string }\n | {\n type: \"image\";\n source: { type: \"base64\"; media_type: string; data: string };\n };\n\ntype ClaudeMessage = {\n role: \"user\" | \"assistant\";\n content: string | ClaudeContentBlock[];\n};\n\ntype OpenAIContentPart =\n | { type: \"text\"; text: string }\n | { type: \"image_url\"; image_url: { url: string } };\n\ntype OpenAIMessage = {\n role: \"user\" | \"assistant\";\n content: string | OpenAIContentPart[];\n};\n\ntype GeminiPart =\n | { text: string }\n | { inline_data: { mime_type: string; data: string } };\n\ntype GeminiContent = {\n role: \"user\" | \"model\";\n parts: GeminiPart[];\n};\n\nfunction arrayBufferToBase64(buffer: ArrayBuffer): string {\n const bytes = new Uint8Array(buffer);\n let binary = \"\";\n for (let i = 0; i < bytes.byteLength; i++) {\n binary += String.fromCharCode(bytes[i]!);\n }\n return btoa(binary);\n}\n\nfunction base64ToUint8Array(b64: string): Uint8Array {\n const binary = atob(b64);\n const out = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) {\n out[i] = binary.charCodeAt(i);\n }\n return out;\n}\n\nfunction jsonParse(s: string, fallback: T): T {\n try {\n return JSON.parse(s) as T;\n } catch {\n return fallback;\n }\n}\n\nfunction ensureTable(): Promise {\n return sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n created_at INTEGER NOT NULL,\n updated_at INTEGER NOT NULL,\n status TEXT NOT NULL,\n active_llm TEXT NOT NULL,\n claude_messages TEXT NOT NULL,\n openai_messages TEXT NOT NULL,\n gemini_contents TEXT NOT NULL,\n claude_audio TEXT NOT NULL,\n openai_audio TEXT NOT NULL,\n gemini_audio TEXT NOT NULL\n )\n `);\n}\n\nfunction unauthorized(): Response {\n return new Response(JSON.stringify({ error: \"Unauthorized\" }), {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction badRequest(message: string): Response {\n return new Response(JSON.stringify({ error: message }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction notFound(): Response {\n return new Response(JSON.stringify({ error: \"Not found\" }), {\n status: 404,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction checkAuth(req: Request): boolean {\n const secret = Deno.env.get(\"SHARED_SECRET\");\n if (!secret) return false;\n return req.headers.get(\"X-Key\") === secret;\n}\n\nfunction latestClaudeAssistant(messages: ClaudeMessage[]): string {\n for (let i = messages.length - 1; i >= 0; i--) {\n const m = messages[i]!;\n if (m.role !== \"assistant\") continue;\n const c = m.content;\n if (typeof c === \"string\") return c;\n if (Array.isArray(c)) {\n for (const b of c) {\n if (b.type === \"text\" && \"text\" in b) return b.text;\n }\n }\n }\n return \"\";\n}\n\nfunction latestOpenAIAssistant(messages: OpenAIMessage[]): string {\n for (let i = messages.length - 1; i >= 0; i--) {\n const m = messages[i]!;\n if (m.role !== \"assistant\") continue;\n const c = m.content;\n if (typeof c === \"string\") return c;\n if (Array.isArray(c)) {\n for (const b of c) {\n if (b.type === \"text\" && \"text\" in b) return b.text;\n }\n }\n }\n return \"\";\n}\n\nfunction latestGeminiAssistant(contents: GeminiContent[]): string {\n for (let i = contents.length - 1; i >= 0; i--) {\n const m = contents[i]!;\n if (m.role !== \"model\") continue;\n for (const p of m.parts) {\n if (\"text\" in p && p.text) return p.text;\n }\n }\n return \"\";\n}\n\nfunction previewFromActive(\n active: ActiveLlm,\n claude: ClaudeMessage[],\n openai: OpenAIMessage[],\n gemini: GeminiContent[],\n): string {\n let text = \"\";\n if (active === \"claude\") text = latestClaudeAssistant(claude);\n else if (active === \"openai\") text = latestOpenAIAssistant(openai);\n else text = latestGeminiAssistant(gemini);\n return text.length <= 60 ? text : text.slice(0, 60);\n}\n\nasync function callClaude(\n messages: ClaudeMessage[],\n): Promise {\n try {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) return \"Error: ANTHROPIC_API_KEY is not set\";\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-sonnet-4-5\",\n max_tokens: 4096,\n messages,\n }),\n });\n const raw = await res.text();\n if (!res.ok) return `Error: ${res.status} ${raw}`;\n const data = JSON.parse(raw) as {\n content?: { type?: string; text?: string }[];\n };\n const text = data.content?.[0]?.text;\n if (typeof text !== \"string\" || !text.length) {\n return \"Error: empty or unexpected Claude response\";\n }\n return text;\n } catch (e) {\n return `Error: ${e instanceof Error ? e.message : String(e)}`;\n }\n}\n\nasync function callOpenAIChat(\n messages: OpenAIMessage[],\n): Promise {\n try {\n const key = Deno.env.get(\"OPENAI_API_KEY\");\n if (!key) return \"Error: OPENAI_API_KEY is not set\";\n const res = await fetch(\"https://api.openai.com/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"gpt-4o\",\n max_tokens: 4096,\n messages,\n }),\n });\n const raw = await res.text();\n if (!res.ok) return `Error: ${res.status} ${raw}`;\n const data = JSON.parse(raw) as {\n choices?: { message?: { content?: string } }[];\n };\n const text = data.choices?.[0]?.message?.content;\n if (typeof text !== \"string\" || !text.length) {\n return \"Error: empty or unexpected OpenAI response\";\n }\n return text;\n } catch (e) {\n return `Error: ${e instanceof Error ? e.message : String(e)}`;\n }\n}\n\nasync function callGemini(contents: GeminiContent[]): Promise {\n try {\n const key = Deno.env.get(\"GOOGLE_API_KEY\");\n if (!key) return \"Error: GOOGLE_API_KEY is not set\";\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/gemini-2.0-flash:generateContent?key=${\n encodeURIComponent(key)\n }`;\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ contents }),\n });\n const raw = await res.text();\n if (!res.ok) return `Error: ${res.status} ${raw}`;\n const data = JSON.parse(raw) as {\n candidates?: { content?: { parts?: { text?: string }[] } }[];\n };\n const text = data.candidates?.[0]?.content?.parts?.[0]?.text;\n if (typeof text !== \"string\" || !text.length) {\n return \"Error: empty or unexpected Gemini response\";\n }\n return text;\n } catch (e) {\n return `Error: ${e instanceof Error ? e.message : String(e)}`;\n }\n}\n\nasync function callOpenAITts(input: string): Promise {\n try {\n const key = Deno.env.get(\"OPENAI_API_KEY\");\n if (!key) return \"\";\n const res = await fetch(\"https://api.openai.com/v1/audio/speech\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"tts-1\",\n voice: \"alloy\",\n input,\n }),\n });\n if (!res.ok) {\n console.log(\"TTS HTTP error\", res.status, await res.text());\n return \"\";\n }\n const buf = await res.arrayBuffer();\n return arrayBufferToBase64(buf);\n } catch (e) {\n console.log(\"TTS exception\", e);\n return \"\";\n }\n}\n\ntype SessionRow = {\n id: string;\n created_at: number;\n updated_at: number;\n status: string;\n active_llm: string;\n claude_messages: string;\n openai_messages: string;\n gemini_contents: string;\n claude_audio: string;\n openai_audio: string;\n gemini_audio: string;\n};\n\nasync function loadSession(id: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM sessions WHERE id = ?`,\n args: [id],\n });\n const row = r.rows[0] as SessionRow | undefined;\n return row ?? null;\n}\n\nfunction normalizeActiveLlm(s: string): ActiveLlm {\n if (s === \"openai\" || s === \"gemini\") return s;\n return \"claude\";\n}\n\nexport default async function (req: Request): Promise {\n await ensureTable();\n\n if (!checkAuth(req)) {\n return unauthorized();\n }\n\n const url = new URL(req.url);\n let pathname = url.pathname;\n if (pathname.length > 1 && pathname.endsWith(\"/\")) {\n pathname = pathname.slice(0, -1);\n }\n\n // GET /sessions\n if (req.method === \"GET\" && pathname === \"/sessions\") {\n const r = await sqlite.execute({\n sql:\n `SELECT id, created_at, updated_at, status, active_llm, claude_messages, openai_messages, gemini_contents FROM sessions ORDER BY updated_at DESC LIMIT 20`,\n args: [],\n });\n const rows = r.rows as {\n id: string;\n created_at: number;\n updated_at: number;\n status: string;\n active_llm: string;\n claude_messages: string;\n openai_messages: string;\n gemini_contents: string;\n }[];\n const out = rows.map((row) => {\n const active = normalizeActiveLlm(row.active_llm);\n const claude = jsonParse(row.claude_messages, []);\n const openai = jsonParse(row.openai_messages, []);\n const gemini = jsonParse(row.gemini_contents, []);\n return {\n id: row.id,\n created_at: row.created_at,\n status: row.status,\n active_llm: active,\n preview: previewFromActive(active, claude, openai, gemini),\n };\n });\n return json(out);\n }\n\n // GET /session/:id\n const sessionMatch = pathname.match(/^\\/session\\/([^/]+)$/);\n if (req.method === \"GET\" && sessionMatch) {\n const id = sessionMatch[1]!;\n const row = await loadSession(id);\n if (!row) return notFound();\n const claude = jsonParse(row.claude_messages, []);\n const openai = jsonParse(row.openai_messages, []);\n const gemini = jsonParse(row.gemini_contents, []);\n const active = normalizeActiveLlm(row.active_llm);\n return json({\n id: row.id,\n created_at: row.created_at,\n updated_at: row.updated_at,\n status: row.status,\n active_llm: active,\n claude_text: latestClaudeAssistant(claude),\n openai_text: latestOpenAIAssistant(openai),\n gemini_text: latestGeminiAssistant(gemini),\n audio_url: `/audio/${id}`,\n });\n }\n\n // GET /audio/:id\n const audioMatch = pathname.match(/^\\/audio\\/([^/]+)$/);\n if (req.method === \"GET\" && audioMatch) {\n const id = audioMatch[1]!;\n const row = await loadSession(id);\n if (!row) return notFound();\n const active = normalizeActiveLlm(row.active_llm);\n let b64 = \"\";\n if (active === \"claude\") b64 = row.claude_audio;\n else if (active === \"openai\") b64 = row.openai_audio;\n else b64 = row.gemini_audio;\n if (!b64) {\n return new Response(null, {\n status: 204,\n headers: { \"Content-Type\": \"audio/mpeg\" },\n });\n }\n const bytes = base64ToUint8Array(b64);\n return new Response(bytes, {\n headers: { \"Content-Type\": \"audio/mpeg\" },\n });\n }\n\n // POST /switch-llm/:id\n const switchMatch = pathname.match(/^\\/switch-llm\\/([^/]+)$/);\n if (req.method === \"POST\" && switchMatch) {\n const id = switchMatch[1]!;\n const row = await loadSession(id);\n if (!row) return notFound();\n const order: ActiveLlm[] = [\"claude\", \"openai\", \"gemini\"];\n const cur = normalizeActiveLlm(row.active_llm);\n const idx = order.indexOf(cur);\n const next = order[(idx + 1) % 3]!;\n const now = Date.now();\n await sqlite.execute({\n sql: `UPDATE sessions SET active_llm = ?, updated_at = ? WHERE id = ?`,\n args: [next, now, id],\n });\n return json({ active_llm: next, audio_url: `/audio/${id}` });\n }\n\n // POST /capture\n if (req.method === \"POST\" && pathname === \"/capture\") {\n const bodyBuf = await req.arrayBuffer();\n if (!bodyBuf.byteLength) {\n return badRequest(\"Expected JPEG body\");\n }\n const imageB64 = arrayBufferToBase64(bodyBuf);\n const dataUrl = `data:image/jpeg;base64,${imageB64}`;\n\n const existingId = req.headers.get(\"X-Session-Id\");\n let id: string;\n let created_at: number;\n let claude: ClaudeMessage[];\n let openai: OpenAIMessage[];\n let gemini: GeminiContent[];\n\n if (existingId) {\n const row = await loadSession(existingId);\n if (!row) return notFound();\n id = row.id;\n created_at = row.created_at;\n claude = jsonParse(row.claude_messages, []);\n openai = jsonParse(row.openai_messages, []);\n gemini = jsonParse(row.gemini_contents, []);\n } else {\n id = crypto.randomUUID();\n created_at = Date.now();\n claude = [];\n openai = [];\n gemini = [];\n }\n\n const claudeUser: ClaudeMessage = {\n role: \"user\",\n content: [\n {\n type: \"image\",\n source: {\n type: \"base64\",\n media_type: \"image/jpeg\",\n data: imageB64,\n },\n },\n { type: \"text\", text: USER_PROMPT },\n ],\n };\n const openaiUser: OpenAIMessage = {\n role: \"user\",\n content: [\n { type: \"image_url\", image_url: { url: dataUrl } },\n { type: \"text\", text: USER_PROMPT },\n ],\n };\n const geminiUser: GeminiContent = {\n role: \"user\",\n parts: [\n { inline_data: { mime_type: \"image/jpeg\", data: imageB64 } },\n { text: USER_PROMPT },\n ],\n };\n\n claude.push(claudeUser);\n openai.push(openaiUser);\n gemini.push(geminiUser);\n\n const nowProc = Date.now();\n\n // Persist processing state (insert or update)\n if (existingId) {\n await sqlite.execute({\n sql:\n `UPDATE sessions SET updated_at = ?, status = ?, claude_messages = ?, openai_messages = ?, gemini_contents = ? WHERE id = ?`,\n args: [\n nowProc,\n \"processing\",\n JSON.stringify(claude),\n JSON.stringify(openai),\n JSON.stringify(gemini),\n id,\n ],\n });\n } else {\n await sqlite.execute({\n sql:\n `INSERT INTO sessions (id, created_at, updated_at, status, active_llm, claude_messages, openai_messages, gemini_contents, claude_audio, openai_audio, gemini_audio) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n created_at,\n nowProc,\n \"processing\",\n \"claude\",\n JSON.stringify(claude),\n JSON.stringify(openai),\n JSON.stringify(gemini),\n \"\",\n \"\",\n \"\",\n ],\n });\n }\n\n console.log(\"received capture\", {\n session_id: id,\n follow_up: !!existingId,\n });\n console.log(\"calling LLMs\");\n\n const llmSettled = await Promise.allSettled([\n callClaude(claude),\n callOpenAIChat(openai),\n callGemini(gemini),\n ]);\n\n const claudeText = llmSettled[0]!.status === \"fulfilled\"\n ? llmSettled[0].value\n : `Error: ${String(llmSettled[0]!.reason)}`;\n const openaiText = llmSettled[1]!.status === \"fulfilled\"\n ? llmSettled[1].value\n : `Error: ${String(llmSettled[1]!.reason)}`;\n const geminiText = llmSettled[2]!.status === \"fulfilled\"\n ? llmSettled[2].value\n : `Error: ${String(llmSettled[2]!.reason)}`;\n\n claude.push({ role: \"assistant\", content: claudeText });\n openai.push({ role: \"assistant\", content: openaiText });\n gemini.push({\n role: \"model\",\n parts: [{ text: geminiText }],\n });\n\n console.log(\"LLMs done\");\n\n await sqlite.execute({\n sql:\n `UPDATE sessions SET updated_at = ?, claude_messages = ?, openai_messages = ?, gemini_contents = ? WHERE id = ?`,\n args: [\n Date.now(),\n JSON.stringify(claude),\n JSON.stringify(openai),\n JSON.stringify(gemini),\n id,\n ],\n });\n\n console.log(\"calling TTS\");\n\n const ttsSettled = await Promise.allSettled([\n callOpenAITts(claudeText),\n callOpenAITts(openaiText),\n callOpenAITts(geminiText),\n ]);\n\n const claudeAudio = ttsSettled[0]!.status === \"fulfilled\"\n ? ttsSettled[0].value\n : \"\";\n const openaiAudio = ttsSettled[1]!.status === \"fulfilled\"\n ? ttsSettled[1].value\n : \"\";\n const geminiAudio = ttsSettled[2]!.status === \"fulfilled\"\n ? ttsSettled[2].value\n : \"\";\n\n console.log(\"TTS done\");\n\n const readyTime = Date.now();\n await sqlite.execute({\n sql:\n `UPDATE sessions SET updated_at = ?, status = ?, claude_audio = ?, openai_audio = ?, gemini_audio = ? WHERE id = ?`,\n args: [\n readyTime,\n \"ready\",\n claudeAudio,\n openaiAudio,\n geminiAudio,\n id,\n ],\n });\n\n console.log(\"ready\", { session_id: id });\n\n return json({ session_id: id, status: \"ready\" });\n }\n\n return new Response(\"Not found\", { status: 404 });\n}","/**\n * Belt backend — paste into a Val Town HTTP val.\n * Secrets: ANTHROPIC_API_KEY, OPENAI_API_KEY, GOOGLE_API_KEY,\n * ELEVENLABS_API_KEY, SHARED_SECRET\n *\n * export default matches Val Town’s HTTP trigger shape.\n */\nimport sqlite from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n/** Val Town / Deno — env secrets */\ndeclare const Deno: { env: { get(key: string): string | undefined } };\n\n/**\n * Val Town exposes secrets via the val’s Environment Variables sidebar.\n * Docs list both `Deno.env.get` and `process.env`; some runtimes only populate one.\n */\nfunction getEnv(name: string): string | undefined {\n const fromDeno = Deno.env.get(name);\n if (fromDeno != null && String(fromDeno).length > 0) return String(fromDeno);\n\n const proc =\n (globalThis as unknown as {\n process?: { env?: Record };\n })\n .process;\n const fromProcess = proc?.env?.[name];\n if (typeof fromProcess === \"string\" && fromProcess.length > 0) {\n return fromProcess;\n }\n\n return undefined;\n}\n\n// --- Tunables (user-facing text to all models on every image) ---\n\nexport const USER_PROMPT =\n \"Describe the question / problem / task you see clearly. Then solve the task to the best of your ability, in a way that would get full points from the grader. Wehn writing the code, formulas, induction, write the solution in fully english senteces, telling me what to type in, No Markdown, no LaTeX, no symbols. Say math in words: for example, 'd underscore k', 'n squared', 'big O of n log n', 'gamma', 'sigma'. If there is code, mathematical calculations, drawing or anything still have them. if anything needs to be drawn explain in detail. Some problems require analysis of the code, add that as well.\";\n\n/** Flagship / max-capability IDs (vision-capable). */\nconst MODEL_CLAUDE = \"claude-haiku-4-5\";\nconst MODEL_OPENAI = \"gpt-5-nano\";\nconst MODEL_GEMINI = \"gemini-2.5-flash-lite\";\nconst MODEL_GEMINI_FALLBACKS = [\"gemini-2.5-flash\"] as const;\nconst CLAUDE_IMAGE_MAX_BYTES = 5 * 1024 * 1024;\nconst CLAUDE_TOO_LARGE_PREFIX = \"__CLAUDE_IMAGE_TOO_LARGE__:\";\n\n/** Provider output ceilings (APIs require explicit caps; set to each model’s documented maximum). */\nconst CLAUDE_MAX_OUTPUT_TOKENS = 128_000;\nconst GEMINI_MAX_OUTPUT_TOKENS = 65_536;\n\ntype LLMKey = \"claude\" | \"openai\" | \"gemini\";\n\ntype UserMsg = {\n role: \"user\";\n text: string;\n image_blob_key: string;\n image_mime: string;\n};\ntype AsstMsg = { role: \"assistant\"; text: string };\ntype Msg = UserMsg | AsstMsg;\n\ntype SessionRow = {\n id: string;\n created_at: number;\n updated_at: number;\n active_llm: LLMKey;\n history_claude: string;\n history_openai: string;\n history_gemini: string;\n audio_claude: string | null;\n audio_openai: string | null;\n audio_gemini: string | null;\n};\n\nfunction jsonResponse(\n data: unknown,\n status = 200,\n extraHeaders: HeadersInit = {},\n): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n ...extraHeaders,\n },\n });\n}\n\nfunction bad(msg: string, status = 400): Response {\n return jsonResponse({ error: msg }, status);\n}\n\nfunction unauthorized(): Response {\n return new Response(\"Unauthorized\", { status: 401 });\n}\n\nfunction isUuid(id: string): boolean {\n return /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i\n .test(\n id,\n );\n}\n\nasync function ensureSchema(): Promise {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n created_at INTEGER NOT NULL,\n updated_at INTEGER NOT NULL,\n active_llm TEXT NOT NULL DEFAULT 'claude',\n history_claude TEXT NOT NULL DEFAULT '[]',\n history_openai TEXT NOT NULL DEFAULT '[]',\n history_gemini TEXT NOT NULL DEFAULT '[]',\n audio_claude TEXT,\n audio_openai TEXT,\n audio_gemini TEXT\n )\n `);\n}\n\nfunction parseHist(s: string): Msg[] {\n try {\n const j = JSON.parse(s) as unknown;\n if (!Array.isArray(j)) return [];\n return j as Msg[];\n } catch {\n return [];\n }\n}\n\nfunction getAnthropicKey(): string | undefined {\n return getEnv(\"ANTHROPIC_API_KEY\");\n}\nfunction getOpenAIKey(): string | undefined {\n return getEnv(\"OPENAI_API_KEY\");\n}\nfunction getGoogleKey(): string | undefined {\n return getEnv(\"GOOGLE_API_KEY\");\n}\nfunction getElevenLabsKey(): string | undefined {\n return getEnv(\"ELEVENLABS_API_KEY\");\n}\nfunction getElevenLabsVoiceId(): string {\n // Default is a clear, neutral voice; override via ELEVENLABS_VOICE_ID.\n return getEnv(\"ELEVENLABS_VOICE_ID\") ?? \"EXAVITQu4vr4xnSDxMaL\";\n}\nfunction parseBoolEnv(name: string, fallback: boolean): boolean {\n const raw = getEnv(name);\n if (!raw) return fallback;\n const v = raw.trim().toLowerCase();\n if (v === \"1\" || v === \"true\" || v === \"yes\" || v === \"on\") return true;\n if (v === \"0\" || v === \"false\" || v === \"no\" || v === \"off\") return false;\n return fallback;\n}\nfunction parseNumberEnv(\n name: string,\n fallback: number,\n min: number,\n max: number,\n): number {\n const raw = getEnv(name);\n if (!raw) return fallback;\n const n = Number(raw);\n if (!Number.isFinite(n)) return fallback;\n return Math.max(min, Math.min(max, n));\n}\nfunction getElevenLabsVoiceSettings(): {\n stability: number;\n similarity_boost: number;\n style: number;\n use_speaker_boost: boolean;\n} {\n return {\n // More stable, less jittery default delivery.\n stability: parseNumberEnv(\"ELEVENLABS_STABILITY\", 0.82, 0, 1),\n similarity_boost: parseNumberEnv(\"ELEVENLABS_SIMILARITY_BOOST\", 0.75, 0, 1),\n style: parseNumberEnv(\"ELEVENLABS_STYLE\", 0.1, 0, 1),\n use_speaker_boost: parseBoolEnv(\"ELEVENLABS_USE_SPEAKER_BOOST\", true),\n };\n}\nfunction getElevenLabsSpeed(): number {\n // Slightly slower than real-time for clearer listening.\n return parseNumberEnv(\"ELEVENLABS_SPEED\", 0.86, 0.7, 1.2);\n}\nfunction getSharedSecret(): string | undefined {\n return getEnv(\"SHARED_SECRET\");\n}\n\n/** Returns a Response if the request is not allowed; `null` if OK. */\nfunction requireAuth(req: Request): Response | null {\n const want = getSharedSecret();\n if (!want) return secretNotConfigured();\n if (req.headers.get(\"X-Key\") !== want) return unauthorized();\n return null;\n}\n\n/** Use when auth is required but SHARED_SECRET was never set in the val’s env. */\nfunction secretNotConfigured(): Response {\n return jsonResponse(\n {\n error:\n \"SHARED_SECRET is not set. Open this val → Environment Variables (sidebar) and add SHARED_SECRET, then redeploy or save.\",\n },\n 503,\n );\n}\n\n/** Chunked base64 — avoids call stack limits on large screenshots. */\nfunction bytesToBase64(u8: Uint8Array): string {\n const chunk = 0x8000;\n const parts: string[] = [];\n for (let i = 0; i < u8.length; i += chunk) {\n parts.push(\n String.fromCharCode.apply(\n null,\n u8.subarray(i, i + chunk) as unknown as number[],\n ),\n );\n }\n return btoa(parts.join(\"\"));\n}\n\nasync function blobToBase64(\n key: string,\n mimeHint?: string,\n): Promise<{ b64: string; mime: string; bytes: number }> {\n const body = await blob.get(key);\n const ab = await body.arrayBuffer();\n const u8 = new Uint8Array(ab);\n const mime = mimeHint && mimeHint.startsWith(\"image/\")\n ? mimeHint\n : body.type && body.type !== \"application/octet-stream\"\n ? body.type\n : \"image/png\";\n return { b64: bytesToBase64(u8), mime, bytes: u8.byteLength };\n}\n\nasync function callClaude(\n messages: Msg[],\n apiKey: string,\n): Promise {\n const anthropicMsgs: Array<{ role: \"user\" | \"assistant\"; content: unknown }> =\n [];\n for (const m of messages) {\n if (m.role === \"user\") {\n const { b64, mime, bytes } = await blobToBase64(\n m.image_blob_key,\n m.image_mime,\n );\n if (bytes > CLAUDE_IMAGE_MAX_BYTES) {\n return `${CLAUDE_TOO_LARGE_PREFIX}${bytes}`;\n }\n const media = mime === \"image/jpeg\" || mime === \"image/jpg\"\n ? \"image/jpeg\"\n : mime === \"image/webp\"\n ? \"image/webp\"\n : \"image/png\";\n anthropicMsgs.push({\n role: \"user\",\n content: [\n { type: \"text\", text: m.text },\n {\n type: \"image\",\n source: { type: \"base64\", media_type: media, data: b64 },\n },\n ],\n });\n } else {\n anthropicMsgs.push({\n role: \"assistant\",\n content: [{ type: \"text\", text: m.text }],\n });\n }\n }\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": apiKey,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL_CLAUDE,\n max_tokens: CLAUDE_MAX_OUTPUT_TOKENS,\n thinking: { type: \"adaptive\" },\n output_config: { effort: \"max\" },\n messages: anthropicMsgs,\n }),\n });\n const raw = await r.text();\n if (!r.ok) return `[claude error] ${r.status}: ${raw.slice(0, 400)}`;\n try {\n const data = JSON.parse(raw) as {\n content?: Array<{ type: string; text?: string }>;\n };\n const parts: string[] = [];\n for (const block of data.content ?? []) {\n if (block?.type === \"text\" && typeof block.text === \"string\") {\n parts.push(block.text);\n }\n }\n if (parts.length > 0) return parts.join(\"\");\n return `[claude unexpected] ${raw.slice(0, 400)}`;\n } catch {\n return `[claude parse] ${raw.slice(0, 400)}`;\n }\n}\n\nfunction extractOpenAIResponsesText(data: unknown): string | null {\n if (typeof data !== \"object\" || data === null) return null;\n const d = data as Record;\n if (typeof d.output_text === \"string\" && d.output_text.length > 0) {\n return d.output_text;\n }\n const out = d.output;\n if (!Array.isArray(out)) return null;\n const chunks: string[] = [];\n for (const item of out) {\n if (typeof item !== \"object\" || item === null) continue;\n const it = item as Record;\n if (it.type === \"message\" && Array.isArray(it.content)) {\n for (const part of it.content) {\n if (typeof part !== \"object\" || part === null) continue;\n const p = part as Record;\n if (p.type === \"output_text\" && typeof p.text === \"string\") {\n chunks.push(p.text);\n }\n }\n }\n }\n return chunks.length > 0 ? chunks.join(\"\") : null;\n}\n\nasync function callOpenAI(messages: Msg[], apiKey: string): Promise {\n type InputPart =\n | { type: \"input_text\"; text: string }\n | { type: \"input_image\"; image_url: string; detail?: string };\n const input: Array<{\n role: \"user\" | \"assistant\";\n content: string | InputPart[];\n }> = [];\n for (const m of messages) {\n if (m.role === \"user\") {\n const { b64, mime } = await blobToBase64(m.image_blob_key, m.image_mime);\n const mt = mime === \"image/jpeg\" || mime === \"image/jpg\"\n ? \"image/jpeg\"\n : mime === \"image/webp\"\n ? \"image/webp\"\n : \"image/png\";\n input.push({\n role: \"user\",\n content: [\n { type: \"input_text\", text: m.text },\n {\n type: \"input_image\",\n image_url: `data:${mt};base64,${b64}`,\n detail: \"high\",\n },\n ],\n });\n } else {\n input.push({ role: \"assistant\", content: m.text });\n }\n }\n const r = await fetch(\"https://api.openai.com/v1/responses\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL_OPENAI,\n reasoning: { effort: \"xhigh\" },\n input,\n }),\n });\n const raw = await r.text();\n if (!r.ok) return `[openai error] ${r.status}: ${raw.slice(0, 400)}`;\n try {\n const data = JSON.parse(raw) as unknown;\n const t = extractOpenAIResponsesText(data);\n if (typeof t === \"string\" && t.length > 0) return t;\n return `[openai unexpected] ${raw.slice(0, 400)}`;\n } catch {\n return `[openai parse] ${raw.slice(0, 400)}`;\n }\n}\n\nasync function callGemini(messages: Msg[], apiKey: string): Promise {\n type GPart = {\n text?: string;\n inline_data?: { mime_type: string; data: string };\n };\n type GContent = { role: \"user\" | \"model\"; parts: GPart[] };\n const contents: GContent[] = [];\n for (const m of messages) {\n if (m.role === \"user\") {\n const { b64, mime } = await blobToBase64(m.image_blob_key, m.image_mime);\n const mt = mime === \"image/jpeg\" || mime === \"image/jpg\"\n ? \"image/jpeg\"\n : mime === \"image/webp\"\n ? \"image/webp\"\n : \"image/png\";\n contents.push({\n role: \"user\",\n parts: [\n { text: m.text },\n { inline_data: { mime_type: mt, data: b64 } },\n ],\n });\n } else {\n contents.push({\n role: \"model\",\n parts: [{ text: m.text }],\n });\n }\n }\n const models = [MODEL_GEMINI, ...MODEL_GEMINI_FALLBACKS];\n let lastErr = \"[gemini error] unknown\";\n\n for (let i = 0; i < models.length; i++) {\n const model = models[i];\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/${model}:generateContent?key=${\n encodeURIComponent(apiKey)\n }`;\n const r = await fetch(url, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n contents,\n generationConfig: { maxOutputTokens: GEMINI_MAX_OUTPUT_TOKENS },\n }),\n });\n const raw = await r.text();\n if (r.ok) {\n try {\n const data = JSON.parse(raw) as {\n candidates?: Array<\n { content?: { parts?: Array<{ text?: string }> } }\n >;\n };\n const parts = data.candidates?.[0]?.content?.parts;\n const text = parts?.map((p) => p.text ?? \"\").join(\"\") ?? \"\";\n if (text) return text;\n lastErr = `[gemini unexpected ${model}] ${raw.slice(0, 400)}`;\n } catch {\n lastErr = `[gemini parse ${model}] ${raw.slice(0, 400)}`;\n }\n continue;\n }\n\n lastErr = `[gemini error ${model}] ${r.status}: ${raw.slice(0, 400)}`;\n const shouldFallback = i < models.length - 1 &&\n isGeminiOverloadedOrUnavailable(r.status, raw);\n if (!shouldFallback) return lastErr;\n }\n\n return lastErr;\n}\n\nfunction isGeminiOverloadedOrUnavailable(status: number, raw: string): boolean {\n if (status === 429 || status === 503) return true;\n const text = raw.toLowerCase();\n return (\n text.includes(\"overloaded\") ||\n text.includes(\"overused\") ||\n text.includes(\"unavailable\") ||\n text.includes(\"resource exhausted\") ||\n text.includes(\"quota\") ||\n text.includes(\"temporarily\")\n );\n}\n\nfunction bytesToMbLabel(bytes: number): string {\n return `${(bytes / (1024 * 1024)).toFixed(2)}MB`;\n}\n\nasync function getSessionOrdinal(\n sessionId: string,\n createdAt: number,\n): Promise {\n const res = await sqlite.execute({\n sql: `SELECT COUNT(*) AS c\n FROM sessions\n WHERE created_at < ?\n OR (created_at = ? AND id < ?)`,\n args: [createdAt, createdAt, sessionId],\n });\n const row = res.rows?.[0] as { c?: number } | undefined;\n const before = Number(row?.c ?? 0);\n return before + 1;\n}\n\nfunction withSpeakerPrefix(\n sessionOrdinal: number,\n model: LLMKey,\n text: string,\n): string {\n const modelLabel = model === \"claude\"\n ? \"Claude\"\n : model === \"openai\"\n ? \"OpenAI\"\n : \"Gemini\";\n return `Session ${sessionOrdinal}. ${modelLabel} speaking. ${text}`;\n}\n\nasync function synthesizeElevenLabs(\n text: string,\n apiKey: string,\n voiceId: string,\n): Promise {\n const normalized = normalizeForTts(text);\n if (!normalized) throw new Error(\"empty tts text\");\n const voiceSettings = getElevenLabsVoiceSettings();\n const speed = getElevenLabsSpeed();\n const r = await fetch(\n `https://api.elevenlabs.io/v1/text-to-speech/${\n encodeURIComponent(voiceId)\n }`,\n {\n method: \"POST\",\n headers: {\n \"xi-api-key\": apiKey,\n \"content-type\": \"application/json\",\n accept: \"audio/mpeg\",\n },\n body: JSON.stringify({\n text: normalized,\n model_id: \"eleven_multilingual_v2\",\n voice_settings: voiceSettings,\n speed,\n }),\n },\n );\n if (!r.ok) {\n const raw = await r.text();\n throw new Error(`elevenlabs ${r.status}: ${raw.slice(0, 300)}`);\n }\n return new Uint8Array(await r.arrayBuffer());\n}\n\nfunction normalizeForTts(input: string): string {\n if (!input) return \"\";\n\n // Fix common UTF-8 mojibake sequences (often from smart punctuation).\n let s = input\n .replace(/ΓÇ£/g, '\"')\n .replace(/ΓÇ¥/g, '\"')\n .replace(/ΓÇÖ/g, \"'\")\n .replace(/ΓÇô/g, \"-\")\n .replace(/ΓÇö/g, \"-\")\n .replace(/ΓÇª/g, \"...\")\n .replace(/â€œ/g, '\"')\n .replace(/â€�/g, '\"')\n .replace(/â€˜/g, \"'\")\n .replace(/â€™/g, \"'\")\n .replace(/â€“/g, \"-\")\n .replace(/â€”/g, \"-\")\n .replace(/â€¦/g, \"...\");\n\n // Handle JSON-escaped newlines/tabs that sometimes leak into model output.\n s = s\n .replace(/\\\\r\\\\n/g, \". \")\n .replace(/\\\\n+/g, \". \")\n .replace(/\\\\t+/g, \" \");\n\n // Convert real line breaks and markdown separators into sentence pauses.\n s = s\n .replace(/\\r\\n/g, \"\\n\")\n .replace(/\\n{2,}/g, \". \")\n .replace(/\\n+/g, \". \")\n .replace(/^\\s*[-*]\\s+/gm, \"\")\n .replace(/^\\s*\\d+[.)]\\s+/gm, \"\");\n\n // Reduce common markdown noise that reads poorly in TTS.\n s = s\n .replace(/`{1,3}/g, \"\")\n .replace(/[*_#~]/g, \"\")\n .replace(/\\[(.*?)\\]\$(.*?)\$/g, \"$1\")\n .replace(/\$(https?:\\/\\/[^\\s)]+)\$/g, \"$1\");\n\n // Make grouping symbols explicit so TTS reads math/expressions correctly.\n s = s\n .replace(/\$/g, \" open parenthesis \")\n .replace(/\$/g, \" close parenthesis \")\n .replace(/\\[/g, \" open bracket \")\n .replace(/\\]/g, \" close bracket \")\n .replace(/\\{/g, \" open brace \")\n .replace(/\\}/g, \" close brace \");\n\n // Improve spoken pacing around punctuation and normalize whitespace.\n s = s\n .replace(/\\s*([,;:!?])\\s*/g, \"$1 \")\n .replace(/\\s*\\.\\s*/g, \". \")\n .replace(/\\s*-\\s*/g, \" - \")\n .replace(/\\s+/g, \" \")\n .trim();\n\n // Prevent awkward repeated pauses.\n s = s\n .replace(/([.!?]){2,}/g, \"$1\")\n .replace(/([,;:]){2,}/g, \"$1\")\n .replace(/(\\.\\s+){2,}/g, \". \");\n\n return s;\n}\n\nfunction latestAssistant(msgs: Msg[]): string {\n for (let i = msgs.length - 1; i >= 0; i--) {\n const m = msgs[i];\n if (m.role === \"assistant\") return m.text;\n }\n return \"\";\n}\n\nfunction previewFromSession(\n hc: string,\n ho: string,\n hg: string,\n): string {\n const a = latestAssistant(parseHist(hc));\n const b = latestAssistant(parseHist(ho));\n const c = latestAssistant(parseHist(hg));\n const pick = [a, b, c].find((s) => s.length > 0) ?? \"\";\n return pick.length > 160 ? pick.slice(0, 157) + \"…\" : pick;\n}\n\nfunction nextLlm(current: LLMKey): LLMKey {\n const order: LLMKey[] = [\"claude\", \"openai\", \"gemini\"];\n const i = order.indexOf(current);\n return order[(i + 1) % order.length];\n}\n\nfunction sessionPayload(\n row: SessionRow,\n origin: string,\n): Record {\n const hc = parseHist(row.history_claude);\n const ho = parseHist(row.history_openai);\n const hg = parseHist(row.history_gemini);\n const audioByLlm: Record = {\n claude: row.audio_claude,\n openai: row.audio_openai,\n gemini: row.audio_gemini,\n };\n const activeAudioBlob = audioByLlm[row.active_llm];\n return {\n id: row.id,\n created_at: row.created_at,\n updated_at: row.updated_at,\n active_llm: row.active_llm,\n latest: {\n claude: latestAssistant(hc),\n openai: latestAssistant(ho),\n gemini: latestAssistant(hg),\n },\n histories: {\n claude: hc,\n openai: ho,\n gemini: hg,\n },\n audio_url: activeAudioBlob ? `${origin}/audio/${row.id}` : null,\n };\n}\n\nexport default async function handler(req: Request): Promise {\n await ensureSchema();\n\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/$/, \"\") || \"/\";\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-Key, X-Session-Id\",\n \"Access-Control-Max-Age\": \"86400\",\n },\n });\n }\n\n const isCapturePost = req.method === \"POST\" && path === \"/capture\";\n if (!isCapturePost) {\n const authErr = requireAuth(req);\n if (authErr) return authErr;\n }\n\n // --- POST /admin/clear-sessions ---\n if (req.method === \"POST\" && path === \"/admin/clear-sessions\") {\n await sqlite.execute({ sql: \"DELETE FROM sessions\" });\n return jsonResponse({ ok: true, cleared: true });\n }\n\n // --- GET /sessions ---\n if (req.method === \"GET\" && path === \"/sessions\") {\n const res = await sqlite.execute({\n sql:\n `SELECT id, created_at, updated_at, history_claude, history_openai, history_gemini\n FROM sessions ORDER BY updated_at DESC LIMIT 20`,\n });\n const rows = (res.rows ?? []) as Array<{\n id: string;\n created_at: number;\n updated_at: number;\n history_claude: string;\n history_openai: string;\n history_gemini: string;\n }>;\n const sessions = rows.map((r) => ({\n id: r.id,\n created_at: r.created_at,\n updated_at: r.updated_at,\n preview: previewFromSession(\n r.history_claude,\n r.history_openai,\n r.history_gemini,\n ),\n }));\n return jsonResponse({ sessions });\n }\n\n // --- GET /session/:id ---\n const sessionMatch = path.match(/^\\/session\\/([^/]+)$/);\n if (req.method === \"GET\" && sessionMatch) {\n const id = sessionMatch[1];\n if (!isUuid(id)) return bad(\"Invalid session id\");\n const res = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE id = ?\",\n args: [id],\n });\n const row = res.rows?.[0] as SessionRow | undefined;\n if (!row) return bad(\"Not found\", 404);\n return jsonResponse(sessionPayload(row, url.origin));\n }\n\n // --- GET /audio/:id ---\n const audioMatch = path.match(/^\\/audio\\/([^/]+)$/);\n if (req.method === \"GET\" && audioMatch) {\n const id = audioMatch[1];\n if (!isUuid(id)) return bad(\"Invalid session id\");\n const res = await sqlite.execute({\n sql:\n \"SELECT active_llm, audio_claude, audio_openai, audio_gemini FROM sessions WHERE id = ?\",\n args: [id],\n });\n const row = res.rows?.[0] as {\n active_llm: LLMKey;\n audio_claude: string | null;\n audio_openai: string | null;\n audio_gemini: string | null;\n } | undefined;\n if (!row) return bad(\"Not found\", 404);\n const keyMap: Record = {\n claude: row.audio_claude,\n openai: row.audio_openai,\n gemini: row.audio_gemini,\n };\n const blobKey = keyMap[row.active_llm];\n if (!blobKey) return bad(\"No audio yet\", 404);\n try {\n const b = await blob.get(blobKey);\n const buf = await b.arrayBuffer();\n return new Response(buf, {\n headers: {\n \"Content-Type\": \"audio/mpeg\",\n \"Cache-Control\": \"private, max-age=60\",\n },\n });\n } catch {\n return bad(\"Audio missing\", 404);\n }\n }\n\n // --- POST /switch-llm/:id ---\n const switchMatch = path.match(/^\\/switch-llm\\/([^/]+)$/);\n if (req.method === \"POST\" && switchMatch) {\n const id = switchMatch[1];\n if (!isUuid(id)) return bad(\"Invalid session id\");\n const cur = await sqlite.execute({\n sql: \"SELECT active_llm FROM sessions WHERE id = ?\",\n args: [id],\n });\n const active = cur.rows?.[0] as { active_llm: LLMKey } | undefined;\n if (!active) return bad(\"Not found\", 404);\n const n = nextLlm(active.active_llm);\n const now = Date.now();\n await sqlite.execute({\n sql: \"UPDATE sessions SET active_llm = ?, updated_at = ? WHERE id = ?\",\n args: [n, now, id],\n });\n const full = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE id = ?\",\n args: [id],\n });\n const row = full.rows?.[0] as SessionRow;\n const originBase = url.origin;\n return jsonResponse({\n ok: true,\n active_llm: n,\n ...sessionPayload(row, originBase),\n });\n }\n\n // --- POST /capture ---\n if (req.method === \"POST\" && path === \"/capture\") {\n const authErr = requireAuth(req);\n if (authErr) return authErr;\n\n const anth = getAnthropicKey();\n const oai = getOpenAIKey();\n const goog = getGoogleKey();\n const eleven = getElevenLabsKey();\n const elevenVoiceId = getElevenLabsVoiceId();\n if (!anth || !oai || !goog || !eleven) {\n return bad(\"Server missing API keys\", 500);\n }\n\n const ct = req.headers.get(\"Content-Type\") ?? \"image/png\";\n const mime = ct.split(\";\")[0].trim().toLowerCase();\n if (!mime.startsWith(\"image/\")) {\n return bad(\"Content-Type must be an image/*\");\n }\n\n const buf = new Uint8Array(await req.arrayBuffer());\n if (buf.length === 0) return bad(\"Empty body\");\n if (buf.length > 15 * 1024 * 1024) {\n return bad(\"Image too large (max ~15MB)\");\n }\n\n const headerSession = req.headers.get(\"X-Session-Id\")?.trim();\n let sessionId: string;\n let imageIndex: number;\n let hc: Msg[];\n let ho: Msg[];\n let hg: Msg[];\n let active_llm: LLMKey;\n let created_at: number;\n\n const now = Date.now();\n\n if (headerSession && isUuid(headerSession)) {\n const ex = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE id = ?\",\n args: [headerSession],\n });\n const existing = ex.rows?.[0] as SessionRow | undefined;\n if (!existing) return bad(\"Unknown session id\", 404);\n sessionId = existing.id;\n created_at = existing.created_at;\n active_llm = existing.active_llm;\n hc = parseHist(existing.history_claude);\n ho = parseHist(existing.history_openai);\n hg = parseHist(existing.history_gemini);\n imageIndex = hc.filter((m) => m.role === \"user\").length;\n } else {\n sessionId = crypto.randomUUID();\n created_at = now;\n active_llm = \"claude\";\n hc = [];\n ho = [];\n hg = [];\n imageIndex = 0;\n }\n\n const imageMime = mime === \"image/jpg\" ? \"image/jpeg\" : mime;\n const ext = imageMime === \"image/jpeg\"\n ? \"jpg\"\n : imageMime === \"image/webp\"\n ? \"webp\"\n : \"png\";\n const blobKey = `belt/${sessionId}/img/${imageIndex}.${ext}`;\n await blob.set(blobKey, buf);\n\n const userPart: UserMsg = {\n role: \"user\",\n text: USER_PROMPT,\n image_blob_key: blobKey,\n image_mime: imageMime,\n };\n hc.push(userPart);\n ho.push({ ...userPart });\n hg.push({ ...userPart });\n\n const [rc, ro, rg] = await Promise.allSettled([\n callClaude(hc, anth),\n callOpenAI(ho, oai),\n callGemini(hg, goog),\n ]);\n\n const to = ro.status === \"fulfilled\"\n ? ro.value\n : `[openai error] ${String(ro.reason).slice(0, 300)}`;\n const tg = rg.status === \"fulfilled\"\n ? rg.value\n : `[gemini error] ${String(rg.reason).slice(0, 300)}`;\n let tc = rc.status === \"fulfilled\"\n ? rc.value\n : `[claude error] ${String(rc.reason).slice(0, 300)}`;\n if (tc.startsWith(CLAUDE_TOO_LARGE_PREFIX)) {\n const rawBytes = Number(tc.slice(CLAUDE_TOO_LARGE_PREFIX.length));\n const sizeLabel = Number.isFinite(rawBytes)\n ? bytesToMbLabel(rawBytes)\n : \"unknown size\";\n const fallback = to.startsWith(\"[openai error]\") ? tg : to;\n tc =\n `[claude fallback] image ${sizeLabel} exceeds Claude 5MB image limit. Using alternate model output. ${fallback}`;\n }\n\n hc.push({ role: \"assistant\", text: tc });\n ho.push({ role: \"assistant\", text: to });\n hg.push({ role: \"assistant\", text: tg });\n\n const sessionOrdinal = await getSessionOrdinal(sessionId, created_at);\n const spokenClaude = withSpeakerPrefix(sessionOrdinal, \"claude\", tc);\n const spokenOpenAI = withSpeakerPrefix(sessionOrdinal, \"openai\", to);\n const spokenGemini = withSpeakerPrefix(sessionOrdinal, \"gemini\", tg);\n\n let audioClaude: string | null = null;\n let audioOpenAI: string | null = null;\n let audioGemini: string | null = null;\n const [ac, ao, ag] = await Promise.allSettled([\n synthesizeElevenLabs(spokenClaude, eleven, elevenVoiceId),\n synthesizeElevenLabs(spokenOpenAI, eleven, elevenVoiceId),\n synthesizeElevenLabs(spokenGemini, eleven, elevenVoiceId),\n ]);\n if (ac.status === \"fulfilled\") {\n const k = `belt/${sessionId}/audio/claude-${now}.mp3`;\n await blob.set(k, ac.value);\n audioClaude = k;\n }\n if (ao.status === \"fulfilled\") {\n const k = `belt/${sessionId}/audio/openai-${now}.mp3`;\n await blob.set(k, ao.value);\n audioOpenAI = k;\n }\n if (ag.status === \"fulfilled\") {\n const k = `belt/${sessionId}/audio/gemini-${now}.mp3`;\n await blob.set(k, ag.value);\n audioGemini = k;\n }\n\n const row: SessionRow = {\n id: sessionId,\n created_at,\n updated_at: now,\n active_llm,\n history_claude: JSON.stringify(hc),\n history_openai: JSON.stringify(ho),\n history_gemini: JSON.stringify(hg),\n audio_claude: audioClaude,\n audio_openai: audioOpenAI,\n audio_gemini: audioGemini,\n };\n\n if (headerSession && isUuid(headerSession)) {\n await sqlite.execute({\n sql: `UPDATE sessions SET\n updated_at = ?, history_claude = ?, history_openai = ?, history_gemini = ?,\n audio_claude = ?, audio_openai = ?, audio_gemini = ?\n WHERE id = ?`,\n args: [\n now,\n row.history_claude,\n row.history_openai,\n row.history_gemini,\n row.audio_claude,\n row.audio_openai,\n row.audio_gemini,\n sessionId,\n ],\n });\n } else {\n await sqlite.execute({\n sql: `INSERT INTO sessions (\n id, created_at, updated_at, active_llm,\n history_claude, history_openai, history_gemini,\n audio_claude, audio_openai, audio_gemini\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n row.id,\n row.created_at,\n row.updated_at,\n row.active_llm,\n row.history_claude,\n row.history_openai,\n row.history_gemini,\n row.audio_claude,\n row.audio_openai,\n row.audio_gemini,\n ],\n });\n }\n\n const originBase = url.origin;\n return jsonResponse({\n ok: true,\n session_id: sessionId,\n ...sessionPayload(row, originBase),\n });\n }\n\n if (req.method === \"GET\" && path === \"/\") {\n return new Response(\n \"Belt backend OK. POST /capture with image; see README.\",\n {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n\n return bad(\"Not found\", 404);\n}","createdAt",["D",1778709775499],"branchVersion","branchId","db29a1f8-33a3-11f1-ac5c-42b51c65c3df","id","db26d81a-33a3-11f1-ac5c-42b51c65c3df","untitled-753",["D",1775691427462],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","cf543f84-0db2-4b4f-a39b-58281a21b5ff","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d6f58-ab5b-76c5-9a0f-ec878657e051","tursoName","tursoHostname","tursoMeasuredAt","pinned",1,"userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":54,"_99":100,"_101":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",6,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isaacgreenmann","handle","displayName","avatar","https://avatars.githubusercontent.com/u/103331631?v=4","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":148,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":149,"_79":150,"_81":151,"_83":25},"tree",[143],"files",[143],"counts",{"_133":60,"_134":67,"_135":60,"_136":137,"_138":139},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"7ec875ee-4f17-11f1-b6e5-ee650bb23af1","parentId","latest",["D",1778709775499],4,"label",[28],"pulls","branches","forks","envVars",{"_140":60,"_142":60},"connections",{"_140":60,"_141":60},"count","unfilledCount","emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":144,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_145":146,"_27":147},["D",1778709775499],"children",[],[28],["D",1775691427462],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":54,"_99":100,"_101":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_122":185,"_186":187,"_188":189,"_190":25,"_191":25,"_192":25,"_193":194,"_195":-5,"_196":-7,"_197":-7,"_198":60,"_199":25,"_200":25,"_201":-5,"_202":25,"_203":25,"_204":25,"_205":-5},"ENV",{"_156":157,"_158":159,"_160":85,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v5