Update app.py

app.py

@@ -16,6 +16,10 @@ from io import StringIO
 from pdfminer.high_level import extract_text_to_fp
 from pdfminer.layout import LAParams
 
+import datetime
+
+APP_START_TIME = datetime.datetime.utcnow()
+
 # --- PDF Extraction ---
 def extract_text_from_pdf(pdf_path):
     output_string = StringIO()
@@ -159,22 +163,25 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
                 time.sleep(5)
 
     def poll_new_conversations():
-        print("➡️ Monitoring for new WhatsApp conversations...")
-        while True:
-            try:
-                conversations = client.conversations.v1.conversations.list(limit=20)
-                for convo in conversations:
-                    if convo.sid not in processed_convos:
-                        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:"):
-                                print(f"🆕 New WhatsApp convo found: {convo.sid}")
-                                processed_convos.add(convo.sid)
-                                threading.Thread(target=poll_conversation, args=(convo.sid,), daemon=True).start()
-            except Exception as e:
-                print("❌ Error polling conversations:", e)
-            time.sleep(5)
+    print("➡️ Monitoring for new WhatsApp conversations...")
+    while True:
+        try:
+            conversations = client.conversations.v1.conversations.list(limit=20)
+            for convo in conversations:
+                convo_full = client.conversations.v1.conversations(convo.sid).fetch()
+                # convo_full.date_created should be available
+                if convo.sid not in processed_convos and convo_full.date_created > APP_START_TIME:
+                    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:"):
+                            print(f"🆕 New WhatsApp convo found: {convo.sid}")
+                            processed_convos.add(convo.sid)
+                            threading.Thread(target=poll_conversation, args=(convo.sid,), daemon=True).start()
+        except Exception as e:
+            print("❌ Error polling conversations:", e)
+        time.sleep(5)
+
 
     threading.Thread(target=poll_new_conversations, daemon=True).start()
 
@@ -199,4 +206,4 @@ if all([account_sid, auth_token, GROQ_API_KEY]):
     st.success("🟢 Monitoring new WhatsApp conversations...")
     index, model, chunks = setup_knowledge_base()
     threading.Thread(target=start_conversation_monitor, args=(client, index, model, chunks), daemon=True).start()
-    st.info("⏳ Waiting for new messages...")
+    st.info("⏳ Waiting for new messages...")