Add APP_WEBHOOK_FILES_BASE64 configuration option and convert media files to base64 before sending to webhook

Author: andresayac

.env.example

@@ -14,3 +14,4 @@ AUTHENTICATION_GLOBAL_AUTH_TOKEN=A4gx18YGxKAvR01ClcHpcR7TjZUNtwvE
 # WEBHOOK CONFIGURATION
 APP_WEBHOOK_URL="https://webhook.site/dbf387ed-a861-4ae9-9b30-9344c972cb74"
 APP_WEBHOOK_ALLOWED_EVENTS=MESSAGES_UPSERT,MESSAGES_DELETE,MESSAGES_UPDATE
+APP_WEBHOOK_FILE_IN_BASE64=false

whatsapp.js

@@ -58,9 +58,9 @@ const shouldReconnect = (sessionId) => {
     return false
 }
 
-const callWebhook = (instance, eventType, eventData) => {
+const callWebhook = async (instance, eventType, eventData) => {
     if (APP_WEBHOOK_ALLOWED_EVENTS.includes('ALL') || APP_WEBHOOK_ALLOWED_EVENTS.includes(eventType)) {
-        webhook(instance, eventType, eventData)
+        await webhook(instance, eventType, eventData)
     }
 }
 
@@ -170,14 +170,55 @@ const createSession = async (sessionId, res = null, options = { usePairingCode:
             return m.key.fromMe === false
         })
         if (messages.length > 0) {
-            // Change status
-            for (const message of messages) {
-                if (message?.status) {
-                    m.status = WAMessageStatus[m?.status] ?? 'UNKNOWN'
-                }
+            const messageTmp = await Promise.all(
+                messages.map(async (msg) => {
+                    try {
+                        const typeMessage = Object.keys(msg.message)[0]
+                        if (msg?.status) {
+                            msg.status = WAMessageStatus[msg?.status] ?? 'UNKNOWN'
+                        }
+
+                        if (
+                            ['documentMessage', 'imageMessage', 'videoMessage', 'audioMessage'].includes(typeMessage) &&
+                            process.env.APP_WEBHOOK_FILE_IN_BASE64 === 'true'
+                        ) {
+                            const mediaMessage = await getMessageMedia(wa, msg)
+
+                            const fieldsToConvert = [
+                                'fileEncSha256',
+                                'mediaKey',
+                                'fileSha256',
+                                'jpegThumbnail',
+                                'thumbnailSha256',
+                                'thumbnailEncSha256',
+                                'streamingSidecar',
+                            ]
+
+                            fieldsToConvert.forEach((field) => {
+                                if (msg.message[typeMessage]?.[field] !== undefined) {
+                                    msg.message[typeMessage][field] = convertToBase64(msg.message[typeMessage][field])
+                                }
+                            })
+
+                            return {
+                                ...msg,
+                                message: {
+                                    [typeMessage]: {
+                                        ...msg.message[typeMessage],
+                                        fileBase64: mediaMessage.base64,
+                                    },
+                                },
+                            }
+                        }
+
+                        return msg
+                    } catch {
+                        return {}
+                    }
+                }),
+            )
 
-                callWebhook(sessionId, 'MESSAGES_UPSERT', message)
-            }
+            callWebhook(sessionId, 'MESSAGES_UPSERT', messageTmp)
         }
     })
 
@@ -550,6 +591,11 @@ const getMessageMedia = async (session, message) => {
     }
 }
 
+const convertToBase64 = (arrayBytes) => {
+    const byteArray = new Uint8Array(arrayBytes)
+    return Buffer.from(byteArray).toString('base64')
+}
+
 const init = () => {
     readdir(sessionsDir(), (err, files) => {
         if (err) {