fixing contacts update engine

This commit is contained in:
Lucas Batista 2024-09-09 17:20:03 -03:00
parent a58ee7eede
commit 1da43d373a
2 changed files with 3 additions and 2 deletions

View File

@ -26,6 +26,7 @@ export class KwikController {
const messages = connection.collection('messages'); const messages = connection.collection('messages');
const pipeline: Document[] = [ const pipeline: Document[] = [
{ $sort: { 'key.remoteJid': -1, messageTimestamp: -1 } }, { $sort: { 'key.remoteJid': -1, messageTimestamp: -1 } },
{ $match: { owner: instanceName }},
{ {
$group: { $group: {
_id: '$key.remoteJid', _id: '$key.remoteJid',
@ -36,7 +37,7 @@ export class KwikController {
fromMe: { $first: '$key.fromMe' }, fromMe: { $first: '$key.fromMe' },
}, },
}, },
{ $match: { owner: instanceName, lastAllMsgTimestamp: { $gte: messageTimestamp } } }, { $match: { lastAllMsgTimestamp: { $gte: messageTimestamp } } },
{ $sort: { lastAllMsgTimestamp: -1 } }, { $sort: { lastAllMsgTimestamp: -1 } },
]; ];

View File

@ -86,7 +86,7 @@ export class ContactRepository extends Repository {
const contacts = data.map((contact) => { const contacts = data.map((contact) => {
return { return {
updateOne: { updateOne: {
filter: { id: contact.id }, filter: { id: contact.id, owner: instanceName },
update: { ...contact }, update: { ...contact },
upsert: true, upsert: true,
}, },