mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-07 20:31:06 -05:00
Remove old exception-handling and shutdown-related mechanisms
This commit is contained in:
parent
6a679023d3
commit
85d3c0a852
3 changed files with 2 additions and 132 deletions
|
@ -12,11 +12,8 @@ const fileController = require('./app/js/FileController')
|
|||
const bucketController = require('./app/js/BucketController')
|
||||
const keyBuilder = require('./app/js/KeyBuilder')
|
||||
const healthCheckController = require('./app/js/HealthCheckController')
|
||||
const ExceptionHandler = require('./app/js/ExceptionHandler')
|
||||
const exceptionHandler = new ExceptionHandler()
|
||||
|
||||
const app = express()
|
||||
app.exceptionHandler = exceptionHandler
|
||||
|
||||
if (settings.sentry && settings.sentry.dsn) {
|
||||
logger.initializeErrorReporting(settings.sentry.dsn)
|
||||
|
@ -34,8 +31,6 @@ app.use(function(req, res, next) {
|
|||
next()
|
||||
})
|
||||
|
||||
exceptionHandler.addMiddleware(app)
|
||||
|
||||
Metrics.injectMetricsRoute(app)
|
||||
|
||||
app.head(
|
||||
|
@ -133,51 +128,24 @@ app.get('/heapdump', (req, res, next) =>
|
|||
)
|
||||
)
|
||||
|
||||
app.post('/shutdown', function(req, res) {
|
||||
exceptionHandler.setNotOk()
|
||||
res.sendStatus(200)
|
||||
})
|
||||
|
||||
app.get('/status', function(req, res) {
|
||||
if (exceptionHandler.appIsOk()) {
|
||||
res.send('filestore sharelatex up')
|
||||
} else {
|
||||
logger.log('app is not ok - shutting down')
|
||||
res.status(500).send('server is being shut down')
|
||||
}
|
||||
res.send('filestore sharelatex up')
|
||||
})
|
||||
|
||||
app.get('/health_check', healthCheckController.check)
|
||||
|
||||
app.get('*', (req, res) => res.sendStatus(404))
|
||||
|
||||
const port = settings.internal.filestore.port || 3009
|
||||
const host = '0.0.0.0'
|
||||
|
||||
if (!module.parent) {
|
||||
// Called directly
|
||||
const server = app.listen(port, host, error => {
|
||||
app.listen(port, host, error => {
|
||||
if (error) {
|
||||
logger.error('Error starting Filestore', error)
|
||||
throw error
|
||||
}
|
||||
logger.info(`Filestore starting up, listening on ${host}:${port}`)
|
||||
})
|
||||
exceptionHandler.server = server
|
||||
}
|
||||
|
||||
module.exports = app
|
||||
|
||||
process.on('SIGTERM', function() {
|
||||
logger.log('filestore got SIGTERM, shutting down gracefully')
|
||||
exceptionHandler.beginShutdown()
|
||||
})
|
||||
|
||||
if (global.gc) {
|
||||
const oneMinute = 60 * 1000
|
||||
const gcTimer = setInterval(function() {
|
||||
global.gc()
|
||||
logger.log(process.memoryUsage(), 'global.gc')
|
||||
}, 3 * oneMinute)
|
||||
gcTimer.unref()
|
||||
}
|
||||
|
|
|
@ -1,97 +0,0 @@
|
|||
const Metrics = require('metrics-sharelatex')
|
||||
const logger = require('logger-sharelatex')
|
||||
|
||||
// TODO: domain has been deprecated for some time - do we need it and is there a better way?
|
||||
|
||||
// eslint-disable-next-line node/no-deprecated-api
|
||||
const domain = require('domain')
|
||||
|
||||
const TWO_MINUTES = 120 * 1000
|
||||
|
||||
class ExceptionHandler {
|
||||
constructor() {
|
||||
this._appIsOk = true
|
||||
}
|
||||
|
||||
beginShutdown() {
|
||||
if (this._appIsOk) {
|
||||
this._appIsOk = false
|
||||
|
||||
// hard-terminate this process if graceful shutdown fails
|
||||
const killTimer = setTimeout(() => process.exit(1), TWO_MINUTES)
|
||||
|
||||
if (typeof killTimer.unref === 'function') {
|
||||
killTimer.unref()
|
||||
} // prevent timer from keeping process alive
|
||||
|
||||
this.server.close(function() {
|
||||
logger.log('closed all connections')
|
||||
Metrics.close()
|
||||
if (typeof process.disconnect === 'function') {
|
||||
process.disconnect()
|
||||
}
|
||||
})
|
||||
logger.log('server will stop accepting connections')
|
||||
}
|
||||
}
|
||||
|
||||
addMiddleware(app) {
|
||||
app.use(this.middleware.bind(this))
|
||||
}
|
||||
|
||||
appIsOk() {
|
||||
return this._appIsOk
|
||||
}
|
||||
|
||||
setNotOk() {
|
||||
this._appIsOk = false
|
||||
}
|
||||
|
||||
middleware(req, res, next) {
|
||||
const rescueLogger = require('logger-sharelatex')
|
||||
const requestDomain = domain.create()
|
||||
requestDomain.add(req)
|
||||
requestDomain.add(res)
|
||||
requestDomain.on('error', err => {
|
||||
try {
|
||||
// request a shutdown to prevent memory leaks
|
||||
this.beginShutdown()
|
||||
if (!res.headerSent) {
|
||||
res.status(500).send('uncaught exception')
|
||||
}
|
||||
req = {
|
||||
body: req.body,
|
||||
headers: req.headers,
|
||||
url: req.url,
|
||||
key: req.key,
|
||||
statusCode: req.statusCode
|
||||
}
|
||||
err = {
|
||||
message: err.message,
|
||||
stack: err.stack,
|
||||
name: err.name,
|
||||
type: err.type,
|
||||
arguments: err.arguments
|
||||
}
|
||||
rescueLogger.err(
|
||||
{ err, req, res },
|
||||
'uncaught exception thrown on request'
|
||||
)
|
||||
} catch (exception) {
|
||||
rescueLogger.err(
|
||||
{ err: exception },
|
||||
'exception in request domain handler'
|
||||
)
|
||||
}
|
||||
})
|
||||
|
||||
if (!this._appIsOk) {
|
||||
// when shutting down, close any HTTP keep-alive connections
|
||||
res.set('Connection', 'close')
|
||||
}
|
||||
|
||||
requestDomain.run(next)
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = ExceptionHandler
|
|
@ -44,7 +44,6 @@ class FilestoreApp {
|
|||
resolve()
|
||||
}
|
||||
)
|
||||
this.app.exceptionHandler.server = this.server
|
||||
})
|
||||
|
||||
if (Settings.filestore.backend === 's3') {
|
||||
|
|
Loading…
Reference in a new issue