BatteryStatusComplication: load state from cache

Author: thewizrd

wear/src/main/AndroidManifest.xml

@@ -252,7 +252,7 @@
         </service>
 
         <service
-            android:icon="@drawable/ic_smartphone_white_24dp"
+            android:icon="@drawable/ic_charging_station_24dp"
             android:label="@string/pref_title_phone_batt_state"
             android:permission="com.google.android.wearable.permission.BIND_COMPLICATION_PROVIDER"
             android:name=".wearable.complications.BatteryStatusComplicationService"

wear/src/main/java/com/thewizrd/simplewear/wearable/WearableDataListenerService.kt

@@ -58,6 +58,7 @@ import com.thewizrd.simplewear.datastore.media.mediaDataStore
 import com.thewizrd.simplewear.media.MediaPlayerActivity
 import com.thewizrd.simplewear.preferences.Settings
 import com.thewizrd.simplewear.viewmodels.WearableListenerViewModel
+import com.thewizrd.simplewear.wearable.complications.BatteryStatusComplicationService
 import com.thewizrd.simplewear.wearable.tiles.DashboardTileProviderService
 import com.thewizrd.simplewear.wearable.tiles.MediaPlayerTileProviderService
 import kotlinx.coroutines.Dispatchers
@@ -323,8 +324,13 @@ class WearableDataListenerService : WearableListenerService() {
                             cache.copy(batteryStatus = status)
                         }
 
-                        if (!mLegacyTilesEnabled && currentState?.batteryStatus != status) {
-                            DashboardTileProviderService.requestTileUpdate(appLib.context)
+                        if (currentState?.batteryStatus != status) {
+                            BatteryStatusComplicationService.requestComplicationUpdate(
+                                applicationContext
+                            )
+                            if (!mLegacyTilesEnabled) {
+                                DashboardTileProviderService.requestTileUpdate(appLib.context)
+                            }
                         }
                     }
                 }

wear/src/main/java/com/thewizrd/simplewear/wearable/complications/BatteryStatusComplicationService.kt

@@ -2,6 +2,7 @@ package com.thewizrd.simplewear.wearable.complications
 
 import android.app.PendingIntent
 import android.content.ComponentName
+import android.content.Context
 import android.content.Intent
 import android.graphics.drawable.Icon
 import androidx.wear.watchface.complications.data.ComplicationData
@@ -15,19 +16,53 @@ import androidx.wear.watchface.complications.data.ShortTextComplicationData
 import androidx.wear.watchface.complications.datasource.ComplicationDataSourceUpdateRequester
 import androidx.wear.watchface.complications.datasource.ComplicationRequest
 import androidx.wear.watchface.complications.datasource.SuspendingComplicationDataSourceService
+import com.thewizrd.shared_resources.actions.BatteryStatus
+import com.thewizrd.shared_resources.appLib
+import com.thewizrd.shared_resources.utils.Logger
 import com.thewizrd.simplewear.DashboardActivity
 import com.thewizrd.simplewear.R
+import com.thewizrd.simplewear.datastore.dashboard.dashboardDataStore
 import com.thewizrd.simplewear.utils.asLauncherIntent
 import com.thewizrd.simplewear.wearable.tiles.DashboardTileMessenger
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.Job
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.async
 import kotlinx.coroutines.cancel
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.firstOrNull
+import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.isActive
+import kotlinx.coroutines.launch
 
 class BatteryStatusComplicationService : SuspendingComplicationDataSourceService() {
     companion object {
         private const val TAG = "BatteryStatusComplicationService"
+
+        fun requestComplicationUpdate(context: Context, complicationInstanceId: Int? = null) {
+            updateJob?.cancel()
+
+            updateJob = appLib.appScope.launch {
+                delay(1000)
+                if (isActive) {
+                    Logger.debug(TAG, "requesting complication update")
+
+                    ComplicationDataSourceUpdateRequester.create(
+                        context,
+                        ComponentName(context, this::class.java)
+                    ).run {
+                        if (complicationInstanceId != null) {
+                            requestUpdate(complicationInstanceId)
+                        } else {
+                            requestUpdateAll()
+                        }
+                    }
+                }
+            }
+        }
+
+        private var updateJob: Job? = null
     }
 
     private val scope = CoroutineScope(SupervisorJob() + Dispatchers.Default)
@@ -47,13 +82,7 @@ class BatteryStatusComplicationService : SuspendingComplicationDataSourceService
 
     override fun onComplicationActivated(complicationInstanceId: Int, type: ComplicationType) {
         super.onComplicationActivated(complicationInstanceId, type)
-
-        ComplicationDataSourceUpdateRequester.create(
-            applicationContext,
-            ComponentName(applicationContext, this::class.java)
-        ).run {
-            requestUpdate(complicationInstanceId)
-        }
+        requestComplicationUpdate(applicationContext, complicationInstanceId)
     }
 
     override suspend fun onComplicationRequest(request: ComplicationRequest): ComplicationData {
@@ -62,8 +91,7 @@ class BatteryStatusComplicationService : SuspendingComplicationDataSourceService
         }
 
         return scope.async {
-            val batteryStatus = tileMessenger.requestBatteryStatusAsync()
-                ?: return@async NoDataComplicationData()
+            val batteryStatus = latestStatus() ?: return@async NoDataComplicationData()
 
             val batteryLvl = batteryStatus.batteryLevel
             val statusText = if (batteryStatus.isCharging) {
@@ -197,4 +225,15 @@ class BatteryStatusComplicationService : SuspendingComplicationDataSourceService
             )
         }
     }
+
+    private suspend fun latestStatus(): BatteryStatus? {
+        var status = this.dashboardDataStore.data.map { it.batteryStatus }.firstOrNull()
+
+        if (status == null) {
+            Logger.debug(TAG, "No battery status available. loading from remote...")
+            status = tileMessenger.requestBatteryStatusAsync()
+        }
+
+        return status
+    }
 }