Update app.py

app.py

@@ -90,9 +90,8 @@ def generate_answer_with_groq(question, context):
     return response.json()['choices'][0]['message']['content'].strip()
 
 # --- Twilio Functions ---
-def get_whatsapp_conversation_sids(client):
-    sids = []
-    conversations = client.conversations.v1.conversations.list(limit=50)
+def get_latest_whatsapp_conversation_sid(client):
+    conversations = client.conversations.v1.conversations.list(limit=10, order='desc')
     for convo in conversations:
         try:
             participants = client.conversations.v1.conversations(convo.sid).participants.list()
@@ -100,11 +99,11 @@ def get_whatsapp_conversation_sids(client):
                 if (p.identity and p.identity.startswith("whatsapp:")) or (
                     p.messaging_binding and p.messaging_binding.get("address", "").startswith("whatsapp:")
                 ):
-                    sids.append(convo.sid)
-                    break
+                    return convo.sid  # Only return the latest one
         except:
             continue
-    return sids
+    return None
+
 
 def fetch_latest_incoming_message(client, conversation_sid):
     messages = client.conversations.v1.conversations(conversation_sid).messages.list(limit=10)
@@ -145,7 +144,7 @@ def setup_knowledge_base():
     return index, model, chunks
 
 # --- Monitor Conversations ---
-def start_conversation_monitor(client, index, embed_model, text_chunks):
+def start_conversation_monitor(client, index, embed_model, text_chunks, specific_sid=None):
     monitored_sids = set()
 
     def poll_conversation(convo_sid):
@@ -170,20 +169,10 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
                 time.sleep(5)
 
     def monitor_all_conversations():
-        while True:
-            try:
-                current_sids = set(get_whatsapp_conversation_sids(client))
-                new_sids = current_sids - monitored_sids
-                for sid in new_sids:
-                    print(f"➡️ Monitoring new conversation: {sid}")
-                    monitored_sids.add(sid)
-                    threading.Thread(target=poll_conversation, args=(sid,), daemon=True).start()
-                time.sleep(15)
-            except Exception as e:
-                print("❌ Error in conversation monitoring loop:", e)
-                time.sleep(15)
+     if specific_sid:
+        print(f"➡️ Monitoring only the latest conversation: {specific_sid}")
+        threading.Thread(target=poll_conversation, args=(specific_sid,), daemon=True).start()
 
-    threading.Thread(target=monitor_all_conversations, daemon=True).start()
 
 # --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")
@@ -202,12 +191,16 @@ if not all([account_sid, auth_token, GROQ_API_KEY]):
 if all([account_sid, auth_token, GROQ_API_KEY]):
     os.environ["GROQ_API_KEY"] = GROQ_API_KEY
     client = Client(account_sid, auth_token)
-    conversation_sids = get_whatsapp_conversation_sids(client)
-
-    if conversation_sids:
-        st.success(f"✅ {len(conversation_sids)} WhatsApp conversation(s) found. Initializing chatbot...")
-        index, model, chunks = setup_knowledge_base()
-        start_conversation_monitor(client, index, model, chunks)
-        st.success("🟢 Chatbot is running in background and will reply to new messages.")
-    else:
-        st.error("❌ No WhatsApp conversations found.")
+    latest_sid = get_latest_whatsapp_conversation_sid(client)
+
+latest_sid = get_latest_whatsapp_conversation_sid(client)
+
+if latest_sid:
+    st.success(f"✅ Monitoring latest WhatsApp conversation: {latest_sid}")
+    index, model, chunks = setup_knowledge_base()
+    # Start monitoring only this conversation
+    threading.Thread(target=start_conversation_monitor, args=(client, index, model, chunks, latest_sid), daemon=True).start()
+    st.success("🟢 Chatbot is running in background and will reply to the latest conversation.")
+else:
+    st.error("❌ No WhatsApp conversations found.")
+