[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_184":185,"_186":187},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_107":89,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":59,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_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":25},"version",14,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","scheduler.ts","latestPath","fileId","39cb6420-9def-11f1-a5c6-1607ee4eb77e","name","fileType","interval","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ntype Interval = { lastRunAt?: Date };\nconst now = () => Date.now();\nconst MAX_TASKS = 500;\n\nasync function setup() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n kind TEXT NOT NULL,\n title TEXT NOT NULL,\n target TEXT,\n state TEXT NOT NULL DEFAULT 'pending',\n priority INTEGER NOT NULL DEFAULT 50,\n attempts INTEGER NOT NULL DEFAULT 0,\n next_run_at INTEGER NOT NULL DEFAULT 0,\n last_run_at INTEGER,\n last_http INTEGER,\n last_error TEXT,\n last_result TEXT,\n updated_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n task_id TEXT,\n ts INTEGER NOT NULL,\n level TEXT NOT NULL,\n message TEXT NOT NULL\n )`);\n}\n\nasync function seed() {\n const seeds = [\n ['salla-bridge-health','http_health','فحص جسر سلة السحابي','https://salla-control-bridge.val.run/api/status',100],\n ['salla-store-health','http_health','فحص صفحة متجر غرفة الأخبار الذكية','https://salla.sa/smart-newsroom',95]\n ];\n for (const [id,kind,title,target,priority] of seeds) {\n await sqlite.execute({sql:`INSERT INTO tasks(id,kind,title,target,state,priority,next_run_at,updated_at)\n VALUES(?,?,?,?, 'pending', ?,0,?) ON CONFLICT(id) DO NOTHING`,args:[id,kind,title,target,priority,now()]});\n }\n}\n\nfunction delay(attempts:number) {\n return Math.min(6*60*60*1000, 15*60*1000 * Math.max(1, Math.pow(2, Math.min(attempts,4))));\n}\n\nasync function event(taskId:string, level:string, message:string) {\n await sqlite.execute({sql:`INSERT INTO events(task_id,ts,level,message) VALUES(?,?,?,?)`,args:[taskId,now(),level,message.slice(0,900)]});\n}\n\nasync function finish(task:any,state:string,result:any,error:string|null=null,http:number|null=null,nextRun:number=0) {\n await sqlite.execute({sql:`UPDATE tasks SET state=?,attempts=?,next_run_at=?,last_http=?,last_error=?,last_result=?,updated_at=? WHERE id=?`,args:[state,state==='retry'?Number(task.attempts)+1:0,nextRun,http,error,result==null?null:JSON.stringify(result).slice(0,7000),now(),task.id]});\n}\n\nasync function probe(url:string) {\n const ac=new AbortController();\n const timer=setTimeout(()=>ac.abort(),12000);\n try {\n const r=await fetch(url,{method:'GET',signal:ac.signal,headers:{'user-agent':'AI1000-Leader/1.1'}});\n const text=(await r.text()).slice(0,1600);\n return {url,http:r.status,ok:r.status>=200&&r.status<400,body:text};\n } finally { clearTimeout(timer); }\n}\n\nasync function runTask(task:any) {\n const started=now();\n await sqlite.execute({sql:`UPDATE tasks SET state='running',last_run_at=?,updated_at=? WHERE id=?`,args:[started,started,task.id]});\n await event(String(task.id),'info','job started by real worker');\n try {\n if (task.kind === 'http_health') {\n const p=await probe(String(task.target));\n const next=now()+(p.ok?15*60*1000:delay(Number(task.attempts)+1));\n await finish(task,p.ok?'done':'retry',p,p.ok?null:`HTTP ${p.http}`,p.http,next);\n await event(String(task.id),p.ok?'info':'warn',`${task.title}: HTTP ${p.http}`);\n return;\n }\n\n if (task.kind === 'command_health') {\n const results=await Promise.allSettled([\n probe('https://salla-control-bridge.val.run/api/status'),\n probe('https://salla.sa/smart-newsroom')\n ]);\n const normalized=results.map((r:any)=>r.status==='fulfilled'?r.value:{ok:false,error:String(r.reason)});\n const ok=normalized.every((x:any)=>x.ok===true);\n await finish(task,ok?'done':'retry',{executed:true,type:'system_health',checks:normalized},ok?null:'one_or_more_health_checks_failed',null,ok?0:now()+delay(Number(task.attempts)+1));\n await event(String(task.id),ok?'info':'warn',ok?'system health command executed':'health command needs retry');\n return;\n }\n\n if (task.kind === 'command_salla') {\n const routeChecks:any[]=[];\n const bridge=await probe('https://salla-control-bridge.val.run/api/status');\n let bridgeState:any=null; try { bridgeState=JSON.parse(bridge.body); } catch {}\n routeChecks.push({route:'cloud_mcp_bridge',ok:bridge.ok&&bridgeState?.connected===true,http:bridge.http,connected:bridgeState?.connected===true});\n\n if (bridge.ok && bridgeState?.connected===true) {\n await finish(task,'blocked',{executed:true,stage:'executor_selection',bank_policy:'fallback-first',routes_checked:routeChecks,selected:'cloud_mcp_bridge',reason:'Bridge authorization is active but a product write executor is not exposed yet'},'Salla product action executor not exposed yet',bridge.http,0);\n await event(String(task.id),'warn','Salla bridge connected; product write executor still missing');\n return;\n }\n\n const manager=await probe('https://salla-manager.athaqafimedia.com');\n routeChecks.push({route:'private_salla_manager',ok:manager.ok,http:manager.http,role:'candidate_executor'});\n const productPage=await probe('https://s.salla.sa/products/1935484287');\n routeChecks.push({route:'direct_product_dashboard',ok:productPage.ok,http:productPage.http,role:'dashboard_fallback'});\n const store=await probe('https://salla.sa/smart-newsroom');\n routeChecks.push({route:'public_store_verification',ok:store.ok,http:store.http,role:'verification_only'});\n\n const available=routeChecks.filter((x:any)=>x.ok).map((x:any)=>x.route);\n const bankRoutes=['Salla AI Connector/MCP','Product API GET/PUT','Product Actions','Bulk Product Actions/Bulk Editor','Mahally category/features','Sales Channels → Mahally','Direct product dashboard','Private Salla Manager','Resync + GET verification'];\n await finish(task,'blocked',{executed:true,stage:'fallback_router_exhausted_current_connectors',bank_policy:'do_not_stop_on_single_tool_or_oauth',routes_checked:routeChecks,available_routes:available,bank_routes:bankRoutes,reason:'No currently connected authorized write executor is exposed to this runtime; OAuth is not treated as the only path'},'No authorized Salla write executor currently exposed to leader runtime',bridge.http,0);\n await event(String(task.id),'warn',`Salla fallback router checked ${routeChecks.length} live paths; no authorized write executor exposed`);\n return;\n }\n\n if (task.kind === 'command_generic') {\n await finish(task,'blocked',{executed:true,stage:'router',reason:'No approved executor is connected for this command yet',command:String(task.target||'')},'No approved executor connected for this command',null,0);\n await event(String(task.id),'warn','Command accepted and routed, but no approved executor is connected');\n return;\n }\n\n throw new Error('unsupported task kind');\n } catch (e) {\n const attempts=Number(task.attempts)+1;\n const err=String(e).slice(0,700);\n await sqlite.execute({sql:`UPDATE tasks SET state='retry',attempts=?,next_run_at=?,last_error=?,updated_at=? WHERE id=?`,args:[attempts,now()+delay(attempts),err,now(),task.id]});\n await event(String(task.id),'error',err);\n }\n}\n\nexport async function runOne(id:string) {\n await setup();\n const r=await sqlite.execute({sql:`SELECT * FROM tasks WHERE id=?`,args:[id]});\n const task=r.rows[0] as any;\n if (!task) return {ok:false,error:'not_found'};\n if (!['pending','retry'].includes(String(task.state))) return {ok:true,skipped:true,state:task.state};\n await runTask(task);\n const done=await sqlite.execute({sql:`SELECT id,kind,title,state,attempts,last_http,last_error,last_result,last_run_at,updated_at FROM tasks WHERE id=?`,args:[id]});\n return {ok:true,job:done.rows[0]||null};\n}\n\n\nexport default async function (_interval: Interval) {\n await setup();\n await seed();\n const c=await sqlite.execute(`SELECT COUNT(*) AS n FROM tasks`);\n if (Number((c.rows[0] as any)?.n||0)>MAX_TASKS) throw new Error('logical task capacity exceeded');\n const due=await sqlite.execute({sql:`SELECT * FROM tasks WHERE state IN ('pending','retry','done') AND next_run_at<=? ORDER BY priority DESC,next_run_at ASC LIMIT 20`,args:[now()]});\n for (const task of due.rows) await runTask(task);\n console.log(JSON.stringify({ok:true,real_worker:true,processed:due.rows.length,total:Number((c.rows[0] as any)?.n||0),ts:new Date().toISOString()}));\n}","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ntype Interval = { lastRunAt?: Date };\nconst now = () => Date.now();\nconst MAX_TASKS = 500;\n\nasync function setup() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n kind TEXT NOT NULL,\n title TEXT NOT NULL,\n target TEXT,\n state TEXT NOT NULL DEFAULT 'pending',\n priority INTEGER NOT NULL DEFAULT 50,\n attempts INTEGER NOT NULL DEFAULT 0,\n next_run_at INTEGER NOT NULL DEFAULT 0,\n last_run_at INTEGER,\n last_http INTEGER,\n last_error TEXT,\n last_result TEXT,\n updated_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n task_id TEXT,\n ts INTEGER NOT NULL,\n level TEXT NOT NULL,\n message TEXT NOT NULL\n )`);\n}\n\nasync function seed() {\n const seeds = [\n ['salla-bridge-health','http_health','فحص جسر سلة السحابي','https://salla-control-bridge.val.run/api/status',100],\n ['salla-store-health','http_health','فحص صفحة متجر غرفة الأخبار الذكية','https://salla.sa/smart-newsroom',95]\n ];\n for (const [id,kind,title,target,priority] of seeds) {\n await sqlite.execute({sql:`INSERT INTO tasks(id,kind,title,target,state,priority,next_run_at,updated_at)\n VALUES(?,?,?,?, 'pending', ?,0,?) ON CONFLICT(id) DO NOTHING`,args:[id,kind,title,target,priority,now()]});\n }\n}\n\nfunction delay(attempts:number) {\n return Math.min(6*60*60*1000, 15*60*1000 * Math.max(1, Math.pow(2, Math.min(attempts,4))));\n}\n\nasync function event(taskId:string, level:string, message:string) {\n await sqlite.execute({sql:`INSERT INTO events(task_id,ts,level,message) VALUES(?,?,?,?)`,args:[taskId,now(),level,message.slice(0,900)]});\n}\n\nasync function finish(task:any,state:string,result:any,error:string|null=null,http:number|null=null,nextRun:number=0) {\n await sqlite.execute({sql:`UPDATE tasks SET state=?,attempts=?,next_run_at=?,last_http=?,last_error=?,last_result=?,updated_at=? WHERE id=?`,args:[state,state==='retry'?Number(task.attempts)+1:0,nextRun,http,error,result==null?null:JSON.stringify(result).slice(0,7000),now(),task.id]});\n}\n\nasync function probe(url:string) {\n const ac=new AbortController();\n const timer=setTimeout(()=>ac.abort(),12000);\n try {\n const r=await fetch(url,{method:'GET',signal:ac.signal,headers:{'user-agent':'AI1000-Leader/1.2'}});\n const text=(await r.text()).slice(0,1600);\n return {url,http:r.status,ok:r.status>=200&&r.status<400,body:text,error:null};\n } catch (e) {\n return {url,http:null,ok:false,body:'',error:String(e).slice(0,500)};\n } finally { clearTimeout(timer); }\n}\n\nasync function runTask(task:any) {\n const started=now();\n await sqlite.execute({sql:`UPDATE tasks SET state='running',last_run_at=?,updated_at=? WHERE id=?`,args:[started,started,task.id]});\n await event(String(task.id),'info','job started by real worker');\n try {\n if (task.kind === 'http_health') {\n const p=await probe(String(task.target));\n const next=now()+(p.ok?15*60*1000:delay(Number(task.attempts)+1));\n await finish(task,p.ok?'done':'retry',p,p.ok?null:`HTTP ${p.http}`,p.http,next);\n await event(String(task.id),p.ok?'info':'warn',`${task.title}: HTTP ${p.http}`);\n return;\n }\n\n if (task.kind === 'command_health') {\n const results=await Promise.allSettled([\n probe('https://salla-control-bridge.val.run/api/status'),\n probe('https://salla.sa/smart-newsroom')\n ]);\n const normalized=results.map((r:any)=>r.status==='fulfilled'?r.value:{ok:false,error:String(r.reason)});\n const ok=normalized.every((x:any)=>x.ok===true);\n await finish(task,ok?'done':'retry',{executed:true,type:'system_health',checks:normalized},ok?null:'one_or_more_health_checks_failed',null,ok?0:now()+delay(Number(task.attempts)+1));\n await event(String(task.id),ok?'info':'warn',ok?'system health command executed':'health command needs retry');\n return;\n }\n\n if (task.kind === 'command_salla') {\n const routeChecks:any[]=[];\n const bridge=await probe('https://salla-control-bridge.val.run/api/status');\n let bridgeState:any=null; try { bridgeState=JSON.parse(bridge.body); } catch {}\n routeChecks.push({route:'cloud_mcp_bridge',ok:bridge.ok&&bridgeState?.connected===true,http:bridge.http,connected:bridgeState?.connected===true});\n\n if (bridge.ok && bridgeState?.connected===true) {\n await finish(task,'blocked',{executed:true,stage:'executor_selection',bank_policy:'fallback-first',routes_checked:routeChecks,selected:'cloud_mcp_bridge',reason:'Bridge authorization is active but a product write executor is not exposed yet'},'Salla product action executor not exposed yet',bridge.http,0);\n await event(String(task.id),'warn','Salla bridge connected; product write executor still missing');\n return;\n }\n\n const manager=await probe('https://salla-manager.athaqafimedia.com');\n routeChecks.push({route:'private_salla_manager',ok:manager.ok,http:manager.http,role:'candidate_executor'});\n const productPage=await probe('https://s.salla.sa/products/1935484287');\n routeChecks.push({route:'direct_product_dashboard',ok:productPage.ok,http:productPage.http,role:'dashboard_fallback'});\n const store=await probe('https://salla.sa/smart-newsroom');\n routeChecks.push({route:'public_store_verification',ok:store.ok,http:store.http,role:'verification_only'});\n\n const available=routeChecks.filter((x:any)=>x.ok).map((x:any)=>x.route);\n const bankRoutes=['Salla AI Connector/MCP','Product API GET/PUT','Product Actions','Bulk Product Actions/Bulk Editor','Mahally category/features','Sales Channels → Mahally','Direct product dashboard','Private Salla Manager','Resync + GET verification'];\n await finish(task,'blocked',{executed:true,stage:'fallback_router_exhausted_current_connectors',bank_policy:'do_not_stop_on_single_tool_or_oauth',routes_checked:routeChecks,available_routes:available,bank_routes:bankRoutes,reason:'No currently connected authorized write executor is exposed to this runtime; OAuth is not treated as the only path'},'No authorized Salla write executor currently exposed to leader runtime',bridge.http,0);\n await event(String(task.id),'warn',`Salla fallback router checked ${routeChecks.length} live paths; no authorized write executor exposed`);\n return;\n }\n\n if (task.kind === 'command_generic') {\n await finish(task,'blocked',{executed:true,stage:'router',reason:'No approved executor is connected for this command yet',command:String(task.target||'')},'No approved executor connected for this command',null,0);\n await event(String(task.id),'warn','Command accepted and routed, but no approved executor is connected');\n return;\n }\n\n throw new Error('unsupported task kind');\n } catch (e) {\n const attempts=Number(task.attempts)+1;\n const err=String(e).slice(0,700);\n await sqlite.execute({sql:`UPDATE tasks SET state='retry',attempts=?,next_run_at=?,last_error=?,updated_at=? WHERE id=?`,args:[attempts,now()+delay(attempts),err,now(),task.id]});\n await event(String(task.id),'error',err);\n }\n}\n\nexport async function runOne(id:string) {\n await setup();\n const r=await sqlite.execute({sql:`SELECT * FROM tasks WHERE id=?`,args:[id]});\n const task=r.rows[0] as any;\n if (!task) return {ok:false,error:'not_found'};\n if (!['pending','retry'].includes(String(task.state))) return {ok:true,skipped:true,state:task.state};\n await runTask(task);\n const done=await sqlite.execute({sql:`SELECT id,kind,title,state,attempts,last_http,last_error,last_result,last_run_at,updated_at FROM tasks WHERE id=?`,args:[id]});\n return {ok:true,job:done.rows[0]||null};\n}\n\n\nexport default async function (_interval: Interval) {\n await setup();\n await seed();\n const c=await sqlite.execute(`SELECT COUNT(*) AS n FROM tasks`);\n if (Number((c.rows[0] as any)?.n||0)>MAX_TASKS) throw new Error('logical task capacity exceeded');\n const due=await sqlite.execute({sql:`SELECT * FROM tasks WHERE state IN ('pending','retry','done') AND next_run_at<=? ORDER BY priority DESC,next_run_at ASC LIMIT 20`,args:[now()]});\n for (const task of due.rows) await runTask(task);\n console.log(JSON.stringify({ok:true,real_worker:true,processed:due.rows.length,total:Number((c.rows[0] as any)?.n||0),ts:new Date().toISOString()}));\n}","createdAt",["D",1787393677218],"branchVersion","branchId","f2fee760-ed9c-41fb-8880-4b0998c66942","id","dede4889-98a9-4f4b-b437-c6239fc420d1","ai1000-hyperscheduler",["D",1787378621716],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Cloud queue for 500 AI1000 logical tasks","imageUrl","d01b5ba9-4190-4170-b205-935688c090c0","pinnedFileId","3fe972fc-9def-11f1-b9a3-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fff33-2891-750b-b930-6536da9aa970","tursoName","dede488998a94f4bb437c6239fc420d1","tursoHostname","dede488998a94f4bb437c6239fc420d1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789472446807],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":102},"org",{"_99":98,"_100":98,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":14,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","hucccc","handle","displayName","avatar","https://avatars.githubusercontent.com/u/290340746?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":179,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":180,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":181,"_84":182,"_86":183,"_88":25},"tree",[166,167,168],"files",[166,167,168],"counts",{"_155":63,"_156":157,"_158":63,"_159":160,"_161":162},"contents",[129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":146,"_32":147,"_30":148,"_134":-5,"_41":42,"_40":149,"_136":59,"_38":150,"_13":151,"_33":139,"_35":152,"_24":25,"_141":153,"_27":154},{"_43":143,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":59,"_38":144,"_13":138,"_33":34,"_35":37,"_24":25,"_141":-5,"_27":145},{"_43":132,"_32":133,"_30":57,"_134":-5,"_41":42,"_40":135,"_136":59,"_38":137,"_13":138,"_33":139,"_35":140,"_24":25,"_141":-5,"_27":142},"83fb51ee-618e-4ae5-a313-9e73b0790aca","status.ts","parentId",8,"latest",["D",1787385705575],4,"http","import { runOne } from \"./scheduler.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst now = () => Date.now();\n\nasync function setup() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n kind TEXT NOT NULL,\n title TEXT NOT NULL,\n target TEXT,\n state TEXT NOT NULL DEFAULT 'pending',\n priority INTEGER NOT NULL DEFAULT 50,\n attempts INTEGER NOT NULL DEFAULT 0,\n next_run_at INTEGER NOT NULL DEFAULT 0,\n last_run_at INTEGER,\n last_http INTEGER,\n last_error TEXT,\n last_result TEXT,\n updated_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n task_id TEXT,\n ts INTEGER NOT NULL,\n level TEXT NOT NULL,\n message TEXT NOT NULL\n )`);\n}\n\nfunction headers(extra: Record = {}) {\n return {\n 'cache-control':'no-store',\n 'x-content-type-options':'nosniff',\n 'access-control-allow-origin':'*',\n 'access-control-allow-methods':'GET,POST,OPTIONS',\n 'access-control-allow-headers':'content-type',\n ...extra,\n };\n}\n\nfunction classify(command:string) {\n const t=command.toLowerCase();\n if (t.includes('افحص حالة النظام') || t.includes('فحص حالة النظام') || t.includes('health check') || t === 'health') return 'command_health';\n if (t.includes('سلة') || t.includes('محلي') || t.includes('salla') || t.includes('mahly')) return 'command_salla';\n return 'command_generic';\n}\n\nexport default async function handler(req: Request) {\n await setup();\n if (req.method === 'OPTIONS') return new Response(null,{status:204,headers:headers()});\n const url=new URL(req.url);\n const path=url.pathname.replace(/\\/+$/,'') || '/';\n\n if (req.method === 'POST' && (path === '/jobs' || path === '/command' || path === '/')) {\n let data:any={};\n try { data=await req.json(); } catch { return Response.json({ok:false,error:'invalid_json'},{status:400,headers:headers()}); }\n const command=String(data.command||data.prompt||'').trim();\n if (command.length < 2 || command.length > 4000) return Response.json({ok:false,error:'command_length'},{status:400,headers:headers()});\n const count=await sqlite.execute(`SELECT COUNT(*) AS n FROM tasks`);\n if (Number((count.rows[0] as any)?.n||0) >= 500) return Response.json({ok:false,error:'queue_capacity'},{status:429,headers:headers()});\n const active=await sqlite.execute(`SELECT COUNT(*) AS n FROM tasks WHERE state IN ('pending','running','retry')`);\n if (Number((active.rows[0] as any)?.n||0) >= 100) return Response.json({ok:false,error:'queue_busy'},{status:429,headers:headers()});\n const id=crypto.randomUUID();\n const kind=classify(command);\n const priority=Math.max(1,Math.min(100,Number(data.priority||70)));\n const title=String(data.title||command.slice(0,120));\n await sqlite.execute({sql:`INSERT INTO tasks(id,kind,title,target,state,priority,attempts,next_run_at,updated_at,last_result) VALUES(?,?,?,?, 'pending', ?,0,0,?,?)`,args:[id,kind,title,command,priority,now(),JSON.stringify({accepted:true,command})]});\n await sqlite.execute({sql:`INSERT INTO events(task_id,ts,level,message) VALUES(?,?,?,?)`,args:[id,now(),'info','command accepted into real queue']});\n const execution=await runOne(id);\n const final=await sqlite.execute({sql:`SELECT id,kind,title,state,priority,attempts,last_http,last_error,last_result,next_run_at,last_run_at,updated_at FROM tasks WHERE id=?`,args:[id]});\n return Response.json({ok:true,job_id:id,kind,execution,job:final.rows[0]||null,accepted_at:new Date().toISOString()},{status:200,headers:headers()});\n }\n\n const jobMatch=path.match(/^\\/jobs\\/([0-9a-f-]{36})$/i);\n if (req.method === 'GET' && jobMatch) {\n const r=await sqlite.execute({sql:`SELECT id,kind,title,state,priority,attempts,last_http,last_error,last_result,next_run_at,last_run_at,updated_at FROM tasks WHERE id=?`,args:[jobMatch[1]]});\n if (!r.rows[0]) return Response.json({ok:false,error:'not_found'},{status:404,headers:headers()});\n const ev=await sqlite.execute({sql:`SELECT ts,level,message FROM events WHERE task_id=? ORDER BY id DESC LIMIT 20`,args:[jobMatch[1]]});\n return Response.json({ok:true,job:r.rows[0],events:ev.rows,ts:new Date().toISOString()},{headers:headers()});\n }\n\n if (req.method === 'GET' && path === '/health') {\n const counts=await sqlite.execute(`SELECT state,COUNT(*) AS n FROM tasks GROUP BY state`);\n return Response.json({ok:true,engine:'AI1000 HyperScheduler',real_queue:true,worker:'scheduler.ts',capacity:500,counts:counts.rows,ts:new Date().toISOString()},{headers:headers()});\n }\n\n if (req.method === 'GET') {\n const r=await sqlite.execute(`SELECT id,kind,title,state,priority,attempts,last_http,last_error,last_result,next_run_at,last_run_at,updated_at FROM tasks ORDER BY updated_at DESC LIMIT 500`);\n const counts=await sqlite.execute(`SELECT state,COUNT(*) AS n FROM tasks GROUP BY state`);\n return Response.json({ok:true,engine:'AI1000 HyperScheduler',real_queue:true,counts:counts.rows,tasks:r.rows,ts:new Date().toISOString()},{headers:headers()});\n }\n\n return Response.json({ok:false,error:'method_not_allowed'},{status:405,headers:headers({'allow':'GET,POST,OPTIONS'})});\n}","label",[133],"5b5115ad-fac6-4b36-b50e-a62a13292f3c",["D",1787393677218],[28],"0a82c45a-c3b3-4f1e-804f-3c8127fc6fed","leader.ts","fc230cd4-9dff-11f1-8659-1607ee4eb77e",12,["D",1787385895132],3,"const ENGINE='https://hucccc--3fe972fc9def11f1b9a31607ee4eb77e.web.val.run';\n\nexport default function handler(_req:Request){\n const html=`\n\n\n\n\nالعقل الموحد — القائد التنفيذي\n\n\n\n

