HomeStateModel.swift 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758
  1. import Combine
  2. import CoreData
  3. import Foundation
  4. import LoopKitUI
  5. import SwiftDate
  6. import SwiftUI
  7. extension Home {
  8. final class StateModel: BaseStateModel<Provider> {
  9. @Injected() var broadcaster: Broadcaster!
  10. @Injected() var apsManager: APSManager!
  11. @Injected() var nightscoutManager: NightscoutManager!
  12. private let timer = DispatchTimer(timeInterval: 5)
  13. private(set) var filteredHours = 24
  14. @Published var manualGlucose: [BloodGlucose] = []
  15. @Published var announcement: [Announcement] = []
  16. @Published var uploadStats = false
  17. @Published var recentGlucose: BloodGlucose?
  18. @Published var maxBasal: Decimal = 2
  19. @Published var autotunedBasalProfile: [BasalProfileEntry] = []
  20. @Published var basalProfile: [BasalProfileEntry] = []
  21. @Published var tempTargets: [TempTarget] = []
  22. @Published var timerDate = Date()
  23. @Published var closedLoop = false
  24. @Published var pumpSuspended = false
  25. @Published var isLooping = false
  26. @Published var statusTitle = ""
  27. @Published var lastLoopDate: Date = .distantPast
  28. @Published var battery: Battery?
  29. @Published var reservoir: Decimal?
  30. @Published var pumpName = ""
  31. @Published var pumpExpiresAtDate: Date?
  32. @Published var tempTarget: TempTarget?
  33. @Published var setupPump = false
  34. @Published var errorMessage: String? = nil
  35. @Published var errorDate: Date? = nil
  36. @Published var bolusProgress: Decimal?
  37. @Published var eventualBG: Int?
  38. @Published var allowManualTemp = false
  39. @Published var units: GlucoseUnits = .mmolL
  40. @Published var pumpDisplayState: PumpDisplayState?
  41. @Published var alarm: GlucoseAlarm?
  42. @Published var animatedBackground = false
  43. @Published var manualTempBasal = false
  44. @Published var smooth = false
  45. @Published var maxValue: Decimal = 1.2
  46. @Published var lowGlucose: Decimal = 4 / 0.0555
  47. @Published var highGlucose: Decimal = 10 / 0.0555
  48. @Published var overrideUnit: Bool = false
  49. @Published var displayXgridLines: Bool = false
  50. @Published var displayYgridLines: Bool = false
  51. @Published var thresholdLines: Bool = false
  52. @Published var timeZone: TimeZone?
  53. @Published var hours: Int16 = 6
  54. @Published var totalBolus: Decimal = 0
  55. @Published var isStatusPopupPresented: Bool = false
  56. @Published var tins: Bool = false
  57. @Published var isTempTargetActive: Bool = false
  58. @Published var roundedTotalBolus: String = ""
  59. @Published var selectedTab: Int = 0
  60. @Published var waitForSuggestion: Bool = false
  61. @Published var glucoseFromPersistence: [GlucoseStored] = []
  62. @Published var manualGlucoseFromPersistence: [GlucoseStored] = []
  63. @Published var carbsFromPersistence: [CarbEntryStored] = []
  64. @Published var fpusFromPersistence: [CarbEntryStored] = []
  65. @Published var determinationsFromPersistence: [OrefDetermination] = []
  66. @Published var enactedAndNonEnactedDeterminations: [OrefDetermination] = []
  67. @Published var insulinFromPersistence: [PumpEventStored] = []
  68. @Published var tempBasals: [PumpEventStored] = []
  69. var boluses: [PumpEventStored] = []
  70. @Published var suspensions: [PumpEventStored] = []
  71. @Published var batteryFromPersistence: [OpenAPS_Battery] = []
  72. @Published var lastPumpBolus: PumpEventStored?
  73. let context = CoreDataStack.shared.newTaskContext()
  74. let viewContext = CoreDataStack.shared.persistentContainer.viewContext
  75. override func subscribe() {
  76. setupNotification()
  77. setupGlucoseArray()
  78. setupManualGlucoseArray()
  79. setupCarbsArray()
  80. setupFPUsArray()
  81. setupDeterminationsArray()
  82. setupInsulinArray()
  83. setupLastBolus()
  84. setupBatteryArray()
  85. setupPumpSettings()
  86. setupBasalProfile()
  87. setupTempTargets()
  88. setupReservoir()
  89. setupAnnouncements()
  90. setupCurrentPumpTimezone()
  91. uploadStats = settingsManager.settings.uploadStats
  92. units = settingsManager.settings.units
  93. allowManualTemp = !settingsManager.settings.closedLoop
  94. closedLoop = settingsManager.settings.closedLoop
  95. lastLoopDate = apsManager.lastLoopDate
  96. alarm = provider.glucoseStorage.alarm
  97. manualTempBasal = apsManager.isManualTempBasal
  98. setupCurrentTempTarget()
  99. smooth = settingsManager.settings.smoothGlucose
  100. maxValue = settingsManager.preferences.autosensMax
  101. lowGlucose = settingsManager.settings.low
  102. highGlucose = settingsManager.settings.high
  103. overrideUnit = settingsManager.settings.overrideHbA1cUnit
  104. displayXgridLines = settingsManager.settings.xGridLines
  105. displayYgridLines = settingsManager.settings.yGridLines
  106. thresholdLines = settingsManager.settings.rulerMarks
  107. tins = settingsManager.settings.tins
  108. broadcaster.register(GlucoseObserver.self, observer: self)
  109. broadcaster.register(DeterminationObserver.self, observer: self)
  110. broadcaster.register(SettingsObserver.self, observer: self)
  111. broadcaster.register(PumpSettingsObserver.self, observer: self)
  112. broadcaster.register(BasalProfileObserver.self, observer: self)
  113. broadcaster.register(TempTargetsObserver.self, observer: self)
  114. broadcaster.register(PumpReservoirObserver.self, observer: self)
  115. animatedBackground = settingsManager.settings.animatedBackground
  116. timer.eventHandler = {
  117. DispatchQueue.main.async { [weak self] in
  118. self?.timerDate = Date()
  119. self?.setupCurrentTempTarget()
  120. }
  121. }
  122. timer.resume()
  123. apsManager.isLooping
  124. .receive(on: DispatchQueue.main)
  125. .weakAssign(to: \.isLooping, on: self)
  126. .store(in: &lifetime)
  127. apsManager.lastLoopDateSubject
  128. .receive(on: DispatchQueue.main)
  129. .weakAssign(to: \.lastLoopDate, on: self)
  130. .store(in: &lifetime)
  131. apsManager.pumpName
  132. .receive(on: DispatchQueue.main)
  133. .weakAssign(to: \.pumpName, on: self)
  134. .store(in: &lifetime)
  135. apsManager.pumpExpiresAtDate
  136. .receive(on: DispatchQueue.main)
  137. .weakAssign(to: \.pumpExpiresAtDate, on: self)
  138. .store(in: &lifetime)
  139. apsManager.lastError
  140. .receive(on: DispatchQueue.main)
  141. .map { [weak self] error in
  142. self?.errorDate = error == nil ? nil : Date()
  143. if let error = error {
  144. info(.default, error.localizedDescription)
  145. }
  146. return error?.localizedDescription
  147. }
  148. .weakAssign(to: \.errorMessage, on: self)
  149. .store(in: &lifetime)
  150. apsManager.bolusProgress
  151. .receive(on: DispatchQueue.main)
  152. .weakAssign(to: \.bolusProgress, on: self)
  153. .store(in: &lifetime)
  154. apsManager.pumpDisplayState
  155. .receive(on: DispatchQueue.main)
  156. .sink { [weak self] state in
  157. guard let self = self else { return }
  158. self.pumpDisplayState = state
  159. if state == nil {
  160. self.reservoir = nil
  161. self.battery = nil
  162. self.pumpName = ""
  163. self.pumpExpiresAtDate = nil
  164. self.setupPump = false
  165. } else {
  166. self.setupReservoir()
  167. }
  168. }
  169. .store(in: &lifetime)
  170. $setupPump
  171. .sink { [weak self] show in
  172. guard let self = self else { return }
  173. if show, let pumpManager = self.provider.apsManager.pumpManager,
  174. let bluetoothProvider = self.provider.apsManager.bluetoothManager
  175. {
  176. let view = PumpConfig.PumpSettingsView(
  177. pumpManager: pumpManager,
  178. bluetoothManager: bluetoothProvider,
  179. completionDelegate: self,
  180. setupDelegate: self
  181. ).asAny()
  182. self.router.mainSecondaryModalView.send(view)
  183. } else {
  184. self.router.mainSecondaryModalView.send(nil)
  185. }
  186. }
  187. .store(in: &lifetime)
  188. }
  189. func runLoop() {
  190. provider.heartbeatNow()
  191. }
  192. func cancelBolus() {
  193. Task {
  194. await apsManager.cancelBolus()
  195. // perform determine basal sync, otherwise you have could end up with too much iob when opening the calculator again
  196. await apsManager.determineBasalSync()
  197. }
  198. }
  199. @MainActor func cancelProfile(withID id: NSManagedObjectID) async {
  200. do {
  201. let profileToCancel = try viewContext.existingObject(with: id) as? OverrideStored
  202. profileToCancel?.enabled = false
  203. profileToCancel?.date = Date()
  204. guard viewContext.hasChanges else { return }
  205. try viewContext.save()
  206. } catch {
  207. debugPrint("\(DebuggingIdentifiers.failed) \(#file) \(#function) Failed to cancel Profile")
  208. }
  209. }
  210. func calculateTINS() -> String {
  211. let date = Date()
  212. let calendar = Calendar.current
  213. let offset = hours
  214. var offsetComponents = DateComponents()
  215. offsetComponents.hour = -Int(offset)
  216. let startTime = calendar.date(byAdding: offsetComponents, to: date)!
  217. let bolusesForCurrentDay = boluses.filter { $0.timestamp ?? .distantPast >= startTime }
  218. let totalBolus = bolusesForCurrentDay.map { Double($0.bolus?.amount ?? 0.0) }.reduce(0.0, +)
  219. roundedTotalBolus = Decimal(round(100 * Double(totalBolus)) / 100).formatted()
  220. return roundedTotalBolus
  221. }
  222. private func setupPumpSettings() {
  223. DispatchQueue.main.async { [weak self] in
  224. guard let self = self else { return }
  225. self.maxBasal = self.provider.pumpSettings().maxBasal
  226. }
  227. }
  228. private func setupBasalProfile() {
  229. DispatchQueue.main.async { [weak self] in
  230. guard let self = self else { return }
  231. self.autotunedBasalProfile = self.provider.autotunedBasalProfile()
  232. self.basalProfile = self.provider.basalProfile()
  233. }
  234. }
  235. private func setupTempTargets() {
  236. DispatchQueue.main.async { [weak self] in
  237. guard let self = self else { return }
  238. self.manualTempBasal = self.apsManager.isManualTempBasal
  239. self.tempTargets = self.provider.tempTargets(hours: self.filteredHours)
  240. }
  241. }
  242. private func setupAnnouncements() {
  243. DispatchQueue.main.async { [weak self] in
  244. guard let self = self else { return }
  245. self.announcement = self.provider.announcement(self.filteredHours)
  246. }
  247. }
  248. private func setupReservoir() {
  249. DispatchQueue.main.async { [weak self] in
  250. guard let self = self else { return }
  251. self.reservoir = self.provider.pumpReservoir()
  252. }
  253. }
  254. private func setupCurrentTempTarget() {
  255. tempTarget = provider.tempTarget()
  256. }
  257. private func setupCurrentPumpTimezone() {
  258. DispatchQueue.main.async { [weak self] in
  259. guard let self = self else { return }
  260. self.timeZone = self.provider.pumpTimeZone()
  261. }
  262. }
  263. func openCGM() {
  264. guard var url = nightscoutManager.cgmURL else { return }
  265. switch url.absoluteString {
  266. case "http://127.0.0.1:1979":
  267. url = URL(string: "spikeapp://")!
  268. case "http://127.0.0.1:17580":
  269. url = URL(string: "diabox://")!
  270. case CGMType.libreTransmitter.appURL?.absoluteString:
  271. showModal(for: .libreConfig)
  272. default: break
  273. }
  274. UIApplication.shared.open(url, options: [:], completionHandler: nil)
  275. }
  276. func infoPanelTTPercentage(_ hbt_: Double, _ target: Decimal) -> Decimal {
  277. guard hbt_ != 0 || target != 0 else {
  278. return 0
  279. }
  280. let c = Decimal(hbt_ - 100)
  281. let ratio = min(c / (target + c - 100), maxValue)
  282. return (ratio * 100)
  283. }
  284. }
  285. }
  286. extension Home.StateModel:
  287. GlucoseObserver,
  288. DeterminationObserver,
  289. SettingsObserver,
  290. PumpSettingsObserver,
  291. BasalProfileObserver,
  292. TempTargetsObserver,
  293. PumpReservoirObserver,
  294. PumpTimeZoneObserver
  295. {
  296. func glucoseDidUpdate(_: [BloodGlucose]) {
  297. // setupGlucose()
  298. }
  299. func determinationDidUpdate(_: Determination) {
  300. waitForSuggestion = false
  301. }
  302. func settingsDidChange(_ settings: FreeAPSSettings) {
  303. allowManualTemp = !settings.closedLoop
  304. uploadStats = settingsManager.settings.uploadStats
  305. closedLoop = settingsManager.settings.closedLoop
  306. units = settingsManager.settings.units
  307. animatedBackground = settingsManager.settings.animatedBackground
  308. manualTempBasal = apsManager.isManualTempBasal
  309. smooth = settingsManager.settings.smoothGlucose
  310. lowGlucose = settingsManager.settings.low
  311. highGlucose = settingsManager.settings.high
  312. overrideUnit = settingsManager.settings.overrideHbA1cUnit
  313. displayXgridLines = settingsManager.settings.xGridLines
  314. displayYgridLines = settingsManager.settings.yGridLines
  315. thresholdLines = settingsManager.settings.rulerMarks
  316. tins = settingsManager.settings.tins
  317. }
  318. // func pumpHistoryDidUpdate(_: [PumpHistoryEvent]) {
  319. // setupAnnouncements()
  320. // }
  321. func pumpSettingsDidChange(_: PumpSettings) {
  322. setupPumpSettings()
  323. }
  324. func basalProfileDidChange(_: [BasalProfileEntry]) {
  325. setupBasalProfile()
  326. }
  327. func tempTargetsDidUpdate(_: [TempTarget]) {
  328. setupTempTargets()
  329. }
  330. func pumpReservoirDidChange(_: Decimal) {
  331. setupReservoir()
  332. }
  333. func pumpTimeZoneDidChange(_: TimeZone) {
  334. setupCurrentPumpTimezone()
  335. }
  336. }
  337. extension Home.StateModel: CompletionDelegate {
  338. func completionNotifyingDidComplete(_: CompletionNotifying) {
  339. setupPump = false
  340. }
  341. }
  342. extension Home.StateModel: PumpManagerOnboardingDelegate {
  343. func pumpManagerOnboarding(didCreatePumpManager pumpManager: PumpManagerUI) {
  344. provider.apsManager.pumpManager = pumpManager
  345. if let insulinType = pumpManager.status.insulinType {
  346. settingsManager.updateInsulinCurve(insulinType)
  347. }
  348. }
  349. func pumpManagerOnboarding(didOnboardPumpManager _: PumpManagerUI) {
  350. // nothing to do
  351. }
  352. func pumpManagerOnboarding(didPauseOnboarding _: PumpManagerUI) {
  353. // TODO:
  354. }
  355. }
  356. // MARK: - Setup Core Data observation
  357. extension Home.StateModel {
  358. /// listens for the notifications sent when the managedObjectContext has saved!
  359. func setupNotification() {
  360. Foundation.NotificationCenter.default.addObserver(
  361. self,
  362. selector: #selector(contextDidSave(_:)),
  363. name: Notification.Name.NSManagedObjectContextDidSave,
  364. object: nil
  365. )
  366. /// custom notification that is sent when a batch insert of glucose objects is done
  367. Foundation.NotificationCenter.default.addObserver(
  368. self,
  369. selector: #selector(handleBatchInsert),
  370. name: .didPerformBatchInsert,
  371. object: nil
  372. )
  373. }
  374. /// determine the actions when the context has changed
  375. ///
  376. /// its done on a background thread and after that the UI gets updated on the main thread
  377. @objc private func contextDidSave(_ notification: Notification) {
  378. guard let userInfo = notification.userInfo else { return }
  379. Task { [weak self] in
  380. await self?.processUpdates(userInfo: userInfo)
  381. }
  382. }
  383. @objc private func handleBatchInsert() {
  384. setupGlucoseArray()
  385. }
  386. private func processUpdates(userInfo: [AnyHashable: Any]) async {
  387. var objects = Set((userInfo[NSInsertedObjectsKey] as? Set<NSManagedObject>) ?? [])
  388. objects.formUnion((userInfo[NSUpdatedObjectsKey] as? Set<NSManagedObject>) ?? [])
  389. objects.formUnion((userInfo[NSDeletedObjectsKey] as? Set<NSManagedObject>) ?? [])
  390. let glucoseUpdates = objects.filter { $0 is GlucoseStored }
  391. let manualGlucoseUpdates = objects.filter { $0 is GlucoseStored }
  392. let determinationUpdates = objects.filter { $0 is OrefDetermination }
  393. let carbUpdates = objects.filter { $0 is CarbEntryStored }
  394. let insulinUpdates = objects.filter { $0 is PumpEventStored }
  395. let batteryUpdates = objects.filter { $0 is OpenAPS_Battery }
  396. DispatchQueue.global(qos: .background).async {
  397. if !glucoseUpdates.isEmpty {
  398. self.setupGlucoseArray()
  399. }
  400. if !manualGlucoseUpdates.isEmpty {
  401. self.setupManualGlucoseArray()
  402. }
  403. if !determinationUpdates.isEmpty {
  404. self.setupDeterminationsArray()
  405. }
  406. if !carbUpdates.isEmpty {
  407. self.setupCarbsArray()
  408. self.setupFPUsArray()
  409. }
  410. if !insulinUpdates.isEmpty {
  411. self.setupInsulinArray()
  412. self.setupLastBolus()
  413. }
  414. if !batteryUpdates.isEmpty {
  415. self.setupBatteryArray()
  416. }
  417. }
  418. }
  419. }
  420. // MARK: - Handle Core Data changes and update Arrays to display them in the UI
  421. extension Home.StateModel {
  422. // Setup Glucose
  423. private func setupGlucoseArray() {
  424. Task {
  425. let ids = await self.fetchGlucose()
  426. await updateGlucoseArray(with: ids)
  427. }
  428. }
  429. private func fetchGlucose() async -> [NSManagedObjectID] {
  430. CoreDataStack.shared.fetchEntities(
  431. ofType: GlucoseStored.self,
  432. onContext: context,
  433. predicate: NSPredicate.glucose,
  434. key: "date",
  435. ascending: false,
  436. fetchLimit: 288
  437. ).map(\.objectID)
  438. }
  439. @MainActor private func updateGlucoseArray(with IDs: [NSManagedObjectID]) {
  440. do {
  441. let glucoseObjects = try IDs.compactMap { id in
  442. try viewContext.existingObject(with: id) as? GlucoseStored
  443. }
  444. glucoseFromPersistence = glucoseObjects
  445. } catch {
  446. debugPrint(
  447. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the glucose array: \(error.localizedDescription)"
  448. )
  449. }
  450. }
  451. // Setup Manual Glucose
  452. private func setupManualGlucoseArray() {
  453. Task {
  454. let ids = await self.fetchManualGlucose()
  455. await updateManualGlucoseArray(with: ids)
  456. }
  457. }
  458. private func fetchManualGlucose() async -> [NSManagedObjectID] {
  459. CoreDataStack.shared.fetchEntities(
  460. ofType: GlucoseStored.self,
  461. onContext: context,
  462. predicate: NSPredicate.manualGlucose,
  463. key: "date",
  464. ascending: false,
  465. fetchLimit: 288
  466. ).map(\.objectID)
  467. }
  468. @MainActor private func updateManualGlucoseArray(with IDs: [NSManagedObjectID]) {
  469. do {
  470. let manualGlucoseObjects = try IDs.compactMap { id in
  471. try viewContext.existingObject(with: id) as? GlucoseStored
  472. }
  473. manualGlucoseFromPersistence = manualGlucoseObjects
  474. } catch {
  475. debugPrint(
  476. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the manual glucose array: \(error.localizedDescription)"
  477. )
  478. }
  479. }
  480. // Setup Carbs
  481. private func setupCarbsArray() {
  482. Task {
  483. let ids = await self.fetchCarbs()
  484. await updateCarbsArray(with: ids)
  485. }
  486. }
  487. private func fetchCarbs() async -> [NSManagedObjectID] {
  488. CoreDataStack.shared.fetchEntities(
  489. ofType: CarbEntryStored.self,
  490. onContext: context,
  491. predicate: NSPredicate.carbsForChart,
  492. key: "date",
  493. ascending: false
  494. ).map(\.objectID)
  495. }
  496. @MainActor private func updateCarbsArray(with IDs: [NSManagedObjectID]) {
  497. do {
  498. let carbObjects = try IDs.compactMap { id in
  499. try viewContext.existingObject(with: id) as? CarbEntryStored
  500. }
  501. carbsFromPersistence = carbObjects
  502. } catch {
  503. debugPrint(
  504. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the carbs array: \(error.localizedDescription)"
  505. )
  506. }
  507. }
  508. // Setup FPUs
  509. private func setupFPUsArray() {
  510. Task {
  511. let ids = await self.fetchFPUs()
  512. await updateFPUsArray(with: ids)
  513. }
  514. }
  515. private func fetchFPUs() async -> [NSManagedObjectID] {
  516. CoreDataStack.shared.fetchEntities(
  517. ofType: CarbEntryStored.self,
  518. onContext: context,
  519. predicate: NSPredicate.fpusForChart,
  520. key: "date",
  521. ascending: false
  522. ).map(\.objectID)
  523. }
  524. @MainActor private func updateFPUsArray(with IDs: [NSManagedObjectID]) {
  525. do {
  526. let fpuObjects = try IDs.compactMap { id in
  527. try viewContext.existingObject(with: id) as? CarbEntryStored
  528. }
  529. fpusFromPersistence = fpuObjects
  530. } catch {
  531. debugPrint(
  532. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the fpus array: \(error.localizedDescription)"
  533. )
  534. }
  535. }
  536. // Setup Determinations
  537. private func setupDeterminationsArray() {
  538. Task {
  539. let enactedObjectIDs = await fetchDeterminations(predicate: NSPredicate.enactedDetermination)
  540. let enactedAndNonEnactedObjectIDs = await fetchDeterminations(
  541. predicate: NSPredicate
  542. .predicateFor30MinAgoForDetermination
  543. )
  544. await updateDeterminationsArray(with: enactedObjectIDs, keyPath: \.determinationsFromPersistence)
  545. await updateDeterminationsArray(with: enactedAndNonEnactedObjectIDs, keyPath: \.enactedAndNonEnactedDeterminations)
  546. }
  547. }
  548. private func fetchDeterminations(predicate: NSPredicate) async -> [NSManagedObjectID] {
  549. CoreDataStack.shared.fetchEntities(
  550. ofType: OrefDetermination.self,
  551. onContext: context,
  552. predicate: predicate,
  553. key: "deliverAt",
  554. ascending: false,
  555. fetchLimit: 1
  556. ).map(\.objectID)
  557. }
  558. @MainActor private func updateDeterminationsArray(
  559. with IDs: [NSManagedObjectID],
  560. keyPath: ReferenceWritableKeyPath<Home.StateModel, [OrefDetermination]>
  561. ) {
  562. do {
  563. let determinationObjects = try IDs.compactMap { id in
  564. try viewContext.existingObject(with: id) as? OrefDetermination
  565. }
  566. self[keyPath: keyPath] = determinationObjects
  567. } catch {
  568. debugPrint(
  569. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the determinations array: \(error.localizedDescription)"
  570. )
  571. }
  572. }
  573. // Setup Insulin
  574. private func setupInsulinArray() {
  575. Task {
  576. let ids = await self.fetchInsulin()
  577. await updateInsulinArray(with: ids)
  578. }
  579. }
  580. private func fetchInsulin() async -> [NSManagedObjectID] {
  581. CoreDataStack.shared.fetchEntities(
  582. ofType: PumpEventStored.self,
  583. onContext: context,
  584. predicate: NSPredicate.pumpHistoryLast24h,
  585. key: "timestamp",
  586. ascending: true
  587. ).map(\.objectID)
  588. }
  589. @MainActor private func updateInsulinArray(with IDs: [NSManagedObjectID]) {
  590. do {
  591. let insulinObjects = try IDs.compactMap { id in
  592. try viewContext.existingObject(with: id) as? PumpEventStored
  593. }
  594. insulinFromPersistence = insulinObjects
  595. // filter tempbasals
  596. manualTempBasal = apsManager.isManualTempBasal
  597. tempBasals = insulinFromPersistence.filter({ $0.tempBasal != nil })
  598. // suspension and resume events
  599. suspensions = insulinFromPersistence
  600. .filter({ $0.type == EventType.pumpSuspend.rawValue || $0.type == EventType.pumpResume.rawValue })
  601. let lastSuspension = suspensions.last
  602. pumpSuspended = tempBasals.last?.timestamp ?? Date() > lastSuspension?.timestamp ?? .distantPast && lastSuspension?
  603. .type == EventType.pumpSuspend
  604. .rawValue
  605. } catch {
  606. debugPrint(
  607. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the insulin array: \(error.localizedDescription)"
  608. )
  609. }
  610. }
  611. // Setup Last Bolus to display the bolus progress bar
  612. // The predicate filters out all external boluses to prevent the progress bar from displaying the amount of an external bolus when an external bolus is added after a pump bolus
  613. private func setupLastBolus() {
  614. Task {
  615. guard let id = await self.fetchLastBolus() else { return }
  616. await updateLastBolus(with: id)
  617. }
  618. }
  619. private func fetchLastBolus() async -> NSManagedObjectID? {
  620. CoreDataStack.shared.fetchEntities(
  621. ofType: PumpEventStored.self,
  622. onContext: context,
  623. predicate: NSPredicate.lastPumpBolus,
  624. key: "timestamp",
  625. ascending: false,
  626. fetchLimit: 1
  627. ).map(\.objectID).first
  628. }
  629. @MainActor private func updateLastBolus(with ID: NSManagedObjectID) {
  630. do {
  631. lastPumpBolus = try viewContext.existingObject(with: ID) as? PumpEventStored
  632. } catch {
  633. debugPrint(
  634. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the insulin array: \(error.localizedDescription)"
  635. )
  636. }
  637. }
  638. // Setup Battery
  639. private func setupBatteryArray() {
  640. Task {
  641. let ids = await self.fetchBattery()
  642. await updateBatteryArray(with: ids)
  643. }
  644. }
  645. private func fetchBattery() async -> [NSManagedObjectID] {
  646. CoreDataStack.shared.fetchEntities(
  647. ofType: OpenAPS_Battery.self,
  648. onContext: context,
  649. predicate: NSPredicate.predicateFor30MinAgo,
  650. key: "date",
  651. ascending: false
  652. ).map(\.objectID)
  653. }
  654. @MainActor private func updateBatteryArray(with IDs: [NSManagedObjectID]) {
  655. do {
  656. let batteryObjects = try IDs.compactMap { id in
  657. try viewContext.existingObject(with: id) as? OpenAPS_Battery
  658. }
  659. batteryFromPersistence = batteryObjects
  660. } catch {
  661. debugPrint(
  662. "Home State: \(#function) \(DebuggingIdentifiers.failed) error while updating the battery array: \(error.localizedDescription)"
  663. )
  664. }
  665. }
  666. }