Update app.py

app.py

@@ -23,7 +23,7 @@ client.base_url = os.getenv("OPENAI_API_BASE", "https://api.openai.com/v1")
 # Chatwoot config
 CHATWOOT_BASE_URL = os.getenv("CHATWOOT_BASE_URL")           # e.g., https://app.chatwoot.com
 CHATWOOT_API_KEY = os.getenv("CHATWOOT_API_KEY")             # API Access Token of bot
-BOT_AGENT_ID = os.getenv("BOT_AGENT_ID")                     # Agent ID (integer)
+CHATWOOT_ACCOUNT_ID = os.getenv("CHATWOOT_ACCOUNT_ID")       # Account ID (integer)
 
 @app.post("/ask")
 async def ask(request: Request):
@@ -33,8 +33,8 @@ async def ask(request: Request):
     user_question = payload.get("message") or payload.get("content") or ""
     conversation_id = payload.get("conversation", {}).get("id")
 
-    if not user_question or not conversation_id:
-        print("❌ Missing message or conversation 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"}
 
     messages = [
@@ -55,17 +55,18 @@ async def ask(request: Request):
         print("❌ OpenAI Error:", e)
         answer = "Sorry, I'm having trouble answering right now."
 
-    # Send answer back to Chatwoot conversation
+    # Prepare Chatwoot message payload
     message_payload = {
         "content": answer,
         "message_type": "outgoing",
         "private": False,
-        "agent_id": int(BOT_AGENT_ID)
+        "content_type": "text",
+        "content_attributes": {}
     }
 
     try:
         async with httpx.AsyncClient() as http:
-            chatwoot_url = f"{CHATWOOT_BASE_URL}/api/v1/conversations/{conversation_id}/messages"
+            chatwoot_url = f"{CHATWOOT_BASE_URL}/api/v1/accounts/{CHATWOOT_ACCOUNT_ID}/conversations/{conversation_id}/messages"
             print("📤 Sending to Chatwoot:", chatwoot_url)
             print("📦 Payload to Chatwoot:", json.dumps(message_payload, indent=2))