2c23da077f
Fixing + doing some maintenance as I was using it for some things. Changes: - fixed a bug related to how React is injected - added a progress tracker for the numbers of requests - retry on 500 - added a param for crashing the lambda manually (useful for cold boots) - added a param to skip build, useful if you want to retest the same variation - don't crash when there's no data to compare ## Bug - [ ] Related issues linked using `fixes #number` - [ ] Integration tests added - [ ] Errors have a helpful link attached, see [`contributing.md`](https://github.com/vercel/next.js/blob/canary/contributing.md) ## Feature - [ ] Implements an existing feature request or RFC. Make sure the feature request has been accepted for implementation before opening a PR. - [ ] Related issues linked using `fixes #number` - [ ] [e2e](https://github.com/vercel/next.js/blob/canary/contributing/core/testing.md#writing-tests-for-nextjs) tests added - [ ] Documentation added - [ ] Telemetry added. In case of a feature if it's used or not. - [ ] Errors have a helpful link attached, see [`contributing.md`](https://github.com/vercel/next.js/blob/canary/contributing.md) ## Documentation / Examples - [ ] Make sure the linting passes by running `pnpm build && pnpm lint` - [ ] The "examples guidelines" are followed from [our contributing doc](https://github.com/vercel/next.js/blob/canary/contributing/examples/adding-examples.md)
43 lines
1.1 KiB
JavaScript
43 lines
1.1 KiB
JavaScript
import https from 'https'
|
|
import timer from '@szmarczak/http-timer'
|
|
|
|
// a wrapper around genAsyncRequest that will retry the request 5 times if it fails
|
|
export async function genRetryableRequest(url) {
|
|
let retries = 0
|
|
while (retries < 10) {
|
|
try {
|
|
return await genAsyncRequest(url)
|
|
} catch (err) {}
|
|
retries++
|
|
}
|
|
throw new Error(`Failed to fetch ${url}, too many retries`)
|
|
}
|
|
|
|
// a wrapper around http.request that is enhanced with timing information
|
|
async function genAsyncRequest(url) {
|
|
return new Promise((resolve, reject) => {
|
|
const request = https.get(url)
|
|
timer(request)
|
|
request.on('response', (response) => {
|
|
let body = ''
|
|
response.on('data', (data) => {
|
|
body += data
|
|
})
|
|
response.on('end', () => {
|
|
if (response.statusCode !== 200) {
|
|
reject(new Error(`Failed to fetch ${url}`))
|
|
}
|
|
resolve({
|
|
...response.timings.phases,
|
|
cold: !body.includes('HOT'),
|
|
})
|
|
})
|
|
response.on('error', (err) => {
|
|
reject(err)
|
|
})
|
|
})
|
|
request.on('error', (err) => {
|
|
reject(err)
|
|
})
|
|
})
|
|
}
|