changes

groq_voice_service.py

@@ -96,6 +96,8 @@ class GroqVoiceService:
         # Use default voice for the configured language if no voice specified
         if voice is None:
             voice = self._get_default_voice()
+        
+        logger.info(f"🔊 Generating TTS with voice: {voice}, language: {self.language}")
 
         try:
             if self.tts_provider == "edge-tts":
@@ -106,13 +108,42 @@ class GroqVoiceService:
                 async for chunk in communicate.stream():
                     if chunk["type"] == "audio":
                         audio_data += chunk["data"]
+                
+                # Validate audio data was received
+                if not audio_data:
+                    logger.warning(f"⚠️ No audio generated from TTS for voice: {voice}")
+                    # Try fallback voice
+                    fallback_voice = "en-US-AriaNeural"
+                    logger.info(f"🔄 Retrying with fallback voice: {fallback_voice}")
+                    communicate = edge_tts.Communicate(text, fallback_voice, rate=f"{int((self.voice_speed - 1) * 100):+d}%")
+                    audio_data = b""
+                    async for chunk in communicate.stream():
+                        if chunk["type"] == "audio":
+                            audio_data += chunk["data"]
+                    
+                    if not audio_data:
+                        logger.error("❌ Fallback TTS also failed")
+                        return None
+                    
                 return audio_data
             elif self.tts_provider == "murf":
                 audio_data = await self._murf_tts(text, voice)
                 return audio_data
         except Exception as e:
             logger.error(f"❌ TTS Error: {e}")
-            return None
+            # Try one last fallback with basic US English voice
+            try:
+                import edge_tts
+                logger.info("🔄 Attempting emergency fallback TTS")
+                communicate = edge_tts.Communicate(text, "en-US-AriaNeural")
+                audio_data = b""
+                async for chunk in communicate.stream():
+                    if chunk["type"] == "audio":
+                        audio_data += chunk["data"]
+                return audio_data if audio_data else None
+            except:
+                logger.error("❌ All TTS attempts failed")
+                return None
 
     async def _murf_tts(self, text: str, voice: str = None) -> Optional[bytes]:
         """