HomeStateModel.swift 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703
  1. import Combine
  2. import CoreData
  3. import Foundation
  4. import LoopKitUI
  5. import Observation
  6. import SwiftDate
  7. import SwiftUI
  8. extension Home {
  9. @Observable final class StateModel: BaseStateModel<Provider> {
  10. @ObservationIgnored @Injected() var broadcaster: Broadcaster!
  11. @ObservationIgnored @Injected() var apsManager: APSManager!
  12. @ObservationIgnored @Injected() var fetchGlucoseManager: FetchGlucoseManager!
  13. @ObservationIgnored @Injected() var nightscoutManager: NightscoutManager!
  14. @ObservationIgnored @Injected() var determinationStorage: DeterminationStorage!
  15. @ObservationIgnored @Injected() var glucoseStorage: GlucoseStorage!
  16. @ObservationIgnored @Injected() var carbsStorage: CarbsStorage!
  17. @ObservationIgnored @Injected() var tempTargetStorage: TempTargetsStorage!
  18. private let timer = DispatchTimer(timeInterval: 5)
  19. private(set) var filteredHours = 24
  20. var manualGlucose: [BloodGlucose] = []
  21. var announcement: [Announcement] = []
  22. var uploadStats = false
  23. var recentGlucose: BloodGlucose?
  24. var maxBasal: Decimal = 2
  25. var autotunedBasalProfile: [BasalProfileEntry] = []
  26. var basalProfile: [BasalProfileEntry] = []
  27. var tempTargets: [TempTarget] = []
  28. var timerDate = Date()
  29. var closedLoop = false
  30. var pumpSuspended = false
  31. var isLooping = false
  32. var statusTitle = ""
  33. var lastLoopDate: Date = .distantPast
  34. var battery: Battery?
  35. var reservoir: Decimal?
  36. var pumpName = ""
  37. var pumpExpiresAtDate: Date?
  38. var tempTarget: TempTarget?
  39. var setupPump = false
  40. var errorMessage: String?
  41. var errorDate: Date?
  42. var bolusProgress: Decimal?
  43. var eventualBG: Int?
  44. var allowManualTemp = false
  45. var units: GlucoseUnits = .mgdL
  46. var pumpDisplayState: PumpDisplayState?
  47. var alarm: GlucoseAlarm?
  48. var manualTempBasal = false
  49. var isSmoothingEnabled = false
  50. var maxValue: Decimal = 1.2
  51. var lowGlucose: Decimal = 70
  52. var highGlucose: Decimal = 180
  53. var currentGlucoseTarget: Decimal = 100
  54. var glucoseColorScheme: GlucoseColorScheme = .staticColor
  55. var overrideUnit: Bool = false
  56. var displayXgridLines: Bool = false
  57. var displayYgridLines: Bool = false
  58. var thresholdLines: Bool = false
  59. var timeZone: TimeZone?
  60. var hours: Int16 = 6
  61. var totalBolus: Decimal = 0
  62. var isStatusPopupPresented: Bool = false
  63. var isLegendPresented: Bool = false
  64. var legendSheetDetent = PresentationDetent.large
  65. var totalInsulinDisplayType: TotalInsulinDisplayType = .totalDailyDose
  66. var roundedTotalBolus: String = ""
  67. var selectedTab: Int = 0
  68. var waitForSuggestion: Bool = false
  69. var glucoseFromPersistence: [GlucoseStored] = []
  70. var latestTwoGlucoseValues: [GlucoseStored] = []
  71. var carbsFromPersistence: [CarbEntryStored] = []
  72. var fpusFromPersistence: [CarbEntryStored] = []
  73. var determinationsFromPersistence: [OrefDetermination] = []
  74. var enactedAndNonEnactedDeterminations: [OrefDetermination] = []
  75. var insulinFromPersistence: [PumpEventStored] = []
  76. var tempBasals: [PumpEventStored] = []
  77. var suspensions: [PumpEventStored] = []
  78. var batteryFromPersistence: [OpenAPS_Battery] = []
  79. var lastPumpBolus: PumpEventStored?
  80. var overrides: [OverrideStored] = []
  81. var overrideRunStored: [OverrideRunStored] = []
  82. var isOverrideCancelled: Bool = false
  83. var preprocessedData: [(id: UUID, forecast: Forecast, forecastValue: ForecastValue)] = []
  84. var pumpStatusHighlightMessage: String?
  85. var cgmAvailable: Bool = false
  86. var showCarbsRequiredBadge: Bool = true
  87. var tempTargetStored: [TempTargetStored] = []
  88. var tempTargetRunStored: [TempTargetRunStored] = []
  89. private(set) var setupPumpType: PumpConfig.PumpType = .minimed
  90. @Published var currentBGTarget: Decimal = 0
  91. var minForecast: [Int] = []
  92. var maxForecast: [Int] = []
  93. var minCount: Int = 12 // count of Forecasts drawn in 5 min distances, i.e. 12 means a min of 1 hour
  94. var forecastDisplayType: ForecastDisplayType = .cone
  95. var minYAxisValue: Decimal = 39
  96. var maxYAxisValue: Decimal = 300
  97. var minValueCobChart: Decimal = 0
  98. var maxValueCobChart: Decimal = 20
  99. var minValueIobChart: Decimal = 0
  100. var maxValueIobChart: Decimal = 5
  101. let taskContext = CoreDataStack.shared.newTaskContext()
  102. let glucoseFetchContext = CoreDataStack.shared.newTaskContext()
  103. let carbsFetchContext = CoreDataStack.shared.newTaskContext()
  104. let fpuFetchContext = CoreDataStack.shared.newTaskContext()
  105. let determinationFetchContext = CoreDataStack.shared.newTaskContext()
  106. let pumpHistoryFetchContext = CoreDataStack.shared.newTaskContext()
  107. let overrideFetchContext = CoreDataStack.shared.newTaskContext()
  108. let tempTargetFetchContext = CoreDataStack.shared.newTaskContext()
  109. let batteryFetchContext = CoreDataStack.shared.newTaskContext()
  110. let viewContext = CoreDataStack.shared.persistentContainer.viewContext
  111. private var coreDataPublisher: AnyPublisher<Set<NSManagedObject>, Never>?
  112. private var subscriptions = Set<AnyCancellable>()
  113. typealias PumpEvent = PumpEventStored.EventType
  114. override func subscribe() {
  115. coreDataPublisher =
  116. changedObjectsOnManagedObjectContextDidSavePublisher()
  117. .receive(on: DispatchQueue.global(qos: .background))
  118. .share()
  119. .eraseToAnyPublisher()
  120. registerSubscribers()
  121. registerHandlers()
  122. // Parallelize Setup functions
  123. setupHomeViewConcurrently()
  124. }
  125. private func setupHomeViewConcurrently() {
  126. Task {
  127. await withTaskGroup(of: Void.self) { group in
  128. group.addTask {
  129. self.setupGlucoseArray()
  130. }
  131. group.addTask {
  132. self.setupCarbsArray()
  133. }
  134. group.addTask {
  135. self.setupFPUsArray()
  136. }
  137. group.addTask {
  138. self.setupDeterminationsArray()
  139. }
  140. group.addTask {
  141. self.setupInsulinArray()
  142. }
  143. group.addTask {
  144. self.setupLastBolus()
  145. }
  146. group.addTask {
  147. self.setupBatteryArray()
  148. }
  149. group.addTask {
  150. self.setupPumpSettings()
  151. }
  152. group.addTask {
  153. self.setupBasalProfile()
  154. }
  155. group.addTask {
  156. self.setupReservoir()
  157. }
  158. group.addTask {
  159. self.setupCurrentPumpTimezone()
  160. }
  161. group.addTask {
  162. self.setupOverrides()
  163. }
  164. group.addTask {
  165. self.setupOverrideRunStored()
  166. }
  167. group.addTask {
  168. self.setupTempTargetsStored()
  169. }
  170. group.addTask {
  171. self.setupTempTargetsRunStored()
  172. }
  173. group.addTask {
  174. await self.setupSettings()
  175. }
  176. group.addTask {
  177. self.registerObservers()
  178. }
  179. group.addTask {
  180. await self.getCurrentBGTarget()
  181. }
  182. }
  183. }
  184. }
  185. // These combine subscribers are only necessary due to the batch inserts of glucose/FPUs which do not trigger a ManagedObjectContext change notification
  186. private func registerSubscribers() {
  187. glucoseStorage.updatePublisher
  188. .receive(on: DispatchQueue.global(qos: .background))
  189. .sink { [weak self] _ in
  190. guard let self = self else { return }
  191. self.setupGlucoseArray()
  192. }
  193. .store(in: &subscriptions)
  194. carbsStorage.updatePublisher
  195. .receive(on: DispatchQueue.global(qos: .background))
  196. .sink { [weak self] _ in
  197. guard let self = self else { return }
  198. self.setupFPUsArray()
  199. }
  200. .store(in: &subscriptions)
  201. }
  202. private func registerHandlers() {
  203. coreDataPublisher?.filterByEntityName("OrefDetermination").sink { [weak self] _ in
  204. guard let self = self else { return }
  205. self.setupDeterminationsArray()
  206. }.store(in: &subscriptions)
  207. coreDataPublisher?.filterByEntityName("GlucoseStored").sink { [weak self] _ in
  208. guard let self = self else { return }
  209. self.setupGlucoseArray()
  210. }.store(in: &subscriptions)
  211. coreDataPublisher?.filterByEntityName("CarbEntryStored").sink { [weak self] _ in
  212. guard let self = self else { return }
  213. self.setupCarbsArray()
  214. }.store(in: &subscriptions)
  215. coreDataPublisher?.filterByEntityName("PumpEventStored").sink { [weak self] _ in
  216. guard let self = self else { return }
  217. self.setupInsulinArray()
  218. self.setupLastBolus()
  219. self.displayPumpStatusHighlightMessage()
  220. }.store(in: &subscriptions)
  221. coreDataPublisher?.filterByEntityName("OpenAPS_Battery").sink { [weak self] _ in
  222. guard let self = self else { return }
  223. self.setupBatteryArray()
  224. }.store(in: &subscriptions)
  225. coreDataPublisher?.filterByEntityName("OverrideStored").sink { [weak self] _ in
  226. guard let self = self else { return }
  227. self.setupOverrides()
  228. }.store(in: &subscriptions)
  229. coreDataPublisher?.filterByEntityName("OverrideRunStored").sink { [weak self] _ in
  230. guard let self = self else { return }
  231. self.setupOverrideRunStored()
  232. }.store(in: &subscriptions)
  233. coreDataPublisher?.filterByEntityName("TempTargetStored").sink { [weak self] _ in
  234. guard let self = self else { return }
  235. self.setupTempTargetsStored()
  236. }.store(in: &subscriptions)
  237. coreDataPublisher?.filterByEntityName("TempTargetRunStored").sink { [weak self] _ in
  238. guard let self = self else { return }
  239. self.setupTempTargetsRunStored()
  240. }.store(in: &subscriptions)
  241. }
  242. private func registerObservers() {
  243. broadcaster.register(GlucoseObserver.self, observer: self)
  244. broadcaster.register(DeterminationObserver.self, observer: self)
  245. broadcaster.register(SettingsObserver.self, observer: self)
  246. broadcaster.register(PumpSettingsObserver.self, observer: self)
  247. broadcaster.register(BasalProfileObserver.self, observer: self)
  248. broadcaster.register(PumpReservoirObserver.self, observer: self)
  249. broadcaster.register(PumpDeactivatedObserver.self, observer: self)
  250. timer.eventHandler = {
  251. DispatchQueue.main.async { [weak self] in
  252. self?.timerDate = Date()
  253. }
  254. }
  255. timer.resume()
  256. apsManager.isLooping
  257. .receive(on: DispatchQueue.main)
  258. .weakAssign(to: \.isLooping, on: self)
  259. .store(in: &lifetime)
  260. apsManager.lastLoopDateSubject
  261. .receive(on: DispatchQueue.main)
  262. .weakAssign(to: \.lastLoopDate, on: self)
  263. .store(in: &lifetime)
  264. apsManager.pumpName
  265. .receive(on: DispatchQueue.main)
  266. .weakAssign(to: \.pumpName, on: self)
  267. .store(in: &lifetime)
  268. apsManager.pumpExpiresAtDate
  269. .receive(on: DispatchQueue.main)
  270. .weakAssign(to: \.pumpExpiresAtDate, on: self)
  271. .store(in: &lifetime)
  272. apsManager.lastError
  273. .receive(on: DispatchQueue.main)
  274. .map { [weak self] error in
  275. self?.errorDate = error == nil ? nil : Date()
  276. if let error = error {
  277. info(.default, error.localizedDescription)
  278. }
  279. return error?.localizedDescription
  280. }
  281. .weakAssign(to: \.errorMessage, on: self)
  282. .store(in: &lifetime)
  283. apsManager.bolusProgress
  284. .receive(on: DispatchQueue.main)
  285. .weakAssign(to: \.bolusProgress, on: self)
  286. .store(in: &lifetime)
  287. apsManager.pumpDisplayState
  288. .receive(on: DispatchQueue.main)
  289. .sink { [weak self] state in
  290. guard let self = self else { return }
  291. self.pumpDisplayState = state
  292. if state == nil {
  293. self.reservoir = nil
  294. self.battery = nil
  295. self.pumpName = ""
  296. self.pumpExpiresAtDate = nil
  297. self.setupPump = false
  298. } else {
  299. self.setupReservoir()
  300. self.displayPumpStatusHighlightMessage()
  301. self.setupBatteryArray()
  302. }
  303. }
  304. .store(in: &lifetime)
  305. }
  306. private enum SettingType {
  307. case basal
  308. case carbRatio
  309. case bgTarget
  310. case isf
  311. }
  312. private func getCurrentBGTarget() async {
  313. let now = Date()
  314. let calendar = Calendar.current
  315. let dateFormatter = DateFormatter()
  316. dateFormatter.dateFormat = "HH:mm:ss"
  317. dateFormatter.timeZone = TimeZone.current
  318. let entries: [(start: String, value: Decimal)]
  319. let bgTargets = await provider.getBGTarget()
  320. entries = bgTargets.targets.map { ($0.start, $0.low) }
  321. for (index, entry) in entries.enumerated() {
  322. guard let entryTime = dateFormatter.date(from: entry.start) else {
  323. print("Invalid entry start time: \(entry.start)")
  324. continue
  325. }
  326. let entryComponents = calendar.dateComponents([.hour, .minute, .second], from: entryTime)
  327. let entryStartTime = calendar.date(
  328. bySettingHour: entryComponents.hour!,
  329. minute: entryComponents.minute!,
  330. second: entryComponents.second!,
  331. of: now
  332. )!
  333. let entryEndTime: Date
  334. if index < entries.count - 1,
  335. let nextEntryTime = dateFormatter.date(from: entries[index + 1].start)
  336. {
  337. let nextEntryComponents = calendar.dateComponents([.hour, .minute, .second], from: nextEntryTime)
  338. entryEndTime = calendar.date(
  339. bySettingHour: nextEntryComponents.hour!,
  340. minute: nextEntryComponents.minute!,
  341. second: nextEntryComponents.second!,
  342. of: now
  343. )!
  344. } else {
  345. entryEndTime = calendar.date(byAdding: .day, value: 1, to: entryStartTime)!
  346. }
  347. if now >= entryStartTime, now < entryEndTime {
  348. await MainActor.run {
  349. currentBGTarget = entry.value
  350. }
  351. return
  352. }
  353. }
  354. }
  355. @MainActor private func setupSettings() async {
  356. units = settingsManager.settings.units
  357. allowManualTemp = !settingsManager.settings.closedLoop
  358. closedLoop = settingsManager.settings.closedLoop
  359. lastLoopDate = apsManager.lastLoopDate
  360. alarm = provider.glucoseStorage.alarm
  361. manualTempBasal = apsManager.isManualTempBasal
  362. isSmoothingEnabled = settingsManager.settings.smoothGlucose
  363. glucoseColorScheme = settingsManager.settings.glucoseColorScheme
  364. maxValue = settingsManager.preferences.autosensMax
  365. lowGlucose = units == .mgdL ? settingsManager.settings.low : settingsManager.settings.low.asMmolL
  366. highGlucose = units == .mgdL ? settingsManager.settings.high : settingsManager.settings.high.asMmolL
  367. overrideUnit = settingsManager.settings.overrideHbA1cUnit
  368. displayXgridLines = settingsManager.settings.xGridLines
  369. displayYgridLines = settingsManager.settings.yGridLines
  370. thresholdLines = settingsManager.settings.rulerMarks
  371. totalInsulinDisplayType = settingsManager.settings.totalInsulinDisplayType
  372. cgmAvailable = fetchGlucoseManager.cgmGlucoseSourceType != CGMType.none
  373. showCarbsRequiredBadge = settingsManager.settings.showCarbsRequiredBadge
  374. forecastDisplayType = settingsManager.settings.forecastDisplayType
  375. }
  376. func addPump(_ type: PumpConfig.PumpType) {
  377. setupPumpType = type
  378. setupPump = true
  379. }
  380. /// Display the eventual status message provided by the manager of the pump
  381. /// Only display if state is warning or critical message else return nil
  382. private func displayPumpStatusHighlightMessage(_ didDeactivate: Bool = false) {
  383. DispatchQueue.main.async { [weak self] in
  384. guard let self = self else { return }
  385. if let statusHighlight = self.provider.deviceManager.pumpManager?.pumpStatusHighlight,
  386. statusHighlight.state == .warning || statusHighlight.state == .critical, !didDeactivate
  387. {
  388. pumpStatusHighlightMessage = (statusHighlight.state == .warning ? "⚠️\n" : "‼️\n") + statusHighlight
  389. .localizedMessage
  390. } else {
  391. pumpStatusHighlightMessage = nil
  392. }
  393. }
  394. }
  395. func runLoop() {
  396. provider.heartbeatNow()
  397. }
  398. func showProgressView() {
  399. glucoseStorage
  400. .isGlucoseDataFresh(glucoseFromPersistence.first?.date) ? (waitForSuggestion = true) : (waitForSuggestion = false)
  401. }
  402. func cancelBolus() {
  403. Task {
  404. await apsManager.cancelBolus()
  405. // perform determine basal sync, otherwise you have could end up with too much iob when opening the calculator again
  406. await apsManager.determineBasalSync()
  407. }
  408. }
  409. @MainActor func cancelOverride(withID id: NSManagedObjectID) async {
  410. do {
  411. let profileToCancel = try viewContext.existingObject(with: id) as? OverrideStored
  412. profileToCancel?.enabled = false
  413. await saveToOverrideRunStored(withID: id)
  414. guard viewContext.hasChanges else { return }
  415. try viewContext.save()
  416. Foundation.NotificationCenter.default.post(name: .willUpdateOverrideConfiguration, object: nil)
  417. } catch {
  418. debugPrint("\(DebuggingIdentifiers.failed) \(#file) \(#function) Failed to cancel Profile")
  419. }
  420. }
  421. func calculateTINS() -> String {
  422. let startTime = calculateStartTime(hours: Int(hours))
  423. let totalBolus = calculateTotalBolus(from: insulinFromPersistence, since: startTime)
  424. let totalBasal = calculateTotalBasal(from: insulinFromPersistence, since: startTime)
  425. let totalInsulin = totalBolus + totalBasal
  426. return formatInsulinAmount(totalInsulin)
  427. }
  428. private func calculateStartTime(hours: Int) -> Date {
  429. let date = Date()
  430. let calendar = Calendar.current
  431. var offsetComponents = DateComponents()
  432. offsetComponents.hour = -hours
  433. return calendar.date(byAdding: offsetComponents, to: date)!
  434. }
  435. private func calculateTotalBolus(from events: [PumpEventStored], since startTime: Date) -> Double {
  436. let bolusEvents = events.filter { $0.timestamp ?? .distantPast >= startTime && $0.type == PumpEvent.bolus.rawValue }
  437. return bolusEvents.compactMap { $0.bolus?.amount?.doubleValue }.reduce(0, +)
  438. }
  439. private func calculateTotalBasal(from events: [PumpEventStored], since startTime: Date) -> Double {
  440. let basalEvents = events
  441. .filter { $0.timestamp ?? .distantPast >= startTime && $0.type == PumpEvent.tempBasal.rawValue }
  442. .sorted { $0.timestamp ?? .distantPast < $1.timestamp ?? .distantPast }
  443. var basalDurations: [Double] = []
  444. for (index, basalEntry) in basalEvents.enumerated() {
  445. if index + 1 < basalEvents.count {
  446. let nextEntry = basalEvents[index + 1]
  447. let durationInSeconds = nextEntry.timestamp?.timeIntervalSince(basalEntry.timestamp ?? Date()) ?? 0
  448. basalDurations.append(durationInSeconds / 3600) // Conversion to hours
  449. }
  450. }
  451. return zip(basalEvents, basalDurations).map { entry, duration in
  452. guard let rate = entry.tempBasal?.rate?.doubleValue else { return 0 }
  453. return rate * duration
  454. }.reduce(0, +)
  455. }
  456. private func formatInsulinAmount(_ amount: Double) -> String {
  457. let roundedAmount = Decimal(round(100 * amount) / 100)
  458. return roundedAmount.formatted()
  459. }
  460. private func setupPumpSettings() {
  461. DispatchQueue.main.async { [weak self] in
  462. guard let self = self else { return }
  463. self.maxBasal = self.provider.pumpSettings().maxBasal
  464. }
  465. }
  466. private func setupBasalProfile() {
  467. DispatchQueue.main.async { [weak self] in
  468. guard let self = self else { return }
  469. self.autotunedBasalProfile = self.provider.autotunedBasalProfile()
  470. self.basalProfile = self.provider.basalProfile()
  471. }
  472. }
  473. private func setupReservoir() {
  474. DispatchQueue.main.async { [weak self] in
  475. guard let self = self else { return }
  476. self.reservoir = self.provider.pumpReservoir()
  477. }
  478. }
  479. private func setupCurrentPumpTimezone() {
  480. DispatchQueue.main.async { [weak self] in
  481. guard let self = self else { return }
  482. self.timeZone = self.provider.pumpTimeZone()
  483. }
  484. }
  485. private func getCurrentGlucoseTarget() async {
  486. let now = Date()
  487. let calendar = Calendar.current
  488. let dateFormatter = DateFormatter()
  489. dateFormatter.dateFormat = "HH:mm:ss"
  490. dateFormatter.timeZone = TimeZone.current
  491. let bgTargets = await provider.getBGTarget()
  492. let entries: [(start: String, value: Decimal)] = bgTargets.targets.map { ($0.start, $0.low) }
  493. for (index, entry) in entries.enumerated() {
  494. guard let entryTime = dateFormatter.date(from: entry.start) else {
  495. print("Invalid entry start time: \(entry.start)")
  496. continue
  497. }
  498. let entryComponents = calendar.dateComponents([.hour, .minute, .second], from: entryTime)
  499. let entryStartTime = calendar.date(
  500. bySettingHour: entryComponents.hour!,
  501. minute: entryComponents.minute!,
  502. second: entryComponents.second!,
  503. of: now
  504. )!
  505. let entryEndTime: Date
  506. if index < entries.count - 1,
  507. let nextEntryTime = dateFormatter.date(from: entries[index + 1].start)
  508. {
  509. let nextEntryComponents = calendar.dateComponents([.hour, .minute, .second], from: nextEntryTime)
  510. entryEndTime = calendar.date(
  511. bySettingHour: nextEntryComponents.hour!,
  512. minute: nextEntryComponents.minute!,
  513. second: nextEntryComponents.second!,
  514. of: now
  515. )!
  516. } else {
  517. entryEndTime = calendar.date(byAdding: .day, value: 1, to: entryStartTime)!
  518. }
  519. if now >= entryStartTime, now < entryEndTime {
  520. await MainActor.run {
  521. currentGlucoseTarget = units == .mgdL ? entry.value : entry.value.asMmolL
  522. }
  523. return
  524. }
  525. }
  526. }
  527. func openCGM() {
  528. router.mainSecondaryModalView.send(router.view(for: .cgmDirect))
  529. }
  530. }
  531. }
  532. extension Home.StateModel:
  533. GlucoseObserver,
  534. DeterminationObserver,
  535. SettingsObserver,
  536. PumpSettingsObserver,
  537. BasalProfileObserver,
  538. PumpReservoirObserver,
  539. PumpTimeZoneObserver,
  540. PumpDeactivatedObserver
  541. {
  542. // TODO: still needed?
  543. func glucoseDidUpdate(_: [BloodGlucose]) {
  544. // setupGlucose()
  545. }
  546. func determinationDidUpdate(_: Determination) {
  547. waitForSuggestion = false
  548. }
  549. func settingsDidChange(_ settings: FreeAPSSettings) {
  550. allowManualTemp = !settings.closedLoop
  551. closedLoop = settingsManager.settings.closedLoop
  552. units = settingsManager.settings.units
  553. manualTempBasal = apsManager.isManualTempBasal
  554. isSmoothingEnabled = settingsManager.settings.smoothGlucose
  555. lowGlucose = units == .mgdL ? settingsManager.settings.low : settingsManager.settings.low.asMmolL
  556. highGlucose = units == .mgdL ? settingsManager.settings.high : settingsManager.settings.high.asMmolL
  557. Task {
  558. await getCurrentGlucoseTarget()
  559. }
  560. overrideUnit = settingsManager.settings.overrideHbA1cUnit
  561. glucoseColorScheme = settingsManager.settings.glucoseColorScheme
  562. displayXgridLines = settingsManager.settings.xGridLines
  563. displayYgridLines = settingsManager.settings.yGridLines
  564. thresholdLines = settingsManager.settings.rulerMarks
  565. totalInsulinDisplayType = settingsManager.settings.totalInsulinDisplayType
  566. showCarbsRequiredBadge = settingsManager.settings.showCarbsRequiredBadge
  567. forecastDisplayType = settingsManager.settings.forecastDisplayType
  568. cgmAvailable = (fetchGlucoseManager.cgmGlucoseSourceType != CGMType.none)
  569. displayPumpStatusHighlightMessage()
  570. setupBatteryArray()
  571. Task {
  572. await self.getCurrentBGTarget()
  573. }
  574. }
  575. // TODO: is this ever really triggered? react to MOC changes?
  576. func pumpHistoryDidUpdate(_: [PumpHistoryEvent]) {
  577. displayPumpStatusHighlightMessage()
  578. }
  579. func pumpSettingsDidChange(_: PumpSettings) {
  580. setupPumpSettings()
  581. setupBatteryArray()
  582. }
  583. func basalProfileDidChange(_: [BasalProfileEntry]) {
  584. setupBasalProfile()
  585. }
  586. func pumpReservoirDidChange(_: Decimal) {
  587. setupReservoir()
  588. displayPumpStatusHighlightMessage()
  589. }
  590. func pumpDeactivatedDidChange() {
  591. displayPumpStatusHighlightMessage(true)
  592. batteryFromPersistence = []
  593. }
  594. func pumpTimeZoneDidChange(_: TimeZone) {
  595. setupCurrentPumpTimezone()
  596. }
  597. }
  598. extension Home.StateModel: CompletionDelegate {
  599. func completionNotifyingDidComplete(_: CompletionNotifying) {
  600. setupPump = false
  601. }
  602. }
  603. extension Home.StateModel: PumpManagerOnboardingDelegate {
  604. func pumpManagerOnboarding(didCreatePumpManager pumpManager: PumpManagerUI) {
  605. provider.apsManager.pumpManager = pumpManager
  606. if let insulinType = pumpManager.status.insulinType {
  607. settingsManager.updateInsulinCurve(insulinType)
  608. }
  609. }
  610. func pumpManagerOnboarding(didOnboardPumpManager _: PumpManagerUI) {
  611. // nothing to do
  612. }
  613. func pumpManagerOnboarding(didPauseOnboarding _: PumpManagerUI) {
  614. // TODO:
  615. }
  616. }