jonalan7 / hydra-bot Goto Github PK

Webhooktest Return object  {
  onType: 'interfaceChange',
  session: 'user',
  result: { displayInfo: 'CONNECTING', mode: 'QR', info: 'OPENING' },
  token: '5cc32e366c87c4cb49e4309b75f57d64'
}
Webhooktest Return object  {
  onType: 'interfaceChange',
  session: 'user',
  result: { displayInfo: 'CONNECTING', mode: 'QR', info: 'PAIRING' },
  token: '5cc32e366c87c4cb49e4309b75f57d64'
}
node:internal/process/promises:279
            triggerUncaughtException(err, true /* fromPromise */);
            ^

[UnhandledPromiseRejection: This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). The promise rejected with the reason "AxiosError: Request failed with status code 429".] {
  code: 'ERR_UNHANDLED_REJECTION'
}
disconnect
child process exited with code 1

const hydraBot = require('hydra-bot');
var serveStatic = require( "serve-static" );
(async () => {
  // start Web Service
  const WS = hydraBot.initWs(
      {
        port: '8080',
        url: '', // point a URL to receive a callback!
        authentication: true, // ask for authentication in routes
        pathNameToken: "token", // The path and name of the folder where the client tokens will be saved
        printQRInTerminal: true, // The QR CODE will be printed on the terminal if true
        updatesLog: true, // Logs info updates automatically in terminal
        timeAutoClose: 60000, // If you don't read the QR CODE by default 60 seconds, it will automatically close the client's browser to save memory, if you want to disable it, set 0 or false
        mkdirFolderToken: 'E:\\', // Token folder path, only inside the project
        puppeteerOptions: {
          headless: true, // Start the project with the browser open or not!
          args: [], // Additional arguments to pass to the browser instance. adding any parameter you will replace the default args of the project
          executablePath: 'useChrome' // The browser that will be used for the project, you can specify a path, if you don't pass any parameters it will open the installed browser.
        }
      }
      );
      
      
})();

[CON]: initBrowser
[CON]: initWhatsapp
[CON]: openedWhatsapp
(node:6764) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 interfaceChange listeners added to [EventEmitter]. Use emitter.setMaxListeners() to increase limit
(Use `node --trace-warnings ...` to show where the warning was created)
MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 interfaceChange listeners added to [EventEmitter]. Use emitter.setMaxListeners() to increase limit
    at _addListener (node:events:587:17)
    at EventEmitter.addListener (node:events:605:10)
    at webPack.listener (C:\Users\Admin\Documents\Ag2\node_modules\hydra-bot\dist\webpack\api\layes\listener.layes.js:76:30)
    at webPack.initLitener (C:\Users\Admin\Documents\Ag2\node_modules\hydra-bot\dist\webpack\api\layes\listener.layes.js:71:14)
    at processTicksAndRejections (node:internal/process/task_queues:96:5)

console.log('process.platform',process.platform);
let client;
// start bot service
const ev = await hydraBot.initServer({
    session: "session-1",
    pathNameToken:"token-1",
    mkdirFolderToken:'',
    puppeteerOptions: {
        headless: process.platform === 'linux' ? true : false ,
        executablePath: process.platform === 'linux' ? "/usr/bin/google-chrome" : "/Applications/Google Chrome.app/Contents/MacOS/Google Chrome",
        args: [], // Additional arguments to pass to the browser instance. adding any parameter you will replace the default args of the project
    }
});

// return to current whatsapp interface
ev.on('interfaceChange', (change) => {
    console.log("interfaceChange: ", change);
});

// return qrcode parameters
ev.on('qrcode', (qrcode) => {
    console.log('qrcode: ', qrcode);
});

// return connection information
ev.on('connection', async (conn) => {

    // browser information!
    if (conn.statusFind === 'browser') {
        console.log('info Browser: ', conn.text);
    }

    // Was connected to whatsapp chat
    if (conn.connect) {
        client = conn.client;
        // send a text message
        await client.sendMessage({
            to: "[email protected]", // you can pass the contact number or group number
            body: "hi i'm hydra bot", // message text
            options: {
                type: 'text', // shipping type
            }
        }).then((result) => {
            console.log(result); // message result
        }).catch((error) => {
            console.log(error); // message error
        });
    }
});

