Update app.py

app.py

@@ -43,11 +43,16 @@ def extract_text_from_docx(docx_path):
 
 # --- Chunking & Retrieval ---
 def chunk_text(text, tokenizer, chunk_size=128, chunk_overlap=32, max_tokens=512):
-
-
     tokens = tokenizer.tokenize(text)
     chunks = []
     start = 0
+    while start < len(tokens):
+        end = min(start + chunk_size, len(tokens))
+        chunk_tokens = tokens[start:end]
+        chunk_text = tokenizer.convert_tokens_to_string(chunk_tokens)
+        chunks.append(chunk_text)
+        if end == len(tokens):
+            break
         start += chunk_size - chunk_overlap
     return chunks
 
@@ -99,12 +104,11 @@ def get_latest_whatsapp_conversation_sid(client):
                 if (p.identity and p.identity.startswith("whatsapp:")) or (
                     p.messaging_binding and p.messaging_binding.get("address", "").startswith("whatsapp:")
                 ):
-                    return convo.sid  # Only return the latest one
+                    return convo.sid
         except:
             continue
     return None
 
-
 def fetch_latest_incoming_message(client, conversation_sid):
     messages = client.conversations.v1.conversations(conversation_sid).messages.list(limit=10)
     for msg in reversed(messages):
@@ -169,10 +173,11 @@ def start_conversation_monitor(client, index, embed_model, text_chunks, specific
                 time.sleep(5)
 
     def monitor_all_conversations():
-     if specific_sid:
-        print(f"➡️ Monitoring only the latest conversation: {specific_sid}")
-        threading.Thread(target=poll_conversation, args=(specific_sid,), daemon=True).start()
+        if specific_sid:
+            print(f"➡️ Monitoring only the latest conversation: {specific_sid}")
+            threading.Thread(target=poll_conversation, args=(specific_sid,), daemon=True).start()
 
+    monitor_all_conversations()
 
 # --- Streamlit UI ---
 st.set_page_config(page_title="Quasa – A Smart WhatsApp Chatbot", layout="wide")
@@ -193,14 +198,10 @@ if all([account_sid, auth_token, GROQ_API_KEY]):
     client = Client(account_sid, auth_token)
     latest_sid = get_latest_whatsapp_conversation_sid(client)
 
-latest_sid = get_latest_whatsapp_conversation_sid(client)
-
-if latest_sid:
-    st.success(f"✅ Monitoring latest WhatsApp conversation: {latest_sid}")
-    index, model, chunks = setup_knowledge_base()
-    # Start monitoring only this conversation
-    threading.Thread(target=start_conversation_monitor, args=(client, index, model, chunks, latest_sid), daemon=True).start()
-    st.success("🟢 Chatbot is running in background and will reply to the latest conversation.")
-else:
-    st.error("❌ No WhatsApp conversations found.")
-
+    if latest_sid:
+        st.success(f"✅ Monitoring latest WhatsApp conversation: {latest_sid}")
+        index, model, chunks = setup_knowledge_base()
+        threading.Thread(target=start_conversation_monitor, args=(client, index, model, chunks, latest_sid), daemon=True).start()
+        st.success("🟢 Chatbot is running in background and will reply to the latest conversation.")
+    else:
+        st.error("❌ No WhatsApp conversations found.")