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

adds filtering of old messages in fetchChats endpoint

Browse Source
This commit is contained in:
Pedro Howat 2024-08-27 11:47:05 -03:00
parent a26e062936
commit 58ef0cb3ac
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/api/integrations/kwik/controllers/kwik.controller.ts
View File

@ -14,7 +14,13 @@ export class KwikController {
private isTextMessage(messageType: any) { private isTextMessage(messageType: any) {
return ['senderKeyDistributionMessage', 'conversation', 'extendedTextMessage'].includes(messageType); return ['senderKeyDistributionMessage', 'conversation', 'extendedTextMessage'].includes(messageType);
} }
public async fetchChats({ instanceName }: InstanceDto, limit: number, skip: number, sort: any) { public async fetchChats(
{ instanceName }: InstanceDto,
limit: number,
skip: number,
sort: any,
messageTimestamp: number,
) {
const db = configService.get<Database>('DATABASE'); const db = configService.get<Database>('DATABASE');
const connection = dbserver.getClient().db(db.CONNECTION.DB_PREFIX_NAME + '-whatsapp-api'); const connection = dbserver.getClient().db(db.CONNECTION.DB_PREFIX_NAME + '-whatsapp-api');
const messages = connection.collection('messages'); const messages = connection.collection('messages');
@ -30,7 +36,7 @@ export class KwikController {
fromMe: { $first: '$key.fromMe' }, fromMe: { $first: '$key.fromMe' },
}, },
}, },
{ $match: { owner: instanceName } }, { $match: { owner: instanceName, lastAllMsgTimestamp: { $gte: messageTimestamp } } },
{ $sort: { lastAllMsgTimestamp: -1 } }, { $sort: { lastAllMsgTimestamp: -1 } },
]; ];
@ -120,7 +126,6 @@ export class KwikController {
const messageUpdate = connection.collection('messageUpdate'); const messageUpdate = connection.collection('messageUpdate');
const chats = connection.collection('chats'); const chats = connection.collection('chats');
const contacts = connection.collection('contacts'); const contacts = connection.collection('contacts');
logger.error('DELETEME: Deleting messages for instance ' + instanceName);
const x = messages.deleteMany({ owner: instanceName }); const x = messages.deleteMany({ owner: instanceName });
logger.error(x); logger.error(x);
const y = chats.deleteMany({ owner: instanceName }); const y = chats.deleteMany({ owner: instanceName });

8
src/api/integrations/kwik/routes/kwik.router.ts
View File

@ -24,7 +24,13 @@ export class KwikRouter extends RouterBroker {
schema: null, schema: null,
ClassRef: InstanceDto, ClassRef: InstanceDto,
execute: (instance) => execute: (instance) =>
kwikController.fetchChats(instance, Number(req.query.limit), Number(req.query.skip), req.query.sort), kwikController.fetchChats(
instance,
Number(req.query.limit),
Number(req.query.skip),
req.query.sort,
Number(req.query.messageTimestamp),
),
}); });
return res.status(HttpStatus.OK).json(response); return res.status(HttpStatus.OK).json(response);