Update app.py

app.py

@@ -212,22 +212,22 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
             if latest_msg:
                 msg_time = latest_msg["timestamp"]
                 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)
+                    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():
     # convo.date_created is a datetime object in UTC, compare it with APP_START_TIME
-    if convo.date_created is not None and 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()
+        if convo.date_created is not None and 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 ----------------