backend-base/dist/request.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const request = require("request");
const utils_1 = require("./utils");
const logger_1 = require("./logger");
function requestAsync(url, options = {}) {
    return new Promise((resolve, reject) => request(url, options, (err, res, body) => {
        const statusCode = res ? res.statusCode : 0;
        if (err)
            return reject(new logger_1.Exception('Request error', {
                statusCode,
                body: body || '',
                error: err,
                url,
                options,
            }));
        return resolve({ res, statusCode, body: body || '' });
    }));
}
async function _requestRaw(url, options) {
    const { attemptsCount = 5, attemptDelay = 1000 } = options;
    for (let i = 1; i <= attemptsCount; i++) {
        logger_1.logger.trace('Request', { url, options, attempt: i === 1 ? undefined : i });
        let res;
        try {
            res = await requestAsync(url, options);
        }
        catch (error) {
            if (error instanceof logger_1.Exception) {
                const jsonErr = error.json;
                const nativeErr = jsonErr.error;
                const timeoutError = nativeErr && (nativeErr.code === 'ETIMEDOUT' || nativeErr.code === 'ESOCKETTIMEDOUT');
                if (timeoutError || error.json.statusCode >= 500) {
                    if (i < attemptsCount) {
                        await utils_1.sleep(attemptDelay);
                        continue;
                    }
                    else {
                        throw new logger_1.ExternalException(timeoutError ? 'Request timeout' : '500', error.json);
                    }
                }
            }
            throw error;
        }
        const errJson = { body: res.body, options, url, statusCode: res.statusCode };
        if (res.statusCode >= 500)
            throw new logger_1.ExternalException('500', errJson);
        if (res.statusCode >= 400)
            throw new logger_1.Exception('400', errJson);
        if (res.statusCode >= 200 && res.statusCode < 300) {
            return res;
        }
        throw new logger_1.Exception('Request error', errJson);
    }
    throw utils_1.never();
}
async function requestRaw(url, options = {}) {
    const res = await _requestRaw(url, options);
    logger_1.logger.trace('RequestResponse', { statusCode: res.statusCode, body: res.body });
    return res;
}
exports.requestRaw = requestRaw;
async function requestJSON(url, options) {
    let d;
    try {
        d = await _requestRaw(url, { headers: { 'content-type': 'application/json' }, ...options });
    }
    catch (e) {
        if (e instanceof logger_1.BaseException) {
            const err = e.json;
            if (typeof err.body === 'string') {
                try {
                    err.body = JSON.parse(err.body);
                }
                catch (e) { }
            }
        }
        throw e;
    }
    try {
        let json;
        if (d.body instanceof Object) {
            json = d.body;
        }
        else {
            json = JSON.parse(d.body.toString() || '{}');
        }
        logger_1.logger.trace('RequestJSONResponse', { statusCode: d.statusCode, body: json });
        return { ...d, data: json };
    }
    catch {
        throw new logger_1.Exception(`Response is not json`, d);
    }
}
exports.requestJSON = requestJSON;
function mockJsonRequest(_method, _url, _json, _result) { }
exports.mockJsonRequest = mockJsonRequest;
function mockGetJsonRequest(url, result) {
    return mockJsonRequest('get', url, undefined, result);
}
exports.mockGetJsonRequest = mockGetJsonRequest;
function mockPostJsonRequest(url, json, result) {
    return mockJsonRequest('post', url, json, result);
}
exports.mockPostJsonRequest = mockPostJsonRequest;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicmVxdWVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9yZXF1ZXN0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsbUNBQW9DO0FBQ3BDLG1DQUF1QztBQUN2QyxxQ0FBK0U7QUFvQi9FLFNBQVMsWUFBWSxDQUFDLEdBQVcsRUFBRSxVQUEwQixFQUFFO0lBQzlELE9BQU8sSUFBSSxPQUFPLENBQVcsQ0FBQyxPQUFPLEVBQUUsTUFBTSxFQUFFLEVBQUUsQ0FDaEQsT0FBTyxDQUFDLEdBQUcsRUFBRSxPQUFPLEVBQUUsQ0FBQyxHQUFVLEVBQUUsR0FBaUMsRUFBRSxJQUF3QixFQUFFLEVBQUU7UUFDakcsTUFBTSxVQUFVLEdBQUcsR0FBRyxDQUFDLENBQUMsQ0FBQyxHQUFHLENBQUMsVUFBVSxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUM7UUFDNUMsSUFBSSxHQUFHO1lBQ04sT0FBTyxNQUFNLENBQ1osSUFBSSxrQkFBUyxDQUFnQixlQUFlLEVBQUU7Z0JBQzdDLFVBQVU7Z0JBQ1YsSUFBSSxFQUFFLElBQUksSUFBSSxFQUFFO2dCQUNoQixLQUFLLEVBQUUsR0FBRztnQkFDVixHQUFHO2dCQUNILE9BQU87YUFDUCxDQUFDLENBQ0YsQ0FBQztRQUNILE9BQU8sT0FBTyxDQUFDLEVBQUUsR0FBRyxFQUFFLFVBQVUsRUFBRSxJQUFJLEVBQUUsSUFBSSxJQUFJLEVBQUUsRUFBRSxDQUFDLENBQUM7SUFDdkQsQ0FBQyxDQUFDLENBQ0YsQ0FBQztBQUNILENBQUM7QUFDRCxLQUFLLFVBQVUsV0FBVyxDQUFDLEdBQVcsRUFBRSxPQUF1QjtJQUM5RCxNQUFNLEVBQUUsYUFBYSxHQUFHLENBQUMsRUFBRSxZQUFZLEdBQUcsSUFBSSxFQUFFLEdBQUcsT0FBTyxDQUFDO0lBQzNELEtBQUssSUFBSSxDQUFDLEdBQUcsQ0FBQyxFQUFFLENBQUMsSUFBSSxhQUFhLEVBQUUsQ0FBQyxFQUFFLEVBQUU7UUFDeEMsZUFBTSxDQUFDLEtBQUssQ0FBQyxTQUFTLEVBQUUsRUFBRSxHQUFHLEVBQUUsT0FBTyxFQUFFLE9BQU8sRUFBRSxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUMsQ0FBQyxTQUFTLENBQUMsQ0FBQyxDQUFDLENBQUMsRUFBRSxDQUFDLENBQUM7UUFDNUUsSUFBSSxHQUFHLENBQUM7UUFDUixJQUFJO1lBQ0gsR0FBRyxHQUFHLE1BQU0sWUFBWSxDQUFDLEdBQUcsRUFBRSxPQUFPLENBQUMsQ0FBQztTQUN2QztRQUFDLE9BQU8sS0FBSyxFQUFFO1lBQ2YsSUFBSSxLQUFLLFlBQVksa0JBQVMsRUFBRTtnQkFDL0IsTUFBTSxPQUFPLEdBQUcsS0FBSyxDQUFDLElBQXFCLENBQUM7Z0JBQzVDLE1BQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxLQUE4QixDQUFDO2dCQUN6RCxNQUFNLFlBQVksR0FBRyxTQUFTLElBQUksQ0FBQyxTQUFTLENBQUMsSUFBSSxLQUFLLFdBQVcsSUFBSSxTQUFTLENBQUMsSUFBSSxLQUFLLGlCQUFpQixDQUFDLENBQUM7Z0JBQzNHLElBQUksWUFBWSxJQUFJLEtBQUssQ0FBQyxJQUFJLENBQUMsVUFBVSxJQUFJLEdBQUcsRUFBRTtvQkFDakQsSUFBSSxDQUFDLEdBQUcsYUFBYSxFQUFFO3dCQUN0QixNQUFNLGFBQUssQ0FBQyxZQUFZLENBQUMsQ0FBQzt3QkFDMUIsU0FBUztxQkFDVDt5QkFBTTt3QkFDTixNQUFNLElBQUksMEJBQWlCLENBQWdCLFlBQVksQ0FBQyxDQUFDLENBQUMsaUJBQWlCLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxLQUFLLENBQUMsSUFBSSxDQUFDLENBQUM7cUJBQ2pHO2lCQUNEO2FBQ0Q7WUFDRCxNQUFNLEtBQUssQ0FBQztTQUNaO1FBQ0QsTUFBTSxPQUFPLEdBQWtCLEVBQUUsSUFBSSxFQUFFLEdBQUcsQ0FBQyxJQUFJLEVBQUUsT0FBTyxFQUFFLEdBQUcsRUFBRSxVQUFVLEVBQUUsR0FBRyxDQUFDLFVBQVUsRUFBRSxDQUFDO1FBQzVGLElBQUksR0FBRyxDQUFDLFVBQVUsSUFBSSxHQUFHO1lBQUUsTUFBTSxJQUFJLDBCQUFpQixDQUFnQixLQUFLLEVBQUUsT0FBTyxDQUFDLENBQUM7UUFDdEYsSUFBSSxHQUFHLENBQUMsVUFBVSxJQUFJLEdBQUc7WUFBRSxNQUFNLElBQUksa0JBQVMsQ0FBZ0IsS0FBSyxFQUFFLE9BQU8sQ0FBQyxDQUFDO1FBQzlFLElBQUksR0FBRyxDQUFDLFVBQVUsSUFBSSxHQUFHLElBQUksR0FBRyxDQUFDLFVBQVUsR0FBRyxHQUFHLEVBQUU7WUFDbEQsT0FBTyxHQUFHLENBQUM7U0FDWDtRQUNELE1BQU0sSUFBSSxrQkFBUyxDQUFnQixlQUFlLEVBQUUsT0FBTyxDQUFDLENBQUM7S0FDN0Q7SUFDRCxNQUFNLGFBQUssRUFBRSxDQUFDO0FBQ2YsQ0FBQztBQUNNLEtBQUssVUFBVSxVQUFVLENBQUMsR0FBVyxFQUFFLFVBQTBCLEVBQUU7SUFDekUsTUFBTSxHQUFHLEdBQUcsTUFBTSxXQUFXLENBQUMsR0FBRyxFQUFFLE9BQU8sQ0FBQyxDQUFDO0lBQzVDLGVBQU0sQ0FBQyxLQUFLLENBQUMsaUJBQWlCLEVBQUUsRUFBRSxVQUFVLEVBQUUsR0FBRyxDQUFDLFVBQVUsRUFBRSxJQUFJLEVBQUUsR0FBRyxDQUFDLElBQUksRUFBRSxDQUFDLENBQUM7SUFDaEYsT0FBTyxHQUFHLENBQUM7QUFDWixDQUFDO0FBSkQsZ0NBSUM7QUFFTSxLQUFLLFVBQVUsV0FBVyxDQUFJLEdBQVcsRUFBRSxPQUF3QjtJQUN6RSxJQUFJLENBQUMsQ0FBQztJQUNOLElBQUk7UUFDSCxDQUFDLEdBQUcsTUFBTSxXQUFXLENBQUMsR0FBRyxFQUFFLEVBQUUsT0FBTyxFQUFFLEVBQUUsY0FBYyxFQUFFLGtCQUFrQixFQUFFLEVBQUUsR0FBRyxPQUFPLEVBQUUsQ0FBQyxDQUFDO0tBQzVGO0lBQUMsT0FBTyxDQUFDLEVBQUU7UUFDWCxJQUFJLENBQUMsWUFBWSxzQkFBYSxFQUFFO1lBQy9CLE1BQU0sR0FBRyxHQUFHLENBQUMsQ0FBQyxJQUFnQixDQUFDO1lBQy9CLElBQUksT0FBTyxHQUFHLENBQUMsSUFBSSxLQUFLLFFBQVEsRUFBRTtnQkFDakMsSUFBSTtvQkFDSCxHQUFHLENBQUMsSUFBSSxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUMsR0FBRyxDQUFDLElBQUksQ0FBQyxDQUFDO2lCQUNoQztnQkFBQyxPQUFPLENBQUMsRUFBRSxHQUFFO2FBQ2Q7U0FDRDtRQUNELE1BQU0sQ0FBQyxDQUFDO0tBQ1I7SUFDRCxJQUFJO1FBQ0gsSUFBSSxJQUFJLENBQUM7UUFDVCxJQUFJLENBQUMsQ0FBQyxJQUFJLFlBQVksTUFBTSxFQUFFO1lBQzdCLElBQUksR0FBSSxDQUFDLENBQUMsSUFBcUIsQ0FBQztTQUNoQzthQUFNO1lBQ04sSUFBSSxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxRQUFRLEVBQUUsSUFBSSxJQUFJLENBQU0sQ0FBQztTQUNsRDtRQUNELGVBQU0sQ0FBQyxLQUFLLENBQUMscUJBQXFCLEVBQUUsRUFBRSxVQUFVLEVBQUUsQ0FBQyxDQUFDLFVBQVUsRUFBRSxJQUFJLEVBQUUsSUFBSSxFQUFFLENBQUMsQ0FBQztRQUM5RSxPQUFPLEVBQUUsR0FBRyxDQUFDLEVBQUUsSUFBSSxFQUFFLElBQUksRUFBRSxDQUFDO0tBQzVCO0lBQUMsTUFBTTtRQUNQLE1BQU0sSUFBSSxrQkFBUyxDQUFDLHNCQUFzQixFQUFFLENBQUMsQ0FBQyxDQUFDO0tBQy9DO0FBQ0YsQ0FBQztBQTNCRCxrQ0EyQkM7QUFFRCxTQUFnQixlQUFlLENBQUMsT0FBZSxFQUFFLElBQVksRUFBRSxLQUF5QixFQUFFLE9BQWUsSUFBRyxDQUFDO0FBQTdHLDBDQUE2RztBQUM3RyxTQUFnQixrQkFBa0IsQ0FBQyxHQUFXLEVBQUUsTUFBYztJQUM3RCxPQUFPLGVBQWUsQ0FBQyxLQUFLLEVBQUUsR0FBRyxFQUFFLFNBQVMsRUFBRSxNQUFNLENBQUMsQ0FBQztBQUN2RCxDQUFDO0FBRkQsZ0RBRUM7QUFDRCxTQUFnQixtQkFBbUIsQ0FBQyxHQUFXLEVBQUUsSUFBd0IsRUFBRSxNQUFjO0lBQ3hGLE9BQU8sZUFBZSxDQUFDLE1BQU0sRUFBRSxHQUFHLEVBQUUsSUFBSSxFQUFFLE1BQU0sQ0FBQyxDQUFDO0FBQ25ELENBQUM7QUFGRCxrREFFQyJ9