Update main.py

main.py

@@ -1,14 +1,19 @@
+import os
+import requests
 from fastapi import FastAPI, Request
 from datetime import datetime, timezone, timedelta
 
 app = FastAPI()
 
+# Load Supabase environment variables
+SUPABASE_URL = os.getenv("SUPABASE_URL")
+SUPABASE_API_KEY = os.getenv("SUPABASE_API_KEY")
+
 @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
@@ -24,33 +29,75 @@ async def receive_webhook(request: Request):
 
     # 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')}")
-        
+        lead_id = entry.get('id')
+        campaign_id = entry.get('campaign_id')
+        campaign_name = entry.get('campaign_name')
+        adset_id = entry.get('adgroup_id')
+        adset_name = entry.get('adgroup_name')
+        ad_id = entry.get('ad_id')
+        ad_name = entry.get('ad_name')
+        advertiser_id = entry.get('advertiser_id')
         create_ts = entry.get('create_time')
-        print(f"Create Time (Unix): {create_ts}")
+
+        print(f"Lead ID: {lead_id}")
+        print(f"Campaign ID: {campaign_id}")
+        print(f"Campaign Name: {campaign_name}")
+        print(f"Ad Group ID: {adset_id}")
+        print(f"Ad Group Name: {adset_name}")
+        print(f"Ad ID: {ad_id}")
+        print(f"Ad Name: {ad_name}")
         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}")
+            formatted_create_time = datetime.fromtimestamp(create_ts, gmt_plus_3).isoformat()
+            print(f"Create Time: {formatted_create_time}")
         except Exception:
-            print("Create Time (Formatted): Invalid timestamp")
+            formatted_create_time = None
+            print("Create Time: Invalid")
 
-        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
+        # Extract lead fields
+        field_map = {}
         for change in entry.get('changes', []):
-            print(f"{change.get('field').capitalize()}: {change.get('value')}")
+            field = change.get('field')
+            value = change.get('value')
+            field_map[field] = value
+            print(f"{field}: {value}")
+
         print("----")
 
+        # Prepare data for Supabase insertion
+        insert_data = {
+            "platform": "tiktok",
+            "campaign_id": campaign_id,
+            "campaign_name": campaign_name,
+            "adset_id": adset_id,
+            "adset_name": adset_name,
+            "ad_id": ad_id,
+            "lead_id": lead_id,
+            "full_name": field_map.get("full_name"),
+            "email": field_map.get("email"),
+            "phone": field_map.get("phone_number"),
+            "city": field_map.get("city"),
+            "lead_timestamp": formatted_create_time
+        }
+
+        headers = {
+            "apikey": SUPABASE_API_KEY,
+            "Authorization": f"Bearer {SUPABASE_API_KEY}",
+            "Content-Type": "application/json"
+        }
+
+        supa_resp = requests.post(
+            f"{SUPABASE_URL}/rest/v1/binrushdleads",
+            headers=headers,
+            json=insert_data
+        )
+
+        print("💾 Supabase insert status:", supa_resp.status_code)
+        if supa_resp.status_code == 201:
+            print("✅ Lead inserted successfully.")
+        else:
+            try:
+                print("❌ Supabase Error:", supa_resp.json())
+            except Exception:
+                print("❌ Supabase Response:", supa_resp.text)
+
     return {"status": "ok"}