Added HTTP interceptors

Author: MikeFot

net/build.gradle

@@ -1,5 +1,8 @@
 apply plugin: 'java'
 
+sourceCompatibility = "1.7"
+targetCompatibility = "1.7"
+
 dependencies {
     compile "com.squareup.retrofit2:retrofit:${retrofit2Version}"
     compile "com.squareup.retrofit2:converter-gson:${retrofitGsonVersion}"
@@ -9,5 +12,3 @@ dependencies {
     compile project(':steam')
 }
 
-sourceCompatibility = "1.7"
-targetCompatibility = "1.7"

net/src/main/java/com/michaelfotiadis/steam/net/OkHttpFactoryImpl.java

@@ -0,0 +1,54 @@
+package com.michaelfotiadis.steam.net;
+
+
+import com.michaelfotiadis.steam.net.client.interceptors.HeadersInterceptor;
+import com.michaelfotiadis.steam.net.client.interceptors.RetryPolicyInterceptor;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import okhttp3.Interceptor;
+import okhttp3.OkHttpClient;
+import okhttp3.logging.HttpLoggingInterceptor;
+
+public class OkHttpFactoryImpl implements OkHttpFactory {
+
+    private final boolean enableDebug;
+
+    public OkHttpFactoryImpl(final boolean enableDebug) {
+        this.enableDebug = enableDebug;
+    }
+
+    public OkHttpClient create(final Class<?> clazz) {
+        /**
+         * This is important to avoid using a {@link TokenManager} in {@link LoginApi}
+         * as the job of the {@link TokenManager} is to use the {@link LoginApi} to
+         * refresh the token.
+         */
+        final List<Interceptor> interceptors = new ArrayList<>();
+        interceptors.add(new HeadersInterceptor());
+        interceptors.add(new RetryPolicyInterceptor());
+        interceptors.add(createLoggingInterceptor());
+
+        return createClient(interceptors);
+    }
+
+    private OkHttpClient createClient(final List<Interceptor> interceptors) {
+        final OkHttpClient.Builder builder = new OkHttpClient.Builder();
+
+        for (final Interceptor interceptor : interceptors) {
+            builder.addInterceptor(interceptor);
+        }
+
+        return builder.build();
+    }
+
+    private Interceptor createLoggingInterceptor() {
+        final HttpLoggingInterceptor.Level level = enableDebug ? HttpLoggingInterceptor.Level.BASIC : HttpLoggingInterceptor.Level.NONE;
+
+        final HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();
+        interceptor.setLevel(level);
+
+        return interceptor;
+    }
+}

net/src/main/java/com/michaelfotiadis/steam/net/client/interceptors/HeadersInterceptor.java

@@ -0,0 +1,22 @@
+package com.michaelfotiadis.steam.net.client.interceptors;
+
+import java.io.IOException;
+
+import okhttp3.Interceptor;
+import okhttp3.Request;
+import okhttp3.Response;
+
+public class HeadersInterceptor implements Interceptor {
+
+    private static final String CONTENT_TYPE = "Content-Type";
+    private static final String APPLICATION_JSON = "application/json";
+
+    @Override
+    public Response intercept(final Chain chain) throws IOException {
+        final Request originalRequest = chain.request();
+        final Request.Builder builder = originalRequest.newBuilder();
+        builder.addHeader(CONTENT_TYPE, APPLICATION_JSON);
+
+        return chain.proceed(builder.build());
+    }
+}

net/src/main/java/com/michaelfotiadis/steam/net/client/interceptors/RetryPolicyInterceptor.java

@@ -0,0 +1,65 @@
+package com.michaelfotiadis.steam.net.client.interceptors;
+
+import java.io.IOException;
+import java.net.SocketTimeoutException;
+
+import okhttp3.Interceptor;
+import okhttp3.Request;
+import okhttp3.Response;
+
+public class RetryPolicyInterceptor implements Interceptor {
+    private static final int HTTP_CODE_202 = 202;
+    private static final long MAX_RETRY_TIME = 60 * 60 * 1000; // 1 minute
+    private static final long SLEEP_TIME = 3 * 1000; // 3 seconds
+
+    @Override
+    public Response intercept(final Chain chain) throws IOException {
+
+        final Request request = chain.request();
+        final Response response;
+        try {
+            // try the call
+            response = chain.proceed(request);
+
+            //noinspection IfStatementWithNegatedCondition
+            if (response.code() != HTTP_CODE_202) {
+                return response;
+            } else {
+                response.body().close();
+                return repeatRequest(chain, request);
+            }
+        } catch (final SocketTimeoutException e) {
+            throw e;
+        }
+    }
+
+    @SuppressWarnings("MethodMayBeStatic")
+    private Response repeatRequest(final Chain chain, final Request authorisedRequest) throws IOException {
+
+        Response repeatResponse = chain.proceed(authorisedRequest);
+
+        final long startTime = System.currentTimeMillis();
+        while (repeatResponse.code() == HTTP_CODE_202) {
+            final long elapsedTime = System.currentTimeMillis() - startTime;
+            if (elapsedTime > MAX_RETRY_TIME) {
+                return chain.proceed(authorisedRequest);
+            } else {
+                try {
+                    Thread.sleep(SLEEP_TIME);
+                } catch (final InterruptedException e) {
+                    //Do nothing.
+                }
+                repeatResponse = chain.proceed(authorisedRequest);
+                //noinspection IfStatementWithNegatedCondition
+                if (repeatResponse.code() != HTTP_CODE_202) {
+                    return chain.proceed(authorisedRequest);
+                } else {
+                    chain.proceed(authorisedRequest);
+                }
+            }
+        }
+
+        return repeatResponse;
+    }
+
+}