Update utils.py

utils.py

@@ -8,15 +8,44 @@ def clean_history(chat_history):
     return [msg for msg in chat_history if isinstance(msg.get("content"), str)]
 
 def save_image(image: Image.Image) -> str:
-    filename = f"output_{uuid.uuid4()}.png"
-    image.save(filename)
-    return filename
+    try:
+        filename = f"output_{uuid.uuid4()}.png"
+        image.save(filename)
+        return filename
+    except Exception as e:
+        print(f"Error saving image: {str(e)}")
+        return None
 
 async def text_to_speech(text: str, voice: str):
-    output_file = f"speech_{uuid.uuid4()}.mp3"
-    communicate = edge_tts.Communicate(text, voice)
-    await communicate.save(output_file)
-    return output_file
+    try:
+        output_file = f"speech_{uuid.uuid4()}.mp3"
+        # Add rate and volume parameters
+        communicate = edge_tts.Communicate(
+            text=text,
+            voice=voice,
+            rate="+0%",  # Normal speed
+            volume="+0%"  # Normal volume
+        )
+        await communicate.save(output_file)
+        return output_file
+    except ValueError as ve:
+        print(f"Voice error: {str(ve)}")
+        # Fallback to default voice if specified voice fails
+        try:
+            communicate = edge_tts.Communicate(
+                text=text,
+                voice="en-US-JennyNeural",  # Fallback voice
+                rate="+0%",
+                volume="+0%"
+            )
+            await communicate.save(output_file)
+            return output_file
+        except Exception as e:
+            print(f"Fallback voice error: {str(e)}")
+            return None
+    except Exception as e:
+        print(f"TTS error: {str(e)}")
+        return None
 
 def web_search(query: str) -> str:
     try: