fix: integrate Typebot status change events for webhook in chatbot controller and service

Author: Josias Maceda

src/api/integrations/chatbot/base-chatbot.controller.ts

@@ -9,6 +9,7 @@ import { getConversationMessage } from '@utils/getConversationMessage';
 
 import { BaseChatbotDto } from './base-chatbot.dto';
 import { ChatbotController, ChatbotControllerInterface, EmitData } from './chatbot.controller';
+import { Events } from '@api/types/wa.types';
 
 // Common settings interface for all chatbot integrations
 export interface ChatbotSettings {
@@ -58,7 +59,7 @@ export abstract class BaseChatbotController<BotType = any, BotData extends BaseC
   settingsRepository: any;
   sessionRepository: any;
   userMessageDebounce: { [key: string]: { message: string; timeoutId: NodeJS.Timeout } } = {};
-
+  
   // Name of the integration, to be set by the derived class
   protected abstract readonly integrationName: string;
 
@@ -445,7 +446,17 @@ export abstract class BaseChatbotController<BotType = any, BotData extends BaseC
       });
 
       const remoteJid = data.remoteJid;
-      const status = data.status;
+      const status = data.status;      
+      const session = await this.getSession(remoteJid, instance);
+
+      if (this.integrationName === 'Typebot') {
+        const typebotData = {
+          remoteJid: remoteJid,
+          status: status,
+          session
+        };
+        this.waMonitor.waInstances[instance.instanceName].sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);
+      }
 
       if (status === 'delete') {
         await this.sessionRepository.deleteMany({
@@ -496,7 +507,7 @@ export abstract class BaseChatbotController<BotType = any, BotData extends BaseC
           status: status,
           session,
         };
-
+        
         return { bot: { ...instance, bot: botData } };
       }
     } catch (error) {
@@ -867,6 +878,16 @@ export abstract class BaseChatbotController<BotType = any, BotData extends BaseC
             status: 'paused',
           },
         });
+
+        if (this.integrationName === 'Typebot') {
+          const typebotData = {
+            remoteJid: remoteJid,
+            status: 'paused',
+            session,
+          };
+          this.waMonitor.waInstances[instance.instanceName].sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);
+        }
+        
         return;
       }
 

src/api/integrations/chatbot/typebot/services/typebot.service.ts

@@ -8,18 +8,19 @@ import axios from 'axios';
 
 import { BaseChatbotService } from '../../base-chatbot.service';
 import { OpenaiService } from '../../openai/services/openai.service';
+import { Events } from '@api/types/wa.types';
 
 export class TypebotService extends BaseChatbotService<TypebotModel, any> {
-  private openaiService: OpenaiService;
-
+  private openaiService: OpenaiService;  
+  
   constructor(
     waMonitor: WAMonitoringService,
     configService: ConfigService,
     prismaRepository: PrismaRepository,
     openaiService: OpenaiService,
   ) {
     super(waMonitor, prismaRepository, 'TypebotService', configService);
-    this.openaiService = openaiService;
+    this.openaiService = openaiService;      
   }
 
   /**
@@ -151,6 +152,14 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
           },
         });
       }
+
+      const typebotData = {
+          remoteJid: data.remoteJid,
+          status: 'opened',
+          session,
+      };
+      this.waMonitor.waInstances[instance.name].sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);        
+
       return { ...request.data, session };
     } catch (error) {
       this.logger.error(error);
@@ -399,12 +408,14 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
         },
       });
     } else {
+      let statusChange = 'closed';
       if (!settings?.keepOpen) {
         await prismaRepository.integrationSession.deleteMany({
           where: {
             id: session.id,
           },
         });
+        statusChange = 'delete';
       } else {
         await prismaRepository.integrationSession.update({
           where: {
@@ -415,6 +426,14 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
           },
         });
       }
+
+      const typebotData = {
+        remoteJid: session.remoteJid,
+        status: statusChange,
+        session,
+      };
+      instance.sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);
+      
     }
   }
 
@@ -639,6 +658,7 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
           }
 
           if (keywordFinish && content.toLowerCase() === keywordFinish.toLowerCase()) {
+            let statusChange = 'closed';
             if (keepOpen) {
               await this.prismaRepository.integrationSession.update({
                 where: {
@@ -649,13 +669,22 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
                 },
               });
             } else {
+              statusChange = 'delete';
               await this.prismaRepository.integrationSession.deleteMany({
                 where: {
                   botId: findTypebot.id,
                   remoteJid: remoteJid,
                 },
               });
             }
+             
+            const typebotData = {
+              remoteJid: remoteJid,
+              status: statusChange,
+              session,
+            };
+            waInstance.sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);            
+
             return;
           }
 
@@ -788,6 +817,7 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
         }
 
         if (keywordFinish && content.toLowerCase() === keywordFinish.toLowerCase()) {
+          let statusChange = 'closed';
           if (keepOpen) {
             await this.prismaRepository.integrationSession.update({
               where: {
@@ -798,13 +828,21 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
               },
             });
           } else {
+            statusChange = 'delete';
             await this.prismaRepository.integrationSession.deleteMany({
               where: {
                 botId: findTypebot.id,
                 remoteJid: remoteJid,
               },
             });
           }
+          
+          const typebotData = {
+              remoteJid: remoteJid,
+              status: statusChange,
+              session,
+            };
+          waInstance.sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);          
 
           return;
         }
@@ -881,6 +919,7 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
     }
 
     if (keywordFinish && content.toLowerCase() === keywordFinish.toLowerCase()) {
+      let statusChange = 'closed';
       if (keepOpen) {
         await this.prismaRepository.integrationSession.update({
           where: {
@@ -891,13 +930,23 @@ export class TypebotService extends BaseChatbotService<TypebotModel, any> {
           },
         });
       } else {
+        statusChange = 'delete';
         await this.prismaRepository.integrationSession.deleteMany({
           where: {
             botId: findTypebot.id,
             remoteJid: remoteJid,
           },
         });
       }
+
+      const typebotData = {
+        remoteJid: remoteJid,
+        status: statusChange,
+        session,
+      };
+
+      waInstance.sendDataWebhook(Events.TYPEBOT_CHANGE_STATUS, typebotData);      
+
       return;
     }