use ruststream::memory::prelude::*;
use serde::{Deserialize, Serialize};
#[derive(Debug, PartialEq, Deserialize, Serialize, Outgoing)]
#[outgoing(name = "orders.placed")]
struct Order {
id: u64,
customer: String,
}
#[subscriber("orders.placed")]
async fn accept(order: &Order) -> HandlerOutcome {
tracing::info!(order = order.id, customer = %order.customer, "order accepted");
HandlerOutcome::ack()
}
#[ruststream::app]
fn app() -> impl App {
RustStream::new(AppInfo::new("shop", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
b.include(accept);
})
}
#[cfg(test)]
mod tests {
use std::error::Error;
use ruststream::memory::prelude::*;
use ruststream::testing::TestApp;
use super::{Order, app};
#[tokio::test]
async fn a_placed_order_is_accepted() -> Result<(), Box<dyn Error>> {
let tb = TestApp::start(app()).await?;
let order = Order {
id: 7,
customer: "ada@example.com".to_owned(),
};
tb.message(&order).publish().await?;
tb.broker::<MemoryBroker>()
.subscriber("orders.placed")
.assert_called_once()
.with(&order)
.settled(HandlerOutcome::ack());
Ok(())
}
}