Update app.py

app.py

@@ -149,36 +149,30 @@ def setup_knowledge_base():
     return index, model, chunks
 
 # --- Monitor Conversations ---
-def start_conversation_monitor(client, index, embed_model, text_chunks, specific_sid=None):
-    monitored_sids = set()
+def monitor_all_conversations():
+    print("➡️ Monitoring all new incoming WhatsApp conversations...")
 
-    def poll_conversation(convo_sid):
-        last_processed_timestamp = None
+    def poll_new_conversations():
+        processed_convos = set()
         while True:
             try:
-                latest_msg = fetch_latest_incoming_message(client, convo_sid)
-                if latest_msg:
-                    msg_time = latest_msg["timestamp"]
-                    if last_processed_timestamp is None or msg_time > last_processed_timestamp:
-                        last_processed_timestamp = msg_time
-                        question = latest_msg["body"]
-                        sender = latest_msg["author"]
-                        print(f"\n📥 New message from {sender} in {convo_sid}: {question}")
-                        context = "\n\n".join(retrieve_chunks(question, index, embed_model, text_chunks))
-                        answer = generate_answer_with_groq(question, context)
-                        send_twilio_message(client, convo_sid, answer)
-                        print(f"📤 Replied to {sender}: {answer}")
-                time.sleep(3)
+                conversations = client.conversations.v1.conversations.list(limit=20)
+                for convo in conversations:
+                    if convo.sid not in processed_convos:
+                        # Check if WhatsApp participant exists
+                        participants = client.conversations.v1.conversations(convo.sid).participants.list()
+                        for p in participants:
+                            address = p.messaging_binding.get("address", "") if p.messaging_binding else ""
+                            if address.startswith("whatsapp:"):
+                                processed_convos.add(convo.sid)
+                                print(f"🆕 New conversation detected: {convo.sid}")
+                                threading.Thread(target=poll_conversation, args=(convo.sid,), daemon=True).start()
             except Exception as e:
-                print(f"❌ Error in convo {convo_sid} polling:", e)
-                time.sleep(5)
+                print("❌ Error while polling for new conversations:", e)
+            time.sleep(5)
 
-    def monitor_all_conversations():
-        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=poll_new_conversations, daemon=True).start()
 
-    monitor_all_conversations()
 
 # --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")
@@ -199,10 +193,6 @@ if all([account_sid, auth_token, GROQ_API_KEY]):
     client = Client(account_sid, auth_token)
     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()
-        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.")
+    st.success("🟢 Monitoring new WhatsApp conversations... Waiting for messages.")
+index, model, chunks = setup_knowledge_base()
+threading.Thread(target=start_conversation_monitor, args=(client, index, model, chunks), daemon=True).start()