Update app.py

app.py

@@ -11,12 +11,7 @@ import docx
 from groq import Groq
 import PyPDF2
 import requests
-
-# --- Auto Refresh ---
-st_autorefresh = st.experimental_rerun  # fallback if newer version doesn't have st_autorefresh
-if hasattr(st, "autorefresh"):
-    st_autorefresh = st.autorefresh
-    st_autorefresh(interval=10000, key="refresh")  # every 10 seconds
+from streamlit_extras.st_autorefresh import st_autorefresh
 
 # --- Document Loaders ---
 def extract_text_from_pdf(pdf_path):
@@ -103,16 +98,12 @@ def send_twilio_message(account_sid, auth_token, conversation_sid, body):
     except Exception as e:
         return str(e)
 
-def fetch_latest_conversation_sid(account_sid, auth_token):
-    client = Client(account_sid, auth_token)
-    conversations = client.conversations.v1.conversations.list(limit=1)
-    if conversations:
-        return conversations[0].sid
-    return ""
-
 # --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")
 
+# Auto-refresh every 10 seconds
+st_autorefresh(interval=10 * 1000, key="auto_refresh")
+
 # Styling
 st.markdown("""
     <style>
@@ -151,8 +142,7 @@ if not all([account_sid, auth_token, GROQ_API_KEY]):
     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 "")
 
-conversation_sid_input = st.text_input("Enter Twilio Conversation SID (leave blank for latest)", value="")
-conversation_sid = conversation_sid_input or fetch_latest_conversation_sid(account_sid, auth_token)
+conversation_sid = st.text_input("Enter Twilio Conversation SID", value="")
 
 if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
     os.environ["GROQ_API_KEY"] = GROQ_API_KEY
@@ -177,25 +167,24 @@ if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
 
     index, embedding_model, text_chunks = setup_knowledge_base()
 
-    st.success("✅ Knowledge base ready. Checking WhatsApp messages every 10 seconds...")
+    st.success("✅ Knowledge base ready. Monitoring WhatsApp messages...")
 
-    # Track last message index
     if "last_processed_index" not in st.session_state:
         st.session_state.last_processed_index = -1
 
-    question, sender, msg_index = fetch_latest_incoming_message(account_sid, auth_token, conversation_sid)
-
-    if question and msg_index != st.session_state.last_processed_index:
-        st.session_state.last_processed_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 back to user on WhatsApp!")
-        st.markdown(f"### ✨ Answer:\n\n{answer}")
-    else:
-        st.write("🔄 No new message yet... waiting.")
-
+    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_processed_index:
+            st.session_state.last_processed_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 back to user on WhatsApp!")
+            st.markdown(f"### ✨ Answer:\n\n{answer}")
+        else:
+            st.info("🔄 No new messages yet...")
 else:
-    st.warning("❗ Please provide all required credentials.")
+    st.warning("❗ Please provide all required credentials and conversation SID.")