NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-09-07 14:49:31 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge websocket new events to the defaults

Browse Source
This commit is contained in:
Stênio Aníbal 2024-08-20 11:26:05 -03:00
parent cb36f04534
commit 82634c0cb2
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/api/integrations/websocket/controllers/websocket.controller.ts
View File

@ -14,7 +14,6 @@ export class WebsocketController {
private waMonitor: WAMonitoringService; private waMonitor: WAMonitoringService;
private corsConfig: Array<any>; private corsConfig: Array<any>;
private readonly logger = new Logger('SocketStartupService'); private readonly logger = new Logger('SocketStartupService');
public readonly monitorEvents = ['REMOVE_INSTANCE', 'LOGOUT_INSTANCE'];
public readonly events = [ public readonly events = [
'APPLICATION_STARTUP', 'APPLICATION_STARTUP',
'QRCODE_UPDATED', 'QRCODE_UPDATED',
@ -41,6 +40,8 @@ export class WebsocketController {
'CALL', 'CALL',
'TYPEBOT_START', 'TYPEBOT_START',
'TYPEBOT_CHANGE_STATUS', 'TYPEBOT_CHANGE_STATUS',
'REMOVE_INSTANCE',
'LOGOUT_INSTANCE',
]; ];
constructor(prismaRepository: PrismaRepository, waMonitor: WAMonitoringService) { constructor(prismaRepository: PrismaRepository, waMonitor: WAMonitoringService) {
@ -195,10 +196,7 @@ export class WebsocketController {
return; return;
} }
if ( if (Array.isArray(instanceSocket.events) && instanceSocket.events.includes(configEv)) {
this.monitorEvents.includes(configEv) ||
(Array.isArray(instanceSocket.events) && instanceSocket.events.includes(configEv))
) {
this.socket.of(`/${instanceName}`).emit(event, message); this.socket.of(`/${instanceName}`).emit(event, message);
if (logEnabled) { if (logEnabled) {