Function EXK

package/cli.js:3972–3972

({agentId:q,description:K,prompt:_,selectedAgent:z,setAppState:Y,autoBackgroundMs:$,toolUseId:A})

<${FT}>${M}</${FT}>
<${wj}>${_}</${wj}>
<${gw}>${J}</${gw}>${P}${W}${D}
</${XA}>`;IO({value:f,mode:"task-notification"})}function aq6(q,K){let _=!1;if(A3(q,K,(z)=>{if(z.status!=="running")return z;return _=!0,z.abortController?.abort(),z.unregisterCleanup?.(),{...z,status:"killed",endTime:Date.now(),evictAfter:z.retain?void 0:Date.now()+BN8,abortController:void 0,unregisterCleanup:void 0,selectedAgent:void 0}}),_)Zw(q)}function dXK(q,K){for(let[_,z]of Object.entries(q))if(z.type==="local_agent"&&z.status==="running")aq6(_,K)}function cXK(q,K){A3(q,K,(_)=>{if(_.notified)return _;return{..._,notified:!0}})}function ia6(q,K,_){A3(q,_,(z)=>{if(z.status!=="running")return z;let Y=z.progress?.summary;return{...z,progress:Y?{...K,summary:Y}:K}})}function _5K(q,K,_){let z=null;if(A3(q,_,(Y)=>{if(Y.status!=="running")return Y;return z={tokenCount:Y.progress?.tokenCount??0,toolUseCount:Y.progress?.toolUseCount??0,startTime:Y.startTime,toolUseId:Y.toolUseId},{...Y,progress:{...Y.progress,toolUseCount:Y.progress?.toolUseCount??0,tokenCount:Y.progress?.tokenCount??0,summary:K}}}),z&&sp()){let{tokenCount:Y,toolUseCount:$,startTime:A,toolUseId:O}=z;VL8({taskId:q,toolUseId:O,description:K,startTime:A,totalTokens:Y,toolUses:$,summary:K})}}function hL8(q,K){let _=q.agentId;A3(_,K,(z)=>{if(z.status!=="running")return z;return z.unregisterCleanup?.(),{...z,status:"completed",result:q,endTime:Date.now(),evictAfter:z.retain?void 0:Date.now()+BN8,abortController:void 0,unregisterCleanup:void 0,selectedAgent:void 0}}),Zw(_)}function SL8(q,K,_){A3(q,_,(z)=>{if(z.status!=="running")return z;return z.unregisterCleanup?.(),{...z,status:"failed",error:K,endTime:Date.now(),evictAfter:z.retain?void 0:Date.now()+BN8,abortController:void 0,unregisterCleanup:void 0,selectedAgent:void 0}}),Zw(q)}function Fm8({agentId:q,description:K,prompt:_,selectedAgent:z,setAppState:Y,parentAbortController:$,toolUseId:A}){zH6(q,c0(pO(q)));let O=$?bC($):P3(),w={...C0(q,"local_agent",K,A),type:"local_agent",status:"running",agentId:q,prompt:_,selectedAgent:z,agentType:z.agentType??"general-purpose",abortController:O,retrieved:!1,lastReportedToolCount:0,lastReportedTokenCount:0,isBackgrounded:!0,pendingMessages:[],retain:!1,diskLoaded:!1},j=pq(async()=>{aq6(q,Y)});return w.unregisterCleanup=j,H0(w,Y),w}function EXK({agentId:q,description:K,prompt:_,selectedAgent:z,setAppState:Y,autoBackgroundMs:$,toolUseId:A}){zH6(q,c0(pO(q)));let O=P3(),w=pq(async()=>{aq6(q,Y)}),j={...C0(q,"local_agent",K,A),type:"local_agent",status:"running",agentId:q,prompt:_,selectedAgent:z,agentType:z.agentType??"general-purpose",abortController:O,unregisterCleanup:w,retrieved:!1,lastReportedToolCount:0,lastReportedTokenCount:0,isBackgrounded:!1,pendingMessages:[],retain:!1,diskLoaded:!1},H,J=new Promise((X)=>{H=X});gR6.set(q,H),H0(j,Y);let M;if($!==void 0&&$>0){let X=setTimeout((P,W)=>{P((f)=>{let G=f.tasks[W];if(!EJ(G)||G.isBackgrounded)return f;return{...f,tasks:{...f.tasks,[W]:{...G,isBackgrounded:!0}}}});let D=gR6.get(W);if(D)D(),gR6.delete(W)},$,Y,q);M=()=>clearTimeout(X)}return{taskId:q,backgroundSignal:J,cancelAutoBackground:M}}function lXK(q,K,_){let Y=K().tasks[q];if(!EJ(Y)||Y.isBackgrounded)return!1;_((A)=>{let O=A.tasks[q];if(!EJ(O))return A;return{...A,tasks:{...A.tasks,[q]:{...O,isBackgrounded:!0}}}});let $=gR6.get(q);if($)$(),gR6.delete(q);return!0}function LXK(q,K){gR6.delete(q);let _;K((z)=>{let Y=z.tasks[q];if(!EJ(Y)||Y.isBackgrounded)return z;_=Y.unregisterCleanup;let{[q]:$,...A}=z.tasks;return{...z,tasks:A}}),_?.()}var c4Y=5,Jm8,gR6;var gP=y(()=>{v8();RY();Yw6();GN();Bq();GU();M0();B2();c9();Bo();p2();_K();Ij();J0();ZF1();Jm8={name:"LocalAgentTask",type:"local_agent",async kill(q,K){aq6(q,K)}};gR6=new Map});import{stat as n4Y}from"fs/promises";function s4Y(q){let K=q.trimEnd().split(`
`).pop()??"";return a4Y.some((_)=>_.test(K))}function R67(q,K,_,z,Y){if(_==="monitor")return()=>{};let $=sz(q),A=0,O=Date.now(),w=!1,j=setInterval(()=>{n4Y($).then((H)=>{if(H.size>A){A=H.size,O=Date.now();return}if(Date.now()-O<r4Y)return;ot($,o4Y).then(({content:J})=>{if(w)return;if(!s4Y(J)){O=Date.now();return}w=!0,clearInterval(j);let M=z?`
<${gT}>${z}</${gT}>`:"",X=`${FR6}"${K}" appears to be waiting for interactive input`,P=`<${XA}>