Trio/Dependencies/rileylink_ios/MinimedKit/PumpManager/MinimedPumpManagerState.swift

//
//  MinimedPumpManagerState.swift
//  Loop
//
//  Copyright © 2018 LoopKit Authors. All rights reserved.
//

import LoopKit
import RileyLinkKit
import RileyLinkBLEKit

public struct ReconciledDoseMapping: Equatable {
    let startTime: Date
    let uuid: UUID
    let eventRaw: Data
}

extension ReconciledDoseMapping: RawRepresentable {
    public typealias RawValue = [String:Any]
    
    public init?(rawValue: [String : Any]) {
        guard
            let startTime = rawValue["startTime"] as? Date,
            let uuidString = rawValue["uuid"] as? String,
            let uuid = UUID(uuidString: uuidString),
            let eventRawString = rawValue["eventRaw"] as? String,
            let eventRaw = Data(hexadecimalString: eventRawString) else
        {
            return nil
        }
        self.startTime = startTime
        self.uuid = uuid
        self.eventRaw = eventRaw
    }
    
    public var rawValue: [String : Any] {
        return [
            "startTime": startTime,
            "uuid": uuid.uuidString,
            "eventRaw": eventRaw.hexadecimalString,
        ]
    }
}

public struct MinimedPumpManagerState: RawRepresentable, Equatable {
    public typealias RawValue = PumpManager.RawStateValue

    public static let version = 2

    public var isOnboarded: Bool

    public var batteryChemistry: BatteryChemistryType = .alkaline

    public var batteryPercentage: Double?

    public var suspendState: SuspendState

    public var lastReservoirReading: ReservoirReading?

    public var lastTuned: Date?  // In-memory only

    public var lastValidFrequency: Measurement<UnitFrequency>?

    public var preferredInsulinDataSource: InsulinDataSource = .pumpHistory

    public var useMySentry: Bool

    public let pumpColor: PumpColor

    public let pumpModel: PumpModel
    
    public let pumpFirmwareVersion: String

    public let pumpID: String

    public let pumpRegion: PumpRegion

    public var pumpSettings: PumpSettings {
        get {
            return PumpSettings(pumpID: pumpID, pumpRegion: pumpRegion)
        }
    }
    
    public var pumpState: PumpState {
        get {
            var state = PumpState()
            state.pumpModel = pumpModel
            state.timeZone = timeZone
            state.lastValidFrequency = lastValidFrequency
            state.lastTuned = lastTuned
            state.useMySentry = useMySentry
            return state
        }
        set {
            lastValidFrequency = newValue.lastValidFrequency
            lastTuned = newValue.lastTuned
            timeZone = newValue.timeZone
        }
    }

    public var rileyLinkConnectionState: RileyLinkConnectionState?

    public var timeZone: TimeZone

    public var unfinalizedBolus: UnfinalizedDose?

    public var unfinalizedTempBasal: UnfinalizedDose?

    // Doses we're tracking that haven't shown up in history yet
    public var pendingDoses: [UnfinalizedDose] = []

    // Maps
    public var reconciliationMappings: [Data:ReconciledDoseMapping] = [:]

    public var lastReconciliation: Date?
    
    public var insulinType: InsulinType?
    
    public var rileyLinkBatteryAlertLevel: Int?
    
    public var lastRileyLinkBatteryAlertDate: Date = .distantPast
    
    public init(isOnboarded: Bool, useMySentry: Bool, pumpColor: PumpColor, pumpID: String, pumpModel: PumpModel, pumpFirmwareVersion: String, pumpRegion: PumpRegion, rileyLinkConnectionState: RileyLinkConnectionState?, timeZone: TimeZone, suspendState: SuspendState, insulinType: InsulinType, lastTuned: Date?, lastValidFrequency: Measurement<UnitFrequency>?)
    {
        self.isOnboarded = isOnboarded
        self.useMySentry = useMySentry
        self.pumpColor = pumpColor
        self.pumpID = pumpID
        self.pumpModel = pumpModel
        self.pumpFirmwareVersion = pumpFirmwareVersion
        self.pumpRegion = pumpRegion
        self.rileyLinkConnectionState = rileyLinkConnectionState
        self.timeZone = timeZone
        self.suspendState = suspendState
        self.insulinType = insulinType
        self.lastTuned = lastTuned
        self.lastValidFrequency = lastValidFrequency
    }

