feat: accept async iterators into blockstore.putMany

.travis.yml

@@ -7,6 +7,7 @@ stages:
 
 node_js:
   - '10'
+  - '12'
 
 os:
   - linux
@@ -20,7 +21,6 @@ jobs:
   include:
     - stage: check
       script:
-        - npx aegir commitlint --travis
         - npx aegir dep-check
         - npm run lint
 

README.md

@@ -189,7 +189,7 @@ Get a value at the root of the repo.
 
 Put many blocks.
 
-* `block` should be an array of type [Block](https://github.com/ipfs/js-ipfs-block#readme).
+* `block` should be an Iterable or AsyncIterable that yields entries of type [Block](https://github.com/ipfs/js-ipfs-block#readme).
 
 #### `Promise<Buffer> repo.blocks.get (cid)`
 

src/blockstore.js

@@ -85,26 +85,21 @@ function createBaseStore (store) {
     /**
      * Like put, but for more.
      *
-     * @param {Array<Block>} blocks
+     * @param {AsyncIterable<Block>|Iterable<Block>} blocks
      * @returns {Promise<void>}
      */
     async putMany (blocks) {
-      const keys = blocks.map((b) => ({
-        key: cidToKey(b.cid),
-        block: b
-      }))
-
       const batch = store.batch()
 
-      await Promise.all(
-        keys.map(async k => {
-          if (await store.has(k.key)) {
-            return
-          }
+      for await (const block of blocks) {
+        const key = cidToKey(block.cid)
 
-          batch.put(k.key, k.block.data)
-        })
-      )
+        if (await store.has(key)) {
+          continue
+        }
+
+        batch.put(key, block.data)
+      }
 
       return batch.commit()
     },