aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/middlewares/async.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/middlewares/async.ts')
-rw-r--r--server/middlewares/async.ts14
1 files changed, 11 insertions, 3 deletions
diff --git a/server/middlewares/async.ts b/server/middlewares/async.ts
index 29ebd169d..9692f9be7 100644
--- a/server/middlewares/async.ts
+++ b/server/middlewares/async.ts
@@ -1,10 +1,18 @@
1import { Request, Response, NextFunction } from 'express' 1import { Request, Response, NextFunction, RequestHandler } from 'express'
2import { eachSeries } from 'async'
2 3
3// Syntactic sugar to avoid try/catch in express controllers 4// Syntactic sugar to avoid try/catch in express controllers
4// Thanks: https://medium.com/@Abazhenov/using-async-await-in-express-with-node-8-b8af872c0016 5// Thanks: https://medium.com/@Abazhenov/using-async-await-in-express-with-node-8-b8af872c0016
5function asyncMiddleware (fn: (req: Request, res: Response, next: NextFunction) => Promise<any>) { 6function asyncMiddleware (fun: RequestHandler | RequestHandler[]) {
6 return (req: Request, res: Response, next: NextFunction) => { 7 return (req: Request, res: Response, next: NextFunction) => {
7 return Promise.resolve(fn(req, res, next)) 8 if (Array.isArray(fun) === true) {
9 return eachSeries(fun as RequestHandler[], (f, cb) => {
10 Promise.resolve(f(req, res, cb))
11 .catch(next)
12 }, next)
13 }
14
15 return Promise.resolve((fun as RequestHandler)(req, res, next))
8 .catch(next) 16 .catch(next)
9 } 17 }
10} 18}