config-map-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 { ConfigMap } from './config-map.ts';
import { BinaryVersion, convertStringToBinaryVersion, FindBinaryStatus, getAgentOsName, getReason } from './utils/exec_helper.ts';

async function run(): Promise<void> {
  const version = task.getInput('version');
  const agentOS = getAgentOsName(task.getPlatform());;
  const useLocalOc: boolean = task.getBoolInput('useLocalOc');
  const proxy: string = task.getInput('proxy');

  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)));
  }

  const configMapName = task.getInput('configMapName');
  const namespace = task.getInput('namespace');
  const properties = task.getInput('properties');
  const configMap = new ConfigMap(configMapName, properties);

  await auth.createKubeConfig(ocBinary.path, agentOS);
  await RunnerHandler.execOc(ocBinary.path, configMap.patchCmd(namespace));
}

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