Method pollForProcessingCompletion

src/deploy.ts:661–697

(deployId: string)

  }

  private async pollForProcessingCompletion(deployId: string): Promise<GetDeployResponse> {
    const {deployPollInterval: pollInterval = DEPLOY_POLL_INTERVAL_MS} = this.deployOptions;

    // Poll for processing completion
    const spinner = this.effects.clack.spinner();
    spinner.start("Server processing deploy");
    const pollExpiration = Date.now() + DEPLOY_POLL_MAX_MS;
    let deployInfo: null | GetDeployResponse = null;
    pollLoop: while (true) {
      if (Date.now() > pollExpiration) {
        spinner.stop("Deploy timed out");
        throw new CliError(`Deploy failed to process on server: status = ${deployInfo?.status}`);
      }
      deployInfo = await this.apiClient.getDeploy(deployId);
      switch (deployInfo.status) {
        case "created":
        case "pending":
          break;
        case "uploaded":
          spinner.stop("Deploy complete");
          break pollLoop;
        case "failed":
          spinner.stop("Deploy failed");
          throw new CliError("Deploy failed to process on server");
        case "canceled":
          spinner.stop("Deploy canceled");
          throw new CliError("Deploy canceled");
        default:
          spinner.stop("Unknown status");
          throw new CliError(`Unknown deploy status: ${deployInfo.status}`);
      }
      await new Promise((resolve) => setTimeout(resolve, pollInterval));
    }

    if (!deployInfo) throw new CliError("Deploy failed to process on server");
    return deployInfo;
  }
}

// export for testing