Method createServer

src/adapter/cdpProxy.ts:235–287

()

  }

  private async createServer() {
    const path = `/${randomBytes(20).toString('hex')}`;
    const server = await acquireTrackedWebSocketServer(this.portTracker, {
      perMessageDeflate: true,
      path,
    });

    this.logger.info(LogTag.ProxyActivity, 'activated cdp proxy');

    server.on('connection', client => {
      const clientHandle = new ClientHandle(client, this.logger);
      this.logger.info(LogTag.ProxyActivity, 'accepted proxy connection', {
        id: clientHandle.id,
      });

      client.on('close', () => {
        this.logger.verbose(LogTag.ProxyActivity, 'closed proxy connection', {
          id: clientHandle.id,
        });
        this.disposables.disposeObject(clientHandle);
      });

      client.on('message', async d => {
        let message: CdpProtocol.ICommand;
        try {
          message = JSON.parse(d.toString());
        } catch (e) {
          return clientHandle.send({
            id: 0,
            error: { code: ProxyErrors.ParseError, message: e.message },
          });
        }

        this.logger.verbose(LogTag.ProxyActivity, 'received proxy message', message);

        const { method, params, id = 0 } = message;
        const [domain, fn] = method.split('.');
        try {
          const result = domain === jsDebugDomain
            ? await this.invokeJsDebugDomainMethod(clientHandle, fn, params)
            : await this.invokeCdpMethod(clientHandle, domain, fn, params);
          clientHandle.send({ id, result });
        } catch (e) {
          const error = e instanceof ProtocolError && e.cause
            ? e.cause
            : { code: 0, message: e.message };
          clientHandle.send({ id, error });
        }
      });
    });

    return { server, path };
  }

  /**
   * @inheritdoc