NCNetworkingE2EE.swift 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429
  1. //
  2. // NCNetworkingE2EE.swift
  3. // Nextcloud
  4. //
  5. // Created by Marino Faggiana on 05/05/2020.
  6. // Copyright © 2020 Marino Faggiana. All rights reserved.
  7. //
  8. // This program is free software: you can redistribute it and/or modify
  9. // it under the terms of the GNU General Public License as published by
  10. // the Free Software Foundation, either version 3 of the License, or
  11. // (at your option) any later version.
  12. //
  13. // This program is distributed in the hope that it will be useful,
  14. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. // GNU General Public License for more details.
  17. //
  18. // You should have received a copy of the GNU General Public License
  19. // along with this program. If not, see <http://www.gnu.org/licenses/>.
  20. //
  21. import Foundation
  22. import OpenSSL
  23. import NCCommunication
  24. import CFNetwork
  25. import Alamofire
  26. @objc class NCNetworkingE2EE: NSObject {
  27. @objc public static let shared: NCNetworkingE2EE = {
  28. let instance = NCNetworkingE2EE()
  29. return instance
  30. }()
  31. //MARK: - WebDav Create Folder
  32. func createFolder(fileName: String, serverUrl: String, account: String, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  33. var fileNameFolder = CCUtility.removeForbiddenCharactersServer(fileName)!
  34. var fileNameFolderUrl = ""
  35. var fileNameIdentifier = ""
  36. var key: NSString?
  37. var initializationVector: NSString?
  38. fileNameFolder = NCUtility.sharedInstance.createFileName(fileNameFolder, serverUrl: serverUrl, account: account)
  39. if fileNameFolder.count == 0 {
  40. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": Int(0)], errorDescription: "", completion: completion)
  41. return
  42. }
  43. fileNameIdentifier = CCUtility.generateRandomIdentifier()
  44. fileNameFolderUrl = serverUrl + "/" + fileNameIdentifier
  45. self.lock(account: account, serverUrl: serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  46. if errorCode == 0 && e2eToken != nil && directory != nil {
  47. NCCommunication.shared.createFolder(fileNameFolderUrl, addCustomHeaders: ["e2e-token" : e2eToken!]) { (account, ocId, date, errorCode, errorDescription) in
  48. if errorCode == 0 {
  49. NCCommunication.shared.markE2EEFolder(fileId: ocId!, delete: false) { (account, errorCode, errorDescription) in
  50. if errorCode == 0 {
  51. let object = tableE2eEncryption()
  52. NCEndToEndEncryption.sharedManager()?.encryptkey(&key, initializationVector: &initializationVector)
  53. object.account = account
  54. object.authenticationTag = nil
  55. object.fileName = fileNameFolder
  56. object.fileNameIdentifier = fileNameIdentifier
  57. object.fileNamePath = ""
  58. object.key = key! as String
  59. object.initializationVector = initializationVector! as String
  60. if let result = NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) {
  61. object.metadataKey = result.metadataKey
  62. object.metadataKeyIndex = result.metadataKeyIndex
  63. } else {
  64. object.metadataKey = (NCEndToEndEncryption.sharedManager()?.generateKey(16)?.base64EncodedString(options: []))! as String // AES_KEY_128_LENGTH
  65. object.metadataKeyIndex = 0
  66. }
  67. object.mimeType = "httpd/unix-directory"
  68. object.serverUrl = serverUrl
  69. object.version = 1
  70. let _ = NCManageDatabase.sharedInstance.addE2eEncryption(object)
  71. self.sendE2EMetadata(account: account, serverUrl: serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: nil, url: url) { (e2eToken, errorCode, errorDescription) in
  72. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  73. }
  74. } else {
  75. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  76. }
  77. }
  78. } else {
  79. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  80. }
  81. }
  82. } else {
  83. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  84. }
  85. }
  86. }
  87. //MARK: - WebDav Delete
  88. func deleteMetadata(_ metadata: tableMetadata, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  89. self.lock(account:metadata.account, serverUrl: metadata.serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  90. if errorCode == 0 && e2eToken != nil && directory != nil {
  91. let deleteE2eEncryption = NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameIdentifier == %@", metadata.account, metadata.serverUrl, metadata.fileName)
  92. NCNetworking.shared.deleteMetadataPlain(metadata, addCustomHeaders: ["e2e-token" :e2eToken!]) { (errorCode, errorDescription) in
  93. let webDavRoot = NCManageDatabase.sharedInstance.getCapabilitiesServerString(account: metadata.account, elements: NCElementsJSON.shared.capabilitiesWebDavRoot) ?? "remote.php/webdav"
  94. let home = url + "/" + webDavRoot
  95. if metadata.serverUrl != home {
  96. self.sendE2EMetadata(account: metadata.account, serverUrl: metadata.serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: deleteE2eEncryption, url: url) { (e2eToken, errorCode, errorDescription) in
  97. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  98. }
  99. } else {
  100. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  101. }
  102. }
  103. } else {
  104. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  105. }
  106. }
  107. }
  108. //MARK: - WebDav Rename
  109. func renameMetadata(_ metadata: tableMetadata, fileNameNew: String, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String?)->()) {
  110. // verify if exists the new fileName
  111. if NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileName == %@", metadata.account, metadata.serverUrl, fileNameNew)) != nil {
  112. self.NotificationPost(name: k_notificationCenter_renameFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": Int(k_CCErrorInternalError)], errorDescription: "_file_already_exists_", completion: completion)
  113. } else {
  114. self.sendE2EMetadata(account: metadata.account, serverUrl: metadata.serverUrl, fileNameRename: metadata.fileName, fileNameNewRename: fileNameNew, deleteE2eEncryption: nil, url: url) { (e2eToken, errorCode, errorDescription) in
  115. if errorCode == 0 {
  116. NCManageDatabase.sharedInstance.setMetadataFileNameView(serverUrl: metadata.serverUrl, fileName: metadata.fileName, newFileNameView: fileNameNew, account: metadata.account)
  117. // Move file system
  118. let atPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId) + "/" + metadata.fileNameView
  119. let toPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId) + "/" + fileNameNew
  120. do {
  121. try FileManager.default.moveItem(atPath: atPath, toPath: toPath)
  122. } catch { }
  123. }
  124. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  125. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  126. }
  127. }
  128. }
  129. //MARK: - Upload
  130. func upload(metadata: tableMetadata, account: tableAccount, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  131. let objectE2eEncryption = tableE2eEncryption()
  132. var key: NSString?, initializationVector: NSString?, authenticationTag: NSString?
  133. let ocIdTemp = metadata.ocId
  134. let serverUrl = metadata.serverUrl
  135. // Update metadata
  136. let metadataUpdate = tableMetadata.init(value: metadata)
  137. metadataUpdate.fileName = CCUtility.generateRandomIdentifier()!
  138. metadataUpdate.e2eEncrypted = true
  139. metadataUpdate.status = Int(k_metadataStatusInUpload)
  140. metadataUpdate.session = NCCommunicationCommon.shared.sessionIdentifierUpload
  141. metadataUpdate.sessionError = ""
  142. NCManageDatabase.sharedInstance.addMetadata(metadataUpdate)
  143. let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileName)!
  144. let serverUrlFileName = serverUrl + "/" + metadata.fileName
  145. if NCEndToEndEncryption.sharedManager()?.encryptFileName(metadata.fileNameView, fileNameIdentifier: metadata.fileName, directory: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId), key: &key, initializationVector: &initializationVector, authenticationTag: &authenticationTag) == false {
  146. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":k_CCErrorInternalError, "errorDescription":"_e2e_error_create_encrypted_"])
  147. completion(Int(k_CCErrorInternalError), "_e2e_error_create_encrypted_")
  148. return
  149. }
  150. if let result = NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, serverUrl)) {
  151. objectE2eEncryption.metadataKey = result.metadataKey
  152. objectE2eEncryption.metadataKeyIndex = result.metadataKeyIndex
  153. } else {
  154. let key = NCEndToEndEncryption.sharedManager()?.generateKey(16) as NSData?
  155. objectE2eEncryption.metadataKey = key!.base64EncodedString()
  156. objectE2eEncryption.metadataKeyIndex = 0
  157. }
  158. objectE2eEncryption.account = metadata.account
  159. objectE2eEncryption.authenticationTag = authenticationTag as String?
  160. objectE2eEncryption.fileName = metadata.fileNameView
  161. objectE2eEncryption.fileNameIdentifier = metadata.fileName
  162. objectE2eEncryption.fileNamePath = fileNameLocalPath
  163. objectE2eEncryption.key = key! as String
  164. objectE2eEncryption.initializationVector = initializationVector! as String
  165. objectE2eEncryption.mimeType = metadata.contentType
  166. objectE2eEncryption.serverUrl = serverUrl
  167. objectE2eEncryption.version = 1
  168. if NCManageDatabase.sharedInstance.addE2eEncryption(objectE2eEncryption) == false {
  169. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":k_CCErrorInternalError, "errorDescription":"_e2e_error_create_encrypted_"])
  170. completion(Int(k_CCErrorInternalError), "_e2e_error_create_encrypted_")
  171. return
  172. }
  173. guard let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp)) else { return }
  174. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  175. NCNetworkingE2EE.shared.sendE2EMetadata(account: metadata.account, serverUrl: serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: nil, url: account.url, upload: true) { (e2eToken, errorCode, errorDescription) in
  176. if errorCode == 0 && e2eToken != nil {
  177. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  178. NCCommunication.shared.upload(serverUrlFileName: serverUrlFileName, fileNameLocalPath: fileNameLocalPath, dateCreationFile: metadata.date as Date, dateModificationFile: metadata.date as Date, addCustomHeaders: ["e2e-token":e2eToken!], requestHandler: { (request) in
  179. NCNetworking.shared.uploadRequest[fileNameLocalPath] = request
  180. NCManageDatabase.sharedInstance.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: nil, sessionSelector: nil, sessionTaskIdentifier: nil, status: Int(k_metadataStatusUploading))
  181. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadFileStart, userInfo: ["ocId":metadata.ocId, "serverUrl":serverUrl, "account": metadata.account])
  182. }, progressHandler: { (progress) in
  183. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_progressTask, userInfo: ["account":metadata.account, "ocId":metadata.ocId, "serverUrl":serverUrl, "status":NSNumber(value: k_metadataStatusInUpload), "progress":NSNumber(value: progress.fractionCompleted), "totalBytes":NSNumber(value: progress.totalUnitCount), "totalBytesExpected":NSNumber(value: progress.completedUnitCount)])
  184. }) { (account, ocId, etag, date, size, error, errorCode, errorDescription) in
  185. NCNetworking.shared.uploadRequest[fileNameLocalPath] = nil
  186. guard let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId)) else { return }
  187. if error?.isExplicitlyCancelledError ?? false {
  188. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  189. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  190. } else if errorCode == 0 && ocId != nil {
  191. guard let metadataTemp = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId)) else { return }
  192. let metadata = tableMetadata.init(value: metadataTemp)
  193. CCUtility.moveFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId), toPath: CCUtility.getDirectoryProviderStorageOcId(ocId))
  194. metadata.date = date ?? NSDate()
  195. metadata.etag = etag ?? ""
  196. metadata.ocId = ocId!
  197. metadata.session = ""
  198. metadata.sessionError = ""
  199. metadata.sessionTaskIdentifier = 0
  200. metadata.status = Int(k_metadataStatusNormal)
  201. NCManageDatabase.sharedInstance.addMetadata(metadata)
  202. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  203. NCManageDatabase.sharedInstance.addLocalFile(metadata: metadata)
  204. //CCGraphics.createNewImage(from: metadata.fileNameView, ocId: metadata.ocId, filterGrayScale: false, typeFile: metadata.typeFile, writeImage: true)
  205. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":errorCode, "errorDescription":""])
  206. } else if errorCode == 401 || errorCode == 403 {
  207. NCNetworkingCheckRemoteUser.shared.checkRemoteUser(account: metadata.account)
  208. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  209. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  210. } else if errorCode == Int(CFNetworkErrors.cfurlErrorServerCertificateUntrusted.rawValue) {
  211. CCUtility.setCertificateError(metadata.account, error: true)
  212. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  213. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  214. } else {
  215. NCManageDatabase.sharedInstance.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: errorDescription, sessionTaskIdentifier: 0, status: Int(k_metadataStatusUploadError))
  216. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":errorCode, "errorDescription":errorDescription])
  217. }
  218. NCNetworkingE2EE.shared.unlock(account: metadata.account, serverUrl: serverUrl) { (_, _, _, _) in }
  219. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  220. completion(errorCode, errorDescription)
  221. }
  222. } else {
  223. if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp)) {
  224. NCManageDatabase.sharedInstance.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: errorDescription, sessionTaskIdentifier: 0, status: Int(k_metadataStatusUploadError))
  225. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":errorCode, "errorDescription":errorDescription ?? ""])
  226. }
  227. completion(errorCode, errorDescription ?? "")
  228. }
  229. }
  230. }
  231. //MARK: - E2EE
  232. @objc func lock(account:String, serverUrl: String, completion: @escaping (_ direcrtory: tableDirectory?, _ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  233. var e2eToken: String?
  234. guard let directory = NCManageDatabase.sharedInstance.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) else {
  235. completion(nil, nil, 0, "")
  236. return
  237. }
  238. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  239. e2eToken = tableLock.e2eToken
  240. }
  241. NCCommunication.shared.lockE2EEFolder(fileId: directory.fileId, e2eToken: e2eToken, method: "POST") { (account, e2eToken, errorCode, errorDescription) in
  242. if errorCode == 0 && e2eToken != nil {
  243. NCManageDatabase.sharedInstance.setE2ETokenLock(serverUrl: serverUrl, fileId: directory.fileId, e2eToken: e2eToken!)
  244. }
  245. completion(directory, e2eToken, errorCode, errorDescription)
  246. }
  247. }
  248. @objc func unlock(account:String, serverUrl: String, completion: @escaping (_ direcrtory: tableDirectory?, _ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  249. var e2eToken: String?
  250. guard let directory = NCManageDatabase.sharedInstance.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) else {
  251. completion(nil, nil, 0, "")
  252. return
  253. }
  254. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  255. e2eToken = tableLock.e2eToken
  256. }
  257. NCCommunication.shared.lockE2EEFolder(fileId: directory.fileId, e2eToken: e2eToken, method: "DELETE") { (account, e2eToken, errorCode, errorDescription) in
  258. if errorCode == 0 {
  259. NCManageDatabase.sharedInstance.deteleE2ETokenLock(serverUrl: serverUrl)
  260. }
  261. completion(directory, e2eToken, errorCode, errorDescription)
  262. }
  263. }
  264. @objc func sendE2EMetadata(account: String, serverUrl: String, fileNameRename: String?, fileNameNewRename: String?, deleteE2eEncryption : NSPredicate?, url: String, upload: Bool = false, completion: @escaping (_ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  265. self.lock(account: account, serverUrl: serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  266. if errorCode == 0 && e2eToken != nil && directory != nil {
  267. NCCommunication.shared.getE2EEMetadata(fileId: directory!.fileId, e2eToken: e2eToken) { (account, e2eMetadata, errorCode, errorDescription) in
  268. var method = "POST"
  269. var e2eMetadataNew: String?
  270. if errorCode == 0 && e2eMetadata != nil {
  271. if !NCEndToEndMetadata.sharedInstance.decoderMetadata(e2eMetadata!, privateKey: CCUtility.getEndToEndPrivateKey(account), serverUrl: serverUrl, account: account, url: url) {
  272. completion(e2eToken, Int(k_CCErrorInternalError), NSLocalizedString("_e2e_error_encode_metadata_", comment: ""))
  273. return
  274. }
  275. method = "PUT"
  276. }
  277. // Rename
  278. if (fileNameRename != nil && fileNameNewRename != nil) {
  279. NCManageDatabase.sharedInstance.renameFileE2eEncryption(serverUrl: serverUrl, fileNameIdentifier: fileNameRename!, newFileName: fileNameNewRename!, newFileNamePath: CCUtility.returnFileNamePath(fromFileName: fileNameNewRename!, serverUrl: serverUrl, activeUrl: url))
  280. }
  281. // Delete
  282. if deleteE2eEncryption != nil {
  283. NCManageDatabase.sharedInstance.deleteE2eEncryption(predicate: deleteE2eEncryption!)
  284. }
  285. // Rebuild metadata for send it
  286. let tableE2eEncryption = NCManageDatabase.sharedInstance.getE2eEncryptions(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl))
  287. if tableE2eEncryption != nil {
  288. e2eMetadataNew = NCEndToEndMetadata.sharedInstance.encoderMetadata(tableE2eEncryption!, privateKey: CCUtility.getEndToEndPrivateKey(account), serverUrl: serverUrl)
  289. } else {
  290. method = "DELETE"
  291. }
  292. NCCommunication.shared.putE2EEMetadata(fileId: directory!.fileId, e2eToken: e2eToken!, e2eMetadata: e2eMetadataNew, method: method) { (account, e2eMetadata, errorCode, errorDescription) in
  293. if upload {
  294. completion(e2eToken, errorCode, errorDescription)
  295. } else {
  296. self.unlock(account: account, serverUrl: serverUrl) { (_, e2eToken, _, _) in
  297. completion(e2eToken, errorCode, errorDescription)
  298. }
  299. }
  300. }
  301. }
  302. } else {
  303. completion(e2eToken, errorCode, errorDescription)
  304. }
  305. }
  306. }
  307. //MARK: - Notification Post
  308. private func NotificationPost(name: String, serverUrl: String, userInfo: [AnyHashable : Any], errorDescription: Any?, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  309. var userInfo = userInfo
  310. DispatchQueue.main.async {
  311. // unlock
  312. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  313. NCCommunication.shared.lockE2EEFolder(fileId: tableLock.fileId, e2eToken: tableLock.e2eToken, method: "DELETE") { (_, _, _, _) in }
  314. }
  315. if errorDescription == nil { userInfo["errorDescription"] = "" }
  316. else { userInfo["errorDescription"] = NSLocalizedString(errorDescription as! String, comment: "") }
  317. NotificationCenter.default.postOnMainThread(name: name, userInfo: userInfo)
  318. completion(userInfo["errorCode"] as! Int, userInfo["errorDescription"] as! String)
  319. }
  320. }
  321. }