fix: do not write blocks we already have (#3801)

We had this filter previously, it got removed somewhere.

Author: achingbrain

packages/ipfs-core/package.json

@@ -87,6 +87,7 @@
     "is-ipfs": "^6.0.1",
     "it-all": "^1.0.4",
     "it-drain": "^1.0.3",
+    "it-filter": "^1.0.2",
     "it-first": "^1.0.4",
     "it-last": "^1.0.4",
     "it-map": "^1.0.4",

packages/ipfs-core/src/block-storage.js

@@ -3,6 +3,7 @@
 const { BlockstoreAdapter } = require('interface-blockstore')
 const merge = require('it-merge')
 const pushable = require('it-pushable')
+const filter = require('it-filter')
 
 /**
  * @typedef {import('interface-blockstore').Blockstore} Blockstore
@@ -55,6 +56,10 @@ class BlockStorage extends BlockstoreAdapter {
    * @param {AbortOptions} [options]
    */
   async put (cid, block, options = {}) {
+    if (await this.has(cid)) {
+      return
+    }
+
     if (this.bitswap.isStarted()) {
       await this.bitswap.put(cid, block, options)
     } else {
@@ -69,10 +74,12 @@ class BlockStorage extends BlockstoreAdapter {
    * @param {AbortOptions} [options]
    */
   async * putMany (blocks, options = {}) {
+    const missingBlocks = filter(blocks, async ({ key }) => { return !(await this.has(key)) })
+
     if (this.bitswap.isStarted()) {
-      yield * this.bitswap.putMany(blocks, options)
+      yield * this.bitswap.putMany(missingBlocks, options)
     } else {
-      yield * this.child.putMany(blocks, options)
+      yield * this.child.putMany(missingBlocks, options)
     }
   }