pumpsync on suspend/resume

omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/OmnipodDashPumpPlugin.kt

@@ -17,6 +17,7 @@ import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.event.PodEven
 import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.definition.ActivationProgress
 import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.definition.BeepType
 import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.definition.DeliveryStatus
+import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.definition.PodConstants
 import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.response.ResponseType
 import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.state.CommandConfirmed
 import info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.state.OmnipodDashPodStateManager
@@ -296,7 +297,7 @@ class OmnipodDashPumpPlugin @Inject constructor(
                 tempBasalBeeps
             )
                 .filter { podEvent -> podEvent is PodEvent.CommandSent }
-                .map { pumpSyncTempBasal(it, tbrType) }
+                .map { pumpSyncTempBasal(it, absoluteRate, durationInMinutes.toLong(), tbrType) }
                 .ignoreElements(),
             pre = observeNoActiveTempBasal(enforceNew)
         ).toPumpEnactResult()
@@ -304,6 +305,8 @@ class OmnipodDashPumpPlugin @Inject constructor(
 
     private fun pumpSyncTempBasal(
         podEvent: PodEvent,
+        absoluteRate: Double,
+        durationInMinutes: Long,
         tbrType: PumpSync.TemporaryBasalType
     ): Boolean {
         val activeCommand = podStateManager.activeCommand
@@ -315,14 +318,11 @@ class OmnipodDashPumpPlugin @Inject constructor(
             )
         }
         val historyEntry = history.getById(activeCommand.historyId)
-        val record = historyEntry.record
+
-        if (record == null || !(record is TempBasalRecord)) {
-            throw IllegalArgumentException("Illegal recording in history: $record. Expected a temp basal")
-        }
         val ret = pumpSync.syncTemporaryBasalWithPumpId(
             timestamp = historyEntry.createdAt,
-            rate = record.rate,
+            rate = absoluteRate,
-            duration = T.mins(record.duration.toLong()).msecs(),
+            duration = T.mins(durationInMinutes.toLong()).msecs(),
             isAbsolute = true,
             type = tbrType,
             pumpId = historyEntry.pumpId(),
@@ -363,8 +363,9 @@ class OmnipodDashPumpPlugin @Inject constructor(
     }
 
     private fun observeActiveTempBasal(): Completable {
+
         return Completable.defer {
-            if (podStateManager.tempBasalActive)
+            if (podStateManager.tempBasalActive || pumpSync.expectedPumpState().temporaryBasal != null)
                 Completable.complete()
             else
                 Completable.error(
@@ -523,8 +524,16 @@ class OmnipodDashPumpPlugin @Inject constructor(
 
     private fun suspendDelivery(): PumpEnactResult {
         return executeSimpleProgrammingCommand(
-            history.createRecord(OmnipodCommandType.SUSPEND_DELIVERY),
+            historyEntry = history.createRecord(OmnipodCommandType.SUSPEND_DELIVERY),
-            omnipodManager.suspendDelivery().ignoreElements(),
+            command = omnipodManager.suspendDelivery()
+                .filter { podEvent -> podEvent is PodEvent.CommandSent }
+                .map {
+                    pumpSyncTempBasal(it,
+                                      0.0,
+                                      PodConstants.MAX_POD_LIFETIME.standardMinutes,
+                                      PumpSync.TemporaryBasalType.PUMP_SUSPEND)
+                }
+                .ignoreElements(),
             pre = observeDeliveryActive(),
         ).toPumpEnactResult()
     }
@@ -619,7 +628,9 @@ class OmnipodDashPumpPlugin @Inject constructor(
         val historyEntry = history.getById(confirmation.historyId)
         aapsLogger.debug(LTag.PUMPCOMM, "handling confirmation command: $confirmation")
         when (historyEntry.commandType) {
-            OmnipodCommandType.CANCEL_TEMPORARY_BASAL ->
+            OmnipodCommandType.CANCEL_TEMPORARY_BASAL,
+            OmnipodCommandType.SET_BASAL_PROFILE,
+            OmnipodCommandType.RESUME_DELIVERY ->
                 // We can't invalidate this command,
                 // and this is why it is pumpSync-ed at this point
                 if (confirmation.success) {
@@ -639,6 +650,12 @@ class OmnipodDashPumpPlugin @Inject constructor(
                 }
             }
 
+            OmnipodCommandType.SUSPEND_DELIVERY -> {
+                if (!confirmation.success) {
+                    pumpSync.invalidateTemporaryBasal(historyEntry.pumpId())
+                }
+            }
+
             else ->
                 aapsLogger.warn(
                     LTag.PUMP,

omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/driver/pod/definition/PodConstants.kt

@@ -0,0 +1,9 @@
+package info.nightscout.androidaps.plugins.pump.omnipod.dash.driver.pod.definition
+
+import org.joda.time.Duration
+
+class PodConstants {
+    companion object {
+        val MAX_POD_LIFETIME = Duration.standardHours(80)
+    }
+}

omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/driver/pod/state/OmnipodDashPodStateManager.kt

@@ -73,7 +73,7 @@ interface OmnipodDashPodStateManager {
     fun updateFromPairing(uniqueId: Id, pairResult: PairResult)
     fun reset()
 
-    fun createActiveCommand(historyId: String): Single<ActiveCommand>
+    fun createActiveCommand(historyId: String, basalProgram: BasalProgram?=null): Single<ActiveCommand>
     fun updateActiveCommand(): Maybe<CommandConfirmed>
     fun observeNoActiveCommand(): Observable<PodEvent>
     fun getCommandConfirmationFromState(): CommandConfirmationFromState
@@ -84,6 +84,7 @@ interface OmnipodDashPodStateManager {
         var sentRealtime: Long = 0,
         val historyId: String,
         var sendError: Throwable?,
+        var basalProgram: BasalProgram?
     )
     // TODO: set created to "now" on boot
     data class TempBasal(val startTime: Long, val rate: Double, val durationInMinutes: Short) : Serializable

omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/driver/pod/state/OmnipodDashPodStateManagerImpl.kt

@@ -188,7 +188,8 @@ class OmnipodDashPodStateManagerImpl @Inject constructor(
         get() = podState.activeCommand
 
     @Synchronized
-    override fun createActiveCommand(historyId: String): Single<OmnipodDashPodStateManager.ActiveCommand> {
+    override fun createActiveCommand(historyId: String, basalProgram: BasalProgram?):
+        Single<OmnipodDashPodStateManager.ActiveCommand> {
         return Single.create { source ->
             if (activeCommand == null) {
                 val command = OmnipodDashPodStateManager.ActiveCommand(
@@ -196,6 +197,7 @@ class OmnipodDashPodStateManagerImpl @Inject constructor(
                     createdRealtime = SystemClock.elapsedRealtime(),
                     historyId = historyId,
                     sendError = null,
+                    basalProgram = basalProgram,
                 )
                 podState.activeCommand = command
                 source.onSuccess(command)
@@ -261,7 +263,7 @@ class OmnipodDashPodStateManagerImpl @Inject constructor(
             CommandConfirmationSuccess -> {
                 podState.activeCommand = null
 
-                source.onSuccess(CommandConfirmed(activeCommand.historyId, true)) 
+                source.onSuccess(CommandConfirmed(activeCommand.historyId, true))
             }
 
             NoActiveCommand -> {