Update main.py

main.py

@@ -3,54 +3,47 @@ from datetime import datetime, timezone, timedelta
 
 app = FastAPI()
 
+@app.get("/webhook")
+async def verify_webhook(hub_mode: str = "", hub_verify_token: str = "", hub_challenge: str = ""):
+    VERIFY_TOKEN = "my_secure_token"  # Match this to your subscription
+    if hub_mode == "subscribe" and hub_verify_token == VERIFY_TOKEN:
+        return int(hub_challenge)
+    return {"status": "verification failed"}
+
 @app.post("/webhook")
 async def receive_webhook(request: Request):
     payload = await request.json()
     print("📥 Webhook received:")
 
-    # Define GMT+3 offset
     gmt_plus_3 = timezone(timedelta(hours=3))
 
-    # Top-level fields
-    print(f"Request ID: {payload.get('request_id')}")
     print(f"Object: {payload.get('object')}")
-    print(f"Time (Unix): {payload.get('time')}")
-    try:
-        formatted_time = datetime.fromtimestamp(payload.get('time'), gmt_plus_3).strftime('%Y-%m-%d %H:%M:%S GMT+3')
-        print(f"Time (Formatted): {formatted_time}")
-    except Exception:
-        print("Time (Formatted): Invalid timestamp")
     print("----")
 
-    # Loop through entries
     for entry in payload.get('entry', []):
-        print(f"Lead ID: {entry.get('id')}")
-        print(f"Page ID: {entry.get('page_id')}")
-        print(f"Page Name: {entry.get('page_name')}")
-        print(f"Campaign ID: {entry.get('campaign_id')}")
-        print(f"Campaign Name: {entry.get('campaign_name')}")
-        print(f"Ad Group ID: {entry.get('adgroup_id')}")
-        print(f"Ad Group Name: {entry.get('adgroup_name')}")
-        print(f"Ad ID: {entry.get('ad_id')}")
-        print(f"Ad Name: {entry.get('ad_name')}")
-        
-        create_ts = entry.get('create_time')
-        print(f"Create Time (Unix): {create_ts}")
-        try:
-            formatted_create_time = datetime.fromtimestamp(create_ts, gmt_plus_3).strftime('%Y-%m-%d %H:%M:%S GMT+3')
-            print(f"Create Time (Formatted): {formatted_create_time}")
-        except Exception:
-            print("Create Time (Formatted): Invalid timestamp")
-
-        print(f"Advertiser ID: {entry.get('advertiser_id')}")
-        print(f"Advertiser Name: {entry.get('advertiser_name')}")
-        print(f"Library ID: {entry.get('library_id')}")
-        print(f"Lead Source: {entry.get('lead_source')}")
-        print("----")
-
-        # Lead field values
-        for change in entry.get('changes', []):
-            print(f"{change.get('field').capitalize()}: {change.get('value')}")
-        print("----")
-
-    return {"status": "ok"}
+        entry_id = entry.get("id")
+        timestamp = entry.get("time")
+
+        print(f"📄 Entry ID (Page ID): {entry_id}")
+        if timestamp:
+            try:
+                formatted = datetime.fromtimestamp(timestamp, gmt_plus_3).strftime('%Y-%m-%d %H:%M:%S GMT+3')
+                print(f"🕒 Time: {formatted}")
+            except:
+                print(f"🕒 Time: {timestamp} (Invalid format)")
+
+        for change in entry.get("changes", []):
+            field = change.get("field")
+            value = change.get("value", {})
+
+            print(f"🔔 Change Field: {field}")
+            if field == "leadgen":
+                print("📌 Lead Details:")
+                print(f"• Lead ID: {value.get('leadgen_id')}")
+                print(f"• Form ID: {value.get('form_id')}")
+                print(f"• Ad ID: {value.get('ad_id')}")
+                print(f"• Page ID: {value.get('page_id')}")
+                print(f"• Created Time: {value.get('created_time')}")
+
+    print("----")
+    return {"status": "ok"}