العقل الموحد — القائد التنفيذي

تنفيذ حقيقي عبر Queue + Worker، لا ردود محاكاة.

جاري فحص المحرك…

الأوامر غير المرتبطة بمنفذ تنفيذي فعلي ستظهر كـ blocked مع السبب بدل ادعاء التنفيذ.

سجل التنفيذ

\n\n`;\n return new Response(html,{headers:{'content-type':'text/html; charset=utf-8','cache-control':'no-store','x-content-type-options':'nosniff'}});\n}","ai1000-leader",[147],"pulls","branches",1,"forks","envVars",{"_163":63,"_165":63},"connections",{"_163":63,"_164":63},"count","unfilledCount","emptyCount",{"_43":146,"_32":147,"_30":148,"_134":-5,"_41":42,"_40":149,"_136":59,"_38":176,"_13":151,"_33":139,"_35":152,"_24":25,"_141":153,"_170":177,"_27":178},{"_43":143,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":59,"_38":173,"_13":138,"_33":34,"_35":37,"_24":25,"_141":-5,"_170":174,"_27":175},{"_43":132,"_32":133,"_30":57,"_134":-5,"_41":42,"_40":135,"_136":59,"_38":169,"_13":138,"_33":139,"_35":140,"_24":25,"_141":-5,"_170":171,"_27":172},["D",1787385705575],"children",[],[133],["D",1787393677218],[],[28],["D",1787385895132],[],[147],["D",1787378621716],["D",1789472446807],{"_99":98,"_106":102},{"_99":98,"_100":98,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":14,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_82":-5,"_126":217,"_218":219,"_220":221,"_222":25,"_223":25,"_224":25,"_225":59,"_226":-5,"_227":-7,"_228":-7,"_229":63,"_230":25,"_231":25,"_232":-5,"_233":25,"_234":25,"_235":25,"_236":-5},"ENV",{"_188":189,"_190":191,"_192":89,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216},"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 · v14