Update app.py

app.py

@@ -6,8 +6,9 @@ from voice_processing import tts, get_model_names, voice_mapping
 from io import BytesIO
 import json
 from concurrent.futures import ThreadPoolExecutor, as_completed
+import asyncio
 
-def convert_tts(model_name, tts_text, selected_voice, slang_rate, use_uploaded_voice, voice_upload):
+async def convert_tts(model_name, tts_text, selected_voice, slang_rate, use_uploaded_voice, voice_upload):
     edge_tts_voice = voice_mapping.get(selected_voice)
     if not edge_tts_voice:
         return {"error": f"Invalid voice '{selected_voice}'."}, None
@@ -17,7 +18,7 @@ def convert_tts(model_name, tts_text, selected_voice, slang_rate, use_uploaded_v
         with open(voice_upload.name, 'rb') as f:
             voice_upload_file = f.read()
 
-    info, edge_tts_output_path, tts_output_data, edge_output_file = tts(
+    info, edge_tts_output_path, tts_output_data, edge_output_file = await tts(
         model_name, tts_text, edge_tts_voice, slang_rate, use_uploaded_voice, voice_upload_file
     )
 
@@ -35,12 +36,15 @@ def convert_tts(model_name, tts_text, selected_voice, slang_rate, use_uploaded_v
     audio_data_uri = f"data:audio/wav;base64,{base64.b64encode(audio_bytes).decode('utf-8')}"
     return {"info": info}, audio_data_uri
 
+def convert_tts_sync(*args):
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+    return loop.run_until_complete(convert_tts(*args))
+
 def batch_convert_tts(json_file):
     results = []
-    tasks = []
 
     try:
-        # Read JSON content from the uploaded file
         with open(json_file.name, 'r') as file:
             batch_data = json.load(file)
     except Exception as e:
@@ -49,7 +53,7 @@ def batch_convert_tts(json_file):
     with ThreadPoolExecutor() as executor:
         future_to_entry = {
             executor.submit(
-                convert_tts,
+                convert_tts_sync,
                 entry.get("model_name"),
                 entry.get("text"),
                 entry.get("voice"),
@@ -76,7 +80,7 @@ def get_voices():
     return list(voice_mapping.keys())
 
 iface = gr.Interface(
-    fn=convert_tts,
+    fn=convert_tts_sync,
     inputs=[
         gr.Dropdown(choices=get_models(), label="Model", interactive=True),
         gr.Textbox(label="Text", placeholder="Enter text here"),
@@ -108,5 +112,3 @@ app = gr.TabbedInterface(
 
 app.launch()
 
-
-