Core Data: run functions in context closure

Author: liamcharger

InfiniLink/BLE/BLEManager.swift

@@ -187,8 +187,10 @@ class BLEManager: NSObject, ObservableObject, CBCentralManagerDelegate, CBPeriph
     }
 
     func removeDevice(device: Device? = nil) {
-        deviceManager.removeDevice(device ?? pairedDevice)
-        unpair(device: device)
+        Task {
+            await deviceManager.removeDevice(device ?? pairedDevice)
+            unpair(device: device)
+        }
     }
 
     func resetDevice() {
@@ -197,12 +199,14 @@ class BLEManager: NSObject, ObservableObject, CBCentralManagerDelegate, CBPeriph
     }
 
     func unpair(device: Device? = nil) {
-        if let pairedDevice {
-            // Delete the device object we have said for this watch
-            deviceManager.removeDevice(device ?? pairedDevice)
+        Task {
+            if let pairedDevice {
+                // Delete the device object we have said for this watch
+                await deviceManager.removeDevice(device ?? pairedDevice)
+            }
+            // Update the list of user watches
+            await deviceManager.fetchAllDevices()
         }
-        // Update the list of user watches
-        deviceManager.fetchAllDevices()
 
         if let first = deviceManager.watches.first, deviceManager.watches.count <= 1 {
             // Switch to the user's next watch

InfiniLink/BLE/DeviceManager.swift

@@ -144,10 +144,8 @@ class DeviceManager: ObservableObject {
         infineatWatchFace.showSideCover = settings.watchFaceInfineat.showSideCover
         device.watchFaceInfineat = infineatWatchFace
 
-        do {
-            try context.save()
-        } catch {
-            log(error.localizedDescription, caller: "DeviceManager - updateSettings")
+        Task {
+            await save()
         }
 
         getSettings()
@@ -159,10 +157,8 @@ class DeviceManager: ObservableObject {
 
         device.name = name
 
-        do {
-            try context.save()
-        } catch {
-            log(error.localizedDescription, caller: "DeviceManager - updateName")
+        Task {
+            await save()
         }
     }
 
@@ -183,24 +179,38 @@ class DeviceManager: ObservableObject {
         }
     }
 
-    func removeDevice(_ device: Device) {
+    func removeDevice(_ device: Device) async {
         do {
-            context.delete(device)
-            try context.save()
+            try await context.perform {
+                self.context.delete(device)
+                try self.context.save()
+            }
         } catch {
             log(error.localizedDescription, caller: "DeviceManager - removeDevice")
         }
     }
 
-    func fetchAllDevices() {
+    func fetchAllDevices() async {
         let fetchRequest: NSFetchRequest<Device> = Device.fetchRequest()
 
         do {
-            self.watches = try context.fetch(fetchRequest)
+            try await context.perform {
+                self.watches = try self.context.fetch(fetchRequest)
+            }
         } catch {
             log("Error fetching devices: \(error.localizedDescription)", caller: "DeviceManager")
         }
     }
+    
+    func save() async {
+        do {
+            try await context.perform {
+                try self.context.save()
+            }
+        } catch {
+            log(error.localizedDescription, caller: "DeviceManager - updateSettings")
+        }
+    }
 }
 
 extension DeviceManager {

InfiniLink/Core/Connect/MyDevicesView.swift

@@ -97,7 +97,9 @@ struct MyDevicesView: View {
                 ConnectView()
             }
             .onAppear {
-                deviceManager.fetchAllDevices()
+                Task {
+                    await deviceManager.fetchAllDevices()
+                }
             }
         }
         .navigationViewStyle(.stack)