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