[bidi][java] Add 'fetchError' event

Author: pujagani

java/src/org/openqa/selenium/bidi/Network.java

@@ -26,6 +26,7 @@
 import org.openqa.selenium.WebDriver;
 import org.openqa.selenium.bidi.network.AddInterceptParameters;
 import org.openqa.selenium.bidi.network.BeforeRequestSent;
+import org.openqa.selenium.bidi.network.FetchError;
 import org.openqa.selenium.bidi.network.ResponseDetails;
 import org.openqa.selenium.internal.Require;
 
@@ -38,6 +39,9 @@ public class Network implements AutoCloseable {
   private final Event<BeforeRequestSent> beforeRequestSentEvent =
       new Event<>("network.beforeRequestSent", BeforeRequestSent::fromJsonMap);
 
+  private final Event<FetchError> fetchErrorEvent =
+      new Event<>("network.fetchError", FetchError::fromJsonMap);
+
   private final Event<ResponseDetails> responseStarted =
       new Event<>("network.responseStarted", ResponseDetails::fromJsonMap);
 
@@ -122,6 +126,14 @@ public void onBeforeRequestSent(Consumer<BeforeRequestSent> consumer) {
     }
   }
 
+  public void onFetchError(Consumer<FetchError> consumer) {
+    if (browsingContextIds.isEmpty()) {
+      this.bidi.addListener(fetchErrorEvent, consumer);
+    } else {
+      this.bidi.addListener(browsingContextIds, fetchErrorEvent, consumer);
+    }
+  }
+
   public void onResponseStarted(Consumer<ResponseDetails> consumer) {
     if (browsingContextIds.isEmpty()) {
       this.bidi.addListener(responseStarted, consumer);

java/src/org/openqa/selenium/bidi/network/FetchError.java

@@ -0,0 +1,53 @@
+// Licensed to the Software Freedom Conservancy (SFC) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The SFC licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.openqa.selenium.bidi.network;
+
+import java.io.StringReader;
+import java.util.Map;
+import org.openqa.selenium.json.Json;
+import org.openqa.selenium.json.JsonInput;
+
+public class FetchError extends BaseParameters {
+  private static final Json JSON = new Json();
+
+  private final String errorText;
+
+  private FetchError(BaseParameters baseParameters, String errorText) {
+    super(
+        baseParameters.getBrowsingContextId(),
+        baseParameters.isBlocked(),
+        baseParameters.getNavigationId(),
+        baseParameters.getRedirectCount(),
+        baseParameters.getRequest(),
+        baseParameters.getTimestamp(),
+        baseParameters.getIntercepts());
+    this.errorText = errorText;
+  }
+
+  public static FetchError fromJsonMap(Map<String, Object> jsonMap) {
+    try (StringReader baseParameterReader = new StringReader(JSON.toJson(jsonMap));
+        JsonInput baseParamsInput = JSON.newInput(baseParameterReader); ) {
+      String errorText = JSON.toJson(jsonMap.get("errorText"));
+      return new FetchError(BaseParameters.fromJson(baseParamsInput), errorText);
+    }
+  }
+
+  public String getErrorText() {
+    return errorText;
+  }
+}

java/test/org/openqa/selenium/bidi/network/NetworkEventsTest.java

@@ -20,6 +20,7 @@
 import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
 import static org.openqa.selenium.testing.Safely.safelyCall;
 import static org.openqa.selenium.testing.drivers.Browser.EDGE;
+import static org.openqa.selenium.testing.drivers.Browser.FIREFOX;
 import static org.openqa.selenium.testing.drivers.Browser.IE;
 import static org.openqa.selenium.testing.drivers.Browser.SAFARI;
 
@@ -31,6 +32,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.openqa.selenium.Cookie;
+import org.openqa.selenium.WebDriverException;
 import org.openqa.selenium.bidi.Network;
 import org.openqa.selenium.environment.webserver.AppServer;
 import org.openqa.selenium.environment.webserver.NettyAppServer;
@@ -167,6 +169,33 @@ void canListenToOnAuthRequiredEvent()
     }
   }
 
+  @Test
+  @NotYetImplemented(SAFARI)
+  @NotYetImplemented(IE)
+  @NotYetImplemented(EDGE)
+  @NotYetImplemented(FIREFOX)
+  void canListenToFetchError() throws ExecutionException, InterruptedException, TimeoutException {
+    try (Network network = new Network(driver)) {
+      CompletableFuture<FetchError> future = new CompletableFuture<>();
+      network.onFetchError(future::complete);
+      page = server.whereIs("error");
+      try {
+        driver.get("https://not_a_valid_url.test/");
+      } catch (WebDriverException ignored) {
+      }
+
+      FetchError fetchError = future.get(5, TimeUnit.SECONDS);
+      String windowHandle = driver.getWindowHandle();
+      assertThat(fetchError.getBrowsingContextId()).isEqualTo(windowHandle);
+      assertThat(fetchError.getRequest().getRequestId()).isNotNull();
+      assertThat(fetchError.getRequest().getMethod()).isEqualToIgnoringCase("get");
+      assertThat(fetchError.getRequest().getUrl()).contains("https://not_a_valid_url.test/");
+      assertThat(fetchError.getRequest().getHeaders().size()).isGreaterThanOrEqualTo(1);
+      assertThat(fetchError.getNavigationId()).isNotNull();
+      assertThat(fetchError.getErrorText()).contains("UNKNOWN_HOST");
+    }
+  }
+
   @AfterEach
   public void quitDriver() {
     if (driver != null) {