Class Router

java/src/org/openqa/selenium/grid/router/Router.java:39–96

A simple router that is aware of the selenium-protocol.

/** A simple router that is aware of the selenium-protocol. */
public class Router implements HasReadyState, Routable, Closeable {

  private final Routable routes;
  private final SessionMap sessions;
  private final Distributor distributor;
  private final NewSessionQueue queue;
  private final HandleSession sessionHandler;

  public Router(
      Tracer tracer,
      HttpClient.Factory clientFactory,
      SessionMap sessions,
      NewSessionQueue queue,
      Distributor distributor) {
    Require.nonNull("Tracer to use", tracer);
    Require.nonNull("HTTP client factory", clientFactory);

    this.sessions = Require.nonNull("Session map", sessions);
    this.queue = Require.nonNull("New Session Request Queue", queue);
    this.distributor = Require.nonNull("Distributor", distributor);

    this.sessionHandler = new HandleSession(tracer, clientFactory, sessions);

    routes =
        combine(
            get("/status").to(() -> new GridStatusHandler(tracer, distributor)),
            sessions.with(new SpanDecorator(tracer, req -> "session_map")),
            queue.with(new SpanDecorator(tracer, req -> "session_queue")),
            distributor.with(new SpanDecorator(tracer, req -> "distributor")),
            matching(req -> req.getUri().startsWith("/session/")).to(() -> sessionHandler));
  }

  @Override
  public boolean isReady() {
    try {
      return Set.of(distributor, sessions, queue).parallelStream()
          .map(HasReadyState::isReady)
          .reduce(true, Boolean::logicalAnd);
    } catch (RuntimeException e) {
      return false;
    }
  }

  @Override
  public boolean matches(HttpRequest req) {
    return routes.matches(req);
  }

  @Override
  public HttpResponse execute(HttpRequest req) {
    return routes.execute(req);
  }

  @Override
  public void close() {
    sessionHandler.close();
  }
}