| 2166 | `)}function De6(q,K){return{type:"idle_notification",from:q,timestamp:new Date().toISOString(),idleReason:K?.idleReason,summary:K?.summary,completedTaskId:K?.completedTaskId,completedStatus:K?.completedStatus,failureReason:K?.failureReason}}function fe6(q){try{let K=r8(q);if(K&&K.type==="idle_notification")return K}catch{}return null}function wi1(q){return{type:"permission_request",request_id:q.request_id,agent_id:q.agent_id,tool_name:q.tool_name,tool_use_id:q.tool_use_id,description:q.description,input:q.input,permission_suggestions:q.permission_suggestions||[]}}function ji1(q){if(q.subtype==="error")return{type:"permission_response",request_id:q.request_id,subtype:"error",error:q.error||"Permission denied"};return{type:"permission_response",request_id:q.request_id,subtype:"success",response:{updated_input:q.updated_input,permission_updates:q.permission_updates}}}function Ze6(q){try{let K=r8(q);if(K&&K.type==="permission_request")return K}catch{}return null}function i26(q){try{let K=r8(q);if(K&&K.type==="permission_response")return K}catch{}return null}function Hi1(q){return{type:"sandbox_permission_request",requestId:q.requestId,workerId:q.workerId,workerName:q.workerName,workerColor:q.workerColor,hostPattern:{host:q.host},createdAt:Date.now()}}function Ji1(q){return{type:"sandbox_permission_response",requestId:q.requestId,host:q.host,allow:q.allow,timestamp:new Date().toISOString()}}function IC8(q){try{let K=r8(q);if(K&&K.type==="sandbox_permission_request")return K}catch{}return null}function Ge6(q){try{let K=r8(q);if(K&&K.type==="sandbox_permission_response")return K}catch{}return null}function DE6(q){return{type:"shutdown_request",requestId:q.requestId,from:q.from,reason:q.reason,timestamp:new Date().toISOString()}}function Mi1(q){return{type:"shutdown_approved",requestId:q.requestId,from:q.from,timestamp:new Date().toISOString(),paneId:q.paneId,backendType:q.backendType}}function Xi1(q){return{type:"shutdown_rejected",requestId:q.requestId,from:q.from,reason:q.reason,timestamp:new Date().toISOString()}}async function uC8(q,K,_){let z=K||$9(),Y=M_()||wz,$=jE6("shutdown",q),A=DE6({requestId:$,from:Y,reason:_});return await R_(q,{from:Y,text:g6(A),timestamp:new Date().toISOString(),color:vj()},z),{requestId:$,target:q}}function n46(q){try{let K=X7K().safeParse(r8(q));if(K.success)return K.data}catch{}return null}function r26(q){try{let K=J7K().safeParse(r8(q));if(K.success)return K.data}catch{}return null}function qk(q){try{let K=P7K().safeParse(r8(q));if(K.success)return K.data}catch{}return null}function mC8(q){try{let K=W7K().safeParse(r8(q));if(K.success)return K.data}catch{}return null}function fE6(q){try{let K=M7K().safeParse(r8(q));if(K.success)return K.data}catch{}return null}function pC8(q){try{let K=r8(q);if(K&&K.type==="task_assignment")return K}catch{}return null}function BC8(q){try{let K=r8(q);if(K&&K.type==="team_permission_update")return K}catch{}return null}function gC8(q){return{type:"mode_set_request",mode:q.mode,from:q.from}}function FC8(q){try{let K=D7K().safeParse(r8(q));if(K.success)return K.data}catch{}return null}function UC8(q){try{let K=r8(q);if(!K||typeof K!=="object"||!("type"in K))return!1;let _=K.type;return _==="permission_request"||_==="permission_response"||_==="sandbox_permission_request"||_==="sandbox_permission_response"||_==="shutdown_request"||_==="shutdown_approved"||_==="team_permission_update"||_==="mode_set_request"||_==="plan_approval_request"||_==="plan_approval_response"}catch{return!1}}async function Pi1(q,K,_){let z=l26(q,_),Y=`${z}.lock`,$;try{$=await PJ(z,{lockfilePath:Y,...xC8});let A=await Qo(q,_);if(A.length===0)return;let O=A.map((w)=>!w.read&&K(w)?{...w,read:!0}:w);await WE6(z,g6(O,null,2),"utf-8")}catch(A){if(s1(A)==="ENOENT")return;H6(A)}finally{if($)try{await $()}catch{}}}function Te6(q){for(let K=q.length-1;K>=0;K--){let _=q[K];if(!_)continue;if(_.type==="user"&&typeof _.message.content==="string")break;if(_.type!=="assistant")continue;for(let z of _.message.content)if(z.type==="tool_use"&&z.name===wD&&typeof z.input==="object"&&z.input!==null&&"to"in z.input&&typeof z.input.to==="string"&&z.input.to!=="*"&&z.input.to.toLowerCase()!==wz.toLowerCase()&&"message"in z.input&&typeof z.input.message==="string"){let Y=z.input.to,$="summary"in z.input&&typeof z.input.summary==="string"?z.input.summary:z.input.message.slice(0,80);return`[to ${Y}] ${$}`}}return}var xC8,J7K,M7K,X7K,P7K,W7K,D7K;var RJ=y(()=>{x7();RY();Ai1();_8();m8();y8();E8();l8();gj();AY();xC8={retries:{retries:10,minTimeout:5,maxTimeout:100}};J7K=B6(()=>L.object({type:L.literal("plan_approval_request"),from:L.string(),timestamp:L.string(),planFilePath:L.string(),planContent:L.string(),requestId:L.string()})),M7K=B6(()=>L.object({type:L.literal("plan_approval_response"),requestId:L.string(),approved:L.boolean(),feedback:L.string().optional(),timestamp:L.string(),permissionMode:Uo().optional()})),X7K=B6(()=>L.object({type:L.literal("shutdown_request"),requestId:L.string(),from:L.string(),reason:L.string().optional(),timestamp:L.string()})),P7K=B6(()=>L.object({type:L.literal("shutdown_approved"),requestId:L.string(),from:L.string(),timestamp:L.string(),paneId:L.string().optional(),backendType:L.string().optional()})),W7K=B6(()=>L.object({type:L.literal("shutdown_rejected"),requestId:L.string(),from:L.string(),reason:L.string(),timestamp:L.string()}));D7K=B6(()=>L.object({type:L.literal("mode_set_request"),mode:Uo(),from:L.string()}))});var ZE6,QC8;var Wi1=y(()=>{x7();ZE6=B6(()=>KK.enum(["allow","deny","ask"])),QC8=B6(()=>KK.object({toolName:KK.string(),ruleContent:KK.string().optional()}))});var GE6,TE6;var dC8=y(()=>{x7();yW();Wi1();GE6=B6(()=>KK.enum(["userSettings","projectSettings","localSettings","session","cliArg"])),TE6=B6(()=>KK.discriminatedUnion("type",[KK.object({type:KK.literal("addRules"),rules:KK.array(QC8()),behavior:ZE6(),destination:GE6()}),KK.object({type:KK.literal("replaceRules"),rules:KK.array(QC8()),behavior:ZE6(),destination:GE6()}),KK.object({type:KK.literal("removeRules"),rules:KK.array(QC8()),behavior:ZE6(),destination:GE6()}),KK.object({type:KK.literal("setMode"),mode:gh7(),destination:GE6()}),KK.object({type:KK.literal("addDirectories"),directories:KK.array(KK.string()),destination:GE6()}),KK.object({type:KK.literal("removeDirectories"),directories:KK.array(KK.string()),destination:GE6()})]))});function oBz(){return`perm-${Date.now()}-${Math.random().toString(36).substring(2,9)}`}function cC8(q){let K=q.teamName||$9(),_=q.workerId||NP(),z=q.workerName||M_(),Y=q.workerColor||vj();if(!K)throw Error("Team name is required for permission requests");if(!_)throw Error("Worker ID is required for permission requests");if(!z)throw Error("Worker name is required for permission requests");return{id:oBz(),workerId:_,workerName:z,workerColor:Y,teamName:K,toolName:q.toolName,toolUseId:q.toolUseId,description:q.description,input:q.input,permissionSuggestions:q.permissionSuggestions||[],status:"pending",createdAt:Date.now()}}function aBz(q){if(!(q||$9()))return!1;let _=NP();return!_||_==="team-lead"}function ve6(){let q=$9(),K=NP();return!!q&&!!K&&!aBz()}async function Z7K(q){let K=q||$9();if(!K)return null;let _=await jb(K);if(!_)return N(`[PermissionSync] Team file not found for team: ${K}`),null;return _.members.find((Y)=>Y.agentId===_.leadAgentId)?.name||"team-lead"}async function lC8(q){let K=await Z7K(q.teamName);if(!K)return N("[PermissionSync] Cannot send permission request: leader name not found"),!1;try{let _=wi1({request_id:q.id,agent_id:q.workerName,tool_name:q.toolName,tool_use_id:q.toolUseId,description:q.description,input:q.input,permission_suggestions:q.permissionSuggestions});return await R_(K,{from:q.workerName,text:g6(_),timestamp:new Date().toISOString(),color:q.workerColor},q.teamName),N(`[PermissionSync] Sent permission request ${q.id} to leader ${K} via mailbox`),!0}catch(_){return N(`[PermissionSync] Failed to send permission request via mailbox: ${_}`),H6(_),!1}}async function nC8(q,K,_,z){let Y=z||$9();if(!Y)return N("[PermissionSync] Cannot send permission response: team name not found"),!1;try{let $=ji1({request_id:_,subtype:K.decision==="approved"?"success":"error",error:K.feedback,updated_input:K.updatedInput,permission_updates:K.permissionUpdates}),A=M_()||"team-lead";return await R_(q,{from:A,text:g6($),timestamp:new Date().toISOString()},Y),N(`[PermissionSync] Sent permission response for ${_} to worker ${q} via mailbox`),!0}catch($){return N(`[PermissionSync] Failed to send permission response via mailbox: ${$}`),H6($),!1}}function G7K(){return`sandbox-${Date.now()}-${Math.random().toString(36).substring(2,9)}`}async function T7K(q,K,_){let z=_||$9();if(!z)return N("[PermissionSync] Cannot send sandbox permission request: team name not found"),!1;let Y=await Z7K(z);if(!Y)return N("[PermissionSync] Cannot send sandbox permission request: leader name not found"),!1;let $=NP(),A=M_(),O=vj();if(!$||!A)return N("[PermissionSync] Cannot send sandbox permission request: worker ID or name not found"),!1;try{let w=Hi1({requestId:K,workerId:$,workerName:A,workerColor:O,host:q});return await R_(Y,{from:A,text:g6(w),timestamp:new Date().toISOString(),color:O},z),N(`[PermissionSync] Sent sandbox permission request ${K} for host ${q} to leader ${Y} via mailbox`),!0}catch(w){return N(`[PermissionSync] Failed to send sandbox permission request via mailbox: ${w}`),H6(w),!1}}async function v7K(q,K,_,z,Y){let $=Y||$9();if(!$)return N("[PermissionSync] Cannot send sandbox permission response: team name not found"),!1;try{let A=Ji1({requestId:K,host:_,allow:z}),O=M_()||"team-lead";return await R_(q,{from:O,text:g6(A),timestamp:new Date().toISOString()},$),N(`[PermissionSync] Sent sandbox permission response for ${K} (host: ${_}, allow: ${z}) to worker ${q} via mailbox`),!0}catch(A){return N(`[PermissionSync] Failed to send sandbox permission response via mailbox: ${A}`),H6(A),!1}}var tpO;var vE6=y(()=>{x7();_8();y8();E8();l8();AY();RJ();RD();tpO=B6(()=>L.object({id:L.string(),workerId:L.string(),workerName:L.string(),workerColor:L.string().optional(),teamName:L.string(),toolName:L.string(),toolUseId:L.string(),description:L.string(),input:L.record(L.string(),L.unknown()),permissionSuggestions:L.array(L.unknown()),status:L.enum(["pending","approved","rejected"]),resolvedBy:L.enum(["worker","leader"]).optional(),resolvedAt:L.number().optional(),feedback:L.string().optional(),updatedInput:L.record(L.string(),L.unknown()).optional(),permissionUpdates:L.array(L.unknown()).optional(),createdAt:L.number()}))});function sBz(q){if(!Array.isArray(q))return[];let K=TE6(),_=[];for(let z of q){let Y=K.safeParse(z);if(Y.success)_.push(Y.data);else N(`[SwarmPermissionPoller] Dropping malformed permissionUpdate entry: ${Y.error.message}`,{level:"warn"})}return _}function iC8(q){VE6.set(q.requestId,q),N(`[SwarmPermissionPoller] Registered callback for request ${q.requestId}`)}function k7K(q){VE6.delete(q),N(`[SwarmPermissionPoller] Unregistered callback for request ${q}`)}function V7K(q){return VE6.has(q)}function N7K(){VE6.clear(),ke6.clear()}function NE6(q){let K=VE6.get(q.requestId);if(!K)return N(`[SwarmPermissionPoller] No callback registered for mailbox response ${q.requestId}`),!1;if(N(`[SwarmPermissionPoller] Processing mailbox response for request ${q.requestId}: ${q.decision}`),VE6.delete(q.requestId),q.decision==="approved"){let _=sBz(q.permissionUpdates),z=q.updatedInput;K.onAllow(z,_)}else K.onReject(q.feedback);return!0}function y7K(q){ke6.set(q.requestId,q),N(`[SwarmPermissionPoller] Registered sandbox callback for request ${q.requestId}`)}function E7K(q){return ke6.has(q)}function L7K(q){let K=ke6.get(q.requestId);if(!K)return N(`[SwarmPermissionPoller] No sandbox callback registered for request ${q.requestId}`),!1;return N(`[SwarmPermissionPoller] Processing sandbox response for request ${q.requestId}: allow=${q.allow}`),ke6.delete(q.requestId),K.resolve(q.allow),!0}var Di1,VE6,ke6;var yE6=y(()=>{_8();y8();dC8();vE6();AY();Di1=O6(D6(),1);VE6=new Map;ke6=new Map});function R7K(q){fi1=q}function EE6(){return fi1}function h7K(){fi1=null}function S7K(q){Zi1=q}function C7K(){return Zi1}function b7K(){Zi1=null}var fi1=null,Zi1=null;var x7K={};T8(x7K,{TEAMMATE_SYSTEM_PROMPT_ADDENDUM:()=>Gi1});var Gi1=` |