[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_806":807,"_808":809},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",1472,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","app-compact.ts","latestPath","fileId","7c7e2310-ae0d-11f1-b403-1607ee4eb77e","name","fileType","script","content","// Conversation compaction: a running summary of everything older than the last few exchanges, stored per session in\n// omni_state (key compact:) and prepended to the model context in place of the messages it covers. Messages\n// themselves are never deleted — history rendering is unchanged — only what the model sees is folded.\n// Runs as its own val invocation (POST ?compact) so it never competes with a turn's 60 s budget.\nimport { all, run, sql, unwrap } from \"./db.ts\";\nimport { renderPrompt } from \"./prompts.ts\";\nimport { normalizeSettings, type Settings } from \"./app-settings.ts\";\n\nexport type Compact = { summary: string; uptoId: number; ts: number; covered: number; chars: number };\n\nexport async function loadCompact(session: string): Promise {\n const rows = unwrap(await all<\"omni_state\">(\"omni_state\", sql`SELECT value FROM omni_state WHERE key = ${\"compact:\" + session}`), []);\n try { return rows[0] ? JSON.parse(rows[0].value) as Compact : null; } catch { return null; }\n}\nexport async function saveCompact(session: string, c: Compact | null): Promise {\n const key = \"compact:\" + session;\n if (!c) { await run(sql`DELETE FROM omni_state WHERE key = ${key}`); return; }\n await run(sql`INSERT INTO omni_state (key, value, ts) VALUES (${key}, ${JSON.stringify(c)}, ${Date.now()}) ON CONFLICT(key) DO UPDATE SET value = excluded.value, ts = excluded.ts`);\n}\n\n/** Chars of live (uncompacted) history — what a turn would have to fit. */\nexport async function liveChars(session: string, uptoId: number): Promise<{ chars: number; count: number }> {\n const rows = unwrap(await all<\"message\">(\"message\", sql`SELECT id, content FROM message WHERE session = ${session} AND id > ${uptoId} ORDER BY id DESC LIMIT 200`), []);\n return { chars: rows.reduce((n, r) => n + r.content.length, 0), count: rows.length };\n}\n\nconst KEEP_TAIL = 6; // the last 3 exchanges are never folded: the model needs them verbatim\n\n/** Fold everything older than the last KEEP_TAIL messages into the summary. `call` is the inference function (fast tier). */\nexport async function compactSession(\n session: string,\n call: (messages: unknown[]) => Promise,\n prompts?: Record,\n examples = true,\n): Promise<{ ok: boolean; before: number; after: number; covered: number; uptoId: number; reason?: string }> {\n const prev = await loadCompact(session);\n const uptoPrev = prev?.uptoId ?? 0;\n const rows = unwrap(await all<\"message\">(\"message\", sql`SELECT * FROM message WHERE session = ${session} AND id > ${uptoPrev} ORDER BY id ASC`), []);\n if (rows.length <= KEEP_TAIL + 1) return { ok: false, before: 0, after: prev?.chars ?? 0, covered: 0, uptoId: uptoPrev, reason: \"nothing old enough to fold\" };\n const fold = rows.slice(0, rows.length - KEEP_TAIL);\n const before = fold.reduce((n, r) => n + r.content.length, 0);\n const transcript = fold.map((m) => `[#${m.id} ${m.role}] ${m.content.length > 5_000 ? m.content.slice(0, 3_800) + \"\\n…[\" + (m.content.length - 4_800) + \" chars trimmed]…\\n\" + m.content.slice(-1_000) : m.content}`).join(\"\\n\\n\");\n const prompt = renderPrompt(\"compact\", { previous: prev?.summary ?? \"(none — this is the first compaction)\", transcript }, prompts as any, examples);\n const summary = (await call([{ role: \"system\", content: \"You maintain the running summary of a long working conversation. Output only the summary.\" }, { role: \"user\", content: prompt }])).trim();\n if (summary.length < 80) return { ok: false, before, after: prev?.chars ?? 0, covered: 0, uptoId: uptoPrev, reason: \"model returned no usable summary\" };\n const next: Compact = { summary: summary.slice(0, 12_000), uptoId: fold[fold.length - 1].id, ts: Date.now(), covered: (prev?.covered ?? 0) + fold.length, chars: summary.length };\n await saveCompact(session, next);\n return { ok: true, before, after: next.chars, covered: fold.length, uptoId: next.uptoId };\n}\n\n/** The system message a turn prepends when a compaction exists. */\nexport function compactMessage(c: Compact): { role: \"system\"; content: string } {\n return { role: \"system\", content: `CONVERSATION SO FAR (compacted summary of ${c.covered} earlier messages; treat as established context, do not repeat it back):\\n${c.summary}` };\n}\n\n/** HTTP: POST ?compact {session, settings} folds old turns; GET ?compact= reads the summary; DELETE clears it. Null when not a compact route. */\nexport async function handleCompact(req: Request, url: URL, infer: (messages: unknown[], settings: Settings) => Promise): Promise {\n if (!url.searchParams.has(\"compact\")) return null;\n const session = url.searchParams.get(\"compact\") || \"\";\n if (req.method === \"GET\") return Response.json({ compact: await loadCompact(session) });\n if (req.method === \"DELETE\") { await saveCompact(session, null); return Response.json({ ok: true }); }\n if (req.method !== \"POST\") return null;\n const b = await req.json().catch(() => ({}));\n const settings = normalizeSettings(b.settings ?? {});\n const s = String(b.session ?? \"\");\n if (!s) return Response.json({ error: { message: \"session required\" } }, { status: 400 });\n try { return Response.json(await compactSession(s, (m) => infer(m, settings), settings.prompts as Record, settings.examples)); }\n catch (e: any) { return Response.json({ error: { message: `compact failed: ${String(e?.message ?? e).slice(0, 300)}` } }, { status: 502 }); }\n}\n","// Conversation compaction: a running summary of everything older than the last few exchanges, stored per session in\n// omni_state (key compact:) and prepended to the model context in place of the messages it covers. Messages\n// themselves are never deleted — history rendering is unchanged — only what the model sees is folded.\n// Runs as its own val invocation (POST ?compact) so it never competes with a turn's 60 s budget.\nimport { all, run, sql, unwrap } from \"./db.ts\";\nimport { renderPrompt } from \"./prompts.ts\";\nimport { normalizeSettings, type Settings } from \"./app-settings.ts\";\n\nexport type Compact = { summary: string; uptoId: number; ts: number; covered: number; chars: number };\n\nexport async function loadCompact(session: string): Promise {\n const rows = unwrap(await all<\"omni_state\">(\"omni_state\", sql`SELECT value FROM omni_state WHERE key = ${\"compact:\" + session}`), []);\n try { return rows[0] ? JSON.parse(rows[0].value) as Compact : null; } catch { return null; }\n}\nexport async function saveCompact(session: string, c: Compact | null): Promise {\n const key = \"compact:\" + session;\n if (!c) { await run(sql`DELETE FROM omni_state WHERE key = ${key}`); return; }\n await run(sql`INSERT INTO omni_state (key, value, ts) VALUES (${key}, ${JSON.stringify(c)}, ${Date.now()}) ON CONFLICT(key) DO UPDATE SET value = excluded.value, ts = excluded.ts`);\n}\n\n/** Chars of live (uncompacted) history — what a turn would have to fit. */\nexport async function liveChars(session: string, uptoId: number): Promise<{ chars: number; count: number }> {\n const rows = unwrap(await all<\"message\">(\"message\", sql`SELECT id, content FROM message WHERE session = ${session} AND id > ${uptoId} ORDER BY id DESC LIMIT 200`), []);\n return { chars: rows.reduce((n, r) => n + r.content.length, 0), count: rows.length };\n}\n\nconst KEEP_TAIL = 6; // the last 3 exchanges are never folded: the model needs them verbatim\n\n/** Fold everything older than the last KEEP_TAIL messages into the summary. `call` is the inference function (fast tier). */\nexport async function compactSession(\n session: string,\n call: (messages: unknown[]) => Promise,\n prompts?: Record,\n examples = true,\n): Promise<{ ok: boolean; before: number; after: number; covered: number; uptoId: number; reason?: string }> {\n const prev = await loadCompact(session);\n const uptoPrev = prev?.uptoId ?? 0;\n const rows = unwrap(await all<\"message\">(\"message\", sql`SELECT * FROM message WHERE session = ${session} AND id > ${uptoPrev} ORDER BY id ASC`), []);\n if (rows.length <= KEEP_TAIL + 1) return { ok: false, before: 0, after: prev?.chars ?? 0, covered: 0, uptoId: uptoPrev, reason: \"nothing old enough to fold\" };\n const fold = rows.slice(0, rows.length - KEEP_TAIL);\n const before = fold.reduce((n, r) => n + r.content.length, 0);\n const transcript = fold.map((m) => `[#${m.id} ${m.role}] ${m.content.length > 5_000 ? m.content.slice(0, 3_800) + \"\\n…[\" + (m.content.length - 4_800) + \" chars trimmed]…\\n\" + m.content.slice(-1_000) : m.content}`).join(\"\\n\\n\");\n const prompt = renderPrompt(\"compact\", { previous: prev?.summary ?? \"(none — this is the first compaction)\", transcript }, prompts as any, examples);\n const summary = (await call([{ role: \"system\", content: \"You maintain the running summary of a long working conversation. Output only the summary.\" }, { role: \"user\", content: prompt }])).trim();\n if (summary.length < 80) return { ok: false, before, after: prev?.chars ?? 0, covered: 0, uptoId: uptoPrev, reason: \"model returned no usable summary\" };\n const next: Compact = { summary: summary.slice(0, 12_000), uptoId: fold[fold.length - 1].id, ts: Date.now(), covered: (prev?.covered ?? 0) + fold.length, chars: summary.length };\n await saveCompact(session, next);\n return { ok: true, before, after: next.chars, covered: fold.length, uptoId: next.uptoId };\n}\n\n/** The system message a turn prepends when a compaction exists. */\nexport function compactMessage(c: Compact): { role: \"system\"; content: string } {\n return { role: \"system\", content: `CONVERSATION SO FAR (compacted summary of ${c.covered} earlier messages; treat as established context, do not repeat it back):\\n${c.summary}` };\n}\n\n/** HTTP: POST ?compact {session, settings} folds old turns; GET ?compact= reads the summary; DELETE clears it. Null when not a compact route. */\nexport async function handleCompact(req: Request, url: URL, infer: (messages: unknown[], settings: Settings) => Promise): Promise {\n if (!url.searchParams.has(\"compact\")) return null;\n const session = url.searchParams.get(\"compact\") || \"\";\n if (req.method === \"GET\") {\n const c = await loadCompact(session); const budget = Number(url.searchParams.get(\"check\")) || 0;\n const live = budget ? await liveChars(session, c?.uptoId ?? 0) : null;\n return Response.json({ compact: c, needs: !!live && live.count > 8 && live.chars > 2 * budget, live });\n }\n if (req.method === \"DELETE\") { await saveCompact(session, null); return Response.json({ ok: true }); }\n if (req.method !== \"POST\") return null;\n const b = await req.json().catch(() => ({}));\n const settings = normalizeSettings(b.settings ?? {});\n const s = String(b.session ?? \"\");\n if (!s) return Response.json({ error: { message: \"session required\" } }, { status: 400 });\n try { return Response.json(await compactSession(s, (m) => infer(m, settings), settings.prompts as Record, settings.examples)); }\n catch (e: any) { return Response.json({ error: { message: `compact failed: ${String(e?.message ?? e).slice(0, 300)}` } }, { status: 502 }); }\n}\n","createdAt",["D",1789154314199],"branchVersion","branchId","1a44bbd4-418c-11f1-af64-42b51c65c3df","id","1a430fbe-418c-11f1-af64-42b51c65c3df","free-ai",["D",1777220541701],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Free ai chat with inference router.","imageUrl","2c6d46b0-54dd-11f0-a86c-6fbc2b29331a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","1a430fbe418c11f1af6442b51c65c3df","tursoHostname","1a430fbe418c11f1af6442b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789508444194],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",1682,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ziggyware","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yekJHRDE5SGVoUHUzUENQaXY2MTRkT3h0cncifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":801,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":802,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":803,"_82":804,"_84":805,"_86":25},"tree",[588,589,590,591,592,593,594,595,596,597,598,599,600,601,602,603,604,605,606,607,608,609,610,611,612,613,614,615,616,617,618,619,620,621,622,623,624,625,626,627,628,629,630,631,632,633,634,635,636,637,638,639,640],"files",[588,589,590,591,592,593,594,595,596,597,598,599,600,601,602,603,604,605,606,607,608,609,610,611,612,613,614,615,616,617,618,619,620,621,622,623,624,625,626,627,628,629,630,631,632,633,634,635,636,637,638,639,640],"counts",{"_577":61,"_578":350,"_579":61,"_580":581,"_582":583},"contents",[129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166,167,168,169,170,171,172,173,174,175,176,177,178,179,180,181],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":570,"_32":571,"_30":572,"_185":-5,"_41":42,"_40":573,"_187":124,"_38":574,"_13":198,"_33":20,"_35":575,"_24":25,"_191":-5,"_27":576},{"_43":562,"_32":563,"_30":564,"_185":-5,"_41":42,"_40":565,"_187":124,"_38":566,"_13":567,"_33":34,"_35":568,"_24":25,"_191":-5,"_27":569},{"_43":555,"_32":556,"_30":557,"_185":-5,"_41":42,"_40":558,"_187":124,"_38":559,"_13":329,"_33":34,"_35":560,"_24":25,"_191":-5,"_27":561},{"_43":548,"_32":549,"_30":550,"_185":-5,"_41":42,"_40":551,"_187":124,"_38":552,"_13":236,"_33":34,"_35":553,"_24":25,"_191":-5,"_27":554},{"_43":541,"_32":542,"_30":543,"_185":-5,"_41":42,"_40":544,"_187":124,"_38":545,"_13":350,"_33":34,"_35":546,"_24":25,"_191":-5,"_27":547},{"_43":533,"_32":534,"_30":535,"_185":-5,"_41":42,"_40":536,"_187":124,"_38":537,"_13":538,"_33":34,"_35":539,"_24":25,"_191":-5,"_27":540},{"_43":525,"_32":526,"_30":527,"_185":-5,"_41":42,"_40":528,"_187":124,"_38":529,"_13":300,"_33":34,"_35":530,"_24":25,"_191":531,"_27":532},{"_43":517,"_32":518,"_30":519,"_185":-5,"_41":42,"_40":520,"_187":124,"_38":521,"_13":260,"_33":34,"_35":522,"_24":25,"_191":523,"_27":524},{"_43":510,"_32":511,"_30":512,"_185":-5,"_41":42,"_40":513,"_187":124,"_38":514,"_13":372,"_33":34,"_35":515,"_24":25,"_191":-5,"_27":516},{"_43":503,"_32":504,"_30":505,"_185":-5,"_41":42,"_40":506,"_187":124,"_38":507,"_13":198,"_33":34,"_35":508,"_24":25,"_191":-5,"_27":509},{"_43":495,"_32":496,"_30":497,"_185":-5,"_41":42,"_40":498,"_187":124,"_38":499,"_13":500,"_33":34,"_35":501,"_24":25,"_191":-5,"_27":502},{"_43":492,"_32":28,"_30":31,"_185":-5,"_41":42,"_40":14,"_187":25,"_38":493,"_13":189,"_33":34,"_35":37,"_24":25,"_191":-5,"_27":494},{"_43":485,"_32":486,"_30":487,"_185":-5,"_41":42,"_40":488,"_187":25,"_38":489,"_13":189,"_33":34,"_35":490,"_24":25,"_191":-5,"_27":491},{"_43":478,"_32":479,"_30":480,"_185":-5,"_41":42,"_40":481,"_187":124,"_38":482,"_13":350,"_33":34,"_35":483,"_24":25,"_191":-5,"_27":484},{"_43":471,"_32":472,"_30":473,"_185":-5,"_41":42,"_40":474,"_187":25,"_38":475,"_13":236,"_33":34,"_35":476,"_24":25,"_191":-5,"_27":477},{"_43":463,"_32":464,"_30":465,"_185":-5,"_41":42,"_40":466,"_187":25,"_38":467,"_13":403,"_33":245,"_35":468,"_24":25,"_191":469,"_27":470},{"_43":456,"_32":457,"_30":458,"_185":-5,"_41":42,"_40":459,"_187":25,"_38":460,"_13":277,"_33":34,"_35":461,"_24":25,"_191":-5,"_27":462},{"_43":449,"_32":450,"_30":451,"_185":-5,"_41":42,"_40":452,"_187":124,"_38":453,"_13":277,"_33":34,"_35":454,"_24":25,"_191":-5,"_27":455},{"_43":442,"_32":443,"_30":444,"_185":-5,"_41":42,"_40":445,"_187":124,"_38":446,"_13":350,"_33":34,"_35":447,"_24":25,"_191":-5,"_27":448},{"_43":435,"_32":436,"_30":437,"_185":-5,"_41":42,"_40":438,"_187":124,"_38":439,"_13":228,"_33":34,"_35":440,"_24":25,"_191":-5,"_27":441},{"_43":427,"_32":428,"_30":429,"_185":-5,"_41":42,"_40":430,"_187":25,"_38":431,"_13":432,"_33":34,"_35":433,"_24":25,"_191":-5,"_27":434},{"_43":420,"_32":421,"_30":422,"_185":-5,"_41":42,"_40":423,"_187":25,"_38":424,"_13":61,"_33":34,"_35":425,"_24":25,"_191":-5,"_27":426},{"_43":413,"_32":414,"_30":415,"_185":-5,"_41":42,"_40":416,"_187":124,"_38":417,"_13":61,"_33":34,"_35":418,"_24":25,"_191":-5,"_27":419},{"_43":406,"_32":407,"_30":408,"_185":-5,"_41":42,"_40":409,"_187":25,"_38":410,"_13":61,"_33":34,"_35":411,"_24":25,"_191":-5,"_27":412},{"_43":398,"_32":399,"_30":400,"_185":-5,"_41":42,"_40":401,"_187":25,"_38":402,"_13":403,"_33":34,"_35":404,"_24":25,"_191":-5,"_27":405},{"_43":391,"_32":392,"_30":393,"_185":-5,"_41":42,"_40":394,"_187":124,"_38":395,"_13":61,"_33":34,"_35":396,"_24":25,"_191":-5,"_27":397},{"_43":383,"_32":384,"_30":385,"_185":-5,"_41":42,"_40":386,"_187":25,"_38":387,"_13":388,"_33":34,"_35":389,"_24":25,"_191":-5,"_27":390},{"_43":375,"_32":376,"_30":377,"_185":-5,"_41":42,"_40":378,"_187":25,"_38":379,"_13":380,"_33":34,"_35":381,"_24":25,"_191":-5,"_27":382},{"_43":367,"_32":368,"_30":369,"_185":-5,"_41":42,"_40":370,"_187":25,"_38":371,"_13":372,"_33":34,"_35":373,"_24":25,"_191":-5,"_27":374},{"_43":360,"_32":361,"_30":362,"_185":-5,"_41":42,"_40":363,"_187":25,"_38":364,"_13":350,"_33":34,"_35":365,"_24":25,"_191":-5,"_27":366},{"_43":353,"_32":354,"_30":355,"_185":-5,"_41":42,"_40":356,"_187":124,"_38":357,"_13":61,"_33":34,"_35":358,"_24":25,"_191":-5,"_27":359},{"_43":345,"_32":346,"_30":347,"_185":-5,"_41":42,"_40":348,"_187":124,"_38":349,"_13":350,"_33":34,"_35":351,"_24":25,"_191":-5,"_27":352},{"_43":339,"_32":340,"_30":341,"_185":-5,"_41":42,"_40":342,"_187":124,"_38":343,"_13":61,"_33":34,"_35":107,"_24":25,"_191":-5,"_27":344},{"_43":332,"_32":333,"_30":334,"_185":-5,"_41":42,"_40":335,"_187":25,"_38":336,"_13":61,"_33":34,"_35":337,"_24":25,"_191":-5,"_27":338},{"_43":324,"_32":325,"_30":326,"_185":-5,"_41":42,"_40":327,"_187":25,"_38":328,"_13":329,"_33":34,"_35":330,"_24":25,"_191":-5,"_27":331},{"_43":317,"_32":318,"_30":319,"_185":-5,"_41":42,"_40":320,"_187":124,"_38":321,"_13":61,"_33":34,"_35":322,"_24":25,"_191":-5,"_27":323},{"_43":310,"_32":311,"_30":312,"_185":-5,"_41":42,"_40":313,"_187":124,"_38":314,"_13":236,"_33":34,"_35":315,"_24":25,"_191":-5,"_27":316},{"_43":303,"_32":304,"_30":305,"_185":-5,"_41":42,"_40":306,"_187":124,"_38":307,"_13":277,"_33":34,"_35":308,"_24":25,"_191":-5,"_27":309},{"_43":295,"_32":296,"_30":297,"_185":-5,"_41":42,"_40":298,"_187":25,"_38":299,"_13":300,"_33":34,"_35":301,"_24":25,"_191":-5,"_27":302},{"_43":288,"_32":289,"_30":290,"_185":-5,"_41":42,"_40":291,"_187":124,"_38":292,"_13":189,"_33":34,"_35":293,"_24":25,"_191":-5,"_27":294},{"_43":280,"_32":281,"_30":282,"_185":-5,"_41":42,"_40":283,"_187":25,"_38":284,"_13":285,"_33":34,"_35":286,"_24":25,"_191":-5,"_27":287},{"_43":272,"_32":273,"_30":274,"_185":-5,"_41":42,"_40":275,"_187":25,"_38":276,"_13":277,"_33":34,"_35":278,"_24":25,"_191":-5,"_27":279},{"_43":263,"_32":264,"_30":265,"_185":-5,"_41":42,"_40":266,"_187":25,"_38":267,"_13":268,"_33":245,"_35":269,"_24":25,"_191":270,"_27":271},{"_43":255,"_32":256,"_30":257,"_185":-5,"_41":42,"_40":258,"_187":25,"_38":259,"_13":260,"_33":245,"_35":261,"_24":25,"_191":-5,"_27":262},{"_43":249,"_32":250,"_30":251,"_185":-5,"_41":42,"_40":252,"_187":124,"_38":253,"_13":61,"_33":34,"_35":107,"_24":25,"_191":-5,"_27":254},{"_43":239,"_32":240,"_30":241,"_185":-5,"_41":42,"_40":242,"_187":124,"_38":243,"_13":244,"_33":245,"_35":246,"_24":25,"_191":247,"_27":248},{"_43":231,"_32":232,"_30":233,"_185":-5,"_41":42,"_40":234,"_187":25,"_38":235,"_13":236,"_33":34,"_35":237,"_24":25,"_191":-5,"_27":238},{"_43":223,"_32":224,"_30":225,"_185":-5,"_41":42,"_40":226,"_187":25,"_38":227,"_13":228,"_33":34,"_35":229,"_24":25,"_191":-5,"_27":230},{"_43":216,"_32":217,"_30":218,"_185":-5,"_41":42,"_40":219,"_187":25,"_38":220,"_13":61,"_33":34,"_35":221,"_24":25,"_191":-5,"_27":222},{"_43":208,"_32":209,"_30":210,"_185":-5,"_41":42,"_40":211,"_187":25,"_38":212,"_13":213,"_33":34,"_35":214,"_24":25,"_191":-5,"_27":215},{"_43":201,"_32":202,"_30":203,"_185":-5,"_41":42,"_40":204,"_187":124,"_38":205,"_13":61,"_33":34,"_35":206,"_24":25,"_191":-5,"_27":207},{"_43":193,"_32":194,"_30":195,"_185":-5,"_41":42,"_40":196,"_187":25,"_38":197,"_13":198,"_33":34,"_35":199,"_24":25,"_191":-5,"_27":200},{"_43":182,"_32":183,"_30":184,"_185":-5,"_41":42,"_40":186,"_187":25,"_38":188,"_13":189,"_33":34,"_35":190,"_24":25,"_191":-5,"_27":192},"bde597fb-4fd9-44be-87f7-098cc1466880","ui-timeline.ts","6a4fbfcc-acb5-11f1-93b9-1607ee4eb77e","parentId",1436,"latest",["D",1789091312789],1,"// Run timeline: ONE renderer for everything the AI did in a turn — live (fed by\n// ?progress events) and from history (fed by message_meta.toolEvents). Collapsed to a\n// summary line; each row expands to the request args and the response, pretty-printed.\nexport const timelineStyle: string = `\n.tl{margin:4px 0 8px;border:1px solid var(--line);background:var(--s0);font-size:11px;}\n.tl-h{display:flex;gap:8px;align-items:center;padding:4px 8px;cursor:pointer;color:var(--dim);letter-spacing:.06em;user-select:none;}\n.tl-h::before{content:\"▸\";color:var(--acc);font-size:10px;} .tl.open .tl-h::before{content:\"▾\";}\n.tl-h .tl-sum{flex:1;overflow:hidden;text-overflow:ellipsis;white-space:nowrap;} .tl-h .tl-n{color:var(--dim2);font-size:10px;}\n.tl-body{display:none;border-top:1px solid var(--line);} .tl.open .tl-body{display:block;}\n.tl-row{display:flex;gap:8px;align-items:center;padding:3px 8px;border-bottom:1px solid var(--line);cursor:pointer;} .tl-row:last-child{border-bottom:0;} .tl-row:hover{background:var(--s1);}\n.tl-k{font-size:9px;letter-spacing:.12em;text-transform:uppercase;padding:1px 6px;border:1px solid var(--line2);color:var(--dim);white-space:nowrap;min-width:52px;text-align:center;}\n.tl-k.ok{border-color:rgba(198,255,127,.35);color:var(--acc2);} .tl-k.err{border-color:rgba(255,107,107,.4);color:var(--err);} .tl-k.sys{border-color:transparent;color:var(--dim2);} .tl-k.live{border-color:var(--acc);color:var(--acc);}\n.tl-d{flex:1;overflow:hidden;text-overflow:ellipsis;white-space:nowrap;color:var(--text);} .tl-t{color:var(--dim2);font-size:10px;white-space:nowrap;}\n.tl-x{display:none;padding:6px 8px 8px;background:var(--bg);border-bottom:1px solid var(--line);} .tl-row.open+.tl-x{display:grid;grid-template-columns:1fr 1fr;gap:8px;} @media (max-width:800px){.tl-row.open+.tl-x{grid-template-columns:1fr;}}\n.tl-x h5{font-size:9px;letter-spacing:.14em;text-transform:uppercase;color:var(--dim2);margin:0 0 4px;font-weight:500;display:flex;justify-content:space-between;} .tl-x h5 button{background:none;border:0;color:var(--dim2);font:inherit;cursor:pointer;} .tl-x h5 button:hover{color:var(--acc);}\n.tl-x pre{margin:0;white-space:pre-wrap;word-break:break-word;font-size:11px;line-height:1.45;color:var(--dim);max-height:320px;overflow:auto;} .tl-x pre.full{max-height:none;}\n.tl-x .tl-more{color:var(--acc);cursor:pointer;font-size:10px;margin-top:4px;display:inline-block;}\n.tl.live .tl-h{color:var(--acc);}\n.tl-st{font-size:9px;letter-spacing:.12em;text-transform:uppercase;min-width:56px;text-align:right;color:var(--dim2);}\n.tl-row.st-done .tl-st{color:var(--acc2);} .tl-row.st-failed .tl-st{color:var(--err);} .tl-row.st-repeated .tl-st{color:var(--warn);} .tl-row.st-running .tl-st{color:var(--acc);} .tl-row.st-running .tl-st::after{content:\"\";display:inline-block;width:6px;height:6px;border-radius:50%;background:var(--acc);margin-left:5px;animation:blink 1s infinite;}\n.tl-row.st-failed .tl-k{border-color:rgba(255,107,107,.4);color:var(--err);} .tl-row.st-done .tl-k{border-color:rgba(198,255,127,.3);color:var(--acc2);} .tl-row[data-kind=step] .tl-k{border-color:transparent;color:var(--dim2);}\n.tl-plan{display:flex;gap:4px;flex-wrap:wrap;padding:5px 8px;border-bottom:1px solid var(--line);} .tl-pl{font-size:9px;letter-spacing:.12em;text-transform:uppercase;padding:1px 8px;border:1px solid var(--line2);color:var(--dim2);} .tl-pl::before{content:\"○ \";} .tl-pl.st-running{border-color:var(--acc);color:var(--acc);} .tl-pl.st-running::before{content:\"● \";} .tl-pl.st-done{border-color:rgba(198,255,127,.3);color:var(--acc2);} .tl-pl.st-done::before{content:\"✓ \";} .tl-pl.st-failed{border-color:var(--err);color:var(--err);} .tl-pl.st-failed::before{content:\"✗ \";} .tl-pl.st-skipped{opacity:.5;} .tl-pl.st-skipped::before{content:\"– \";}\n`;\n\nexport const timelineScript: string = String.raw`\nconst TL = (() => {\n const LABEL = { web_search: 'search', eval_js: 'eval', create_artifact: 'build', update_artifact: 'edit', read_artifact: 'read', search_artifact: 'grep', memory_recall: 'recall', memory_write: 'remember', name_session: 'name', session_clear: 'clear', session_delete: 'delete' };\n const esc = (s) => String(s).replace(/[&<>\"]/g, (c) => ({ '&': '&', '<': '<', '>': '>', '\"': '"' }[c]));\n const short = (v) => { if (v == null) return ''; if (typeof v === 'string') return v; try { return JSON.stringify(v); } catch { return String(v); } };\n const pretty = (v) => { if (v == null) return ''; if (typeof v === 'string') return v; try { return JSON.stringify(v, null, 2); } catch { return String(v); } };\n function desc(ev) {\n const a = ev.args || {}, r = ev.result;\n switch (ev.tool) {\n case 'web_search': return 'search: ' + (a.query || '');\n case 'eval_js': return 'eval: ' + String(a.code || a.expression || '').slice(0, 80).replace(/\\s+/g, ' ');\n case 'create_artifact': return 'built ' + (a.title || (r && r.title) || '') + (a.files ? ' (' + (1 + (a.files.length || 0)) + ' files)' : '');\n case 'update_artifact': { const n = (a.edits && a.edits.length) || 0, f = (a.files && a.files.length) || 0; return 'edit #' + (a.id ?? (r && r.id) ?? '') + (n ? ' · ' + n + ' edit' + (n > 1 ? 's' : '') : '') + (f ? ' · ' + f + ' file' + (f > 1 ? 's' : '') : '') + (a.delete ? ' · delete' : ''); }\n case 'search_artifact': return 'grep: ' + (a.query || '') + (r && r.matches != null ? ' → ' + r.matches + ' hits' : '');\n case 'read_artifact': return 'read #' + (a.id ?? '') + (a.all ? ' (all files)' : a.path ? ' ' + a.path : '');\n case 'memory_recall': return 'recall: ' + (a.query || '');\n case 'memory_write': return 'remember: ' + String(a.fact || a.value || '').slice(0, 80);\n case 'name_session': return 'title: ' + (a.name || '');\n default: return ev.tool + ' ' + short(a).slice(0, 80);\n }\n }\n function stageText(ev) {\n if (ev.type === 'pass') return 'model call ' + ev.n + '/' + ev.of;\n if (ev.type === 'continue') return 'reply cut at the limit — continuing (' + ev.n + ')';\n if (ev.type === 'retry') return 'retry ' + ev.n + (ev.error ? ' — ' + ev.error : '');\n if (ev.type === 'thinking') return 'thinking…';\n return ev.label || ev.text || ev.type;\n }\n function summary(events) {\n const tools = events.filter(e => e.tool);\n const errs = tools.filter(e => e.error && e.error !== 'repeated').length;\n const parts = [tools.length + ' tool' + (tools.length === 1 ? '' : 's')];\n const files = tools.filter(e => /artifact/.test(e.tool) && !e.error).length; if (files) parts.push(files + ' artifact op' + (files > 1 ? 's' : ''));\n if (errs) parts.push(errs + ' failed');\n const conts = events.filter(e => e.type === 'continue').length; if (conts) parts.push(conts + ' continued');\n const retries = events.filter(e => e.type === 'retry').length; if (retries) parts.push(retries + ' retr' + (retries > 1 ? 'ies' : 'y'));\n return parts.join(' · ');\n }\n function pane(title, value) {\n const s = pretty(value), cut = s.length > 4000;\n const wrap = document.createElement('div');\n const h = document.createElement('h5'); h.innerHTML = esc(title) + (s ? ' ' : '');\n const pre = document.createElement('pre'); pre.textContent = cut ? s.slice(0, 4000) + '\\n…' : s;\n wrap.appendChild(h); wrap.appendChild(pre);\n if (h.querySelector('button')) h.querySelector('button').onclick = (e) => { e.stopPropagation(); navigator.clipboard.writeText(s); h.querySelector('button').textContent = 'copied'; };\n if (cut) { const m = document.createElement('span'); m.className = 'tl-more'; m.textContent = 'show all ' + s.length.toLocaleString() + ' chars'; m.onclick = (e) => { e.stopPropagation(); pre.textContent = s; pre.classList.add('full'); m.remove(); }; wrap.appendChild(m); }\n return wrap;\n }\n // status vocabulary: waiting · running · done · failed · repeated · skipped\n function statusOf(ev, isLast, live) {\n if (ev.tool) return ev.error === 'repeated' || (ev.result && ev.result.repeated) ? 'repeated' : ev.error ? 'failed' : 'done';\n if (ev.type === 'retry') return 'failed';\n return live && isLast ? 'running' : 'done';\n }\n function row(ev, status) {\n const r = document.createElement('div'); r.className = 'tl-row st-' + status; r.dataset.kind = ev.tool ? 'tool' : 'step';\n const k = document.createElement('span'); k.className = 'tl-k'; k.textContent = ev.tool ? (LABEL[ev.tool] || ev.tool.replace(/^rojs_/, 'rojs ').slice(0, 10)) : (ev.type === 'pass' ? 'model' : ev.type === 'stage' ? 'step' : ev.type);\n const d = document.createElement('span'); d.className = 'tl-d'; d.textContent = ev.tool ? desc(ev) + (ev.error && ev.error !== 'repeated' ? ' — ' + ev.error : '') : stageText(ev);\n const st = document.createElement('span'); st.className = 'tl-st'; st.textContent = status;\n const t = document.createElement('span'); t.className = 'tl-t'; t.textContent = ev.ms ? (ev.ms / 1000).toFixed(1) + 's' : ev.hop != null && ev.tool ? 'hop ' + (ev.hop + 1) : '';\n r.appendChild(k); r.appendChild(d); r.appendChild(st); r.appendChild(t);\n if (!ev.tool) return [r];\n const x = document.createElement('div'); x.className = 'tl-x';\n x.appendChild(pane('request · ' + ev.tool, ev.args)); x.appendChild(pane(ev.error && ev.error !== 'repeated' ? 'error' : 'response', ev.error && ev.error !== 'repeated' ? ev.error : ev.result));\n r.onclick = () => r.classList.toggle('open');\n return [r, x];\n }\n /** Build a timeline. Rendering is INCREMENTAL: rows already on screen are kept (so an expanded row stays expanded\n * while live events stream in); only new events are appended and the previous last step is re-labelled done.\n * opts.live: expanded, elapsed clock, checklist of planned stages (opts.plan: ['plan','answer','verify']). */\n function make(events, opts = {}) {\n const root = document.createElement('div'); root.className = 'tl' + (opts.live ? ' live open' : (opts.open ? ' open' : ''));\n const h = document.createElement('div'); h.className = 'tl-h';\n const sum = document.createElement('span'); sum.className = 'tl-sum'; const clock = document.createElement('span'); clock.className = 'tl-n';\n h.appendChild(sum); h.appendChild(clock); h.onclick = () => root.classList.toggle('open');\n const body = document.createElement('div'); body.className = 'tl-body';\n let plan = null;\n if (opts.live && opts.plan && opts.plan.length) { plan = document.createElement('div'); plan.className = 'tl-plan'; plan.innerHTML = opts.plan.map(p => '' + esc(p) + '').join(''); root.appendChild(plan); }\n root.appendChild(h); root.appendChild(body);\n const t0 = Date.now(); let rendered = 0, lastStepRow = null, timer = null;\n const api = {\n root, events: [],\n set(evs) {\n api.events = evs;\n if (evs.length < rendered) { body.innerHTML = ''; rendered = 0; lastStepRow = null; } // not append-only: rebuild\n for (let i = rendered; i < evs.length; i++) {\n const ev = evs[i]; if (ev.type === 'thinking') continue;\n if (lastStepRow) { lastStepRow.classList.remove('st-running'); lastStepRow.classList.add('st-done'); lastStepRow.querySelector('.tl-st').textContent = 'done'; lastStepRow = null; }\n const status = statusOf(ev, i === evs.length - 1, !!opts.live);\n const els = row(ev, status); for (const el of els) body.appendChild(el);\n if (status === 'running') lastStepRow = els[0];\n if (plan && ev.type === 'stage') { const key = String(ev.label || '').toLowerCase(); plan.querySelectorAll('.tl-pl').forEach(pl => { const p = pl.dataset.p; if (key.startsWith(p) || (p === 'answer' && /answer|summar/.test(key)) || (p === 'plan' && key.startsWith('plan')) || (p === 'verify' && key.startsWith('verif'))) { plan.querySelectorAll('.tl-pl.st-running').forEach(o => { o.className = 'tl-pl st-done'; }); pl.className = 'tl-pl st-running'; } }); }\n }\n rendered = evs.length;\n const now = evs.filter(e => e.type !== 'thinking').slice(-1)[0];\n sum.textContent = opts.live ? ((opts.label || 'working') + (now ? ' · now: ' + (now.tool ? desc(now) : stageText(now)) : '') + ' · ' + summary(evs)) : summary(evs);\n if (!opts.live) clock.textContent = evs.length ? evs.length + ' step' + (evs.length > 1 ? 's' : '') : '';\n },\n label(l) { opts.label = l; api.set(api.events); },\n finish(ok) { clearInterval(timer); if (lastStepRow) { lastStepRow.classList.remove('st-running'); lastStepRow.classList.add(ok ? 'st-done' : 'st-failed'); lastStepRow.querySelector('.tl-st').textContent = ok ? 'done' : 'failed'; } if (plan) plan.querySelectorAll('.tl-pl').forEach(pl => { if (pl.classList.contains('st-running')) pl.className = 'tl-pl ' + (ok ? 'st-done' : 'st-failed'); else if (pl.classList.contains('st-waiting')) pl.className = 'tl-pl st-skipped'; }); },\n };\n if (opts.live) timer = setInterval(() => { clock.textContent = Math.round((Date.now() - t0) / 1000) + 's'; }, 1000);\n api.set(events || []);\n return api;\n }\n return { make, summary, desc };\n})();\nwindow.TL = TL;\n`;\n","label",[183],"77f22f22-05db-4711-b208-8baba0bda84d","ui-style-settings.ts","c77c9562-abcf-11f1-a463-1607ee4eb77e",1395,["D",1789003062000],4,"// Layout column, themes, density, settings drawer, thinking/tool/error blocks.\nexport const settingsStyle: string = `\n:root{--content-w:760px;--fs:13px;}\nbody[data-theme=\"black\"]{--bg:#000;--s0:#050505;--s1:#0a0a0a;--s2:#111;--s3:#181818;--line:#1f1f1f;--line2:#2a2a2a;}\nbody[data-theme=\"paper\"]{--bg:#f4f4f1;--s0:#ececea;--s1:#e4e4e1;--s2:#dcdcd8;--s3:#d2d2ce;--line:#c9c9c4;--line2:#b8b8b3;--text:#15171c;--dim:#4d5260;--dim2:#7a7f8c;--acc2:#3b7d00;}\nbody[data-theme=\"paper\"] .user .msg-body{color:#15171c;}\nbody[data-theme=\"paper\"] .hljs-title,body[data-theme=\"paper\"] .hljs-title.function_,body[data-theme=\"paper\"] .hljs-title.class_,body[data-theme=\"paper\"] .hljs-section,body[data-theme=\"paper\"] .hljs-name{color:#15171c;}\nbody[data-theme=\"paper\"] .hljs-variable,body[data-theme=\"paper\"] .hljs-template-variable,body[data-theme=\"paper\"] .hljs-params,body[data-theme=\"paper\"] .hljs-property{color:#3a3f4c;}\nbody[data-theme=\"paper\"] .hljs-attribute,body[data-theme=\"paper\"] .hljs-selector-id,body[data-theme=\"paper\"] .hljs-selector-class{color:#1f4f9a;}\nbody[data-theme=\"paper\"] .hljs-number,body[data-theme=\"paper\"] .hljs-symbol,body[data-theme=\"paper\"] .hljs-meta{color:#9a5a00;}\nbody[data-font=\"sans\"] .msg-body,body[data-font=\"sans\"] #inp,body[data-font=\"sans\"] .md p,body[data-font=\"sans\"] .md li{font-family:var(--sans);}\n.msg-body,#inp{font-size:var(--fs);}\nbody[data-density=\"compact\"] .msg-wrap{padding:5px 0;} body[data-density=\"compact\"] .md p{margin-bottom:.4em;}\nbody.no-ts .msg-ts{display:none;} body.no-tel .telemetry{display:none;} body.no-tools .tool-chain{display:none;}\nbody.code-wrap .cb pre code{white-space:pre-wrap;word-break:break-word;}\n\n/* reading column: messages, composer and typing row share one centered width */\n#chat>.msg-wrap,#typing,#empty,.bar-inner,.bar-meta{max-width:var(--content-w);margin-left:auto;margin-right:auto;width:100%;}\n\n/* thinking block */\n.think{margin:4px 0 8px;border:1px solid var(--line);background:var(--s0);}\n.think summary{cursor:pointer;list-style:none;padding:4px 8px;font-size:10px;letter-spacing:.1em;text-transform:uppercase;color:var(--dim);display:flex;gap:8px;align-items:center;}\n.think summary::before{content:\"▸\";color:var(--acc);} .think[open] summary::before{content:\"▾\";}\n.think .think-body{padding:6px 10px 8px;font-size:calc(var(--fs) - 1px);line-height:1.55;color:var(--dim);white-space:pre-wrap;word-break:break-word;border-top:1px solid var(--line);max-height:320px;overflow:auto;}\nbody[data-thinking=\"hidden\"] .think{display:none;}\n#live-think{font-size:11px;color:var(--dim2);white-space:pre-wrap;max-height:64px;overflow:hidden;margin-top:4px;line-height:1.4;}\n\n.trunc{font-size:10px;color:var(--warn);letter-spacing:.08em;text-transform:uppercase;display:flex;align-items:center;gap:6px;margin-top:4px;}\n/* error card */\n.err-card{border:1px solid var(--err);background:rgba(255,107,107,.06);padding:8px 10px;}\n.err-card .err-h{color:var(--err);font-size:11px;letter-spacing:.08em;text-transform:uppercase;margin-bottom:4px;}\n.err-card .err-m{font-size:12px;white-space:pre-wrap;word-break:break-word;}\n.err-card details{margin-top:6px;} .err-card summary{cursor:pointer;font-size:10px;color:var(--dim);letter-spacing:.08em;text-transform:uppercase;}\n.err-card pre{margin:6px 0 0;font-size:11px;white-space:pre-wrap;word-break:break-word;color:var(--dim);max-height:260px;overflow:auto;}\n.err-card .err-actions{margin-top:6px;display:flex;gap:6px;}\n\n/* settings drawer */\n#settings{position:fixed;top:0;right:0;height:100dvh;width:min(380px,100vw);background:var(--s0);border-left:1px solid var(--line);z-index:40;display:flex;flex-direction:column;transition:transform .18s;}\n#settings.closed{transform:translateX(100%);}\n#st-scrim{position:fixed;inset:0;background:rgba(0,0,0,.35);z-index:39;display:none;} #st-scrim.on{display:block;}\n#st-hdr{display:flex;align-items:center;justify-content:space-between;padding:10px 12px;border-bottom:1px solid var(--line);font-size:11px;letter-spacing:.18em;text-transform:uppercase;color:var(--acc);}\n#st-body{overflow:auto;padding:6px 12px 24px;}\n#st-body section{padding:10px 0;border-bottom:1px solid var(--line);}\n#st-body h4{font-size:10px;letter-spacing:.14em;text-transform:uppercase;color:var(--dim2);margin:0 0 8px;font-weight:500;}\n#st-body label{display:flex;align-items:center;justify-content:space-between;gap:10px;font-size:12px;color:var(--text);padding:4px 0;}\n#st-body label>input[type=checkbox]{order:-1;margin:0 8px 0 0;accent-color:var(--acc);} #st-body label:has(input[type=checkbox]){justify-content:flex-start;}\n#st-body select,#st-body input[type=text],#st-body textarea{background:var(--s1);color:var(--text);border:1px solid var(--line2);font:inherit;font-size:12px;padding:4px 6px;min-width:150px;}\n#st-body textarea{width:100%;resize:vertical;line-height:1.5;}\n#st-body input[type=range]{flex:1;accent-color:var(--acc);} #st-body output{min-width:36px;text-align:right;color:var(--dim);font-size:11px;}\n#st-body input[type=color]{width:36px;height:22px;border:1px solid var(--line2);background:none;padding:0;}\n#st-tools label{padding:2px 0;}\n.pr-hint{font-size:10px;color:var(--dim2);letter-spacing:.04em;margin:2px 0 4px;flex:1;}\n#pr-text{font-family:var(--mono);font-size:11px;line-height:1.45;min-height:160px;} #pr-text.custom{border-color:var(--acc);}\n.sk{border:1px solid var(--line);margin:4px 0;padding:0 8px 4px;} .sk summary{cursor:pointer;list-style:none;display:flex;gap:8px;padding:5px 0;font-size:11px;} .sk .sk-name{color:var(--text);flex:1;} .sk .sk-mode{color:var(--dim2);font-size:10px;white-space:nowrap;overflow:hidden;text-overflow:ellipsis;max-width:55%;} .sk textarea{font-family:var(--mono);font-size:11px;margin:4px 0;} .sk label{padding:2px 0;} .sk label>input[type=text]{flex:1;min-width:0;}\n.st-row{display:flex;gap:6px;flex-wrap:wrap;align-items:center;}\ntable.rt{width:100%;border-collapse:collapse;font-size:10px;margin-top:6px;} table.rt th{text-align:left;color:var(--dim2);font-weight:500;letter-spacing:.1em;text-transform:uppercase;font-size:9px;padding:2px 4px;border-bottom:1px solid var(--line);} table.rt td{padding:2px 4px;border-bottom:1px solid var(--line);color:var(--dim);} table.rt td.cool{color:var(--warn);} .st-btn{background:none;border:1px solid var(--line2);color:var(--dim);font:inherit;font-size:10px;letter-spacing:.1em;text-transform:uppercase;padding:4px 8px;cursor:pointer;} .st-btn:hover{border-color:var(--acc);color:var(--acc);}\n`;\n",[194],"1e8e8db7-ea81-46a6-b774-05c9cbc5e81d","ui-style-md.ts","b8f94408-abb2-11f1-81cd-1607ee4eb77e",1282,["D",1788891952093],"// Styles for Markdown bodies, code blocks (hljs token map on the house palette),\n// tables, math, the progress line, model chips and the stop control.\nexport const mdStyle: string = `\n.msg-body.md{white-space:normal;}\n.md p{margin:0 0 .7em;} .md p:last-child{margin-bottom:0;}\n.md h1,.md h2,.md h3,.md h4{font-family:var(--mono);letter-spacing:.04em;margin:.9em 0 .4em;color:var(--text);line-height:1.3;}\n.md h1{font-size:16px;} .md h2{font-size:14px;} .md h3{font-size:13px;color:var(--acc);} .md h4{font-size:12px;color:var(--dim);}\n.md ul,.md ol{margin:0 0 .7em 1.3em;} .md li{margin:.15em 0;} .md li>ul,.md li>ol{margin-bottom:0;}\n.md blockquote{border-left:2px solid var(--line2);padding:.1em 0 .1em .8em;margin:0 0 .7em;color:var(--dim);}\n.md hr{border:0;border-top:1px solid var(--line);margin:.9em 0;}\n.md a{color:var(--acc);text-decoration:none;border-bottom:1px solid rgba(79,140,255,.35);} .md a:hover{border-bottom-color:var(--acc);}\n.md code{font-family:var(--mono);font-size:12px;background:var(--s2);border:1px solid var(--line);padding:0 4px;border-radius:var(--r);color:var(--acc2);}\n.md .ck{display:inline-block;width:10px;height:10px;border:1px solid var(--line2);margin:0 6px -1px 0;} .md .ck.on{background:var(--acc2);border-color:var(--acc2);}\n.md .tbl{overflow-x:auto;margin:0 0 .7em;border:1px solid var(--line);}\n.md table{border-collapse:collapse;font-size:12px;min-width:100%;} .md th,.md td{padding:5px 9px;border-bottom:1px solid var(--line);text-align:left;vertical-align:top;}\n.md th{background:var(--s1);color:var(--dim);font-weight:500;letter-spacing:.06em;text-transform:uppercase;font-size:10px;} .md tr:last-child td{border-bottom:0;}\n.md .mx-d{display:block;text-align:center;margin:.5em 0;} .md .mx:not(.done){color:var(--dim);}\n.md .katex{font-size:1.05em;}\n\n.cb{margin:.6em 0;border:1px solid var(--line);background:var(--s0);}\n.cb-h{display:flex;align-items:center;gap:10px;padding:4px 8px;border-bottom:1px solid var(--line);background:var(--s1);font-size:10px;letter-spacing:.08em;text-transform:uppercase;color:var(--dim);}\n.cb-lang{color:var(--acc);} .cb-n{color:var(--dim2);margin-right:auto;}\n.cb-copy{background:none;border:1px solid var(--line2);color:var(--dim);font:inherit;letter-spacing:.08em;text-transform:uppercase;padding:1px 6px;cursor:pointer;} .cb-copy:hover{border-color:var(--acc);color:var(--acc);}\n.cb pre{margin:0;padding:9px 10px;overflow-x:auto;font-size:12px;line-height:1.55;tab-size:2;}\n.cb pre code{background:none;border:0;padding:0;color:var(--text);font-size:inherit;white-space:pre;}\n.hljs{background:transparent;color:var(--text);}\n.hljs-comment,.hljs-quote{color:var(--dim2);font-style:italic;}\n.hljs-keyword,.hljs-selector-tag,.hljs-literal,.hljs-built_in,.hljs-type{color:var(--acc);}\n.hljs-string,.hljs-regexp,.hljs-addition,.hljs-attr,.hljs-template-tag{color:var(--acc2);}\n.hljs-number,.hljs-symbol,.hljs-bullet,.hljs-meta,.hljs-link{color:var(--warn);}\n.hljs-title,.hljs-title.function_,.hljs-title.class_,.hljs-section,.hljs-name{color:#e4e8f4;font-weight:500;}\n.hljs-variable,.hljs-template-variable,.hljs-params,.hljs-property{color:#c4cbe0;}\n.hljs-attribute,.hljs-selector-id,.hljs-selector-class,.hljs-selector-attr,.hljs-selector-pseudo{color:#9fd0ff;}\n.hljs-deletion{color:var(--err);} .hljs-emphasis{font-style:italic;} .hljs-strong{font-weight:600;}\n\n#progress{font-size:10px;color:var(--dim);letter-spacing:.08em;text-transform:uppercase;margin-left:8px;white-space:nowrap;overflow:hidden;text-overflow:ellipsis;max-width:60vw;}\n#progress .tk{color:var(--acc);}\n.bar-modes{display:flex;gap:4px;margin-left:auto;}\n.mode{background:none;border:1px solid var(--line);color:var(--dim2);font:inherit;font-size:9px;letter-spacing:.1em;text-transform:uppercase;padding:2px 7px;cursor:pointer;}\n.mode:hover{border-color:var(--acc);color:var(--acc);} .mode.on{border-color:var(--acc);color:var(--acc);background:var(--s1);}\n#send.stop{background:var(--err);border-color:var(--err);}\n.msg-wrap.streaming .msg-body::after{content:\"▌\";color:var(--acc);animation:blink 1s steps(2) infinite;} @keyframes blink{to{opacity:0;}}\n.telemetry{font-size:9px;color:var(--dim2);letter-spacing:.06em;margin-left:auto;}\n`;\n",[202],"1a4c41f9-82b4-46e1-a366-26f1b90aed01","ui-settings.ts","c73730bc-abcf-11f1-a6fb-1607ee4eb77e",1470,["D",1789150848032],11,"// Settings drawer: markup + logic. State lives in localStorage(\"omni.settings\");\n// `SETTINGS.current()` is read by main-script on every send, and appearance is\n// applied as CSS variables / body classes so the page re-skins without reload.\nexport const settingsHtml: string = `\n

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 vendor order \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 auto-continue unfinished work (rounds) \n keep retrying when providers are exhausted (min) \n swarm builders in parallel \n keep going until I press stop (unlimited retries, cut-reply continues and follow-up rounds)\n two top-tier examples in every prompt (few-shot; off saves input tokens on tight free tiers)\n app-scale asks go through /build automatically (architect → parallel builders → integrate)\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: 3, cardPreview: true, autoSwarm: true, examples: true, untilStopped: false, keyPolicy: '', contextChars: 16000, retryMinutes: 5, vendorOrder: 'openrouter', autoComplete: 4 };\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 let lintIssues = []; const autoFixed = {}; // artifact id → rounds used\n function showLint(issues) {\n lintIssues = issues || [];\n if (lintIssues.length) { lint.hidden = false; $('ap-lint-n').textContent = lintIssues.length + ' lint issue' + (lintIssues.length > 1 ? 's' : ''); $('ap-lint-b').textContent = lintIssues.join('\\n'); maybeAutoFix(); }\n else lint.hidden = true;\n }\n function lintVars() { return { ...vars(), lint: lintIssues.join('\\n') }; }\n function fixLint() { if (!cur || !lintIssues.length || typeof sendWith !== 'function') return; const text = tpl(E.pLint, lintVars()); askSt.textContent = 'fixing lint'; sendWith(text, focusPayload()); }\n function copyLint() { navigator.clipboard.writeText(lintIssues.join('\\n')); }\n function maybeAutoFix() {\n if (!E.autoFixLint || !cur || !lintIssues.length || (window.inflightTurn && window.inflightTurn())) return;\n const key = cur.id + ':' + lintIssues.join('|');\n autoFixed[cur.id] = autoFixed[cur.id] || { rounds: 0, last: '' };\n const st = autoFixed[cur.id]; if (st.rounds >= 2 || st.last === key) return;\n st.rounds++; st.last = key; setTimeout(fixLint, 400);\n }\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, fixLint, copyLint, 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",[232],"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",[240],"0b992977-7e91-405a-8e51-7642b04aaad8","test.txt","e40c4538-ad82-11f1-82c6-1607ee4eb77e",1432,["D",1789091310842],[250],"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}",[256],"903f8626-211f-4ba4-b8d7-4952169f0056","router.tsx","334f4f70-7c3a-11f1-857e-1607ee4eb77e",1449,["D",1789091786257],36,"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\", vendor_order: (Deno.env.get(\"OMNI_VENDOR_ORDER\") ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean),\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",[264],"16b59061-8d36-4a7a-86c9-899887e12d08","router-state.ts","b109aa6c-ab4e-11f1-8d3d-1607ee4eb77e",1446,["D",1789091784754],8,"// 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 coolInfo = (name: string): Cooldown | undefined => mem.cool[name];\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",[273],"75f7a2a5-6cf6-4af5-94c6-82832f0fb4a8","router-openai.ts","6a8c10a8-ab4d-11f1-aa95-1607ee4eb77e",1448,["D",1789091785241],6,"// 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 exclude: Array.isArray(body.omni_exclude) ? body.omni_exclude.filter((v: unknown) => typeof v === \"string\").slice(0, 24) : undefined,\n vendorOrder: typeof body.omni_vendor_order === \"string\" ? body.omni_vendor_order.split(\",\").map((s: string) => s.trim().toLowerCase()).filter(Boolean).slice(0, 12) : Array.isArray(body.omni_vendor_order) ? body.omni_vendor_order.filter((v: unknown) => typeof v === \"string\").slice(0, 12) : 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",[281],"3ba4d79f-be8e-41dc-a05d-9f0d06316c50","router-discover.ts","b14c41f6-ab4e-11f1-8fec-1607ee4eb77e",1406,["D",1789017793310],"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",[289],"c8a652a4-7d06-4225-89fc-b93d3a6fd008","router-core.ts","6a4ef8c6-ab4d-11f1-9c11-1607ee4eb77e",1464,["D",1789096032027],20,"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, coolInfo, 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.\n/** Upper bound on vendor calls a single request may make while walking the roster: 40-line failure lists were 40 upstream calls\n * in ~50 s, which is what trips edge blocks and per-second limits. Override with OMNI_MAX_ATTEMPTS. */\nconst MAX_ATTEMPTS = Math.max(6, Number(Deno.env.get(\"OMNI_MAX_ATTEMPTS\") ?? 12) || 12);\n/** Real attempts one request may spend on a single vendor (all its key slots together) before moving to the next vendor:\n * five OpenRouter keys all hitting the same upstream 429 must not consume the whole request budget while together/nvidia sit untried. */\n/** Soft cap on one attempt while other candidates remain (ms). Env OMNI_ATTEMPT_CAP_MS. */\nconst ATTEMPT_CAP_MS = Math.max(8_000, Number(Deno.env.get(\"OMNI_ATTEMPT_CAP_MS\") ?? 25_000) || 25_000);\nconst MAX_PER_VENDOR = Math.max(2, Number(Deno.env.get(\"OMNI_MAX_PER_VENDOR\") ?? 3) || 3);\n/** Minimum spacing between calls to the same instance, per vendor (ms). Free tiers that limit requests per second. */\nconst MIN_GAP_MS: Record = { mistral: 1100, nvidia_nim: 700, siliconflow: 700, together: 350, huggingface: 500 };\nconst KEY_POLICY = ([\"breadth\", \"rr\"].includes(Deno.env.get(\"OMNI_KEY_POLICY\") ?? \"\") ? Deno.env.get(\"OMNI_KEY_POLICY\") : \"depth\") as \"depth\" | \"breadth\" | \"rr\";\nconst VENDOR_ORDER = (Deno.env.get(\"OMNI_VENDOR_ORDER\") ?? \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\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 let spent = 0;\n const spentBy: Record = {}; /* real attempts per vendor this request */ /* real inference attempts (rate/transient/size), for MAX_ATTEMPTS */\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}`); for (const k of Object.keys(spentBy)) spentBy[k] = 0; /* per-vendor budget is per round; the global cap still holds */\n }\n for (const p of resolved.targets) if (isCool(p.name)) { const c = coolInfo(p.name); errors.push(`${p.name}: cooling ${Math.ceil(((c?.until ?? 0) - Date.now()) / 1000)}s — ${c?.reason ?? \"\"}`.slice(0, 160)); }\n let targets = resolved.targets.filter((p) => !isCool(p.name));\n // per-request exclusion (the app excludes an instance that just returned an empty/garbage reply); ignored if it would leave nothing\n if (o.exclude?.length) { const kept = targets.filter((p) => !o.exclude!.includes(p.name)); /* instance names only: slot 0 is named like its vendor */ if (kept.length) { for (const p of targets) if (!kept.includes(p)) errors.push(`${p.name}: excluded by caller`); targets = kept; } }\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 // Explicit vendor order (OMNI_VENDOR_ORDER env or per-request omni_vendor_order): listed vendors go first, in that\n // order, every key slot of one before the next vendor, and the deadline-fit heuristic does not demote them — the\n // user chose them; a slow vendor gets a capped max_tokens and the app continues the reply. Unlisted vendors keep the\n // quality/priority ranking behind them.\n const order = o.vendorOrder ?? VENDOR_ORDER;\n const rankOf = (p: ProviderInstance) => { const i = order.indexOf(p.vendor); return i === -1 ? order.length : i; };\n targets = [...targets].sort((a, b) => (+!!a.paid - +!!b.paid) || rankOf(a) - rankOf(b) || (rankOf(a) < order.length ? 0 : (+!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 && rankOf(p) === order.length && 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 if (spent >= MAX_ATTEMPTS) { errors.push(`attempt cap ${MAX_ATTEMPTS} reached — remaining instances not tried`); break; }\n if ((spentBy[p.vendor] ?? 0) >= MAX_PER_VENDOR) { errors.push(`${p.name}: skipped (${MAX_PER_VENDOR} attempts already spent on ${p.vendor} this request)`); continue; }\n // Pacing: free tiers with a per-second limit (mistral: 1 req/s) fail on bursts, and a swarm is a burst. Space calls to the same\n // instance by its vendor's minimum gap — a short wait beats a 429 that cools the key for a minute.\n const gap = MIN_GAP_MS[p.vendor] ?? 0; const sinceLast = Date.now() - (statFor(p.name)?.last ?? 0);\n if (gap && sinceLast < gap) { if (left() < gap - sinceLast + 3000) { errors.push(`${p.name}: paced (last call ${sinceLast} ms ago)`); continue; } await new Promise((r) => setTimeout(r, gap - sinceLast)); }\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 if (spent >= MAX_ATTEMPTS || (spentBy[p.vendor] ?? 0) >= MAX_PER_VENDOR) { 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 // One attempt may not eat the whole deadline while other instances are still queued: cap it so a slow model\n // leaves room for at least one more try elsewhere (floor 8 s; the last candidate gets everything that is left).\n const others = idx < targets.length - 1 || i < models.length - 1;\n const perAttempt = others ? Math.min(left(), Math.max(8_000, Math.min(left() * 0.6, ATTEMPT_CAP_MS))) : left();\n const res = await attempt(p, model, messages, o, Math.min(HARD_TIMEOUT_MS, perAttempt), 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 // quota/auth/model failures are instant rejections and do not count as spent capacity; everything else does\n if (!/^(quota|auth|model)$/.test(String((e as Fail).kind))) { spent++; spentBy[p.vendor] = (spentBy[p.vendor] ?? 0) + 1; }\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\": {\n // OpenRouter relays an UPSTREAM per-model limit (\"Provider returned error\" / \"temporarily rate-limited upstream\"): every key\n // sees the same wall, so park the model vendor-wide for 10 min and try this key's next model instead of burning the other keys.\n if (/provider returned error|rate-limited upstream|temporarily rate.?limited/i.test(e.message)) { await markDead(p.vendor, model, Date.now() + 600_000); errors.push(`${p.name}: ${model} rate-limited upstream (10 min), trying next model`); break; }\n await coolFor(p.name, e.retryAfterMs ?? COOL.rate, \"rate \" + e.message.slice(0, 80)); stop = true; break;\n }\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:\n // A TIMEOUT is the MODEL being too slow for the budget, not the key being broken: park that model vendor-wide for\n // 30 min (every key sees the same throughput) and try this key's next model. Other transient errors move to the next key.\n if (e.message === \"TIMEOUT\" && !forcedModel) { await markDead(p.vendor, model, Date.now() + 1_800_000); errors.push(`${p.name}: ${model} timed out — parked 30 min, trying next model`); break; }\n 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",[296],"f4612f85-5e74-4631-bd53-239e820c0dee","router-attempt.ts","c60156b4-abcf-11f1-b2a4-1607ee4eb77e",1445,["D",1789091784441],"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\"; vendorOrder?: string[]; exclude?: string[] };\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 // A 400 is a request/output defect, never billing: the body often quotes the model's own generation (tool_use_failed\n // carries failed_generation), and any \"credits\"/\"balance\" word in that text would otherwise cool the key for hours.\n if (status === 400) return \"transient\";\n if (status === 402 || (status === 403 && 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",[304],"907e461a-ab53-4642-a09e-fdbb24410980","rate-limit-tracker.ts","2ed0f30a-aae2-11f1-ad3f-1607ee4eb77e",1219,["D",1788802411124],"// 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}",[311],"14c474e8-2e93-4d58-a954-adbffc7c5b8b","quality-report.ts","fc3a82a2-ad8a-11f1-9829-1607ee4eb77e",1457,["D",1789094787388],"import { qualityReport } from \"./artifacts.ts\";\nconst basic = [{ path: \"index.html\", content: \"

