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

fix logging message type

Browse Source
This commit is contained in:
Kevin Jahns 2017-07-27 14:49:36 +02:00
parent eb4fb3a225
commit 574f0c3269
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Connector.js
View File

@ -233,6 +233,9 @@ export default function extendConnector (Y/* :any */) {
let messageType = decoder.readVarString() let messageType = decoder.readVarString()
let senderConn = this.connections.get(sender) let senderConn = this.connections.get(sender)
this.log('%s: Receive \'%s\' from %s', this.userId, messageType, sender)
this.logMessage('Message: %Y', buffer)
if (senderConn == null) { if (senderConn == null) {
throw new Error('Received message from unknown peer!') throw new Error('Received message from unknown peer!')
} }
@ -265,9 +268,6 @@ export default function extendConnector (Y/* :any */) {
return return
} }
this.log('%s: Receive \'%s\' from %s', this.userId, messageType, sender)
this.logMessage('Message: %Y', buffer)
if (messageType === 'sync step 1' && (senderConn.auth === 'write' || senderConn.auth === 'read')) { if (messageType === 'sync step 1' && (senderConn.auth === 'write' || senderConn.auth === 'read')) {
// cannot wait for sync step 1 to finish, because we may wait for sync step 2 in sync step 1 (->lock) // cannot wait for sync step 1 to finish, because we may wait for sync step 2 in sync step 1 (->lock)
computeMessageSyncStep1(decoder, encoder, this, senderConn, sender) computeMessageSyncStep1(decoder, encoder, this, senderConn, sender)

1
src/MessageHandler.js
View File

@ -22,6 +22,7 @@ export function formatYjsMessage (buffer) {
export function formatYjsMessageType (buffer) { export function formatYjsMessageType (buffer) {
let decoder = new BinaryDecoder(buffer) let decoder = new BinaryDecoder(buffer)
decoder.readVarString() // roomname
return decoder.readVarString() return decoder.readVarString()
} }