server.js

"use strict";

var mongoose = require("mongoose");
var async = require("async");
var dbsObject = {};
var models = require("./helpers/models")(dbsObject);
var dbsNames = {};
var connectOptions;
var mainDb;
var app;

require("pmx").init();

process.env.NODE_ENV = process.env.NODE_ENV || "production";
require("./config/environment/" + process.env.NODE_ENV);

connectOptions = {
  db: { native_parser: true },
  server: { poolSize: 5 },
  w: 1,
  j: true
};
mainDb = mongoose.createConnection(
  process.env.MONGODB_URI || process.env.MAIN_DB_HOST,
  process.env.MAIN_DB_NAME,
  process.env.DB_PORT,
  connectOptions
);
mainDb.on("error", function(err) {
  err = err || "connection error";
  console.error(err);

  process.exit(1, err);
});
mainDb.once("open", function callback() {
  var mainDBSchema;
  var port = parseInt(process.env.PORT, 10) || 8089;
  var instance = parseInt(process.env.NODE_APP_INSTANCE, 10) || 0;
  var main;

  port += instance;
  mainDb.dbsObject = dbsObject;

  dbsObject.mainDB = mainDb;

  console.log("Connection to mainDB is success");

  require("./models/index.js");

  mainDBSchema = mongoose.Schema(
    {
      _id: Number,
      url: { type: String, default: "localhost" },
      DBname: { type: String, default: "" },
      pass: { type: String, default: "" },
      user: { type: String, default: "" },
      port: Number
    },
    { collection: "easyErpDBS" }
  );

  main = mainDb.model("easyErpDBS", mainDBSchema);
  main.find().exec(function(err, result) {
    if (err) {
      process.exit(1, err);
    }

    async.each(
      result,
      function(_db, eachCb) {
        var dbInfo = {
          DBname: "",
          url: ""
        };
        var opts = {
          db: { native_parser: true },
          server: { poolSize: 5 },
          w: 1,
          j: true
        };
        var dbObject = mongoose.createConnection(
          _db.url,
          _db.DBname,
          _db.port,
          opts
        );

        dbObject.on("error", function(err) {
          console.error(err);
          eachCb(err);
        });
        dbObject.once("open", function() {
          console.log("Connection to " + _db.DBname + " is success");

          dbInfo.url = _db.url;
          dbInfo.DBname = _db.DBname;
          dbsObject[_db.DBname] = dbObject;
          dbsNames[_db.DBname] = dbInfo;

          eachCb();
        });
      },
      function(err) {
        if (err) {
          return console.error(err);
        }
        app = require("./app")(mainDb, dbsNames);

        app.listen(port, function() {
          var Scheduler = require("./services/scheduler")(models);
          var scheduler = new Scheduler(dbsObject);

          console.log(
            "=============================================================="
          );
          console.log(
            "|| server instance=" +
              instance +
              " start success on port=" +
              port +
              " in " +
              process.env.NODE_ENV +
              " version ||"
          );
          console.log(
            "==============================================================\n"
          );

          if (result.length > 0) {
            scheduler.initEveryDayScheduler();
          }
        });
      }
    );
  });

  mainDb.mongoose = mongoose;
});