fixed sse update stream for non $set updates

agco · Sep 19, 2017 · ba97a56 · ba97a56
1 parent ec6032b
commit ba97a56
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/adapters/mongodb/sse/index.js b/lib/adapters/mongodb/sse/index.js
@@ -161,7 +161,7 @@ module.exports = function (mongodbOplogUrl, options) {
                 data = deserialize(chunk.o)
                 break
             case 'u' :
-                data = dot.object(chunk.o.$set);
+                data = dot.object(chunk.o.$set || {});
                 if (!data.id && chunk.o2 && chunk.o2._id) {
                     data.id = chunk.o2._id
                 }

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "hapi-harvester",
-  "version": "0.5.4",
+  "version": "0.5.5",
   "description": "Harvester Hapi Plugin",
   "main": "index.js",
   "scripts": {