rillflow 0.1.0-alpha.8

Rillflow — a lightweight document + event store for Rust, powered by Postgres.
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

use anyhow::Result;
use rillflow::Store;
use serde_json::json;
use testcontainers::{
    GenericImage, ImageExt,
    core::{IntoContainerPort, WaitFor},
    runners::AsyncRunner,
};
use uuid::Uuid;

#[tokio::test]
async fn patch_single_and_multiple_fields() -> Result<()> {
    let image = GenericImage::new("postgres", "16-alpine")
        .with_exposed_port(5432.tcp())
        .with_wait_for(WaitFor::message_on_stderr(
            "database system is ready to accept connections",
        ))
        .with_env_var("POSTGRES_USER", "postgres")
        .with_env_var("POSTGRES_PASSWORD", "postgres");
    let container = image.start().await?;
    let host = container.get_host().await?;
    let port = container.get_host_port_ipv4(5432).await?;
    let url = format!("postgres://postgres:postgres@{host}:{port}/postgres?sslmode=disable");

    let store = Store::connect(&url).await?;
    rillflow::testing::migrate_core_schema(store.pool()).await?;

    let id = Uuid::new_v4();
    let v1 = store
        .docs()
        .put(&id, &json!({"profile": {"name": "Alice", "age": 30}}), None)
        .await?;
    assert_eq!(v1, 1);

    // single field patch
    let v2 = store
        .docs()
        .patch(&id, Some(1), "profile.name", &json!("Alicia"))
        .await?;
    assert_eq!(v2, 2);
    let (doc, ver) = store.docs().get::<serde_json::Value>(&id).await?.unwrap();
    assert_eq!(doc["profile"]["name"], "Alicia");
    assert_eq!(ver, 2);

    // multi-field patch
    let v3 = store
        .docs()
        .patch_fields(
            &id,
            Some(2),
            &[("profile.age", json!(31)), ("extra.flag", json!(true))],
        )
        .await?;
    assert_eq!(v3, 3);
    let (doc2, ver2) = store.docs().get::<serde_json::Value>(&id).await?.unwrap();
    assert_eq!(doc2["profile"]["age"], 31);
    assert_eq!(doc2["extra"]["flag"], true);
    assert_eq!(ver2, 3);

    Ok(())
}