NCNetworkingE2EE.swift 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466
  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. @objc class NCNetworkingE2EE: NSObject {
  26. @objc public static let shared: NCNetworkingE2EE = {
  27. let instance = NCNetworkingE2EE()
  28. return instance
  29. }()
  30. let appDelegate = UIApplication.shared.delegate as! AppDelegate
  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. if let e2eeApiVersion = NCManageDatabase.sharedInstance.getCapabilitiesServerString(account: account, elements: NCElementsJSON.shared.capabilitiesE2EEApiVersion) {
  78. object.version = Int(e2eeApiVersion) ?? 1
  79. } else {
  80. object.version = 1
  81. }
  82. let _ = NCManageDatabase.sharedInstance.addE2eEncryption(object)
  83. self.sendE2EMetadata(account: account, serverUrl: serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: nil, url: url) { (e2eToken, errorCode, errorDescription) in
  84. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  85. }
  86. } else {
  87. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  88. }
  89. }
  90. } else {
  91. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  92. }
  93. }
  94. } else {
  95. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  96. }
  97. }
  98. } else {
  99. self.NotificationPost(name: k_notificationCenter_createFolder, serverUrl: serverUrl, userInfo: ["fileName": fileName, "serverUrl": serverUrl, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  100. }
  101. }
  102. }
  103. //MARK: - WebDav Delete
  104. func deleteMetadata(_ metadata: tableMetadata, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  105. self.lock(account:metadata.account, serverUrl: metadata.serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  106. if errorCode == 0 && e2eToken != nil && directory != nil {
  107. let deleteE2eEncryption = NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameIdentifier == %@", metadata.account, metadata.serverUrl, metadata.fileName)
  108. NCNetworking.shared.deleteMetadataPlain(metadata, addCustomHeaders: ["e2e-token" :e2eToken!]) { (errorCode, errorDescription) in
  109. let webDavRoot = NCManageDatabase.sharedInstance.getCapabilitiesServerString(account: metadata.account, elements: NCElementsJSON.shared.capabilitiesWebDavRoot) ?? "remote.php/webdav"
  110. let home = url + "/" + webDavRoot
  111. if metadata.serverUrl != home {
  112. self.sendE2EMetadata(account: metadata.account, serverUrl: metadata.serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: deleteE2eEncryption, url: url) { (e2eToken, errorCode, errorDescription) in
  113. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  114. }
  115. } else {
  116. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  117. }
  118. }
  119. } else {
  120. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  121. }
  122. }
  123. }
  124. //MARK: - WebDav Rename
  125. func renameMetadata(_ metadata: tableMetadata, fileNameNew: String, url: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String?)->()) {
  126. // verify if exists the new fileName
  127. if NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileName == %@", metadata.account, metadata.serverUrl, fileNameNew)) != nil {
  128. self.NotificationPost(name: k_notificationCenter_renameFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": Int(k_CCErrorInternalError)], errorDescription: "_file_already_exists_", completion: completion)
  129. } else {
  130. self.sendE2EMetadata(account: metadata.account, serverUrl: metadata.serverUrl, fileNameRename: metadata.fileName, fileNameNewRename: fileNameNew, deleteE2eEncryption: nil, url: url) { (e2eToken, errorCode, errorDescription) in
  131. if errorCode == 0 {
  132. NCManageDatabase.sharedInstance.setMetadataFileNameView(serverUrl: metadata.serverUrl, fileName: metadata.fileName, newFileNameView: fileNameNew, account: metadata.account)
  133. // Move file system
  134. let atPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId) + "/" + metadata.fileNameView
  135. let toPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId) + "/" + fileNameNew
  136. do {
  137. try FileManager.default.moveItem(atPath: atPath, toPath: toPath)
  138. } catch { }
  139. let atPathIcon = CCUtility.getDirectoryProviderStorageIconOcId(metadata.ocId, fileNameView: metadata.fileNameView)!
  140. let toPathIcon = CCUtility.getDirectoryProviderStorageIconOcId(metadata.ocId, fileNameView: fileNameNew)!
  141. do {
  142. try FileManager.default.moveItem(atPath: atPathIcon, toPath: toPathIcon)
  143. } catch { }
  144. }
  145. self.NotificationPost(name: k_notificationCenter_deleteFile, serverUrl: metadata.serverUrl, userInfo: ["metadata": metadata, "errorCode": errorCode], errorDescription: errorDescription, completion: completion)
  146. }
  147. }
  148. }
  149. //MARK: - Upload
  150. @objc func upload(metadata: tableMetadata) {
  151. var metadataForUpload: tableMetadata?
  152. let internalContenType = NCCommunicationCommon.shared.getInternalContenType(fileName: metadata.fileNameView, contentType: metadata.contentType, directory: false)
  153. var fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileNameView)!
  154. let fileNameIdentifier = CCUtility.generateRandomIdentifier()!
  155. if CCUtility.fileProviderStorageExists(metadata.ocId, fileNameView: metadata.fileNameView) {
  156. metadata.fileName = fileNameIdentifier
  157. metadata.e2eEncrypted = true
  158. metadata.contentType = internalContenType.contentType
  159. metadata.iconName = internalContenType.iconName
  160. metadata.typeFile = internalContenType.typeFile
  161. metadata.date = NCUtilityFileSystem.shared.getFileModificationDate(filePath: fileNameLocalPath) as NSDate
  162. metadata.size = NCUtilityFileSystem.shared.getFileSize(filePath: fileNameLocalPath)
  163. metadata.session = k_upload_session_default
  164. if metadata.size > Double(k_max_filesize_E2EE) {
  165. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_uploadedFile), object: nil, userInfo: ["metadata":metadata, "errorCode":k_CCErrorInternalError, "errorDescription":"E2E Error file too big"])
  166. return
  167. }
  168. metadataForUpload = NCManageDatabase.sharedInstance.addMetadata(metadata)
  169. self.upload(metadataForUpload: metadataForUpload!)
  170. } else {
  171. CCUtility.extractImageVideoFromAssetLocalIdentifier(forUpload: metadata, notification: true) { (extractMetadata, fileNamePath) in
  172. guard let extractMetadata = extractMetadata else {
  173. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  174. return
  175. }
  176. fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(extractMetadata.ocId, fileNameView: extractMetadata.fileNameView)
  177. CCUtility.moveFile(atPath: fileNamePath, toPath: fileNameLocalPath)
  178. extractMetadata.fileName = fileNameIdentifier
  179. extractMetadata.e2eEncrypted = true
  180. extractMetadata.session = k_upload_session_default
  181. if extractMetadata.size > Double(k_max_filesize_E2EE) {
  182. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_uploadedFile), object: nil, userInfo: ["metadata":metadata, "errorCode":k_CCErrorInternalError, "errorDescription":"E2E Error file too big"])
  183. return
  184. }
  185. metadataForUpload = NCManageDatabase.sharedInstance.addMetadata(extractMetadata)
  186. self.upload(metadataForUpload: metadataForUpload!)
  187. }
  188. }
  189. }
  190. private func upload(metadataForUpload: tableMetadata) {
  191. let object = tableE2eEncryption()
  192. var key: NSString?, initializationVector: NSString?, authenticationTag: NSString?
  193. var e2eMetadataKey = ""
  194. var e2eMetadataKeyIndex = 0
  195. let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadataForUpload.ocId, fileNameView: metadataForUpload.fileNameView)!
  196. let serverUrlFileName = metadataForUpload.serverUrl + "/" + metadataForUpload.fileName
  197. if NCEndToEndEncryption.sharedManager()?.encryptFileName(metadataForUpload.fileNameView, fileNameIdentifier: metadataForUpload.fileName, directory: CCUtility.getDirectoryProviderStorageOcId(metadataForUpload.ocId), key: &key, initializationVector: &initializationVector, authenticationTag: &authenticationTag) == false {
  198. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_uploadedFile), object: nil, userInfo: ["metadata":metadataForUpload, "errorCode":k_CCErrorInternalError, "errorDescription":"_e2e_error_create_encrypted_"])
  199. return
  200. }
  201. if let object = NCManageDatabase.sharedInstance.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadataForUpload.account, metadataForUpload.serverUrl)) {
  202. e2eMetadataKey = object.metadataKey
  203. e2eMetadataKeyIndex = object.metadataKeyIndex
  204. } else {
  205. let key = NCEndToEndEncryption.sharedManager()?.generateKey(16) as NSData?
  206. e2eMetadataKey = key!.base64EncodedString()
  207. }
  208. object.account = metadataForUpload.account
  209. object.authenticationTag = authenticationTag as String?
  210. object.fileName = metadataForUpload.fileNameView
  211. object.fileNameIdentifier = metadataForUpload.fileName
  212. object.fileNamePath = fileNameLocalPath
  213. object.key = key! as String
  214. object.initializationVector = initializationVector! as String
  215. object.metadataKey = e2eMetadataKey
  216. object.metadataKeyIndex = e2eMetadataKeyIndex
  217. object.mimeType = metadataForUpload.contentType
  218. object.serverUrl = metadataForUpload.serverUrl
  219. let e2eeApiVersion = NCManageDatabase.sharedInstance.getCapabilitiesServerString(account: metadataForUpload.account, elements: NCElementsJSON.shared.capabilitiesE2EEApiVersion)!
  220. object.version = Int(e2eeApiVersion) ?? 1
  221. if NCManageDatabase.sharedInstance.addE2eEncryption(object) == false {
  222. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_uploadedFile), object: nil, userInfo: ["metadata":metadataForUpload, "errorCode":k_CCErrorInternalError, "errorDescription":"_e2e_error_create_encrypted_"])
  223. return
  224. }
  225. NCNetworkingE2EE.shared.sendE2EMetadata(account: metadataForUpload.account, serverUrl: metadataForUpload.serverUrl, fileNameRename: nil, fileNameNewRename: nil, deleteE2eEncryption: nil, url: appDelegate.activeUrl, upload: true) { (e2eToken, errorCode, errorDescription) in
  226. if errorCode == 0 && e2eToken != nil {
  227. NCCommunication.shared.upload(serverUrlFileName: serverUrlFileName, fileNameLocalPath: fileNameLocalPath, dateCreationFile: metadataForUpload.date as Date, dateModificationFile: metadataForUpload.date as Date, addCustomHeaders: ["e2e-token":e2eToken!], progressHandler: { (progress) in
  228. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_progressTask), object: nil, userInfo: ["account":metadataForUpload.account, "ocId":metadataForUpload.ocId, "serverUrl":metadataForUpload.serverUrl, "status":NSNumber(value: k_metadataStatusInUpload), "progress":NSNumber(value: progress.fractionCompleted), "totalBytes":NSNumber(value: progress.totalUnitCount), "totalBytesExpected":NSNumber(value: progress.completedUnitCount)])
  229. }) { (account, ocId, etag, date, size, errorCode, errorDescription) in
  230. if (errorCode == 0 && date != nil && etag != nil && ocId != nil) {
  231. CCUtility.moveFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadataForUpload.ocId), toPath: CCUtility.getDirectoryProviderStorageOcId(ocId))
  232. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadataForUpload.ocId))
  233. metadataForUpload.date = date!
  234. metadataForUpload.etag = etag!
  235. metadataForUpload.ocId = ocId!
  236. metadataForUpload.session = ""
  237. metadataForUpload.sessionError = ""
  238. metadataForUpload.sessionTaskIdentifier = Int(k_taskIdentifierDone)
  239. metadataForUpload.status = Int(k_metadataStatusNormal)
  240. NCManageDatabase.sharedInstance.addMetadata(metadataForUpload)
  241. NCManageDatabase.sharedInstance.addLocalFile(metadata: metadataForUpload)
  242. CCGraphics.createNewImage(from: metadataForUpload.fileNameView, ocId: metadataForUpload.ocId, filterGrayScale: false, typeFile: metadataForUpload.typeFile, writeImage: true)
  243. print("[LOG] Insert new upload : " + metadataForUpload.fileNameView)
  244. } else if errorCode == Int(CFNetworkErrors.cfurlErrorCancelled.rawValue) {
  245. if (metadataForUpload.status == k_metadataStatusUploadForcedStart) {
  246. metadataForUpload.sessionError = ""
  247. metadataForUpload.sessionTaskIdentifier = 0
  248. metadataForUpload.status = Int(k_metadataStatusInUpload)
  249. NCManageDatabase.sharedInstance.addMetadata(metadataForUpload)
  250. } else {
  251. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadataForUpload.ocId))
  252. NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadataForUpload.ocId))
  253. }
  254. } else {
  255. if errorCode == 401 || errorCode == 403 {
  256. NCNetworkingCheckRemoteUser.shared.checkRemoteUser(account: metadataForUpload.account)
  257. } else if errorCode == Int(CFNetworkErrors.cfurlErrorServerCertificateUntrusted.rawValue) {
  258. CCUtility.setCertificateError(metadataForUpload.account, error: true)
  259. }
  260. NCManageDatabase.sharedInstance.setMetadataSession(nil, sessionError: errorDescription, sessionSelector: nil, sessionTaskIdentifier: Int(k_taskIdentifierDone), status: Int(k_metadataStatusUploadError), predicate: NSPredicate(format: "ocId == %@", metadataForUpload.ocId))
  261. }
  262. NCNetworkingE2EE.shared.unlock(account: metadataForUpload.account, serverUrl: metadataForUpload.session) { (_, _, _, _) in }
  263. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_uploadedFile), object: nil, userInfo: ["metadata":metadataForUpload, "errorCode":errorCode, "errorDescription":errorDescription ?? ""])
  264. }
  265. /*
  266. NCManageDatabase.sharedInstance.setMetadataSession(metadataForUpload.session, sessionError: "", sessionSelector: nil, sessionTaskIdentifier: taskUpload.taskIdentifier, status: Int(k_metadataStatusUploading), predicate: NSPredicate(format: "ocId == %@", metadataForUpload.ocId))
  267. NotificationCenter.default.post(name: Notification.Name.init(rawValue: k_notificationCenter_uploadFileStart), object: nil, userInfo: ["ocId":metadataForUpload.ocId, "task":taskUpload, "serverUrl":metadataForUpload.serverUrl, "account": metadataForUpload.account])
  268. */
  269. print("[LOG] Upload file " + metadataForUpload.fileNameView)
  270. }
  271. }
  272. }
  273. //MARK: - E2EE
  274. @objc func lock(account:String, serverUrl: String, completion: @escaping (_ direcrtory: tableDirectory?, _ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  275. var e2eToken: String?
  276. guard let directory = NCManageDatabase.sharedInstance.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) else {
  277. completion(nil, nil, 0, "")
  278. return
  279. }
  280. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  281. e2eToken = tableLock.e2eToken
  282. }
  283. NCCommunication.shared.lockE2EEFolder(fileId: directory.fileId, e2eToken: e2eToken, delete: false) { (account, e2eToken, errorCode, errorDescription) in
  284. if errorCode == 0 && e2eToken != nil {
  285. NCManageDatabase.sharedInstance.setE2ETokenLock(serverUrl: serverUrl, fileId: directory.fileId, e2eToken: e2eToken!)
  286. }
  287. completion(directory, e2eToken, errorCode, errorDescription)
  288. }
  289. }
  290. @objc func unlock(account:String, serverUrl: String, completion: @escaping (_ direcrtory: tableDirectory?, _ e2eToken: String?, _ errorCode: Int, _ errorDescription: String?)->()) {
  291. var e2eToken: String?
  292. guard let directory = NCManageDatabase.sharedInstance.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl)) else {
  293. completion(nil, nil, 0, "")
  294. return
  295. }
  296. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  297. e2eToken = tableLock.e2eToken
  298. }
  299. NCCommunication.shared.lockE2EEFolder(fileId: directory.fileId, e2eToken: e2eToken, delete: true) { (account, e2eToken, errorCode, errorDescription) in
  300. if errorCode == 0 {
  301. NCManageDatabase.sharedInstance.deteleE2ETokenLock(serverUrl: serverUrl)
  302. }
  303. completion(directory, e2eToken, errorCode, errorDescription)
  304. }
  305. }
  306. @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?)->()) {
  307. self.lock(account: account, serverUrl: serverUrl) { (directory, e2eToken, errorCode, errorDescription) in
  308. if errorCode == 0 && e2eToken != nil && directory != nil {
  309. NCCommunication.shared.getE2EEMetadata(fileId: directory!.fileId, e2eToken: e2eToken) { (account, e2eMetadata, errorCode, errorDescription) in
  310. var method = "POST"
  311. var e2eMetadataNew: String?
  312. if errorCode == 0 && e2eMetadata != nil {
  313. if !NCEndToEndMetadata.sharedInstance.decoderMetadata(e2eMetadata!, privateKey: CCUtility.getEndToEndPrivateKey(account), serverUrl: serverUrl, account: account, url: url) {
  314. completion(e2eToken, Int(k_CCErrorInternalError), NSLocalizedString("_e2e_error_encode_metadata_", comment: ""))
  315. return
  316. }
  317. method = "PUT"
  318. }
  319. // Rename
  320. if (fileNameRename != nil && fileNameNewRename != nil) {
  321. NCManageDatabase.sharedInstance.renameFileE2eEncryption(serverUrl: serverUrl, fileNameIdentifier: fileNameRename!, newFileName: fileNameNewRename!, newFileNamePath: CCUtility.returnFileNamePath(fromFileName: fileNameNewRename!, serverUrl: serverUrl, activeUrl: url))
  322. }
  323. // Delete
  324. if deleteE2eEncryption != nil {
  325. NCManageDatabase.sharedInstance.deleteE2eEncryption(predicate: deleteE2eEncryption!)
  326. }
  327. // Rebuild metadata for send it
  328. let tableE2eEncryption = NCManageDatabase.sharedInstance.getE2eEncryptions(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl))
  329. if tableE2eEncryption != nil {
  330. e2eMetadataNew = NCEndToEndMetadata.sharedInstance.encoderMetadata(tableE2eEncryption!, privateKey: CCUtility.getEndToEndPrivateKey(account), serverUrl: serverUrl)
  331. }
  332. NCCommunication.shared.putE2EEMetadata(fileId: directory!.fileId, e2eToken: e2eToken!, e2eMetadata: e2eMetadataNew, method: method) { (account, e2eMetadata, errorCode, errorDescription) in
  333. if upload {
  334. completion(e2eToken, errorCode, errorDescription)
  335. } else {
  336. self.unlock(account: account, serverUrl: serverUrl) { (_, e2eToken, _, _) in
  337. completion(e2eToken, errorCode, errorDescription)
  338. }
  339. }
  340. }
  341. }
  342. } else {
  343. completion(e2eToken, errorCode, errorDescription)
  344. }
  345. }
  346. }
  347. //MARK: - Notification Post
  348. private func NotificationPost(name: String, serverUrl: String, userInfo: [AnyHashable : Any], errorDescription: Any?, completion: @escaping (_ errorCode: Int, _ errorDescription: String)->()) {
  349. var userInfo = userInfo
  350. DispatchQueue.main.async {
  351. // unlock
  352. if let tableLock = NCManageDatabase.sharedInstance.getE2ETokenLock(serverUrl: serverUrl) {
  353. NCCommunication.shared.lockE2EEFolder(fileId: tableLock.fileId, e2eToken: tableLock.e2eToken, delete: true) { (_, _, _, _) in }
  354. }
  355. if errorDescription == nil { userInfo["errorDescription"] = "" }
  356. else { userInfo["errorDescription"] = NSLocalizedString(errorDescription as! String, comment: "") }
  357. NotificationCenter.default.post(name: Notification.Name.init(rawValue: name), object: nil, userInfo: userInfo)
  358. completion(userInfo["errorCode"] as! Int, userInfo["errorDescription"] as! String)
  359. }
  360. }
  361. }