app.py

# from fastapi import FastAPI, Query, HTTPException
import hmac
import hashlib

from fastapi import FastAPI, Header, HTTPException, Request, Query
from typing import Optional

app = FastAPI()

VERIFY_TOKEN = "lintasmediadanawa"  # Replace with your actual verify token

@app.get("/webhooks")
async def handle_webhook(
    hub_mode: str = Query(..., alias="hub.mode"),
    hub_challenge: int = Query(..., alias="hub.challenge"),
    hub_verify_token: str = Query(..., alias="hub.verify_token")
):
    if hub_mode == "subscribe" and hub_verify_token == VERIFY_TOKEN:
        return int(hub_challenge)
    else:
        raise HTTPException(status_code=403, detail="Verification failed")



# @app.post("/webhooks")
# async def handle_event_notifications(
#     request: Request,
#     x_hub_signature_256: Optional[str] = Header(None)  # Header for signature verification
# ):
#     # # Read and verify the request body
#     # body = await request.body()

#     # # Verify the X-Hub-Signature-256 header
#     # if not x_hub_signature_256:
#     #     raise HTTPException(status_code=400, detail="Missing X-Hub-Signature-256 header")
    
#     # # Compute the expected signature
#     # expected_signature = (
#     #     "sha256="
#     #     + hmac.new(VERIFY_TOKEN.encode(), body, hashlib.sha256).hexdigest()
#     # )

#     # if not hmac.compare_digest(expected_signature, x_hub_signature_256):
#     #     raise HTTPException(status_code=403, detail="Signature verification failed")
#     print("POST SUCCESS!", request)
#     # Parse the JSON payload
#     payload = await request.json()
#     print("POST SUCCESS!", request)
#     print(payload)
#     object_type = payload.get("object")
#     entries = payload.get("entry", [])

#     # Log the received event (or process as needed)
#     for entry in entries:
#         changes = entry.get("changes", [])
#         for change in changes:
#             field = change.get("field")
#             value = change.get("value")
#             # Handle specific fields or values as required
#             print(f"Received change for field: {field}, value: {value}")

#     # Return a 200 OK response to acknowledge receipt
#     return {"status": "ok"}



@app.post("/webhooks")
async def get_all_params(request: Request):
    print("POST GET ALL PARAMS!")
    # Get headers
    headers = dict(request.headers)

    # Get query parameters
    query_params = dict(request.query_params)

    # Get the body (as JSON or raw data)
    try:
        body = await request.json()  # Parse JSON if possible
    except Exception:
        body = await request.body()  # Fall back to raw body if not JSON

    # Combine all details
    all_params = {
        "headers": headers,
        "query_params": query_params,
        "body": body,
    }

    # Log the params (optional)
    print(all_params)

    return all_params