Added filterMutationsToNode

Author: Josema

src/api/action.js

@@ -1,13 +1,13 @@
-dop.action = function(f) {
+dop.action = function(f, filterMutationsToNode) {
     dop.util.invariant(
         isFunction(f),
-        'dop.action only accept one argument as function'
+        'dop.action needs one argument as function'
     )
     return function() {
         var collectors = dop.data.collectors
         var collector = dop.core.createCollector(collectors, collectors.length)
         var output = f.apply(this, arguments)
-        collector.emit()
+        collector.emit(filterMutationsToNode)
         return output
     }
 }

src/core/constructors/collector.js

@@ -16,14 +16,16 @@ dop.core.collector.prototype.add = function(mutation) {
     return false
 }
 
-dop.core.collector.prototype.emit = function(shallWeEmitToNode) {
+dop.core.collector.prototype.emit = function(filterMutationsToNode) {
     this.destroy()
-    return this.emitWithoutDestroy(shallWeEmitToNode)
+    return this.emitWithoutDestroy(filterMutationsToNode)
 }
 
-dop.core.collector.prototype.emitWithoutDestroy = function(shallWeEmitToNode) {
+dop.core.collector.prototype.emitWithoutDestroy = function(
+    filterMutationsToNode
+) {
     var snapshot = new dop.core.snapshot(this.mutations)
-    snapshot.emit(shallWeEmitToNode)
+    snapshot.emit(filterMutationsToNode)
     this.mutations = []
     return snapshot
 }

src/core/constructors/snapshot.js

@@ -17,9 +17,9 @@ dop.core.snapshot.prototype.redo = function() {
     }
 }
 
-dop.core.snapshot.prototype.emit = function(shallWeEmitToNode) {
+dop.core.snapshot.prototype.emit = function(filterMutationsToNode) {
     if (this.mutations.length > 0) {
-        dop.core.emitToObservers(this, shallWeEmitToNode)
+        dop.core.emitToObservers(this, filterMutationsToNode)
     }
 }
 

src/core/objects/emitToObservers.js

@@ -1,4 +1,4 @@
-dop.core.emitToObservers = function(snapshot, shallWeEmitToNode) {
+dop.core.emitToObservers = function(snapshot, filterMutationsToNode) {
     var mutations = snapshot.mutations,
         mutation,
         path_id,
@@ -75,7 +75,7 @@ dop.core.emitToObservers = function(snapshot, shallWeEmitToNode) {
             // We need to make sure that the observer still exists, because maybe has been removed after calling previous observers
             observer.callback(
                 mutations_by_observers[observer_id],
-                shallWeEmitToNode
+                filterMutationsToNode
             )
     }
 

src/core/protocol/registerSubscriber.js

@@ -1,11 +1,18 @@
 dop.core.registerSubscriber = function(node, object, object_path_id) {
-    var observer = dop.createObserver(function(mutations, shallWeEmitToNode) {
+    var observer = dop.createObserver(function(
+        mutations,
+        filterMutationsToNode
+    ) {
+        if (typeof filterMutationsToNode == 'function')
+            mutations = filterMutationsToNode(mutations, node)
+
         var object_id,
             chunks,
             patch = dop.core.getPatch(mutations)
         for (object_id in patch) {
             chunks = patch[object_id].chunks
             dop.protocol.patch(node, object_path_id, chunks, subscriber)
+            return
         }
     })
     var subscriber = {