// return receive new messages
ev.on('newMessage', async (newMsg) => {
    // when is received
    if (!newMsg.result.isSentByMe) {
        // message received!
        console.log('NewMessageReceived: ', newMsg.result);
        // dowload files
        if (newMsg.result.isMedia === true || newMsg.result.isMMS === true) {
            const buffer = await client.decryptFile(newMsg.result);
            // At this point you can do whatever you want with the buffer
            // Most likely you want to write it into a file
            const fileName = `some-file-name.${mime.extension(newMsg.result.mimetype)}`;
            fs.writeFile(fileName, buffer, (err) => {
                console.log(err);
            });
        }
    }
    // when is it sent
    if (!!newMsg.result.isSentByMe) {
        // Message sent
        console.log('NewMessageSent: ', newMsg.result);
    }
});

// returns the status of each message
ev.on('newOnAck', async (event) => {
    console.log('id Message: ', event.id._serialized); // message id
    console.log('Status Message: ', event.ack); // -7 = MD_DOWNGRADE, -6 = INACTIVE, -5 = CONTENT_UNUPLOADABLE, -4 = CONTENT_TOO_BIG, -3 = CONTENT_GONE, -2 = EXPIRED, -1 = FAILED, 0 = CLOCK, 1 = SENT, 2 = RECEIVED, 3 = READ, 4 = PLAYED
    console.log('From Message: ', event.from); // from message
    console.log('To Message: ', event.to); // to message
});

let client;
// start bot service
const ev = await hydraBot.initServer({
    puppeteerOptions: {
        headless: process.platform === 'linux' ? true : false ,
        executablePath: process.platform === 'linux' ? "/usr/bin/google-chrome" : "/Applications/Google Chrome.app/Contents/MacOS/Google Chrome",
        args: ['--no-sandbox'], // Additional arguments to pass to the browser instance. adding any parameter you will replace the default args of the project
    }
});

// return to current whatsapp interface
ev.on('interfaceChange', (change) => {
    console.log("interfaceChange: ", change);
});

// return qrcode parameters
ev.on('qrcode', (qrcode) => {
    console.log('qrcode: ', qrcode);
});

// return connection information
ev.on('connection', async (conn) => {

    // browser information!
    if (conn.statusFind === 'browser') {
        console.log('info Browser: ', conn.text);
    }

    // Was connected to whatsapp chat
    if (conn.connect) {
        client = conn.client;
        // send a text message
        await client.sendMessage({
            to: "[email protected]", // you can pass the contact number or group number
            body: "hi i'm hydra bot", // message text
            options: {
                type: 'text', // shipping type
            }
        }).then((result) => {
            console.log(result); // message result
        }).catch((error) => {
            console.log(error); // message error
        });
    }
});

// return receive new messages
ev.on('newMessage', async (newMsg) => {
    // when is received
    if (!newMsg.result.isSentByMe) {
        // message received!
        console.log('NewMessageReceived: ', newMsg.result);
        // dowload files
        if (newMsg.result.isMedia === true || newMsg.result.isMMS === true) {
            const buffer = await client.decryptFile(newMsg.result);
            // At this point you can do whatever you want with the buffer
            // Most likely you want to write it into a file
            const fileName = `some-file-name.${mime.extension(newMsg.result.mimetype)}`;
            fs.writeFile(fileName, buffer, (err) => {
                console.log(err);
            });
        }
    }
    // when is it sent
    if (!!newMsg.result.isSentByMe) {
        // Message sent
        console.log('NewMessageSent: ', newMsg.result);
    }
});

// returns the status of each message
ev.on('newOnAck', async (event) => {
    console.log('id Message: ', event.id._serialized); // message id
    console.log('Status Message: ', event.ack); // -7 = MD_DOWNGRADE, -6 = INACTIVE, -5 = CONTENT_UNUPLOADABLE, -4 = CONTENT_TOO_BIG, -3 = CONTENT_GONE, -2 = EXPIRED, -1 = FAILED, 0 = CLOCK, 1 = SENT, 2 = RECEIVED, 3 = READ, 4 = PLAYED
    console.log('From Message: ', event.from); // from message
    console.log('To Message: ', event.to); // to message
});