app.js

process.title = "demoapp";

const express = require('express');
const app = express();
const nconf = require("nconf");
const umsBridge = require('./server/umsBridge');
const installationBridge = require('./server/appInstallationBridge');
const accountConfBridge = require('./server/accountConfBridge');
const notifications = require('./server/notifications');
const csdsBridge = require('./server/csdsBridge');
const historyBridge = require('./server/convHistoryBridge');
const authorizationBridge = require('./server/authorizationBridge');
const bodyParser = require('body-parser');
const logger = require('./server/util/logger');
const uuid = require('uuid/v4');
const session = require('express-session');
const MemoryStore = require('memorystore')(session);
const passport = require('passport');
const authLocalStrategy = require('./server/auth/authLocalStrategy');
const router = express.Router();
const subscriptionsHandler = require('./server/util/subscriptionsHandler');
const HttpStatus = require('http-status-codes');
const helmet = require('helmet');

app.use(helmet());

nconf.file({file: "settings.json"});
router.get("/", (req, res) => res.json({status: 'UP'}));

app.use("/health", router);
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
//receive webhooks notifications
app.use("/notifications", notifications);
// configure passport.js to use the local strategy
passport.use(authLocalStrategy());
// tell passport how to serialize the user
passport.serializeUser((user, done) => {
  //Here i have to save the user data in the format I want
  done(null, user);
});
passport.deserializeUser((user, done) => {
  done(null, user);
});

const halfHour =  1800 * 1000;
const secret = process.env.secret || '582e3ed11562c6ed3808e3325fd';
const sess = {
  genid: () => { return uuid()},
  secret: secret,
  store: new MemoryStore({
    checkPeriod: halfHour
  }),
  resave: true,
  cookie: {
    maxAge: halfHour,
    httpOnly: true,
    overwrite: true,
  },
  saveUninitialized: false
};

if(process.env.NODE_ENV === 'prod') {
  app.set('trust proxy', 1); // trust first proxy
  sess.cookie.secure = true // serve secure cookies
}

app.use(session(sess));
app.use(passport.initialize());
app.use(passport.session());

app.get("/subscribe/notifications/:convid/:appKey", (req, res) => {
  req.isAuthenticated() ? subscriptionsHandler.handleSubscriptionRequest(req, res) : res.status(HttpStatus.UNAUTHORIZED).send("Unauthorized");
});
app.use('/demo', function (req, res, next) {
  req.isAuthenticated() ? next() : res.status(HttpStatus.UNAUTHORIZED).send("Unauthorized");
});

app.use("/demo/installation", installationBridge);
app.use("/demo/property/", accountConfBridge);
app.use("/demo/ums", umsBridge);
app.use("/demo/history", historyBridge);
app.use("/demo/authorization", authorizationBridge);
//CSDS
app.use("/domains", csdsBridge);

app.post('/login', (req, res, next) => {
  passport.authenticate('local', (err, user, info) => {
    if(info) {
      return res.status(HttpStatus.UNAUTHORIZED).send(info.message)}
    if (err) {
      return next(err); }
    if (!user) {
      return res.status(HttpStatus.UNAUTHORIZED).redirect('/#/settings'); }
    req.session.regenerate(function(err) {
      if (err) { return res.status(HttpStatus.UNAUTHORIZED).redirect('/#/settings'); }
      req.logIn(user, function (err) {
        if (err) {
          return next(err);
        }
        return res.send({
          'userId': user.config.userId,
          'sessionTTl': user.sessionTTl
        });
      });
    })

  })(req, res, next);
});

app.get('/logout', (req, res, next) => {
  req.logOut();
  req.session.destroy((error) => {
    if(error) { res.status(HttpStatus.INTERNAL_SERVER_ERROR).send("LOG OUT ERROR");}
    res.json({status: 'OK'});
  });
});
app.get('/demo/getUserInfo', (req, res) => {
  try {
    const user = {};
    user.account = req.session.passport.user.csdsCollectionResponse.baseURIs[0].account;
    user.loginName = req.session.passport.user.config.loginName;
    res.send(user);
  }catch(error) {
    logger.error("ERROR: " + error);
    res.status(HttpStatus.INTERNAL_SERVER_ERROR).send({error: HttpStatus.getStatusText(HttpStatus.INTERNAL_SERVER_ERROR)});
  }
});
app.get('/isAuthenticated',(req, res, next) => res.send(req.isAuthenticated()));
//Serve our UI
app.use(express.static('dist'));
//http server
app.listen(nconf.get("SERVER_HTTP_PORT"), () => {
  logger.info("listening...");
  app.isReady = true;
  app.emit("ready", true);
});

module.exports = app;