How to use NetworkInterceptor class of org.openqa.selenium.devtools package

1// Licensed to the Software Freedom Conservancy (SFC) under one
2// or more contributor license agreements.  See the NOTICE file
3// distributed with this work for additional information
4// regarding copyright ownership.  The SFC licenses this file
5// to you under the Apache License, Version 2.0 (the
6// "License"); you may not use this file except in compliance
7// with the License.  You may obtain a copy of the License at
8//
9//   http://www.apache.org/licenses/LICENSE-2.0
10//
11// Unless required by applicable law or agreed to in writing,
12// software distributed under the License is distributed on an
13// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14// KIND, either express or implied.  See the License for the
15// specific language governing permissions and limitations
16// under the License.
17
18package org.openqa.selenium.support.devtools;
19
20import org.openqa.selenium.WebDriver;
21import org.openqa.selenium.devtools.DevTools;
22import org.openqa.selenium.devtools.HasDevTools;
23import org.openqa.selenium.devtools.idealized.Network;
24import org.openqa.selenium.devtools.idealized.OpaqueKey;
25import org.openqa.selenium.internal.Require;
26import org.openqa.selenium.remote.http.HttpResponse;
27import org.openqa.selenium.remote.http.Route;
28
29import java.io.Closeable;
30
31import static org.openqa.selenium.remote.http.Contents.utf8String;
32
33/**
34 * Provides a mechanism for stubbing out responses to requests in drivers which
35 * implement {@link HasDevTools}. Usage is done by specifying a {@link Route},
36 * which will be checked for every request to see if that request should be
37 * handled or not. Note that the URLs given to the {@code Route} will be fully
38 * qualified.
39 * <p>
40 * Example usage:
41 * <p>
42 * <code>
43 *   Route route = Route.matching(req -&gt; GET == req.getMethod() &amp;&amp; req.getUri().endsWith("/example"))
44 *     .to(() -&gt; req -&gt; new HttpResponse().setContent(Contents.utf8String("Hello, World!")));
45 *
46 *   try (NetworkInterceptor interceptor = new NetworkInterceptor(driver, route)) {
47 *     // Your code here.
48 *   }
49 * </code>
50 */
51public class NetworkInterceptor implements Closeable {
52
53  public static final HttpResponse PROCEED_WITH_REQUEST = new HttpResponse()
54    .addHeader("Selenium-Interceptor", "Continue")
55    .setContent(utf8String("Original request should proceed"));
56
57  private final OpaqueKey key;
58  private final Network<?, ?> network;
59
60  public NetworkInterceptor(WebDriver driver, Route route) {
61    if (!(driver instanceof HasDevTools)) {
62      throw new IllegalArgumentException("WebDriver instance must implement HasDevTools");
63    }
64    Require.nonNull("Route", route);
65
66    DevTools devTools = ((HasDevTools) driver).getDevTools();
67    devTools.createSessionIfThereIsNotOne();
68
69    network = devTools.getDomains().network();
70
71    key = network.addRequestHandler(route);
72  }
73
74  @Override
75  public void close() {
76    network.removeRequestHandler(key);
77  }
78}
79

Source: NetworkInterceptor.java

// 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.support.devtools;

import org.openqa.selenium.WebDriver;
import org.openqa.selenium.devtools.DevTools;
import org.openqa.selenium.devtools.HasDevTools;
import org.openqa.selenium.devtools.idealized.Network;
import org.openqa.selenium.devtools.idealized.OpaqueKey;
import org.openqa.selenium.internal.Require;
import org.openqa.selenium.remote.http.HttpResponse;
import org.openqa.selenium.remote.http.Route;

import java.io.Closeable;

import static org.openqa.selenium.remote.http.Contents.utf8String;

/**
 * Provides a mechanism for stubbing out responses to requests in drivers which
 * implement {@link HasDevTools}. Usage is done by specifying a {@link Route},
 * which will be checked for every request to see if that request should be
 * handled or not. Note that the URLs given to the {@code Route} will be fully
 * qualified.
 * <p>
 * Example usage:
 * <p>
 * <code>
 *   Route route = Route.matching(req -&gt; GET == req.getMethod() &amp;&amp; req.getUri().endsWith("/example"))
 *     .to(() -&gt; req -&gt; new HttpResponse().setContent(Contents.utf8String("Hello, World!")));
 *
 *   try (NetworkInterceptor interceptor = new NetworkInterceptor(driver, route)) {
 *     // Your code here.
 *   }
 * </code>
 */
public class NetworkInterceptor implements Closeable {

  public static final HttpResponse PROCEED_WITH_REQUEST = new HttpResponse()
    .addHeader("Selenium-Interceptor", "Continue")
    .setContent(utf8String("Original request should proceed"));

  private final OpaqueKey key;
  private final Network<?, ?> network;

