feat: events based on PouchDB’s .changes()

BREAKING CHANGE:

Before, change events (incl. add, update, remove) have only been triggered when using the custom APIs like `.add()` or `.update()`. Now they get always triggered, including for changes replicated into the database.

helpers/find-or-add-many.js

@@ -1,7 +1,6 @@
 var toId = require('../utils/to-id')
 var findMany = require('./find-many')
 var addMany = require('./add-many')
-var eventify = require('./eventify')
 
 module.exports = function findOrAddMany (state, passedObjects) {
   var self = this
@@ -22,7 +21,7 @@ module.exports = function findOrAddMany (state, passedObjects) {
     }, [])
 
     if (state) {
-      return eventify(self, state, addMany)(notFoundObjects)
+      return addMany.call(self, notFoundObjects)
     }
 
     return addMany.call(self, notFoundObjects)

helpers/find-or-add-one.js

@@ -6,7 +6,6 @@ var Promise = require('lie')
 var toId = require('../utils/to-id')
 var findOne = require('./find-one')
 var addOne = require('./add-one')
-var eventify = require('./eventify')
 
 function findOrAddOne (state, idOrObject, newObject) {
   var self = this
@@ -30,7 +29,7 @@ function findOrAddOne (state, idOrObject, newObject) {
     }
 
     if (state) {
-      return eventify(self, state, addOne)(newObject)
+      return addOne.call(self, newObject)
     }
 
     return addOne.call(self, newObject)

helpers/start-listen-to-changes.js

@@ -0,0 +1,18 @@
+module.exports = startListenToChanges
+
+var toObject = require('../utils/to-object')
+
+function startListenToChanges (state) {
+  this.changes({
+    since: 'now',
+    live: true,
+    include_docs: true
+  })
+  .on('change', function (change) {
+    var doc = change.doc
+
+    var eventName = doc.deletedAt ? 'remove' : doc.updatedAt ? 'update' : 'add'
+    state.emitter.emit(eventName, toObject(doc))
+    state.emitter.emit('change', eventName, toObject(doc))
+  })
+}

index.js

@@ -3,25 +3,26 @@
 var exports = module.exports = { hoodieApi: hoodieApi }
 
 var EventEmitter = require('events').EventEmitter
-
-var eventify = require('./helpers/eventify')
+var startListenToChanges = require('./helpers/start-listen-to-changes')
 
 function hoodieApi (options) {
   var state = {
     emitter: options && options.emitter || new EventEmitter()
   }
 
+  state.emitter.once('newListener', startListenToChanges.bind(this, state))
+
   return {
     db: this,
-    add: eventify(this, state, require('./add')),
+    add: require('./add').bind(this),
     find: require('./find').bind(this),
     findAll: require('./find-all').bind(this),
-    findOrAdd: require('./lib/find-or-add-with-events').bind(this, state),
-    update: eventify(this, state, require('./update')),
-    updateOrAdd: eventify(this, state, require('./update-or-add')),
-    updateAll: eventify(this, state, require('./update-all')),
-    remove: eventify(this, state, require('./remove'), 'remove'),
-    removeAll: eventify(this, state, require('./remove-all'), 'remove'),
+    findOrAdd: require('./find-or-add').bind(this),
+    update: require('./update').bind(this),
+    updateOrAdd: require('./update-or-add').bind(this),
+    updateAll: require('./update-all').bind(this),
+    remove: require('./remove').bind(this),
+    removeAll: require('./remove-all').bind(this),
     on: require('./lib/on').bind(this, state),
     one: require('./lib/one').bind(this, state),
     off: require('./lib/off').bind(this, state),

utils/add-timestamps.js

@@ -3,8 +3,11 @@
 var now = require('./now')
 
 module.exports = function addTimestamps (object) {
-  object.updatedAt = now()
-  object.createdAt = object.createdAt || object.updatedAt
+  if (object.createdAt) {
+    object.updatedAt = now()
+  } else {
+    object.createdAt = now()
+  }
 
   if (object._deleted) {
     object.deletedAt = object.deletedAt || object.updatedAt