From 1da43d373a36b6f33e25d6bc9465c03236afde40 Mon Sep 17 00:00:00 2001 From: Lucas Batista Date: Mon, 9 Sep 2024 17:20:03 -0300 Subject: [PATCH] fixing contacts update engine --- src/api/integrations/kwik/controllers/kwik.controller.ts | 3 ++- src/api/repository/contact.repository.ts | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/api/integrations/kwik/controllers/kwik.controller.ts b/src/api/integrations/kwik/controllers/kwik.controller.ts index c646e10d..bdce2426 100644 --- a/src/api/integrations/kwik/controllers/kwik.controller.ts +++ b/src/api/integrations/kwik/controllers/kwik.controller.ts @@ -26,6 +26,7 @@ export class KwikController { const messages = connection.collection('messages'); const pipeline: Document[] = [ { $sort: { 'key.remoteJid': -1, messageTimestamp: -1 } }, + { $match: { owner: instanceName }}, { $group: { _id: '$key.remoteJid', @@ -36,7 +37,7 @@ export class KwikController { fromMe: { $first: '$key.fromMe' }, }, }, - { $match: { owner: instanceName, lastAllMsgTimestamp: { $gte: messageTimestamp } } }, + { $match: { lastAllMsgTimestamp: { $gte: messageTimestamp } } }, { $sort: { lastAllMsgTimestamp: -1 } }, ]; diff --git a/src/api/repository/contact.repository.ts b/src/api/repository/contact.repository.ts index d26ada35..826328c5 100644 --- a/src/api/repository/contact.repository.ts +++ b/src/api/repository/contact.repository.ts @@ -86,7 +86,7 @@ export class ContactRepository extends Repository { const contacts = data.map((contact) => { return { updateOne: { - filter: { id: contact.id }, + filter: { id: contact.id, owner: instanceName }, update: { ...contact }, upsert: true, },