fix: snapshots handled by record handler even if they exist locally

deepstreamIO · May 29, 2017 · 6e2bdf0 · 6e2bdf0
1 parent 5b04616
commit 6e2bdf0
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/record/record-handler.js b/src/record/record-handler.js
@@ -355,19 +355,21 @@ 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]))
 
   } else if (message.action === C.ACTIONS.HAS && this._hasRegistry.hasRequest(name)) {
     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)