Update app.py

app.py

@@ -124,8 +124,17 @@ def fetch_latest_incoming_message(client, conversation_sid):
     try:
         messages = client.conversations.v1.conversations(conversation_sid).messages.list()
         for msg in reversed(messages):
-            if msg.author.startswith("whatsapp:"):
-                return {"sid": msg.sid, "body": msg.body, "author": msg.author, "timestamp": msg.date_created}
+            if (
+                msg.author.startswith("whatsapp:") and
+                msg.date_created and
+                msg.date_created > APP_START_TIME
+            ):
+                return {
+                    "sid": msg.sid,
+                    "body": msg.body,
+                    "author": msg.author,
+                    "timestamp": msg.date_created,
+                }
     except TwilioRestException:
         return None
 
@@ -135,12 +144,17 @@ def send_twilio_message(client, conversation_sid, body):
 def get_latest_whatsapp_conversation_sid(client):
     try:
         conversations = client.conversations.v1.conversations.list(limit=20)
-        for convo in sorted(conversations, key=lambda c: c.date_created, reverse=True):
+        # Filter conversations created after app start time
+        filtered = [
+            c for c in conversations
+            if c.date_created and c.date_created > APP_START_TIME
+        ]
+        for convo in sorted(filtered, key=lambda c: c.date_created, reverse=True):
             messages = convo.messages.list(limit=1)
-            if messages and any(m.author.startswith("whatsapp:") for m in messages):
+            if messages and any(m.author.startswith("whatsapp:") and m.date_created > APP_START_TIME for m in messages):
                 return convo.sid
     except Exception as e:
-        print("Error fetching latest conversation SID:", e)
+        print("Error fetching valid conversation SID:", e)
     return None
 
 # ---------------- Knowledge Base Setup ----------------
@@ -181,7 +195,7 @@ def process_messages_loop():
             continue
 
         message = fetch_latest_incoming_message(twilio_client, conversation_sid)
-        if message and message["sid"] not in seen_sids and message["timestamp"] > APP_START_TIME:
+        if message and message["sid"] not in seen_sids:
             seen_sids.add(message["sid"])
             question = message["body"]
             chunks = retrieve_chunks(question, index, embed_model, text_chunks)
@@ -196,4 +210,4 @@ st.title("ToyShop WhatsApp Assistant (Groq + Twilio)")
 if st.button("Start WhatsApp Bot"):
     thread = threading.Thread(target=process_messages_loop)
     thread.start()
-    st.success("WhatsApp assistant started and monitoring for new messages.")
+    st.success("WhatsApp assistant started and monitoring for new messages.")