1 import Bluebird from 'bluebird'
2 import { NextFunction, Request, RequestHandler, Response } from 'express'
3 import { ValidationChain } from 'express-validator'
4 import { ExpressPromiseHandler } from '@server/types/express-handler'
5 import { retryTransactionWrapper } from '../helpers/database-utils'
7 // Syntactic sugar to avoid try/catch in express controllers/middlewares
9 export type RequestPromiseHandler = ValidationChain | ExpressPromiseHandler
11 function asyncMiddleware (fun: RequestPromiseHandler | RequestPromiseHandler[]) {
12 return (req: Request, res: Response, next: NextFunction) => {
13 if (Array.isArray(fun) === true) {
14 return Bluebird.each(fun as RequestPromiseHandler[], f => {
15 return new Promise<void>((resolve, reject) => {
16 return asyncMiddleware(f)(req, res, err => {
17 if (err) return reject(err)
23 .catch(err => next(err))
26 return Promise.resolve((fun as RequestHandler)(req, res, next))
27 .catch(err => next(err))
31 function asyncRetryTransactionMiddleware (fun: (req: Request, res: Response, next: NextFunction) => Promise<any>) {
32 return (req: Request, res: Response, next: NextFunction) => {
33 return Promise.resolve(
34 retryTransactionWrapper(fun, req, res, next)
35 ).catch(err => next(err))
39 // ---------------------------------------------------------------------------
43 asyncRetryTransactionMiddleware