settings

appearance

\n width \n font \n size \n theme \n accent \n density \n timestamps\n telemetry tags\n wrap long code lines\n

thinking & tools

\n thinking \n show tool chain\n live thinking while generating\n

router

\n router url \n router key \n key rotation \n

model

\n routing \n pin \n reasoning effort \n temperature \n max_tokens policy \n fixed max_tokens \n history sent to the model \n expected length \n in-turn continues \n auto-continue across turns \n swarm builders in parallel \n inline preview on artifact cards\n turn budget (s) \n

governor

\n plan before answering (complex asks)\n verification pass\n ensemble on high-stakes\n long-term memory\n

tools

custom instructions

\n \n

prompts

\n edit \n

\n \n

import

skills

Instruction packs the model receives as binding rules. always = every turn; auto = when the message matches the keywords (comma-separated) or a /regex/i.

input

\n send with \n auto-scroll to new replies\n

data

\n`;\n\nexport const settingsScript: string = String.raw`\nconst SETTINGS = (() => {\n const KEY = 'omni.settings';\n const DEF = { width: '760', font: 'mono', fontSize: 13, theme: 'midnight', accent: '#4f8cff', density: 'cozy', timestamps: true, telemetry: true, codeWrap: false,\n thinking: 'collapsed', showTools: true, liveThinking: true, mode: 'auto', pin: '', reasoning: '', temp10: -1, maxTokens: 0, continueMax: 3, budgetS: 52,\n plan: true, verify: true, ensemble: true, memory: true, tools: null, system: '', sendKey: 'enter', autoScroll: true, prompts: {}, skills: [],\n routerUrl: '', routerKey: '', maxMode: 'auto', expect: 'auto', autoContinue: 6, swarm: 6, cardPreview: true, keyPolicy: '', contextChars: 16000 };\n const PRESETS = {\n 'single-file html': { name: 'single-file html', mode: 'auto', when: 'html, webgl, canvas, shader, game, app, visuali', body: 'Deliver browser artifacts as ONE self-contained index.html: inline all CSS in '; });\n const base = '';\n html = /]*>/i.test(html) ? html.replace(/]*>/i, (m) => m + base + HOOK) : base + HOOK + html;\n return html;\n }\n function reload(fromServer) {\n if (!cur) return;\n if (!fromServer && liveCb.checked) { const doc = buildLive(); if (doc !== null) { frame.srcdoc = doc; return; } }\n frame.removeAttribute('srcdoc'); frame.src = '/artifact/' + cur.id + '/?v=' + Date.now();\n }\n function scheduleLive() { if (!liveCb.checked) return; clearTimeout(liveTimer); liveTimer = setTimeout(() => { clearConsole(); reload(false); }, E.liveDelay); }\n function scheduleSave() { if (!E.autoSave) return; clearTimeout(saveTimer); saveTimer = setTimeout(() => save(), E.autoSaveDelay); }\n\n // ─── file tree ──────────────────────────────────────────────────────────────\n function renderTree() {\n treeB.innerHTML = '';\n const root = {};\n for (const f of [...cur.files].sort((a, b) => a.path.localeCompare(b.path))) { const parts = f.path.split('/'); let n = root; for (const p of parts.slice(0, -1)) n = n[p] = n[p] || {}; n[parts[parts.length - 1]] = f; }\n const walk = (node, host, prefix, depth) => {\n const names = Object.keys(node).sort((a, b) => (typeof node[a].path === 'string') - (typeof node[b].path === 'string') || a.localeCompare(b));\n for (const name of names) {\n const v = node[name];\n if (typeof v.path === 'string') { const d = document.createElement('div'); d.className = 'tr-f' + (v.path === active ? ' on' : '') + (cur.dirty.has(v.path) ? ' dirty' : ''); d.style.paddingLeft = (8 + depth * 12) + 'px'; d.textContent = name; d.title = v.path; d.onclick = () => showFile(v.path); host.appendChild(d); }\n else { const dir = prefix + name + '/'; const d = document.createElement('div'); d.className = 'tr-d' + (closedDirs.has(dir) ? ' closed' : ''); d.style.paddingLeft = (6 + depth * 12) + 'px'; d.textContent = name; d.onclick = () => { closedDirs.has(dir) ? closedDirs.delete(dir) : closedDirs.add(dir); renderTree(); }; host.appendChild(d); const kids = document.createElement('div'); kids.className = 'tr-kids'; host.appendChild(kids); walk(v, kids, dir, depth + 1); }\n }\n };\n walk(root, treeB, '', 0);\n }\n function showFile(p) {\n if (!cur) return; const f = cur.files.find(x => x.path === p); if (!f) return;\n active = p;\n if (isBin(p, f.content)) { bin.hidden = false; ta.hidden = true; gutter.hidden = true; if (cm) cm.getWrapperElement().style.display = 'none'; bin.innerHTML = /^data:image\\//.test(f.content) ? '' : 'binary · ' + Math.round(f.content.length * 0.75 / 1024) + ' KB'; if (bin.querySelector('img')) bin.querySelector('img').src = f.content; }\n else { bin.hidden = true; if (cm) { cm.getWrapperElement().style.display = ''; } else { ta.hidden = false; gutter.hidden = !E.lineNumbers || !!E.wrap; } ED.mode(p); ED.set(f.content); }\n renderTree(); updState(); updPos(); ED.refresh();\n }\n function onEdit() { if (!cur || !active) return; const f = cur.files.find(x => x.path === active); if (!f || isBin(active, f.content)) return; f.content = ED.get(); cur.dirty.add(active); renderTree(); updState(); renderGutter(); lintLocal(); scheduleLive(); scheduleSave(); }\n function renderGutter() { if (cm || !E.lineNumbers || E.wrap) return; const n = ta.value.split('\\n').length; if (gutter.dataset.n == n) return; gutter.dataset.n = n; let s = ''; for (let i = 1; i <= n; i++) s += i + '\\n'; gutter.textContent = s; }\n ta.addEventListener('scroll', () => { gutter.scrollTop = ta.scrollTop; });\n function updState() { const f = cur.files.find(x => x.path === active); state.textContent = (f ? (isBin(f.path, f.content) ? 'binary' : f.content.length + ' chars · ' + f.content.split('\\n').length + ' lines') : '') + (cur.dirty.size ? ' · ' + cur.dirty.size + ' unsaved' : ''); }\n function updPos() { const [l, c, s] = ED.cursor(); pos.textContent = l + ':' + c + (s ? ' (' + s + ' sel)' : ''); }\n function showLint(issues) { if (issues && issues.length) { lint.hidden = false; lint.textContent = issues.join('\\n'); } else lint.hidden = true; }\n function lintLocal() { if (!E.lintOnType || !active || !/\\.m?js$/.test(active)) return; try { new Function(ED.get().replace(/^\\s*import\\s[\\s\\S]*?from\\s*[\"'][^\"']+[\"']\\s*;?/gm, '').replace(/^\\s*export\\s*\\{[\\s\\S]*?\\}\\s*;?/gm, '').replace(/^\\s*export\\s+(default\\s+)?/gm, '')); showLint(null); } catch (e) { showLint([active + ': ' + e.message]); } }\n // textarea fallback keys\n ta.addEventListener('input', onEdit); ta.addEventListener('keyup', updPos); ta.addEventListener('click', updPos);\n ta.addEventListener('keydown', (e) => {\n const s = ta.selectionStart, en = ta.selectionEnd, ind = E.softTabs ? ' '.repeat(E.tabSize) : '\\t';\n if ((e.ctrlKey || e.metaKey) && e.key.toLowerCase() === 's') { e.preventDefault(); save(); }\n else if ((e.ctrlKey || e.metaKey) && e.key === 'Enter') { e.preventDefault(); reload(true); }\n else if ((e.ctrlKey || e.metaKey) && e.key.toLowerCase() === 'f') { e.preventDefault(); findToggle(true); }\n else if (e.key === 'Tab') { e.preventDefault(); ta.setRangeText(ind, s, en, 'end'); ta.dispatchEvent(new Event('input')); }\n else if (e.key === 'Enter' && E.autoIndent) { const line = ta.value.slice(0, s).split('\\n').pop(); const base = line.match(/^\\s*/)[0] + (/[{(\\[:]\\s*$/.test(line) ? ind : ''); e.preventDefault(); ta.setRangeText('\\n' + base, s, en, 'end'); ta.dispatchEvent(new Event('input')); }\n });\n\n // ─── find / replace ─────────────────────────────────────────────────────────\n const fbox = $('ap-find'), fin = $('ap-find-in'), frep = $('ap-find-rep'), fn = $('ap-find-n'), fall = $('ap-find-all');\n function findToggle(open) { const o = open ?? fbox.hidden; fbox.hidden = !o; if (o) { fin.value = ED.sel() || fin.value; fin.focus(); fin.select(); } else ED.focus(); }\n function rx() { try { return new RegExp(fin.value, 'gi'); } catch { return new RegExp(fin.value.replace(/[.*+?^$\\{\\}()|[\\]\\\\]/g, '\\\\$&'), 'gi'); } }\n function findNext(dir) {\n if (!fin.value) return;\n if (fall.checked) { const hits = cur.files.filter(f => !isBin(f.path, f.content) && rx().test(f.content)); fn.textContent = hits.length + ' files'; const i = hits.findIndex(f => f.path === active); const nxt = hits[(i + (dir > 0 ? 1 : hits.length - 1)) % Math.max(1, hits.length)]; if (nxt && nxt.path !== active) { showFile(nxt.path); } }\n const v = ED.get(), re = rx(); const all = [...v.matchAll(re)]; fn.textContent = (fall.checked ? fn.textContent + ' · ' : '') + all.length + ' here'; if (!all.length) return;\n const from = cm ? cm.indexFromPos(dir > 0 ? cm.getCursor('to') : cm.getCursor('from')) : (dir > 0 ? ta.selectionEnd : ta.selectionStart);\n const m = dir > 0 ? (all.find(x => x.index >= from) || all[0]) : ([...all].reverse().find(x => x.index < from) || all[all.length - 1]);\n if (cm) { cm.setSelection(cm.posFromIndex(m.index), cm.posFromIndex(m.index + m[0].length)); cm.scrollIntoView(cm.posFromIndex(m.index), 60); } else { ta.focus(); ta.setSelectionRange(m.index, m.index + m[0].length); }\n }\n function replaceOne() { const sel = ED.sel(); if (!sel || !rx().test(sel)) { findNext(1); return; } if (cm) cm.replaceSelection(sel.replace(rx(), frep.value)); else { ta.setRangeText(sel.replace(rx(), frep.value), ta.selectionStart, ta.selectionEnd, 'end'); ta.dispatchEvent(new Event('input')); } if (cm) onEdit(); findNext(1); }\n function replaceAll() {\n if (!fin.value) return; let n = 0;\n const targets = fall.checked ? cur.files.filter(f => !isBin(f.path, f.content)) : cur.files.filter(f => f.path === active);\n for (const f of targets) { const out = f.content.replace(rx(), (m) => { n++; return frep.value; }); if (out !== f.content) { f.content = out; cur.dirty.add(f.path); } }\n fn.textContent = n + ' replaced'; showFile(active); scheduleLive();\n }\n fin.addEventListener('keydown', (e) => { if (e.key === 'Enter') findNext(e.shiftKey ? -1 : 1); if (e.key === 'Escape') findToggle(false); });\n\n // ─── save / files ───────────────────────────────────────────────────────────\n async function save() {\n if (!cur || !cur.dirty.size) return true;\n const files = [...cur.dirty].map(p => cur.files.find(x => x.path === p)).filter(Boolean).map(f => ({ path: f.path, content: f.content }));\n const r = await post('?artifact_save_many', { id: cur.id, session: cur.session, files });\n if (!r.ok) { state.textContent = 'save failed: ' + r.status; return false; }\n const j = await r.json(); for (const f of files) { cur.dirty.delete(f.path); cur.orig[f.path] = f.content; }\n showLint(j.issues); renderTree(); updState(); state.textContent += ' · saved'; clearConsole(); reload(true); return true;\n }\n function ask(label, def) { return new Promise((res) => { const box = $('ap-prompt'), inp = $('ap-prompt-in'); inp.placeholder = label; inp.value = def || ''; box.hidden = false; inp.focus(); inp.select();\n const done = (v) => { box.hidden = true; $('ap-prompt-ok').onclick = $('ap-prompt-no').onclick = null; inp.onkeydown = null; res(v); };\n $('ap-prompt-ok').onclick = () => done(inp.value.trim()); $('ap-prompt-no').onclick = () => done(null); inp.onkeydown = (e) => { if (e.key === 'Enter') done(inp.value.trim()); if (e.key === 'Escape') done(null); }; }); }\n async function addFile() { const p = await ask('path, e.g. src/game/enemy.js'); if (!p || !cur) return; const clean = p.replace(/^\\/+/, ''); if (!cur.files.some(f => f.path === clean)) cur.files.push({ path: clean, content: '' }); cur.dirty.add(clean); showFile(clean); ED.focus(); }\n async function renameFile() {\n if (!cur || !active || /^index\\.html?$/.test(active)) return; const p = await ask('new path', active); if (!p || p === active) return;\n const f = cur.files.find(x => x.path === active); const old = active;\n await post('?artifact_save_many', { id: cur.id, session: cur.session, files: [{ path: p, content: f.content }] });\n await post('?artifact_delete_file', { id: cur.id, path: old });\n f.path = p; cur.dirty.delete(old); cur.orig[p] = f.content; showFile(p); reload(true);\n }\n async function deleteFile() {\n if (!cur || !active || /^index\\.html?$/.test(active)) return; const ok = await ask('type DELETE to remove ' + active); if (ok !== 'DELETE') return;\n await post('?artifact_delete_file', { id: cur.id, path: active });\n cur.files = cur.files.filter(f => f.path !== active); cur.dirty.delete(active); showFile(cur.files[0].path); reload(true);\n }\n function revert() { if (!cur || !active) return; const f = cur.files.find(x => x.path === active); f.content = cur.orig[active] ?? f.content; cur.dirty.delete(active); showFile(active); scheduleLive(); }\n function copy() { if (cur && active) navigator.clipboard.writeText(cur.files.find(x => x.path === active)?.content ?? ''); }\n async function loadZip() { if (!window.JSZip) await new Promise((res, rej) => { const s = document.createElement('script'); s.src = 'https://cdnjs.cloudflare.com/ajax/libs/jszip/3.10.1/jszip.min.js'; s.onload = res; s.onerror = rej; document.head.appendChild(s); }); return window.JSZip; }\n async function zip() {\n if (!cur) return; const J = await loadZip(); const z = new J();\n for (const f of cur.files) { if (isBin(f.path, f.content)) { const m = f.content.match(/^data:[^;,]*;base64,(.*)$/s); if (m) z.file(f.path, m[1], { base64: true }); } else z.file(f.path, f.content); }\n const blob = await z.generateAsync({ type: 'blob' }); const a = document.createElement('a'); a.href = URL.createObjectURL(blob); a.download = (cur.title || 'artifact').replace(/[^\\w.-]+/g, '_') + '.zip'; a.click();\n }\n /** Upload loose files or a .zip into the open artifact (or create a new artifact from a zip when none is open). Text as-is, binaries as data: URLs. */\n async function upload(fileList) {\n const files = [];\n const readText = (f) => f.text(); const readData = (f) => new Promise((res) => { const r = new FileReader(); r.onload = () => res(r.result); r.readAsDataURL(f); });\n for (const f of fileList) {\n if (/\\.zip$/i.test(f.name)) { const J = await loadZip(); const z = await J.loadAsync(f); const names = Object.keys(z.files).filter(n => !z.files[n].dir && !/(^|\\/)(\\.|__MACOSX)/.test(n)); const strip = names.every(n => n.includes('/')) && new Set(names.map(n => n.split('/')[0])).size === 1 ? names[0].split('/')[0].length + 1 : 0;\n for (const n of names) { const path = n.slice(strip); if (!path) continue; if (isBin(path)) { const b64 = await z.files[n].async('base64'); files.push({ path, content: 'data:' + (mimeOf(path)) + ';base64,' + b64 }); } else files.push({ path, content: await z.files[n].async('string') }); } }\n else files.push({ path: f.name, content: isBin(f.name) ? await readData(f) : await readText(f) });\n }\n if (!files.length) return;\n if (!cur) { const r = await post('?artifact_save_many', { session: window.currentSession, title: files.find(f => /\\.zip$/i.test(f.path))?.path || 'Imported', files }); const j = await r.json(); if (j.id) { open(j.id, 'split'); listForSession(window.currentSession); } return; }\n for (const f of files) { const ex = cur.files.find(x => x.path === f.path); if (ex) ex.content = f.content; else cur.files.push(f); cur.dirty.add(f.path); }\n renderTree(); updState(); state.textContent = files.length + ' file' + (files.length > 1 ? 's' : '') + ' added (unsaved)'; if (!E.autoSave) scheduleLive(); else scheduleSave();\n }\n const mimeOf = (p) => ({ png: 'image/png', jpg: 'image/jpeg', jpeg: 'image/jpeg', gif: 'image/gif', webp: 'image/webp', ico: 'image/x-icon', woff: 'font/woff', woff2: 'font/woff2', ttf: 'font/ttf', otf: 'font/otf', mp3: 'audio/mpeg', ogg: 'audio/ogg', wav: 'audio/wav', mp4: 'video/mp4', webm: 'video/webm', wasm: 'application/wasm' })[(p.split('.').pop() || '').toLowerCase()] || 'application/octet-stream';\n const tree = $('ap-tree');\n ['dragenter', 'dragover'].forEach(ev => tree.addEventListener(ev, (e) => { e.preventDefault(); tree.classList.add('drag'); }));\n ['dragleave', 'drop'].forEach(ev => tree.addEventListener(ev, (e) => { e.preventDefault(); tree.classList.remove('drag'); if (ev === 'drop' && e.dataTransfer?.files?.length) upload(e.dataTransfer.files); }));\n\n // ─── jobs strip (swarm builds) ──────────────────────────────────────────────\n const jobs = {};\n function setJobs(list) { if (list === null) { jobsEl.hidden = true; jobsEl.innerHTML = ''; for (const k in jobs) delete jobs[k]; return; } for (const j of list) jobs[j.path] = j.st; jobsEl.hidden = false; jobsEl.innerHTML = Object.entries(jobs).map(([p, s]) => '' + p.split('/').pop() + '').join(''); }\n\n // ─── composer ───────────────────────────────────────────────────────────────\n function prefill(text) { askIn.value = text; askIn.dispatchEvent(new Event('input')); askIn.focus(); askIn.setSelectionRange(askIn.value.length, askIn.value.length); }\n function askEdit() { if (cur) prefill(tpl(E.pAsk, vars())); }\n function askFix() { if (cur) prefill(tpl(E.pFix, vars())); }\n function askSelection() { if (!cur) return; const v = vars(); if (!v.selection) { state.textContent = 'select some text first'; return; } prefill(tpl(E.pSel, v)); }\n function focusPayload() { if (!cur || el.classList.contains('closed')) return null; const v = vars(); return { focus: { id: cur.id, title: cur.title, file: active || '', files: cur.files.map(f => f.path), selection: (v.selection || '').slice(0, 4000), errors: lastErrors.slice(-E.errorsToAI) } }; }\n async function send() {\n const t = askIn.value.trim(); if (!t || !cur || typeof sendWith !== 'function') return;\n const fp = focusPayload(), text = (E.pPrefix ? tpl(E.pPrefix, vars()) + '\\n' : '') + t;\n if (E.saveBeforeAsk && cur.dirty.size) { askSt.textContent = 'saving'; if (!(await save())) return; }\n askIn.value = ''; askIn.dispatchEvent(new Event('input')); askGo.disabled = true; askSt.textContent = 'sending';\n sendWith(text, fp);\n }\n askIn.addEventListener('input', () => { askIn.style.height = 'auto'; askIn.style.height = Math.min(askIn.scrollHeight, 120) + 'px'; });\n askIn.addEventListener('keydown', (e) => { if (e.key === 'Enter' && (e.ctrlKey || e.metaKey)) { e.preventDefault(); send(); } });\n document.addEventListener('omni:typing', (e) => { if (el.classList.contains('closed')) return; askSt.textContent = e.detail.on ? (e.detail.label + (e.detail.progress ? ' · ' + e.detail.progress.replace(/<[^>]+>/g, '') : '')) : ''; });\n document.addEventListener('omni:turn', (e) => {\n askGo.disabled = false; askSt.textContent = e.detail.error ? 'error' : '';\n if (el.classList.contains('closed') || !E.focusReply) return;\n const f = e.detail.final; reply.hidden = false; $('ap-reply-t').textContent = e.detail.error ? 'error' : 'reply';\n replyB.innerHTML = e.detail.error ? '' + MD.esc(e.detail.error) + '' : MD.render(f && f.reply || '');\n if (!e.detail.error && window.MD && MD.enhance) MD.enhance(replyB);\n });\n function hideReply() { reply.hidden = true; }\n\n // ─── resize + keys ──────────────────────────────────────────────────────────\n const drag = (handle, onMove) => handle.addEventListener('pointerdown', (e) => { e.preventDefault(); handle.setPointerCapture(e.pointerId); frame.style.pointerEvents = 'none'; const mv = (ev) => onMove(ev); const up = () => { handle.removeEventListener('pointermove', mv); handle.removeEventListener('pointerup', up); frame.style.pointerEvents = ''; saveE(); }; handle.addEventListener('pointermove', mv); handle.addEventListener('pointerup', up); });\n drag($('ap-resize'), (ev) => { E.width = Math.round(Math.max(30, Math.min(100, (window.innerWidth - ev.clientX) / window.innerWidth * 100))); document.documentElement.style.setProperty('--ap-w', E.width + 'vw'); });\n drag($('ap-divider'), (ev) => { const body = $('ap-body'), r = body.getBoundingClientRect(); const horiz = getComputedStyle(body).flexDirection === 'row'; let pct = horiz ? (ev.clientX - r.left) / r.width * 100 : (ev.clientY - r.top) / r.height * 100; if (E.side !== 'left') pct = 100 - pct; E.split = Math.round(Math.max(15, Math.min(85, pct))); document.documentElement.style.setProperty('--ap-split', E.split + '%'); ED.refresh(); });\n liveCb.addEventListener('change', () => { E.live = liveCb.checked; saveE(); reload(!liveCb.checked); });\n const narrow = () => el.classList.toggle('narrow', window.innerWidth < 1000); window.addEventListener('resize', () => { narrow(); ED.refresh(); }); narrow();\n document.addEventListener('keydown', (e) => {\n if (el.classList.contains('closed')) return;\n if (e.key === 'Escape') { if (!fbox.hidden) findToggle(false); else if (!setEl.classList.contains('closed')) toggleSettings(false); else if (document.activeElement !== ta && !(cm && cm.hasFocus()) && $('ap-prompt').hidden) close(); }\n else if ((e.ctrlKey || e.metaKey) && e.key === ',') { e.preventDefault(); toggleSettings(); }\n });\n\n // ─── sidebar list ───────────────────────────────────────────────────────────\n async function listForSession(session) {\n const host = $('sb-artifacts'); if (!host) return;\n try { listCache = await (await fetch('?artifacts&session=' + encodeURIComponent(session))).json();\n host.innerHTML = listCache.length ? '

