![import { LoroDoc } from "loro-crdt";
import { schema, SyncDirection, Mirror } from "loro-mirror";
// 1) Declare state shape – a MovableList of todos with stable Container ID `$cid`
type TodoStatus = "todo" | "inProgress" | "done";
const appSchema = schema({
todos: schema.LoroMovableList(
schema.LoroMap({
text: schema.String(),
status: schema.String<TodoStatus>(),
}),
// $cid is the container ID of LoroMap assigned by Loro
(t) => t.$cid,
),
});
// 2) Create a Loro document and a Mirror store
const doc = new LoroDoc();
const store = new Mirror({
doc,
schema: appSchema,
// InitialState will not be written into LoroDoc
initialState: { todos: [] },
});
// 3) Subscribe (optional) – know whether updates came from local or remote
const unsubscribe = store.subscribe((state, { direction, tags }) => {
if (direction === SyncDirection.FROM_LORO) {
console.log("Remote update", { state, tags });
} else {
console.log("Local update", { state, tags](https://venexa.site/media/G1c2oSSaAAE4jgO.jpg)
ALT import { LoroDoc } from "loro-crdt"; import { schema, SyncDirection, Mirror } from "loro-mirror"; // 1) Declare state shape – a MovableList of todos with stable Container ID `$cid` type TodoStatus = "todo" | "inProgress" | "done"; const appSchema = schema({ todos: schema.LoroMovableList( schema.LoroMap({ text: schema.String(), status: schema.String<TodoStatus>(), }), // $cid is the container ID of LoroMap assigned by Loro (t) => t.$cid, ), }); // 2) Create a Loro document and a Mirror store const doc = new LoroDoc(); const store = new Mirror({ doc, schema: appSchema, // InitialState will not be written into LoroDoc initialState: { todos: [] }, }); // 3) Subscribe (optional) – know whether updates came from local or remote const unsubscribe = store.subscribe((state, { direction, tags }) => { if (direction === SyncDirection.FROM_LORO) { console.log("Remote update", { state, tags }); } else { console.log("Local update", { state, tags
ALT const doc = new LoroDoc(); doc.setPeerId(0); doc.subscribePreCommit((e) => { const changes = doc.exportJsonInIdSpan(e.changeMeta); expect(changes).toHaveLength(1); const hash = crypto.createHash("sha256"); const change = { ...changes[0], deps: changes[0].deps.map((d) => { const depChange = doc.getChangeAt(idStrToId(d)); return depChange.message; }), }; hash.update(JSON.stringify(change)); const sha256Hash = hash.digest("hex"); e.modifier.setMessage(sha256Hash); }); console.log(change); // The output is shown below doc.getList("list").insert(0, 100); doc.commit(); // Change 0 // { // id: '0@0', // timestamp: 0, // deps: [], // lamport: 0, // msg: undefined, // ops: [ // { // container: 'cid:root-list:List', // content: { type: 'insert', pos: 0, value: [100] }, // counter: 0 // } // ] // } doc.getList("list").insert(0, 200); doc.commit(); expect(doc.getChangeAt({ peer: "0", counter: 0 }).message) .toBe("2a