FileProviderExtension+NetworkingDelegate.swift 4.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. //
  2. // FileProviderExtension+NetworkingDelegate.swift
  3. // File Provider Extension
  4. //
  5. // Created by Marino Faggiana on 02/11/2019.
  6. // Copyright © 2018 Marino Faggiana. All rights reserved.
  7. //
  8. // Author Marino Faggiana <marino.faggiana@nextcloud.com>
  9. //
  10. // This program is free software: you can redistribute it and/or modify
  11. // it under the terms of the GNU General Public License as published by
  12. // the Free Software Foundation, either version 3 of the License, or
  13. // (at your option) any later version.
  14. //
  15. // This program is distributed in the hope that it will be useful,
  16. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  18. // GNU General Public License for more details.
  19. //
  20. // You should have received a copy of the GNU General Public License
  21. // along with this program. If not, see <http://www.gnu.org/licenses/>.
  22. //
  23. import FileProvider
  24. import NCCommunication
  25. extension FileProviderExtension: NCNetworkingDelegate {
  26. func uploadComplete(fileName: String, serverUrl: String, ocId: String?, etag: String?, date: NSDate?, size: Int64, description: String?, error: Error?, statusCode: Int) {
  27. guard let ocIdTemp = description else { return }
  28. guard let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp)) else { return }
  29. let url = URL(fileURLWithPath: CCUtility.getDirectoryProviderStorageOcId(ocIdTemp, fileNameView: fileName))
  30. outstandingSessionTasks.removeValue(forKey: url)
  31. outstandingOcIdTemp[ocIdTemp] = ocId
  32. if error == nil && statusCode >= 200 && statusCode < 300 {
  33. guard let parentItemIdentifier = fileProviderUtility.sharedInstance.getParentItemIdentifier(metadata: metadata, homeServerUrl: fileProviderData.sharedInstance.homeServerUrl) else {
  34. return
  35. }
  36. var item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier)
  37. // New file
  38. if ocId != ocIdTemp {
  39. fileProviderData.sharedInstance.fileProviderSignalDeleteContainerItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  40. fileProviderData.sharedInstance.fileProviderSignalDeleteWorkingSetItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  41. fileProviderData.sharedInstance.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  42. }
  43. metadata.fileName = fileName
  44. metadata.serverUrl = serverUrl
  45. if let etag = etag { metadata.etag = etag }
  46. if let ocId = ocId { metadata.ocId = ocId }
  47. if let date = date { metadata.date = date }
  48. metadata.session = ""
  49. metadata.size = Double(size)
  50. metadata.status = Int(k_metadataStatusNormal)
  51. guard let metadataUpdated = NCManageDatabase.sharedInstance.addMetadata(metadata) else { return }
  52. NCManageDatabase.sharedInstance.addLocalFile(metadata: metadataUpdated)
  53. // New file
  54. if ocId != ocIdTemp {
  55. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  56. // File system
  57. let atPath = CCUtility.getDirectoryProviderStorageOcId(ocIdTemp)
  58. let toPath = CCUtility.getDirectoryProviderStorageOcId(ocId)
  59. CCUtility.copyFile(atPath: atPath, toPath: toPath)
  60. }
  61. // Signal update
  62. item = FileProviderItem(metadata: metadataUpdated, parentItemIdentifier: parentItemIdentifier)
  63. fileProviderData.sharedInstance.fileProviderSignalUpdateContainerItem[item.itemIdentifier] = item
  64. fileProviderData.sharedInstance.fileProviderSignalUpdateWorkingSetItem[item.itemIdentifier] = item
  65. fileProviderData.sharedInstance.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  66. } else {
  67. // Error
  68. NCManageDatabase.sharedInstance.setMetadataSession("", sessionError: "", sessionSelector: "", sessionTaskIdentifier: 0, status: Int(k_metadataStatusUploadError), predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  69. }
  70. }
  71. }