Webhook Best Practices

@app.post("/webhooks")
async def handle_webhook(request):
    raw_body = await request.body()
    verify_signature(raw_body, request.headers)

    event = json.loads(raw_body)
    await event_store.save(event)
    background_tasks.add_task(process_event, event)

    return {"status": "received"}

def process_event(event):
    event_id = event["id"]

    if is_already_processed(event_id):
        return

    handle_event(event)
    mark_as_processed(event_id)

from datetime import datetime


def handle_payout_event(event):
    payout = event["data"]
    current = db.get_payout(payout["id"])

    if current and datetime.fromisoformat(current["updated"]) > datetime.fromisoformat(payout["updated"]):
        return

    db.update_payout(payout["id"], payout)

ngrok http 8000