WIP: SwiftUI utils

Sources/ObjectPublisher.swift

@@ -173,6 +173,11 @@ public final class ObjectPublisher<O: DynamicObject>: ObjectRepresentation, Hash
         }
         return ObjectSnapshot<O>(objectID: self.id, context: context)
     }
+    
+    public func cs_dataStack() -> DataStack? {
+        
+        return self.context.parentStack
+    }
 
 
     // MARK: Equatable

Sources/ObjectReader.swift

@@ -0,0 +1,100 @@
+//
+//  ListState.swift
+//  CoreStore
+//
+//  Created by John Rommel Estropia on 2020/12/26.
+//  Copyright © 2020 John Rommel Estropia. All rights reserved.
+//
+
+#if canImport(Combine) && canImport(SwiftUI)
+
+import Combine
+import SwiftUI
+
+
+// MARK: - ObjectReader
+
+@available(iOS 13.0, tvOS 13.0, watchOS 6.0, macOS 10.15, *)
+public struct ObjectReader<Object: DynamicObject, Content: View, Placeholder: View>: View {
+    
+    // MARK: Internal
+    
+    public init(
+        _ objectPublisher: ObjectPublisher<Object>?,
+        @ViewBuilder content: @escaping (ObjectSnapshot<Object>) -> Content,
+        @ViewBuilder placeholder: @escaping () -> Placeholder
+    ) {
+        
+        self.objectPublisher = .init(
+            objectPublisher.flatMap {
+                
+                guard let dataStack = $0.cs_dataStack() else {
+                    
+                    return nil
+                }
+                return $0.asPublisher(in: dataStack)
+            }
+        )
+        self.content = content
+        self.placeholder = placeholder
+    }
+    
+    public init(
+        _ objectPublisher: ObjectPublisher<Object>?,
+        @ViewBuilder content: @escaping (ObjectSnapshot<Object>) -> Content
+    ) where Placeholder == EmptyView {
+        
+        self.init(
+            objectPublisher,
+            content: content,
+            placeholder: EmptyView.init
+        )
+    }
+    
+    
+    // MARK: View
+    
+    public var body: some View {
+        
+        if let snapshot = self.objectPublisher.wrappedValue?.snapshot {
+            
+            self.content(snapshot)
+        }
+        else {
+            
+            self.placeholder()
+        }
+    }
+    
+    
+    // MARK: Private
+    
+    @ObservedObject
+    private var objectPublisher: OptionalObservedObject<ObjectPublisher<Object>>
+    
+    private let content: (ObjectSnapshot<Object>) -> Content
+    private let placeholder: () -> Placeholder
+    
+    
+    // MARK: - OptionalObservedObject
+    
+    fileprivate final class OptionalObservedObject<T: ObservableObject>: ObservableObject where ObservableObjectPublisher == T.ObjectWillChangePublisher {
+        
+        // MARK: Internal
+        
+        let wrappedValue: T?
+        
+        init(_ wrappedValue: T?) {
+            
+            self.wrappedValue = wrappedValue
+            self.objectWillChange = wrappedValue.map(\.objectWillChange) ?? .init()
+        }
+        
+        // MARK: ObservableObject
+        
+        let objectWillChange: ObservableObjectPublisher
+    }
+}
+
+#endif
+

Sources/ObjectRepresentation.swift

@@ -67,6 +67,11 @@ public protocol ObjectRepresentation {
      A thread-safe `struct` that is a full-copy of the object's properties
      */
     func asSnapshot(in transaction: BaseDataTransaction) -> ObjectSnapshot<ObjectType>?
+    
+    /**
+     Used internally by CoreStore. Do not call directly.
+     */
+    func cs_dataStack() -> DataStack?
 }
 
 extension NSManagedObject: ObjectRepresentation {}
@@ -142,4 +147,9 @@ extension DynamicObject where Self: ObjectRepresentation {
         let context = transaction.unsafeContext()
         return ObjectSnapshot<Self>(objectID: self.cs_id(), context: context)
     }
+    
+    public func cs_dataStack() -> DataStack? {
+        
+        return self.cs_toRaw().managedObjectContext?.parentStack
+    }
 }

Sources/ObjectSnapshot.swift

@@ -86,6 +86,11 @@ public struct ObjectSnapshot<O: DynamicObject>: ObjectRepresentation, Hashable {
         let context = transaction.unsafeContext()
         return ObjectSnapshot<O>(objectID: self.id, context: context)
     }
+    
+    public func cs_dataStack() -> DataStack? {
+        
+        return self.context.parentStack
+    }
 
 
     // MARK: Equatable