Update app.py

app.py

@@ -230,23 +230,30 @@ def submit():
         st.error("❌ ไม่สามารถเชื่อมต่อกับระบบได้ กรุณาลองใหม่อีกครั้ง")
         return
 
+    # Prevent duplicate submissions
+    if "processing_query" in st.session_state and st.session_state.processing_query:
+        return
+
+    st.session_state.processing_query = True
+
     user_query = st.session_state.query_input
     st.session_state.chat_history.append(("user", user_query))
 
-    # Display loading message
+    # Show loading message
     st.session_state.chat_history.append(("assistant", {
         "answer": "🔍 กำลังค้นหาคำตอบ...",
         "documents": [],
         "query_info": {}
     }))
-
-    st.session_state.query_input = ""  # Clear input after submission
+    
+    st.session_state.query_input = ""  # Clear input
 
     try:
-        # Process the query
+        print("Processing query:", user_query)  # Debugging
         result = st.session_state.pipeline.process_query(user_query)
+        print("Query processed successfully")  # Debugging
 
-        # Replace loading message with actual answer
+        # Update the answer
         st.session_state.chat_history[-1] = ("assistant", {
             "answer": result["answer"],
             "documents": result["documents"],
@@ -257,6 +264,7 @@ def submit():
         add_to_qa_history(user_query, result["answer"])
 
     except Exception as e:
+        print("Error processing query:", str(e))  # Debugging
         st.session_state.chat_history[-1] = ("assistant", {
             "answer": f"❌ เกิดข้อผิดพลาด: {str(e)}",
             "documents": [],
@@ -264,7 +272,10 @@ def submit():
         })
         st.error(f"Query processing error: {e}")
 
-    st.rerun()
+    finally:
+        st.session_state.processing_query = False  # Reset flag
+
+    st.rerun()  # Refresh UI
 
 def main():
     # Page config