Function connect

src/protocol.js:16–193

({port:port = 9222} = {})

][Math.floor(Math.random()*6)];

export async function connect({port:port = 9222} = {}) {
  let webSocketDebuggerUrl, socket;
  let url;
  try {
    await untilTrue(async () => {
      let result = false;
      try {
        url = `http://${RANDOM_LOCAL()}:${port}/json/version`;
        DEBUG.verbose && console.log(`Trying browser at ${url}...`, url);
        const {webSocketDebuggerUrl} = await Promise.race([
          fetch(url).then(r => r.json()),
          (async () => {
            await sleep(2500);
            throw new Error(`Connect took too long.`)
          })(),
        ]);
        if ( webSocketDebuggerUrl ) {
          result = true;
        }
      } catch(e) {
        DEBUG.verbose && console.error('Error while checking browser', e);
      } finally {
        return result; 
      }
    });
    ({webSocketDebuggerUrl} = await fetch(url).then(r => r.json()));
    let isOpen = false;
    socket = new Ws(webSocketDebuggerUrl);
    socket.on('open', () => { isOpen = true });
    await untilTrue(() => isOpen);
    DEBUG.verbose && console.log(`Connected to browser`);
  } catch(e) {
    console.log("Error communicating with browser", e);
    process.exit(1);
  }

  const Resolvers = {};
  const Handlers = {};
  socket.on('message', handle);
  let id = 0;

  let resolve, reject;
  const promise = new Promise((res, rej) => (resolve = res, reject = rej));

  switch(socket.readyState) {
    case Ws.CONNECTING:
      socket.on('open', () => resolve()); break;
    case Ws.OPEN:
      resolve(); break;
    case Ws.CLOSED:
    case Ws.CLOSING:
      reject(); break;
  }

  await promise;

  return {
    send,