Function h75

package/cli.js:16416–16416

({commands:q,prompt:K,promptUuid:_,isMeta:z,cwd:Y,tools:$,mcpClients:A,verbose:O=!1,thinkingConfig:w,maxTurns:j,maxBudgetUsd:H,taskBudget:J,canUseTool:M,mutableMessages:X=[],getReadFileCache:P,setReadFileCache:W,customSystemPrompt:D,appendSystemPrompt:f,userSpecifiedModel:G,fallbackModel:Z,jsonSchema:T,getAppState:v,setAppState:V,abortController:E,replayUserMessages:S=!1,includePartialMessages:R=!1,handleElicitation:x,agents:I=[],setSDKStatus:B,orphanedPermission:p})

`);else process.stderr.write(`${k75} ${O}
`),N(`streamJsonStdoutGuard diverted non-JSON stdout line: ${O.slice(0,200)}`)}let A=typeof K==="function"?K:_;if(A)queueMicrotask(()=>A());return $},pq(async()=>{if(ad.length>0){if(GM6&&V75(ad))GM6(ad+`
`);else process.stderr.write(`${k75} ${ad}
`);ad=""}if(GM6)process.stdout.write=GM6,GM6=null;dA7=!1})}var k75="[stdout-guard]",dA7=!1,ad="",GM6=null;var y75=y(()=>{c9();_8()});async function cA7({tools:q,mainLoopModel:K,additionalWorkingDirectories:_,mcpClients:z,customSystemPrompt:Y}){let[$,A,O]=await Promise.all([Y!==void 0?Promise.resolve([]):QP(q,K,_,z),bO(),Y!==void 0?Promise.resolve({}):tw()]);return{defaultSystemPrompt:$,userContext:A,systemContext:O}}async function E75({tools:q,commands:K,mcpClients:_,messages:z,readFileState:Y,getAppState:$,setAppState:A,customSystemPrompt:O,appendSystemPrompt:w,thinkingConfig:j,agents:H}){let J=D5(),M=$(),{defaultSystemPrompt:X,userContext:P,systemContext:W}=await cA7({tools:q,mainLoopModel:J,additionalWorkingDirectories:Array.from(M.toolPermissionContext.additionalWorkingDirectories.keys()),mcpClients:_,customSystemPrompt:O}),D=iK([...O!==void 0?[O]:X,...w?[w]:[]]),f=z.at(-1),G=f?.type==="assistant"&&f.message.stop_reason===null?z.slice(0,-1):z,Z={options:{commands:K,debug:!1,mainLoopModel:J,tools:q,verbose:!1,thinkingConfig:j??(j76()!==!1?{type:"adaptive"}:{type:"disabled"}),mcpClients:_,mcpResources:{},isNonInteractiveSession:!0,agentDefinitions:{activeAgents:H,allAgents:[]},customSystemPrompt:O,appendSystemPrompt:w},abortController:P3(),readFileState:Y,getAppState:$,setAppState:A,messages:G,setInProgressToolUseIDs:()=>{},setResponseLength:()=>{},updateFileHistoryState:()=>{},updateAttributionState:()=>{}};return{systemPrompt:D,userContext:P,systemContext:W,toolUseContext:Z,forkContextMessages:G}}var lA7=y(()=>{rL();jN();B2();aq();WL()});import{randomUUID as TM6}from"crypto";class R75{config;mutableMessages;abortController;permissionDenials;totalUsage;hasHandledOrphanedPermission=!1;readFileState;discoveredSkillNames=new Set;loadedNestedMemoryPaths=new Set;constructor(q){this.config=q,this.mutableMessages=q.initialMessages??[],this.abortController=q.abortController??P3(),this.permissionDenials=[],this.readFileState=q.readFileCache,this.totalUsage=n0}async*submitMessage(q,K){let{cwd:_,commands:z,tools:Y,mcpClients:$,verbose:A=!1,thinkingConfig:O,maxTurns:w,maxBudgetUsd:j,taskBudget:H,canUseTool:J,customSystemPrompt:M,appendSystemPrompt:X,userSpecifiedModel:P,fallbackModel:W,jsonSchema:D,getAppState:f,setAppState:G,replayUserMessages:Z=!1,includePartialMessages:T=!1,agents:v=[],setSDKStatus:V,orphanedPermission:E}=this.config;this.discoveredSkillNames.clear(),QO(_);let S=!ey(),R=Date.now(),x=async(C6,l6,S6,E6,R6,h6)=>{let x6=await J(C6,l6,S6,E6,R6,h6);if(x6.behavior!=="allow")this.permissionDenials.push({tool_name:Xz7(C6.name),tool_use_id:R6,tool_input:l6});return x6},I=f(),B=P?A5(P):D5(),p=O?O:j76()!==!1?{type:"adaptive"}:{type:"disabled"};HM("before_getSystemPrompt");let C=typeof M==="string"?M:void 0,{defaultSystemPrompt:g,userContext:F,systemContext:U}=await cA7({tools:Y,mainLoopModel:B,additionalWorkingDirectories:Array.from(I.toolPermissionContext.additionalWorkingDirectories.keys()),mcpClients:$,customSystemPrompt:C});HM("after_getSystemPrompt");let c={...F,...loY($,Sd()?n56():void 0)},K6=C!==void 0&&Gf8()?await GQ8():null,t=iK([...C!==void 0?[C]:g,...K6?[K6]:[],...X?[X]:[]]),q6=Y.some((C6)=>g_(C6,MD));if(D&&q6)EQ8(G,N8());let e={messages:this.mutableMessages,setMessages:(C6)=>{this.mutableMessages=C6(this.mutableMessages)},onChangeAPIKey:()=>{},handleElicitation:this.config.handleElicitation,options:{commands:z,debug:!1,tools:Y,verbose:A,mainLoopModel:B,thinkingConfig:p,mcpClients:$,mcpResources:{},ideInstallationStatus:null,isNonInteractiveSession:!0,customSystemPrompt:M,appendSystemPrompt:X,agentDefinitions:{activeAgents:v,allAgents:[]},theme:OF(j8().theme),maxBudgetUsd:j},getAppState:f,setAppState:G,abortController:this.abortController,readFileState:this.readFileState,nestedMemoryAttachmentTriggers:new Set,loadedNestedMemoryPaths:this.loadedNestedMemoryPaths,dynamicSkillDirTriggers:new Set,discoveredSkillNames:this.discoveredSkillNames,setInProgressToolUseIDs:()=>{},setResponseLength:()=>{},updateFileHistoryState:(C6)=>{G((l6)=>{let S6=C6(l6.fileHistory);if(S6===l6.fileHistory)return l6;return{...l6,fileHistory:S6}})},updateAttributionState:(C6)=>{G((l6)=>{let S6=C6(l6.attribution);if(S6===l6.attribution)return l6;return{...l6,attribution:S6}})},setSDKStatus:V};if(E&&!this.hasHandledOrphanedPermission){this.hasHandledOrphanedPermission=!0;for await(let C6 of Ey4(E,Y,this.mutableMessages,e))yield C6}let{messages:i,shouldQuery:$6,allowedTools:M6,model:j6,resultText:G6}=await kc8({input:q,mode:"prompt",setToolJSX:()=>{},context:{...e,messages:this.mutableMessages},messages:this.mutableMessages,uuid:K?.uuid,isMeta:K?.isMeta,querySource:"sdk"});this.mutableMessages.push(...i);let w6=[...this.mutableMessages];if(S&&i.length>0){let C6=fN(w6);if(f9());else if(await C6,i6(process.env.CLAUDE_CODE_EAGER_FLUSH)||i6(process.env.CLAUDE_CODE_IS_COWORK))await Hd()}let o=i.filter((C6)=>C6.type==="user"&&!C6.isMeta&&!C6.toolUseResult&&L75().selectableUserMessagesFilter(C6)||C6.type==="system"&&C6.subtype==="compact_boundary"),s=Z?o:[];G((C6)=>({...C6,toolPermissionContext:{...C6.toolPermissionContext,alwaysAllowRules:{...C6.toolPermissionContext.alwaysAllowRules,command:M6}}}));let a=j6??B;e={messages:w6,setMessages:()=>{},onChangeAPIKey:()=>{},handleElicitation:this.config.handleElicitation,options:{commands:z,debug:!1,tools:Y,verbose:A,mainLoopModel:a,thinkingConfig:p,mcpClients:$,mcpResources:{},ideInstallationStatus:null,isNonInteractiveSession:!0,customSystemPrompt:M,appendSystemPrompt:X,theme:OF(j8().theme),agentDefinitions:{activeAgents:v,allAgents:[]},maxBudgetUsd:j},getAppState:f,setAppState:G,abortController:this.abortController,readFileState:this.readFileState,nestedMemoryAttachmentTriggers:new Set,loadedNestedMemoryPaths:this.loadedNestedMemoryPaths,dynamicSkillDirTriggers:new Set,discoveredSkillNames:this.discoveredSkillNames,setInProgressToolUseIDs:()=>{},setResponseLength:()=>{},updateFileHistoryState:e.updateFileHistoryState,updateAttributionState:e.updateAttributionState,setSDKStatus:V},HM("before_skills_plugins");let[n,{enabled:l}]=await Promise.all([EO6(Z8()),ZJ()]);if(HM("after_skills_plugins"),yield eQ8({tools:Y,mcpClients:$,model:a,permissionMode:I.toolPermissionContext.mode,commands:z,agents:v,skills:n,plugins:l,fastMode:I.fastMode}),HM("system_message_yielded"),!$6){for(let C6 of i){if(C6.type==="user"&&typeof C6.message.content==="string"&&(C6.message.content.includes(`<${bZ}>`)||C6.message.content.includes(`<${__6}>`)||C6.isCompactSummary))yield{type:"user",message:{...C6.message,content:VY(C6.message.content)},session_id:N8(),parent_tool_use_id:null,uuid:C6.uuid,timestamp:C6.timestamp,isReplay:!C6.isCompactSummary,isSynthetic:C6.isMeta||C6.isVisibleInTranscriptOnly};if(C6.type==="system"&&C6.subtype==="local_command"&&typeof C6.content==="string"&&(C6.content.includes(`<${bZ}>`)||C6.content.includes(`<${__6}>`)))yield e57(C6.content,C6.uuid);if(C6.type==="system"&&C6.subtype==="compact_boundary")yield{type:"system",subtype:"compact_boundary",session_id:N8(),uuid:C6.uuid,compact_metadata:MU8(C6.compactMetadata)}}if(S){if(await fN(w6),i6(process.env.CLAUDE_CODE_EAGER_FLUSH)||i6(process.env.CLAUDE_CODE_IS_COWORK))await Hd()}yield{type:"result",subtype:"success",is_error:!1,duration_ms:Date.now()-R,duration_api_ms:ay(),num_turns:w6.length-1,result:G6??"",stop_reason:null,session_id:N8(),total_cost_usd:fW(),usage:this.totalUsage,modelUsage:Nx(),permission_denials:this.permissionDenials,fast_mode_state:II(a,I.fastMode),uuid:TM6()};return}if(e$()&&S)i.filter(L75().selectableUserMessagesFilter).forEach((C6)=>{aE6((l6)=>{G((S6)=>({...S6,fileHistory:l6(S6.fileHistory)}))},C6.uuid)});let A6=n0,J6=1,X6=!1,f6,N6=null,Z6=A_6().at(-1),V6=D?H77(this.mutableMessages,MD):0;for await(let C6 of Db({messages:w6,systemPrompt:t,userContext:c,systemContext:U,canUseTool:x,toolUseContext:e,fallbackModel:W,querySource:"sdk",maxTurns:w,taskBudget:H})){if(C6.type==="assistant"||C6.type==="user"||C6.type==="system"&&C6.subtype==="compact_boundary"){if(S&&C6.type==="system"&&C6.subtype==="compact_boundary"){let l6=C6.compactMetadata?.preservedSegment?.tailUuid;if(l6){let S6=this.mutableMessages.findLastIndex((E6)=>E6.uuid===l6);if(S6!==-1)await fN(this.mutableMessages.slice(0,S6+1))}}if(w6.push(C6),S)if(C6.type==="assistant")fN(w6);else await fN(w6);if(!X6&&s.length>0){X6=!0;for(let l6 of s)if(l6.type==="user")yield{type:"user",message:l6.message,session_id:N8(),parent_tool_use_id:null,uuid:l6.uuid,timestamp:l6.timestamp,isReplay:!0}}}if(C6.type==="user")J6++;switch(C6.type){case"tombstone":break;case"assistant":if(C6.message.stop_reason!=null)N6=C6.message.stop_reason;this.mutableMessages.push(C6),yield*IN8(C6);break;case"progress":if(this.mutableMessages.push(C6),S)w6.push(C6),fN(w6);yield*IN8(C6);break;case"user":this.mutableMessages.push(C6),yield*IN8(C6);break;case"stream_event":if(C6.event.type==="message_start")A6=n0,A6=iK6(A6,C6.event.message.usage);if(C6.event.type==="message_delta"){if(A6=iK6(A6,C6.event.usage),C6.event.delta.stop_reason!=null)N6=C6.event.delta.stop_reason}if(C6.event.type==="message_stop")this.totalUsage=Ep8(this.totalUsage,A6);if(T)yield{type:"stream_event",event:C6.event,session_id:N8(),parent_tool_use_id:null,uuid:TM6()};break;case"attachment":if(this.mutableMessages.push(C6),S)w6.push(C6),fN(w6);if(C6.attachment.type==="structured_output")f6=C6.attachment.data;else if(C6.attachment.type==="max_turns_reached"){if(S){if(i6(process.env.CLAUDE_CODE_EAGER_FLUSH)||i6(process.env.CLAUDE_CODE_IS_COWORK))await Hd()}yield{type:"result",subtype:"error_max_turns",duration_ms:Date.now()-R,duration_api_ms:ay(),is_error:!0,num_turns:C6.attachment.turnCount,stop_reason:N6,session_id:N8(),total_cost_usd:fW(),usage:this.totalUsage,modelUsage:Nx(),permission_denials:this.permissionDenials,fast_mode_state:II(a,I.fastMode),uuid:TM6(),errors:[`Reached maximum number of turns (${C6.attachment.maxTurns})`]};return}else if(Z&&C6.attachment.type==="queued_command")yield{type:"user",message:{role:"user",content:C6.attachment.prompt},session_id:N8(),parent_tool_use_id:null,uuid:C6.attachment.source_uuid||C6.uuid,timestamp:C6.timestamp,isReplay:!0};break;case"stream_request_start":break;case"system":{let l6=this.config.snipReplay?.(C6,this.mutableMessages);if(l6!==void 0){if(l6.executed)this.mutableMessages.length=0,this.mutableMessages.push(...l6.messages);break}if(this.mutableMessages.push(C6),C6.subtype==="compact_boundary"&&C6.compactMetadata){let S6=this.mutableMessages.length-1;if(S6>0)this.mutableMessages.splice(0,S6);let E6=w6.length-1;if(E6>0)w6.splice(0,E6);yield{type:"system",subtype:"compact_boundary",session_id:N8(),uuid:C6.uuid,compact_metadata:MU8(C6.compactMetadata)}}if(C6.subtype==="api_error")yield{type:"system",subtype:"api_retry",attempt:C6.retryAttempt,max_retries:C6.maxRetries,retry_delay_ms:C6.retryInMs,error_status:C6.error.status??null,error:wZK(C6.error),session_id:N8(),uuid:C6.uuid};break}case"tool_use_summary":yield{type:"tool_use_summary",summary:C6.summary,preceding_tool_use_ids:C6.precedingToolUseIds,session_id:N8(),uuid:C6.uuid};break}if(j!==void 0&&fW()>=j){if(S){if(i6(process.env.CLAUDE_CODE_EAGER_FLUSH)||i6(process.env.CLAUDE_CODE_IS_COWORK))await Hd()}yield{type:"result",subtype:"error_max_budget_usd",duration_ms:Date.now()-R,duration_api_ms:ay(),is_error:!0,num_turns:J6,stop_reason:N6,session_id:N8(),total_cost_usd:fW(),usage:this.totalUsage,modelUsage:Nx(),permission_denials:this.permissionDenials,fast_mode_state:II(a,I.fastMode),uuid:TM6(),errors:[`Reached maximum budget ($${j})`]};return}if(C6.type==="user"&&D){let S6=H77(this.mutableMessages,MD)-V6,E6=parseInt(process.env.MAX_STRUCTURED_OUTPUT_RETRIES||"5",10);if(S6>=E6){if(S){if(i6(process.env.CLAUDE_CODE_EAGER_FLUSH)||i6(process.env.CLAUDE_CODE_IS_COWORK))await Hd()}yield{type:"result",subtype:"error_max_structured_output_retries",duration_ms:Date.now()-R,duration_api_ms:ay(),is_error:!0,num_turns:J6,stop_reason:N6,session_id:N8(),total_cost_usd:fW(),usage:this.totalUsage,modelUsage:Nx(),permission_denials:this.permissionDenials,fast_mode_state:II(a,I.fastMode),uuid:TM6(),errors:[`Failed to provide valid structured output after ${E6} attempts`]};return}}}let y6=w6.findLast((C6)=>C6.type==="assistant"||C6.type==="user"),T6=y6?.type??"undefined",n6=y6?.type==="assistant"?tS(y6.message.content)?.type??"none":"n/a";if(S){if(i6(process.env.CLAUDE_CODE_EAGER_FLUSH)||i6(process.env.CLAUDE_CODE_IS_COWORK))await Hd()}if(!yy4(y6,N6)){yield{type:"result",subtype:"error_during_execution",duration_ms:Date.now()-R,duration_api_ms:ay(),is_error:!0,num_turns:J6,stop_reason:N6,session_id:N8(),total_cost_usd:fW(),usage:this.totalUsage,modelUsage:Nx(),permission_denials:this.permissionDenials,fast_mode_state:II(a,I.fastMode),uuid:TM6(),errors:(()=>{let C6=A_6(),l6=Z6?C6.lastIndexOf(Z6)+1:0;return[`[ede_diagnostic] result_type=${T6} last_content_type=${n6} stop_reason=${N6}`,...C6.slice(l6).map((S6)=>S6.error)]})()};return}let o6="",I6=!1;if(y6.type==="assistant"){let C6=tS(y6.message.content);if(C6?.type==="text"&&!i76.has(C6.text))o6=C6.text;I6=Boolean(y6.isApiErrorMessage)}yield{type:"result",subtype:"success",is_error:I6,duration_ms:Date.now()-R,duration_api_ms:ay(),num_turns:J6,result:o6,stop_reason:N6,session_id:N8(),total_cost_usd:fW(),usage:this.totalUsage,modelUsage:Nx(),permission_denials:this.permissionDenials,structured_output:f6,fast_mode_state:II(a,I.fastMode),uuid:TM6()}}interrupt(){this.abortController.abort()}getMessages(){return this.mutableMessages}getReadFileState(){return this.readFileState}getSessionId(){return N8()}setModel(q){this.config.userSpecifiedModel=q}}async function*h75({commands:q,prompt:K,promptUuid:_,isMeta:z,cwd:Y,tools:$,mcpClients:A,verbose:O=!1,thinkingConfig:w,maxTurns:j,maxBudgetUsd:H,taskBudget:J,canUseTool:M,mutableMessages:X=[],getReadFileCache:P,setReadFileCache:W,customSystemPrompt:D,appendSystemPrompt:f,userSpecifiedModel:G,fallbackModel:Z,jsonSchema:T,getAppState:v,setAppState:V,abortController:E,replayUserMessages:S=!1,includePartialMessages:R=!1,handleElicitation:x,agents:I=[],setSDKStatus:B,orphanedPermission:p}){let C=new R75({cwd:Y,tools:$,commands:q,mcpClients:A,agents:I,canUseTool:M,getAppState:v,setAppState:V,initialMessages:X,readFileCache:gu(P()),customSystemPrompt:D,appendSystemPrompt:f,userSpecifiedModel:G,fallbackModel:Z,thinkingConfig:w,maxTurns:j,maxBudgetUsd:H,taskBudget:J,jsonSchema:T,verbose:O,handleElicitation:x,replayUserMessages:S,includePartialMessages:R,setSDKStatus:B,abortController:E,orphanedPermission:p,...{}});try{yield*C.submitMessage(K,{uuid:_,isMeta:z})}finally{W(C.getReadFileState())}}var L75=()=>(Md8(),Eq(IQK)),loY=()=>({});var S75=y(()=>{cl6();v8();ew();J18();CT();yA();RY();Tb();n76();rw();Tj6();SC();Bq();GU();B2();V1();I7();m8();xf();oN();NG();mr6();LQ8();E8();i1();aq();bj();b$7();lA7();tN();_K();WL();yS6();Pz7();Tz();To6()});var C75=y(()=>{k8();hx8();I7();y8();E8();nC();or1()});function b75(q){let K=process.env.CLAUDE_CODE_EXIT_AFTER_STOP_DELAY,_=K?parseInt(K,10):null,z=_&&!isNaN(_)&&_>0,Y=null,$=0;return{start(){if(Y)clearTimeout(Y),Y=null;if(z)$=Date.now(),Y=setTimeout(()=>{let A=Date.now()-$;if(q()&&A>=_)N(`Exiting after ${_}ms of idle time`),eK()},_)},stop(){if(Y)clearTimeout(Y),Y=null}}}var x75=y(()=>{_8();RA()});import{randomUUID as I75}from"crypto";function u75(q){if(q.toLowerCase().endsWith(".jsonl"))return{sessionId:I75(),ingressUrl:null,isUrl:!1,jsonlFile:q,isJsonlFile:!0};if(BL(q))return{sessionId:q,ingressUrl:null,isUrl:!1,jsonlFile:null,isJsonlFile:!1};try{let K=new URL(q);return{sessionId:I75(),ingressUrl:K.href,isUrl:!0,jsonlFile:null,isJsonlFile:!1}}catch{}return null}var m75=y(()=>{jm()});import{readFile as p75}from"fs/promises";import{join as nA7}from"path";async function noY(){try{let q=await p75(y17(),"utf-8"),K=OD6().safeParse(r8(q));if(!K.success)return N(`Invalid known_marketplaces.json in zip cache: ${K.error.message}`,{level:"error"}),{};return K.data}catch{return{}}}async function ioY(q){await JB8(y17(),g6(q,null,2))}async function roY(q,K){let _=R18();if(!_)return;let z=await ooY(K);if(z!==null){let Y=xfK(q);await JB8(nA7(_,Y),z)}}async function ooY(q){let K=[nA7(q,".claude-plugin","marketplace.json"),nA7(q,"marketplace.json"),q];for(let _ of K)try{return await p75(_,"utf-8")}catch{}return null}async function B75(){let q=await eK6();for(let[z,Y]of Object.entries(q)){if(!Y.installLocation)continue;try{await roY(z,Y.installLocation)}catch($){N(`Failed to save marketplace JSON for ${z}: ${$}`)}}let _={...await noY(),...q};await ioY(_)}var g75=y(()=>{_8();l8();Nw();BZ();Oh6()});async function F75(){let q=Sb();N(`installPluginsForHeadless: starting${q?" (zip cache mode)":""}`);let K=await GB8();if(K)zd(),Yk("headlessPluginInstall: seed marketplaces registered");if(q)await X8().mkdir(hfK()),await X8().mkdir(SfK());let _=Object.keys(tK6()).length,z={marketplaces_installed:0,delisted_count:0},Y=K;try{if(_===0)N("installPluginsForHeadless: no marketplaces declared");else{let A=await mW6("headless_marketplace_reconcile",()=>rc8({skip:q?(w,j)=>!IfK(j):void 0,onProgress:(w)=>{if(w.type==="installed")N(`installPluginsForHeadless: installed marketplace ${w.name}`);else if(w.type==="failed")N(`installPluginsForHeadless: failed to install marketplace ${w.name}: ${w.error}`)}}),(w)=>({installed_count:w.installed.length,updated_count:w.updated.length,failed_count:w.failed.length,skipped_count:w.skipped.length}));if(A.skipped.length>0)N(`installPluginsForHeadless: skipped ${A.skipped.length} marketplace(s) unsupported by zip cache: ${A.skipped.join(", ")}`);let O=A.installed.length+A.updated.length;if(O>0)zd(),Yk("headlessPluginInstall: marketplaces reconciled"),Y=!0;z.marketplaces_installed=O}if(q)await B75();let $=await Lc8();if(z.delisted_count=$.length,$.length>0)Y=!0;if(Y)Yk("headlessPluginInstall: plugins changed");if(q)pq(CfK);return Y}catch($){return H6($),!1}finally{d("tengu_headless_plugin_install",z)}}var U75=y(()=>{k8();c9();_8();oY();e7();E8();Nw();p$7();bj();zA7();Oh6();g75()});var _q5={};T8(_q5,{runHeadless:()=>_aY,removeInterruptedMessage:()=>t75,reconcileMcpServers:()=>Kq5,joinPromptValues:()=>i75,handleOrphanedPermissionResponse:()=>e75,handleMcpSetServers:()=>qq5,getCanUseToolFn:()=>a75,createCanUseToolWithPermissionPrompt:()=>o75,canBatchWith:()=>r75});import{readFile as aoY,stat as soY}from"fs/promises";import{dirname as Q75}from"path";import{cwd as GK8}from"process";import{randomUUID as wW}from"crypto";function qaY(q){if(Vl8.has(q))return!1;if(Vl8.add(q),vl8.push(q),vl8.length>n75){let K=vl8.splice(0,vl8.length-n75);for(let _ of K)Vl8.delete(_)}return!0}function KaY(q){return typeof q==="string"?[{type:"text",text:q}]:q}function i75(q){if(q.length===1)return q[0];if(q.every((K)=>typeof K==="string"))return q.join(`
`);return q.flatMap(KaY)}function r75(q,K){return K!==void 0&&K.mode==="prompt"&&K.workload===q.workload&&K.isMeta===q.isMeta}async function _aY(q,K,_,z,Y,$,A,O){if(WX.subscribe((x)=>{if(mB8(x,_),BK())_((I)=>{let B=I.settings,p=B.fastMode===!0&&!B.fastModePerSessionOptIn;return{...I,fastMode:p}})}),typeof Bun<"u")setInterval(Bun.gc,1000).unref();if(qu1(),HM("runHeadless_entry"),await cN6())await Bx4();if(HM("after_grove_check"),Xi(),O.resumeSessionAt&&!O.resume){process.stderr.write(`Error: --resume-session-at requires --resume
`),eK(1);return}if(O.rewindFiles&&!O.resume){process.stderr.write(`Error: --rewind-files requires --resume