Last active
July 14, 2023 20:11
-
-
Save stephen/779254766d463283a5f82065a077b8fd to your computer and use it in GitHub Desktop.
same as https://gist.github.com/stephen/5aeac63971520dca4473b5b15f2c42e6, but shows that mangled text doc has bad changes
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
const odiff = require("odiff"); | |
/** | |
* changeText uses odiff to write a minimal string diff to an automerge.Text. | |
*/ | |
const changeText = (base, newValue) => { | |
const diff = odiff([...base.toString()], [...newValue]); | |
for (const patch of diff) { | |
switch (patch.type) { | |
case "add": | |
base?.insertAt(patch.index, ...patch.vals); | |
break; | |
case "rm": | |
base?.deleteAt(patch.index, patch.num); | |
break; | |
case "set": | |
base?.set(patch.path[0], patch.val); | |
break; | |
default: | |
throw new Error(`unexpected unset patch in text diff: ${patch}`); | |
} | |
} | |
}; | |
function verify(doc) { | |
Automerge.load(Automerge.save(doc)); | |
} | |
const Automerge = require("@automerge/automerge"); | |
// Make a doc and make some changes... | |
let original = Automerge.from({ t: new Automerge.Text("") }); | |
original = Automerge.change(original, (doc) => | |
changeText(doc.t, `Billy Wald "You’re great"`) | |
); | |
original = Automerge.change(original, (doc) => changeText(doc.t, `Unknown`)); | |
original = Automerge.change(original, (doc) => | |
changeText(doc.t, `billy culinary dropout`) | |
); | |
// Case 1: original output (ok) | |
// Output: | |
// original: billy culinary dropout | |
console.log("original:", original.t.toString()); | |
try { | |
verify(original); | |
} catch (err) { | |
console.log("verification failed"); | |
} | |
// Case 2: using applyChanges (fails) | |
const changes = Automerge.getAllChanges(original); | |
const [replayed] = Automerge.applyChanges(Automerge.init(), changes); | |
// Output: | |
// replayed: billy culiknary dropowt | |
console.log("replayed using applyChanges:", replayed.t.toString()); | |
try { | |
verify(replayed); | |
} catch (err) { | |
console.log("verification failed"); | |
} | |
// Case 3: using loadIncremental (fails) | |
let incrementalReplay = Automerge.init(); | |
for (const change of changes) { | |
incrementalReplay = Automerge.loadIncremental(incrementalReplay, change); | |
} | |
console.log("replayed using loadIncremental:", incrementalReplay.t.toString()); | |
try { | |
verify(incrementalReplay); | |
} catch (err) { | |
console.log("verification failed"); | |
} | |
// Case 4: using sync (fails) | |
let msg; | |
let peerASync = Automerge.initSyncState(); | |
let peerBSync = Automerge.initSyncState(); | |
let peerA = Automerge.clone(original); | |
let peerB = Automerge.init(); | |
do { | |
if (msg) { | |
[peerA, peerASync, msg] = Automerge.receiveSyncMessage( | |
peerA, | |
peerASync, | |
msg | |
); | |
} | |
[peerASync, msg] = Automerge.generateSyncMessage(peerA, peerASync); | |
if (!msg) { | |
break; | |
} | |
[peerB, peerBSync] = Automerge.receiveSyncMessage(peerB, peerBSync, msg); | |
[peerBSync, msg] = Automerge.generateSyncMessage(peerB, peerBSync); | |
} while (msg); | |
console.log("replayed using sync:", peerB.t.toString()); | |
try { | |
verify(peerB); | |
} catch (err) { | |
console.log("verification failed"); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment