Update app.py

app.py

@@ -816,9 +816,16 @@ def get_ice_servers():
 
     return token.ice_servers
 
-# Function to generate question audio (placeholder)
-async def generate_question_audio(question):
-    return "question.mp3"
+# Function to generate question audio and save to a valid path
+async def generate_question_audio(question, voice="en-IE-EmilyNeural"):
+    clean_question = question.strip().replace("\n", " ")
+    tts = edge_tts.Communicate(text=clean_question, voice=voice)
+
+    
+    with tempfile.NamedTemporaryFile(delete=False, suffix=".mp3", dir=os.getcwd()) as tmp_file:
+        output_path = tmp_file.name
+        await tts.save(output_path)
+    return output_path
 
 @st.cache_data(show_spinner=False)
 def get_cached_question_audio(question_text):
@@ -842,15 +849,25 @@ if st.session_state["generated_questions"]:
             })
         """
         if not st.session_state.get("question_played"):
-            st.session_state["question_audio_file"] = get_cached_question_audio(question)
+            st.session_state["question_audio_file"] = asyncio.run(generate_question_audio(question))
             st.session_state.update({
                 "question_played": True,
                 "question_start_time": time.time(),
                 "record_phase": "audio_playing",
             })
+        
+
+        #st.markdown(f"**Q{idx + 1}:** {question}")
+        #st.audio(st.session_state["question_audio_file"], format="audio/mp3")
 
         st.markdown(f"**Q{idx + 1}:** {question}")
-        st.audio(st.session_state["question_audio_file"], format="audio/mp3")
+        audio_file = st.session_state["question_audio_file"]
+        if os.path.exists(audio_file) and os.path.getsize(audio_file) > 0:
+            st.audio(audio_file, format="audio/mp3")
+        else:
+            st.warning("⚠️ Could not load question audio. Please retry.")
+
+        
 
         now = time.time()
         elapsed = now - st.session_state.get("question_start_time", 0)