unity-builder/src/model/cloud-runner/workflows/custom-workflow.ts

import CloudRunnerLogger from '../services/cloud-runner-logger';
import CloudRunnerSecret from '../services/cloud-runner-secret';
import { CloudRunnerFolders } from '../services/cloud-runner-folders';
import YAML from 'yaml';
import { CloudRunner, Input } from '../..';
import CloudRunnerEnvironmentVariable from '../services/cloud-runner-environment-variable';

export class CustomWorkflow {
  public static async runCustomJob(
    buildSteps,
    environmentVariables: CloudRunnerEnvironmentVariable[],
    secrets: CloudRunnerSecret[],
  ) {
    try {
      CloudRunnerLogger.log(`Cloud Runner is running in custom job mode`);
      if (CloudRunner.buildParameters.cloudRunnerIntegrationTests) {
        CloudRunnerLogger.log(`Parsing build steps: ${buildSteps}`);
      }
      try {
        buildSteps = YAML.parse(buildSteps);
      } catch (error) {
        CloudRunnerLogger.log(`failed to parse a custom job "${buildSteps}"`);
        throw error;
      }
      let output = '';
      for (const step of buildSteps) {
        const stepSecrets: CloudRunnerSecret[] = step.secrets.map((x) => {
          const secret: CloudRunnerSecret = {
            ParameterKey: x.name,
            EnvironmentVariable: Input.ToEnvVarFormat(x.name),
            ParameterValue: x.value,
          };

          return secret;
        });
        output += await CloudRunner.Provider.runTask(
          CloudRunner.buildParameters.buildGuid,
          step['image'],
          step['commands'],
          `/${CloudRunnerFolders.buildVolumeFolder}`,
          `/${CloudRunnerFolders.projectPathAbsolute}/`,
          environmentVariables,
          [...secrets, ...stepSecrets],
        );
      }

      return output;
    } catch (error) {
      throw error;
    }
  }
}