Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More
How to use toString method of org.openqa.selenium.grid.data.RequestId class
Best Selenium code snippet using org.openqa.selenium.grid.data.RequestId.toString
Source:GraphqlHandlerTest.java 
...132 assertThat(topLevel).isEqualTo(133 singletonMap(134 "data", singletonMap(135 "grid", singletonMap(136 "uri", publicUri.toString()))));137 }138 @Test139 public void shouldBeAbleToGetGridVersion() {140 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);141 Map<String, Object> topLevel = executeQuery(handler, "{ grid { version } }");142 assertThat(topLevel).isEqualTo(143 singletonMap(144 "data", singletonMap(145 "grid", singletonMap(146 "version", version))));147 }148 private void continueOnceAddedToQueue(SessionRequest request) {149 // Add to the queue in the background150 CountDownLatch latch = new CountDownLatch(1);151 events.addListener(NewSessionRequestEvent.listener(id -> latch.countDown()));152 new Thread(() -> {153 queue.addToQueue(request);154 }).start();155 try {156 assertThat(latch.await(5, SECONDS)).isTrue();157 } catch (InterruptedException e) {158 Thread.currentThread().interrupt();159 throw new RuntimeException(e);160 }161 }162 @Test163 public void shouldBeAbleToGetSessionQueueSize() throws URISyntaxException {164 SessionRequest request = new SessionRequest(165 new RequestId(UUID.randomUUID()),166 Instant.now(),167 Set.of(W3C),168 Set.of(caps),169 Map.of(),170 Map.of());171 continueOnceAddedToQueue(request);172 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);173 Map<String, Object> topLevel = executeQuery(handler, "{ grid { sessionQueueSize } }");174 assertThat(topLevel).isEqualTo(175 singletonMap(176 "data", singletonMap(177 "grid", singletonMap(178 "sessionQueueSize", 1L))));179 }180 @Test181 public void shouldBeAbleToGetSessionQueueRequests() throws URISyntaxException {182 SessionRequest request = new SessionRequest(183 new RequestId(UUID.randomUUID()),184 Instant.now(),185 Set.of(W3C),186 Set.of(caps),187 Map.of(),188 Map.of());189 continueOnceAddedToQueue(request);190 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);191 Map<String, Object> topLevel = executeQuery(handler,192 "{ sessionsInfo { sessionQueueRequests } }");193 assertThat(topLevel).isEqualTo(194 singletonMap(195 "data", singletonMap(196 "sessionsInfo", singletonMap(197 "sessionQueueRequests", singletonList(JSON.toJson(caps))))));198 }199 @Test200 public void shouldBeReturnAnEmptyListIfQueueIsEmpty() {201 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);202 Map<String, Object> topLevel = executeQuery(handler,203 "{ sessionsInfo { sessionQueueRequests } }");204 assertThat(topLevel).isEqualTo(205 singletonMap(206 "data", singletonMap(207 "sessionsInfo", singletonMap(208 "sessionQueueRequests", Collections.emptyList()))));209 }210 @Test211 public void shouldReturnAnEmptyListForNodesIfNoneAreRegistered() {212 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);213 Map<String, Object> topLevel = executeQuery(handler, "{ nodesInfo { nodes { uri } } }");214 assertThat(topLevel).describedAs(topLevel.toString()).isEqualTo(215 singletonMap(216 "data", singletonMap(217 "nodesInfo", singletonMap(218 "nodes", Collections.emptyList()))));219 }220 @Test221 public void shouldBeAbleToGetUrlsOfAllNodes() throws URISyntaxException {222 Capabilities stereotype = new ImmutableCapabilities("cheese", "stilton");223 String nodeUri = "http://localhost:5556";224 Node node = LocalNode.builder(tracer, events, new URI(nodeUri), publicUri, registrationSecret)225 .add(stereotype, new SessionFactory() {226 @Override227 public Either<WebDriverException, ActiveSession> apply(228 CreateSessionRequest createSessionRequest) {229 return Either.left(new SessionNotCreatedException("Factory for testing"));230 }231 @Override232 public boolean test(Capabilities capabilities) {233 return false;234 }235 })236 .build();237 distributor.add(node);238 wait.until(obj -> distributor.getStatus().hasCapacity());239 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);240 Map<String, Object> topLevel = executeQuery(handler, "{ nodesInfo { nodes { uri } } }");241 assertThat(topLevel).describedAs(topLevel.toString()).isEqualTo(242 singletonMap(243 "data", singletonMap(244 "nodesInfo", singletonMap(245 "nodes", singletonList(singletonMap("uri", nodeUri))))));246 }247 @Test248 public void shouldBeAbleToGetSessionCount() throws URISyntaxException {249 String nodeUrl = "http://localhost:5556";250 URI nodeUri = new URI(nodeUrl);251 Node node = LocalNode.builder(tracer, events, nodeUri, publicUri, registrationSecret)252 .add(caps, new TestSessionFactory((id, caps) -> new org.openqa.selenium.grid.data.Session(253 id,254 nodeUri,255 stereotype,256 caps,257 Instant.now()))).build();258 distributor.add(node);259 wait.until(obj -> distributor.getStatus().hasCapacity());260 Either<SessionNotCreatedException, CreateSessionResponse> response = distributor.newSession(sessionRequest);261 if (response.isRight()) {262 Session session = response.right().getSession();263 assertThat(session).isNotNull();264 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);265 Map<String, Object> topLevel = executeQuery(handler,266 "{ grid { sessionCount } }");267 assertThat(topLevel).isEqualTo(268 singletonMap(269 "data", singletonMap(270 "grid", singletonMap(271 "sessionCount", 1L ))));272 } else {273 fail("Session creation failed", response.left());274 }275 }276 @Test277 public void shouldBeAbleToGetSessionInfo() throws URISyntaxException {278 String nodeUrl = "http://localhost:5556";279 URI nodeUri = new URI(nodeUrl);280 Node node = LocalNode.builder(tracer, events, nodeUri, publicUri, registrationSecret)281 .add(caps, new TestSessionFactory((id, caps) -> new org.openqa.selenium.grid.data.Session(282 id,283 nodeUri,284 stereotype,285 caps,286 Instant.now()))).build();287 distributor.add(node);288 wait.until(obj -> distributor.getStatus().hasCapacity());289 Either<SessionNotCreatedException, CreateSessionResponse> response = distributor.newSession(sessionRequest);290 if (response.isRight()) {291 Session session = response.right().getSession();292 assertThat(session).isNotNull();293 String sessionId = session.getId().toString();294 Set<Slot> slots = distributor.getStatus().getNodes().stream().findFirst().get().getSlots();295 Slot slot = slots.stream().findFirst().get();296 org.openqa.selenium.grid.graphql.Session graphqlSession =297 new org.openqa.selenium.grid.graphql.Session(298 sessionId,299 session.getCapabilities(),300 session.getStartTime(),301 session.getUri(),302 node.getId().toString(),303 node.getUri(),304 slot);305 String query = String.format(306 "{ session (id: \"%s\") { id, capabilities, startTime, uri } }", sessionId);307 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);308 Map<String, Object> result = executeQuery(handler, query);309 assertThat(result).describedAs(result.toString()).isEqualTo(310 singletonMap(311 "data", singletonMap(312 "session", ImmutableMap.of(313 "id", sessionId,314 "capabilities", graphqlSession.getCapabilities(),315 "startTime", graphqlSession.getStartTime(),316 "uri", graphqlSession.getUri().toString()))));317 } else {318 fail("Session creation failed", response.left());319 }320 }321 @Test322 public void shouldBeAbleToGetNodeInfoForSession() throws URISyntaxException {323 String nodeUrl = "http://localhost:5556";324 URI nodeUri = new URI(nodeUrl);325 Node node = LocalNode.builder(tracer, events, nodeUri, publicUri, registrationSecret)326 .add(caps, new TestSessionFactory((id, caps) -> new org.openqa.selenium.grid.data.Session(327 id,328 nodeUri,329 stereotype,330 caps,331 Instant.now()))).build();332 distributor.add(node);333 wait.until(obj -> distributor.getStatus().hasCapacity());334 Either<SessionNotCreatedException, CreateSessionResponse> response = distributor.newSession(sessionRequest);335 if (response.isRight()) {336 Session session = response.right().getSession();337 assertThat(session).isNotNull();338 String sessionId = session.getId().toString();339 Set<Slot> slots = distributor.getStatus().getNodes().stream().findFirst().get().getSlots();340 Slot slot = slots.stream().findFirst().get();341 org.openqa.selenium.grid.graphql.Session graphqlSession =342 new org.openqa.selenium.grid.graphql.Session(343 sessionId,344 session.getCapabilities(),345 session.getStartTime(),346 session.getUri(),347 node.getId().toString(),348 node.getUri(),349 slot);350 String query = String.format("{ session (id: \"%s\") { nodeId, nodeUri } }", sessionId);351 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);352 Map<String, Object> result = executeQuery(handler, query);353 assertThat(result).describedAs(result.toString()).isEqualTo(354 singletonMap(355 "data", singletonMap(356 "session", ImmutableMap.of(357 "nodeId", graphqlSession.getNodeId(),358 "nodeUri", graphqlSession.getNodeUri().toString()))));359 } else {360 fail("Session creation failed", response.left());361 }362 }363 @Test364 public void shouldBeAbleToGetSlotInfoForSession() throws URISyntaxException {365 String nodeUrl = "http://localhost:5556";366 URI nodeUri = new URI(nodeUrl);367 Node node = LocalNode.builder(tracer, events, nodeUri, publicUri, registrationSecret)368 .add(caps, new TestSessionFactory((id, caps) -> new org.openqa.selenium.grid.data.Session(369 id,370 nodeUri,371 stereotype,372 caps,373 Instant.now()))).build();374 distributor.add(node);375 wait.until(obj -> distributor.getStatus().hasCapacity());376 Either<SessionNotCreatedException, CreateSessionResponse> response = distributor.newSession(sessionRequest);377 if (response.isRight()) {378 Session session = response.right().getSession();379 assertThat(session).isNotNull();380 String sessionId = session.getId().toString();381 Set<Slot> slots = distributor.getStatus().getNodes().stream().findFirst().get().getSlots();382 Slot slot = slots.stream().findFirst().get();383 org.openqa.selenium.grid.graphql.Session graphqlSession =384 new org.openqa.selenium.grid.graphql.Session(385 sessionId,386 session.getCapabilities(),387 session.getStartTime(),388 session.getUri(),389 node.getId().toString(),390 node.getUri(),391 slot);392 org.openqa.selenium.grid.graphql.Slot graphqlSlot = graphqlSession.getSlot();393 String query = String.format(394 "{ session (id: \"%s\") { slot { id, stereotype, lastStarted } } }", sessionId);395 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);396 Map<String, Object> result = executeQuery(handler, query);397 assertThat(result).describedAs(result.toString()).isEqualTo(398 singletonMap(399 "data", singletonMap(400 "session", singletonMap(401 "slot", ImmutableMap.of(402 "id", graphqlSlot.getId(),403 "stereotype", graphqlSlot.getStereotype(),404 "lastStarted", graphqlSlot.getLastStarted())))));405 } else {406 fail("Session creation failed", response.left());407 }408 }409 @Test410 public void shouldBeAbleToGetSessionDuration() throws URISyntaxException {411 String nodeUrl = "http://localhost:5556";412 URI nodeUri = new URI(nodeUrl);413 Node node = LocalNode.builder(tracer, events, nodeUri, publicUri, registrationSecret)414 .add(caps, new TestSessionFactory((id, caps) -> new org.openqa.selenium.grid.data.Session(415 id,416 nodeUri,417 stereotype,418 caps,419 Instant.now()))).build();420 distributor.add(node);421 wait.until(obj -> distributor.getStatus().hasCapacity());422 Either<SessionNotCreatedException, CreateSessionResponse> response = distributor.newSession(sessionRequest);423 if (response.isRight()) {424 Session session = response.right().getSession();425 assertThat(session).isNotNull();426 String sessionId = session.getId().toString();427 String query = String.format("{ session (id: \"%s\") { sessionDurationMillis } }", sessionId);428 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);429 Map<String, Object> result = executeQuery(handler, query);430 assertThat(result)431 .containsOnlyKeys("data")432 .extracting("data").asInstanceOf(MAP).containsOnlyKeys("session")433 .extracting("session").asInstanceOf(MAP).containsOnlyKeys("sessionDurationMillis");434 } else {435 fail("Session creation failed", response.left());436 }437 }438 @Test439 public void shouldThrowExceptionWhenSessionNotFound() throws URISyntaxException {440 String nodeUrl = "http://localhost:5556";441 URI nodeUri = new URI(nodeUrl);442 Node node = LocalNode.builder(tracer, events, nodeUri, publicUri, registrationSecret)443 .add(caps, new TestSessionFactory((id, caps) -> new org.openqa.selenium.grid.data.Session(444 id,445 nodeUri,446 stereotype,447 caps,448 Instant.now()))).build();449 distributor.add(node);450 wait.until(obj -> distributor.getStatus().hasCapacity());451 String randomSessionId = UUID.randomUUID().toString();452 String query = "{ session (id: \"" + randomSessionId + "\") { sessionDurationMillis } }";453 GraphqlHandler handler = new GraphqlHandler(tracer, distributor, queue, publicUri, version);454 Map<String, Object> result = executeQuery(handler, query);455 assertThat(result)456 .containsEntry("data", null)457 .containsKey("errors")458 .extracting("errors").asInstanceOf(LIST).isNotEmpty()459 .element(0).asInstanceOf(MAP).containsKey("extensions")460 .extracting("extensions").asInstanceOf(MAP).containsKey("sessionId")461 .extracting("sessionId").isEqualTo(randomSessionId);462 }463 @Test464 public void shouldThrowExceptionWhenSessionIsEmpty() throws URISyntaxException {465 String nodeUrl = "http://localhost:5556";...
Source:NewSessionQueuerTest.java
...324 HttpClient client = new PassthroughHttpClient(local);325 remote = new RemoteNewSessionQueuer(tracer, client);326 HttpRequest request = createRequest(payload, POST, "/session");327 request.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER,328 Long.toString(1539091064));329 AtomicInteger count = new AtomicInteger();330 bus.addListener(NewSessionRequestEvent.listener(reqId -> {331 // Add to front of queue, when retry is triggered it will check if request timed out332 count.incrementAndGet();333 remote.retryAddToQueue(request, reqId);334 }));335 HttpResponse httpResponse = remote.addToQueue(request);336 assertEquals(count.get(),1);337 assertEquals(httpResponse.getStatus(), HTTP_INTERNAL_ERROR);338 }339 @Test340 public void shouldBeAbleToTimeoutARequestOnPoll() {341 Tracer tracer = DefaultTestTracer.createTracer();342 LocalNewSessionQueue sessionQueue = new LocalNewSessionQueue(343 tracer,344 bus,345 Duration.ofSeconds(4),346 Duration.ofSeconds(0));347 local = new LocalNewSessionQueuer(tracer, bus, sessionQueue);348 HttpClient client = new PassthroughHttpClient(local);349 remote = new RemoteNewSessionQueuer(tracer, client);350 AtomicBoolean isPresent = new AtomicBoolean();351 bus.addListener(NewSessionRequestEvent.listener(reqId -> {352 Optional<HttpRequest> request = remote.remove();353 isPresent.set(request.isPresent());354 bus.fire(355 new NewSessionRejectedEvent(356 new NewSessionErrorResponse(reqId, "Error")));357 }));358 HttpResponse httpResponse = remote.addToQueue(request);359 assertEquals(httpResponse.getStatus(), HTTP_INTERNAL_ERROR);360 assertThat(isPresent.get()).isFalse();361 }362 @Test363 public void shouldBeAbleToClearQueueAndRejectMultipleRequests() {364 ExecutorService executor = Executors.newFixedThreadPool(2);365 Callable<HttpResponse> callable = () -> remote.addToQueue(request);366 Future<HttpResponse> firstRequest = executor.submit(callable);367 Future<HttpResponse> secondRequest = executor.submit(callable);368 int count = 0;369 while (count < 2) {370 count += remote.clearQueue();371 }372 try {373 HttpResponse firstResponse = firstRequest.get(30, TimeUnit.SECONDS);374 HttpResponse secondResponse = secondRequest.get(30, TimeUnit.SECONDS);375 assertEquals(firstResponse.getStatus(), HTTP_INTERNAL_ERROR);376 assertEquals(secondResponse.getStatus(), HTTP_INTERNAL_ERROR);377 } catch (InterruptedException | ExecutionException | TimeoutException e) {378 fail("Could not create session");379 }380 executor.shutdown();381 }382 private HttpRequest createRequest(NewSessionPayload payload, HttpMethod httpMethod, String uri) {383 StringBuilder builder = new StringBuilder();384 try {385 payload.writeTo(builder);386 } catch (IOException e) {387 throw new UncheckedIOException(e);388 }389 HttpRequest request = new HttpRequest(httpMethod, uri);390 request.setContent(utf8String(builder.toString()));391 return request;392 }393}...
Source:LocalDistributor.java
...368 Map<String, EventAttributeValue> attributeMap = new HashMap<>();369 attributeMap.put(370 AttributeKey.LOGGER_CLASS.getKey(),371 EventAttribute.setValue(getClass().getName()));372 span.setAttribute(AttributeKey.REQUEST_ID.getKey(), reqId.toString());373 attributeMap.put(374 AttributeKey.REQUEST_ID.getKey(),375 EventAttribute.setValue(reqId.toString()));376 attributeMap.put("request", EventAttribute.setValue(sessionRequest.toString()));377 Either<SessionNotCreatedException, CreateSessionResponse> response =378 newSession(sessionRequest);379 if (response.isRight()) {380 CreateSessionResponse sessionResponse = response.right();381 NewSessionResponse newSessionResponse =382 new NewSessionResponse(383 reqId,384 sessionResponse.getSession(),385 sessionResponse.getDownstreamEncodedResponse());386 bus.fire(new NewSessionResponseEvent(newSessionResponse));387 } else {388 SessionNotCreatedException exception = response.left();389 if (exception instanceof RetrySessionRequestException) {390 boolean retried = sessionRequests.retryAddToQueue(sessionRequest, reqId);...
Source:LocalNewSessionQueueTest.java
...99 long timestamp = Instant.now().getEpochSecond();100 ImmutableCapabilities chromeCaps = new ImmutableCapabilities("browserName", "chrome");101 NewSessionPayload chromePayload = NewSessionPayload.create(chromeCaps);102 HttpRequest chromeRequest = createRequest(chromePayload, POST, "/session");103 chromeRequest.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER, Long.toString(timestamp));104 RequestId chromeRequestId = new RequestId(UUID.randomUUID());105 ImmutableCapabilities firefoxCaps = new ImmutableCapabilities("browserName", "firefox");106 NewSessionPayload firefoxpayload = NewSessionPayload.create(firefoxCaps);107 HttpRequest firefoxRequest = createRequest(firefoxpayload, POST, "/session");108 firefoxRequest.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER, Long.toString(timestamp));109 RequestId firefoxRequestId = new RequestId(UUID.randomUUID());110 boolean addedChromeRequest = sessionQueue.offerFirst(chromeRequest, chromeRequestId);111 assertTrue(addedChromeRequest);112 boolean addFirefoxRequest = sessionQueue.offerFirst(firefoxRequest, firefoxRequestId);113 assertTrue(addFirefoxRequest);114 Optional<HttpRequest> polledChromeRequest = sessionQueue.remove(chromeRequestId);115 assertTrue(polledChromeRequest.isPresent());116 assertEquals(chromeRequest, polledChromeRequest.get());117 Optional<HttpRequest> polledFirefoxRequest = sessionQueue.remove(firefoxRequestId);118 assertTrue(polledFirefoxRequest.isPresent());119 assertEquals(firefoxRequest, polledFirefoxRequest.get());120 }121 @Test122 public void shouldAddTimestampHeader() {123 boolean added = sessionQueue.offerLast(expectedSessionRequest, requestId);124 assertTrue(added);125 Optional<HttpRequest> receivedRequest = sessionQueue.remove(requestId);126 assertTrue(receivedRequest.isPresent());127 HttpRequest request = receivedRequest.get();128 assertEquals(expectedSessionRequest, request);129 assertTrue(request.getHeader(NewSessionQueue.SESSIONREQUEST_TIMESTAMP_HEADER) != null);130 }131 @Test132 public void shouldAddRequestIdHeader() {133 boolean added = sessionQueue.offerLast(expectedSessionRequest, requestId);134 assertTrue(added);135 Optional<HttpRequest> receivedRequest = sessionQueue.remove(requestId);136 assertTrue(receivedRequest.isPresent());137 HttpRequest request = receivedRequest.get();138 assertEquals(expectedSessionRequest, request);139 String polledRequestId = request.getHeader(NewSessionQueue.SESSIONREQUEST_ID_HEADER);140 assertTrue(polledRequestId != null);141 assertEquals(requestId, new RequestId(UUID.fromString(polledRequestId)));142 }143 @Test144 public void shouldBeAbleToAddToFrontOfQueue() {145 long timestamp = Instant.now().getEpochSecond();146 ImmutableCapabilities chromeCaps = new ImmutableCapabilities("browserName", "chrome");147 NewSessionPayload chromePayload = NewSessionPayload.create(chromeCaps);148 HttpRequest chromeRequest = createRequest(chromePayload, POST, "/session");149 chromeRequest.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER, Long.toString(timestamp));150 RequestId chromeRequestId = new RequestId(UUID.randomUUID());151 ImmutableCapabilities firefoxCaps = new ImmutableCapabilities("browserName", "firefox");152 NewSessionPayload firefoxpayload = NewSessionPayload.create(firefoxCaps);153 HttpRequest firefoxRequest = createRequest(firefoxpayload, POST, "/session");154 firefoxRequest.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER, Long.toString(timestamp));155 RequestId firefoxRequestId = new RequestId(UUID.randomUUID());156 boolean addedChromeRequest = sessionQueue.offerFirst(chromeRequest, chromeRequestId);157 assertTrue(addedChromeRequest);158 boolean addFirefoxRequest = sessionQueue.offerFirst(firefoxRequest, firefoxRequestId);159 assertTrue(addFirefoxRequest);160 Optional<HttpRequest> polledFirefoxRequest = sessionQueue.remove(firefoxRequestId);161 assertTrue(polledFirefoxRequest.isPresent());162 assertEquals(firefoxRequest, polledFirefoxRequest.get());163 Optional<HttpRequest> polledChromeRequest = sessionQueue.remove(chromeRequestId);164 assertTrue(polledChromeRequest.isPresent());165 assertEquals(chromeRequest, polledChromeRequest.get());166 }167 @Test168 public void shouldBeClearAPopulatedQueue() {169 sessionQueue.offerLast(expectedSessionRequest, new RequestId(UUID.randomUUID()));170 sessionQueue.offerLast(expectedSessionRequest, new RequestId(UUID.randomUUID()));171 int count = sessionQueue.clear();172 assertEquals(count, 2);173 }174 @Test175 public void shouldBeClearAEmptyQueue() {176 int count = sessionQueue.clear();177 assertEquals(count, 0);178 }179 @Test180 public void shouldBeAbleToGetQueueSize() {181 boolean added = sessionQueue.offerLast(expectedSessionRequest, requestId);182 assertTrue(added);183 int size = sessionQueue.getQueueSize();184 assertEquals(1, size);185 }186 @Test187 public void shouldBeAbleToGetQueueContents() {188 long timestamp = Instant.now().getEpochSecond();189 ImmutableCapabilities chromeCaps = new ImmutableCapabilities(190 "browserName", "chrome",191 "platform", "mac",192 "version", "87");193 NewSessionPayload chromePayload = NewSessionPayload.create(chromeCaps);194 HttpRequest chromeRequest = createRequest(chromePayload, POST, "/session");195 chromeRequest.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER, Long.toString(timestamp));196 RequestId chromeRequestId = new RequestId(UUID.randomUUID());197 boolean addedChromeRequest = sessionQueue.offerLast(chromeRequest, chromeRequestId);198 assertTrue(addedChromeRequest);199 ImmutableCapabilities firefoxCaps = new ImmutableCapabilities(200 "browserName", "firefox",201 "platform", "windows",202 "version", "84");203 NewSessionPayload firefoxPayload = NewSessionPayload.create(firefoxCaps);204 HttpRequest firefoxRequest = createRequest(firefoxPayload, POST, "/session");205 firefoxRequest.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER, Long.toString(timestamp));206 RequestId firefoxRequestId = new RequestId(UUID.randomUUID());207 boolean addFirefoxRequest = sessionQueue.offerLast(firefoxRequest, firefoxRequestId);208 assertTrue(addFirefoxRequest);209 List<Object> response = sessionQueue.getQueuedRequests();210 assertThat(response).isNotNull();211 assertEquals(2, response.size());212 assertEquals(chromeCaps, response.get(0));213 assertEquals(firefoxCaps, response.get(1));214 }215 @Test216 public void shouldBeAbleToRemoveRequestsOnTimeout() throws InterruptedException {217 NewSessionQueue localSessionQueue = new LocalNewSessionQueue(218 DefaultTestTracer.createTracer(),219 bus,220 Duration.ofSeconds(30),221 Duration.ofSeconds(1));222 CountDownLatch latch = new CountDownLatch(1);223 bus.addListener(NewSessionRejectedEvent.listener(reqId -> latch.countDown()));224 boolean added = localSessionQueue.offerLast(expectedSessionRequest, requestId);225 assertTrue(added);226 boolean requestExpired = latch.await(2, TimeUnit.MINUTES);227 assertThat(requestExpired).isTrue();228 assertThat(localSessionQueue.getQueueSize()).isZero();229 }230 private HttpRequest createRequest(NewSessionPayload payload, HttpMethod httpMethod, String uri) {231 StringBuilder builder = new StringBuilder();232 try {233 payload.writeTo(builder);234 } catch (IOException e) {235 throw new UncheckedIOException(e);236 }237 HttpRequest request = new HttpRequest(httpMethod, uri);238 request.setContent(utf8String(builder.toString()));239 return request;240 }241}...
Source:LocalNewSessionQueue.java
...83 try {84 added = sessionRequests.offerLast(request);85 addRequestHeaders(request, requestId);86 attributeMap87 .put(AttributeKey.REQUEST_ID.getKey(), EventAttribute.setValue(requestId.toString()));88 attributeMap.put("request.added", EventAttribute.setValue(added));89 span.addEvent("Add new session request to the queue", attributeMap);90 return added;91 } finally {92 writeLock.unlock();93 span.close();94 if (added) {95 bus.fire(new NewSessionRequestEvent(requestId));96 }97 }98 }99 @Override100 public boolean offerFirst(HttpRequest request, RequestId requestId) {101 Require.nonNull("New Session request", request);...
Source:AddBackToSessionQueue.java
...42 @Override43 public HttpResponse execute(HttpRequest req) {44 try (Span span = newSpanAsChildOf(tracer, req, "sessionqueue.retry")) {45 HTTP_REQUEST.accept(span, req);46 span.setAttribute(AttributeKey.REQUEST_ID.getKey(), id.toString());47 SessionRequest sessionRequest = Contents.fromJson(req, SessionRequest.class);48 boolean value = newSessionQueue.retryAddToQueue(sessionRequest);49 span.setAttribute("request.retry", value);50 HttpResponse response = new HttpResponse()51 .setContent(asJson(singletonMap("value", value)));52 HTTP_RESPONSE.accept(span, response);53 return response;54 }55 }56}...
Source:RequestId.java
...26 public UUID toUuid() {27 return uuid;28 }29 @Override30 public String toString() {31 return uuid.toString();32 }33 @Override34 public boolean equals(Object o) {35 if (!(o instanceof RequestId)) {36 return false;37 }38 RequestId that = (RequestId) o;39 return Objects.equals(this.uuid, that.uuid);40 }41 @Override42 public int hashCode() {43 return Objects.hash(uuid);44 }45 private Object toJson() {...
toString
Using AI Code Generation
1import org.openqa.selenium.grid.data.RequestId;2public class RequestIdExample {3 public static void main(String[] args) {4 RequestId id = new RequestId("1234-5678-9012-3456");5 System.out.println(id.toString());6 }7}
toString
Using AI Code Generation
1import org.openqa.selenium.grid.data.RequestId;2public class RequestIdToStringExample {3 public static void main(String[] args) {4 RequestId requestId = new RequestId("1234-5678-1234-5678");5 System.out.println("RequestId: "+requestId.toString());6 }7}
toString
Using AI Code Generation
1public class RequestId {2 private final String id;3 public RequestId(String id) {4 this.id = id;5 }6 public String toString() {7 return id;8 }9}
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.
Selenium 101 certifications:
LambdaTest also provides certification for Selenium testing to accelerate your career in Selenium automation testing.
Run Selenium automation tests on LambdaTest cloud grid
Perform automation testing on 3000+ real desktop and mobile devices online.
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
