loro 1.12.0

Loro is a high-performance CRDTs framework. Make your app collaborative efforlessly.
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

#![allow(unexpected_cfgs)]
#![allow(deprecated)]

use loro::{ExportMode, LoroDoc, LoroError, ToJson};
use serde_json::json;
use tracing::debug_span;

#[ctor::ctor]
fn init() {
    dev_utils::setup_test_log();
}

#[test]
fn conflict_moves() -> Result<(), LoroError> {
    let doc1 = LoroDoc::new();
    doc1.set_peer_id(1)?;
    let list1 = doc1.get_movable_list("list");
    list1.insert(0, 1)?;
    list1.insert(1, 2)?;
    list1.insert(2, 3)?;
    assert_eq!(
        doc1.get_deep_value().to_json_value(),
        json!({
            "list": [1, 2, 3]
        })
    );

    // 0@1, 1@1, 2@1
    let doc2 = LoroDoc::new();
    let updates = doc1.export(ExportMode::all_updates()).unwrap();
    doc2.import(&updates)?;
    doc2.set_peer_id(2)?;
    let list2 = doc2.get_movable_list("list");
    // [0@1], 1@1, 2@1, 3@1
    list1.mov(0, 2)?;
    list1.log_internal_state();
    // [0@1], 1@1, 0@2, 2@1
    list2.mov(0, 1)?;
    list2.log_internal_state();
    debug_span!("doc1 import").in_scope(|| {
        let updates = doc2.export(ExportMode::all_updates()).unwrap();
        doc1.import(&updates).unwrap();
    });
    debug_span!("doc2 import").in_scope(|| {
        let updates = doc1.export(ExportMode::all_updates()).unwrap();
        doc2.import(&updates).unwrap();
    });
    // [0@1], 1@1, 0@2, 2@1, 3@1
    //   -     2    1    3   (1)
    list1.log_internal_state();
    list2.log_internal_state();
    assert_eq!(doc1.get_deep_value(), doc2.get_deep_value());
    assert_eq!(
        doc1.get_deep_value().to_json_value(),
        json!({
            "list": [2, 1, 3]
        })
    );

    Ok(())
}