basiliq 0.1.2

REST API server exposing a Postgres database using JSON:API
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

use super::*;

async fn apply_migrations(pool: &mut sqlx::PgPool) {
    let mut conn = pool.acquire().await.unwrap();

    sqlx::query(
        r#"
		CREATE TABLE peoples(
			id			UUID PRIMARY KEY,
			name		TEXT NOT NULL
		);
	"#,
    )
    .execute(&mut *conn)
    .await
    .unwrap();
    sqlx::query(
        r#"
		CREATE TABLE movies(
			id			UUID PRIMARY KEY,
			title		TEXT NOT NULL
		);
		"#,
    )
    .execute(&mut *conn)
    .await
    .unwrap();
    sqlx::query(
        r#"
		CREATE TABLE movies_staff(
			id			UUID PRIMARY KEY,
			role		TEXT NOT NULL,
			person		UUID NOT NULL REFERENCES peoples(id) ON DELETE CASCADE,
			movies		UUID NOT NULL REFERENCES movies(id) ON DELETE CASCADE
		);
	"#,
    )
    .execute(&mut *conn)
    .await
    .unwrap();
}

#[basiliq_test]
async fn config_default(mut pool: sqlx::PgPool) {
    apply_migrations(&mut pool).await;
    let mut conn = pool.acquire().await.unwrap();
    let raw_table = BasiliqDbScannedTable::scan_db(&mut *conn).await.unwrap();
    let builder = BasiliqStoreBuilder::new(raw_table);
    let config = builder.gen_config();
    insta::assert_json_snapshot!(config);
}

#[basiliq_test]
async fn merging_some_informations_into_builder(mut pool: sqlx::PgPool) {
    apply_migrations(&mut pool).await;
    let mut conn = pool.acquire().await.unwrap();
    let raw_table = BasiliqDbScannedTable::scan_db(&mut *conn).await.unwrap();
    let mut builder = BasiliqStoreBuilder::new(raw_table);
    let mut config = builder.gen_config();
    config
        .resources_mut()
        .remove_entry("public__movies")
        .and_then(|(_k, v)| {
            config
                .resources_mut()
                .insert("court_metrage".to_string(), v)
        }); // Rename "public__movies" to court_metrage
    config
        .resources_mut()
        .remove_entry("public__peoples")
        .and_then(|(_k, v)| config.resources_mut().insert("employee".to_string(), v)); // Rename "public__peoples" to "employee"
    config
        .resources_mut()
        .remove_entry("public__movies_staff")
        .and_then(|(_k, v)| config.resources_mut().insert("movies_staff".to_string(), v)); // Rename "public__movies_staff" to "movies_staff"
    config
        .resources_mut()
        .get_mut("court_metrage")
        .and_then(|v| {
            v.relationships_mut()
                .remove_entry("peoples")
                .and_then(|(_k, v2)| {
                    v.relationships_mut()
                        .insert(ArcStr::from("participant"), v2)
                })
        }); // Rename the "peoples" relationships in "court_metrage" to "participant"
    if let Some(v) = config.resources_mut().get_mut("movies_staff") {
        *v.enabled_mut() = false; // Disable direct access to the relationships "movies_staff"
    }
    config.resources_mut().get_mut("employee").and_then(|v| {
        v.relationships_mut().get_mut("movies_staff").map(|v2| {
            *v2.enabled_mut() = false;
        })
    }); // Disable accessing to "movies_staff" table through "employee"
    builder.basiliq_config_merge(&config).unwrap();
    insta::assert_json_snapshot!(builder.config());
}