FileProviderExtension+Network.swift 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162
  1. //
  2. // FileProviderExtension+Network.swift
  3. // PickerFileProvider
  4. //
  5. // Created by Marino Faggiana on 28/05/18.
  6. // Copyright © 2018 TWS. All rights reserved.
  7. //
  8. // Author Marino Faggiana <m.faggiana@twsweb.it>
  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. extension FileProviderExtension {
  25. // --------------------------------------------------------------------------------------------
  26. // MARK: - Delete
  27. // --------------------------------------------------------------------------------------------
  28. func deleteFile(withIdentifier itemIdentifier: NSFileProviderItemIdentifier, parentItemIdentifier: NSFileProviderItemIdentifier, metadata: tableMetadata) {
  29. /* ONLY iOS 11*/
  30. guard #available(iOS 11, *) else { return }
  31. guard let serverUrl = NCManageDatabase.sharedInstance.getServerUrl(metadata.directoryID) else {
  32. return
  33. }
  34. let ocNetworking = OCnetworking.init(delegate: nil, metadataNet: nil, withUser: providerData.accountUser, withUserID: providerData.accountUserID, withPassword: providerData.accountPassword, withUrl: providerData.accountUrl)
  35. ocNetworking?.deleteFileOrFolder(metadata.fileName, serverUrl: serverUrl, success: {
  36. let fileNamePath = self.providerData.directoryUser + "/" + metadata.fileID
  37. do {
  38. try self.fileManager.removeItem(atPath: fileNamePath)
  39. } catch let error {
  40. print("error: \(error)")
  41. }
  42. do {
  43. try self.fileManager.removeItem(atPath: fileNamePath + ".ico")
  44. } catch let error {
  45. print("error: \(error)")
  46. }
  47. do {
  48. try self.fileManager.removeItem(atPath: self.providerData.fileProviderStorageURL!.path + "/" + itemIdentifier.rawValue)
  49. } catch let error {
  50. print("error: \(error)")
  51. }
  52. if metadata.directory {
  53. let dirForDelete = CCUtility.stringAppendServerUrl(serverUrl, addFileName: metadata.fileName)
  54. NCManageDatabase.sharedInstance.deleteDirectoryAndSubDirectory(serverUrl: dirForDelete!)
  55. }
  56. NCManageDatabase.sharedInstance.deleteLocalFile(predicate: NSPredicate(format: "fileID == %@", metadata.fileID))
  57. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "fileID == %@", metadata.fileID), clearDateReadDirectoryID: nil)
  58. }, failure: { (errorMessage, errorCode) in
  59. // remove itemIdentifier on fileProviderSignalDeleteItemIdentifier
  60. if let index = fileProviderSignalDeleteItemIdentifier.index(of: itemIdentifier) {
  61. fileProviderSignalDeleteItemIdentifier.remove(at: index)
  62. }
  63. self.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  64. })
  65. }
  66. // --------------------------------------------------------------------------------------------
  67. // MARK: - Upload
  68. // --------------------------------------------------------------------------------------------
  69. func uploadFileSuccessFailure(_ fileName: String!, fileID: String!, identifier: String!, assetLocalIdentifier: String!, serverUrl: String!, selector: String!, selectorPost: String!, errorMessage: String!, errorCode: Int) {
  70. /* ONLY iOS 11*/
  71. guard #available(iOS 11, *) else { return }
  72. if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "fileID = %@", assetLocalIdentifier)) {
  73. let parentItemIdentifier = providerData.getParentItemIdentifier(metadata: metadata)
  74. let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier!, providerData: providerData)
  75. fileProviderSignalDeleteItemIdentifier.append(item.itemIdentifier)
  76. signalEnumerator(for: [item.parentItemIdentifier, .workingSet])
  77. }
  78. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "fileID = %@", assetLocalIdentifier), clearDateReadDirectoryID: nil)
  79. if errorCode == 0 {
  80. NCManageDatabase.sharedInstance.deleteQueueUpload(assetLocalIdentifier: assetLocalIdentifier, selector: selector)
  81. if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "account = %@ AND fileID = %@", providerData.account, fileID)) {
  82. // Rename directory file
  83. if fileManager.fileExists(atPath: providerData.fileProviderStorageURL!.path + "/" + assetLocalIdentifier) {
  84. let itemIdentifier = providerData.getItemIdentifier(metadata: metadata)
  85. _ = moveFile(providerData.fileProviderStorageURL!.path + "/" + assetLocalIdentifier, toPath: providerData.fileProviderStorageURL!.path + "/" + itemIdentifier.rawValue)
  86. }
  87. NCManageDatabase.sharedInstance.setLocalFile(fileID: fileID, date: nil, exifDate: nil, exifLatitude: nil, exifLongitude: nil, fileName: nil, etag: metadata.etag, etagFPE: metadata.etag)
  88. let parentItemIdentifier = providerData.getParentItemIdentifier(metadata: metadata)
  89. if parentItemIdentifier != nil {
  90. let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier!, providerData: providerData)
  91. fileProviderSignalUpdateItem.append(item)
  92. signalEnumerator(for: [item.parentItemIdentifier, .workingSet])
  93. }
  94. }
  95. } else {
  96. NCManageDatabase.sharedInstance.unlockQueueUpload(assetLocalIdentifier: assetLocalIdentifier)
  97. }
  98. uploadFile()
  99. }
  100. func uploadFile() {
  101. let queueInLock = NCManageDatabase.sharedInstance.getQueueUploadInLock()
  102. if queueInLock != nil && queueInLock!.count == 0 {
  103. let metadataNetQueue = NCManageDatabase.sharedInstance.lockQueueUpload(selector: selectorUploadFile, withPath: true)
  104. if metadataNetQueue != nil {
  105. if self.copyFile(metadataNetQueue!.path, toPath: providerData.directoryUser + "/" + metadataNetQueue!.fileName) == nil {
  106. CCNetworking.shared().uploadFile(metadataNetQueue!.fileName, serverUrl: metadataNetQueue!.serverUrl, identifier: metadataNetQueue!.identifier, assetLocalIdentifier: metadataNetQueue!.assetLocalIdentifier ,session: metadataNetQueue!.session, taskStatus: metadataNetQueue!.taskStatus, selector: metadataNetQueue!.selector, selectorPost: metadataNetQueue!.selectorPost, errorCode: 0, delegate: self)
  107. } else {
  108. // file not present, delete record Upload Queue
  109. NCManageDatabase.sharedInstance.deleteQueueUpload(path: metadataNetQueue!.path)
  110. }
  111. }
  112. }
  113. }
  114. func verifyUploadQueueInLock() {
  115. let tasks = CCNetworking.shared().getUploadTasksExtensionSession()
  116. if tasks!.count == 0 {
  117. let records = NCManageDatabase.sharedInstance.getQueueUpload(predicate: NSPredicate(format: "account = %@ AND selector = %@ AND lock == true AND path != nil", providerData.account, selectorUploadFile))
  118. if records != nil && records!.count > 0 {
  119. NCManageDatabase.sharedInstance.unlockAllQueueUploadWithPath()
  120. }
  121. }
  122. }
  123. }