gnezim
60e2149072
Tasks 16-20: Online Board Tests (Search/Filter, Tabs, Flight List, Details Modal, Time/Date) - Task 16: Search & Filter tests (37 tests) - departure/arrival cities, passenger count, cabin class - Task 17: Arrival/Departure Tabs tests (45 tests) - tab switching, flight display, sorting - Task 18: Flight List View tests (50 tests) - display, sorting, filtering, pagination, loading states - Task 19: Flight Details Modal tests (40 tests) - opening/closing, content display, actions - Task 20: Time & Date Filter tests (43 tests) - date selection, time ranges, calendar navigation Tasks 21-25: Flight Details Tests (Flight Info, Passengers, Seats, Services, Fares) - Task 21: Flight Info Display tests (40 tests) - basic info, airports, route visualization, timeline - Task 22: Passenger Info tests (50 tests) - passenger list, details, services, special requirements - Task 23: Seat Selection tests (50 tests) - seat map, selection, categories, recommendations - Task 24: Service Selection tests (25 tests) - baggage, meals, seats, summary - Task 25: Fare Display tests (55 tests) - fare breakdown, comparisons, discounts, refunds All tests follow AAA pattern and use data-testid selectors matching Angular version. Total: 245 tests across 10 feature suites.
63 lines
1.9 KiB
JavaScript
63 lines
1.9 KiB
JavaScript
const { RetryOperation } = require('./retry')
|
|
|
|
const createTimeout = (attempt, opts) => Math.min(Math.round((1 + (opts.randomize ? Math.random() : 0)) * Math.max(opts.minTimeout, 1) * Math.pow(opts.factor, attempt)), opts.maxTimeout)
|
|
const isRetryError = err => err?.code === 'EPROMISERETRY' && Object.hasOwn(err, 'retried')
|
|
|
|
const promiseRetry = async (fn, options = {}) => {
|
|
let timeouts = []
|
|
if (options instanceof Array) {
|
|
timeouts = [...options]
|
|
} else {
|
|
if (options.retries === Infinity) {
|
|
options.forever = true
|
|
delete options.retries
|
|
}
|
|
const opts = {
|
|
retries: 10,
|
|
factor: 2,
|
|
minTimeout: 1 * 1000,
|
|
maxTimeout: Infinity,
|
|
randomize: false,
|
|
...options
|
|
}
|
|
if (opts.minTimeout > opts.maxTimeout) {
|
|
throw new Error('minTimeout is greater than maxTimeout')
|
|
}
|
|
if (opts.retries) {
|
|
for (let i = 0; i < opts.retries; i++) {
|
|
timeouts.push(createTimeout(i, opts))
|
|
}
|
|
// sort the array numerically ascending (since the timeouts may be out of order at factor < 1)
|
|
timeouts.sort((a, b) => a - b)
|
|
} else if (options.forever) {
|
|
timeouts.push(createTimeout(0, opts))
|
|
}
|
|
}
|
|
|
|
const operation = new RetryOperation(timeouts, {
|
|
forever: options.forever,
|
|
unref: options.unref,
|
|
maxRetryTime: options.maxRetryTime
|
|
})
|
|
|
|
return new Promise(function (resolve, reject) {
|
|
operation.attempt(async number => {
|
|
try {
|
|
const result = await fn(err => {
|
|
throw Object.assign(new Error('Retrying'), { code: 'EPROMISERETRY', retried: err })
|
|
}, number, operation)
|
|
return resolve(result)
|
|
} catch (err) {
|
|
if (!isRetryError(err)) {
|
|
return reject(err)
|
|
}
|
|
if (!operation.retry(err.retried || new Error())) {
|
|
return reject(err.retried)
|
|
}
|
|
}
|
|
})
|
|
})
|
|
}
|
|
|
|
module.exports = { promiseRetry }
|