1 // TODO: import from ES6 when retry typing file will include errorFilter function
2 import * as retry from 'async/retry'
4 import { logger } from './logger'
6 type RetryTransactionWrapperOptions = { errorMessage: string, arguments?: any[] }
7 function retryTransactionWrapper (functionToRetry: (... args) => Promise<any>, options: RetryTransactionWrapperOptions) {
8 const args = options.arguments ? options.arguments : []
10 return transactionRetryer(callback => {
11 functionToRetry.apply(this, args)
12 .then(result => callback(null, result))
13 .catch(err => callback(err))
16 // Do not throw the error, continue the process
17 logger.error(options.errorMessage, err)
21 function transactionRetryer (func: Function) {
22 return new Promise((res, rej) => {
27 const willRetry = (err.name === 'SequelizeDatabaseError')
28 logger.debug('Maybe retrying the transaction function.', { willRetry })
31 }, func, err => err ? rej(err) : res())
35 // ---------------------------------------------------------------------------
38 retryTransactionWrapper,