bolus: send progress

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

@@ -12,6 +12,7 @@ import info.nightscout.androidaps.plugins.bus.RxBusWrapper
 import info.nightscout.androidaps.plugins.common.ManufacturerType
 import info.nightscout.androidaps.plugins.general.actions.defs.CustomAction
 import info.nightscout.androidaps.plugins.general.actions.defs.CustomActionType
+import info.nightscout.androidaps.plugins.general.overview.events.EventOverviewBolusProgress
 import info.nightscout.androidaps.plugins.pump.common.defs.PumpType
 import info.nightscout.androidaps.plugins.pump.omnipod.common.definition.OmnipodCommandType
 import info.nightscout.androidaps.plugins.pump.omnipod.common.queue.command.*
@@ -39,12 +40,13 @@ import info.nightscout.androidaps.utils.sharedPreferences.SP
 import io.reactivex.Completable
 import io.reactivex.Observable
 import io.reactivex.Single
-import io.reactivex.rxkotlin.plusAssign
 import io.reactivex.rxkotlin.subscribeBy
 import org.json.JSONObject
 import java.util.*
+import java.util.concurrent.TimeUnit
 import javax.inject.Inject
 import javax.inject.Singleton
+import kotlin.math.ceil
 
 @Singleton
 class OmnipodDashPumpPlugin @Inject constructor(
@@ -240,59 +242,103 @@ class OmnipodDashPumpPlugin @Inject constructor(
         get() = 0
 
     override fun deliverTreatment(detailedBolusInfo: DetailedBolusInfo): PumpEnactResult {
-        // TODO update Treatments (?)
-        // TODO bolus progress
         // TODO report actual delivered amount after Pod Alarm and bolus cancellation
-
-        return Single.create<PumpEnactResult> { source ->
         val bolusBeeps = sp.getBoolean(R.string.key_omnipod_common_bolus_beeps_enabled, false)
 
-            Observable.concat(
+        if (detailedBolusInfo.carbs > 0 || detailedBolusInfo.insulin == 0.0) {
-                history.createRecord(
+            return PumpEnactResult(injector)
+                .success(false)
+                .enacted(false)
+                .bolusDelivered(0.0)
+                .carbsDelivered(0.0)
+                .comment("Invalid input");
+        }
+        val requestedBolusAmount = detailedBolusInfo.insulin
+        var delieveredBolusAmount = 0.0
+
+        aapsLogger.info(
+            LTag.PUMP,
+            "deliverTreatment: units: ${requestedBolusAmount}"
+        )
+        return executeProgrammingCommand(
+            pre = observeNoActiveTempBasal(true),
+            historyEntry = history.createRecord(
                 commandType = OmnipodCommandType.SET_BOLUS,
                 bolusRecord = BolusRecord(
-                        detailedBolusInfo.insulin,
+                    requestedBolusAmount,
-                        BolusType.fromBolusInfoBolusType(detailedBolusInfo.bolusType),
+                    BolusType.fromBolusInfoBolusType(detailedBolusInfo.bolusType)
+                )
             ),
-                ).flatMapObservable { recordId ->
+            command = omnipodManager.bolus(
-                    podStateManager.createActiveCommand(recordId).toObservable()
-                },
-                omnipodManager.bolus(
                 detailedBolusInfo.insulin,
                 bolusBeeps,
                 bolusBeeps
-                ),
+            ).filter { podEvent -> podEvent is PodEvent.CommandSent }
-                history.updateFromState(podStateManager).toObservable(),
+                .map { pumpSyncBolusStart(it, requestedBolusAmount, detailedBolusInfo.bolusType) }
-                podStateManager.updateActiveCommand().toObservable(),
+                .ignoreElements(),
-            ).subscribeBy(
+            post = waitForBolusDeliveryToComplete(5, requestedBolusAmount, detailedBolusInfo.bolusType)
-                onNext = { podEvent ->
+        ).toSingleDefault(PumpEnactResult(injector).success(true).enacted(true).bolusDelivered(delieveredBolusAmount))
-                    aapsLogger.debug(
+            .onErrorReturnItem(PumpEnactResult(injector).success(false).enacted(false))
-                        LTag.PUMP,
+            .blockingGet()
-                        "Received PodEvent in deliverTreatment: $podEvent"
+    }
-                    )
+
-                },
+    private fun waitForBolusDeliveryToComplete(
-                onError = { throwable ->
+        maxRetriesAtTheEnd: Int,
-                    aapsLogger.error(LTag.PUMP, "Error in deliverTreatment", throwable)
+        requestedBolusAmount: Double,
-                    source.onSuccess(
+        bolusType: DetailedBolusInfo.BolusType
-                        PumpEnactResult(injector).success(false).enacted(false).comment(
+    ): Completable {
-                            throwable.toString()
+        // TODO: wait for bolus delivery to start!
-                        )
+        // For now, we assume it started with success
-                    )
+
-                },
+        val estimatedDeliveryTimeSeconds = ceil(requestedBolusAmount / 0.05).toLong() * 2
-                onComplete = {
+        aapsLogger.info(LTag.PUMP, "estimatedDeliveryTimeSeconds: $estimatedDeliveryTimeSeconds")
-                    aapsLogger.debug("deliverTreatment completed")
+        return Completable.concat(listOf(
-                    source.onSuccess(
+            Observable.interval(1, TimeUnit.SECONDS)
-                        PumpEnactResult(injector).success(true).enacted(true)
+                .take(estimatedDeliveryTimeSeconds)
-                            .bolusDelivered(detailedBolusInfo.insulin)
+                .doOnNext {
-                            .carbsDelivered(detailedBolusInfo.carbs)
+                    if (bolusType == DetailedBolusInfo.BolusType.SMB) {
+                        return@doOnNext
+                    }
+                    val progressUpdateEvent = EventOverviewBolusProgress
+                    val percent = (100 * it) / estimatedDeliveryTimeSeconds
+                    progressUpdateEvent.status = resourceHelper.gs(R.string.bolusdelivering, requestedBolusAmount)
+                    progressUpdateEvent.percent = percent.toInt()
+                    rxBus.send(progressUpdateEvent)
+                }.ignoreElements(),
+            Observable.interval(5, TimeUnit.SECONDS).ignoreElements()
+            // TODO check delivery status. for now, we are just sleeping for 5 sec
+        ))
+    }
+
+    private fun pumpSyncBolusStart(
+        podEvent: PodEvent,
+        requestedBolusAmount: Double,
+        bolusType: DetailedBolusInfo.BolusType
+    ): Boolean {
+        val activeCommand = podStateManager.activeCommand
+        if (activeCommand == null || podEvent !is PodEvent.CommandSent) {
+            throw IllegalArgumentException(
+                "No active command or illegal podEvent: " +
+                    "activeCommand=$activeCommand" +
+                    "podEvent=$podEvent"
             )
         }
+        val historyEntry = history.getById(activeCommand.historyId)
+        val ret = pumpSync.syncBolusWithPumpId(
+            timestamp = historyEntry.createdAt,
+            amount = requestedBolusAmount,
+            type = bolusType,
+            pumpId = historyEntry.pumpId(),
+            pumpType = PumpType.OMNIPOD_DASH,
+            pumpSerial = serialNumber()
         )
-        }.blockingGet()
+        aapsLogger.debug(LTag.PUMP, "pumpSyncBolusStart: $ret")
+        return ret
     }
 
     override fun stopBolusDelivering() {
         // TODO update Treatments (?)
+        aapsLogger.info(LTag.PUMP, "stopBolusDelivering called")
         executeProgrammingCommand(
             historyEntry = history.createRecord(OmnipodCommandType.CANCEL_BOLUS),
             command = omnipodManager.stopBolus().ignoreElements()
@@ -312,7 +358,9 @@ class OmnipodDashPumpPlugin @Inject constructor(
             "setTempBasalAbsolute: $durationInMinutes min :: $absoluteRate U/h :: " +
                 "enforce: $enforceNew :: tbrType: $tbrType"
         )
+
         return executeProgrammingCommand(
+            pre = observeNoActiveTempBasal(true),
             historyEntry = history.createRecord(
                 commandType = OmnipodCommandType.SET_TEMPORARY_BASAL,
                 tempBasalRecord = TempBasalRecord(duration = durationInMinutes, rate = absoluteRate)
@@ -335,7 +383,6 @@ class OmnipodDashPumpPlugin @Inject constructor(
                 .filter { podEvent -> podEvent is PodEvent.CommandSent }
                 .map { pumpSyncTempBasal(it, absoluteRate, durationInMinutes.toLong(), tbrType) }
                 .ignoreElements(),
-            pre = observeNoActiveTempBasal(true),
         ).toPumpEnactResult()
     }
 
@@ -365,7 +412,7 @@ class OmnipodDashPumpPlugin @Inject constructor(
             pumpType = PumpType.OMNIPOD_DASH,
             pumpSerial = serialNumber()
         )
-        aapsLogger.debug(LTag.PUMP, "Pump sync temp basal: $ret")
+        aapsLogger.debug(LTag.PUMP, "pumpSyncTempBasal: $ret")
         return ret
     }
 
@@ -722,6 +769,19 @@ class OmnipodDashPumpPlugin @Inject constructor(
                 }
             }
 
+            OmnipodCommandType.SET_BOLUS -> {
+                if (!confirmation.success) {
+                    pumpSync.syncBolusWithPumpId(
+                        timestamp = historyEntry.createdAt,
+                        amount = 0.0,
+                        pumpId = historyEntry.pumpId(),
+                        pumpType = PumpType.OMNIPOD_DASH,
+                        pumpSerial = serialNumber(),
+                        type = null // TODO: set the correct bolus type here!!!
+                    )
+                }
+            }
+
             else ->
                 aapsLogger.warn(
                     LTag.PUMP,