- crash solution for threaded queries

Author: anonymoussprocket

conseilUtil.js

@@ -276,14 +276,21 @@ const getArtisticUniverse = async (max_time) => {
     const objectQueries = queryChunks.map(c => makeObjectQuery(c))
 
     let universe = []
-    await Promise.all(objectQueries.map(async (q) => await conseiljs.TezosConseilClient.getTezosEntityData({ url: conseilServer, apiKey: conseilApiKey, network: 'mainnet' }, 'mainnet', 'big_map_contents', q)
-        .then(result => result.map(row => {
-            const objectId = row['value'].toString().replace(/^Pair ([0-9]{1,}) .*/, '$1')
-            const objectUrl = row['value'].toString().replace(/.* 0x([0-9a-z]{1,}) \}$/, '$1')
-            const ipfsHash = Buffer.from(objectUrl, 'hex').toString().slice(7);
-
-            universe.push({ objectId, ipfsHash, minter: artistMap[objectId], swaps: swapMap[objectId] !== undefined ? swapMap[objectId] : []})
-    }))))
+    await Promise.all(
+        objectQueries.map(async (q) =>  {
+            const r = []
+            try {
+                r = await conseiljs.TezosConseilClient.getTezosEntityData({ url: conseilServer, apiKey: conseilApiKey, network: 'mainnet' }, 'mainnet', 'big_map_contents', q)
+                    .then(result => result.map(row => {
+                        const objectId = row['value'].toString().replace(/^Pair ([0-9]{1,}) .*/, '$1')
+                        const objectUrl = row['value'].toString().replace(/.* 0x([0-9a-z]{1,}) \}$/, '$1')
+                        const ipfsHash = Buffer.from(objectUrl, 'hex').toString().slice(7);
+
+                    universe.push({ objectId, ipfsHash, minter: artistMap[objectId], swaps: swapMap[objectId] !== undefined ? swapMap[objectId] : []})
+                    })) // NOTE: it's a work in progress, this will drop failed requests and return a smaller set than expected
+            } finally {
+                return r
+            }}))
 
     return universe
 }