[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","navneett","name","quantize-freeze","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":-5,"_53":-5,"_54":55,"_56":25,"_57":32,"_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":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":12,"_13":44},"permalink","https://www.val.town/x/navneett/quantize-freeze/code/main.ts","extension","id","90bc6c58-9784-4e36-88d2-ba3c8be52e0a","fileId","01a04978-1fac-70db-9ecc-4b01f53a2ffa","parentId","branchId","aa21f267-7519-4a44-ab76-173eb7192aa6","branchVersion",8,"latest",true,"createdAt",["D",1787940230285],"version",7,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ---------- storage ----------\nconst init = await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS freezes (\n freezeId TEXT PRIMARY KEY,\n request TEXT NOT NULL,\n response TEXT NOT NULL\n )`,\n);\n\n// ---------- helpers ----------\nconst enc = new TextEncoder();\n\nfunction sha256Hex(data: Uint8Array): Promise {\n return crypto.subtle.digest(\"SHA-256\", data as unknown as ArrayBuffer).then((h) =>\n [...new Uint8Array(h)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\")\n );\n}\n\nfunction utf8Compare(a: string, b: string): number {\n const ab = enc.encode(a), bb = enc.encode(b);\n const n = Math.min(ab.length, bb.length);\n for (let i = 0; i < n; i++) {\n if (ab[i] !== bb[i]) return ab[i] - bb[i];\n }\n return ab.length - bb.length;\n}\n\nfunction isNonEmptyString(v: unknown): v is string {\n return typeof v === \"string\" && v.length > 0;\n}\n\nfunction deepEqual(a: unknown, b: unknown): boolean {\n if (a === b) return true;\n if (typeof a !== typeof b || a === null || b === null) return false;\n if (Array.isArray(a) && Array.isArray(b)) {\n if (a.length !== b.length) return false;\n return a.every((x, i) => deepEqual(x, b[i]));\n }\n if (typeof a === \"object\" && typeof b === \"object\") {\n const ka = Object.keys(a as object), kb = Object.keys(b as object);\n if (ka.length !== kb.length) return false;\n return ka.every((k) =>\n deepEqual((a as Record)[k], (b as Record)[k])\n );\n }\n return false;\n}\n\nfunction round12(x: number): number {\n return Math.round(x * 1e12) / 1e12;\n}\n\nfunction sortCodes(codes: string[]): string[] {\n return [...new Set(codes)].sort(utf8Compare);\n}\n\nconst json = (obj: unknown, status = 200) =>\n new Response(JSON.stringify(obj), {\n status,\n headers: { \"content-type\": \"application/json\" },\n });\n\n// ---------- freeze ----------\ntype Cand = Record;\n\nasync function handleFreeze(body: Cand) {\n // Hard 400 only for an empty/non-array candidate list (per spec); rejected IDs are not reserved.\n if (!Array.isArray(body.candidates) || body.candidates.length === 0) {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n\n const allowedRaw = Array.isArray(body.allowedUnsupportedReasons) ? body.allowedUnsupportedReasons : [];\n const allowed = allowedRaw.filter((r: unknown) => isNonEmptyString(r));\n\n // name duplication detection (names must be unique)\n const nameCounts = new Map();\n for (const cand of body.candidates) {\n if (cand && typeof cand === \"object\" && isNonEmptyString(cand.name)) {\n nameCounts.set(cand.name, (nameCounts.get(cand.name) ?? 0) + 1);\n }\n }\n\n const out: Cand[] = [];\n\n for (const cand of body.candidates) {\n const codes: string[] = [];\n let inventory: any[] = [];\n let totalBytes: number | null = null;\n let packageDigest: string | null = null;\n let status = \"frozen\";\n\n // candidate-level structural validation -> status invalid, NOT an HTTP 400\n const candValid =\n cand && typeof cand === \"object\" && !Array.isArray(cand) &&\n isNonEmptyString(cand.name) &&\n (nameCounts.get(cand.name) ?? 0) === 1;\n if (!candValid) {\n out.push({\n name: cand && typeof cand === \"object\" && isNonEmptyString(cand.name) ? cand.name : \"\",\n status: \"invalid\",\n inventory: [],\n totalBytes: null,\n packageDigest: null,\n reasonCodes: sortCodes([\"INVALID_INPUT\"]),\n });\n continue;\n }\n\n // manifest validation\n const files = cand.files;\n let filesOk = typeof files === \"object\" && files !== null && !Array.isArray(files) &&\n Object.keys(files).length > 0;\n let fileEntries: [string, unknown][] = [];\n if (filesOk) {\n fileEntries = Object.entries(files);\n if (!fileEntries.every(([, v]) => typeof v === \"string\")) filesOk = false;\n }\n if (!filesOk) {\n status = \"invalid\";\n codes.push(\"INVALID_INPUT\");\n } else {\n // inventory sorted by UTF-8 filename\n const built: any[] = [];\n for (const [fname, content] of fileEntries as [string, string][]) {\n const bytes = enc.encode(content);\n built.push({\n name: fname,\n bytes: bytes.length,\n sha256: await sha256Hex(bytes),\n });\n }\n built.sort((a, b) => utf8Compare(a.name, b.name));\n inventory = built;\n totalBytes = built.reduce((s, f) => s + f.bytes, 0);\n packageDigest = await sha256Hex(enc.encode(JSON.stringify(built)));\n }\n\n // reason check\n const reason = Object.prototype.hasOwnProperty.call(cand, \"unsupportedReason\")\n ? cand.unsupportedReason : undefined;\n const hasAllowedReason = reason !== undefined && reason !== null &&\n isNonEmptyString(reason) && allowed.includes(reason);\n if (reason !== undefined && reason !== null) {\n if (!isNonEmptyString(reason)) {\n status = \"invalid\";\n codes.push(\"INVALID_INPUT\");\n } else if (hasAllowedReason) {\n status = \"unsupported\";\n } else {\n status = \"invalid\";\n codes.push(\"UNALLOWED_UNSUPPORTED_REASON\");\n }\n }\n // loadable / digest checks (skipped only when an allowed reason applies)\n if (!hasAllowedReason) {\n if (cand.loadable !== true) {\n status = \"invalid\";\n codes.push(\"NOT_LOADABLE\");\n }\n if (cand.calibrationDigest !== body.calibrationDigest) {\n status = \"invalid\";\n codes.push(\"CALIBRATION_MISMATCH\");\n }\n if (cand.tokenizerDigest !== body.tokenizerDigest) {\n status = \"invalid\";\n codes.push(\"TOKENIZER_MISMATCH\");\n }\n }\n\n out.push({\n name: cand.name,\n status,\n inventory,\n totalBytes,\n packageDigest,\n reasonCodes: sortCodes(codes),\n });\n }\n\n out.sort((a, b) => utf8Compare(a.name, b.name));\n\n const response = { freezeId: body.freezeId, candidates: out };\n\n // persist (conflict detection + replay)\n const existing = await sqlite.execute(\n \"SELECT request, response FROM freezes WHERE freezeId = ?\",\n [body.freezeId],\n );\n if (existing.rows.length > 0) {\n const row = existing.rows[0] as { request: string; response: string };\n if (deepEqual(JSON.parse(row.request), body)) {\n return json(JSON.parse(row.response));\n }\n return json({ error: \"FREEZE_ID_CONFLICT\" }, 409);\n }\n await sqlite.execute(\n \"INSERT INTO freezes (freezeId, request, response) VALUES (?, ?, ?)\",\n [body.freezeId, JSON.stringify(body), JSON.stringify(response)],\n );\n return json(response);\n}\n\n// ---------- select ----------\nfunction handleSelect(body: Cand, frozen: Cand | null) {\n // shape check: array candidates + rows, object policy -> else hard 400\n const shapeOk = Array.isArray(body.candidates) && Array.isArray(body.rows) &&\n typeof body.policy === \"object\" && body.policy !== null && !Array.isArray(body.policy);\n if (!shapeOk) return json({ error: \"INVALID_INPUT\" }, 400);\n\n if (frozen === null) return json({ error: \"NOT_FROZEN\" }, 400);\n const storedCands = frozen.candidates;\n const norm = (arr: any[]) =>\n JSON.stringify([...arr].sort((a, b) => utf8Compare(a.name ?? \"\", b.name ?? \"\")));\n const submittedNorm = norm(body.candidates), storedNorm = norm(storedCands);\n if (submittedNorm !== storedNorm) {\n console.log(\"DEBUG lineage mismatch — submitted:\", submittedNorm.slice(0, 2500));\n console.log(\"DEBUG lineage mismatch — stored:\", storedNorm.slice(0, 2500));\n return json({ error: \"INVALID_LINEAGE\" }, 400);\n }\n\n const policy = body.policy;\n let policyOk =\n Number.isSafeInteger(policy.maxBytes) && policy.maxBytes >= 0 &&\n typeof policy.aggregateFloor === \"number\" && Number.isFinite(policy.aggregateFloor) &&\n policy.aggregateFloor >= 0 && policy.aggregateFloor <= 1 &&\n typeof policy.maxLatencyMs === \"number\" && Number.isFinite(policy.maxLatencyMs) && policy.maxLatencyMs >= 0 &&\n typeof policy.requiredSlices === \"object\" && policy.requiredSlices !== null && !Array.isArray(policy.requiredSlices) &&\n Object.values(policy.requiredSlices).every((v: any) =>\n typeof v === \"number\" && Number.isFinite(v) && v >= 0 && v <= 1\n ) &&\n Array.isArray(policy.candidateOrder) && policy.candidateOrder.every((n: unknown) => isNonEmptyString(n)) &&\n new Set(policy.candidateOrder).size === policy.candidateOrder.length;\n if (!policyOk) return json({ error: \"INVALID_POLICY\" }, 400);\n\n for (const row of body.rows) {\n if (typeof row !== \"object\" || row === null) return json({ error: \"INVALID_PREDICTIONS\" }, 400);\n if (!isNonEmptyString(row.slice) && row.slice !== undefined) return json({ error: \"INVALID_PREDICTIONS\" }, 400);\n }\n\n const candNames = storedCands.map((c: any) => c.name);\n const orderNames = new Set(policy.candidateOrder as string[]);\n if (orderNames.size !== candNames.length || !candNames.every((n: string) => orderNames.has(n))) {\n return json({ error: \"INVALID_POLICY\" }, 400);\n }\n\n // latencies\n const lat: Record = {};\n for (const n of candNames) {\n const v = (body.latencies ?? {})[n];\n lat[n] = typeof v === \"number\" && Number.isFinite(v) && v >= 0 ? v : null;\n }\n\n const required: Record = policy.requiredSlices;\n const requiredNames = Object.keys(required).sort(utf8Compare);\n\n const results: Cand[] = [];\n const candByOrder = (policy.candidateOrder as string[])\n .slice()\n .sort((a, b) => {\n const ai = candNames.indexOf(a), bi = candNames.indexOf(b);\n return ai - bi;\n });\n\n for (const name of candByOrder) {\n const stored = storedCands.find((c: any) => c.name === name);\n const codes: string[] = [];\n\n if (stored.status !== \"frozen\") {\n codes.push(stored.totalBytes === null ? \"INVALID_MANIFEST\" : \"NOT_FROZEN\");\n }\n\n // recompute totals from stored inventory (never trust submitted)\n let totalBytes: number | null = null;\n let manifestOk = true;\n if (Array.isArray(stored.inventory) && stored.inventory.length > 0) {\n let ok = true;\n totalBytes = stored.inventory.reduce((s: number, f: any) => s + f.bytes, 0);\n if (stored.totalBytes !== null && stored.totalBytes !== totalBytes) ok = false;\n manifestOk = ok;\n if (!ok) codes.push(\"INVALID_MANIFEST\");\n } else {\n manifestOk = false;\n if (stored.status === \"frozen\") codes.push(\"INVALID_MANIFEST\");\n }\n\n // predictions\n let predictionsValid = Array.isArray(body.rows) && body.rows.length > 0;\n const rowPreds: number[] = [];\n const sliceHits: Record = {};\n if (predictionsValid) {\n for (const row of body.rows) {\n const p = (row.predictions ?? {})[name];\n if (typeof row.predictions !== \"object\" || row.predictions === null ||\n (p !== 0 && p !== 1)) {\n predictionsValid = false;\n break;\n }\n rowPreds.push(p as number);\n const s = typeof row.slice === \"string\" ? row.slice : \"\";\n (sliceHits[s] ??= []).push(p as number);\n }\n }\n if (!predictionsValid) codes.push(\"INVALID_PREDICTIONS\");\n\n let aggregate: number | null = null;\n let slices: Record = {};\n\n if (predictionsValid) {\n aggregate = round12(rowPreds.reduce((s, p) => s + p, 0) / rowPreds.length);\n for (const sn of requiredNames) {\n const hits = sliceHits[sn];\n if (!hits || hits.length === 0) {\n slices[sn] = null;\n codes.push(`MISSING_SLICE:${sn}`);\n } else {\n const acc = round12(hits.reduce((s, p) => s + p, 0) / hits.length);\n slices[sn] = acc;\n if (acc < required[sn]) codes.push(`SLICE_FLOOR:${sn}`);\n }\n }\n if (aggregate < policy.aggregateFloor) codes.push(\"AGGREGATE_FLOOR\");\n } else {\n for (const sn of requiredNames) slices[sn] = null;\n }\n\n if (totalBytes === null || totalBytes > policy.maxBytes) codes.push(\"SIZE_LIMIT\");\n if (lat[name] === null || lat[name]! > policy.maxLatencyMs) codes.push(\"LATENCY_LIMIT\");\n\n const admitted =\n codes.length === 0 &&\n stored.status === \"frozen\" && manifestOk && predictionsValid &&\n aggregate !== null && totalBytes !== null && lat[name] !== null;\n\n results.push({\n name,\n aggregate: predictionsValid ? aggregate : null,\n slices,\n totalBytes,\n latencyMs: lat[name],\n admitted,\n reasonCodes: sortCodes(codes),\n });\n }\n\n // selection: smaller bytes, lower latency, then candidate order\n const admittedList = results.filter((r) => r.admitted);\n admittedList.sort((a, b) => {\n if (a.totalBytes !== b.totalBytes) return (a.totalBytes as number) - (b.totalBytes as number);\n if (a.latencyMs !== b.latencyMs) return (a.latencyMs as number) - (b.latencyMs as number);\n return candNames.indexOf(a.name) - candNames.indexOf(b.name);\n });\n const winner = admittedList[0] ?? null;\n\n return json({\n freezeId: body.freezeId,\n selected: winner ? winner.name : null,\n results,\n packageManifest: winner ? JSON.parse(JSON.stringify(winner)) : null,\n });\n}\n\n// ---------- entrypoint ----------\nexport default async function fetchHandler(req: Request): Promise {\n if (req.method !== \"POST\") return json({ error: \"INVALID_INPUT\" }, 400);\n const url = new URL(req.url);\n if (url.pathname !== \"/quantize\" && url.pathname !== \"/quantize/\" && url.pathname !== \"/adapt\" && url.pathname !== \"/adapt/\") {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n\n let body: Cand;\n try {\n body = await req.json();\n } catch {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n if (typeof body !== \"object\" || body === null || Array.isArray(body)) {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n\n if (body.phase === \"freeze\") return handleFreeze(body);\n if (body.phase === \"select\") {\n const stored = await sqlite.execute(\n \"SELECT response FROM freezes WHERE freezeId = ?\",\n [body.freezeId],\n );\n const frozen = stored.rows.length > 0\n ? JSON.parse((stored.rows[0] as any).response)\n : null;\n return handleSelect(body, frozen);\n }\n return json({ error: \"INVALID_INPUT\" }, 400);\n}\n","deleted",false,"label",[14],"3dd03321-46da-4511-883e-3c88a2058ab6",["D",1787938996146],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","0b226cf7-648e-4c18-a637-a242174ea0ae","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04960-730b-72cd-9a55-540d95db24cf","tursoName","3dd0332146da4511883e3c88a2058ab6","tursoHostname","3dd0332146da4511883e3c88a2058ab6-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789510270483],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":99},"org",{"_9":10,"_96":97,"_98":99,"_54":55,"_100":101,"_102":42},"branch",{"_35":30,"_11":87,"_22":28,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":12,"_95":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Navneet","avatar","https://lh3.googleusercontent.com/a/ACg8ocJAPndyQ_8iMhy-CLbFWFKg3UQvEmVag37z1F6jRx4Vf-V-Zw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_80":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":32,"_147":-5,"_148":-7,"_149":-7,"_150":61,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":87,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]