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

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const cli_ux_1 = require("cli-ux");
const axios_1 = require("axios");
const login_1 = require("../actions/login");
const constants_1 = require("./constants");
class Client {
    constructor(command) {
        this.command = command;
        this.instance = axios_1.default.create({
            baseURL: command.constants.DeveloperPortalAPIUrl
        });
        this.instance.interceptors.response.use(r => r, error => {
            if (error.response && error.response.status) {
                command.error('Unauthorized action, please run bearer login first');
            }
            return Promise.reject(error);
        });
    }
    async request(data) {
        await withFreshToken(this.command);
        const token = await this.command.bearerConfig.getToken();
        return await this.instance.post('', data, {
            headers: {
                Authorization: `Bearer ${token.access_token}`
            }
        });
    }
}
exports.Client = Client;
exports.devPortalClient = (command) => {
    return new Client(command);
};
async function withFreshToken(command) {
    const { expires_at, refresh_token } = (await command.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(command, refresh_token);
                cli_ux_1.default.action.stop();
            }
        }
        catch (error) {
            cli_ux_1.default.action.stop(`Failed`);
            command.error(error.message);
        }
    }
    else {
        await login_1.promptToLogin(command);
    }
}
exports.withFreshToken = withFreshToken;
// 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;
}