fix(provider): attempt to fix ConcurrentModificationException on up…

…dater
flixclusiveorg · Nov 8, 2024 · ab5187c · ab5187c
1 parent 25151fd
commit ab5187c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/data/provider/src/main/kotlin/com/flixclusive/data/provider/ProviderManager.kt b/data/provider/src/main/kotlin/com/flixclusive/data/provider/ProviderManager.kt
@@ -31,6 +31,7 @@ import com.flixclusive.provider.Provider
 import com.flixclusive.provider.settings.ProviderSettings
 import dagger.hilt.android.qualifiers.ApplicationContext
 import dalvik.system.PathClassLoader
+import kotlinx.coroutines.CompletableDeferred
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.launch
 import okhttp3.OkHttpClient
@@ -58,6 +59,7 @@ class ProviderManager @Inject constructor(
     private val classLoaders: MutableMap<PathClassLoader, Provider> = Collections.synchronizedMap(HashMap())
 
     private var notificationChannelHasBeenInitialized = false
+    val initialization = CompletableDeferred<Unit>()
 
     /**
      * An observable map of provider data
@@ -117,6 +119,8 @@ class ProviderManager @Inject constructor(
 
                 notificationChannelHasBeenInitialized = true
             }
+
+            initialization.complete(Unit)
         }
     }
 

diff --git a/domain/updater/src/main/kotlin/com/flixclusive/domain/updater/ProviderUpdaterUseCase.kt b/domain/updater/src/main/kotlin/com/flixclusive/domain/updater/ProviderUpdaterUseCase.kt
@@ -43,6 +43,10 @@ class ProviderUpdaterUseCase @Inject constructor(
     private var notificationChannelHasBeenInitialized = false
 
     suspend fun checkForUpdates(notify: Boolean) {
+        // Wait for providers to be initialized
+        // To avoid ConcurrentModificationException
+        providerManager.initialization.await()
+
         val appSettingsProvider = appSettingsManager.providerSettings.data.first()
 
         outdatedProviders.clear()