Webhook Events

{
  "id": "evt_1234567890abcdef",
  "type": "payout.completed",
  "created": "2024-01-15T10:00:00Z",
  "data": {
    // Event-specific data
  }
}

{
  "id": "evt_123",
  "type": "account.created",
  "created": "2024-01-15T10:00:00Z",
  "data": {
    "id": "acc_1234567890abcdef",
    "customer_id": "cus_1234567890abcdef",
    "status": "active",
    "created": "2024-01-15T10:00:00Z"
  }
}

{
  "id": "evt_456",
  "type": "payout.created",
  "created": "2024-01-15T10:00:00Z",
  "data": {
    "id": "pout_1234567890abcdef",
    "account_id": "acc_1234567890abcdef",
    "beneficiary_id": "ben_1234567890abcdef",
    "amount": "100.00",
    "currency": "USD",
    "status": "pending",
    "created": "2024-01-15T10:00:00Z"
  }
}

{
  "id": "evt_789",
  "type": "payout.completed",
  "created": "2024-01-17T09:30:00Z",
  "data": {
    "id": "pout_1234567890abcdef",
    "account_id": "acc_1234567890abcdef",
    "amount": "100.00",
    "currency": "USD",
    "status": "completed",
    "completed_at": "2024-01-17T09:30:00Z"
  }
}

{
  "id": "evt_101",
  "type": "payout.failed",
  "created": "2024-01-17T10:00:00Z",
  "data": {
    "id": "pout_1234567890abcdef",
    "status": "failed",
    "error": {
      "code": "insufficient_funds",
      "message": "Insufficient balance"
    }
  }
}

{
  "id": "evt_202",
  "type": "payin.completed",
  "created": "2024-01-15T10:05:00Z",
  "data": {
    "id": "pin_1234567890abcdef",
    "account_id": "acc_1234567890abcdef",
    "amount": "1000.00",
    "currency": "USD",
    "status": "completed",
    "payment_method": "virtual_account",
    "completed_at": "2024-01-15T10:05:00Z"
  }
}

{
  "id": "evt_303",
  "type": "fx.trade.completed",
  "created": "2024-01-15T10:00:30Z",
  "data": {
    "id": "fxt_1234567890abcdef",
    "account_id": "acc_1234567890abcdef",
    "from_currency": "USD",
    "to_currency": "EUR",
    "source_amount": "1000.00",
    "target_amount": "920.50",
    "exchange_rate": "0.9205"
  }
}

create_webhook_endpoint(
    customer_id="cus_123",
    url="https://api.example.com/webhooks",
    events=[
        "payout.created",
        "payout.completed",
        "payout.failed",
        "payin.completed"
    ]
)

def handle_webhook(event):
    # Check if already processed
    if is_event_processed(event["id"]):
        return {"status": "already_processed"}

    # Process event
    process_event(event)

    # Mark as processed
    mark_event_processed(event["id"])

    return {"status": "success"}

def process_payout_event(event):
    payout_id = event["data"]["id"]
    event_time = event["created"]

    # Check if this is the latest event for this payout
    if is_newer_event_exists(payout_id, event_time):
        return  # Skip outdated event

    # Process the event
    update_payout_status(payout_id, event["data"]["status"])

@app.post("/webhooks")
async def handle_webhook(request):
    # Verify signature first
    verify_webhook_signature(request)

    # Queue for async processing
    event = await request.json()
    queue.enqueue(process_webhook_event, event)

    # Return 200 immediately
    return {"status": "received"}

def process_webhook_event(event):
    # Process event asynchronously
    # Handle errors, retries, etc.
    pass

# Create test payout to trigger webhook
payout = create_payout(
    account_id="acc_test_123",
    beneficiary_id="ben_test_456",
    amount="10.00",
    currency="USD"
)

# This will trigger:
# 1. payout.created event
# 2. payout.processing event
# 3. payout.completed event (in test mode)