Class NettyServer

java/src/org/openqa/selenium/netty/server/NettyServer.java:57–214

import org.openqa.selenium.remote.http.Message;

public class NettyServer implements Server<NettyServer> {

  private final EventLoopGroup bossGroup;
  private final EventLoopGroup workerGroup;
  private final int port;
  private final String host;
  private final boolean bindHost;
  private final URL externalUrl;
  private final HttpHandler handler;
  private final BiFunction<String, Consumer<Message>, Optional<Consumer<Message>>> websocketHandler;
  private final @Nullable SslContext sslCtx;
  private final boolean allowCors;
  private final @Nullable Function<String, Optional<URI>> tcpTunnelResolver;

  @Nullable private Channel channel;

  public NettyServer(BaseServerOptions options, HttpHandler handler) {
    this(options, handler, (str, sink) -> Optional.empty());
  }

  public NettyServer(
      BaseServerOptions options,
      HttpHandler handler,
      BiFunction<String, Consumer<Message>, Optional<Consumer<Message>>> websocketHandler) {
    this(options, handler, websocketHandler, null);
  }

  /**
   * Creates a {@link NettyServer} with an optional TCP-level tunnel resolver for WebSocket
   * connections. When {@code tcpTunnelResolver} is non-null, WebSocket upgrade requests that
   * contain a Selenium session ID are intercepted before the normal WebSocket handler: the Router
   * opens a raw TCP connection to the resolved Node URI and bridges the two sockets directly,
   * removing itself from the WebSocket data path entirely.
   *
   * @param tcpTunnelResolver maps a request URI to the target Node URI. Return {@link
   *     Optional#empty()} to fall through to the normal WebSocket handler.
   */
  public NettyServer(
      BaseServerOptions options,
      HttpHandler handler,
      BiFunction<String, Consumer<Message>, Optional<Consumer<Message>>> websocketHandler,
      @Nullable Function<String, Optional<URI>> tcpTunnelResolver) {
    Require.nonNull("Server options", options);
    Require.nonNull("Handler", handler);
    this.websocketHandler = Require.nonNull("Factory for websocket connections", websocketHandler);
    this.tcpTunnelResolver = tcpTunnelResolver;

    InternalLoggerFactory.setDefaultFactory(JdkLoggerFactory.INSTANCE);

    boolean secure = options.isSecure();
    if (secure) {
      try {
        sslCtx =
            SslContextBuilder.forServer(options.getCertificate(), options.getPrivateKey()).build();
      } catch (SSLException e) {
        throw new UncheckedIOException(new IOException("Certificate problem.", e));
      }
    } else if (options.isSelfSigned()) {