NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-22 03:56:54 -06:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix_and_add_name_to_find_chats_and_paginate_get_contacts_and_get_chats

Browse Source
This commit is contained in:
pedro-php 2025-03-25 10:52:19 -03:00
parent 787d90ff20
commit b760d98e13
2 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts
View File

@ -1186,7 +1186,8 @@ export class BaileysStartupService extends ChannelStartupService {
existingChat && existingChat &&
received.pushName && received.pushName &&
existingChat.name !== 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 }]); this.sendDataWebhook(Events.CHATS_UPSERT, [{ ...existingChat, name: received.pushName }]);
if (this.configService.get<Database>('DATABASE').SAVE_DATA.CHATS) { if (this.configService.get<Database>('DATABASE').SAVE_DATA.CHATS) {

12
src/api/services/channel.service.ts
View File

@ -503,7 +503,7 @@ export class ChannelStartupService {
where['remoteJid'] = remoteJid; where['remoteJid'] = remoteJid;
} }
return await this.prismaRepository.contact.findMany({ const contactFindManyArgs: Prisma.ContactFindManyArgs = {
where, where,
}; };
@ -682,6 +682,13 @@ export class ChannelStartupService {
: createJid(query.where?.remoteJid) : createJid(query.where?.remoteJid)
: null; : 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 = { const where = {
instanceId: this.instanceId, instanceId: this.instanceId,
}; };
@ -708,6 +715,7 @@ export class ChannelStartupService {
to_timestamp("Message"."messageTimestamp"::double precision), to_timestamp("Message"."messageTimestamp"::double precision),
"Contact"."updatedAt" "Contact"."updatedAt"
) as "updatedAt", ) as "updatedAt",
"Chat"."name" as "chatName",
"Chat"."createdAt" as "windowStart", "Chat"."createdAt" as "windowStart",
"Chat"."createdAt" + INTERVAL '24 hours' as "windowExpires", "Chat"."createdAt" + INTERVAL '24 hours' as "windowExpires",
CASE CASE
@ -738,6 +746,7 @@ export class ChannelStartupService {
ORDER BY ORDER BY
"Contact"."remoteJid", "Contact"."remoteJid",
"Message"."messageTimestamp" DESC "Message"."messageTimestamp" DESC
${limit}
) )
SELECT * FROM rankedMessages SELECT * FROM rankedMessages
ORDER BY "updatedAt" DESC NULLS LAST; ORDER BY "updatedAt" DESC NULLS LAST;
@ -766,6 +775,7 @@ export class ChannelStartupService {
id: contact.id, id: contact.id,
remoteJid: contact.remoteJid, remoteJid: contact.remoteJid,
pushName: contact.pushName, pushName: contact.pushName,
chatName: contact.chatName,
profilePicUrl: contact.profilePicUrl, profilePicUrl: contact.profilePicUrl,
updatedAt: contact.updatedAt, updatedAt: contact.updatedAt,
windowStart: contact.windowStart, windowStart: contact.windowStart,