NCNetworkingE2EE.swift 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431
  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. NCNetworking.shared.readFile(serverUrlFileName: fileNameFolderUrl, account: account) { (account, metadataFolder, errorCode, errorDescription) in
  50. if errorCode == 0 {
  51. // Add Metadata
  52. metadataFolder?.fileNameView = fileNameFolder
  53. metadataFolder?.e2eEncrypted = true
  54. NCManageDatabase.sharedInstance.addMetadata(metadataFolder!)
  55. // Add folder
  56. NCManageDatabase.sharedInstance.addDirectory(encrypted: true, favorite: metadataFolder!.favorite, ocId: metadataFolder!.ocId, fileId: metadataFolder!.fileId, etag: nil, permissions: metadataFolder!.permissions, serverUrl: fileNameFolderUrl, richWorkspace: metadataFolder!.richWorkspace, account: account)
  57. NCCommunication.shared.markE2EEFolder(fileId: metadataFolder!.fileId, delete: false) { (account, errorCode, errorDescription) in
  58. if errorCode == 0 {
  59. let object = tableE2eEncryption()
  60. NCEndToEndEncryption.sharedManager()?.encryptkey(&key, initializationVector: &initializationVector)
  61. object.account = account
  62. object.authenticationTag = nil
  63. object.fileName = fileNameFolder
  64. object.fileNameIdentifier = fileNameIdentifier
  65. object.fileNamePath = ""
  66. object.key = key! as String
  67. object.initializationVector = initializationVector! as String
  68. if let result = NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) {
  69. object.metadataKey = result.metadataKey
  70. object.metadataKeyIndex = result.metadataKeyIndex
  71. } else {
  72. object.metadataKey = (NCEndToEndEncryption.sharedManager()?.generateKey(16)?.base64EncodedString(options: []))! as String // AES_KEY_128_LENGTH
  73. object.metadataKeyIndex = 0
  74. }
  75. object.mimeType = "httpd/unix-directory"
  76. object.serverUrl = serverUrl
  77. object.version = 1
  78. let _ = NCManageDatabase.sharedInstance.addE2eEncryption(object)
  79. self.sendE2EMetadata(account: account, serverUrl: serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: nil, url: url) { (e2eToken, errorCode, errorDescription) in
  80. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  81. }
  82. self.NotificationPost(name: k_notificationCenter_reloadDataSource, serverUrl: serverUrl, userInfo: ["serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  83. } else {
  84. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  85. }
  86. }
  87. } else {
  88. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  89. }
  90. }
  91. } else {
  92. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  93. }
  94. }
  95. } else {
  96. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  97. }
  98. }
  99. }
  100. //MARK: - WebDav Delete
  101. func deleteMetadata(_ metadata: tableMetadata, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  102. self.lock(account:metadata.account, serverUrl: metadata.serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  103. if errorCode == 0 && e2eToken != nil && directory != nil {
  104. let deleteE2eEncryption = NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameIdentifier == %@", metadata.account, metadata.serverUrl, metadata.fileName)
  105. NCNetworking.shared.deleteMetadataPlain(metadata, addCustomHeaders: ["e2e-token" :e2eToken!]) { (errorCode, errorDescription) in
  106. let webDavRoot = NCManageDatabase.sharedInstance.getCapabilitiesServerString(account: metadata.account, elements: NCElementsJSON.shared.capabilitiesWebDavRoot) ?? "remote.php/webdav"
  107. let home = url + "/" + webDavRoot
  108. if metadata.serverUrl != home {
  109. self.sendE2EMetadata(account: metadata.account, serverUrl: metadata.serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: deleteE2eEncryption, url: url) { (e2eToken, errorCode, errorDescription) in
  110. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  111. }
  112. } else {
  113. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  114. }
  115. }
  116. } else {
  117. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  118. }
  119. }
  120. }
  121. //MARK: - WebDav Rename
  122. func renameMetadata(_ metadata: tableMetadata, fileNameNew: String, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String?)->()) {
  123. // verify if exists the new fileName
  124. if NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileName == %@", metadata.account, metadata.serverUrl, fileNameNew)) != nil {
  125. self.NotificationPost(name: k_notificationCenter_renameFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": Int(k_CCErrorInternalError)], errorDescription: "_file_already_exists_", completion: completion)
  126. } else {
  127. self.sendE2EMetadata(account: metadata.account, serverUrl: metadata.serverUrl, fileNameRename: metadata.fileName, fileNameNewRename: fileNameNew, deleteE2eEncryption: nil, url: url) { (e2eToken, errorCode, errorDescription) in
  128. if errorCode == 0 {
  129. NCManageDatabase.sharedInstance.setMetadataFileNameView(serverUrl: metadata.serverUrl, fileName: metadata.fileName, newFileNameView: fileNameNew, account: metadata.account)
  130. // Move file system
  131. let atPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId) + "/" + metadata.fileNameView
  132. let toPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId) + "/" + fileNameNew
  133. do {
  134. try FileManager.default.moveItem(atPath: atPath, toPath: toPath)
  135. } catch { }
  136. }
  137. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  138. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  139. }
  140. }
  141. }
  142. //MARK: - Upload
  143. func upload(metadata: tableMetadata, account: tableAccount, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  144. let objectE2eEncryption = tableE2eEncryption()
  145. var key: NSString?, initializationVector: NSString?, authenticationTag: NSString?
  146. let metadata = tableMetadata.init(value: metadata)
  147. let serverUrl = metadata.serverUrl
  148. metadata.fileName = CCUtility.generateRandomIdentifier()!
  149. metadata.e2eEncrypted = true
  150. let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileName)!
  151. let serverUrlFileName = serverUrl + "/" + metadata.fileName
  152. if NCEndToEndEncryption.sharedManager()?.encryptFileName(metadata.fileNameView, fileNameIdentifier: metadata.fileName, directory: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId), key: &key, initializationVector: &initializationVector, authenticationTag: &authenticationTag) == false {
  153. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":k_CCErrorInternalError, "errorDescription":"_e2e_error_create_encrypted_"])
  154. completion(Int(k_CCErrorInternalError), "_e2e_error_create_encrypted_")
  155. return
  156. }
  157. if let result = NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, serverUrl)) {
  158. objectE2eEncryption.metadataKey = result.metadataKey
  159. objectE2eEncryption.metadataKeyIndex = result.metadataKeyIndex
  160. } else {
  161. let key = NCEndToEndEncryption.sharedManager()?.generateKey(16) as NSData?
  162. objectE2eEncryption.metadataKey = key!.base64EncodedString()
  163. objectE2eEncryption.metadataKeyIndex = 0
  164. }
  165. objectE2eEncryption.account = metadata.account
  166. objectE2eEncryption.authenticationTag = authenticationTag as String?
  167. objectE2eEncryption.fileName = metadata.fileNameView
  168. objectE2eEncryption.fileNameIdentifier = metadata.fileName
  169. objectE2eEncryption.fileNamePath = fileNameLocalPath
  170. objectE2eEncryption.key = key! as String
  171. objectE2eEncryption.initializationVector = initializationVector! as String
  172. objectE2eEncryption.mimeType = metadata.contentType
  173. objectE2eEncryption.serverUrl = serverUrl
  174. objectE2eEncryption.version = 1
  175. if NCManageDatabase.sharedInstance.addE2eEncryption(objectE2eEncryption) == false {
  176. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":k_CCErrorInternalError, "errorDescription":"_e2e_error_create_encrypted_"])
  177. completion(Int(k_CCErrorInternalError), "_e2e_error_create_encrypted_")
  178. return
  179. }
  180. NCNetworkingE2EE.shared.sendE2EMetadata(account: metadata.account, serverUrl: serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: nil, url: account.url, upload: true) { (e2eToken, errorCode, errorDescription) in
  181. if errorCode == 0 && e2eToken != nil {
  182. // Start Upload file
  183. metadata.status = Int(k_metadataStatusInUpload)
  184. metadata.session = NCCommunicationCommon.shared.sessionIdentifierUpload
  185. NCManageDatabase.sharedInstance.addMetadata(metadata)
  186. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  187. NCCommunication.shared.upload(serverUrlFileName: serverUrlFileName, fileNameLocalPath: fileNameLocalPath, dateCreationFile: metadata.date as Date, dateModificationFile: metadata.date as Date, addCustomHeaders: ["e2e-token":e2eToken!], requestHandler: { (request) in
  188. NCNetworking.shared.uploadRequest[fileNameLocalPath] = request
  189. NCManageDatabase.sharedInstance.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: nil, sessionSelector: nil, sessionTaskIdentifier: nil, status: Int(k_metadataStatusUploading))
  190. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadFileStart, userInfo: ["ocId":metadata.ocId, "serverUrl":serverUrl, "account": metadata.account])
  191. }, progressHandler: { (progress) in
  192. 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)])
  193. }) { (account, ocId, etag, date, size, error, errorCode, errorDescription) in
  194. NCNetworking.shared.uploadRequest[fileNameLocalPath] = nil
  195. if error?.isExplicitlyCancelledError ?? false {
  196. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  197. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  198. } else if errorCode == 0 && ocId != nil {
  199. let metadata = tableMetadata.init(value: metadata)
  200. CCUtility.moveFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId), toPath: CCUtility.getDirectoryProviderStorageOcId(ocId))
  201. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  202. metadata.date = date ?? NSDate()
  203. metadata.etag = etag ?? ""
  204. metadata.ocId = ocId!
  205. metadata.session = ""
  206. metadata.sessionError = ""
  207. metadata.status = Int(k_metadataStatusNormal)
  208. NCManageDatabase.sharedInstance.addLocalFile(metadata: metadata)
  209. NCManageDatabase.sharedInstance.addMetadata(metadata)
  210. //CCGraphics.createNewImage(from: metadata.fileNameView, ocId: metadata.ocId, filterGrayScale: false, typeFile: metadata.typeFile, writeImage: true)
  211. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":errorCode, "errorDescription":""])
  212. } else if errorCode == 401 || errorCode == 403 {
  213. NCNetworkingCheckRemoteUser.shared.checkRemoteUser(account: metadata.account)
  214. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  215. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  216. } else if errorCode == Int(CFNetworkErrors.cfurlErrorServerCertificateUntrusted.rawValue) {
  217. CCUtility.setCertificateError(metadata.account, error: true)
  218. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  219. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  220. } else {
  221. NCManageDatabase.sharedInstance.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: errorDescription, sessionTaskIdentifier: 0, status: Int(k_metadataStatusUploadError))
  222. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":errorCode, "errorDescription":errorDescription])
  223. }
  224. NCNetworkingE2EE.shared.unlock(account: metadata.account, serverUrl: serverUrl) { (_, _, _, _) in }
  225. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_reloadDataSource, userInfo: ["ocId":metadata.ocId, "serverUrl":metadata.serverUrl])
  226. completion(errorCode, errorDescription)
  227. }
  228. } else {
  229. NotificationCenter.default.postOnMainThread(name: k_notificationCenter_uploadedFile, userInfo: ["metadata":metadata, "errorCode":errorCode, "errorDescription":errorDescription ?? ""])
  230. completion(errorCode, errorDescription ?? "")
  231. }
  232. }
  233. }
  234. //MARK: - E2EE
  235. @objc func lock(account:String, serverUrl: String, completion: @escaping (_ direcrtory: tableDirectory?, _ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  236. var e2eToken: String?
  237. guard let directory = NCManageDatabase.sharedInstance.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) else {
  238. completion(nil, nil, 0, "")
  239. return
  240. }
  241. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  242. e2eToken = tableLock.e2eToken
  243. }
  244. NCCommunication.shared.lockE2EEFolder(fileId: directory.fileId, e2eToken: e2eToken, delete: false) { (account, e2eToken, errorCode, errorDescription) in
  245. if errorCode == 0 && e2eToken != nil {
  246. NCManageDatabase.sharedInstance.setE2ETokenLock(serverUrl: serverUrl, fileId: directory.fileId, e2eToken: e2eToken!)
  247. }
  248. completion(directory, e2eToken, errorCode, errorDescription)
  249. }
  250. }
  251. @objc func unlock(account:String, serverUrl: String, completion: @escaping (_ direcrtory: tableDirectory?, _ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  252. var e2eToken: String?
  253. guard let directory = NCManageDatabase.sharedInstance.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) else {
  254. completion(nil, nil, 0, "")
  255. return
  256. }
  257. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  258. e2eToken = tableLock.e2eToken
  259. }
  260. NCCommunication.shared.lockE2EEFolder(fileId: directory.fileId, e2eToken: e2eToken, delete: true) { (account, e2eToken, errorCode, errorDescription) in
  261. if errorCode == 0 {
  262. NCManageDatabase.sharedInstance.deteleE2ETokenLock(serverUrl: serverUrl)
  263. }
  264. completion(directory, e2eToken, errorCode, errorDescription)
  265. }
  266. }
  267. @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?)->()) {
  268. self.lock(account: account, serverUrl: serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  269. if errorCode == 0 && e2eToken != nil && directory != nil {
  270. NCCommunication.shared.getE2EEMetadata(fileId: directory!.fileId, e2eToken: e2eToken) { (account, e2eMetadata, errorCode, errorDescription) in
  271. var method = "POST"
  272. var e2eMetadataNew: String?
  273. if errorCode == 0 && e2eMetadata != nil {
  274. if !NCEndToEndMetadata.sharedInstance.decoderMetadata(e2eMetadata!, privateKey: CCUtility.getEndToEndPrivateKey(account), serverUrl: serverUrl, account: account, url: url) {
  275. completion(e2eToken, Int(k_CCErrorInternalError), NSLocalizedString("_e2e_error_encode_metadata_", comment: ""))
  276. return
  277. }
  278. method = "PUT"
  279. }
  280. // Rename
  281. if (fileNameRename != nil && fileNameNewRename != nil) {
  282. NCManageDatabase.sharedInstance.renameFileE2eEncryption(serverUrl: serverUrl, fileNameIdentifier: fileNameRename!, newFileName: fileNameNewRename!, newFileNamePath: CCUtility.returnFileNamePath(fromFileName: fileNameNewRename!, serverUrl: serverUrl, activeUrl: url))
  283. }
  284. // Delete
  285. if deleteE2eEncryption != nil {
  286. NCManageDatabase.sharedInstance.deleteE2eEncryption(predicate: deleteE2eEncryption!)
  287. }
  288. // Rebuild metadata for send it
  289. let tableE2eEncryption = NCManageDatabase.sharedInstance.getE2eEncryptions(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl))
  290. if tableE2eEncryption != nil {
  291. e2eMetadataNew = NCEndToEndMetadata.sharedInstance.encoderMetadata(tableE2eEncryption!, privateKey: CCUtility.getEndToEndPrivateKey(account), serverUrl: serverUrl)
  292. }
  293. NCCommunication.shared.putE2EEMetadata(fileId: directory!.fileId, e2eToken: e2eToken!, e2eMetadata: e2eMetadataNew, method: method) { (account, e2eMetadata, errorCode, errorDescription) in
  294. if upload {
  295. completion(e2eToken, errorCode, errorDescription)
  296. } else {
  297. self.unlock(account: account, serverUrl: serverUrl) { (_, e2eToken, _, _) in
  298. completion(e2eToken, errorCode, errorDescription)
  299. }
  300. }
  301. }
  302. }
  303. } else {
  304. completion(e2eToken, errorCode, errorDescription)
  305. }
  306. }
  307. }
  308. //MARK: - Notification Post
  309. private func NotificationPost(name: String, serverUrl: String, userInfo: [AnyHashable : Any], errorDescription: Any?, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  310. var userInfo = userInfo
  311. DispatchQueue.main.async {
  312. // unlock
  313. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  314. NCCommunication.shared.lockE2EEFolder(fileId: tableLock.fileId, e2eToken: tableLock.e2eToken, delete: true) { (_, _, _, _) in }
  315. }
  316. if errorDescription == nil { userInfo["errorDescription"] = "" }
  317. else { userInfo["errorDescription"] = NSLocalizedString(errorDescription as! String, comment: "") }
  318. NotificationCenter.default.postOnMainThread(name: name, userInfo: userInfo)
  319. completion(userInfo["errorCode"] as! Int, userInfo["errorDescription"] as! String)
  320. }
  321. }
  322. }