Added PeriodicLocalSyncWorker

Signed-off-by: Arnau Mora <arnyminerz@proton.me>

Author: ArnyminerZ

app/src/main/java/at/bitfire/icsdroid/AppAccount.kt

@@ -11,7 +11,7 @@ import android.content.Context
 import android.content.SharedPreferences.OnSharedPreferenceChangeListener
 import android.provider.CalendarContract
 import android.util.Log
-import at.bitfire.icsdroid.worker.PeriodicSyncWorker
+import at.bitfire.icsdroid.worker.BaseSyncWorker
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.awaitClose
 import kotlinx.coroutines.flow.buffer
@@ -81,13 +81,10 @@ object AppAccount {
             .putLong(KEY_SYNC_INTERVAL, syncInterval)
             .apply()
 
-        // set up periodic worker
-        PeriodicSyncWorker.setInterval(
+        // set up periodic workers
+        BaseSyncWorker.setInterval(
             context,
-            if (syncInterval == SYNC_INTERVAL_MANUALLY)
-                null
-            else
-                syncInterval
+            syncInterval.takeUnless { syncInterval == SYNC_INTERVAL_MANUALLY }
         )
     }
 

app/src/main/java/at/bitfire/icsdroid/worker/BaseSyncWorker.kt

@@ -88,6 +88,14 @@ open class BaseSyncWorker(
             wm.cancelUniqueWork(NetworkSyncWorker.NAME)
             wm.cancelUniqueWork(LocalSyncWorker.NAME)
         }
+
+        /**
+         * Sets the interval of both [PeriodicNetworkSyncWorker] and [PeriodicLocalSyncWorker].
+         */
+        fun setInterval(context: Context, seconds: Long?) {
+            PeriodicNetworkSyncWorker.setInterval(context, seconds)
+            PeriodicLocalSyncWorker.setInterval(context, seconds)
+        }
     }
 
     private val database = AppDatabase.getInstance(applicationContext)

app/src/main/java/at/bitfire/icsdroid/worker/LocalSyncWorker.kt

@@ -12,7 +12,7 @@ import at.bitfire.icsdroid.db.entity.Subscription
  * Synchronizes all subscriptions from local fs.
  * Always runs, regardless of current network condition, and filters local URLs (not http(s)).
  */
-class LocalSyncWorker(
+open class LocalSyncWorker(
     context: Context,
     workerParams: WorkerParameters
 ) : BaseSyncWorker(context, workerParams) {

app/src/main/java/at/bitfire/icsdroid/worker/NetworkSyncWorker.kt

@@ -20,7 +20,7 @@ import at.bitfire.icsdroid.db.entity.Subscription
  * Synchronizes all subscriptions with their respective servers.
  * Only runs if the network is available, and filters remote URLs (http(s)).
  */
-class NetworkSyncWorker(
+open class NetworkSyncWorker(
     context: Context,
     workerParams: WorkerParameters
 ) : BaseSyncWorker(context, workerParams) {

app/src/main/java/at/bitfire/icsdroid/worker/PeriodicLocalSyncWorker.kt

@@ -0,0 +1,33 @@
+/***************************************************************************************************
+ * Copyright © All Contributors. See LICENSE and AUTHORS in the root directory for details.
+ **************************************************************************************************/
+
+package at.bitfire.icsdroid.worker
+
+import android.content.Context
+import androidx.work.ExistingPeriodicWorkPolicy
+import androidx.work.PeriodicWorkRequestBuilder
+import androidx.work.WorkManager
+import androidx.work.WorkerParameters
+import java.time.Duration
+
+class PeriodicLocalSyncWorker(
+    context: Context,
+    workerParams: WorkerParameters
+): LocalSyncWorker(context, workerParams) {
+
+    companion object {
+        private const val NAME = "PeriodicLocalSync"
+
+        fun setInterval(context: Context, seconds: Long?) {
+            val wm = WorkManager.getInstance(context)
+
+            if (seconds != null) {
+                val request = PeriodicWorkRequestBuilder<PeriodicLocalSyncWorker>(Duration.ofSeconds(seconds))
+                    .build()
+                wm.enqueueUniquePeriodicWork(NAME, ExistingPeriodicWorkPolicy.CANCEL_AND_REENQUEUE, request)
+            } else
+                wm.cancelUniqueWork(NAME)
+        }
+    }
+}

app/src/main/java/at/bitfire/icsdroid/worker/PeriodicSyncWorker.kt app/src/main/java/at/bitfire/icsdroid/worker/PeriodicNetworkSyncWorker.kt

@@ -13,19 +13,19 @@ import androidx.work.WorkManager
 import androidx.work.WorkerParameters
 import java.time.Duration
 
-class PeriodicSyncWorker(
+class PeriodicNetworkSyncWorker(
     context: Context,
     workerParams: WorkerParameters
-): BaseSyncWorker(context, workerParams) {
+): NetworkSyncWorker(context, workerParams) {
 
     companion object {
-        private const val NAME = "PeriodicSync"
+        private const val NAME = "PeriodicNetworkSync"
 
         fun setInterval(context: Context, seconds: Long?) {
             val wm = WorkManager.getInstance(context)
 
             if (seconds != null) {
-                val request = PeriodicWorkRequestBuilder<PeriodicSyncWorker>(Duration.ofSeconds(seconds))
+                val request = PeriodicWorkRequestBuilder<PeriodicNetworkSyncWorker>(Duration.ofSeconds(seconds))
                     .setConstraints(Constraints.Builder()
                         .setRequiredNetworkType(NetworkType.CONNECTED)      // network connection is usually required for synchronization
                         .build())