How to use newSession method of org.openqa.selenium.grid.node.remote.RemoteNode class

Best Selenium code snippet using org.openqa.selenium.grid.node.remote.RemoteNode.newSession

Source:NodeTest.java

...98  public void shouldRefuseToCreateASessionIfNoFactoriesAttached() {99    Node local = LocalNode.builder(tracer, bus, clientFactory, uri).build();100    HttpClient.Factory clientFactory = new PassthroughHttpClient.Factory<>(local);101    Node node = new RemoteNode(tracer, clientFactory, UUID.randomUUID(), uri, ImmutableSet.of());102    Optional<Session> session = node.newSession(createSessionRequest(caps))103        .map(CreateSessionResponse::getSession);104    assertThat(session.isPresent()).isFalse();105  }106  @Test107  public void shouldCreateASessionIfTheCorrectCapabilitiesArePassedToIt() {108    Optional<Session> session = node.newSession(createSessionRequest(caps))109        .map(CreateSessionResponse::getSession);110    assertThat(session.isPresent()).isTrue();111  }112  @Test113  public void shouldOnlyCreateAsManySessionsAsFactories() {114    Node node = LocalNode.builder(tracer, bus, clientFactory, uri)115        .add(caps, new TestSessionFactory((id, c) -> new Session(id, uri, c)))116        .build();117    Optional<Session> session = node.newSession(createSessionRequest(caps))118        .map(CreateSessionResponse::getSession);119    assertThat(session.isPresent()).isTrue();120    session = node.newSession(createSessionRequest(caps))121        .map(CreateSessionResponse::getSession);122    assertThat(session.isPresent()).isFalse();123  }124  @Test125  public void willRefuseToCreateMoreSessionsThanTheMaxSessionCount() {126    Optional<Session> session = node.newSession(createSessionRequest(caps))127        .map(CreateSessionResponse::getSession);128    assertThat(session.isPresent()).isTrue();129    session = node.newSession(createSessionRequest(caps))130        .map(CreateSessionResponse::getSession);131    assertThat(session.isPresent()).isTrue();132    session = node.newSession(createSessionRequest(caps))133        .map(CreateSessionResponse::getSession);134    assertThat(session.isPresent()).isFalse();135  }136  @Test137  public void stoppingASessionReducesTheNumberOfCurrentlyActiveSessions() {138    assertThat(local.getCurrentSessionCount()).isEqualTo(0);139    Session session = local.newSession(createSessionRequest(caps))140        .map(CreateSessionResponse::getSession)141        .orElseThrow(() -> new RuntimeException("Session not created"));142    assertThat(local.getCurrentSessionCount()).isEqualTo(1);143    local.stop(session.getId());144    assertThat(local.getCurrentSessionCount()).isEqualTo(0);145  }146  @Test147  public void sessionsThatAreStoppedWillNotBeReturned() {148    Session expected = node.newSession(createSessionRequest(caps))149        .map(CreateSessionResponse::getSession)150        .orElseThrow(() -> new RuntimeException("Session not created"));151    node.stop(expected.getId());152    assertThatExceptionOfType(NoSuchSessionException.class)153        .isThrownBy(() -> local.getSession(expected.getId()));154    assertThatExceptionOfType(NoSuchSessionException.class)155        .isThrownBy(() -> node.getSession(expected.getId()));156  }157  @Test158  public void stoppingASessionThatDoesNotExistWillThrowAnException() {159    assertThatExceptionOfType(NoSuchSessionException.class)160        .isThrownBy(() -> local.stop(new SessionId(UUID.randomUUID())));161    assertThatExceptionOfType(NoSuchSessionException.class)162        .isThrownBy(() -> node.stop(new SessionId(UUID.randomUUID())));163  }164  @Test165  public void attemptingToGetASessionThatDoesNotExistWillCauseAnExceptionToBeThrown() {166    assertThatExceptionOfType(NoSuchSessionException.class)167        .isThrownBy(() -> local.getSession(new SessionId(UUID.randomUUID())));168    assertThatExceptionOfType(NoSuchSessionException.class)169        .isThrownBy(() -> node.getSession(new SessionId(UUID.randomUUID())));170  }171  @Test172  public void willRespondToWebDriverCommandsSentToOwnedSessions() throws IOException {173    AtomicBoolean called = new AtomicBoolean(false);174    class Recording extends Session implements CommandHandler {175      private Recording() {176        super(new SessionId(UUID.randomUUID()), uri, caps);177      }178      @Override179      public void execute(HttpRequest req, HttpResponse resp) {180        called.set(true);181      }182    }183    Node local = LocalNode.builder(tracer, bus, clientFactory, uri)184        .add(caps, new TestSessionFactory((id, c) -> new Recording()))185        .build();186    Node remote = new RemoteNode(187        tracer,188        new PassthroughHttpClient.Factory<>(local),189        UUID.randomUUID(),190        uri,191        ImmutableSet.of(caps));192    Session session = remote.newSession(createSessionRequest(caps))193        .map(CreateSessionResponse::getSession)194        .orElseThrow(() -> new RuntimeException("Session not created"));195    HttpRequest req = new HttpRequest(POST, String.format("/session/%s/url", session.getId()));196    remote.execute(req, new HttpResponse());197    assertThat(called.get()).isTrue();198  }199  @Test200  public void shouldOnlyRespondToWebDriverCommandsForSessionsTheNodeOwns() {201    Session session = node.newSession(createSessionRequest(caps))202        .map(CreateSessionResponse::getSession)203        .orElseThrow(() -> new RuntimeException("Session not created"));204    HttpRequest req = new HttpRequest(POST, String.format("/session/%s/url", session.getId()));205    assertThat(local.test(req)).isTrue();206    assertThat(node.test(req)).isTrue();207    req = new HttpRequest(POST, String.format("/session/%s/url", UUID.randomUUID()));208    assertThat(local.test(req)).isFalse();209    assertThat(node.test(req)).isFalse();210  }211  @Test212  public void aSessionThatTimesOutWillBeStoppedAndRemovedFromTheSessionMap() {213    AtomicReference<Instant> now = new AtomicReference<>(Instant.now());214    Clock clock = new MyClock(now);215    Node node = LocalNode.builder(tracer, bus, clientFactory, uri)216        .add(caps, new TestSessionFactory((id, c) -> new Session(id, uri, c)))217        .sessionTimeout(Duration.ofMinutes(3))218        .advanced()219        .clock(clock)220        .build();221    Session session = node.newSession(createSessionRequest(caps))222        .map(CreateSessionResponse::getSession)223        .orElseThrow(() -> new RuntimeException("Session not created"));224    now.set(now.get().plus(Duration.ofMinutes(5)));225    assertThatExceptionOfType(NoSuchSessionException.class)226        .isThrownBy(() -> node.getSession(session.getId()));227  }228  @Test229  public void shouldNotPropagateExceptionsWhenSessionCreationFails() {230    Node local = LocalNode.builder(tracer, bus, clientFactory, uri)231        .add(caps, new TestSessionFactory((id, c) -> {232          throw new SessionNotCreatedException("eeek");233        }))234        .build();235    Optional<Session> session = local.newSession(createSessionRequest(caps))236        .map(CreateSessionResponse::getSession);237    assertThat(session.isPresent()).isFalse();238  }239  @Test240  public void eachSessionShouldReportTheNodesUrl() throws URISyntaxException {241    URI sessionUri = new URI("http://cheese:42/peas");242    Node node = LocalNode.builder(tracer, bus, clientFactory, uri)243        .add(caps, new TestSessionFactory((id, c) -> new Session(id, sessionUri, c)))244        .build();245    Optional<Session> session = node.newSession(createSessionRequest(caps))246        .map(CreateSessionResponse::getSession);247    assertThat(session.isPresent()).isTrue();248    assertThat(session.get().getUri()).isEqualTo(uri);249  }250  @Test251  public void quittingASessionShouldCauseASessionClosedEventToBeFired() {252    AtomicReference<Object> obj = new AtomicReference<>();253    bus.addListener(SESSION_CLOSED, event -> obj.set(event.getData(Object.class)));254    Session session = node.newSession(createSessionRequest(caps))255        .map(CreateSessionResponse::getSession)256        .orElseThrow(() -> new AssertionError("Cannot create session"));257    node.stop(session.getId());258    // Because we're using the event bus, we can't expect the event to fire instantly. We're using259    // an inproc bus, so in reality it's reasonable to expect the event to fire synchronously, but260    // let's play it safe.261    Wait<AtomicReference<Object>> wait = new FluentWait<>(obj).withTimeout(ofSeconds(2));262    wait.until(ref -> ref.get() != null);263  }264  private CreateSessionRequest createSessionRequest(Capabilities caps) {265    return new CreateSessionRequest(266            ImmutableSet.copyOf(Dialect.values()),267            caps,268            ImmutableMap.of());...

Source:LocalDistributor.java

...81      add(node);82    });83  }84  @Override85  public Session newSession(NewSessionPayload payload) throws SessionNotCreatedException {86    Iterator<Capabilities> allCaps = payload.stream().iterator();87    if (!allCaps.hasNext()) {88      throw new SessionNotCreatedException("No capabilities found");89    }90    Capabilities caps = allCaps.next();91    Optional<Supplier<Session>> selected;92    Lock writeLock = this.lock.writeLock();93    writeLock.lock();94    try {95      selected = this.hosts.stream()96          .filter(host -> host.getHostStatus() == UP)97          // Find a host that supports this kind of thing98          .filter(host -> host.hasCapacity(caps))99          .min(...

Source:RemoteNode.java

...74                caps.getCapability(name),75                capabilities.getCapability(name))));76  }77  @Override78  public Optional<Session> newSession(Capabilities capabilities) {79    Objects.requireNonNull(capabilities, "Capabilities for session are not set");80    HttpRequest req = new HttpRequest(POST, "/se/grid/node/session");81    req.setContent(JSON.toJson(capabilities).getBytes(UTF_8));82    HttpResponse res = client.apply(req);83    return Optional.ofNullable(Values.get(res, Session.class));84  }85  @Override86  protected boolean isSessionOwner(SessionId id) {87    Objects.requireNonNull(id, "Session ID has not been set");88    HttpRequest req = new HttpRequest(GET, "/se/grid/node/owner/" + id);89    HttpResponse res = client.apply(req);90    return Values.get(res, Boolean.class) == Boolean.TRUE;91  }92  @Override...

