Update instance.controller.ts

This commit is contained in:
Francis Breit 2023-09-20 01:43:09 -03:00 committed by GitHub
parent ce41131424
commit 86fec6fb24
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

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