Update app.py

app.py

@@ -357,6 +357,7 @@ def clean_for_speech(text: str) -> str:
     text = re.sub(r"\s+", " ", text).strip()
     return text
 
+
 async def edge_tts_generate_audio(text, voice="en-US-AriaNeural", rate=0, pitch=0, file_format="mp3"):
     """Async TTS generation with edge-tts library."""
     text = clean_for_speech(text)
@@ -364,15 +365,43 @@ async def edge_tts_generate_audio(text, voice="en-US-AriaNeural", rate=0, pitch=
         return None
     rate_str = f"{rate:+d}%"
     pitch_str = f"{pitch:+d}Hz"
-    communicate = edge_tts.Communicate(text, voice, rate=rate_str, pitch=pitch_str)
+    communicate = Communicate(text, voice, rate=rate_str, pitch=pitch_str)
     out_fn = generate_filename(text, text, file_type=file_format)
     await communicate.save(out_fn)
     return out_fn
 
 def speak_with_edge_tts(text, voice="en-US-AriaNeural", rate=0, pitch=0, file_format="mp3"):
     """Wrapper for the async TTS generate call."""
-    # asyncio.run(edge_tts_generate_audio(text, voice, rate, pitch, file_format))
-    await edge_tts_generate_audio(text, voice, rate, pitch, file_format)
+    try:
+        loop = asyncio.get_event_loop()
+    except RuntimeError:
+        # No event loop running, create one
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
+
+    try:
+        result = loop.run_until_complete(edge_tts_generate_audio(text, voice, rate, pitch, file_format))
+        return result
+    finally:
+        if not asyncio.get_event_loop().is_running():
+            loop.close()
+
+            
+async def edge_tts_generate_audio0(text, voice="en-US-AriaNeural", rate=0, pitch=0, file_format="mp3"):
+    """Async TTS generation with edge-tts library."""
+    text = clean_for_speech(text)
+    if not text.strip():
+        return None
+    rate_str = f"{rate:+d}%"
+    pitch_str = f"{pitch:+d}Hz"
+    communicate = edge_tts.Communicate(text, voice, rate=rate_str, pitch=pitch_str)
+    out_fn = generate_filename(text, text, file_type=file_format)
+    await communicate.save(out_fn)
+    return out_fn
+
+def speak_with_edge_tts0(text, voice="en-US-AriaNeural", rate=0, pitch=0, file_format="mp3"):
+    """Wrapper for the async TTS generate call."""
+    asyncio.run(edge_tts_generate_audio(text, voice, rate, pitch, file_format))
     return
 
 def play_and_download_audio(file_path, file_type="mp3"):