JokeAPI-v2/src/main.js

// The main coordination file of JokeAPI
// This file starts all necessary modules like the joke parser, the JokeAPI Documentation page injection and the HTTP listener, etc.

"use strict";


const jsl = require("svjsl");
const fs = require("fs-extra");
const promiseAllSequential = require("promise-all-sequential");
require("dotenv").config();

const env = require("./env");
const debug = require("./verboseLogging");
const parseJokes = require("./parseJokes");
const httpServer = require("./httpServer");
const lists = require("./lists");
const docs = require("./docs");
const analytics = require("./analytics");
const logRequest = require("./logRequest");
const auth = require("./auth");
const languages = require("./languages");
const translate = require("./translate");
const meter = require("./meter");
const settings = require("../settings");

const col = jsl.colors.fg;
process.debuggerActive = jsl.inDebugger();
const noDbg = process.debuggerActive || false;

settings.init.exitSignals.forEach(sig => {
    process.on(sig, () => softExit(0));
});

//#MARKER init all
const initAll = () => {
    env.init();

    let initTimestamp = new Date().getTime();

    console.log(`Initializing ${settings.info.name}...\n`);

    process.jokeapi = {};
    initializeDirs();

    let initPromises = [];
    let initStages = [
        {
            name: "Initializing languages",
            fn: languages.init
        },
        {
            name: "Initializing translations",
            fn: translate.init
        },
        {
            name: "Initializing joke parser",
            fn: parseJokes.init
        },
        {
            name: "Initializing lists",
            fn: lists.init
        },
        {
            name: "Initializing documentation",
            fn: docs.init
        },
        {
            name: "Initializing authorization module",
            fn: auth.init
        },
        {
            name: "Initializing HTTP server",
            fn: httpServer.init
        },
        {
            name: "Initializing analytics module",
            fn: analytics.init
        },
        {
            name: "Initializing pm2 meter",
            fn: meter.init
        }
    ];

    let pb;
    if(!noDbg && !settings.debug.progressBarDisabled)
        pb = new jsl.ProgressBar(initStages.length, initStages[0].name);

    initStages.forEach(stage => {
        initPromises.push(stage.fn);
    });

    debug("Init", `Sequentially initializing all ${initStages.length} modules...`);

    promiseAllSequential(initPromises).then((res) => {
        jsl.unused(res);

        if(!jsl.isEmpty(pb))
            pb.next("Done.");

        debug("Init", `Done initializing all ${initStages.length} modules. Printing init message...`);

        logRequest.initMsg(initTimestamp);
    }).catch(err => {
        initError("initializing", err);
    });
};


//#MARKER other

/**
 * This function gets called when JokeAPI encounters an error while initializing.
 * Because the initialization phase is such a delicate and important process, JokeAPI shuts down if an error is encountered.
 * @param {String} action 
 * @param {Error} err 
 */
const initError = (action, err) => {
    let errMsg = err.stack || err || "(No error message provided)";
    console.log(`\n\n\n${col.red}JokeAPI encountered an error while ${action}:\n${errMsg}\n\n${jsl.colors.rst}`);
    process.exit(1);
}

/**
 * Makes sure all directories exist and creates them if they don't
 */
const initializeDirs = () => {
    try
    {
        settings.init.initDirs.forEach(dir => {
            if(!fs.existsSync(dir))
            {
                debug("InitDirs", `Dir "${dir}" doesn't exist, creating it...`);
                fs.mkdirSync(dir);
            }
        });
    }
    catch(err)
    {
        initError("initializing default directories", err);
    }
}

/**
 * Ends all open connections and then shuts down the process with the specified exit code
 * @param {Number} [code=0] Exit code - defaults to 0
 */
const softExit = code => {
    if(typeof code != "number" || code < 0)
        code = 0;

    analytics.endSqlConnection().then(() => process.exit(code)).catch(() => process.exit(code));
}


module.exports = { softExit };
initAll();