@akala/server/dist/master.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const fs = require("fs");
const akala = require("@akala/core");
const path_1 = require("path");
const debug = require("debug");
const router_1 = require("./router");
var log = debug('akala:master');
const microservice_1 = require("./microservice");
const config_1 = require("./config");
const master_meta_1 = require("./master-meta");
var httpPackage = 'http';
var port = process.env.PORT || '5678';
akala.register('$updateConfig', new Proxy(config_1.updateConfig, {
    get: function (uc, key) {
        return function (config, subKey) {
            return uc(config, key + '.' + subKey);
        };
    }
}));
akala.registerFactory('$config', new Proxy(config_1.getConfig, {
    get: function (c, key) {
        return function () {
            return c().then(function (config) { return config[key]; });
        };
    }
}));
var lateBoundRoutes = router_1.router();
var preAuthenticatedRouter = router_1.router();
var authenticationRouter = router_1.router();
var app = router_1.router();
akala.register('$preAuthenticationRouter', preAuthenticatedRouter);
akala.register('$authenticationRouter', authenticationRouter);
akala.register('$router', lateBoundRoutes);
var masterRouter = router_1.router();
masterRouter.use(preAuthenticatedRouter.router);
masterRouter.use(authenticationRouter.router);
masterRouter.use(lateBoundRoutes.router);
masterRouter.use(app.router);
var root;
var index;
var privateKey;
var fullchain;
var configFile = fs.realpathSync('./config.json');
fs.exists(configFile, function (exists) {
    var config = exists && require(configFile) || {};
    root = config && config['@akala/server'] && config['@akala/server'].root;
    index = config && config['@akala/server'] && config['@akala/server'].index;
    port = config && config['@akala/server'] && config['@akala/server'].port || port;
    privateKey = config && config['@akala/server'] && config['@akala/server'].privateKey || 'privkey.pem';
    fullchain = config && config['@akala/server'] && config['@akala/server'].fullchain || 'fullchain.pem';
    if (fs.existsSync(privateKey) && fs.existsSync(fullchain))
        httpPackage = 'https';
    var dn = config && config['@akala/server'] && config['@akala/server'].dn || 'localhost';
    akala.register('$rootUrl', httpPackage + '://' + dn + ':' + port);
    var sourcesFile = './sources.list';
    fs.readFile(sourcesFile, 'utf8', function (error, sourcesFileContent) {
        var sources = [];
        var modules = [];
        if (error && error.code == 'ENOENT') {
            var pkg = require(path_1.join(process.cwd(), './package.json'));
            var [source, folder] = pkg.name.split('/');
            microservice_1.microservice(pkg.name, source, [source], config);
            modules.push(pkg.name);
        }
        else {
            sources = JSON.parse(sourcesFileContent);
        }
        akala.eachAsync(sources, function (source, i, next) {
            fs.readdir('node_modules/' + source, function (err, dirModules) {
                if (err) {
                    console.error(err);
                    return;
                }
                dirModules.forEach(function (folder) {
                    microservice_1.microservice(source + '/' + folder, source, [source], config);
                    modules.push(source + '/' + folder);
                });
                next();
            });
        }, function (error) {
            if (error) {
                console.error(error);
                return;
            }
            akala.register('$$modules', modules);
            log(modules);
            akala.module('bootstrap', ...modules).init([], function () {
                log('registering error handler');
                var serveRoot = master_meta_1.serveStatic(root, { index: index || undefined });
                preAuthenticatedRouter.use(master_meta_1.serveStatic(root, { index: index || undefined, fallthrough: true }));
                preAuthenticatedRouter.get('/favicon.ico', master_meta_1.serveStatic(root, { index: index || undefined, fallthrough: false }));
                preAuthenticatedRouter.get('/manifest.json', master_meta_1.serveStatic(root, { index: index || undefined, fallthrough: false }));
                app.get('/@akala/client', function (_req, res) {
                    res.json(modules.map(m => { return { name: m, dep: akala.module(m).dep }; }));
                });
                app.get('*', function (request, response) {
                    if (request.url.endsWith('.map')) {
                        response.sendStatus(404);
                    }
                    else
                        serveRoot(request, response, function () {
                            fs.createReadStream(root + '/index.html').pipe(response);
                        });
                });
                masterRouter.use(function (err, req, res, next) {
                    try {
                        if (err) {
                            console.error('error occurred on ' + req.url);
                            console.error(err.stack);
                            res.statusCode = 500;
                            res.write(JSON.stringify(err));
                            res.end();
                        }
                        else
                            res.sendStatus(404);
                    }
                    catch (e) {
                        console.error(e.stack);
                        res.statusCode = 500;
                        res.end();
                    }
                });
            });
            akala.module('bootstrap').run(['$rootUrl'], function (url) {
                console.log('server ready and listening on ' + url + '...');
            });
            akala.module('bootstrap').start();
        });
    });
    switch (httpPackage) {
        case 'http':
            const http = require('http');
            var server = http.createServer();
            break;
        case 'https':
            // const http2 = require('http2');
            // var server = http2.createSecureServer({ allowHTTP1: true, key: fs.readFileSync('priv.pem'), cert: fs.readFileSync('fullchain.pem') });
            const https = require(httpPackage);
            var server = https.createServer({ key: fs.readFileSync(privateKey), cert: fs.readFileSync(fullchain) });
            break;
    }
    server.listen(port, dn);
    akala.register('$server', server);
    masterRouter.attachTo(server);
});
//# sourceMappingURL=master.js.map