@akala/server/dist/master-meta.js

"use strict";
var __importStar = (this && this.__importStar) || function (mod) {
    if (mod && mod.__esModule) return mod;
    var result = {};
    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
    result["default"] = mod;
    return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const akala = __importStar(require("@akala/core"));
const router = __importStar(require("./router"));
const stream = __importStar(require("stream"));
const send_1 = __importDefault(require("send"));
var log = akala.log('akala:master');
var httpRouter = router.HttpRouter;
exports.Router = httpRouter;
function serveStatic(path, options) {
    if (!options)
        options = {};
    if (typeof (options.fallthrough) == 'undefined')
        options.fallthrough = true;
    return function (req, res, ...next) {
        var sendstr = send_1.default(req, path || req.url, options);
        sendstr.on('error', function (error) {
            if (error && error.code == "ENOENT")
                if (options.fallthrough)
                    next[next.length - 1]();
                else
                    res.status(404).end();
            else
                next[next.length - 1](error);
        });
        sendstr.pipe(res);
    };
}
exports.serveStatic = serveStatic;
function expressWrap(handler) {
    return function (req, response, ...rest) {
        handler(req, response, rest[rest.length - 1]);
    };
}
exports.expressWrap = expressWrap;
function expressWrapError(handler) {
    return function (error, req, response, ...rest) {
        handler(error, req, response, rest[rest.length - 1]);
    };
}
exports.expressWrapError = expressWrapError;
function translateRequest(req) {
    return {
        url: req.url,
        headers: req.headers,
        httpVersion: req.httpVersion,
        httpVersionMajor: req.httpVersionMajor,
        httpVersionMinor: req.httpVersionMinor,
        ip: req.ip,
        method: req.method,
        params: req.params,
        path: req.path,
        protocol: req.protocol,
        query: req.query,
        rawHeaders: req.rawHeaders,
        rawTrailers: req.rawTrailers,
        statusCode: req.statusCode,
        statusMessage: req.statusMessage,
        trailers: req.trailers,
        body: req['body'],
        user: req['user']
    };
}
exports.translateRequest = translateRequest;
function handleResponse(res, locationReplacer, defaultStatus) {
    return function (response) {
        var status = response.statusCode || defaultStatus;
        if (response.headers)
            Object.keys(response.headers).forEach(function (header) {
                if (header.toLowerCase() == 'location' && locationReplacer != null)
                    response.headers[header] = locationReplacer(response.headers[header]);
                res.setHeader(header, response.headers[header]);
            });
        res.writeHead(status, response.statusMessage, response.headers);
        if (response instanceof stream.Readable)
            response.pipe(res);
        else {
            if (Buffer.isBuffer(response.data)) {
                log('sending buffer');
                res.write(response.data);
            }
            else if (Array.isArray(response.data)) {
                log('sending array');
                response.data.forEach(function (chunk) {
                    res.write(chunk);
                });
            }
            else {
                log('sending object');
                if (typeof (response.data) !== 'string' && typeof response.data != 'number' && typeof (response.data) !== 'undefined')
                    res.write(JSON.stringify(response.data));
                else if (typeof (response.data) != 'undefined')
                    res.write(response.data);
            }
            res.end();
        }
    };
}
exports.handleResponse = handleResponse;
//# sourceMappingURL=master-meta.js.map