Update app.py

app.py

@@ -13,7 +13,6 @@ import PyPDF2
 import requests
 from streamlit_autorefresh import st_autorefresh
 
-# Extract text from PDF with fallback
 # --- Document Loaders ---
 def extract_text_from_pdf(pdf_path):
     try:
@@ -51,7 +50,6 @@ def retrieve_chunks(question, index, embed_model, text_chunks, k=3):
     D, I = index.search(np.array([question_embedding]), k)
     return [text_chunks[i] for i in I[0]]
 
-# Generate answer using Groq API with retries and timeout
 def generate_answer_with_groq(question, context, retries=3, delay=2):
     url = "https://api.groq.com/openai/v1/chat/completions"
     api_key = os.environ.get("GROQ_API_KEY")
@@ -100,7 +98,6 @@ def generate_answer_with_groq(question, context, retries=3, delay=2):
         except Exception as e:
             return f"⚠️ Groq API Error: {e}"
 
-# Twilio message fetch and send
 def fetch_latest_incoming_message(account_sid, auth_token, conversation_sid):
     client = Client(account_sid, auth_token)
     messages = client.conversations.v1.conversations(conversation_sid).messages.list(limit=10)
@@ -117,7 +114,7 @@ def send_twilio_message(account_sid, auth_token, conversation_sid, body):
     except Exception as e:
         return str(e)
 
-# Streamlit UI
+# --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")
 st.title("📱 Quasa – A Smart WhatsApp Chatbot")
 
@@ -127,18 +124,14 @@ if "last_index" not in st.session_state:
 account_sid = st.secrets.get("TWILIO_SID")
 auth_token = st.secrets.get("TWILIO_TOKEN")
 GROQ_API_KEY = st.secrets.get("GROQ_API_KEY")
+conversation_sid = st.secrets.get("TWILIO_CONVERSATION_SID")
 
-if not all([account_sid, auth_token, GROQ_API_KEY]):
+if not all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
     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 "")
-
-enable_autorefresh = st.checkbox("🔄 Enable Auto-Refresh", value=True)
-interval_seconds = st.selectbox("Refresh Interval (seconds)", options=[5, 10, 15, 30, 60], index=4)
-
-if enable_autorefresh:
-    st_autorefresh(interval=interval_seconds * 1000, key="auto-refresh")
+    conversation_sid = st.text_input("Twilio Conversation SID", value=conversation_sid or "")
 
 if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
     os.environ["GROQ_API_KEY"] = GROQ_API_KEY
@@ -165,12 +158,19 @@ if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
             st.error(f"Error setting up knowledge base: {e}")
             return None, None, None
 
+    st.info("🔄 Loading knowledge base...")
     index, embedding_model, text_chunks = setup_knowledge_base()
+
     if index is None:
         st.stop()
 
     st.success("✅ Knowledge base ready. Monitoring WhatsApp...")
 
+    enable_autorefresh = st.checkbox("🔄 Enable Auto-Refresh", value=True)
+    interval_seconds = st.selectbox("Refresh Interval (seconds)", options=[5, 10, 15, 30, 60], index=4)
+    if enable_autorefresh:
+        st_autorefresh(interval=interval_seconds * 1000, key="auto-refresh")
+
     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:
@@ -185,4 +185,4 @@ if all([account_sid, auth_token, GROQ_API_KEY, conversation_sid]):
         else:
             st.caption("✅ No new message yet. Waiting for refresh...")
 else:
-    st.warning("❗ Please provide all required credentials and conversation SID.")
+    st.warning("❗ Please provide all required credentials and conversation SID.")