Update app.py

app.py

@@ -135,9 +135,8 @@ def setup_knowledge_base():
 # --- Monitor All Conversations ---
 def start_conversation_monitor(client, index, embed_model, text_chunks):
     last_msg_index = {}
-    
-    print(embed_model)
-    
+    monitored_sids = set()
+
     def poll_conversation(convo_sid):
         while True:
             try:
@@ -154,8 +153,23 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
                 print(f"❌ Error in convo {convo_sid} polling:", e)
                 time.sleep(5)
 
-    for sid in get_whatsapp_conversation_sids(client):
-        threading.Thread(target=poll_conversation, args=(sid,), daemon=True).start()
+    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"➡️ Starting to monitor new conversation: {sid}")
+                    monitored_sids.add(sid)
+                    threading.Thread(target=poll_conversation, args=(sid,), daemon=True).start()
+                time.sleep(15)  # refresh every 15 seconds or adjust as needed
+            except Exception as e:
+                print("❌ Error in conversation monitoring loop:", e)
+                time.sleep(15)
+
+    # Start the monitoring loop in a separate thread so it runs in background
+    threading.Thread(target=monitor_all_conversations, daemon=True).start()
+
 
 # --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")