[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_148":149,"_150":151},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_87":69,"_88":89,"_67":-7,"_90":-5,"_13":91,"_92":93,"_11":94,"_95":96,"_97":98,"_99":-5,"_100":-5,"_101":-5,"_102":26,"_103":104,"_105":37,"_106":-5,"_107":-5,"_108":109},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":35,"_36":37,"_38":-5,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":-5,"_51":52,"_53":52,"_54":55,"_56":55,"_57":55,"_58":52,"_59":52,"_60":61,"_62":63,"_64":65,"_66":26},"query","handle","navneett","id","3dd03321-46da-4511-883e-3c88a2058ab6","name","quantize-freeze","createdAt",["D",1787938996146],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","0b226cf7-648e-4c18-a637-a242174ea0ae","pinnedFileId","01a04978-1fac-70db-9ecc-4b01f53a2ffa","pinPreview",true,"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",{"_16":17,"_86":82},"org",{"_16":17,"_79":80,"_81":82,"_32":33,"_83":84,"_85":26},"branch",{"_67":68,"_20":69,"_18":70,"_71":19,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":21,"_78":17},"isOwned","version",8,"main","aa21f267-7519-4a44-ab76-173eb7192aa6","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","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":143,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":35,"_36":37,"_38":-5,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_48":144,"_50":-5,"_51":52,"_53":52,"_54":55,"_56":55,"_57":55,"_58":52,"_59":52,"_60":145,"_62":146,"_64":147,"_66":26},"tree",[138],[138],"counts",{"_127":41,"_128":129,"_130":41,"_131":132,"_133":134},"contents",[110],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":111,"_20":112,"_113":35,"_114":-5,"_115":70,"_116":68,"_117":37,"_22":118,"_67":119,"_120":121,"_122":123,"_124":26,"_125":21,"_88":126},"90bc6c58-9784-4e36-88d2-ba3c8be52e0a","main.ts","fileId","parentId","branchId","branchVersion","latest",["D",1787940230285],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","label",[112],"pulls","branches",1,"forks","envVars",{"_135":41,"_137":41},"connections",{"_135":41,"_136":41},"count","unfilledCount","emptyCount",{"_18":111,"_20":112,"_113":35,"_114":-5,"_115":70,"_116":68,"_117":37,"_22":139,"_67":119,"_120":121,"_122":123,"_124":26,"_125":21,"_140":141,"_88":142},["D",1787940230285],"children",[],[112],["D",1787938996146],["D",1789510270483],{"_16":17,"_86":82},{"_16":17,"_79":80,"_81":82,"_32":33,"_83":84,"_85":26},{"_67":68,"_20":69,"_18":70,"_71":19,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":21,"_78":17},"ctx",{"_60":-5,"_107":181,"_182":183,"_184":185,"_186":26,"_187":26,"_188":26,"_189":37,"_190":-5,"_191":-7,"_192":-7,"_193":41,"_194":26,"_195":26,"_196":-5,"_197":26,"_198":26,"_199":26,"_200":-5},"ENV",{"_152":153,"_154":155,"_156":69,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search