Struct Receiver 

pub struct Receiver { /* private fields */ }

Implementations

impl Receiver

pub fn new( gateway: Arc<dyn Gateway>, log: Arc<dyn WebhookLog>, handler: impl Fn(WebhookEvent) -> BoxFuture<Result<()>> + Send + Sync + 'static, ) -> Receiver

pub async fn deliver(&self, headers: &Headers, body: &[u8]) -> Handled

Process one delivery. Separated from the HTTP handler so it can be tested without a request, and so a replay tool can call it.

pub async fn handle(&self, request: Request) -> Response

The route handler: mount it at whatever path the gateway was given.

let receiver = Arc::new(Receiver::new(gateway, log, |event| Box::pin(async move { … })));
r.post("/webhooks/payment", move |req: Request| {
    let receiver = Arc::clone(&receiver);
    async move { receiver.handle(req).await }
});

Behind no CSRF and no session middleware: the caller is a server with a signature, and a CSRF check would refuse it every time.