Update main.py

main.py

@@ -1,20 +1,60 @@
 # main.py
+import os
+import httpx
 from fastapi import FastAPI, Request
 
 app = FastAPI()
 
+NOTION_SECRET = os.getenv("NOTION_SECRET")  # ضع secret هنا أو كمتغير بيئة
+NOTION_VERSION = "2022-06-28"
+
+
+async def get_page_title(page_id: str) -> str:
+    """Fetch page title from Notion."""
+    async with httpx.AsyncClient() as client:
+        res = await client.get(
+            f"https://api.notion.com/v1/pages/{page_id}",
+            headers={
+                "Authorization": f"Bearer {NOTION_SECRET}",
+                "Notion-Version": NOTION_VERSION,
+            },
+        )
+
+    data = res.json()
+
+    # نجيب الـ Title من الـ property الخاص بالاسم
+    props = data.get("properties", {})
+    for prop in props.values():
+        if prop.get("type") == "title":
+            title_items = prop.get("title", [])
+            if len(title_items) > 0:
+                return title_items[0].get("plain_text", "")
+
+    return "(No Title)"
+
+
 @app.post("/webhook")
 async def webhook(request: Request):
-    # جرّب تقرأ البودي كـ JSON
-    try:
-        data = await request.json()
-    except Exception:
-        # لو مش JSON هنقراه كنص عادي
-        data = await request.body()
-        data = data.decode("utf-8")
-
-    print("===== NEW REQUEST =====")
-    print(data)          # يطبع اللي وصله
-    print("======================")
-
-    return {"status": "ok", "received": data}
+    body = await request.json()
+
+    event_type = body.get("type")
+    page_id = body.get("entity", {}).get("id")
+    timestamp = body.get("timestamp")
+
+    print("\n===== NEW WEBHOOK EVENT =====")
+
+    # لو الحدث page.created أو page.deleted
+    if event_type in ["page.created", "page.deleted"]:
+        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}")
+
+    else:
+        print("Event received but ignored:", event_type)
+
+    print("================================\n")
+
+    return {"status": "ok"}