filler phrase while starting tool call

Author: rootflo-hardik

wavefront/server/apps/call_processing/call_processing/constants/filler_phrases.py

@@ -0,0 +1,33 @@
+FILLER_PHRASES = {
+    'en': [
+        'Please wait a moment.',
+        'Just a second.',
+        'Give me a moment.',
+        'One moment please.',
+    ],
+    'hi': ['कृपया एक पल प्रतीक्षा करें।', 'बस एक सेकंड।', 'मुझे एक पल दें।', 'एक पल रुकिए।'],
+    'ta': [
+        'தயவுசெய்து ஒரு நிமிடம் காத்திருக்கவும்.',
+        'ஒரு நொடி.',
+        'எனக்கு ஒரு நிமிடம் கொடுங்கள்.',
+        'ஒரு நிமிடம்.',
+    ],
+    'te': [
+        'దయచేసి ఒక్క క్షణం వేచి ఉండండి.',
+        'ఒక్క నిమిషం.',
+        'నాకు ఒక్క క్షణం ఇవ్వండి.',
+        'ఒక్క క్షణం దయచేసి.',
+    ],
+    'ml': [
+        'ദയവായി ഒരു നിമിഷം കാത്തിരിക്കൂ.',
+        'ഒരു സെക്കൻഡ്.',
+        'എനിക്ക് ഒരു നിമിഷം തരൂ.',
+        'ഒരു നിമിഷം ദയവായി.',
+    ],
+    'kn': [
+        'ದಯವಿಟ್ಟು ಒಂದು ಕ್ಷಣ ಕಾಯಿರಿ.',
+        'ಒಂದು ಕ್ಷಣ.',
+        'ನನಗೆ ಒಂದು ಕ್ಷಣ ನೀಡಿ.',
+        'ಒಂದು ಕ್ಷಣ ದಯವಿಟ್ಟು.',
+    ],
+}

wavefront/server/apps/call_processing/call_processing/services/pipecat_service.py

@@ -6,6 +6,7 @@
 
 from typing import Dict, Any, List
 from copy import deepcopy
+import random
 from call_processing.log.logger import logger
 from call_processing.services.tool_wrapper_service import ToolWrapperFactory
 from call_processing.utils import get_current_ist_time_str
@@ -57,6 +58,7 @@
 from call_processing.constants.language_config import (
     LANGUAGE_INSTRUCTIONS,
 )
+from call_processing.constants.filler_phrases import FILLER_PHRASES
 
 
 class STTLanguageSwitcher(ParallelPipeline):
@@ -519,6 +521,15 @@ async def run_conversation(
         task_container['task'] = task
 
         # Register event handlers
+        @llm.event_handler('on_function_calls_started')
+        async def on_function_calls_started(service, function_calls):
+            current_lang = language_state.get('current_language', 'en')
+            phrases = FILLER_PHRASES.get(
+                current_lang, FILLER_PHRASES.get('en', ['Please wait a moment'])
+            )
+            phrase = random.choice(phrases)
+            await task.queue_frame(TTSSpeakFrame(phrase))
+
         @transport.event_handler('on_client_connected')
         async def on_client_connected(transport, client):
             logger.info(f"Client connected for agent: {agent_config['name']}")