Update app.py

app.py

@@ -25,23 +25,31 @@ CHATWOOT_BASE_URL = os.getenv("CHATWOOT_BASE_URL")           # e.g., https://app
 CHATWOOT_API_KEY = os.getenv("CHATWOOT_API_KEY")             # API Access Token of bot
 CHATWOOT_ACCOUNT_ID = os.getenv("CHATWOOT_ACCOUNT_ID")       # Account ID (integer)
 
+# Add at the top after imports:
+stop_reply_conversations = set()
+
 # @app.post("/ask")
 # async def ask(request: Request):
 #     payload = await request.json()
 #     print("📥 Incoming payload:", json.dumps(payload, indent=2))
 
 #     message_type = payload.get("message_type", "").lower()
-#     sender_type = payload.get("sender", {}).get("type", "").lower()
-    
-#     # Only respond to incoming messages from users
-#     if message_type != "incoming" or sender_type != "user":
-#         print("⚠️ Ignoring non-user incoming messages or outgoing messages to prevent loop.")
+#     account_id = payload.get("account", {}).get("id")        # bot's account id
+#     sender_id = payload.get("sender", {}).get("id")          # sender id of this message
+
+#     # Only respond to incoming messages
+#     if message_type != "incoming":
+#         print("⚠️ Ignoring non-incoming messages")
 #         return {"status": "ignored"}
 
+#     # Ignore messages sent by bot itself (to avoid loops)
+#     if sender_id == account_id:
+#         print("⚠️ Ignoring message from bot itself to prevent loop.")
+#         return {"status": "ignored"}
 
-#     user_question = payload.get("message") or payload.get("content") or ""
+#     # Extract user question and conversation id
+#     user_question = payload.get("content", "")
 #     conversation_id = payload.get("conversation", {}).get("id")
-
 #     if not user_question or not conversation_id or not CHATWOOT_ACCOUNT_ID:
 #         print("❌ Missing message, conversation ID, or account ID")
 #         return {"status": "invalid payload"}
@@ -64,7 +72,6 @@ CHATWOOT_ACCOUNT_ID = os.getenv("CHATWOOT_ACCOUNT_ID")       # Account ID (integ
 #         print("❌ OpenAI Error:", e)
 #         answer = "Sorry, I'm having trouble answering right now."
 
-#     # Prepare Chatwoot message payload
 #     message_payload = {
 #         "content": answer,
 #         "message_type": "outgoing",
@@ -100,22 +107,26 @@ async def ask(request: Request):
     print("📥 Incoming payload:", json.dumps(payload, indent=2))
 
     message_type = payload.get("message_type", "").lower()
-    account_id = payload.get("account", {}).get("id")        # bot's account id
-    sender_id = payload.get("sender", {}).get("id")          # sender id of this message
+    account_id = payload.get("account", {}).get("id")
+    sender_id = payload.get("sender", {}).get("id")
+    conversation_id = payload.get("conversation", {}).get("id")
 
     # Only respond to incoming messages
     if message_type != "incoming":
         print("⚠️ Ignoring non-incoming messages")
         return {"status": "ignored"}
 
-    # Ignore messages sent by bot itself (to avoid loops)
+    # Ignore messages from bot itself to prevent loops
     if sender_id == account_id:
-        print("⚠️ Ignoring message from bot itself to prevent loop.")
+        print("⚠️ Ignoring message from bot itself")
+        return {"status": "ignored"}
+
+    # If conversation is blacklisted (bot should stop replying)
+    if conversation_id in stop_reply_conversations:
+        print(f"⚠️ Conversation {conversation_id} is blacklisted, no reply sent.")
         return {"status": "ignored"}
 
-    # Extract user question and conversation id
     user_question = payload.get("content", "")
-    conversation_id = payload.get("conversation", {}).get("id")
     if not user_question or not conversation_id or not CHATWOOT_ACCOUNT_ID:
         print("❌ Missing message, conversation ID, or account ID")
         return {"status": "invalid payload"}
@@ -138,6 +149,11 @@ async def ask(request: Request):
         print("❌ OpenAI Error:", e)
         answer = "Sorry, I'm having trouble answering right now."
 
+    # If answer is "I'm not sure about that..." message, blacklist this conversation
+    if answer == "I'm not sure about that. Let me connect you with a human agent.":
+        stop_reply_conversations.add(conversation_id)
+        print(f"⚠️ Added conversation {conversation_id} to stop reply blacklist.")
+
     message_payload = {
         "content": answer,
         "message_type": "outgoing",