cala-ledger 0.15.9

An embeddable double sided accounting ledger built on PG/SQLx
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
37
38
39
40
41
42
43
44
45
46
47

use cala_types::outbox::OutboxEventPayload;
use es_entity::clock::ClockHandle;

use super::ObixOutbox;

#[derive(Debug, Clone)]
pub struct OutboxPublisher {
    inner: ObixOutbox,
}

impl OutboxPublisher {
    pub async fn init(pool: &sqlx::PgPool, clock: &ClockHandle) -> Result<Self, sqlx::Error> {
        let config = obix::MailboxConfig::builder()
            .clock(clock.clone())
            .build()
            .expect("MailboxConfig");
        let outbox = ObixOutbox::init(pool, config).await?;
        Ok(Self { inner: outbox })
    }

    pub async fn publish_entity_events<Entity, Event>(
        &self,
        op: &mut impl es_entity::AtomicOperation,
        _: Entity,
        new_events: es_entity::LastPersisted<'_, Event>,
    ) -> Result<(), sqlx::Error>
    where
        Event: es_entity::EsEvent,
        for<'a> &'a Event: Into<OutboxEventPayload>,
    {
        self.inner
            .publish_all_persisted(op, new_events.map(|e| &e.event))
            .await
    }

    pub async fn publish_all(
        &self,
        op: &mut impl es_entity::AtomicOperation,
        events: impl Iterator<Item = OutboxEventPayload>,
    ) -> Result<(), sqlx::Error> {
        self.inner.publish_all_persisted(op, events).await
    }

    pub fn inner(&self) -> &ObixOutbox {
        &self.inner
    }
}