loro/crates/loro-internal/examples/event.rs

use std::sync::Arc;

use loro_common::ContainerType;
use loro_internal::{
    delta::DeltaItem,
    event::Diff,
    handler::{Handler, ValueOrContainer},
    LoroDoc, ToJson,
};

fn main() {
    let mut doc = LoroDoc::new();
    doc.start_auto_commit();
    let list = doc.get_list("list");
    doc.subscribe_root(Arc::new(|e| match &e.container.diff {
        Diff::List(list) => {
            for item in list.iter() {
                if let DeltaItem::Insert {
                    insert,
                    attributes: _,
                } = item
                {
                    for v in insert {
                        match v {
                            ValueOrContainer::Container(h) => {
                                // You can directly obtain the handler and perform some operations.
                                if matches!(h, Handler::Map(_)) {
                                    let text = h
                                        .as_map()
                                        .unwrap()
                                        .insert_container("text", ContainerType::Text)
                                        .unwrap();
                                    text.as_text()
                                        .unwrap()
                                        .insert(0, "created from event")
                                        .unwrap();
                                }
                            }
                            ValueOrContainer::Value(value) => {
                                println!("insert value {:?}", value);
                            }
                        }
                    }
                }
            }
        }
        Diff::Map(map) => {
            println!("map container updates {:?}", map.updated);
        }
        _ => {}
    }));
    list.insert(0, "abc").unwrap();
    list.insert_container(1, ContainerType::List).unwrap();
    list.insert_container(2, ContainerType::Map).unwrap();
    list.insert_container(3, ContainerType::Text).unwrap();
    list.insert_container(4, ContainerType::Tree).unwrap();
    doc.commit_then_renew();
    assert_eq!(
        doc.get_deep_value().to_json(),
        r#"{"list":["abc",[],{"text":"created from event"},"",[]]}"#
    );
}