lordcodes

dependencies {
    implementation(enforcedPlatform(project(":dependency-constraints")))
  
    implementation("org.jetbrains.kotlin:kotlin-stdlib")
    implementation("androidx.lifecycle:lifecycle-livedata-ktx")
    implementation("io.coil-kt:coil")
}

lordcodes

class AuthorizationInterceptor(
    private val authorizationRepository: AuthorizationRepository
) : Interceptor {
    override fun intercept(chain: Interceptor.Chain): Response {
        val newRequest = chain.request().signedRequest()
        return chain.proceed(newRequest)
    }

    private fun Request.signedRequest() = when (AuthorizationType.fromRequest(this)) {
        AuthorizationType.ACCESS_TOKEN -> signWithFreshAccessToken()

lordcodes

interface CreateAccountRemoteApi {
    @POST("user/identity")
    fun createAccount(
        @Body request: CreateAccountRemoteDto,
        @Tag authorization: AuthorizationType = AuthorizationType.CLIENT_CREDENTIALS
    ): Single<AccountCreatedRemoteDto>
}

lordcodes

enum class AuthorizationType {
    ACCESS_TOKEN,
    CLIENT_CREDENTIALS,
    NONE;

    companion object {
        fun fromRequest(request: Request): AuthorizationType =
            request.tag(AuthorizationType::class.java) ?: ACCESS_TOKEN
    }
}

lordcodes

OkHttpClient.Builder()
    .addInterceptor(authorizationInterceptor)
    .authenticator(tokenRefreshAuthenticator)
    .build()

lordcodes

class TokenRefreshAuthenticator(
    private val authorizationRepository: AuthorizationRepository
) : Authenticator {
    override fun authenticate(route: Route?, response: Response): Request? = when {
        response.retryCount > 2 -> null
        else -> response.createSignedRequest()
    }

    private fun Response.createSignedRequest(): Request? = try {
        val accessToken = authenticationRepository.fetchFreshAccessToken()

lordcodes

private val Response.retryCount: Int
    get() {
        var currentResponse = priorResponse
        var result = 0
        while (currentResponse != null) {
            result++
            currentResponse = currentResponse.priorResponse
        }
        return result
    }

lordcodes

fun Request.signWithToken(accessToken: AccessToken) =
    newBuilder()
        .header("Authorization", "Bearer ${accessToken.rawToken}")
        .build()

lordcodes

fun okHttpClient(authorizationInterceptor: AuthorizationInterceptor) =
    OkHttpClient.Builder()
        .addInterceptor(authorizationInterceptor)
        .build()

lordcodes

class AuthorizationInterceptor(
    private val authorizationRepository: AuthorizationRepository
) : Interceptor {
    override fun intercept(chain: Interceptor.Chain): Response {
        val newRequest = chain.request().signedRequest()
        return chain.proceed(newRequest)
    }

    private fun Request.signedRequest(): Request {
        val accessToken = authorizationRepository.fetchFreshAccessToken()