artifacts

' : '';\n for (const a of listCache) { const b = document.createElement('button'); b.className = 'sb-art'; b.textContent = '#' + a.id + ' ' + a.title; b.onclick = () => open(a.id); host.appendChild(b); }\n } catch {}\n }\n applyE();\n return { open, close, restore, view, reload, save, addFile, renameFile, deleteFile, revert, copy, zip, upload, askEdit, askFix, askSelection, send, hideReply, clearConsole, hideConsole, listForSession, toggleSettings, resetPrompts, resetSettings,\n findToggle, findNext, replaceOne, replaceAll, jobs: setJobs, tpl: (k, v) => tpl(E['p' + k[0].toUpperCase() + k.slice(1)] || PDEF['p' + k[0].toUpperCase() + k.slice(1)], v), list: () => listCache, lastErrors: () => lastErrors.slice(-E.errorsToAI),\n focusPayload, settings: () => E, setSettings: (o) => { if (o && typeof o === 'object') { E = { ...DEF, ...o }; saveE(); } }, current: () => cur };\n})();\nwindow.ART = ART;\n`;\n",[221],"f7688a5e-462d-11f1-b542-42b51c65c3df","text-chunker.ts","1093f85e-462b-11f1-8725-42b51c65c3df",888,["D",1777729866332],12,"http","// ─────────────────────────────────────────────────────────────────────────────\n// CHUNK ENGINE · mobile-first · Val Town Hono/Deno\n// ─────────────────────────────────────────────────────────────────────────────\n\n// ── Constants ────────────────────────────────────────────────────────────────\n\nconst DEFAULT_CHUNK = 10_000;\nconst MAX_BOUND = 1_000_000;\n\nconst CFG = Object.freeze({\n NORMALIZE: true,\n SAFE_SLICE: true,\n HTML_ESCAPE: true,\n JSON_ESCAPE: true,\n});\n\nconst ESC: Readonly> = Object.freeze({\n \"&\": \"&\",\n \"<\": \"<\",\n \">\": \">\",\n '\"': \""\",\n \"'\": \"'\",\n});\n\n// ── Pure utilities ────────────────────────────────────────────────────────────\n\nfunction escH(s: string): string {\n return CFG.HTML_ESCAPE ? s.replace(/[&<>\"']/g, (c) => ESC[c]) : s;\n}\n\nfunction escJSON(v: unknown): string {\n return JSON.stringify(v)\n .replace(/<\\/script>/gi, \"<\\\\/script>\")\n .replace(/\n

