如何在身份验证方法中击中同步刷新的呼叫,而无需循环依赖性dagger2



我想在我的httpauthentication interceptor的身份验证方法中添加刷新令牌调用,以管理401未经授权的响应上的access_token到期。

我使用Retrofit的ServiceClient接口(ServiceGateWay(在身份验证方法中添加了一个同步调用。我需要为此刷新令牌调用做一个单独的服务界面吗?

这是我的Authentication Interceptor和NetworkModule类

class AuthenticationInterceptor @Inject constructor(private val preferences: SharedPreferencesKeyValueDataSource, private val serviceGateway: ServiceGateway) : Interceptor, Authenticator{
    @Throws(IOException::class)
    override fun authenticate(route: Route?, response: Response): Request?{
        if (response.code() == 401) {
            val credentials = Credentials.basic("dummy", "dummy")
            val refreshCall = serviceGateway.refreshToken(credentials, preferences.getValue(Constants.REFRESH_TOKEN, ""))
            //make it as retrofit synchronous call
            val refreshResponse = refreshCall.execute()
            return if (refreshResponse.code() == 200) {
                //Save the access token and refresh token in preferences
                refreshResponse.body()?.let{
                    preferences.setValue(Constants.ACCESS_TOKEN, it.access_token)
                    preferences.setValue(Constants.REFRESH_TOKEN, it.refresh_token)
                }
                val newAccessToken = refreshResponse.body()?.access_token
                response.request().newBuilder()
                        .header(AuthenticationInterceptor.AUTHORIZATION, "Bearer $newAccessToken")
                        .build()
            } else {
                null
            }
        }
        return null
    }
}

//和NetworkModule的代码在下面,

@Provides
    @Singleton
    fun provideAuthenticationInterceptor(preferences: SharedPreferencesKeyValueDataSource, serviceGateway: ServiceGateway) = AuthenticationInterceptor(preferences, serviceGateway)
    @Provides
    @Singleton
    fun provideOkhttpClient(loggingInterceptor: HttpLoggingInterceptor,
                            authenticationInterceptor: AuthenticationInterceptor): OkHttpClient {
        val client = OkHttpClient.Builder()
        client.addInterceptor(loggingInterceptor)
        client.addInterceptor(authenticationInterceptor)
        client.authenticator(authenticationInterceptor)
        client.connectTimeout(15, TimeUnit.SECONDS)
        client.readTimeout(20, TimeUnit.SECONDS)
        return client.build()
    }

    @Provides
    @Singleton
    fun provideRetrofit(gson: Gson, okHttpClient: OkHttpClient,
                        @Named("BASE_URL_CORE") baseUrl: String)
            : Retrofit {
        return Retrofit.Builder()
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create(gson))
                .baseUrl(baseUrl)
                .client(okHttpClient)
                .build()
    }
    @Provides
    @Singleton
    fun provideGateway(retrofit: Retrofit): ServiceGateway {
        return retrofit.create(ServiceGateway::class.java)
    }

编译器错误是...

  • ServiceGateway注入... NetworkModule.ProvideAthenticationInterceptor(…,ServiceGateway(
  • AuthenticationInterceptor以
    注入... networkModule.provideokhttpclient(…,authentication Interceptor(
  • Okhttp3.okhttpclient注入... NetworkModule.ProviderEtrofit(…,OkhttpClient,…(
  • reTROFIT2.ROTROFIT被注入... NetworkModule.ProvideGateway(Raturofit(

我尝试了dagger懒惰注入(import daggger.lazy(用于servicegateway,并且在没有dagger的循环依赖性的情况下工作正常。

class AuthenticationInterceptor @Inject constructor(private val preferences: SharedPreferencesKeyValueDataSource, private val serviceGateway: Lazy<ServiceGateway>) : Interceptor, Authenticator{
}

RefreshToken API现在正在调用,但这会导致另一个问题(循环刷新呼叫(。因此,为了解决这个循环刷新的呼叫问题,最好像这样的人YasinKaçmaz在这里回答,为刷新通话做一个单独的服务门户。另一个解决方案是直接在OKHTTP上进行更新的调用(不使用Raterofit服务接口(

感谢Aamir Abro帮助我解决此问题。

最新更新