Имеется такой интерцептор:
class AuthToken(context: Context) : Interceptor {
var cont = context
override fun intercept(chain: Interceptor.Chain): Response {
val sp = cont.getSharedPreferences("app_data", 0)
val originalRequest:Request? = (if (sp!!.getLong("expires_in", 0) - sp.getLong("time_delta", 0) - System.currentTimeMillis() / 1000 <= 60) {
updateToken(chain)
null
} else {
chain.request()
.newBuilder()
.header("Content-type:", "application/json")
.header("Authorization", "Bearer " + cont.getSharedPreferences("app_data", 0).getString("access_token", "")!!)
.build()
})
if (originalRequest!=null){
val response = chain.proceed(originalRequest)
when (response.code) {
401 -> {
updateToken(chain)
}
500 -> {
Toast.makeText(cont, cont.getString(R.string.server_error_500), Toast.LENGTH_SHORT).show()
}
}
return response
}else chain.proceed(originalRequest)
}
private fun updateToken(request: Interceptor.Chain) {
val interceptor = HttpLoggingInterceptor()
interceptor.level = HttpLoggingInterceptor.Level.BODY
val dispatcher = Dispatcher()
dispatcher.maxRequests = 1
val client = OkHttpClient.Builder()
.addInterceptor(interceptor)
.connectTimeout(100, TimeUnit.SECONDS)
.dispatcher(dispatcher)
.readTimeout(100, TimeUnit.SECONDS).build()
client.dispatcher.cancelAll()
val retrofit = Retrofit.Builder()
.baseUrl(BuildConfig.API_URL)
.client(client)
.addConverterFactory(GsonConverterFactory.create())
.build()
val api = retrofit.create(APIService::class.java)
api.getNewToken(ReqAccessToken(cont.getSharedPreferences("app_data", 0).getString("refresh_token", "")!!)).enqueue(object : Callback<ResNewTokens> {
override fun onResponse(call: Call<ResNewTokens>, response: retrofit2.Response<ResNewTokens>) {
if (response.isSuccessful) {
val editor = cont.getSharedPreferences("app_data", 0).edit()
editor.putString("access_token", Objects.requireNonNull<ResNewTokens>(response.body()).access_token).apply()
editor.putString("refresh_token", Objects.requireNonNull<ResNewTokens>(response.body()).refresh_token).apply()
editor.putLong("expires_in", response.body()!!.expires_in!!).apply()
makeNewCall(request)
} else {
when (response.code()) {
401 -> {
Singleton.logOut(cont)
}
500 -> {
Toast.makeText(cont, cont.getString(R.string.server_error_500), Toast.LENGTH_SHORT).show()
}
}
}
}
override fun onFailure(call: Call<ResNewTokens>, t: Throwable) {
}
})
}
private fun makeNewCall(req: Interceptor.Chain): Request {
return req.request()
.newBuilder()
.header("Content-type:", "application/json")
.header("Authorization", "Bearer " + cont.getSharedPreferences("app_data", 0).getString("access_token", "")!!)
.build()
}
}
проблема в этих строках:
if (sp!!.getLong("expires_in", 0) - sp.getLong("time_delta", 0) - System.currentTimeMillis() / 1000 <= 60) {
updateToken(chain)
null
}
суть задачи которую я пытаюсь решить - убрать лишний запрос с протухшим токеном который заведомо точно вернет 401 ошибку. Для этого я обернул все в if но не получается нормально это реализовать так как функция intercept
должна полюбому возвращать Response
чего не делается в данном условии. Думал сделать чтобы null слался но получается криво. Нужно как-то либо отменить запрос который планировался к посланию либо как-то иначе решить данную проблему но я не придумал как именно :(
UPDATE:
Вот что пока получилось:
override fun intercept(chain: Interceptor.Chain): Response {
val sp = cont.getSharedPreferences("app_data", 0)
val originalRequest = if (sp!!.getLong("expires_in", 0) - sp.getLong("time_delta", 0) - System.currentTimeMillis() / 1000 <= 60) {
val interceptor = HttpLoggingInterceptor()
interceptor.level = HttpLoggingInterceptor.Level.BODY
val dispatcher = Dispatcher()
dispatcher.maxRequests = 1
val client = OkHttpClient.Builder()
.addInterceptor(interceptor)
.connectTimeout(100, TimeUnit.SECONDS)
.dispatcher(dispatcher)
.readTimeout(100, TimeUnit.SECONDS).build()
client.dispatcher.cancelAll()
val retrofit = Retrofit.Builder()
.baseUrl(BuildConfig.API_URL)
.client(client)
.addConverterFactory(GsonConverterFactory.create())
.build()
val api = retrofit.create(APIService::class.java)
synchronized(this) {
when {
api.getNewToken(ReqAccessToken(cont.getSharedPreferences("app_data", 0).getString("refresh_token", "")!!)).execute().isSuccessful -> {
val responseBody = api.getNewToken(ReqAccessToken(cont.getSharedPreferences("app_data", 0).getString("refresh_token", "")!!)).execute().body()
val editor = cont.getSharedPreferences("app_data", 0).edit()
editor.putString("access_token", Objects.requireNonNull<ResNewTokens>(responseBody).access_token).apply()
editor.putString("refresh_token", Objects.requireNonNull<ResNewTokens>(responseBody).refresh_token).apply()
editor.putLong("expires_in", responseBody!!.expires_in!!).apply()
chain.request()
.newBuilder()
.header("Content-type:", "application/json")
.header("Authorization", "Bearer " + cont.getSharedPreferences("app_data", 0).getString("access_token", "")!!)
.build()
}
else->{
}
}
}
} else {
chain.request()
.newBuilder()
.header("Content-type:", "application/json")
.header("Authorization", "Bearer " + cont.getSharedPreferences("app_data", 0).getString("access_token", "")!!)
.build()
}
val response = chain.proceed(originalRequest)
when (response.code) {
401 -> {
//updateToken(chain)
}
500 -> {
Toast.makeText(cont, cont.getString(R.string.server_error_500), Toast.LENGTH_SHORT).show()
}
}
return response
}
и val response = chain.proceed(originalRequest)
говорит о том что ждут request. Я то пробовал в if прописать request но его тогда не видно я так понял.
api.getNewToken().execute()
,пишем токен из ответа в префы
,составляем запрос с новым токеном
,возвращаем его из
updateToken() используя в fun intercept() в качестве возвращаемого значения`,