whatsappLink.js

module.exports = function(RED) {
    const QRCode = require('qrcode');
    const FS = require('node:fs')
    const OS = require('os');
    const Path = require('path');
    let userDir = OS.homedir();
    let whatsappLinkDir = Path.join(userDir, '.node-red', 'Whatsapp-Link');
    let whatsappLinkDirSocket = Path.join(whatsappLinkDir, 'WA-Sockets');
    // let whatsappLinkDirSocketLogs = Path.join(whatsappLinkDir, 'WA-Sockets-logs');
        
    function RemoteClientNode(n) {
        RED.nodes.createNode(this,n);
        var WAnode = this;
        var clientType = n.clientType;
        var loopTime = n.loopTime;
        loopTime = loopTime + Math.random();
        loopTime = loopTime * 60 * 60 * 1000 || 3600000;
        var onlineStatus = n.onlineStatus;
        var whatsappConnectionStatus;
        var client

        if (clientType ==="waWebClient"){
            const { Client, LocalAuth } = require('whatsapp-web.js');
            
            var WAConnect = function(){
                const webClient = new Client({
                    authStrategy : new LocalAuth({
                        dataPath : whatsappLinkDir
                    }),
                    puppeteer : {
                        headless : true,
                        args : ['--no-sandbox', '--disable-setuid-sandbox', '--user-data-dir=' + WAnode.id]
                    }
                });

                try {
                    webClient.initialize();
                    WAnode.log("Status : Initializing Whatsapp..");
                }
                catch(e) {
                    WAnode.log(`Error : Unable to start Whatsapp. Try Again..`);
                };
                return webClient ;
            };
            client = WAConnect();
            WAnode.connectionSetupID = setInterval(connectionSetup, 10000); 
            
            async function pressenceUpdate(OLS){
                try {
                    if (!OLS){
                        await client.sendPresenceUnavailable();
                        WAnode.log(`Whatsapp marked as Offline`)
                    } else {
                        await client.sendPresenceAvailable();
                    }
                } catch (e){
                    WAnode.error("Error at pressence : " + e)
                }
            }
            
            function WAClose(){
                try { 
                    client.destroy();
                }
                catch(e){
                    WAnode.err(`Error : Too many instructions! Try again.`)
                }
            };
            
            var WARestart = function(){
                WAClose();
                WAConnect();
            }
            
            async function connectionSetup(){
                try {
                    whatsappConnectionStatus = await client.getState();
                    if(whatsappConnectionStatus === "CONNECTED"){
                        clearInterval(WAnode.connectionSetupID);
                    }
                    else {
                        WAnode.log(`Status : Connecting to Whatsapp...`);
                    }
                }
                catch(e){
                    WAnode.log(`Error : Waiting for Initializion...`);
                }
            };
            
            //QR-Code on Terminal and Ready Status. 
            client.on("qr", (qr)=>{
                clearInterval(WAnode.connectionSetupID);
                QRCode.toString(qr, {type : 'terminal', small:true }, function(err, QRTerminal){
                    WAnode.log(`To Connect, Scan the QR Code through your Whatsapp Mobile App.`)
                    console.log("");
                    console.log(QRTerminal);
                });
            });
            client.on("ready", ()=>{
                WAnode.log(`Status : Whatsapp Connected`);
                pressenceUpdate(onlineStatus);
            });

            client.WAConnect = WAConnect;
            client.WARestart = WARestart;
            client.WAClose = WAClose;
            client.clientType = clientType;
            WAnode.client = client;
        };

        if (clientType === "waSocketClient"){
            const makeWASocket = require('@adiwajshing/baileys');
            const { useMultiFileAuthState } = makeWASocket;
            const pino = require('pino');
            
            async function connectSocketClient() {
                const { state, saveCreds } = await useMultiFileAuthState(whatsappLinkDirSocket);
                // const loggerFile = pino.destination(whatsappLinkDirSocketLogs);
                const socketClient = makeWASocket.default({
                    printQRInTerminal: false,
                    logger:pino({level: "silent"}),
                    auth : state,
                    browser: ["Node-RED", "Chrome", "4.0.0"],
                    markOnlineOnConnect: onlineStatus,
                    patchMessageBeforeSending: (message) => {
                        const requiresPatch = !!(
                            message.buttonsMessage || message.templateMessage || message.listMessage
                        );
                        if (requiresPatch) {
                            message = {
                                viewOnceMessage: {
                                    message: {
                                        messageContextInfo: {
                                            deviceListMetadataVersion: 2,
                                            deviceListMetadata: {},
                                        },
                                        ...message,
                                    },
                                },
                            };
                        }
                        return message;
                        },
                })

                socketClient.ev.on('creds.update', saveCreds);
            
                socketClient.ev.on('connection.update', (update) => {
                    const { connection, lastDisconnect } = update
                    if (connection === 'close') {
                        // reconnect if not logged out
        
                        if (
                            lastDisconnect &&
                            lastDisconnect.error &&
                            lastDisconnect.error.output &&
                            (lastDisconnect.error.output.statusCode === 410 ||
                                lastDisconnect.error.output.statusCode === 428 ||
                                lastDisconnect.error.output.statusCode === 515)
                        ) {
                            connectSocketClient()
                        } else {
                            if (
                                lastDisconnect &&
                                lastDisconnect.error &&
                                lastDisconnect.error.output &&
                                lastDisconnect.error.output.statusCode === 401
                            ) {
                                FS.rmSync(whatsappLinkDirSocket, {recursive : true, force: true})
                                connectSocketClient()
                            } else {
                                WAnode.log("Error : " + lastDisconnect?.error)
                            }
                        }
                    }
                })              
                return socketClient
            };
            client = connectSocketClient();
            client.onlineStatus = onlineStatus;
            client.clientType = clientType;
            client.clientStartFunction = connectSocketClient;
            WAnode.client = client
        };
        
        async function loopStatusUpdate(){
          try {
            if (clientType === "waSocketClient"){
                let myClient = await WAnode.client;
                let id = myClient.user.id;
                await myClient.sendPresenceUpdate("available", id)
                if (!onlineStatus) {
                    setTimeout(()=> {
                        myClient.sendPresenceUpdate("unavailable", id)
                    },17000)
                };
            } 
            else {
                await WAnode.client.sendPresenceAvailable();
                if (!onlineStatus) {
                    setTimeout(()=> {
                        WAnode.client.sendPresenceUnavailable();
                    },17000)
                };
            }}
            catch(e){
                WAnode.error("Error in whatsapp Ping.")
            }
        }
  
        var loopStatusUpdateID = setInterval(()=> {
            loopStatusUpdate();
        }, loopTime)
        
        this.on('close', (removed, done)=>{
            clearInterval(loopStatusUpdateID);
            if(removed){
                if(clientType === "waWebClient"){
                    clearInterval(WAnode.connectionSetupID);
                    WAnode.client.WAClose();
                } else {
                    // WAnode.client.removeAllListeners();
                    WAnode.client.end();
                }

            }
            else {
                if(clientType === "waWebClient"){
                    clearInterval(WAnode.connectionSetupID);
                    WAnode.client.WAClose();
                } else { WAnode.client.end() }
            }
            done();

        });
       
    }
    RED.nodes.registerType("whatsappLink",RemoteClientNode);
}