\" }, { path: \"app.js\", content: \"const c=document.getElementById('c').getContext('2d');\\nfunction draw(){c.fillRect(0,0,10,10);requestAnimationFrame(draw)}\\ndraw();\\nalert('hi')\\n\" }];\nconst q = qualityReport(basic); console.log(q.length, \"findings\"); console.log(q.map(x => x.slice(0, 60)).join(\"\\n\"));\nconst good = Array.from({ length: 9 }, (_, i) => ({ path: i ? `m${i}.js` : \"index.html\", content: (i ? \"export const x=1;\\n\" : \"

nothing here yet

\") + \"// filler\\n\".repeat(110) }));\ngood.push({ path: \"README.md\", content: \"- f\\n\".repeat(12) });\ngood.push({ path: \"core.js\", content: \"devicePixelRatio; new ResizeObserver(()=>{}); document.addEventListener('visibilitychange',()=>{}); requestAnimationFrame(()=>{}); addEventListener('keydown',()=>{}); addEventListener('pointerdown',()=>{}); try{localStorage.getItem('a')}catch(e){} const schemaVersion=2; function undo(){} toast(); fetch('x').catch(()=>{})\" });\nconsole.log(\"good:\", qualityReport(good));\n",[318],"96c51c4a-75e5-4f3c-8509-86ed457fb151","prompts.ts","2f259634-abe2-11f1-966c-1607ee4eb77e",1469,["D",1789150842706],9,"// 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.\nimport { PROMPT_EXAMPLES } from \"./prompt-examples.ts\";\n\nexport type PromptKey = \"system\" | \"meta\" | \"firstExchange\" | \"plan\" | \"reconcile\" | \"critique\" | \"revise\" | \"reground\" | \"continue\" | \"summarize\" | \"workbench\" | \"skill\" | \"architect\" | \"builder\" | \"integrate\" | \"digest\" | \"completion\" | \"brief\" | \"compact\";\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\", \"features\", \"visual\"],\n integrate: [\"id\", \"issues\"],\n digest: [\"ask\", \"part\", \"n\", \"text\"],\n completion: [\"ask\", \"did\", \"reply\", \"quality\"],\n brief: [\"ask\"],\n compact: [\"previous\", \"transcript\"],\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 (binding, checked): you are the strongest engineer and designer on this project, and a build is a finished PRODUCT, never a demo. Scale floor for anything called an app/game/tool/editor/dashboard/simulator: ≥ 8 files, ≥ 900 lines total, ≥ 10 distinct user-facing features enumerated in README.md and all implemented. Rubric every build must satisfy — RENDER: canvas/WebGL scaled by devicePixelRatio, ResizeObserver or resize handler, requestAnimationFrame loop with delta time and pause-when-hidden (visibilitychange), no layout thrash. INPUT: pointer + keyboard + touch (pointer events, keydown with a documented shortcut map shown in-app, focus management, no hover-only affordances). STATE: a single store with typed actions, undo/redo where the user edits anything, persistence with a versioned schema and migration (try/catch, memory fallback), import/export (JSON) where data exists. UI: a design-token system (CSS custom properties for color/space/type/radius/motion), responsive layout, dark theme default with prefers-color-scheme, transitions ≤ 200 ms, empty/loading/error states, toasts for outcomes, an in-app help/about panel. ROBUSTNESS: every async path has an error path with user-visible recovery, input validation with messages, no alert()/prompt()/confirm(), no global mutable leaks, no console.log left in shipped code (a real logger with levels if logging exists). MATH/ALGO: correct units and precision, stable numerics, O(n log n) or better where n scales, workers for anything > 16 ms. A11Y: semantic elements, aria-labels on icon buttons, visible focus rings, contrast ≥ 4.5:1. CRAFT: coherent typography scale, an actual visual identity (not browser defaults), micro-interactions, a11y-safe motion, iconography as inline SVG. Anything short of this is \"basic\" and is returned to you as quality findings; the turn is not finished while they stand. 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",[384],"f4de80e9-04a6-4602-817c-5664568fd8f5","lint-portability.ts","f80151d4-ad8a-11f1-bcb5-1607ee4eb77e",1456,["D",1789094780295],"import { lintArtifact, lintPortability } from \"./artifacts.ts\";\nconst files = [\n { path: \"index.html\", content: `` },\n { path: \"main.js\", content: `import {DATA} from './data.js';\\nfetch('./levels.json').then(r=>r.json());\\nparent.postMessage({a:1},'*');\\nconst u = location.origin + '/api';\\nlocalStorage.setItem('k','v');\\nnavigator.serviceWorker.register('sw.js');\\nconst img='/artifact/12/x.png';\\nexport function boot(){ return DATA.length }` },\n { path: \"data.js\", content: `export const DATA=[1,2,3];` },\n { path: \"ok.js\", content: `// comment /artifact/1\\nfunction save(k,v){ try{ localStorage.setItem(k,v) }catch(e){ mem[k]=v } }\\nconst mem={};\\nif (window.parent !== window) { parent.postMessage('x','*'); }\\nexport { save };` },\n];\nconst p = lintPortability(files); console.log(p.join(\"\\n\")); console.log(\"count\", p.length, \"ok.js hits\", p.filter(x=>x.startsWith(\"ok.js\")).length);\nconsole.log(\"full\", lintArtifact(files).length);\n",[392],"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",[399],"b47557f3-ee0c-482b-b150-7cbd46be6a14","e2e9.mjs","05b43346-ad8b-11f1-a3e8-1607ee4eb77e",1460,["D",1789094803234],"import { chromium } from \"playwright-core\";\nimport fs from \"node:fs\";\nconst html = fs.readFileSync(\"app/page.html\", \"utf8\");\nconst files = { \"index.html\": \"

