@akala/server/dist/triggers/http.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const commands_1 = require("@akala/commands");
const router_1 = require("../router");
const core_1 = require("@akala/core");
const processors_1 = require("@akala/commands/dist/processors");
function wrapHttp(container, command) {
    return function (req, res, next) {
        var result = processCommand(container, command, { '$request': req, $next: next, $response: res });
        if (core_1.isPromiseLike(result)) {
            result.then(function (r) {
                res.json(r);
            }, function (err) {
                res.status(500).json(err);
            });
        }
        else if (typeof result != 'undefined')
            res.json(result);
        else
            res.sendStatus(201);
    };
}
async function processCommand(container, c, injected) {
    var req = injected.$request;
    return processors_1.Local.execute(c, function (...args) {
        container.dispatch(c.name, ...args);
    }, container, { param: [], route: req.params, query: req.query, body: req.body, headers: req.headers, ...injected });
}
function wrapWorker(container, c) {
    return function (req, res) {
        var result = processCommand(container, c, { '$request': req, $callback: res });
        if (core_1.isPromiseLike(result)) {
            result.then(function (r) {
                res(200, r);
            }, function (err) {
                res(500, err);
            });
        }
        else if (typeof result != 'undefined')
            res(result);
        else
            res(201);
    };
}
exports.trigger = new commands_1.Trigger('http', function register(container, router) {
    var commandRouter = new router_1.HttpRouter();
    if (!(router instanceof router_1.HttpRouter))
        commandRouter.attachTo(router);
    commands_1.metadata(container).commands.forEach(command => {
        if (!command.config || !command.config.http)
            return;
        var config = command.config.http;
        if (config.method === 'use' || !config.method) {
            if (commandRouter instanceof router_1.HttpRouter)
                commandRouter.use(config.route, wrapHttp(container, command));
            else
                commandRouter.use(config.route, wrapWorker(container, command));
        }
        else if (router instanceof router_1.HttpRouter)
            commandRouter[config.method](config.route, wrapHttp(container, command));
        else
            commandRouter[config.method](config.route, wrapWorker(container, command));
    });
    return commandRouter;
});
//# sourceMappingURL=http.js.map