\n Input ▾\n

\n \n

\n \n \n \n

\n\n\n

\n Chunking ▾\n

\n Size\n \n

\n Overlap\n \n

\n Min Length\n \n

\n Boundary Snap\n \n

\n Token Model\n \n

\n \n

\n \n Collapse whitespace\n \n \n \n \n \n \n Reverse order\n \n \n \n \n \n \n NFKC normalize\n \n \n \n \n \n \n Strip BOM\n \n \n \n \n \n

\n\n\n

\n Wrap & Describe ▾\n

\n Global Prefix\n \n

\n Global Postfix\n \n

\n Per-chunk Prefix Template\n \n

\n Per-chunk Postfix Template\n \n

\n Templates: {i} = 1-based index · {n} = total · {s} = start offset · {e} = end offset · {chars} = length · {tokens} = est. tokens · {hash} = 8-char fingerprint\n

\n \n Show chunk descriptions\n \n \n \n \n \n \n Base64 output\n \n \n \n \n \n

\n Description template\n \n

\n\n\n\n\n

\n\n\n\n\n\n`;\n}\n\n// ── Handler ───────────────────────────────────────────────────────────────────\n\nconst handler = async (req: Request): Promise => {\n let text = \"\";\n let reqSize = 0;\n\n if (req.method === \"POST\") {\n const parsed = await parse(req);\n text = parsed.text;\n reqSize = parsed.size;\n }\n\n const size = clamp(reqSize > 0 ? reqSize : DEFAULT_CHUNK, 1, MAX_BOUND);\n const chunks = chunk(text, size);\n const meta = buildMeta(chunks, text.length, size);\n const payload: Payload = Object.freeze({ chunks, meta });\n\n return new Response(html(text, payload), {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n};\n\nexport default handler;","label","text-chunker",[151],"11743adc-45e9-11f1-b6ab-42b51c65c3df","test-inference.ts","b9598324-41ca-11f1-898b-42b51c65c3df",752,["D",1777700274460],48,"const INFERENCE_URL = \"https://inference-router-dev.val.run\";\n\nexport default async function (): Promise {\n const res = await fetch(INFERENCE_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n messages: [\n { role: \"user\", content: \"Hello — testing inference.\" },\n ],\n }),\n });\n\n /*example response:\n\n {\"id\":\"chatcmpl-omni-1600e4d2-90ed-4b01-ade3-3ae3a1e3b239\",\"object\":\"chat.completion\",\"created\":1777700178,\"model\":\"qwen/qwen3-32b\",\"choices\":[{\"index\":0,\"message\":{\"role\":\"assistant\",\"content\":\"\\nOkay, the user sent \\\"Hello — testing inference.\\\" Let me break this down. First, they're greeting me, which is standard. The phrase \\\"testing inference\\\" is key here. They probably want to see how I handle a query that's not straightforward. Maybe they're checking if I can infer the intent behind a vague message.\\n\\nI should consider possible scenarios. Are they testing if I can ask clarifying questions? Or maybe they want to see if I can generate a response without more context. Since the message is short, I need to respond in a way that invites them to provide more details. \\n\\nI should acknowledge their greeting and then ask what specific aspect of inference they're testing. That way, I can tailor my response to their actual needs. Also, making sure the tone is friendly and helpful is important. Let me check if there's any other nuance I might be missing. Maybe they're a developer testing the model's capabilities? Or a student trying to understand how inference works in practice. \\n\\nEither way, the best approach is to be open and ask for clarification. That way, I can provide a more accurate and useful response. I'll go with that.\\n\\n\\nHello! It seems like you're testing how I handle inference or interpretation. Could you clarify what specific aspect you'd like me to demonstrate or explain? For example: \\n\\n- Are you testing my ability to infer intent from ambiguous input? \\n- Do you want an example of logical inference? \\n- Are you curious about how I process context or generate responses? \\n\\nLet me know how I can assist! 😊\"},\"finish_reason\":\"stop\"}],\"_omni_meta\":{\"provider\":{\"id\":3,\"name\":\"groq\",\"base\":\"https://api.groq.com/openai/v1\",\"keyEnv\":\"GROQ_API_KEY\",\"fallbackModel\":\"llama-3.3-70b-versatile\",\"priority\":3},\"latency_ms\":936,\"inflight_requests\":0,\"circuit_states\":[{\"name\":\"openrouter_free\",\"state\":\"CLOSED\"},{\"name\":\"sambanova\",\"state\":\"CLOSED\"},{\"name\":\"groq\",\"state\":\"CLOSED\"},{\"name\":\"github_models\",\"state\":\"CLOSED\"},{\"name\":\"mistral\",\"state\":\"CLOSED\"},{\"name\":\"siliconflow\",\"state\":\"CLOSED\"},{\"name\":\"deepinfra\",\"state\":\"CLOSED\"},{\"name\":\"cerebras\",\"state\":\"CLOSED\"}]}}\n */\n\n return res //?.choices?.[0]?.message?.content,\n ; //provider: res?._omni_meta?.providerId ?? null,});\n}",[164],"89696552-feee-4541-9b65-fbfec292fd03","router.tsx","334f4f70-7c3a-11f1-857e-1607ee4eb77e",1208,["D",1783720857000],26,"import { getProviderArray } from \"./inference-provider.ts\";\nimport { all, initDB, type Row, run, sql } from \"./db.ts\";\n\ntype Provider = Row<\"provider\">;\n\nconst MAX_CONCURRENCY = 3;\nconst MAX_FAILS = 2;\nconst BREAK_DURATION_MS = 25_000;\nconst HARD_TIMEOUT_MS = 120_000;\nconst INFERENCE_TEMPERATURE = 0.0;\nconst MAX_TOKENS = 40_000;\n\n// ============================================================================\n// STATE MANAGEMENT (SQLite) & CACHING\n// ============================================================================\nasync function getSavedModels(): Promise> {\n const r = await all(\n \"omni_router_config\",\n sql`SELECT * FROM omni_router_config`,\n );\n if (!r.ok) {\n console.error(\"getSavedModels failed:\", r.error);\n return {};\n }\n const map: Record = {};\n for (const row of r.value) map[row.provider] = row.selected_model;\n return map;\n}\n\nlet inflight = 0;\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst now = () => performance.now();\n\n// ============================================================================\n// CIRCUIT BREAKER\n// ============================================================================\ntype BreakerState = \"CLOSED\" | \"OPEN\" | \"HALF_OPEN\";\ninterface Breaker {\n failCount: number;\n state: BreakerState;\n nextAttempt: number;\n}\nconst breakers = new Map();\n\nfunction getBreaker(name: string): Breaker {\n if (!breakers.has(name)) {\n breakers.set(name, { failCount: 0, state: \"CLOSED\", nextAttempt: 0 });\n }\n return breakers.get(name)!;\n}\n\nfunction checkBreaker(name: string): boolean {\n const b = getBreaker(name);\n if (b.state === \"OPEN\" && Date.now() >= b.nextAttempt) {\n b.state = \"HALF_OPEN\";\n }\n return b.state === \"HALF_OPEN\" || b.state === \"CLOSED\";\n}\n\nfunction reportBreaker(name: string, success: boolean) {\n const b = getBreaker(name);\n if (success) {\n b.failCount = 0;\n b.state = \"CLOSED\";\n } else {\n b.failCount++;\n if (b.failCount >= MAX_FAILS || b.state === \"HALF_OPEN\") {\n b.state = \"OPEN\";\n b.nextAttempt = Date.now() + BREAK_DURATION_MS;\n b.failCount = 0;\n }\n }\n}\n\n// ============================================================================\n// CORE INFERENCE ENGINE\n// ============================================================================\nasync function invokeProvider(\n provider: Provider,\n targetModel: string,\n messages: any[],\n tools?: any[],\n toolChoice?: any,\n temperature: number = 0.0,\n maxTokens: number = MAX_TOKENS,\n) {\n const key = Deno.env.get(provider.keyEnv!)!;\n const url = `${provider.base}/chat/completions`;\n\n const payload: any = {\n model: targetModel,\n messages,\n temperature: temperature,\n stream: false,\n max_tokens: maxTokens,\n };\n if (tools && tools.length > 0) {\n payload.tools = tools;\n if (toolChoice) payload.tool_choice = toolChoice;\n }\n\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), HARD_TIMEOUT_MS);\n\n try {\n const t0 = now();\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": \"https://val.town\",\n \"X-Title\": \"Ziggyware-OmniRouter\",\n },\n body: JSON.stringify(payload),\n signal: controller.signal,\n });\n clearTimeout(timeoutId);\n if (!res.ok) {\n throw new Error(\n `HTTP ${res.status}: ${await res.text().catch(() => \"Unknown\")}`,\n );\n }\n\n const json = await res.json();\n if (!json.choices?.[0]?.message) throw new Error(\"Malformed JSON response\");\n\n return {\n message: json.choices[0].message,\n latencyMs: Math.round(now() - t0),\n modelUsed: targetModel,\n provider: provider,\n };\n } catch (e: any) {\n clearTimeout(timeoutId);\n throw new Error(\n e.name === \"AbortError\" ? \"API_STALLED_TIMEOUT\" : e.message,\n );\n }\n}\n\nasync function routeInference(\n messages: any[],\n tools?: any[],\n toolChoice?: any,\n temperature: number,\n maxTokens: number,\n) {\n while (inflight >= MAX_CONCURRENCY) await sleep(10);\n inflight++;\n\n try {\n const savedModels = await getSavedModels();\n const enabledProviders = getProviderArray()\n .filter((p) => Deno.env.get(p.keyEnv!))\n .sort((a, b) => a.priority - b.priority);\n\n if (enabledProviders.length === 0) {\n throw new Error(\"NO_PROVIDERS_CONFIGURED\");\n }\n\n for (const prov of enabledProviders) {\n if (!checkBreaker(prov.name)) continue;\n const targetModel = savedModels[prov.name] || prov.fallbackModel!;\n\n try {\n const { message, latencyMs, modelUsed, provider } =\n await invokeProvider(\n prov,\n targetModel,\n messages,\n tools,\n toolChoice,\n temperature,\n maxTokens,\n );\n\n reportBreaker(provider.name, true);\n\n return { message, provider, model: modelUsed, latencyMs };\n } catch (e: any) {\n reportBreaker(prov.name, false);\n console.warn(\n `[SEVERED] ${prov.name} failed (${e.message}). Routing next...`,\n );\n }\n }\n throw new Error(\"ALL_PROVIDERS_EXHAUSTED_OR_OPEN\");\n } finally {\n inflight--;\n }\n}\n\nasync function handleChatCompletions(body: any) {\n const messages = body.messages ||\n (body.prompt ? [{ role: \"user\", content: body.prompt }] : []);\n if (!messages.length) {\n return new Response(\n JSON.stringify({ error: \"Empty message payload\" }),\n { status: 400 },\n );\n }\n const { message, provider, model, latencyMs } = await routeInference(\n messages,\n body.tools,\n body.tool_choice,\n INFERENCE_TEMPERATURE,\n );\n\n const activeGuards = getProviderArray()\n .filter((p) => Deno.env.get(p.keyEnv!))\n .map((p) => ({ name: p.name, state: getBreaker(p.name).state }));\n\n const sseId = `chatcmpl-omni-${crypto.randomUUID()}`;\n\n if (body.stream) {\n const encoder = new TextEncoder();\n const stream = new ReadableStream({\n start(controller) {\n const sendChunk = (\n delta: any,\n finish_reason: string | null = null,\n ) => {\n controller.enqueue(encoder.encode(`data: ${\n JSON.stringify({\n id: sseId,\n object: \"chat.completion.chunk\",\n created: Math.floor(Date.now() / 1000),\n model: model,\n choices: [{ index: 0, delta, finish_reason }],\n })\n }\\n\\n`));\n };\n sendChunk({ role: \"assistant\", content: \"\" });\n if (message.content) sendChunk({ content: message.content });\n if (message.tool_calls) sendChunk({ tool_calls: message.tool_calls });\n sendChunk({}, message.tool_calls ? \"tool_calls\" : \"stop\");\n controller.enqueue(encoder.encode(\"data: [DONE]\\n\\n\"));\n controller.close();\n },\n });\n return new Response(stream, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n return new Response(\n JSON.stringify({\n id: sseId,\n object: \"chat.completion\",\n created: Math.floor(Date.now() / 1000),\n model: model,\n choices: [{\n index: 0,\n message: message,\n finish_reason: message.tool_calls ? \"tool_calls\" : \"stop\",\n }],\n _omni_meta: {\n provider: provider,\n latency_ms: latencyMs,\n inflight_requests: inflight,\n circuit_states: activeGuards,\n },\n }),\n {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Headers\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n },\n });\n }\n\n const init = await initDB();\n if (!init.ok) {\n return Response.json({ error: `DB init failed: ${init.error}` }, {\n status: 500,\n });\n }\n\n if (req.method === \"GET\") {\n if (url.pathname === \"/health\") {\n const providers = getProviderArray().filter((p) =>\n Deno.env.get(p.keyEnv!)\n );\n return Response.json({\n status: providers.length > 0 ? \"ok\" : \"degraded\",\n providers_configured: providers.length,\n inflight_requests: inflight,\n });\n }\n\n if (url.pathname === \"/api/providers\") {\n const savedModels = await getSavedModels();\n const status = getProviderArray().map((p) => ({\n ...p,\n hasKey: !!Deno.env.get(p.keyEnv!),\n currentModel: savedModels[p.name] || p.fallbackModel,\n })).sort((a, b) => a.priority - b.priority);\n return Response.json(status);\n }\n\n if (url.pathname === \"/api/models\") {\n const pName = url.searchParams.get(\"provider\");\n const p = getProviderArray().find((x) => x.name === pName);\n if (!p) {\n return Response.json({ error: \"Provider not found\" }, { status: 404 });\n }\n const key = Deno.env.get(p.keyEnv!);\n if (!key) {\n return Response.json({ error: \"Missing API Key\" }, { status: 401 });\n }\n try {\n const res = await fetch(`${p.base}/models`, {\n headers: { \"Authorization\": `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n const data = await res.json();\n return Response.json(data.data || data);\n } catch (e: any) {\n return Response.json({ error: e.message, fallback: p.fallbackModel }, {\n status: 500,\n });\n }\n }\n\n // OpenAPI-style aggregate model list across all configured providers\n if (url.pathname === \"/v1/models\") {\n const providers = getProviderArray().filter((p) =>\n Deno.env.get(p.keyEnv!)\n );\n const results = await Promise.all(\n providers.map(async (p) => {\n try {\n const res = await fetch(`${p.base}/models`, {\n headers: { \"Authorization\": `Bearer ${Deno.env.get(p.keyEnv!)}` },\n });\n if (!res.ok) return [];\n const data = await res.json();\n const list = data.data || data;\n return Array.isArray(list)\n ? list.map((m: any) => ({\n id: typeof m === \"string\" ? m : m.id,\n object: \"model\",\n owned_by: p.name,\n }))\n : [];\n } catch {\n return [];\n }\n }),\n );\n return Response.json({ object: \"list\", data: results.flat() });\n }\n\n return new Response(\n `\n \n \n \n \n \n Ziggyware Router Matrix\n \n \n \n \n \n \n \n

// empty

';\n return;\n }\n list.forEach(s => {\n const row = document.createElement('div');\n row.className = 'sess-row' + (s.id === currentSession ? ' active' : '');\n row.dataset.id = s.id;\n\n const name = document.createElement('span');\n name.className = 'sess-name';\n name.textContent = (s.name || 'New Chat').toUpperCase();\n\n const del = document.createElement('button');\n del.className = 'sess-del';\n del.title = 'Delete';\n del.innerHTML = '';\n del.onclick = (e) => { e.stopPropagation(); deleteSession(s.id); };\n\n row.appendChild(name);\n row.appendChild(del);\n row.onclick = () => switchSession(s.id, s.name);\n sessionsEl.appendChild(row);\n });\n }\n\n async function switchSession(id, name) {\n currentSession = id;\n titleEl.textContent = (name || 'New Chat').toUpperCase();\n msgCount = 0;\n [...chat.querySelectorAll('.msg-wrap')].forEach(n => n.remove());\n empty.style.display = '';\n document.querySelectorAll('.sess-row').forEach(el =>\n el.classList.toggle('active', el.dataset.id === id));\n\n const r = await fetch('?history=' + encodeURIComponent(id));\n const history = await r.json();\n history.forEach(m => {\n if (m.role === 'user' || m.role === 'assistant')\n addMsg(m.role === 'user' ? 'user' : 'ai', m.content, null, false);\n });\n }\n\n async function deleteSession(id) {\n await fetch('?session=' + encodeURIComponent(id), { method: 'DELETE' });\n if (id === currentSession) newChat();\n loadSessions();\n }\n\n function newChat() {\n currentSession = crypto.randomUUID();\n titleEl.textContent = 'NEW CHAT';\n msgCount = 0;\n [...chat.querySelectorAll('.msg-wrap')].forEach(n => n.remove());\n empty.style.display = '';\n loadSessions();\n }\n\n // ─── Rename ───────────────────────────────────────────────────────────────────\n function startRename() {\n titleEl.style.display = 'none';\n titleInp.style.display = 'block';\n titleInp.value = titleEl.textContent;\n titleInp.focus(); titleInp.select();\n }\n function commitRename() {\n const v = (titleInp.value.trim() || 'New Chat').toUpperCase();\n titleEl.textContent = v;\n titleEl.style.display = ''; titleInp.style.display = 'none';\n fetch('?rename', {\n method: 'POST', headers: {'content-type':'application/json'},\n body: JSON.stringify({ id: currentSession, name: v })\n });\n loadSessions();\n }\n function titleKey(e) {\n if (e.key === 'Enter') commitRename();\n if (e.key === 'Escape') { titleInp.style.display = 'none'; titleEl.style.display = ''; }\n }\n\n // ─── Clear ────────────────────────────────────────────────────────────────────\n function confirmClear() {\n const btn = document.querySelector('#hdr .ib[title=\"clear\"]');\n if (btn.dataset.confirming) {\n doClear(); delete btn.dataset.confirming; btn.style.color = '';\n } else {\n btn.dataset.confirming = '1'; btn.style.color = 'var(--err)';\n setTimeout(() => { delete btn.dataset.confirming; btn.style.color = ''; }, 2500);\n }\n }\n async function doClear() {\n await fetch('?clear', {\n method: 'POST', headers: {'content-type':'application/json'},\n body: JSON.stringify({ id: currentSession })\n });\n [...chat.querySelectorAll('.msg-wrap')].forEach(n => n.remove());\n msgCount = 0; empty.style.display = '';\n }\n\n // ─── Tool chain rendering ─────────────────────────────────────────────────────\n // Keys here must match the backend's TOOLS registry names exactly — the\n // previous 'memory_read' entry never matched the backend's 'memory_recall'\n // tool, so every memory-recall event silently fell through to the generic\n // uppercase-name fallback instead of getting its intended label/color.\n const TOOL_LABELS = {\n memory_recall: { label:'MEM_R', desc: (a) => 'recall: ' + (a?.query ?? '') },\n memory_write: { label:'MEM_W', desc: (a) => 'write: ' + (a?.fact?.slice(0,60) ?? '') },\n create_artifact:{ label:'APP', desc: (a) => 'built: ' + (a?.title ?? '') },\n name_session: { label:'NAME', desc: (a) => 'title: ' + (a?.name ?? '') },\n session_clear: { label:'CLR', desc: (a) => 'clear session messages' },\n session_delete: { label:'DEL', desc: (a) => 'delete session' },\n web_search: { label:'SRCH', desc: (a) => 'query: ' + (a?.query ?? '') },\n eval_js: { label:'EVAL', desc: (a) => (a?.code ?? '').split('\\\\n')[0].slice(0,72) },\n };\n\n function renderToolChain(events) {\n // events: [{hop, tool, args, result, error}]\n if (!events?.length) return null;\n\n const chain = document.createElement('div');\n chain.className = 'tool-chain';\n\n let lastHop = -1;\n events.forEach((ev, i) => {\n // hop separator between hops (not before first)\n if (ev.hop !== lastHop && i > 0) {\n const sep = document.createElement('div');\n sep.className = 'hop-sep';\n sep.textContent = 'hop ' + ev.hop;\n chain.appendChild(sep);\n }\n lastHop = ev.hop;\n\n // MCP-bridged tools arrive as '_' (e.g. rojs_hover) —\n // label them by server rather than shouting the whole name.\n const meta = TOOL_LABELS[ev.tool] ||\n (ev.tool.startsWith('rojs_')\n ? { label: 'ROJS', desc: () => ev.tool.slice(5).replace(/_/g, ' ') }\n : { label: ev.tool.toUpperCase(), desc: () => '' });\n const hasError = !!ev.error;\n\n const row = document.createElement('div');\n row.className = 'tool-event';\n\n const kind = document.createElement('span');\n kind.className = 'tool-kind tk-' + (hasError ? 'error' : ev.tool);\n kind.textContent = hasError ? 'ERR' : meta.label;\n\n const desc = document.createElement('span');\n desc.className = 'tool-desc';\n if (hasError) {\n desc.innerHTML = '' + ev.tool + ': ' + String(ev.error).slice(0, 80);\n } else {\n const dText = meta.desc(ev.args);\n desc.innerHTML = dText ? '' + ev.tool + ' — ' + dText : '' + ev.tool + '';\n }\n\n row.appendChild(kind);\n row.appendChild(desc);\n chain.appendChild(row);\n\n // result row (collapsed by default) — skipped for create_artifact,\n // which gets its own app-card instead of a raw JSON dump.\n if (ev.result !== undefined && ev.result !== null && ev.tool !== 'create_artifact') {\n const resultStr = typeof ev.result === 'string'\n ? ev.result : JSON.stringify(ev.result, null, 2);\n const preview = resultStr.slice(0, 120).replace(/\\\\n/g, ' ');\n const isLong = resultStr.length > 120;\n\n const resultRow = document.createElement('div');\n resultRow.className = 'tool-event';\n resultRow.style.paddingLeft = '2px';\n\n const resultEl = document.createElement('div');\n resultEl.className = 'tool-result';\n resultEl.textContent = preview + (isLong ? '…' : '');\n\n resultRow.appendChild(resultEl);\n\n if (isLong) {\n const expBtn = document.createElement('button');\n expBtn.className = 'tool-expand';\n expBtn.textContent = '[expand]';\n expBtn.onclick = () => {\n const expanded = resultEl.classList.toggle('expanded');\n resultEl.textContent = expanded ? resultStr : preview + '…';\n expBtn.textContent = expanded ? '[collapse]' : '[expand]';\n };\n resultRow.appendChild(expBtn);\n }\n chain.appendChild(resultRow);\n }\n });\n\n return chain;\n }\n\n // ─── App cards (create_artifact results) ─────────────────────────────────────\n function renderAppCard(ev) {\n const url = ev.result?.url;\n if (!url) return null;\n\n const card = document.createElement('div');\n card.className = 'app-card';\n\n const bar = document.createElement('div');\n bar.className = 'app-card-bar';\n\n const title = document.createElement('span');\n title.className = 'app-card-title';\n title.textContent = ev.result.title || 'untitled';\n\n const open = document.createElement('a');\n open.className = 'app-card-open';\n open.href = url;\n open.target = '_blank';\n open.rel = 'noopener noreferrer';\n open.textContent = 'open ↗';\n\n bar.appendChild(title);\n bar.appendChild(open);\n card.appendChild(bar);\n\n const kind = ev.args?.kind;\n if (kind === 'html' || kind === 'svg') {\n const frame = document.createElement('iframe');\n frame.className = 'app-card-frame';\n frame.src = url;\n // allow-scripts only — deliberately omits allow-same-origin, so\n // agent-authored content can run its own script but cannot reach\n // this page's cookies, DOM, or session storage.\n frame.sandbox = 'allow-scripts';\n frame.loading = 'lazy';\n card.appendChild(frame);\n }\n\n return card;\n }\n\n // ─── Message rendering ────────────────────────────────────────────────────────\n function ts() {\n return new Date().toLocaleTimeString([], {hour:'2-digit', minute:'2-digit', hour12:false});\n }\n\n function addMsg(cls, text, meta = null, animate = true, toolEvents = null) {\n if (!msgCount++) empty.style.display = 'none';\n\n const w = document.createElement('div');\n w.className = 'msg-wrap ' + cls;\n if (!animate) w.style.animation = 'none';\n\n // label row\n const label = document.createElement('div');\n label.className = 'msg-label';\n\n const roleTag = document.createElement('span');\n roleTag.className = 'role-tag';\n roleTag.textContent = cls === 'user' ? 'YOU' : 'AI';\n\n const tsSpan = document.createElement('span');\n tsSpan.className = 'msg-ts';\n tsSpan.textContent = ts();\n\n label.appendChild(roleTag);\n label.appendChild(tsSpan);\n\n if (cls === 'ai' && meta?.provider) {\n const pt = document.createElement('span');\n pt.className = 'provider-tag';\n const p = meta.provider;\n pt.textContent = (p?.name ?? '') + (meta.model ? ' / ' + meta.model : '');\n label.appendChild(pt);\n }\n\n w.appendChild(label);\n\n // tool chain + app cards (before body, for AI messages)\n if (cls === 'ai' && toolEvents?.length) {\n const chain = renderToolChain(toolEvents);\n if (chain) w.appendChild(chain);\n\n toolEvents\n .filter(ev => ev.tool === 'create_artifact' && !ev.error)\n .forEach(ev => {\n const card = renderAppCard(ev);\n if (card) w.appendChild(card);\n });\n }\n\n // body\n const body = document.createElement('div');\n body.className = 'msg-body';\n body.textContent = text;\n w.appendChild(body);\n\n // actions\n const actions = document.createElement('div');\n actions.className = 'msg-actions';\n\n const copyBtn = document.createElement('button');\n copyBtn.className = 'act-btn';\n copyBtn.textContent = 'copy';\n const flash = document.createElement('span');\n flash.className = 'copy-flash';\n flash.textContent = '✓ copied';\n copyBtn.onclick = () => {\n navigator.clipboard.writeText(body.textContent || '');\n flash.classList.add('show');\n setTimeout(() => flash.classList.remove('show'), 1200);\n };\n actions.appendChild(copyBtn);\n actions.appendChild(flash);\n\n if (cls === 'user') {\n const editBtn = document.createElement('button');\n editBtn.className = 'act-btn';\n editBtn.textContent = 'edit';\n editBtn.onclick = () => enterEditMode(w, body, text);\n actions.appendChild(editBtn);\n }\n\n if (cls === 'ai') {\n const retryBtn = document.createElement('button');\n retryBtn.className = 'act-btn';\n retryBtn.textContent = 'retry';\n retryBtn.onclick = () => retryFromMsg(w);\n actions.appendChild(retryBtn);\n }\n\n w.appendChild(actions);\n chat.insertBefore(w, typing);\n chat.scrollTop = chat.scrollHeight;\n return w;\n }\n\n // ─── Edit mode ────────────────────────────────────────────────────────────────\n function enterEditMode(wrap, bodyEl, originalText) {\n bodyEl.style.display = 'none';\n wrap.querySelectorAll('.msg-actions').forEach(el => el.style.display = 'none');\n\n const ta = document.createElement('textarea');\n ta.className = 'edit-area';\n ta.value = originalText;\n ta.rows = Math.min(originalText.split('\\\\n').length + 1, 8);\n ta.addEventListener('input', () => {\n ta.style.height = 'auto';\n ta.style.height = Math.min(ta.scrollHeight, 180) + 'px';\n });\n\n const btns = document.createElement('div');\n btns.className = 'edit-btns';\n\n const cancel = document.createElement('button');\n cancel.className = 'edit-btn';\n cancel.textContent = 'cancel';\n cancel.onclick = () => {\n ta.remove(); btns.remove();\n bodyEl.style.display = '';\n wrap.querySelectorAll('.msg-actions').forEach(el => el.style.display = '');\n };\n\n const confirm = document.createElement('button');\n confirm.className = 'edit-btn confirm';\n confirm.textContent = 'resend →';\n confirm.onclick = async () => {\n const newText = ta.value.trim();\n if (!newText) return;\n const allWraps = [...chat.querySelectorAll('.msg-wrap')];\n const idx = allWraps.indexOf(wrap);\n allWraps.slice(idx).forEach(n => n.remove());\n msgCount = Math.max(0, msgCount - (allWraps.length - idx));\n await sendWith(newText);\n };\n\n btns.appendChild(cancel);\n btns.appendChild(confirm);\n wrap.appendChild(ta);\n wrap.appendChild(btns);\n ta.focus();\n ta.setSelectionRange(ta.value.length, ta.value.length);\n }\n\n // ─── Retry ────────────────────────────────────────────────────────────────────\n async function retryFromMsg(aiWrap) {\n const allWraps = [...chat.querySelectorAll('.msg-wrap')];\n const idx = allWraps.indexOf(aiWrap);\n if (idx < 1) return;\n const userText = allWraps[idx-1].querySelector('.msg-body')?.textContent || '';\n allWraps.slice(idx - 1).forEach(n => n.remove());\n msgCount = Math.max(0, msgCount - (allWraps.length - (idx - 1)));\n await sendWith(userText);\n }\n\n // ─── Send ─────────────────────────────────────────────────────────────────────\n async function sendMsg() {\n const t = inp.value.trim();\n if (!t || inflight) return;\n inp.value = ''; inp.style.height = 'auto';\n charEl.textContent = ''; charEl.className = '';\n await sendWith(t);\n }\n\n async function sendWith(text) {\n if (inflight) return;\n inflight = true; setSendState(true);\n addMsg('user', text);\n showTyping(true, 'thinking');\n\n try {\n const r = await fetch(\n '?q=' + encodeURIComponent(text) + '&session=' + encodeURIComponent(currentSession)\n );\n const j = await r.json();\n showTyping(false);\n addMsg('ai', j.reply || '…', j.meta, true, j.toolEvents);\n\n if (j.sessionName) {\n titleEl.textContent = j.sessionName.toUpperCase();\n loadSessions();\n } else if (msgCount <= 2) {\n loadSessions();\n }\n } catch(e) {\n showTyping(false);\n addMsg('ai', '[network error: ' + e.message + ']');\n } finally {\n inflight = false; setSendState(false);\n }\n }\n\n function setSendState(busy) {\n sendBtn.disabled = busy;\n sendBtn.innerHTML = busy\n ? '

'\n : '';\n }\n\n function showTyping(v, label = 'thinking') {\n typingLbl.textContent = label;\n typing.style.display = v ? 'flex' : 'none';\n if (v) chat.scrollTop = chat.scrollHeight;\n }\n\n // ─── Textarea ─────────────────────────────────────────────────────────────────\n inp.addEventListener('input', () => {\n inp.style.height = 'auto';\n inp.style.height = Math.min(inp.scrollHeight, 100) + 'px';\n const len = inp.value.length;\n charEl.textContent = len > 50 ? len : '';\n charEl.className = len > 4000 ? 'danger' : len > 500 ? 'warn' : '';\n });\n inp.addEventListener('keydown', e => {\n if (e.key === 'Enter' && !e.shiftKey) { e.preventDefault(); sendMsg(); }\n });\n inp.addEventListener('focus', () => {\n setTimeout(() => { if (sidebarOpen) toggleSidebar(); chat.scrollTop = chat.scrollHeight; }, 350);\n });\n\n // ─── Scroll pill ──────────────────────────────────────────────────────────────\n chat.addEventListener('scroll', () => {\n const atBottom = chat.scrollHeight - chat.scrollTop - chat.clientHeight < 60;\n pill.classList.toggle('visible', !atBottom);\n });\n function scrollBottom() { chat.scrollTo({ top: chat.scrollHeight, behavior: 'smooth' }); }\n\n // ─── vh fix ───────────────────────────────────────────────────────────────────\n (function setVH() {\n document.documentElement.style.setProperty('--vh', window.innerHeight * .01 + 'px');\n window.addEventListener('resize', setVH);\n })();\n\n // ─── Init ─────────────────────────────────────────────────────────────────────\n loadSessions();`;",[201],"c09de40c-ea08-4e45-9e2a-643d7e33602d","main-html.tsx","43b65d66-45ff-11f1-9d6b-42b51c65c3df",1086,["D",1783630192239],32,"/** @jsxImportSource https://esm.sh/react@19.2.0 */\n\nimport { style } from \"./main-style.ts\";\nimport { script } from \"./main-script.ts\";\n//import React from \"https://esm.sh/react@19.2.0\";\nexport const PAGE_HTML: string = `\n \n \n \n ZIGGYWARE\n \n \n \n \n \n\n \n

\n \n

\n NEW CHAT\n \n \n

live

\n\n

// ziggyware free ai //

How can I help?

\n \n

\n thinking\n

↓ bottom

\n\n

\n \n \n \n

\n tools active:\n

\n web_search\n eval_js\n create_artifact\n memory_r/w\n session_mgmt\n

\n \n \n \n `;",[209],"23db7e3c-a456-4cab-8973-452c63237cca","inference-provider.ts","f5b23648-43b6-11f1-91e9-42b51c65c3df",1200,["D",1783678101871],"import type { Row } from \"./db.ts\";\n\ntype Provider = Row<\"provider\">;\n\nexport function getProviderArray(): Provider[] {\n const ret: Provider[] = [{\n id: \"1\",\n name: \"cerebras\",\n base: \"https://api.cerebras.ai/v1\",\n keyEnv: \"CEREBRAS_API_KEY\",\n fallbackModel: \"llama3.3-70b\",\n priority: 3,\n }, {\n id: \"2\",\n name: \"sambanova\",\n base: \"https://api.sambanova.ai/v1\",\n keyEnv: \"SAMBANOVA_API_KEY\",\n fallbackModel: \"Meta-Llama-3.3-70B-Instruct\",\n priority: 4,\n }, {\n id: \"3\",\n name: \"groq\",\n base: \"https://api.groq.com/openai/v1\",\n keyEnv: \"GROQ_API_KEY\",\n fallbackModel: \"llama-3.3-70b-versatile\",\n priority: 1,\n }, {\n id: \"4\",\n name: \"github_models\",\n base: \"https://models.inference.ai.azure.com\",\n keyEnv: \"GITHUB_TOKEN\",\n fallbackModel: \"Llama-3.3-8B-Instruct\",\n priority: 6,\n }, {\n id: \"5\",\n name: \"mistral\",\n base: \"https://api.mistral.ai/v1\",\n keyEnv: \"MISTRAL_API_KEY\",\n fallbackModel: \"mistral-large-latest\",\n priority: 5,\n }, {\n id: \"7\",\n name: \"deepinfra\",\n base: \"https://api.deepinfra.com/v1/openai\",\n keyEnv: \"DEEPINFRA_API_KEY\",\n fallbackModel: \"meta-llama/Meta-Llama-3.3-70B-Instruct\",\n priority: 8,\n }, {\n id: \"8\",\n name: \"openrouter_free\",\n base: \"https://openrouter.ai/api/v1\",\n keyEnv: \"OPENROUTER_API_KEY\",\n fallbackModel: \"meta-llama/llama-3.3-8b-instruct:free\",\n priority: 2,\n }, {\n id: \"9\",\n name: \"gemini\",\n base: \"https://generativelanguage.googleapis.com/v1beta/openai/\",\n keyEnv: \"GEMINI_API_KEY\",\n fallbackModel: \"gemini-2.5-flash-lite\",\n priority: -7,\n }, {\n id: \"10\",\n name: \"nvidia_nim\",\n base: \"https://integrate.api.nvidia.com/v1\",\n keyEnv: \"NVIDIA_API_KEY\",\n fallbackModel: \"meta/llama-3.1-405b-instruct\",\n priority: -6,\n }, {\n id: \"11\",\n name: \"huggingface\",\n base: \"https://router.huggingface.co/v1\",\n keyEnv: \"HF_TOKEN\",\n fallbackModel: \"meta-llama/Llama-3.1-8B-Instruct\",\n priority: -5,\n }, {\n id: \"13\",\n name: \"siliconflow\",\n base: \"https://api.siliconflow.cn/v1\",\n keyEnv: \"SILICONFLOW_API_KEY\",\n fallbackModel: \"Qwen/Qwen3-8B\",\n priority: -3,\n }, {\n id: \"14\",\n name: \"zai\",\n base: \"https://open.bigmodel.cn/api/paas/v4\",\n keyEnv: \"ZAI_API_KEY\",\n fallbackModel: \"GLM-4.7-Flash\",\n priority: -2,\n }];\n return ret.filter((p) => Deno.env.get(p.keyEnv!))\n .sort((a, b) => a.priority - b.priority);\n}\n\nexport function getProviderMap(): Record {\n const ret: Record = {};\n getProviderArray().forEach((p) => ret[p.name] = p);\n return ret;\n}",[217],"b8350fe4-4b88-4148-b15f-db6736718854","db.ts","0b4ab11c-43c9-11f1-8043-42b51c65c3df",1085,["D",1783629983404],41,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/* ────────────────────────────────────────────────────────────────\n Result monad — DB failures are values, never uncaught exceptions.\n Error channel is a closed literal union, not bare `string`, so\n every `r.error === \"...\"` comparison downstream is checked at\n compile time instead of merely hoped for.\n ──────────────────────────────────────────────────────────────── */\ntype Result = { ok: true; value: T } | { ok: false; error: E };\ntype DbError = \"QUOTA_EXCEEDED\" | \"UNKNOWN\";\n\nfunction Ok(value: T): Result {\n return { ok: true, value };\n}\n\nfunction Err(error: E): Result {\n return { ok: false, error };\n}\n\nasync function attempt(fn: () => Promise): Promise> {\n try {\n return Ok(await fn());\n } catch (e) {\n return Err(\n /full|quota/i.test(String(e)) ? \"QUOTA_EXCEEDED\" : \"UNKNOWN\",\n );\n }\n}\n\n/* ────────────────────────────────────────────────────────────────\n Schema — single source of truth. Row shapes come from an actual\n TS interface, not from pattern-matching SQL text.\n ──────────────────────────────────────────────────────────────── */\ninterface Schema {\n provider: {\n id: string; // natural key — matches message.providerId's type; no cast needed at the join\n name: string;\n base: string;\n keyEnv: string | null;\n fallbackModel: string | null;\n priority: number;\n };\n message: {\n id: number;\n role: \"user\" | \"assistant\" | \"system\";\n content: string;\n ts: number;\n session: string;\n providerId: string | null;\n };\n memory: { key: string; value: string; weight: number; ts: number };\n memory_fact: {\n id: number;\n fact: string;\n salience: number; // 1 - predictability; decays on non-access\n created: number;\n accessed: number;\n hits: number;\n };\n session: { id: string; name: string; ts: number };\n omni_router_config: { provider: string; selected_model: string };\n artifact: {\n id: number;\n session: string;\n title: string;\n kind: \"html\" | \"svg\" | \"markdown\";\n content: string;\n ts: number;\n };\n}\ntype Table = keyof Schema;\ntype Row = Schema[T];\n\nconst DDL: Record = {\n provider: `CREATE TABLE IF NOT EXISTS provider (\n id TEXT PRIMARY KEY, name TEXT NOT NULL, base TEXT NOT NULL,\n keyEnv TEXT, fallbackModel TEXT, priority INTEGER NOT NULL)`,\n message: `CREATE TABLE IF NOT EXISTS message (\n id INTEGER PRIMARY KEY AUTOINCREMENT, role TEXT NOT NULL, content TEXT NOT NULL,\n ts INTEGER NOT NULL, session TEXT NOT NULL REFERENCES session(id),\n providerId TEXT REFERENCES provider(id))`,\n memory: `CREATE TABLE IF NOT EXISTS memory (\n key TEXT PRIMARY KEY, value TEXT NOT NULL, weight REAL NOT NULL, ts INTEGER NOT NULL)`,\n memory_fact: `CREATE TABLE IF NOT EXISTS memory_fact (\n id INTEGER PRIMARY KEY AUTOINCREMENT, fact TEXT NOT NULL, salience REAL NOT NULL,\n created INTEGER NOT NULL, accessed INTEGER NOT NULL, hits INTEGER NOT NULL DEFAULT 0)`,\n session: `CREATE TABLE IF NOT EXISTS session (\n id TEXT PRIMARY KEY, name TEXT NOT NULL DEFAULT 'New Chat', ts INTEGER NOT NULL)`,\n omni_router_config: `CREATE TABLE IF NOT EXISTS omni_router_config (\n provider TEXT PRIMARY KEY, selected_model TEXT NOT NULL)`,\n artifact: `CREATE TABLE IF NOT EXISTS artifact (\n id INTEGER PRIMARY KEY AUTOINCREMENT, session TEXT NOT NULL REFERENCES session(id),\n title TEXT NOT NULL, kind TEXT NOT NULL, content TEXT NOT NULL, ts INTEGER NOT NULL,\n UNIQUE(session, title))`,\n};\n\nconst INDEXES = [\n `CREATE INDEX IF NOT EXISTS idx_message_session_id ON message(session, id)`,\n `CREATE INDEX IF NOT EXISTS idx_memory_ts ON memory(ts)`,\n `CREATE INDEX IF NOT EXISTS idx_memory_fact_accessed ON memory_fact(accessed)`,\n `CREATE INDEX IF NOT EXISTS idx_artifact_session_ts ON artifact(session, ts)`,\n];\n\nconst initDB = () =>\n attempt(() =>\n sqlite.batch([\n `PRAGMA foreign_keys = ON`,\n ...Object.values(DDL),\n ...INDEXES,\n ])\n );\n\n/* ────────────────────────────────────────────────────────────────\n Query core — one primitive, three call shapes.\n\n `sql` is a tagged template: values are never concatenated into\n the statement text, so injection is structurally impossible, not\n just discouraged by convention.\n\n The `Table` argument to `all`/`one` is a phantom: zero runtime\n cost, exists purely to pin the generic so the return type is\n declared honestly by the caller instead of inferred from SQL\n text (which is what broke in the original — template-literal\n type matching only resolves on string-literal SQL and silently\n collapses to `unknown` for anything built at runtime).\n ──────────────────────────────────────────────────────────────── */\n// The exact set of values libsql/SQLite can bind as a parameter (mirrors\n// @libsql/client's InValue). `unknown[]` doesn't satisfy either `execute`\n// overload — TS falls through to the `(sql: string, args?: InArgs)` form\n// and reports the whole `{sql, args}` object as an invalid `sql` argument,\n// which is a confusing symptom of an unrelated cause. Declaring the real\n// value type here fixes it at the source instead of casting at each call.\ntype SqlValue =\n | string\n | number\n | bigint\n | boolean\n | ArrayBuffer\n | Uint8Array\n | Date\n | null;\ntype Bound = { text: string; values: SqlValue[] };\nconst sql = (strings: TemplateStringsArray, ...values: SqlValue[]): Bound => ({\n text: strings.reduce(\n (acc, s, i) => acc + s + (i < values.length ? \"?\" : \"\"),\n \"\",\n ),\n values,\n});\n\n// sqlite.execute returns libsql's ResultSet, whose .rows are libsql's own\n// Row type — every column typed as `Value = null | string | number | bigint\n// | ArrayBuffer`, regardless of what our schema declares. TS correctly\n// refuses a direct cast to Row here: nothing in the type system knows a\n// TEXT NOT NULL column can't come back null, or that an INTEGER won't come\n// back as bigint. That guarantee lives in the SQL schema, not in types, so\n// this is an explicit, acknowledged boundary crossing — not a verified one.\nfunction all(_table: T, q: Bound) {\n return attempt(\n async () =>\n (await sqlite.execute({ sql: q.text, args: q.values }))\n .rows as unknown as Row[],\n );\n}\n\nasync function one(table: T, q: Bound) {\n const r = await all(table, q);\n return r.ok ? Ok(r.value[0] ?? null) : r;\n}\n\n// Escape hatch for shapes that don't correspond to any single table — an\n// aggregate like `SELECT COUNT(*) AS c`, a join projection, etc. `all`/`one`\n// can't type these honestly because their phantom `Table` argument has\n// nothing to pin to. Here the caller declares the shape directly via the\n// explicit generic — same honesty contract as `all`, just without a table\n// to anchor it to.\nfunction raw(q: Bound) {\n return attempt(async () =>\n (await sqlite.execute({ sql: q.text, args: q.values }))\n .rows as unknown as T[]\n );\n}\n\nfunction unwrap(r: Result, fallback: T): T {\n return r.ok ? r.value : fallback;\n}\n\n// libsql's ResultSet carries rowsAffected and lastInsertRowid — the only\n// way to learn the AUTOINCREMENT id of a row just inserted, or to confirm\n// a write actually touched anything. Discarding it (`.then(() => undefined)`)\n// made insertMessage() write rows whose id was permanently unrecoverable.\ntype Effect = { rowsAffected: number; lastInsertRowid: bigint | undefined };\nconst run = (q: Bound) =>\n attempt(async () => {\n const r = await sqlite.execute({ sql: q.text, args: q.values });\n return {\n rowsAffected: r.rowsAffected,\n lastInsertRowid: r.lastInsertRowid,\n } satisfies Effect;\n });\n\n/* ────────────────────────────────────────────────────────────────\n Domain operations — thin pipelines over the three primitives.\n Retention is not an afterthought: every write can fail on quota,\n and the failure is handled as data, not caught upstream by luck.\n ──────────────────────────────────────────────────────────────── */\nconst messagesFor = (session: string, limit = 200) =>\n all(\n \"message\",\n sql`SELECT * FROM message WHERE session = ${session} ORDER BY id DESC LIMIT ${limit}`,\n );\n\nconst insertMessage = async (m: Omit, \"id\">) => {\n const r = await run(\n sql`INSERT INTO message (role, content, ts, session, providerId)\n VALUES (${m.role}, ${m.content}, ${m.ts}, ${m.session}, ${m.providerId})`,\n );\n if (!r.ok) return r;\n // lastInsertRowid is undefined only if this wasn't actually an INSERT into\n // a ROWID table — Number(undefined) would silently produce NaN here, which\n // is worse than failing loudly, since a NaN id would propagate downstream\n // looking like a valid one.\n if (r.value.lastInsertRowid === undefined) return Err(\"UNKNOWN\");\n return Ok(Number(r.value.lastInsertRowid));\n};\n\nconst pruneSession = (session: string, keep = 200) =>\n run(sql`DELETE FROM message WHERE session = ${session} AND id NOT IN\n (SELECT id FROM message WHERE session = ${session} ORDER BY id DESC LIMIT ${keep})`);\n\n// Val Town's real ceiling is the storage quota (10MB free / 1GB paid,\n// Turso-backed), not SQLite's own ~2^31-byte string limit. On\n// QUOTA_EXCEEDED, prune this session hard and retry once. If the\n// retry still fails, the caller gets the real error, not a silent drop.\nconst insertMessageSafe = async (m: Omit, \"id\">) => {\n const first = await insertMessage(m);\n if (first.ok || first.error !== \"QUOTA_EXCEEDED\") return first;\n const pruned = await pruneSession(m.session, 100);\n return pruned.ok ? insertMessage(m) : pruned;\n};\n\nconst upsertMemory = (key: string, value: string, weight: number, ts: number) =>\n run(\n sql`INSERT INTO memory (key, value, weight, ts) VALUES (${key}, ${value}, ${weight}, ${ts})\n ON CONFLICT(key) DO UPDATE SET value = excluded.value, weight = excluded.weight, ts = excluded.ts`,\n );\n\nconst providerById = (id: string) =>\n one(\"provider\", sql`SELECT * FROM provider WHERE id = ${id}`);\n\nconst providersByPriority = () =>\n all(\"provider\", sql`SELECT * FROM provider ORDER BY priority ASC`);\n\nconst touchSession = (id: string, name: string, ts: number) =>\n run(sql`INSERT INTO session (id, name, ts) VALUES (${id}, ${name}, ${ts})\n ON CONFLICT(id) DO UPDATE SET name = excluded.name, ts = excluded.ts`);\n\nexport {\n all,\n type Bound,\n type DbError,\n Err,\n initDB,\n insertMessage,\n insertMessageSafe,\n messagesFor,\n Ok,\n one,\n providerById,\n providersByPriority,\n pruneSession,\n raw,\n type Result,\n type Row,\n run,\n type Schema,\n sql,\n type Table,\n touchSession,\n unwrap,\n upsertMemory,\n};",[224],"924f41af-021e-4bc4-b1ea-af23b3e04377","app.tsx","a03409c6-79e4-11f1-bc29-1607ee4eb77e",1211,["D",1783723364980],19,"import { PAGE_HTML } from \"./main-html.tsx\";\nimport { discoverMcpTools } from \"./mcp-client.ts\";\nimport {\n all,\n type Bound,\n type DbError,\n Err,\n initDB,\n insertMessageSafe,\n messagesFor,\n Ok,\n one,\n pruneSession,\n raw,\n type Result,\n type Row,\n run,\n sql,\n touchSession,\n unwrap,\n} from \"./db.ts\";\n\n// ════════════════════════════════════════════════════════════════════════════\n// CONSTANTS\n// ════════════════════════════════════════════════════════════════════════════\nconst INFERENCE_URL = \"https://router.val.run\";\n\n// Hop/pass budget governor caps. A single cheap query spends 1 inference pass;\n// escalation spends from a bounded pool so \"brilliant\" never becomes \"slow\".\nconst BUDGET = {\n loopHops: 8, // max tool-hops inside agentLoop (unchanged from original)\n planPass: 1, // deliberation pass (mechanism 5)\n ensembleSamples: 3, // self-consistency fan-out on high-stakes (mechanism 6)\n verifyPass: 1, // adversarial self-refutation (mechanism 1)\n regroundPass: 1, // abstention→retrieval escalation (mechanism 2)\n hardCeilingPasses: 14, // absolute upper bound on total inference calls / turn\n};\n\n// Optional distinct model for the verifier so self-critique doesn't share the\n// generator's exact blind spots. If the router ignores `model`, this is inert.\nconst VERIFIER_MODEL: string | null = null; // e.g. \"different-model-id\"\n\n// ════════════════════════════════════════════════════════════════════════════\n// RATE LIMIT + SANITIZE\n// ════════════════════════════════════════════════════════════════════════════\nconst recent = new Map();\nfunction rateLimit(k: string, ms = 900): boolean {\n const now = Date.now();\n if (now - (recent.get(k) ?? 0) < ms) return false;\n recent.set(k, now);\n return true;\n}\nfunction clean(s: string): string {\n return s.replace(/[<>]/g, \"\");\n}\nasync function safeJson(res: Response) {\n const ct = res.headers.get(\"content-type\") || \"\";\n const body = await res.text(); // read once, as text\n if (!res.ok || !ct.includes(\"application/json\")) {\n throw new Error(\n `Expected JSON, got ${res.status} ${ct}: ${body.slice(0, 120)}`,\n );\n }\n try {\n return JSON.parse(body);\n } catch {\n throw new Error(`Bad JSON: ${body.slice(0, 120)}`);\n }\n}\n\n// ════════════════════════════════════════════════════════════════════════════\n// LEGACY BLOB MEMORY (kept for backward compat; no longer the ratchet path)\n// ════════════════════════════════════════════════════════════════════════════\nasync function getMemoryBlob(): Promise | null> {\n return unwrap(\n await one(\"memory\", sql`SELECT * FROM memory WHERE key = ${\"core\"}`),\n null,\n );\n}\n\n// ════════════════════════════════════════════════════════════════════════════\n// EPISODIC MEMORY: write with surprise-salience, retrieve by relevance, decay\n// ════════════════════════════════════════════════════════════════════════════\nconst DECAY_HALFLIFE_MS = 1000 * 60 * 60 * 24 * 7; // 7 days\nconst FACT_CAP = 500;\n\nfunction decayed(salience: number, accessed: number, now: number): number {\n const age = Math.max(0, now - accessed);\n return salience * Math.pow(0.5, age / DECAY_HALFLIFE_MS);\n}\n\nasync function writeFact(fact: string, predictability: number): Promise {\n const now = Date.now();\n // salience = information content ≈ (1 - self-reported predictability).\n const salience = Math.max(0.01, Math.min(1, 1 - predictability));\n await run(\n sql`INSERT INTO memory_fact (fact, salience, created, accessed, hits)\n VALUES (${fact}, ${salience}, ${now}, ${now}, 0)`,\n );\n\n // Bounded store: evict lowest current-value rows beyond a cap.\n const rows = unwrap(\n await all(\"memory_fact\", sql`SELECT * FROM memory_fact`),\n [],\n );\n if (rows.length <= FACT_CAP) return;\n const ranked = rows\n .map((r) => ({ id: r.id, v: decayed(r.salience, r.accessed, now) }))\n .sort((a, b) => a.v - b.v);\n const drop = ranked.slice(0, rows.length - FACT_CAP).map((r) => r.id);\n if (!drop.length) return;\n // Placeholder count varies with drop.length, but every bound value is still\n // a real parameter — this is `run` given a Bound built directly rather than\n // via the tagged template, which only supports a fixed interpolation count.\n const deleteEvicted: Bound = {\n text: `DELETE FROM memory_fact WHERE id IN (${\n drop.map(() => \"?\").join(\",\")\n })`,\n values: drop,\n };\n await run(deleteEvicted);\n}\n\n// Keyword-overlap retrieval — no embedding dependency. Deliberately simple;\n// swap for vector search later without touching callers.\nfunction tokenize(s: string): Set {\n return new Set(\n s.toLowerCase().replace(/[^a-z0-9 ]/g, \" \").split(/\\s+/).filter((w) =>\n w.length > 2\n ),\n );\n}\n\nasync function retrieveFacts(query: string, k = 5): Promise {\n const now = Date.now();\n const qTok = tokenize(query);\n if (!qTok.size) return [];\n const rows = unwrap(\n await all(\"memory_fact\", sql`SELECT * FROM memory_fact`),\n [],\n );\n const scored = rows.map((r) => {\n const fTok = tokenize(r.fact);\n let overlap = 0;\n for (const t of qTok) if (fTok.has(t)) overlap++;\n const relevance = overlap / Math.sqrt(fTok.size || 1);\n const value = decayed(r.salience, r.accessed, now);\n return { id: r.id, fact: r.fact, score: relevance * (0.5 + value) };\n });\n const top = scored.filter((s) => s.score > 0).sort((a, b) =>\n b.score - a.score\n ).slice(0, k);\n // reinforce accessed facts (anti-decay); this is retrieval-as-rehearsal\n for (const t of top) {\n await run(\n sql`UPDATE memory_fact SET accessed = ${now}, hits = hits + 1 WHERE id = ${t.id}`,\n );\n }\n return top.map((t) => t.fact);\n}\n\n// ════════════════════════════════════════════════════════════════════════════\n// SESSION CRUD\n// ════════════════════════════════════════════════════════════════════════════\nasync function ensureSession(id: string): Promise> {\n const existing = unwrap(\n await one(\"session\", sql`SELECT * FROM session WHERE id = ${id}`),\n null,\n );\n if (existing) return existing;\n const row: Row<\"session\"> = { id, name: \"New Chat\", ts: Date.now() };\n await touchSession(row.id, row.name, row.ts);\n return row;\n}\n\nasync function listSessions(): Promise[]> {\n return unwrap(\n await all(\"session\", sql`SELECT * FROM session ORDER BY ts DESC LIMIT 50`),\n [],\n );\n}\n\n// Deliberately does NOT reuse touchSession (which also bumps ts) — renaming\n// a session shouldn't move it to the top of a recency-sorted list.\nasync function renameSession(id: string, name: string): Promise {\n await run(sql`UPDATE session SET name = ${name} WHERE id = ${id}`);\n}\n\nasync function deleteSession(id: string): Promise {\n // Messages first: message.session REFERENCES session(id) under\n // PRAGMA foreign_keys = ON, so the child rows must go before the parent.\n await run(sql`DELETE FROM message WHERE session = ${id}`);\n await run(sql`DELETE FROM session WHERE id = ${id}`);\n}\n\n// pruneSession(id, 0): the \"keep newest 0\" subquery returns no rows, so\n// `id NOT IN (∅)` is true for every row — this clears the session without\n// a second hand-written DELETE statement.\nasync function clearSession(id: string): Promise {\n await pruneSession(id, 0);\n}\n\n// ════════════════════════════════════════════════════════════════════════════\n// MESSAGE CRUD\n// ════════════════════════════════════════════════════════════════════════════\nasync function addMsg(\n role: Row<\"message\">[\"role\"],\n content: string,\n providerId: string | null = null,\n session = \"default\",\n): Promise {\n const r = await insertMessageSafe({\n role,\n content,\n ts: Date.now(),\n session,\n providerId,\n });\n if (!r.ok) console.error(`addMsg failed (session=${session}):`, r.error);\n}\n\nasync function getContext(\n session = \"default\",\n limit = 18,\n): Promise[]> {\n // messagesFor orders newest-first for LIMIT to keep the most recent\n // messages; reverse back to chronological order for the model's context.\n return unwrap(await messagesFor(session, limit), []).slice().reverse();\n}\n\nasync function getHistory(session: string): Promise[]> {\n return unwrap(\n await all(\n \"message\",\n sql`SELECT * FROM message WHERE session = ${session} ORDER BY id ASC`,\n ),\n [],\n );\n}\n\n// ════════════════════════════════════════════════════════════════════════════\n// ARTIFACTS — small standalone apps (html/svg/markdown) the agent builds\n// in-chat. Uniqueness is (session, title): re-using a title overwrites the\n// same artifact rather than accumulating duplicates as the agent iterates.\n// ════════════════════════════════════════════════════════════════════════════\nasync function upsertArtifact(\n session: string,\n title: string,\n kind: Row<\"artifact\">[\"kind\"],\n content: string,\n): Promise, DbError>> {\n const ts = Date.now();\n const w = await run(\n sql`INSERT INTO artifact (session, title, kind, content, ts)\n VALUES (${session}, ${title}, ${kind}, ${content}, ${ts})\n ON CONFLICT(session, title) DO UPDATE SET\n kind = excluded.kind, content = excluded.content, ts = excluded.ts`,\n );\n if (!w.ok) return w;\n // lastInsertRowid isn't reliably set to the existing row's id when the\n // ON CONFLICT...DO UPDATE branch fires rather than a fresh INSERT, so the\n // only correct way to hand back the definitive row (with its real id) is\n // to refetch by the unique key rather than trust the write's own result.\n const r = await one(\n \"artifact\",\n sql`SELECT * FROM artifact WHERE session = ${session} AND title = ${title}`,\n );\n if (!r.ok) return r;\n return r.value ? Ok(r.value) : Err(\"UNKNOWN\");\n}\n\n// ════════════════════════════════════════════════════════════════════════════\n// TOOLS (registry unchanged in spirit; memory tools now hit the fact store)\n// ════════════════════════════════════════════════════════════════════════════\ninterface ToolEvent {\n hop: number;\n tool: string;\n args: Record;\n result?: unknown;\n error?: string;\n}\ninterface ToolCtx {\n session: string;\n // Per-request tool registry: built-ins plus whatever MCP servers exposed at\n // discovery time. Threaded through the loop instead of read from module\n // globals so MCP availability can vary turn-by-turn without racing.\n tools: Record;\n schemas: unknown[];\n}\ninterface Tool {\n schema: Record;\n handle: (args: Record, ctx: ToolCtx) => Promise;\n}\n\nasync function webSearch(query: string): Promise {\n const url = `https://html.duckduckgo.com/html/?q=${\n encodeURIComponent(query)\n }`;\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const text = await res.text();\n const snippets: string[] = [];\n const re = /]*>([\\s\\S]*?)<\\/a>/g;\n let m: RegExpExecArray | null;\n while ((m = re.exec(text)) !== null && snippets.length < 6) {\n snippets.push(m[1].replace(/<[^>]+>/g, \"\").trim());\n }\n return snippets.length ? snippets.join(\"\\n---\\n\") : \"No results found.\";\n}\n\nfunction evalJs(code: string): unknown {\n try {\n const logs: string[] = [];\n const fakeConsole = { log: (...a: unknown[]) => logs.push(a.join(\" \")) };\n const fn = new Function(\n \"Math\",\n \"JSON\",\n \"Array\",\n \"Object\",\n \"String\",\n \"Number\",\n \"Boolean\",\n \"Date\",\n \"RegExp\",\n \"Map\",\n \"Set\",\n \"console\",\n `\"use strict\";\\n${code}`,\n );\n const result = fn(\n Math,\n JSON,\n Array,\n Object,\n String,\n Number,\n Boolean,\n Date,\n RegExp,\n Map,\n Set,\n fakeConsole,\n );\n return { result: result ?? null, logs };\n } catch (e) {\n return { error: String(e) };\n }\n}\n\nconst TOOLS: Record = {\n memory_recall: {\n schema: {\n type: \"function\",\n function: {\n name: \"memory_recall\",\n description:\n \"Retrieve the most relevant remembered facts for a query, ranked by relevance × decayed-salience.\",\n parameters: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"What to recall about.\" },\n },\n required: [\"query\"],\n },\n },\n },\n handle: async ({ query }) => ({\n facts: await retrieveFacts(String(query)),\n }),\n },\n memory_write: {\n schema: {\n type: \"function\",\n function: {\n name: \"memory_write\",\n description:\n \"Persist a durable fact. Provide `predictability` 0..1: how obvious/derivable this fact was to you BEFORE learning it (0 = totally surprising, 1 = you would have guessed it). Surprising facts are retained longer.\",\n parameters: {\n type: \"object\",\n properties: {\n fact: { type: \"string\", description: \"The fact (≤400 chars).\" },\n predictability: {\n type: \"number\",\n description: \"0..1 self-estimated prior predictability.\",\n },\n },\n required: [\"fact\", \"predictability\"],\n },\n },\n },\n handle: async ({ fact, predictability }) => {\n const p = Number(predictability);\n await writeFact(String(fact), Number.isFinite(p) ? p : 0.5);\n return { ok: true };\n },\n },\n name_session: {\n schema: {\n type: \"function\",\n function: {\n name: \"name_session\",\n description:\n \"Set a concise title (≤40 chars, ≤4 words) for the current conversation.\",\n parameters: {\n type: \"object\",\n properties: {\n name: { type: \"string\", description: \"Session title.\" },\n },\n required: [\"name\"],\n },\n },\n },\n handle: async ({ name }, { session }) => {\n const trimmed = String(name).slice(0, 40);\n await renameSession(session, trimmed);\n return { ok: true, name: trimmed };\n },\n },\n session_clear: {\n schema: {\n type: \"function\",\n function: {\n name: \"session_clear\",\n description: \"Erase all messages in the current session.\",\n parameters: { type: \"object\", properties: {}, required: [] },\n },\n },\n handle: async (_a, { session }) => {\n await clearSession(session);\n return { ok: true };\n },\n },\n session_delete: {\n schema: {\n type: \"function\",\n function: {\n name: \"session_delete\",\n description:\n \"Permanently delete the current session and all its messages.\",\n parameters: { type: \"object\", properties: {}, required: [] },\n },\n },\n handle: async (_a, { session }) => {\n await deleteSession(session);\n return { ok: true };\n },\n },\n create_artifact: {\n schema: {\n type: \"function\",\n function: {\n name: \"create_artifact\",\n description:\n \"Build or update a small standalone application the user can open and interact with: an HTML page (inline \n \n \n

Invariant Lab

Multi‑provider claim graphs · invariants · disagreement spectra · ?mode=registry for JSON

\n \n

Technique

${TECHNIQUES[0].name}

${TECHNIQUES[0].goal}

Strata

Syntactic: ${\n TECHNIQUES[0].strata.syntactic\n }
Semantic: ${TECHNIQUES[0].strata.semantic}
Structural: ${\n TECHNIQUES[0].strata.structural\n }

Bayesian Δ & Invariants

${\n TECHNIQUES[0].bayesianDelta\n }

${x}

Diff · v1214