Method doEnsureReady

src/node/runtime/CoderSSHRuntime.ts:270–415

* Core ensureReady logic - called once (protected by ensureReadyPromise). * * Flow: * 1. Check status via `coder list` - short-circuit for "running" or "not_found" * 2. If "stopping"/"canceling": poll until it clears (coder ssh can't autostart during these) * 3. Run `coder ssh --wait=

(
    workspaceName: string,
    options?: EnsureReadyOptions
  )

   *    - starting/pending: waits for build completion + startup scripts
   */
  private async doEnsureReady(
    workspaceName: string,
    options?: EnsureReadyOptions
  ): Promise<EnsureReadyResult> {
    const statusSink = options?.statusSink;
    const signal = options?.signal;
    const startTime = Date.now();

    const emitStatus = (phase: RuntimeStatusEvent["phase"], detail?: string) => {
      statusSink?.({ phase, runtimeType: "ssh", detail });
    };

    // Helper: check if we've exceeded overall timeout
    const isTimedOut = () => Date.now() - startTime > CODER_ENSURE_READY_TIMEOUT_MS;
    const remainingMs = () => Math.max(0, CODER_ENSURE_READY_TIMEOUT_MS - (Date.now() - startTime));

    // Step 1: Check current status for short-circuits
    emitStatus("checking");

    if (signal?.aborted) {
      emitStatus("error");
      return { ready: false, error: "Aborted", errorType: "runtime_start_failed" };
    }

    let statusResult = await this.coderService.getWorkspaceStatus(workspaceName, {
      timeoutMs: Math.min(remainingMs(), 10_000),
      signal,
    });

    // Short-circuit: already running
    if (statusResult.kind === "ok" && statusResult.status === "running") {
      return this.markReadyIfRepoPresent(workspaceName, options, emitStatus);
    }

    // Short-circuit: workspace doesn't exist
    if (statusResult.kind === "not_found") {
      emitStatus("error");
      return this.coderWorkspaceNotFound(workspaceName);
    }

    // For status check errors (timeout, auth issues), proceed optimistically
    // and let SSH fail naturally to avoid blocking the happy path
    if (statusResult.kind === "error") {
      if (signal?.aborted) {
        emitStatus("error");
        return { ready: false, error: "Aborted", errorType: "runtime_start_failed" };
      }
      log.debug("Coder workspace status unknown, proceeding optimistically", {
        workspaceName,
        error: statusResult.error,
      });
    }

    // Step 2: Wait for "stopping"/"canceling" to clear (coder ssh can't autostart during these)
    try {
      statusResult = await this.waitForStoppingOrCancelingToClear(workspaceName, statusResult, {
        abortSignal: signal,
        timeoutMs: () => Math.min(remainingMs(), 10_000),