fix: Fixed 'Unhandled Rejection' that was killing the application

src/api/helpers/evaluate-and-return.ts

@@ -128,6 +128,12 @@ export async function evaluateAndReturn<T extends EvaluateFn>(
 
     Object.assign(error, result.__error);
 
+    let jsStack = error.stack;
+    Error.captureStackTrace(error);
+    if (jsStack) {
+      error.stack = (error.stack || '') + '\nJS Stack: ' + jsStack;
+    }
+
     throw error;
   }
 

src/api/layers/listener.layer.ts

@@ -15,7 +15,7 @@
  * along with WPPConnect.  If not, see <https://www.gnu.org/licenses/>.
  */
 
-import { EventEmitter } from 'events';
+import { EventEmitter, captureRejectionSymbol } from 'events';
 import { Page } from 'puppeteer';
 import { CreateConfig } from '../../config/create-config';
 import { evaluateAndReturn } from '../helpers';
@@ -45,14 +45,22 @@ declare global {
 }
 
 export class ListenerLayer extends ProfileLayer {
-  private listenerEmitter = new EventEmitter();
+  private listenerEmitter = new EventEmitter({
+    captureRejections: true,
+  });
 
   constructor(public page: Page, session?: string, options?: CreateConfig) {
     super(page, session, options);
 
     this.listenerEmitter.on(ExposedFn.onInterfaceChange, (state) => {
       this.log('http', `Current state: ${state.mode} (${state.displayInfo})`);
     });
+    this.listenerEmitter.on('error', (error) => {
+      this.log('error', error.toString());
+    });
+    this.listenerEmitter[captureRejectionSymbol] = (error) => {
+      this.log('error', error.toString());
+    };
   }
 
   protected async afterPageLoad() {
@@ -356,7 +364,6 @@ export class ListenerLayer extends ProfileLayer {
     return this.registerEvent(
       ExposedFn.onNotificationMessage,
       (message: Message) => {
-        console.log('notification', message);
         // Only group events
         if (
           message.type !== MessageType.GP2 ||

src/controllers/browser.ts

@@ -21,7 +21,6 @@ import * as path from 'path';
 import * as rimraf from 'rimraf';
 import * as waVersion from '@wppconnect/wa-version';
 import axios from 'axios';
-import { addExitCallback } from 'catch-exit';
 import { Browser, BrowserContext, Page } from 'puppeteer';
 import puppeteer from 'puppeteer-extra';
 import { CreateConfig } from '../config/create-config';
@@ -213,13 +212,11 @@ export async function initBrowser(
         if (
           path.relative(os.tmpdir(), tmpUserDataDir).startsWith('puppeteer')
         ) {
-          addExitCallback((signal) => {
+          process.on('exit', () => {
             // Remove only on exit signal
-            if (signal === 'exit') {
-              try {
-                rimraf.sync(tmpUserDataDir);
-              } catch (error) {}
-            }
+            try {
+              rimraf.sync(tmpUserDataDir);
+            } catch (error) {}
           });
         }
       }

src/controllers/initializer.ts

@@ -27,6 +27,25 @@ import {
   StatusFindCallback,
 } from '../api/model/initializer';
 import { SessionToken } from '../token-store';
+import { defaultLogger } from '../utils/logger';
+
+process.on(
+  'unhandledRejection',
+  (reason: Error | any, promise: Promise<any>) => {
+    let message = 'Unhandled Rejection: ';
+    if (reason instanceof Error) {
+      if (reason.stack) {
+        message += reason.stack;
+      } else {
+        message += reason.toString();
+      }
+    } else {
+      message += JSON.stringify(reason);
+    }
+
+    defaultLogger.error(message);
+  }
+);
 
 /**
  * Start the bot

src/utils/ffmpeg.ts

@@ -14,7 +14,6 @@
  * You should have received a copy of the GNU Lesser General Public License
  * along with WPPConnect.  If not, see <https://www.gnu.org/licenses/>.
  */
-import { addExitCallback } from 'catch-exit';
 import execa from 'execa';
 import * as fs from 'fs';
 import * as path from 'path';
@@ -26,7 +25,7 @@ const tmpDir = tmp.dirSync({});
 
 let i = 0;
 
-addExitCallback((signal) => {
+process.on('exit', () => {
   // Remove only on exit signal
   try {
     // Use rimraf because it is synchronous