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

simplify testhelper

Browse Source
This commit is contained in:
Kevin Jahns 2022-04-20 18:01:33 +02:00
parent 71fad52854
commit 14c14de21e
1 changed files with 3 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
tests/testHelper.js
View File

@ -5,6 +5,7 @@ import * as encoding from 'lib0/encoding'
import * as decoding from 'lib0/decoding' import * as decoding from 'lib0/decoding'
import * as syncProtocol from 'y-protocols/sync' import * as syncProtocol from 'y-protocols/sync'
import * as object from 'lib0/object' import * as object from 'lib0/object'
import * as map from 'lib0/map'
import * as Y from '../src/index.js' import * as Y from '../src/index.js'
export * from '../src/index.js' export * from '../src/index.js'
@ -89,8 +90,8 @@ export class TestYInstance extends Y.Doc {
const encoder = encoding.createEncoder() const encoder = encoding.createEncoder()
syncProtocol.writeUpdate(encoder, update) syncProtocol.writeUpdate(encoder, update)
broadcastMessage(this, encoding.toUint8Array(encoder)) broadcastMessage(this, encoding.toUint8Array(encoder))
this.updates.push(update)
} }
this.updates.push(update)
}) })
this.connect() this.connect()
} }
@ -133,12 +134,7 @@ export class TestYInstance extends Y.Doc {
* @param {TestYInstance} remoteClient * @param {TestYInstance} remoteClient
*/ */
_receive (message, remoteClient) { _receive (message, remoteClient) {
let messages = this.receiving.get(remoteClient) map.setIfUndefined(this.receiving, remoteClient, () => []).push(message)
if (messages === undefined) {
messages = []
this.receiving.set(remoteClient, messages)
}
messages.push(message)
} }
} }
@ -202,17 +198,6 @@ export class TestConnector {
// send reply message // send reply message
sender._receive(encoding.toUint8Array(encoder), receiver) sender._receive(encoding.toUint8Array(encoder), receiver)
} }
{
// If update message, add the received message to the list of received messages
const decoder = decoding.createDecoder(m)
const messageType = decoding.readVarUint(decoder)
switch (messageType) {
case syncProtocol.messageYjsUpdate:
case syncProtocol.messageYjsSyncStep2:
receiver.updates.push(decoding.readVarUint8Array(decoder))
break
}
}
return true return true
} }
return false return false