feat: Implement recurring work once a day given constraints

Author: filipebezerra

app/src/main/java/com/example/android/devbyteviewer/DevByteApplication.kt

@@ -18,13 +18,22 @@
 package com.example.android.devbyteviewer
 
 import android.app.Application
+import androidx.work.*
+import androidx.work.impl.Schedulers
+import com.example.android.devbyteviewer.work.RefreshDataWork
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 import timber.log.Timber
+import java.util.concurrent.TimeUnit
 
 /**
  * Override application to setup background work via WorkManager
  */
 class DevByteApplication : Application() {
 
+ private val applicationScope = CoroutineScope(Dispatchers.Default)
+
  /**
  * onCreate is called before the first screen is shown to the user.
  *
@@ -34,5 +43,31 @@ class DevByteApplication : Application() {
  override fun onCreate() {
  super.onCreate()
  Timber.plant(Timber.DebugTree())
+ delayedInit()
+ }
+
+ private fun delayedInit() {
+ applicationScope.launch { setupRecurringWork() }
+ }
+
+ private fun setupRecurringWork() {
+ val constraints = Constraints.Builder()
+ .setRequiredNetworkType(NetworkType.UNMETERED)
+ .setRequiresBatteryNotLow(true)
+ .setRequiresCharging(true)
+ .apply {
+ if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.M) {
+ setRequiresDeviceIdle(true)
+ }
+ }
+ .build()
+ val repeatingRequest = PeriodicWorkRequestBuilder<RefreshDataWork>(1, TimeUnit.DAYS)
+ .setConstraints(constraints)
+ .build()
+ WorkManager.getInstance(this).enqueueUniquePeriodicWork(
+ RefreshDataWork.WORK_NAME,
+ ExistingPeriodicWorkPolicy.KEEP,
+ repeatingRequest
+ )
  }
 }

app/src/main/java/com/example/android/devbyteviewer/repository/VideoRepository.kt

@@ -40,10 +40,15 @@ class VideoRepository(private val videoDao: VideoDao) {
  suspend fun refreshVideos() {
  withContext(Dispatchers.IO) {
  try {
+ Timber.i("Refreshing videos")
  val playlist = Network.devbytes.getPlaylist()
+ Timber.i("Videos were fetched from internet successfully")
  videoDao.insertAll(*playlist.asDatabaseModel())
+ Timber.i("Videos were saved to local data store successfully")
  } catch (error: Exception) {
  Timber.e(error, "Failed to refresh videos")
+ // TODO Log to Crashlytics/Bugsnag
+ // TODO Show visual feedback
  }
  }
  }

app/src/main/java/com/example/android/devbyteviewer/work/RefreshDataWork.kt

@@ -16,3 +16,40 @@
  */
 
 package com.example.android.devbyteviewer.work
+
+import android.content.Context
+import androidx.work.CoroutineWorker
+import androidx.work.WorkerParameters
+import com.example.android.devbyteviewer.database.getDatabase
+import com.example.android.devbyteviewer.repository.VideoRepository
+import retrofit2.HttpException
+import timber.log.Timber
+
+/**
+ * Worker which uses [VideoRepository] to refresh data from the internet and cache data to the database.
+ */
+class RefreshDataWork(
+ private val appContext: Context,
+ params: WorkerParameters
+) : CoroutineWorker(appContext, params) {
+
+ override suspend fun doWork(): Result {
+ val database = getDatabase(appContext)
+ val repository = VideoRepository(database.videoDao)
+
+ return try {
+ Timber.i("Starting refresh work")
+ repository.refreshVideos()
+ Timber.i("Refresh work done successfully")
+ Result.success()
+ } catch (error: HttpException) {
+ Timber.e(error, "Failed to complete refresh work. Signalling to retry")
+ Result.retry()
+ // TODO Log to Crashlytics/Bugsnag
+ }
+ }
+
+ companion object {
+ const val WORK_NAME = "RefreshDataWork"
+ }
+}