Update app.py

app.py

@@ -34,7 +34,7 @@ async def ask(request: Request):
     print("📥 Incoming payload:", json.dumps(payload, indent=2))
 
     account_id = payload.get("account", {}).get("id")
-    conversation_id = payload.get("conversation", {}).get("id")
+    conversation_id = str(payload.get("conversation", {}).get("id"))
     sender = payload.get("sender") or {}
     sender_id = sender.get("id")
     sender_role = (sender.get("role") or "").lower()
@@ -43,8 +43,17 @@ async def ask(request: Request):
 
     print(f"🧾 sender_id: {sender_id}, sender_role: {sender_role}, account_id: {account_id}")
 
-    # Ignore non-incoming messages
+    # Step 1: Detect agent message via Slack and disable AI for that conversation
     if message_type != "incoming":
+        messages = payload.get("conversation", {}).get("messages", [])
+        if messages:
+            msg = messages[0]
+            external_ids = msg.get("external_source_ids", {})
+            if "slack" in external_ids:
+                stop_reply_conversations.add(conversation_id)
+                print(f"🛑 Human intervened via Slack in conversation {conversation_id}. Disabling AI.")
+                return {"status": "AI disabled due to Slack intervention"}
+        
         print("⚠️ Ignoring non-incoming message")
         return {"status": "ignored"}
 
@@ -60,12 +69,6 @@ async def ask(request: Request):
         await send_chatwoot_message(conversation_id, "Bot resumed and will reply to users now.")
         return {"status": "bot resumed"}
 
-    # If message is from other inbox (Slack), disable bot
-    if account_id != CHATWOOT_ACCOUNT_ID:
-        stop_reply_conversations.add(conversation_id)
-        print(f"🚫 Message from other inbox (account ID {account_id}) → disabling AI for conversation {conversation_id}")
-        return {"status": "AI disabled due to human intervention"}
-
     # Check if AI is blacklisted for this conversation
     if conversation_id in stop_reply_conversations:
         print(f"🚫 AI is disabled for conversation {conversation_id}")