diff --git a/lib/cli/scripts/kubectl-delete.ts b/lib/cli/scripts/kubectl-delete.ts new file mode 100644 index 0000000000..ebb0b017e7 --- /dev/null +++ b/lib/cli/scripts/kubectl-delete.ts @@ -0,0 +1,90 @@ +#!/usr/bin/env node + +/*! + * @license + * Copyright 2019 Alfresco Software, Ltd. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import { logging } from '@angular-devkit/core'; +import { spawnSync } from 'child_process'; + +export interface KubeArgs { + username?: string; + token?: string; + clusterEnv?: string; + clusterUrl?: string; + label?: string; +} + +function _exec(command: string, args: string[], opts: { cwd?: string }, logger: logging.Logger) { + if (process.platform.startsWith('win')) { + args.unshift('/c', command); + command = 'cmd.exe'; + } + + const { status, error, stderr, stdout } = spawnSync(command, args, { ...opts }); + + if (status !== 0) { + logger.error(`Command failed: ${command} ${args.map((x) => JSON.stringify(x)).join(', ')}`); + if (error) { + logger.error('Error: ' + (error ? error.message : 'undefined')); + } else { + logger.error(`STDERR:\n${stderr}`); + } + throw error; + } else { + return stdout.toString(); + } +} + +function _setCluster(args: KubeArgs, logger: logging.Logger) { + logger.info('Perform set-cluster...'); + const response = _exec('kubectl', [`config`, `set-cluster`, `${args.clusterEnv}`, `--server=${args.clusterUrl}`], {}, logger); + logger.info(response); +} + +function _setCredentials(args: KubeArgs, logger: logging.Logger) { + logger.info('Perform set-credentials...'); + const response = _exec('kubectl', [`config`, `set-credentials`, `${args.username}`, `--token=${args.token}`], {}, logger); + logger.info(response); +} + +function _setContext(args: KubeArgs, logger: logging.Logger) { + logger.info('Perform set-context...'); + const response = _exec('kubectl', [`config`, `set-context`, `${args.clusterEnv}`, `--cluster=${args.clusterEnv}`, `--user=${args.username}`], {}, logger); + logger.info(response); +} + +function _useContext(args: KubeArgs, logger: logging.Logger) { + logger.info('Perform use-context...'); + const response = _exec('kubectl', [`config`, `use-context`, `${args.clusterEnv}`], {}, logger); + logger.info(response); +} + +function _deletePod(args: KubeArgs, logger: logging.Logger) { + logger.info('Perform delete pods...'); + const response = _exec('kubectl', [`delete`, `pods`, `--all-namespaces`, `-l`, `app=${args.label}`], {}, logger); + logger.info(response); +} + +export default async function (args: KubeArgs, logger: logging.Logger) { + if (args.label !== undefined) { + _setCluster(args, logger); + _setCredentials(args, logger); + _setContext(args, logger); + _useContext(args, logger); + _deletePod(args, logger); + } +}