/
UserRepository.kt
74 lines (57 loc) · 2.77 KB
/
UserRepository.kt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
package io.philippeboisney.repository
import androidx.lifecycle.LiveData
import io.philippeboisney.local.dao.UserDao
import io.philippeboisney.model.ApiResult
import io.philippeboisney.model.User
import io.philippeboisney.remote.UserDatasource
import io.philippeboisney.repository.utils.NetworkBoundResource
import io.philippeboisney.repository.utils.Resource
import kotlinx.coroutines.Deferred
interface UserRepository {
suspend fun getTopUsersWithCache(forceRefresh: Boolean = false): LiveData<Resource<List<User>>>
suspend fun getUserDetailWithCache(forceRefresh: Boolean = false, login: String): LiveData<Resource<User>>
}
class UserRepositoryImpl(private val datasource: UserDatasource,
private val dao: UserDao): UserRepository {
/**
* Suspended function that will get a list of top [User]
* whether in cache (SQLite) or via network (API).
* [NetworkBoundResource] is responsible to handle this behavior.
*/
override suspend fun getTopUsersWithCache(forceRefresh: Boolean): LiveData<Resource<List<User>>> {
return object : NetworkBoundResource<List<User>, ApiResult<User>>() {
override fun processResponse(response: ApiResult<User>): List<User>
= response.items
override suspend fun saveCallResults(items: List<User>)
= dao.save(items)
override fun shouldFetch(data: List<User>?): Boolean
= data == null || data.isEmpty() || forceRefresh
override suspend fun loadFromDb(): List<User>
= dao.getTopUsers()
override fun createCallAsync(): Deferred<ApiResult<User>>
= datasource.fetchTopUsersAsync()
}.build().asLiveData()
}
/**
* Suspended function that will get details of a [User]
* whether in cache (SQLite) or via network (API).
* [NetworkBoundResource] is responsible to handle this behavior.
*/
override suspend fun getUserDetailWithCache(forceRefresh: Boolean, login: String): LiveData<Resource<User>> {
return object : NetworkBoundResource<User, User>() {
override fun processResponse(response: User): User
= response
override suspend fun saveCallResults(item: User)
= dao.save(item)
override fun shouldFetch(data: User?): Boolean
= data == null
|| data.haveToRefreshFromNetwork()
|| data.name.isNullOrEmpty()
|| forceRefresh
override suspend fun loadFromDb(): User
= dao.getUser(login)
override fun createCallAsync(): Deferred<User>
= datasource.fetchUserDetailsAsync(login)
}.build().asLiveData()
}
}