TrioRemoteControl+Override.swift 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. import CoreData
  2. import Foundation
  3. import UIKit
  4. extension TrioRemoteControl {
  5. @MainActor internal func handleCancelOverrideCommand(_ payload: CommandPayload) async {
  6. await disableAllActiveOverrides()
  7. await logSuccess(
  8. "Remote command processed successfully. \(payload.humanReadableDescription())",
  9. payload: payload,
  10. customNotificationMessage: "Override canceled"
  11. )
  12. }
  13. @MainActor internal func handleStartOverrideCommand(_ payload: CommandPayload) async {
  14. do {
  15. guard let overrideName = payload.overrideName, !overrideName.isEmpty else {
  16. await logError("Command rejected: override name is missing.", payload: payload)
  17. return
  18. }
  19. let presetIDs = try await overrideStorage.fetchForOverridePresets()
  20. let presets = try presetIDs.compactMap { try viewContext.existingObject(with: $0) as? OverrideStored }
  21. if let preset = presets.first(where: { $0.name == overrideName }) {
  22. await enactOverridePreset(preset: preset, payload: payload)
  23. } else {
  24. await logError("Command rejected: override preset '\(overrideName)' not found.", payload: payload)
  25. }
  26. } catch {
  27. debug(.remoteControl, "\(DebuggingIdentifiers.failed) Failed to handle start override command: \(error)")
  28. await logError("Command failed: \(error.localizedDescription)", payload: payload)
  29. }
  30. }
  31. @MainActor private func enactOverridePreset(preset: OverrideStored, payload: CommandPayload) async {
  32. preset.enabled = true
  33. preset.date = Date()
  34. preset.isUploadedToNS = false
  35. await disableAllActiveOverrides(except: preset.objectID)
  36. do {
  37. if viewContext.hasChanges {
  38. try viewContext.save()
  39. Foundation.NotificationCenter.default.post(name: .willUpdateOverrideConfiguration, object: nil)
  40. await awaitNotification(.didUpdateOverrideConfiguration)
  41. await logSuccess(
  42. "Remote command processed successfully. \(payload.humanReadableDescription())",
  43. payload: payload,
  44. customNotificationMessage: "Override started"
  45. )
  46. }
  47. } catch {
  48. debug(.remoteControl, "Failed to enact override preset: \(error)")
  49. await logError("Failed to enact override preset: \(error.localizedDescription)", payload: payload)
  50. }
  51. }
  52. @MainActor private func disableAllActiveOverrides(except overrideID: NSManagedObjectID? = nil) async {
  53. do {
  54. let ids = try await overrideStorage.loadLatestOverrideConfigurations(fetchLimit: 0)
  55. let didPostNotification = try await viewContext.perform { () -> Bool in
  56. let results = try ids.compactMap { try self.viewContext.existingObject(with: $0) as? OverrideStored }
  57. guard !results.isEmpty else { return false }
  58. for canceledOverride in results where canceledOverride.enabled {
  59. if let overrideID = overrideID, canceledOverride.objectID == overrideID { continue }
  60. let newOverrideRunStored = OverrideRunStored(context: self.viewContext)
  61. newOverrideRunStored.id = UUID()
  62. newOverrideRunStored.name = canceledOverride.name
  63. newOverrideRunStored.startDate = canceledOverride.date ?? .distantPast
  64. newOverrideRunStored.endDate = Date()
  65. newOverrideRunStored
  66. .target = NSDecimalNumber(decimal: self.overrideStorage.calculateTarget(override: canceledOverride))
  67. newOverrideRunStored.override = canceledOverride
  68. newOverrideRunStored.isUploadedToNS = false
  69. canceledOverride.enabled = false
  70. canceledOverride.isUploadedToNS = false
  71. }
  72. if self.viewContext.hasChanges {
  73. try self.viewContext.save()
  74. Foundation.NotificationCenter.default.post(name: .willUpdateOverrideConfiguration, object: nil)
  75. return true
  76. } else {
  77. return false
  78. }
  79. }
  80. if didPostNotification { await awaitNotification(.didUpdateOverrideConfiguration) }
  81. } catch {
  82. debug(.remoteControl, "\(DebuggingIdentifiers.failed) Failed to disable active overrides: \(error)")
  83. }
  84. }
  85. }