Method waitForInit

src/node/services/initStateManager.ts:422–513

* Wait for workspace initialization to complete. * Used by tools (bash, file_*) to ensure files are ready before executing. * * Behavior: * - No init state: Returns immediately (init not needed or backwards compat) * - Init succeeded/failed: Returns immediately (tools proceed regardle

(workspaceId: string, abortSignal?: AbortSignal)

   * @param abortSignal Optional signal to abort the wait early
   */
  async waitForInit(workspaceId: string, abortSignal?: AbortSignal): Promise<void> {
    const state = this.getInitState(workspaceId);

    // No init state - proceed immediately (backwards compat or init not needed)
    if (!state) {
      return;
    }

    // Init already completed (success or failure) - proceed immediately
    // Tools should work regardless of init outcome
    if (state.status !== "running") {
      return;
    }

    // Early exit if already aborted
    if (abortSignal?.aborted) {
      return;
    }

    // Init is running - wait for completion promise with timeout
    const promiseEntry = this.initPromises.get(workspaceId);

    if (!promiseEntry) {
      // State says running but no promise exists (shouldn't happen, but handle gracefully)
      log.error(`Init state is running for ${workspaceId} but no promise found, proceeding`);
      return;
    }

    const INIT_HOOK_TIMEOUT_MS = 5 * 60 * 1000; // 5 minutes

    // Track cleanup handlers
    let timeoutId: NodeJS.Timeout | undefined;
    let abortHandler: (() => void) | undefined;

    try {
      const abortPromise = new Promise<void>((resolve) => {
        if (!abortSignal) return; // Never resolves if no signal
        if (abortSignal.aborted) {
          resolve();
          return;
        }
        abortHandler = () => resolve();
        abortSignal.addEventListener("abort", abortHandler, { once: true });
      });

      // Intentional: provisioning (Coder/devcontainer/etc.) can be long-running, so we
      // avoid timeouts until .mux/init begins. The wait is still interruptible via
      // abortSignal or workspace deletion (clearInMemoryState).
      const phase = state.phase ?? "runtime_setup";
      if (phase === "runtime_setup") {
        const first = await Promise.race([
          promiseEntry.promise.then(() => "complete"),
          promiseEntry.hookPhasePromise.then(() => "hook"),
          abortPromise.then(() => "abort"),
        ]);
        if (first !== "hook") {
          return;
        }