Update app.py

app.py

@@ -11,6 +11,7 @@ from dotenv import load_dotenv
 import os
 from starlette.websockets import WebSocketState
 from jose import JWTError
+import httpx 
 
 load_dotenv()
 
@@ -103,9 +104,29 @@ def get_current_user(token: str = Depends(OAuth2PasswordRequestForm)):
 async def submit_query(name: str = Form(...), email: str = Form(...), message: str = Form(...)):
     query = {"name": name, "email": email, "message": message, "created_at": datetime.utcnow()}
     result = collection.insert_one(query)
+
+    DISCORD_WEBHOOK_URL = os.environ.get("DISCORD_WEBHOOK_URL")  # Add to .env
+
+    async def send_discord_notification(data: dict):
+        content = (
+            f"📩 **New Quotation Received**\n"
+            f"👤 **Name:** {data['name']}\n"
+            f"📧 **Email:** {data['email']}\n"
+            f"💬 **Message:** {data['message']}\n"
+            f"🕒 **Time:** {datetime.utcnow().strftime('%Y-%m-%d %H:%M UTC')}"
+        )
+        async with httpx.AsyncClient() as client:
+            await client.post(DISCORD_WEBHOOK_URL, json={"content": content})
+
     query["_id"] = str(result.inserted_id)
 
     total_count = collection.count_documents({})
+
+    try:
+        await send_discord_notification(query)
+    except Exception as e:
+        print("[Discord Notification Failed]", e)
+
     await manager.broadcast({
         "event": "new_quote",
         "data": {