FileProviderExtension+NetworkingDelegate.swift 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. //
  2. // FileProviderExtension+NetworkingDelegate.swift
  3. // File Provider Extension
  4. //
  5. // Created by Marino Faggiana on 02/11/2019.
  6. // Copyright © 2019 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?, task: URLSessionTask, errorCode: Int, errorDescription: String) {
  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. DispatchQueue.main.asyncAfter(deadline: .now() + 1) {
  31. self.outstandingSessionTasks.removeValue(forKey: url)
  32. }
  33. outstandingOcIdTemp[ocIdTemp] = ocId
  34. if errorCode == 0 {
  35. guard let parentItemIdentifier = fileProviderUtility.sharedInstance.getParentItemIdentifier(metadata: metadata, homeServerUrl: fileProviderData.sharedInstance.homeServerUrl) else {
  36. return
  37. }
  38. var item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier)
  39. // New file
  40. if ocId != ocIdTemp {
  41. fileProviderData.sharedInstance.fileProviderSignalDeleteContainerItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  42. fileProviderData.sharedInstance.fileProviderSignalDeleteWorkingSetItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  43. fileProviderData.sharedInstance.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  44. }
  45. metadata.fileName = fileName
  46. metadata.serverUrl = serverUrl
  47. if let etag = etag { metadata.etag = etag }
  48. if let ocId = ocId { metadata.ocId = ocId }
  49. if let date = date { metadata.date = date }
  50. metadata.session = ""
  51. metadata.size = Double(size)
  52. metadata.status = Int(k_metadataStatusNormal)
  53. guard let metadataUpdated = NCManageDatabase.sharedInstance.addMetadata(metadata) else { return }
  54. _ = NCManageDatabase.sharedInstance.addLocalFile(metadata: metadataUpdated)
  55. // New file
  56. if ocId != ocIdTemp {
  57. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  58. // File system
  59. let atPath = CCUtility.getDirectoryProviderStorageOcId(ocIdTemp)
  60. let toPath = CCUtility.getDirectoryProviderStorageOcId(ocId)
  61. CCUtility.copyFile(atPath: atPath, toPath: toPath)
  62. }
  63. // Signal update
  64. item = FileProviderItem(metadata: metadataUpdated, parentItemIdentifier: parentItemIdentifier)
  65. fileProviderData.sharedInstance.fileProviderSignalUpdateContainerItem[item.itemIdentifier] = item
  66. fileProviderData.sharedInstance.fileProviderSignalUpdateWorkingSetItem[item.itemIdentifier] = item
  67. fileProviderData.sharedInstance.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  68. } else {
  69. // Error
  70. NCManageDatabase.sharedInstance.setMetadataSession("", sessionError: "", sessionSelector: "", sessionTaskIdentifier: 0, status: Int(k_metadataStatusUploadError), predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  71. }
  72. }
  73. }