| import { ErrorCodes, isError2 } from '#/errors'; | |
| import type { AgentContext } from '#/agent/agentContext/agentContext'; | |
| import { resolveSubagentScopeEvictTimeoutMs } from '#/session/subagent/subagentScopeCache'; | |
| import type { CreateAgentOptions, IAgentLifecycleService } from './agentLifecycle'; | |
| const CLOSE_WAIT_POLL_MS = 50; | |
| export async function createAgentAwaitingClose( | |
| lifecycle: IAgentLifecycleService, | |
| opts: CreateAgentOptions, | |
| signal?: AbortSignal, | |
| ): Promise<AgentContext> { | |
| const deadline = Date.now() + resolveSubagentScopeEvictTimeoutMs(); | |
| for (;;) { | |
| signal?.throwIfAborted(); | |
| try { | |
| return await lifecycle.create(opts); | |
| } catch (error) { | |
| const closing = isError2(error) && error.code === ErrorCodes.AGENT_ALREADY_EXISTS; | |
| if (!closing || Date.now() >= deadline) throw error; | |
| await new Promise((resolve) => { | |
| setTimeout(resolve, CLOSE_WAIT_POLL_MS); | |
| }); | |
| } | |
| } | |
| } | |