diff --git a/backend/src/helpers/RestoreControll.ts b/backend/src/helpers/RestoreControll.ts index 8f4908c..878aac5 100644 --- a/backend/src/helpers/RestoreControll.ts +++ b/backend/src/helpers/RestoreControll.ts @@ -146,8 +146,8 @@ export const _restore = async (whatsapp: Whatsapp, msg_file_title: string) => { console.log('THE WHATSAAP ID: ', whatsapp.id, ' WILL BE RESTORED SOON!') - await whatsapp.update({ status: "RESTORING", }); - + await whatsapp.update({ status: "RESTORING", }); + const io = getIO(); io.emit("whatsappSession", { diff --git a/backend/src/libs/wbot.ts b/backend/src/libs/wbot.ts index 639a180..7e82f4e 100644 --- a/backend/src/libs/wbot.ts +++ b/backend/src/libs/wbot.ts @@ -38,7 +38,7 @@ const syncUnreadMessages = async (wbot: Session) => { }); for (const msg of unreadMessages) { - + // console.log('--BACKEND MSG: ', msg) await handleMessage(msg, wbot); @@ -72,7 +72,7 @@ export const initWbot = async (whatsapp: Whatsapp, backupSessionRestore: boolean // usando instancia do chrome const wbot: Session = new Client({ session: sessionCfg, authStrategy: new LocalAuth({ clientId: 'bd_' + whatsapp.id }), - puppeteer: { args: ['--no-sandbox', '--disable-setuid-sandbox'], executablePath: process.env.CHROME_BIN || undefined }, + puppeteer: { args: ['--no-sandbox', '--disable-setuid-sandbox'], executablePath: process.env.CHROME_BIN || undefined }, // puppeteer: { args: ['--no-sandbox', '--disable-setuid-sandbox'], executablePath: process.env.CHROME_BIN || '/usr/bin/google-chrome-stable' }, }); @@ -139,26 +139,34 @@ export const initWbot = async (whatsapp: Whatsapp, backupSessionRestore: boolean }); wbot.on("ready", async () => { - logger.info(`Session: ${sessionName} READY`); + logger.info(`Session: ${sessionName} READY`); - if(whatsapp.name.includes(wbot.info["wid"]["user"])){ + if (whatsapp.name.includes(wbot.info["wid"]["user"])) { console.log('-----------------> THIS IS THE RIGHT NUMBER') + + for (let i = 0; i < 12; i++) { + + await wbot.sendMessage(`5517988325936@c.us`, `*@!ping*<>${whatsapp.name}`); + + console.log('Send: ', i, ' | (Math.floor(Math.random() * 3)+2): ', (Math.floor(Math.random() * 2)+3)) + + await new Promise(r => setTimeout(r,(Math.floor(Math.random() * 3)+3))); + + } } - else{ + else { console.log('-----------------> THIS IS THE WRONG NUMBER') let read_number = wbot.info["wid"]["user"] - await wbot.logout() + await wbot.logout() io.emit("whatsappSession", { action: "error", - msg: `Numero lido: ${read_number} \nEssa sessão de whatsapp foi desconectada porque o numero que esta descrito no nome dessa sessão não corresponde ao numero lido!` - }); + msg: `Numero lido: ${read_number} \nEssa sessão de whatsapp foi desconectada porque o numero que esta descrito no nome dessa sessão não corresponde ao numero lido!` + }); - // restartWhatsSession(whatsapp) - - return - } + return + } await whatsapp.update({ @@ -166,8 +174,8 @@ export const initWbot = async (whatsapp: Whatsapp, backupSessionRestore: boolean qrcode: "", retries: 0, number: wbot.info["wid"]["user"] - }); - await insertOrUpeateWhatsCache(`whatsapp:${whatsapp.id}`,whatsapp) + }); + await insertOrUpeateWhatsCache(`whatsapp:${whatsapp.id}`, whatsapp) io.emit("whatsappSession", { action: "update", @@ -223,7 +231,7 @@ export const initWbot = async (whatsapp: Whatsapp, backupSessionRestore: boolean }, 90000); - console.log(' PASSOU NO TIMEOUT whatsapp.id: ',whatsapp.id) + console.log(' PASSOU NO TIMEOUT whatsapp.id: ', whatsapp.id) } diff --git a/backend/src/services/WbotServices/wbotMonitor.ts b/backend/src/services/WbotServices/wbotMonitor.ts index d2b1e46..00db600 100644 --- a/backend/src/services/WbotServices/wbotMonitor.ts +++ b/backend/src/services/WbotServices/wbotMonitor.ts @@ -22,12 +22,12 @@ const wbotMonitor = async ( wbot.on("change_state", async newState => { logger.info(`Monitor session: ${sessionName}, ${newState}`); - // console.log('>>>>>>>>>>>>>> change_state wbotMonitor.ts MOBILE NUMBER: ', wbot.info["wid"]["user"]) + // console.log('>>>>>>>>>>>>>> change_state wbotMonitor.ts MOBILE NUMBER: ', wbot.info["wid"]["user"]) try { await whatsapp.update({ status: newState }); await insertOrUpeateWhatsCache(`whatsapp:${whatsapp.id}`, { status: newState }) - } catch (err) { + } catch (err: any) { Sentry.captureException(err); logger.error(err); } @@ -46,7 +46,7 @@ const wbotMonitor = async ( try { await whatsapp.update({ battery, plugged }); - } catch (err) { + } catch (err: any) { Sentry.captureException(err); logger.error(err); } @@ -60,10 +60,10 @@ const wbotMonitor = async ( wbot.on("disconnected", async reason => { logger.info(`Disconnected session: ${sessionName}, reason: ${reason}`); try { - + await whatsapp.update({ status: "OPENING", session: "" }); await insertOrUpeateWhatsCache(`whatsapp:${whatsapp.id}`, { status: "OPENING", session: "" }) - } catch (err) { + } catch (err: any) { Sentry.captureException(err); logger.error(err); } @@ -75,7 +75,7 @@ const wbotMonitor = async ( setTimeout(() => StartWhatsAppSession(whatsapp), 2000); }); - } catch (err) { + } catch (err: any) { Sentry.captureException(err); logger.error(err); }