reliar-store-postgres 0.7.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

//! N8 — a serializer that rejects the body must fail `enqueue` as `EnqueueError::Serialize`
//! before any SQL runs (no partial/aborted `INSERT`), classified `Permanent` (the same body
//! serializes the same way every time) — the ordinary failure of the crate's one enqueue method,
//! not an unreachable variant (ADR 0036 amendment B, B.10).

use crate::common;

use crate::common::{AlwaysFailingSerializer, OrderCreated};
use reliar_core::{Classify, Envelope, FailureKind};
use reliar_outbox::OutboxEnqueue;
use reliar_store_postgres::{EnqueueError, PostgresOutboxSettings, PostgresOutboxStore};

async fn a_failing_serializer_yields_enqueue_error_serialize_before_touching_the_database() {
    let pool = common::fresh_db().await;
    let store = PostgresOutboxStore::connect(
        pool.clone(),
        PostgresOutboxSettings::default(),
        AlwaysFailingSerializer,
    )
    .await
    .unwrap();

    let envelope = Envelope::builder(OrderCreated { order_id: 1 }).build();
    let mut tx = pool.begin().await.unwrap();
    let err = store.enqueue_envelope(&mut tx, envelope).await.unwrap_err();

    assert!(matches!(err, EnqueueError::Serialize { .. }));
    assert_eq!(err.kind(), FailureKind::Permanent);
    // The transaction is still usable — nothing was sent to the database for this row, so it
    // was never aborted by a bad statement.
    tx.rollback().await.unwrap();

    let count: i64 = sqlx::query_scalar("SELECT count(*) FROM outbox")
        .fetch_one(&pool)
        .await
        .unwrap();
    assert_eq!(count, 0, "the rejected body must never reach the table");
}

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