mirror of
https://github.com/yu-i-i/overleaf-cep.git
synced 2026-11-12 13:13:45 +01:00
Jakob Ackermann
f48132a70e
* [notifications] adopt strict zod types and extend test coverage * [notifications] validate expires date via schema GitOrigin-RevId: 25dee0578ec443447e4c38a50a7e6c8b44831fe7
79 lines
2.2 KiB
TypeScript
79 lines
2.2 KiB
TypeScript
// Metrics must be initialized before importing anything else
|
|
import '@overleaf/metrics/initialize.js'
|
|
import metrics from '@overleaf/metrics'
|
|
import Settings from '@overleaf/settings'
|
|
import logger from '@overleaf/logger'
|
|
import express, {
|
|
type Request,
|
|
type Response,
|
|
type ErrorRequestHandler,
|
|
type NextFunction,
|
|
} from 'express'
|
|
import { mongoClient } from './app/js/mongodb.js'
|
|
import NotificationsController from './app/js/NotificationsController.ts'
|
|
import HealthCheckController from './app/js/HealthCheckController.ts'
|
|
import { handleValidationError } from '@overleaf/validation-tools'
|
|
|
|
const app = express()
|
|
|
|
logger.initialize('notifications')
|
|
|
|
metrics.memory.monitor(logger)
|
|
metrics.open_sockets.monitor()
|
|
|
|
app.use(express.json())
|
|
app.use(metrics.http.monitor(logger))
|
|
|
|
metrics.injectMetricsRoute(app)
|
|
|
|
app.post('/user/:user_id', NotificationsController.addNotification)
|
|
app.get('/user/:user_id', NotificationsController.getUserNotifications)
|
|
app.delete(
|
|
'/user/:user_id/notification/:notification_id',
|
|
NotificationsController.removeNotificationId
|
|
)
|
|
app.delete('/user/:user_id', NotificationsController.removeNotificationKey)
|
|
app.delete('/key/:key', NotificationsController.removeNotificationByKeyOnly)
|
|
app.get('/key/:key/count', NotificationsController.countNotificationsByKeyOnly)
|
|
app.delete(
|
|
'/key/:key/bulk',
|
|
NotificationsController.deleteUnreadNotificationsByKeyOnlyBulk
|
|
)
|
|
|
|
app.get('/status', (req, res) => res.send('notifications is up'))
|
|
|
|
app.get('/health_check', HealthCheckController.check)
|
|
|
|
app.get('*', (req, res) => res.sendStatus(404))
|
|
|
|
app.use(handleValidationError)
|
|
|
|
const handleApiError: ErrorRequestHandler = (
|
|
err: Error,
|
|
req: Request,
|
|
res: Response,
|
|
next: NextFunction
|
|
) => {
|
|
req.logger.addFields({ err })
|
|
req.logger.setLevel('error')
|
|
res.sendStatus(500)
|
|
}
|
|
|
|
app.use(handleApiError)
|
|
|
|
const host = Settings.internal.notifications?.host || '127.0.0.1'
|
|
const port = Settings.internal.notifications?.port || 3042
|
|
try {
|
|
await mongoClient.connect()
|
|
} catch (err) {
|
|
logger.fatal({ err }, 'Cannot connect to mongo. Exiting.')
|
|
process.exit(1)
|
|
}
|
|
|
|
if (import.meta.url === `file://${process.argv[1]}`) {
|
|
app.listen(port, host, () =>
|
|
logger.debug({}, `notifications starting up, listening on ${host}:${port}`)
|
|
)
|
|
}
|
|
export default app
|