    public init?(rawValue: RawValue) {
        guard
            let version = rawValue["version"] as? Int,
            let useMySentry = rawValue["useMySentry"] as? Bool,
            let pumpID = rawValue["pumpID"] as? String,

            let batteryChemistryRaw = rawValue["batteryChemistry"] as? BatteryChemistryType.RawValue,
            let batteryChemistry = BatteryChemistryType(rawValue: batteryChemistryRaw),
            
            let insulinDataSourceRaw = rawValue["insulinDataSource"] as? InsulinDataSource.RawValue,
            let insulinDataSource = InsulinDataSource(rawValue: insulinDataSourceRaw),
            
            let pumpColorRaw = rawValue["pumpColor"] as? PumpColor.RawValue,
            let pumpColor = PumpColor(rawValue: pumpColorRaw),
            
            let pumpModelNumber = rawValue["pumpModel"] as? PumpModel.RawValue,
            let pumpModel = PumpModel(rawValue: pumpModelNumber),
            
            let pumpRegionRaw = rawValue["pumpRegion"] as? PumpRegion.RawValue,
            let pumpRegion = PumpRegion(rawValue: pumpRegionRaw),
            
            let timeZoneSeconds = rawValue["timeZone"] as? Int,
            let timeZone = TimeZone(secondsFromGMT: timeZoneSeconds)
        else {
            return nil
        }
        
        // Migrate
        if version == 1
        {
            if let oldRileyLinkPumpManagerStateRaw = rawValue["rileyLinkPumpManagerState"] as? [String : Any],
                let connectedPeripheralIDs = oldRileyLinkPumpManagerStateRaw["connectedPeripheralIDs"] as? [String]
            {
                self.rileyLinkConnectionState = RileyLinkConnectionState(autoConnectIDs: Set(connectedPeripheralIDs))
            }
        } else {
            if let rawState = rawValue["rileyLinkConnectionManagerState"] as? RileyLinkConnectionState.RawValue {
                self.rileyLinkConnectionState = RileyLinkConnectionState(rawValue: rawState)
            }
        }
        
        
        self.useMySentry = useMySentry
        self.pumpID = pumpID
        self.batteryChemistry = batteryChemistry
        self.preferredInsulinDataSource = insulinDataSource
        self.pumpColor = pumpColor
        self.pumpModel = pumpModel
        self.pumpRegion = pumpRegion
        self.timeZone = timeZone

        isOnboarded = rawValue["isOnboarded"] as? Bool ?? true // Backward compatibility

        if let isPumpSuspended = rawValue["isPumpSuspended"] as? Bool {
            // migrate
            if isPumpSuspended {
                suspendState = .suspended(Date())
            } else {
                suspendState = .resumed(Date())
            }
        } else if let rawSuspendState = rawValue["suspendState"] as? SuspendState.RawValue, let storedSuspendState = SuspendState(rawValue: rawSuspendState) {
            suspendState = storedSuspendState
        } else {
            return nil
        }
        
        if let frequencyRaw = rawValue["lastValidFrequency"] as? Double {
            lastValidFrequency = Measurement<UnitFrequency>(value: frequencyRaw, unit: .megahertz)
        } else {
            lastValidFrequency = nil
        }
        
        pumpFirmwareVersion = (rawValue["pumpFirmwareVersion"] as? String) ?? ""
        batteryPercentage = rawValue["batteryPercentage"] as? Double
        
        if let rawLastReservoirReading = rawValue["lastReservoirReading"] as? ReservoirReading.RawValue {
            lastReservoirReading = ReservoirReading(rawValue: rawLastReservoirReading)
        }

        if let rawUnfinalizedBolus = rawValue["unfinalizedBolus"] as? UnfinalizedDose.RawValue {
            unfinalizedBolus = UnfinalizedDose(rawValue: rawUnfinalizedBolus)
        }

        if let rawUnfinalizedTempBasal = rawValue["unfinalizedTempBasal"] as? UnfinalizedDose.RawValue {
            unfinalizedTempBasal = UnfinalizedDose(rawValue: rawUnfinalizedTempBasal)
        }

        if let rawPendingDoses = rawValue["pendingDoses"] as? [UnfinalizedDose.RawValue] {
            pendingDoses = rawPendingDoses.compactMap( { UnfinalizedDose(rawValue: $0) } )
        } else {
            pendingDoses = []
        }

        let recentlyReconciledEvents: [Data:ReconciledDoseMapping]
        if let rawRecentlyReconciledEvents = rawValue["recentlyReconciledEvents"] as? [ReconciledDoseMapping.RawValue] {
            let mappings = rawRecentlyReconciledEvents.compactMap { ReconciledDoseMapping(rawValue: $0) }
            recentlyReconciledEvents = Dictionary(mappings.map{ ($0.eventRaw, $0) }, uniquingKeysWith: { (old, new) in new } )
        } else {
            recentlyReconciledEvents = [:]
        }
        reconciliationMappings = recentlyReconciledEvents
        
        lastReconciliation = rawValue["lastReconciliation"] as? Date
        
        if let rawInsulinType = rawValue["insulinType"] as? InsulinType.RawValue {
            insulinType = InsulinType(rawValue: rawInsulinType)
        }
        
        rileyLinkBatteryAlertLevel = rawValue["rileyLinkBatteryAlertLevel"] as? Int
        lastRileyLinkBatteryAlertDate = rawValue["lastRileyLinkBatteryAlertDate"] as? Date ?? Date.distantPast

    }

