perf: 优化消息处理逻辑，增加接收图片事件触发

wai-server/core/baileys/index.js

@@ -89,18 +89,22 @@ const createWhatsApp = async phone => {
             groupSubjectCache.set(msg.key.remoteJid, groupMetadata.subject)
           }
 
+          const emitEventName = msg.key.fromMe ? 'message:updated' : 'message:received';
+          const msgDirection = msg.key.fromMe ? 'outbound' : 'inbound';
+          const msgFrom = msg.key.fromMe ? whatsAppNo : remoteNo;
+          const msgTo = msg.key.fromMe ? remoteNo : whatsAppNo;
+
           if (msg.message?.conversation || msg.message?.extendedTextMessage?.text) {
 
             const text = msg.message?.conversation || msg.message?.extendedTextMessage?.text;
 
-            if (msg.key.fromMe) {
+            waEmitter.emit(emitEventName, {
-              waEmitter.emit('message:updated', {
               id: msg.key.id,
               externalId,
               status: formatStatus(msg.status),
-                direction: 'outbound',
+              direction: msgDirection,
-                from: whatsAppNo,
+              from: msgFrom,
-                to: remoteNo,
+              to: msgTo,
               type: 'text',
               text: {
                 body: text,
@@ -118,34 +122,7 @@ const createWhatsApp = async phone => {
               eventSource: serverConfig.name + '.messages.upsert.notify',
               updateTime: formatTimestamp(msg.messageTimestamp),
             });
-            } else {
-              waEmitter.emit('message:received', {
-                id: msg.key.id,
-                externalId,
-                status: '',
-                direction: 'inbound',
-                from: remoteNo,
-                to: whatsAppNo,
-                type: 'text',
-                text: {
-                  body: text,
-                },
-                conversation: {
-                  type: isJidUser(msg.key.remoteJid) ? 'individual' : 'group',
-                  name: groupSubject,
-                },
-                customerProfile: {
-                  id: decodeJid(msg.key.participant),
-                  name: msg.pushName,
-                },
-                whatsAppNo,
-                fromMe: msg.key.fromMe,
-                eventSource: serverConfig.name + '.messages.upsert.notify',
-                createTime: formatTimestamp(msg.messageTimestamp),
-              });
-            }
           } else if (messageType === 'imageMessage') {
-            console.info('image message: ', msg)
             const imageMessage = msg.message.imageMessage;
             const fileExtension = getFileExtension(imageMessage.mimetype);
             const imageBuffer = await downloadMediaMessage(
@@ -153,14 +130,14 @@ const createWhatsApp = async phone => {
             );
             const imageFilename = './temp/image_'  + whatsAppNo + '_' + msg.key.id + fileExtension;
             await writeFile(imageFilename, imageBuffer);
-            if (msg.key.fromMe) {
+
-              waEmitter.emit('message:updated', {
+            waEmitter.emit(emitEventName, {
               id: msg.key.id,
               externalId,
               status: formatStatus(msg.status),
-                direction: 'outbound',
+              direction: msgDirection,
-                from: whatsAppNo,
+              from: msgFrom,
-                to: remoteNo,
+              to: msgTo,
               type: 'image',
               image: {
                 mimetype: imageMessage.mimetype,
@@ -183,7 +160,6 @@ const createWhatsApp = async phone => {
             });
           }
         }
-        }
       } else if (upsert.type === 'append') {
         for (const msg of upsert.messages) {
           if (msg.message?.conversation || msg.message?.extendedTextMessage?.text) {