2017-05-15 20:22:03 +00:00
|
|
|
// TODO: import from ES6 when retry typing file will include errorFilter function
|
2017-06-05 19:53:49 +00:00
|
|
|
import * as retry from 'async/retry'
|
2017-01-15 18:53:11 +00:00
|
|
|
|
2017-05-15 20:22:03 +00:00
|
|
|
import { logger } from './logger'
|
2017-01-17 19:38:45 +00:00
|
|
|
|
2017-06-10 20:15:25 +00:00
|
|
|
type RetryTransactionWrapperOptions = { errorMessage: string, arguments?: any[] }
|
2017-07-05 11:26:25 +00:00
|
|
|
function retryTransactionWrapper (functionToRetry: (... args) => Promise<any>, options: RetryTransactionWrapperOptions) {
|
2017-01-15 18:53:11 +00:00
|
|
|
const args = options.arguments ? options.arguments : []
|
|
|
|
|
2017-07-11 15:04:57 +00:00
|
|
|
return transactionRetryer(callback => {
|
|
|
|
functionToRetry.apply(this, args)
|
2017-07-05 11:26:25 +00:00
|
|
|
.then(result => callback(null, result))
|
|
|
|
.catch(err => callback(err))
|
2017-07-11 15:04:57 +00:00
|
|
|
})
|
2017-07-05 11:26:25 +00:00
|
|
|
.catch(err => {
|
|
|
|
// Do not throw the error, continue the process
|
2017-07-07 16:26:12 +00:00
|
|
|
logger.error(options.errorMessage, err)
|
2017-07-05 11:26:25 +00:00
|
|
|
})
|
2017-01-15 18:53:11 +00:00
|
|
|
}
|
|
|
|
|
2017-07-05 11:26:25 +00:00
|
|
|
function transactionRetryer (func: Function) {
|
|
|
|
return new Promise((res, rej) => {
|
|
|
|
retry({
|
|
|
|
times: 5,
|
2017-01-15 18:53:11 +00:00
|
|
|
|
2017-07-11 15:04:57 +00:00
|
|
|
errorFilter: err => {
|
2017-07-05 11:26:25 +00:00
|
|
|
const willRetry = (err.name === 'SequelizeDatabaseError')
|
|
|
|
logger.debug('Maybe retrying the transaction function.', { willRetry })
|
|
|
|
return willRetry
|
|
|
|
}
|
2017-07-11 15:04:57 +00:00
|
|
|
}, func, err => err ? rej(err) : res())
|
2017-01-15 18:53:11 +00:00
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
// ---------------------------------------------------------------------------
|
|
|
|
|
2017-05-15 20:22:03 +00:00
|
|
|
export {
|
|
|
|
retryTransactionWrapper,
|
|
|
|
transactionRetryer
|
|
|
|
}
|