chore: wrap list of tasks in promise.all

Author: achingbrain

package.json

@@ -48,7 +48,7 @@
     "benchmark": "^2.1.4",
     "chai": "^4.2.0",
     "dirty-chai": "^2.0.1",
-    "ipfs-repo": "ipfs/js-ipfs-repo#blockstore-accept-async-iterator",
+    "ipfs-repo": "^0.28.0",
     "libp2p": "^0.26.1",
     "libp2p-kad-dht": "^0.16.0",
     "libp2p-mplex": "^0.8.0",

src/decision-engine/index.js

@@ -82,7 +82,8 @@ class DecisionEngine {
     const groupedTasks = groupBy(task => task.target.toB58String(), tasks)
 
     const blocks = await Promise.all(uniqCids.map(cid => this.blockstore.get(cid)))
-    await Object.values(groupedTasks).map(async (tasks) => {
+
+    await Promise.all(Object.values(groupedTasks).map(async (tasks) => {
       // all tasks in the group have the same target
       const peer = tasks[0].target
       const blockList = cids.map((cid) => blocks.find(b => b.cid.equals(cid)))
@@ -97,7 +98,7 @@ class DecisionEngine {
       for (const block of blockList) {
         this.messageSent(peer, block)
       }
-    })
+    }))
 
     this._tasks = []
   }