mirror of
https://github.com/microsoft/playwright.git
synced 2025-06-26 21:40:17 +00:00
fix: timeout error when downloading browsers (#35564)
This commit is contained in:
parent
b10f920a15
commit
24699d6bd0
@ -71,10 +71,14 @@ export function httpRequest(params: HTTPRequestParams, onResponse: (r: http.Inco
|
|||||||
|
|
||||||
const requestCallback = (res: http.IncomingMessage) => {
|
const requestCallback = (res: http.IncomingMessage) => {
|
||||||
const statusCode = res.statusCode || 0;
|
const statusCode = res.statusCode || 0;
|
||||||
if (statusCode >= 300 && statusCode < 400 && res.headers.location)
|
if (statusCode >= 300 && statusCode < 400 && res.headers.location) {
|
||||||
|
// Close the original socket before following the redirect. Otherwise
|
||||||
|
// it may stay idle and cause a timeout error.
|
||||||
|
request.destroy();
|
||||||
httpRequest({ ...params, url: new URL(res.headers.location, params.url).toString() }, onResponse, onError);
|
httpRequest({ ...params, url: new URL(res.headers.location, params.url).toString() }, onResponse, onError);
|
||||||
else
|
} else {
|
||||||
onResponse(res);
|
onResponse(res);
|
||||||
|
}
|
||||||
};
|
};
|
||||||
const request = options.protocol === 'https:' ?
|
const request = options.protocol === 'https:' ?
|
||||||
https.request(options, requestCallback) :
|
https.request(options, requestCallback) :
|
||||||
|
|||||||
@ -72,6 +72,64 @@ test(`playwright cdn should race with a timeout`, async ({ exec }) => {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test(`playwright cdn should not timeout on redirect`, {
|
||||||
|
annotation: { type: 'issue', description: 'https://github.com/microsoft/playwright/issues/34686' }
|
||||||
|
}, async ({ exec }) => {
|
||||||
|
const server = http.createServer(async (req, res) => {
|
||||||
|
if (req.url !== '/foo.zip') {
|
||||||
|
res.writeHead(307, {
|
||||||
|
'Connection': 'keep-alive',
|
||||||
|
'location': `http://127.0.0.1:${(server.address() as AddressInfo).port}/foo.zip`,
|
||||||
|
});
|
||||||
|
res.flushHeaders();
|
||||||
|
// Keep the connection open, the client is expected to close it.
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
const emptyZip = Buffer.from([
|
||||||
|
0x50, 0x4B, 0x05, 0x06, // EOCD
|
||||||
|
0x00, 0x00, // Disk number
|
||||||
|
0x00, 0x00, // Central dir start disk
|
||||||
|
0x00, 0x00, // Central dir records on this disk
|
||||||
|
0x00, 0x00, // Total central dir records
|
||||||
|
0x00, 0x00, 0x00, 0x00, // Central dir size
|
||||||
|
0x00, 0x00, 0x00, 0x00, // Offset of start of central dir
|
||||||
|
0x00, 0x00 // ZIP comment length
|
||||||
|
]);
|
||||||
|
res.socket.setNoDelay(true);
|
||||||
|
res.writeHead(200, {
|
||||||
|
'Content-Type': 'application/zip',
|
||||||
|
'Content-Disposition': 'attachment; filename="empty.zip"',
|
||||||
|
'Content-Length': emptyZip.length,
|
||||||
|
});
|
||||||
|
res.flushHeaders();
|
||||||
|
// Send one byte at a time in small intervals (< 1000ms) during 2 seconds
|
||||||
|
// to keep the second connection slow but alive.
|
||||||
|
for (let i = 0; i < emptyZip.length; i ++) {
|
||||||
|
res.write(emptyZip.subarray(i, i + 1));
|
||||||
|
await new Promise(resolve => setTimeout(resolve, 2000 / emptyZip.length));
|
||||||
|
}
|
||||||
|
res.end();
|
||||||
|
});
|
||||||
|
await new Promise<void>(resolve => server.listen(0, resolve));
|
||||||
|
|
||||||
|
try {
|
||||||
|
await exec('npm i playwright');
|
||||||
|
const result = await exec('npx playwright install chromium', {
|
||||||
|
env: {
|
||||||
|
PLAYWRIGHT_DOWNLOAD_HOST: `http://127.0.0.1:${(server.address() as AddressInfo).port}`,
|
||||||
|
DEBUG: 'pw:install',
|
||||||
|
PLAYWRIGHT_DOWNLOAD_CONNECTION_TIMEOUT: '1000',
|
||||||
|
},
|
||||||
|
expectToExitWithError: true
|
||||||
|
});
|
||||||
|
// Steps after the extraction will fail, but the download should succeed without timeouts.
|
||||||
|
expect(result).toContain(`pw:install SUCCESS downloading Chromium`);
|
||||||
|
expect(result).not.toContain(`timed out after 1000ms`);
|
||||||
|
} finally {
|
||||||
|
await new Promise(resolve => server.close(resolve));
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
test(`npx playwright install should not hang when CDN closes the connection`, async ({ exec }) => {
|
test(`npx playwright install should not hang when CDN closes the connection`, async ({ exec }) => {
|
||||||
let retryCount = 0;
|
let retryCount = 0;
|
||||||
const server = http.createServer((req, res) => {
|
const server = http.createServer((req, res) => {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user