|
|
|
@ -12,25 +12,48 @@ protocol SomeSyncedCollection: SomeCollection { |
|
|
|
func loadCollectionsFromServerIfNoFile() async throws |
|
|
|
func loadCollectionsFromServerIfNoFile() async throws |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSyncedCollection { |
|
|
|
public class SyncedCollection<T : SyncedStorable>: SomeSyncedCollection, CollectionDelegate { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public typealias Item = T |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let store: Store |
|
|
|
|
|
|
|
let collection: StoredCollection<T> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
init(store: Store, indexed: Bool = false, inMemory: Bool = false, limit: Int? = nil, synchronousLoading: Bool = false) { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
self.store = store |
|
|
|
|
|
|
|
self.collection = StoredCollection<T>(store: store, indexed: indexed, limit: limit, synchronousLoading: synchronousLoading) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
init(store: Store, inMemory: Bool) async { |
|
|
|
|
|
|
|
self.store = store |
|
|
|
|
|
|
|
self.collection = await StoredCollection(store: store, inMemory: inMemory) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var storeCenter: StoreCenter { return self.store.storeCenter } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var storeId: String? { |
|
|
|
|
|
|
|
return self.store.identifier |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Returns a dummy SyncedCollection instance |
|
|
|
/// Returns a dummy SyncedCollection instance |
|
|
|
public static func placeholder() -> SyncedCollection<T> { |
|
|
|
public static func placeholder() -> SyncedCollection<T> { |
|
|
|
return SyncedCollection<T>(store: Store(storeCenter: StoreCenter.main)) |
|
|
|
return SyncedCollection<T>(store: Store(storeCenter: StoreCenter.main)) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Migrates if necessary and asynchronously decodes the json file |
|
|
|
/// Migrates if necessary and asynchronously decodes the json file |
|
|
|
override func load() async { |
|
|
|
// override func load() async { |
|
|
|
do { |
|
|
|
// do { |
|
|
|
if self.inMemory { |
|
|
|
// if self.inMemory { |
|
|
|
try await self.loadDataFromServerIfAllowed() |
|
|
|
// try await self.loadDataFromServerIfAllowed() |
|
|
|
} else { |
|
|
|
// } else { |
|
|
|
await self.loadFromFile() |
|
|
|
// await self.loadFromFile() |
|
|
|
} |
|
|
|
// } |
|
|
|
} catch { |
|
|
|
// } catch { |
|
|
|
Logger.error(error) |
|
|
|
// Logger.error(error) |
|
|
|
} |
|
|
|
// } |
|
|
|
} |
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
/// Loads the collection using the server data only if the collection file doesn't exists |
|
|
|
/// Loads the collection using the server data only if the collection file doesn't exists |
|
|
|
func loadCollectionsFromServerIfNoFile() async throws { |
|
|
|
func loadCollectionsFromServerIfNoFile() async throws { |
|
|
|
@ -64,90 +87,56 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
Task { |
|
|
|
Task { |
|
|
|
await _updateLocalInstance(serverInstance) |
|
|
|
await self.collection.updateLocalInstance(serverInstance) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// DispatchQueue.main.async { |
|
|
|
|
|
|
|
// if let localInstance = self.findById(serverInstance.id) { |
|
|
|
|
|
|
|
// localInstance.copy(from: serverInstance) |
|
|
|
|
|
|
|
// self.setChanged() |
|
|
|
|
|
|
|
// } |
|
|
|
|
|
|
|
// } |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@MainActor |
|
|
|
|
|
|
|
fileprivate func _updateLocalInstance(_ serverInstance: T) { |
|
|
|
|
|
|
|
if let localInstance = self.findById(serverInstance.id) { |
|
|
|
|
|
|
|
localInstance.copy(from: serverInstance) |
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@MainActor |
|
|
|
@MainActor |
|
|
|
func loadItems(_ items: [T], clear: Bool = false) { |
|
|
|
func loadItems(_ items: [T], clear: Bool = false) { |
|
|
|
if clear { |
|
|
|
self.collection.loadAndWrite(items, clear: clear) |
|
|
|
self.setItems(items) |
|
|
|
|
|
|
|
self.setAsLoaded() |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
self.setAsLoaded() |
|
|
|
|
|
|
|
self.addOrUpdateNoSync(contentOfs: items) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// MARK: - Basic operations with sync |
|
|
|
// MARK: - Basic operations with sync |
|
|
|
|
|
|
|
|
|
|
|
/// Adds or update an instance synchronously, dispatching network operations to background tasks |
|
|
|
/// Adds or update an instance synchronously, dispatching network operations to background tasks |
|
|
|
public override func addOrUpdate(instance: T) { |
|
|
|
public func addOrUpdate(instance: T) { |
|
|
|
if let result = _addOrUpdateCore(instance: instance) { |
|
|
|
let result = _addOrUpdateCore(instance: instance) |
|
|
|
if result.isNewItem { |
|
|
|
if result.method == .insert { |
|
|
|
Task { await self._sendInsertion(result.item) } |
|
|
|
Task { await self._sendInsertion(instance) } |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
Task { await self._sendUpdate(result.item) } |
|
|
|
Task { await self._sendUpdate(instance) } |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Private helper function that contains the shared logic |
|
|
|
/// Private helper function that contains the shared logic |
|
|
|
private func _addOrUpdateCore(instance: T) -> (item: T, isNewItem: Bool)? { |
|
|
|
private func _addOrUpdateCore(instance: T) -> ActionResult<T> { |
|
|
|
instance.lastUpdate = Date() |
|
|
|
instance.lastUpdate = Date() |
|
|
|
if let index = self.items.firstIndex(where: { $0.id == instance.id }) { |
|
|
|
|
|
|
|
if self.updateItem(instance, index: index, shouldBeSynchronized: true) { |
|
|
|
let result = self.collection.addOrUpdate(instance: instance) |
|
|
|
self.triggerWrite() |
|
|
|
if result.method == .update { |
|
|
|
if instance.shared == true { |
|
|
|
if instance.shared == true { |
|
|
|
self._cleanUpSharedDependencies() |
|
|
|
self._cleanUpSharedDependencies() |
|
|
|
} |
|
|
|
|
|
|
|
return (instance, false) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
if self.addItem(instance: instance, shouldBeSynchronized: true) { |
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
return (instance, true) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
return nil |
|
|
|
|
|
|
|
|
|
|
|
return result |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
fileprivate func _addOrUpdateCore(contentOfs sequence: any Sequence<T>) -> OperationBatch<T> { |
|
|
|
fileprivate func _addOrUpdateCore(contentOfs sequence: any Sequence<T>) -> OperationBatch<T> { |
|
|
|
|
|
|
|
|
|
|
|
defer { |
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let date = Date() |
|
|
|
let date = Date() |
|
|
|
let batch = OperationBatch<T>() |
|
|
|
let batch = OperationBatch<T>() |
|
|
|
|
|
|
|
|
|
|
|
for instance in sequence { |
|
|
|
for instance in sequence { |
|
|
|
|
|
|
|
|
|
|
|
instance.lastUpdate = date |
|
|
|
instance.lastUpdate = date |
|
|
|
if let index = self.items.firstIndex(where: { $0.id == instance.id }) { |
|
|
|
let result = self.collection.addOrUpdate(instance: instance) |
|
|
|
if self.updateItem(instance, index: index, shouldBeSynchronized: true) { |
|
|
|
|
|
|
|
batch.addUpdate(instance) |
|
|
|
if result.method == .insert { |
|
|
|
} |
|
|
|
batch.addInsert(instance) |
|
|
|
} else { // insert |
|
|
|
} else { |
|
|
|
if self.addItem(instance: instance, shouldBeSynchronized: true) { |
|
|
|
batch.addUpdate(instance) |
|
|
|
batch.addInsert(instance) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -158,48 +147,47 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Adds or update a sequence and writes |
|
|
|
/// Adds or update a sequence and writes |
|
|
|
override public func addOrUpdate(contentOfs sequence: any Sequence<T>) { |
|
|
|
public func addOrUpdate(contentOfs sequence: any Sequence<T>) { |
|
|
|
let batch = self._addOrUpdateCore(contentOfs: sequence) |
|
|
|
let batch = self._addOrUpdateCore(contentOfs: sequence) |
|
|
|
Task { await self._sendOperationBatch(batch) } |
|
|
|
Task { await self._sendOperationBatch(batch) } |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes all items of the sequence by id and sets the collection as changed to trigger a write |
|
|
|
/// Deletes an instance and writes |
|
|
|
fileprivate func _deleteCore(contentOfs sequence: any RandomAccessCollection<T>) -> OperationBatch<T> { |
|
|
|
public func delete(instance: T) { |
|
|
|
|
|
|
|
|
|
|
|
defer { |
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var deleted: [T] = [] |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for instance in sequence { |
|
|
|
self.collection.delete(instance: instance, actionOption: .syncedCascade) |
|
|
|
if self.deleteItem(instance, shouldBeSynchronized: true) { |
|
|
|
self.storeCenter.createDeleteLog(instance) |
|
|
|
deleted.append(instance) |
|
|
|
Task { await self._sendDeletion(instance) } |
|
|
|
} |
|
|
|
|
|
|
|
self.storeCenter.createDeleteLog(instance) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let batch = OperationBatch<T>() |
|
|
|
|
|
|
|
batch.deletes = deleted |
|
|
|
|
|
|
|
return batch |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes all items of the sequence by id and sets the collection as changed to trigger a write |
|
|
|
/// Deletes all items of the sequence by id and sets the collection as changed to trigger a write |
|
|
|
public override func delete(contentOfs sequence: any RandomAccessCollection<T>) { |
|
|
|
public func delete(contentOfs sequence: any RandomAccessCollection<T>) { |
|
|
|
guard sequence.isNotEmpty else { return } |
|
|
|
self.delete(contentOfs: sequence, actionOption: .syncedCascade) |
|
|
|
let batch = self._deleteCore(contentOfs: sequence) |
|
|
|
|
|
|
|
Task { await self._sendOperationBatch(batch) } |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes an instance and writes |
|
|
|
func delete(contentOfs sequence: any RandomAccessCollection<T>, actionOption: ActionOption) { |
|
|
|
override public func delete(instance: T) { |
|
|
|
guard sequence.isNotEmpty else { return } |
|
|
|
defer { |
|
|
|
let batch = self._deleteCore(contentOfs: sequence, actionOption: actionOption) |
|
|
|
self.triggerWrite() |
|
|
|
if actionOption.synchronize { |
|
|
|
|
|
|
|
Task { await self._sendOperationBatch(batch) } |
|
|
|
} |
|
|
|
} |
|
|
|
self.deleteItem(instance, shouldBeSynchronized: true) |
|
|
|
} |
|
|
|
self.storeCenter.createDeleteLog(instance) |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes all items of the sequence by id and sets the collection as changed to trigger a write |
|
|
|
|
|
|
|
fileprivate func _deleteCore(contentOfs sequence: any RandomAccessCollection<T>, actionOption: ActionOption) -> OperationBatch<T> { |
|
|
|
|
|
|
|
|
|
|
|
Task { await self._sendDeletion(instance) } |
|
|
|
var deleted: [T] = [] |
|
|
|
|
|
|
|
self.collection.delete(contentOfs: sequence, actionOption: actionOption) { result in |
|
|
|
|
|
|
|
self.storeCenter.createDeleteLog(result.instance) |
|
|
|
|
|
|
|
if !result.pending { |
|
|
|
|
|
|
|
deleted.append(result.instance) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let batch = OperationBatch<T>() |
|
|
|
|
|
|
|
batch.deletes = deleted |
|
|
|
|
|
|
|
return batch |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes an instance without writing, logs the operation and sends an API call |
|
|
|
/// Deletes an instance without writing, logs the operation and sends an API call |
|
|
|
@ -209,30 +197,33 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
//// await self._sendDeletion(instance) |
|
|
|
//// await self._sendDeletion(instance) |
|
|
|
// } |
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
public func deleteDependencies(_ items: any RandomAccessCollection<T>, shouldBeSynchronized: Bool) { |
|
|
|
// public func deleteDependencies(_ items: any RandomAccessCollection<T>, actionOption: ActionOption) { |
|
|
|
guard items.isNotEmpty else { return } |
|
|
|
// guard items.isNotEmpty else { return } |
|
|
|
if shouldBeSynchronized { |
|
|
|
// if actionOption.synchronize { |
|
|
|
self.delete(contentOfs: items) |
|
|
|
// self.delete(contentOfs: items) |
|
|
|
} else { |
|
|
|
// } else { |
|
|
|
self.deleteNoSync(contentOfs: items) |
|
|
|
// self.deleteNoSync(contentOfs: items) |
|
|
|
} |
|
|
|
// } |
|
|
|
} |
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
public override func deleteDependencies(_ items: any Sequence<T>) { |
|
|
|
// public func deleteDependencies(_ items: any Sequence<T>) { |
|
|
|
super.deleteDependencies(items) |
|
|
|
// |
|
|
|
|
|
|
|
// self.collection.deleteDependencies(items) |
|
|
|
let batch = OperationBatch<T>() |
|
|
|
// |
|
|
|
batch.deletes = Array(items) |
|
|
|
//// super.deleteDependencies(items) |
|
|
|
Task { await self._sendOperationBatch(batch) } |
|
|
|
// |
|
|
|
} |
|
|
|
// let batch = OperationBatch<T>() |
|
|
|
|
|
|
|
// batch.deletes = Array(items) |
|
|
|
|
|
|
|
// Task { await self._sendOperationBatch(batch) } |
|
|
|
|
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
public func deleteDependenciesAsync(_ items: any Sequence<T>) async { |
|
|
|
// public func deleteDependenciesAsync(_ items: any Sequence<T>) async { |
|
|
|
super.deleteDependencies(items) |
|
|
|
// super.deleteDependencies(items) |
|
|
|
|
|
|
|
// |
|
|
|
let batch = OperationBatch<T>() |
|
|
|
// let batch = OperationBatch<T>() |
|
|
|
batch.deletes = Array(items) |
|
|
|
// batch.deletes = Array(items) |
|
|
|
await self._sendOperationBatch(batch) |
|
|
|
// await self._sendOperationBatch(batch) |
|
|
|
} |
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
fileprivate func _cleanUpSharedDependencies() { |
|
|
|
fileprivate func _cleanUpSharedDependencies() { |
|
|
|
for relationship in T.relationships() { |
|
|
|
for relationship in T.relationships() { |
|
|
|
@ -261,22 +252,38 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
|
|
|
|
|
|
|
|
fileprivate func _deleteUnusedSharedInstances() { |
|
|
|
fileprivate func _deleteUnusedSharedInstances() { |
|
|
|
|
|
|
|
|
|
|
|
let sharedItems = self.items.filter { $0.shared == true } |
|
|
|
let sharedItems = self.collection.items.filter { $0.shared == true } |
|
|
|
for sharedItem in sharedItems { |
|
|
|
for sharedItem in sharedItems { |
|
|
|
self.store.deleteUnusedSharedIfNecessary(sharedItem) |
|
|
|
self.store.deleteUnusedSharedIfNecessary(sharedItem) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func deleteAllItemsAndDependencies(actionOption: ActionOption) { |
|
|
|
|
|
|
|
if actionOption.synchronize { |
|
|
|
|
|
|
|
self.delete(contentOfs: self.items, actionOption: actionOption) |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
self.collection.deleteAllItemsAndDependencies(actionOption: actionOption) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func deleteDependencies(actionOption: ActionOption, _ isIncluded: (T) -> Bool) { |
|
|
|
|
|
|
|
let items = self.items.filter(isIncluded) |
|
|
|
|
|
|
|
if actionOption.synchronize { |
|
|
|
|
|
|
|
self.delete(contentOfs: items, actionOption: actionOption) |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
self.collection.delete(contentOfs: items) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// MARK: - Asynchronous operations |
|
|
|
// MARK: - Asynchronous operations |
|
|
|
|
|
|
|
|
|
|
|
/// Adds or update an instance asynchronously and waits for network operations |
|
|
|
/// Adds or update an instance asynchronously and waits for network operations |
|
|
|
func addOrUpdateAsync(instance: T) async throws { |
|
|
|
func addOrUpdateAsync(instance: T) async throws { |
|
|
|
if let result = _addOrUpdateCore(instance: instance) { |
|
|
|
let result = _addOrUpdateCore(instance: instance) |
|
|
|
if result.isNewItem { |
|
|
|
if result.method == .insert { |
|
|
|
try await self._executeBatchOnce(OperationBatch(insert: result.item)) |
|
|
|
try await self._executeBatchOnce(OperationBatch(insert: instance)) |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
try await self._executeBatchOnce(OperationBatch(update: result.item)) |
|
|
|
try await self._executeBatchOnce(OperationBatch(update: instance)) |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -288,16 +295,13 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
/// Deletes all items of the sequence by id and sets the collection as changed to trigger a write |
|
|
|
/// Deletes all items of the sequence by id and sets the collection as changed to trigger a write |
|
|
|
public func deleteAsync(contentOfs sequence: any RandomAccessCollection<T>) async throws { |
|
|
|
public func deleteAsync(contentOfs sequence: any RandomAccessCollection<T>) async throws { |
|
|
|
guard sequence.isNotEmpty else { return } |
|
|
|
guard sequence.isNotEmpty else { return } |
|
|
|
let batch = self._deleteCore(contentOfs: sequence) |
|
|
|
let batch = self._deleteCore(contentOfs: sequence, actionOption: .syncedCascade) |
|
|
|
try await self._executeBatchOnce(batch) |
|
|
|
try await self._executeBatchOnce(batch) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes an instance and writes |
|
|
|
/// Deletes an instance and writes |
|
|
|
func deleteAsync(instance: T) async throws { |
|
|
|
func deleteAsync(instance: T) async throws { |
|
|
|
defer { |
|
|
|
self.collection.delete(instance: instance, actionOption: .syncedCascade) |
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
self.deleteItem(instance, shouldBeSynchronized: true) |
|
|
|
|
|
|
|
self.storeCenter.createDeleteLog(instance) |
|
|
|
self.storeCenter.createDeleteLog(instance) |
|
|
|
try await self._executeBatchOnce(OperationBatch(delete: instance)) |
|
|
|
try await self._executeBatchOnce(OperationBatch(delete: instance)) |
|
|
|
} |
|
|
|
} |
|
|
|
@ -306,51 +310,63 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
|
|
|
|
|
|
|
|
/// Adds or update an instance without synchronizing it |
|
|
|
/// Adds or update an instance without synchronizing it |
|
|
|
func addOrUpdateNoSync(_ instance: T) { |
|
|
|
func addOrUpdateNoSync(_ instance: T) { |
|
|
|
self.addOrUpdateItem(instance: instance) |
|
|
|
self.collection.addOrUpdate(instance: instance) |
|
|
|
|
|
|
|
// self.addOrUpdateItem(instance: instance) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Adds or update a sequence of elements without synchronizing it |
|
|
|
/// Adds or update a sequence of elements without synchronizing it |
|
|
|
func addOrUpdateNoSync(contentOfs sequence: any Sequence<T>) { |
|
|
|
func addOrUpdateNoSync(contentOfs sequence: any Sequence<T>) { |
|
|
|
self.addSequence(sequence) |
|
|
|
self.collection.addOrUpdate(contentOfs: sequence) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes the instance in the collection without synchronization |
|
|
|
/// Deletes the instance in the collection without synchronization |
|
|
|
func deleteNoSync(contentOfs sequence: any Sequence<T>) { |
|
|
|
// func deleteNoSync(instance: T) { |
|
|
|
defer { |
|
|
|
// self.collection.delete(instance: instance) |
|
|
|
self.triggerWrite() |
|
|
|
// } |
|
|
|
} |
|
|
|
|
|
|
|
for item in sequence { |
|
|
|
|
|
|
|
self.deleteItem(item, shouldBeSynchronized: false) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// Deletes the instance in the collection without synchronization |
|
|
|
/// Deletes the instance in the collection without synchronization |
|
|
|
func deleteNoSync(instance: T) { |
|
|
|
func deleteNoSync(contentOfs sequence: any RandomAccessCollection<T>) { |
|
|
|
defer { |
|
|
|
self.collection.delete(contentOfs: sequence) |
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
self.deleteItem(instance, shouldBeSynchronized: false) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func deleteUnusedShared(instance: T) { |
|
|
|
func deleteUnusedShared(instance: T) { |
|
|
|
|
|
|
|
|
|
|
|
guard instance.shared == true else { return } |
|
|
|
guard instance.shared == true else { return } |
|
|
|
|
|
|
|
|
|
|
|
// Delete the instance and its non-used shared dependencies |
|
|
|
self.delete(instance: instance) |
|
|
|
self.deleteUnusedShared(instance, shouldBeSynchronized: false) |
|
|
|
instance.deleteUnusedSharedDependencies(store: self.store) |
|
|
|
|
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// Deletes the instance in the collection without synchronization |
|
|
|
/// Deletes the instance in the collection without synchronization |
|
|
|
func deleteByStringIdNoSync(_ id: String) { |
|
|
|
func deleteNoSyncNoCascade(id: String) { |
|
|
|
defer { |
|
|
|
self.collection.deleteByStringId(id, actionOption: .standard) |
|
|
|
self.triggerWrite() |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// MARK: - Collection Delegate |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func loadingForMemoryCollection() async { |
|
|
|
|
|
|
|
do { |
|
|
|
|
|
|
|
try await self.loadDataFromServerIfAllowed() |
|
|
|
|
|
|
|
} catch { |
|
|
|
|
|
|
|
Logger.error(error) |
|
|
|
} |
|
|
|
} |
|
|
|
let realId = T.buildRealId(id: id) |
|
|
|
} |
|
|
|
if let instance = self.findById(realId) { |
|
|
|
|
|
|
|
self.deleteItem(instance, shouldBeSynchronized: false) |
|
|
|
func itemMerged(_ pendingOperation: PendingOperation<T>) { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let batch = OperationBatch<T>() |
|
|
|
|
|
|
|
switch pendingOperation.method { |
|
|
|
|
|
|
|
case .add: |
|
|
|
|
|
|
|
batch.inserts.append(pendingOperation.data) |
|
|
|
|
|
|
|
case .update: |
|
|
|
|
|
|
|
batch.updates.append(pendingOperation.data) |
|
|
|
|
|
|
|
case .delete: |
|
|
|
|
|
|
|
batch.deletes.append(pendingOperation.data) |
|
|
|
|
|
|
|
case .deleteUnusedShared: |
|
|
|
|
|
|
|
break |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Task { await self._sendOperationBatch(batch) } |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// MARK: - Send requests |
|
|
|
// MARK: - Send requests |
|
|
|
@ -397,14 +413,15 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
|
|
|
|
|
|
|
|
/// Adds or update an instance if it is newer than the local instance |
|
|
|
/// Adds or update an instance if it is newer than the local instance |
|
|
|
func addOrUpdateIfNewer(_ instance: T, shared: Bool) { |
|
|
|
func addOrUpdateIfNewer(_ instance: T, shared: Bool) { |
|
|
|
defer { |
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
// defer { |
|
|
|
} |
|
|
|
// self.triggerWrite() |
|
|
|
|
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
if let index = self.items.firstIndex(where: { $0.id == instance.id }) { |
|
|
|
if let index = self.collection.items.firstIndex(where: { $0.id == instance.id }) { |
|
|
|
let localInstance = self.items[index] |
|
|
|
let localInstance = self.collection.items[index] |
|
|
|
if instance.lastUpdate > localInstance.lastUpdate { |
|
|
|
if instance.lastUpdate > localInstance.lastUpdate { |
|
|
|
self.updateItem(instance, index: index) |
|
|
|
self.collection.update(instance, index: index, actionOption: .standard) |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
print("do not update \(T.resourceName()): \(instance.lastUpdate.timeIntervalSince1970) / local: \(localInstance.lastUpdate.timeIntervalSince1970)") |
|
|
|
print("do not update \(T.resourceName()): \(instance.lastUpdate.timeIntervalSince1970) / local: \(localInstance.lastUpdate.timeIntervalSince1970)") |
|
|
|
} |
|
|
|
} |
|
|
|
@ -412,7 +429,7 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
if shared { |
|
|
|
if shared { |
|
|
|
instance.shared = true |
|
|
|
instance.shared = true |
|
|
|
} |
|
|
|
} |
|
|
|
self.addItem(instance: instance, shouldBeSynchronized: false) |
|
|
|
self.collection.add(instance: instance, actionOption: .standard) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
@ -421,14 +438,37 @@ public class SyncedCollection<T : SyncedStorable>: BaseCollection<T>, SomeSynced |
|
|
|
|
|
|
|
|
|
|
|
/// Sends a POST request for the instance, and changes the collection to perform a write |
|
|
|
/// Sends a POST request for the instance, and changes the collection to perform a write |
|
|
|
public func writeChangeAndInsertOnServer(instance: T) { |
|
|
|
public func writeChangeAndInsertOnServer(instance: T) { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
self.collection.addOrUpdate(instance: instance) |
|
|
|
Task { |
|
|
|
Task { |
|
|
|
await self._sendInsertion(instance) |
|
|
|
await self._sendInsertion(instance) |
|
|
|
await MainActor.run { |
|
|
|
|
|
|
|
self.triggerWrite() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// MARK: - SomeCollection |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var hasLoaded: Bool { return self.collection.hasLoaded} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var inMemory: Bool { return self.collection.inMemory } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var type: any Storable.Type { return T.self } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func referenceCount<S>(type: S.Type, id: String) -> Int where S : Storable { |
|
|
|
|
|
|
|
return self.collection.referenceCount(type: type, id: id) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func reset() { |
|
|
|
|
|
|
|
self.collection.reset() |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func findById(_ id: T.ID) -> T? { |
|
|
|
|
|
|
|
return self.collection.findById(id) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var items: [T] { |
|
|
|
|
|
|
|
return self.collection.items |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
class OperationBatch<T> { |
|
|
|
class OperationBatch<T> { |
|
|
|
@ -459,3 +499,25 @@ class OperationBatch<T> { |
|
|
|
self.deletes.append(instance) |
|
|
|
self.deletes.append(instance) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
extension SyncedCollection: RandomAccessCollection { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var startIndex: Int { return self.collection.items.startIndex } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public var endIndex: Int { return self.collection.items.endIndex } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func index(after i: Int) -> Int { |
|
|
|
|
|
|
|
return self.collection.items.index(after: i) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public subscript(index: Int) -> T { |
|
|
|
|
|
|
|
get { |
|
|
|
|
|
|
|
return self.collection.items[index] |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
set(newValue) { |
|
|
|
|
|
|
|
self.collection.update(newValue, index: index, actionOption: .standard) |
|
|
|
|
|
|
|
// self.collection.items[index] = newValue |
|
|
|
|
|
|
|
// self._triggerWrite = true |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
