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

Merge branch 'QnixXBLF_text_search' of https://github.com/instantsol/evolution-api into QnixXBLF

Browse Source
This commit is contained in:
Pedro Howat 2024-10-04 12:59:23 -03:00
commit 7788d740bd
2 changed files with 62 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -9,6 +9,14 @@ import { SettingsService } from '../../../services/settings.service';
const logger = new Logger('KwikController');
type SearchObject = {
text_search: string;
where: {
owner: string;
messageTimestamp: Record<string, any>; // Generic key-value pair
}[];
};
export class KwikController {
constructor(private readonly waMonitor: WAMonitoringService, private readonly settingsService: SettingsService) {}
@ -198,4 +206,39 @@ export class KwikController {
return { status: 'ok' };
}
public async textSearch({ instanceName }: InstanceDto, query: SearchObject) {
logger.error('request received in textSearch');
logger.error(instanceName);
logger.error(query);
const db = configService.get<Database>('DATABASE');
const connection = dbserver.getClient().db(db.CONNECTION.DB_PREFIX_NAME + '-whatsapp-api');
query.where.forEach((w) => {
logger.error(w.messageTimestamp);
logger.error(w.owner);
});
const messages = await connection
.collection('messages')
.find({
// $and: [
// {
// $or: query.where,
// },
// {
$text: { $search: query.text_search },
// },
// ],
})
.limit(10)
.toArray();
// const conversations = messages.map((m) => `${m.owner}#${m.key.remoteJid}#${m.messageTimestamp}`);
// logger.error('DELETEME: messages -> ');
// logger.error(conversations);
// logger.error(messages.length);
return { messages };
}
}

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

@ -72,19 +72,13 @@ export class KwikRouter extends RouterBroker {
});
this.router.post(this.routerPath('cleanChats'), ...guards, async (req, res) => {
logger.verbose('request received in cleanChats');
logger.verbose('request received in cleanChats');
logger.verbose('request body: ');
logger.verbose(req.body);
logger.verbose('request query: ');
logger.verbose(req.query);
logger.error('request received in cleanChats');
logger.error('request body: ');
logger.error(req.body);
logger.error('request query: ');
logger.error(req.query);
const response = await this.dataValidate<InstanceDto>({
request: req,
schema: null,
@ -94,6 +88,24 @@ export class KwikRouter extends RouterBroker {
return res.status(HttpStatus.OK).json(response);
});
this.router.post(this.routerPath('textSearch'), ...guards, async (req, res) => {
logger.verbose('request received in textSearch');
logger.verbose('request body: ');
logger.verbose(req.body);
logger.verbose('request query: ');
logger.verbose(req.query);
const response = await this.dataValidate<InstanceDto>({
request: req,
schema: null,
ClassRef: InstanceDto,
execute: (instance) => kwikController.textSearch(instance, req.body),
});
return res.status(HttpStatus.OK).json(response);
});
}
public readonly router = Router();