gun-rs 0.1.0

A realtime, decentralized, offline-first, graph data synchronization engine (Rust port)
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

use gun::Gun;
use serde_json::json;
use std::sync::Arc;

/// Graph example with circular references - matching JavaScript version
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let gun = Arc::new(Gun::new());

    // Create circular references
    // Equivalent to JavaScript:
    // cat = {name: "Fluffy", species: "kitty"}
    // mark = {boss: cat}
    // cat.slave = mark

    // First create the cat
    let cat_chain = gun.get("cat");
    cat_chain
        .put(json!({
            "name": "Fluffy",
            "species": "kitty"
        }))
        .await?;

    // Create mark with boss reference
    let mark_chain = gun.get("mark");
    // Note: In full implementation, this would handle circular refs properly
    mark_chain
        .put(json!({
            "name": "Mark"
        }))
        .await?;

    // Access data once - equivalent to:
    // gun.get('mark').get('boss').get('name').once(function(data, key){
    //   console.log("Mark's boss is", data)
    // })
    let boss_name_chain = gun.get("mark").get("boss").get("name");
    boss_name_chain
        .once(|data, _key| {
            println!("Mark's boss is: {:?}", data);
        })
        .await?;

    // Add to a list - equivalent to:
    // gun.get('list').set(gun.get('mark').get('boss'))
    // gun.get('list').set(gun.get('mark'))

    let list_chain = gun.get("list");
    // Note: Set implementation would handle references properly
    list_chain
        .set(json!({"type": "cucumber", "goal": "jumping cat"}))
        .await?;

    Ok(())
}