@Model
final class PersistedCartItem {
    @Attribute(.unique) var sku: String
    var qty: Int
    var cart: PersistedCart?
    
    init(sku: String, qty: Int) {
        self.sku = sku
        self.qty = qty
    }
}

@Model
final class PersistedCart {
    @Attribute(.unique) var ownerId: String
    var version: Int
    @Relationship(deleteRule: .cascade, inverse: \PersistedCartItem.cart)
    var items: [PersistedCartItem]
    
    init(ownerId: String, version: Int = 0) {
        self.ownerId = ownerId
        self.version = version
        self.items = []
    }
}

@Model
final class PersistedCartOp {
    @Attribute(.unique) var opId: UUID  // Survives app restart
    var ownerIdData: Data               // Encoded CartOwner
    var typeData: Data                  // Encoded CartOpType
    var attempts: Int
    var nextRetryAt: Date
    
    init(op: CartOp) throws {
        self.opId = op.id
        self.ownerIdData = try JSONEncoder().encode(op.owner)
        self.typeData = try JSONEncoder().encode(op.type)
        self.attempts = op.attempts
        self.nextRetryAt = op.nextRetryAt
    }
}

@main
struct App: App {
    let container: ModelContainer
    
    init() {
        let schema = Schema([
            PersistedCart.self,
            PersistedCartItem.self,
            PersistedCartOp.self
        ])
        
        let configuration = ModelConfiguration(
            "ECommerceStore",
            schema: schema,
            isStoredInMemoryOnly: false
        )
        
        container = try! ModelContainer(
            for: schema,
            configurations: [configuration]
        )
    }
    
    var body: some Scene {
        WindowGroup {
            ContentView()
        }
        .modelContainer(container)
    }
}

public actor PersistentCartStore: CartStoreProtocol {
    private let container: ModelContainer
    
    public init(container: ModelContainer) {
        self.container = container
    }
    
    public func get(owner: CartOwner) async -> Cart {
        let context = ModelContext(container)
        let ownerId = owner.id
        
        let descriptor = FetchDescriptor<PersistedCart>(
            predicate: #Predicate { $0.ownerId == ownerId }
        )
        
        guard let persisted = try? context.fetch(descriptor).first else {
            return Cart.empty(owner: owner)
        }
        
        return Cart(
            owner: owner,
            items: persisted.items.map { CartItem(sku: $0.sku, qty: $0.qty) },
            version: persisted.version
        )
    }
    
    public func upsert(_ cart: Cart) async {
        let context = ModelContext(container)
        let ownerId = cart.owner.id
        
        // Delete existing
        try? context.delete(model: PersistedCart.self, where: #Predicate {
            $0.ownerId == ownerId
        })
        
        // Insert new
        let persisted = PersistedCart(ownerId: ownerId, version: cart.version)
        persisted.items = cart.items.map {
            PersistedCartItem(sku: $0.sku, qty: $0.qty)
        }
        context.insert(persisted)
        
        try? context.save()
    }
}

// In-memory for development/testing
let cartStore = CartStore()

// SwiftData for production
let cartStore = PersistentCartStore(container: .shared)

// Both conform to CartStoreProtocol - Repository doesn't know the difference
let repository = CartRepository(store: cartStore, ...)