github/puppeteer
0
0
Fork 0
mirror of https://github.com/puppeteer/puppeteer synced 2024-06-14 14:02:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: use --parallel (#8612)

Browse Source
This commit is contained in:
jrandolf
2022-07-05 14:42:55 +02:00
committed by GitHub
parent 45eb2c607f
commit 28e236f1a6
7 changed files with 41 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
utils/testserver/src/index.ts
View File

@@ -29,6 +29,7 @@ import {
ServerOptions as HttpsServerOptions,
} from 'https';
import {getType as getMimeType} from 'mime';
import {AddressInfo} from 'net';
import {join} from 'path';
import {Duplex} from 'stream';
import {Server as WebSocketServer, WebSocket} from 'ws';
@@ -65,27 +66,35 @@ export class TestServer {
#gzipRoutes = new Set<string>();
#requestSubscribers = new Map<string, Subscriber>();
static async create(dirPath: string, port: number): Promise<TestServer> {
const server = new TestServer(dirPath, port);
await new Promise(x => {
return server.#server.once('listening', x);
static async create(dirPath: string): Promise<TestServer> {
let res!: (value: unknown) => void;
const promise = new Promise(resolve => {
res = resolve;
});
const server = new TestServer(dirPath);
server.#server.once('listening', res);
server.#server.listen(0);
await promise;
return server;
}
static async createHTTPS(dirPath: string, port: number): Promise<TestServer> {
const server = new TestServer(dirPath, port, {
static async createHTTPS(dirPath: string): Promise<TestServer> {
let res!: (value: unknown) => void;
const promise = new Promise(resolve => {
res = resolve;
});
const server = new TestServer(dirPath, {
key: readFileSync(join(__dirname, '..', 'key.pem')),
cert: readFileSync(join(__dirname, '..', 'cert.pem')),
passphrase: 'aaaa',
});
await new Promise(x => {
return server.#server.once('listening', x);
});
server.#server.once('listening', res);
server.#server.listen(0);
await promise;
return server;
}
constructor(dirPath: string, port: number, sslOptions?: HttpsServerOptions) {
constructor(dirPath: string, sslOptions?: HttpsServerOptions) {
this.#dirPath = dirPath;
if (sslOptions) {
@@ -96,7 +105,6 @@ export class TestServer {
this.#server.on('connection', this.#onServerConnection);
this.#wsServer = new WebSocketServer({server: this.#server});
this.#wsServer.on('connection', this.#onWebSocketConnection);
this.#server.listen(port);
}
#onServerConnection = (connection: Duplex): void => {
@@ -113,6 +121,10 @@ export class TestServer {
});
};
get port(): number {
return (this.#server.address() as AddressInfo).port;
}
enableHTTPCache(pathPrefix: string): void {
this.#cachedPathPrefix = pathPrefix;
}