projeto-hit/TEST_SERVER1/api/app.js

const express = require('express');
const bodyparser = require('body-parser');
const dotenv = require('dotenv');
dotenv.config({ path: '.env' });
const copyFolder = require('./helpers/copyFolder')
const createDir = require('./helpers/createDir')
const createFile = require('./helpers/createFile')
const path = require('path');
const db_info = require('./db_conn')
const fs = require('fs');
let mysql_conn = require('./helpers/mysql_conn.js');
const { exec, execSync, spawn } = require("child_process");

const startPm2Process = require('./helpers/startPm2Process');
const removeDir = require('./helpers/remove_dir');
const setSessionName = require('./helpers/setSessionNumber')
const getNumberFromName = require('./helpers/getNumberSequence')
const pm2 = require('pm2');

const app = express();

app.use(bodyparser.json());

app.get('/', function (req, res) { return res.send('Express + TypeScript Server'); });

app.post('/api/session', async function (req, res) {

    let { app_name, whatsappId, client_url, number } = req.body

    if(app_name){
        app_name = app_name.trim()
    }

    console.log('__dirname: ', path.join(__dirname, '..', app_name))

    console.log('app_name: ', app_name, ' | whatsappId: ', whatsappId, ' | client_url: ',client_url)

    const sessionsPath = path.join(__dirname, '..', 'sessions')

    const directoriesInDIrectory = fs.readdirSync(sessionsPath, { withFileTypes: true })
        .filter((item) => item.isDirectory())
        .map((item) => item.name);

    console.log('directoriesInDIrectory: ', directoriesInDIrectory)

    const dirExist = directoriesInDIrectory.filter((e) => e.trim() == app_name)

    let dirSessionsApp = path.join(sessionsPath, app_name)

    if (dirExist.length == 0) {

        let create = createDir(dirSessionsApp)

        if (!create) {

            res.status(500).json({ message: 'Cannot create the directory path!' })
            return

        }
    }

    let appPort = []



    let existSubDir = false

    for (let i = 0; i < directoriesInDIrectory.length; i++) {

        console.log('directoriesInDIrectory[i]', directoriesInDIrectory[i])

        const subDir = fs.readdirSync(path.join(sessionsPath, directoriesInDIrectory[i]), { withFileTypes: true })
            .filter((item) => item.isDirectory())
            .map((item) => item.name);

        for (let x = 0; x < subDir.length; x++) {

            console.log('subdir: ', subDir[x])

            let whatsId = subDir[x].split('_')[0]

            if (whatsId == whatsappId && app_name == directoriesInDIrectory[i]) {

                let currPath = path.join(sessionsPath, directoriesInDIrectory[i], subDir[x])

                console.log('PATH: ', path.join(sessionsPath, directoriesInDIrectory[i], subDir[x]))

                let oldNumber = subDir[x].split('_')[1]
                // let sessionNum = subDir[x].split('_')[2]
                // let sessionPort = subDir[x].split('_')[3]
                // let newSessionAppName = `${whatsId}_${number}_${sessionNum}_${sessionPort}`

                // let newPath = path.join(sessionsPath, directoriesInDIrectory[i], newSessionAppName)

                // console.log(`number: ${number}\noldNumber: ${oldNumber}\nsessionNum: ${sessionNum}\nsessionPort: ${sessionPort}\nnewSessionAppName:${newSessionAppName}`)

                if (oldNumber != number) {

                    deletePm2Process(subDir[x], currPath)

                    removeDir(currPath)
                }
                else {
                    res.send('ok')
                    return
                }




                // try {

                //     //  

                //     fs.renameSync(currPath, newPath)

                //     console.log("Successfully renamed the directory.")

                //     const data = fs.readFileSync(path.join(`${newPath}`, '.env'), 'utf-8');

                //     // console.log('Data: ', data)

                //     const newValue = data.replace(`MOBILEUID=${oldNumber}`, `MOBILEUID=${number}`)

                //     fs.writeFileSync(path.join(`${newPath}`, '.env'), newValue, 'utf-8');

                //     if (oldNumber != number) { 
                //         removeDir(path.join(newPath, '.wwebjs_auth')) 
                //     }                    

                //     startPm2Process(newSessionAppName, 'app.js', newPath, sessionPort)


                // } catch (err) {
                //     console.log(err)
                // }


                // res.send('ok')
                // return
            }

            appPort.push(+subDir[x].split('_')[3])

            console.log('---------> appPort: '+appPort)

            existSubDir = true

        }

    }

    appPort = existSubDir ? Math.max(...appPort) + 1 : process.env.PORT_START

    console.log('new port: ', appPort)



    let dirSessionAppName

    let numberSession = 1

    // const dirSessionsNumberAppDirectories = fs.readdirSync(dirSessionsApp, { withFileTypes: true })
    //     .filter((item) => item.isDirectory() && item.name.includes(`${number}`))
    //     .map((item) => item.name);

    // console.log('dirSessionsNumberAppDirectories', dirSessionsNumberAppDirectories, ' | dirSessionsApp: ', dirSessionsApp)

    console.log('client_url: ', client_url)

    let db = db_info.filter((e) => e.client_url == client_url)

    if (db && db.length > 0) {

        db = db[0].db_conf
    }

    // if (dirSessionsNumberAppDirectories.length > 0) {

        if (db && Object.keys(db).length > 0) {

            const whatsapp_numbers = await new Promise((resolve, reject) => {
                mysql_conn(db).query('SELECT name FROM Whatsapps WHERE name LIKE ?', [`%${number}%`], (err, result) => {
                    if (err) {
                        reject(err)
                    }
                    else {
                        resolve(result)
                    }
                });
            })

            console.log('whatsapp_numbers: ', whatsapp_numbers)

            let session_num = []

            if (whatsapp_numbers && whatsapp_numbers.length > 0) {

                console.log('whatsapp_numbers.length: ', whatsapp_numbers.length)

                if (whatsapp_numbers.length == 5) {
                    res.status(400).json({ message: 'Cannot create more than 4 sessions from the same number' })
                    return
                }

                let regex = /-> [a-zA-Z]\d$/

                let numbered_sessions = whatsapp_numbers.filter((e) => regex.test(e.name))

                console.log('numbered_sessions: ', numbered_sessions)

                session_num = numbered_sessions.map((e) => parseInt((e.name.split('->')[e.name.split('->').length - 1]).trim().match(/\d+/)[0]))

                console.log('session_num', session_num)
            }

            let index = 1;

            while (index <= 4) {

                if (!session_num.includes(index)) {
                    console.log(index)
                    numberSession = index
                    break
                }
                index++
            }


        }


        // numberSession = Math.max(...session_number) + 1

        console.log('Number session: ', numberSession)

    // }

    dirSessionAppName = `${whatsappId}_${number}_${numberSession}_${appPort}`



    destDir = path.join(dirSessionsApp, dirSessionAppName)

    originDir = path.join(__dirname, '..', 'whats')

    copyFolder(originDir, destDir)


    if (db && Object.keys(db).length > 0) {

        console.log('kkkkkkkkkkkkkkk')

        let whatsName

        const whatsapp = await new Promise((resolve, reject) => {

            mysql_conn(db).query("SELECT name from Whatsapps where id = ?", [whatsappId], (err, result) => {

                if (err) {
                    reject(err)
                }
                else {
                    resolve(result)
                }
            });

        })

        if (whatsapp[0]["name"].split('->').length > 0) {
            whatsName = `${whatsapp[0]["name"].split('->')[0]} -> S${numberSession}`
        }
        else {
            whatsName = `${whatsapp[0]["name"]} -> S${numberSession}`
        }

        console.log('whatsName: ', whatsName)

        console.log(`url: ${process.env.BASE_URL}:${appPort}\n whatsname: ${whatsName}\n whatsappId: ${whatsappId}`)

        await new Promise((resolve, reject) => {
            mysql_conn(db).query("UPDATE Whatsapps SET url = ?, name = ? where id = ?", [`${process.env.BASE_URL}:${appPort}`, `${whatsName}`, whatsappId],

                function (err, result) {
                    if (err) {
                        reject(err)
                        console.log("===> ERROR: " + err);
                    }
                    else {
                        resolve(result)
                        // console.log('RESULT: ', result)
                    }
                    // else
                    //     console.log('myslq result: ', result);
                });
        })

        let whatsappName = `${number} - s${numberSession}`

        console.log('-------------- numberSession', numberSession)

        if (whatsapp.length > 0) {

            if (whatsapp[0]['name'].split(' ').length > 0) {

                whatsappName = `${whatsapp[0]['name'].split(' ')[0]} - S${numberSession}`

            }

        }

        console.log('whatsapp: ', whatsapp)
        console.log("whatsapp[0]['name']: ", whatsapp[0]['name'])

        const keys = Object.keys(db);

        var stream = fs.createWriteStream(path.join(destDir, '.env'));
        stream.once('open', function (fd) {
            stream.write("# NUMBER AND NAME THAT WILL BE DISPLAYED ON CONSOLE\n");
            stream.write(`MOBILEUID=${number}\n`);
            stream.write(`MOBILENAME=${whatsappName}\n`);
            stream.write("\n");

            stream.write("# PORT NUMBER FOR THIS API\n");
            stream.write(`PORT=${appPort}\n`);
            stream.write("\n");

            stream.write("# URL FROM THE OMNIHIT BACKEND API\n");
            stream.write(`CLIENT_URL=${client_url}\n`);
            stream.write("\n");

            stream.write("# OMNIHIT DATABASE\n");
            keys.forEach((key, index) => {
                stream.write(`${key}=${db[key]}\n`);
            });
            stream.write("\n");

            stream.write(`# WHATSAPP ID OF THE TABLE Whatsapps FROM THE OMNIHIT DATABASE\n`);
            stream.write(`WHATSAPP_ID=${whatsappId}`);

            stream.end();
        });



        console.log('----------------destDir: ', destDir)


        execSync(`npm install`, { cwd: destDir }, (error, stdout, stderr) => {
            if (error) {
                console.log(`error: ${error.message}`);
                return;
            }
            if (stderr) {
                console.log(`stderr: ${stderr}`);
                return;
            }
            console.log(`stdout: ${stdout}`);
        });

        startPm2Process(dirSessionAppName, 'app.js', destDir, appPort)

    }

    res.send("OK");

});

