WorkManager worker to preload local media

Author: zhombie

bazaar/build.gradle

@@ -72,4 +72,7 @@ dependencies {
     // Kotlin coroutines
     implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.4.2'
     implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.4.2'
+
+    // WorkManager
+    implementation "androidx.work:work-runtime-ktx:2.5.0"
 }

bazaar/src/main/java/kz/zhombie/bazaar/Bazaar.kt

@@ -7,6 +7,7 @@ import kz.zhombie.bazaar.api.core.ImageLoader
 import kz.zhombie.bazaar.api.core.exception.ImageLoaderNullException
 import kz.zhombie.bazaar.api.core.settings.CameraSettings
 import kz.zhombie.bazaar.api.core.settings.Mode
+import kz.zhombie.bazaar.api.core.worker.MediaSyncWorker
 import kz.zhombie.bazaar.api.event.EventListener
 import kz.zhombie.bazaar.api.result.ResultCallback
 import kz.zhombie.bazaar.core.media.MediaScanManager
@@ -23,10 +24,19 @@ class Bazaar private constructor() {
             Settings.setLoggingEnabled(isLoggingEnabled)
         }
 
+        suspend fun sync(context: Context): Boolean {
+            return MediaSyncWorker.startWork(context)
+        }
+
         suspend fun preload(context: Context, mode: Mode) {
             MediaScanManager.preload(context, mode)
         }
 
+        suspend fun preloadAll(context: Context) {
+            MediaScanManager.preload(context, Mode.IMAGE_AND_VIDEO)
+            MediaScanManager.preload(context, Mode.AUDIO)
+        }
+
         suspend fun clearCache() {
             MediaScanManager.clearCache()
         }

bazaar/src/main/java/kz/zhombie/bazaar/api/core/worker/MediaSyncWorker.kt

@@ -0,0 +1,66 @@
+package kz.zhombie.bazaar.api.core.worker
+
+import android.content.Context
+import androidx.work.*
+import kz.zhombie.bazaar.Bazaar
+import kz.zhombie.bazaar.api.core.settings.Mode
+
+class MediaSyncWorker constructor(
+    private val context: Context,
+    params: WorkerParameters
+) : CoroutineWorker(context, params) {
+
+    companion object {
+        private val TAG = MediaSyncWorker::class.java.simpleName
+
+        const val UNIQUE_WORK_NAME = "BazaarMediaSyncWork"
+
+        suspend fun startWork(context: Context): Boolean {
+            val constraints = Constraints.Builder()
+                .setRequiresBatteryNotLow(true)
+                .setRequiresCharging(false)
+                .setRequiresStorageNotLow(false)
+                .setRequiresDeviceIdle(false)
+                .setRequiredNetworkType(NetworkType.NOT_REQUIRED)
+                .build()
+
+            val operation = WorkManager.getInstance(context)
+                .enqueueUniqueWork(
+                    UNIQUE_WORK_NAME,
+                    ExistingWorkPolicy.REPLACE,
+                    OneTimeWorkRequestBuilder<MediaSyncWorker>()
+                        .setConstraints(constraints)
+                        .build()
+                )
+            return try {
+                val success = operation.await()
+                @Suppress("USELESS_IS_CHECK")
+                return success is Operation.State.SUCCESS
+            } catch (e: Exception) {
+                e.printStackTrace()
+                false
+            }
+        }
+
+        suspend fun cancelWork(context: Context): Boolean {
+            val operation = WorkManager.getInstance(context)
+                .cancelUniqueWork(UNIQUE_WORK_NAME)
+
+            return try {
+                val success = operation.await()
+                @Suppress("USELESS_IS_CHECK")
+                return success is Operation.State.SUCCESS
+            } catch (e: Exception) {
+                e.printStackTrace()
+                false
+            }
+        }
+    }
+
+    override suspend fun doWork(): Result {
+        Bazaar.preload(context, Mode.IMAGE_AND_VIDEO)
+        Bazaar.preload(context, Mode.AUDIO)
+        return Result.success()
+    }
+
+}

bazaar/src/main/java/kz/zhombie/bazaar/core/cache/Cache.kt

@@ -29,6 +29,10 @@ internal class Cache private constructor() {
         }
     }
 
+    fun isEmpty(): Boolean {
+        return multimedia.isNullOrEmpty()
+    }
+
     suspend fun getMultimedia(): List<Multimedia>? = withContext(Dispatchers.IO) {
         Logger.d(TAG, "getMultimedia() -> multimedia: ${multimedia?.size}")
         return@withContext multimedia

bazaar/src/main/java/kz/zhombie/bazaar/core/media/MediaScanManager.kt

@@ -50,8 +50,7 @@ internal class MediaScanManager constructor(private val context: Context) {
                     Mode.IMAGE -> mediaScanManager.loadLocalMediaImages()
                     Mode.VIDEO -> mediaScanManager.loadLocalMediaVideos()
                     Mode.IMAGE_AND_VIDEO -> mediaScanManager.loadLocalMediaImagesAndVideos()
-                    else ->
-                        null
+                    else -> null
                 }
                 Logger.d(TAG, "preload() -> media: ${media?.size}")
                 if (!media.isNullOrEmpty()) {

sample/src/main/java/kz/zhombie/bazaar/MainActivity.kt

@@ -4,15 +4,18 @@ import android.Manifest
 import android.content.pm.PackageManager
 import android.os.Bundle
 import android.util.Log
+import android.widget.Toast
 import androidx.appcompat.app.AppCompatActivity
 import androidx.core.app.ActivityCompat
 import androidx.lifecycle.lifecycleScope
 import androidx.recyclerview.widget.RecyclerView
+import androidx.work.*
 import com.google.android.material.button.MaterialButton
 import com.google.android.material.dialog.MaterialAlertDialogBuilder
 import com.google.android.material.textview.MaterialTextView
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
+import kotlinx.coroutines.withContext
 import kz.zhombie.bazaar.api.core.ImageLoader
 import kz.zhombie.bazaar.api.core.settings.CameraSettings
 import kz.zhombie.bazaar.api.core.settings.Mode
@@ -150,9 +153,20 @@ class MainActivity : AppCompatActivity(), ResultCallback {
             }
         }
 
+//        lifecycleScope.launch(Dispatchers.IO) {
+//            Bazaar.preloadAll(this@MainActivity)
+//        }
+    }
+
+    override fun onResume() {
+        super.onResume()
+
         lifecycleScope.launch(Dispatchers.IO) {
-            Bazaar.preload(this@MainActivity, Mode.IMAGE_AND_VIDEO)
-            Bazaar.preload(this@MainActivity, Mode.AUDIO)
+            withContext(Dispatchers.Main) {
+                Toast.makeText(this@MainActivity, "launch", Toast.LENGTH_SHORT).show()
+            }
+
+            Bazaar.sync(applicationContext)
         }
     }