Update app.py

app.py

@@ -211,20 +211,25 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
             latest_msg = fetch_latest_incoming_message(client, convo_sid)
             if latest_msg:
                 msg_time = latest_msg["timestamp"]
-                if convo_sid not in last_processed_timestamp or msg_time > last_processed_timestamp[convo_sid]:
-                    last_processed_timestamp[convo_sid] = msg_time
-                    question = latest_msg["body"]
-                    sender = latest_msg["author"]
-                    print(f"📩 New message from {sender}: {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)
+                if msg_time > APP_START_TIME:
+                    if convo_sid not in last_processed_timestamp or msg_time > last_processed_timestamp[convo_sid]:
+                        last_processed_timestamp[convo_sid] = msg_time
+                        question = latest_msg["body"]
+                        sender = latest_msg["author"]
+                        print(f"📩 New message from {sender}: {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)
             time.sleep(5)
 
-    for convo in client.conversations.v1.conversations.list():
-        if convo.sid not in processed_convos:
-            processed_convos.add(convo.sid)
-            threading.Thread(target=poll_convo, args=(convo.sid,), daemon=True).start()
+    # Filter only conversations created after app start
+    conversations = client.conversations.v1.conversations.list()
+    for convo in conversations:
+        if convo.date_created > APP_START_TIME:
+            if convo.sid not in processed_convos:
+                processed_convos.add(convo.sid)
+                threading.Thread(target=poll_convo, args=(convo.sid,), daemon=True).start()
+
 
 # ---------------- Main Entry ----------------
 if __name__ == "__main__":