tablo-core 0.10.0

The core toolkit types for Tablo, a server-rendered admin toolkit on Topcoat and Toasty.
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
53
54
55
56
57

use std::sync::{
    Arc,
    atomic::{AtomicUsize, Ordering},
};

use topcoat::context::Cx;

use super::*;
use crate::test_support::tableless_db;

/// A counter, and work that bumps it.
fn counter() -> (Arc<AtomicUsize>, impl FnOnce() + Send + 'static) {
    let count = Arc::new(AtomicUsize::new(0));
    let bump = Arc::clone(&count);
    (count, move || {
        bump.fetch_add(1, Ordering::SeqCst);
    })
}

/// Work queued on a write runs once it commits, and is dropped with a write that rolls back.
#[tokio::test]
async fn queued_work_runs_on_commit_and_never_on_rollback() {
    let mut db = tableless_db(toasty::models!()).await;
    let cx = Cx::default();

    let (committed, bump) = counter();
    let tx = WriteTx::begin(&cx, &mut db).await.unwrap();
    assert!(after_write_commits(cx.id(), bump).is_ok());
    assert_eq!(committed.load(Ordering::SeqCst), 0, "not before the commit");
    tx.commit().await.unwrap();
    assert_eq!(committed.load(Ordering::SeqCst), 1);

    let (rolled_back, bump) = counter();
    let tx = WriteTx::begin(&cx, &mut db).await.unwrap();
    assert!(after_write_commits(cx.id(), bump).is_ok());
    drop(tx);
    assert_eq!(rolled_back.load(Ordering::SeqCst), 0);

    let (_, bump) = counter();
    assert!(
        after_write_commits(cx.id(), bump).is_err(),
        "with no write open the work comes back"
    );
}

/// Another request's write leaves this one free to take a connection.
#[tokio::test]
async fn the_guard_holds_only_for_the_request_that_opened_the_write() {
    let mut db = tableless_db(toasty::models!()).await;
    let (writing, other) = (Cx::default(), Cx::default());
    let _tx = WriteTx::begin(&writing, &mut db).await.unwrap();

    assert!(no_write_open(other.id(), "db(cx)").is_ok());
    assert!(no_write_open(writing.id(), "db(cx)").is_err());
    let (_, bump) = counter();
    assert!(after_write_commits(other.id(), bump).is_err());
}