Method create

src/cdp/webSocketTransport.ts:27–79

* Creates a WebSocket transport by connecting to the given URL.

(
    url: string,
    cancellationToken: CancellationToken,
    remoteHostHeader?: string,
  )

   * Creates a WebSocket transport by connecting to the given URL.
   */
  static async create(
    url: string,
    cancellationToken: CancellationToken,
    remoteHostHeader?: string,
  ): Promise<WebSocketTransport> {
    const isSecure = !url.startsWith('ws://');
    const targetAddressIsLoopback = await isLoopback(url);

    while (true) {
      const dontRetryBefore = Date.now() + maxRetryInterval;
      try {
        const options = {
          headers: { host: remoteHostHeader ?? 'localhost' },
          perMessageDeflate: false,
          maxPayload: 256 * 1024 * 1024, // 256Mb
          rejectUnauthorized: !(isSecure && targetAddressIsLoopback),
          followRedirects: true,
        };

        const ws = new WebSocket(url, [], options);
        return await timeoutPromise(
          new Promise<WebSocketTransport>((resolve, reject) => {
            ws.addEventListener('open', () => resolve(new WebSocketTransport(ws)));
            ws.addEventListener('error', errorEvent => {
              // Check for invalid http redirects for compatibility with old cdp proxies
              const redirectUrl = url === ws.url ? url : ws.url.replace(/^http(s?):/, 'ws$1:');

              if (redirectUrl === url) {
                reject(errorEvent.error); // Parameter is an ErrorEvent. See https://github.com/websockets/ws/blob/master/doc/ws.md#websocketonerror
                return;
              }

              this.create(redirectUrl, cancellationToken, remoteHostHeader).then(resolve, reject);
            });
          }),
          CancellationTokenSource.withTimeout(2000, cancellationToken).token,
          `Could not open ${url}`,
        ).catch(err => {
          ws.close();
          throw err;
        });
      } catch (err) {
        if (cancellationToken.isCancellationRequested) {
          throw err;
        }

        const retryIn = dontRetryBefore - Date.now();
        if (retryIn > 0) {
          await delay(retryIn);
        }
      }
    }
  }

  constructor(ws: WebSocket) {
    this._ws = ws;