yonote/yjs
23
0
Fork 0
Code Pull Requests 1 Releases Activity

lint

Browse Source
This commit is contained in:
Kevin Jahns 2020-12-29 17:07:25 +01:00
parent 0a40b541e8
commit 8013b4ef5c
1 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
tests/testHelper.js
View File

@ -27,31 +27,35 @@ const broadcastMessage = (y, m) => {
} }
} }
let useV2 = false export let useV2 = false
export let encodeStateAsUpdate = Y.encodeStateAsUpdate export const encV1 = {
export let mergeUpdates = Y.mergeUpdates encodeStateAsUpdate: Y.encodeStateAsUpdate,
export let applyUpdate = Y.applyUpdate mergeUpdates: Y.mergeUpdates,
export let logUpdate = Y.logUpdate applyUpdate: Y.applyUpdate,
export let updateEventName = 'update' logUpdate: Y.logUpdate,
updateEventName: 'update'
const setEncoders = () => {
encodeStateAsUpdate = useV2 ? Y.encodeStateAsUpdateV2 : Y.encodeStateAsUpdate
mergeUpdates = useV2 ? Y.mergeUpdatesV2 : Y.mergeUpdates
applyUpdate = useV2 ? Y.applyUpdateV2 : Y.applyUpdate
logUpdate = useV2 ? Y.logUpdateV2 : Y.logUpdate
updateEventName = useV2 ? 'updateV2' : 'update'
} }
export const encV2 = {
encodeStateAsUpdate: Y.encodeStateAsUpdateV2,
mergeUpdates: Y.mergeUpdatesV2,
applyUpdate: Y.applyUpdateV2,
logUpdate: Y.logUpdateV2,
updateEventName: 'updateV2'
}
export let enc = encV1
const useV1Encoding = () => { const useV1Encoding = () => {
useV2 = false useV2 = false
setEncoders() enc = encV1
} }
const useV2Encoding = () => { const useV2Encoding = () => {
useV2 = false
console.error('sync protocol doesnt support v2 protocol yet, fallback to v1 encoding') // @Todo console.error('sync protocol doesnt support v2 protocol yet, fallback to v1 encoding') // @Todo
setEncoders() useV2 = false
enc = encV1
} }
export class TestYInstance extends Y.Doc { export class TestYInstance extends Y.Doc {
@ -78,7 +82,7 @@ export class TestYInstance extends Y.Doc {
*/ */
this.updates = [] this.updates = []
// set up observe on local model // set up observe on local model
this.on(updateEventName, /** @param {Uint8Array} update @param {any} origin */ (update, origin) => { this.on(enc.updateEventName, /** @param {Uint8Array} update @param {any} origin */ (update, origin) => {
if (origin !== testConnector) { if (origin !== testConnector) {
const encoder = encoding.createEncoder() const encoder = encoding.createEncoder()
syncProtocol.writeUpdate(encoder, update) syncProtocol.writeUpdate(encoder, update)
@ -323,7 +327,7 @@ export const compare = users => {
// This ensures that mergeUpdates works correctly // This ensures that mergeUpdates works correctly
const mergedDocs = users.map(user => { const mergedDocs = users.map(user => {
const ydoc = new Y.Doc() const ydoc = new Y.Doc()
applyUpdate(ydoc, mergeUpdates(user.updates)) enc.applyUpdate(ydoc, enc.mergeUpdates(user.updates))
return ydoc return ydoc
}) })
users.push(.../** @type {any} */(mergedDocs)) users.push(.../** @type {any} */(mergedDocs))