reliar-store-postgres 0.9.0

PostgreSQL provider for the Reliar transactional outbox and inbox: migrations, migrate(), enqueue and the SKIP LOCKED claim.
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
48
49
50
51
52

//! `complete` increments `attempts` (it counts an observed outcome, the same as
//! `fail` does, ADR 0009); no existing test asserted this directly.

use crate::common;

use reliar_outbox::{AcquireRequest, OutboxStore, WorkerId};
use reliar_store_postgres::PostgresOutboxStore;

async fn complete_increments_attempts() {
    let pool = common::fresh_db().await;
    let store = PostgresOutboxStore::new(pool.clone());
    let envelopes = common::seed(&store, &pool, 1).await;
    let id = envelopes[0].id;

    let worker = WorkerId::generate();
    let batch = store
        .acquire(AcquireRequest::new(worker.clone()))
        .await
        .unwrap();
    let record = &batch.records[0];

    assert_eq!(
        record.attempts, 0,
        "claim itself never counts as an attempt"
    );

    let affected = store
        .complete(&worker, &[record.record_ref()])
        .await
        .unwrap();
    assert_eq!(affected, 1);

    let attempts: i32 = sqlx::query_scalar("SELECT attempts FROM outbox WHERE message_id = $1")
        .bind(id.as_uuid())
        .fetch_one(&pool)
        .await
        .unwrap();
    assert_eq!(
        attempts, 1,
        "complete must count as one observed publish attempt"
    );
}

pub(crate) fn trials(rt: &'static tokio::runtime::Runtime) -> Vec<libtest_mimic::Trial> {
    vec![libtest_mimic::Trial::test(
        "outbox_complete::complete_increments_attempts",
        move || {
            rt.block_on(complete_increments_attempts());
            Ok(())
        },
    )]
}