Для автоматического крепления токена к запросу используются перехватчики или по английски Interceptor. Есть два вида на мой взгляд таких перехватчиков - простой и сложный. Если брать простой, то он называется Authentificator:
class TokenAuthenticator : Authenticator {
override fun authenticate(route: Route?, response: Response): Request? {
// This is a synchronous call
val updatedToken = getUpdatedToken()
return response.request().newBuilder()
.header(ApiClient.HEADER_AUTHORIZATION, updatedToken)
.build()
}
private fun getNewToken(): String {
val requestParams = HashMap<String, String>()
...
val authTokenResponse = ApiClient.userApiService.getAuthenticationToken(requestParams).execute().body()!!
val newToken = "${authTokenResponse.tokenType} ${authTokenResponse.accessToken}"
SharedPreferenceUtils.saveString(Constants.PreferenceKeys.USER_ACCESS_TOKEN, newToken)
return newToken
}
}
В нем вы передаете токен в заголовках к запросу и если что-то происходит не по сценарию, например токен протух, то данный перехватчик пошлет запрос на обновление токена и повторит запрос. Второй вариант - писать свой аналог authentificator при помощи interceptor. У меня был подобный вопрос некоторое время назад и благодаря @ЮрийСПБ у меня получилось понять как именно и что нужно сделать чтобы решить мою задачу. Ниже привожу пример того что у меня используется в качестве перехватчика:
class AuthToken(context: Context) : Interceptor {
var cont = context
override fun intercept(chain: Interceptor.Chain): Response {
val sp = cont.getSharedPreferences(Constants.SHARED_PREFS_STORAGE, 0)
if (check_expiration) {
updateAccessToken(cont)
}
val initialRequest = if (check_expiration) {
updateAccessToken(cont)
requestBuilder(chain)
} else {
requestBuilder(chain)
}
val initialResponse = chain.proceed(initialRequest)
return if (initialResponse.code == 401
&& !sp.getString("refresh_token", "").isNullOrBlank()
&& check_expiration) {
updateAccessToken(cont)
initialResponse.close()
val authorizedRequest = initialRequest
.newBuilder()
.addHeader("Content-type:", "application/json")
.addHeader("Authorization", "Bearer " + sp.getString("access_token", "")!!)
.build()
chain.proceed(authorizedRequest)
} else {
if (initialResponse.code == 500) {
val thread = object : Thread() {
override fun run() {
Looper.prepare()
Toast.makeText(cont, cont.getString(R.string.server_error_500), Toast.LENGTH_SHORT).show()
Looper.loop()
}
}
thread.start()
}
initialResponse
}
}
private fun updateAccessToken(context: Context) {
val sp = context.getSharedPreferences(Constants.SHARED_PREFS_STORAGE, 0)
synchronized(this) {
val tokensCall = accessTokenApi()
.getNewToken(ReqAccessToken(sp.getString("refresh_token", "")!!))
.execute()
if (tokensCall.isSuccessful) {
val responseBody = tokensCall.body()
val editor = sp.edit()
val localTime = SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss Z", Locale.ENGLISH).parse(tokensCall.headers()["Date"]!!)
Singleton.setServerTime(localTime!!.time / 1000, context)
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()
} else {
when (tokensCall.code()) {
500 -> {
val thread = object : Thread() {
override fun run() {
Looper.prepare()
Toast.makeText(cont, cont.getString(R.string.server_error_500), Toast.LENGTH_SHORT).show()
Looper.loop()
}
}
thread.start()
}
401 -> {
Singleton.logOut(context)
}
}
}
}
}
private fun requestBuilder(chain: Interceptor.Chain): Request {
return chain.request()
.newBuilder()
.header("Content-type:", "application/json")
.header("Authorization", "Bearer " + cont.getSharedPreferences(Constants.SHARED_PREFS_STORAGE, 0).getString("access_token", "")!!)
.build()
}
private fun accessTokenApi(): APIService {
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()
return retrofit.create(APIService::class.java)
}
}
Тут происходит проверка на протухлость токена и если все гуд то шлется запрос. Вот как подключить данный перехватчик к запросу:
val client = OkHttpClient.Builder()
.addInterceptor(interceptor)
.addInterceptor(AuthToken(context))
.connectTimeout(100, TimeUnit.SECONDS)
.dispatcher(dispatcher)
.readTimeout(100, TimeUnit.SECONDS).build()
Если же нет желания строить велосипед, то я бы советовал использовать Authentificator
. Но вам нужно так же кроме его подключения передавать либо токен либо контекст для получения доступа к хранилищу. Вот пример подключения Authentificator:
OkHttpClient.Builder()
.connectTimeout(TIMEOUT_IN_SECONDS.toLong(), TimeUnit.SECONDS)
.readTimeout(TIMEOUT_IN_SECONDS.toLong(), TimeUnit.SECONDS)
.authenticator(TokenAuthenticator())`
.addInterceptor(MyInterceptor())
Туториал_1,туториал_2 подобный вопрос.