overleaf/services/notifications/app.js

/*
 * decaffeinate suggestions:
 * DS102: Remove unnecessary code created because of implicit returns
 * DS103: Rewrite code to no longer use __guard__
 * DS207: Consider shorter variations of null checks
 * Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
 */
const metrics = require('@overleaf/metrics')
metrics.initialize('notifications')
const Settings = require('@overleaf/settings')
const logger = require('@overleaf/logger')
logger.initialize('notifications-sharelatex')
const express = require('express')
const app = express()
const methodOverride = require('method-override')
const bodyParser = require('body-parser')
const { mongoClient } = require('./app/js/mongodb')
const controller = require('./app/js/NotificationsController')

metrics.memory.monitor(logger)
metrics.open_sockets.monitor()

const HealthCheckController = require('./app/js/HealthCheckController')

app.use(methodOverride())
app.use(bodyParser())
app.use(metrics.http.monitor(logger))

metrics.injectMetricsRoute(app)

app.post('/user/:user_id', controller.addNotification)
app.get('/user/:user_id', controller.getUserNotifications)
app.delete(
  '/user/:user_id/notification/:notification_id',
  controller.removeNotificationId
)
app.delete('/user/:user_id', controller.removeNotificationKey)
app.delete('/key/:key', controller.removeNotificationByKeyOnly)
app.get('/key/:key/count', controller.countNotificationsByKeyOnly)
app.delete('/key/:key/bulk', controller.deleteUnreadNotificationsByKeyOnlyBulk)

app.get('/status', (req, res) => res.send('notifications sharelatex up'))

app.get('/health_check', (req, res) =>
  HealthCheckController.check(function (err) {
    if (err != null) {
      logger.err({ err }, 'error performing health check')
      return res.sendStatus(500)
    } else {
      return res.sendStatus(200)
    }
  })
)

app.get('*', (req, res) => res.sendStatus(404))

const host =
  __guard__(
    Settings.internal != null ? Settings.internal.notifications : undefined,
    x => x.host
  ) || 'localhost'
const port =
  __guard__(
    Settings.internal != null ? Settings.internal.notifications : undefined,
    x1 => x1.port
  ) || 3042

mongoClient
  .connect()
  .then(() => {
    app.listen(port, host, () =>
      logger.debug(`notifications starting up, listening on ${host}:${port}`)
    )
  })
  .catch(err => {
    logger.fatal({ err }, 'Cannot connect to mongo. Exiting.')
    process.exit(1)
  })

function __guard__(value, transform) {
  return typeof value !== 'undefined' && value !== null
    ? transform(value)
    : undefined
}