How to use stream method of org.openqa.selenium.remote.NewSessionPayload class
Best Selenium code snippet using org.openqa.selenium.remote.NewSessionPayload.stream
Source:NewSessionPayload.java 
...66import java.util.ServiceLoader;67import java.util.Set;68import java.util.TreeMap;69import java.util.function.Predicate;70import java.util.stream.Collectors;71import java.util.stream.Stream;72public class NewSessionPayload implements Closeable {73 private final Set<CapabilitiesFilter> adapters;74 private final Set<CapabilityTransform> transforms;75 private static final Dialect DEFAULT_DIALECT = Dialect.OSS;76 private final static Predicate<String> ACCEPTED_W3C_PATTERNS = new AcceptedW3CCapabilityKeys();77 private final Json json = new Json();78 private final FileBackedOutputStream backingStore;79 private final ImmutableSet<Dialect> dialects;80 public static NewSessionPayload create(Capabilities caps) {81 // We need to convert the capabilities into a new session payload. At this point we're dealing82 // with references, so I'm Just Sure This Will Be Fine.83 return create(ImmutableMap.of("desiredCapabilities", caps.asMap()));84 }85 public static NewSessionPayload create(Map<String, ?> source) {86 Objects.requireNonNull(source, "Payload must be set");87 String json = new Json().toJson(source);88 return new NewSessionPayload(new StringReader(json));89 }90 public static NewSessionPayload create(Reader source) {91 return new NewSessionPayload(source);92 }93 private NewSessionPayload(Reader source) {94 // Dedicate up to 10% of all RAM or 20% of available RAM (whichever is smaller) to storing this95 // payload.96 int threshold = (int) Math.min(97 Integer.MAX_VALUE,98 Math.min(99 Runtime.getRuntime().freeMemory() / 5,100 Runtime.getRuntime().maxMemory() / 10));101 backingStore = new FileBackedOutputStream(threshold);102 try (Writer writer = new OutputStreamWriter(backingStore, UTF_8)) {103 CharStreams.copy(source, writer);104 } catch (IOException e) {105 throw new UncheckedIOException(e);106 }107 ImmutableSet.Builder<CapabilitiesFilter> adapters = ImmutableSet.builder();108 ServiceLoader.load(CapabilitiesFilter.class).forEach(adapters::add);109 adapters110 .add(new ChromeFilter())111 .add(new EdgeFilter())112 .add(new FirefoxFilter())113 .add(new InternetExplorerFilter())114 .add(new OperaFilter())115 .add(new SafariFilter());116 this.adapters = adapters.build();117 ImmutableSet.Builder<CapabilityTransform> transforms = ImmutableSet.builder();118 ServiceLoader.load(CapabilityTransform.class).forEach(transforms::add);119 transforms120 .add(new ProxyTransform())121 .add(new StripAnyPlatform())122 .add(new W3CPlatformNameNormaliser());123 this.transforms = transforms.build();124 ImmutableSet.Builder<Dialect> dialects = ImmutableSet.builder();125 try {126 if (getOss() != null) {127 dialects.add(Dialect.OSS);128 }129 if (getAlwaysMatch() != null || getFirstMatches() != null) {130 dialects.add(Dialect.W3C);131 }132 this.dialects = dialects.build();133 validate();134 } catch (IOException e) {135 throw new UncheckedIOException(e);136 }137 }138 private void validate() throws IOException {139 Map<String, Object> alwaysMatch = getAlwaysMatch();140 if (alwaysMatch == null) {141 alwaysMatch = ImmutableMap.of();142 }143 Map<String, Object> always = alwaysMatch;144 Collection<Map<String, Object>> firsts = getFirstMatches();145 if (firsts == null) {146 firsts = ImmutableList.of(ImmutableMap.of());147 }148 if (firsts.isEmpty()) {149 throw new IllegalArgumentException("First match w3c capabilities is zero length");150 }151 firsts.stream()152 .peek(map -> {153 Set<String> overlap = Sets.intersection(always.keySet(), map.keySet());154 if (!overlap.isEmpty()) {155 throw new IllegalArgumentException(156 "Overlapping keys between w3c always and first match capabilities: " + overlap);157 }158 })159 .map(first -> {160 Map<String, Object> toReturn = new HashMap<>();161 toReturn.putAll(always);162 toReturn.putAll(first);163 return toReturn;164 })165 .peek(map -> {166 ImmutableSortedSet<String> nullKeys = map.entrySet().stream()167 .filter(entry -> entry.getValue() == null)168 .map(Map.Entry::getKey)169 .collect(ImmutableSortedSet.toImmutableSortedSet(Ordering.natural()));170 if (!nullKeys.isEmpty()) {171 throw new IllegalArgumentException(172 "Null values found in w3c capabilities. Keys are: " + nullKeys);173 }174 })175 .peek(map -> {176 ImmutableSortedSet<String> illegalKeys = map.entrySet().stream()177 .filter(entry -> !ACCEPTED_W3C_PATTERNS.test(entry.getKey()))178 .map(Map.Entry::getKey)179 .collect(ImmutableSortedSet.toImmutableSortedSet(Ordering.natural()));180 if (!illegalKeys.isEmpty()) {181 throw new IllegalArgumentException(182 "Illegal key values seen in w3c capabilities: " + illegalKeys);183 }184 })185 .forEach(map -> {});186 }187 public void writeTo(Appendable appendable) throws IOException {188 try (JsonOutput json = new Json().newOutput(appendable)) {189 json.beginObject();190 Map<String, Object> first = getOss();191 if (first == null) {192 //noinspection unchecked193 first = stream().findFirst()194 .orElse(new ImmutableCapabilities())195 .asMap();196 }197 Map<String, Object> ossFirst = new HashMap<>(first);198 if (first.containsKey(CapabilityType.PROXY)) {199 Map<String, Object> proxyMap;200 Object rawProxy = first.get(CapabilityType.PROXY);201 if (rawProxy instanceof Proxy) {202 proxyMap = ((Proxy) rawProxy).toJson();203 } else if (rawProxy instanceof Map) {204 proxyMap = (Map<String, Object>) rawProxy;205 } else {206 proxyMap = new HashMap<>();207 }208 if (proxyMap.containsKey("noProxy")) {209 Map<String, Object> ossProxyMap = new HashMap<>(proxyMap);210 Object rawData = proxyMap.get("noProxy");211 if (rawData instanceof List) {212 ossProxyMap.put("noProxy", ((List<String>) rawData).stream().collect(Collectors.joining(",")));213 }214 ossFirst.put(CapabilityType.PROXY, ossProxyMap);215 }216 }217 // Write the first capability we get as the desired capability.218 json.name("desiredCapabilities");219 json.write(ossFirst);220 // Now for the w3c capabilities221 json.name("capabilities");222 json.beginObject();223 // Then write everything into the w3c payload. Because of the way we do this, it's easiest224 // to just populate the "firstMatch" section. The spec says it's fine to omit the225 // "alwaysMatch" field, so we do this.226 json.name("firstMatch");227 json.beginArray();228 //noinspection unchecked229 getW3C().forEach(json::write);230 json.endArray();231 json.endObject(); // Close "capabilities" object232 writeMetaData(json);233 json.endObject();234 }235 }236 private void writeMetaData(JsonOutput out) throws IOException {237 CharSource charSource = backingStore.asByteSource().asCharSource(UTF_8);238 try (Reader reader = charSource.openBufferedStream();239 JsonInput input = json.newInput(reader)) {240 input.beginObject();241 while (input.hasNext()) {242 String name = input.nextName();243 switch (name) {244 case "capabilities":245 case "desiredCapabilities":246 case "requiredCapabilities":247 input.skipValue();248 break;249 default:250 out.name(name);251 out.write(input.<Object>read(Object.class));252 break;253 }254 }255 }256 }257 /**258 * Stream the {@link Capabilities} encoded in the payload used to create this instance. The259 * {@link Stream} will start with a {@link Capabilities} object matching the OSS capabilities, and260 * will then expand each of the "{@code firstMatch}" and "{@code alwaysMatch}" contents as defined261 * in the W3C WebDriver spec.262 * <p>263 * The OSS {@link Capabilities} are listed first because converting the OSS capabilities to the264 * equivalent W3C capabilities isn't particularly easy, so it's hoped that this approach gives us265 * the most compatible implementation.266 */267 public Stream<Capabilities> stream() {268 try {269 // OSS first270 Stream<Map<String, Object>> oss = Stream.of(getOss());271 // And now W3C272 Stream<Map<String, Object>> w3c = getW3C();273 return Stream.concat(oss, w3c)274 .filter(Objects::nonNull)275 .map(this::applyTransforms)276 .filter(Objects::nonNull)277 .distinct()278 .map(ImmutableCapabilities::new);279 } catch (IOException e) {280 throw new UncheckedIOException(e);281 }282 }283 public ImmutableSet<Dialect> getDownstreamDialects() {284 return dialects.isEmpty() ? ImmutableSet.of(DEFAULT_DIALECT) : dialects;285 }286 @Override287 public void close() {288 try {289 backingStore.reset();290 } catch (IOException e) {291 throw new UncheckedIOException(e);292 }293 }294 private Map<String, Object> getOss() throws IOException {295 CharSource charSource = backingStore.asByteSource().asCharSource(UTF_8);296 try (Reader reader = charSource.openBufferedStream();297 JsonInput input = json.newInput(reader)) {298 input.beginObject();299 while (input.hasNext()) {300 String name = input.nextName();301 if ("desiredCapabilities".equals(name)) {302 return input.read(MAP_TYPE);303 } else {304 input.skipValue();305 }306 }307 }308 return null;309 }310 private Stream<Map<String, Object>> getW3C() throws IOException {311 // If there's an OSS value, generate a stream of capabilities from that using the transforms,312 // then add magic to generate each of the w3c capabilities. For the sake of simplicity, we're313 // going to make the (probably wrong) assumption we can hold all of the firstMatch values and314 // alwaysMatch value in memory at the same time.315 Map<String, Object> oss = convertOssToW3C(getOss());316 Stream<Map<String, Object>> fromOss;317 if (oss != null) {318 Set<String> usedKeys = new HashSet<>();319 // Are there any values we care want to pull out into a mapping of their own?320 List<Map<String, Object>> firsts = adapters.stream()321 .map(adapter -> adapter.apply(oss))322 .filter(Objects::nonNull)323 .filter(map -> !map.isEmpty())324 .map(map ->325 map.entrySet().stream()326 .filter(entry -> entry.getKey() != null)327 .filter(entry -> ACCEPTED_W3C_PATTERNS.test(entry.getKey()))328 .filter(entry -> entry.getValue() != null)329 .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)))330 .peek(map -> usedKeys.addAll(map.keySet()))331 .collect(ImmutableList.toImmutableList());332 if (firsts.isEmpty()) {333 firsts = ImmutableList.of(ImmutableMap.of());334 }335 // Are there any remaining unused keys?336 Map<String, Object> always = oss.entrySet().stream()337 .filter(entry -> !usedKeys.contains(entry.getKey()))338 .filter(entry -> entry.getValue() != null)339 .collect(ImmutableMap.toImmutableMap(Map.Entry::getKey, Map.Entry::getValue));340 // Firsts contains at least one entry, always contains everything else. Let's combine them341 // into the stream to form a unified set of capabilities. Woohoo!342 fromOss = firsts.stream()343 .map(first -> ImmutableMap.<String, Object>builder().putAll(always).putAll(first).build())344 .map(this::applyTransforms)345 .map(map -> map.entrySet().stream()346 .filter(entry -> ACCEPTED_W3C_PATTERNS.test(entry.getKey()))347 .collect(ImmutableMap.toImmutableMap(Map.Entry::getKey, Map.Entry::getValue)));348 } else {349 fromOss = Stream.of();350 }351 Stream<Map<String, Object>> fromW3c;352 Map<String, Object> alwaysMatch = getAlwaysMatch();353 Collection<Map<String, Object>> firsts = getFirstMatches();354 if (alwaysMatch == null && firsts == null) {355 fromW3c = Stream.of(); // No W3C capabilities.356 } else {357 if (alwaysMatch == null) {358 alwaysMatch = ImmutableMap.of();359 }360 Map<String, Object> always = alwaysMatch; // Keep the comoiler happy.361 if (firsts == null) {362 firsts = ImmutableList.of(ImmutableMap.of());363 }364 fromW3c = firsts.stream()365 .map(first -> ImmutableMap.<String, Object>builder().putAll(always).putAll(first).build());366 }367 return Stream.concat(fromOss, fromW3c).distinct();368 }369 private Map<String, Object> convertOssToW3C(Map<String, Object> capabilities) {370 if (capabilities == null) {371 return null;372 }373 Map<String, Object> toReturn = new TreeMap<>(capabilities);374 // Platform name375 if (capabilities.containsKey(PLATFORM) && !capabilities.containsKey(PLATFORM_NAME)) {376 toReturn.put(PLATFORM_NAME, String.valueOf(capabilities.get(PLATFORM)));377 }378 if (capabilities.containsKey(PROXY)) {...
Source:ProtocolHandshake.java
...29import java.util.Map;30import java.util.Optional;31import java.util.function.Function;32import java.util.logging.Logger;33import java.util.stream.Stream;34import static com.google.common.net.HttpHeaders.CONTENT_LENGTH;35import static com.google.common.net.HttpHeaders.CONTENT_TYPE;36import static com.google.common.net.MediaType.JSON_UTF_8;37import static java.nio.charset.StandardCharsets.UTF_8;38import static org.openqa.selenium.remote.CapabilityType.PROXY;39public class ProtocolHandshake {40 private final static Logger LOG = Logger.getLogger(ProtocolHandshake.class.getName());41 public Result createSession(HttpClient client, Command command)42 throws IOException {43 Capabilities desired = (Capabilities) command.getParameters().get("desiredCapabilities");44 desired = desired == null ? new ImmutableCapabilities() : desired;45 int threshold = (int) Math.min(Runtime.getRuntime().freeMemory() / 10, Integer.MAX_VALUE);46 FileBackedOutputStream os = new FileBackedOutputStream(threshold);47 try (...
Source:AppiumProtocolHandshake.java
...35import java.lang.reflect.InvocationTargetException;36import java.lang.reflect.Method;37import java.util.Map;38import java.util.Set;39import java.util.stream.Stream;40import static java.nio.charset.StandardCharsets.UTF_8;41@SuppressWarnings("UnstableApiUsage")42public class AppiumProtocolHandshake extends ProtocolHandshake {43 private static void writeJsonPayload(NewSessionPayload srcPayload, Appendable destination) {44 try (JsonOutput json = new Json().newOutput(destination)) {45 json.beginObject();46 json.name("capabilities");47 json.beginObject();48 json.name("firstMatch");49 json.beginArray();50 json.beginObject();51 json.endObject();52 json.endArray();53 json.name("alwaysMatch");54 try {55 Method getW3CMethod = NewSessionPayload.class.getDeclaredMethod("getW3C");56 getW3CMethod.setAccessible(true);57 //noinspection unchecked58 ((Stream<Map<String, Object>>) getW3CMethod.invoke(srcPayload))59 .findFirst()60 .map(json::write)61 .orElseGet(() -> {62 json.beginObject();63 json.endObject();64 return null;65 });66 } catch (NoSuchMethodException | InvocationTargetException | IllegalAccessException e) {67 throw new WebDriverException(e);68 }69 json.endObject(); // Close "capabilities" object70 try {71 Method writeMetaDataMethod = NewSessionPayload.class.getDeclaredMethod(72 "writeMetaData", JsonOutput.class);73 writeMetaDataMethod.setAccessible(true);74 writeMetaDataMethod.invoke(srcPayload, json);75 } catch (NoSuchMethodException | InvocationTargetException | IllegalAccessException e) {76 throw new WebDriverException(e);77 }78 json.endObject();79 }80 }81 @Override82 public Result createSession(HttpHandler client, Command command) throws IOException {83 //noinspection unchecked84 Capabilities desired = ((Set<Map<String, Object>>) command.getParameters().get("capabilities"))85 .stream()86 .findAny()87 .map(ImmutableCapabilities::new)88 .orElseGet(ImmutableCapabilities::new);89 try (NewSessionPayload payload = NewSessionPayload.create(desired)) {90 Either<SessionNotCreatedException, Result> result = createSession(client, payload);91 if (result.isRight()) {92 return result.right();93 }94 throw result.left();95 }96 }97 @Override98 public Either<SessionNotCreatedException, Result> createSession(99 HttpHandler client, NewSessionPayload payload) throws IOException {...
Source:NewSessionQueuer.java
...71 Reader reader = reader(request);72 NewSessionPayload payload = NewSessionPayload.create(reader)) {73 Objects.requireNonNull(payload, "Requests to process must be set.");74 attributeMap.put("request.payload", EventAttribute.setValue(payload.toString()));75 Iterator<Capabilities> iterator = payload.stream().iterator();76 if (!iterator.hasNext()) {77 SessionNotCreatedException78 exception =79 new SessionNotCreatedException("No capabilities found");80 EXCEPTION.accept(attributeMap, exception);81 attributeMap.put(AttributeKey.EXCEPTION_MESSAGE.getKey(),82 EventAttribute.setValue(exception.getMessage()));83 span.addEvent(AttributeKey.EXCEPTION_EVENT.getKey(), attributeMap);84 throw exception;85 }86 } catch (IOException e) {87 SessionNotCreatedException exception = new SessionNotCreatedException(e.getMessage(), e);88 EXCEPTION.accept(attributeMap, exception);89 attributeMap.put(AttributeKey.EXCEPTION_MESSAGE.getKey(),...
Source:ActiveSessionFactory.java
...23import java.util.Map;24import java.util.Objects;25import java.util.ServiceLoader;26import java.util.logging.Logger;27import java.util.stream.StreamSupport;28/**29 * Used to create new {@link ActiveSession} instances as required.30 */31public class ActiveSessionFactory {32 private final static Logger LOG = Logger.getLogger(ActiveSessionFactory.class.getName());33 private final Map<String, SessionFactory> factories;34 public ActiveSessionFactory() {35 Map<String, SessionFactory> builder = new LinkedHashMap<>();36 ImmutableMap.<String, String>builder()37 .put(chrome().getBrowserName(), "org.openqa.selenium.chrome.ChromeDriverService")38 .put(edge().getBrowserName(), "org.openqa.selenium.edge.EdgeDriverService")39 .put(firefox().getBrowserName(), "org.openqa.selenium.firefox.GeckoDriverService")40 .put(internetExplorer().getBrowserName(), "org.openqa.selenium.ie.InternetExplorerDriverService")41 .put(opera().getBrowserName(), "org.openqa.selenium.opera.OperaDriverService")42 .put(operaBlink().getBrowserName(), "org.openqa.selenium.ie.OperaDriverService")43 .put(phantomjs().getBrowserName(), "org.openqa.selenium.phantomjs.PhantomJSDriverService")44 .put(safari().getBrowserName(), "org.openqa.selenium.safari.SafariDriverService")45 .build()46 .entrySet().stream()47 .filter(e -> {48 try {49 Class.forName(e.getValue());50 return true;51 } catch (ClassNotFoundException cnfe) {52 return false;53 }54 })55 .forEach(e -> builder.put(e.getKey(), new ServicedSession.Factory(e.getValue())));56 // Attempt to bind the htmlunitdriver if it's present.57 try {58 Class<? extends WebDriver> clazz = Class.forName("org.openqa.selenium.htmlunit.HtmlUnitDriver")59 .asSubclass(WebDriver.class);60 builder.put(61 htmlUnit().getBrowserName(),62 new InMemorySession.Factory(new DefaultDriverProvider(htmlUnit(), clazz)));63 } catch (ReflectiveOperationException ignored) {64 // Just carry on. Everything is fine.65 }66 // Allow user-defined factories to override default ones67 StreamSupport.stream(ServiceLoader.load(DriverProvider.class).spliterator(), false)68 .forEach(p -> builder.put(p.getProvidedCapabilities().getBrowserName(), new InMemorySession.Factory(p)));69 this.factories = ImmutableMap.copyOf(builder);70 }71 public ActiveSession createSession(NewSessionPayload newSessionPayload) throws IOException {72 return newSessionPayload.stream()73 .map(this::determineBrowser)74 .filter(Objects::nonNull)75 .map(factory -> factory.apply(newSessionPayload))76 .filter(Objects::nonNull)77 .findFirst()78 .orElseThrow(() -> new SessionNotCreatedException(79 "Unable to create a new session because of no configuration."));80 }81 private SessionFactory determineBrowser(Capabilities caps) {82 return caps.asMap().entrySet().stream()83 .map(entry -> guessBrowserName(entry.getKey(), entry.getValue()))84 .filter(factories.keySet()::contains)85 .map(factories::get)86 .findFirst()87 .orElse(null);88 }89 private String guessBrowserName(String capabilityKey, Object value) {90 if (BROWSER_NAME.equals(capabilityKey)) {91 return (String) value;92 }93 if ("chromeOptions".equals(capabilityKey)) {94 return CHROME;95 }96 if ("edgeOptions".equals(capabilityKey)) {...
Source:BeginSession.java
...77 .put("webdriver.remote.sessionid", session.getId().toString())78 .build();79 }80 Object toConvert;81 switch (session.getDownstreamDialect()) {82 case OSS:83 toConvert = ImmutableMap.of(84 "status", 0,85 "sessionId", session.getId().toString(),86 "value", caps);87 break;88 case W3C:89 toConvert = ImmutableMap.of(90 "value", ImmutableMap.of(91 "sessionId", session.getId().toString(),92 "capabilities", caps));93 break;94 default:95 throw new SessionNotCreatedException(96 "Unrecognized downstream dialect: " + session.getDownstreamDialect());97 }98 byte[] payload = json.toJson(toConvert).getBytes(UTF_8);99 resp.setStatus(HTTP_OK);100 resp.setHeader("Cache-Control", "no-cache");101 resp.setHeader("Content-Type", JSON_UTF_8.toString());102 resp.setHeader("Content-Length", String.valueOf(payload.length));103 resp.setContent(payload);104 }105}...
stream
Using AI Code Generation
1import org.openqa.selenium.remote.NewSessionPayload;2import org.openqa.selenium.remote.SessionId;3import org.openqa.selenium.remote.http.HttpClient;4import org.openqa.selenium.remote.http.HttpRequest;5import org.openqa.selenium.remote.http.HttpResponse;6import org.openqa.selenium.remote.http.W3CHttpCommandCodec;7import org.openqa.selenium.remote.http.W3CHttpResponseCodec;8import java.io.IOException;9import java.net.MalformedURLException;10import java.net.URL;11import java.util.Base64;12import java.util.HashMap;13import java.util.Map;14public class WebDriverSessionStream {15 public static void main(String[] args) throws MalformedURLException, IOException {16 HttpClient client = HttpClient.Factory.createDefault().createClient(url);17 Map<String, Object> capabilities = new HashMap<>();18 capabilities.put("browserName", "chrome");19 capabilities.put("platformName", "windows");20 capabilities.put("version", "latest");21 NewSessionPayload payload = new NewSessionPayload();22 payload.setAlwaysMatch(capabilities);23 payload.setFirstMatch(new HashMap<>());24 W3CHttpCommandCodec codec = new W3CHttpCommandCodec();25 W3CHttpResponseCodec responseCodec = new W3CHttpResponseCodec();26 HttpRequest request = codec.encode(new HttpRequest("POST", "/session"), payload);27 HttpResponse response = client.execute(request);28 Map<String, Object> rawResponse = responseCodec.decode(response);29 String sessionId = rawResponse.get("sessionId").toString();30 SessionId id = new SessionId(sessionId);31 System.out.println("Session ID: " + id);32 Map<String, Object> value = (Map<String, Object>) rawResponse.get("value");33 String encoded = (String) value.get("value");34 byte[] decoded = Base64.getDecoder().decode(encoded);35 System.out.println(new String(decoded));36 }37}38{"sessionId":"1b8c3c3d-4e4c-4e8e-8d43-7c0d1e0c1c9e","status":0,"value":{"acceptInsecureCerts":false,"browserName":"chrome","browserVersion":"80.0.3987.132
stream
Using AI Code Generation
1import java.io.InputStream;2import java.io.InputStreamReader;3import java.io.BufferedReader;4import java.io.IOException;5import java.io.Reader;6import java.io.UnsupportedEncodingException;7import java.io.ByteArrayInputStream;8import java.io.ByteArrayOutputStream;9import java.io.OutputStream;10import java.io.OutputStreamWriter;11import java.io.BufferedWriter;12import java.io.Writer;13import java.io.FileOutputStream;14import java.io.FileNotFoundException;15import java.io.File;16import org.openqa.selenium.remote.NewSessionPayload;17public class ReadWriteStream {18 public static void main(String[] args) throws IOException {19 String json = "{\"desiredCapabilities\": {\"browserName\": \"firefox\"}}";20 InputStream stream = new ByteArrayInputStream(json.getBytes("UTF-8"));21 NewSessionPayload payload = NewSessionPayload.create(stream);22 System.out.println(payload.toString());23 File file = new File("test.json");24 OutputStream out = new FileOutputStream(file);25 payload.writeTo(out);26 }27}28import java.io.InputStream;29import java.io.InputStreamReader;30import java.io.BufferedReader;31import java.io.IOException;32import java.io.Reader;33import java.io.UnsupportedEncodingException;34import java.io.ByteArrayInputStream;35import java.io.ByteArrayOutputStream;36import java.io.OutputStream;37import java.io.OutputStreamWriter;38import java.io.BufferedWriter;39import java.io.Writer;40import java.io.FileOutputStream;41import java.io.FileNotFoundException;42import java.io.File;43import org.openqa.selenium.remote.NewSessionPayload;44public class ReadWriteStream {45 public static void main(String[] args) throws IOException {46 String json = "{\"desiredCapabilities\": {\"browserName\": \"firefox\"}}";47 InputStream stream = new ByteArrayInputStream(json.getBytes("UTF-8"));48 NewSessionPayload payload = NewSessionPayload.create(stream);49 System.out.println(payload.toString());50 File file = new File("test.json");51 OutputStream out = new FileOutputStream(file);52 payload.writeTo(out);53 }54}55import java.io.InputStream;56import java.io.InputStreamReader;
stream
Using AI Code Generation
1import org.openqa.selenium.remote.NewSessionPayload;2import org.openqa.selenium.remote.CapabilityType;3import org.openqa.selenium.remote.DesiredCapabilities;4import org.openqa.selenium.remote.RemoteWebDriver;5import org.openqa.selenium.remote.SessionId;6import org.openqa.selenium.remote.http.HttpClient;7import org.openqa.selenium.remote.http.HttpMethod;8import org.openqa.selenium.remote.http.HttpRequest;9import org.openqa.selenium.remote.http.HttpResponse;10import java.io.IOException;11import java.net.URL;12import java.util.Map;13import java.util.stream.Collectors;14public class NewSessionPayloadTest {15 public static void main(String[] args) throws IOException {16 DesiredCapabilities capabilities = new DesiredCapabilities();17 capabilities.setCapability(CapabilityType.BROWSER_NAME, "chrome");18 capabilities.setCapability(CapabilityType.VERSION, "latest");19 capabilities.setCapability(CapabilityType.PLATFORM_NAME, "windows");20 capabilities.setCapability("sauce:options", Map.of("name", "Test"));21 NewSessionPayload payload = NewSessionPayload.create(capabilities);22 Map<String, Object> capabilitiesMap = payload.getDownstreamEncoded().getCapability();23 System.out.println(capabilitiesMap);24 HttpRequest request = new HttpRequest(HttpMethod.POST, "/session");25 request.setContent(payload.getDownstreamEncoded().asOutputSteam());26 HttpResponse response = client.execute(request);27 SessionId sessionId = new SessionId(response.getHeader("Location").split("/")[3]);28 System.out.println(sessionId);29 RemoteWebDriver driver = new RemoteWebDriver(client, sessionId);30 driver.quit();31 }32}33{browserName=chrome, browserVersion=latest, platformName=windows, platformVersion=latest, sauce:options={name=Test}}
stream
Using AI Code Generation
1import org.openqa.selenium.remote.NewSessionPayload;2import java.util.HashMap;3import java.util.Map;4import java.util.stream.Collectors;5import java.util.stream.Stream;6public class MapToJson {7 public static void main(String[] args) {8 Map<String, Object> map = new HashMap<>();9 map.put("name", "Selenium");10 map.put("version", "4.0");11 String json = NewSessionPayload.stream(map).collect(Collectors.joining(",","{","}"));12 System.out.println(json);13 }14}15{ "name": "Selenium", "version": "4.0" }
stream
Using AI Code Generation
1import org.openqa.selenium.remote.NewSessionPayload;2import org.openqa.selenium.remote.CapabilityType;3import org.openqa.selenium.remote.DesiredCapabilities;4DesiredCapabilities cap = new DesiredCapabilities();5cap.setCapability(CapabilityType.BROWSER_NAME, "firefox");6NewSessionPayload payload = new NewSessionPayload(cap);7String browserName = payload.stream().filter(c -> c.getName().equals(CapabilityType.BROWSER_NAME)).map(c -> c.getValue().toString()).findFirst().get();8System.out.println(browserName);9The filter() method filters the stream using
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.
Most used method in NewSessionPayload
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
