@@ -1,866 +0,0 @@
package bou.amine.apps.readerforselfossv2.repository
import bou.amine.apps.readerforselfossv2.dao.ITEM
import bou.amine.apps.readerforselfossv2.dao.ReaderForSelfossDB
import bou.amine.apps.readerforselfossv2.dao.SOURCE
import bou.amine.apps.readerforselfossv2.dao.TAG
import bou.amine.apps.readerforselfossv2.model.SelfossModel
import bou.amine.apps.readerforselfossv2.rest.SelfossApi
import bou.amine.apps.readerforselfossv2.service.AppSettingsService
import bou.amine.apps.readerforselfossv2.utils.ItemType
import bou.amine.apps.readerforselfossv2.utils.toView
import com.github.ln_12.library.ConnectivityStatus
import io.mockk.*
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.runBlocking
import kotlin.test.*
class RepositoryTest ( ) {
private val connectivityStatus = mockk < ConnectivityStatus > ( )
private val db = mockk < ReaderForSelfossDB > ( )
private val appSettingsService = mockk < AppSettingsService > ( )
private val api = mockk < SelfossApi > ( )
private val NUMBER _ARTICLES = 100
private val NUMBER _UNREAD = 50
private val NUMBER _STARRED = 20
@BeforeTest
fun setup ( ) {
clearAllMocks ( )
every { appSettingsService . getApiVersion ( ) } returns 4
every { appSettingsService . getBaseUrl ( ) } returns " https://test.com/selfoss/ "
every { appSettingsService . isItemCachingEnabled ( ) } returns false
every { appSettingsService . isUpdateSourcesEnabled ( ) } returns true
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( true )
coEvery { api . version ( ) } returns SelfossModel . StatusAndData ( success = true , data = SelfossModel . ApiVersion ( " 2.19-ba1e8e3 " , " 4.0.0 " ) )
coEvery { api . stats ( ) } returns SelfossModel . StatusAndData ( success = true , data = SelfossModel . Stats ( NUMBER _ARTICLES , NUMBER _UNREAD , NUMBER _STARRED ) )
every { db . itemsQueries . items ( ) . executeAsList ( ) } returns generateTestDBItems ( )
every { db . tagsQueries . deleteAllTags ( ) } returns Unit
every { db . tagsQueries . transaction ( any ( ) , any ( ) ) } returns Unit
every { db . tagsQueries . insertTag ( any ( ) ) } returns Unit
}
@Test
fun `Instantiate repository` ( ) {
val success = try {
Repository ( api , appSettingsService , connectivityStatus , db )
true
} catch ( e : Exception ) {
false
}
assertEquals ( true , success )
}
@Test
fun `Instantiate repository without api version` ( ) {
every { appSettingsService . getApiVersion ( ) } returns - 1
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val success = try {
Repository ( api , appSettingsService , connectivityStatus , db )
true
} catch ( e : Exception ) {
false
}
assertEquals ( true , success )
}
@Test
fun `Instantiate repository with negative stats` ( ) {
coEvery { api . stats ( ) } returns SelfossModel . StatusAndData ( success = true , data = SelfossModel . Stats ( - 100 , - 50 , - 20 ) )
val success = try {
Repository ( api , appSettingsService , connectivityStatus , db )
true
} catch ( e : Exception ) {
false
}
assertEquals ( true , success )
}
@Test
fun `Get api 4 date with api 1 version stored` ( ) {
every { appSettingsService . getApiVersion ( ) } returns 1
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
every { appSettingsService . updateApiVersion ( any ( ) ) } returns Unit
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
runBlocking {
repository . getNewerItems ( )
}
assertSame ( repository . items . size , 1 )
verify ( exactly = 1 ) { appSettingsService . updateApiVersion ( 4 ) }
}
@Test
fun `Get api 1 date with api 4 version stored` ( ) {
every { appSettingsService . getApiVersion ( ) } returns 4
coEvery { api . version ( ) } returns SelfossModel . StatusAndData ( success = false , null )
val itemParameters = FakeItemParameters ( )
itemParameters . datetime = " 2021-04-23 11:45:32 "
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( itemParameters ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
runBlocking {
repository . getNewerItems ( )
}
assertSame ( 1 , repository . items . size )
}
@Test
fun `Get newer items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
runBlocking {
repository . getNewerItems ( )
}
assertSame ( repository . items . size , 1 )
coVerify ( exactly = 1 ) { api . getItems ( " unread " , 0 , null , null , null , null , any ( ) ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get all newer items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . displayedItems = ItemType . ALL
runBlocking {
repository . getNewerItems ( )
}
assertSame ( repository . items . size , 1 )
coVerify ( exactly = 1 ) { api . getItems ( " all " , 0 , null , null , null , null , any ( ) ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get newer starred items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . displayedItems = ItemType . STARRED
runBlocking {
repository . getNewerItems ( )
}
assertSame ( repository . items . size , 1 )
coVerify ( exactly = 1 ) { api . getItems ( " starred " , 0 , null , null , null , null , any ( ) ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get newer items without connectivity` ( ) {
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
every { appSettingsService . isItemCachingEnabled ( ) } returns true
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
runBlocking {
repository . getNewerItems ( )
}
assertSame ( repository . items . size , 1 )
coVerify ( exactly = 0 ) { api . getItems ( " unread " , 0 , null , null , null , null , any ( ) ) }
verify ( atLeast = 1 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get older items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . items = ArrayList ( generateTestApiItem ( ) )
runBlocking {
repository . getOlderItems ( )
}
assertSame ( repository . items . size , 2 )
coVerify ( exactly = 1 ) { api . getItems ( " unread " , 1 , null , null , null , null , any ( ) ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get all older items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . items = ArrayList ( generateTestApiItem ( ) )
repository . displayedItems = ItemType . ALL
runBlocking {
repository . getOlderItems ( )
}
assertSame ( repository . items . size , 2 )
coVerify ( exactly = 1 ) { api . getItems ( " all " , 1 , null , null , null , null , any ( ) ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get older starred items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . displayedItems = ItemType . STARRED
repository . items = ArrayList ( generateTestApiItem ( ) )
runBlocking {
repository . getOlderItems ( )
}
assertSame ( repository . items . size , 2 )
coVerify ( exactly = 1 ) { api . getItems ( " starred " , 1 , null , null , null , null , any ( ) ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Reload badges` ( ) {
var success = false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
runBlocking {
success = repository . reloadBadges ( )
}
assertSame ( true , success )
assertSame ( NUMBER _ARTICLES , repository . badgeAll )
assertSame ( NUMBER _UNREAD , repository . badgeUnread )
assertSame ( NUMBER _STARRED , repository . badgeStarred )
coVerify ( atLeast = 1 ) { api . stats ( ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Reload badges without response` ( ) {
coEvery { api . stats ( ) } returns SelfossModel . StatusAndData ( success = false , data = null )
var success = false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
runBlocking {
success = repository . reloadBadges ( )
}
assertSame ( false , success )
assertSame ( 0 , repository . badgeAll )
assertSame ( 0 , repository . badgeUnread )
assertSame ( 0 , repository . badgeStarred )
coVerify ( atLeast = 1 ) { api . stats ( ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Reload badges with items caching` ( ) {
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
every { appSettingsService . isItemCachingEnabled ( ) } returns true
every { db . itemsQueries . items ( ) . executeAsList ( ) } returns generateTestDBItems ( )
val itemParameter = FakeItemParameters ( )
itemParameter . starred = true
itemParameter . unread = false
var success = false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . items = ArrayList ( generateTestApiItem ( itemParameter ) )
runBlocking {
success = repository . reloadBadges ( )
}
assertSame ( true , success )
assertSame ( 1 , repository . badgeAll )
assertSame ( 1 , repository . badgeUnread )
assertSame ( 1 , repository . badgeStarred )
coVerify ( exactly = 0 ) { api . stats ( ) }
verify ( atLeast = 1 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Reload badges without items caching` ( ) {
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
every { appSettingsService . isItemCachingEnabled ( ) } returns false
val itemParameter = FakeItemParameters ( )
itemParameter . starred = true
itemParameter . unread = false
var success = false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . items = ArrayList ( generateTestApiItem ( itemParameter ) )
runBlocking {
success = repository . reloadBadges ( )
}
assertSame ( false , success )
assertSame ( 0 , repository . badgeAll )
assertSame ( 0 , repository . badgeUnread )
assertSame ( 0 , repository . badgeStarred )
coVerify ( exactly = 0 ) { api . stats ( ) }
verify ( exactly = 0 ) { db . itemsQueries . items ( ) . executeAsList ( ) }
}
@Test
fun `Get tags` ( ) {
val tags = listOf ( SelfossModel . Tag ( " test " , " red " , 6 ) ,
SelfossModel . Tag ( " second " , " yellow " , 0 ) )
coEvery { api . tags ( ) } returns SelfossModel . StatusAndData ( success = true , data = tags )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testTags : List < SelfossModel . Tag > ? = null
runBlocking {
testTags = repository . getTags ( )
}
assertSame ( tags , testTags )
verify ( exactly = 0 ) { db . tagsQueries . tags ( ) . executeAsList ( ) }
}
@Test
fun `Get tags with sources update disabled` ( ) {
val tags = listOf ( SelfossModel . Tag ( " test " , " red " , 6 ) ,
SelfossModel . Tag ( " second " , " yellow " , 0 ) )
val tagsDB = listOf ( TAG ( " test_DB " , " red " , 6 ) ,
TAG ( " second_DB " , " yellow " , 0 ) )
coEvery { api . tags ( ) } returns SelfossModel . StatusAndData ( success = true , data = tags )
coEvery { db . tagsQueries . tags ( ) . executeAsList ( ) } returns tagsDB
every { appSettingsService . isUpdateSourcesEnabled ( ) } returns false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testTags : List < SelfossModel . Tag > = emptyList ( )
runBlocking {
testTags = repository . getTags ( )
testTags = repository . getTags ( )
}
assertNotSame ( tags , testTags )
assertContentEquals ( tagsDB . map { it . toView ( ) } , testTags )
coVerify ( exactly = 1 ) { api . tags ( ) }
verify ( atLeast = 1 ) { db . tagsQueries . tags ( ) . executeAsList ( ) }
}
@Test
fun `Get tags with sources update and items caching disabled` ( ) {
val tags = listOf ( SelfossModel . Tag ( " test " , " red " , 6 ) ,
SelfossModel . Tag ( " second " , " yellow " , 0 ) )
val tagsDB = listOf ( TAG ( " test_DB " , " red " , 6 ) ,
TAG ( " second_DB " , " yellow " , 0 ) )
coEvery { api . tags ( ) } returns SelfossModel . StatusAndData ( success = true , data = tags )
coEvery { db . tagsQueries . tags ( ) . executeAsList ( ) } returns tagsDB
every { appSettingsService . isUpdateSourcesEnabled ( ) } returns false
every { appSettingsService . isItemCachingEnabled ( ) } returns false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testTags : List < SelfossModel . Tag > = emptyList ( )
runBlocking {
testTags = repository . getTags ( )
}
assertSame ( emptyList ( ) , testTags )
coVerify ( exactly = 0 ) { api . tags ( ) }
verify ( exactly = 0 ) { db . tagsQueries . tags ( ) . executeAsList ( ) }
}
@Test
fun `Get tags without connection` ( ) {
val tags = listOf ( SelfossModel . Tag ( " test " , " red " , 6 ) ,
SelfossModel . Tag ( " second " , " yellow " , 0 ) )
val tagsDB = listOf ( TAG ( " test_DB " , " red " , 6 ) ,
TAG ( " second_DB " , " yellow " , 0 ) )
coEvery { api . tags ( ) } returns SelfossModel . StatusAndData ( success = true , data = tags )
coEvery { db . tagsQueries . tags ( ) . executeAsList ( ) } returns tagsDB
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testTags : List < SelfossModel . Tag > = emptyList ( )
runBlocking {
testTags = repository . getTags ( )
}
assertNotSame ( tags , testTags )
assertSame ( tagsDB . first ( ) . name , testTags . first ( ) . tag )
coVerify ( exactly = 0 ) { api . tags ( ) }
verify ( atLeast = 1 ) { db . tagsQueries . tags ( ) . executeAsList ( ) }
}
@Test
fun `Get tags without connection and items caching disabled` ( ) {
val tags = listOf ( SelfossModel . Tag ( " test " , " red " , 6 ) ,
SelfossModel . Tag ( " second " , " yellow " , 0 ) )
val tagsDB = listOf ( TAG ( " test_DB " , " red " , 6 ) ,
TAG ( " second_DB " , " yellow " , 0 ) )
coEvery { api . tags ( ) } returns SelfossModel . StatusAndData ( success = true , data = tags )
coEvery { db . tagsQueries . tags ( ) . executeAsList ( ) } returns tagsDB
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
every { appSettingsService . isItemCachingEnabled ( ) } returns false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testTags : List < SelfossModel . Tag > = emptyList ( )
runBlocking {
testTags = repository . getTags ( )
}
assertContentEquals ( tagsDB . map { it . toView ( ) } , testTags )
coVerify ( exactly = 0 ) { api . tags ( ) }
verify ( atLeast = 1 ) { db . tagsQueries . tags ( ) . executeAsList ( ) }
}
@Test
fun `Get tags without connection and sources update disabled` ( ) {
val tags = listOf ( SelfossModel . Tag ( " test " , " red " , 6 ) ,
SelfossModel . Tag ( " second " , " yellow " , 0 ) )
val tagsDB = listOf ( TAG ( " test_DB " , " red " , 6 ) ,
TAG ( " second_DB " , " yellow " , 0 ) )
coEvery { api . tags ( ) } returns SelfossModel . StatusAndData ( success = true , data = tags )
coEvery { db . tagsQueries . tags ( ) . executeAsList ( ) } returns tagsDB
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
every { appSettingsService . isUpdateSourcesEnabled ( ) } returns false
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testTags : List < SelfossModel . Tag > = emptyList ( )
runBlocking {
testTags = repository . getTags ( )
}
assertNotSame ( tags , testTags )
assertContentEquals ( tagsDB . map { it . toView ( ) } , testTags )
coVerify ( exactly = 0 ) { api . tags ( ) }
verify ( atLeast = 1 ) { db . tagsQueries . tags ( ) . executeAsList ( ) }
}
@Test
fun `get sources` ( ) {
val sources = arrayListOf ( SelfossModel . Source ( 1 , " First source " , listOf ( " Test " , " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SelfossModel . Source ( 2 , " Second source " , listOf ( " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
coEvery { api . sources ( ) } returns SelfossModel . StatusAndData ( success = true , data = sources )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testSources : List < SelfossModel . Source > ? = null
runBlocking {
testSources = repository . getSources ( )
}
assertSame ( sources , testSources )
coVerify ( exactly = 1 ) { api . sources ( ) }
verify ( exactly = 0 ) { db . sourcesQueries . sources ( ) . executeAsList ( ) }
}
@Test
fun `get sources without connection` ( ) {
val sources = arrayListOf ( SelfossModel . Source ( 1 , " First source " , listOf ( " Test " , " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SelfossModel . Source ( 2 , " Second source " , listOf ( " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
val sourcesDB = listOf < SOURCE > ( SOURCE ( " 1 " , " First source " , " Test,second " , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SOURCE ( " 2 " , " Second source " , " second " , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
coEvery { api . sources ( ) } returns SelfossModel . StatusAndData ( success = true , data = sources )
every { db . sourcesQueries . sources ( ) . executeAsList ( ) } returns sourcesDB
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testSources : List < SelfossModel . Source > ? = null
runBlocking {
testSources = repository . getSources ( )
}
assertContentEquals ( sources , testSources )
coVerify ( exactly = 0 ) { api . sources ( ) }
verify ( atLeast = 1 ) { db . sourcesQueries . sources ( ) . executeAsList ( ) }
}
@Test
fun `get sources without connection and items caching disabled` ( ) {
val sources = arrayListOf ( SelfossModel . Source ( 1 , " First source " , listOf ( " Test " , " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SelfossModel . Source ( 2 , " Second source " , listOf ( " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
val sourcesDB = listOf < SOURCE > ( SOURCE ( " 1 " , " First source " , " Test,second " , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SOURCE ( " 2 " , " Second source " , " second " , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
every { appSettingsService . isItemCachingEnabled ( ) } returns false
coEvery { api . sources ( ) } returns SelfossModel . StatusAndData ( success = true , data = sources )
every { db . sourcesQueries . sources ( ) . executeAsList ( ) } returns sourcesDB
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testSources : List < SelfossModel . Source > ? = null
runBlocking {
testSources = repository . getSources ( )
}
assertSame ( null , testSources )
coVerify ( exactly = 0 ) { api . sources ( ) }
verify ( exactly = 0 ) { db . sourcesQueries . sources ( ) . executeAsList ( ) }
}
@Test
fun `get sources with sources update disabled` ( ) {
val sources = arrayListOf ( SelfossModel . Source ( 1 , " First source " , listOf ( " Test " , " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SelfossModel . Source ( 2 , " Second source " , listOf ( " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
val sourcesDB = listOf < SOURCE > ( SOURCE ( " 1 " , " First source " , " Test,second " , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SOURCE ( " 2 " , " Second source " , " second " , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
every { appSettingsService . isUpdateSourcesEnabled ( ) } returns false
coEvery { api . sources ( ) } returns SelfossModel . StatusAndData ( success = true , data = sources )
every { db . sourcesQueries . sources ( ) . executeAsList ( ) } returns sourcesDB
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testSources : List < SelfossModel . Source > ? = null
runBlocking {
testSources = repository . getSources ( )
}
assertContentEquals ( sources , testSources )
coVerify ( exactly = 0 ) { api . sources ( ) }
verify ( atLeast = 1 ) { db . sourcesQueries . sources ( ) . executeAsList ( ) }
}
@Test
fun `get sources with sources update and items caching disabled` ( ) {
val sources = arrayListOf ( SelfossModel . Source ( 1 , " First source " , listOf ( " Test " , " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SelfossModel . Source ( 2 , " Second source " , listOf ( " second " ) , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
val sourcesDB = listOf < SOURCE > ( SOURCE ( " 1 " , " First source " , " Test,second " , " spouts \\ rss \\ fulltextrss " , " " , " d8c92cdb1ef119ea85c4b9205c879ca7.png " ) ,
SOURCE ( " 2 " , " Second source " , " second " , " spouts \\ rss \\ fulltextrss " , " " , " b3aa8a664d08eb15d6ff1db2fa83e0d9.png " ) )
every { appSettingsService . isUpdateSourcesEnabled ( ) } returns false
every { appSettingsService . isItemCachingEnabled ( ) } returns false
coEvery { api . sources ( ) } returns SelfossModel . StatusAndData ( success = true , data = sources )
every { db . sourcesQueries . sources ( ) . executeAsList ( ) } returns sourcesDB
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var testSources : List < SelfossModel . Source > ? = null
runBlocking {
testSources = repository . getSources ( )
}
assertSame ( null , testSources )
coVerify ( exactly = 0 ) { api . sources ( ) }
verify ( exactly = 0 ) { db . sourcesQueries . sources ( ) . executeAsList ( ) }
}
@Test
fun `create source` ( ) {
coEvery { api . createSourceForVersion ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . SuccessResponse ( true )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . createSource ( " test " , " https://test.com/feed " , " spouts \\ rss \\ fulltextrss " , " Test, New " , " " )
}
coVerify ( exactly = 1 ) { api . createSourceForVersion ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) }
assertSame ( true , response )
}
@Test
fun `create source but response fails` ( ) {
coEvery { api . createSourceForVersion ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . SuccessResponse ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . createSource ( " test " , " https://test.com/feed " , " spouts \\ rss \\ fulltextrss " , " Test, New " , " " )
}
coVerify ( exactly = 1 ) { api . createSourceForVersion ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) }
assertSame ( false , response )
}
@Test
fun `create source without connection` ( ) {
coEvery { api . createSourceForVersion ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . SuccessResponse ( true )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . createSource ( " test " , " https://test.com/feed " , " spouts \\ rss \\ fulltextrss " , " Test, New " , " " )
}
coVerify ( exactly = 0 ) { api . createSourceForVersion ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) }
assertSame ( false , response )
}
@Test
fun `delete source` ( ) {
coEvery { api . deleteSource ( any ( ) ) } returns SelfossModel . SuccessResponse ( true )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . deleteSource ( 5 )
}
coVerify ( exactly = 1 ) { api . deleteSource ( 5 ) }
assertSame ( true , response )
}
@Test
fun `delete source but response fails` ( ) {
coEvery { api . deleteSource ( any ( ) ) } returns SelfossModel . SuccessResponse ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . deleteSource ( 5 )
}
coVerify ( exactly = 1 ) { api . deleteSource ( 5 ) }
assertSame ( false , response )
}
@Test
fun `delete source without connection` ( ) {
coEvery { api . deleteSource ( any ( ) ) } returns SelfossModel . SuccessResponse ( false )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . deleteSource ( 5 )
}
coVerify ( exactly = 0 ) { api . deleteSource ( 5 ) }
assertSame ( false , response )
}
@Test
fun `update remote` ( ) {
coEvery { api . update ( ) } returns SelfossModel . StatusAndData ( success = true , data = " finished " )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . updateRemote ( )
}
coVerify ( exactly = 1 ) { api . update ( ) }
assertSame ( true , response )
}
@Test
fun `update remote but response fails` ( ) {
coEvery { api . update ( ) } returns SelfossModel . StatusAndData ( success = false , data = " undocumented... " )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . updateRemote ( )
}
coVerify ( exactly = 1 ) { api . update ( ) }
assertSame ( false , response )
}
@Test
fun `update remote without connection` ( ) {
coEvery { api . update ( ) } returns SelfossModel . StatusAndData ( success = true , data = " undocumented... " )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . updateRemote ( )
}
coVerify ( exactly = 0 ) { api . update ( ) }
assertSame ( false , response )
}
@Test
fun login ( ) {
coEvery { api . login ( ) } returns SelfossModel . SuccessResponse ( success = true )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . login ( )
}
coVerify ( exactly = 1 ) { api . login ( ) }
assertSame ( true , response )
}
@Test
fun `login but response fails` ( ) {
coEvery { api . login ( ) } returns SelfossModel . SuccessResponse ( success = false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . login ( )
}
coVerify ( exactly = 1 ) { api . login ( ) }
assertSame ( false , response )
}
@Test
fun `login but without connection` ( ) {
coEvery { api . login ( ) } returns SelfossModel . SuccessResponse ( success = true )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
var response = false
runBlocking {
response = repository . login ( )
}
coVerify ( exactly = 0 ) { api . login ( ) }
assertSame ( false , response )
}
@Test
fun `refresh login information` ( ) {
coEvery { api . refreshLoginInformation ( ) } returns Unit
coEvery { appSettingsService . refreshLoginInformation ( any ( ) , any ( ) , any ( ) ) } returns Unit
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . refreshLoginInformation ( " https://test.com/selfoss/ " , " login " , " password " )
coVerify ( exactly = 1 ) { api . refreshLoginInformation ( ) }
coVerify ( exactly = 1 ) { appSettingsService . refreshLoginInformation ( " https://test.com/selfoss/ " , " login " , " password " ) }
}
@Test
fun `cache items` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = true , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . tagFilter = SelfossModel . Tag ( " Tag " , " read " , 0 )
repository . sourceFilter = SelfossModel . Source (
1 ,
" First source " ,
listOf ( " Test " , " second " ) ,
" spouts \\ rss \\ fulltextrss " ,
" " ,
" d8c92cdb1ef119ea85c4b9205c879ca7.png "
)
repository . searchFilter = " search "
var items = emptyList < SelfossModel . Item > ( )
runBlocking {
items = repository . tryToCacheItemsAndGetNewOnes ( )
}
coVerify ( exactly = 3 ) { api . getItems ( any ( ) , 0 , null , null , null , null , 200 ) }
assertSame ( 3 , items . size )
}
@Test
fun `cache items but response fails` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = false , data = generateTestApiItem ( ) )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . tagFilter = SelfossModel . Tag ( " Tag " , " read " , 0 )
repository . sourceFilter = SelfossModel . Source (
1 ,
" First source " ,
listOf ( " Test " , " second " ) ,
" spouts \\ rss \\ fulltextrss " ,
" " ,
" d8c92cdb1ef119ea85c4b9205c879ca7.png "
)
repository . searchFilter = " search "
var items = emptyList < SelfossModel . Item > ( )
runBlocking {
items = repository . tryToCacheItemsAndGetNewOnes ( )
}
coVerify ( exactly = 3 ) { api . getItems ( any ( ) , 0 , null , null , null , null , 200 ) }
assertSame ( 0 , items . size )
}
@Test
fun `cache items without connection` ( ) {
coEvery { api . getItems ( any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) , any ( ) ) } returns
SelfossModel . StatusAndData ( success = false , data = generateTestApiItem ( ) )
every { connectivityStatus . isNetworkConnected } returns MutableStateFlow ( false )
val repository = Repository ( api , appSettingsService , connectivityStatus , db )
repository . tagFilter = SelfossModel . Tag ( " Tag " , " read " , 0 )
repository . sourceFilter = SelfossModel . Source (
1 ,
" First source " ,
listOf ( " Test " , " second " ) ,
" spouts \\ rss \\ fulltextrss " ,
" " ,
" d8c92cdb1ef119ea85c4b9205c879ca7.png "
)
repository . searchFilter = " search "
var items = emptyList < SelfossModel . Item > ( )
runBlocking {
items = repository . tryToCacheItemsAndGetNewOnes ( )
}
coVerify ( exactly = 0 ) { api . getItems ( any ( ) , 0 , null , null , null , null , 200 ) }
assertSame ( emptyList < SelfossModel . Item > ( ) , items )
}
}
fun generateTestDBItems ( item : FakeItemParameters = FakeItemParameters ( ) ) : List < ITEM > {
return listOf ( ITEM (
id = item . id ,
datetime = item . datetime ,
title = item . title ,
content = item . content ,
unread = item . unread ,
starred = item . starred ,
thumbnail = item . thumbnail ,
icon = item . icon ,
link = item . link ,
sourcetitle = item . sourcetitle ,
tags = item . tags
) ) }
fun generateTestApiItem ( item : FakeItemParameters = FakeItemParameters ( ) ) : List < SelfossModel . Item > {
return listOf (
SelfossModel . Item (
id = item . id . toInt ( ) ,
datetime = item . datetime ,
title = item . title ,
content = item . content ,
unread = item . unread ,
starred = item . starred ,
thumbnail = item . thumbnail ,
icon = item . icon ,
link = item . link ,
sourcetitle = item . sourcetitle ,
tags = item . tags . split ( ',' )
)
)
}
class FakeItemParameters ( ) {
val id = " 20 "
var datetime = " 2022-09-09T03:32:01-04:00 "
val title = " Etica della ricerca sotto i riflettori. "
val content = " <p><strong>Luigi Campanella, già Presidente SCI</strong></p> \n <p>L’ \n <p>L’ \n <p>Per evitare che ciò accada si sta procedendo filtrando secondo criteri di autocensura i dati da cui l’ \n <p>Comincia ad intravedersi un futuro prossimo di competizione fra autori umani ed artificiali nel quale sarà importante, quando i loro prodotti saranno indistinguibili, dichiararne l’ \n <p>Come si comprende, si conferma che gli aspetti etici dell’ \n <p>La biologia molecolare e la genetica già in passato hanno posto all’ \n <p>L’ \n <img src= \" https://ilblogdellasci.files.wordpress.com/2022/09/image002-1.png?w=481 \" alt= \" \" width= \" 697 \" height= \" 430 \" /><img src= \" https://ilblogdellasci.files.wordpress.com/2022/09/image003-1.png?w=906 \" alt= \" \" /><p>Magdalena Zernicka-Goetz</p> \n <img src= \" https://ilblogdellasci.files.wordpress.com/2022/09/image004.jpg?w=474 \" alt= \" \" width= \" 622 \" height= \" 465 \" /><p>Gianluca Amadei</p> \n <p>Del gruppo fa parte anche uno scienziato italiano Gianluca Amadei,che dinnanzi alle obiezioni di natura etica sulla realizzazione della vita artificiale si è affrettato a sostenere che non è creare nuove vite il fine primario della ricerca, ma quello di salvare quelle esistenti, di dare contributi essenziali alla medicina citando il caso del fallimento tuttora non interpretato di alcune gravidanze e di superare la sperimentazione animale, così contribuendo positivamente alla soluzione di un altro dilemma etico.</p> \n <p>L’ ’ ’ "
var unread = true
var starred = true
val thumbnail = null
val icon = " ba79e238383ce83c23a169929c8906ef.png "
val link = " https://ilblogdellasci.wordpress.com/2022/09/09/etica-della-ricerca-sotto-i-riflettori/ "
val sourcetitle = " La Chimica e la Società "
val tags = " Chimica, Testing "
}
Amine Louveau