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

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const axios_1 = require("axios");
const login_1 = require("../commands/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 this.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 create_1.default.run([]);
                        break;
                    case 'select':
                        await link_1.default.run([]);
                    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()) {
                        this.ux.action.start('Refreshing token');
                        await refreshMyToken(this, refresh_token);
                        this.ux.action.stop();
                    }
                }
                catch (error) {
                    this.ux.action.stop(`Failed`);
                    this.error(error.message);
                }
            }
            else {
                const error = this.colors.bold('⚠️ It looks like you are not logged in');
                this.log(error);
                const { shoudlLogin } = await this.inquirer.prompt([
                    {
                        message: 'Would you like to login?',
                        name: 'shoudlLogin',
                        type: 'list',
                        choices: [{ name: 'Yes', value: true }, { name: 'No', value: false }]
                    }
                ]);
                if (shoudlLogin) {
                    await login_1.default.run([]);
                }
                else {
                    this.exit(0);
                }
            }
            await originalMethod.apply(this, arguments);
            return descriptor;
        };
        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;
}
// note: moving this line here, since link require RequireIntegrationFolder to be defined because it produces
// this error: decorators_1.RequireIntegrationFolder is not a function
const link_1 = require("../commands/link");
const create_1 = require("../commands/integrations/create");