From 6e2bdf0122a63b5f2e4d9e11eac597b1dd9449b3 Mon Sep 17 00:00:00 2001 From: Alex Harley Date: Mon, 29 May 2017 15:47:11 +0200 Subject: [PATCH] fix: snapshots handled by record handler even if they exist locally --- src/record/record-handler.js | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/record/record-handler.js b/src/record/record-handler.js index 0642d98db..eef760798 100644 --- a/src/record/record-handler.js +++ b/src/record/record-handler.js @@ -355,11 +355,13 @@ RecordHandler.prototype._$handle = function (message) { let processed = false - if (this._records[name]) { + const record = this._records[name] + if (record) { processed = true - this._records[name]._$onMessage(message) + record._$onMessage(message) + } - } else if (message.action === C.ACTIONS.READ && this._snapshotRegistry.hasRequest(name)) { + if (message.action === C.ACTIONS.READ && this._snapshotRegistry.hasRequest(name)) { processed = true this._snapshotRegistry.recieve(name, null, JSON.parse(message.data[2])) @@ -367,7 +369,7 @@ RecordHandler.prototype._$handle = function (message) { processed = true this._hasRegistry.recieve(name, null, messageParser.convertTyped(message.data[1])) - } else if (message.action === C.ACTIONS.WRITE_ACKNOWLEDGEMENT) { + } else if (message.action === C.ACTIONS.WRITE_ACKNOWLEDGEMENT && !record) { processed = true Record._handleWriteAcknowledgements(message, this._writeCallbacks[name], this._client)