[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","project-brain-general-superhero-v1","path","generic_controller_v22_schema_normalize.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":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":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/project-brain-general-superhero-v1/code/generic_controller_v22_schema_normalize.ts","extension","id","e6e7f16d-70e5-41ce-9277-787928ee4f77","fileId","01a0a865-3b87-733c-b52e-da43db30d525","parentId","branchId","46206f4c-dd85-446f-8795-9a683e5332d3","branchVersion",971,"latest",true,"createdAt",["D",1789531677691],"version",2,"fileType","script","content","const MODEL_FAST=\"nex-agi/nex-n2.5-mini:free\";\nconst MODEL_DEEP=\"nex-agi/nex-n2.5-pro:free\";\nconst MODEL_LING=\"inclusionai/ling-3.0-flash-fin:free\";\nconst GATEWAY=\"https://api.kilo.ai/api/gateway/chat/completions\";\nconst ROUTE_TIMEOUT_MS:Record={[MODEL_FAST]:6000,[MODEL_DEEP]:25000,[MODEL_LING]:25000};\nconst HEDGE_DELAY_MS=500;\nconst QUALITY_PREFERENCE_MS=1750;\nconst TYPESAFE_INPUT_PRICE_USD_PER_MILLION=0.042;\nconst TYPESAFE_MAX_INPUT_TOKENS_PER_RUN=100000;\nconst enc=new TextEncoder();\nexport async function sha256Text(s:string){return [...new Uint8Array(await crypto.subtle.digest(\"SHA-256\",enc.encode(s)))].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nexport const canonical=(x:any):string=>x===null||typeof x!==\"object\"?JSON.stringify(x):Array.isArray(x)?\"[\"+x.map(canonical).join(\",\")+\"]\":\"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canonical(x[k])).join(\",\")+\"}\";\n\nexport type CatalogAction={key:string,description:string,method:string,path:string,query_schema?:any,body_schema?:any,mutating?:boolean,grounded_query_fields?:string[],grounded_body_fields?:string[],grounded_query_sources?:Record,grounded_body_sources?:Record};\nexport type ControllerInput={goal:any,action_catalog:CatalogAction[],request_contracts:any,max_turns?:number};\nexport type Observation={status:number,data:any};\nexport type Executor=(action:{key:string,query:any,body:any,attempt_id?:string})=>Promise;\nexport type VerificationProbe=(action:{key:string,query:any,body:any},observation:Observation,history:any[])=>Promise<{verified:boolean,evidence:any}>;\n\nexport type RouteState={disabled:string[]};\ntype DecisionResult={args:any,telemetry:any};\nexport type ControllerResumeState={history:any[],telemetry:any[],verification:{verified:boolean,evidence:any},route_state:RouteState,next_turn:number};\nexport type ControllerRunOptions={resume_state?:ControllerResumeState,checkpoint?:(state:ControllerResumeState)=>Promise,routeDecision?:(ctx:{input:ControllerInput,keys:string[],history:any[],verification:{verified:boolean,evidence:any},mode:\"FAST\"|\"DEEP\",route_state:RouteState,progress_state:any,semantic_hint?:any})=>Promise,semanticRoute?:(ctx:{goal:any,latest_observation:any,verification:any,progress:any,action_keys:string[],current_mode:\"FAST\"|\"DEEP\"})=>Promise};\nconst decisionSchema=(keys:string[])=>({type:\"object\",additionalProperties:false,properties:{action_key:{type:\"string\",enum:[...keys,\"FINISH\"]},query_json:{type:\"string\"},body_json:{type:\"string\"},reason:{type:\"string\",minLength:1}},required:[\"action_key\",\"query_json\",\"body_json\",\"reason\"]});\nfunction routeError(message:string,retryable:boolean){const e:any=new Error(message);e.retryable_route=retryable;return e}\n\nasync function modelDecision(input:any,keys:string[],model:string,externalSignal?:AbortSignal):Promise{\n const request={model,messages:[\n {role:\"system\",content:\"You are one frozen generic goal-directed controller. Use only the supplied goal, public action catalog, request contracts, and observations. Do not assume hidden handles, values, ordering, or success. Every handle, version, receipt, token, identifier, or other reference field marked grounded must come from the matching observed provenance declared by the action contract, never from an unrelated observed string. Discovery searches use conjunctive term matching: start with a few discriminative terms and, after an empty result, shorten or simplify the query instead of making it more specific. Discover missing knowledge and capabilities at runtime. After any failed or stale action, use the new evidence to re-read, rediscover, or change the next action rather than blindly repeating it. Treat detailed deterministic verifier failures as authoritative diagnostic evidence about the artifact under test. When verifier output identifies failed checks, expected-versus-observed behavior, declarations, bindings, or preserved-state requirements and the relevant state is mutable, prioritize a causally targeted mutation that repairs those concrete failures. Before every action, reconcile progress_state.confirmed_mutations against the goal: never treat a required mutating step as complete unless a successful mutation is explicitly present there. If progress_state.stagnation_warning is true, stop repeating unchanged read-only observations; identify the unmet requirement and choose an action that advances it or an explicit verifier action. When a field is a runtime capability binding, use the observed registered capability identifier rather than a human-readable operation label. When repairing a declaration, prefer the minimal representation consistent with existing naming patterns plus authoritative semantics rather than inventing a new label. Do not restart discovery or repeat already-successful lifecycle steps unless later evidence invalidates them. If current authoritative knowledge plus verifier diagnostics already identify the defect, repair it directly rather than searching for redundant knowledge. Choose FINISH only when verification_state.verified is true. Return exactly one required tool call.\"},\n {role:\"user\",content:JSON.stringify(input)}\n ],tools:[{type:\"function\",function:{name:\"next_action\",description:\"Choose one public action or FINISH.\",parameters:decisionSchema(keys)}}],tool_choice:\"required\",temperature:0,max_tokens:1800,stream:false,reasoning:{effort:\"none\",exclude:true}};\n const timeoutMs=ROUTE_TIMEOUT_MS[model]??25000,ac=new AbortController();let timedOut=false,hedgeAborted=false;const timer=setTimeout(()=>{timedOut=true;ac.abort()},timeoutMs);const onAbort=()=>{hedgeAborted=true;ac.abort()};if(externalSignal){if(externalSignal.aborted)onAbort();else externalSignal.addEventListener(\"abort\",onAbort,{once:true})}let r:Response;\n try{r=await fetch(GATEWAY,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify(request),signal:ac.signal})}catch(e){const name=String((e as any)?.name??\"\");const retryable=timedOut||hedgeAborted||name===\"AbortError\"||e instanceof TypeError;throw routeError(hedgeAborted?\"MODEL_ROUTE_HEDGE_ABORT\":timedOut?\"MODEL_ROUTE_TIMEOUT\":\"MODEL_ROUTE_TRANSPORT_FAILURE\",retryable)}finally{clearTimeout(timer);externalSignal?.removeEventListener(\"abort\",onAbort)}\n const raw=await r.text();let j:any=null;try{j=JSON.parse(raw)}catch{throw routeError(\"MODEL_BAD_JSON\",false)}\n if(!r.ok){const retryable=r.status===408||r.status===429||r.status>=500;throw routeError(\"MODEL_HTTP_\"+r.status+\":\"+raw.slice(0,300),retryable)}\n if(j?.usage?.cost!==0)throw routeError(\"NONZERO_COST:\"+model+\":\"+String(j?.usage?.cost),false);\n const tc=j?.choices?.[0]?.message?.tool_calls?.[0];if(tc?.function?.name!==\"next_action\")throw routeError(\"MODEL_TOOL_REQUIRED:\"+model,false);\n let args:any;try{args=JSON.parse(String(tc.function.arguments||\"{}\"))}catch{throw routeError(\"MODEL_TOOL_ARGS_BAD_JSON\",false)}\n return {args,telemetry:{requested_model:model,resolved_model:j?.model??null,provider:j?.provider??null,cost:j?.usage?.cost,usage:j?.usage??null}};\n}\n\nexport async function __testRouteV10(callModel:(model:string,signal:AbortSignal)=>Promise,state:RouteState,hedgeDelayMs=HEDGE_DELAY_MS,qualityPreferenceMs=QUALITY_PREFERENCE_MS){\n const primary=MODEL_DEEP,secondary=MODEL_LING,disabled=new Set((state.disabled??[]).map(String)),failures:any[]=[];\n const outcome=(model:string,ac:AbortController)=>callModel(model,ac.signal).then(result=>({kind:\"success\" as const,model,result})).catch(error=>({kind:\"error\" as const,model,error}));\n const failClosed=(error:any)=>{throw error};\n const direct=async(model:string,hedged:boolean)=>{const ac=new AbortController(),o=await outcome(model,ac);if(o.kind===\"success\")return {ok:true,...o.result,used_model:model,disabled:[...disabled],route_failures:failures,hedged};if((o.error as any)?.retryable_route!==true)return failClosed(o.error);disabled.add(model);failures.push({model,error:String((o.error as any)?.message??o.error)});throw routeError(\"ALL_QUALITY_HEDGE_ROUTES_UNAVAILABLE\",false)};\n if(disabled.has(primary)){if(disabled.has(secondary))throw routeError(\"ALL_QUALITY_HEDGE_ROUTES_UNAVAILABLE\",false);return await direct(secondary,false)}\n if(disabled.has(secondary))return await direct(primary,false);\n const pa=new AbortController(),primaryP=outcome(primary,pa);let hedgeTimer:any;const hedgeTick=new Promise(resolve=>{hedgeTimer=setTimeout(()=>resolve({kind:\"hedge\"}),Math.max(0,hedgeDelayMs))});const first:any=await Promise.race([primaryP,hedgeTick]);\n if(first.kind!==\"hedge\"){clearTimeout(hedgeTimer);if(first.kind===\"success\")return {ok:true,...first.result,used_model:primary,disabled:[...disabled],route_failures:failures,hedged:false};if((first.error as any)?.retryable_route!==true)return failClosed(first.error);disabled.add(primary);failures.push({model:primary,error:String((first.error as any)?.message??first.error)});return await direct(secondary,true)}\n const sa=new AbortController(),secondaryP=outcome(secondary,sa);const firstAfterHedge:any=await Promise.race([primaryP,secondaryP]);\n if(firstAfterHedge.model===primary){if(firstAfterHedge.kind===\"success\"){sa.abort();return {ok:true,...firstAfterHedge.result,used_model:primary,disabled:[...disabled],route_failures:failures,hedged:true}}if((firstAfterHedge.error as any)?.retryable_route!==true){sa.abort();return failClosed(firstAfterHedge.error)}disabled.add(primary);failures.push({model:primary,error:String((firstAfterHedge.error as any)?.message??firstAfterHedge.error)});const s:any=await secondaryP;if(s.kind===\"success\")return {ok:true,...s.result,used_model:secondary,disabled:[...disabled],route_failures:failures,hedged:true};if((s.error as any)?.retryable_route!==true)return failClosed(s.error);disabled.add(secondary);failures.push({model:secondary,error:String((s.error as any)?.message??s.error)});throw routeError(\"ALL_QUALITY_HEDGE_ROUTES_UNAVAILABLE\",false)}\n if(firstAfterHedge.kind===\"error\"){if((firstAfterHedge.error as any)?.retryable_route!==true){pa.abort();return failClosed(firstAfterHedge.error)}disabled.add(secondary);failures.push({model:secondary,error:String((firstAfterHedge.error as any)?.message??firstAfterHedge.error)});const p:any=await primaryP;if(p.kind===\"success\")return {ok:true,...p.result,used_model:primary,disabled:[...disabled],route_failures:failures,hedged:true};if((p.error as any)?.retryable_route!==true)return failClosed(p.error);disabled.add(primary);failures.push({model:primary,error:String((p.error as any)?.message??p.error)});throw routeError(\"ALL_QUALITY_HEDGE_ROUTES_UNAVAILABLE\",false)}\n let prefTimer:any;const preferenceTick=new Promise(resolve=>{prefTimer=setTimeout(()=>resolve({kind:\"preference_expired\"}),Math.max(0,qualityPreferenceMs))});const preferred:any=await Promise.race([primaryP,preferenceTick]);\n if(preferred.kind===\"success\"){clearTimeout(prefTimer);sa.abort();return {ok:true,...preferred.result,used_model:primary,disabled:[...disabled],route_failures:failures,hedged:true}}\n if(preferred.kind===\"error\"){clearTimeout(prefTimer);if((preferred.error as any)?.retryable_route!==true){sa.abort();return failClosed(preferred.error)}disabled.add(primary);failures.push({model:primary,error:String((preferred.error as any)?.message??preferred.error)});return {ok:true,...firstAfterHedge.result,used_model:secondary,disabled:[...disabled],route_failures:failures,hedged:true}}\n pa.abort();return {ok:true,...firstAfterHedge.result,used_model:secondary,disabled:[...disabled],route_failures:failures,hedged:true};\n}\n\nfunction parseJson(s:any,fallback:any){try{return typeof s===\"string\"&&s.length?JSON.parse(s):fallback}catch{return fallback}}\nexport function __testNormalizeActionV22(spec:CatalogAction,query:any,body:any){\n const q={...(query&&typeof query===\"object\"&&!Array.isArray(query)?query:{})},b={...(body&&typeof body===\"object\"&&!Array.isArray(body)?body:{})};\n const oq={...q},ob={...b},qk=new Set(Object.keys(spec.query_schema??{})),bk=new Set(Object.keys(spec.body_schema??{}));\n for(const k of qk)if(q[k]===undefined&&ob[k]!==undefined){q[k]=ob[k];if(!bk.has(k))delete b[k]}\n for(const k of bk)if(b[k]===undefined&&oq[k]!==undefined){b[k]=oq[k];if(!qk.has(k))delete q[k]}\n return{query:q,body:b};\n}\nfunction compactHistory(h:any[]){return h.slice(-40).map(x=>({turn:x.turn,request:x.request,response:x.response,verification:x.verification}))}\nexport const __testCompactHistoryV11=compactHistory;\nfunction primitives(x:any,out:any[]=[]):any[]{if(x===null||typeof x!==\"object\"){out.push(x);return out}if(Array.isArray(x)){for(const v of x)primitives(v,out);return out}for(const v of Object.values(x))primitives(v,out);return out}\nfunction observed(value:any,history:any[]){const want=canonical(value);for(const h of history){for(const v of primitives(h?.response?.data,[])){if(canonical(v)===want)return true}}return false}\nfunction valuesUnderKeys(x:any,keys:Set,out:any[]=[]):any[]{if(x===null||typeof x!==\"object\")return out;if(Array.isArray(x)){for(const v of x)valuesUnderKeys(v,keys,out);return out}for(const [k,v] of Object.entries(x)){if(keys.has(k))primitives(v,out);valuesUnderKeys(v,keys,out)}return out}\nfunction observedFrom(value:any,history:any[],sourceKeys:string[]){const want=canonical(value),ks=new Set(sourceKeys);for(const h of history){for(const v of valuesUnderKeys(h?.response?.data,ks,[])){if(canonical(v)===want)return true}}return false}\nfunction validateAction(spec:CatalogAction,query:any,body:any,history:any[]){for(const k of Object.keys(spec.query_schema??{}))if(query?.[k]===undefined)return `MISSING_QUERY_FIELD:${k}`;for(const k of Object.keys(spec.body_schema??{}))if(body?.[k]===undefined)return `MISSING_BODY_FIELD:${k}`;for(const k of spec.grounded_query_fields??[])if(!observed(query?.[k],history))return `UNGROUNDED_QUERY_FIELD:${k}`;for(const k of spec.grounded_body_fields??[])if(!observed(body?.[k],history))return `UNGROUNDED_BODY_FIELD:${k}`;for(const [k,sources] of Object.entries(spec.grounded_query_sources??{}))if(!observedFrom(query?.[k],history,sources))return `BAD_QUERY_PROVENANCE:${k}`;for(const [k,sources] of Object.entries(spec.grounded_body_sources??{}))if(!observedFrom(body?.[k],history,sources))return `BAD_BODY_PROVENANCE:${k}`;return null}\nfunction deepSignal(x:any):boolean{if(x===null||typeof x!==\"object\")return false;if(Array.isArray(x))return x.some(deepSignal);for(const [k,v] of Object.entries(x)){if((k===\"replan_required\"&&v===true)||(k===\"pass\"&&v===false))return true;if(deepSignal(v))return true}return false}\nfunction chooseModel(history:any[]){const last=history.at(-1);if(!last)return MODEL_FAST;if(Number(last?.response?.status??0)>=400||deepSignal(last?.response?.data))return MODEL_DEEP;return MODEL_FAST}\nfunction targetLabelForRef(ref:any,history:any[],beforeTurn:number){if(typeof ref!==\"string\"||!ref)return null;for(let i=history.length-1;i>=0;i--){const h=history[i];if(Number(h?.turn??0)>beforeTurn)continue;const targets=h?.response?.data?.targets;if(!Array.isArray(targets))continue;const hit=targets.find((x:any)=>x?.visual_target_ref===ref);if(hit&&hit.label!==undefined)return String(hit.label)}return null}\nfunction buildProgressState(history:any[]){\n const successful=history.filter((h:any)=>Number(h?.response?.status??0)>=200&&Number(h?.response?.status??0)<300&&h?.response?.data?.ok!==false&&(typeof h?.request?.attempt_id===\"string\"||typeof h?.response?.data?.clicked_visual_target_ref===\"string\"));\n const confirmed_mutations=successful.slice(-12).map((h:any)=>{const ref=h?.request?.query?.visual_target_ref??h?.request?.body?.visual_target_ref??h?.response?.data?.clicked_visual_target_ref??null;return{turn:Number(h.turn),action_key:String(h?.request?.key??\"\"),reason:String(h?.request?.reason??\"\"),visual_target_ref:ref,target_label:targetLabelForRef(ref,history,Number(h.turn)),status:Number(h?.response?.status??0)}});\n const lastMutationTurn=successful.length?Number(successful.at(-1)?.turn??0):0;const observed=history.filter((h:any)=>Number(h?.turn??0)>lastMutationTurn&&!h?.request?.attempt_id&&Number(h?.response?.status??0)>=200&&Number(h?.response?.status??0)<300&&typeof h?.response?.data?.screenshot_sha256===\"string\");let consecutive=0;const lastShot=observed.at(-1)?.response?.data?.screenshot_sha256??null;if(lastShot)for(let i=observed.length-1;i>=0;i--){if(observed[i]?.response?.data?.screenshot_sha256!==lastShot)break;consecutive++}\n let latest_visual_targets:any[]=[];for(let i=history.length-1;i>=0;i--){const t=history[i]?.response?.data?.targets;if(Array.isArray(t)&&t.length){latest_visual_targets=t.slice(0,20).map((x:any)=>({visual_target_ref:x?.visual_target_ref??null,label:x?.label??null,confidence:x?.confidence??null}));break}}\n return{schema:\"GENERIC_CONTROLLER_PROGRESS_STATE_V14\",confirmed_mutations,latest_visual_targets,last_successful_mutation_turn:lastMutationTurn,last_screenshot_sha256:lastShot,consecutive_same_screenshot_observations:consecutive,stagnation_warning:consecutive>=2};\n}\nexport const __testBuildProgressStateV14=buildProgressState;\nfunction externalProviderGate(history:any[]){const h=history.at(-1),d=h?.response?.data;if(d?.provider_gate!==true)return null;return{terminal:true,reason:\"EXTERNAL_PROVIDER_GATE\",action_key:String(h?.request?.key??\"\"),http_status:Number(h?.response?.status??0)||null,error_code:String(d?.error_code??\"EXTERNAL_PROVIDER_GATE\"),error:String(d?.error??\"\").slice(0,1500),retry_after_seconds:Number(d?.retry_after_seconds??0)||null,retry_not_before:typeof d?.retry_not_before===\"string\"?d.retry_not_before:null,last_turn:Number(h?.turn??0)||null};}\n\nfunction validateResumeState(state:ControllerResumeState,max:number){\n if(!state||!Array.isArray(state.history)||!Array.isArray(state.telemetry)||!state.verification||!state.route_state||!Array.isArray(state.route_state.disabled))throw new Error(\"BAD_RESUME_STATE\");\n const turns=state.history.map((x:any)=>Number(x?.turn));if(turns.some((x:number)=>!Number.isInteger(x)||x<1))throw new Error(\"BAD_RESUME_STATE\");for(let i=1;imax&&!terminalBudgetCheckpoint))throw new Error(\"BAD_RESUME_STATE\");\n}\nexport async function runFrozenGenericControllerV15(input:ControllerInput,execute:Executor,probe:VerificationProbe,options:ControllerRunOptions={}){\n const max=Math.max(1,Math.min(64,Number(input.max_turns??32)));\n const keys=input.action_catalog.map(x=>x.key);\n if(keys.length===0||new Set(keys).size!==keys.length)throw new Error(\"BAD_ACTION_CATALOG\");\n const seed=options.resume_state?structuredClone(options.resume_state):null;if(seed)validateResumeState(seed,max);\n const history:any[]=seed?.history??[];const telemetry:any[]=seed?.telemetry??[];let verification=seed?.verification??{verified:false,evidence:null as any};let finish:any=null;let termination:any=externalProviderGate(history);let routeState:RouteState=seed?.route_state??{disabled:[]};const startTurn=seed?.next_turn??1;let typesafeInputTokensUsed=telemetry.reduce((n:number,x:any)=>n+((x?.semantic_preroute&&x.semantic_preroute.cache_hit!==true)?Math.max(0,Number(x?.semantic_preroute?.usage?.input_tokens??0)):0),0);\n const emit=async(next_turn:number)=>{if(!options.checkpoint)return;const state:ControllerResumeState={history:structuredClone(history),telemetry:structuredClone(telemetry),verification:structuredClone(verification),route_state:{disabled:[...routeState.disabled]},next_turn};await options.checkpoint(state)};\n await emit(startTurn);\n for(let turn=startTurn;turn<=max;turn++){\n if(termination)break;\n if(verification.verified===true){finish={turn,reason:\"DETERMINISTIC_VERIFIED_FINISH\"};break;}\n const progress_state=buildProgressState(history);const baselinePreferred=progress_state.stagnation_warning?MODEL_DEEP:chooseModel(history),baselineMode:\"FAST\"|\"DEEP\"=baselinePreferred===MODEL_DEEP?\"DEEP\":\"FAST\";const directPlans=__testDirectPlansV20(input.action_catalog,history),safeDirectPlans=directPlans.filter((x:any)=>x.mutating!==true);let semantic_hint:any=null;if(options.semanticRoute&&typesafeInputTokensUsed({key:x.key,description:x.description,mutating:false})),current_mode:baselineMode});if(semantic_hint?.cache_hit!==true)typesafeInputTokensUsed+=Math.max(0,Number(semantic_hint?.usage?.input_tokens??0))}catch(e){semantic_hint={schema:\"TYPESAFE_SEMANTIC_ROUTE_ERROR\",error:String((e as any)?.message??e),high_confidence:false,recommended_mode:null,direct_action_high_confidence:false}}}else if(options.semanticRoute){semantic_hint={schema:\"TYPESAFE_SEMANTIC_ROUTE_BUDGET_EXHAUSTED\",high_confidence:false,recommended_mode:null,direct_action_high_confidence:false,input_tokens_used:typesafeInputTokensUsed,input_token_cap:TYPESAFE_MAX_INPUT_TOKENS_PER_RUN}}const mode:\"FAST\"|\"DEEP\"=__testApplyTypeSafePreRouteV18(baselineMode,semantic_hint);const preferred=mode===\"DEEP\"?MODEL_DEEP:MODEL_FAST;const directPlan=semantic_hint?.direct_action_high_confidence===true?safeDirectPlans.find((x:any)=>x.key===semantic_hint.direct_action):null;\n let routed:any;try{routed=directPlan?{ok:true,args:{action_key:directPlan.key,query_json:JSON.stringify(directPlan.query??{}),body_json:JSON.stringify(directPlan.body??{}),reason:`TypeSafe direct semantic action: ${directPlan.key}`},telemetry:{requested_model:\"typesafe/jev-direct\",resolved_model:semantic_hint?.model??null,provider:\"typesafe\",cost:null,usage:semantic_hint?.usage??null},used_model:\"typesafe/jev-direct\",disabled:[...routeState.disabled],route_failures:[],hedged:false,semantic_direct:true}:options.routeDecision?await options.routeDecision({input,keys,history:compactHistory(history),verification:structuredClone(verification),mode,route_state:{disabled:[...routeState.disabled]},progress_state:structuredClone(progress_state),semantic_hint}):await __testRouteByModeV19(mode,(m:string,s:AbortSignal)=>modelDecision({goal:input.goal,action_catalog:input.action_catalog,request_contracts:input.request_contracts,history:compactHistory(history),progress_state,verification_state:verification,semantic_hint:semantic_hint?{failure_class:semantic_hint.failure_class??null,next_strategy:semantic_hint.next_strategy??null,needs_deep:semantic_hint.needs_deep??null,meaningful_progress:semantic_hint.meaningful_progress??null}:null,controller_mode:mode===\"DEEP\"?\"DEEP_REPAIR\":\"FAST_ROUTINE\"},keys,m,s),routeState)}catch(e){await emit(turn);throw e}\n routeState={disabled:[...(routed.disabled??routeState.disabled)]};\n telemetry.push({...routed.telemetry,controller_mode:mode===\"DEEP\"?\"DEEP_REPAIR\":\"FAST_ROUTINE\",route_failures:routed.route_failures??[],disabled_routes:[...routeState.disabled],hedged:routed.hedged===true,semantic_direct:routed.semantic_direct===true,semantic_preroute:semantic_hint?{schema:semantic_hint.schema??null,model:semantic_hint.model??null,latency_ms:semantic_hint.latency_ms??null,usage:semantic_hint.usage??null,cache_hit:semantic_hint.cache_hit===true,recommended_mode:semantic_hint.recommended_mode??null,high_confidence:semantic_hint.high_confidence===true,direct_action:semantic_hint.direct_action??null,direct_action_confidence:semantic_hint.direct_action_confidence??null,direct_action_high_confidence:semantic_hint.direct_action_high_confidence===true,failure_class:semantic_hint.failure_class??null,next_strategy:semantic_hint.next_strategy??null,cost_verified_zero:false}:null});\n const a=routed.args;if(a.action_key===\"FINISH\"){\n if(!verification.verified){history.push({turn,request:{key:\"FINISH\",reason:a.reason},response:{status:409,data:{ok:false,error:\"VERIFICATION_REQUIRED\"}},verification});await emit(turn+1);continue}\n finish={turn,reason:a.reason};break;\n }\n if(!keys.includes(String(a.action_key))){history.push({turn,request:{key:a.action_key},response:{status:400,data:{ok:false,error:\"UNKNOWN_ACTION\"}},verification});await emit(turn+1);continue}\n const spec=input.action_catalog.find(x=>x.key===a.action_key)!;\n const parsedQuery=parseJson(a.query_json,{}),parsedBody=parseJson(a.body_json,{}),normalized=__testNormalizeActionV22(spec,parsedQuery,parsedBody),query=normalized.query,body=normalized.body;\n const attempt_id=spec.mutating?`g-${turn}-${crypto.randomUUID().replaceAll(\"-\",\"\").slice(0,12)}`:undefined;\n const request={key:spec.key,query,body,attempt_id,reason:a.reason};\n const invalid=validateAction(spec,query,body,history);\n if(invalid){const response={status:409,data:{ok:false,error:\"ACTION_GROUNDING_REJECTED\",detail:invalid,replan_required:true}};verification={verified:false,evidence:null};history.push({turn,request,response,verification});await emit(turn+1);continue}\n const response=await execute(request);\n verification=await probe(request,response,history);\n history.push({turn,request,response,verification});termination=externalProviderGate(history);await emit(turn+1);if(termination)break;\n }\n const exhausted_turn_budget=termination===null&&finish===null&&verification.verified!==true&&Number(history.at(-1)?.turn??0)>=max;\n termination=termination??(exhausted_turn_budget?{terminal:true,reason:\"TURN_BUDGET_EXHAUSTED\",max_turns:max,last_turn:Number(history.at(-1)?.turn??0)}:finish?{terminal:true,reason:\"VERIFIED_FINISH\",last_turn:Number(finish?.turn??0)}:null);\n const semanticUsed=telemetry.some((x:any)=>x?.semantic_preroute);const typesafe_input_tokens=telemetry.reduce((s:number,x:any)=>s+(x?.semantic_preroute&&x.semantic_preroute.cache_hit!==true?Number(x.semantic_preroute?.usage?.input_tokens??0):0),0);const typesafe_cached_input_tokens_reused=telemetry.reduce((s:number,x:any)=>s+(x?.semantic_preroute?.cache_hit===true?Number(x.semantic_preroute?.usage?.input_tokens??0):0),0);const typesafe_estimated_cost_usd=typesafe_input_tokens*TYPESAFE_INPUT_PRICE_USD_PER_MILLION/1_000_000;const result={schema:\"FROZEN_GENERIC_CONTROLLER_RUN_V20_TYPESAFE\",exhausted_turn_budget,termination,controller_policy:{routine_mode_label:MODEL_FAST,quality_primary:MODEL_DEEP,hedge_model:MODEL_LING,hedge_delay_ms:HEDGE_DELAY_MS,quality_preference_ms:QUALITY_PREFERENCE_MS,history_retention_turns:40,max_turns_cap:64,route_timeouts_ms:ROUTE_TIMEOUT_MS,route_strategy:\"deterministic finish first; persistent cache; TypeSafe Jev direct non-mutating grounded action when confidence>=0.90 and needs_deep<=0.20; otherwise real FAST model; DEEP quality hedge only when needed\",deep_trigger:\"latest status>=400 OR nested pass=false OR replan_required=true OR repeated unchanged observations\",resumable_state:true,explicit_progress_state:true,confirmed_mutation_ledger:true,stagnation_guard:true,external_provider_gate_terminal:true,typesafe_semantic_preroute:true,typesafe_direct_nonmutating:true},verified:verification.verified,verification_evidence:verification.evidence,finish,history,telemetry,zero_cost:telemetry.every((x:any)=>x?.provider===\"typesafe\"?true:x?.cost===0)&&typesafe_input_tokens===0,typesafe_used:semanticUsed,typesafe_cost_verified_zero:typesafe_input_tokens===0,typesafe_input_tokens,typesafe_cached_input_tokens_reused,typesafe_input_price_usd_per_million:TYPESAFE_INPUT_PRICE_USD_PER_MILLION,typesafe_estimated_cost_usd,typesafe_input_token_cap:TYPESAFE_MAX_INPUT_TOKENS_PER_RUN,typesafe_estimated_cost_cap_usd:TYPESAFE_MAX_INPUT_TOKENS_PER_RUN*TYPESAFE_INPUT_PRICE_USD_PER_MILLION/1_000_000,typesafe_budget_exhausted:typesafeInputTokensUsed>=TYPESAFE_MAX_INPUT_TOKENS_PER_RUN};\n return {...result,result_sha256:await sha256Text(canonical(result))};\n}\nexport const runFrozenGenericControllerV15Gate=runFrozenGenericControllerV15;\n\nexport function __testApplyTypeSafePreRouteV18(baseline:\"FAST\"|\"DEEP\",semantic:any){if(semantic?.high_confidence!==true)return baseline;if(semantic?.recommended_mode===\"FAST\"&&Number(semantic?.needs_deep)<=0.20)return \"FAST\";if(semantic?.recommended_mode===\"DEEP\"&&Number(semantic?.needs_deep)>=0.80)return \"DEEP\";return baseline}\n\nexport async function __testRouteByModeV19(mode:\"FAST\"|\"DEEP\",callModel:(model:string,signal:AbortSignal)=>Promise,state:RouteState){\n if(mode===\"DEEP\")return await __testRouteV10(callModel,state);\n const disabled=new Set((state.disabled??[]).map(String));\n if(disabled.has(MODEL_FAST))return await __testRouteV10(callModel,state);\n const ac=new AbortController();\n try{const result=await callModel(MODEL_FAST,ac.signal);return{ok:true,...result,used_model:MODEL_FAST,disabled:[...disabled],route_failures:[],hedged:false}}\n catch(error){if((error as any)?.retryable_route!==true)throw error;disabled.add(MODEL_FAST);const fallback:any=await __testRouteV10(callModel,{disabled:[...disabled]});return{...fallback,disabled:[...new Set([...(fallback.disabled??[]),...disabled])],route_failures:[{model:MODEL_FAST,error:String((error as any)?.message??error)},...(fallback.route_failures??[])],hedged:true}}\n}\n\nexport const __testModelDecisionV19=modelDecision;\n\nexport function __testDirectPlansV20(catalog:CatalogAction[],history:any[]){\n const uniqueFromSources=(sources:string[])=>{const vals:any[]=[];const ks=new Set(sources);for(const h of history)valuesUnderKeys(h?.response?.data,ks,vals);const m=new Map(vals.map(v=>[canonical(v),v]));return[...m.values()]};\n const out:any[]=[];\n for(const spec of catalog){\n const query:any={},body:any={};let ok=true;\n for(const field of Object.keys(spec.query_schema??{})){\n const sources=spec.grounded_query_sources?.[field];\n if(!Array.isArray(sources)||sources.length===0){ok=false;break}\n const vals=uniqueFromSources(sources);if(vals.length!==1){ok=false;break}query[field]=vals[0];\n }\n if(!ok)continue;\n for(const field of Object.keys(spec.body_schema??{})){\n const sources=spec.grounded_body_sources?.[field];\n if(!Array.isArray(sources)||sources.length===0){ok=false;break}\n const vals=uniqueFromSources(sources);if(vals.length!==1){ok=false;break}body[field]=vals[0];\n }\n if(ok)out.push({key:spec.key,description:spec.description,query,body,mutating:spec.mutating===true});\n }\n return out;\n}\n","deleted",false,"label",[14],"6d135bbb-731b-4088-9c59-129c84174b8f",["D",1789475272117],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated General Superhero V1 capability substrate candidate","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","1b425052-b10b-11f1-95f8-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","6d135bbb731b40889c59129c84174b8f","tursoHostname","6d135bbb731b40889c59129c84174b8f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522252250],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_55":56,"_103":104,"_105":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",1180,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":42,"_147":42,"_148":42,"_149":32,"_150":-5,"_151":-7,"_152":-7,"_153":63,"_154":42,"_155":42,"_156":-5,"_157":42,"_158":42,"_159":42,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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"]