Update app.py

app.py

@@ -5,8 +5,8 @@ from google.cloud import texttospeech_v1 as texttospeech
 import streamlit as st
 from dotenv import load_dotenv
 import speech_recognition as sr
-from threading import Timer
 from datetime import datetime, timedelta
+from streamlit_autorefresh import st_autorefresh
 
 # Configurar la página de Streamlit
 st.set_page_config(page_title="Galatea Asistente - OMARDENT", layout="wide")
@@ -54,26 +54,33 @@ def obtener_respuesta_groq(pregunta, contexto="", modelo="llama3-8b-8192", tempe
         )
 
         # Realizar la solicitud de síntesis de voz
-        response = client.synthesize_speech(
+        response_audio = client.synthesize_speech(
             input=input_text, voice=voice, audio_config=audio_config
         )
 
-        # Reproducir el audio en Streamlit
-        st.audio(response.audio_content, format="audio/mp3")
-        return respuesta
+        # Guardar el archivo de audio temporalmente
+        audio_file_path = f'tmp_respuesta_{int(time.time())}.mp3'
+        with open(audio_file_path, 'wb') as audio_file:
+            audio_file.write(response_audio.audio_content)
+        
+        # Devolver la respuesta y la ruta del archivo de audio
+        return respuesta, audio_file_path
 
     except Exception as e:
         st.error(f"Error al generar la respuesta y el audio: {e}")
-        return "Lo siento, ocurrió un error al procesar tu solicitud."
+        return "Lo siento, ocurrió un error al procesar tu solicitud.", None
 
 # Función para manejar el chat del asistente
 def mostrar_galatea_asistente():
     st.title("🦷 Galatea - Asistente Virtual OMARDENT")
 
-    # Inicializa el historial del chat
+    # Inicializa el historial del chat y el temporizador
     if 'mensajes_chat' not in st.session_state:
         st.session_state['mensajes_chat'] = []
 
+    if 'respuesta_programada' not in st.session_state:
+        st.session_state['respuesta_programada'] = None
+
     # Mostrar los mensajes del chat
     for mensaje in st.session_state['mensajes_chat']:
         clase = "user" if mensaje["role"] == "user" else "assistant"
@@ -107,29 +114,42 @@ def mostrar_galatea_asistente():
             # Guardar la pregunta en el historial
             st.session_state['mensajes_chat'].append({"role": "user", "content": pregunta_usuario})
 
-            # Función para ejecutar la respuesta después del tiempo seleccionado
-            def ejecutar_respuesta():
-                respuesta = obtener_respuesta_groq(pregunta_usuario)
-
-                # Guardar la respuesta en el historial
-                st.session_state['mensajes_chat'].append({"role": "assistant", "content": respuesta})
-
-                # Mostrar la respuesta
-                st.write(f"**Respuesta:** {respuesta}")
-
             # Calcular el tiempo en segundos
             tiempo_en_segundos = intervalo * 60
-
-            # Mostrar un mensaje con la hora programada
             tiempo_ejecucion = datetime.now() + timedelta(minutes=intervalo)
             st.success(f"La respuesta se generará a las {tiempo_ejecucion.strftime('%H:%M:%S')}")
 
-            # Programar la ejecución
-            Timer(tiempo_en_segundos, ejecutar_respuesta).start()
+            # Guardar la información de la respuesta programada
+            st.session_state['respuesta_programada'] = {
+                'pregunta': pregunta_usuario,
+                'tiempo_ejecucion': tiempo_ejecucion,
+                'tiempo_en_segundos': tiempo_en_segundos,
+                'audio_file_path': None
+            }
+
+# Actualizar la interfaz cada segundo para verificar si el tiempo ha pasado
+st_autorefresh(interval=1000, key="data_refresh")
+
+# Verificar si hay una respuesta programada que deba ejecutarse
+if 'respuesta_programada' in st.session_state and st.session_state['respuesta_programada']:
+    respuesta_programada = st.session_state['respuesta_programada']
+    if datetime.now() >= respuesta_programada['tiempo_ejecucion'] and respuesta_programada['audio_file_path'] is None:
+        # Generar la respuesta
+        respuesta, audio_file_path = obtener_respuesta_groq(respuesta_programada['pregunta'])
+
+        # Guardar la respuesta y el audio en el estado
+        st.session_state['mensajes_chat'].append({"role": "assistant", "content": respuesta})
+        st.session_state['respuesta_programada']['audio_file_path'] = audio_file_path
+
+    # Reproducir el audio si ya fue generado
+    if st.session_state['respuesta_programada']['audio_file_path']:
+        audio_file_path = st.session_state['respuesta_programada']['audio_file_path']
+        with open(audio_file_path, "rb") as audio_file:
+            st.audio(audio_file.read(), format="audio/mp3")
 
 # Función principal
 def main():
     mostrar_galatea_asistente()
 
 if __name__ == "__main__":
-    main()
+    main()