Doubled fired events fix

poanetwork · Nov 20, 2018 · 22d40ab · 22d40ab
1 parent 03935e3
commit 22d40ab
Show file tree

Hide file tree

Showing 3 changed files with 277 additions and 285 deletions.
diff --git a/base-filter.js b/base-filter.js
@@ -1,4 +1,5 @@
 const SafeEventEmitter = require('safe-event-emitter')
+const deepEqual = require('fast-deep-equal')
 
 class BaseFilter extends SafeEventEmitter {
 
@@ -15,9 +16,16 @@ class BaseFilter extends SafeEventEmitter {
   }
 
   addResults (newResults) {
-    this.updates = this.updates.concat(newResults)
-    this.allResults = this.allResults.concat(newResults)
-    newResults.forEach(result => this.emit('update', result))
+    const newResultsFiltered = newResults.filter((newResult) => {
+      const emittedBefore = this.allResults.some((emiitedResult) => {
+        return deepEqual(emiitedResult, newResult)
+      })
+
+      return !emittedBefore
+    })
+    this.updates = this.updates.concat(newResultsFiltered)
+    this.allResults = this.allResults.concat(newResultsFiltered)
+    newResultsFiltered.forEach(result => this.emit('update', result))
   }
 
   addInitialResults (newResults) {