index.js

/*_______ ____  _   _  _____
 |__   __/ __ \| \ | |/ ____|
    | | | |  | |  \| | (_____      ____ _ _ __
    | | | |  | | . ` |\___ \ \ /\ / / _` | '_ \
    | | | |__| | |\  |____) \ V  V / (_| | |_) |
    |_|  \____/|_| \_|_____/ \_/\_/ \__,_| .__/
                                         | |
                                         |_| */
/**
 * @name TONSwap project - tonswap.com
 * @copyright SVOI.dev Labs - https://svoi.dev
 * @license Apache-2.0
 */
//let WORKERS = 1;
let WORKERS = (require('os').cpus().length) * 2;

const {FavoritoApp} = require('favorito');
const fs = require('fs');

const bodyParser = require('body-parser');

const cluster = require('cluster');

const config = require(__dirname + '/' + process.argv[2] ?? __dirname + '/config.js');

if(config.maxWorkers) {
    WORKERS = config.maxWorkers;
}


if(cluster.isMaster) {
    console.log(`Master ${process.pid} is running`);

    console.log('Starting', WORKERS, 'workers');

    /**
     * Получает сообщения от воркеров и распространяет их по другим воркерам
     * @param msg
     */
    function messageHandler(msg) {
        if(msg.cmd) {
            //console.log('WORKER MSG', msg);

            //Broadcast message to all workers
            for (const id in cluster.workers) {
                try {
                    cluster.workers[id].send(msg);
                } catch (e) {
                    console.log('CLUSTER SEND ERROR', e);
                }
            }
        }
    }

    // Fork workers.
    for (let i = 0; i < WORKERS; i++) {
        let worker = cluster.fork();
        worker.on('message', messageHandler);
    }


    cluster.on('exit', (worker, code, signal) => {
        console.log(`Worker ${worker.process.pid} died. Spawn new.`);
        console.log(code, signal);
        let newWorker = cluster.fork();
        newWorker.on('message', messageHandler);
    });
} else {

    (async () => {
        const express = require('express');
        const App = new FavoritoApp(__dirname + '/' + process.argv[2] ?? __dirname + '/config.js', 'conFederation ' + process.pid);
        await App.init();

        App.expressApp.use(bodyParser.json({limit: '50mb'}));
        App.expressApp.disable('view cache');
        App.expressApp.set('cache', false);
        App.expressApp.set('etag', false);


        App.expressApp.use('/modules/freeton', express.static('node_modules/freeton/src'));
        App.expressApp.use('/modules/ton-client-web-js', express.static('node_modules/ton-client-web-js/'));
        App.expressApp.use('/ton', express.static('dist'));
        App.expressApp.use('/tonclient.wasm', express.static('dist/tonclient.wasm'));

        const Twig = require('twig');
        const Utils = require('./modules/utils/utils')
        Twig.extendFilter("shortenPubkey", (text) => Utils.shortenPubkey(text));
        Twig.extendFilter("unsignedNumberToSigned", (text, args) => Utils.unsignedNumberToSigned(text, args[0]));
        Twig.extendFilter("numberToUnsignedNumber", (text, args) => Utils.numberToUnsignedNumber(text, args[0]));
        Twig.extendFilter("numberToPercent",        (text, args) => Utils.numberToPercent(text));
        Twig.extendFilter('numberToPretty',    (text, args) => Utils.numberToPretty(text, args[0]));


        await App.start();


        App.on('error', (error) => {
            console.log('ERR', error);
        })

        //App.db.newdb.db.options.logging = false;


        //let config = App.config;
        //let db = App.db.default;


    })()

    process.on('unhandledRejection', error => {
        console.error(error);
    });

    process.on('uncaughtException', error => {
        console.error(error);
    });

    /*setInterval(() => {
        process.send({cmd: 'test', data: {a: 1, b: 2}});
    }, 5000)

    process.on('message', (msg) => {
        console.log('WORKER NEW MESSAGE', process.pid, msg)
    });*/
    //console.log(`Worker ${process.pid} started`);
}


process.on('unhandledRejection', error => {
    console.error(error);
});

process.on('uncaughtException', error => {
    console.error(error);
});