\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;","text-chunker",[229],"0b992977-7e91-405a-8e51-7642b04aaad8",["D",1789091310842],[27],"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}",[242],"c542dd05-2729-4cf3-9664-84b7e3438d2d","router.tsx","334f4f70-7c3a-11f1-857e-1607ee4eb77e",1419,["D",1789018934885],35,"import { getCatalogStatus, getInstanceRoster, getProviderArray, type ProviderInstance } from \"./inference-provider.ts\";\nimport { initDB } from \"./db.ts\";\nimport { inflight } from \"./router-core.ts\";\nimport { bindModel, loadState, resetCooldowns, stateView } from \"./router-state.ts\";\nimport { clientAuthorized, CORS, handleChatCompletions, json } from \"./router-openai.ts\";\n\nconst OPENAI_PATHS = new Set([\"/\", \"/chat/completions\", \"/v1/chat/completions\"]);\nconst OPEN_GET = new Set([\"/\", \"/health\", \"/source\"]);\n\nasync function listUpstreamModels(p: ProviderInstance): Promise {\n const headers: Record = { ...(p.headers ?? {}) };\n if (p.key) headers.Authorization = `Bearer ${p.key}`;\n const res = await fetch(`${p.base}/models`, { headers });\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n const data = await res.json();\n return data.data || data;\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: { ...CORS, \"Access-Control-Allow-Headers\": \"*\", \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\" } });\n }\n const init = await initDB();\n if (!init.ok) return json({ error: `DB init failed: ${init.error}` }, 500);\n if (!(req.method === \"GET\" && OPEN_GET.has(url.pathname)) && !clientAuthorized(req)) {\n return json({ error: { message: \"UNAUTHORIZED: send Authorization: Bearer \" } }, 401);\n }\n\n if (req.method === \"GET\") {\n if (url.pathname === \"/source\") return new Response(null, { status: 302, headers: { Location: \"https://www.val.town/x/ziggyware/free-ai/code/router.tsx\" } });\n if (url.pathname === \"/health\") {\n await loadState();\n const live = getProviderArray();\n const s = stateView();\n return json({\n status: live.length ? \"ok\" : \"degraded\", providers_configured: live.length,\n vendors: [...new Set(live.map((p) => p.vendor))], cooling: s.cooling, dead_models: s.dead_models,\n resolved: s.resolved, caps: s.caps, caps_in: s.caps_in, inflight_requests: inflight, auth: !!Deno.env.get(\"OMNI_CLIENT_KEYS\"), key_policy: Deno.env.get(\"OMNI_KEY_POLICY\") ?? \"depth\",\n instances: getInstanceRoster().map((i) => { const c = s.cooling.find((x) => x.name === i.name); const st = s.stat[i.name]; return { ...i, cooling: c ? { reason: c.reason, ms_left: c.ms_left } : null, requests: st?.req ?? 0, ok: st?.ok ?? 0, failed: st?.fail ?? 0, last_used: st?.last ?? null, last_model: st?.model ?? null, last_error: st?.err || null }; }),\n });\n }\n if (url.pathname === \"/api/providers\") {\n await loadState();\n const s = stateView();\n return json(getCatalogStatus().map((p) => ({\n ...p, currentModel: s.bound[p.vendor] || p.models.find((m) => !s.dead_models.includes(`${p.vendor}:${m}`)) || s.resolved[p.vendor] || p.fallbackModel,\n cooling: s.cooling.filter((c) => c.name.split(\"#\")[0] === p.vendor),\n })));\n }\n if (url.pathname === \"/api/models\") {\n const pName = url.searchParams.get(\"provider\");\n const p = getProviderArray().find((x) => x.name === pName || x.vendor === pName);\n if (!p) return json({ error: \"Provider not found or no key\" }, 404);\n try { return json(await listUpstreamModels(p)); } catch (e: any) { return json({ error: e.message, fallback: p.fallbackModel }, 502); }\n }\n // OpenAI-style list: aliases, vendors, then every upstream id as \":\"\n if (url.pathname === \"/v1/models\") {\n await loadState();\n const live = getProviderArray();\n const s = stateView();\n const seen = new Set();\n const rows: Record[] = [];\n const add = (id: string, owned_by: string, extra: Record = {}) => { if (!seen.has(id)) { seen.add(id); rows.push({ id, object: \"model\", owned_by, ...extra }); } };\n for (const a of [\"auto\", \"fast\", \"coder\", \"reasoning\", \"long\", \"vision\"]) add(a, \"omni\");\n for (const p of live) add(p.vendor, p.vendor, { bound: s.bound[p.vendor] || s.resolved[p.vendor] || p.fallbackModel, slots: live.filter((x) => x.vendor === p.vendor).length });\n const lists = await Promise.all(live.filter((p) => p.slot === 0).map(async (p) => {\n try { const l = await listUpstreamModels(p); return Array.isArray(l) ? l.map((m: any) => `${p.vendor}:${typeof m === \"string\" ? m : m.id}`) : []; } catch { return []; }\n }));\n for (const id of lists.flat()) add(id, id.split(\":\")[0]);\n return json({ object: \"list\", data: rows });\n }\n return new Response(\n `\n \n \n \n \n \n Ziggyware Router Matrix\n \n \n \n \n \n \n \n

