Method collectAndValidateOutputsAsync

packages/steps/src/BuildStep.ts:461–496

(outputsDir: string)

  }

  private async collectAndValidateOutputsAsync(outputsDir: string): Promise<void> {
    const files = await fs.readdir(outputsDir);

    for (const outputId of files) {
      if (!(outputId in this.outputById)) {
        const newOutput = new BuildStepOutput(this.ctx.global, {
          id: outputId,
          stepDisplayName: this.displayName,
          required: false,
        });
        this.outputById[outputId] = newOutput;
      }

      const file = path.join(outputsDir, outputId);
      const rawContents = await fs.readFile(file, 'utf-8');
      const decodedContents = Buffer.from(rawContents, 'base64').toString('utf-8');
      this.outputById[outputId].set(decodedContents);
    }

    const nonSetRequiredOutputIds: string[] = [];
    for (const output of Object.values(this.outputById)) {
      try {
        const value = output.value;
        this.ctx.logger.debug(`Output parameter "${output.id}" is set to "${value}"`);
      } catch (err) {
        this.ctx.logger.debug({ err }, `Getting value for output parameter "${output.id}" failed.`);
        nonSetRequiredOutputIds.push(output.id);
      }
    }
    if (nonSetRequiredOutputIds.length > 0) {
      const idsString = nonSetRequiredOutputIds.map(i => `"${i}"`).join(', ');
      throw new BuildStepRuntimeError(`Some required outputs have not been set: ${idsString}`, {
        metadata: { ids: nonSetRequiredOutputIds },
      });
    }
  }

  private async collectAndUpdateEnvsAsync(envsDir: string): Promise<void> {
    const filenames = await fs.readdir(envsDir);