[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","r3a3-m6q9-shadow2","path","capacity/readonly_coalesce_v6_epoch_incarnation.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":38,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/mosadek/r3a3-m6q9-shadow2/code/capacity/readonly_coalesce_v6_epoch_incarnation.ts","extension","id","e4dc15f3-ccac-4075-b06b-b7f211c17463","readonly_coalesce_v6_epoch_incarnation.ts","fileId","01a092e7-153a-764e-9ced-d3ce5019bd4b","parentId","01a092e7-153a-764e-9cee-8e1fd2bf1108","branchId","1da4df5d-ade5-4da9-8efa-00b2d8f1294a","branchVersion",1,"latest",true,"createdAt",["D",1789171012789],"version",0,"fileType","script","content","import { classifyValidCoalesceResult, TRANSPORT_PRIORITY_CAP, MAX_JOB_TIMEOUT } from \"./readonly_coalesce_v5_incarnation.ts\";\nexport type EpochAtomicPlan={sql:string;args:unknown[];command:\"verify-chain\"|\"verify-claim-graph\"};\nfunction tn(t:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(t))throw new Error('BAD_TABLE');return t}\nfunction closedReadonlySql(a:string){return `(${a}.op='brain' AND json_valid(${a}.payload_json)=1 AND json_type(${a}.payload_json,'$.args')='array' AND json_array_length(json_extract(${a}.payload_json,'$.args'))=1 AND json_extract(${a}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph') AND json_type(${a}.payload_json,'$.timeout')='integer' AND json_extract(${a}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT} AND (SELECT COUNT(*) FROM json_each(${a}.payload_json))=2)`}\nfunction validRecoverStaleSql(a:string){return `(${a}.op='brain' AND json_valid(${a}.payload_json)=1 AND json_type(${a}.payload_json,'$.args')='array' AND json_array_length(json_extract(${a}.payload_json,'$.args'))=1 AND json_extract(${a}.payload_json,'$.args[0]')='recover-stale' AND json_type(${a}.payload_json,'$.timeout')='integer' AND json_extract(${a}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT} AND (SELECT COUNT(*) FROM json_each(${a}.payload_json))=2)`}\nfunction canonicalMutationSql(a:string){return `(${a}.op='brain' AND NOT ${closedReadonlySql(a)})`}\nfunction effectivePrioritySql(a:string){return `(CASE WHEN ${a}.priority > ${TRANSPORT_PRIORITY_CAP} THEN ${TRANSPORT_PRIORITY_CAP} ELSE ${a}.priority END)`}\nfunction mutatingReadyPrecedesSql(b:string,f:string){\n const br=validRecoverStaleSql(b);\n const bp=effectivePrioritySql(b),fp=effectivePrioritySql(f);\n return `(${canonicalMutationSql(b)} AND (\n ${br}\n OR (\n NOT ${br}\n AND (\n ${bp} > ${fp}\n OR (${bp}=${fp} AND (\n ${b}.created_at < ${f}.created_at\n OR (${b}.created_at=${f}.created_at AND ${b}.id<${f}.id)\n ))\n )\n )\n ))`;\n}\n\nexport function atomicSuccessfulCoalesceSqlV6(table='brain_bridge_jobs',authorityTable='brain_bridge_authority_epoch'){\n table=tn(table);authorityTable=tn(authorityTable);\n return `WITH leader AS MATERIALIZED (\n SELECT l.id,l.op,l.payload_json,l.priority,l.updated_at AS leased_at\n FROM ${table} l\n WHERE l.id=? AND l.state='LEASED' AND l.lease_owner=? AND l.lease_instance_id=? AND l.lease_attempt_id=? AND l.transport_lease_generation=? AND l.authority_epoch=? AND l.lease_expires_at IS NOT NULL AND l.lease_expires_at>datetime('now')\n AND l.op='brain' AND json_valid(l.payload_json)=1 AND json_type(l.payload_json,'$.args')='array' AND json_array_length(json_extract(l.payload_json,'$.args'))=1 AND json_extract(l.payload_json,'$.args[0]')=? AND json_type(l.payload_json,'$.timeout')='integer' AND json_extract(l.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT} AND (SELECT COUNT(*) FROM json_each(l.payload_json))=2\n AND EXISTS(SELECT 1 FROM ${authorityTable} a WHERE a.id=1 AND a.epoch=? AND a.writer='host_bridge' AND a.mode='ACTIVE')\n )\n UPDATE ${table} AS j SET state='COMPLETE',result_json=?,error_json=NULL,lease_owner=NULL,lease_instance_id=NULL,lease_attempt_id=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE j.id IN (SELECT id FROM leader) OR (\n j.state='READY' AND EXISTS(SELECT 1 FROM leader l WHERE j.op=l.op AND j.payload_json=l.payload_json AND j.priority=l.priority AND j.created_atj.id AND b.id<>l.id AND b.state='READY' AND ${mutatingReadyPrecedesSql('b','j')})\n AND NOT EXISTS(SELECT 1 FROM ${table} m WHERE m.id<>j.id AND m.id<>l.id AND m.state='LEASED' AND ${canonicalMutationSql('m')})\n AND NOT EXISTS(SELECT 1 FROM ${table} t WHERE t.id<>j.id AND t.id<>l.id AND t.state IN ('COMPLETE','FAILED') AND t.updated_at>=l.leased_at AND ${canonicalMutationSql('t')})\n )\n ) RETURNING id`;\n}\n\nexport function prepareAtomicCoalescePlanV6(resultJson:string,id:string,worker:string,instance:string,attempt:string,generation:number,authorityEpoch:number,success:boolean,table='brain_bridge_jobs',authorityTable='brain_bridge_authority_epoch'):EpochAtomicPlan|null{\n if(success!==true||!id||!worker||!instance||!attempt||!Number.isInteger(generation)||generation<1||!Number.isInteger(authorityEpoch)||authorityEpoch<1)return null;\n const command=classifyValidCoalesceResult(resultJson); if(command===null)return null;\n return {command,sql:atomicSuccessfulCoalesceSqlV6(table,authorityTable),args:[id,worker,instance,attempt,generation,authorityEpoch,command,authorityEpoch,resultJson]};\n}\n","deleted",false,"label",[47,24],"capacity","04900e5a-0cc1-401b-9ed8-b0fe6196756a",["D",1789171012789],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable R3A3 exact cohort falsifier","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a092e7-1539-7581-b5ef-8e522619d4aa","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","04900e5a0cc1401b9ed8b0fe6196756a","tursoHostname","04900e5a0cc1401b9ed8b0fe6196756a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_101":102,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":91,"_11":92,"_22":30,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":12,"_100":10},"isOwned",2,"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",{"_84":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":38,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":92,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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"]