Update app.py

app.py

@@ -99,18 +99,50 @@ async def ask(request: Request):
         )
         answer = response.choices[0].message.content.strip()
         print("✅ GPT Answer:", answer)
-    except Exception as e:
-        print("❌ OpenAI Error:", e)
-        answer = "Sorry, I'm having trouble answering right now."
-
-    if answer == "I'm not sure about that. Let me connect you with a human agent.":
-        stop_reply_conversations.add(conversation_id)
-        print(f"🚫 Fallback answer, disabling AI for conversation {conversation_id}")
 
-    await send_chatwoot_message(conversation_id, answer)
+        # ✅ Extract and send token usage to Slack
+        usage = response.usage
+        if usage:
+            prompt_tokens = usage.prompt_tokens
+            completion_tokens = usage.completion_tokens
+            total_tokens = usage.total_tokens
+
+            slack_msg = (
+                f"📊 Token usage for conversation `{conversation_id}`:\n"
+                f"> Prompt: {prompt_tokens} tokens\n"
+                f"> Completion: {completion_tokens} tokens\n"
+                f"> Total: {total_tokens} tokens"
+            )
+            await send_to_slack(slack_msg)
+        else:
+            print("⚠️ No token usage info returned from API")
+            
+        except Exception as e:
+            print("❌ OpenAI Error:", e)
+            answer = "Sorry, I'm having trouble answering right now."
+    
+        if answer == "I'm not sure about that. Let me connect you with a human agent.":
+            stop_reply_conversations.add(conversation_id)
+            print(f"🚫 Fallback answer, disabling AI for conversation {conversation_id}")
+    
+        await send_chatwoot_message(conversation_id, answer)
 
     return {"status": "ok"}
 
+async def send_to_slack(message: str):
+    webhook_url = os.getenv("SLACK_WEBHOOK_URL")
+    if not webhook_url:
+        print("❌ SLACK_WEBHOOK_URL not set")
+        return
+
+    payload = {"text": message}
+
+    try:
+        async with httpx.AsyncClient() as http:
+            resp = await http.post(webhook_url, json=payload)
+            print("📨 Slack response:", resp.status_code, resp.text)
+    except Exception as e:
+        print("❌ Slack Send Error:", e)
 
 async def send_chatwoot_message(conversation_id: str, content: str):
     message_payload = {