distributed 4.3.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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

//! Outbox lookup helpers over the public `OutboxStore` surface, shared across
//! test targets via `#[path = "../support/outbox.rs"]`.
#![allow(dead_code)] // each including target uses a subset

use distributed::{OutboxMessage, OutboxMessageStatus, OutboxStore};

/// Find an outbox message by id by scanning every status bucket — the only
/// by-id lookup the public store surface offers.
pub async fn find_outbox_by_id<S>(outbox: &S, id: &str) -> Option<OutboxMessage>
where
    S: OutboxStore + Send + Sync,
{
    for status in [
        OutboxMessageStatus::Pending,
        OutboxMessageStatus::InFlight,
        OutboxMessageStatus::Published,
        OutboxMessageStatus::Failed,
    ] {
        let messages = outbox
            .messages_by_status(status, usize::MAX)
            .await
            .expect("outbox status lookup should succeed");
        if let Some(message) = messages.into_iter().find(|message| message.id() == id) {
            return Some(message);
        }
    }
    None
}

/// The current status of the outbox message with `id`, if it is stored at all.
pub async fn outbox_status_by_id<S>(outbox: &S, id: &str) -> Option<OutboxMessageStatus>
where
    S: OutboxStore + Send + Sync,
{
    find_outbox_by_id(outbox, id).await.map(|m| m.status)
}