@blnlpa/asf-tools/tools.api.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 });
const bodyParser = require("body-parser");
const express = require("express");
const tools_1 = require("./tools");
exports.checkRequiredParams = (r) => {
    try {
        if (r.required && r.required.length) {
            const _body = Object.keys(r.req.body), _params = Object.keys(r.req.params);
            if (_body.length && _params.length) {
                for (let i = 0; i < r.required.length; i++) {
                    if (_body.indexOf(r.required[i]) < 0) {
                        if (_params.indexOf(r.required[i]) > -1) {
                            continue;
                        }
                        return tools_1.response(false, `${r.context} '${r.required[i]}' is required`);
                    }
                }
                return tools_1.response(true, null, true);
            }
            else {
                const p = _body.length ? _body : (_params.length ? _params : null);
                if (p && p.length) {
                    for (let i = 0; i < r.required.length; i++) {
                        if (p.indexOf(r.required[i]) < 0) {
                            return tools_1.response(false, `${r.context} '${r.required[i]}' is required`);
                        }
                    }
                    return tools_1.response(true, null, true);
                }
            }
            return tools_1.response(false, 'Required parameters do not match requirements!', null);
        }
    }
    catch (error) {
        console.log(65, error);
    }
};
class Api {
    constructor(dependencies) {
        if (dependencies) {
            this.dependencies = dependencies;
        }
        const app = express();
        process.setMaxListeners(Infinity);
        app.use(bodyParser.json({ strict: false }));
        app.use(function (req, res, next) {
            res
                .set('Access-Control-Allow-Origin', '*')
                .set('Access-Control-Allow-Methods', 'GET, POST, DELETE, PUT')
                .set('Access-Control-Allow-Credentials', true)
                .set('Access-Control-Allow-Headers', 'Origin, Accept, Content-Type, X-Requested-With, X-Merchant-Id');
            process.on('unhandledRejection', (reason, p) => {
                console.log('Unhandled Rejection at: Promise', p, 'reason:', reason);
            });
            next();
        });
        app.disable('x-powered-by');
        this.app = app;
    }
    get(dependencyName) {
        if (this.dependencies[dependencyName]) {
            return this.dependencies[dependencyName];
        }
        return null;
    }
    routes(params) {
        for (let i = 0; i < params.length; i++) {
            let route = params[i].route.toString().trim(), method, swaggerFilePath = params[i].swaggerFilePath || '../../swagger';
            if (route.indexOf(' ') > -1) {
                [method, route] = params[i].route.split(' ');
            }
            else {
                route = params[i].route;
                method = (params[i].method === undefined) ? 'get' : params[i].method.toString();
            }
            method = method.toLowerCase();
            const _params = params[i], that = this;
            this.app[method](route, function (req, res) {
                if (_params.allowCors === undefined) {
                    _params.allowCors = true;
                }
                res
                    .set('Access-Control-Allow-Origin', '*')
                    .set('Access-Control-Allow-Methods', 'GET, POST, DELETE, PUT')
                    .set('Access-Control-Allow-Credentials', true)
                    .set('Access-Control-Allow-Headers', 'Origin, Accept, Content-Type, X-Requested-With, X-Merchant-Id');
                if (route.indexOf('_swagger') > -1) {
                    return res.json(require(swaggerFilePath));
                }
                else {
                    if (_params.required && _params.required.length) {
                        const __response = exports.checkRequiredParams({ req, required: _params.required, context: _params.context });
                        if (!__response.success) {
                            return res.status(400).json(__response);
                        }
                    }
                    const p = {
                        res,
                        req,
                        method,
                        instance: that,
                        context: _params.context,
                        execute: _params['execute'],
                        allowCors: _params.allowCors
                    };
                    that.app.res = res;
                    that.app.req = req;
                    if (_params.executeFirst) {
                        p['executeFirst'] = _params['executeFirst'];
                    }
                    that.executeRoute(p);
                }
            });
        }
    }
    getSourceIp() {
        return __awaiter(this, void 0, void 0, function* () {
            try {
                if (!this.app || !this.app.req) {
                    return tools_1.response(false, 'Not SourceIp Address found.');
                }
                const sourceIp = (this.app.req.headers['x-forwarded-for'] ||
                    this.app.req.connection.remoteAddress ||
                    this.app.req.socket.remoteAddress ||
                    this.app.req.connection.socket.remoteAddress).split(",")[0] || '';
                if (sourceIp) {
                    return tools_1.response(true, null, { sourceIp: sourceIp });
                }
                else {
                    return tools_1.response(false, 'Not SourceIp Address found.');
                }
            }
            catch (error) {
                console.log(78, error);
                return tools_1.response(false, error);
            }
        });
    }
    executeRoute(params) {
        return __awaiter(this, void 0, void 0, function* () {
            const execute = params.execute, executeFirst = params.executeFirst, instance = params.instance;
            let res = params.res, req = params.req;
            try {
                if (executeFirst) {
                    const [obj, meth] = params['executeFirst'].split('.');
                    const awResult = yield instance['dependencies'][obj][meth](params.method === 'get' ? params.req.params : params.req.body, params.method !== 'get' ? params.req.params : instance, params.method !== 'get' ? instance : null);
                    if (awResult) {
                        if (awResult.success) {
                            const [obj, meth] = params['execute'].split('.');
                            const _response = yield instance['dependencies'][obj][meth](params.method === 'get' ? params.req.params : params.req.body, params.method !== 'get' ? params.req.params : instance, params.method !== 'get' ? instance : null);
                            if (_response) {
                                if (_response.success && _response.data) {
                                    if (Array.isArray(_response.data.Items)) {
                                        return res.status(_response.data.Items.length ? 200 : 404).json(tools_1.response(true, false, _response.data.Items.length > 1 ? _response.data.Items : _response.data.Items[0]));
                                    }
                                    else {
                                        res.status(200);
                                    }
                                }
                                else {
                                    res.status(400);
                                }
                            }
                            else {
                                res.status(500);
                            }
                        }
                        else {
                            res.status(400);
                        }
                    }
                    else {
                        res.status(500);
                    }
                    res.json(awResult);
                }
                else {
                    const [obj, meth] = params['execute'].split('.');
                    const _response = yield instance['dependencies'][obj][meth](params.method === 'get' ? params.req.params : params.req.body, params.method !== 'get' ? params.req.params : instance, params.method !== 'get' ? instance : null);
                    if (_response) {
                        if (_response.success && _response.data) {
                            if (Array.isArray(_response.data.Items)) {
                                return res.status(_response.data.Items.length ? 200 : 404).json(tools_1.response(true, false, _response.data.Items.length > 1 ? _response.data.Items : _response.data.Items[0]));
                            }
                            else {
                                res.status(200);
                            }
                        }
                        else {
                            res.status(400);
                        }
                    }
                    else {
                        res.status(500);
                    }
                    res.json(_response);
                }
            }
            catch (error) {
                console.log('[api()] error:', error);
                return res.status(500).json(tools_1.response(false, error.message));
            }
        });
    }
}
exports.Api = Api;
//# sourceMappingURL=tools.api.js.map