Merge pull request #1334 from adaptwebtech/fix_and_add_name_to_find_chats_and_paginate_get_contacts_and_get_chats

Corrigindo um bug no endpoint de findChats e permitindo paginação nos endpoints de findChats e findContacts
This commit is contained in:
Davidson Gomes 2025-03-26 10:34:56 -03:00 committed by GitHub
commit b89f1144b4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 22 additions and 3 deletions

View File

@ -1223,7 +1223,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) {

View File

@ -503,9 +503,17 @@ 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) {
const validPage = Math.max(query.page as number, 1);
contactFindManyArgs.skip = query.offset * (validPage - 1);
}
return await this.prismaRepository.contact.findMany(contactFindManyArgs);
}
public cleanMessageData(message: any) {
@ -674,6 +682,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,
};
@ -700,6 +715,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
@ -730,6 +746,7 @@ export class ChannelStartupService {
ORDER BY
"Contact"."remoteJid",
"Message"."messageTimestamp" DESC
${limit}
)
SELECT * FROM rankedMessages
ORDER BY "updatedAt" DESC NULLS LAST;
@ -758,6 +775,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,