Small tweaks and improvements.

Author: ashleydavis

listing-2.js

@@ -1,12 +1,12 @@
-'use strict';
+"use strict";
 
 const openCsvInputStream = require('./toolkit/open-csv-input-stream');
 const openMongodbOutputStream = require('./toolkit/open-mongodb-output-stream');
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:6000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:6000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 const inputFilePath = "./data/weather-stations.csv";
 
@@ -31,10 +31,10 @@ function streamData (inputFilePath, dbCollection) {
     return new Promise((resolve, reject) => {
         openCsvInputStream(inputFilePath)
             .pipe(openMongodbOutputStream(dbCollection))
-            .on('finish', () => {
+            .on("finish", () => {
                 resolve();
             })
-            .on('error', err => {
+            .on("error", err => {
                 reject(err);
             });
     });
@@ -46,7 +46,7 @@ openDatabase()
             .then(() => client.close());
     })
     .then(() => {
-        console.log('Done');
+        console.log("Done");
     })
     .catch(err => {
         console.error("An error occurred.");

listing-3.js

@@ -1,10 +1,10 @@
-'use strict';
+"use strict";
 
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 //
 // Open the connection to the database.

listing-4.js

@@ -1,10 +1,10 @@
-'use strict';
+"use strict";
 
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 //
 // Open the connection to the database.

listing-5.js

@@ -1,10 +1,10 @@
-'use strict';
+"use strict";
 
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 //
 // Open the connection to the database.

listing-6.js

@@ -1,10 +1,10 @@
-'use strict';
+"use strict";
 
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 //
 // Open the connection to the database.
@@ -31,7 +31,6 @@ openDatabase()
                 _id: 0,
                 Year: 1,
                 Month: 1,
-                Day: 1,
                 Precipitation: 1
             }
         };

listing-7.js

@@ -1,10 +1,10 @@
-'use strict';
+"use strict";
 
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 //
 // Open the connection to the database.

listing-8.js

@@ -1,11 +1,11 @@
-'use strict';
+"use strict";
 
 const argv = require('yargs').argv;
 const MongoClient = require('mongodb').MongoClient;
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 if (argv.skip === undefined || argv.limit === undefined) {
     throw new Error("Slave process requires command line arguments 'skip' and 'limit' to define the data window.");

listing-9.js

@@ -1,13 +1,13 @@
-'use strict';
+"use strict";
 
 const argv = require('yargs').argv;
 const MongoClient = require('mongodb').MongoClient;
 const spawn = require('child_process').spawn;
 const parallel = require('async-await-parallel');
 
-const hostName = 'mongodb://127.0.0.1:7000';
-const databaseName = 'weather_stations';
-const collectionName = 'daily_readings';
+const hostName = "mongodb://127.0.0.1:7000";
+const databaseName = "weather_stations";
+const collectionName = "daily_readings";
 
 //
 // Open the connection to the database.
@@ -31,18 +31,18 @@ function openDatabase () {
 //
 function runSlave (skip, limit, slaveIndex) {
     return new Promise((resolve, reject) => {
-        const args = [ 'listing-8.js', '--skip', skip, '--limit', limit ];
+        const args = [ "listing-8.js", "--skip", skip, "--limit", limit ];
 
-        const childProcess = spawn('node', args);
-        childProcess.stdout.on('data', data => {
+        const childProcess = spawn("node", args);
+        childProcess.stdout.on("data", data => {
             console.log("[" + slaveIndex + "]: INF: " + data);
         });
 
-        childProcess.stderr.on('data', data => {
+        childProcess.stderr.on("data", data => {
             console.log("[" + slaveIndex + "]: ERR: " + data);
         });
 
-        childProcess.on('close', code => {
+        childProcess.on("close", code => {
             if (code === 0) {
                 resolve();
             }
@@ -51,7 +51,7 @@ function runSlave (skip, limit, slaveIndex) {
             }
         });
 
-        childProcess.on('error', err => {
+        childProcess.on("error", err => {
             reject(err);
         });
     });