mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-07 20:31:06 -05:00
f7275a6c4b
Upgrade logger and metrics in all services GitOrigin-RevId: 2baf63eeeab77fb3559cf763ddacfbf4b745cd0b
83 lines
2.5 KiB
JavaScript
83 lines
2.5 KiB
JavaScript
/*
|
|
* 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 mongodb = require('./app/js/mongodb')
|
|
const controller = require('./app/js/NotificationsController')
|
|
|
|
metrics.memory.monitor(logger)
|
|
|
|
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
|
|
|
|
mongodb
|
|
.waitForDb()
|
|
.then(() => {
|
|
app.listen(port, host, () =>
|
|
logger.info(`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
|
|
}
|