main.cjs

const { fork } = require('node:child_process');
const http = require('http');
const readline = require('node:readline');

async function wrapper() {
    var meta = {
        "_mariadb": false
    };
    if(process.argv.indexOf("--iapi-shell") !== -1){
        console.log("[WRAPPER] Entering IAPI shell testing environment...");
        const initializeBlorumServer = (await import("./modules/init.mjs")).initializeBlorumServer;
        const prerequisite = initializeBlorumServer();
        prerequisite.then(async function (results) {
            scheduleDaemon = results.scheduleDaemon;
            scheduleDaemon.on('message', (message) => {
                switch (message.action) {
                    case "log":
                        results.log(message.level, "ScheduleD", message.info);
                        break;
                }
            });

            const IAPI = (await import("./modules/iapi.mjs")).IAPI;
            const iapi = new IAPI(meta, results.mysql, results.redis, results.siteConfig, results.log, results.bootConfig.security.digest_salt, results.bootConfig.database.redis.prefix, scheduleDaemon);
            const rl = readline.createInterface({
                input: process.stdin,
                output: process.stdout,
                prefix: '> ',
            });
            rl.on('line', (input) => {
                try{
                    eval(input);
                }catch(e){
                    console.log(e);
                }
            });
        });
    }else{
        const utils = (await import("./modules/utils.mjs"));
        console.log("[WRAPPER] Starting Blorum Server (" + utils.version + ")...");
        const initializeBlorumServer = (await import("./modules/init.mjs")).initializeBlorumServer;
        const initializeRouter = (await import("./modules/router.mjs")).default;
        //const extensionList = (await import("./modules/extension.mjs")).getExtensionsList;  
        const prerequisite = initializeBlorumServer();
        prerequisite.then(async (results) => {
            meta._mariadb = results._mariadb;
            scheduleDaemon = results.scheduleDaemon;
            scheduleDaemon.on('message', (message) => {
                switch (message.action) {
                    case "log":
                        results.log(message.level, "ScheduleD", message.info);
                        break;
                }
            });
            
            const IAPI = (await import("./modules/iapi.mjs")).IAPI;
            const iapi = new IAPI(meta, results.mysql, results.redis, results.siteConfig, results.log, results.bootConfig.security.digest_salt, results.bootConfig.database.redis.prefix, scheduleDaemon);
            results.log("log", "Main", "Blorum pre-initialization finished.");
            let router = initializeRouter(iapi, results.mysql, results.redis, results.siteConfig, results.log);
            if (results.bootConfig.port <= 1000 && results.bootConfig.port != 0) {
                results.log("warn", "Main", "Port might cause conflict.");
                results.log("warn", "Main", "If you are under *Unix system, this require privilege.");
            }
            let finalServer = http.createServer(
                router
            ).listen(results.bootConfig.port, function () {
                results.log("log", "Main", "Blorum Server started on port " + finalServer.address().port);
                console.log("Welcome to Blorum, made with spaghetti by Winslow S.E.M.");
            }).on('error', function (err) {
                results.log("error", "Main", "Blorum Server failed to start on port " + results.bootConfig.port);
                results.log("error", "Main", err);
            });
        });
    }
}

wrapper();