- Making the OAuth class general purpose Interceptor and Authenticato…

…r. (#50)

- Improving the linting of client utility classes

src/main/resources/templates/client-code/http-resilience4j-util.kt.hbs

@@ -5,7 +5,8 @@ import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry
 
 fun <T> withCircuitBreaker(
     circuitBreakerRegistry: CircuitBreakerRegistry,
-    apiClientName: String, apiCall: () -> ApiResponse<T>
+    apiClientName: String,
+    apiCall: () -> ApiResponse<T>
 ): ApiResponse<T> {
     val circuitBreaker = circuitBreakerRegistry.circuitBreaker(apiClientName)
     return CircuitBreaker.decorateSupplier(circuitBreaker, apiCall).get()

src/main/resources/templates/client-code/logging-interceptor.kt.hbs

@@ -13,13 +13,13 @@ class LoggingInterceptor : Interceptor {
         val request = chain.request()
 
         val t1 = System.nanoTime()
-        logger.info("Client Request: ${request}")
+        logger.info("Client Request: $request")
 
         val response = chain.proceed(request)
 
         val t2 = System.nanoTime()
-        logger.info("Client Response after ${(t2 - t1) / 100_000}ms: ${response}")
+        logger.info("Client Response after ${(t2 - t1) / 100_000}ms: $response")
 
         return response
     }
-}
+}

src/main/resources/templates/client-code/oauth.kt.hbs

@@ -1,17 +1,21 @@
 package {{ client }}
 
-import okhttp3.Authenticator
+import okhttp3.Interceptor
 import okhttp3.Request
 import okhttp3.Response
 import okhttp3.Route
-import okio.IOException
 
-class OAuth2 : Authenticator {
-    var accessToken: String? = null
+class OAuth2(val accessToken: () -> String) : Authenticator, Interceptor {
 
-    @Throws(IOException::class)
-    override fun authenticate(route: Route?, response: Response): Request? =
+    override fun authenticate(route: Route?, response: Response): Request =
         response.request.newBuilder()
-                .header("Authorization", "Bearer $accessToken")
-                .build()
+            .header("Authorization", "Bearer ${accessToken().trim()}")
+            .build()
+
+    override fun intercept(chain: Interceptor.Chain): Response {
+        val request = chain.request().newBuilder()
+            .header("Authorization", "Bearer ${accessToken().trim()}")
+            .build()
+        return chain.proceed(request)
+    }
 }

src/test/resources/examples/okHttpClient/client/HttpResilience4jUtil.kt

@@ -5,7 +5,8 @@ import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry
 
 fun <T> withCircuitBreaker(
     circuitBreakerRegistry: CircuitBreakerRegistry,
-    apiClientName: String, apiCall: () -> ApiResponse<T>
+    apiClientName: String,
+    apiCall: () -> ApiResponse<T>
 ): ApiResponse<T> {
     val circuitBreaker = circuitBreakerRegistry.circuitBreaker(apiClientName)
     return CircuitBreaker.decorateSupplier(circuitBreaker, apiCall).get()

src/test/resources/examples/okHttpClient/client/LoggingInterceptor.kt

@@ -13,13 +13,13 @@ class LoggingInterceptor : Interceptor {
         val request = chain.request()
 
         val t1 = System.nanoTime()
-        logger.info("Client Request: ${request}")
+        logger.info("Client Request: $request")
 
         val response = chain.proceed(request)
 
         val t2 = System.nanoTime()
-        logger.info("Client Response after ${(t2 - t1) / 100_000}ms: ${response}")
+        logger.info("Client Response after ${(t2 - t1) / 100_000}ms: $response")
 
         return response
     }
-}
+}

src/test/resources/examples/okHttpClient/client/OAuth.kt

@@ -1,17 +1,22 @@
 package examples.okHttpClient.client
 
 import okhttp3.Authenticator
+import okhttp3.Interceptor
 import okhttp3.Request
 import okhttp3.Response
 import okhttp3.Route
-import okio.IOException
 
-class OAuth2 : Authenticator {
-    var accessToken: String? = null
+class OAuth2(val accessToken: () -> String) : Authenticator, Interceptor {
 
-    @Throws(IOException::class)
-    override fun authenticate(route: Route?, response: Response): Request? =
+    override fun authenticate(route: Route?, response: Response): Request =
         response.request.newBuilder()
-                .header("Authorization", "Bearer $accessToken")
-                .build()
-}
+            .header("Authorization", "Bearer ${accessToken().trim()}")
+            .build()
+
+    override fun intercept(chain: Interceptor.Chain): Response {
+        val request = chain.request().newBuilder()
+            .header("Authorization", "Bearer ${accessToken().trim()}")
+            .build()
+        return chain.proceed(request)
+    }
+}