/
UserRepositoryTest.kt
144 lines (114 loc) · 5 KB
/
UserRepositoryTest.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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
package io.philippeboisney.repository
import androidx.arch.core.executor.testing.InstantTaskExecutorRule
import androidx.lifecycle.Observer
import io.mockk.*
import io.philippeboisney.common_test.rules.CoroutinesMainDispatcherRule
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.FakeData
import io.philippeboisney.repository.utils.Resource
import kotlinx.coroutines.*
import org.junit.Before
import org.junit.Rule
import org.junit.Test
import java.util.*
@ExperimentalCoroutinesApi
class UserRepositoryTest {
@get:Rule
val instantExecutorRule = InstantTaskExecutorRule()
@get:Rule
var coroutinesMainDispatcherRule = CoroutinesMainDispatcherRule()
// FOR DATA
private lateinit var observer: Observer<Resource<List<User>>>
private lateinit var observerUser: Observer<Resource<User>>
private lateinit var userRepository: UserRepository
private val userService = mockk<UserDatasource>()
private val userDao = mockk<UserDao>(relaxed = true)
@Before
fun setUp() {
observer = mockk(relaxed = true)
observerUser = mockk(relaxed = true)
userRepository = UserRepositoryImpl(userService, userDao)
}
@Test
fun `Get top users from server when no internet is available`() {
val exception = Exception("Internet")
every { userService.fetchTopUsersAsync() } throws exception
coEvery { userDao.getTopUsers() } returns listOf()
runBlocking {
userRepository.getTopUsersWithCache().observeForever(observer)
}
verifyOrder {
observer.onChanged(Resource.loading(null)) // Init loading with no value
observer.onChanged(Resource.loading(listOf())) // Then trying to load from db (fast temp loading) before load from remote source
observer.onChanged(Resource.error(exception, listOf())) // Retrofit 403 error
}
confirmVerified(observer)
}
@Test
fun `Get top users from network`() {
val fakeUsers = FakeData.createFakeUsers(5)
every { userService.fetchTopUsersAsync() } returns GlobalScope.async { ApiResult(fakeUsers.size, fakeUsers) }
coEvery { userDao.getTopUsers() } returns listOf() andThen { fakeUsers }
runBlocking {
userRepository.getTopUsersWithCache().observeForever(observer)
}
verifyOrder {
observer.onChanged(Resource.loading(null)) // Loading from remote source
observer.onChanged(Resource.loading(listOf())) // Then trying to load from db (fast temp loading) before load from remote source
observer.onChanged(Resource.success(fakeUsers)) // Success
}
coVerify(exactly = 1) {
userDao.save(fakeUsers)
}
confirmVerified(observer)
}
@Test
fun `Get top users from db`() {
val fakeUsers = FakeData.createFakeUsers(5)
every { userService.fetchTopUsersAsync() } returns GlobalScope.async { ApiResult(fakeUsers.size, fakeUsers) }
coEvery { userDao.getTopUsers() } returns fakeUsers
runBlocking {
userRepository.getTopUsersWithCache().observeForever(observer)
}
verifyOrder {
observer.onChanged(Resource.loading(null)) // Loading from remote source
observer.onChanged(Resource.success(fakeUsers)) // Success
}
confirmVerified(observer)
}
@Test
fun `Get user's detail from network`() {
val fakeUser = FakeData.createFakeUser("fake")
every { userService.fetchUserDetailsAsync("fake_login") } returns GlobalScope.async { fakeUser }
coEvery { userDao.getUser("fake_login") } returns fakeUser
runBlocking {
userRepository.getUserDetailWithCache(login = "fake_login").observeForever(observerUser)
}
verify {
observerUser.onChanged(Resource.loading(null)) // Loading from remote source
observerUser.onChanged(Resource.loading(fakeUser)) // Then trying to load from db (fast temp loading) before load from remote source
observerUser.onChanged(Resource.success(fakeUser)) // Success
}
coVerify(exactly = 1) {
userDao.save(fakeUser)
}
confirmVerified(observerUser)
}
@Test
fun `Get user's detail from db`() {
val fakeUser = FakeData.createFakeUser("fake")
every { userService.fetchUserDetailsAsync("fake_login") } returns GlobalScope.async { fakeUser }
coEvery { userDao.getUser("fake_login") } returns fakeUser.apply { lastRefreshed = Date() }
runBlocking {
userRepository.getUserDetailWithCache(login = "fake_login").observeForever(observerUser)
}
verify {
observerUser.onChanged(Resource.loading(null)) // Loading from remote source
observerUser.onChanged(Resource.success(fakeUser)) // Success
}
confirmVerified(observerUser)
}
}