Method uploadFiles

src/deploy.ts:583–639

(deployId: string, buildFilePaths: string[])

  }

  private async uploadFiles(deployId: string, buildFilePaths: string[]) {
    const progressSpinner = this.effects.clack.spinner();
    progressSpinner.start("");

    // upload a manifest before uploading the files
    progressSpinner.message("Hashing local files");
    const manifestFileInfo: DeployManifestFile[] = [];
    await runAllWithConcurrencyLimit(buildFilePaths, async (path) => {
      const fullPath = join(this.deployOptions.config.output, path);
      const statInfo = await stat(fullPath);
      const hash = createHash("sha512")
        .update(await readFile(fullPath))
        .digest("base64");
      manifestFileInfo.push({path, size: statInfo.size, hash});
    });
    progressSpinner.message("Sending file manifest to server");
    const instructions = await this.apiClient.postDeployManifest(deployId, manifestFileInfo);
    const fileErrors: {path: string; detail: string | null}[] = [];
    for (const fileInstruction of instructions.files) {
      if (fileInstruction.status === "error") {
        fileErrors.push({path: fileInstruction.path, detail: fileInstruction.detail});
      }
    }
    if (fileErrors.length) {
      this.effects.clack.log.error(
        "The server rejected some files from the upload:\n\n" +
          fileErrors.map(({path, detail}) => `  - ${path} - ${detail ? `(${detail})` : "no details"}`).join("\n")
      );
    }
    if (instructions.status === "error" || fileErrors.length) {
      throw new CliError(`Server rejected deploy manifest${instructions.detail ? `: ${instructions.detail}` : ""}`);
    }
    const filesToUpload: string[] = instructions.files
      .filter((instruction) => instruction.status === "upload")
      .map((instruction) => instruction.path);

    // Upload the files
    const rateLimiter = new RateLimiter(5);
    const waitForRateLimit = filesToUpload.length <= 300 ? async () => {} : () => rateLimiter.wait();

    await runAllWithConcurrencyLimit(
      filesToUpload,
      async (path, i) => {
        await waitForRateLimit();
        progressSpinner.message(
          `${i + 1} / ${filesToUpload.length} ${faint("uploading")} ${path.slice(0, this.effects.outputColumns - 17)}`
        );
        await this.apiClient.postDeployFile(deployId, join(this.deployOptions.config.output, path), path);
      },
      {maxConcurrency: this.deployOptions.maxConcurrency}
    );
    progressSpinner.stop(
      `${filesToUpload.length} uploaded, ${buildFilePaths.length - filesToUpload.length} unchanged, ${
        buildFilePaths.length
      } total.`
    );
  }