app.js

"use strict";
/**
 * We need to set up the app loggers before we import modules
 * that also make use of it.
 */
const { configureAppLogging } = require('./config/loggers');
configureAppLogging();

const app           = require("express")();
const fs            = require('fs');
const uploadDir     = process.env.UPLOAD_DIRECTORY || "./uploads/";
const hostname      = process.env.API_HOSTNAME || "localhost:3000";
const swaggerTools  = require("swagger-tools");
const YAML          = require("yamljs");
const mongoose      = require("mongoose");
const auth          = require("./api/helpers/auth");
const databaseIndexes = require("./api/helpers/databaseIndexes");
const swaggerConfig = YAML.load("./api/swagger/swagger.yaml");
const winston       = require('winston');
const bodyParser    = require('body-parser');
const dbConnection  = 'mongodb://'
                    + (process.env.MONGODB_SERVICE_HOST || process.env.DB_1_PORT_27017_TCP_ADDR || 'localhost')
                    + '/'
                    + (process.env.MONGODB_DATABASE || 'landuseplanning');
const dbUsername = process.env.MONGODB_USERNAME || '';
const dbPassword = process.env.MONGODB_PASSWORD || '';
const defaultLog = winston.loggers.get('defaultLog');

// Increase postbody sizing
app.use(bodyParser.json({limit: '10mb', extended: true}))
app.use(bodyParser.urlencoded({limit: '10mb', extended: true}));

// Enable CORS
app.use(function (req, res, next) {
  defaultLog.info(req.method, req.url);
  res.setHeader('Access-Control-Allow-Origin', '*');
  res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS, PUT, PATCH, DELETE, HEAD');
  res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,Content-Type,Authorization,responseType');
  res.setHeader('Access-Control-Expose-Headers', 'x-total-count,x-pending-comment-count,x-next-comment-id');
  res.setHeader('Access-Control-Allow-Credentials', true);
  res.setHeader('Cache-Control', 'max-age=4');
  next();
});

// Dynamically set the hostname based on what environment we're in.
swaggerConfig.host = hostname;

// Swagger UI needs to be told that we only serve https in Openshift
if (hostname !== 'localhost:3000') {
  swaggerConfig.schemes = ['https'];
}

swaggerTools.initializeMiddleware(swaggerConfig, function(middleware) {
  app.use(middleware.swaggerMetadata());

  // TODO: Fix this
  // app.use(middleware.swaggerValidator({ validateResponse: false}));

  app.use(
    middleware.swaggerSecurity({
      Bearer: auth.verifyToken
    })
  );
  
  const routerConfig = {
    controllers: "./api/controllers",
    useStubs: false
  };

  app.use(middleware.swaggerRouter(routerConfig));

  app.use(middleware.swaggerUi({apiDocs: '/api/docs', swaggerUi: '/api/docs'}));

  // Make sure uploads directory exists
  try {
    if (!fs.existsSync(uploadDir)){
        fs.mkdirSync(uploadDir);
    }
  } catch (e) {
    // Fall through - uploads will continue to fail until this is resolved locally.
    defaultLog.info("Couldn't create upload folder:", e);
  }
  // Load up DB
  const options = {
    useNewUrlParser: true,
    useUnifiedTopology: true,
    poolSize: 10,
    user: dbUsername,
    pass: dbPassword,
    reconnectTries: Number.MAX_VALUE, // Never stop trying to reconnect
    reconnectInterval: 500, // Reconnect every 500ms
    poolSize: 10, // Maintain up to 10 socket connections
    // If not connected, return errors immediately rather than waiting for reconnect
    bufferMaxEntries: 0,
    connectTimeoutMS: 10000, // Give up initial connection after 10 seconds
    socketTimeoutMS: 45000 // Close sockets after 45 seconds of inactivity
  };
  defaultLog.info("Connecting to:", dbConnection);
  mongoose.Promise  = global.Promise;
  mongoose.connect(dbConnection, options).then(
    () => {
      defaultLog.info("Database connected");

      // Global mongoose config.
      mongoose.set('useFindAndModify', false);

      // Load database models
      defaultLog.info("loading db models.");
      require('./api/helpers/models/audit');
      require('./api/helpers/models/list');
      require('./api/helpers/models/user');
      require('./api/helpers/models/group');
      require('./api/helpers/models/pin');
      require('./api/helpers/models/organization');
      require('./api/helpers/models/vc');
      require('./api/helpers/models/project');
      require('./api/helpers/models/recentActivity');
      require('./api/helpers/models/survey');
      require('./api/helpers/models/surveyQuestion');
      require('./api/helpers/models/surveyLikert');
      require('./api/helpers/models/surveyQuestionAnswer');
      require('./api/helpers/models/surveyResponse');
      require('./api/helpers/models/document');
			require('./api/helpers/models/externalLink');
      require('./api/helpers/models/documentSection');
      require('./api/helpers/models/comment');
      require('./api/helpers/models/commentperiod');
      require('./api/helpers/models/topic');
      require('./api/helpers/models/emailSubscribe');
      defaultLog.info("db model loading done.");

      // Build text index.
      databaseIndexes.generateTextIndex();

      app.listen(3000, '0.0.0.0', function() {
        defaultLog.info("Started server on port 3000");
      });
    },
    err => {
      defaultLog.info("err:", err);
      return;
    });
});