[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_199":200,"_201":202},"routes/_app.x.$handle.$name",{"_92":91,"_31":42,"_101":82,"_26":102,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":24,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_40":41,"_31":42,"_35":43,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66,"_67":66,"_68":69,"_70":69,"_71":69,"_72":66,"_73":66,"_74":75,"_76":77,"_78":79,"_80":24},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":20,"_33":34,"_35":36,"_37":14,"_38":39,"_23":24},"previous","deleted",false,"deletedHere","path","TEST_GENERATOR_R2.mjs","latestPath","fileId","7e3e0f3a-aac5-11f1-8099-1607ee4eb77e","name","fileType","content","import assert from 'node:assert/strict';\nimport { allocationDecision, executableFrontier, generateFrontierWork } from './causal_frontier_work_generator_r2.mjs';\n\nconst completed=['ROOT','LAW'];\nconst tasks=[\n {id:'ROOT',state:'COMPLETE',priority:1,depends_json:'[]'},\n {id:'LAW',state:'COMPLETE',priority:1,depends_json:'[]'},\n {id:'D',state:'LEASED',priority:100,depends_json:'[\"ROOT\",\"LAW\"]',requires_json:'[\"file_analysis\"]',writes_json:'[\"evidence:D\"]'},\n {id:'LATER',state:'READY',priority:999,depends_json:'[\"D\"]',requires_json:'[\"file_analysis\"]',writes_json:'[\"evidence:L\"]'},\n {id:'GUARDED',state:'READY',priority:50,depends_json:'[]',guards_satisfied:false}\n];\n\nconst f=executableFrontier(tasks,['D','LATER','GUARDED'],completed);\nassert.deepEqual(f.admitted.map(x=>x.id),['D']);\nassert.equal(f.rejected.find(x=>x.id==='LATER').reason,'UNMET_DEPENDENCIES');\nassert.equal(f.rejected.find(x=>x.id==='GUARDED').reason,'UNSATISFIED_GUARDS');\n\nassert.equal(allocationDecision([], {max_runnable_n:8}).target_n,1);\nassert.equal(allocationDecision([], {max_runnable_n:8,active_population_n:1}).reason,'BASELINE_POPULATION_IN_FLIGHT');\nassert.equal(allocationDecision([{n:1,verified_latency_s:100,verified_quality:1}], {max_runnable_n:8}).target_n,2);\nassert.equal(allocationDecision([\n {n:1,verified_latency_s:100,verified_quality:1},\n {n:2,verified_latency_s:70,verified_quality:1}\n], {max_runnable_n:8}).target_n,4);\nassert.equal(allocationDecision([\n {n:1,verified_latency_s:100,verified_quality:1},\n {n:2,verified_latency_s:101,verified_quality:1}\n], {max_runnable_n:8}).reason,'CONTENTION_SATURATION');\nassert.equal(allocationDecision([\n {n:1,verified_latency_s:100,verified_quality:0.8},\n {n:2,verified_latency_s:80,verified_quality:0.7}\n], {max_runnable_n:8,quality_target:1}).reason,'QUALITY_REGRESSION');\nassert.equal(allocationDecision([\n {n:1,verified_latency_s:100,verified_quality:1},\n {n:2,verified_latency_s:70,verified_quality:1}\n], {max_runnable_n:2}).reason,'CAPACITY_BOUND');\nassert.equal(allocationDecision([\n {n:1,verified_latency_s:100,verified_quality:1},\n {n:2,verified_latency_s:70,verified_quality:1}\n], {max_runnable_n:8,lower_bound_s:68,epsilon_s:2}).reason,'N_STAR_ESTABLISHED');\n\nconst g1=generateFrontierWork({\n tasks,frontier_node_ids:['D','LATER'],completed_ids:completed,max_runnable_n:4,\n curves_by_parent:{D:[{n:1,verified_latency_s:100,verified_quality:1}]},\n options_by_parent:{D:{quality_target:1,epsilon_s:3}}\n});\nassert.deepEqual(g1.admitted_frontier_nodes,['D']);\nassert.equal(g1.generated_tasks.length,1);\nconst t=g1.generated_tasks[0];\nfor (const k of ['parent_frontier_node','predicted_causal_contribution','independence_dedupe_identity','required_capabilities','required_resources','stop_consequence','invalid_consequence','marginal_value_hypothesis']) assert.ok(k in t,k);\nassert.equal(t.later_blocked_stage_capacity,0);\n\nconst g2=generateFrontierWork({\n tasks,frontier_node_ids:['D'],completed_ids:completed,max_runnable_n:4,\n curves_by_parent:{D:[{n:1,verified_latency_s:100,verified_quality:1}]},\n existing_dedupe_identities:[t.independence_dedupe_identity]\n});\nassert.equal(g2.generated_tasks.length,0);\n\n// Falsification anchor: E12-style counterexample, more structure was slower.\nconst e12=allocationDecision([\n {n:1,verified_latency_s:353.114127455,verified_quality:1,note:'E12 single'},\n {n:2,verified_latency_s:385.920956793,verified_quality:1,note:'E12 structured proxy'}\n], {max_runnable_n:8});\nassert.equal(e12.reason,'CONTENTION_SATURATION');\n\nconsole.log(JSON.stringify({ok:true,tests:14,e12_decision:e12,generator_sample:g1},null,2));\n","createdAt",["D",1788790062778],"branchVersion","branchId","3a482b85-9344-42eb-8e2f-8e03079e2ef8","id","362c5283-3a16-4816-835c-5401484577e5","cfwg-r2-review-9f3c",["D",1788789898951],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable CFWG R2 independent review harness","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_92":91,"_100":96},"org",{"_92":91,"_93":94,"_95":96,"_18":52,"_97":98,"_99":24},"branch",{"_13":81,"_31":82,"_40":39,"_83":41,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":42,"_90":91},"isOwned",7,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_40":41,"_31":42,"_35":195,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66,"_67":66,"_68":69,"_70":69,"_71":69,"_72":66,"_73":66,"_74":196,"_76":197,"_78":198,"_80":24},"tree",[174,175,176,177,178],"files",[174,175,176,177,178],"counts",{"_164":58,"_165":143,"_166":58,"_167":168,"_169":170},"contents",[123,124,125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_40":157,"_31":158,"_29":159,"_131":-5,"_38":39,"_37":160,"_133":134,"_35":161,"_13":58,"_32":20,"_33":162,"_23":24,"_138":-5,"_26":163},{"_40":151,"_31":152,"_29":153,"_131":-5,"_38":39,"_37":143,"_133":134,"_35":154,"_13":58,"_32":20,"_33":155,"_23":24,"_138":-5,"_26":156},{"_40":148,"_31":27,"_29":30,"_131":-5,"_38":39,"_37":14,"_133":134,"_35":149,"_13":58,"_32":20,"_33":34,"_23":24,"_138":-5,"_26":150},{"_40":140,"_31":141,"_29":142,"_131":-5,"_38":39,"_37":143,"_133":134,"_35":144,"_13":58,"_32":145,"_33":146,"_23":24,"_138":-5,"_26":147},{"_40":128,"_31":129,"_29":130,"_131":-5,"_38":39,"_37":132,"_133":134,"_35":135,"_13":58,"_32":136,"_33":137,"_23":24,"_138":-5,"_26":139},"e5249c02-18f3-476f-b1af-6a4d41e3b18b","review.ts","40cb9a82-aac5-11f1-ace6-1607ee4eb77e","parentId",2,"latest",true,["D",1788789959736],"script","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst manifest=JSON.parse(await (await blob.get(\"CFWG_R2_DURABILITY_MANIFEST_V2.json\")).text());\nconst enc=new TextEncoder(),dec=new TextDecoder();\nasync function shaBytes(b:Uint8Array){const d=await crypto.subtle.digest(\"SHA-256\",b);return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function shaText(s:string){return shaBytes(enc.encode(s))}\nconst parts:string[]=[],partChecks:any[]=[];\nfor(const p of manifest.package.parts){\n const name=p.blob_key.split(\"/\").pop();\n const t=await (await blob.get(name)).text(); parts.push(t);\n const h=await shaText(t);\n partChecks.push({part:p.part,bytes:enc.encode(t).length,sha256:h,expected:p.sha256,pass:h===p.sha256&&enc.encode(t).length===p.bytes});\n}\nconst b64=parts.join(\"\"), raw=atob(b64), gz=new Uint8Array(raw.length);\nfor(let i=0;ix===0))break;\n const name=dec.decode(h.slice(0,100)).replace(/\\0.*$/,\"\"),size=oct(dec.decode(h.slice(124,136)));\n const body=tar.slice(o+512,o+512+size);\n files[name]={bytes:size,sha256:await shaBytes(body),content:dec.decode(body)};\n o+=512+Math.ceil(size/512)*512;\n}\nconst summary={\n schema:\"CFWG_R2_INDEPENDENT_RECONSTRUCTION_9F3C_V1\",\n partChecks,\n base64:{bytes:enc.encode(b64).length,sha256:await shaText(b64),expected:manifest.package.base64_sha256},\n gzip:{bytes:gz.length,sha256:await shaBytes(gz),expected:manifest.package.gzip_sha256},\n tar:{bytes:tar.length,sha256:await shaBytes(tar),expected:manifest.package.tar_sha256},\n files:Object.fromEntries(Object.entries(files).map(([k,v]:any)=>[k,{bytes:v.bytes,sha256:v.sha256,expected:(manifest.files.find((x:any)=>x.path===k)||{}).sha256,pass:v.sha256===(manifest.files.find((x:any)=>x.path===k)||{}).sha256}]))\n};\nawait blob.set(\"RECONSTRUCTION_SUMMARY.json\",JSON.stringify(summary,null,2));\nfor(const [name,v] of Object.entries(files) as any)await blob.set(\"pkg/\"+name,v.content);\nconsole.log(JSON.stringify(summary,null,2));\n","label",[129],"0fa688e6-ee7b-48e0-b84c-03c815c8e1e7","monitor.ts","01a07c2f-bf31-7409-85f8-bb6dc29d2e41",1,["D",1788789898951],"interval","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\n// The URL to monitor. Change this to your website.\nconst URL_TO_MONITOR = \"https://example.com\";\n\nexport default async function () {\n let up = false;\n let detail = \"\";\n try {\n const res = await fetch(URL_TO_MONITOR);\n up = res.ok;\n detail = `HTTP ${res.status}`;\n } catch (e) {\n detail = String(e);\n }\n\n const last = await blob.getJSON(\"last-status\") as { up: boolean } | undefined;\n if (last?.up === up) return; // no change, stay quiet\n\n await blob.setJSON(\"last-status\", { up });\n if (last === undefined) return; // first run: just record the baseline\n\n await email({\n subject: up\n ? `Recovered: ${URL_TO_MONITOR} is back up (${detail})`\n : `Down: ${URL_TO_MONITOR} (${detail})`,\n text: `${URL_TO_MONITOR} is ${up ? \"back up\" : \"down\"}. ${detail}`,\n });\n}\n",[141],"870e0a20-db74-4ce8-a3bc-ca6f7705a0a6",["D",1788790062778],[27],"152446bc-c8ab-44a1-832d-40bb3728a1ee","README.md","01a07c2f-bf31-7409-85f8-b49ca902a5ff",["D",1788789898951],"# How do I get an email alert when my website goes down?\n\nThis val checks your website every 5 minutes and emails you (via Val Town's built-in std/email, to your account email) only when the status changes: one email when the site goes down, one when it recovers. The last known status is stored in blob storage, so you never get repeat alerts while the site stays down.\n\n## Setup\n\n1. Remix this val.\n2. In `monitor.ts`, change `URL_TO_MONITOR` to your website's URL.\n3. That's it. The first run records a baseline; after that you get an email on every down/recovered transition.\n\nNo API keys or environment variables needed. To test it, point `URL_TO_MONITOR` at a URL that 404s and run `monitor.ts` manually.\n",[152],"4d244b6d-49c0-45e7-9356-0137c3b35e84","GENERATOR_R2.mjs","7c6cc20a-aac5-11f1-885c-1607ee4eb77e",3,["D",1788790059783],"export const CONTRIBUTION_CLASSES = [\n {\n id: 'independent_falsification',\n role: 'immune',\n capabilities: ['file_analysis'],\n contribution: 'Try to falsify the parent frontier node result or its current limiting-factor hypothesis using an independent route.'\n },\n {\n id: 'alternative_solution',\n role: 'architect',\n capabilities: ['file_analysis'],\n contribution: 'Develop a materially different solution route that can remove the parent critical path or expose a shorter one.'\n },\n {\n id: 'verification',\n role: 'immune',\n capabilities: ['file_analysis'],\n contribution: 'Independently verify the parent success condition and detect false completion before integration.'\n },\n {\n id: 'decomposition',\n role: 'maker',\n capabilities: ['file_analysis'],\n contribution: 'Decompose the parent into independent causally useful subproblems that can shorten verified completion latency.'\n },\n {\n id: 'lower_bound_attack',\n role: 'scientist',\n capabilities: ['file_analysis'],\n contribution: 'Attack the claimed serial/lower-bound bottleneck and search for reformulations that make more work executable now.'\n },\n {\n id: 'evidence_acquisition',\n role: 'scout',\n capabilities: ['file_analysis', 'web_research'],\n contribution: 'Acquire only evidence whose resolution can change the parent decision or remove a current uncertainty bottleneck.'\n },\n {\n id: 'coordination_resource_optimization',\n role: 'coordinator',\n capabilities: ['file_analysis'],\n contribution: 'Reduce queueing, contention, duplication, integration, or verification overhead on the parent frontier node.'\n },\n {\n id: 'architecture_shortcut',\n role: 'architect',\n capabilities: ['file_analysis'],\n contribution: 'Search for deletion, bypass, reuse, or a simpler architecture that removes the parent limiter rather than optimizing it.'\n }\n];\n\nfunction asArray(v) {\n if (Array.isArray(v)) return v;\n if (typeof v === 'string') {\n try { const x = JSON.parse(v); return Array.isArray(x) ? x : []; } catch { return []; }\n }\n return [];\n}\n\nfunction finiteNumber(v, fallback = null) {\n const n = Number(v);\n return Number.isFinite(n) ? n : fallback;\n}\n\nexport function validateMeasurement(m) {\n const n = finiteNumber(m?.n);\n const t = finiteNumber(m?.verified_latency_s);\n const q = finiteNumber(m?.verified_quality);\n if (!Number.isInteger(n) || n < 1) return { ok: false, reason: 'BAD_N' };\n if (!(t >= 0)) return { ok: false, reason: 'BAD_LATENCY' };\n if (!(q >= 0 && q <= 1)) return { ok: false, reason: 'BAD_QUALITY' };\n return { ok: true, value: { n, verified_latency_s: t, verified_quality: q, note: String(m?.note ?? '') } };\n}\n\nexport function executableFrontier(tasks, frontierNodeIds, completedIds = []) {\n const byId = new Map(tasks.map(t => [String(t.id), t]));\n const completed = new Set(completedIds.map(String));\n for (const t of tasks) if (String(t.state) === 'COMPLETE') completed.add(String(t.id));\n const wanted = new Set(frontierNodeIds.map(String));\n const admitted = [];\n const rejected = [];\n\n for (const id of wanted) {\n const t = byId.get(id);\n if (!t) { rejected.push({ id, reason: 'MISSING_TASK' }); continue; }\n if (!['READY', 'LEASED'].includes(String(t.state))) {\n rejected.push({ id, reason: 'STATE_NOT_EXECUTABLE', state: String(t.state) });\n continue;\n }\n const deps = asArray(t.depends_json ?? t.depends_on ?? t.depends);\n const unmet = deps.filter(d => !completed.has(String(d)));\n if (unmet.length) { rejected.push({ id, reason: 'UNMET_DEPENDENCIES', unmet }); continue; }\n if (t.guards_satisfied === false) { rejected.push({ id, reason: 'UNSATISFIED_GUARDS' }); continue; }\n if (t.frontier_relevance === false) { rejected.push({ id, reason: 'NOT_CURRENT_FRONTIER_RELEVANT' }); continue; }\n admitted.push({ ...t, depends: deps });\n }\n return { admitted, rejected };\n}\n\nexport function allocationDecision(curve = [], opts = {}) {\n const qTarget = finiteNumber(opts.quality_target, 1);\n const epsilon = Math.max(0, finiteNumber(opts.epsilon_s, 0));\n const lowerBound = finiteNumber(opts.lower_bound_s, null);\n const maxN = Math.max(1, Math.floor(finiteNumber(opts.max_runnable_n, 1)));\n const minLatencyGainFraction = Math.max(0, finiteNumber(opts.min_latency_gain_fraction, 0.02));\n const minQualityGain = Math.max(0, finiteNumber(opts.min_quality_gain, 0.001));\n const activeN = Math.max(0, Math.floor(finiteNumber(opts.active_population_n, 0)));\n\n const checked = [];\n for (const raw of curve) {\n const v = validateMeasurement(raw);\n if (!v.ok) return { action: 'INVALID', reason: v.reason, bad_measurement: raw };\n checked.push(v.value);\n }\n checked.sort((a, b) => a.n - b.n);\n for (let i = 1; i < checked.length; i++) {\n if (checked[i].n === checked[i - 1].n) return { action: 'INVALID', reason: 'DUPLICATE_N' };\n }\n\n if (!checked.length) {\n if (activeN > 0) return { action: 'WAIT', reason: 'BASELINE_POPULATION_IN_FLIGHT', current_n: activeN, target_n: activeN, n_star: null };\n return { action: 'ALLOCATE', reason: 'NEED_BASELINE_N1', current_n: 0, target_n: 1, n_star: null };\n }\n\n const curr = checked.at(-1);\n if (activeN > curr.n) return { action: 'WAIT', reason: 'POPULATION_POINT_IN_FLIGHT', current_n: activeN, target_n: activeN, n_star: null };\n if (curr.verified_quality >= qTarget && lowerBound !== null && curr.verified_latency_s <= lowerBound + epsilon) {\n return { action: 'STOP', reason: 'N_STAR_ESTABLISHED', current_n: curr.n, target_n: curr.n, n_star: curr.n };\n }\n if (curr.n >= maxN) {\n return { action: 'STOP', reason: 'CAPACITY_BOUND', current_n: curr.n, target_n: curr.n, n_star: null };\n }\n if (checked.length === 1) {\n return { action: 'ALLOCATE', reason: 'NEED_NEXT_POPULATION_POINT', current_n: curr.n, target_n: Math.min(maxN, curr.n * 2), n_star: null };\n }\n\n const prev = checked.at(-2);\n const qualityDelta = curr.verified_quality - prev.verified_quality;\n const latencyGainFraction = prev.verified_latency_s > 0\n ? (prev.verified_latency_s - curr.verified_latency_s) / prev.verified_latency_s\n : 0;\n\n if (curr.verified_quality < qTarget) {\n if (qualityDelta < minQualityGain) {\n return {\n action: 'STOP', reason: qualityDelta < 0 ? 'QUALITY_REGRESSION' : 'QUALITY_BOUND_NO_MEANINGFUL_GAIN',\n current_n: curr.n, target_n: curr.n, n_star: null, quality_delta: qualityDelta, latency_gain_fraction: latencyGainFraction\n };\n }\n return {\n action: 'ALLOCATE', reason: 'QUALITY_IMPROVING_BELOW_TARGET', current_n: curr.n,\n target_n: Math.min(maxN, curr.n * 2), n_star: null, quality_delta: qualityDelta, latency_gain_fraction: latencyGainFraction\n };\n }\n\n if (prev.verified_quality >= qTarget && curr.verified_quality >= qTarget && latencyGainFraction < minLatencyGainFraction) {\n return {\n action: 'STOP', reason: latencyGainFraction < 0 ? 'CONTENTION_SATURATION' : 'LATENCY_SATURATION_KNEE',\n current_n: curr.n, target_n: curr.n, n_star: curr.n, quality_delta: qualityDelta, latency_gain_fraction: latencyGainFraction\n };\n }\n\n return {\n action: 'ALLOCATE', reason: 'POSITIVE_MARGINAL_VERIFIED_VALUE', current_n: curr.n,\n target_n: Math.min(maxN, curr.n * 2), n_star: null, quality_delta: qualityDelta, latency_gain_fraction: latencyGainFraction\n };\n}\n\nfunction mergeCapabilities(parentRequires, contributionRequires) {\n return [...new Set([...asArray(parentRequires), ...contributionRequires])].sort();\n}\n\nfunction makeTask(parent, contribution, slot, decision, opts) {\n const parentId = String(parent.id);\n const targetN = decision.target_n;\n const dedupe = `${parentId}::N${targetN}::${contribution.id}::S${slot}`;\n return {\n id: `CFWG-R2::${dedupe}`,\n authority_class: 'CANDIDATE_NONAUTHORITY',\n parent_frontier_node: parentId,\n target_population_n: targetN,\n contribution_class: contribution.id,\n proposed_role: contribution.role,\n predicted_causal_contribution: contribution.contribution,\n independence_dedupe_identity: dedupe,\n required_capabilities: mergeCapabilities(parent.requires_json ?? parent.requires, contribution.capabilities),\n required_resources: asArray(parent.writes_json ?? parent.resources),\n stop_consequence: `Stop this slice if ${parentId} verifies complete, this contribution becomes semantically duplicated, or measured marginal verified value at N=${targetN} is non-positive.`,\n invalid_consequence: 'Mark INVALID and return capacity to the current frontier if prerequisites, evidence isolation, resource fencing, or independent execution cannot be satisfied.',\n marginal_value_hypothesis: `This independent ${contribution.id} slice at target population N=${targetN} will reduce verified critical-path latency or increase verified quality for ${parentId}; falsify by T_D(N)/Q_D(N) measurement.`,\n quality_target: finiteNumber(opts.quality_target, 1),\n epsilon_s: Math.max(0, finiteNumber(opts.epsilon_s, 0)),\n allocation_reason: decision.reason,\n later_blocked_stage_capacity: 0\n };\n}\n\nexport function generateFrontierWork(input) {\n const tasks = Array.isArray(input?.tasks) ? input.tasks : [];\n const frontierNodeIds = Array.isArray(input?.frontier_node_ids) ? input.frontier_node_ids : [];\n const curves = input?.curves_by_parent ?? {};\n const options = input?.options_by_parent ?? {};\n const defaultMaxN = Math.max(1, Math.floor(finiteNumber(input?.max_runnable_n, 1)));\n const existingDedupe = new Set((input?.existing_dedupe_identities ?? []).map(String));\n const frontier = executableFrontier(tasks, frontierNodeIds, input?.completed_ids ?? []);\n const generated = [];\n const decisions = [];\n\n for (const parent of frontier.admitted.sort((a, b) => Number(b.priority ?? 0) - Number(a.priority ?? 0))) {\n const opts = { max_runnable_n: defaultMaxN, ...(options[String(parent.id)] ?? {}) };\n const decision = allocationDecision(curves[String(parent.id)] ?? [], opts);\n decisions.push({ parent_frontier_node: String(parent.id), ...decision });\n if (decision.action !== 'ALLOCATE') continue;\n const currentN = decision.current_n;\n const needed = Math.max(0, decision.target_n - currentN);\n for (let slot = 0; slot < needed; slot++) {\n const contribution = CONTRIBUTION_CLASSES[(currentN + slot) % CONTRIBUTION_CLASSES.length];\n const candidate = makeTask(parent, contribution, slot, decision, opts);\n if (!existingDedupe.has(candidate.independence_dedupe_identity)) {\n existingDedupe.add(candidate.independence_dedupe_identity);\n generated.push(candidate);\n }\n }\n }\n\n return {\n schema: 'CAUSAL_FRONTIER_WORK_GENERATOR_R2_OUTPUT_V1',\n admitted_frontier_nodes: frontier.admitted.map(t => String(t.id)),\n rejected_frontier_nodes: frontier.rejected,\n allocation_decisions: decisions,\n generated_tasks: generated,\n invariants: {\n later_blocked_stages_receive_capacity: false,\n correctness_before_latency: true,\n configured_identity_is_not_capacity: true,\n dedupe_is_required: true,\n measured_T_D_N_Q_D_N_controls_scaling: true,\n human_authority_approval: false\n }\n };\n}\n",[158],"pulls","branches","forks","envVars",{"_171":58,"_173":58},"connections",{"_171":58,"_172":58},"count","unfilledCount","emptyCount",{"_40":157,"_31":158,"_29":159,"_131":-5,"_38":39,"_37":160,"_133":134,"_35":192,"_13":58,"_32":20,"_33":162,"_23":24,"_138":-5,"_180":193,"_26":194},{"_40":151,"_31":152,"_29":153,"_131":-5,"_38":39,"_37":143,"_133":134,"_35":189,"_13":58,"_32":20,"_33":155,"_23":24,"_138":-5,"_180":190,"_26":191},{"_40":148,"_31":27,"_29":30,"_131":-5,"_38":39,"_37":14,"_133":134,"_35":186,"_13":58,"_32":20,"_33":34,"_23":24,"_138":-5,"_180":187,"_26":188},{"_40":140,"_31":141,"_29":142,"_131":-5,"_38":39,"_37":143,"_133":134,"_35":183,"_13":58,"_32":145,"_33":146,"_23":24,"_138":-5,"_180":184,"_26":185},{"_40":128,"_31":129,"_29":130,"_131":-5,"_38":39,"_37":132,"_133":134,"_35":179,"_13":58,"_32":136,"_33":137,"_23":24,"_138":-5,"_180":181,"_26":182},["D",1788789959736],"children",[],[129],["D",1788789898951],[],[141],["D",1788790062778],[],[27],["D",1788789898951],[],[152],["D",1788790059783],[],[158],["D",1788789898951],{"_92":91,"_100":96},{"_92":91,"_93":94,"_95":96,"_18":52,"_97":98,"_99":24},{"_13":81,"_31":82,"_40":39,"_83":41,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":42,"_90":91},"ctx",{"_74":-5,"_120":232,"_233":234,"_235":236,"_237":24,"_238":24,"_239":24,"_240":134,"_241":-5,"_242":-7,"_243":-7,"_244":58,"_245":24,"_246":24,"_247":-5,"_248":24,"_249":24,"_250":24,"_251":-5},"ENV",{"_203":204,"_205":206,"_207":82,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231},"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"]

Diff · v4