Webhooks — `nestrs-webhooks`

[dependencies]
nestrs = { version = "1.7.1", features = ["webhooks"] } # implies outbox

use nestrs::webhooks::{WebhooksModule, WebhooksOptions, WebhooksService};
use std::sync::Arc;

#[module(
    imports = [WebhooksModule::register(WebhooksOptions::new("whsec_…"))],
    providers = [Hooks],
)]
struct AppModule;

#[injectable]
struct Hooks {
    webhooks: Arc<WebhooksService>,
}

impl Hooks {
    fn outbound(&self, body: &[u8]) -> String {
        let signed = self.webhooks.sign("msg_123", 1_700_000_000, body);
        signed.signature_header
    }

    fn inbound(&self, msg_id: &str, ts: &str, sig: &str, raw: &[u8]) {
        self.webhooks.verify(msg_id, ts, sig, raw).expect("valid");
    }
}

use nestrs::outbox::OutboxRelay;
use nestrs::webhooks::{WebhooksOptions, WebhooksService};
use serde_json::json;
use std::sync::Arc;

let outbox: Arc<OutboxRelay> = /* from OutboxModule */;
let hooks = WebhooksService::new("whsec_…", Some(outbox));
hooks
    .dispatch("invoice.paid", "https://partner.example/hooks", json!({ "id": 1 }))
    .await
    .unwrap();

use nestrs::webhooks::{sign_standard_webhook, verify_standard_webhook};

let signed = sign_standard_webhook("whsec_…", "msg_1", 1_700_000_000, body);
verify_standard_webhook(
    "whsec_…",
    "msg_1",
    &ts.to_string(),
    &signed.signature_header,
    body,
)?;