oc-conditional-exec-task.ts

/*-----------------------------------------------------------------------------------------------
 *  Copyright (c) Red Hat, Inc. All rights reserved.
 *  Licensed under the MIT License. See LICENSE file in the project root for license information.
 *-----------------------------------------------------------------------------------------------*/
import task = require('azure-pipelines-task-lib/task');
import { RunnerHandler } from './oc-exec.ts';
import { InstallHandler } from './oc-install.ts';
import * as auth from './oc-auth.ts';
import { BinaryVersion, convertStringToBinaryVersion, FindBinaryStatus, getReason, ConditionStatus, isFailed, isTimedOut, getAgentOsName } from './utils/exec_helper.ts';
import { ConditionHandler } from './oc-condition.ts';

async function run(): Promise<void> {
  const version = task.getInput('version');
  const argLine = task.getInput('cmd');

  const condition = task.getInput('condition');
  const resource = task.getInput('resource');
  const timedout = task.getInput('timedout');
  const noTimedOutError = task.getBoolInput('noTimedOutError');

  const ignoreFlag: boolean = task.getBoolInput('ignoreFlag');
  const useLocalOc: boolean = task.getBoolInput('useLocalOc');
  const proxy: string = task.getInput('proxy');
  const agentOS = getAgentOsName(task.getPlatform());;

  const binaryVersion: BinaryVersion = convertStringToBinaryVersion(version);
  const ocBinary: FindBinaryStatus = await InstallHandler.installOc(binaryVersion, agentOS, useLocalOc, proxy);
  if (ocBinary.found === false) {
    return Promise.reject(new Error(getReason(ocBinary)));
  }

  await auth.createKubeConfig(ocBinary.path, agentOS);

  const conditionStatus: ConditionStatus = await ConditionHandler.isConditionValid(ocBinary.path, condition, resource, timedout, noTimedOutError);
  if (isFailed(conditionStatus) || isTimedOut(conditionStatus)) {
      return Promise.reject(new Error(conditionStatus.reason));
  }
  await RunnerHandler.execOc(ocBinary.path, argLine, ignoreFlag);
}

run()
  .then(() => {
    task.setResult(
      task.TaskResult.Succeeded,
      'oc command successfully executed.'
    );
  })
  .catch((err: Error) => {
    task.setResult(task.TaskResult.Failed, err.message);
  });