function cacheRoute (lifetimeArg: string | number) {
return async function (req: express.Request, res: express.Response, next: express.NextFunction) {
- const redisKey = Redis.Instance.buildCachedRouteKey(req)
+ const redisKey = Redis.Instance.generateCachedRouteKey(req)
try {
await lock.acquire(redisKey, async (done) => {
logger.debug('No cached results for route %s.', req.originalUrl)
const sendSave = res.send.bind(res)
+ const redirectSave = res.redirect.bind(res)
res.send = (body) => {
if (res.statusCode >= 200 && res.statusCode < 400) {
logger.error('Cannot cache route.', { err })
return done(err)
})
+ } else {
+ done()
}
return sendSave(body)
}
+ res.redirect = url => {
+ done()
+
+ return redirectSave(url)
+ }
+
return next()
}
return done()
})
} catch (err) {
- logger.error('Cannot serve cached route.', err)
+ logger.error('Cannot serve cached route.', { err })
return next()
}
}