    public var rawValue: RawValue {
        var value: [String : Any] = [
            "isOnboarded": isOnboarded,
            "batteryChemistry": batteryChemistry.rawValue,
            "insulinDataSource": preferredInsulinDataSource.rawValue,
            "pumpColor": pumpColor.rawValue,
            "pumpID": pumpID,
            "pumpModel": pumpModel.rawValue,
            "pumpFirmwareVersion": pumpFirmwareVersion,
            "pumpRegion": pumpRegion.rawValue,
            "timeZone": timeZone.secondsFromGMT(),
            "suspendState": suspendState.rawValue,
            "version": MinimedPumpManagerState.version,
            "pendingDoses": pendingDoses.map { $0.rawValue },
            "recentlyReconciledEvents": reconciliationMappings.values.map { $0.rawValue },
        ]

        value["useMySentry"] = useMySentry
        value["batteryPercentage"] = batteryPercentage
        value["lastReservoirReading"] = lastReservoirReading?.rawValue
        value["lastValidFrequency"] = lastValidFrequency?.converted(to: .megahertz).value
        value["rileyLinkConnectionManagerState"] = rileyLinkConnectionState?.rawValue
        value["unfinalizedBolus"] = unfinalizedBolus?.rawValue
        value["unfinalizedTempBasal"] = unfinalizedTempBasal?.rawValue
        value["lastReconciliation"] = lastReconciliation
        value["insulinType"] = insulinType?.rawValue
        value["rileyLinkBatteryAlertLevel"] = rileyLinkBatteryAlertLevel
        value["lastRileyLinkBatteryAlertDate"] = lastRileyLinkBatteryAlertDate

        return value
    }
}


extension MinimedPumpManagerState {
    static let idleListeningEnabledDefaults: RileyLinkBluetoothDevice.IdleListeningState = .enabled(timeout: .minutes(4), channel: 0)
}


extension MinimedPumpManagerState: CustomDebugStringConvertible {
    public var debugDescription: String {
        return [
            "## MinimedPumpManagerState",
            "isOnboarded: \(isOnboarded)",
            "batteryChemistry: \(batteryChemistry)",
            "batteryPercentage: \(String(describing: batteryPercentage))",
            "suspendState: \(suspendState)",
            "lastValidFrequency: \(String(describing: lastValidFrequency))",
            "preferredInsulinDataSource: \(preferredInsulinDataSource)",
            "useMySentry: \(useMySentry)",
            "pumpColor: \(pumpColor)",
            "pumpID: ✔︎",
            "pumpModel: \(pumpModel.rawValue)",
            "pumpFirmwareVersion: \(pumpFirmwareVersion)",
            "pumpRegion: \(pumpRegion)",
            "reservoirUnits: \(String(describing: lastReservoirReading?.units))",
            "reservoirValidAt: \(String(describing: lastReservoirReading?.validAt))",
            "unfinalizedBolus: \(String(describing: unfinalizedBolus))",
            "unfinalizedTempBasal: \(String(describing: unfinalizedTempBasal))",
            "pendingDoses: \(pendingDoses)",
            "timeZone: \(timeZone)",
            "recentlyReconciledEvents: \(reconciliationMappings.values.map { "\($0.eventRaw.hexadecimalString) -> \($0.uuid)" })",
            "lastReconciliation: \(String(describing: lastReconciliation))",
            "insulinType: \(String(describing: insulinType))",
            "rileyLinkBatteryAlertLevel: \(String(describing: rileyLinkBatteryAlertLevel))",
            "lastRileyLinkBatteryAlertDate \(String(describing: lastRileyLinkBatteryAlertDate))",
            String(reflecting: rileyLinkConnectionState),
        ].joined(separator: "\n")
    }
}

public enum SuspendState: Equatable, RawRepresentable {
    public typealias RawValue = [String: Any]

    private enum SuspendStateType: Int {
        case suspend, resume
    }

    case suspended(Date)
    case resumed(Date)

    private var identifier: Int {
        switch self {
        case .suspended:
            return 1
        case .resumed:
            return 2
        }
    }

    public init?(rawValue: RawValue) {
        guard let suspendStateType = rawValue["case"] as? SuspendStateType.RawValue,
            let date = rawValue["date"] as? Date else {
                return nil
        }
        switch SuspendStateType(rawValue: suspendStateType) {
        case .suspend?:
            self = .suspended(date)
        case .resume?:
            self = .resumed(date)
        default:
            return nil
        }
    }

    public var rawValue: RawValue {
        switch self {
        case .suspended(let date):
            return [
                "case": SuspendStateType.suspend.rawValue,
                "date": date
            ]
        case .resumed(let date):
            return [
                "case": SuspendStateType.resume.rawValue,
                "date": date
            ]
        }
    }
}