Improve data hierarchy

LeStorage/Codables/DataAccess.swift

@@ -7,8 +7,7 @@
 
 import Foundation
 
-class DataAccess: ModelObject, SyncedStorable {
+class DataAccess: SyncedModelObject, SyncedStorable {
-    var lastUpdate: Date = Date()
 
     static func tokenExemptedMethods() -> [HTTPMethod] { return [] }
     static func resourceName() -> String { return "data-access" }
@@ -27,6 +26,39 @@ class DataAccess: ModelObject, SyncedStorable {
         self.sharedWith = sharedWith
         self.modelName = modelName
         self.modelId = modelId
+        super.init()
+    }
+    
+    // Codable implementation
+    enum CodingKeys: String, CodingKey {
+        case id
+        case owner
+        case sharedWith
+        case modelName
+        case modelId
+        case grantedAt
+    }
+    
+    required init(from decoder: Decoder) throws {
+        let container = try decoder.container(keyedBy: CodingKeys.self)
+        id = try container.decode(String.self, forKey: .id)
+        owner = try container.decode(String.self, forKey: .owner)
+        sharedWith = try container.decode([String].self, forKey: .sharedWith)
+        modelName = try container.decode(String.self, forKey: .modelName)
+        modelId = try container.decode(String.self, forKey: .modelId)
+        grantedAt = try container.decode(Date.self, forKey: .grantedAt)
+        try super.init(from: decoder)
+    }
+    
+    override func encode(to encoder: Encoder) throws {
+        var container = encoder.container(keyedBy: CodingKeys.self)
+        try container.encode(id, forKey: .id)
+        try container.encode(owner, forKey: .owner)
+        try container.encode(sharedWith, forKey: .sharedWith)
+        try container.encode(modelName, forKey: .modelName)
+        try container.encode(modelId, forKey: .modelId)
+        try container.encode(grantedAt, forKey: .grantedAt)
+        try super.encode(to: encoder)
     }
     
     func copy(from other: any Storable) {

LeStorage/Codables/FailedAPICall.swift

@@ -40,6 +40,47 @@ class FailedAPICall: SyncedModelObject, SyncedStorable {
         self.apiCall = apiCall
         self.error = error
         self.authentication = authentication
+        super.init()
+    }
+
+    // MARK: - Codable
+
+    enum CodingKeys: String, CodingKey {
+        case id
+        case date
+        case callId
+        case type
+        case apiCall
+        case error
+        case authentication
+    }
+
+    required init(from decoder: Decoder) throws {
+        let container = try decoder.container(keyedBy: CodingKeys.self)
+
+        id = try container.decode(String.self, forKey: .id)
+        date = try container.decode(Date.self, forKey: .date)
+        callId = try container.decode(String.self, forKey: .callId)
+        type = try container.decode(String.self, forKey: .type)
+        apiCall = try container.decode(String.self, forKey: .apiCall)
+        error = try container.decode(String.self, forKey: .error)
+        authentication = try container.decodeIfPresent(String.self, forKey: .authentication)
+        
+        try super.init(from: decoder)
+    }
+
+    override func encode(to encoder: Encoder) throws {
+        var container = encoder.container(keyedBy: CodingKeys.self)
+
+        try container.encode(id, forKey: .id)
+        try container.encode(date, forKey: .date)
+        try container.encode(callId, forKey: .callId)
+        try container.encode(type, forKey: .type)
+        try container.encode(apiCall, forKey: .apiCall)
+        try container.encode(error, forKey: .error)
+        try container.encodeIfPresent(authentication, forKey: .authentication)
+        
+        try super.encode(to: encoder)
     }
 
     func copy(from other: any Storable) {

LeStorage/Codables/GetSyncData.swift

@@ -7,13 +7,11 @@
 
 import Foundation
 
-class GetSyncData: ModelObject, SyncedStorable, URLParameterConvertible {
+class GetSyncData: SyncedModelObject, SyncedStorable, URLParameterConvertible {
     
     static func filterByStoreIdentifier() -> Bool { return false }
     static func tokenExemptedMethods() -> [HTTPMethod] { return [] }
     
-    var lastUpdate: Date = Date.distantPast
-    
     static func resourceName() -> String {
         return "data"
     }

LeStorage/Codables/Log.swift

@@ -22,6 +22,30 @@ class Log: SyncedModelObject, SyncedStorable {
 
     init(message: String) {
         self.message = message
+        super.init()
+    }
+    
+    // MARK: - Codable
+    enum CodingKeys: String, CodingKey {
+        case id
+        case date
+        case message
+    }
+    
+    required init(from decoder: Decoder) throws {
+        let container = try decoder.container(keyedBy: CodingKeys.self)
+        id = try container.decode(String.self, forKey: .id)
+        date = try container.decode(Date.self, forKey: .date)
+        message = try container.decode(String.self, forKey: .message)
+        try super.init(from: decoder)
+    }
+    
+    override func encode(to encoder: Encoder) throws {
+        var container = encoder.container(keyedBy: CodingKeys.self)
+        try container.encode(id, forKey: .id)
+        try container.encode(date, forKey: .date)
+        try container.encode(message, forKey: .message)
+        try super.encode(to: encoder)
     }
     
     func copy(from other: any Storable) {

LeStorage/ModelObject.swift

@@ -13,8 +13,6 @@ open class ModelObject: NSObject {
     
     public var store: Store? = nil
     
-    var storeId: String? = nil
-    
     public override init() { }
     
     open func deleteDependencies() {
@@ -27,46 +25,64 @@ open class ModelObject: NSObject {
     
     static var relationshipNames: [String] = []
     
-//    // MARK: - Codable
+}
-//    
+
-//    enum CodingKeys: CodingKey {
+open class BaseModelObject: ModelObject, Codable {
-//        case storeId
+
-//    }
+    public var storeId: String? = nil
-//    
+
-//    public required init(from decoder: any Decoder) throws {
+    public override init() { }
-//        let decoder = try decoder.container(keyedBy: CodingKeys.self)
+
-//        self.storeId = try decoder.decodeIfPresent(String.self, forKey: CodingKeys.storeId)
+    // Coding Keys to map properties during encoding/decoding
-//    }
+    enum CodingKeys: String, CodingKey {
-//    
+        case storeId
-//    public func encode(to encoder: any Encoder) throws {
+    }
-//        var container = encoder.container(keyedBy: CodingKeys.self)
+    
-//        try container.encodeIfPresent(self.storeId, forKey: .storeId)
+    // Required initializer for Decodable
-//    }
+    required public init(from decoder: Decoder) throws {
+        let container = try decoder.container(keyedBy: CodingKeys.self)
+        self.storeId = try container.decodeIfPresent(String.self, forKey: .storeId)
+    }
     
+    // Required method for Encodable
+    open func encode(to encoder: Encoder) throws {
+        var container = encoder.container(keyedBy: CodingKeys.self)
+        try container.encode(self.storeId, forKey: .storeId)
+    }
 }
 
-open class SyncedModelObject: ModelObject {
+open class SyncedModelObject: BaseModelObject {
     
     public var lastUpdate: Date = Date()
+    public var shared: Bool?
     
-//    enum CodingKeys: CodingKey {
+    public override init() {
-//        case lastUpdate
+        super.init()
-//    }
+    }
-//    
+
-//    public override init() {
+    enum CodingKeys: String, CodingKey {
-//        super.init()
+        case lastUpdate
-//    }
+        case shared = "_shared"
-//    
+    }
-//    public required init(from decoder: any Decoder) throws {
+    
-//        try super.init(from: decoder)
+    // Required initializer for Decodable
-//        let decoder = try decoder.container(keyedBy: CodingKeys.self)
+    required public init(from decoder: Decoder) throws {
-//        self.lastUpdate = try decoder.decode(Date.self, forKey: CodingKeys.lastUpdate)
+        let container = try decoder.container(keyedBy: CodingKeys.self)
-//    }
+        self.lastUpdate = try container.decodeIfPresent(Date.self, forKey: .lastUpdate) ?? Date()
-//    
+        self.shared = try container.decodeIfPresent(Bool.self, forKey: .shared)
-//    open override func encode(to encoder: any Encoder) throws {
+        
-//        try super.encode(to: encoder)
+        try super.init(from: decoder)
-//        var container = encoder.container(keyedBy: CodingKeys.self)
+    }
-//        try container.encodeIfPresent(self.lastUpdate, forKey: .lastUpdate)
+    
-//    }
+    // Required method for Encodable
+    open override func encode(to encoder: Encoder) throws {
+        var container = encoder.container(keyedBy: CodingKeys.self)
+        try container.encode(lastUpdate, forKey: .lastUpdate)
+        if self.shared == true {
+            try container.encodeIfPresent(shared, forKey: .shared)
+        }
+        
+        try super.encode(to: encoder)
+    }
     
 }

LeStorage/Storable.swift

@@ -84,4 +84,15 @@ extension Storable {
         return storageDirectory
     }
     
+    static func buildRealId(id: String) -> ID {
+        switch ID.self {
+        case is String.Type:
+            return id as! ID
+        case is Int64.Type:
+            return Formatter.number.number(from: id)?.int64Value as! ID
+        default:
+            fatalError("ID \(type(of: ID.self)) is neither String nor Int, can't parse \(id)")
+        }
+    }
+    
 }

LeStorage/Store.swift

@@ -215,9 +215,9 @@ final public class Store {
     // MARK: - Synchronization
     
     /// Calls addOrUpdateIfNewer from the collection corresponding to the instance
-    func addOrUpdateIfNewer<T: SyncedStorable>(_ instance: T) {
+    func addOrUpdateIfNewer<T: SyncedStorable>(_ instance: T, shared: Bool) {
         let collection: StoredCollection<T> = self.registerOrGetSyncedCollection(T.self)
-        collection.addOrUpdateIfNewer(instance)
+        collection.addOrUpdateIfNewer(instance, shared: shared)
     }
     
     /// Calls deleteById from the collection corresponding to the instance

LeStorage/StoreCenter.swift

@@ -435,7 +435,7 @@ public class StoreCenter {
             }
             
             if let updates = json["grants"] as? [String: Any] {
-                try self._parseSyncUpdates(updates)
+                try self._parseSyncUpdates(updates, shared: true)
             }
 
             if let revocations = json["revocations"] as? [String: Any] {
@@ -456,7 +456,7 @@ public class StoreCenter {
         }
     }
 
-    fileprivate func _parseSyncUpdates(_ updates: [String: Any]) throws {
+    fileprivate func _parseSyncUpdates(_ updates: [String: Any], shared: Bool = false) throws {
         for (className, updateData) in updates {
             guard let updateArray = updateData as? [[String: Any]] else {
                 Logger.w("Invalid update data for \(className)")
@@ -473,7 +473,7 @@ public class StoreCenter {
                     let decodedObject = try JSON.decoder.decode(type, from: jsonData)
 
                     let storeId: String? = decodedObject.getStoreId()
-                    StoreCenter.main.synchronizationAddOrUpdate(decodedObject, storeId: storeId)
+                    StoreCenter.main.synchronizationAddOrUpdate(decodedObject, storeId: storeId, shared: shared)
                 } catch {
                     Logger.w("Issue with json decoding: \(updateItem)")
                     Logger.error(error)
@@ -569,11 +569,11 @@ public class StoreCenter {
         })
     }
 
-    func synchronizationAddOrUpdate<T: SyncedStorable>(_ instance: T, storeId: String?) {
+    func synchronizationAddOrUpdate<T: SyncedStorable>(_ instance: T, storeId: String?, shared: Bool) {
         let hasAlreadyBeenDeleted: Bool = self._hasAlreadyBeenDeleted(instance)
         if !hasAlreadyBeenDeleted {
             DispatchQueue.main.asyncAfter(deadline: .now() + 1) {
-                self._store(id: storeId).addOrUpdateIfNewer(instance)
+                self._store(id: storeId).addOrUpdateIfNewer(instance, shared: shared)
             }
         }
     }
@@ -596,9 +596,11 @@ public class StoreCenter {
         DispatchQueue.main.async {
             do {
                 let type = try StoreCenter.classFromName(model)
-                let count = Store.main.referenceCount(type: type, id: id)
+                if self._instanceShared(id: id, type: type) {
-                if count == 0 {
+                    let count = Store.main.referenceCount(type: type, id: id)
-                    try self._store(id: storeId).deleteNoSync(type: type, id: id)
+                    if count == 0 {
+                        try self._store(id: storeId).deleteNoSync(type: type, id: id)
+                    }
                 }
             } catch {
                 Logger.error(error)
@@ -606,6 +608,12 @@ public class StoreCenter {
         }
     }
     
+    fileprivate func _instanceShared<T: SyncedStorable>(id: String, type: T.Type) -> Bool {
+        let realId: T.ID = T.buildRealId(id: id)
+        let instance: T? = Store.main.findById(realId)
+        return instance?.shared == true
+    }
+
     fileprivate func _cleanupDataLog(dataId: String) {
         let logs = self._dataLogs.filter { $0.dataId == dataId }
         self._dataLogs.delete(contentOfs: logs)

LeStorage/StoredCollection+Sync.swift

@@ -87,13 +87,9 @@ extension StoredCollection: SomeSyncedCollection where T : SyncedStorable {
         defer {
             self.setChanged()
         }
-        if let realId = self._buildRealId(id: id) {
+        let realId = T.buildRealId(id: id)
-            if let instance = self.findById(realId) {
+        if let instance = self.findById(realId) {
-                self.deleteItem(instance)
+            self.deleteItem(instance)
-            }
-        } else {
-            Logger.w("CRITICAL: collection \(T.resourceName()) could not build id from \(id)")
-            StoreCenter.main.log(message: "Could not build an id from \(id)")
         }
     }
     
@@ -102,27 +98,23 @@ extension StoredCollection: SomeSyncedCollection where T : SyncedStorable {
         defer {
             self.setChanged()
         }
-        if let realId = self._buildRealId(id: id) {
+        let realId = T.buildRealId(id: id)
-            if let instance = self.findById(realId) {
+        if let instance = self.findById(realId) {
-                self.deleteItemIfUnused(instance)
+            self.deleteItemIfUnused(instance)
-            }
-        } else {
-            Logger.w("CRITICAL: collection \(T.resourceName()) could not build id from \(id)")
-            StoreCenter.main.log(message: "Could not build an id from \(id)")
         }
     }
     
-    fileprivate func _buildRealId(id: String) -> T.ID? {
+//    fileprivate func _buildRealId(id: String) -> T.ID? {
-        switch T.ID.self {
+//        switch T.ID.self {
-        case is String.Type:
+//        case is String.Type:
-            return id as? T.ID
+//            return id as? T.ID
-        case is Int64.Type:
+//        case is Int64.Type:
-            return Formatter.number.number(from: id)?.int64Value as? T.ID
+//            return Formatter.number.number(from: id)?.int64Value as? T.ID
-        default:
+//        default:
-            fatalError("ID \(type(of: T.ID.self)) is neither String nor Int, can't parse \(id)")
+//            fatalError("ID \(type(of: T.ID.self)) is neither String nor Int, can't parse \(id)")
-//            return nil
+////            return nil
-        }
+//        }
-    }
+//    }
     
     public func addOrUpdate(instance: T) {
         defer {
@@ -230,7 +222,7 @@ extension StoredCollection: SomeSyncedCollection where T : SyncedStorable {
     
     // MARK: - Synchronization
     
-    func addOrUpdateIfNewer(_ instance: T) {
+    func addOrUpdateIfNewer(_ instance: T, shared: Bool) {
         defer {
             self.setChanged()
         }
@@ -241,6 +233,9 @@ extension StoredCollection: SomeSyncedCollection where T : SyncedStorable {
                 self.updateItem(instance, index: index)
             }
         } else { // insert
+            if shared {
+                instance.shared = true
+            }
             self.addItem(instance: instance)
         }
 

LeStorage/SyncedStorable.swift

@@ -10,6 +10,7 @@ import Foundation
 public protocol SyncedStorable: Storable {
         
     var lastUpdate: Date { get set }
+    var shared: Bool? { get set }
     
     /// Returns HTTP methods that do not need to pass the token to the request
     static func tokenExemptedMethods() -> [HTTPMethod]