Function qgz

package/cli.js:2177–2177

(q,K,_,z)

The user interacts primarily with the team lead. Your work is coordinated through the task system and teammate messaging.
`;function eBz(q,K,_){return async(z,Y,$,A,O,w)=>{let j=w??await uX(z,Y,$,A,O);if(j.behavior!=="ask")return j;if(K.signal.aborted)return{behavior:"ask",message:um};let H=$.getAppState(),J=await z.description(Y,{isNonInteractiveSession:$.options.isNonInteractiveSession,toolPermissionContext:H.toolPermissionContext,tools:$.options.tools});if(K.signal.aborted)return{behavior:"ask",message:um};let M=EE6();if(M)return new Promise((X)=>{let P=!1,W=Date.now(),D=()=>{_?.(Date.now()-W)},f=()=>{if(P)return;P=!0,D(),X({behavior:"ask",message:um}),M((G)=>G.filter((Z)=>Z.toolUseID!==O))};K.signal.addEventListener("abort",f,{once:!0}),M((G)=>[...G,{assistantMessage:A,tool:z,description:J,input:Y,toolUseContext:$,toolUseID:O,permissionResult:j,permissionPromptStartTimeMs:W,workerBadge:q.color?{name:q.agentName,color:q.color}:void 0,onUserInteraction(){},onAbort(){if(P)return;P=!0,K.signal.removeEventListener("abort",f),D(),X({behavior:"ask",message:um})},async onAllow(Z,T,v,V){if(P)return;if(P=!0,K.signal.removeEventListener("abort",f),D(),ru(T),T.length>0){let S=C7K();if(S){let R=$.getAppState(),x=XN(R.toolPermissionContext,T);S(x,{preserveMode:!0})}}let E=v?.trim();X({behavior:"allow",updatedInput:Z,userModified:!1,acceptFeedback:E||void 0,...V&&V.length>0&&{contentBlocks:V}})},onReject(Z,T){if(P)return;P=!0,K.signal.removeEventListener("abort",f),D();let v=Z?`${Ve6}${Z}`:um;X({behavior:"ask",message:v,contentBlocks:T})},async recheckPermission(){if(P)return;let Z=await uX(z,Y,$,A,O);if(Z.behavior==="allow")P=!0,K.signal.removeEventListener("abort",f),D(),M((T)=>T.filter((v)=>v.toolUseID!==O)),X({...Z,updatedInput:Y,userModified:!1})}}])});return new Promise((X)=>{let P=cC8({toolName:z.name,toolUseId:O,input:Y,description:J,permissionSuggestions:j.suggestions,workerId:q.agentId,workerName:q.agentName,workerColor:q.color,teamName:q.teamName});iC8({requestId:P.id,toolUseId:O,onAllow(G,Z,T,v){f(),ru(Z);let V=G&&Object.keys(G).length>0?G:Y;X({behavior:"allow",updatedInput:V,userModified:!1,...v&&v.length>0&&{contentBlocks:v}})},onReject(G,Z){f();let T=G?`${Ve6}${G}`:um;X({behavior:"ask",message:T,contentBlocks:Z})}}),lC8(P);let W=setInterval(async(G,Z,T,v,V)=>{if(G.signal.aborted){Z(),T({behavior:"ask",message:um});return}let E=await Qo(v.agentName,v.teamName);for(let S=0;S<E.length;S++){let R=E[S];if(R&&!R.read){let x=i26(R.text);if(x&&x.request_id===V.id){if(await Pe6(v.agentName,v.teamName,S),x.subtype==="success")NE6({requestId:x.request_id,decision:"approved",updatedInput:x.response?.updated_input,permissionUpdates:x.response?.permission_updates});else NE6({requestId:x.request_id,decision:"rejected",feedback:x.error});return}}}},tBz,K,f,X,q,P),D=()=>{f(),X({behavior:"ask",message:um})};K.signal.addEventListener("abort",D,{once:!0});function f(){clearInterval(W),k7K(P.id),K.signal.removeEventListener("abort",D)}})}}function Ti1(q,K,_,z){let Y=_?` color="${_}"`:"",$=z?` summary="${z}"`:"";return`<${dJ} teammate_id="${q}"${Y}${$}>
${K}
</${dJ}>`}function Im(q,K,_){_((z)=>{let Y=z.tasks[q];if(!Y||Y.type!=="in_process_teammate")return z;let $=K(Y);if($===Y)return z;return{...z,tasks:{...z.tasks,[q]:$}}})}async function qgz(q,K,_,z){await R_(wz,{from:q,text:K,timestamp:new Date().toISOString(),color:_},z)}async function I7K(q,K,_,z){let Y=De6(q,z);await qgz(q,g6(Y),K,_)}function Kgz(q){let K=new Set(q.filter((_)=>_.status!=="completed").map((_)=>_.id));return q.find((_)=>{if(_.status!=="pending")return!1;if(_.owner)return!1;return _.blockedBy.every((z)=>!K.has(z))})}function _gz(q){let K=`Complete all open tasks. Start with task #${q.id}: 

 ${q.subject}`;if(q.description)K+=`