x

\", \"app.js\": \"console.log(1);\\n\".repeat(40) };\nconst b = await chromium.launch({ executablePath: \"/opt/pw-browsers/chromium\", args: [\"--no-sandbox\", \"--headless=new\"], ignoreDefaultArgs: [\"--headless=old\"] });\nconst p = await b.newPage({ viewport: { width: 1400, height: 800 } }); const errs = []; p.on(\"pageerror\", e => errs.push(e.message));\nlet qCount = 0, progressCalls = 0;\nawait p.route(\"**/*\", async (route) => { const u = new URL(route.request().url());\n if (u.host === \"cdnjs.cloudflare.com\") { const m = u.pathname.match(/codemirror\\/5\\.65\\.16\\/(.*)$/); const f = m ? \"/tmp/cm/\" + m[1] : null; if (f && fs.existsSync(f)) return route.fulfill({ contentType: f.endsWith(\".css\") ? \"text/css\" : \"text/javascript\", body: fs.readFileSync(f) }); return route.abort(); }\n if (u.host !== \"app.local\") return route.abort();\n if (u.search.includes(\"?artifact_files=\")) return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ id: 1, title: \"T\", kind: \"html\", session: \"s\", files: Object.entries(files).map(([path, content]) => ({ path, content })), issues: [] }) });\n if (u.search.startsWith(\"?q\")) { qCount++; const body = JSON.parse(route.request().postData()); await new Promise(r => setTimeout(r, 2500));\n if (qCount === 1) return route.fulfill({ status: 503, contentType: \"application/json\", body: JSON.stringify({ error: { message: \"router 503: ALL_PROVIDERS_EXHAUSTED_OR_COOLING\", details: [\"groq: cooling 20s — rate\", \"openrouter: TIMEOUT\"] } }) });\n return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ reply: \"done after retry (retryOf=\" + body.settings.retryOf + \")\", toolEvents: [{ hop: 0, tool: \"eval_js\", args: { code: \"1\" }, result: 1 }], meta: {} }) }); }\n if (u.search.includes(\"?progress\")) { progressCalls++; return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ events: [{ type: \"stage\", label: \"answering\" }, { type: \"pass\", n: 1, of: 8 }, { type: \"tool\", hop: 0, tool: \"read_artifact\", args: { id: 1 } }, { type: \"tool\", hop: 0, tool: \"eval_js\", args: { code: \"1\" } }].slice(0, Math.min(4, progressCalls)), next: 4 }) }); }\n if (u.pathname.startsWith(\"/artifact/\")) return route.fulfill({ contentType: \"text/html\", body: files[\"index.html\"] });\n if (u.search) return route.fulfill({ contentType: \"application/json\", body: \"[]\" });\n return route.fulfill({ contentType: \"text/html\", body: html }); });\nawait p.goto(\"https://app.local/\", { waitUntil: \"load\" }); await p.waitForTimeout(300);\n// A) editor resizes with the window\nawait p.evaluate(() => ART.open(1, 'split')); await p.waitForTimeout(900);\nconst h1 = await p.evaluate(() => document.querySelector('.CodeMirror').getBoundingClientRect().height);\nawait p.setViewportSize({ width: 1000, height: 500 }); await p.waitForTimeout(400);\nconst h2 = await p.evaluate(() => ({ cm: document.querySelector('.CodeMirror').getBoundingClientRect().height | 0, wrap: document.getElementById('ap-edwrap').getBoundingClientRect().height | 0, scroll: document.querySelector('.CodeMirror-scroll').clientHeight | 0 }));\nawait p.setViewportSize({ width: 1400, height: 800 }); await p.keyboard.press(\"Escape\"); await p.waitForTimeout(300);\n// B) live timeline: statuses, expanded row survives polling, retry loop\nawait p.evaluate(() => { SETTINGS.set('retryMinutes', 1); });\nawait p.fill(\"#inp\", \"hello\"); await p.keyboard.press(\"Enter\");\nawait p.waitForTimeout(3200); // first progress polls have landed\nconst r1 = await p.evaluate(() => { const tl = document.querySelector('#live-tl .tl'); const rows = [...tl.querySelectorAll('.tl-row')]; rows.find(r => r.dataset.kind === 'tool')?.click(); return { plan: [...tl.querySelectorAll('.tl-pl')].map(x => x.className.replace('tl-pl ', '') + ':' + x.textContent), rows: rows.map(r => r.querySelector('.tl-k').textContent + '=' + r.querySelector('.tl-st').textContent), header: tl.querySelector('.tl-sum').textContent, label: document.getElementById('typing-label').textContent }; });\nawait p.waitForTimeout(2000); // more polls → the expanded row must still be open\nconst r2 = await p.evaluate(() => { const tl = document.querySelector('#live-tl .tl'); return { stillOpen: !!tl.querySelector('.tl-row.open'), xVisible: getComputedStyle(tl.querySelector('.tl-row.open + .tl-x')).display, rows: tl.querySelectorAll('.tl-row').length, label: document.getElementById('typing-label').textContent }; });\nawait p.waitForTimeout(9000); // retry wait (8s) then second attempt\nconst r3 = await p.evaluate(() => ({ q: document.querySelectorAll('.msg-wrap.ai').length, reply: [...document.querySelectorAll('.msg-wrap.ai .msg-body')].pop()?.textContent, err: document.querySelectorAll('.err-card').length }));\nconsole.log(JSON.stringify({ h1, h2, r1, r2, r3, qCount }, null, 1)); console.log(\"errors:\", errs.filter(e => !/cdnjs/.test(e)));\nawait b.close();\n",[407],"c98a97b9-4cfd-4562-806c-462d1abcde70","e2e11.mjs","03081450-ad8b-11f1-bc95-1607ee4eb77e",1459,["D",1789094798792],"import { chromium } from \"playwright-core\";\nimport fs from \"node:fs\";\nconst html = fs.readFileSync(\"app/page.html\", \"utf8\");\nconst manifest = { title: \"Demo\", shared: \"x\", files: [{ path: \"index.html\", purpose: \"entry\" }, { path: \"a.js\", purpose: \"a\" }, { path: \"b.js\", purpose: \"b\" }, { path: \"c.js\", purpose: \"c\" }] };\nconst b = await chromium.launch({ executablePath: \"/opt/pw-browsers/chromium\", args: [\"--no-sandbox\", \"--headless=new\"], ignoreDefaultArgs: [\"--headless=old\"] });\nconst p = await b.newPage({ viewport: { width: 1400, height: 800 } }); const errs = []; p.on(\"pageerror\", e => errs.push(e.message));\nconst built = [], jobPosts = [], planCalls = []; let qBodies = [];\nawait p.route(\"**/*\", async (route) => { const u = new URL(route.request().url());\n if (u.host === \"cdnjs.cloudflare.com\") { const m = u.pathname.match(/codemirror\\/5\\.65\\.16\\/(.*)$/); const f = m ? \"/tmp/cm/\" + m[1] : null; if (f && fs.existsSync(f)) return route.fulfill({ contentType: f.endsWith(\".css\") ? \"text/css\" : \"text/javascript\", body: fs.readFileSync(f, \"utf8\") }); return route.abort(); }\n if (u.host !== \"app.local\") return route.abort();\n if (u.search.startsWith(\"?sessions\")) return route.fulfill({ contentType: \"application/json\", body: JSON.stringify([{ id: \"S1\", name: \"demo\", ts: 1 }]) });\n if (u.search.startsWith(\"?history\")) return route.fulfill({ contentType: \"application/json\", body: \"[]\" });\n if (u.search.startsWith(\"?job=list\")) return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ jobs: [{ artifactId: 7, manifest, done: [\"index.html\", \"a.js\"], failed: [\"b.js\"], status: \"building\", title: \"Demo\", ask: \"make demo\" }] }) });\n if (u.search.startsWith(\"?job\")) { jobPosts.push(JSON.parse(route.request().postData())); return route.fulfill({ contentType: \"application/json\", body: \"{\\\"ok\\\":true}\" }); }\n if (u.search.startsWith(\"?plan\")) { planCalls.push(JSON.parse(route.request().postData()).q); return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ manifest, artifactId: 9, title: \"Demo\" }) }); }\n if (u.search.startsWith(\"?build_file\")) { const body = JSON.parse(route.request().postData()); built.push(body.path); await new Promise(r => setTimeout(r, 300)); return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ ok: true, path: body.path, lines: 10, issues: [], meta: { instance: \"openrouter#2\" } }) }); }\n if (u.search.includes(\"?artifact_files=\")) return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ id: 7, title: \"Demo\", kind: \"html\", session: \"S1\", files: [{ path: \"index.html\", content: \"

