Add cores update script

package.json

@@ -13,7 +13,8 @@
     "ships": "node scripts/ships.js",
     "upcoming": "node scripts/upcoming.js",
     "launchpad": "node scripts/launchpad.js",
-    "landpad": "node scripts/landpad.js"
+    "landpad": "node scripts/landpad.js",
+    "cores": "node scripts/cores.js"
   },
   "repository": {
     "type": "git",

scripts/cores.js

@@ -0,0 +1,134 @@
+#!/usr/bin/env node
+
+/**
+ * This script updates core missions, reuse, and landing counts
+ */
+
+const MongoClient = require('mongodb');
+
+// Created so we can use async await with requests, and
+// to use async sleep function inside the IIFE
+async function asyncForEach(array, callback) {
+  for (let index = 0; index < array.length; index += 1) {
+    // Allow await for nested async functions
+    // eslint-disable-next-line no-await-in-loop
+    await callback(array[index], index, array);
+  }
+}
+
+(async () => {
+  let client;
+  try {
+    client = await MongoClient.connect(process.env.MONGO_URL, { useNewUrlParser: true });
+  } catch (err) {
+    console.log(err.stack);
+    process.exit(1);
+  }
+
+  const col = client.db('spacex-api').collection('core');
+  const launch = client.db('spacex-api').collection('launch');
+
+  const cores = [];
+  const data = await col.find({}).sort({ core_serial: 1 }).toArray();
+  data.forEach(core => {
+    cores.push(core.core_serial);
+  });
+
+
+  const start = async () => {
+    await asyncForEach(cores, async core => {
+      const rtls_attempts = await launch.countDocuments({
+        upcoming: false,
+        'rocket.first_stage.cores': {
+          $elemMatch: {
+            core_serial: core, landing_type: 'RTLS', landing_intent: true,
+          },
+        },
+        launch_success: true,
+      });
+      const rtls_successes = await launch.countDocuments({
+        upcoming: false,
+        'rocket.first_stage.cores': {
+          $elemMatch: {
+            core_serial: core, landing_type: 'RTLS', landing_intent: true, land_success: true,
+          },
+        },
+        launch_success: true,
+      });
+      const asds_attempts = await launch.countDocuments({
+        upcoming: false,
+        'rocket.first_stage.cores': {
+          $elemMatch: {
+            core_serial: core, landing_type: 'ASDS', landing_intent: true,
+          },
+        },
+        launch_success: true,
+      });
+      const asds_sucesses = await launch.countDocuments({
+        upcoming: false,
+        'rocket.first_stage.cores': {
+          $elemMatch: {
+            core_serial: core, landing_type: 'ASDS', landing_intent: true, land_success: true,
+          },
+        },
+        launch_success: true,
+      });
+
+      const missions = [];
+      const launch_results = await launch.find({
+        upcoming: false,
+        'rocket.first_stage.cores': {
+          $elemMatch: {
+            core_serial: core,
+          },
+        },
+      }).project({
+        _id: 0,
+        flight_number: 1,
+        mission_name: 1,
+      }).sort({
+        flight_number: 1,
+      }).toArray();
+
+      launch_results.forEach(i => {
+        const mission = {
+          name: i.mission_name,
+          flight: i.flight_number,
+        };
+        missions.push(mission);
+      });
+
+      let reuse_count;
+      if (missions.length - 1 < 0) {
+        reuse_count = 0;
+      } else {
+        reuse_count = missions.length - 1;
+      }
+
+      console.log(core);
+      console.log(missions);
+      console.log(`Reuse Count: ${reuse_count}`);
+      console.log(`RTLS Attempts: ${rtls_attempts}`);
+      console.log(`RTLS Sucesses: ${rtls_successes}`);
+      console.log(`ASDS Attempts: ${asds_attempts}`);
+      console.log(`ASDS Successes: ${asds_sucesses}\n`);
+
+      await col.updateOne({ core_serial: core }, {
+        $set: {
+          reuse_count,
+          rtls_attempts,
+          rtls_landings: rtls_successes,
+          asds_attempts,
+          asds_landings: asds_sucesses,
+          missions,
+        },
+      });
+    });
+  };
+
+  await start();
+
+  if (client) {
+    client.close();
+  }
+})();