Filip/playwright
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

promisify

Browse source
This commit is contained in:
Simon Knott 2024-11-29 12:30:53 +01:00
parent b177157220
commit 8055eeb14d
No known key found for this signature in database
GPG key ID: 8CEDC00028084AEC
1 changed files with 48 additions and 55 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

93
packages/playwright-core/src/server/registry/browserFetcher.ts
View file

@ -29,6 +29,8 @@ import { browserDirectoryToMarkerFilePath } from '.';
import { getUserAgent } from '../../utils/userAgent';
import type { DownloadParams } from './oopDownloadBrowserMain';
import { httpRequest } from '../../utils';
import type { IncomingMessage } from 'http';
import { pipeline, finished } from 'stream/promises';
export async function downloadBrowserWithProgressBar(title: string, browserDirectory: string, executablePath: string | undefined, downloadURLs: string[], downloadFileName: string, downloadConnectionTimeout: number): Promise<boolean> {
if (await existsAsync(browserDirectoryToMarkerFilePath(browserDirectory))) {
@ -118,73 +120,64 @@ function downloadBrowserWithProgressBarOutOfProcess(title: string, browserDirect
async function downloadBrotli(title: string, browserDirectory: string, url: string, zipPath: string, executablePath: string | undefined, connectionTimeout: number): Promise<{ error: Error | null }> {
try {
debugLogger.log('install', `running download:`);
debugLogger.log('install', `-- from url: ${url}`);
debugLogger.log('install', `-- to location: ${zipPath}`);
let downloadedBytes = 0;
let totalBytes = 0;
const promise = new ManualPromise<{ error: Error | null }>();
const progress = getDownloadProgress(title);
const response = await new Promise<IncomingMessage>((resolve, reject) => {
httpRequest({
url,
headers: { 'User-Agent': getUserAgent() },
timeout: connectionTimeout,
}, response => {
}, resolve, reject);
});
debugLogger.log('install', `-- response status code: ${response.statusCode}`);
if (response.statusCode !== 200) {
let content = '';
const handleError = () => {
const error = new Error(`Download failed: server returned code ${response.statusCode} body '${content}'. URL: ${url}`);
response.on('data', chunk => content += chunk);
try { await finished(response); } catch {}
// consume response data to free up memory
response.resume();
promise.reject(error);
};
response
.on('data', chunk => content += chunk)
.on('end', handleError)
.on('error', handleError);
return;
throw new Error(`Download failed: server returned code ${response.statusCode} body '${content}'. URL: ${url}`);
}
totalBytes = parseInt(response.headers['content-length'] || '0', 10);
debugLogger.log('install', `-- total bytes: ${totalBytes}`);
const decompress = zlib.createBrotliDecompress();
const extract = tarFs.extract(browserDirectory);
response
.pipe(decompress)
.pipe(extract)
.on('finish', () => {
if (downloadedBytes !== totalBytes) {
debugLogger.log('install', `-- download failed, size mismatch: ${downloadedBytes} != ${totalBytes}`);
promise.resolve({ error: new Error(`Download failed: size mismatch, file size: ${downloadedBytes}, expected size: ${totalBytes} URL: ${url}`) });
} else {
debugLogger.log('install', `-- download complete, size: ${downloadedBytes}`);
promise.resolve({ error: null });
}
})
.on('error', error => promise.resolve({ error }));
response.on('data', onData);
response.on('error', (error: any) => {
if (error?.code === 'ECONNRESET') {
debugLogger.log('install', `-- download failed, server closed connection`);
promise.resolve({ error: new Error(`Download failed: server closed connection. URL: ${url}`) });
} else {
debugLogger.log('install', `-- download failed, unexpected error`);
promise.resolve({ error: new Error(`Download failed: ${error?.message ?? error}. URL: ${url}`) });
}
});
}, (error: any) => promise.resolve({ error }));
return promise;
function onData(chunk: string) {
const progress = getDownloadProgress(title);
const totalBytes = parseInt(response.headers['content-length'] || '0', 10);
let downloadedBytes = 0;
response.on('data', chunk => {
downloadedBytes += chunk.length;
progress(downloadedBytes, totalBytes);
});
debugLogger.log('install', `-- total bytes: ${totalBytes}`);
try {
await pipeline(
response,
zlib.createBrotliDecompress(),
tarFs.extract(browserDirectory)
);
} catch (error) {
if (error?.code === 'ECONNRESET') {
debugLogger.log('install', `-- download failed, server closed connection`);
throw new Error(`Download failed: server closed connection. URL: ${url}`);
}
debugLogger.log('install', `-- download failed, unexpected error`);
throw new Error(`Download failed: ${error?.message ?? error}. URL: ${url}`);
}
if (downloadedBytes !== totalBytes) {
debugLogger.log('install', `-- download failed, size mismatch: ${downloadedBytes} != ${totalBytes}`);
throw new Error(`Download failed: size mismatch, file size: ${downloadedBytes}, expected size: ${totalBytes} URL: ${url}`);
}
debugLogger.log('install', `-- download complete, size: ${downloadedBytes}`);
return { error: null };
} catch (error) {
return { error };
}
}