back

app/chat.py

@@ -11,21 +11,20 @@ from app.db import supabase
 import os
 import glob
 import time
-import threading
 from dotenv import load_dotenv
 
 load_dotenv()
 
-# Bersihkan cache audio lama
+# Bersihkan cache audio lama (opsional)
 def clean_old_cache(tts_dir="cache_tts", max_age_hours=12):
     now = time.time()
     for f in glob.glob(os.path.join(tts_dir, "*.mp3")):
         if os.stat(f).st_mtime < now - max_age_hours * 3600:
             os.remove(f)
 
+# Jalankan pembersihan saat startup
 clean_old_cache()
 
-# Simpan feedback ke Supabase
 def save_feedback_to_supabase(feedback_text):
     try:
         data = {"message": feedback_text}
@@ -35,7 +34,6 @@ def save_feedback_to_supabase(feedback_text):
         st.error(f"Gagal menyimpan feedback: {e}")
         return False
 
-# Inisialisasi session state
 def initialize_session_state():
     if 'history' not in st.session_state:
         st.session_state['history'] = []
@@ -54,14 +52,14 @@ def initialize_session_state():
     if 'tts_output' not in st.session_state:
         st.session_state['tts_output'] = ""
     if 'tts_played' not in st.session_state:
-        st.session_state['tts_played'] = True
+        st.session_state['tts_played'] = True  # default True supaya tidak main saat awal
 
-# edge-tts fallback
+# edge-tts fallback (cadangan)
 async def generate_audio_edge(text, path, voice="id-ID-GadisNeural"):
     communicate = edge_tts.Communicate(text, voice=voice)
     await communicate.save(path)
 
-# Fungsi utama TTS dengan cache-busting
+# fungsi utama TTS dengan fallback
 def text_to_speech(text):
     cache_dir = "cache_tts"
     os.makedirs(cache_dir, exist_ok=True)
@@ -87,24 +85,20 @@ def text_to_speech(text):
         with open(path, "rb") as audio_file:
             audio_base64 = base64.b64encode(audio_file.read()).decode()
 
-        # 🔹 Cache-busting query string
-        ts = int(time.time())
         return f"""
         <audio autoplay>
-            <source src="data:audio/mp3;base64,{audio_base64}?v={ts}" type="audio/mp3">
+            <source src="data:audio/mp3;base64,{audio_base64}" type="audio/mp3">
         </audio>
         """
     except Exception as e:
         print(f"[Error saat membaca audio] {e}")
         return ""
 
-# Fungsi chat utama
 def conversation_chat(query, chain, history):
     result = chain({"question": query, "chat_history": history})
     history.append((query, result["answer"]))
     return result["answer"]
 
-# Tampilan chat + TTS indikator
 def display_chat_history(chain):
     reply_container = st.container()
 
@@ -112,16 +106,16 @@ def display_chat_history(chain):
 
     col2, col3 = st.columns([1, 1])
 
-    # Tombol toggle TTS
+    # Tombol TTS Aktif / Nonaktif
     with col2:
-        if st.button("🔊 Text-to-Speech Aktif" if st.session_state['should_speak'] else "🔇 Text-to-Speech Nonaktif",
-                     key="toggle_tts",
-                     help="Aktifkan/Nonaktifkan Text-to-Speech",
+        if st.button("🔊 Text-to-Speech Aktif" if st.session_state['should_speak'] else "🔇 Text-to-Speech Nonaktif", 
+                     key="toggle_tts", 
+                     help="Aktifkan/Nonaktifkan Text-to-Speech", 
                      use_container_width=True):
             st.session_state['should_speak'] = not st.session_state['should_speak']
             st.experimental_rerun()
 
-    # Input suara STT
+    # Tombol Input Suara
     with col3:
         stt_text = speech_to_text(
             start_prompt="🎤 Input Suara",
@@ -132,6 +126,7 @@ def display_chat_history(chain):
             use_container_width=True,
         )
 
+    # Jika ada STT
     if stt_text:
         st.session_state.input_text = stt_text
         st.experimental_rerun()
@@ -147,30 +142,19 @@ def display_chat_history(chain):
         st.session_state['generated'].append(output)
         st.session_state.input_text = ""
 
-        # Reset flag TTS setiap ada output baru
+        # Reset flag supaya TTS siap memutar lagi
         if st.session_state['should_speak'] and output:
-            if st.session_state.get('tts_output') != output:
-                st.session_state['tts_output'] = output
-                st.session_state['tts_played'] = False
+            st.session_state['tts_output'] = output
+            st.session_state['tts_played'] = False
 
-    # Tampilkan riwayat chat
+    # Tampilkan Riwayat Chat
     if st.session_state['generated']:
         with reply_container:
             for i in range(len(st.session_state['generated'])):
                 message(st.session_state["past"][i], is_user=True, key=str(i) + '_user', avatar_style="no-avatar")
                 message(st.session_state["generated"][i], key=str(i), avatar_style="no-avatar")
 
-    # Pemutaran TTS + indikator
+    # Pemutaran TTS
     if st.session_state.get('tts_output') and not st.session_state.get('tts_played'):
-        indicator = st.empty()
-        indicator.markdown("🎧 **Memutar audio...**")
-
         st.markdown(text_to_speech(st.session_state['tts_output']), unsafe_allow_html=True)
         st.session_state['tts_played'] = True
-
-        # Hilangkan indikator setelah 3 detik (tidak blok UI)
-        def remove_indicator():
-            time.sleep(3)
-            indicator.empty()
-
-        threading.Thread(target=remove_indicator).start()