NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-12-10 18:39:38 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #2250 from gabrielmouallem/fix/respect-database-save-data-contacts

Browse Source 
fix: respect DATABASE_SAVE_DATA_CONTACTS in contact updates
This commit is contained in:
Davidson Gomes 2025-12-05 11:01:46 -03:00 committed by GitHub
commit b55c9fcab7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 28 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -406,7 +406,7 @@ export class BaileysStartupService extends ChannelStartupService {
qrcodeTerminal.generate(qr, { small: true }, (qrcode) => qrcodeTerminal.generate(qr, { small: true }, (qrcode) =>
this.logger.log( this.logger.log(
`\n{ instance: ${this.instance.name} pairingCode: ${this.instance.qrcode.pairingCode}, qrcodeCount: ${this.instance.qrcode.count} }\n` + `\n{ instance: ${this.instance.name} pairingCode: ${this.instance.qrcode.pairingCode}, qrcodeCount: ${this.instance.qrcode.count} }\n` +
qrcode, qrcode,
), ),
); );
@ -861,10 +861,13 @@ export class BaileysStartupService extends ChannelStartupService {
this.sendDataWebhook(Events.CONTACTS_UPDATE, updatedContacts); this.sendDataWebhook(Events.CONTACTS_UPDATE, updatedContacts);
await Promise.all( await Promise.all(
updatedContacts.map(async (contact) => { updatedContacts.map(async (contact) => {
const update = this.prismaRepository.contact.updateMany({ if (this.configService.get<Database>('DATABASE').SAVE_DATA.CONTACTS) {
where: { remoteJid: contact.remoteJid, instanceId: this.instanceId }, await this.prismaRepository.contact.updateMany({
data: { profilePicUrl: contact.profilePicUrl }, where: { remoteJid: contact.remoteJid, instanceId: this.instanceId },
}); data: { profilePicUrl: contact.profilePicUrl },
});
}
if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED && this.localChatwoot?.enabled) { if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED && this.localChatwoot?.enabled) {
const instance = { instanceName: this.instance.name, instanceId: this.instance.id }; const instance = { instanceName: this.instance.name, instanceId: this.instance.id };
@ -883,8 +886,6 @@ export class BaileysStartupService extends ChannelStartupService {
avatar_url: contact.profilePicUrl, avatar_url: contact.profilePicUrl,
}); });
} }
return update;
}), }),
); );
} }
@ -908,14 +909,17 @@ export class BaileysStartupService extends ChannelStartupService {
this.sendDataWebhook(Events.CONTACTS_UPDATE, contactsRaw); this.sendDataWebhook(Events.CONTACTS_UPDATE, contactsRaw);
const updateTransactions = contactsRaw.map((contact) => if (this.configService.get<Database>('DATABASE').SAVE_DATA.CONTACTS) {
this.prismaRepository.contact.upsert({ const updateTransactions = contactsRaw.map((contact) =>
where: { remoteJid_instanceId: { remoteJid: contact.remoteJid, instanceId: contact.instanceId } }, this.prismaRepository.contact.upsert({
create: contact, where: { remoteJid_instanceId: { remoteJid: contact.remoteJid, instanceId: contact.instanceId } },
update: contact, create: contact,
}), update: contact,
); }),
await this.prismaRepository.$transaction(updateTransactions); );
await this.prismaRepository.$transaction(updateTransactions);
}
//const usersContacts = contactsRaw.filter((c) => c.remoteJid.includes('@s.whatsapp')); //const usersContacts = contactsRaw.filter((c) => c.remoteJid.includes('@s.whatsapp'));
}, },
@ -997,16 +1001,16 @@ export class BaileysStartupService extends ChannelStartupService {
const messagesRepository: Set<string> = new Set( const messagesRepository: Set<string> = new Set(
chatwootImport.getRepositoryMessagesCache(instance) ?? chatwootImport.getRepositoryMessagesCache(instance) ??
( (
await this.prismaRepository.message.findMany({ await this.prismaRepository.message.findMany({
select: { key: true }, select: { key: true },
where: { instanceId: this.instanceId }, where: { instanceId: this.instanceId },
}) })
).map((message) => { ).map((message) => {
const key = message.key as { id: string }; const key = message.key as { id: string };
return key.id; return key.id;
}), }),
); );
if (chatwootImport.getRepositoryMessagesCache(instance) === null) { if (chatwootImport.getRepositoryMessagesCache(instance) === null) {