Fix background refresh functionality

Closes #38

Author: julieminer

app/src/main/java/com/melonhead/mangadexfollower/work_manager/RefreshWorker.kt

@@ -3,21 +3,19 @@ package com.melonhead.mangadexfollower.work_manager
 import android.content.Context
 import androidx.work.CoroutineWorker
 import androidx.work.WorkerParameters
+import com.melonhead.feature_manga_list.usecases.RefreshMangaUseCase
 import com.melonhead.lib_app_events.AppEventsRepository
 import com.melonhead.lib_app_events.events.UserEvent
 import com.melonhead.lib_logging.Clog
 import org.koin.core.component.KoinComponent
 import org.koin.core.component.inject
 
 class RefreshWorker(appContext: Context, workerParams: WorkerParameters): CoroutineWorker(appContext, workerParams), KoinComponent {
-    private val appEventsRepository: AppEventsRepository by inject()
+    @Suppress("DEPRECATION") // Necessary to await the result of the refresh
+    private val refreshMangaUseCase: RefreshMangaUseCase by inject()
 
     override suspend fun doWork(): Result {
-        return if (appEventsRepository.postEvent(UserEvent.RefreshManga)) {
-            Result.success()
-        } else {
-            Clog.e("RefreshWorker: Failed to post RefreshManga event", RuntimeException("RefreshWorker: Failed to post RefreshManga event"))
-            Result.failure()
-        }
+        refreshMangaUseCase.invoke()
+        return Result.success()
     }
 }

feature-manga-list/src/main/java/com/melonhead/feature_manga_list/MangaRepository.kt

@@ -33,6 +33,8 @@ internal interface MangaRepository {
     val manga: Flow<List<UIManga>>
     val refreshStatus: Flow<MangaRefreshStatus>
     suspend fun getChapterData(mangaId: String,chapterId: String): List<String>?
+    @Deprecated("Use UserEvent.RefreshManga event instead of using this directly")
+    suspend fun forceRefresh()
 }
 
 internal class MangaRepositoryImpl(
@@ -64,6 +66,7 @@ internal class MangaRepositoryImpl(
     private var isLoggedIn: Boolean = false
 
     init {
+        Clog.i("MangaRepository init")
         externalScope.launch {
             // refresh manga on login
             try {
@@ -74,17 +77,17 @@ internal class MangaRepositoryImpl(
                             is AuthenticationEvent.LoggedIn -> {
                                 if (!isLoggedIn) {
                                     isLoggedIn = true
-                                    forceRefresh()
+                                    refreshMangaThrottled(Unit)
                                 }
                             }
                             is AuthenticationEvent.LoggedOut -> {
                                 isLoggedIn = false
                             }
                             is AppLifecycleEvent.AppForegrounded -> {
-                                forceRefresh()
+                                refreshMangaThrottled(Unit)
                             }
                             is UserEvent.RefreshManga -> {
-                                forceRefresh()
+                                refreshMangaThrottled(Unit)
                             }
                             is UserEvent.SetMarkChapterRead -> {
                                 markChapterRead(it.mangaId, it.chapterId, it.read)
@@ -102,10 +105,13 @@ internal class MangaRepositoryImpl(
                 e.printStackTrace()
             }
         }
+
+        refreshMangaThrottled(Unit)
     }
 
-    private fun forceRefresh() {
-        if (isLoggedIn) refreshMangaThrottled(Unit)
+    @Deprecated("Use UserEvent.RefreshManga event instead of using this directly")
+    override suspend fun forceRefresh() {
+        refreshMangaThrottled(Unit)
     }
 
     private fun generateUIManga(dbSeries: List<MangaEntity>, dbChapters: List<ChapterEntity>): List<UIManga> {

feature-manga-list/src/main/java/com/melonhead/feature_manga_list/di/FeatureMangaListModule.kt

@@ -7,6 +7,8 @@ import com.melonhead.data_user.di.DataUserModule
 import com.melonhead.feature_manga_list.MangaRepository
 import com.melonhead.feature_manga_list.MangaRepositoryImpl
 import com.melonhead.feature_manga_list.navigation.MangaListScreenResolver
+import com.melonhead.feature_manga_list.usecases.RefreshMangaUseCase
+import com.melonhead.feature_manga_list.usecases.RefreshMangaUseCaseImpl
 import com.melonhead.feature_manga_list.viewmodels.MangaListViewModel
 import com.melonhead.lib_app_context.di.LibAppContextModule
 import com.melonhead.lib_app_events.di.LibAppEventsModule
@@ -28,7 +30,7 @@ val FeatureMangaListModule = module {
     includes(DataAtHomeModule)
     includes(DataMangaModule)
 
-    single<MangaRepository> {
+    single<MangaRepository>(createdAtStart = true) {
         MangaRepositoryImpl(
             get(),
             get(),
@@ -48,4 +50,5 @@ val FeatureMangaListModule = module {
     viewModel { MangaListViewModel(get(), get(), get(), get()) }
 
     single<MangaListScreenResolver>(createdAtStart = true) { MangaListScreenResolver() }
+    factory<RefreshMangaUseCase> { RefreshMangaUseCaseImpl(get()) }
 }

feature-manga-list/src/main/java/com/melonhead/feature_manga_list/usecases/RefreshMangaUseCase.kt

@@ -0,0 +1,17 @@
+package com.melonhead.feature_manga_list.usecases
+
+import com.melonhead.feature_manga_list.MangaRepository
+
+@Deprecated("Use UserEvent.RefreshManga event instead of using this directly")
+interface RefreshMangaUseCase {
+    suspend fun invoke()
+}
+
+@Suppress("DEPRECATION") // This is the only valid use case of forceRefresh
+internal class RefreshMangaUseCaseImpl(
+    private val mangaRepository: MangaRepository,
+): RefreshMangaUseCase {
+    override suspend fun invoke() {
+        mangaRepository.forceRefresh()
+    }
+}

lib-app-events/src/main/java/com/melonhead/lib_app_events/AppEventsRepository.kt

@@ -2,6 +2,7 @@ package com.melonhead.lib_app_events
 
 import com.melonhead.lib_app_events.events.AppEvent
 import com.melonhead.lib_logging.Clog
+import kotlinx.coroutines.Job
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.asSharedFlow