new event call.upsert

Author: jrclber

package.json

@@ -65,7 +65,7 @@
     "multer": "^1.4.5-lts.1",
     "node-cache": "^5.1.2",
     "npm": "^10.2.4",
-    "pino-pretty": "^10.2.3",
+    "pino-pretty": "^11.0.0",
     "qrcode": "^1.5.1",
     "qrcode-terminal": "^0.12.0",
     "redis": "^4.6.11",
@@ -88,10 +88,10 @@
     "@types/swagger-ui-express": "^4.1.6",
     "@types/uuid": "^9.0.7",
     "@types/yamljs": "^0.2.34",
-    "@typescript-eslint/eslint-plugin": "^6.13.1",
-    "@typescript-eslint/parser": "^6.13.1",
-    "copy-webpack-plugin": "^11.0.0",
-    "eslint": "^8.55.0",
+    "@typescript-eslint/eslint-plugin": "6.21.0",
+    "@typescript-eslint/parser": "6.21.0",
+    "copy-webpack-plugin": "^12.0.2",
+    "eslint": "8.47.0",
     "eslint-config-prettier": "^9.1.0",
     "eslint-plugin-prettier": "^5.0.1",
     "prettier": "^3.1.0",

src/validate/validate.schema.ts

@@ -538,6 +538,7 @@ export const webhookSchema: JSONSchema7 = {
         connectionUpdated: { type: 'boolean', enum: [true, false] },
         statusInstance: { type: 'boolean', enum: [true, false] },
         refreshToken: { type: 'boolean', enum: [true, false] },
+        callUpsert: { type: 'boolean', enum: [true, false] },
       },
     },
   },

src/whatsapp/dto/webhook.dto.ts

@@ -58,6 +58,7 @@ export class WebhookEvents {
   connectionUpdated?: boolean;
   statusInstance?: boolean;
   refreshToken?: boolean;
+  callUpsert?: boolean;
 }
 
 export type EventsType =
@@ -80,7 +81,8 @@ export type EventsType =
   | 'groups.update'
   | 'group-participants.update'
   | 'status.instance'
-  | 'refresh.token';
+  | 'refresh.token'
+  | 'call.upsert';
 
 export type WebhookEventsType = keyof WebhookEvents;
 
@@ -104,6 +106,7 @@ export const WebhookEventsEnum: Record<WebhookEventsType, EventsType> = {
   connectionUpdated: 'connection.update',
   statusInstance: 'status.instance',
   refreshToken: 'refresh.token',
+  callUpsert: 'call.upsert',
 };
 
 export type WebhookEventsMap = typeof WebhookEventsEnum;

src/whatsapp/services/whatsapp.service.ts

@@ -62,6 +62,7 @@ import makeWASocket, {
   useMultiFileAuthState,
   UserFacingSocketConfig,
   WABrowserDescription,
+  WACallEvent,
   WAConnectionState,
   WAMediaUpload,
   WAMessageUpdate,
@@ -971,78 +972,89 @@ export class WAStartupService {
     },
   };
 
+  private readonly callHandler = {
+    'call.upsert': (call: WACallEvent[]) => {
+      call.forEach((c) => {
+        this.sendDataWebhook('callUpsert', c);
+      });
+    },
+  };
+
   private eventHandler() {
     this.client.ev.process((events) => {
       if (!this.endSession) {
-        const database = this.configService.get<Database>('DATABASE');
-
-        if (events['connection.update']) {
+        if (events?.['connection.update']) {
           this.connectionUpdate(events['connection.update']);
         }
 
-        if (events['creds.update']) {
+        if (events?.['creds.update']) {
           this.authState.saveCreds();
         }
 
-        if (events['messaging-history.set']) {
+        if (events?.['messaging-history.set']) {
           const payload = events['messaging-history.set'];
           this.messageHandle['messaging-history.set'](payload);
         }
 
-        if (events['messages.upsert']) {
+        if (events?.['messages.upsert']) {
           const payload = events['messages.upsert'];
           this.messageHandle['messages.upsert'](payload);
         }
 
-        if (events['messages.update']) {
+        if (events?.['messages.update']) {
           const payload = events['messages.update'];
           this.messageHandle['messages.update'](payload);
         }
 
-        if (events['presence.update']) {
+        if (events?.['presence.update']) {
           const payload = events['presence.update'];
           this.sendDataWebhook('presenceUpdated', payload);
         }
 
-        if (events['groups.upsert']) {
+        if (events?.['groups.upsert']) {
           const payload = events['groups.upsert'];
           this.groupHandler['groups.upsert'](payload);
         }
 
-        if (events['groups.update']) {
+        if (events?.['groups.update']) {
           const payload = events['groups.update'];
           this.groupHandler['groups.update'](payload);
         }
 
-        if (events['group-participants.update']) {
+        if (events?.['group-participants.update']) {
           const payload = events['group-participants.update'];
           this.groupHandler['group-participants.update'](payload);
         }
 
-        if (events['chats.upsert']) {
+        if (events?.['chats.upsert']) {
           const payload = events['chats.upsert'];
           this.chatHandle['chats.upsert'](payload);
         }
 
-        if (events['chats.update']) {
+        if (events?.['chats.update']) {
           const payload = events['chats.update'];
           this.chatHandle['chats.update'](payload);
         }
 
-        if (events['chats.delete']) {
+        if (events?.['chats.delete']) {
           const payload = events['chats.delete'];
           this.chatHandle['chats.delete'](payload);
         }
 
-        if (events['contacts.upsert']) {
+        if (events?.['contacts.upsert']) {
           const payload = events['contacts.upsert'];
           this.contactHandle['contacts.upsert'](payload);
         }
 
-        if (events['contacts.update']) {
+        if (events?.['contacts.update']) {
           const payload = events['contacts.update'];
           this.contactHandle['contacts.update'](payload);
         }
+
+        if (events?.['call']) {
+          const payload = events['call'];
+          this.callHandler['call.upsert'](payload);
+        }
       }
     });
   }