Split off deletion process of updateItemMetadatas of NextcloudFilesDatabaseManager...

Signed-off-by: Claudio Cambra <claudio.cambra@nextcloud.com>

diff --git a/shell_integration/MacOSX/NextcloudIntegration/FileProviderExt/NextcloudFilesDatabaseManager.swift b/shell_integration/MacOSX/NextcloudIntegration/FileProviderExt/NextcloudFilesDatabaseManager.swift
index c6d84fffc175952d5b96658de3d49252bdab89b1..939b87813a115397bf5bb366a92fdcdf6feeed85 100644 (file)
--- a/shell_integration/MacOSX/NextcloudIntegration/FileProviderExt/NextcloudFilesDatabaseManager.swift
+++ b/shell_integration/MacOSX/NextcloudIntegration/FileProviderExt/NextcloudFilesDatabaseManager.swift
@@ -96,25 +96,36 @@ class NextcloudFilesDatabaseManager : NSObject {
         return itemMetadataFromOcId(ocId)
     }
 
+    private func processItemMetadatasToDelete(databaseToWriteTo: Realm,
+                                              existingMetadatas: [NextcloudItemMetadataTable],
+                                              updatedMetadatas: [NextcloudItemMetadataTable]) {
+
+        assert(databaseToWriteTo.isInWriteTransaction)
+
+        for existingMetadata in existingMetadatas {
+            guard !updatedMetadatas.contains(where: { $0.ocId == existingMetadata.ocId }),
+                    let metadataToDelete = itemMetadataFromOcId(existingMetadata.ocId) else { continue }
+
+            print("""
+                    Deleting metadata.
+                    ocID: %@,
+                    fileName: %@,
+                    etag: %@
+                  """
+                  , metadataToDelete.ocId, metadataToDelete.fileName, metadataToDelete.etag)
+            databaseToWriteTo.delete(metadataToDelete)
+        }
+    }
+
     func updateItemMetadatas(existingMetadatas: [NextcloudItemMetadataTable], updatedMetadatas: [NextcloudItemMetadataTable]) {
         let database = ncDatabase()
 
         do {
             try database.write {
-                // Delete metadatas
-                for existingMetadata in existingMetadatas {
-                    guard !updatedMetadatas.contains(where: { $0.ocId == existingMetadata.ocId }),
-                            let metadataToDelete = itemMetadataFromOcId(existingMetadata.ocId) else { continue }
-
-                    print("""
-                            Deleting metadata.
-                            ocID: %@,
-                            fileName: %@,
-                            etag: %@
-                          """
-                          , metadataToDelete.ocId, metadataToDelete.fileName, metadataToDelete.etag)
-                    database.delete(metadataToDelete)
-                }
+                processItemMetadatasToDelete(databaseToWriteTo: database,
+                                             existingMetadatas: existingMetadatas,
+                                             updatedMetadatas: updatedMetadatas)
+
 
                 // Update existing or create new metadatas
                 for updatedMetadata in updatedMetadatas {