app.js

const graphql = require("./data-management/init-graphql");
const createError = require('http-errors');
const express = require('express');
const path = require('path');
const logger = require('morgan');
const fs = require('fs');
const cors = require('cors');
const config = require('./config');
const {createSession} = require("./services/session");
const cronJob = require("node-cron");
const {DataInterface} = require("./data-management/data-interface");
const {getTimeNow} = require("./util/time-util");
const events_router = require("./data-management/events-router");
const {Neo4jService} = require("./data-management/neo4j-service");
const {neo4jDriver} = require("./data-management/neo4j-driver");
const dataInterface = new DataInterface(new Neo4jService(neo4jDriver));
//Print configuration
console.log(config);

const LOG_FOLDER = 'logs';
if (!fs.existsSync(LOG_FOLDER)) {
    fs.mkdirSync(LOG_FOLDER);
}
// create a write stream (in append mode)
const accessLogStream = fs.createWriteStream(path.join(__dirname, LOG_FOLDER, 'access.log'), { flags: 'a'})

const create404 = function(req, res, next) {
    next(createError(404));
};

const errorHandler = function(err, req, res, next) {
    // set locals, only providing error in development
    res.locals.message = err.message;
    res.locals.error = req.app.get('env') === 'development' ? err : {};

    // render the error page
    res.status(err.status || 500);
    res.json(res.locals.message);
};


// Initialize app
const app = express();
// App configuration middleware

app.use(cors());

// setup the logger
app.use(logger('combined', { stream: accessLogStream }))
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(express.static(path.join(__dirname, 'public')));

/* GET ping-ping for health checking. */
app.get('/api/users/ping', function (req, res, next) {
    res.send(`pong`);
});

/* GET version for health checking and version checking. */
app.get('/api/users/version', function (req, res, next) {
    res.json({
        version: config.version, date: config.date
    });
});

app.use(createSession({ sessionSecret: config.cookie_secret, session_timeout: config.session_timeout }));
app.use('/api/users/graphql', graphql);
app.use('/api/users', events_router);

// Scheduled cronjob twice a day (1am, 10am) eastern time
cronJob.schedule("1 0 1,10 * * *", async () => {
    console.log("Running a scheduled background task to disable inactive users at " + getTimeNow());
    await dataInterface.disableInactiveUsers();
    console.log("Running a scheduled background task to delete expired token uuids at " + getTimeNow());
    await dataInterface.deleteExpiredTokenUUIDs()
});

// catch 404 and forward to error handler
app.use(create404);
// error handler
app.use(errorHandler);

module.exports = app;