2019-02-08 13:13:53 +01:00
|
|
|
'use strict'
|
|
|
|
|
|
|
|
const retry = require('p-retry')
|
|
|
|
|
2019-02-08 13:42:32 +01:00
|
|
|
const _request = require('./lib/request')
|
2019-02-08 13:13:53 +01:00
|
|
|
const createClient = require('.')
|
|
|
|
|
|
|
|
const defaultRetryOpts = {
|
|
|
|
retries: 3,
|
|
|
|
factor: 3,
|
|
|
|
minTimeout: 5 * 1000
|
|
|
|
}
|
|
|
|
|
2019-02-08 13:42:32 +01:00
|
|
|
const createClientWithRetry = (profile, userAgent, retryOpts = defaultRetryOpts, request = _request) => {
|
2019-02-08 13:13:53 +01:00
|
|
|
const requestWithRetry = (profile, userAgent, opt, data) => {
|
|
|
|
const attempt = () => {
|
|
|
|
return request(profile, userAgent, opt, data)
|
|
|
|
.catch((err) => {
|
|
|
|
if (err.isHafasError) throw err // continue
|
|
|
|
if (err.code === 'ENOTFOUND') { // abort
|
|
|
|
const abortErr = new retry.AbortError(err)
|
|
|
|
Object.assign(abortErr, err)
|
|
|
|
throw abortErr
|
|
|
|
}
|
|
|
|
throw err // continue
|
|
|
|
})
|
|
|
|
}
|
|
|
|
return retry(attempt, retryOpts)
|
|
|
|
}
|
|
|
|
|
|
|
|
return createClient(profile, userAgent, requestWithRetry)
|
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = createClientWithRetry
|