Adding Queryable

Example/Sources/ChildViewModel.swift

@@ -0,0 +1,28 @@
+//
+//  ChildViewModel.swift
+//  DataThespian
+//
+//  Created by Leo Dion on 10/16/24.
+//
+
+import DataThespian
+import Foundation
+import SwiftData
+
+internal struct ChildViewModel: Sendable, Identifiable {
+  internal let model: Model<ItemChild>
+  internal let timestamp: Date
+
+  internal var id: PersistentIdentifier {
+    model.persistentIdentifier
+  }
+
+  private init(model: Model<ItemChild>, timestamp: Date) {
+    self.model = model
+    self.timestamp = timestamp
+  }
+
+  internal init(child: ItemChild) {
+    self.init(model: .init(child), timestamp: child.timestamp)
+  }
+}

Example/Sources/ContentObject.swift

@@ -17,17 +17,17 @@ internal class ContentObject {
   private var databaseChangeCancellable: AnyCancellable?
   private var databaseChangeSubscription: AnyCancellable?
   private var database: (any Database)?
-  internal private(set) var items = [ItemModel]()
-  internal var selectedItemsID: Set<ItemModel.ID> = []
+  internal private(set) var items = [ItemViewModel]()
+  internal var selectedItemsID: Set<ItemViewModel.ID> = []
   private var newItem: AnyCancellable?
   internal var error: (any Error)?
 
-  internal var selectedItems: [ItemModel] {
+  internal var selectedItems: [ItemViewModel] {
     let selectedItemsID = self.selectedItemsID
-    let items: [ItemModel]
+    let items: [ItemViewModel]
     do {
       items = try self.items.filter(
-        #Predicate<ItemModel> {
+        #Predicate<ItemViewModel> {
           selectedItemsID.contains($0.id)
         }
       )
@@ -49,17 +49,7 @@ internal class ContentObject {
   private static func deleteModels(_ models: [Model<Item>], from database: (any Database))
     async throws
   {
-    try await database.withModelContext { modelContext in
-      let items: [Item] = models.compactMap {
-        modelContext.model(for: $0.persistentIdentifier) as? Item
-      }
-      dump(items.first?.persistentModelID)
-      assert(items.count == models.count)
-      for item in items {
-        modelContext.delete(item)
-      }
-      try modelContext.save()
-    }
+    try await database.deleteModels(models)
   }
 
   private func beginUpdateItems() {
@@ -76,10 +66,10 @@ internal class ContentObject {
     guard let database else {
       return
     }
-    self.items = try await database.withModelContext({ modelContext in
+    self.items = try await database.withModelContext { modelContext in
       let items = try modelContext.fetch(FetchDescriptor<Item>())
-      return items.map(ItemModel.init)
-    })
+      return items.map(ItemViewModel.init)
+    }
   }
 
   internal func initialize(
@@ -114,20 +104,46 @@ internal class ContentObject {
     }
     Task {
       try await Self.deleteModels(models, from: database)
+      try await database.save()
     }
   }
 
-  internal func addItem(withDate date: Date = .init()) {
+  internal func addChild(to item: ItemViewModel) {
     guard let database else {
       return
     }
     Task {
+      let timestamp = Date()
+      let childModel = await database.insert {
+        ItemChild(timestamp: timestamp)
+      }
+
       try await database.withModelContext { modelContext in
-        let newItem = Item(timestamp: date)
-        modelContext.insert(newItem)
-        dump(newItem.persistentModelID)
+        let item = try modelContext.existingModel(for: item.model)
+        let child = try modelContext.existingModel(for: childModel)
+        assert(child != nil && item != nil)
+        child?.parent = item
         try modelContext.save()
       }
     }
   }
+
+  internal func addItem(withDate date: Date = .init()) {
+    guard let database else {
+      return
+    }
+    Task {
+      let insertedModel = await database.insert { Item(timestamp: date) }
+      print("inserted:", insertedModel.isTemporary)
+      try await database.save()
+      let savedModel = try await database.get(
+        for: .predicate(
+          #Predicate<Item> {
+            $0.timestamp == date
+          }
+        )
+      )
+      print("saved:", savedModel.isTemporary)
+    }
+  }
 }

Example/Sources/ContentView.swift

@@ -41,7 +41,7 @@ internal struct ContentView: View {
       if selectedItems.count > 1 {
         Text("Multiple Selected")
       } else if let item = selectedItems.first {
-        Text("Item at \(item.timestamp, format: Date.FormatStyle(date: .numeric, time: .standard))")
+        ItemChildView(object: object, item: item)
       } else {
         Text("Select an item")
       }

Example/Sources/Item.swift

@@ -5,12 +5,20 @@
 //  Created by Leo Dion on 10/10/24.
 //
 
+import DataThespian
 import Foundation
 import SwiftData
 
 @Model
-internal final class Item {
+internal final class Item: Unique {
+  internal enum Keys: UniqueKeys {
+    internal typealias Model = Item
+    internal static let primary = timestamp
+    internal static let timestamp = keyPath(\.timestamp)
+  }
+
   internal private(set) var timestamp: Date
+  internal private(set) var children: [ItemChild]?
 
   internal init(timestamp: Date) {
     self.timestamp = timestamp

Example/Sources/ItemChild.swift

@@ -0,0 +1,19 @@
+//
+//  ItemChild.swift
+//  DataThespian
+//
+//  Created by Leo Dion on 10/16/24.
+//
+import Foundation
+import SwiftData
+
+@Model
+internal final class ItemChild {
+  internal var parent: Item?
+  internal private(set) var timestamp: Date
+
+  internal init(parent: Item? = nil, timestamp: Date) {
+    self.parent = parent
+    self.timestamp = timestamp
+  }
+}

Example/Sources/ItemChildView.swift

@@ -0,0 +1,31 @@
+//
+//  ItemChildView.swift
+//  DataThespianExample
+//
+//  Created by Leo Dion on 10/16/24.
+//
+
+import SwiftUI
+
+internal struct ItemChildView: View {
+  internal var object: ContentObject
+  internal let item: ItemViewModel
+  internal var body: some View {
+    VStack {
+      Text("Item at \(item.timestamp, format: Date.FormatStyle(date: .numeric, time: .standard))")
+      Divider()
+      Button("Add Child") {
+        object.addChild(to: item)
+      }
+      ForEach(item.children) { child in
+        Text(
+          "Child at \(child.timestamp, format: Date.FormatStyle(date: .numeric, time: .standard))"
+        )
+      }
+    }
+  }
+}
+//
+// #Preview {
+//    ItemChildView()
+// }

Example/Sources/ItemModel.swift → Example/Sources/ItemViewModel.swift

@@ -9,20 +9,26 @@ import DataThespian
 import Foundation
 import SwiftData
 
-internal struct ItemModel: Identifiable {
+internal struct ItemViewModel: Sendable, Identifiable {
   internal let model: Model<Item>
   internal let timestamp: Date
+  internal let children: [ChildViewModel]
 
   internal var id: PersistentIdentifier {
     model.persistentIdentifier
   }
 
-  private init(model: Model<Item>, timestamp: Date) {
+  private init(model: Model<Item>, timestamp: Date, children: [ChildViewModel]?) {
     self.model = model
     self.timestamp = timestamp
+    self.children = children ?? []
   }
 
   internal init(item: Item) {
-    self.init(model: .init(item), timestamp: item.timestamp)
+    self.init(
+      model: .init(item),
+      timestamp: item.timestamp,
+      children: item.children?.map(ChildViewModel.init)
+    )
   }
 }

Sources/DataThespian/Database+Extras.swift → Sources/DataThespian/Databases/Database+Extras.swift

@@ -32,13 +32,6 @@
   public import SwiftData
 
   extension Database {
-    public func insert<PersistentModelType: PersistentModel>(
-      _ closuer: @Sendable @escaping () -> PersistentModelType
-    ) async -> Model<PersistentModelType> {
-      let id: PersistentIdentifier = await self.insert(closuer)
-      return .init(persistentIdentifier: id)
-    }
-
     public func with<PersistentModelType: PersistentModel, U: Sendable>(
       _ id: Model<PersistentModelType>,
       _ closure: @escaping @Sendable (PersistentModelType) throws -> U
@@ -53,7 +46,8 @@
       }
     }
 
-    public func first<T: PersistentModel>(_ selectPredicate: Predicate<T>) async throws -> Model<T>? {
+    public func first<T: PersistentModel>(_ selectPredicate: Predicate<T>) async throws -> Model<T>?
+    {
       try await self.first(selectPredicate, with: Model.ifMap)
     }
 
@@ -67,25 +61,25 @@
       }
     }
 
-    public func first<T: PersistentModel, U: Sendable>(
-      fetchWith selectPredicate: Predicate<T>,
-      otherwiseInsertBy insert: @Sendable @escaping () -> T,
-      with closure: @escaping @Sendable (T) throws -> U
-    ) async throws -> U {
-      let value = try await self.fetch {
-        .init(predicate: selectPredicate, fetchLimit: 1)
-      } with: { models in
-        try models.first.map(closure)
-      }
-
-      if let value {
-        return value
-      }
-
-      let inserted: Model = await self.insert(insert)
-
-      return try await self.with(inserted, closure)
-    }
+    //    public func first<T: PersistentModel, U: Sendable>(
+    //      fetchWith selectPredicate: Predicate<T>,
+    //      otherwiseInsertBy insert: @Sendable @escaping () -> T,
+    //      with closure: @escaping @Sendable (T) throws -> U
+    //    ) async throws -> U {
+    //      let value = try await self.fetch {
+    //        .init(predicate: selectPredicate, fetchLimit: 1)
+    //      } with: { models in
+    //        try models.first.map(closure)
+    //      }
+    //
+    //      if let value {
+    //        return value
+    //      }
+    //
+    //      let inserted: Model = await self.insert(insert)
+    //
+    //      return try await self.with(inserted, closure)
+    //    }
 
     public func delete<T: PersistentModel>(model _: T.Type, where predicate: Predicate<T>? = nil)
       async throws
@@ -96,7 +90,8 @@
     }
 
     public func deleteAll(of types: [any PersistentModel.Type]) async throws {
-      try await self.transaction { context in for type in types { try context.delete(model: type) } }
+      try await self.transaction { context in for type in types { try context.delete(model: type) }
+      }
     }
 
     public func fetch<T: PersistentModel, U: Sendable>(

Sources/DataThespian/Database+ModelContext.swift → Sources/DataThespian/Databases/Database+ModelContext.swift

@@ -34,8 +34,6 @@
   public import SwiftData
 
   extension Database {
-    public func save() async throws { try await self.withModelContext { try $0.save() } }
-
     @discardableResult public func delete<T: PersistentModel>(
       _ modelType: T.Type, withID id: PersistentIdentifier
     ) async -> Bool { await self.withModelContext { $0.delete(modelType, withID: id) } }
@@ -44,10 +42,6 @@
       try await self.withModelContext { try $0.delete(where: predicate) }
     }
 
-    public func insert(_ closuer: @Sendable @escaping () -> some PersistentModel) async
-      -> PersistentIdentifier
-    { await self.withModelContext { $0.insert(closuer) } }
-
     public func fetch<T, U: Sendable>(
       _ selectDescriptor: @escaping @Sendable () -> FetchDescriptor<T>,
       with closure: @escaping @Sendable ([T]) throws -> U