Merge pull request #1 from instantsol/lucas

fix kwik service

src/api/integrations/kwik/controllers/kwik.controller.ts

@@ -23,9 +23,9 @@ export class KwikController {
       {
         $group: {
           _id: '$key.remoteJid',
-          lastAllMsgTimestamp: { $max: '$messageTimestamp' },
+          lastAllMsgTimestamp: { $max: '$messageTimestamp' }
         },
-      },
+    }
     ];
 
     if (sort === 'asc') {
@@ -43,27 +43,39 @@ export class KwikController {
     }
 
     const msgs = await messages.aggregate(pipeline).toArray();
-    const mm = await Promise.all(
+    const chat_id_list = msgs.map(m=>m._id)
-      msgs.map(async (msg) => {
+    const chat_promises = connection.collection('chats').find({ id: { $in: chat_id_list}}).toArray()
-        const chat = await connection.collection('chats').findOne({ id: msg._id });
+    const last_messages_promises = connection.collection('messages').find({
-        const lastMsg = await this.waMonitor.waInstances[instanceName].repository.message.find({
+      owner: instanceName,
-          where: {
+      messageTimestamp: { $in : msgs.map(m=>m.lastAllMsgTimestamp)},
-            owner: instanceName,
+      "key.remoteJid": { $in: chat_id_list}
-            messageTimestamp: msg.lastAllMsgTimestamp,
+    }).toArray()
-            key: {
+    const contacts_promises = connection.collection('contacts').find({
-              remoteJid: chat.id,
+      owner: instanceName,
-            },
+      id: { $in: chat_id_list},
-          },
+    }).toArray()
-          limit: 1,
+
-        });
+    const group_promises = chat_id_list.filter(g => g.includes('@g.us')).map(g=> this.waMonitor.waInstances[instanceName].findGroup({groupJid: g}, "inner"))
+
+    const [chats_solved, last_messages_solved, contacts_solved, ...groups_solved] = await Promise.all([chat_promises, last_messages_promises, contacts_promises, ...group_promises])
+
+    const chats = Object.fromEntries(chats_solved.map(m => ([m.id, m])))
+    const last_messages = Object.fromEntries(last_messages_solved.map(m => ([m.key.remoteJid, m])))
+    const contacts = Object.fromEntries(contacts_solved.map(c => ([c.id, c])))
+    const groups = Object.fromEntries(groups_solved.map(g => {if (g) return [g.id, g]}))
+
+        
+    const mm = msgs.map((msg) => {
+        const chat = chats[String(msg._id)]
+        const lastMsg = last_messages[String(msg._id)]
 
         const chat_data = {
           id: chat.id,
           labels: chat.labels,
           owner: chat.owner,
           last_message_timestamp: msg.lastAllMsgTimestamp,
-          message: this.isTextMessage(lastMsg[0]) ? lastMsg[0].message : null,
+          message: this.isTextMessage(lastMsg) ? lastMsg.message : null,
-          message_type: lastMsg[0].messageType,
+          message_type: lastMsg.messageType,
           phone_num: null,
           profile_picture: null,
           name: null,
@@ -71,27 +83,25 @@ export class KwikController {
         };
 
         const info = chat.id.split('@');
-        logger.error(info);
         if (info[1] == 'g.us') {
           chat_data.type = 'GROUP';
+          const group = groups[String(msg._id)]
+          if (group){
+            chat_data.name = group.subject;
+            chat_data.profile_picture = group.pictureUrl;
+          }
         } else {
-          const contact = await this.waMonitor.waInstances[instanceName].fetchContacts({
+          const contact = contacts[String(msg._id)]
-            where: {
-              owner: instanceName,
-              id: chat.id,
-            },
-          });
           chat_data.type = 'CONTACT';
           chat_data.phone_num = info[0];
-          if (contact && contact.length > 0) {
+          if (contact) {
-            chat_data.name = contact[0].pushName;
+            chat_data.name = contact.pushName;
-            chat_data.profile_picture = contact[0].profilePictureUrl;
+            chat_data.profile_picture = contact.profilePictureUrl;
           }
         }
 
         return chat_data;
-      }),
+      })
-    );
 
     return mm;
   }

src/api/services/channels/whatsapp.baileys.service.ts

@@ -3287,7 +3287,7 @@ export class BaileysStartupService extends ChannelStartupService {
       };
     } catch (error) {
       if (reply === 'inner') {
-        return;
+        return {};
       }
       throw new NotFoundException('Error fetching group', error.toString());
     }