Update main.py

main.py

@@ -15,6 +15,10 @@ app = FastAPI()
 NOTION_SECRET = os.getenv("NOTION_SECRET", "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")
 NOTION_VERSION = "2025-09-03"
 NOTION_DRIVE_PROP_ID = os.getenv("NOTION_DRIVE_PROP_ID", "EFoh")  # ID بتاع حقل Google Drive Link
+NOTION_TARGET_DATABASE_ID = os.getenv(
+    "NOTION_TARGET_DATABASE_ID",
+    "8ad05d66-3b83-4102-ac37-1e3e35dd10a7"  # الداتابيز اللي عايزين نشتغل عليها بس
+)
 
 # ===== Google Drive Config =====
 GOOGLE_CREDENTIALS = os.getenv("GOOGLE_CREDENTIALS")  # JSON string للـ service account
@@ -518,35 +522,50 @@ async def webhook(request: Request):
     event_type = body.get("type")
     page_id = body.get("entity", {}).get("id")
     timestamp = body.get("timestamp")
+    parent = body.get("data", {}).get("parent", {})
+    parent_db_id = None
+    if parent.get("type") == "database":
+        parent_db_id = parent.get("id")
+
+    print(f"[DEBUG] Parent database id: {parent_db_id}")
 
     print("\n===== NEW WEBHOOK EVENT =====")
     print("Raw body:", body)
 
     if event_type == "page.created":
-        title = await get_page_title(page_id)
-
-        print(f"Event Type : {event_type}")
-        print(f"Page Title : {title}")
-        print(f"Page ID    : {page_id}")
-        print(f"Timestamp  : {timestamp}")
-
-        # تشيك الأول: هل الصفحة دي Archived (زي لما تدوس Escape على placeholder)؟
-        archived = await is_block_archived(page_id)
-        if archived:
-            print(f"[TEMPLATE] Page {page_id} is archived right after creation. Skipping template & drive.")
-        else:
-            # 1) نطبّق التمبلت
-            try:
-                await apply_template_to_page(page_id)
-            except Exception as e:
-                print("[ERROR] While applying template:", e)
-
-            # 2) ننشئ فولدر على الدرايف باسم الصفحة ونحط اللينك في النوشن
-            try:
-                drive_link = ensure_drive_folder_for_page(title or page_id)
-                await update_page_drive_link(page_id, drive_link)
-            except Exception as e:
-                print("[ERROR] While creating drive folder or updating Notion URL:", e)
+    # لو الحدث مش جاي من الداتابيز اللي احنا مستهدفينها -> تجاهل
+    if parent_db_id != NOTION_TARGET_DATABASE_ID:
+        print(
+            f"[SKIP] Page {page_id} is in database {parent_db_id}, "
+            f"not target {NOTION_TARGET_DATABASE_ID}. Skipping template & drive."
+        )
+        print("================================\n")
+        return {"status": "ignored"}
+
+    title = await get_page_title(page_id)
+
+    print(f"Event Type : {event_type}")
+    print(f"Page Title : {title}")
+    print(f"Page ID    : {page_id}")
+    print(f"Timestamp  : {timestamp}")
+
+    # تشيك الأول: هل الصفحة دي Archived (زي لما تدوس Escape على placeholder)؟
+    archived = await is_block_archived(page_id)
+    if archived:
+        print(f"[TEMPLATE] Page {page_id} is archived right after creation. Skipping template & drive.")
+    else:
+        # 1) نطبّق التمبلت
+        try:
+            await apply_template_to_page(page_id)
+        except Exception as e:
+            print("[ERROR] While applying template:", e)
+
+        # 2) ننشئ فولدر على الدرايف باسم الصفحة ونحط اللينك في النوشن
+        try:
+            drive_link = ensure_drive_folder_for_page(title or page_id)
+            await update_page_drive_link(page_id, drive_link)
+        except Exception as e:
+            print("[ERROR] While creating drive folder or updating Notion URL:", e)
 
     elif event_type == "page.deleted":
         print(f"Page deleted. ID: {page_id}, Timestamp: {timestamp}")