import tap from 'tap'

import {createClient} from '../index.js'
import {withRetrying} from '../retry.js'
import {profile as vbbProfile} from '../p/vbb/index.js'

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

tap.test('withRetrying works', (t) => {
	// for the first 3 calls, return different kinds of errors
	let calls = 0
	const failingRequest = async (ctx, userAgent, reqData) => {
		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 {
			res: [],
			common: {}
		}
	}

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

	t.plan(2 + 4)
	client.departures(spichernstr, {duration: 1})
	.then((res) => {
		const {
			departures: deps,
			realtimeDataUpdatedAt,
		} = res
		t.same(deps, [], 'resolved with invalid value')
		t.equal(realtimeDataUpdatedAt, null, 'resolved with invalid value')
	})
	.catch(t.ifError)

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