diff --git a/src/whatsapp/controllers/instance.controller.ts b/src/whatsapp/controllers/instance.controller.ts index 2a904761..8d0e21ca 100644 --- a/src/whatsapp/controllers/instance.controller.ts +++ b/src/whatsapp/controllers/instance.controller.ts @@ -67,6 +67,7 @@ export class InstanceController { typebot_keyword_finish, typebot_delay_message, typebot_unknown_message, + typebot_listening_from_me, }: InstanceDto) { try { this.logger.verbose('requested createInstance from ' + instanceName + ' instance'); @@ -126,6 +127,9 @@ export class InstanceController { 'CONNECTION_UPDATE', 'CALL', 'NEW_JWT_TOKEN', + 'TYPEBOT_START', + 'TYPEBOT_CHANGE_STATUS', + 'CHAMA_AI_ACTION', ]; } else { newEvents = events; @@ -172,9 +176,12 @@ export class InstanceController { 'CONNECTION_UPDATE', 'CALL', 'NEW_JWT_TOKEN', + 'TYPEBOT_START', + 'TYPEBOT_CHANGE_STATUS', + 'CHAMA_AI_ACTION', ]; } else { - newEvents = events; + newEvents = websocket_events; } this.websocketService.create(instance, { enabled: true, @@ -216,9 +223,12 @@ export class InstanceController { 'CONNECTION_UPDATE', 'CALL', 'NEW_JWT_TOKEN', + 'TYPEBOT_START', + 'TYPEBOT_CHANGE_STATUS', + 'CHAMA_AI_ACTION', ]; } else { - newEvents = events; + newEvents = rabbitmq_events; } this.rabbitmqService.create(instance, { enabled: true, @@ -247,6 +257,7 @@ export class InstanceController { keyword_finish: typebot_keyword_finish, delay_message: typebot_delay_message, unknown_message: typebot_unknown_message, + listening_from_me: typebot_listening_from_me, }); } catch (error) { this.logger.log(error); @@ -304,6 +315,7 @@ export class InstanceController { keyword_finish: typebot_keyword_finish, delay_message: typebot_delay_message, unknown_message: typebot_unknown_message, + listening_from_me: typebot_listening_from_me, }, settings, qrcode: getQrcode, @@ -396,6 +408,7 @@ export class InstanceController { keyword_finish: typebot_keyword_finish, delay_message: typebot_delay_message, unknown_message: typebot_unknown_message, + listening_from_me: typebot_listening_from_me, }, settings, chatwoot: { @@ -482,12 +495,13 @@ export class InstanceController { } public async fetchInstances({ instanceName }: InstanceDto) { - this.logger.verbose('requested fetchInstances from ' + instanceName + ' instance'); if (instanceName) { + this.logger.verbose('requested fetchInstances from ' + instanceName + ' instance'); this.logger.verbose('instanceName: ' + instanceName); return this.waMonitor.instanceInfo(instanceName); } + this.logger.verbose('requested fetchInstances (all instances)'); return this.waMonitor.instanceInfo(); }