@motionpicture/coa-service/lib/transporters.js

"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
    return new (P || (P = Promise))(function (resolve, reject) {
        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
};
Object.defineProperty(exports, "__esModule", { value: true });
// tslint:disable:max-classes-per-file
/**
 * transporters
 */
const createDebug = require("debug");
const http_status_1 = require("http-status");
const request = require("request");
const debug = createDebug('coa-service:transporters');
// tslint:disable-next-line
const pkg = require('../package.json');
/**
 * リクエスト成功の場合のレスポンス本文のstatus属性の値
 * 失敗の場合はstring型だが、成功の場合のみnumber型が返却されるので注意すること。
 */
const RESPONSE_BODY_STAUS_SUCCESS = 0;
/**
 * transporter abstract class
 * トランスポーター抽象クラス
 */
class Transporter {
}
exports.Transporter = Transporter;
/**
 * COAServiceError
 */
class COAServiceError extends Error {
    constructor(code, status, message) {
        super(message);
        this.name = 'COAServiceError';
        this.code = code;
        this.status = status;
    }
}
exports.COAServiceError = COAServiceError;
/**
 * DefaultTransporter
 */
class DefaultTransporter {
    constructor(expectedStatusCodes) {
        this.expectedStatusCodes = expectedStatusCodes;
    }
    /**
     * Configures request options before making a request.
     */
    static CONFIGURE(options) {
        // set transporter user agent
        options.headers = (options.headers !== undefined) ? options.headers : {};
        // tslint:disable-next-line:no-single-line-block-comment
        /* istanbul ignore else */
        if (!options.headers['User-Agent']) {
            options.headers['User-Agent'] = DefaultTransporter.USER_AGENT;
        }
        else if (options.headers['User-Agent'].indexOf(DefaultTransporter.USER_AGENT) === -1) {
            options.headers['User-Agent'] = `${options.headers['User-Agent']} ${DefaultTransporter.USER_AGENT}`;
        }
        else {
            // no operation
        }
        return options;
    }
    /**
     * Makes a request with given options and invokes callback.
     */
    request(options) {
        return __awaiter(this, void 0, void 0, function* () {
            const requestOptions = DefaultTransporter.CONFIGURE(options);
            debug('requesting...', requestOptions);
            return new Promise((resolve, reject) => {
                request(requestOptions, (error, response, body) => {
                    try {
                        resolve(this.wrapCallback(error, response, body));
                    }
                    catch (callbackErr) {
                        reject(callbackErr);
                    }
                });
            });
        });
    }
    /**
     * Wraps the response callback.
     */
    wrapCallback(error, response, body) {
        let err = new COAServiceError(http_status_1.INTERNAL_SERVER_ERROR, '', 'An unexpected error occurred.');
        if (error instanceof Error) {
            throw new COAServiceError(http_status_1.INTERNAL_SERVER_ERROR, '', error.message);
        }
        debug('request processed', error, body);
        // tslint:disable-next-line:no-single-line-block-comment
        /* istanbul ignore else */
        if (response.statusCode !== undefined) {
            if (this.expectedStatusCodes.indexOf(response.statusCode) < 0) {
                if (typeof body === 'string') {
                    // Consider all 4xx and 5xx responses errors.
                    err = new COAServiceError(response.statusCode, '', body);
                }
                else {
                    // エラーレスポンスにステータスがあった場合
                    // tslint:disable-next-line:no-single-line-block-comment
                    /* istanbul ignore else */
                    if (body.status !== undefined) {
                        err = new COAServiceError(response.statusCode, body.status, body.message);
                    }
                    else {
                        // no operation
                    }
                }
            }
            else {
                // HTTPステータスコード2xxでも、レスポンス本文のステータスが0でなければBadRequest
                if (body.status !== undefined && body.status !== RESPONSE_BODY_STAUS_SUCCESS) {
                    err = new COAServiceError(response.statusCode, body.status, body.message);
                }
                else {
                    if (response.statusCode === http_status_1.NO_CONTENT) {
                        // consider 204
                        return;
                    }
                    else {
                        // consider 200,201
                        return body;
                    }
                }
            }
        }
        else {
            // no operation
        }
        throw err;
    }
}
/**
 * Default user agent.
 */
DefaultTransporter.USER_AGENT = `coa-service/${pkg.version}`;
exports.DefaultTransporter = DefaultTransporter;