Add 8999999999999

voice_service.py

@@ -40,8 +40,10 @@ class VoiceService:
                 import edge_tts
                 self.tts_available = True
                 logger.info("✅ Edge TTS initialized")
+            elif self.tts_provider == "murf":
+                self.tts_available = True
+                logger.info("✅ Murf AI TTS initialized")
             elif self.tts_provider == "openai-tts":
-                # OpenAI TTS would require OpenAI API key
                 self.tts_available = False
                 logger.info("⚠️ OpenAI TTS not configured")
             else:
@@ -158,22 +160,55 @@ class VoiceService:
         try:
             if self.tts_provider == "edge-tts":
                 import edge_tts
-                
                 # Create TTS communication
                 communicate = edge_tts.Communicate(text, voice, rate=f"{int((self.voice_speed - 1) * 100):+d}%")
-                
-                # Generate audio
                 audio_data = b""
                 async for chunk in communicate.stream():
                     if chunk["type"] == "audio":
                         audio_data += chunk["data"]
-                
                 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
 
+    async def _murf_tts(self, text: str, voice: str = None) -> Optional[bytes]:
+        """
+        Call Murf AI TTS API to convert text to speech
+        Returns audio bytes or None
+        """
+        import aiohttp
+        import os
+        murf_api_key = os.environ.get("MURF_API_KEY", "ap2_947765d6-b958-4493-a681-d05f89a63276")
+        murf_url = "https://api.murf.ai/v1/speech/generate"
+        payload = {
+            "text": text,
+            "voice": voice or "en-US-1",  # Default Murf voice
+            "format": "mp3"
+        }
+        headers = {
+            "Authorization": f"Bearer {murf_api_key}",
+            "Content-Type": "application/json"
+        }
+        try:
+            async with aiohttp.ClientSession() as session:
+                async with session.post(murf_url, json=payload, headers=headers) as resp:
+                    if resp.status == 200:
+                        result = await resp.json()
+                        audio_url = result.get("audio_url")
+                        if audio_url:
+                            async with session.get(audio_url) as audio_resp:
+                                if audio_resp.status == 200:
+                                    return await audio_resp.read()
+                        logger.error(f"❌ Murf TTS: No audio_url in response: {result}")
+                    else:
+                        logger.error(f"❌ Murf TTS API error: {resp.status} {await resp.text()}")
+        except Exception as e:
+            logger.error(f"❌ Murf TTS Exception: {e}")
+        return None
+
     async def speech_to_text(self, audio_file_path: str, user_language: str = None) -> Optional[str]:
         """
         Convert speech audio to text