Merge branch 'determinationStorage' of github.com:polscm32/Open-iAPS into core-data_stable

Signed-off-by: Deniz Cengiz <d.c.cengiz@googlemail.com>

FreeAPS.xcodeproj/project.pbxproj

@@ -283,6 +283,7 @@
 		583684082BD195A700070A60 /* Determination.swift in Sources */ = {isa = PBXBuildFile; fileRef = 583684072BD195A700070A60 /* Determination.swift */; };
 		5837A5302BD2E3C700A5DC04 /* CarbEntryStored+helper.swift in Sources */ = {isa = PBXBuildFile; fileRef = 5837A52F2BD2E3C700A5DC04 /* CarbEntryStored+helper.swift */; };
 		585E2CAE2BE7BF46006ECF1A /* PumpEvent+helper.swift in Sources */ = {isa = PBXBuildFile; fileRef = 585E2CAD2BE7BF46006ECF1A /* PumpEvent+helper.swift */; };
+		5864E8592C42CFAE00294306 /* DeterminationStorage.swift in Sources */ = {isa = PBXBuildFile; fileRef = 5864E8582C42CFAE00294306 /* DeterminationStorage.swift */; };
 		587DA1F62B77F3DD00B28F8A /* SettingsRowView.swift in Sources */ = {isa = PBXBuildFile; fileRef = 587DA1F52B77F3DD00B28F8A /* SettingsRowView.swift */; };
 		5887527C2BD986E1008B081D /* OpenAPSBattery.swift in Sources */ = {isa = PBXBuildFile; fileRef = 5887527B2BD986E1008B081D /* OpenAPSBattery.swift */; };
 		588752842BD9986A008B081D /* OpenAPS_Battery+CoreDataClass.swift in Sources */ = {isa = PBXBuildFile; fileRef = 588752822BD9986A008B081D /* OpenAPS_Battery+CoreDataClass.swift */; };
@@ -477,7 +478,7 @@
 		FE41E4D429463C660047FD55 /* NightscoutStatistics.swift in Sources */ = {isa = PBXBuildFile; fileRef = FE41E4D329463C660047FD55 /* NightscoutStatistics.swift */; };
 		FE41E4D629463EE20047FD55 /* NightscoutPreferences.swift in Sources */ = {isa = PBXBuildFile; fileRef = FE41E4D529463EE20047FD55 /* NightscoutPreferences.swift */; };
 		FE66D16B291F74F8005D6F77 /* Bundle+Extensions.swift in Sources */ = {isa = PBXBuildFile; fileRef = FE66D16A291F74F8005D6F77 /* Bundle+Extensions.swift */; };
-		FEFA5C0F299F810B00765C17 /* Core_Data.xcdatamodeld in Sources */ = {isa = PBXBuildFile; fileRef = FEFA5C0D299F810B00765C17 /* Core_Data.xcdatamodeld */; };
+		FEFA5C0F299F810B00765C17 /* TriosPersistentContainer.xcdatamodeld in Sources */ = {isa = PBXBuildFile; fileRef = FEFA5C0D299F810B00765C17 /* TriosPersistentContainer.xcdatamodeld */; };
 		FEFFA7A22929FE49007B8193 /* UIDevice+Extensions.swift in Sources */ = {isa = PBXBuildFile; fileRef = FEFFA7A12929FE49007B8193 /* UIDevice+Extensions.swift */; };
 /* End PBXBuildFile section */
 
