Merge pull request cayasso#62 from will123195/patch-2

Fix circular dependency
aestetype · Mar 16, 2018 · e5b6281 · e5b6281
2 parents cb8f124 + 70b1e51
commit e5b6281
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/filter.js b/src/filter.js
@@ -2,7 +2,12 @@
 
 const Emitter = require('eventemitter3')
 const dbg = require('debug')
-const { events } = require('./')
+
+const events = {
+  i: 'insert',
+  u: 'update',
+  d: 'delete'
+}
 
 function regex(pattern) {
   pattern = pattern || '*'
@@ -21,7 +26,9 @@ module.exports = (ns, oplog) => {
     if (!re.test(doc.ns) || filter.ignore) return
     debug('incoming data %j', doc)
     filter.emit('op', doc)
-    filter.emit(events[doc.op], doc)
+    if (events[doc.op]) {
+      filter.emit(events[doc.op], doc)
+    }
   }
 
   function destroy() {