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(
13 functionToRetry.apply(this, args)
14 .then(result => callback(null, result))
15 .catch(err => callback(err))
19 // Do not throw the error, continue the process
20 logger.error(options.errorMessage, { error: err })
24 function transactionRetryer (func: Function) {
25 return new Promise((res, rej) => {
29 errorFilter: function (err) {
30 const willRetry = (err.name === 'SequelizeDatabaseError')
31 logger.debug('Maybe retrying the transaction function.', { willRetry })
34 }, func, function (err) {
35 err ? rej(err) : res()
40 // ---------------------------------------------------------------------------
43 retryTransactionWrapper,