Merge pull request #202 from jeankassio/CodeChat

Bugfix: cannot read properties of undefined

Author: jrCleber

src/whatsapp/services/whatsapp.service.ts

@@ -52,6 +52,7 @@ import makeWASocket, {
   getContentType,
   getDevice,
   GroupMetadata,
+  GroupParticipant,
   isJidGroup,
   isLidUser,
   makeCacheableSignalKeyStore,
@@ -882,8 +883,14 @@ export class WAStartupService {
 
         this.client.sendPresenceUpdate('unavailable');
 
-        if (Long.isLong(received?.messageTimestamp)) {
-          received.messageTimestamp = received.messageTimestamp.toNumber();
+		let timestamp = received?.messageTimestamp;
+
+        if (timestamp && typeof timestamp === 'object' && typeof timestamp.toNumber === 'function') {
+          timestamp = timestamp.toNumber();
+        }else if (timestamp && typeof timestamp === 'object' && 'low' in timestamp && 'high' in timestamp) {
+          timestamp = Number(timestamp.low) || 0;
+        }else if (typeof timestamp !== 'number') {
+          timestamp = 0;
         }
 
         const messageType = getContentType(received.message);
@@ -912,8 +919,8 @@ export class WAStartupService {
           keyParticipant:
             received?.participant || this.normalizeParticipant(received.key),
           messageType,
-          content: received.message[messageType] as PrismType.Prisma.JsonValue,
-          messageTimestamp: received.messageTimestamp,
+          content: JSON.parse(JSON.stringify(received.message[messageType])) as PrismType.Prisma.JsonValue,
+          messageTimestamp: timestamp,
           instanceId: this.instance.id,
           device: (() => {
             if (isValidUlid(received.key.id)) {
@@ -1062,9 +1069,11 @@ export class WAStartupService {
     },
 
     'group-participants.update': (participantsUpdate: {
-      id: string;
-      participants: string[];
-      action: ParticipantAction;
+      id: string
+	  author: string
+	  authorPn?: string
+	  participants: GroupParticipant[]
+	  action: ParticipantAction
     }) => {
       this.ws.send(this.instance.name, 'group-participants.update', participantsUpdate);
       this.sendDataWebhook('groupsParticipantsUpdated', participantsUpdate);
@@ -1379,6 +1388,16 @@ export class WAStartupService {
             }
           }
         }
+		
+		let timestamp = m?.messageTimestamp;
+
+        if (timestamp && typeof timestamp === 'object' && typeof timestamp.toNumber === 'function') {
+          timestamp = timestamp.toNumber();
+        }else if (timestamp && typeof timestamp === 'object' && 'low' in timestamp && 'high' in timestamp) {
+          timestamp = Number(timestamp.low) || 0;
+        }else if (typeof timestamp !== 'number') {
+          timestamp = 0;
+        }
 
         return {
           keyId: m.key.id,
@@ -1387,13 +1406,8 @@ export class WAStartupService {
           keyParticipant: m?.participant,
           pushName: m?.pushName,
           messageType: getContentType(m.message),
-          content: m.message[getContentType(m.message)] as PrismType.Prisma.JsonValue,
-          messageTimestamp: (() => {
-            if (Long.isLong(m.messageTimestamp)) {
-              return m.messageTimestamp.toNumber();
-            }
-            return m.messageTimestamp;
-          })(),
+          content: JSON.parse(JSON.stringify(m.message[getContentType(m.message)])) as PrismType.Prisma.JsonValue,
+          messageTimestamp: timestamp,
           instanceId: this.instance.id,
           device: 'web',
           isGroup: isJidGroup(m.key.remoteJid),
@@ -2239,7 +2253,7 @@ export class WAStartupService {
       let mediaType: string;
 
       for (const type of TypeMediaMessage) {
-        mediaMessage = msg.message[type];
+        mediaMessage = msg?.message?.[type];
         if (mediaMessage) {
           mediaType = type;
           break;
@@ -2540,4 +2554,5 @@ export class WAStartupService {
       throw new BadRequestException('Unable to leave the group', error.toString());
     }
   }
+  
 }