[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_101":102,"_103":104},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","navneett","name","promote-gate","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":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":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/promote-gate/code/main.ts","extension","id","a3ff4c23-0b4f-439c-bd09-299768d58570","fileId","37c94354-a30d-11f1-bc2f-1607ee4eb77e","parentId","branchId","8e032c27-fa27-4075-808a-6c0e67566635","branchVersion",2,"latest",true,"createdAt",["D",1787941264758],"version",1,"fileType","http","content","// POST /promote — deterministic MLflow model promotion gate.\nconst json = (obj: unknown, status = 200) =>\n new Response(JSON.stringify(obj), {\n status,\n headers: { \"content-type\": \"application/json\" },\n });\n\nfunction utf8Compare(a: string, b: string): number {\n const ab = new TextEncoder().encode(a), bb = new TextEncoder().encode(b);\n const n = Math.min(ab.length, bb.length);\n for (let i = 0; i < n; i++) if (ab[i] !== bb[i]) return ab[i] - bb[i];\n return ab.length - bb.length;\n}\n\nfunction sortCodes(codes: string[]): string[] {\n return [...new Set(codes)].sort(utf8Compare);\n}\n\nfunction round12(x: number): number {\n return Math.round(x * 1e12) / 1e12;\n}\n\n// ---------- time ----------\nfunction parseTime(s: unknown): { ok: boolean; ms?: number } {\n if (typeof s !== \"string\") return { ok: false };\n const m = /^(\\d{4})-(\\d{2})-(\\d{2})T(\\d{2}):(\\d{2}):(\\d{2})(?:\\.(\\d{1,3}))?(Z|[+-]\\d{2}:\\d{2})$/.exec(s);\n if (!m) return { ok: false };\n const y = +m[1], mo = +m[2], d = +m[3], h = +m[4], mi = +m[5], se = +m[6];\n const fr = m[7] ?? \"\";\n const off = m[8];\n const isLeap = (yy: number) => (yy % 4 === 0 && yy % 100 !== 0) || yy % 400 === 0;\n if (mo < 1 || mo > 12) return { ok: false };\n const dim = [31, isLeap(y) ? 29 : 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31][mo - 1];\n if (d < 1 || d > dim) return { ok: false };\n if (h > 23 || mi > 59 || se > 59) return { ok: false };\n let offsetMin = 0;\n if (off !== \"Z\") {\n const om = /^([+-])(\\d{2}):(\\d{2})$/.exec(off)!;\n const oh = +om[2], omin = +om[3];\n if (oh > 14 || (oh === 14 && omin !== 0)) return { ok: false };\n offsetMin = (om[1] === \"-\" ? -1 : 1) * (oh * 60 + omin);\n }\n const ms = Date.UTC(y, mo - 1, d, h, mi, se) - offsetMin * 60000 + (+fr.padEnd(3, \"0\") || 0);\n return { ok: true, ms };\n}\n\n// ---------- policy ----------\ntype Any = Record;\n\nfunction checkPolicy(p: Any): boolean {\n if (!p || typeof p !== \"object\" || Array.isArray(p)) return false;\n const digestsOk = typeof p.datasetDigest === \"string\" && p.datasetDigest.length > 0 &&\n typeof p.schemaDigest === \"string\" && p.schemaDigest.length > 0;\n const ageOk = typeof p.maxAgeSeconds === \"number\" && Number.isSafeInteger(p.maxAgeSeconds) && p.maxAgeSeconds >= 0;\n const accOk = typeof p.accuracyFloor === \"number\" && Number.isFinite(p.accuracyFloor) && p.accuracyFloor >= 0 && p.accuracyFloor <= 1;\n const slicesOk = typeof p.requiredSlices === \"object\" && p.requiredSlices !== null && !Array.isArray(p.requiredSlices) &&\n Object.values(p.requiredSlices).every((v: any) => typeof v === \"number\" && Number.isFinite(v) && v >= 0 && v <= 1);\n const latOk = typeof p.maxLatencyMs === \"number\" && Number.isFinite(p.maxLatencyMs) && p.maxLatencyMs >= 0;\n const sizeOk = typeof p.maxSizeBytes === \"number\" && Number.isSafeInteger(p.maxSizeBytes) && p.maxSizeBytes >= 0;\n const impOk = typeof p.minImprovement === \"number\" && Number.isFinite(p.minImprovement) && p.minImprovement >= 0 && p.minImprovement <= 1;\n return digestsOk && ageOk && accOk && slicesOk && latOk && sizeOk && impOk;\n}\n\n// ---------- per-version gate evaluation ----------\nfunction evaluateVersion(v: Any, policy: Any, asOfMs: number): { codes: string[]; eligible: boolean } {\n const codes: string[] = [];\n const ev = v.evaluation;\n\n if (!ev || typeof ev !== \"object\" || Array.isArray(ev)) {\n return { codes: [\"MISSING_EVALUATION\"], eligible: false };\n }\n\n // timestamp\n const created = parseTime(ev.createdAt);\n if (!created.ok) {\n codes.push(\"INVALID_TIMESTAMP\");\n } else if (created.ms! > asOfMs) {\n codes.push(\"FUTURE_EVALUATION\");\n } else if (asOfMs - created.ms! > policy.maxAgeSeconds * 1000) {\n codes.push(\"STALE_EVALUATION\");\n }\n\n // metrics finiteness / ranges\n const acc = ev.accuracy, lat = ev.latencyMs, size = ev.sizeBytes;\n const accNum = typeof acc === \"number\" && Number.isFinite(acc);\n const latNum = typeof lat === \"number\" && Number.isFinite(lat);\n const sizeNum = typeof size === \"number\" && Number.isFinite(size);\n if (!accNum || !latNum || !sizeNum) {\n codes.push(\"NON_FINITE\");\n } else {\n if (acc < 0 || acc > 1) codes.push(\"METRIC_RANGE\");\n if (lat < 0) codes.push(\"METRIC_RANGE\");\n if (!Number.isSafeInteger(size) || size < 0) codes.push(\"METRIC_RANGE\");\n }\n\n // lineage binding\n if (ev.artifactDigest !== v.artifactDigest) codes.push(\"ARTIFACT_MISMATCH\");\n if (ev.datasetDigest !== policy.datasetDigest) codes.push(\"DATASET_MISMATCH\");\n if (ev.schemaDigest !== policy.schemaDigest) codes.push(\"SCHEMA_MISMATCH\");\n\n // slices\n const slices = (ev.slices && typeof ev.slices === \"object\" && !Array.isArray(ev.slices)) ? ev.slices : null;\n if (!slices) {\n for (const name of Object.keys(policy.requiredSlices)) {\n codes.push(`MISSING_SLICE:${name}`);\n }\n } else {\n for (const [name, floor] of Object.entries(policy.requiredSlices as Record)) {\n const val = slices[name];\n if (val === undefined || val === null) {\n codes.push(`MISSING_SLICE:${name}`);\n } else if (typeof val !== \"number\" || !Number.isFinite(val) || val < 0 || val > 1) {\n codes.push(`SLICE_RANGE:${name}`);\n } else if (val < floor) {\n codes.push(`SLICE_FLOOR:${name}`);\n }\n }\n }\n\n // gates\n if (accNum && (acc < policy.accuracyFloor)) codes.push(\"ACCURACY_FLOOR\");\n if (latNum && (lat > policy.maxLatencyMs)) codes.push(\"LATENCY_LIMIT\");\n if (sizeNum && Number.isSafeInteger(size) && size > policy.maxSizeBytes) codes.push(\"SIZE_LIMIT\");\n\n return { codes: sortCodes(codes), eligible: codes.length === 0 };\n}\n\n// ---------- entrypoint ----------\nexport default async function fetchHandler(req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === \"POST\" && (url.pathname === \"/promote\" || url.pathname === \"/promote/\")) {\n let body: Any;\n try {\n body = JSON.parse(await req.text());\n } catch {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n if (!body || typeof body !== \"object\" || Array.isArray(body)) {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n if (!body.policy || typeof body.policy !== \"object\" || Array.isArray(body.policy) ||\n !Array.isArray(body.versions) || typeof body.championVersion !== \"string\") {\n return json({ error: \"INVALID_INPUT\" }, 400);\n }\n return handlePromote(body);\n }\n return json({ service: \"promote-gate\", endpoint: \"POST /promote\" });\n}\n\nfunction handlePromote(body: Any) {\n const policy = body.policy;\n const policyOk = checkPolicy(policy);\n const asOf = parseTime(body.asOf);\n\n const versions: Any[] = body.versions;\n const failedGates: Record = {};\n const validVersions: Any[] = [];\n\n // version id canonicality / duplicates\n const seen = new Map();\n for (const v of versions) {\n const id = v && typeof v === \"object\" ? v.version : undefined;\n if (typeof id === \"string\") seen.set(id, (seen.get(id) ?? 0) + 1);\n }\n\n for (const v of versions) {\n const id = v && typeof v === \"object\" ? v.version : undefined;\n const canonical = typeof id === \"string\" && /^[1-9]\\d*$/.test(id) &&\n Number.isSafeInteger(+id) && +id <= Number.MAX_SAFE_INTEGER;\n const codes: string[] = [];\n if (!canonical) codes.push(\"INVALID_VERSION\");\n else if ((seen.get(id) ?? 0) > 1) codes.push(\"DUPLICATE_VERSION\");\n if (!policyOk || !asOf.ok) codes.push(\"INVALID_POLICY\");\n if (codes.length > 0) {\n failedGates[id ?? JSON.stringify(id)] = sortCodes(codes);\n continue;\n }\n const res = evaluateVersion(v, policy, asOf.ms!);\n if (res.codes.length > 0) {\n failedGates[id] = res.codes;\n } else {\n validVersions.push(v);\n }\n }\n\n // rank eligible: accuracy desc, latency asc, size asc, numeric version asc\n const ranked = validVersions.slice().sort((a, b) => {\n const ea = a.evaluation, eb = b.evaluation;\n if (eb.accuracy !== ea.accuracy) return eb.accuracy - ea.accuracy;\n if (ea.latencyMs !== eb.latencyMs) return ea.latencyMs - eb.latencyMs;\n if (ea.sizeBytes !== eb.sizeBytes) return ea.sizeBytes - eb.sizeBytes;\n return +a.version - +b.version;\n });\n\n const championVersion: string = body.championVersion;\n const champion = versions.find((v: Any) => v && v.version === championVersion);\n\n let action: string, selectedVersion: string | null, evidence: Any | null, aliasMutation: Any | null;\n\n const championValid = champion !== undefined &&\n !failedGates[championVersion] && policyOk && asOf.ok;\n\n if (!championValid) {\n action = \"block\";\n selectedVersion = null;\n evidence = null;\n aliasMutation = null;\n } else {\n const challenger = ranked[0] ?? champion;\n const delta = round12(challenger.evaluation.accuracy - champion.evaluation.accuracy);\n if (delta >= policy.minImprovement) {\n action = \"promote\";\n selectedVersion = challenger.version;\n evidence = challenger.evaluation;\n aliasMutation = { alias: \"champion\", version: challenger.version };\n } else {\n action = \"retain\";\n selectedVersion = champion.version;\n evidence = champion.evaluation;\n aliasMutation = null;\n }\n }\n\n const eligibleVersions = ranked.map((v: Any) => v.version);\n\n return json({\n action,\n championVersion,\n selectedVersion,\n eligibleVersions,\n failedGates,\n aliasMutation,\n evidence,\n });\n}\n","deleted",false,"label",[14],"3af5658b-3b01-4e4b-b320-e9cda8f7df52",["D",1787941201041],"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","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_100":96},"org",{"_9":10,"_93":94,"_95":96,"_54":55,"_97":98,"_99":42},"branch",{"_35":30,"_11":84,"_22":28,"_85":45,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":12,"_92":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",{"_77":-5,"_134":135,"_136":137,"_138":139,"_140":42,"_141":42,"_142":42,"_143":32,"_144":-5,"_145":-7,"_146":-7,"_147":61,"_148":42,"_149":42,"_150":-5,"_151":42,"_152":42,"_153":42,"_154":-5},"ENV",{"_105":106,"_107":108,"_109":84,"_110":111,"_112":113,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133},"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"]