we function

index.ts

@@ -1,5 +1,6 @@
 import fs from 'fs/promises';
 import _ from 'lodash';
+import Promise from 'bluebird';
 
 import discogsService from './src/discogs';
 
@@ -8,8 +9,7 @@ async function start() {
     const wants = JSON.parse(await fs.readFile('./data/margh.wantlist.json', { encoding: 'utf8' }))
     console.log('wants', wants.length);
 
-
+    return Promise.map(wants, async w => {
-    const listings = await Promise.all(wants.map(async w => {
             try {
                 const l = await discogs.listings(w.id)
                 return l;
@@ -17,16 +17,11 @@ async function start() {
                 // console.error(e);
                 return null;
             }
-    }));
+        })
-
+        .then(listings => _
-
-    // once we have all the listings
-    // group by seller
-
-    return _
         .chain(listings)
         .filter(l => l)
-        .reduce((acc, g) => acc.concat(g), [])
+        .flatten()
         .map(l => ({
             id: l.id,
             description: l.release.description,
@@ -37,7 +32,7 @@ async function start() {
         .sortBy(s => s.length)
         .reverse()
         .head()
-        .value();
+        .value());
 }
 
 start()

package-lock.json

@@ -10,6 +10,7 @@
       "license": "ISC",
       "dependencies": {
         "axios": "^0.27.2",
+        "bluebird": "^3.7.2",
         "bunyan": "^1.8.15",
         "express": "^4.18.1",
         "knex": "^2.2.0",
@@ -188,6 +189,11 @@
         "node": ">=8"
       }
     },
+    "node_modules/bluebird": {
+      "version": "3.7.2",
+      "resolved": "https://registry.npmjs.org/bluebird/-/bluebird-3.7.2.tgz",
+      "integrity": "sha512-XpNj6GDQzdfW+r2Wnn7xiSAd7TM3jzkxGXBGTtWKuSXv1xUV+azxAm8jdWZN06QTQk+2N2XB9jRDkvbmQmcRtg=="
+    },
     "node_modules/body-parser": {
       "version": "1.20.0",
       "resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.0.tgz",
@@ -2041,6 +2047,11 @@
       "integrity": "sha512-jDctJ/IVQbZoJykoeHbhXpOlNBqGNcwXJKJog42E5HDPUwQTSdjCHdihjj0DlnheQ7blbT6dHOafNAiS8ooQKA==",
       "dev": true
     },
+    "bluebird": {
+      "version": "3.7.2",
+      "resolved": "https://registry.npmjs.org/bluebird/-/bluebird-3.7.2.tgz",
+      "integrity": "sha512-XpNj6GDQzdfW+r2Wnn7xiSAd7TM3jzkxGXBGTtWKuSXv1xUV+azxAm8jdWZN06QTQk+2N2XB9jRDkvbmQmcRtg=="
+    },
     "body-parser": {
       "version": "1.20.0",
       "resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.0.tgz",

package.json

@@ -18,6 +18,7 @@
   },
   "dependencies": {
     "axios": "^0.27.2",
+    "bluebird": "^3.7.2",
     "bunyan": "^1.8.15",
     "express": "^4.18.1",
     "knex": "^2.2.0",

src/discogs.ts

@@ -53,7 +53,7 @@ export default function discogs() {
             // console.log('cached', id);
             return JSON.parse(await fs.readFile(path, { encoding: 'utf8' }));
         }
-        // console.log('fetching', id);
+        console.log('fetching', id);
         const res = await api.get(`${apiBase}/marketplace/listings/${id}`);
         await fs.writeFile(path, JSON.stringify(res.data, null, 4));
         return res.data;