Update app.py

app.py

@@ -2,96 +2,84 @@ import os
 import json
 import httpx
 from fastapi import FastAPI, Request
-
 from openai import OpenAI
 
 app = FastAPI()
 
-# Load knowledge base
+# Load KB
 with open("kb.json") as f:
     kb = json.load(f)
 
-# Prepare system prompt
+# Build system prompt
 system_prompt = "You are a helpful assistant. Only answer questions based on the following knowledge base:\n\n"
-for question, answer in kb.items():
-    system_prompt += f"Q: {question}\nA: {answer}\n\n"
-system_prompt += (
-    "If the question is not in the knowledge base, respond with: "
-    "'I'm not sure about that. I've transferred you to a human agent.'"
-)
+for q, a in kb.items():
+    system_prompt += f"Q: {q}\nA: {a}\n\n"
+system_prompt += "If the question is not in the knowledge base, respond with: 'I'm not sure about that. Let me connect you with a human agent.'"
 
-# OpenAI client
+# OpenAI setup
 client = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
-client.base_url = os.getenv("OPENAI_API_BASE", "https://fast.typegpt.net/v1")
-
-# Track conversations transferred
-transferred_conversations = set()
+client.base_url = os.getenv("OPENAI_API_BASE", "https://api.openai.com/v1")
 
-# Chatwoot configs
-CHATWOOT_BASE_URL = os.getenv("CHATWOOT_BASE_URL")  # e.g., https://app.chatwoot.com
-CHATWOOT_API_TOKEN = os.getenv("CHATWOOT_API_TOKEN")  # from profile
-CHATWOOT_AGENT_ID = os.getenv("CHATWOOT_AGENT_ID")  # numeric ID of your agent
+# 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)
 
 @app.post("/ask")
 async def ask(request: Request):
     payload = await request.json()
+    print("📥 Incoming payload:", json.dumps(payload, indent=2))
 
-    user_msg = payload.get("content") or payload.get("message") or ""
-    conv_id = payload.get("conversation", {}).get("id")
-    inbox_id = payload.get("conversation", {}).get("inbox_id")
+    user_question = payload.get("message") or payload.get("content") or ""
+    conversation_id = payload.get("conversation", {}).get("id")
 
-    if not user_msg or not conv_id:
-        return {"status": "ignored"}
+    if not user_question or not conversation_id:
+        print("❌ Missing message or conversation ID")
+        return {"status": "invalid payload"}
 
-    if str(conv_id) in transferred_conversations:
-        return {"status": "already transferred"}
-
-    # Compose OpenAI prompt
     messages = [
         {"role": "system", "content": system_prompt},
-        {"role": "user", "content": user_msg},
+        {"role": "user", "content": user_question},
     ]
 
     try:
         response = client.chat.completions.create(
             model="gpt-4o-mini",
             messages=messages,
-            temperature=0.0,
+            temperature=0,
             max_tokens=200,
         )
         answer = response.choices[0].message.content.strip()
+        print("✅ OpenAI Answer:", answer)
     except Exception as e:
-        print(f"OpenAI error: {e}")
+        print("❌ OpenAI Error:", e)
         answer = "Sorry, I'm having trouble answering right now."
 
-    # If fallback response, stop future replies
-    if "transferred you to a human agent" in answer:
-        transferred_conversations.add(str(conv_id))
-
-    # Send reply using your agent
-    await send_chatwoot_reply(
-        conversation_id=conv_id,
-        message=answer,
-        agent_id=CHATWOOT_AGENT_ID,
-        inbox_id=inbox_id
-    )
-
-    return {"status": "replied"}
-
-
-async def send_chatwoot_reply(conversation_id, message, agent_id, inbox_id):
-    url = f"{CHATWOOT_BASE_URL}/api/v1/conversations/{conversation_id}/messages"
-    headers = {
-        "Content-Type": "application/json",
-        "api_access_token": CHATWOOT_API_TOKEN
-    }
-    payload = {
-        "content": message,
+    # Send answer back to Chatwoot conversation
+    message_payload = {
+        "content": answer,
         "message_type": "outgoing",
         "private": False,
-        "sender_type": "AgentBot",
-        "sender_id": agent_id,
-        "inbox_id": inbox_id
+        "agent_id": int(BOT_AGENT_ID)
     }
-    async with httpx.AsyncClient() as client:
-        await client.post(url, json=payload, headers=headers)
+
+    try:
+        async with httpx.AsyncClient() as http:
+            chatwoot_url = f"{CHATWOOT_BASE_URL}/api/v1/conversations/{conversation_id}/messages"
+            print("📤 Sending to Chatwoot:", chatwoot_url)
+            print("📦 Payload to Chatwoot:", json.dumps(message_payload, indent=2))
+
+            resp = await http.post(
+                chatwoot_url,
+                headers={
+                    "Content-Type": "application/json",
+                    "api_access_token": CHATWOOT_API_KEY,
+                },
+                json=message_payload,
+            )
+            print("📬 Chatwoot Response:", resp.status_code, resp.text)
+
+    except Exception as e:
+        print("❌ Chatwoot Send Error:", e)
+
+    return {"status": "ok"}