Update app.py

app.py

@@ -143,27 +143,24 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
     last_processed_timestamp = {}
 
     def poll_conversation(convo_sid):
-        print(f"🧵 Polling conversation: {convo_sid}")
-        last_processed = last_processed_timestamp.get(convo_sid, APP_START_TIME)
         while True:
             try:
-                messages = client.conversations.v1.conversations(convo_sid).messages.list(limit=50)
-                for msg in reversed(messages):
-                    if msg.date_created > last_processed and msg.author != "system":
-                        text = msg.body.strip()
-                        print(f"📩 Received message: {text}")
-                        last_processed_timestamp[convo_sid] = msg.date_created
-
-                        # Query response
-                        result = query_index(text, index, embed_model, text_chunks)
-
-                        # Send reply
-                        client.conversations.v1.conversations(convo_sid).messages.create(
-                            author="system", body=result
-                        )
+                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"\n📥 New message from {sender} in {convo_sid}: {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)
+                        print(f"📤 Replied to {sender}: {answer}")
+                time.sleep(3)
             except Exception as e:
-                print("❌ Error in poll_conversation:", e)
-            time.sleep(3)
+                print(f"❌ Error in convo {convo_sid} polling:", e)
+                time.sleep(5)
 
     def poll_new_conversations():
         print("➡️ Monitoring for new WhatsApp conversations...")
@@ -181,11 +178,12 @@ def start_conversation_monitor(client, index, embed_model, text_chunks):
                                 processed_convos.add(convo.sid)
                                 threading.Thread(target=poll_conversation, args=(convo.sid,), daemon=True).start()
             except Exception as e:
-                print("❌ Error polling new conversations:", e)
+                print("❌ Error polling conversations:", e)
             time.sleep(5)
 
-# ✅ Start background thread to monitor new conversations
-threading.Thread(target=poll_new_conversations, daemon=True).start()
+    # ✅ Launch conversation polling monitor
+    threading.Thread(target=poll_new_conversations, daemon=True).start()
+
 
 
 # --- Streamlit UI ---