db-vendo-client/test/retry.js

'use strict'

const test = require('tape')

const withRetrying = require('../retry')
const createClient = require('..')
const vbbProfile = require('../p/vbb')

const userAgent = 'public-transport/hafas-client:test'
const spichernstr = '900000042101'

test('withRetrying works', (t) => {
	// for the first 3 calls, return different kinds of errors
	let calls = 0
	const failingRequest = (profile, userAgent, opt, data) => {
		calls++
		if (calls === 1) {
			const err = new Error('HAFAS error')
			err.isHafasError = true
			return Promise.reject(err)
		}
		if (calls === 2) {
			const err = new Error('fetch error')
			err.code = 'EFOO'
			return Promise.reject(err)
		}
		if (calls < 4) return Promise.reject(new Error('generic error'))
		return Promise.resolve([])
	}

	const createRetryingClient = withRetrying(createClient, {
		retries: 3,
		minTimeout: 100,
		factor: 2,
		randomize: false
	})
	const client = createRetryingClient(vbbProfile, userAgent, {
		request: failingRequest
	})

	t.plan(1 + 4)
	client.departures(spichernstr, {duration: 1})
	.then(deps => t.deepEqual(deps, [], 'resolved with invalid value'))
	.catch(t.ifError)

	setTimeout(() => t.equal(calls, 1), 50) // buffer
	setTimeout(() => t.equal(calls, 2), 150) // 100 + buffer
	setTimeout(() => t.equal(calls, 3), 350) // 100 + 200 + buffer
	setTimeout(() => t.equal(calls, 4), 750) // 100 + 200 + 400 + buffer
})