app.js

const express = require('express');
const cors = require("cors");
const bodyParser = require('body-parser');
const cluster = require('cluster');
const os  = require('os');
const readLastLines = require('read-last-lines');


const app = express();
const port = 3002;
const numCpu = os.cpus().length;

app.use(cors());
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());

app.post('/', (req, res) => {
    console.log(req.body, new Date());
    for (let i = 0; i < 1e8; i++) { 

    }
    console.log(new Date());
    res.send({code: 200, pid: process.pid})
    //cluster.Worker.kill(); 
});

app.get('/', (req, res) => {
    console.log(req.body, new Date());
    for (let i = 0; i < 1e8; i++) { 

    }
    console.log(new Date());
    res.send({code: 200, pid: process.pid, name: "Test"})
    //cluster.Worker.kill(); 
});

app.get('/authe/signin', (req, res) => {
    console.log(req.body, new Date());
    for (let i = 0; i < 1e8; i++) { 

    }
    console.log(new Date());
    res.send({code: 200, pid: process.pid})
    //cluster.Worker.kill(); 
});

app.get('/cpu', (req, res) => {
    res.send({code: 200, numOfCpu: numCpu, isMaster: cluster.isMaster})
});

app.get('/err-logs', (req, res) => {
    const startTime = new Date();
    readLastLines.read('./logs/err.log', 10)
    .then((lines) => {
        res.send({Logs: lines, Time: new Date() - startTime }).json()
    }).catch(err=>{
        res.send(err)
    })
 
 
});



// if (cluster.isMaster) {
//     console.log({numCpu});
//     for (let i = 0; i < numCpu; i++) {
//         cluster.fork();    
//     }
//     // cluster.on('exit', (worker, code, signal)=>{
//     //     console.log(`worker ${worker.process.pid} died`);
//     //     cluster.fork() // crete new one after exit 1
//     // })
// }else{
//     app.listen(port, () => { console.log(`server ${process.pid} and app listening on port!`, port) });
// }

 app.listen(port, () => { console.log(`server ${process.pid} and app listening on port!`, port) });