fix_and_add_name_to_find_chats_and_paginate_get_contacts_and_get_chats

Author: matheusmartinsInsper

src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts

@@ -998,7 +998,8 @@ export class BaileysStartupService extends ChannelStartupService {
             existingChat &&
             received.pushName &&
             existingChat.name !== received.pushName &&
-            received.pushName.trim().length > 0
+            received.pushName.trim().length > 0 &&
+            !received.key.remoteJid.includes('@g.us')
           ) {
             this.sendDataWebhook(Events.CHATS_UPSERT, [{ ...existingChat, name: received.pushName }]);
             if (this.configService.get<Database>('DATABASE').SAVE_DATA.CHATS) {
@@ -2371,7 +2372,7 @@ export class BaileysStartupService extends ChannelStartupService {
     const lowerCaseImage = image.toLowerCase();
 
     if (lowerCaseImage.includes('.gif')) return true;
-     
+
     if (lowerCaseImage.includes('.webp')) return this.isAnimatedWebp(buffer);
     return false;
   }

src/api/services/channel.service.ts

@@ -330,9 +330,14 @@ export class ChannelStartupService {
       where['remoteJid'] = remoteJid;
     }
 
-    return await this.prismaRepository.contact.findMany({
+    const contactFindManyArgs: Prisma.ContactFindManyArgs = {
       where,
-    });
+    };
+
+    if (query.offset) contactFindManyArgs.take = query.offset;
+    if (query.page) contactFindManyArgs.skip = query.offset * ((query.page as number) - 1);
+
+    return await this.prismaRepository.contact.findMany(contactFindManyArgs);
   }
 
   public cleanMessageData(message: any) {
@@ -501,6 +506,13 @@ export class ChannelStartupService {
         : createJid(query.where?.remoteJid)
       : null;
 
+    const limit =
+      query.offset && !query.page
+        ? Prisma.sql` LIMIT ${query.offset}`
+        : query.offset && query.page
+          ? Prisma.sql`  LIMIT ${query.offset} OFFSET ${((query.page as number) - 1) * query.offset}`
+          : Prisma.sql``;
+
     const where = {
       instanceId: this.instanceId,
     };
@@ -527,6 +539,7 @@ export class ChannelStartupService {
               to_timestamp("Message"."messageTimestamp"::double precision), 
               "Contact"."updatedAt"
             ) as "updatedAt",
+            "Chat"."name" as "chatName",
             "Chat"."createdAt" as "windowStart",
             "Chat"."createdAt" + INTERVAL '24 hours' as "windowExpires",
             CASE 
@@ -557,6 +570,7 @@ export class ChannelStartupService {
           ORDER BY 
             "Contact"."remoteJid",
             "Message"."messageTimestamp" DESC
+            ${limit}
         )
         SELECT * FROM rankedMessages
         ORDER BY "updatedAt" DESC NULLS LAST;
@@ -585,6 +599,7 @@ export class ChannelStartupService {
           id: contact.id,
           remoteJid: contact.remoteJid,
           pushName: contact.pushName,
+          chatName: contact.chatName,
           profilePicUrl: contact.profilePicUrl,
           updatedAt: contact.updatedAt,
           windowStart: contact.windowStart,