FileProviderExtension+NetworkingDelegate.swift 3.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. //
  2. // FileProviderExtension+NetworkingDelegate.swift
  3. // File Provider Extension
  4. //
  5. // Created by Marino Faggiana on 02/11/2019.
  6. // Copyright © 2019 TWS. All rights reserved.
  7. //
  8. import FileProvider
  9. import NCCommunication
  10. extension FileProviderExtension: NCNetworkingDelegate {
  11. func uploadComplete(fileName: String, serverUrl: String, ocId: String?, etag: String?, date: NSDate?, size: Int64, description: String?, error: Error?, statusCode: Int) {
  12. guard let ocIdTemp = description else { return }
  13. guard let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp)) else { return }
  14. let url = URL(fileURLWithPath: CCUtility.getDirectoryProviderStorageOcId(ocIdTemp, fileNameView: fileName))
  15. outstandingSessionTasks.removeValue(forKey: url)
  16. outstandingOcIdTemp[ocIdTemp] = ocId
  17. if error == nil && statusCode >= 200 && statusCode < 300 {
  18. guard let parentItemIdentifier = fileProviderUtility.sharedInstance.getParentItemIdentifier(metadata: metadata, homeServerUrl: fileProviderData.sharedInstance.homeServerUrl) else {
  19. return
  20. }
  21. var item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier)
  22. // New file
  23. if ocId != ocIdTemp {
  24. fileProviderData.sharedInstance.fileProviderSignalDeleteContainerItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  25. fileProviderData.sharedInstance.fileProviderSignalDeleteWorkingSetItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  26. fileProviderData.sharedInstance.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  27. }
  28. metadata.fileName = fileName
  29. metadata.serverUrl = serverUrl
  30. if let etag = etag { metadata.etag = etag }
  31. if let ocId = ocId { metadata.ocId = ocId }
  32. if let date = date { metadata.date = date }
  33. metadata.session = ""
  34. metadata.size = Double(size)
  35. metadata.status = Int(k_metadataStatusNormal)
  36. guard let metadataUpdated = NCManageDatabase.sharedInstance.addMetadata(metadata) else { return }
  37. NCManageDatabase.sharedInstance.addLocalFile(metadata: metadataUpdated)
  38. // New file
  39. if ocId != ocIdTemp {
  40. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  41. // File system
  42. let atPath = CCUtility.getDirectoryProviderStorageOcId(ocIdTemp)
  43. let toPath = CCUtility.getDirectoryProviderStorageOcId(ocId)
  44. CCUtility.copyFile(atPath: atPath, toPath: toPath)
  45. }
  46. // Signal update
  47. item = FileProviderItem(metadata: metadataUpdated, parentItemIdentifier: parentItemIdentifier)
  48. fileProviderData.sharedInstance.fileProviderSignalUpdateContainerItem[item.itemIdentifier] = item
  49. fileProviderData.sharedInstance.fileProviderSignalUpdateWorkingSetItem[item.itemIdentifier] = item
  50. fileProviderData.sharedInstance.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  51. } else {
  52. // Error
  53. NCManageDatabase.sharedInstance.setMetadataSession("", sessionError: "", sessionSelector: "", sessionTaskIdentifier: 0, status: Int(k_metadataStatusUploadError), predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  54. }
  55. }
  56. }