Update main.py

main.py

@@ -1,12 +1,13 @@
 from fastapi import FastAPI, Request
 from fastapi.responses import PlainTextResponse
 from datetime import datetime, timezone, timedelta
+import requests
 
 app = FastAPI()
 
 VERIFY_TOKEN = "my_secure_token"
+PAGE_ACCESS_TOKEN = "EAAJGMsgQEhMBO3RPgdfKCwDGrmiQCZBZADpRZCqqYyxRkKjr0lZCQk3NfNY6qARDSWpjAVgnwJnHEgZAnp5QNKnoNgZCIFi6g149ZBU02TfKXil2P690Q1ZC0fn8jGQYew8MZB62zUIOed9jG9Li4tmpnZBddZBvyLyRlJH6EqvyYA9Bg03HGyMU0UzKZAA6Aexc5H8tWPrNZBE0wkxF2qT0CWxsZD"  # Replace with your actual Page Token
 
-# Verification (GET)
 @app.get("/webhook")
 async def verify_webhook(request: Request):
     params = request.query_params
@@ -18,16 +19,35 @@ async def verify_webhook(request: Request):
         return PlainTextResponse(content=challenge)
     return PlainTextResponse(content="Verification failed", status_code=403)
 
-# Lead delivery (POST)
+
 @app.post("/webhook")
-async def receive_lead(request: Request):
+async def receive_webhook(request: Request):
     payload = await request.json()
     print("📥 Webhook payload received:")
-
-    # Print with timestamps
+    
     gmt_plus_3 = timezone(timedelta(hours=3))
-    print("Timestamp:", datetime.now(gmt_plus_3).strftime("%Y-%m-%d %H:%M:%S"))
+    print("Timestamp:", datetime.now(gmt_plus_3).strftime('%Y-%m-%d %H:%M:%S'))
 
+    # Extract and print the payload
     print(payload)
 
+    try:
+        for entry in payload.get("entry", []):
+            for change in entry.get("changes", []):
+                if change.get("field") == "leadgen":
+                    lead_id = change["value"]["leadgen_id"]
+                    print(f"🔍 Lead ID: {lead_id}")
+
+                    # Fetch lead details from Graph API
+                    url = f"https://graph.facebook.com/v18.0/{lead_id}"
+                    params = {"access_token": PAGE_ACCESS_TOKEN}
+                    lead_resp = requests.get(url, params=params)
+                    lead_data = lead_resp.json()
+
+                    print("📄 Lead Details:")
+                    print(lead_data)
+
+    except Exception as e:
+        print(f"⚠️ Error processing lead: {e}")
+
     return {"status": "ok"}