server.js

/* jshint esversion: 6 */

// dependencies

const req = require('rfr');
const express = require('express');
const logger = require('morgan');
const mongoose = require('mongoose');

// libs

const settings = req('/settings');

const utils = req('/lib/utils');
const activity = req('/lib/activity');
const ineedhelp = req('/lib/ineedhelp');
const lightfaden = req('/lib/lightfaden');

const Hybris = req('/lib/hybris');
var hybris = new Hybris(settings.cred.hybris.clientid, settings.cred.hybris.secret);

const MONGOPATH = settings.cred.mongo.path;
const MONGOOPTIONS = {
  useMongoClient: true,
  native_parser: true,
  poolSize: 5,
  keepAlive: true,
  socketOptions: {
    socketTimeoutMS: 0,
    connectionTimeout: 0,
  },
};

mongoose.connection.on('connected', function () {
  console.log('> Connected to MongoDB...');

  const app = express();
  app.use(logger('dev'));

  app.use((req, res, next) => {
    if (req.query.userId) {
      utils.createUser(req.query.userId, (err, data) => {
        if (err) {
          console.log(err);
          res.status(500).json({msg: err});
        }
        else {
          console.log(data);
          next();
        }
      });
    } else return res.status(500).json({msg: 'missing userId'});
  });

  app.get('/hybris/createcustomer', function(req, res) {
    var q = req.query;
    var name = q.name;
    var mail = q.email;
    var street = q.street;
    var zip = q.zip;
    var city = q.city;
    var userId = q.userId;
    if (name && mail && street && zip && city) {
      hybris.createCustomer(name, mail, street, zip, city, (err, hybrisId) => {
        utils.updateUser(userId, hybrisId, (err, hybrisId) => {
          res.status(200).json({msg: hybrisId});
        });
      });
    } else {
      res.json({msg: 'missing parameter (name, maik, street, zip, city'});
    }
  });

  app.get('/hybris/subscribecustomertoproduct', (req, res) => {
    var q = req.query;
    var userId = q.userId;
    var product = q.product;
    utils.findUser(userId, (err, user) => {
      if (err) return res.status(500).json({msg: err});
      hybris.subscribeCustomerToProduct(user.hybrisId, product, (err, id) => {
        if (err) return res.status(500).json({msg: err});
        return res.status(500).json({msg: id});
      });
    })
  });

  app.get('/hybris/getbillforcustomer', (req, res) => {
    var q = req.query;
    var userId = q.userId;
    utils.findUser(userId, (err, user) => {
      if (err) return res.status(500).json({msg: err});
      hybris.getBillForCustomer(user.hybrisId, Date.now(), (err, bills) => {
        if (err) return res.status(500).json({msg: err});
        return res.status(500).json({msg: bills});
      });
    })
  });

  app.get('/activity', function(req, res) {
    var q = req.query;
    if (q.activity) {
      activity.setActivity(q.userId, q.activity, (err, msg) => {
        if (err) res.status(500).json({msg: err});
        else res.status(200).json({msg: msg});
      });
    } else {
      res.json({msg: 'missing paramater (activity, target)'});
    }
  });

  app.get('/ineedhelp', function(req, res) {
    if (req.query.element){
      ineedhelp.getHelp(req.query.userId, user.query.element, (err, help) => {
        if (err) res.status(500).json({msg: err});
        else res.status(200).json({msg: help});
      });
    } else res.status(500).json({msg: 'missing parameter (element)'});
  });

  app.get('/lightfaden', function(req, res) {
    if (req.query.route){
      lightfaden.getLightfaden(req.query.userId, req.query.route, (err, lightfaeden) => {
        if (err) return res.status(500).json({msg: err});
        else return res.status(200).json(lightfaeden);
      });
    } else return res.status(500).json({msg: 'missing parameter (route)'});
  });

  var server = app.listen(settings.conf.api.port, function(err) {
    if (err) console.log(err);
    else console.log('server is running: http://localhost:' + settings.conf.api.port);
  });
});

/////////////////////////////////
// MongoDB Connection Handling //
/////////////////////////////////

mongoose.connection.on('error', function (err) {
  console.error('> Failed to connect to MongoDB on startup ', err);
});

mongoose.connection.on('disconnected', function () {
  console.log('> Mongoose default connection to MongoDB disconnected');
});

var gracefulExit = function () {
  mongoose.connection.close(function () {
    console.log('> MongoDB disconnected through app termination');
    process.exit(0);
  });
};

process.on('SIGINT', gracefulExit).on('SIGTERM', gracefulExit);

try {
  mongoose.connect(MONGOPATH, MONGOOPTIONS);
  console.log('> Trying to connect to MongoDB...');
} catch (err) {
  console.log('> Sever initialization failed ', err.message);
}