app.post('/api/session/edit', async function (req, res) {

    const { app_name, whatsappId, client_url, number } = req.body

})

app.post('/api/session/del', async function (req, res) {

    let { whatsappId, app_name } = req.body

    if(app_name){
        app_name = app_name.trim()
    }

    const sessionsPath = path.join(__dirname, '..', 'sessions')

    const directoriesInDIrectory = fs.readdirSync(sessionsPath, { withFileTypes: true })
        .filter((item) => item.isDirectory())
        .map((item) => item.name);

    console.log('directoriesInDIrectory: ', directoriesInDIrectory)

    const dirExist = directoriesInDIrectory.filter((e) => e.trim() == app_name)

    console.log('dirExist: ', dirExist)

    if (dirExist.length == 0)
        res.send('ok')


    for (let i = 0; i < directoriesInDIrectory.length; i++) {

        console.log('directoriesInDIrectory[i]', directoriesInDIrectory[i])

        const subDir = fs.readdirSync(path.join(sessionsPath, directoriesInDIrectory[i]), { withFileTypes: true })
            .filter((item) => item.isDirectory())
            .map((item) => item.name);

        for (let x = 0; x < subDir.length; x++) {

            console.log('subdir: ', subDir[x])

            let whatsId = subDir[x].split('_')[0]

            if (whatsId == whatsappId && app_name == directoriesInDIrectory[i]) {

                let currPath = path.join(sessionsPath, directoriesInDIrectory[i], subDir[x])

                deletePm2Process(subDir[x], currPath);

                console.log('currPath: ', currPath)

                removeDir(currPath)

                return res.send('ok')

            }

        }

    }

    res.send('ok')

})



app.listen(process.env.PORT || 8003, function () {
    console.log("\u26A1[server]: Server is running at Port ::: " + process.env.PORT || 8003);
});

process.on('uncaughtException', function (err) {
    console.error(' ');
    console.error('----- ' + (new Date).toUTCString() + ' ----------------------------------')
    console.error('Erro uncaughtException: ', err.message)
    console.error(err.stack)
    console.error(' ');
    return
});

function deletePm2Process(process_name, currPath) {
    pm2.connect(function (err) {
        if (err) {
            console.error(err);
        }

        pm2.list(function (err, processes) {
            if (err) {
                console.error(err);
            }

            processes.forEach(function (process) {

                console.log(".........process.name: ", process.name);

                if (process.name === process_name) {
                    execSync(`pm2 delete ${process_name} && pm2 save --force`, { cwd: currPath }, (error, stdout, stderr) => {
                        if (error) {
                            console.log(`error: ${error.message}`);
                            return;
                        }
                        if (stderr) {
                            console.log(`stderr: ${stderr}`);
                            return;
                        }
                        console.log(`stdout: ${stdout}`);
                    });
                }

            });

            pm2.disconnect();
        });
    });
}