Android-ViewModel，LiveData，Room和改造以及协程在kotlin中放在一起

Question

我正在学习Android，我一直致力于让所有这些组件协同工作。我说的是ViewModel、LiveData、Room、改装和协同程序。

因此，我想实现以下目标：

当应用程序启动时，我想检查用户是否登录。如果没有登录，我什么也不做，如果他登录了，我将他的名字记录在主活动中。用户可以通过另一个api调用进行身份验证。然后，当用户被更新时，主活动应该向用户反映更改。我在这里部分遵循了谷歌代码实验室https://developer.android.com/jetpack/guide，但它是不完整的，我迷失在其中。

下面是代码块：

UserDao.kt

使用Room DAO进行数据库查询

@Dao
interface UserDao {

    @Query("SELECT * FROM user WHERE id = :userId")
    fun get(userId: Long): LiveData<UserEntity?>

    @Insert(onConflict = REPLACE)
    suspend fun insert(userEntity: UserEntity)

    @Query("SELECT COUNT(*) FROM user WHERE last_update >= :timeout")
    suspend fun hasUser(timeout: Long): Boolean
}

用户服务。kt

这是一个使用改进的简单api调用

interface UserService {

    @GET("users/current-user")
    suspend fun getUser(): Response<User>
}

用户存储库。kt

主活动应该调用get on load并刷新用户（调用api并检索用户id），将用户id保存在保存的StateHandler中，并从刚刚保存的数据库中检索用户。但是在第一次启动时，保存的StateHandler是空的。当我从api中获取用户时，我会将其存储在数据库中，但是传递给userDao.get（userId）的userId变量仍然为空，因此不会从数据库中加载任何内容。我应该在何时何地将用户的id保存在保存的StateHandler中？我在存储库中没有它的引用。此外，当应用程序启动时，调用不会被触发。我如何从活动中触发它？不确定在可变活动数据变量中的哪里设置用户，以便触发活动中的观察者。

suspend fun insert(userEntity: UserEntity) {
    userDao.insert(userEntity)
}

suspend fun get(userId: Long): LiveData<UserEntity?> {
    refreshUser()
    return userDao.get(userId)
}

private suspend fun refreshUser() = withContext(Dispatchers.IO) {
    launch {
        // Check if user data was fetched recently.
        val userExists = userDao.hasUser(FRESH_TIMEOUT)

        if (!userExists) {
            // Refreshes the data.
            val response = userService.getUser()
            try {
                if (response.isSuccessful) {
                    Log.i("user", "Success ${response.code()} - ${response.message()}")
                    // Updates the database. The LiveData object automatically
                    // refreshes, so we don't need to do anything else here.
                    val body: User? = response.body()
                    val user = UserEntity(
                        body!!.id,
                        body.email,
                        body.name.firstName,
                        body.name.lastName,
                        body.telephone,
                        body.dateOfBirth,
                        System.currentTimeMillis() / 1000
                    )
                    userDao.insert(user)
                } else {
                    Log.w(
                        "user",
                        "Not successful ${response.code()} - ${response.message()}"
                    )
                }
            } catch (e: HttpException) {
                Log.e("user", "Exception ${response.code()} - ${response.message()}")
            }
        }
    }
}

UserViewModel.kt

class UserViewModel @ViewModelInject constructor(
      private val repository: UserRepository,
      @Assisted private val savedStateHandle: SavedStateHandle) : ViewModel() {

    fun insert(userEntity: UserEntity) = viewModelScope.launch {
        repository.insert(userEntity)
    }

    private val userId: Long? = savedStateHandle["uid"]

    val user: LiveData<UserEntity?>
        get() = liveData { repository.get(userId) }
}

主要活动。kt

    viewModel.user.observe(this) { user ->
        Log.i("USER IS LOGGED", user.toString())
        Toast.makeText(this, "HELLO ${user?.email}!!", Toast.LENGTH_SHORT).show()
    }

Answer 1

private val userId: Long? = savedStateHandle["uid"]

val user: LiveData<UserEntity?>
   get() = liveData { repository.get(userId) }

应该是

private val userId: MutableLiveData<Long> = savedStateHandle.getLiveData("uid")

val user: LiveData<UserEntity?>
    get() = userId.switchMap { userId -> liveData { repository.get(userId) } }