pgdo-lib 0.5.7

The convenience of SQLite – but with PostgreSQL (Library package)
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

use pgdo::cluster::Cluster;
use pgdo::coordinate::CoordinateError;
use pgdo::coordinate::{run_and_destroy, run_and_stop, run_and_stop_if_exists};
use pgdo::{lock, runtime};
use pgdo_test::for_all_runtimes;

type TestResult<T = ()> = Result<T, Box<dyn std::error::Error>>;

#[for_all_runtimes]
#[test]
fn run_and_stop_leaves_the_cluster_in_place() -> TestResult {
    let (setup, lock) = Setup::run(runtime)?;
    let databases = run_and_stop(&setup.cluster, &[], lock, || setup.cluster.databases())??;
    assert!(!databases.is_empty());
    assert!(!setup.cluster.running()?);
    assert!(setup.datadir.exists());
    Ok(())
}

#[for_all_runtimes]
#[test]
fn run_and_stop_if_exists_leaves_the_cluster_in_place() -> TestResult {
    let (setup, lock) = Setup::run(runtime)?;
    setup.cluster.create()?;
    let databases = run_and_stop(&setup.cluster, &[], lock, || setup.cluster.databases())??;
    assert!(!databases.is_empty());
    assert!(!setup.cluster.running()?);
    assert!(setup.datadir.exists());
    Ok(())
}

#[for_all_runtimes]
#[test]
fn run_and_stop_if_exists_returns_error_if_cluster_does_not_exist() -> TestResult {
    let (setup, lock) = Setup::run(runtime)?;
    assert!(matches!(
        run_and_stop_if_exists(&setup.cluster, &[], lock, || setup.cluster.databases()),
        Err(CoordinateError::DoesNotExist)
    ));
    Ok(())
}

#[for_all_runtimes]
#[test]
fn run_and_destroy_removes_the_cluster() -> TestResult {
    let (setup, lock) = Setup::run(runtime)?;
    let databases = run_and_destroy(&setup.cluster, &[], lock, || setup.cluster.databases())??;
    assert!(!databases.is_empty());
    assert!(!setup.cluster.running()?);
    assert!(!setup.datadir.exists());
    Ok(())
}

#[allow(unused)]
struct Setup {
    tempdir: tempfile::TempDir,
    datadir: std::path::PathBuf,
    cluster: Cluster,
}

impl Setup {
    fn run<S: Into<runtime::strategy::Strategy>>(
        strategy: S,
    ) -> TestResult<(Self, lock::UnlockedFile)> {
        let tempdir = tempfile::tempdir()?;
        let datadir = tempdir.path().join("data");
        let cluster = Cluster::new(&datadir, strategy)?;
        let lockpath = tempdir.path().join("lock");
        Ok((
            Self { tempdir, datadir, cluster },
            lock::UnlockedFile::try_from(&lockpath)?,
        ))
    }
}