rocket-webhook 0.1.0-alpha.2

Webhook validation for Rocket applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

#![allow(unused)]

//! Stripe webhook example. You can test this locally with the Stripe CLI:
//!
//! ```stripe listen -f http://localhost:8000/api/webhook/stripe```
//! ```STRIPE_SECRET=xxxxx cargo run --features stripe --example stripe```

use std::env;

use rocket::{launch, post, routes, serde::json::Value};
use rocket_webhook::{RocketWebhook, WebhookPayload, webhooks::built_in::StripeWebhook};
use serde::Deserialize;

#[launch]
fn rocket() -> _ {
    let webhook_secret = env::var("STRIPE_SECRET").expect("Env var STRIPE_SECRET is not set");
    let webhook = RocketWebhook::builder()
        .webhook(StripeWebhook::with_secret(webhook_secret))
        .max_body_size(10 * 1024)
        .build();

    rocket::build()
        .manage(webhook)
        .mount("/api", routes![stripe_endpoint])
}

#[derive(Debug, Deserialize)]
pub struct StripeEvent {
    data: Value,
    #[serde(rename = "type")]
    type_: String,
}

#[post("/webhook/stripe", data = "<payload>")]
async fn stripe_endpoint(payload: WebhookPayload<'_, StripeEvent, StripeWebhook>) {
    rocket::info!("Received event type: {:?}", payload.data.type_);
}