populate.js

'use strict';

var mongodb = require('mongodb');
var env = require('./../env')();

var util = require('./util');

main();

function main() {
  var MongoClient = mongodb.MongoClient;
  MongoClient.connect(env.storageURI, { "useUnifiedTopology" : true, "useNewUrlParser" : true }, function connected(err, client) {

    console.log('Connecting to mongo...');
    if (err) {
      console.log('Error occurred: ', err);
      throw err;
    }

    var db = client.db();

    populate_collection(db);
  });
}

function populate_collection(db) {
  var cgm_collection = db.collection(env.entries_collection);
  var new_cgm_record = util.get_cgm_record();

  cgm_collection.insert(new_cgm_record, function (err) {
    if (err) {
      throw err;
    }
    process.exit(0);
  });
}