Outbox — `nestrs-outbox`

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

use nestrs::outbox::{OutboxModule, OutboxOptions, OutboxRelay};
use std::sync::Arc;

#[module(
    imports = [OutboxModule::register(OutboxOptions::default())],
    providers = [OrdersService],
)]
struct AppModule;

#[injectable]
struct OrdersService {
    outbox: Arc<OutboxRelay>,
}

use nestrs::outbox::PublishFn;
use serde_json::json;
use std::sync::Arc;

async fn after_commit(relay: Arc<OutboxRelay>) {
    relay.add("order.created", json!({ "id": 1 })).await;

    let publish: PublishFn = Arc::new(|topic, payload| {
        Box::pin(async move {
            // HTTP / NATS / queue publish
            println!("{topic}: {payload}");
            Ok(())
        })
    });

    relay.tick(&publish).await; // claim batch, publish, mark or DLQ
}