goofyahead · June 7, 2017 04:08 · Jun 26, 2015 · Apr 9, 2015 · Apr 9, 2015 · Apr 9, 2015
diff --git a/Interceptor.java b/Interceptor.java
@@ -28,7 +28,7 @@ public Response intercept(Chain chain) throws IOException {
 					}
 				}
 
-				if(settings.hasAccessToken()) { //retry requires new auth token,
+				if(settings.getAccessToken() != null) { //retry requires new auth token,
 					setAuthHeader(builder, settings.getAccessToken()); //set auth token to updated
 					request = builder.build();
 					return chain.proceed(request); //repeat request with new token

diff --git a/Interceptor.java b/Interceptor.java
@@ -45,7 +45,7 @@ private void setAuthHeader(Request.Builder builder, String token) {
 	}
 
 	private int refreshToken() {
-		//Refresh token, synchronously, and return result code
+		//Refresh token, synchronously, save it, and return result code
 		//you might use retrofit here
 	}
 

diff --git a/Interceptor.java b/Interceptor.java
@@ -38,14 +38,17 @@ public Response intercept(Chain chain) throws IOException {
 
 		return response;
 	}
+
 	private void setAuthHeader(Request.Builder builder, String token) {
 		if (token != null) //Add Auth token to each request if authorized
 			builder.header("Authorization", String.format("Bearer %s", token));
 	}
+
 	private int refreshToken() {
 		//Refresh token, synchronously, and return result code
 		//you might use retrofit here
 	}
+
 	private int logout() {
 		//logout your user
 	}

diff --git a/Interceptor.java b/Interceptor.java
@@ -0,0 +1,52 @@
+private class HttpInterceptor implements Interceptor {
+
+	@Override
+	public Response intercept(Chain chain) throws IOException {
+		Request request = chain.request();
+
+		//Build new request
+		Request.Builder builder = request.newBuilder();
+		builder.header("Accept", "application/json"); //if necessary, say to consume JSON
+
+		String token = settings.getAccessToken(); //save token of this request for future
+		setAuthHeader(builder, token); //write current token to request
+
+		request = builder.build(); //overwrite old request
+		Response response = chain.proceed(request); //perform request, here original request will be executed
+
+		if (response.code() == 401) { //if unauthorized
+			synchronized (httpClient) { //perform all 401 in sync blocks, to avoid multiply token updates
+				String currentToken = settings.getAccessToken(); //get currently stored token
+
+				if(currentToken != null && currentToken.equals(token)) { //compare current token with token that was stored before, if it was not updated - do update
+
+					int code = refreshToken() / 100; //refresh token
+					if(code != 2) { //if refresh token failed for some reason
+						if(code == 4) //only if response is 400, 500 might mean that token was not updated
+							logout(); //go to login screen
+						return response; //if token refresh failed - show error to user
+					}
+				}
+
+				if(settings.hasAccessToken()) { //retry requires new auth token,
+					setAuthHeader(builder, settings.getAccessToken()); //set auth token to updated
+					request = builder.build();
+					return chain.proceed(request); //repeat request with new token
+				}
+			}
+		}
+
+		return response;
+	}
+	private void setAuthHeader(Request.Builder builder, String token) {
+		if (token != null) //Add Auth token to each request if authorized
+			builder.header("Authorization", String.format("Bearer %s", token));
+	}
+	private int refreshToken() {
+		//Refresh token, synchronously, and return result code
+		//you might use retrofit here
+	}
+	private int logout() {
+		//logout your user
+	}
+}