Update app.py

app.py

@@ -12,6 +12,7 @@ import docx
 from groq import Groq
 import PyPDF2
 import requests
+from streamlit_extras.st_autorefresh import st_autorefresh
 
 # --- Document Loaders ---
 def extract_text_from_pdf(pdf_path):
@@ -102,24 +103,28 @@ def send_twilio_message(account_sid, auth_token, conversation_sid, body):
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")
 st.title("📱 Quasa – A Smart WhatsApp Chatbot")
 
-# Load from Hugging Face secrets
+# Initialize session state for last index
+if "last_index" not in st.session_state:
+    st.session_state.last_index = -1
+
+# Load secrets or allow manual input
 account_sid = st.secrets.get("TWILIO_SID")
 auth_token = st.secrets.get("TWILIO_TOKEN")
 GROQ_API_KEY = st.secrets.get("GROQ_API_KEY")
 
-# Fallback for testing
 if not all([account_sid, auth_token, GROQ_API_KEY]):
     st.warning("⚠️ Some secrets not found. Please enter missing credentials below:")
     account_sid = st.text_input("Twilio SID", value=account_sid or "")
     auth_token = st.text_input("Twilio Auth Token", type="password", value=auth_token or "")
     GROQ_API_KEY = st.text_input("GROQ API Key", type="password", value=GROQ_API_KEY or "")
 
-# Always show conversation SID input
 conversation_sid = st.text_input("Enter Conversation SID", value="")
 
-# Initialize session state to track last message
-if "last_index" not in st.session_state:
-    st.session_state.last_index = -1
+# Auto-refresh toggle and interval selector
+enable_autorefresh = st.toggle("🔄 Enable Auto-Refresh", value=True)
+interval_seconds = st.selectbox("Refresh Interval (seconds)", options=[5, 10, 15, 30, 60], index=1)
+if enable_autorefresh:
+    st_autorefresh(interval=interval_seconds * 1000, key="auto-refresh")
 
 if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
     os.environ["GROQ_API_KEY"] = GROQ_API_KEY
@@ -146,19 +151,18 @@ if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
 
     st.success("✅ Knowledge base ready. Monitoring WhatsApp...")
 
-    if st.button("🔁 Check for New WhatsApp Query"):
-        with st.spinner("Checking messages..."):
-            question, sender, msg_index = fetch_latest_incoming_message(account_sid, auth_token, conversation_sid)
-            if question and msg_index > st.session_state.last_index:
-                st.session_state.last_index = msg_index
-                st.info(f"📥 New Question from {sender}:\n\n> {question}")
-                relevant_chunks = retrieve_chunks(question, index, embedding_model, text_chunks)
-                context = "\n\n".join(relevant_chunks)
-                answer = generate_answer_with_groq(question, context)
-                send_twilio_message(account_sid, auth_token, conversation_sid, answer)
-                st.success("📤 Answer sent via WhatsApp!")
-                st.markdown(f"### ✨ Answer:\n\n{answer}")
-            else:
-                st.warning("No new messages from users found.")
+    with st.spinner("⏳ Checking for new WhatsApp messages..."):
+        question, sender, msg_index = fetch_latest_incoming_message(account_sid, auth_token, conversation_sid)
+        if question and msg_index > st.session_state.last_index:
+            st.session_state.last_index = msg_index
+            st.info(f"📥 New Question from {sender}:\n\n> {question}")
+            relevant_chunks = retrieve_chunks(question, index, embedding_model, text_chunks)
+            context = "\n\n".join(relevant_chunks)
+            answer = generate_answer_with_groq(question, context)
+            send_twilio_message(account_sid, auth_token, conversation_sid, answer)
+            st.success("📤 Answer sent via WhatsApp!")
+            st.markdown(f"### ✨ Answer:\n\n{answer}")
+        else:
+            st.caption("✅ No new message yet. Waiting for refresh...")
 else:
     st.warning("❗ Please provide all required credentials and conversation SID.")