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

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
// tslint:disable-next-line:function-name
function RequireIntegrationFolder() {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            if (this.bearerConfig.isIntegrationLocation) {
                await originalMethod.apply(this, arguments);
            }
            else {
                this.error('This command must be run within a integration folder.');
            }
        };
        return descriptor;
    };
}
exports.RequireIntegrationFolder = RequireIntegrationFolder;
// tslint:disable-next-line:function-name
function RequireLinkedIntegration() {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            if (this.bearerConfig.hasIntegrationLinked) {
                await originalMethod.apply(this, arguments);
            }
            else {
                const error = this.colors.bold('You integration must be linked before running this command\n') +
                    this.colors.yellow(this.colors.italic('Please run: bearer link'));
                this.error(error);
            }
        };
        return descriptor;
    };
}
exports.RequireLinkedIntegration = RequireLinkedIntegration;
function ensureFreshToken() {
    return function (_target, _propertyKey, descriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function () {
            const { authorization, ExpiresAt } = this.bearerConfig.bearerConfig;
            if (authorization && authorization.AuthenticationResult) {
                try {
                    if (ExpiresAt < Date.now()) {
                        this.ux.action.start('Refreshing token');
                        await refreshMyToken(this);
                        this.ux.action.stop();
                    }
                }
                catch (error) {
                    this.ux.action.stop(`Failed`);
                    this.error(error.message);
                }
                // TS is complaining with TS2445, commenting out this for now
                // this.debug('Running original method')
                await originalMethod.apply(this, arguments);
                return descriptor;
            }
            const error = this.colors.bold('⚠️ It looks like you are not logged in\n') +
                this.colors.yellow(this.colors.italic('Please run: bearer login'));
            this.error(error);
            return descriptor;
        };
        return descriptor;
    };
}
exports.ensureFreshToken = ensureFreshToken;
async function refreshMyToken(command) {
    const { RefreshToken } = command.bearerConfig.bearerConfig.authorization.AuthenticationResult;
    if (!RefreshToken) {
        throw new UnauthorizedRefreshTokenError();
    }
    // try {
    const { statusCode, body } = await command.serviceClient.refresh({ RefreshToken });
    switch (statusCode) {
        case 200: {
            const { authorization: { AuthenticationResult } } = body;
            await command.bearerConfig.storeBearerConfig({
                ExpiresAt: Date.now() + AuthenticationResult.ExpiresIn * 1000,
                authorization: {
                    AuthenticationResult: Object.assign({}, AuthenticationResult, { RefreshToken })
                }
            });
            return true;
        }
        case 401: {
            throw new UnauthorizedRefreshTokenError();
        }
        default: {
            throw new UnexpectedRefreshTokenError(JSON.stringify(body, undefined, 2));
        }
    }
}
class UnauthorizedRefreshTokenError extends Error {
    constructor() {
        super('Something went wrong, please run bearer login and try again');
    }
}
class UnexpectedRefreshTokenError extends Error {
    constructor(body) {
        super(`body : ${body}`);
    }
}