Remove old exception-handling and shutdown-related mechanisms

This commit is contained in:
Simon Detheridge 2020-01-06 15:43:24 +00:00
parent 74b480fc55
commit 87b51d0c35
3 changed files with 1 additions and 131 deletions

View file

@ -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,24 +128,12 @@ 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.send('server is being shut down').status(500)
}
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'
@ -163,21 +146,6 @@ if (!module.parent) {
}
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()
}

View file

@ -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.send('uncaught exception').status(500)
}
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

View file

@ -44,7 +44,6 @@ class FilestoreApp {
resolve()
}
)
this.app.exceptionHandler.server = this.server
})
if (Settings.filestore.backend === 's3') {