AlarmTask.swift 4.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. //
  2. // AlarmTask.swift
  3. // LoopFollow
  4. //
  5. // Created by Jonas Björkert on 2025-01-12.
  6. // Copyright © 2025 Jon Fawcett. All rights reserved.
  7. //
  8. import Foundation
  9. extension MainViewController {
  10. func scheduleAlarmTask(initialDelay: TimeInterval = 30) {
  11. let firstRun = Date().addingTimeInterval(initialDelay)
  12. TaskScheduler.shared.scheduleTask(id: .alarmCheck, nextRun: firstRun) { [weak self] in
  13. guard let self = self else { return }
  14. self.alarmTaskAction()
  15. }
  16. }
  17. func alarmTaskAction() {
  18. DispatchQueue.main.async {
  19. let latestOverrideStart = self.overrideGraphData.last?.date
  20. let latestOverrideEnd = self.overrideGraphData.last?.endDate
  21. let latestTempTargetStart = self.tempTargetGraphData.last?.date
  22. let latestTempTargetEnd = self.tempTargetGraphData.last?.endDate
  23. let recBolus = UserDefaultsRepository.deviceRecBolus.value
  24. let COB = self.latestCOB?.value
  25. let sensorInsertedAt = UserDefaultsRepository.alertSageInsertTime.value
  26. let alarmData = AlarmData(
  27. bgReadings: self.bgData
  28. .suffix(24)
  29. .map { GlucoseValue(sgv: $0.sgv, date: Date(timeIntervalSince1970: $0.date)) }, /// These are oldest .. newest
  30. predictionData: self.predictionData
  31. .prefix(12)
  32. .map { GlucoseValue(sgv: $0.sgv, date: Date(timeIntervalSince1970: $0.date)) }, /// These are oldest .. newest, Predictions not currently available for Trio
  33. expireDate: Storage.shared.expirationDate.value,
  34. lastLoopTime: UserDefaultsRepository.alertLastLoopTime.value,
  35. latestOverrideStart: latestOverrideStart,
  36. latestOverrideEnd: latestOverrideEnd,
  37. latestTempTargetStart: latestTempTargetStart,
  38. latestTempTargetEnd: latestTempTargetEnd,
  39. recBolus: recBolus,
  40. COB: COB,
  41. sageInsertTime: sensorInsertedAt
  42. )
  43. let finalAlarmData: AlarmData
  44. if Observable.shared.debug.value {
  45. self.saveLatestAlarmDataToFile(alarmData)
  46. finalAlarmData = self.loadTestAlarmData() ?? alarmData
  47. } else {
  48. finalAlarmData = alarmData
  49. }
  50. LogManager.shared.log(category: .alarm, message: "Checking alarms based on \(finalAlarmData)", isDebug: true)
  51. AlarmManager.shared.checkAlarms(data: finalAlarmData)
  52. TaskScheduler.shared.rescheduleTask(id: .alarmCheck, to: Date().addingTimeInterval(60))
  53. }
  54. }
  55. func saveLatestAlarmDataToFile(_ alarmData: AlarmData) {
  56. let encoder = JSONEncoder()
  57. encoder.dateEncodingStrategy = .iso8601
  58. do {
  59. let data = try encoder.encode(alarmData)
  60. let url = FileManager.default.urls(for: .documentDirectory, in: .userDomainMask).first!.appendingPathComponent("latestAlarmData.json")
  61. try data.write(to: url)
  62. } catch {
  63. LogManager.shared.log(category: .alarm, message: "Failed to save latest AlarmData: \(error)", isDebug: true)
  64. }
  65. }
  66. func loadTestAlarmData() -> AlarmData? {
  67. let fileManager = FileManager.default
  68. let url = fileManager.urls(for: .documentDirectory, in: .userDomainMask).first!.appendingPathComponent("testAlarmData.json")
  69. if fileManager.fileExists(atPath: url.path) {
  70. do {
  71. let data = try Data(contentsOf: url)
  72. let decoder = JSONDecoder()
  73. decoder.dateDecodingStrategy = .iso8601
  74. let alarmData = try decoder.decode(AlarmData.self, from: data)
  75. LogManager.shared.log(category: .alarm, message: "Loaded test AlarmData from \(url.path)", isDebug: true)
  76. return alarmData
  77. } catch {
  78. LogManager.shared.log(category: .alarm, message: "Failed to load test AlarmData: \(error)", isDebug: true)
  79. }
  80. }
  81. return nil
  82. }
  83. }