@@ -895,6 +896,7 @@
 		583684072BD195A700070A60 /* Determination.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Determination.swift; sourceTree = "<group>"; };
 		5837A52F2BD2E3C700A5DC04 /* CarbEntryStored+helper.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "CarbEntryStored+helper.swift"; sourceTree = "<group>"; };
 		585E2CAD2BE7BF46006ECF1A /* PumpEvent+helper.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "PumpEvent+helper.swift"; sourceTree = "<group>"; };
+		5864E8582C42CFAE00294306 /* DeterminationStorage.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DeterminationStorage.swift; sourceTree = "<group>"; };
 		587DA1F52B77F3DD00B28F8A /* SettingsRowView.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = SettingsRowView.swift; sourceTree = "<group>"; };
 		5887527B2BD986E1008B081D /* OpenAPSBattery.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = OpenAPSBattery.swift; sourceTree = "<group>"; };
 		588752822BD9986A008B081D /* OpenAPS_Battery+CoreDataClass.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "OpenAPS_Battery+CoreDataClass.swift"; sourceTree = SOURCE_ROOT; };
@@ -1879,6 +1881,7 @@
 				38F3B2EE25ED8E2A005C48AA /* TempTargetsStorage.swift */,
 				CE82E02428E867BA00473A9C /* AlertStorage.swift */,
 				BDC2EA442C3043B000E5BBD0 /* OverrideStorage.swift */,
+				5864E8582C42CFAE00294306 /* DeterminationStorage.swift */,
 			);
 			path = Storage;
 			sourceTree = "<group>";
