Update app.py

app.py

@@ -206,43 +206,47 @@ def setup_knowledge_base():
 
 # ---------------- Monitor Twilio Conversations ----------------
 def start_conversation_monitor(client, index, embed_model, text_chunks):
-    #print(f"start_conversation_monitor: {client}")
     processed_convos = set()
     last_processed_timestamp = {}
 
     def poll_convo(convo_sid):
-        print(f"poll_convo before while: {convo_sid}")
+        print(f"🧵 Started polling for SID: {convo_sid}")
         while True:
-            print(f"poll_convo Twilio SID: {convo_sid}")
-            latest_msg = fetch_latest_incoming_message(client, convo_sid)
-            if latest_msg:
-                msg_time = latest_msg["timestamp"]
-                print(f"msg_time: {msg_time}")
-                print(f"last_processed_timestamp: {last_processed_timestamp}")
-                print(f"last_processed_timestamp[convo_sid]: {last_processed_timestamp[convo_sid]}")
-                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)
+            try:
+                latest_msg = fetch_latest_incoming_message(client, convo_sid)
+                if latest_msg:
+                    msg_time = latest_msg["timestamp"]
+                    prev_time = last_processed_timestamp.get(convo_sid)
+
+                    if prev_time is None or msg_time > prev_time:
+                        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)
+            except Exception as e:
+                print(f"⚠️ Error in poll_convo: {e}")
             time.sleep(120)
 
-    conversations = client.conversations.v1.conversations.list(limit=1)
-    
-    for convo in conversations:
-        print(f"convo.sid: {convo.sid}")
-        print(f"convo.date_created: {convo.date_created}")
-        print(f"APP_START_TIME: {APP_START_TIME}")
-        print(f"processed_convos: {processed_convos}")
-        
-        # Filter out conversations created before app startup
-        if convo.date_created > APP_START_TIME:
-            processed_convos.add(convo.sid)
-            print(f"🔍 Monitoring conversation SID: {convo.sid}, Created at: {convo.date_created}")
-            threading.Thread(target=poll_convo, args=(convo.sid,), daemon=True).start()
+    # Get all conversations and find the most recent one after APP_START_TIME
+    conversations = client.conversations.v1.conversations.list(limit=20)
+    sorted_convos = sorted(
+        [c for c in conversations if c.date_created > APP_START_TIME],
+        key=lambda c: c.date_created,
+        reverse=True
+    )
+
+    if not sorted_convos:
+        print("❗ No new Twilio conversations found after app startup.")
+        return
+
+    latest_convo = sorted_convos[0]
+    if latest_convo.sid not in processed_convos:
+        processed_convos.add(latest_convo.sid)
+        print(f"✅ Monitoring latest conversation SID: {latest_convo.sid}, Created: {latest_convo.date_created}")
+        threading.Thread(target=poll_convo, args=(latest_convo.sid,), daemon=True).start()
 
 
 # ---------------- Main Entry ----------------
@@ -261,6 +265,5 @@ if __name__ == "__main__":
         st.error("❌ Twilio credentials not set.")
     else:
         client = Client(account_sid, auth_token)
-        #print(f"client: {client}")
         start_conversation_monitor(client, index, model, chunks)
-        st.info("✅ Bot is now monitoring Twilio conversations.")
+        st.info("✅ Bot is now monitoring the latest Twilio conversation.")