Invalidate custom history data source when data changes. God wish I u…

…se room or sqldelight soon
arunkumar9t2 · Sep 14, 2019 · f0ed22f · f0ed22f
1 parent b6cd73c
commit f0ed22f
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 27 deletions.
diff --git a/android-app/app/src/main/java/arun/com/chromer/data/history/paging/PagedHistoryDataSource.kt b/android-app/app/src/main/java/arun/com/chromer/data/history/paging/PagedHistoryDataSource.kt
@@ -23,14 +23,32 @@ import androidx.paging.DataSource
 import androidx.paging.PositionalDataSource
 import arun.com.chromer.data.history.HistoryStore
 import arun.com.chromer.data.website.model.Website
+import dev.arunkumar.android.rxschedulers.SchedulerProvider
+import io.reactivex.disposables.CompositeDisposable
+import java.util.concurrent.TimeUnit
 import javax.inject.Inject
 import javax.inject.Provider
 import javax.inject.Singleton
 
 @Singleton
 class PagedHistoryDataSource
 @Inject
-constructor(private val historyStore: HistoryStore) : PositionalDataSource<Website>() {
+constructor(
+        private val historyStore: HistoryStore,
+        private val schedulerProvider: SchedulerProvider
+) : PositionalDataSource<Website>() {
+
+    private val compositeDisposable = CompositeDisposable()
+
+    init {
+        addInvalidatedCallback { compositeDisposable.clear() }
+        compositeDisposable.add(
+                historyStore.changes()
+                        .debounce(200, TimeUnit.MILLISECONDS)
+                        .subscribe { invalidate() }
+        )
+    }
+
 
     override fun loadRange(
             params: LoadRangeParams,

diff --git a/android-app/app/src/main/java/arun/com/chromer/history/HistoryFragment.kt b/android-app/app/src/main/java/arun/com/chromer/history/HistoryFragment.kt
@@ -127,7 +127,6 @@ class HistoryFragment : BaseFragment(), Snackable, FabHandler {
             loadingLiveData.observe(owner, Observer { loading(it!!) })
             historyPagedListLiveData.observe(owner, Observer { historyAdapter.submitList(it) })
         }
-        loadHistory()
     }
 
     private fun setupIncognitoSwitch() {
@@ -197,7 +196,10 @@ class HistoryFragment : BaseFragment(), Snackable, FabHandler {
 
         swipeRefreshLayout.apply {
             setColorSchemeColors(ContextCompat.getColor(context!!, R.color.colorPrimary), ContextCompat.getColor(context!!, R.color.accent))
-            setOnRefreshListener { loadHistory() }
+            setOnRefreshListener {
+                viewModel.invalidate()
+                isRefreshing = false
+            }
         }
 
         ItemTouchHelper(object : ItemTouchHelper.SimpleCallback(0, LEFT or RIGHT) {
@@ -214,15 +216,10 @@ class HistoryFragment : BaseFragment(), Snackable, FabHandler {
         }).attachToRecyclerView(historyList)
     }
 
-    private fun loadHistory() {
-        viewModel.loadHistory()
-    }
-
     override fun inject(fragmentComponent: FragmentComponent) = fragmentComponent.inject(this)
 
     override fun onResume() {
         super.onResume()
-        loadHistory()
         historySwitch.isChecked = !preferences.historyDisabled()
     }
 

diff --git a/android-app/app/src/main/java/arun/com/chromer/history/HistoryFragmentViewModel.kt b/android-app/app/src/main/java/arun/com/chromer/history/HistoryFragmentViewModel.kt
@@ -25,7 +25,6 @@ import arun.com.chromer.data.history.HistoryRepository
 import arun.com.chromer.data.website.model.Website
 import arun.com.chromer.util.SchedulerProvider
 import rx.Observable
-import rx.subjects.PublishSubject
 import rx.subscriptions.CompositeSubscription
 import timber.log.Timber
 import javax.inject.Inject
@@ -42,42 +41,28 @@ constructor(
     val loadingLiveData = MutableLiveData<Boolean>()
     var historyPagedListLiveData = historyRepository.pagedHistory()
 
-    private val loaderSubject: PublishSubject<Int> = PublishSubject.create()
     val subs = CompositeSubscription()
 
-    init {
-        /* subs.add(loaderSubject
-                 .doOnNext { loadingLiveData.postValue(true) }
-                 .switchMap {
-                     historyRepository
-                             .allItemsCursor
-                             .compose(SchedulerProvider.applyIoSchedulers())
-                 }.doOnNext { loadingLiveData.postValue(false) }
-                 .doOnNext(historyCursorLiveData::postValue)
-                 .subscribe())*/
-    }
-
-    fun loadHistory() {
-        loaderSubject.onNext(0)
+    fun invalidate() {
+        historyPagedListLiveData.value?.dataSource?.invalidate()
     }
 
     fun deleteAll(onSuccess: (rows: Int) -> Unit) {
         subs.add(historyRepository
                 .deleteAll()
                 .compose(SchedulerProvider.applyIoSchedulers())
                 .doOnNext { rows ->
-                    loadHistory()
+                    invalidate()
                     onSuccess(rows)
                 }.subscribe())
     }
 
     fun deleteHistory(website: Website?) {
         subs.add(Observable.just(website)
                 .filter { webSite -> webSite?.url != null }
-                .flatMap<Website> { historyRepository.delete(it!!) }
+                .flatMap { historyRepository.delete(it!!) }
                 .compose(SchedulerProvider.applyIoSchedulers())
                 .doOnError(Timber::e)
-                .doOnNext { loadHistory() }
                 .subscribe())
     }