[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_143":144,"_145":146},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_84":66,"_85":86,"_64":-7,"_87":-5,"_13":88,"_89":90,"_11":91,"_92":93,"_94":95,"_96":-5,"_97":-5,"_98":-5,"_99":26,"_100":101,"_102":37,"_103":-5,"_104":-5,"_105":106},"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":-5,"_45":-5,"_46":-5,"_47":-5,"_48":49,"_50":49,"_51":52,"_53":52,"_54":52,"_55":49,"_56":49,"_57":58,"_59":60,"_61":62,"_63":26},"query","handle","navneett","id","3af5658b-3b01-4e4b-b320-e9cda8f7df52","name","promote-gate","createdAt",["D",1787941201041],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","0b226cf7-648e-4c18-a637-a242174ea0ae","pinnedFileId","37c94354-a30d-11f1-bc2f-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04960-730b-72cd-9a55-540d95db24cf","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_83":79},"org",{"_16":17,"_76":77,"_78":79,"_32":33,"_80":81,"_82":26},"branch",{"_64":65,"_20":66,"_18":67,"_68":19,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":21,"_75":17},"isOwned","version",2,"main","8e032c27-fa27-4075-808a-6c0e67566635","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":139,"_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":-5,"_45":-5,"_46":-5,"_47":-5,"_48":49,"_50":49,"_51":52,"_53":52,"_54":52,"_55":49,"_56":49,"_57":140,"_59":141,"_61":142,"_63":26},"tree",[134],[134],"counts",{"_124":41,"_125":116,"_126":41,"_127":128,"_129":130},"contents",[107],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":108,"_20":109,"_110":35,"_111":-5,"_112":67,"_113":65,"_114":37,"_22":115,"_64":116,"_117":118,"_119":120,"_121":26,"_122":21,"_85":123},"a3ff4c23-0b4f-439c-bd09-299768d58570","main.ts","fileId","parentId","branchId","branchVersion","latest",["D",1787941264758],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","label",[109],"pulls","branches","forks","envVars",{"_131":41,"_133":41},"connections",{"_131":41,"_132":41},"count","unfilledCount","emptyCount",{"_18":108,"_20":109,"_110":35,"_111":-5,"_112":67,"_113":65,"_114":37,"_22":135,"_64":116,"_117":118,"_119":120,"_121":26,"_122":21,"_136":137,"_85":138},["D",1787941264758],"children",[],[109],["D",1787941201041],{"_16":17,"_83":79},{"_16":17,"_76":77,"_78":79,"_32":33,"_80":81,"_82":26},{"_64":65,"_20":66,"_18":67,"_68":19,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":21,"_75":17},"ctx",{"_57":-5,"_104":176,"_177":178,"_179":180,"_181":26,"_182":26,"_183":26,"_184":37,"_185":-5,"_186":-7,"_187":-7,"_188":41,"_189":26,"_190":26,"_191":-5,"_192":26,"_193":26,"_194":26,"_195":-5},"ENV",{"_147":148,"_149":150,"_151":66,"_152":153,"_154":155,"_156":157,"_158":159,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175},"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