@bearer/cli/lib/utils/decorators.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const axios_1 = require("axios");
const cli_ux_1 = require("cli-ux");
const inquirer = require("inquirer");
const link_1 = require("../actions/link");
const createIntegration_1 = require("../actions/createIntegration");
const login_1 = require("../actions/login");
const constants_1 = require("./constants");
function skipIfNoViews(displayError = false) {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            if (this.hasViews) {
                await originalMethod.apply(this, arguments);
            }
            else {
                if (displayError) {
                    this.error(
                    // tslint:disable-next-line
                    'This integration does not contain any views. If you want to use this command please generate a new integration with --withViews flag');
                }
                else {
                    this.debug('No views present, skipping');
                }
            }
        };
        return descriptor;
    };
}
exports.skipIfNoViews = skipIfNoViews;
// tslint:disable-next-line:function-name
function RequireIntegrationFolder() {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            if (this.isIntegrationLocation) {
                await originalMethod.apply(this, arguments);
            }
            else {
                this.warn(
                // tslint:disable-next-line: max-line-length
                `We couldn't find any auth.config.json file, please make sure this file exists at the root of your integration`);
                this.error('This command must be run within a integration folder.');
            }
        };
        return descriptor;
    };
}
exports.RequireIntegrationFolder = RequireIntegrationFolder;
// tslint:disable-next-line:function-name
function RequireLinkedIntegration(prompt = true) {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            if (!this.bearerConfig.hasIntegrationLinked) {
                if (!prompt) {
                    this.error('Can not run this command, please run link command before');
                }
                const { choice } = await inquirer.prompt([
                    {
                        name: 'choice',
                        message: "Your integration isn't linked, what would you like to do?",
                        type: 'list',
                        choices: [
                            {
                                name: 'Create a new integration',
                                value: 'create'
                            },
                            {
                                name: 'Select an integration from my list',
                                value: 'select'
                            }
                        ]
                    }
                ]);
                switch (choice) {
                    case 'create':
                        await createIntegration_1.default(this, { link: true });
                        break;
                    case 'select':
                        await link_1.default(this);
                    default:
                        break;
                }
            }
            await originalMethod.apply(this, arguments);
        };
        return descriptor;
    };
}
exports.RequireLinkedIntegration = RequireLinkedIntegration;
function ensureFreshToken() {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            const { expires_at, refresh_token } = (await this.bearerConfig.getToken()) || {
                expires_at: null,
                refresh_token: null
            };
            if (expires_at && refresh_token) {
                try {
                    if (expires_at < Date.now()) {
                        cli_ux_1.default.action.start('Refreshing token');
                        await refreshMyToken(this, refresh_token);
                        cli_ux_1.default.action.stop();
                    }
                }
                catch (error) {
                    cli_ux_1.default.action.stop(`Failed`);
                    this.error(error.message);
                }
            }
            else {
                await login_1.promptToLogin(this);
            }
            return await originalMethod.apply(this, arguments);
        };
        return descriptor;
    };
}
exports.ensureFreshToken = ensureFreshToken;
// tslint:disable-next-line variable-name
async function refreshMyToken(command, refresh_token) {
    // TODO: rework refresh mechanism
    const response = await axios_1.default.post(`${command.constants.LoginDomain}/oauth/token`, {
        refresh_token,
        grant_type: 'refresh_token',
        client_id: constants_1.LOGIN_CLIENT_ID
    });
    await command.bearerConfig.storeToken(Object.assign({}, response.data, { refresh_token }));
    return true;
}