sent message erro when not decrypt de message

Author: clairton

__tests__/services/transformer.ts

@@ -734,4 +734,55 @@ describe('service transformer', () => {
       expect(e.message).toBe(`Unknow message type unknown`)
     }
   })
+
+  test('fromBaileysMessageContent Invalid PreKey ID', async () => {
+    const phoneNumer = '5549998093075'
+    const remotePhoneNumber = '+11115551212'
+    const remoteJid = `${remotePhoneNumber}@s.whatsapp.net`
+    const id = `wa.${new Date().getTime()}`
+    const pushName = `Fernanda ${new Date().getTime()}`
+    const messageTimestamp = new Date().getTime()
+    const input = {
+      key: {
+        remoteJid: remoteJid,
+        fromMe: false,
+        id: id,
+      },
+      messageTimestamp,
+      pushName,
+      messageStubType: 2,
+      messageStubParameters: ['Invalid PreKey ID'],
+    }
+    const body = 'Error on decrypt the message!'
+    const output = {
+      object: 'whatsapp_business_account',
+      entry: [
+        {
+          id: phoneNumer,
+          changes: [
+            {
+              value: {
+                messaging_product: 'whatsapp',
+                metadata: { display_phone_number: phoneNumer, phone_number_id: phoneNumer },
+                contacts: [{ profile: { name: pushName }, wa_id: remotePhoneNumber.replace('+', '') }],
+                statuses: [],
+                messages: [
+                  {
+                    from: remotePhoneNumber.replace('+', ''),
+                    id,
+                    timestamp: messageTimestamp,
+                    text: { body },
+                    type: 'text',
+                  },
+                ],
+                errors: [],
+              },
+              field: 'messages',
+            },
+          ],
+        },
+      ],
+    }
+    expect(fromBaileysMessageContent(phoneNumer, input)).toEqual(output)
+  })
 })

src/services/store_file.ts

@@ -61,7 +61,7 @@ const storeFile: store = async (phone: string): Promise<Store> => {
     try {
       dataStore.readFromFile(dataFile)
     } catch (error) {
-      console.error(`erro on read message stores`, error)
+      console.error(`Error on read data store`, error)
     }
   }
   setInterval(() => {

src/services/transformer.ts

@@ -36,6 +36,8 @@ export const getMessageType = (payload: any) => {
   } else if (payload.message) {
     const { message } = payload
     return TYPE_MESSAGES_TO_PROCESS.find((t) => message[t]) || Object.keys(payload.message)[0]
+  } else if (payload.messageStubType) {
+    return 'messageStubType'
   }
 }
 
@@ -155,7 +157,7 @@ export const fromBaileysMessageContent = (phone: string, payload: any): any => {
     const senderJid = isIndividual ? chatJid : (participant && formatJid(participant)) || chatJid
     const senderPhone = jidToPhoneNumber(senderJid)
     const messageType = getMessageType(payload)
-    const binMessage = payload.update || payload.receipt || (messageType && payload.message[messageType])
+    const binMessage = payload.update || payload.receipt || (messageType && payload.message && payload.message[messageType])
     let profileName
     if (fromMe) {
       profileName = senderPhone
@@ -305,6 +307,16 @@ export const fromBaileysMessageContent = (phone: string, payload: any): any => {
         }
         break
 
+      case 'messageStubType':
+        const errors = ['Message absent from node', 'Invalid PreKey ID']
+        if (payload.messageStubType == 2 && payload.messageStubParameters && errors.includes(payload.messageStubParameters[0])) {
+          message.text = {
+            body: 'Error on decrypt the message!',
+          }
+          message.type = 'text'
+        }
+        break
+
       case 'update':
         const baileysStatus = payload.status || payload.update.status
         switch (baileysStatus) {