Update app.py

app.py

@@ -143,46 +143,50 @@ 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:
-                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)
+                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
+                        )
             except Exception as e:
-                print(f"❌ Error in convo {convo_sid} polling:", e)
-                time.sleep(5)
-
-def poll_new_conversations():
-    print("➡️ Monitoring for new WhatsApp conversations...")
-    while True:
-        try:
-            conversations = client.conversations.v1.conversations.list(limit=20)
-            for convo in conversations:
-                convo_full = client.conversations.v1.conversations(convo.sid).fetch()
-                if convo.sid not in processed_convos and convo_full.date_created > APP_START_TIME:
-                    participants = client.conversations.v1.conversations(convo.sid).participants.list()
-                    for p in participants:
-                        address = p.messaging_binding.get("address", "") if p.messaging_binding else ""
-                        if address.startswith("whatsapp:"):
-                            print(f"🆕 New WhatsApp convo found: {convo.sid}")
-                            processed_convos.add(convo.sid)
-                            threading.Thread(target=poll_conversation, args=(convo.sid,), daemon=True).start()
-        except Exception as e:
-            print("❌ Error polling conversations:", e)
-        time.sleep(5)
-
-
-    threading.Thread(target=poll_new_conversations, daemon=True).start()
+                print("❌ Error in poll_conversation:", e)
+            time.sleep(3)
+
+    def poll_new_conversations():
+        print("➡️ Monitoring for new WhatsApp conversations...")
+        while True:
+            try:
+                conversations = client.conversations.v1.conversations.list(limit=20)
+                for convo in conversations:
+                    convo_full = client.conversations.v1.conversations(convo.sid).fetch()
+                    if convo.sid not in processed_convos and convo_full.date_created > APP_START_TIME:
+                        participants = client.conversations.v1.conversations(convo.sid).participants.list()
+                        for p in participants:
+                            address = p.messaging_binding.get("address", "") if p.messaging_binding else ""
+                            if address.startswith("whatsapp:"):
+                                print(f"🆕 New WhatsApp convo found: {convo.sid}")
+                                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)
+            time.sleep(5)
+
+# ✅ Start background thread to monitor new conversations
+threading.Thread(target=poll_new_conversations, daemon=True).start()
+
 
 # --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")