newSession

Using AI Code Generation

1import org.openqa.selenium.grid.node.remote.RemoteNode;2import org.openqa.selenium.grid.node.remote.RemoteNodeFactory;3import org.openqa.selenium.grid.node.remote.RemoteNodeOptions;4import org.openqa.selenium.remote.http.HttpClient;5import org.openqa.selenium.remote.http.HttpClientFactory;6import java.net.URI;7import java.net.URISyntaxException;8import java.util.logging.Logger;9public class NewSession {10    private static final Logger LOG = Logger.getLogger(NewSession.class.getName());11    public static void main(String[] args) throws URISyntaxException {12        HttpClientFactory factory = HttpClient.Factory.createDefault();13        RemoteNodeOptions options = new RemoteNodeOptions();14        RemoteNode node = new RemoteNodeFactory(factory, options).createRemoteNode();15        node.newSession(null, null);16    }17}18[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ selenium-grid-node ---19[INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ selenium-grid-node ---20[INFO] --- maven-resources-plugin:2.6:testResources (default-testResources) @ selenium-grid-node ---21[INFO] --- maven-compiler-plugin:3.1:testCompile (default-testCompile) @ selenium-grid-node ---22[INFO] --- maven-surefire-plugin:2.22.0:test (default-test) @ selenium

newSession

Using AI Code Generation

1import org.openqa.selenium.Capabilities;2import org.openqa.selenium.ImmutableCapabilities;3import org.openqa.selenium.grid.config.Config;4import org.openqa.selenium.grid.config.MapConfig;5import org.openqa.selenium.grid.data.Session;6import org.openqa.selenium.grid.data.SessionId;7import org.openqa.selenium.grid.node.remote.RemoteNode;8import org.openqa.selenium.grid.sessionmap.remote.RemoteSessionMap;9import org.openqa.selenium.remote.http.HttpClient;10import org.openqa.selenium.remote.tracing.DefaultTestTracer;11import org.openqa.selenium.remote.tracing.Tracer;12import java.net.URI;13import java.net.URISyntaxException;14import java.util.HashMap;15import java.util.Map;16public class NewSession {17    public static void main(String[] args) throws URISyntaxException {18        Map<String, String> configMap = new HashMap<>();19        Config config = new MapConfig(configMap);20        RemoteSessionMap sessionMap = new RemoteSessionMap(DefaultTestTracer.createTracer(), HttpClient.Factory.createDefault().createClient(URI.create(config.get("session-map"))));21        RemoteNode node = new RemoteNode(DefaultTestTracer.createTracer(), HttpClient.Factory.createDefault().createClient(URI.create(config.get("node"))));22        Capabilities capabilities = new ImmutableCapabilities("browserName", "chrome");23        SessionId sessionId = node.newSession(capabilities);24        Session session = sessionMap.get(sessionId);25        System.out.println("Session ID: " + session.getId());26        System.out.println("Session URI: " + session.getUri());27        System.out.println("Session Capabilities: " + session.getCapabilities());28    }29}

newSession

Using AI Code Generation

1{2  "value": {3    "capabilities": {4      "chrome": {5        "chromedriverVersion": "89.0.4389.23 (edb0a1f1c1a8a7a2b2f16b7f4c4e8a7d4a1f4e7a-refs/branch-heads/4389@{#1026})",6      },7      "goog:chromeOptions": {8      },9      "proxy": {},10      "timeouts": {11      },12    }13  }14}15{16}

Selenium 4 Tutorial:

LambdaTest’s Selenium 4 tutorial is covering every aspects of Selenium 4 testing with examples and best practices. Here you will learn basics, such as how to upgrade from Selenium 3 to Selenium 4, to some advanced concepts, such as Relative locators and Selenium Grid 4 for Distributed testing. Also will learn new features of Selenium 4, such as capturing screenshots of specific elements, opening a new tab or window on the browser, and new protocol adoptions.

Chapters:

Upgrading From Selenium 3 To Selenium 4?: In this chapter, learn in detail how to update Selenium 3 to Selenium 4 for Java binding. Also, learn how to upgrade while using different build tools such as Maven or Gradle and get comprehensive guidance for upgrading Selenium.
What’s New In Selenium 4 & What’s Being Deprecated? : Get all information about new implementations in Selenium 4, such as W3S protocol adaption, Optimized Selenium Grid, and Enhanced Selenium IDE. Also, learn what is deprecated for Selenium 4, such as DesiredCapabilites and FindsBy methods, etc.
Selenium 4 With Python: Selenium supports all major languages, such as Python, C#, Ruby, and JavaScript. In this chapter, learn how to install Selenium 4 for Python and the features of Python in Selenium 4, such as Relative locators, Browser manipulation, and Chrom DevTool protocol.
Selenium 4 Is Now W3C Compliant: JSON Wireframe protocol is retiring from Selenium 4, and they are adopting W3C protocol to learn in detail about the advantages and impact of these changes.
How To Use Selenium 4 Relative Locator? : Selenium 4 came with new features such as Relative Locators that allow constructing locators with reference and easily located constructors nearby. Get to know its different use cases with examples.
Selenium Grid 4 Tutorial For Distributed Testing: Selenium Grid 4 allows you to perform tests over different browsers, OS, and device combinations. It also enables parallel execution browser testing, reads up on various features of Selenium Grid 4 and how to download it, and runs a test on Selenium Grid 4 with best practices.
Selenium Video Tutorials: Binge on video tutorials on Selenium by industry experts to get step-by-step direction from automating basic to complex test scenarios with Selenium.