mongo-coll-watcher
Advanced tools
Comparing version 1.0.3 to 1.0.4
{ | ||
"name": "mongo-coll-watcher", | ||
"version": "1.0.3", | ||
"version": "1.0.4", | ||
"description": "mongodb change watcher using changes streams, having resumable capabilities.", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -35,7 +35,16 @@ const Log = require('lil-logger').getLogger(__filename); | ||
ns: { db, coll }, | ||
documentKey | ||
documentKey, | ||
updateDescription, | ||
fullDocument | ||
} = change; | ||
Log.debug({ msg: 'onchange, ns: ' + ns, arg1: change }); | ||
try { | ||
this.collListener({ dbName: db, collectionName: coll, type: operationType, id: documentKey }); | ||
this.collListener({ | ||
updateDescription, | ||
fullDocument, | ||
dbName: db, | ||
collectionName: coll, | ||
type: operationType, | ||
id: documentKey | ||
}); | ||
@@ -42,0 +51,0 @@ getCollection(resumeTokenColl) |
4674
90