@@ -2199,7 +2202,7 @@
 		587A54C82BCDCE0F009D38E2 /* Model */ = {
 			isa = PBXGroup;
 			children = (
-				FEFA5C0D299F810B00765C17 /* Core_Data.xcdatamodeld */,
+				FEFA5C0D299F810B00765C17 /* TriosPersistentContainer.xcdatamodeld */,
 				BDF34F8F2C10CF8C00D51995 /* CoreDataStack.swift */,
 				5825D1052BD4056700F36E9B /* Classes+Properties */,
 				5825D1622BD405AE00F36E9B /* Helper */,
@@ -3138,9 +3141,10 @@
 				1BBB001DAD60F3B8CEA4B1C7 /* ISFEditorStateModel.swift in Sources */,
 				F816826028DB441800054060 /* BluetoothTransmitter.swift in Sources */,
 				DD68889D2C386E17006E3C44 /* NightscoutExercise.swift in Sources */,
+				5864E8592C42CFAE00294306 /* DeterminationStorage.swift in Sources */,
 				BD7DA9A72AE06E2B00601B20 /* BolusCalculatorConfigProvider.swift in Sources */,
 				38192E0D261BAF980094D973 /* ConvenienceExtensions.swift in Sources */,
-				FEFA5C0F299F810B00765C17 /* Core_Data.xcdatamodeld in Sources */,
+				FEFA5C0F299F810B00765C17 /* TriosPersistentContainer.xcdatamodeld in Sources */,
 				88AB39B23C9552BD6E0C9461 /* ISFEditorRootView.swift in Sources */,
 				F816825E28DB441200054060 /* HeartBeatManager.swift in Sources */,
 				58F107742BD1A4D000B1A680 /* Determination+helper.swift in Sources */,
@@ -3995,13 +3999,13 @@
 /* End XCSwiftPackageProductDependency section */
 
 /* Begin XCVersionGroup section */
-		FEFA5C0D299F810B00765C17 /* Core_Data.xcdatamodeld */ = {
+		FEFA5C0D299F810B00765C17 /* TriosPersistentContainer.xcdatamodeld */ = {
 			isa = XCVersionGroup;
 			children = (
 				FEFA5C0E299F810B00765C17 /* Core_Data.xcdatamodel */,
 			);
 			currentVersion = FEFA5C0E299F810B00765C17 /* Core_Data.xcdatamodel */;
-			path = Core_Data.xcdatamodeld;
+			path = TriosPersistentContainer.xcdatamodeld;
 			sourceTree = "<group>";
 			versionGroupType = wrapper.xcdatamodel;
 		};

FreeAPS/Sources/APS/APSManager.swift

@@ -67,6 +67,7 @@ final class BaseAPSManager: APSManager, Injectable {
     @Injected() private var tempTargetsStorage: TempTargetsStorage!
     @Injected() private var carbsStorage: CarbsStorage!
     @Injected() private var announcementsStorage: AnnouncementsStorage!
+    @Injected() private var determinationStorage: DeterminationStorage!
     @Injected() private var deviceDataManager: DeviceDataManager!
     @Injected() private var nightscout: NightscoutManager!
     @Injected() private var settingsManager: SettingsManager!
@@ -245,7 +246,9 @@ final class BaseAPSManager: APSManager, Injectable {
 
                 // Open loop completed
                 guard settings.closedLoop else {
-                    await nightscout.uploadStatus()
+                    Task.detached(priority: .low) {
+                        await self.nightscout.uploadStatus()
+                    }
                     loopStatRecord.end = Date()
                     loopStatRecord.duration = roundDouble((loopStatRecord.end! - loopStatRecord.start).timeInterval / 60, 2)
                     loopStatRecord.loopStatus = "Success"
@@ -253,7 +256,9 @@ final class BaseAPSManager: APSManager, Injectable {
                     return
                 }
 
-                await nightscout.uploadStatus()
+                Task.detached(priority: .low) {
+                    await self.nightscout.uploadStatus()
+                }
 
                 // Closed loop - enact Determination
                 try await enactDetermination()
@@ -270,9 +275,7 @@ final class BaseAPSManager: APSManager, Injectable {
 
             // End background task after all the operations are completed
             if let backgroundTask = self.backGroundTaskID {
-                Task {
-                    await UIApplication.shared.endBackgroundTask(backgroundTask)
-                }
+                await UIApplication.shared.endBackgroundTask(backgroundTask)
                 self.backGroundTaskID = .invalid
             }
         }
@@ -665,19 +668,10 @@ final class BaseAPSManager: APSManager, Injectable {
         }
     }
 
-    private func fetchDetermination() async -> NSManagedObjectID? {
-        await CoreDataStack.shared.fetchEntitiesAsync(
-            ofType: OrefDetermination.self,
-            onContext: privateContext,
-            predicate: NSPredicate.predicateFor30MinAgoForDetermination,
-            key: "deliverAt",
-            ascending: false,
-            fetchLimit: 1
-        ).first?.objectID
-    }
-
     private func enactDetermination() async throws {
-        guard let determinationID = await fetchDetermination() else {
+        guard let determinationID = await determinationStorage
+            .fetchLastDeterminationObjectID(predicate: NSPredicate.predicateFor30MinAgoForDetermination).first
+        else {
             throw APSError.apsError(message: "Determination not found")
         }
 
@@ -730,7 +724,10 @@ final class BaseAPSManager: APSManager, Injectable {
     }
 
     private func reportEnacted(wasEnacted: Bool) async {
-        guard let determinationID = await fetchDetermination() else {
+
+        guard let determinationID = await determinationStorage
+            .fetchLastDeterminationObjectID(predicate: NSPredicate.predicateFor30MinAgoForDetermination).first
+        else {
             return
         }
         await privateContext.perform {
@@ -749,6 +746,9 @@ final class BaseAPSManager: APSManager, Injectable {
                 }
 
                 debug(.apsManager, "Determination enacted. Enacted: \(wasEnacted)")
+                Task.detached(priority: .low) {
+                    await self.nightscout.uploadStatus()
+                }
 
                 Task.detached(priority: .low) {
                     await self.nightscout.uploadStatus()

FreeAPS/Sources/APS/Storage/DeterminationStorage.swift

@@ -0,0 +1,66 @@
+import CoreData
+import Foundation
+import Swinject
+
+protocol DeterminationStorage {
+    func fetchLastDeterminationObjectID(predicate: NSPredicate) async -> [NSManagedObjectID]
+    func getForecasts(for determinationID: NSManagedObjectID, in context: NSManagedObjectContext) -> [Forecast]
+    func getForecastValues(for forecastID: NSManagedObjectID, in context: NSManagedObjectContext) -> [ForecastValue]
+}
+
+final class BaseDeterminationStorage: DeterminationStorage, Injectable {
+    private let viewContext = CoreDataStack.shared.persistentContainer.viewContext
+    private let backgroundContext = CoreDataStack.shared.newTaskContext()
+
+    init(resolver: Resolver) {
+        injectServices(resolver)
+    }
+
+    func fetchLastDeterminationObjectID(predicate: NSPredicate) async -> [NSManagedObjectID] {
+        let results = await CoreDataStack.shared.fetchEntitiesAsync(
+            ofType: OrefDetermination.self,
+            onContext: backgroundContext,
+            predicate: predicate,
+            key: "deliverAt",
+            ascending: false,
+            fetchLimit: 1
+        )
+        return await backgroundContext.perform {
+            results.map(\.objectID)
+        }
+    }
+
+    func getForecasts(for determinationID: NSManagedObjectID, in context: NSManagedObjectContext) -> [Forecast] {
+        do {
+            guard let determination = try context.existingObject(with: determinationID) as? OrefDetermination,
+                  let forecastSet = determination.forecasts,
+                  let forecasts = Array(forecastSet) as? [Forecast]
+            else {
+                return []
+            }
+            return forecasts
+        } catch {
+            debugPrint(
+                "Failed \(DebuggingIdentifiers.failed) to fetch OrefDetermination with ID \(determinationID): \(error.localizedDescription)"
+            )
+            return []
+        }
+    }
+
+    func getForecastValues(for forecastID: NSManagedObjectID, in context: NSManagedObjectContext) -> [ForecastValue] {
+        do {
+            guard let forecast = try context.existingObject(with: forecastID) as? Forecast,
+                  let forecastValueSet = forecast.forecastValues,
+                  let forecastValues = Array(forecastValueSet) as? [ForecastValue]
+            else {
+                return []
+            }
+            return forecastValues.sorted(by: { $0.index < $1.index })
+        } catch {
+            debugPrint(
+                "Failed \(DebuggingIdentifiers.failed) to fetch Forecast with ID \(forecastID): \(error.localizedDescription)"
+            )
+            return []
+        }
+    }
+}

FreeAPS/Sources/Assemblies/StorageAssembly.swift

@@ -9,6 +9,7 @@ final class StorageAssembly: Assembly {
         container.register(FileStorage.self) { _ in BaseFileStorage() }
         container.register(PumpHistoryStorage.self) { r in BasePumpHistoryStorage(resolver: r) }
         container.register(OverrideStorage.self) { r in BaseOverrideStorage(resolver: r) }
+        container.register(DeterminationStorage.self) { r in BaseDeterminationStorage(resolver: r) }
         container.register(GlucoseStorage.self) { r in BaseGlucoseStorage(resolver: r) }
         container.register(TempTargetsStorage.self) { r in BaseTempTargetsStorage(resolver: r) }
         container.register(CarbsStorage.self) { r in BaseCarbsStorage(resolver: r) }

FreeAPS/Sources/Modules/Bolus/BolusStateModel.swift

@@ -15,6 +15,7 @@ extension Bolus {
         @Injected() var nsManager: NightscoutManager!
         @Injected() var carbsStorage: CarbsStorage!
         @Injected() var glucoseStorage: GlucoseStorage!
+        @Injected() var determinationStorage: DeterminationStorage!
 
         @Published var predictions: Predictions?
         @Published var amount: Decimal = 0
@@ -619,26 +620,11 @@ extension Bolus.StateModel {
     // Determinations
     private func setupDeterminationsArray() {
         Task {
-            let ids = await self.fetchDeterminations()
+            let ids = await determinationStorage.fetchLastDeterminationObjectID(predicate: NSPredicate.enactedDetermination)
             await updateDeterminationsArray(with: ids)
         }
     }
 
-    private func fetchDeterminations() async -> [NSManagedObjectID] {
-        let results = await CoreDataStack.shared.fetchEntitiesAsync(
-            ofType: OrefDetermination.self,
-            onContext: backgroundContext,
-            predicate: NSPredicate.enactedDetermination,
-            key: "deliverAt",
-            ascending: false,
-            fetchLimit: 1
-        )
-
-        return await backgroundContext.perform {
-            return results.map(\.objectID)
-        }
-    }
-
     @MainActor private func updateDeterminationsArray(with IDs: [NSManagedObjectID]) {
         do {
             let determinationObjects = try IDs.compactMap { id in

FreeAPS/Sources/Modules/Home/HomeStateModel.swift

@@ -10,6 +10,7 @@ extension Home {
         @Injected() var broadcaster: Broadcaster!
         @Injected() var apsManager: APSManager!
         @Injected() var nightscoutManager: NightscoutManager!
+        @Injected() var determinationStorage: DeterminationStorage!
         private let timer = DispatchTimer(timeInterval: 5)
         private(set) var filteredHours = 24
         @Published var manualGlucose: [BloodGlucose] = []
@@ -689,8 +690,9 @@ extension Home.StateModel {
     // Setup Determinations
     private func setupDeterminationsArray() {
         Task {
-            async let enactedObjectIDs = fetchDeterminations(predicate: NSPredicate.enactedDetermination)
-            async let enactedAndNonEnactedObjectIDs = fetchDeterminations(
+            async let enactedObjectIDs = determinationStorage
+                .fetchLastDeterminationObjectID(predicate: NSPredicate.enactedDetermination)
+            async let enactedAndNonEnactedObjectIDs = determinationStorage.fetchLastDeterminationObjectID(
                 predicate: NSPredicate
                     .predicateFor30MinAgoForDetermination
             )
@@ -709,20 +711,6 @@ extension Home.StateModel {
         }
     }
 
-    private func fetchDeterminations(predicate: NSPredicate) async -> [NSManagedObjectID] {
-        let results = await CoreDataStack.shared.fetchEntitiesAsync(
-            ofType: OrefDetermination.self,
-            onContext: context,
-            predicate: predicate,
-            key: "deliverAt",
-            ascending: false,
-            fetchLimit: 1
-        )
-        return await context.perform {
-            results.map(\.objectID)
-        }
-    }
-
     @MainActor private func updateDeterminationsArray(
         with IDs: [NSManagedObjectID],
         keyPath: ReferenceWritableKeyPath<Home.StateModel, [OrefDetermination]>
@@ -967,3 +955,23 @@ extension Home.StateModel {
         }
     }
 }
+
+// MARK: Extension for Main Chart to draw Forecasts
+
+extension Home.StateModel {
+    func preprocessForecastData() -> [(id: UUID, forecast: Forecast, forecastValue: ForecastValue)] {
+        determinationsFromPersistence
+            .compactMap { determination -> NSManagedObjectID? in
+                determination.objectID
+            }
+            .flatMap { determinationID -> [(id: UUID, forecast: Forecast, forecastValue: ForecastValue)] in
+                let forecasts = determinationStorage.getForecasts(for: determinationID, in: viewContext)
+
+                return forecasts.flatMap { forecast in
+                    determinationStorage.getForecastValues(for: forecast.objectID, in: viewContext).map { forecastValue in
+                        (id: UUID(), forecast: forecast, forecastValue: forecastValue)
+                    }
+                }
+            }
+    }
+}

FreeAPS/Sources/Modules/Home/View/Chart/MainChartView.swift

@@ -447,42 +447,8 @@ extension MainChartView {
         return currentTime.addingTimeInterval(timeInterval)
     }
 
-    private func getForecasts(for determinationID: NSManagedObjectID, in context: NSManagedObjectContext) -> [Forecast] {
-        do {
-            guard let determination = try context.existingObject(with: determinationID) as? OrefDetermination,
-                  let forecastSet = determination.forecasts,
-                  let forecasts = Array(forecastSet) as? [Forecast]
-            else {
-                return []
-            }
-            return forecasts
-        } catch {
-            debugPrint(
-                "Failed \(DebuggingIdentifiers.failed) to fetch OrefDetermination with ID \(determinationID): \(error.localizedDescription)"
-            )
-            return []
-        }
-    }
-
-    private func getForecastValues(for forecastID: NSManagedObjectID, in context: NSManagedObjectContext) -> [ForecastValue] {
-        do {
-            guard let forecast = try context.existingObject(with: forecastID) as? Forecast,
-                  let forecastValueSet = forecast.forecastValues,
-                  let forecastValues = Array(forecastValueSet) as? [ForecastValue]
-            else {
-                return []
-            }
-            return forecastValues.sorted(by: { $0.index < $1.index })
-        } catch {
-            debugPrint(
-                "Failed \(DebuggingIdentifiers.failed) to fetch Forecast with ID \(forecastID): \(error.localizedDescription)"
-            )
-            return []
-        }
-    }
-
     private func drawForecasts() -> some ChartContent {
-        let preprocessedData = preprocessForecastData()
+        let preprocessedData = state.preprocessForecastData()
 
         return ForEach(preprocessedData, id: \.id) { tuple in
             let forecastValue = tuple.forecastValue
@@ -496,22 +462,6 @@ extension MainChartView {
         }
     }
 
-    private func preprocessForecastData() -> [(id: UUID, forecast: Forecast, forecastValue: ForecastValue)] {
-        state.determinationsFromPersistence
-            .compactMap { determination -> NSManagedObjectID? in
-                determination.objectID
-            }
-            .flatMap { determinationID -> [(id: UUID, forecast: Forecast, forecastValue: ForecastValue)] in
-                let forecasts = getForecasts(for: determinationID, in: context)
-
-                return forecasts.flatMap { forecast in
-                    getForecastValues(for: forecast.objectID, in: context).map { forecastValue in
-                        (id: UUID(), forecast: forecast, forecastValue: forecastValue)
-                    }
-                }
-            }
-    }
-
     private func drawCurrentTimeMarker() -> some ChartContent {
         RuleMark(
             x: .value(

FreeAPS/Sources/Modules/ISFEditor/ISFEditorStateModel.swift

@@ -3,6 +3,7 @@ import SwiftUI
 
 extension ISFEditor {
     final class StateModel: BaseStateModel<Provider> {
+        @Injected() var determinationStorage: DeterminationStorage!
         @Published var items: [Item] = []
         private(set) var autosensISF: Decimal?
         private(set) var autosensRatio: Decimal = 0
@@ -99,22 +100,11 @@ extension ISFEditor {
 
         private func setupDeterminationsArray() {
             Task {
-                let ids = await self.fetchDeterminations()
+                let ids = await determinationStorage.fetchLastDeterminationObjectID(predicate: NSPredicate.enactedDetermination)
                 await updateDeterminationsArray(with: ids)
             }
         }
 
-        private func fetchDeterminations() async -> [NSManagedObjectID] {
-            CoreDataStack.shared.fetchEntities(
-                ofType: OrefDetermination.self,
-                onContext: context,
-                predicate: NSPredicate.enactedDetermination,
-                key: "deliverAt",
-                ascending: false,
-                fetchLimit: 1
-            ).map(\.objectID)
-        }
-
         @MainActor private func updateDeterminationsArray(with IDs: [NSManagedObjectID]) {
             do {
                 let objects = try IDs.compactMap { id in

FreeAPS/Sources/Services/Network/NightscoutAPI.swift

@@ -438,7 +438,7 @@ extension NightscoutAPI {
         if let secret = secret {
             request.addValue(secret.sha1(), forHTTPHeaderField: "api-secret")
         }
-        request.httpBody = try! JSONCoding.encoder.encode(status)
+        request.httpBody = try JSONCoding.encoder.encode(status)
         request.httpMethod = "POST"
 
         let (data, response) = try await URLSession.shared.data(for: request)
@@ -446,10 +446,6 @@ extension NightscoutAPI {
         guard let httpResponse = response as? HTTPURLResponse, (200 ... 299).contains(httpResponse.statusCode) else {
             throw URLError(.badServerResponse)
         }
-//        return service.run(request)
-//            .retry(Config.retryCount)
-//            .map { _ in () }
-//            .eraseToAnyPublisher()
     }
 
     func uploadPrefs(_ prefs: NightscoutPreferences) -> AnyPublisher<Void, Swift.Error> {

FreeAPS/Sources/Services/Network/NightscoutManager.swift

@@ -255,29 +255,6 @@ final class BaseNightscoutManager: NightscoutManager, Injectable {
         }
     }
 
-//    func uploadStatistics(dailystat: Statistics) {
-//        let stats = NightscoutStatistics(
-//            dailystats: dailystat
-//        )
-//
-//        guard let nightscout = nightscoutAPI, isUploadEnabled else {
-//            return
-//        }
-//
-//        processQueue.async {
-//            nightscout.uploadStats(stats)
-//                .sink { completion in
-//                    switch completion {
-//                    case .finished:
-//                        debug(.nightscout, "Statistics uploaded")
-//                    case let .failure(error):
-//                        debug(.nightscout, error.localizedDescription)
-//                    }
-//                } receiveValue: {}
-//                .store(in: &self.lifetime)
-//        }
-//    }
-
     func uploadPreferences(_ preferences: Preferences) {
         let prefs = NightscoutPreferences(
             preferences: settingsManager.preferences
@@ -358,37 +335,6 @@ final class BaseNightscoutManager: NightscoutManager, Injectable {
         }
     }
 
-//    private func fetchDeterminations() async {
-//        let results = await CoreDataStack.shared.fetchEntitiesAsync(
-//            ofType: OrefDetermination.self,
-//            onContext: backgroundContext,
-//            predicate: NSPredicate.predicateFor30MinAgoForDetermination,
-//            key: "deliverAt",
-//            ascending: false,
-//            fetchLimit: 2
-//        )
-//
-//        let determinationIds = await backgroundContext.perform {
-//            results.map(\.objectID)
-//        }
-//
-//        do {
-//            // Ensure this is performed on the correct context
-//            let determinationObjects: [OrefDetermination] = try await context.perform {
-//                try determinationIds.compactMap { id in
-//                    try self.context.existingObject(with: id) as? OrefDetermination
-//                }
-//            }
-//
-//            // Assign fetched objects to the determination property
-//            determinations = determinationObjects
-//
-//        } catch {
-//            debugPrint(
-//                "NightscoutManager \(#function) \(DebuggingIdentifiers.failed) error while updating the determinations: \(error.localizedDescription)"
-//            )
-//        }
-//    }
 
     private func fetchEnactedDetermination() async -> [OrefDetermination] {
         let enactedDeterminations = await CoreDataStack.shared.fetchEntitiesAsync(
@@ -593,25 +539,13 @@ final class BaseNightscoutManager: NightscoutManager, Injectable {
 
         do {
             try await nightscout.uploadStatus(status)
-            debug(.nightscout, "OpenAPS Status uploaded")
+            debug(.nightscout, "Status uploaded")
         } catch {
             debug(.nightscout, error.localizedDescription)
         }
-//        processQueue.async {
-//            nightscout.uploadStatus(status)
-//                .sink { completion in
-//                    switch completion {
-//                    case .finished:
-//                        debug(.nightscout, "Status uploaded")
-//                    case let .failure(error):
-//                        debug(.nightscout, error.localizedDescription)
-//                    }
-//                } receiveValue: {}
-//                .store(in: &self.lifetime)
-//        }
-
-        Task {
-            await uploadPodAge()
+
+        Task.detached {
+            await self.uploadPodAge()
         }
     }
 

Model/CoreDataStack.swift

@@ -44,7 +44,7 @@ class CoreDataStack: ObservableObject {
 
     /// A persistent container to set up the Core Data Stack
     lazy var persistentContainer: NSPersistentContainer = {
-        let container = NSPersistentContainer(name: "Core_Data")
+        let container = NSPersistentContainer(name: "TriosPersistentContainer")
 
         guard let description = container.persistentStoreDescriptions.first else {
             fatalError("Failed \(DebuggingIdentifiers.failed) to retrieve a persistent store description")