diff options
Diffstat (limited to 'server/middlewares/async.ts')
-rw-r--r-- | server/middlewares/async.ts | 14 |
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 @@ | |||
1 | import { Request, Response, NextFunction } from 'express' | 1 | import { Request, Response, NextFunction, RequestHandler } from 'express' |
2 | import { 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 |
5 | function asyncMiddleware (fn: (req: Request, res: Response, next: NextFunction) => Promise<any>) { | 6 | function 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 | } |