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

Refactor logical message deletion in BaileysStartupService

Browse Source
This commit is contained in:
Aditya Nandwana 2025-02-01 16:04:35 +05:30
parent db9cdbfc38
commit c1494ca035
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3551,25 +3551,31 @@ export class BaileysStartupService extends ChannelStartupService {
const messageId = response.message?.protocolMessage?.key?.id; const messageId = response.message?.protocolMessage?.key?.id;
if (messageId) { if (messageId) {
const isLogicalDeleted = configService.get<Database>('DATABASE').DELETE_DATA.LOGICAL_MESSAGE_DELETE; const isLogicalDeleted = configService.get<Database>('DATABASE').DELETE_DATA.LOGICAL_MESSAGE_DELETE;
let message = await this.prismaRepository.message.findUnique({ let message = await this.prismaRepository.message.findFirst({
where: { id: messageId }, where: {
key: {
path: ['id'],
equals: messageId,
},
},
}); });
if (isLogicalDeleted) { if (isLogicalDeleted) {
if (!message) return response; if (!message) return response;
const existingKey = typeof message?.key === 'object' && message.key !== null ? message.key : {}; const existingKey = typeof message?.key === 'object' && message.key !== null ? message.key : {};
message = await this.prismaRepository.message.update({ message = await this.prismaRepository.message.update({
where: { id: messageId }, where: { id: message.id },
data: { data: {
key: { key: {
...existingKey, ...existingKey,
deleted: true, deleted: true,
}, },
status: 'DELETED',
}, },
}); });
} else { } else {
await this.prismaRepository.message.deleteMany({ await this.prismaRepository.message.deleteMany({
where: { where: {
id: messageId, id: message.id,
}, },
}); });
} }
@ -3578,7 +3584,7 @@ export class BaileysStartupService extends ChannelStartupService {
instanceId: message.instanceId, instanceId: message.instanceId,
key: message.key, key: message.key,
messageType: message.messageType, messageType: message.messageType,
status: message.status, status: 'DELETED',
source: message.source, source: message.source,
messageTimestamp: message.messageTimestamp, messageTimestamp: message.messageTimestamp,
pushName: message.pushName, pushName: message.pushName,