@iguazu/core/lib/core.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var IO = require("socket.io");
var fastify = require("fastify");
var dotenv = require("dotenv");
var module_1 = require("./module");
function registerPlugins(server, plugins) {
    plugins.forEach(function (plugin) {
        server.register(plugin.handler, plugin.options);
    });
}
function registerControllers(server, controllers) {
    controllers.forEach(function (controller) {
        server.register(controller.handler, { prefix: controller.path });
    });
}
function registerRepositories(server, repositories) {
    repositories.forEach(function (repository) {
        server.register(repository.controller.handler, {
            prefix: repository.controller.path
        });
    });
}
function registerModules(server, modules, wss) {
    modules.forEach(function (module) {
        var plugins = module.plugins, controllers = module.controllers, repositories = module.repositories;
        if (wss) {
            registerWebsockets(wss, repositories);
        }
        registerPlugins(server, plugins);
        registerControllers(server, controllers);
        registerRepositories(server, repositories);
    });
}
function registerWebsockets(wss, repositories) {
    repositories.forEach(function (repo) {
        if (!repo.websocket) {
            return;
        }
        wss.on("connection", function (socket) {
            repo.model.findAll().then(function (all) {
                socket.emit("" + repo.name, all);
            });
        });
    });
}
function startServer(port, server) {
    server.listen(port, function (error) {
        if (error) {
            server.log.error(error);
            process.exit(1);
            return;
        }
        server.log.info(" > Server running on PORT " + port);
        return;
    });
}
function bootstrap(_a) {
    var modules = _a.modules;
    dotenv.config();
    var port = process.env.PORT || "3000";
    var server = fastify();
    var wss = IO(server.server);
    modules = [module_1.DefaultModule].concat(modules);
    registerModules(server, modules, wss);
    return startServer(port, server);
}
exports.bootstrap = bootstrap;