80 lines
2.5 KiB
Kotlin
80 lines
2.5 KiB
Kotlin
package it.unisannio.ding.ids.wedroid.app.data.repository
|
|
|
|
import android.util.Log
|
|
import it.unisannio.ding.ids.wedroid.app.data.dao.WListDao
|
|
import it.unisannio.ding.ids.wedroid.app.data.entity.WList
|
|
import it.unisannio.ding.ids.wedroid.app.data.entity.convert
|
|
import it.unisannio.ding.ids.wedroid.app.util.PreferenceReader
|
|
import it.unisannio.ding.ids.wedroid.wrapper.api.ListService
|
|
import kotlinx.coroutines.CoroutineScope
|
|
import kotlinx.coroutines.Dispatchers
|
|
import kotlinx.coroutines.launch
|
|
import retrofit2.Call
|
|
import retrofit2.Callback
|
|
import retrofit2.Response
|
|
|
|
class WListRepository(
|
|
private val dao: WListDao,
|
|
private val service: ListService,
|
|
private val reader: PreferenceReader
|
|
) {
|
|
val allWLists by lazy{
|
|
dao.getAllWList()
|
|
}
|
|
|
|
init {
|
|
synchronize()
|
|
}
|
|
|
|
fun synchronize() {
|
|
service.getAllList(reader.boardId)
|
|
.enqueue(object :
|
|
Callback<MutableList<it.unisannio.ding.ids.wedroid.wrapper.entity.WList>> {
|
|
override fun onFailure(
|
|
call: Call<MutableList<it.unisannio.ding.ids.wedroid.wrapper.entity.WList>>,
|
|
t: Throwable
|
|
) = logNetworkError(t.message)
|
|
|
|
override fun onResponse(
|
|
call: Call<MutableList<it.unisannio.ding.ids.wedroid.wrapper.entity.WList>>,
|
|
response: Response<MutableList<it.unisannio.ding.ids.wedroid.wrapper.entity.WList>>
|
|
) {
|
|
CoroutineScope(Dispatchers.IO).launch {
|
|
synchronizeCallback(response)
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
private suspend fun synchronizeCallback(
|
|
response: Response<MutableList<it.unisannio.ding.ids.wedroid.wrapper.entity.WList>>)
|
|
{
|
|
if (!response.isSuccessful) {
|
|
logNetworkError("${response.code()} ${response.message()}")
|
|
return
|
|
}
|
|
|
|
val wLists = (response.body() ?: return)
|
|
.map { it.convert() }
|
|
|
|
addNewWListToDb(wLists)
|
|
removeOldWListsFromDb(wLists)
|
|
}
|
|
|
|
private suspend fun addNewWListToDb(wLists: Collection<WList>) {
|
|
wLists.forEach {
|
|
dao.insert(it)
|
|
}
|
|
}
|
|
|
|
private suspend fun removeOldWListsFromDb(wLists: Collection<WList>) {
|
|
allWLists.value?.minus(wLists)
|
|
?.forEach {
|
|
dao.delete(it)
|
|
}
|
|
}
|
|
|
|
private fun logNetworkError(message: String?) {
|
|
Log.e("RETROFIT", message)
|
|
}
|
|
} |