DataSource class and Retrofit Unit testing using coroutines and Mockito

Viewed 262

Hi I am writing Unit tests for my repository and data layer in network module but while writing unit tests for my DataSource layer I am getting error from Mockito.

SaltDataSource class:

class SaltDataSource : BaseDataSource() {
/**
 * This method will get salt from server
 */
suspend fun getSalt(saltRequest: SaltRequest) =
    getResult { TMSService.instance.getSaltAsync(SALT_URL, saltRequest) }
}

TMS Service retrofit interface:

interface TMSService {

@POST
suspend fun postHeartBeatAsync(
    @Url url: String, @Header("Authorization") authToken: String,
    @Body
    heartBeatList: PostHeartBeat
):
        Response<HeartBeatResponse>

@POST
suspend fun getSaltAsync(@Url url: String, @Body saltRequest: SaltRequest):
        Response<SaltResponse>

companion object {
    //creating singleton object of TMSService
    val instance: TMSService by lazy {
        ApiClient.retrofitInstance.create(TMSService::class.java)
    }
}

}

SaltDataSourceTestClass:

/**
 * Unit Test class for SaltDataSource
 */
@RunWith(MockitoJUnitRunner::class)
class SaltDataSourceTest {

@Mock
private lateinit var tmsService: TMSService

@Mock
private lateinit var saltRequest: SaltRequest

private lateinit var saltDataSource: SaltDataSource

private lateinit var saltResponse: SaltResponse

@Before
fun beforeTest() {
    saltDataSource = SaltDataSource()
}

@Test
fun givenSaltRequest_whenGetSaltCalled_shouldCallGetSaltApi() {
    runBlocking {
        saltDataSource.getSalt(saltRequest)

        delay(2000)
        Mockito.verify(tmsService).getSaltAsync("url", saltRequest)
    }
}

}

I am getting this issue while trying to verify my call using Mockito:

Wanted but not invoked:
tmsService.getSaltAsync("url", saltRequest);

I have checked http logs and I am getting response i.e this method is getting called.

0 Answers
Related