NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-14 01:41:24 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Improve update messages status

Browse Source
This commit is contained in:
Jesus 2024-10-08 12:51:10 +02:00
parent cada7be1e5
commit c6ee463dae
1 changed files with 55 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -666,7 +666,6 @@ export class BaileysStartupService extends ChannelStartupService {
instanceId: this.instanceId, instanceId: this.instanceId,
remoteJid: chat.id, remoteJid: chat.id,
name: chat.name, name: chat.name,
unreadMessages: typeof chat.unreadCount === 'number' ? chat.unreadCount : 0,
}, },
data: { remoteJid: chat.id }, data: { remoteJid: chat.id },
}); });
@ -1106,6 +1105,11 @@ export class BaileysStartupService extends ChannelStartupService {
data: messageRaw, data: messageRaw,
}); });
if (received.key.fromMe === false && msg.status === status[3]) {
// is received not read message
await this.updateChatUnreadMessages(received.key.remoteJid);
}
if (isMedia) { if (isMedia) {
if (this.configService.get<S3>('S3').ENABLE) { if (this.configService.get<S3>('S3').ENABLE) {
try { try {
@ -1237,7 +1241,7 @@ export class BaileysStartupService extends ChannelStartupService {
}, },
'messages.update': async (args: WAMessageUpdate[], settings: any) => { 'messages.update': async (args: WAMessageUpdate[], settings: any) => {
const unreadChatToUpdate: Record<string, number> = {}; // {remoteJid: readedMessages} const readChatToUpdate: Record<string, true> = {}; // remoteJid[]
for await (const { key, update } of args) { for await (const { key, update } of args) {
if (settings?.groupsIgnore && key.remoteJid?.includes('@g.us')) { if (settings?.groupsIgnore && key.remoteJid?.includes('@g.us')) {
@ -1309,13 +1313,28 @@ export class BaileysStartupService extends ChannelStartupService {
return; return;
} else if (update.status !== undefined && status[update.status] !== findMessage.status) { } else if (update.status !== undefined && status[update.status] !== findMessage.status) {
if (!unreadChatToUpdate[key.remoteJid!]) { if (!key.fromMe && key.remoteJid) {
unreadChatToUpdate[key.remoteJid!] = 0; readChatToUpdate[key.remoteJid] = true;
if (status[update.status] === status[4]) {
// Mark to read old messages
await this.prismaRepository.message.updateMany({
where: {
AND: [
{ key: { path: ['remoteJid'], equals: key.remoteJid } },
{ key: { path: ['fromMe'], equals: false } },
{ messageTimestamp: { lt: findMessage.messageTimestamp } }, // Delivered messages
{
OR: [{ status: null }, { status: status[3] }],
},
],
},
data: { status: status[4] },
});
}
} }
unreadChatToUpdate[key.remoteJid!]++; await this.prismaRepository.message.update({
this.prismaRepository.message.update({
where: { id: findMessage.id }, where: { id: findMessage.id },
data: { status: status[update.status] }, data: { status: status[update.status] },
}); });
@ -1341,16 +1360,7 @@ export class BaileysStartupService extends ChannelStartupService {
} }
} }
for await (const [remoteJid, unreadMessages] of Object.entries(unreadChatToUpdate)) { await Promise.all(Object.keys(readChatToUpdate).map((remoteJid) => this.updateChatUnreadMessages(remoteJid)));
const chat = await this.prismaRepository.chat.findFirst({ where: { remoteJid } });
if (chat) {
this.prismaRepository.chat.update({
where: { id: chat.id },
data: { unreadMessages: Math.max(0, chat.unreadMessages - unreadMessages) },
});
}
}
}, },
}; };
@ -3708,6 +3718,10 @@ export class BaileysStartupService extends ChannelStartupService {
source: getDevice(message.key.id), source: getDevice(message.key.id),
}; };
if (!messageRaw.status && message.key.fromMe === false) {
messageRaw.status = status[3]; // DELIVERED MESSAGE
}
if (messageRaw.message.extendedTextMessage) { if (messageRaw.message.extendedTextMessage) {
messageRaw.messageType = 'conversation'; messageRaw.messageType = 'conversation';
messageRaw.message.conversation = messageRaw.message.extendedTextMessage.text; messageRaw.message.conversation = messageRaw.message.extendedTextMessage.text;
@ -3735,4 +3749,28 @@ export class BaileysStartupService extends ChannelStartupService {
task.start(); task.start();
} }
} }
private async updateChatUnreadMessages(remoteJid: string): Promise<number> {
const [chat, unreadMessages] = await Promise.all([
this.prismaRepository.chat.findFirst({ where: { remoteJid } }),
this.prismaRepository.message.count({
where: {
AND: [
{ key: { path: ['remoteJid'], equals: remoteJid } },
{ key: { path: ['fromMe'], equals: false } },
{ status: { equals: status[3] } },
],
},
}),
]);
if (chat && chat.unreadMessages !== unreadMessages) {
await this.prismaRepository.chat.update({
where: { id: chat.id },
data: { unreadMessages },
});
}
return unreadMessages;
}
} }