feat(Typebot): add splitMessages and timePerChar fields to Typebot models

DavidsonGomes · DavidsonGomes · commit bc451e8493a4 · 2025-06-12T13:24:25.000-03:00
- Introduced `splitMessages` and `timePerChar` fields in the Typebot and TypebotSetting models with default values.
- Created a migration script to update the database schema accordingly.
- Updated audio message handling to prepend `[audio]` to transcriptions for better clarity in message context.
diff --git a/prisma/postgresql-migrations/20250612155048_add_coluns_trypebot_tables/migration.sql b/prisma/postgresql-migrations/20250612155048_add_coluns_trypebot_tables/migration.sql
@@ -0,0 +1,7 @@
+-- AlterTable
+ALTER TABLE "Typebot" ADD COLUMN     "splitMessages" BOOLEAN DEFAULT false,
+ADD COLUMN     "timePerChar" INTEGER DEFAULT 50;
+
+-- AlterTable
+ALTER TABLE "TypebotSetting" ADD COLUMN     "splitMessages" BOOLEAN DEFAULT false,
+ADD COLUMN     "timePerChar" INTEGER DEFAULT 50;
diff --git a/prisma/postgresql-schema.prisma b/prisma/postgresql-schema.prisma
@@ -357,6 +357,8 @@ model Typebot {
   triggerType     TriggerType?
   triggerOperator TriggerOperator?
   triggerValue    String?
+  splitMessages   Boolean?         @default(false) @db.Boolean
+  timePerChar     Int?             @default(50) @db.Integer
   Instance        Instance         @relation(fields: [instanceId], references: [id], onDelete: Cascade)
   instanceId      String
   TypebotSetting  TypebotSetting[]
@@ -374,6 +376,8 @@ model TypebotSetting {
   debounceTime      Int?      @db.Integer
   typebotIdFallback String?   @db.VarChar(100)
   ignoreJids        Json?
+  splitMessages     Boolean?         @default(false) @db.Boolean
+  timePerChar       Int?             @default(50) @db.Integer
   createdAt         DateTime? @default(now()) @db.Timestamp
   updatedAt         DateTime  @updatedAt @db.Timestamp
   Fallback          Typebot?  @relation(fields: [typebotIdFallback], references: [id])
diff --git a/src/api/integrations/channel/evolution/evolution.channel.service.ts b/src/api/integrations/channel/evolution/evolution.channel.service.ts
@@ -165,7 +165,7 @@ export class EvolutionStartupService extends ChannelStartupService {
             openAiDefaultSettings.speechToText &&
             received?.message?.audioMessage
           ) {
-            messageRaw.message.speechToText = await this.openaiService.speechToText(received, this);
+            messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(received, this)}`;
           }
         }
 
diff --git a/src/api/integrations/channel/meta/whatsapp.business.service.ts b/src/api/integrations/channel/meta/whatsapp.business.service.ts
@@ -520,15 +520,15 @@ export class BusinessStartupService extends ChannelStartupService {
                   openAiDefaultSettings.speechToText
                 ) {
                   try {
-                    messageRaw.message.speechToText = await this.openaiService.speechToText(
+                    messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(
                       openAiDefaultSettings.OpenaiCreds,
                       {
                         message: {
                           mediaUrl: messageRaw.message.mediaUrl,
                           ...messageRaw,
                         },
                       },
-                    );
+                    )}`;
                   } catch (speechError) {
                     this.logger.error(`Error processing speech-to-text: ${speechError}`);
                   }
@@ -554,15 +554,15 @@ export class BusinessStartupService extends ChannelStartupService {
 
               if (openAiDefaultSettings && openAiDefaultSettings.openaiCredsId && openAiDefaultSettings.speechToText) {
                 try {
-                  messageRaw.message.speechToText = await this.openaiService.speechToText(
+                  messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(
                     openAiDefaultSettings.OpenaiCreds,
                     {
                       message: {
                         base64: messageRaw.message.base64,
                         ...messageRaw,
                       },
                     },
-                  );
+                  )}`;
                 } catch (speechError) {
                   this.logger.error(`Error processing speech-to-text: ${speechError}`);
                 }
diff --git a/src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts b/src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts
@@ -1188,7 +1188,7 @@ export class BaileysStartupService extends ChannelStartupService {
             });
 
             if (openAiDefaultSettings && openAiDefaultSettings.openaiCredsId && openAiDefaultSettings.speechToText) {
-              messageRaw.message.speechToText = await this.openaiService.speechToText(received, this);
+              messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(received, this)}`;
             }
           }
 
@@ -2111,7 +2111,7 @@ export class BaileysStartupService extends ChannelStartupService {
         });
 
         if (openAiDefaultSettings && openAiDefaultSettings.openaiCredsId && openAiDefaultSettings.speechToText) {
-          messageRaw.message.speechToText = await this.openaiService.speechToText(messageRaw, this);
+          messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(messageRaw, this)}`;
         }
       }
 
diff --git a/src/api/integrations/chatbot/base-chatbot.controller.ts b/src/api/integrations/chatbot/base-chatbot.controller.ts
@@ -280,7 +280,7 @@ export abstract class BaseChatbotController<BotType = any, BotData extends BaseC
       });
 
       if (!bot) {
-        throw new Error(`${this.integrationName} not found`);
+        return null;
       }
 
       return bot;
diff --git a/src/api/integrations/chatbot/evoai/services/evoai.service.ts b/src/api/integrations/chatbot/evoai/services/evoai.service.ts
@@ -55,7 +55,7 @@ export class EvoaiService extends BaseChatbotService<Evoai, EvoaiSetting> {
           this.logger.debug(`[EvoAI] Downloading audio for Whisper transcription`);
           const transcription = await this.openaiService.speechToText(msg, instance);
           if (transcription) {
-            processedContent = transcription;
+            processedContent = `[audio] ${transcription}`;
           }
         } catch (err) {
           this.logger.error(`[EvoAI] Failed to transcribe audio: ${err}`);
diff --git a/src/api/integrations/chatbot/evolutionBot/services/evolutionBot.service.ts b/src/api/integrations/chatbot/evolutionBot/services/evolutionBot.service.ts
@@ -64,7 +64,7 @@ export class EvolutionBotService extends BaseChatbotService<EvolutionBot, Evolut
           this.logger.debug(`[EvolutionBot] Downloading audio for Whisper transcription`);
           const transcription = await this.openaiService.speechToText(msg, instance);
           if (transcription) {
-            payload.query = transcription;
+            payload.query = `[audio] ${transcription}`;
           }
         } catch (err) {
           this.logger.error(`[EvolutionBot] Failed to transcribe audio: ${err}`);
diff --git a/src/api/integrations/chatbot/flowise/services/flowise.service.ts b/src/api/integrations/chatbot/flowise/services/flowise.service.ts
@@ -72,7 +72,7 @@ export class FlowiseService extends BaseChatbotService<FlowiseModel> {
         this.logger.debug(`[Flowise] Downloading audio for Whisper transcription`);
         const transcription = await this.openaiService.speechToText(msg, instance);
         if (transcription) {
-          payload.question = transcription;
+          payload.question = `[audio] ${transcription}`;
         }
       } catch (err) {
         this.logger.error(`[Flowise] Failed to transcribe audio: ${err}`);
diff --git a/src/api/integrations/chatbot/n8n/services/n8n.service.ts b/src/api/integrations/chatbot/n8n/services/n8n.service.ts
@@ -61,7 +61,7 @@ export class N8nService extends BaseChatbotService<N8n, N8nSetting> {
           this.logger.debug(`[N8n] Downloading audio for Whisper transcription`);
           const transcription = await this.openaiService.speechToText(msg, instance);
           if (transcription) {
-            payload.chatInput = transcription;
+            payload.chatInput = `[audio] ${transcription}`;
           }
         } catch (err) {
           this.logger.error(`[N8n] Failed to transcribe audio: ${err}`);
diff --git a/src/api/integrations/chatbot/typebot/controllers/typebot.controller.ts b/src/api/integrations/chatbot/typebot/controllers/typebot.controller.ts
@@ -90,8 +90,25 @@ export class TypebotController extends BaseChatbotController<TypebotModel, Typeb
     pushName?: string,
     msg?: any,
   ) {
-    // Use the simplified service method that follows the base class pattern
-    await this.typebotService.processTypebot(instance, remoteJid, bot, session, settings, content, pushName, msg);
+    // Map to the original processTypebot method signature
+    await this.typebotService.processTypebot(
+      instance,
+      remoteJid,
+      msg,
+      session,
+      bot,
+      bot.url,
+      settings.expire,
+      bot.typebot,
+      settings.keywordFinish,
+      settings.delayMessage,
+      settings.unknownMessage,
+      settings.listeningFromMe,
+      settings.stopBotFromMe,
+      settings.keepOpen,
+      content,
+      {}, // prefilledVariables (optional)
+    );
   }
 
   // TypeBot specific method for starting a bot from API
@@ -211,25 +228,23 @@ export class TypebotController extends BaseChatbotController<TypebotModel, Typeb
         },
       });
 
-      // Use the simplified service method instead of the complex one
-      const settings = {
+      // Use the original processTypebot method with all parameters
+      await this.typebotService.processTypebot(
+        this.waMonitor.waInstances[instanceData.name],
+        remoteJid,
+        null, // msg
+        null, // session
+        findBot,
+        url,
         expire,
+        typebot,
         keywordFinish,
         delayMessage,
         unknownMessage,
         listeningFromMe,
         stopBotFromMe,
         keepOpen,
-      };
-
-      await this.typebotService.processTypebot(
-        instanceData,
-        remoteJid,
-        findBot,
-        null, // session
-        settings,
         'init',
-        null, // pushName
         prefilledVariables,
       );
     } else {
diff --git a/src/api/integrations/chatbot/typebot/services/typebot.service.ts b/src/api/integrations/chatbot/typebot/services/typebot.service.ts

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ export class EvolutionStartupService extends ChannelStartupService {`
`165`	`165`	`openAiDefaultSettings.speechToText &&`
`166`	`166`	`received?.message?.audioMessage`
`167`	`167`	`) {`
`168`		`- messageRaw.message.speechToText = await this.openaiService.speechToText(received, this);`
	`168`	+ messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(received, this)}`;
`169`	`169`	`}`
`170`	`170`	`}`
`171`	`171`
Original file line number	Diff line number	Diff line change
`@@ -1188,7 +1188,7 @@ export class BaileysStartupService extends ChannelStartupService {`
`1188`	`1188`	`});`
`1189`	`1189`
`1190`	`1190`	`if (openAiDefaultSettings && openAiDefaultSettings.openaiCredsId && openAiDefaultSettings.speechToText) {`
`1191`		`- messageRaw.message.speechToText = await this.openaiService.speechToText(received, this);`
	`1191`	+ messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(received, this)}`;
`1192`	`1192`	`}`
`1193`	`1193`	`}`
`1194`	`1194`
`@@ -2111,7 +2111,7 @@ export class BaileysStartupService extends ChannelStartupService {`
`2111`	`2111`	`});`
`2112`	`2112`
`2113`	`2113`	`if (openAiDefaultSettings && openAiDefaultSettings.openaiCredsId && openAiDefaultSettings.speechToText) {`
`2114`		`- messageRaw.message.speechToText = await this.openaiService.speechToText(messageRaw, this);`
	`2114`	+ messageRaw.message.speechToText = `[audio] ${await this.openaiService.speechToText(messageRaw, this)}`;
`2115`	`2115`	`}`
`2116`	`2116`	`}`
`2117`	`2117`
Original file line number	Diff line number	Diff line change
`@@ -280,7 +280,7 @@ export abstract class BaseChatbotController<BotType = any, BotData extends BaseC`
`280`	`280`	`});`
`281`	`281`
`282`	`282`	`if (!bot) {`
`283`		- throw new Error(`${this.integrationName} not found`);
	`283`	`+ return null;`
`284`	`284`	`}`
`285`	`285`
`286`	`286`	`return bot;`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ export class EvoaiService extends BaseChatbotService<Evoai, EvoaiSetting> {`
`55`	`55`	this.logger.debug(`[EvoAI] Downloading audio for Whisper transcription`);
`56`	`56`	`const transcription = await this.openaiService.speechToText(msg, instance);`
`57`	`57`	`if (transcription) {`
`58`		`- processedContent = transcription;`
	`58`	+ processedContent = `[audio] ${transcription}`;
`59`	`59`	`}`
`60`	`60`	`} catch (err) {`
`61`	`61`	this.logger.error(`[EvoAI] Failed to transcribe audio: ${err}`);
Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ export class EvolutionBotService extends BaseChatbotService<EvolutionBot, Evolut`
`64`	`64`	this.logger.debug(`[EvolutionBot] Downloading audio for Whisper transcription`);
`65`	`65`	`const transcription = await this.openaiService.speechToText(msg, instance);`
`66`	`66`	`if (transcription) {`
`67`		`- payload.query = transcription;`
	`67`	+ payload.query = `[audio] ${transcription}`;
`68`	`68`	`}`
`69`	`69`	`} catch (err) {`
`70`	`70`	this.logger.error(`[EvolutionBot] Failed to transcribe audio: ${err}`);
Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ export class FlowiseService extends BaseChatbotService<FlowiseModel> {`
`72`	`72`	this.logger.debug(`[Flowise] Downloading audio for Whisper transcription`);
`73`	`73`	`const transcription = await this.openaiService.speechToText(msg, instance);`
`74`	`74`	`if (transcription) {`
`75`		`- payload.question = transcription;`
	`75`	+ payload.question = `[audio] ${transcription}`;
`76`	`76`	`}`
`77`	`77`	`} catch (err) {`
`78`	`78`	this.logger.error(`[Flowise] Failed to transcribe audio: ${err}`);
Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ export class N8nService extends BaseChatbotService<N8n, N8nSetting> {`
`61`	`61`	this.logger.debug(`[N8n] Downloading audio for Whisper transcription`);
`62`	`62`	`const transcription = await this.openaiService.speechToText(msg, instance);`
`63`	`63`	`if (transcription) {`
`64`		`- payload.chatInput = transcription;`
	`64`	+ payload.chatInput = `[audio] ${transcription}`;
`65`	`65`	`}`
`66`	`66`	`} catch (err) {`
`67`	`67`	this.logger.error(`[N8n] Failed to transcribe audio: ${err}`);