FileProviderExtension+Network.swift 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199
  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. fileProviderSignalDeleteItemIdentifier.removeValue(forKey: itemIdentifier)
  61. self.signalEnumerator(for: [parentItemIdentifier, .workingSet])
  62. })
  63. }
  64. // --------------------------------------------------------------------------------------------
  65. // MARK: - Favorite
  66. // --------------------------------------------------------------------------------------------
  67. func settingFavorite(_ favorite: Bool, withIdentifier itemIdentifier: NSFileProviderItemIdentifier, parentItemIdentifier: NSFileProviderItemIdentifier, metadata: tableMetadata) {
  68. /* ONLY iOS 11*/
  69. guard #available(iOS 11, *) else { return }
  70. guard let serverUrl = NCManageDatabase.sharedInstance.getServerUrl(metadata.directoryID) else {
  71. return
  72. }
  73. let fileNamePath = CCUtility.returnFileNamePath(fromFileName: metadata.fileName, serverUrl: serverUrl, activeUrl: self.providerData.accountUrl)
  74. let ocNetworking = OCnetworking.init(delegate: nil, metadataNet: nil, withUser: providerData.accountUser, withUserID: providerData.accountUserID, withPassword: providerData.accountPassword, withUrl: providerData.accountUrl)
  75. ocNetworking?.settingFavorite(fileNamePath, favorite: favorite, success: {
  76. // Change DB
  77. metadata.favorite = favorite
  78. _ = NCManageDatabase.sharedInstance.addMetadata(metadata)
  79. }, failure: { (errorMessage, errorCode) in
  80. // Errore, remove from listFavoriteIdentifierRank
  81. listFavoriteIdentifierRank.removeValue(forKey: itemIdentifier.rawValue)
  82. let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier, providerData: self.providerData)
  83. fileProviderSignalUpdateItem[item.itemIdentifier] = item
  84. self.signalEnumerator(for: [item.parentItemIdentifier, .workingSet])
  85. })
  86. }
  87. // --------------------------------------------------------------------------------------------
  88. // MARK: - Upload
  89. // --------------------------------------------------------------------------------------------
  90. func uploadFileSuccessFailure(_ fileName: String!, fileID: String!, assetLocalIdentifier: String!, serverUrl: String!, selector: String!, selectorPost: String!, errorMessage: String!, errorCode: Int) {
  91. /* ONLY iOS 11*/
  92. guard #available(iOS 11, *) else { return }
  93. if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "fileID = %@", assetLocalIdentifier)) {
  94. let parentItemIdentifier = providerData.getParentItemIdentifier(metadata: metadata)
  95. if parentItemIdentifier != nil {
  96. let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier!, providerData: providerData)
  97. fileProviderSignalDeleteItemIdentifier[item.itemIdentifier] = item.itemIdentifier
  98. signalEnumerator(for: [item.parentItemIdentifier, .workingSet])
  99. }
  100. }
  101. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "fileID = %@", assetLocalIdentifier), clearDateReadDirectoryID: nil)
  102. if errorCode == 0 {
  103. NCManageDatabase.sharedInstance.deleteQueueUpload(assetLocalIdentifier: assetLocalIdentifier, selector: selector)
  104. if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "account = %@ AND fileID = %@", providerData.account, fileID)) {
  105. // Rename directory file
  106. if fileManager.fileExists(atPath: providerData.fileProviderStorageURL!.path + "/" + assetLocalIdentifier) {
  107. let itemIdentifier = providerData.getItemIdentifier(metadata: metadata)
  108. _ = moveFile(providerData.fileProviderStorageURL!.path + "/" + assetLocalIdentifier, toPath: providerData.fileProviderStorageURL!.path + "/" + itemIdentifier.rawValue)
  109. }
  110. NCManageDatabase.sharedInstance.setLocalFile(fileID: fileID, date: nil, exifDate: nil, exifLatitude: nil, exifLongitude: nil, fileName: nil, etag: metadata.etag, etagFPE: metadata.etag)
  111. guard let parentItemIdentifier = providerData.getParentItemIdentifier(metadata: metadata) else {
  112. return
  113. }
  114. let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier, providerData: providerData)
  115. fileProviderSignalUpdateItem[item.itemIdentifier] = item
  116. signalEnumerator(for: [item.parentItemIdentifier, .workingSet])
  117. }
  118. } else {
  119. NCManageDatabase.sharedInstance.unlockQueueUpload(assetLocalIdentifier: assetLocalIdentifier)
  120. }
  121. uploadFile()
  122. }
  123. func uploadFile() {
  124. let queueInLock = NCManageDatabase.sharedInstance.getQueueUploadInLock()
  125. if queueInLock != nil && queueInLock!.count == 0 {
  126. let metadataNetQueue = NCManageDatabase.sharedInstance.lockQueueUpload(selector: selectorUploadFile, withPath: true)
  127. if metadataNetQueue != nil {
  128. if self.copyFile(metadataNetQueue!.path, toPath: providerData.directoryUser + "/" + metadataNetQueue!.fileName) == nil {
  129. CCNetworking.shared().uploadFile(metadataNetQueue!.fileName, serverUrl: metadataNetQueue!.serverUrl, assetLocalIdentifier: metadataNetQueue!.assetLocalIdentifier ,session: metadataNetQueue!.session, taskStatus: metadataNetQueue!.taskStatus, selector: metadataNetQueue!.selector, selectorPost: metadataNetQueue!.selectorPost, errorCode: 0, delegate: self)
  130. } else {
  131. // file not present, delete record Upload Queue
  132. NCManageDatabase.sharedInstance.deleteQueueUpload(path: metadataNetQueue!.path)
  133. }
  134. }
  135. }
  136. }
  137. func verifyUploadQueueInLock() {
  138. let tasks = CCNetworking.shared().getUploadTasksExtensionSession()
  139. if tasks!.count == 0 {
  140. let records = NCManageDatabase.sharedInstance.getQueueUpload(predicate: NSPredicate(format: "account = %@ AND selector = %@ AND lock == true AND path != nil", providerData.account, selectorUploadFile))
  141. if records != nil && records!.count > 0 {
  142. NCManageDatabase.sharedInstance.unlockAllQueueUploadWithPath()
  143. }
  144. }
  145. }
  146. }