\n \n \n \n `,\n { headers: { \"Content-Type\": \"text/html\" } },\n );\n } else if (req.method === \"POST\") {\n if (url.pathname === \"/api/reset\") { // clear cooldowns: {name?: \"groq\" | \"groq#2\" | \"\"}\n const b = await req.json().catch(() => ({}));\n await loadState(true);\n return json({ ok: true, ...(await resetCooldowns(typeof b?.name === \"string\" ? b.name : \"\")) });\n }\n if (url.pathname === \"/api/update\") {\n const { provider, model } = await req.json();\n if (typeof provider !== \"string\" || typeof model !== \"string\") return json({ error: \"provider and model required\" }, 400);\n const r = await bindModel(provider.split(\"#\")[0], model);\n return r.ok ? json({ success: true }) : json({ error: r.error }, 500);\n }\n if (!OPENAI_PATHS.has(url.pathname)) return new Response(\"Not Found\", { status: 404 });\n let body: unknown;\n try { body = await req.json(); } catch { return json({ error: { message: \"Invalid JSON body\" } }, 400); }\n return await handleChatCompletions(body);\n }\n return new Response(\"Not Found\", { status: 404 });\n}\n","router",[250],"be44aeba-707a-4b92-861f-74ae75f6a109","router-state.ts","b109aa6c-ab4e-11f1-8d3d-1607ee4eb77e",1412,["D",1789018831852],7,"// Routing state that must survive isolate recycling: instance cooldowns\n// (breaker / 429 / bad key), dead model ids, auto-resolved replacements, and\n// the UI's per-vendor model binding. One SELECT per request, write-through.\nimport { all, run, sql } from \"./db.ts\";\n\nexport type Cooldown = { until: number; reason: string; fails: number };\nexport type Stat = { req: number; ok: number; fail: number; last: number; model: string; err: string };\ntype State = { cool: Record; dead: Record; resolved: Record; bound: Record; cap: Record; capin: Record; stat: Record };\n\nconst MAX_FAILS = 2;\nexport const COOL = { breaker: 25_000, rate: 60_000, auth: 3_600_000, model: 3_600_000, cap: 900_000 };\n\nlet mem: State = { cool: {}, dead: {}, resolved: {}, bound: {}, cap: {}, capin: {}, stat: {} };\nlet loadedAt = 0;\n\nexport async function loadState(force = false): Promise {\n if (!force && Date.now() - loadedAt < 2_000) return mem;\n const [st, cfg] = await Promise.all([\n all(\"omni_state\", sql`SELECT key, value FROM omni_state`),\n all(\"omni_router_config\", sql`SELECT provider, selected_model FROM omni_router_config`),\n ]);\n const next: State = { cool: {}, dead: {}, resolved: {}, bound: {}, cap: {}, capin: {}, stat: {} };\n if (st.ok) {\n for (const r of st.value as { key: string; value: string }[]) {\n const [kind, ...rest] = r.key.split(\":\");\n const id = rest.join(\":\");\n try {\n if (kind === \"cool\") next.cool[id] = JSON.parse(r.value);\n else if (kind === \"dead\") next.dead[id] = Number(r.value);\n else if (kind === \"resolved\") next.resolved[id] = r.value;\n else if (kind === \"cap\") next.cap[id] = JSON.parse(r.value);\n else if (kind === \"stat\") next.stat[id] = JSON.parse(r.value);\n else if (kind === \"capin\") next.capin[id] = JSON.parse(r.value);\n } catch { /* skip corrupt row */ }\n }\n }\n if (cfg.ok) for (const r of cfg.value as { provider: string; selected_model: string }[]) next.bound[r.provider] = r.selected_model;\n mem = next; loadedAt = Date.now();\n return mem;\n}\n\nconst put = (key: string, value: string) =>\n run(sql`INSERT INTO omni_state (key, value, ts) VALUES (${key}, ${value}, ${Date.now()})\n ON CONFLICT(key) DO UPDATE SET value = excluded.value, ts = excluded.ts`);\nconst del = (key: string) => run(sql`DELETE FROM omni_state WHERE key = ${key}`);\n\nexport const isCool = (name: string) => (mem.cool[name]?.until ?? 0) > Date.now();\nexport const isDead = (vendor: string, model: string) => (mem.dead[`${vendor}:${model}`] ?? 0) > Date.now();\n// Per-INSTANCE model death (a key's daily quota for one model). Namespaced with \"@\" because slot 0's\n// instance name equals the vendor name — without the prefix, slot 0's quota would kill the model for every slot.\nexport const isDeadOn = (instance: string, model: string) => (mem.dead[`@${instance}:${model}`] ?? 0) > Date.now();\nexport async function markDeadOn(instance: string, model: string, until: number) {\n mem.dead[`@${instance}:${model}`] = until;\n await put(`dead:@${instance}:${model}`, String(until));\n}\nexport const resolvedFor = (vendor: string) => mem.resolved[vendor];\nexport const boundFor = (vendor: string) => mem.bound[vendor];\n/** learned per-model output ceiling (from \"Limit N\" size errors), or Infinity */\nexport const capFor = (vendor: string, model: string) => { const c = mem.cap[`${vendor}:${model}`]; return c && c.until > Date.now() ? c.lim : Infinity; };\n/** learned per-model INPUT ceiling (ITPM / context) — a tier limit, so it lives 24 h */\nexport const capInFor = (vendor: string, model: string) => { const c = mem.capin[`${vendor}:${model}`] ?? mem.capin[`${vendor}:*`]; return c && c.until > Date.now() ? c.lim : Infinity; };\nexport async function setCapIn(vendor: string, model: string, lim: number) {\n mem.capin[`${vendor}:${model}`] = { lim, until: Date.now() + 24 * 3_600_000 };\n await put(`capin:${vendor}:${model}`, JSON.stringify(mem.capin[`${vendor}:${model}`]));\n}\nexport async function setCap(vendor: string, model: string, lim: number) {\n mem.cap[`${vendor}:${model}`] = { lim, until: Date.now() + COOL.cap };\n await put(`cap:${vendor}:${model}`, JSON.stringify(mem.cap[`${vendor}:${model}`]));\n}\n\n/** Transient failure: counts toward the breaker; opens after MAX_FAILS. */\nexport async function noteFailure(name: string, reason: string) {\n const c = mem.cool[name] ?? { until: 0, reason, fails: 0 };\n c.fails++; c.reason = reason;\n if (c.fails >= MAX_FAILS) { c.until = Date.now() + COOL.breaker; c.fails = 0; }\n mem.cool[name] = c;\n await put(`cool:${name}`, JSON.stringify(c));\n}\n/** Hard cooldown for a known duration (429 retry-after, 401/403 key/tier). */\nexport async function coolFor(name: string, ms: number, reason: string) {\n mem.cool[name] = { until: Date.now() + ms, reason, fails: 0 };\n await put(`cool:${name}`, JSON.stringify(mem.cool[name]));\n}\nexport async function noteSuccess(name: string) {\n if (!mem.cool[name]) return;\n delete mem.cool[name];\n await del(`cool:${name}`);\n}\n/** Per-instance counters: the only externally checkable evidence that a key slot is actually used. Written every attempt. */\nexport async function noteStat(name: string, ok: boolean, model: string, err = \"\") {\n const s = mem.stat[name] ?? { req: 0, ok: 0, fail: 0, last: 0, model: \"\", err: \"\" };\n s.req++; ok ? s.ok++ : s.fail++; s.last = Date.now(); s.model = model; s.err = ok ? \"\" : err.slice(0, 120);\n mem.stat[name] = s;\n await put(`stat:${name}`, JSON.stringify(s));\n}\nexport const statFor = (name: string): Stat | undefined => mem.stat[name];\nexport async function markDead(vendor: string, model: string, until = Date.now() + COOL.model) {\n mem.dead[`${vendor}:${model}`] = until;\n await put(`dead:${vendor}:${model}`, String(until));\n}\n/** Clear cooldowns (and per-instance model deaths) — admin reset. `name` = instance or vendor; empty = everything. */\nexport async function resetCooldowns(name = \"\") {\n const hit = (k: string) => !name || k === name || k.split(\"#\")[0] === name || k.startsWith(name + \":\");\n const cool = Object.keys(mem.cool).filter(hit), dead = Object.keys(mem.dead).filter((k) => !name || hit(k.replace(/^@/, \"\"))), resolved = Object.keys(mem.resolved).filter(hit);\n for (const k of cool) { delete mem.cool[k]; await del(`cool:${k}`); }\n for (const k of dead) { delete mem.dead[k]; await del(`dead:${k}`); }\n for (const k of resolved) { delete mem.resolved[k]; await del(`resolved:${k}`); } // a junk discovery (whisper, prompt-guard) must not survive a reset\n return { cool, dead, resolved };\n}\nexport async function setResolved(vendor: string, model: string) {\n mem.resolved[vendor] = model;\n await put(`resolved:${vendor}`, model);\n}\nexport async function bindModel(vendor: string, model: string) {\n mem.bound[vendor] = model;\n return run(sql`INSERT INTO omni_router_config (provider, selected_model) VALUES (${vendor}, ${model})\n ON CONFLICT(provider) DO UPDATE SET selected_model = excluded.selected_model`);\n}\n\nexport async function unbind(vendor: string) {\n delete mem.bound[vendor];\n return run(sql`DELETE FROM omni_router_config WHERE provider = ${vendor}`);\n}\n\n/** ms until the first of these instances stops cooling; 0 if any is free now; Infinity if none listed. */\nexport function soonestCooldown(names: string[]): number {\n const now = Date.now();\n let best = Infinity;\n for (const n of names) { const u = mem.cool[n]?.until ?? 0; if (u <= now) return 0; best = Math.min(best, u - now); }\n return best;\n}\n\n/** Snapshot for /health and the UI. */\nexport function stateView() {\n const now = Date.now();\n return {\n cooling: Object.entries(mem.cool).filter(([, c]) => c.until > now).map(([name, c]) => ({ name, reason: c.reason, ms_left: c.until - now })),\n dead_models: Object.entries(mem.dead).filter(([, t]) => t > now).map(([k]) => k),\n resolved: mem.resolved,\n bound: mem.bound,\n caps: Object.fromEntries(Object.entries(mem.cap).filter(([, c]) => c.until > now).map(([k, c]) => [k, c.lim])),\n caps_in: Object.fromEntries(Object.entries(mem.capin).filter(([, c]) => c.until > now).map(([k, c]) => [k, c.lim])),\n stat: mem.stat,\n };\n}\n",[259],"75ff0735-1d6a-47f6-8fac-ec78ab48df57","router-openai.ts","6a8c10a8-ab4d-11f1-aa95-1607ee4eb77e",1405,["D",1789017792950],5,"// OpenAI chat.completions surface. Streams are piped byte-for-byte from\n// upstream; failover happens only before the first upstream byte.\n// Client auth is opt-in: set OMNI_CLIENT_KEYS=\"k1,k2\" and callers must send\n// Authorization: Bearer . Unset ⇒ open endpoint (current behaviour).\nimport { inflight, type RouteHit, routeInference, type RouteOpts } from \"./router-core.ts\";\nimport { stateView } from \"./router-state.ts\";\n\n// OpenAI params forwarded verbatim (tools included). Reasoning models (gpt-oss, qwen3.x)\n// spend max_tokens on reasoning first — send ≥256 or reasoning_effort:\"low\".\n// Router-only params (not forwarded): omni_deadline_ms — must finish within this;\n// omni_expect_tokens — expected output length, used with vendor tps to pick a\n// model that can make the deadline (quality-first among those that fit).\nconst PASS = [\"temperature\", \"max_tokens\", \"max_completion_tokens\", \"tools\", \"tool_choice\", \"response_format\", \"reasoning_effort\", \"stop\", \"top_p\", \"seed\", \"presence_penalty\", \"frequency_penalty\", \"parallel_tool_calls\", \"user\"];\nexport const CORS = { \"Access-Control-Allow-Origin\": \"*\" };\nexport const json = (body: unknown, status = 200, extra: Record = {}) =>\n new Response(JSON.stringify(body), { status, headers: { \"Content-Type\": \"application/json\", ...CORS, ...extra } });\n\nexport function clientAuthorized(req: Request): boolean {\n const keys = (Deno.env.get(\"OMNI_CLIENT_KEYS\") ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\n if (!keys.length) return true;\n const h = req.headers.get(\"authorization\") ?? \"\";\n const tok = h.replace(/^Bearer\\s+/i, \"\").trim() || new URL(req.url).searchParams.get(\"key\") || \"\";\n return keys.includes(tok);\n}\n\nconst sanitize = (p: RouteHit[\"provider\"]) => ({ id: p.name, name: p.name, vendor: p.vendor, base: p.base, keyEnv: p.keyEnv, slot: p.slot, priority: p.priority, fallbackModel: p.fallbackModel });\n\nconst meta = (hit: RouteHit) => ({\n provider: sanitize(hit.provider), model: hit.model, latency_ms: hit.latencyMs, attempts: hit.attempts, max_tokens_sent: hit.sentMax ?? null, instance: hit.provider.name, slot: hit.provider.slot,\n inflight_requests: inflight, cooling: stateView().cooling,\n});\n\nexport async function handleChatCompletions(body: any): Promise {\n const messages = body?.messages ?? (body?.prompt ? [{ role: \"user\", content: body.prompt }] : []);\n if (!Array.isArray(messages) || !messages.length) return json({ error: { message: \"Empty message payload\" } }, 400);\n const extra: Record = {};\n for (const k of PASS) if (body[k] !== undefined && body[k] !== null) extra[k] = body[k];\n const opts: RouteOpts = { model: body.model, stream: !!body.stream, extra, deadlineMs: +body.omni_deadline_ms || undefined, expectTokens: +body.omni_expect_tokens || undefined, keyPolicy: [\"depth\", \"breadth\", \"rr\"].includes(body.omni_key_policy) ? body.omni_key_policy : undefined };\n let hit: RouteHit;\n try {\n hit = await routeInference(messages, opts);\n } catch (e: any) {\n return json({ error: { message: e.message, details: e.errors ?? null, attempts: e.attempts ?? 0 } }, e.status ?? 503);\n }\n const m = meta(hit);\n const prov = { \"X-Omni-Provider\": hit.provider.name, \"X-Omni-Model\": hit.model };\n\n if (!opts.stream) {\n const up = await hit.res.json().catch(() => ({}));\n if (!up?.choices?.[0]?.message) return json({ error: { message: \"MALFORMED_UPSTREAM\", details: [`${hit.provider.name}/${hit.model}`] } }, 502);\n return json({ ...up, model: up.model ?? hit.model, _omni_meta: m }, 200, prov);\n }\n\n const enc = new TextEncoder();\n const upstream = hit.res.body ?? new ReadableStream({ start(c) { c.close(); } });\n const out = new ReadableStream({\n async start(c) {\n c.enqueue(enc.encode(`: omni ${JSON.stringify(m)}\\n\\n`)); // SSE comment: SDKs ignore, humans can read\n const r = upstream.getReader();\n try {\n for (;;) { const { done, value } = await r.read(); if (done) break; c.enqueue(value); }\n } catch (e: any) {\n c.enqueue(enc.encode(`data: ${JSON.stringify({ error: { message: `UPSTREAM_STREAM_ABORTED: ${e.message}` } })}\\n\\ndata: [DONE]\\n\\n`));\n }\n c.close();\n },\n cancel() { hit.res.body?.cancel().catch(() => {}); },\n });\n return new Response(out, { headers: { \"Content-Type\": \"text/event-stream\", \"Cache-Control\": \"no-cache\", ...prov, ...CORS } });\n}\n",[267],"3ba4d79f-be8e-41dc-a05d-9f0d06316c50","router-discover.ts","b14c41f6-ab4e-11f1-8fec-1607ee4eb77e",1406,["D",1789017793310],1,"import type { ProviderInstance } from \"./inference-provider.ts\";\nimport { isDead } from \"./router-state.ts\";\n\nexport function headersFor(p: ProviderInstance): Record {\n const h: Record = { \"Content-Type\": \"application/json\", \"HTTP-Referer\": \"https://val.town\", \"X-Title\": \"omni\", ...p.headers };\n if (p.key) h.Authorization = `Bearer ${p.key}`;\n return h;\n}\n\n\n/** Live /models lookup → first id matching the vendor's `prefer` regex that isn't dead. */\nexport async function discover(p: ProviderInstance): Promise {\n if (!p.prefer) return null;\n try {\n const res = await fetch(`${p.base}/models`, { headers: headersFor(p) });\n if (!res.ok) return null;\n const data = await res.json();\n const ids: string[] = (data.data ?? data).map((m: any) => (typeof m === \"string\" ? m : m.id)).filter(Boolean);\n const rx = new RegExp(p.prefer, \"i\");\n // never \"discover\" non-chat endpoints: guard/moderation, ASR, TTS, embeddings, rerankers\n const JUNK = /guard|safeguard|moderat|whisper|tts|speech|embed|rerank|playai|vision-only|ocr|\\bstt\\b/i;\n return ids.find((id) => rx.test(id) && !JUNK.test(id) && !isDead(p.vendor, id)) ?? null;\n } catch { return null; }\n}\n\n",[275],"4907227b-bb37-44a0-a679-403430854931","router-core.ts","6a4ef8c6-ab4d-11f1-9c11-1607ee4eb77e",1414,["D",1789018832753],17,"import { getProviderArray, type ProviderInstance, type Resolved, resolveTargets } from \"./inference-provider.ts\";\nimport { quality } from \"./catalog.ts\";\nimport { discover } from \"./router-discover.ts\";\nimport { attempt, estimateInputTokens, type Fail, inputBound, outputLimit, shrinkMaxTokens } from \"./router-attempt.ts\";\nimport { boundFor, capFor, capInFor, COOL, coolFor, isCool, isDead, isDeadOn, loadState, markDead, markDeadOn, noteFailure, noteStat, noteSuccess, resolvedFor, setCap, setCapIn, setResolved, soonestCooldown, statFor, unbind } from \"./router-state.ts\";\n// OMNI_KEY_POLICY: \"depth\" (default) exhausts every key slot of a vendor before the next vendor;\n// \"breadth\" tries slot 0 of every vendor first, then slot 1 of every vendor, …\nconst res429 = (e: Error) => /^HTTP 429/.test(e.message);\n// …or \"rr\": spread load — the least-used slot of a vendor goes first. Per-request override: omni_key_policy.\nconst KEY_POLICY = ([\"breadth\", \"rr\"].includes(Deno.env.get(\"OMNI_KEY_POLICY\") ?? \"\") ? Deno.env.get(\"OMNI_KEY_POLICY\") : \"depth\") as \"depth\" | \"breadth\" | \"rr\";\n\nexport const MAX_CONCURRENCY = 3;\nexport const HARD_TIMEOUT_MS = 60_000;\nexport let inflight = 0;\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\nexport type { RouteOpts } from \"./router-attempt.ts\";\nimport type { RouteOpts } from \"./router-attempt.ts\";\nconst etaMs = (p: ProviderInstance, o: RouteOpts) => (p.ttft ?? 1500) + ((o.expectTokens ?? (Number(o.extra?.max_tokens) || 1000)) / (p.tps ?? 60)) * 1000;\nexport type RouteHit = { provider: ProviderInstance; model: string; latencyMs: number; res: Response; attempts: number; sentMax?: number };\nconst TOOL_SAFE = /gpt-oss|deepseek|kimi|glm|gemini|claude|gpt-5|grok|command-a|mistral/i; // reliable structured tool calls\nconst score = (id: string, boost?: RegExp, tools = false) => quality(id) + (boost?.test(id) ? 6 : 0) + (tools && TOOL_SAFE.test(id) ? 5 : 0);\n// bound (UI) model leads; then quality or catalog order; models whose learned output\n// ceiling is below the expected length go last; discovered id last of all.\nfunction candidates(p: ProviderInstance, r: Resolved, o: RouteOpts = {}): string[] {\n if (r.forcedModel) return [r.forcedModel];\n const tools = !!(o.extra?.tools as unknown[] | undefined)?.length;\n const list = r.rank === \"quality\" ? [...p.models].sort((a, b) => score(b, r.boost, tools) - score(a, r.boost, tools)) : [...p.models];\n const need = o.expectTokens ?? 0;\n const fitsCap = (m: string) => capFor(p.vendor, m) >= need;\n const ordered = [...list.filter(fitsCap), ...list.filter((m) => !fitsCap(m))];\n const seq = [boundFor(p.vendor), ...ordered, resolvedFor(p.vendor)].filter((m): m is string => !!m);\n return [...new Set(seq)].filter((m) => !isDead(p.vendor, m) && !isDeadOn(p.name, m)); // vendor-wide (404) or this key's daily quota for that model\n}\n\nexport async function routeInference(messages: unknown[], o: RouteOpts = {}): Promise {\n while (inflight >= MAX_CONCURRENCY) await sleep(10);\n inflight++;\n const errors: string[] = [];\n let attempts = 0;\n const t0 = performance.now();\n const left = () => (o.deadlineMs ?? HARD_TIMEOUT_MS) - (performance.now() - t0);\n try {\n await loadState();\n const live = getProviderArray();\n if (!live.length) throw Object.assign(new Error(\"NO_PROVIDERS_CONFIGURED\"), { status: 503 });\n const resolved = resolveTargets(o.model, live);\n const { forcedModel } = resolved;\n const inTok = estimateInputTokens(messages, o.extra);\n const tooBig = new Set(); // vendors whose tier cannot take this prompt (learned this request)\n if (!resolved.targets.length) throw Object.assign(new Error(`UNKNOWN_MODEL: ${o.model}`), { status: 404 });\n for (let round = 0; round < 3; round++) {\n if (round) {\n const wait = soonestCooldown(resolved.targets.map((p) => p.name));\n if (wait > left() - 3000) break;\n if (wait > 0) await sleep(wait + 50);\n await loadState(true);\n errors.push(`--- retry round ${round + 1}`);\n }\n let targets = resolved.targets.filter((p) => !isCool(p.name));\n // free before paid; those that can make the deadline before those that can't; then quality (auto) or latency priority (fast)\n const fits = (p: ProviderInstance) => !o.deadlineMs || etaMs(p, o) <= o.deadlineMs;\n const best = new Map(targets.map((p) => [p.name, resolved.rank === \"quality\" ? Math.max(-1, ...candidates(p, resolved, o).map((m) => score(m, resolved.boost, !!(o.extra?.tools as unknown[] | undefined)?.length))) : 0]));\n const policy = o.keyPolicy ?? KEY_POLICY;\n const used = (p: ProviderInstance) => statFor(p.name)?.req ?? 0;\n targets = [...targets].sort((a, b) => (+!!a.paid - +!!b.paid) || (+!fits(a) - +!fits(b)) || (policy === \"breadth\" ? a.slot - b.slot : 0) || best.get(b.name)! - best.get(a.name)! || a.priority - b.priority || (policy === \"rr\" ? used(a) - used(b) : 0) || a.slot - b.slot);\n for (const [idx, p] of targets.entries()) {\n if (left() < 1500) break;\n if (tooBig.has(p.vendor)) continue; // every key slot of a vendor shares the tier's prompt ceiling\n if (p.maxIn && inTok > p.maxIn) { errors.push(`${p.name}: skipped (prompt ≈${inTok} tok > maxIn ${p.maxIn})`); continue; }\n // a vendor that cannot finish in the time left is skipped while a faster one is still queued behind it\n if (o.deadlineMs && etaMs(p, o) > left() && targets.slice(idx + 1).some((q) => etaMs(q, o) <= left())) { errors.push(`${p.name}: skipped (eta ${Math.round(etaMs(p, o) / 1000)}s > ${Math.round(left() / 1000)}s left)`); continue; }\n const shrinkCount = new Map();\n const models = candidates(p, resolved, o).filter((m) => capInFor(p.vendor, m) >= inTok);\n if (!models.length && !forcedModel) { errors.push(`${p.name}: skipped (prompt ≈${inTok} tok over every model's learned input limit)`); continue; }\n let stop = false;\n for (let i = 0; i < models.length + 1 && !stop; i++) {\n const model = i < models.length ? models[i] : (forcedModel ? null : await discover(p));\n if (!model) break;\n if (i === models.length) await setResolved(p.vendor, model);\n if (left() < 1500) { errors.push(\"DEADLINE\"); stop = true; break; }\n attempts++;\n const t0 = performance.now();\n try {\n const capMax = Math.min(capFor(p.vendor, model), o.deadlineMs && !o.stream ? Math.max(512, Math.floor(((left() - (p.ttft ?? 1500)) / 1000) * (p.tps ?? 60) * 0.85)) : Infinity);\n const res = await attempt(p, model, messages, o, Math.min(HARD_TIMEOUT_MS, left()), capMax);\n await Promise.all([noteSuccess(p.name), noteStat(p.name, true, model)]);\n return { provider: p, model, latencyMs: Math.round(performance.now() - t0), res, attempts, sentMax: Number(res.headers.get(\"x-omni-sent-max\")) || Number(o.extra?.max_tokens) || undefined };\n } catch (e: any) {\n errors.push(`${p.name}/${model}: ${e.message}`);\n await noteStat(p.name, false, model, e.message);\n switch ((e as Fail).kind) {\n case \"size\": {\n const inLim = inputBound(e.message);\n if (inLim !== null) { // prompt-bound: no max_tokens shrink can help; remember the ceiling, skip the whole vendor this request\n if (inLim > 0) await setCapIn(p.vendor, model, inLim - 64);\n tooBig.add(p.vendor); errors.push(`${p.name}: prompt too large for this tier (≈${inTok} tok${inLim ? ` > ${inLim}` : \"\"}) — skipping vendor`); stop = true; break;\n }\n const lim = outputLimit(e.message); if (lim) await setCap(p.vendor, model, Math.max(256, lim - 64));\n const shrinks = (shrinkCount.get(model) ?? 0); shrinkCount.set(model, shrinks + 1);\n if (shrinks < 2 && shrinkMaxTokens(o, e.message, e.sentMax)) { i--; errors.push(`shrunk max_tokens→${o.extra!.max_tokens}`); } break;\n }\n case \"model\":\n if (forcedModel) { stop = true; break; }\n await markDead(p.vendor, model);\n if (model === boundFor(p.vendor)) await unbind(p.vendor);\n break;\n case \"rate\": await coolFor(p.name, e.retryAfterMs ?? COOL.rate, \"rate \" + e.message.slice(0, 80)); stop = true; break;\n case \"auth\": await coolFor(p.name, COOL.auth, \"auth \" + e.message.slice(0, 80)); stop = true; break;\n // quota: this KEY is spent until its reset; sibling slots (p.vendor#n) are next in `targets` under depth policy\n case \"quota\": {\n const until = Math.max(Date.now() + 60_000, (e as Fail).resetAt ?? Date.now() + 6 * 3_600_000);\n // Groq-style per-MODEL daily quota (\"Rate limit reached for model `x` … per day\"): only that model on this key is spent; try the key's other models.\n const perModel = e.message.match(/for model [`'\"]?([\\w./:-]+)/i);\n if (perModel && res429(e)) { await markDeadOn(p.name, model, until); errors.push(`${p.name}: ${model} spent until reset, trying next model`); break; }\n await coolFor(p.name, until - Date.now(), \"quota \" + e.message.slice(0, 160)); stop = true; break;\n }\n default: await noteFailure(p.name, e.message.slice(0, 60)); stop = true;\n }\n }\n }\n }\n }\n throw Object.assign(new Error(\"ALL_PROVIDERS_EXHAUSTED_OR_COOLING\"), { status: 503, errors, attempts });\n } finally { inflight--; }\n}\n",[283],"af3a53a6-1b54-4da7-8c17-821daf79bcf5","router-attempt.ts","c60156b4-abcf-11f1-b2a4-1607ee4eb77e",1413,["D",1789018832213],"import type { ProviderInstance } from \"./inference-provider.ts\";\nimport { headersFor } from \"./router-discover.ts\";\n\nexport type RouteOpts = { model?: string; stream?: boolean; extra?: Record; deadlineMs?: number; expectTokens?: number; keyPolicy?: \"depth\" | \"breadth\" | \"rr\" };\nexport type Fail = Error & { kind: \"model\" | \"rate\" | \"auth\" | \"quota\" | \"size\" | \"transient\"; retryAfterMs?: number; sentMax?: number; resetAt?: number };\nconst QUOTA = /balance|recharge|insufficient|余额|credits?|quota|billing|payment|per[ _-]day|daily|monthly|exceeded your|free.?tier|limit reached for the day|\\b[rt]pd\\b/i;\n/** When a quota-class failure heals: header epoch, \"daily\" → next UTC midnight, else re-probe in 6 h (funds/credits can be added any time). */\nexport function quotaResetAt(res: Response | null, body: string): number {\n const now = Date.now();\n const h = res?.headers.get(\"x-ratelimit-reset\") ?? res?.headers.get(\"x-ratelimit-reset-requests\") ?? \"\";\n const n = Number(h);\n if (n > 0) { const ms = n > 1e12 ? n : n > 1e9 ? n * 1000 : now + n * 1000; if (ms > now && ms < now + 36 * 3_600_000) return ms; }\n if (/per day|daily|for the day|today/i.test(body)) { const d = new Date(now); d.setUTCHours(24, 0, 0, 0); return d.getTime() + 60_000; }\n return now + 6 * 3_600_000;\n}\n// \"Limit 6000, Requested 9000\" (Groq TPM) or \"maximum context length is 8192 tokens ... requested 9000\": shrink to fit.\nexport function shrinkMaxTokens(o: RouteOpts, body: string, sent?: number): boolean {\n const cur = sent || Number(o.extra?.max_tokens);\n if (!cur || cur <= 512) return false;\n const lim = body.match(/limit[^\\d]{0,12}(\\d+)/i), req = body.match(/request(?:ed)?[^\\d]{0,12}(\\d+)/i);\n const next = lim && req ? Math.min(cur - (Number(req[1]) - Number(lim[1])) - 64, Number(lim[1]) - 64) : Math.floor(cur / 2);\n o.extra = { ...o.extra, max_tokens: Math.max(512, Math.min(next, cur - 256)) };\n return true;\n}\n/** A size error the PROMPT alone caused: shrinking max_tokens cannot fix it. Groq ITPM, context-length overflows. Returns the input limit when stated. */\nexport function inputBound(body: string): number | null {\n if (!/input tokens|ITPM|prompt tokens|context length|maximum context|too many tokens in (the )?prompt/i.test(body)) return null;\n const m = body.match(/limit[^\\d]{0,12}(\\d+)/i) ?? body.match(/context length (?:of|is) (\\d+)/i);\n return m ? Number(m[1]) : 0;\n}\n/** Rough prompt size in tokens: chars/3.6 over messages + tool schemas (vendors tokenize JSON worse than prose). */\nexport const estimateInputTokens = (messages: unknown[], extra?: Record) => Math.ceil((JSON.stringify(messages).length + (extra?.tools ? JSON.stringify(extra.tools).length : 0)) / 3.6);\n/** \"Limit N\" from a size error when it is an output ceiling (OTPM / max_tokens), else null */\nexport function outputLimit(body: string): number | null {\n if (!/output|max_tokens|completion/i.test(body)) return null;\n const m = body.match(/limit[^\\d]{0,12}(\\d+)/i) ?? body.match(/(?:less than or equal to|maximum value[^\\d]{0,30}is|at most)[^\\d]{0,6}(\\d+)/i);\n return m ? Number(m[1]) : null;\n}\n\nexport function classify(status: number, body: string): Fail[\"kind\"] {\n if ((status === 429 || status === 413 || status === 400) && /too large|too long|context length|maximum context|exceeds.*tokens|reduce.*(length|tokens)/i.test(body)) return \"size\";\n if (status === 429 && QUOTA.test(body)) return \"quota\";\n if ((status === 429 || status === 400) && /max_tokens.{0,40}(less than or equal|maximum value|must be at most)|maximum value for .max_tokens/i.test(body)) return \"size\";\n if (status === 429) return \"rate\";\n if (status === 404 || /model_not_found|invalid.model|tier_not_allowed|does not (exist|support)|not (found|exist|supported|available)|unsupported|decommissioned|deprecated|no access|unable to access/i.test(body)) return \"model\";\n if (status === 402 || ((status === 403 || status === 400) && QUOTA.test(body))) return \"quota\";\n if (status === 401 || status === 403 || /api.?key|unauthorized|invalid.?token/i.test(body)) return \"auth\";\n return \"transient\";\n}\n\n// timeoutMs covers headers AND (non-stream) body: a slow vendor streaming a long\n// completion past the deadline is the failure mode that killed 60 s turns.\n// capMax: the largest completion this vendor can stream before the deadline; a\n// truncated answer (finish_reason \"length\") beats a timeout — the caller continues it.\nexport async function attempt(p: ProviderInstance, model: string, messages: unknown[], o: RouteOpts, timeoutMs: number, capMax = Infinity): Promise {\n const payload: Record = { ...o.extra, model, messages, stream: !!o.stream };\n const cap = Math.min(p.maxOut ?? Infinity, capMax);\n if (Number(payload.max_tokens) > cap) payload.max_tokens = cap;\n const ctl = new AbortController();\n const timer = setTimeout(() => ctl.abort(), timeoutMs);\n const abortP = new Promise((_, rej) => ctl.signal.addEventListener(\"abort\", () => rej(Object.assign(new Error(\"TIMEOUT\"), { kind: \"transient\" }))));\n try {\n const res = await Promise.race([fetch(`${p.base}/chat/completions`, { method: \"POST\", headers: headersFor(p), body: JSON.stringify(payload), signal: ctl.signal }), abortP]);\n if (res.ok) {\n if (o.stream) return res;\n const text = await Promise.race([res.text(), abortP]).catch((e) => { res.body?.cancel().catch(() => {}); throw e; });\n return new Response(text, { status: res.status, headers: { \"content-type\": res.headers.get(\"content-type\") ?? \"application/json\", \"x-omni-sent-max\": String(payload.max_tokens ?? \"\") } });\n }\n const body = await res.text().catch(() => \"\");\n const e = new Error(`HTTP ${res.status}: ${body.slice(0, 500)}`) as Fail;\n e.kind = classify(res.status, body);\n // 429 with \"remaining: 0\" and a reset far away is a quota even when the body says nothing useful (OpenRouter free-models-per-day)\n if (e.kind === \"rate\" && res.headers.get(\"x-ratelimit-remaining\") === \"0\") { const at = quotaResetAt(res, body); if (at - Date.now() > 5 * 60_000) e.kind = \"quota\"; }\n e.sentMax = Number(payload.max_tokens) || undefined;\n const ra = Number(res.headers.get(\"retry-after\")) || Number((body.match(/try again in\\s*([\\d.]+)\\s*s/i) ?? [])[1]) || 0;\n if (e.kind === \"rate\" && ra > 0) e.retryAfterMs = Math.min(Math.ceil(ra * 1000) + 500, 15 * 60_000);\n if (e.kind === \"quota\") e.resetAt = quotaResetAt(res, body);\n throw e;\n } catch (e: any) {\n if (!e.kind) { e.kind = \"transient\"; e.message = e.name === \"AbortError\" ? \"TIMEOUT\" : `NETWORK: ${e.message}`; }\n ctl.abort();\n throw e;\n } finally { clearTimeout(timer); }\n}\n\n",[291],"907e461a-ab53-4642-a09e-fdbb24410980","rate-limit-tracker.ts","2ed0f30a-aae2-11f1-ad3f-1607ee4eb77e",1219,["D",1788802411124],3,"// rate-limit-tracker.ts — ~800 chars\ninterface RateLimitState {\n dailyRequests: Record; // model → request count\n resetTime: Record; // model → unix timestamp (ms)\n}\n\nexport class RateLimitTracker {\n private state: RateLimitState = {\n dailyRequests: {},\n resetTime: {},\n };\n\n canRequest(model: string, limit: number): boolean {\n const now = Date.now();\n const resetAt = this.state.resetTime[model] ?? 0;\n\n if (now >= resetAt) {\n // Day boundary crossed → reset\n this.state.dailyRequests[model] = 0;\n this.state.resetTime[model] = now + 86400000; // +1 day\n }\n\n const current = this.state.dailyRequests[model] ?? 0;\n return current < limit;\n }\n\n recordRequest(model: string) {\n this.state.dailyRequests[model] = (this.state.dailyRequests[model] ?? 0) +\n 1;\n }\n\n remaining(model: string, limit: number): number {\n return Math.max(0, limit - (this.state.dailyRequests[model] ?? 0));\n }\n}",[298],"15bc3b1e-52c4-4748-8a24-f5c9d6a26083","prompts.ts","2f259634-abe2-11f1-966c-1607ee4eb77e",1431,["D",1789091310300],"// Every prompt the app sends, in one place. Each is a template with {{vars}};\n// users override any of them per request (settings.prompts[key]) and the UI\n// fetches this table from GET ?prompts to show defaults + placeholders.\nexport type PromptKey = \"system\" | \"meta\" | \"firstExchange\" | \"plan\" | \"reconcile\" | \"critique\" | \"revise\" | \"reground\" | \"continue\" | \"summarize\" | \"workbench\" | \"skill\" | \"architect\" | \"builder\" | \"integrate\" | \"digest\" | \"completion\";\n\nexport const PROMPT_VARS: Record = {\n system: [\"date\", \"tools\", \"skills\", \"focus\", \"memory\", \"rojs\", \"user\"],\n meta: [\"open\", \"close\"],\n firstExchange: [],\n plan: [],\n reconcile: [\"drafts\"],\n critique: [\"question\", \"answer\"],\n revise: [\"question\", \"answer\", \"flaw\"],\n reground: [\"question\"],\n continue: [],\n summarize: [],\n workbench: [\"id\", \"title\", \"files\", \"file\", \"selection\", \"errors\"],\n skill: [\"name\", \"body\"],\n architect: [\"ask\", \"user\", \"skills\"],\n builder: [\"title\", \"path\", \"purpose\", \"exports\", \"imports\", \"shared\", \"manifest\", \"notes\"],\n integrate: [\"id\", \"issues\"],\n digest: [\"ask\", \"part\", \"n\", \"text\"],\n completion: [\"ask\", \"did\", \"reply\"],\n};\n\nexport const DEFAULT_PROMPTS: Record = {\n system: `You are OMNI: a principal-level engineer, analyst and writer acting as an agent. Date {{date}}. Tools available this turn: {{tools}}.\n\nDoctrine\n1. Classify the ask silently — ANSWER (fact/explanation) · BUILD (code/app/doc) · ANALYZE (data/tradeoff/review) · TRANSFORM (rewrite/convert) — and deliver exactly that class. Never print the class label. No restating the question, no preamble, no closing offers, no \"certainly\".\n2. Density: every sentence load-bearing. Numbers carry units and provenance. Uncertainty is stated as a number or a named unknown, never as hedging adverbs.\n3. Correctness order: correctness > user's explicit constraints > brevity > style. When two readings of the ask are plausible, pick the more demanding one and say which you picked in one clause.\n4. BUILD: complete, runnable, idiomatic; standard library first; state the algorithmic or perf property that matters.\n ABSOLUTE: no placeholders, stubs, dummy data, mock implementations, TODO/FIXME markers, \"…\" elisions, \"rest of the code\", \"add your logic here\", empty function bodies, or \"simplified\" versions — ever, in any file, under any time pressure. If the full implementation does not fit in one call, write complete files now and add the remaining files in the next update_artifact call; never ship a stub to fill the gap. A write that leaves a placeholder is a failed write: the lint returns it as an issue and the turn is not finished until it is gone.\n Virtuoso standard: you are the strongest engineer on this project — architecture, algorithms, numerical care, rendering, audio, networking, security, accessibility, performance, error handling, UX copy. Every subsystem you touch is production-grade: real state machines not flags, real error paths not console.log, real math (units, precision, edge cases), real input handling (keyboard + pointer + resize), real persistence with versioned schemas. Choose the design a principal engineer would defend in review, and implement it fully. Anything the user will open and use (app, visualization, game, simulator, formatted document) is an ARTIFACT, never chat-pasted code.\n Artifact model — a project of files: \\`content\\` = entry index.html; \\`files\\` = siblings referenced by RELATIVE path (\n \n \n \n \n\n`;\n",[355],"fefa6f1c-e2c2-451a-8699-878655f4fb5f","inference-provider.ts","f5b23648-43b6-11f1-91e9-42b51c65c3df",1407,["D",1789017793755],51,"// Instances = vendor × key. Keys per vendor come from every one of:\n// , 1 … 9 (numbered slots)\n// comma-separated values inside any of those (\"k1,k2,k3\")\n// so N accounts at one vendor = N instances, each with its own breaker/cooldown.\n// OMNI_PROVIDERS: JSON array of Vendor rows merged by `vendor` (add or override).\n// OMNI_DISABLE: comma list of vendors to skip.\nimport { CATALOG, type Vendor } from \"./catalog.ts\";\n\nexport type ProviderInstance = Vendor & {\n name: string; // \"\" or \"#\"\n slot: number;\n key: string | null;\n keyEnv: string | null; // resolved env name for this slot\n fallbackModel: string;\n};\n\nconst KEY_SLOTS = 10;\nconst MAX_KEYS = 10; // per vendor, after slot expansion + comma split\nconst validKey = (k: string) => /^[\\x21-\\x7e]{8,}$/.test(k); // header-safe ASCII, no whitespace\nconst interp = (s: string) => s.replace(/\\$\\{(\\w+)\\}/g, (m, v) => Deno.env.get(v) ?? m); // unresolved stays, row dropped below\n\nlet cache: { vendors: Vendor[]; at: number } | null = null;\nexport const invalidateVendors = () => { cache = null; };\nexport function getVendors(): Vendor[] {\n if (cache && Date.now() - cache.at < 60_000) return cache.vendors;\n const byVendor = new Map(CATALOG.map((v) => [v.vendor, { ...v }]));\n try {\n const extra = JSON.parse(Deno.env.get(\"OMNI_PROVIDERS\") ?? \"[]\") as Partial[];\n for (const e of extra) {\n if (!e.vendor) continue;\n byVendor.set(e.vendor, { ...(byVendor.get(e.vendor) ?? { base: \"\", keyEnv: null, models: [], priority: 50 }), ...e } as Vendor);\n }\n } catch (e) { console.warn(\"OMNI_PROVIDERS unparsable:\", e); }\n const disabled = new Set((Deno.env.get(\"OMNI_DISABLE\") ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean));\n const vendors = [...byVendor.values()].filter((v) => !disabled.has(v.vendor) && v.base && v.models.length)\n .map((v) => ({ ...v, base: interp(v.base).replace(/\\/$/, \"\") }))\n .filter((v) => !/\\$\\{/.test(v.base))\n .sort((a, b) => a.priority - b.priority);\n cache = { vendors, at: Date.now() };\n return vendors;\n}\n\nfunction keysFor(v: Vendor): { keyEnv: string; key: string }[] {\n if (!v.keyEnv) return [];\n const out: { keyEnv: string; key: string }[] = [];\n for (let i = 0; i < KEY_SLOTS; i++) {\n const env = v.keyEnv + (i ? String(i) : \"\");\n for (const key of (Deno.env.get(env) ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean)) {\n if (validKey(key)) out.push({ keyEnv: env, key });\n else console.warn(`[omni] ${env}: skipping malformed key (${key.length} chars)`);\n }\n }\n return out.slice(0, MAX_KEYS);\n}\n\nexport function getProviderArray(): ProviderInstance[] {\n const out: ProviderInstance[] = [];\n for (const v of getVendors()) {\n const mk = (slot: number, keyEnv: string | null, key: string | null): ProviderInstance =>\n ({ ...v, name: slot ? `${v.vendor}#${slot}` : v.vendor, slot, keyEnv, key, fallbackModel: v.models[0] });\n if (!v.keyEnv) { out.push(mk(0, null, null)); continue; }\n keysFor(v).forEach((k, i) => out.push(mk(i, k.keyEnv, k.key)));\n }\n return out;\n}\n\n/** One row per vendor×key instance for /health; key shown as env name + last 4 chars only. */\nexport function getInstanceRoster() {\n return getProviderArray().map((p) => ({ name: p.name, vendor: p.vendor, slot: p.slot, keyEnv: p.keyEnv, key: p.key ? \"…\" + p.key.slice(-4) : null, paid: !!p.paid }));\n}\n/** Status rows for UI/health; never carries key material. */\nexport function getCatalogStatus() {\n const live = getProviderArray();\n return getVendors().map((v) => ({\n ...v, name: v.vendor, fallbackModel: v.models[0],\n hasKey: !v.keyEnv || live.some((i) => i.vendor === v.vendor),\n keySlots: live.filter((i) => i.vendor === v.vendor).length,\n }));\n}\n\n/** Request `model` →\n * \"\"|\"auto\"|\"best\" every instance, best model quality first (see catalog QUALITY)\n * \"fast\" every instance, vendor priority (latency) order\n * \"coder\"|\"reasoning\"|\"fast\"|\"long\"|\"vision\" instances whose vendor carries the tag, then the rest\n * \"\" that vendor's instances; \"#n\" one instance\n * \":\" that vendor, forced upstream id\n * \"/\" same as above (OpenRouter-style spelling)\n * unknown → [] */\nexport type Rank = \"quality\" | \"priority\";\nexport type Resolved = { targets: ProviderInstance[]; forcedModel: string | null; rank: Rank; boost?: RegExp };\nexport function resolveTargets(requested: string | undefined, live: ProviderInstance[]): Resolved {\n const none: Resolved = { targets: [], forcedModel: null, rank: \"priority\" };\n if (!requested || requested === \"auto\" || requested === \"best\") return { targets: live, forcedModel: null, rank: \"quality\" };\n if (requested === \"fast\") return { targets: live, forcedModel: null, rank: \"priority\" };\n if (/^(coder|reasoning|long|vision)$/.test(requested)) {\n const tagged = live.filter((p) => p.tags?.includes(requested));\n return { targets: [...tagged, ...live.filter((p) => !tagged.includes(p))], forcedModel: null, rank: \"quality\", boost: requested === \"coder\" ? /coder|code/i : undefined };\n }\n const exact = live.filter((p) => p.name === requested || p.vendor === requested);\n if (exact.length) return { targets: exact, forcedModel: null, rank: \"quality\" };\n const m = requested.match(/^([a-z0-9_-]+)[:/](.+)$/i);\n if (!m) return none;\n const byVendor = live.filter((p) => p.vendor === m[1]);\n return byVendor.length ? { targets: byVendor, forcedModel: m[2], rank: \"priority\" } : none;\n}\n",[363],"0c0046ad-a6f3-45ad-89ff-bde11a1ca235","deploy.py","e2ad6848-ad82-11f1-8b30-1607ee4eb77e",1427,["D",1789091308535],"#!/usr/bin/env python3\n\"\"\"Deploy files to the free-ai val. Pure Python, UTF-8 throughout, body sent from memory (no shell arg limits).\nusage: set VT= (Windows) / export VT= (bash)\n python deploy.py app/*.ts app/*.tsx # or any list of files; order is preserved\n python deploy.py --verify app/app.tsx # GET back and compare\nExit code = number of files that failed.\"\"\"\nimport json, os, sys, urllib.request, urllib.error, glob\n\nVAL = \"1a430fbe-418c-11f1-af64-42b51c65c3df\"\nAPI = f\"https://api.val.town/v2/vals/{VAL}/files\"\nTOKEN = os.environ.get(\"VT\", \"\").strip()\nif not TOKEN:\n sys.exit(\"VT is not set (set VT=vtwn_... / export VT=vtwn_...)\")\n\ndef call(method, url, body=None):\n data = json.dumps(body).encode(\"utf-8\") if body is not None else None\n req = urllib.request.Request(url, data=data, method=method, headers={\n \"Authorization\": f\"Bearer {TOKEN}\", \"content-type\": \"application/json\", \"accept\": \"application/json\"})\n try:\n with urllib.request.urlopen(req, timeout=60) as r:\n return r.status, r.read().decode(\"utf-8\", \"replace\")\n except urllib.error.HTTPError as e:\n return e.code, e.read().decode(\"utf-8\", \"replace\")\n\ndef put(path):\n name = os.path.basename(path)\n with open(path, encoding=\"utf-8\") as f:\n content = f.read()\n n = len(content)\n if n > 80000:\n print(f\"{name}: {n} chars > 80000 — Val Town rejects it; split the file\"); return False\n code, out = call(\"PUT\", f\"{API}?path={name}\", {\"content\": content})\n if code == 404:\n code, out = call(\"POST\", f\"{API}?path={name}\", {\"content\": content, \"type\": \"script\"})\n ok = 200 <= code < 300\n print(f\"{name} ({n} chars) -> {code} {'' if ok else out[:200]}\")\n return ok\n\ndef verify(path):\n name = os.path.basename(path)\n code, out = call(\"GET\", f\"{API}?path={name}&limit=1\")\n if code != 200:\n print(f\"{name}: GET {code} {out[:120]}\"); return False\n ok = False\n try:\n data = json.loads(out)\n items = data.get(\"data\", data) if isinstance(data, dict) else data\n link = None\n for it in items if isinstance(items, list) else []:\n if it.get(\"path\") == name: link = it.get(\"links\", {}).get(\"module\"); break\n if link:\n with urllib.request.urlopen(link, timeout=60) as r: remote = r.read().decode(\"utf-8\")\n with open(path, encoding=\"utf-8\") as f: local = f.read()\n ok = remote.strip() == local.strip()\n print(f\"{name}: remote {len(remote)} chars, local {len(local)} — {'MATCH' if ok else 'DIFFERENT'}\")\n else:\n print(f\"{name}: not found in val file list\")\n except Exception as e:\n print(f\"{name}: verify failed — {e}\")\n return ok\n\nargs = sys.argv[1:]\nmode = verify if args and args[0] == \"--verify\" else put\nif mode is verify: args = args[1:]\nfiles = [p for a in args for p in (glob.glob(a) or [a])]\n# app-helpers.ts must exist before app.tsx imports it: deploy helpers first when both are listed\nfiles.sort(key=lambda p: 0 if p.endswith(\"app-helpers.ts\") else 1 if not p.endswith(\"app.tsx\") else 2)\nif not files: sys.exit(\"no files given\")\nfails = sum(0 if mode(p) else 1 for p in files)\nprint(f\"{len(files) - fails}/{len(files)} ok\")\nsys.exit(fails)\n",[371],"20feeac4-d28f-472a-b0b3-91f1b78e6a48","db.ts","0b4ab11c-43c9-11f1-8043-42b51c65c3df",1381,["D",1789001806726],66,"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 model: 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 message_meta: { message_id: number; meta: string };\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 omni_state: { key: string; value: string; ts: number }; // router cooldowns / dead models / resolved ids\n progress: { session: string; events: string; ts: number }; // live turn progress, polled by the chat UI\n artifact_file: { artifact_id: number; path: string; content: string; ts: number }; // multi-file artifacts; index.html mirrors artifact.content\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, model TEXT NOT NULL,\n keyEnv 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 message_meta: `CREATE TABLE IF NOT EXISTS message_meta (\n message_id INTEGER PRIMARY KEY REFERENCES message(id) ON DELETE CASCADE, meta TEXT NOT NULL)`,\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 omni_state: `CREATE TABLE IF NOT EXISTS omni_state (\n key TEXT PRIMARY KEY, value TEXT NOT NULL, ts INTEGER NOT NULL)`,\n progress: `CREATE TABLE IF NOT EXISTS progress (\n session TEXT PRIMARY KEY, events TEXT NOT NULL, ts INTEGER NOT NULL)`,\n artifact_file: `CREATE TABLE IF NOT EXISTS artifact_file (\n artifact_id INTEGER NOT NULL REFERENCES artifact(id), path TEXT NOT NULL, content TEXT NOT NULL, ts INTEGER NOT NULL,\n PRIMARY KEY(artifact_id, path))`,\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\n// unwrap(r) → value | null; unwrap(r, fallback) → value | fallback. The old signature\n// dropped the fallback, so every `unwrap(x, [])` caller got null on a DB error and\n// then crashed on `.map` — a latent bug the types were hiding.\nfunction unwrap(r: Result): T | null;\nfunction unwrap(r: Result, fallback: T): T;\nfunction unwrap(r: Result, fallback?: T): T | null {\n return r.ok ? r.value : (fallback === undefined ? null : 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\n if (first.ok === false) {\n if (first.error === \"QUOTA_EXCEEDED\") {\n const pruned = await pruneSession(m.session, 100);\n return pruned.ok ? insertMessage(m) : pruned;\n }\n }\n return first;\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};",[378],"f8bca865-5d85-4915-8172-61ec0a2caa65","catalog.ts","b04a98e8-ab4e-11f1-a8c4-1607ee4eb77e",1410,["D",1789018830497],"// Vendor catalog. One row per OpenAI-compatible endpoint. `models` is the\n// ordered fallback list; `prefer` picks a replacement from the vendor's live\n// /models when every listed id 404s. `${ENV}` in `base` is interpolated.\n// Override/extend at runtime with OMNI_PROVIDERS (JSON array, merged by vendor)\n// and OMNI_DISABLE (comma list of vendors). Priority: lower = tried first;\n// 0–19 free & fast, 20–39 free & slow/quota'd, 40+ paid last resort.\nexport type Vendor = {\n vendor: string;\n base: string;\n keyEnv: string | null;\n models: string[];\n prefer?: string; // regex source, case-insensitive\n priority: number;\n tags?: string[]; // coder | reasoning | fast | long | vision\n headers?: Record;\n paid?: boolean; // paid vendors rank after every free one in `auto`, whatever their quality\n tps?: number; // measured/estimated output tokens per second (default 60)\n ttft?: number; // typical ms to first token (default 1500)\n maxOut?: number; // clamp for max_tokens: free tiers meter prompt+max_tokens per minute (Groq TPM 8000)\n maxIn?: number; // largest prompt (tokens) the free tier accepts per request; prompts above it skip the vendor without a wasted call\n};\n\nimport { FREE } from \"./catalog-free.ts\";\nimport { PAID } from \"./catalog-paid.ts\";\nexport const CATALOG: Vendor[] = [...FREE, ...PAID];\n\n// Quality prior per upstream model id (0–100). Drives `auto`/`best` ordering:\n// higher first across vendors, then vendor priority as tie-break. Editorial,\n// dated 2026-09; override any row via OMNI_QUALITY='{\"regex\":score,…}'.\nconst QUALITY: [RegExp, number][] = [\n [/deepseek-v4-pro/i, 95], [/kimi-k3/i, 94], [/qwen3\\.8-2\\.4t/i, 93], [/glm-5\\.3(?!-flash)/i, 92], [/nemotron-3-ultra/i, 90],\n [/deepseek-v4-flash/i, 88], [/minimax-m3/i, 86], [/qwen3-coder-next|qwen3-coder-plus/i, 86], [/qwen[-.]?3\\.8-27b/i, 85],\n [/glm-5\\.3-flash|glm-5-turbo/i, 84], [/nemotron-3-super/i, 84], [/deepseek-v3\\.2/i, 84], [/kimi-k2/i, 83], [/gpt-oss-120b/i, 82],\n [/gemini-2\\.5-flash(?!-lite)/i, 80], [/gemma-4-31b/i, 80], [/qwen3\\.6|qwen3\\.7/i, 78], [/nemotron-3\\.5-lightning/i, 76],\n [/gemini-2\\.5-flash-lite/i, 74], [/glm-4\\.5-air|glm-4\\.7/i, 72], [/mistral-small/i, 72], [/command-a/i, 72], [/qwen3-30b|qwen3-32b/i, 72],\n [/llama-3\\.3-70b|llama-3_3-70b/i, 70], [/gpt-oss-20b/i, 70], [/nemotron-70b|nemotron-51b/i, 68], [/qwen3-14b/i, 65], [/ministral-14b/i, 62],\n [/qwen3-8b/i, 55], [/ministral-8b|llama-3\\.1-8b/i, 50], [/gpt-5-mini/i, 88], [/claude-sonnet/i, 92], [/claude-haiku/i, 84], [/deepseek-chat|deepseek-reasoner/i, 90], [/grok-4/i, 88],\n];\nlet override: [RegExp, number][] | null = null;\nexport function quality(id: string): number {\n if (override === null) {\n override = [];\n try { for (const [k, v] of Object.entries(JSON.parse(Deno.env.get(\"OMNI_QUALITY\") ?? \"{}\"))) override.push([new RegExp(k, \"i\"), Number(v)]); } catch { /* ignore */ }\n }\n for (const [rx, q] of override) if (rx.test(id)) return q;\n for (const [rx, q] of QUALITY) if (rx.test(id)) return q;\n return 40;\n}\n",[386],"c92e54af-69da-4df3-8c7b-020c237004bb","catalog-paid.ts","b0d2b336-ab4e-11f1-a8c4-1607ee4eb77e",1292,["D",1788892849316],"import type { Vendor } from \"./catalog.ts\";\n// Paid — last resort, only routed when a key is present.\nexport const PAID: Vendor[] = [\n { paid: true, vendor: \"deepseek\", base: \"https://api.deepseek.com/v1\", keyEnv: \"DEEPSEEK_API_KEY\", priority: 40, tags: [\"coder\", \"reasoning\"], models: [\"deepseek-chat\", \"deepseek-reasoner\"] },\n { paid: true, vendor: \"moonshot\", base: \"https://api.moonshot.ai/v1\", keyEnv: \"MOONSHOT_API_KEY\", priority: 41, tags: [\"coder\", \"long\"], models: [\"kimi-k2-turbo-preview\", \"kimi-k2-0905-preview\"], prefer: \"kimi\" },\n { paid: true, vendor: \"xai\", base: \"https://api.x.ai/v1\", keyEnv: \"XAI_API_KEY\", priority: 42, tags: [\"reasoning\"], models: [\"grok-4-fast-non-reasoning\", \"grok-4-fast-reasoning\"], prefer: \"grok.*fast\" },\n { paid: true, vendor: \"openai\", base: \"https://api.openai.com/v1\", keyEnv: \"OPENAI_API_KEY\", priority: 43, tags: [\"coder\", \"reasoning\", \"vision\"], models: [\"gpt-5-mini\", \"gpt-4.1-mini\"], prefer: \"gpt-5-mini|gpt-4.1-mini\" },\n { paid: true, vendor: \"anthropic\", base: \"https://api.anthropic.com/v1\", keyEnv: \"ANTHROPIC_API_KEY\", priority: 44, tags: [\"coder\", \"reasoning\", \"vision\"], models: [\"claude-sonnet-4-5\", \"claude-haiku-4-5\"], prefer: \"haiku|sonnet\" },\n];\n",[393],"f72290df-4d4b-4b00-b823-5a2128af5ba9","catalog-free.ts","b08f5190-ab4e-11f1-b3f3-1607ee4eb77e",1411,["D",1789018831358],"import type { Vendor } from \"./catalog.ts\";\n// Free tiers, priority 0–19 = latency order (used by `fast`); `auto` ranks by QUALITY instead.\nexport const FREE: Vendor[] = [\n { vendor: \"groq\", tps: 400, maxOut: 5500, maxIn: 6500, base: \"https://api.groq.com/openai/v1\", keyEnv: \"GROQ_API_KEY\", priority: 0, tags: [\"fast\"],\n models: [\"qwen/qwen3.8-27b\", \"openai/gpt-oss-120b\", \"openai/gpt-oss-20b\"], prefer: \"gpt-oss|qwen|llama\" },\n { vendor: \"cerebras\", tps: 1200, maxOut: 8000, base: \"https://api.cerebras.ai/v1\", keyEnv: \"CEREBRAS_API_KEY\", priority: 1, tags: [\"fast\"],\n models: [\"qwen-3.8-27b\", \"gpt-oss-120b\", \"gemma-4-31b\"], prefer: \"gpt-oss|qwen|llama\" },\n { vendor: \"sambanova\", tps: 300, base: \"https://api.sambanova.ai/v1\", keyEnv: \"SAMBANOVA_API_KEY\", priority: 2, tags: [\"fast\", \"reasoning\"],\n models: [\"MiniMax-M3\", \"DeepSeek-V3.2\", \"gpt-oss-120b\", \"Meta-Llama-3.3-70B-Instruct\"], prefer: \"minimax|deepseek|gpt-oss|llama\" },\n { vendor: \"openrouter\", tps: 30, ttft: 4000, base: \"https://openrouter.ai/api/v1\", keyEnv: \"OPENROUTER_API_KEY\", priority: 3, tags: [\"coder\", \"reasoning\", \"long\"],\n models: [\"nvidia/nemotron-3-ultra-550b-a55b:free\", \"nvidia/nemotron-3-super-120b-a12b:free\", \"google/gemma-4-31b-it:free\", \"nvidia/nemotron-3.5-lightning:free\", \"thinkingmachines/inkling:free\"],\n prefer: \":free$\" },\n { vendor: \"huggingface\", tps: 50, base: \"https://router.huggingface.co/v1\", keyEnv: \"HF_TOKEN\", priority: 4, tags: [\"coder\", \"reasoning\", \"long\"],\n models: [\"deepseek-ai/DeepSeek-V4-Pro\", \"moonshotai/Kimi-K3\", \"zai-org/GLM-5.3\", \"deepseek-ai/DeepSeek-V4-Flash\", \"Qwen/Qwen3-Coder-Next\", \"Qwen/Qwen3.8-27B\", \"openai/gpt-oss-120b\", \"zai-org/GLM-5.3-Flash\"], prefer: \"deepseek|kimi|glm|qwen|gpt-oss\" },\n { vendor: \"gemini\", tps: 150, base: \"https://generativelanguage.googleapis.com/v1beta/openai\", keyEnv: \"GEMINI_API_KEY\", priority: 5, tags: [\"fast\", \"long\", \"vision\"],\n models: [\"gemini-2.5-flash-lite\", \"gemini-2.5-flash\", \"gemini-2.0-flash\"], prefer: \"flash\" },\n { vendor: \"mistral\", tps: 80, base: \"https://api.mistral.ai/v1\", keyEnv: \"MISTRAL_API_KEY\", priority: 6, tags: [\"coder\"],\n models: [\"mistral-small-latest\", \"ministral-14b-latest\", \"ministral-8b-latest\", \"devstral-small-latest\"], prefer: \"mistral-small|ministral\" },\n { vendor: \"nvidia_nim\", tps: 40, base: \"https://integrate.api.nvidia.com/v1\", keyEnv: \"NVIDIA_API_KEY\", priority: 20, tags: [\"reasoning\"],\n models: [\"nvidia/llama-3.1-nemotron-51b-instruct\", \"mistralai/mistral-nemotron\", \"meta/llama-3.2-90b-vision-instruct\"], prefer: \"nemotron-(51|70)b|mistral-nemotron\" },\n { vendor: \"zai\", base: \"https://open.bigmodel.cn/api/paas/v4\", keyEnv: \"ZAI_API_KEY\", priority: 8, tags: [\"coder\"],\n models: [\"glm-5.3-flash\", \"glm-4.5-air\", \"glm-5-turbo\"], prefer: \"flash|air\" },\n { vendor: \"cohere\", base: \"https://api.cohere.ai/compatibility/v1\", keyEnv: \"COHERE_API_KEY\", priority: 9,\n models: [\"command-a-03-2025\", \"command-r7b-12-2024\", \"command-r-plus\"], prefer: \"command\" },\n { vendor: \"cloudflare\", tps: 100, base: \"https://api.cloudflare.com/client/v4/accounts/${CF_ACCOUNT_ID}/ai/v1\", keyEnv: \"CF_AI_TOKEN\", priority: 10, tags: [\"fast\"],\n models: [\"@cf/openai/gpt-oss-120b\", \"@cf/meta/llama-3.3-70b-instruct-fp8-fast\", \"@cf/qwen/qwen3-30b-a3b-fp8\"], prefer: \"gpt-oss|llama-3.3|qwen\" },\n { vendor: \"together\", tps: 80, base: \"https://api.together.xyz/v1\", keyEnv: \"TOGETHER_API_KEY\", priority: 11,\n models: [\"openai/gpt-oss-20b\", \"Qwen/Qwen3-14B\", \"meta-llama/Llama-3.3-70B-Instruct\", \"openai/gpt-oss-120b\"], prefer: \"gpt-oss-20b|qwen3-14b|llama-3.3-70b-instruct$\" },\n { vendor: \"siliconflow\", base: \"https://api.siliconflow.cn/v1\", keyEnv: \"SILICONFLOW_API_KEY\", priority: 12,\n models: [\"Qwen/Qwen3-8B\", \"THUDM/GLM-4-9B-0414\"], prefer: \"qwen3-8b|glm\" },\n { vendor: \"ovh\", base: \"https://oai.endpoints.kepler.ai.cloud.ovh.net/v1\", keyEnv: \"OVH_AI_ENDPOINTS_ACCESS_TOKEN\", priority: 13,\n models: [\"Meta-Llama-3_3-70B-Instruct\", \"gpt-oss-120b\", \"Qwen3-32B\"], prefer: \"llama|gpt-oss|qwen\" },\n { vendor: \"chutes\", base: \"https://llm.chutes.ai/v1\", keyEnv: \"CHUTES_API_KEY\", priority: 14,\n models: [\"openai/gpt-oss-120b\", \"Qwen/Qwen3-235B-A22B-Instruct-2507\"], prefer: \"gpt-oss|qwen\" },\n { vendor: \"novita\", base: \"https://api.novita.ai/v3/openai\", keyEnv: \"NOVITA_API_KEY\", priority: 15,\n models: [\"openai/gpt-oss-120b\", \"meta-llama/llama-3.3-70b-instruct\"], prefer: \"gpt-oss|llama-3.3\" },\n { vendor: \"hyperbolic\", base: \"https://api.hyperbolic.xyz/v1\", keyEnv: \"HYPERBOLIC_API_KEY\", priority: 16,\n models: [\"openai/gpt-oss-120b\", \"meta-llama/Llama-3.3-70B-Instruct\"], prefer: \"gpt-oss|llama-3.3\" },\n { vendor: \"dashscope\", base: \"https://dashscope-intl.aliyuncs.com/compatible-mode/v1\", keyEnv: \"DASHSCOPE_API_KEY\", priority: 17, tags: [\"coder\"],\n models: [\"qwen-plus\", \"qwen3-coder-plus\", \"qwen-turbo\"], prefer: \"qwen\" },\n { vendor: \"scaleway\", base: \"https://api.scaleway.ai/v1\", keyEnv: \"SCW_SECRET_KEY\", priority: 18,\n models: [\"gpt-oss-120b\", \"llama-3.3-70b-instruct\"], prefer: \"gpt-oss|llama\" },\n { vendor: \"featherless\", base: \"https://api.featherless.ai/v1\", keyEnv: \"FEATHERLESS_API_KEY\", priority: 19,\n models: [\"meta-llama/Llama-3.3-70B-Instruct\"], prefer: \"llama-3.3|qwen\" },\n];\n",[400],"192aeb1a-dd66-45b8-b894-cf79eae23402","artifacts.ts","4b6b75ba-ac6f-11f1-a399-1607ee4eb77e",1426,["D",1789091307807],"// Multi-file artifacts: an `artifact` row (title, kind, index content) plus\n// `artifact_file` rows. Served path-style at /artifact// so relative\n// \n \n \n \n \n \n \n

\n \n \n \n `,\n { headers: { \"Content-Type\": \"text/html\" } },\n );\n } else if (req.method === \"POST\") {\n // --- API: Update SQLite DB ---\n if (url.pathname === \"/api/update\") {\n const { provider, model } = await req.json();\n await sqlite.execute({\n sql:\n `INSERT INTO omni_router_config (provider, selected_model) VALUES (?, ?) ON CONFLICT(provider) DO UPDATE SET selected_model = excluded.selected_model`,\n args: [provider, model],\n });\n return Response.json({ success: true });\n }\n\n try {\n const body = await req.json();\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 );\n\n const activeGuards = getProviderArray()\n .filter((p) => Deno.env.get(p.keyEnv))\n .map(\n (p) => ({ name: p.name, state: getBreaker(p.name).state }),\n );\n\n const sseId = `chatcmpl-omni-${crypto.randomUUID()}`;\n\n if (body.stream) {\n const encoder = new TextEncoder();\n\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 _omni_meta: {\n provider: JSON.stringify(provider),\n latency_ms: latencyMs,\n inflight_requests: inflight,\n circuit_states: activeGuards,\n },\n })\n }\\n\\n`));\n };\n\n // 1. Role chunk\n sendChunk({ role: \"assistant\", content: \"\" });\n\n // 2. Content chunk\n if (message.content) sendChunk({ content: message.content });\n\n // 3. Tools chunk\n if (message.tool_calls) {\n sendChunk({ tool_calls: message.tool_calls });\n }\n\n // 4. Finish chunk\n sendChunk({}, message.tool_calls ? \"tool_calls\" : \"stop\");\n\n // 5. End Stream\n controller.enqueue(encoder.encode(\"data: [DONE]\\n\\n\"));\n controller.close();\n },\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 } catch (e: any) {\n return new Response(\n JSON.stringify({\n error: {\n message: \"(error).\",\n details: e.message,\n },\n }),\n {\n status: 503,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n }\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}","inference-router",[466],"273340ae-9854-4838-aaed-d7c30d3e5c9d","_inference-router-dev.tsx","676ac11c-4595-11f1-99e3-42b51c65c3df",1191,["D",1783675963454],20,"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;\n\n// ============================================================================\n// 2. STATE MANAGEMENT (SQLite) & CACHING\n// ============================================================================\n// omni_router_config is already part of db.ts's shared Schema/DDL — initDB()\n// from db.ts creates it (and every other table) idempotently. The local\n// CREATE TABLE here was a second, drifting source of truth for the same\n// table and has been removed rather than kept \"just in case\" the two diverge.\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// 3. ENTERPRISE 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// 4. 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 = 1024000,\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 = 0.0,\n maxTokens: number = 1024000,\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\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n\n // CORS & Preflight\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 === \"/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\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 return new Response(\n `\n \n \n \n \n \n Ziggyware Router Matrix\n \n \n \n \n \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 · v1432