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

fix baileys contact update and insert

Browse Source
This commit is contained in:
Lucas Batista 2024-10-16 11:24:16 -03:00
parent 2c76098d59
commit 98efc10b11
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/api/services/channels/whatsapp.baileys.service.ts
View File

@ -867,7 +867,6 @@ export class BaileysStartupService extends ChannelStartupService {
'contacts.update': async (contacts: Partial<Contact>[], database: Database) => { 'contacts.update': async (contacts: Partial<Contact>[], database: Database) => {
this.logger.verbose('Event received: contacts.update'); this.logger.verbose('Event received: contacts.update');
this.logger.verbose('Verifying if contacts exists in database to update'); this.logger.verbose('Verifying if contacts exists in database to update');
const contactsRaw: ContactRaw[] = []; const contactsRaw: ContactRaw[] = [];
for await (const contact of contacts) { for await (const contact of contacts) {
@ -882,8 +881,9 @@ export class BaileysStartupService extends ChannelStartupService {
this.logger.verbose('Sending data to webhook in event CONTACTS_UPDATE'); this.logger.verbose('Sending data to webhook in event CONTACTS_UPDATE');
this.sendDataWebhook(Events.CONTACTS_UPDATE, contactsRaw); this.sendDataWebhook(Events.CONTACTS_UPDATE, contactsRaw);
//REMOVING DUE TO CREATING NULL CONTACTS ( ADDING FILTER )
this.logger.verbose('Updating contacts in database'); this.logger.verbose('Updating contacts in database');
this.repository.contact.update(contactsRaw, this.instance.name, database.SAVE_DATA.CONTACTS); this.repository.contact.update(contactsRaw.filter(contact => contact.pushName), this.instance.name, database.SAVE_DATA.CONTACTS);
}, },
}; };
@ -1255,10 +1255,10 @@ export class BaileysStartupService extends ChannelStartupService {
this.logger.verbose('Inserting contact in database'); this.logger.verbose('Inserting contact in database');
if (received?.key?.fromMe === true) { if (received?.key?.fromMe === true)
contactRaw.pushName = null; contactRaw.pushName = null;
} if (contactRaw.pushName)
this.repository.contact.insert([contactRaw], this.instance.name, database.SAVE_DATA.CONTACTS); this.repository.contact.insert([contactRaw], this.instance.name, database.SAVE_DATA.CONTACTS);
} }
} catch (error) { } catch (error) {
this.logger.error(error); this.logger.error(error);