feat: notify glance widget of data updates

When the data updates such as updating a series progress, or adding a new series, we need to notify
the glance widget. This is done via a singleton class that listens to the repository, and on updates
to the data fires the required worker to update the widget.

app/build.gradle.kts

@@ -90,6 +90,7 @@ dependencies {
     implementation(libs.androidx.constraintlayout)
     implementation(libs.androidx.core)
     implementation(libs.androidx.fragment)
+    implementation(libs.androidx.glance.appwidget)
     implementation(libs.androidx.hilt.work)
     implementation(libs.androidx.lifecycle.extensions)
     implementation(libs.androidx.lifecycle.livedata)

app/src/main/java/com/chesire/nekome/App.kt

@@ -7,9 +7,13 @@ import androidx.work.Configuration
 import com.chesire.lifecyklelog.LifecykleLog
 import com.chesire.lifecyklelog.LogHandler
 import com.chesire.nekome.core.preferences.ApplicationPreferences
+import com.chesire.nekome.services.DataRefreshNotifier
 import com.chesire.nekome.services.WorkerQueue
 import dagger.hilt.android.HiltAndroidApp
 import javax.inject.Inject
+import kotlinx.coroutines.DelicateCoroutinesApi
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.launch
 import timber.log.Timber
 
 /**
@@ -27,6 +31,10 @@ class App : Application(), Configuration.Provider {
     @Inject
     lateinit var workerQueue: WorkerQueue
 
+    @Inject
+    lateinit var dataRefreshNotifier: DataRefreshNotifier
+
+    @OptIn(DelicateCoroutinesApi::class)
     override fun onCreate() {
         super.onCreate()
 
@@ -46,6 +54,9 @@ class App : Application(), Configuration.Provider {
         workerQueue.enqueueAuthRefresh()
         workerQueue.enqueueSeriesRefresh()
         workerQueue.enqueueUserRefresh()
+        GlobalScope.launch {
+            dataRefreshNotifier.initialize()
+        }
     }
 
     override fun getWorkManagerConfiguration() =

app/src/main/java/com/chesire/nekome/services/DataRefreshNotifier.kt

@@ -0,0 +1,35 @@
+package com.chesire.nekome.services
+
+import androidx.work.ExistingWorkPolicy
+import androidx.work.OneTimeWorkRequestBuilder
+import androidx.work.WorkManager
+import com.chesire.nekome.datasource.series.SeriesRepository
+import javax.inject.Inject
+import javax.inject.Singleton
+
+private const val WIDGET_DATA_NOTIFY_TAG = "WidgetData"
+private const val WIDGET_DATA_UNIQUE_NAME = "WidgetSync"
+
+@Singleton
+class DataRefreshNotifier @Inject constructor(
+    private val workManager: WorkManager,
+    private val seriesRepository: SeriesRepository
+) {
+
+    /**
+     * Initialize the notifier and listen to any data updates.
+     */
+    suspend fun initialize() {
+        seriesRepository.getSeries().collect {
+            val request = OneTimeWorkRequestBuilder<WidgetDataWorker>()
+                .addTag(WIDGET_DATA_NOTIFY_TAG)
+                .build()
+
+            workManager.enqueueUniqueWork(
+                WIDGET_DATA_UNIQUE_NAME,
+                ExistingWorkPolicy.REPLACE,
+                request
+            )
+        }
+    }
+}

app/src/main/java/com/chesire/nekome/services/WidgetDataWorker.kt

@@ -0,0 +1,18 @@
+package com.chesire.nekome.services
+
+import android.content.Context
+import androidx.glance.appwidget.updateAll
+import androidx.work.CoroutineWorker
+import androidx.work.WorkerParameters
+import com.chesire.nekome.feature.serieswidget.ui.SeriesWidget
+
+class WidgetDataWorker(
+    private val context: Context,
+    params: WorkerParameters,
+) : CoroutineWorker(context, params) {
+
+    override suspend fun doWork(): Result {
+        SeriesWidget().updateAll(context)
+        return Result.success()
+    }
+}