x

\" }], issues: [] }) });\n if (u.search.startsWith(\"?q\")) { qBodies.push(JSON.parse(route.request().postData())); return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ reply: \"integrated\", toolEvents: [], meta: {}, completion: { done: true, remaining: [] } }) }); }\n if (u.search.startsWith(\"?slow\")) { await new Promise(r => setTimeout(r, 20000)); return route.fulfill({ body: \"late\" }); }\n if (u.pathname.startsWith(\"/artifact/\")) return route.fulfill({ contentType: \"text/html\", body: \"

x

\" });\n if (u.search && !u.search.startsWith(\"?s=\")) return route.fulfill({ contentType: \"application/json\", body: \"[]\" });\n return route.fulfill({ contentType: \"text/html\", body: html }); });\nawait p.goto(\"https://app.local/?s=S1\", { waitUntil: \"load\" }); await p.waitForTimeout(800);\n// A) worker-backed wait + fetchT timeout\nconst a = await p.evaluate(async () => { const t0 = performance.now(); await omniNet.wait(300); const dt = performance.now() - t0; let err = null; try { await omniNet.fetchT('?slow', {}, 1200); } catch (e) { err = e.message; } let stopped = null; const c = new AbortController(); setTimeout(() => c.abort(), 200); try { await omniNet.fetchT('?slow', { signal: c.signal }, 5000); } catch (e) { stopped = e.name; } return { dt: Math.round(dt), err, stopped }; });\n// B) resume card rendered from the server job row\nconst cardTxt = await p.evaluate(() => { const c = document.querySelector('.manifest'); return c ? { head: c.querySelector('.manifest-h span').textContent, btn: c.querySelector('[data-a=go]').textContent, st: [...c.querySelectorAll('.manifest-f')].map(r => r.querySelector('code').textContent + '=' + r.querySelector('.st').textContent) } : null; });\nawait p.click('.manifest [data-a=go]'); await p.waitForTimeout(2500);\nconst after = await p.evaluate(() => ({ st: [...document.querySelectorAll('.manifest-f')].map(r => r.querySelector('code').textContent + '=' + r.querySelector('.st').textContent), reply: [...document.querySelectorAll('.msg-wrap.ai .msg-body')].pop()?.textContent, title: document.title }));\n// C) app-scale ask auto-routes to the swarm\nawait p.evaluate(() => ART.close()); await p.waitForTimeout(300);\nawait p.fill(\"#inp\", \"build a step sequencer app with effects\"); await p.keyboard.press(\"Enter\"); await p.waitForTimeout(2500);\nawait p.evaluate(() => ART.close()); await p.waitForTimeout(300); await p.fill(\"#inp\", \"what time is it\"); await p.keyboard.press(\"Enter\"); await p.waitForTimeout(800);\nconst c = { planCalls, qAfter: qBodies.length, builtTotal: built.length };\nconsole.log(JSON.stringify({ c, a, cardTxt, built, after, jobStatuses: jobPosts.map(j => j.state.status + ':' + j.state.done.length), integrateQ: qBodies.length, integrateFocus: qBodies[0]?.settings?.focus?.id }, null, 1));\nconsole.log(\"errors:\", errs);\nawait b.close();\n",[414],"b7c4c47f-ee4d-45b4-adb4-ae594aa730ea","e2e10.mjs","008bd9f0-ad8b-11f1-ac72-1607ee4eb77e",1458,["D",1789094794612],"// lint strip: fix button sends a focused fix; auto-fix fires once; completion audit → automatic follow-up turn\nimport { chromium } from \"playwright-core\";\nimport fs from \"node:fs\";\nconst html = fs.readFileSync(\"app/page.html\", \"utf8\");\nconst files = { \"index.html\": \"\", \"app.js\": \"function init() {}\\n\" };\nconst b = await chromium.launch({ executablePath: \"/opt/pw-browsers/chromium\", args: [\"--no-sandbox\", \"--headless=new\"], ignoreDefaultArgs: [\"--headless=old\"] });\nconst p = await b.newPage({ viewport: { width: 1400, height: 800 } }); const errs = []; p.on(\"pageerror\", e => errs.push(e.message));\nconst posts = [];\nawait p.route(\"**/*\", async (route) => { const u = new URL(route.request().url());\n if (u.host !== \"app.local\") return route.abort();\n if (u.search.includes(\"?artifact_files=\")) return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ id: 7, title: \"T\", kind: \"html\", session: \"s\", files: Object.entries(files).map(([path, content]) => ({ path, content })), issues: [\"app.js:1: empty function body — \\\"function init() {}\\\" — replace with the real implementation\"] }) });\n if (u.search.startsWith(\"?q\")) { const body = JSON.parse(route.request().postData()); posts.push({ q: body.q.slice(0, 60), focus: body.settings.focus?.id, followup: body.settings.followup }); await new Promise(r => setTimeout(r, 300));\n const first = posts.length === 1 && !/Continue the task/.test(body.q);\n return route.fulfill({ contentType: \"application/json\", body: JSON.stringify({ reply: \"did part \" + posts.length, toolEvents: [{ hop: 0, tool: \"update_artifact\", args: { id: 7 }, result: { ok: true, id: 7, url: \"/artifact/7/\", title: \"T\" } }], meta: {}, completion: posts.length < 3 ? { done: false, remaining: [\"wire the keyboard handler in input.js\", \"add the score display\"] } : { done: true, remaining: [] } }) }); }\n if (u.search.includes(\"?progress\")) return route.fulfill({ contentType: \"application/json\", body: '{\"events\":[],\"next\":0}' });\n if (u.pathname.startsWith(\"/artifact/\")) return route.fulfill({ contentType: \"text/html\", body: files[\"index.html\"] });\n if (u.search) return route.fulfill({ contentType: \"application/json\", body: \"[]\" });\n return route.fulfill({ contentType: \"text/html\", body: html }); });\nawait p.goto(\"https://app.local/\", { waitUntil: \"load\" }); await p.waitForTimeout(300);\nawait p.evaluate(() => { ART.setSettings({ ...ART.settings(), codemirror: false, autoFixLint: true }); ART.open(7, 'split'); }); await p.waitForTimeout(1200);\nconst r1 = await p.evaluate(() => ({ lintShown: !document.getElementById('ap-lint').hidden, n: document.getElementById('ap-lint-n').textContent, btn: !!document.querySelector('#ap-lint-h button') }));\nawait p.waitForTimeout(3500); // auto-fix turn + completion follow-ups\nconst r2 = await p.evaluate(() => ({ auto: [...document.querySelectorAll('.msg-wrap.sys .msg-body')].map(x => x.textContent.split('\\n')[0]), ai: document.querySelectorAll('.msg-wrap.ai').length }));\nconsole.log(JSON.stringify({ r1, posts, r2 }, null, 1)); console.log(\"errors:\", errs);\nawait b.close();\n",[421],"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};",[428],"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",[436],"6b6be713-93fa-47ed-bafe-4eeb65f5abbe","catalog-paid.ts","b0d2b336-ab4e-11f1-a8c4-1607ee4eb77e",1463,["D",1789096031038],"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 // Credit-based (small free grants, then metered): ranked with the paid tier so they are last resorts, not daily drivers.\n { paid: true, vendor: \"deepinfra\", tps: 60, base: \"https://api.deepinfra.com/v1/openai\", keyEnv: \"DEEPINFRA_API_KEY\", priority: 41, tags: [\"coder\", \"reasoning\", \"long\"], models: [\"deepseek-ai/DeepSeek-V3.1\", \"Qwen/Qwen3-Coder-480B-A35B-Instruct\", \"meta-llama/Llama-3.3-70B-Instruct\"], prefer: \"deepseek|qwen3-coder|llama\" },\n { paid: true, vendor: \"fireworks\", tps: 120, base: \"https://api.fireworks.ai/inference/v1\", keyEnv: \"FIREWORKS_API_KEY\", priority: 42, tags: [\"coder\", \"reasoning\", \"long\"], models: [\"accounts/fireworks/models/deepseek-v3p1\", \"accounts/fireworks/models/qwen3-coder-480b-a35b-instruct\", \"accounts/fireworks/models/kimi-k2-instruct\"], prefer: \"deepseek|qwen3-coder|kimi\" },\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",[443],"682fd4d5-fa55-46d5-93e0-f51806c1f9c8","catalog-free.ts","b08f5190-ab4e-11f1-b3f3-1607ee4eb77e",1462,["D",1789096030770],"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 // ordered by throughput on the free tier: the 550B ultra model times out inside a 50 s turn and is a last resort\n models: [\"nvidia/nemotron-3-super-120b-a12b:free\", \"google/gemma-4-31b-it:free\", \"nvidia/nemotron-3.5-lightning:free\", \"thinkingmachines/inkling:free\", \"nvidia/nemotron-3-ultra-550b-a55b:free\"],\n prefer: \"super|gemma|lightning\" },\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",[450],"77436564-7814-4cf0-b359-a96fcd11f765","artifacts.ts","4b6b75ba-ac6f-11f1-a399-1607ee4eb77e",1440,["D",1789091643225],"// 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",[518],"273340ae-9854-4838-aaed-d7c30d3e5c9d","_inference-router-dev.tsx","676ac11c-4595-11f1-99e3-42b51c65c3df",1191,["D",1783675963454],"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 · v1472