From 574f0c3269f20232d10b4d0393fef9331141985e Mon Sep 17 00:00:00 2001 From: Kevin Jahns Date: Thu, 27 Jul 2017 14:49:36 +0200 Subject: [PATCH] fix logging message type --- src/Connector.js | 6 +++--- src/MessageHandler.js | 1 + 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/Connector.js b/src/Connector.js index c2c58994..2e65103c 100644 --- a/src/Connector.js +++ b/src/Connector.js @@ -233,6 +233,9 @@ export default function extendConnector (Y/* :any */) { let messageType = decoder.readVarString() 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) { throw new Error('Received message from unknown peer!') } @@ -265,9 +268,6 @@ export default function extendConnector (Y/* :any */) { 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')) { // 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) diff --git a/src/MessageHandler.js b/src/MessageHandler.js index 0e9105fc..0081d759 100644 --- a/src/MessageHandler.js +++ b/src/MessageHandler.js @@ -22,6 +22,7 @@ export function formatYjsMessage (buffer) { export function formatYjsMessageType (buffer) { let decoder = new BinaryDecoder(buffer) + decoder.readVarString() // roomname return decoder.readVarString() }