bft-crdt-experiment/side-node/tests/crdt.rs

use bft_crdt_derive::add_crdt_fields;
use bft_json_crdt::json_crdt::{BaseCrdt, CrdtNode, IntoCrdtNode};
use bft_json_crdt::op::ROOT_ID;
use bft_json_crdt::{keypair::make_keypair, list_crdt::ListCrdt};

#[add_crdt_fields]
#[derive(Clone, CrdtNode)]
struct ListExample {
    list: ListCrdt<char>,
}

// case 1 - send valid updates
#[test]
fn test_valid_updates() {
    // Insert to crdt.doc on local node, test applying the same operation to a remote node
    // and check that the view is the same
    let keypair1 = make_keypair();
    let mut crdt1 = BaseCrdt::<ListExample>::new(&keypair1);
    let _a = crdt1.doc.list.insert(ROOT_ID, 'a').sign(&keypair1);
    let _b = crdt1.doc.list.insert(_a.id(), 'b').sign(&keypair1);
    let _c = crdt1.doc.list.insert(_b.id(), 'c').sign(&keypair1);

    assert_eq!(crdt1.doc.list.view(), vec!['a', 'b', 'c']);

    let keypair2 = make_keypair();
    let mut crdt2 = BaseCrdt::<ListExample>::new(&keypair2);
    crdt2.apply(_a.clone());
    crdt2.apply(_b);
    crdt2.apply(_c.clone());

    assert_eq!(
        crdt2.doc.list.view(),
        crdt1.doc.list.view(),
        "views should be equal"
    );

    crdt2.apply(_a.clone());
    crdt2.apply(_a);

    assert_eq!(
        crdt1.doc.list.view(),
        crdt2.doc.list.view(),
        "views are still equal after repeated applies"
    );
}