BAEL-11410: Add timeout OkHttp live tests

Author: kwoyke

libraries-http/src/test/java/com/baeldung/okhttp/OkHttpTimeoutLiveTest.java

@@ -0,0 +1,113 @@
+package com.baeldung.okhttp;
+
+import okhttp3.MediaType;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.InterruptedIOException;
+import java.net.SocketTimeoutException;
+import java.util.concurrent.TimeUnit;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.catchThrowable;
+
+public class OkHttpTimeoutLiveTest {
+
+    private static Logger logger = LoggerFactory.getLogger(OkHttpTimeoutLiveTest.class);
+
+    private static final String HTTP_NON_ROUTABLE_ADDRESS = "http://203.0.113.1";
+    private static final String HTTPS_ADDRESS_DELAY_2 = "https://httpbin.org/delay/2";
+
+    @Test
+    public void whenConnectTimeoutExceededThenSocketTimeoutException() {
+        // Given
+        final OkHttpClient client = new OkHttpClient.Builder()
+                .connectTimeout(10, TimeUnit.MILLISECONDS)
+                .build();
+
+        Request request = new Request.Builder()
+                .url(HTTP_NON_ROUTABLE_ADDRESS)
+                .build();
+
+        // When
+        Throwable thrown = catchThrowable(() -> client.newCall(request).execute());
+
+        // Then
+        assertThat(thrown).isInstanceOf(SocketTimeoutException.class);
+
+        logThrown(thrown);
+    }
+
+    @Test
+    public void whenReadTimeoutExceededThenSocketTimeoutException() {
+        // Given
+        final OkHttpClient client = new OkHttpClient.Builder()
+                .readTimeout(10, TimeUnit.MILLISECONDS)
+                .build();
+
+        Request request = new Request.Builder()
+                .url(HTTPS_ADDRESS_DELAY_2)
+                .build();
+
+        // When
+        Throwable thrown = catchThrowable(() -> client.newCall(request).execute());
+
+        // Then
+        assertThat(thrown).isInstanceOf(SocketTimeoutException.class);
+
+        logThrown(thrown);
+    }
+
+    @Test
+    public void whenWriteTimeoutExceededThenSocketTimeoutException() {
+        // Given
+        final OkHttpClient client = new OkHttpClient.Builder()
+                .writeTimeout(10, TimeUnit.MILLISECONDS)
+                .build();
+
+        Request request = new Request.Builder()
+                .url(HTTPS_ADDRESS_DELAY_2)
+                .post(RequestBody.create(MediaType.parse("text/plain"), create1MBString()))
+                .build();
+
+        // When
+        Throwable thrown = catchThrowable(() -> client.newCall(request).execute());
+
+        // Then
+        assertThat(thrown).isInstanceOf(SocketTimeoutException.class);
+
+        logThrown(thrown);
+    }
+
+    @Test
+    public void whenCallTimeoutExceededThenSocketTimeoutException() {
+        // Given
+        final OkHttpClient client = new OkHttpClient.Builder()
+                .callTimeout(1, TimeUnit.SECONDS)
+                .build();
+
+        Request request = new Request.Builder()
+                .url(HTTPS_ADDRESS_DELAY_2)
+                .build();
+
+        // When
+        Throwable thrown = catchThrowable(() -> client.newCall(request).execute());
+
+        // Then
+        assertThat(thrown).isInstanceOf(InterruptedIOException.class);
+
+        logThrown(thrown);
+    }
+
+    private void logThrown(Throwable thrown) {
+        logger.info("Thrown: ", thrown);
+    }
+
+    private String create1MBString() {
+        return new String(new char[512 * 1024]);
+    }
+}