android - 在 Retrofit 客户端中访问 DataStore 首选项 [HILT]

Question

我正在使用 HILT 注入(inject)改造实例，现在我的问题是我想将授权 token 添加到存储在 Data Store Preferences 中的请求中。我是协程的新手，所以我对如何做同样的事情感到困惑。以前我曾经使用共享首选项来获取 token ，这非常简单。
应用模块.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)

}

session 管理器.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() 函数获取 token 的值，但是该函数返回的数据流是挂起函数，不能从函数中调用。任何形式的帮助将不胜感激。

Answer 1

您可以使用 runBlocking从正常功能运行挂起功能。 OkHttp 拦截器在线程池而不是主线程上运行，因此在那里获取当前 token 应该是安全的。

        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)
        })