Fix CoreData concurrency violations in tests

feature/sendable

Author: roanutil

Tests/CoreDataRepositoryTests/CoreDataXCTestCase.swift

@@ -10,6 +10,14 @@ import CustomDump
 import Internal
 import XCTest
 
+extension FetchableUnmanagedModel {
+    static func initFromManaged(_ managed: ManagedModel) throws -> Self {
+        try managed.managedObjectContext!.performAndWait {
+            try Self.init(managed: managed)
+        }
+    }
+}
+
 class CoreDataXCTestCase: XCTestCase {
     var _container: NSPersistentContainer?
     var _repositoryContext: NSManagedObjectContext?
@@ -55,6 +63,12 @@ class CoreDataXCTestCase: XCTestCase {
         _repositoryContext = nil
         _repository = nil
     }
+    
+    func mapInContext<I, O>(_ input: I, transform: (I) throws -> O) throws -> O {
+        try repositoryContext().performAndWait {
+            try transform(input)
+        }
+    }
 
     func verify<T>(_ item: T) async throws where T: FetchableUnmanagedModel, T: Equatable {
         let context = try repositoryContext()

Tests/CoreDataRepositoryTests/Create_BatchTests.swift

@@ -431,7 +431,7 @@ final class Create_BatchTests: CoreDataXCTestCase {
             try self.repositoryContext().parent?.save()
             return value
         }
-        try await verify(modelType.init(managed: existingValue))
+        try await verify(mapInContext(existingValue, transform: modelType.init(managed:)))
 
         let result = try await repository()
             .createAtomically(_values)
@@ -514,7 +514,7 @@ final class Create_BatchTests: CoreDataXCTestCase {
             try self.repositoryContext().parent?.save()
             return value
         }
-        try await verify(modelType.init(managed: existingValue))
+        try await verify(mapInContext(existingValue, transform: modelType.init(managed:)))
 
         let result = try await repository()
             .createAtomically(_values)
@@ -597,7 +597,7 @@ final class Create_BatchTests: CoreDataXCTestCase {
             try self.repositoryContext().parent?.save()
             return value
         }
-        try await verify(modelType.init(managed: existingValue))
+        try await verify(mapInContext(existingValue, transform: modelType.init(managed:)))
 
         let result = try await repository()
             .createAtomically(_values)
@@ -680,7 +680,7 @@ final class Create_BatchTests: CoreDataXCTestCase {
             try self.repositoryContext().parent?.save()
             return value
         }
-        try await verify(modelType.init(managed: existingValue))
+        try await verify(mapInContext(existingValue, transform: modelType.init(managed:)))
 
         let result = try await repository()
             .createAtomically(_values)