提问人:Akrit Khanna 提问时间:3/21/2022 更新时间:3/23/2022 访问量:2449
在 Retrofit 客户端中访问 DataStore 首选项 [HILT]
Accessing DataStore Preferences inside Retrofit client [HILT]
问:
我正在使用 HILT 注入改造实例,现在我的问题是我想将授权令牌添加到存储在 Data Store Preferences 中的请求中。我是协程和刀柄的新手,所以我对如何做同样的事情感到困惑。以前,我曾经使用共享首选项获取令牌,这非常简单。
AppModule.kt的
@Module
@InstallIn(SingletonComponent::class)
object AppModule {
@Provides
fun provideRetrofit(@ApplicationContext context: Context, sessionManager: SessionManager): Retrofit {
//sessionManager.getToken() cannot call this as it requires provideRetrofit() to be a suspend function
val builder = OkHttpClient.Builder()
//This is to check the logs of api request
val logging = HttpLoggingInterceptor()
logging.setLevel(HttpLoggingInterceptor.Level.BODY)
builder.writeTimeout(60, TimeUnit.SECONDS)
builder.readTimeout(60, TimeUnit.SECONDS)
builder.connectTimeout(60, TimeUnit.SECONDS)
//create network interceptor
//create network interceptor
Log.d("TAG", "provideRetrofit: $token")
builder.addNetworkInterceptor(Interceptor { chain: Interceptor.Chain ->
val request = chain.request()
chain.proceed(request).newBuilder()
.header("Cache-Control", "public")
.removeHeader("Pragma")
.build()
})
//create offline interceptor
builder.addInterceptor(Interceptor { chain: Interceptor.Chain ->
var request = chain.request()
if (!Tools.checkInternet(context)) {
val maxStale = 60 * 60 * 24 * 30 // Offline cache available for 30 days
request = request.newBuilder()
.header("Cache-Control", "public, only-if-cached, max-stale=$maxStale")
.removeHeader("Pragma")
.build()
}
chain.proceed(request)
})
builder.addInterceptor(logging)
//setup cache
//setup cache
val httpCacheDirectory: File = File(context.getCacheDir(), "responses")
val cacheSize = 10 * 1024 * 1024 // 10 MB
val cache = Cache(httpCacheDirectory, cacheSize.toLong())
builder.cache(cache)
return Retrofit.Builder()
.baseUrl(BuildConfig.BASE_URL)
.client(builder.build())
.addConverterFactory(GsonConverterFactory.create())
.build()
}
@Provides
fun provideApi(retrofit: Retrofit): ApiInterface = retrofit.create(ApiInterface::class.java)
@Provides
@Singleton
fun provideSessionManager(@ApplicationContext context: Context) = SessionManager(context)
}
会话管理器.kt
class SessionManager @Inject constructor(@ApplicationContext private val context: Context) {
private val Context.dataStore: DataStore<Preferences> by preferencesDataStore(name = Constants.PREFERENCES)
private val tokenPreferences = stringPreferencesKey(Constants.AUTH_TOKEN)
suspend fun saveToken(token : String){
context.dataStore.edit {
it[tokenPreferences] = token
}
}
fun getToken() = context.dataStore.data.map {
it[tokenPreferences]
}
}
我想使用 getToken() 函数获取令牌的值,但此函数返回的数据流是无法从函数调用的挂起函数。任何形式的帮助将不胜感激。
答:
15赞
Nitrodon
3/23/2022
#1
您可以使用从普通函数运行挂起函数。OkHttp 拦截器运行在线程池而不是主线程上,因此在那里获取当前令牌应该是安全的。runBlocking
builder.addNetworkInterceptor(Interceptor { chain: Interceptor.Chain ->
val token = runBlocking {
sessionManager.getToken().first()
}
val request = chain.request().newBuilder()
.addHeader("Authorization", "Bearer $token")
.build()
chain.proceed(request)
})
评论
0赞
Akrit Khanna
3/23/2022
成功了。我想再问一个问题,我们可以在 runBlocking {...} 中执行一个没有返回类型的挂起函数吗?
0赞
Nitrodon
3/23/2022
@AkritKhanna 每个 Kotlin 函数都有一个返回类型。函数“无返回类型”实际上返回 。Unit
0赞
Akrit Khanna
3/23/2022
哦,但我试图用 Unit 函数阻止线程,但它不起作用。
评论