vantage-table 3.2.0

Table, Column, and operation traits for the Vantage data framework
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

//! MockTableSource meets the write contract.

use serde_json::{Value, json};
use vantage_dataset::contract::{self, Fixture};
use vantage_expressions::{Expression, ExpressiveEnum};
use vantage_table::mocks::mock_table_source::MockTableSource;
use vantage_table::table::Table;
use vantage_types::EmptyEntity;

fn eq(col: &str, v: Value) -> Expression<Value> {
    Expression::new(
        "{} = {}",
        vec![
            ExpressiveEnum::Nested(Expression::new(col, vec![])),
            ExpressiveEnum::Nested(Expression::new("{}", vec![ExpressiveEnum::Scalar(v)])),
        ],
    )
}

async fn tables() -> (
    Table<MockTableSource, EmptyEntity>,
    Table<MockTableSource, EmptyEntity>,
) {
    let src = MockTableSource::new()
        .with_data(
            "item",
            vec![
                json!({"id": "in1", "name": "a", "parent": "p1"}),
                json!({"id": "out1", "name": "b", "parent": "p2"}),
            ],
        )
        .await;
    let all = Table::new("item", src.clone()).with_id_column("id");
    let set = all.clone().with_condition(eq("parent", json!("p1")));
    (all, set)
}

macro_rules! mock_check {
    ($name:ident, $check:path) => {
        #[tokio::test]
        async fn $name() {
            let (all, set) = tables().await;
            $check(&Fixture {
                all: &all,
                set: &set,
                id: |s| s.to_string(),
                text: |s| json!(s),
                detects_outside: true,
            })
            .await;
        }
    };
}

mock_check!(mock_contract_insert, contract::check_insert);
mock_check!(mock_contract_patch, contract::check_patch);
mock_check!(mock_contract_delete_all, contract::check_delete_all);

#[tokio::test]
async fn mock_refuses_conditions_it_cannot_check() {
    let (all, _) = tables().await;
    let set = all.with_condition(vantage_expressions::expr_any!("price > {}", 10));
    contract::check_refused(&set, |s| s.to_string(), |s| json!(s)).await;
}