  public NetworkInterceptor(WebDriver driver, Route route) {
    if (!(driver instanceof HasDevTools)) {
      throw new IllegalArgumentException("WebDriver instance must implement HasDevTools");
    }
    Require.nonNull("Route", route);

    DevTools devTools = ((HasDevTools) driver).getDevTools();
    devTools.createSessionIfThereIsNotOne();

    network = devTools.getDomains().network();

    key = network.addRequestHandler(route);
  }

  @Override
  public void close() {
    network.removeRequestHandler(key);
  }
}

1{
2{
3    okHttpClient = new OkHttpClient.Builder()
4        .addNetworkInterceptor(new LoggingInterceptor())
5        .build();
6}
7
8private class LoggingInterceptor implements Interceptor {
9    @Override public Response intercept(Chain chain) throws IOException {
10        Request request = chain.request();
11        Response response = chain.proceed(request);
12
13        utils.log("LoggingInterceptor", "isRedirect=" + response.isRedirect());
14        utils.log("LoggingInterceptor", "responseCode=" + response.code());
15        utils.log("LoggingInterceptor", "redirectUri=" + response.header("Location"));
16
17        return response;
18    }
19}
20

Source: How to get OkHttp3 redirected URL?

{
{
    okHttpClient = new OkHttpClient.Builder()
        .addNetworkInterceptor(new LoggingInterceptor())
        .build();
}

private class LoggingInterceptor implements Interceptor {
    @Override public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        Response response = chain.proceed(request);

        utils.log("LoggingInterceptor", "isRedirect=" + response.isRedirect());
        utils.log("LoggingInterceptor", "responseCode=" + response.code());
        utils.log("LoggingInterceptor", "redirectUri=" + response.header("Location"));

        return response;
    }
}

1        OkHttpClient httpClient = new OkHttpClient.Builder()
2            .addNetworkInterceptor(new Interceptor() {
3                @Override
4                public Response intercept(Chain chain) throws IOException {
5                    System.out.println("url: " + chain.request().url());
6                    return chain.proceed(chain.request());
7                }
8            })
9            .build();
10    System.out.println(httpClient.newCall(new Request.Builder().url("http://google.com").build()).execute());
11

Source: How to get OkHttp3 redirected URL?

        OkHttpClient httpClient = new OkHttpClient.Builder()
            .addNetworkInterceptor(new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    System.out.println("url: " + chain.request().url());
                    return chain.proceed(chain.request());
                }
            })
            .build();
    System.out.println(httpClient.newCall(new Request.Builder().url("http://google.com").build()).execute());

1public static void send(JSONObject obj){
2    new OkHttpClient().newCall(new Request.Builder()
3            .addHeader("Content-Type", "application/json")
4            .url("URL...")
5            .post(RequestBody.create(
6                    MediaType.parse("application/json; charset=utf-8"),
7                    obj.toString())
8            ).build())
9    .enqueue(new Callback() {
10        @Override
11        public void onFailure(Call call, IOException e) {
12            Log.d("ZAKA",e.getMessage());
13        }
14        @Override
15        public void onResponse(Call call, Response response) throws IOException {
16            Log.d("ZAKA","Report : -> "+response.body().string());
17        }
18    });
19}
20

Source: OkHttp Post not getting data sent on the server side

public static void send(JSONObject obj){
    new OkHttpClient().newCall(new Request.Builder()
            .addHeader("Content-Type", "application/json")
            .url("URL...")
            .post(RequestBody.create(
                    MediaType.parse("application/json; charset=utf-8"),
                    obj.toString())
            ).build())
    .enqueue(new Callback() {
        @Override
        public void onFailure(Call call, IOException e) {
            Log.d("ZAKA",e.getMessage());
        }
        @Override
        public void onResponse(Call call, Response response) throws IOException {
            Log.d("ZAKA","Report : -> "+response.body().string());
        }
    });
}

1JSObject obj = new JSObject();
2obj.put("token","your token");
3send(obj); // Call send method
4

Source: OkHttp Post not getting data sent on the server side

JSObject obj = new JSObject();
obj.put("token","your token");
send(obj); // Call send method

1Logger logger = LoggerFactory.getLogger(HttpUtil.class);
2HttpLoggingInterceptor logging =
3    new HttpLoggingInterceptor((msg) -> {
4        logger.debug(msg);
5    });
6logging.setLevel(Level.BODY);
7
8client.addNetworkInterceptor(logging);
9

Source: OkHttp Post not getting data sent on the server side

Logger logger = LoggerFactory.getLogger(HttpUtil.class);
HttpLoggingInterceptor logging =
    new HttpLoggingInterceptor((msg) -> {
        logger.debug(msg);
    });
logging.setLevel(Level.BODY);

client.addNetworkInterceptor(logging);