Update main.py

main.py

@@ -15,6 +15,7 @@ GAS_WEBAPP_URL = os.getenv("GAS_WEBAPP_URL")
 APP_ID = os.getenv("APP_ID")
 APP_SECRET = os.getenv("APP_SECRET")
 REDIRECT_URI = os.getenv("REDIRECT_URI")
+BINRUSHD_AD_ACCOUNT_ID = os.getenv("BINRUSHD_AD_ACCOUNT_ID") or os.getenv("binrushd_ad_account_id")
 
 @app.get("/webhook")
 async def verify_webhook(request: Request):
@@ -69,6 +70,14 @@ async def receive_webhook(request: Request):
 
                     print("RAW GAS RESPONSE:", data)
 
+                    # ✅ التحقق من مطابقة الحساب الإعلاني (Binrushd Ad Account)
+                    ad_account_id = str(data.get("ad_account_id") or "").replace("act_", "").strip()
+                    expected_ad_account = str(BINRUSHD_AD_ACCOUNT_ID or "").replace("act_", "").strip()
+
+                    if expected_ad_account and ad_account_id != expected_ad_account:
+                        print(f"⏭️ Skipping lead {lead_id}: Ad Account ID '{ad_account_id}' does not match Binrushd Ad Account '{expected_ad_account}'.")
+                        continue
+
                     field_map = {}
                     for item in data.get("field_data", []):
                         field_map[item.get("name")] = ", ".join(item.get("values", []))
@@ -103,4 +112,4 @@ async def receive_webhook(request: Request):
     except Exception as e:
         print(f"⚠️ Error processing lead: {e}")
 
-    return {"status": "ok"}
+    return {"status": "ok"}