@cto.ai/ops/lib/commands/remove.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const tslib_1 = require("tslib");
const base_1 = tslib_1.__importStar(require("../base"));
const sdk_1 = require("@cto.ai/sdk");
const utils_1 = require("../utils");
const env_1 = require("../constants/env");
const CustomErrors_1 = require("../errors/CustomErrors");
const opConfig_1 = require("../constants/opConfig");
class Remove extends base_1.default {
    constructor() {
        super(...arguments);
        // removeTypePrompt = async (
        //   opName: string,
        // ): Promise<Pick<RemoveInputs, 'opName' | 'removeType'>> => {
        //   const { removeType } = await this.ux.prompt<{ removeType: OpTypes }>({
        //     type: 'list',
        //     name: 'removeType',
        //     message: `Start by selecting either private ${this.ux.colors.multiBlue(
        //       titleCase(COMMAND),
        //     )} or ${this.ux.colors.multiOrange(
        //       titleCase(WORKFLOW),
        //     )} to remove  ${this.ux.colors.reset.green('→')}`,
        //     choices: [
        //       {
        //         name: `${this.ux.colors.multiBlue('\u2022')} ${titleCase(COMMAND)}`,
        //         value: COMMAND,
        //       },
        //       {
        //         name: `${this.ux.colors.multiOrange('\u2022')} ${titleCase(
        //           WORKFLOW,
        //         )}`,
        //         value: WORKFLOW,
        //       },
        //     ],
        //   })
        //   return { opName, removeType }
        // }
        this.promptFilter = async (opName) => {
            if (!opName) {
                const answers = await sdk_1.ux.prompt({
                    type: 'input',
                    name: 'opName',
                    message: `\n Please type in the name of the private op you want to remove ${sdk_1.ux.colors.reset.green('→')}\n ${sdk_1.ux.colors.reset(sdk_1.ux.colors.secondary(`Leave blank to list all private ops you can remove`))} \n\n 🗑  ${sdk_1.ux.colors.reset.white('Name or Description')}`,
                });
                opName = answers.opName;
            }
            return { opName };
        };
        this.getApiOpsOrWorkflows = async (inputs) => {
            const { opName } = inputs;
            let apiOps;
            if (!opName) {
                try {
                    ;
                    ({ data: apiOps } = await this.services.api.find(`teams/${this.state.config.team.name}/ops`, {
                        headers: {
                            Authorization: this.accessToken,
                        },
                    }));
                }
                catch (err) {
                    this.debug('%O', err);
                    throw new CustomErrors_1.APIError(err);
                }
            }
            else {
                let apiOp;
                try {
                    ;
                    ({ data: apiOp } = await this.services.api.find(`teams/${this.state.config.team.name}/ops/${opName}`, {
                        headers: {
                            Authorization: this.accessToken,
                        },
                    }));
                }
                catch (err) {
                    this.debug('%O', err);
                    throw new CustomErrors_1.APIError(err);
                }
                if (!apiOp) {
                    throw new CustomErrors_1.NoOpsFound(opName);
                }
                apiOps = [apiOp];
            }
            return Object.assign({}, inputs, { apiOps });
        };
        this.selectOpOrWorkflow = async (inputs) => {
            const { apiOps, removeType } = inputs;
            let opOrWorkflow;
            if (!apiOps || !apiOps.length) {
                throw new CustomErrors_1.NoResultsFoundForDeletion(inputs.opName);
            }
            if (apiOps.length === 1) {
                opOrWorkflow = apiOps[0];
            }
            else {
                const { selected } = await sdk_1.ux.prompt({
                    type: 'list',
                    name: 'selected',
                    pageSize: 100,
                    message: `\n 🗑  Which private op would you like to remove?`,
                    choices: apiOps.map(l => {
                        return {
                            name: `${sdk_1.ux.colors.callOutCyan(l.name)} ${sdk_1.ux.colors.white(l.description)} | id: ${sdk_1.ux.colors.white(l.id.toLowerCase())}`,
                            value: l,
                        };
                    }),
                });
                opOrWorkflow = selected;
            }
            return Object.assign({}, inputs, { opOrWorkflow });
        };
        this.confirmRemove = async (inputs) => {
            const { opOrWorkflow: { name }, } = inputs;
            const { confirmRemove } = await sdk_1.ux.prompt({
                type: 'confirm',
                name: 'confirmRemove',
                message: `Are you sure you want to remove ${name}?`,
            });
            return Object.assign({}, inputs, { confirmRemove });
        };
        this.removeApiOpOrWorkflow = async (inputs) => {
            try {
                if (!inputs.confirmRemove)
                    return inputs;
                const { opOrWorkflow: { id, type }, } = inputs;
                this.log('\n 🗑  Removing from registry...');
                await this.services.api.remove(opConfig_1.getEndpointFromOpType(type), id, {
                    headers: { Authorization: this.accessToken },
                });
                return inputs;
            }
            catch (err) {
                this.debug('%O', err);
                if (err.error[0].code === 5029) {
                    throw new CustomErrors_1.CannotDeleteOps(err);
                }
                throw new CustomErrors_1.APIError(err);
            }
        };
        this.logMessage = (inputs) => {
            const { opOrWorkflow: { id, name }, confirmRemove, } = inputs;
            if (!confirmRemove)
                return inputs;
            this.log(`\n ⚡️ ${sdk_1.ux.colors.bold(`${name}:${id}`)} has been ${sdk_1.ux.colors.green('removed')} from the registry!`);
            this.log(`\n To publish again run: ${sdk_1.ux.colors.green('$')} ${sdk_1.ux.colors.dim('ops publish <path>')}\n`);
            return inputs;
        };
        this.sendAnalytics = (user) => (inputs) => {
            const { email, username } = user;
            const { opOrWorkflow: { id, name, description }, } = inputs;
            this.services.analytics.track({
                userId: email,
                event: 'Ops CLI Remove',
                properties: {
                    email,
                    username,
                    // type: removeType,
                    id,
                    name,
                    description,
                    image: `${env_1.OPS_REGISTRY_HOST}/${name}`,
                },
            }, this.accessToken);
        };
    }
    async run() {
        const { args: { opName }, } = this.parse(Remove);
        try {
            await this.isLoggedIn();
            const removePipeline = utils_1.asyncPipe(
            // this.removeTypePrompt,
            this.promptFilter, this.getApiOpsOrWorkflows, this.selectOpOrWorkflow, this.confirmRemove, this.removeApiOpOrWorkflow, this.logMessage, this.sendAnalytics(this.user));
            await removePipeline(opName);
        }
        catch (err) {
            this.debug('%O', err);
            this.config.runHook('error', { err, accessToken: this.accessToken });
        }
    }
}
Remove.description = 'Remove an op from a team.';
Remove.args = [
    {
        name: 'opName',
        description: 'A part of the name or description of the command or workflow you want to remove.',
    },
];
Remove.flags = {
    help: base_1.flags.help({ char: 'h' }),
};
exports.default = Remove;