[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_143":144,"_145":146},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_82":65,"_83":84,"_63":-7,"_85":-5,"_13":86,"_87":88,"_11":89,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":26,"_98":99,"_100":26,"_101":-5,"_102":-5,"_103":104},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":-5,"_35":26,"_36":-5,"_37":-5,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":-5,"_45":46,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","isaacgreenmann","id","db26d81a-33a3-11f1-ac5c-42b51c65c3df","name","untitled-753","createdAt",["D",1775691427462],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","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",{"_16":17,"_81":77},"org",{"_16":17,"_75":-5,"_76":77,"_32":33,"_78":79,"_80":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",6,"main","db29a1f8-33a3-11f1-ac5c-42b51c65c3df","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://avatars.githubusercontent.com/u/103331631?v=4","tier","pro","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":139,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":-5,"_35":26,"_36":-5,"_37":-5,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":-5,"_45":46,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":140,"_58":141,"_60":142,"_62":26},"tree",[134],[134],"counts",{"_124":39,"_125":46,"_126":39,"_127":128,"_129":130},"contents",[105],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":106,"_20":107,"_108":109,"_110":-5,"_111":66,"_112":64,"_113":114,"_22":115,"_63":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_83":123},"8026c6e8-4f17-11f1-8461-ee650bb23af1","main.ts","fileId","db2c3594-33a3-11f1-ac5c-42b51c65c3df","parentId","branchId","branchVersion","latest",true,["D",1778709777791],5,"fileType","script","content","/**\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 = (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}","deleted","label",[107],"pulls","branches","forks","envVars",{"_131":39,"_133":39},"connections",{"_131":39,"_132":39},"count","unfilledCount","emptyCount",{"_18":106,"_20":107,"_108":109,"_110":-5,"_111":66,"_112":64,"_113":114,"_22":135,"_63":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_136":137,"_83":138},["D",1778709777791],"children",[],[107],["D",1775691427462],{"_16":17,"_81":77},{"_16":17,"_75":-5,"_76":77,"_32":33,"_78":79,"_80":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_102":176,"_177":178,"_179":180,"_181":26,"_182":26,"_183":26,"_184":114,"_185":-5,"_186":-7,"_187":-7,"_188":39,"_189":26,"_190":26,"_191":-5,"_192":26,"_193":26,"_194":26,"_195":-5},"ENV",{"_147":148,"_149":150,"_151":65,"_152":153,"_154":155,"_156":157,"_158":159,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search