NCNetworking.swift 78 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455
  1. //
  2. // NCNetworking.swift
  3. // Nextcloud
  4. //
  5. // Created by Marino Faggiana on 23/10/19.
  6. // Copyright © 2019 Marino Faggiana. All rights reserved.
  7. //
  8. // Author Marino Faggiana <marino.faggiana@nextcloud.com>
  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 UIKit
  24. import OpenSSL
  25. import NCCommunication
  26. import Alamofire
  27. import Queuer
  28. import Photos
  29. @objc public protocol NCNetworkingDelegate {
  30. @objc optional func downloadProgress(_ progress: Float, totalBytes: Int64, totalBytesExpected: Int64, fileName: String, serverUrl: String, session: URLSession, task: URLSessionTask)
  31. @objc optional func uploadProgress(_ progress: Float, totalBytes: Int64, totalBytesExpected: Int64, fileName: String, serverUrl: String, session: URLSession, task: URLSessionTask)
  32. @objc optional func downloadComplete(fileName: String, serverUrl: String, etag: String?, date: NSDate?, dateLastModified: NSDate?, length: Int64, description: String?, task: URLSessionTask, errorCode: Int, errorDescription: String)
  33. @objc optional func uploadComplete(fileName: String, serverUrl: String, ocId: String?, etag: String?, date: NSDate?, size: Int64, description: String?, task: URLSessionTask, errorCode: Int, errorDescription: String)
  34. }
  35. @objc class NCNetworking: NSObject, NCCommunicationCommonDelegate {
  36. @objc public static let shared: NCNetworking = {
  37. let instance = NCNetworking()
  38. return instance
  39. }()
  40. weak var delegate: NCNetworkingDelegate?
  41. var lastReachability: Bool = true
  42. var networkReachability: NCCommunicationCommon.typeReachability?
  43. var downloadRequest: [String: DownloadRequest] = [:]
  44. var uploadRequest: [String: UploadRequest] = [:]
  45. var uploadMetadataInBackground: [String: tableMetadata] = [:]
  46. @objc public let sessionMaximumConnectionsPerHost = 5
  47. @objc public let sessionIdentifierBackground: String = "com.nextcloud.session.upload.background"
  48. @objc public let sessionIdentifierBackgroundWWan: String = "com.nextcloud.session.upload.backgroundWWan"
  49. @objc public let sessionIdentifierBackgroundExtension: String = "com.nextcloud.session.upload.extension"
  50. @objc public lazy var sessionManagerBackground: URLSession = {
  51. let configuration = URLSessionConfiguration.background(withIdentifier: sessionIdentifierBackground)
  52. configuration.allowsCellularAccess = true
  53. configuration.sessionSendsLaunchEvents = true
  54. configuration.isDiscretionary = false
  55. configuration.httpMaximumConnectionsPerHost = sessionMaximumConnectionsPerHost
  56. configuration.requestCachePolicy = NSURLRequest.CachePolicy.reloadIgnoringLocalCacheData
  57. let session = URLSession(configuration: configuration, delegate: NCCommunicationBackground.shared, delegateQueue: OperationQueue.main)
  58. return session
  59. }()
  60. @objc public lazy var sessionManagerBackgroundWWan: URLSession = {
  61. let configuration = URLSessionConfiguration.background(withIdentifier: sessionIdentifierBackgroundWWan)
  62. configuration.allowsCellularAccess = false
  63. configuration.sessionSendsLaunchEvents = true
  64. configuration.isDiscretionary = false
  65. configuration.httpMaximumConnectionsPerHost = sessionMaximumConnectionsPerHost
  66. configuration.requestCachePolicy = NSURLRequest.CachePolicy.reloadIgnoringLocalCacheData
  67. let session = URLSession(configuration: configuration, delegate: NCCommunicationBackground.shared, delegateQueue: OperationQueue.main)
  68. return session
  69. }()
  70. #if EXTENSION
  71. @objc public lazy var sessionManagerBackgroundExtension: URLSession = {
  72. let configuration = URLSessionConfiguration.background(withIdentifier: sessionIdentifierBackgroundExtension)
  73. configuration.allowsCellularAccess = true
  74. configuration.sessionSendsLaunchEvents = true
  75. configuration.isDiscretionary = false
  76. configuration.httpMaximumConnectionsPerHost = sessionMaximumConnectionsPerHost
  77. configuration.requestCachePolicy = NSURLRequest.CachePolicy.reloadIgnoringLocalCacheData
  78. configuration.sharedContainerIdentifier = NCBrandOptions.shared.capabilitiesGroups
  79. let session = URLSession(configuration: configuration, delegate: NCCommunicationBackground.shared, delegateQueue: OperationQueue.main)
  80. return session
  81. }()
  82. #endif
  83. // REQUESTS
  84. var requestsUnifiedSearch: [DataRequest] = []
  85. // MARK: - init
  86. override init() {
  87. super.init()
  88. #if EXTENSION
  89. _ = sessionIdentifierBackgroundExtension
  90. #else
  91. _ = sessionManagerBackground
  92. _ = sessionManagerBackgroundWWan
  93. #endif
  94. }
  95. // MARK: - Communication Delegate
  96. func networkReachabilityObserver(_ typeReachability: NCCommunicationCommon.typeReachability) {
  97. #if !EXTENSION
  98. if typeReachability == NCCommunicationCommon.typeReachability.reachableCellular || typeReachability == NCCommunicationCommon.typeReachability.reachableEthernetOrWiFi {
  99. if !lastReachability {
  100. NCService.shared.startRequestServicesServer()
  101. }
  102. lastReachability = true
  103. } else {
  104. if lastReachability {
  105. NCContentPresenter.shared.messageNotification("_network_not_available_", description: nil, delay: NCGlobal.shared.dismissAfterSecond, type: NCContentPresenter.messageType.info, errorCode: -1009)
  106. }
  107. lastReachability = false
  108. }
  109. networkReachability = typeReachability
  110. #endif
  111. }
  112. func authenticationChallenge(_ session: URLSession, didReceive challenge: URLAuthenticationChallenge, completionHandler: @escaping (URLSession.AuthChallengeDisposition, URLCredential?) -> Void) {
  113. if checkTrustedChallenge(session, didReceive: challenge) {
  114. completionHandler(URLSession.AuthChallengeDisposition.useCredential, URLCredential(trust: challenge.protectionSpace.serverTrust!))
  115. } else {
  116. completionHandler(URLSession.AuthChallengeDisposition.performDefaultHandling, nil)
  117. }
  118. }
  119. func downloadProgress(_ progress: Float, totalBytes: Int64, totalBytesExpected: Int64, fileName: String, serverUrl: String, session: URLSession, task: URLSessionTask) {
  120. delegate?.downloadProgress?(progress, totalBytes: totalBytes, totalBytesExpected: totalBytesExpected, fileName: fileName, serverUrl: serverUrl, session: session, task: task)
  121. }
  122. func downloadComplete(fileName: String, serverUrl: String, etag: String?, date: NSDate?, dateLastModified: NSDate?, length: Int64, description: String?, task: URLSessionTask, errorCode: Int, errorDescription: String) {
  123. delegate?.downloadComplete?(fileName: fileName, serverUrl: serverUrl, etag: etag, date: date, dateLastModified: dateLastModified, length: length, description: description, task: task, errorCode: errorCode, errorDescription: errorDescription)
  124. }
  125. func urlSessionDidFinishEvents(forBackgroundURLSession session: URLSession) {
  126. #if !EXTENSION
  127. if let appDelegate = UIApplication.shared.delegate as? AppDelegate, let completionHandler = appDelegate.backgroundSessionCompletionHandler {
  128. NCCommunicationCommon.shared.writeLog("Called urlSessionDidFinishEvents for Background URLSession")
  129. appDelegate.backgroundSessionCompletionHandler = nil
  130. completionHandler()
  131. }
  132. #endif
  133. }
  134. // MARK: - Pinning check
  135. private func checkTrustedChallenge(_ session: URLSession, didReceive challenge: URLAuthenticationChallenge) -> Bool {
  136. let protectionSpace: URLProtectionSpace = challenge.protectionSpace
  137. let directoryCertificate = CCUtility.getDirectoryCerificates()!
  138. let host = challenge.protectionSpace.host
  139. let certificateSavedPath = directoryCertificate + "/" + host + ".der"
  140. var isTrusted: Bool
  141. #if !EXTENSION
  142. defer {
  143. DispatchQueue.main.async {
  144. if !isTrusted {
  145. (UIApplication.shared.delegate as? AppDelegate)?.trustCertificateError(host: host)
  146. }
  147. }
  148. }
  149. #endif
  150. print("SSL host: \(host)")
  151. if let serverTrust: SecTrust = protectionSpace.serverTrust, let certificate = SecTrustGetCertificateAtIndex(serverTrust, 0) {
  152. // extarct certificate txt
  153. saveX509Certificate(certificate, host: host, directoryCertificate: directoryCertificate)
  154. var secresult = SecTrustResultType.invalid
  155. let status = SecTrustEvaluate(serverTrust, &secresult)
  156. let isServerTrusted = SecTrustEvaluateWithError(serverTrust, nil)
  157. let certificateCopyData = SecCertificateCopyData(certificate)
  158. let data = CFDataGetBytePtr(certificateCopyData);
  159. let size = CFDataGetLength(certificateCopyData);
  160. let certificateData = NSData(bytes: data, length: size)
  161. certificateData.write(toFile: directoryCertificate + "/" + host + ".tmp", atomically: true)
  162. if isServerTrusted {
  163. isTrusted = true
  164. } else if status == errSecSuccess, let certificateDataSaved = NSData(contentsOfFile: certificateSavedPath), certificateData.isEqual(to: certificateDataSaved as Data) {
  165. isTrusted = true
  166. } else {
  167. isTrusted = false
  168. }
  169. } else {
  170. isTrusted = false
  171. }
  172. return isTrusted
  173. }
  174. func writeCertificate(host: String) {
  175. let directoryCertificate = CCUtility.getDirectoryCerificates()!
  176. let certificateAtPath = directoryCertificate + "/" + host + ".tmp"
  177. let certificateToPath = directoryCertificate + "/" + host + ".der"
  178. if !NCUtilityFileSystem.shared.moveFile(atPath: certificateAtPath, toPath: certificateToPath) {
  179. NCContentPresenter.shared.messageNotification("_error_", description: "_error_creation_file_", delay: NCGlobal.shared.dismissAfterSecond, type: NCContentPresenter.messageType.error, errorCode: NCGlobal.shared.errorCreationFile, priority: .max)
  180. }
  181. }
  182. private func saveX509Certificate(_ certificate: SecCertificate, host: String, directoryCertificate: String) {
  183. let certNamePathTXT = directoryCertificate + "/" + host + ".txt"
  184. let data: CFData = SecCertificateCopyData(certificate)
  185. let mem = BIO_new_mem_buf(CFDataGetBytePtr(data), Int32(CFDataGetLength(data)))
  186. let x509cert = d2i_X509_bio(mem, nil)
  187. if x509cert == nil {
  188. print("[LOG] OpenSSL couldn't parse X509 Certificate")
  189. } else {
  190. // save details
  191. if FileManager.default.fileExists(atPath: certNamePathTXT) {
  192. do {
  193. try FileManager.default.removeItem(atPath: certNamePathTXT)
  194. } catch { }
  195. }
  196. let fileCertInfo = fopen(certNamePathTXT, "w")
  197. if fileCertInfo != nil {
  198. let output = BIO_new_fp(fileCertInfo, BIO_NOCLOSE)
  199. X509_print_ex(output, x509cert, UInt(XN_FLAG_COMPAT), UInt(X509_FLAG_COMPAT))
  200. BIO_free(output)
  201. }
  202. fclose(fileCertInfo)
  203. X509_free(x509cert)
  204. }
  205. BIO_free(mem)
  206. }
  207. func checkPushNotificationServerProxyCertificateUntrusted(viewController: UIViewController?, completion: @escaping (_ errorCode: Int) -> Void) {
  208. guard let host = URL(string: NCBrandOptions.shared.pushNotificationServerProxy)?.host else { return }
  209. NCCommunication.shared.checkServer(serverUrl: NCBrandOptions.shared.pushNotificationServerProxy) { errorCode, _ in
  210. guard errorCode == 0 else {
  211. completion(0)
  212. return
  213. }
  214. if errorCode == 0 {
  215. NCNetworking.shared.writeCertificate(host: host)
  216. completion(errorCode)
  217. } else if errorCode == NSURLErrorServerCertificateUntrusted {
  218. let alertController = UIAlertController(title: NSLocalizedString("_ssl_certificate_untrusted_", comment: ""), message: NSLocalizedString("_connect_server_anyway_", comment: ""), preferredStyle: .alert)
  219. alertController.addAction(UIAlertAction(title: NSLocalizedString("_yes_", comment: ""), style: .default, handler: { _ in
  220. NCNetworking.shared.writeCertificate(host: host)
  221. completion(0)
  222. }))
  223. alertController.addAction(UIAlertAction(title: NSLocalizedString("_no_", comment: ""), style: .default, handler: { _ in
  224. completion(errorCode)
  225. }))
  226. alertController.addAction(UIAlertAction(title: NSLocalizedString("_certificate_details_", comment: ""), style: .default, handler: { _ in
  227. if let navigationController = UIStoryboard(name: "NCViewCertificateDetails", bundle: nil).instantiateInitialViewController() as? UINavigationController {
  228. let vcCertificateDetails = navigationController.topViewController as! NCViewCertificateDetails
  229. vcCertificateDetails.host = host
  230. viewController?.present(navigationController, animated: true)
  231. }
  232. }))
  233. viewController?.present(alertController, animated: true)
  234. }
  235. }
  236. }
  237. // MARK: - Utility
  238. func cancelTaskWithUrl(_ url: URL) {
  239. NCCommunication.shared.getSessionManager().getAllTasks { tasks in
  240. tasks.filter { $0.state == .running }.filter { $0.originalRequest?.url == url }.first?.cancel()
  241. }
  242. }
  243. @objc func cancelAllTask() {
  244. NCCommunication.shared.getSessionManager().getAllTasks { tasks in
  245. for task in tasks {
  246. task.cancel()
  247. }
  248. }
  249. }
  250. // MARK: - Download
  251. @objc func cancelDownload(ocId: String, serverUrl: String, fileNameView: String) {
  252. guard let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(ocId, fileNameView: fileNameView) else { return }
  253. if let request = downloadRequest[fileNameLocalPath] {
  254. request.cancel()
  255. } else if let metadata = NCManageDatabase.shared.getMetadataFromOcId(ocId) {
  256. NCManageDatabase.shared.setMetadataSession(ocId: ocId, session: "", sessionError: "", sessionSelector: "", sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusNormal)
  257. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDownloadCancelFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  258. }
  259. }
  260. @objc func download(metadata: tableMetadata, selector: String, notificationCenterProgressTask: Bool = true, progressHandler: @escaping (_ progress: Progress) -> Void = { _ in }, completion: @escaping (_ errorCode: Int) -> Void) {
  261. let serverUrlFileName = metadata.serverUrl + "/" + metadata.fileName
  262. let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileName)!
  263. if NCManageDatabase.shared.getMetadataFromOcId(metadata.ocId) == nil {
  264. NCManageDatabase.shared.addMetadata(tableMetadata.init(value: metadata))
  265. }
  266. if metadata.status == NCGlobal.shared.metadataStatusInDownload || metadata.status == NCGlobal.shared.metadataStatusDownloading { return }
  267. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: NCCommunicationCommon.shared.sessionIdentifierDownload, sessionError: "", sessionSelector: selector, sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusInDownload)
  268. NCCommunication.shared.download(serverUrlFileName: serverUrlFileName, fileNameLocalPath: fileNameLocalPath, queue: NCCommunicationCommon.shared.backgroundQueue, requestHandler: { request in
  269. self.downloadRequest[fileNameLocalPath] = request
  270. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, status: NCGlobal.shared.metadataStatusDownloading)
  271. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDownloadStartFile, userInfo: ["ocId":metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  272. }, taskHandler: { (_) in
  273. }, progressHandler: { (progress) in
  274. if notificationCenterProgressTask {
  275. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterProgressTask, object: nil, userInfo: ["account":metadata.account, "ocId":metadata.ocId, "fileName":metadata.fileName, "serverUrl":metadata.serverUrl, "status":NSNumber(value: NCGlobal.shared.metadataStatusInDownload), "progress":NSNumber(value: progress.fractionCompleted), "totalBytes":NSNumber(value: progress.totalUnitCount), "totalBytesExpected":NSNumber(value: progress.completedUnitCount)])
  276. }
  277. progressHandler(progress)
  278. }) { (account, etag, date, _, allHeaderFields, error, errorCode, errorDescription) in
  279. self.downloadRequest[fileNameLocalPath] = nil
  280. if error?.isExplicitlyCancelledError ?? false {
  281. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: "", sessionError: "", sessionSelector: selector, sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusNormal)
  282. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDownloadCancelFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  283. } else if errorCode == 0 {
  284. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: "", sessionError: "", sessionSelector: selector, sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusNormal, etag: etag)
  285. NCManageDatabase.shared.addLocalFile(metadata: metadata)
  286. #if !EXTENSION
  287. if let result = NCManageDatabase.shared.getE2eEncryption(predicate: NSPredicate(format: "fileNameIdentifier == %@ AND serverUrl == %@", metadata.fileName, metadata.serverUrl)) {
  288. NCEndToEndEncryption.sharedManager()?.decryptFileName(metadata.fileName, fileNameView: metadata.fileNameView, ocId: metadata.ocId, key: result.key, initializationVector: result.initializationVector, authenticationTag: result.authenticationTag)
  289. }
  290. CCUtility.setExif(metadata) { _, _, _, _, _ in }
  291. #endif
  292. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDownloadedFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account, "selector": selector, "errorCode": 0, "errorDescription": ""])
  293. } else {
  294. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: "", sessionError: errorDescription, sessionSelector: selector, sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusDownloadError)
  295. #if !EXTENSION
  296. if errorCode == 401 || errorCode == 403 {
  297. NCNetworkingCheckRemoteUser.shared.checkRemoteUser(account: metadata.account, errorCode: errorCode, errorDescription: errorDescription)
  298. }
  299. #endif
  300. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDownloadedFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account, "selector": selector, "errorCode": errorCode, "errorDescription": errorDescription])
  301. }
  302. DispatchQueue.main.async { completion(errorCode) }
  303. }
  304. }
  305. // MARK: - Upload
  306. @objc func upload(metadata: tableMetadata,
  307. start: @escaping () -> () = { },
  308. completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> () = { errorCode, errorDescription in }) {
  309. let metadata = tableMetadata.init(value: metadata)
  310. NCCommunicationCommon.shared.writeLog("Upload file \(metadata.fileNameView) with Identifier \(metadata.assetLocalIdentifier) with size \(metadata.size) [CHUNCK \(metadata.chunk), E2EE \(metadata.e2eEncrypted)]")
  311. if metadata.e2eEncrypted {
  312. #if !EXTENSION_FILE_PROVIDER_EXTENSION
  313. NCNetworkingE2EE.shared.upload(metadata: metadata, start: start) { errorCode, errorDescription in
  314. DispatchQueue.main.async {
  315. completion(errorCode, errorDescription)
  316. }
  317. }
  318. #endif
  319. } else if metadata.chunk {
  320. uploadChunkedFile(metadata: metadata, start: start) { errorCode, errorDescription in
  321. DispatchQueue.main.async {
  322. completion(errorCode, errorDescription)
  323. }
  324. }
  325. } else if metadata.session == NCCommunicationCommon.shared.sessionIdentifierUpload {
  326. uploadFile(metadata: metadata, start: start) { errorCode, errorDescription in
  327. DispatchQueue.main.async {
  328. completion(errorCode, errorDescription)
  329. }
  330. }
  331. } else {
  332. uploadFileInBackground(metadata: metadata, start: start) { errorCode, errorDescription in
  333. DispatchQueue.main.async {
  334. completion(errorCode, errorDescription)
  335. }
  336. }
  337. }
  338. }
  339. private func uploadFile(metadata: tableMetadata, start: @escaping () -> Void, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  340. let serverUrlFileName = metadata.serverUrl + "/" + metadata.fileName
  341. let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileNameView)!
  342. var uploadTask: URLSessionTask?
  343. let description = metadata.ocId
  344. NCCommunication.shared.upload(serverUrlFileName: serverUrlFileName, fileNameLocalPath: fileNameLocalPath, dateCreationFile: metadata.creationDate as Date, dateModificationFile: metadata.date as Date, customUserAgent: nil, addCustomHeaders: nil, requestHandler: { request in
  345. self.uploadRequest[fileNameLocalPath] = request
  346. }, taskHandler: { task in
  347. uploadTask = task
  348. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, sessionError: "", sessionTaskIdentifier: task.taskIdentifier, status: NCGlobal.shared.metadataStatusUploading)
  349. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadStartFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  350. start()
  351. }, progressHandler: { progress in
  352. NotificationCenter.default.postOnMainThread(
  353. name: NCGlobal.shared.notificationCenterProgressTask,
  354. userInfo: [
  355. "account": metadata.account,
  356. "ocId": metadata.ocId,
  357. "fileName": metadata.fileName,
  358. "serverUrl": metadata.serverUrl,
  359. "status": NSNumber(value: NCGlobal.shared.metadataStatusInUpload),
  360. "progress": NSNumber(value: progress.fractionCompleted),
  361. "totalBytes": NSNumber(value: progress.totalUnitCount),
  362. "totalBytesExpected": NSNumber(value: progress.completedUnitCount)])
  363. }) { _, ocId, etag, date, size, _, _, errorCode, errorDescription in
  364. self.uploadRequest[fileNameLocalPath] = nil
  365. if let uploadTask = uploadTask {
  366. self.uploadComplete(fileName: metadata.fileName, serverUrl: metadata.serverUrl, ocId: ocId, etag: etag, date: date, size: size, description: description, task: uploadTask, errorCode: errorCode, errorDescription: errorDescription)
  367. }
  368. completion(errorCode, errorDescription)
  369. }
  370. }
  371. private func uploadFileInBackground(metadata: tableMetadata, start: @escaping () -> Void, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  372. var session: URLSession?
  373. let metadata = tableMetadata.init(value: metadata)
  374. let serverUrlFileName = metadata.serverUrl + "/" + metadata.fileName
  375. let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileNameView)!
  376. if metadata.session == sessionIdentifierBackground || metadata.session == sessionIdentifierBackgroundExtension {
  377. session = sessionManagerBackground
  378. } else if metadata.session == sessionIdentifierBackgroundWWan {
  379. session = sessionManagerBackgroundWWan
  380. }
  381. start()
  382. // Check file dim > 0
  383. if NCUtilityFileSystem.shared.getFileSize(filePath: fileNameLocalPath) == 0 && metadata.size != 0 {
  384. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  385. completion(NCGlobal.shared.errorResourceNotFound, NSLocalizedString("_error_not_found_", value: "The requested resource could not be found", comment: ""))
  386. } else {
  387. if let task = NCCommunicationBackground.shared.upload(serverUrlFileName: serverUrlFileName, fileNameLocalPath: fileNameLocalPath, dateCreationFile: metadata.creationDate as Date, dateModificationFile: metadata.date as Date, description: metadata.ocId, session: session!) {
  388. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, sessionError: "", sessionTaskIdentifier: task.taskIdentifier, status: NCGlobal.shared.metadataStatusUploading)
  389. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadStartFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  390. completion(0, "")
  391. } else {
  392. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  393. completion(NCGlobal.shared.errorInternalError, "task null")
  394. }
  395. }
  396. }
  397. func uploadComplete(fileName: String, serverUrl: String, ocId: String?, etag: String?, date: NSDate?, size: Int64, description: String?, task: URLSessionTask, errorCode: Int, errorDescription: String) {
  398. DispatchQueue.global().async {
  399. guard self.delegate == nil, let metadata = NCManageDatabase.shared.getMetadataFromOcId(description) else {
  400. self.delegate?.uploadComplete?(fileName: fileName, serverUrl: serverUrl, ocId: ocId, etag: etag, date: date, size: size, description: description, task: task, errorCode: errorCode, errorDescription: errorDescription)
  401. return
  402. }
  403. let ocIdTemp = metadata.ocId
  404. var errorDescription = errorDescription
  405. if errorCode == 0, let ocId = ocId, size == metadata.size {
  406. let metadata = tableMetadata.init(value: metadata)
  407. NCUtilityFileSystem.shared.deleteFile(filePath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  408. metadata.uploadDate = date ?? NSDate()
  409. metadata.etag = etag ?? ""
  410. metadata.ocId = ocId
  411. if let fileId = NCUtility.shared.ocIdToFileId(ocId: ocId) {
  412. metadata.fileId = fileId
  413. }
  414. metadata.session = ""
  415. metadata.sessionError = ""
  416. metadata.sessionTaskIdentifier = 0
  417. metadata.status = NCGlobal.shared.metadataStatusNormal
  418. // Delete Asset on Photos album
  419. if CCUtility.getRemovePhotoCameraRoll() && !metadata.assetLocalIdentifier.isEmpty {
  420. metadata.deleteAssetLocalIdentifier = true
  421. }
  422. NCManageDatabase.shared.addMetadata(metadata)
  423. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", ocIdTemp))
  424. NCCommunicationCommon.shared.writeLog("Upload complete " + serverUrl + "/" + fileName + ", result: success(\(size) bytes)")
  425. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadedFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account, "ocIdTemp": ocIdTemp, "errorCode": errorCode, "errorDescription": ""])
  426. } else {
  427. if errorCode == NSURLErrorCancelled || errorCode == NCGlobal.shared.errorRequestExplicityCancelled {
  428. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  429. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  430. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadCancelFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  431. } else if errorCode == 401 || errorCode == 403 {
  432. #if !EXTENSION
  433. NCNetworkingCheckRemoteUser.shared.checkRemoteUser(account: metadata.account, errorCode: errorCode, errorDescription: errorDescription)
  434. #endif
  435. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: errorDescription, sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusUploadError)
  436. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadedFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account, "ocIdTemp": ocIdTemp, "errorCode": errorCode, "errorDescription": ""])
  437. } else {
  438. if size == 0 {
  439. errorDescription = "File length 0"
  440. NCCommunicationCommon.shared.writeLog("Upload error 0 length " + serverUrl + "/" + fileName + ", result: success(\(size) bytes)")
  441. }
  442. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: nil, sessionError: errorDescription, sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusUploadError)
  443. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadedFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account, "ocIdTemp": ocIdTemp, "errorCode": errorCode, "errorDescription": ""])
  444. }
  445. }
  446. self.uploadMetadataInBackground[fileName + serverUrl] = nil
  447. self.delegate?.uploadComplete?(fileName: fileName, serverUrl: serverUrl, ocId: ocId, etag: etag, date: date, size: size, description: description, task: task, errorCode: errorCode, errorDescription: errorDescription)
  448. }
  449. }
  450. func uploadProgress(_ progress: Float, totalBytes: Int64, totalBytesExpected: Int64, fileName: String, serverUrl: String, session: URLSession, task: URLSessionTask) {
  451. DispatchQueue.global().async {
  452. self.delegate?.uploadProgress?(progress, totalBytes: totalBytes, totalBytesExpected: totalBytesExpected, fileName: fileName, serverUrl: serverUrl, session: session, task: task)
  453. var metadata: tableMetadata?
  454. let description: String = task.taskDescription ?? ""
  455. if let metadataTmp = self.uploadMetadataInBackground[fileName+serverUrl] {
  456. metadata = metadataTmp
  457. } else if let metadataTmp = NCManageDatabase.shared.getMetadataFromOcId(description) {
  458. self.uploadMetadataInBackground[fileName+serverUrl] = metadataTmp
  459. metadata = metadataTmp
  460. }
  461. if let metadata = metadata {
  462. NotificationCenter.default.postOnMainThread(
  463. name: NCGlobal.shared.notificationCenterProgressTask,
  464. userInfo: [
  465. "account": metadata.account,
  466. "ocId": metadata.ocId,
  467. "fileName": metadata.fileName,
  468. "serverUrl": serverUrl,
  469. "status": NSNumber(value: NCGlobal.shared.metadataStatusInUpload),
  470. "progress": NSNumber(value: progress),
  471. "totalBytes": NSNumber(value: totalBytes),
  472. "totalBytesExpected": NSNumber(value: totalBytesExpected)])
  473. }
  474. }
  475. }
  476. func getOcIdInBackgroundSession(queue: DispatchQueue = .main, completion: @escaping (_ listOcId: [String]) -> Void) {
  477. var listOcId: [String] = []
  478. sessionManagerBackground.getAllTasks(completionHandler: { tasks in
  479. for task in tasks {
  480. listOcId.append(task.description)
  481. }
  482. self.sessionManagerBackgroundWWan.getAllTasks(completionHandler: { tasks in
  483. for task in tasks {
  484. listOcId.append(task.description)
  485. }
  486. queue.async { completion(listOcId) }
  487. })
  488. })
  489. }
  490. // MARK: - Transfer (Download Upload)
  491. @objc func cancelTransferMetadata(_ metadata: tableMetadata, completion: @escaping () -> Void) {
  492. let metadata = tableMetadata.init(value: metadata)
  493. if metadata.session.count == 0 {
  494. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  495. return completion()
  496. }
  497. if metadata.session == NCCommunicationCommon.shared.sessionIdentifierDownload {
  498. NCNetworking.shared.cancelDownload(ocId: metadata.ocId, serverUrl: metadata.serverUrl, fileNameView: metadata.fileNameView)
  499. return completion()
  500. }
  501. if metadata.session == NCCommunicationCommon.shared.sessionIdentifierUpload || metadata.chunk {
  502. guard let fileNameLocalPath = CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileNameView) else { return }
  503. if let request = uploadRequest[fileNameLocalPath] {
  504. request.cancel()
  505. } else {
  506. CCUtility.removeFile(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  507. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  508. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadCancelFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  509. }
  510. return completion()
  511. }
  512. var session: URLSession?
  513. if metadata.session == NCNetworking.shared.sessionIdentifierBackground {
  514. session = NCNetworking.shared.sessionManagerBackground
  515. } else if metadata.session == NCNetworking.shared.sessionIdentifierBackgroundWWan {
  516. session = NCNetworking.shared.sessionManagerBackgroundWWan
  517. }
  518. if session == nil {
  519. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  520. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadCancelFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  521. return completion()
  522. }
  523. session?.getTasksWithCompletionHandler { _, uploadTasks, _ in
  524. var cancel = false
  525. if metadata.session.count > 0 && metadata.session.contains("upload") {
  526. for task in uploadTasks {
  527. if task.taskIdentifier == metadata.sessionTaskIdentifier {
  528. task.cancel()
  529. cancel = true
  530. }
  531. }
  532. if cancel == false {
  533. do {
  534. try FileManager.default.removeItem(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  535. } catch { }
  536. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  537. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterUploadCancelFile, userInfo: ["ocId": metadata.ocId, "serverUrl": metadata.serverUrl, "account": metadata.account])
  538. }
  539. }
  540. completion()
  541. }
  542. }
  543. @objc func cancelAllTransfer(account: String, completion: @escaping () -> Void) {
  544. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "status == %d OR status == %d", account, NCGlobal.shared.metadataStatusWaitUpload, NCGlobal.shared.metadataStatusUploadError))
  545. let metadatas = NCManageDatabase.shared.getMetadatas(predicate: NSPredicate(format: "status != %d", NCGlobal.shared.metadataStatusNormal))
  546. var counter = 0
  547. for metadata in metadatas {
  548. counter += 1
  549. if metadata.status == NCGlobal.shared.metadataStatusWaitDownload || metadata.status == NCGlobal.shared.metadataStatusDownloadError {
  550. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: "", sessionError: "", sessionSelector: "", sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusNormal)
  551. }
  552. if metadata.status == NCGlobal.shared.metadataStatusDownloading || metadata.status == NCGlobal.shared.metadataStatusUploading {
  553. self.cancelTransferMetadata(metadata) {
  554. if counter == metadatas.count {
  555. DispatchQueue.main.asyncAfter(deadline: .now() + 0.5) {
  556. completion()
  557. }
  558. }
  559. }
  560. }
  561. }
  562. #if !EXTENSION
  563. NCOperationQueue.shared.downloadCancelAll()
  564. #endif
  565. }
  566. func cancelAllDownloadTransfer() {
  567. let metadatas = NCManageDatabase.shared.getMetadatas(predicate: NSPredicate(format: "status != %d", NCGlobal.shared.metadataStatusNormal))
  568. for metadata in metadatas {
  569. if metadata.status == NCGlobal.shared.metadataStatusWaitDownload || metadata.status == NCGlobal.shared.metadataStatusDownloadError {
  570. NCManageDatabase.shared.setMetadataSession(ocId: metadata.ocId, session: "", sessionError: "", sessionSelector: "", sessionTaskIdentifier: 0, status: NCGlobal.shared.metadataStatusNormal)
  571. }
  572. if metadata.status == NCGlobal.shared.metadataStatusDownloading && metadata.session == NCCommunicationCommon.shared.sessionIdentifierDownload {
  573. cancelDownload(ocId: metadata.ocId, serverUrl: metadata.serverUrl, fileNameView: metadata.fileNameView)
  574. }
  575. }
  576. #if !EXTENSION
  577. NCOperationQueue.shared.downloadCancelAll()
  578. #endif
  579. }
  580. // MARK: - WebDav Read file, folder
  581. @objc func readFolder(serverUrl: String, account: String, completion: @escaping (_ account: String, _ metadataFolder: tableMetadata?, _ metadatas: [tableMetadata]?, _ metadatasUpdate: [tableMetadata]?, _ metadatasLocalUpdate: [tableMetadata]?, _ metadatasDelete: [tableMetadata]?, _ errorCode: Int, _ errorDescription: String) -> Void) {
  582. NCCommunication.shared.readFileOrFolder(serverUrlFileName: serverUrl, depth: "1", showHiddenFiles: CCUtility.getShowHiddenFiles(), queue: NCCommunicationCommon.shared.backgroundQueue) { account, files, _, errorCode, errorDescription in
  583. guard errorCode == 0 else {
  584. completion(account, nil, nil, nil, nil, nil, errorCode, errorDescription)
  585. return
  586. }
  587. NCManageDatabase.shared.convertNCCommunicationFilesToMetadatas(files, useMetadataFolder: true, account: account) { metadataFolder, metadatasFolder, metadatas in
  588. // Add metadata folder
  589. NCManageDatabase.shared.addMetadata(tableMetadata.init(value: metadataFolder))
  590. // Update directory
  591. NCManageDatabase.shared.addDirectory(encrypted: metadataFolder.e2eEncrypted, favorite: metadataFolder.favorite, ocId: metadataFolder.ocId, fileId: metadataFolder.fileId, etag: metadataFolder.etag, permissions: metadataFolder.permissions, serverUrl: serverUrl, account: metadataFolder.account)
  592. NCManageDatabase.shared.setDirectory(richWorkspace: metadataFolder.richWorkspace, serverUrl: serverUrl, account: metadataFolder.account)
  593. // Update sub directories NO Update richWorkspace
  594. for metadata in metadatasFolder {
  595. let serverUrl = metadata.serverUrl + "/" + metadata.fileName
  596. NCManageDatabase.shared.addDirectory(encrypted: metadata.e2eEncrypted, favorite: metadata.favorite, ocId: metadata.ocId, fileId: metadata.fileId, etag: nil, permissions: metadata.permissions, serverUrl: serverUrl, account: account)
  597. }
  598. let metadatasResult = NCManageDatabase.shared.getMetadatas(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND status == %d", account, serverUrl, NCGlobal.shared.metadataStatusNormal))
  599. let metadatasChanged = NCManageDatabase.shared.updateMetadatas(metadatas, metadatasResult: metadatasResult, addCompareEtagLocal: true)
  600. completion(account, metadataFolder, metadatas, metadatasChanged.metadatasUpdate, metadatasChanged.metadatasLocalUpdate, metadatasChanged.metadatasDelete, errorCode, "")
  601. }
  602. }
  603. }
  604. @objc func readFile(serverUrlFileName: String, showHiddenFiles: Bool = CCUtility.getShowHiddenFiles(), queue: DispatchQueue = NCCommunicationCommon.shared.backgroundQueue, completion: @escaping (_ account: String, _ metadata: tableMetadata?, _ errorCode: Int, _ errorDescription: String) -> Void) {
  605. NCCommunication.shared.readFileOrFolder(serverUrlFileName: serverUrlFileName, depth: "0", showHiddenFiles: showHiddenFiles, queue: queue) { account, files, _, errorCode, errorDescription in
  606. guard errorCode == 0, files.count == 1, let file = files.first else {
  607. completion(account, nil, errorCode, errorDescription)
  608. return
  609. }
  610. let isEncrypted = CCUtility.isFolderEncrypted(file.serverUrl, e2eEncrypted: file.e2eEncrypted, account: account, urlBase: file.urlBase)
  611. let metadata = NCManageDatabase.shared.convertNCFileToMetadata(file, isEncrypted: isEncrypted, account: account)
  612. completion(account, metadata, errorCode, errorDescription)
  613. }
  614. }
  615. //MARK: - Search
  616. /// WebDAV search
  617. @objc func searchFiles(urlBase: NCUserBaseUrl, literal: String, completion: @escaping (_ metadatas: [tableMetadata]?, _ errorCode: Int, _ errorDescription: String) -> ()) {
  618. NCCommunication.shared.searchLiteral(serverUrl: urlBase.urlBase, depth: "infinity", literal: literal, showHiddenFiles: CCUtility.getShowHiddenFiles(), queue: NCCommunicationCommon.shared.backgroundQueue) { (account, files, errorCode, errorDescription) in
  619. guard errorCode == 0 else {
  620. return completion(nil, errorCode, errorDescription)
  621. }
  622. NCManageDatabase.shared.convertNCCommunicationFilesToMetadatas(files, useMetadataFolder: false, account: account) { _, metadatasFolder, metadatas in
  623. // Update sub directories
  624. for folder in metadatasFolder {
  625. let serverUrl = folder.serverUrl + "/" + folder.fileName
  626. NCManageDatabase.shared.addDirectory(encrypted: folder.e2eEncrypted, favorite: folder.favorite, ocId: folder.ocId, fileId: folder.fileId, etag: nil, permissions: folder.permissions, serverUrl: serverUrl, account: account)
  627. }
  628. NCManageDatabase.shared.addMetadatas(metadatas)
  629. let metadatas = Array(metadatas.map(tableMetadata.init))
  630. completion(metadatas, errorCode, errorDescription)
  631. }
  632. }
  633. }
  634. /// Unified Search (NC>=20)
  635. ///
  636. func unifiedSearchFiles(urlBase: NCUserBaseUrl, literal: String, providers: @escaping ([NCCSearchProvider]?) -> Void, update: @escaping (_ id: String, NCCSearchResult?, [tableMetadata]?) -> Void, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> ()) {
  637. var errorCode = 0
  638. var errorDescription = ""
  639. let dispatchGroup = DispatchGroup()
  640. dispatchGroup.enter()
  641. dispatchGroup.notify(queue: .main) {
  642. completion(errorCode, errorDescription)
  643. }
  644. NCCommunication.shared.unifiedSearch(term: literal, timeout: 30, timeoutProvider: 90) { provider in
  645. // example filter
  646. // ["calendar", "files", "fulltextsearch"].contains(provider.id)
  647. return true
  648. } request: { request in
  649. if let request = request {
  650. self.requestsUnifiedSearch.append(request)
  651. }
  652. } providers: { allProviders in
  653. providers(allProviders)
  654. } update: { partialResult, provider, errorCode, errorDescription in
  655. guard let partialResult = partialResult else { return }
  656. var metadatas: [tableMetadata] = []
  657. switch provider.id {
  658. case "files":
  659. partialResult.entries.forEach({ entry in
  660. if let fileId = entry.fileId,
  661. let metadata = NCManageDatabase.shared.getMetadata(predicate: NSPredicate(format: "account == %@ && fileId == %@", urlBase.userAccount, String(fileId))) {
  662. metadatas.append(metadata)
  663. } else if let filePath = entry.filePath {
  664. let semaphore = Semaphore()
  665. self.loadMetadata(urlBase: urlBase, filePath: filePath, dispatchGroup: dispatchGroup) { account, metadata, errorCode, errorDescription in
  666. metadatas.append(metadata)
  667. semaphore.continue()
  668. }
  669. semaphore.wait()
  670. } else { print(#function, "[ERROR]: File search entry has no path: \(entry)") }
  671. })
  672. break
  673. case "fulltextsearch":
  674. // NOTE: FTS could also return attributes like files
  675. // https://github.com/nextcloud/files_fulltextsearch/issues/143
  676. partialResult.entries.forEach({ entry in
  677. let url = URLComponents(string: entry.resourceURL)
  678. guard let dir = url?.queryItems?["dir"]?.value, let filename = url?.queryItems?["scrollto"]?.value else { return }
  679. if let metadata = NCManageDatabase.shared.getMetadata(predicate: NSPredicate(
  680. format: "account == %@ && path == %@ && fileName == %@",
  681. urlBase.userAccount,
  682. "/remote.php/dav/files/" + urlBase.user + dir,
  683. filename)) {
  684. metadatas.append(metadata)
  685. } else {
  686. let semaphore = Semaphore()
  687. self.loadMetadata(urlBase: urlBase, filePath: dir + filename, dispatchGroup: dispatchGroup) { account, metadata, errorCode, errorDescription in
  688. metadatas.append(metadata)
  689. semaphore.continue()
  690. }
  691. semaphore.wait()
  692. }
  693. })
  694. default:
  695. partialResult.entries.forEach({ entry in
  696. let metadata = NCManageDatabase.shared.createMetadata(account: urlBase.account, user: urlBase.user, userId: urlBase.userId, fileName: entry.title, fileNameView: entry.title, ocId: NSUUID().uuidString, serverUrl: urlBase.urlBase, urlBase: urlBase.urlBase, url: entry.resourceURL, contentType: "", isUrl: true, name: partialResult.name.lowercased(), subline: entry.subline, iconName: entry.icon, iconUrl: entry.thumbnailURL)
  697. metadatas.append(metadata)
  698. })
  699. }
  700. update(provider.id, partialResult, metadatas)
  701. } completion: { err, description in
  702. self.requestsUnifiedSearch.removeAll()
  703. errorCode = err
  704. errorDescription = description
  705. dispatchGroup.leave()
  706. }
  707. }
  708. func unifiedSearchFilesProvider(urlBase: NCUserBaseUrl, id: String, term: String, limit: Int, cursor: Int, completion: @escaping (NCCSearchResult?, _ metadatas: [tableMetadata]?, _ errorCode: Int, _ errorDescription: String) -> ()) {
  709. var metadatas: [tableMetadata] = []
  710. let request = NCCommunication.shared.searchProvider(id, term: term, limit: limit, cursor: cursor, timeout: 60) { searchResult, errorCode, errorDescription in
  711. guard let searchResult = searchResult else {
  712. completion(nil, metadatas, errorCode, errorDescription)
  713. return
  714. }
  715. switch id {
  716. case "files":
  717. searchResult.entries.forEach({ entry in
  718. if let fileId = entry.fileId, let metadata = NCManageDatabase.shared.getMetadata(predicate: NSPredicate(format: "account == %@ && fileId == %@", urlBase.userAccount, String(fileId))) {
  719. metadatas.append(metadata)
  720. } else if let filePath = entry.filePath {
  721. let semaphore = Semaphore()
  722. self.loadMetadata(urlBase: urlBase, filePath: filePath, dispatchGroup: nil) { account, metadata, errorCode, errorDescription in
  723. metadatas.append(metadata)
  724. semaphore.continue()
  725. }
  726. semaphore.wait()
  727. } else { print(#function, "[ERROR]: File search entry has no path: \(entry)") }
  728. })
  729. break
  730. case "fulltextsearch":
  731. // NOTE: FTS could also return attributes like files
  732. // https://github.com/nextcloud/files_fulltextsearch/issues/143
  733. searchResult.entries.forEach({ entry in
  734. let url = URLComponents(string: entry.resourceURL)
  735. guard let dir = url?.queryItems?["dir"]?.value, let filename = url?.queryItems?["scrollto"]?.value else { return }
  736. if let metadata = NCManageDatabase.shared.getMetadata(predicate: NSPredicate(format: "account == %@ && path == %@ && fileName == %@", urlBase.userAccount, "/remote.php/dav/files/" + urlBase.user + dir, filename)) {
  737. metadatas.append(metadata)
  738. } else {
  739. let semaphore = Semaphore()
  740. self.loadMetadata(urlBase: urlBase, filePath: dir + filename, dispatchGroup: nil) { account, metadata, errorCode, errorDescription in
  741. metadatas.append(metadata)
  742. semaphore.continue()
  743. }
  744. semaphore.wait()
  745. }
  746. })
  747. default:
  748. searchResult.entries.forEach({ entry in
  749. let newMetadata = NCManageDatabase.shared.createMetadata(account: urlBase.account, user: urlBase.user, userId: urlBase.userId, fileName: entry.title, fileNameView: entry.title, ocId: NSUUID().uuidString, serverUrl: urlBase.urlBase, urlBase: urlBase.urlBase, url: entry.resourceURL, contentType: "", isUrl: true, name: searchResult.name.lowercased(), subline: entry.subline, iconName: entry.icon, iconUrl: entry.thumbnailURL)
  750. metadatas.append(newMetadata)
  751. })
  752. }
  753. completion(searchResult, metadatas, errorCode, errorDescription)
  754. }
  755. if let request = request {
  756. requestsUnifiedSearch.append(request)
  757. }
  758. }
  759. func cancelUnifiedSearchFiles() {
  760. for request in requestsUnifiedSearch {
  761. request.cancel()
  762. }
  763. requestsUnifiedSearch.removeAll()
  764. }
  765. private func loadMetadata(urlBase: NCUserBaseUrl, filePath: String, dispatchGroup: DispatchGroup? = nil, completion: @escaping (String, tableMetadata, Int, String) -> Void) {
  766. let urlPath = urlBase.urlBase + "/remote.php/dav/files/" + urlBase.user + filePath
  767. dispatchGroup?.enter()
  768. self.readFile(serverUrlFileName: urlPath) { account, metadata, errorCode, errorDescription in
  769. defer { dispatchGroup?.leave() }
  770. guard let metadata = metadata else { return }
  771. let returnMetadata = tableMetadata.init(value: metadata)
  772. NCManageDatabase.shared.addMetadata(metadata)
  773. completion(account, returnMetadata, errorCode, errorDescription)
  774. }
  775. }
  776. // MARK: - WebDav Create Folder
  777. @objc func createFolder(fileName: String, serverUrl: String, account: String, urlBase: String, overwrite: Bool = false, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  778. let isDirectoryEncrypted = CCUtility.isFolderEncrypted(serverUrl, e2eEncrypted: false, account: account, urlBase: urlBase)
  779. let fileName = fileName.trimmingCharacters(in: .whitespacesAndNewlines)
  780. if isDirectoryEncrypted {
  781. #if !EXTENSION
  782. NCNetworkingE2EE.shared.createFolder(fileName: fileName, serverUrl: serverUrl, account: account, urlBase: urlBase, completion: completion)
  783. #endif
  784. } else {
  785. createFolderPlain(fileName: fileName, serverUrl: serverUrl, account: account, urlBase: urlBase, overwrite: overwrite, completion: completion)
  786. }
  787. }
  788. private func createFolderPlain(fileName: String, serverUrl: String, account: String, urlBase: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  789. var fileNameFolder = CCUtility.removeForbiddenCharactersServer(fileName)!
  790. if !overwrite {
  791. fileNameFolder = NCUtilityFileSystem.shared.createFileName(fileNameFolder, serverUrl: serverUrl, account: account)
  792. }
  793. if fileNameFolder.count == 0 {
  794. return completion(0, "")
  795. }
  796. let fileNameFolderUrl = serverUrl + "/" + fileNameFolder
  797. NCCommunication.shared.createFolder(fileNameFolderUrl) { account, ocId, _, errorCode, errorDescription in
  798. guard errorCode == 0 else {
  799. if errorCode == 405 && overwrite {
  800. completion(0, "")
  801. } else {
  802. completion(errorCode, errorDescription)
  803. }
  804. return
  805. }
  806. self.readFile(serverUrlFileName: fileNameFolderUrl) { (account, metadataFolder, errorCode, errorDescription) in
  807. if errorCode == 0 {
  808. if let metadata = metadataFolder {
  809. NCManageDatabase.shared.addMetadata(metadata)
  810. NCManageDatabase.shared.addDirectory(encrypted: metadata.e2eEncrypted, favorite: metadata.favorite, ocId: metadata.ocId, fileId: metadata.fileId, etag: nil, permissions: metadata.permissions, serverUrl: fileNameFolderUrl, account: account)
  811. }
  812. if let metadata = NCManageDatabase.shared.getMetadataFromOcId(metadataFolder?.ocId) {
  813. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterCreateFolder, userInfo: ["ocId": metadata.ocId])
  814. }
  815. }
  816. completion(errorCode, errorDescription)
  817. }
  818. }
  819. }
  820. func createFolder(assets: [PHAsset], selector: String, useSubFolder: Bool, account: String, urlBase: String) -> Bool {
  821. let serverUrl = NCManageDatabase.shared.getAccountAutoUploadDirectory(urlBase: urlBase, account: account)
  822. let fileName = NCManageDatabase.shared.getAccountAutoUploadFileName()
  823. let autoUploadPath = NCManageDatabase.shared.getAccountAutoUploadPath(urlBase: urlBase, account: account)
  824. var result = createFolderWithSemaphore(fileName: fileName, serverUrl: serverUrl, account: account, urlBase: urlBase)
  825. if useSubFolder && result {
  826. for dateSubFolder in CCUtility.createNameSubFolder(assets) {
  827. let fileName = (dateSubFolder as! NSString).lastPathComponent
  828. let serverUrl = ((autoUploadPath + "/" + (dateSubFolder as! String)) as NSString).deletingLastPathComponent
  829. result = createFolderWithSemaphore(fileName: fileName, serverUrl: serverUrl, account: account, urlBase: urlBase)
  830. if !result { break }
  831. }
  832. }
  833. return result
  834. }
  835. private func createFolderWithSemaphore(fileName: String, serverUrl: String, account: String, urlBase: String) -> Bool {
  836. var result: Bool = false
  837. let semaphore = Semaphore()
  838. NCNetworking.shared.createFolder(fileName: fileName, serverUrl: serverUrl, account: account, urlBase: urlBase, overwrite: true) { errorCode, _ in
  839. if errorCode == 0 { result = true }
  840. semaphore.continue()
  841. }
  842. if semaphore.wait() == .success { result = true }
  843. return result
  844. }
  845. // MARK: - WebDav Delete
  846. @objc func deleteMetadata(_ metadata: tableMetadata, onlyLocalCache: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  847. if onlyLocalCache {
  848. var metadatas = [metadata]
  849. if metadata.directory {
  850. let serverUrl = metadata.serverUrl + "/" + metadata.fileName
  851. metadatas = NCManageDatabase.shared.getMetadatas(predicate: NSPredicate(format: "account == %@ AND serverUrl BEGINSWITH %@ AND directory == false", metadata.account, serverUrl))
  852. }
  853. for metadata in metadatas {
  854. NCManageDatabase.shared.deleteVideo(metadata: metadata)
  855. NCManageDatabase.shared.deleteLocalFile(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  856. NCUtilityFileSystem.shared.deleteFile(filePath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  857. if let metadataLivePhoto = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata) {
  858. NCManageDatabase.shared.deleteLocalFile(predicate: NSPredicate(format: "ocId == %@", metadataLivePhoto.ocId))
  859. NCUtilityFileSystem.shared.deleteFile(filePath: CCUtility.getDirectoryProviderStorageOcId(metadataLivePhoto.ocId))
  860. }
  861. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDeleteFile, userInfo: ["ocId": metadata.ocId, "fileNameView": metadata.fileNameView, "serverUrl": metadata.serverUrl, "account": metadata.account, "classFile": metadata.classFile, "onlyLocalCache": true])
  862. }
  863. return completion(0, "")
  864. }
  865. let isDirectoryEncrypted = CCUtility.isFolderEncrypted(metadata.serverUrl, e2eEncrypted: metadata.e2eEncrypted, account: metadata.account, urlBase: metadata.urlBase)
  866. let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata)
  867. if isDirectoryEncrypted {
  868. #if !EXTENSION
  869. if metadataLive == nil {
  870. NCNetworkingE2EE.shared.deleteMetadata(metadata, completion: completion)
  871. } else {
  872. NCNetworkingE2EE.shared.deleteMetadata(metadataLive!) { errorCode, errorDescription in
  873. if errorCode == 0 {
  874. NCNetworkingE2EE.shared.deleteMetadata(metadata, completion: completion)
  875. } else {
  876. completion(errorCode, errorDescription)
  877. }
  878. }
  879. }
  880. #endif
  881. } else {
  882. if metadataLive == nil {
  883. self.deleteMetadataPlain(metadata, addCustomHeaders: nil, completion: completion)
  884. } else {
  885. self.deleteMetadataPlain(metadataLive!, addCustomHeaders: nil) { errorCode, errorDescription in
  886. if errorCode == 0 {
  887. self.deleteMetadataPlain(metadata, addCustomHeaders: nil, completion: completion)
  888. } else {
  889. completion(errorCode, errorDescription)
  890. }
  891. }
  892. }
  893. }
  894. }
  895. func deleteMetadataPlain(_ metadata: tableMetadata, addCustomHeaders: [String: String]?, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  896. // verify permission
  897. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanDelete)
  898. if metadata.permissions != "" && permission == false {
  899. return completion(NCGlobal.shared.errorInternalError, "_no_permission_delete_file_")
  900. }
  901. let serverUrlFileName = metadata.serverUrl + "/" + metadata.fileName
  902. NCCommunication.shared.deleteFileOrFolder(serverUrlFileName, customUserAgent: nil, addCustomHeaders: addCustomHeaders) { account, errorCode, errorDescription in
  903. if errorCode == 0 || errorCode == NCGlobal.shared.errorResourceNotFound {
  904. do {
  905. try FileManager.default.removeItem(atPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId))
  906. } catch { }
  907. NCManageDatabase.shared.deleteVideo(metadata: metadata)
  908. NCManageDatabase.shared.deleteMetadata(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  909. NCManageDatabase.shared.deleteLocalFile(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  910. if metadata.directory {
  911. NCManageDatabase.shared.deleteDirectoryAndSubDirectory(serverUrl: CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: metadata.fileName), account: metadata.account)
  912. }
  913. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDeleteFile, userInfo: ["ocId": metadata.ocId, "fileNameView": metadata.fileNameView, "serverUrl": metadata.serverUrl, "account": metadata.account, "classFile": metadata.classFile, "onlyLocalCache": false])
  914. }
  915. completion(errorCode, errorDescription)
  916. }
  917. }
  918. // MARK: - WebDav Favorite
  919. @objc func favoriteMetadata(_ metadata: tableMetadata, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  920. if let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata) {
  921. favoriteMetadataPlain(metadataLive) { errorCode, errorDescription in
  922. if errorCode == 0 {
  923. self.favoriteMetadataPlain(metadata, completion: completion)
  924. } else {
  925. completion(errorCode, errorDescription)
  926. }
  927. }
  928. } else {
  929. favoriteMetadataPlain(metadata, completion: completion)
  930. }
  931. }
  932. private func favoriteMetadataPlain(_ metadata: tableMetadata, completion: @escaping (_ errorCode: Int, _ errorDescription: String) -> Void) {
  933. let fileName = CCUtility.returnFileNamePath(fromFileName: metadata.fileName, serverUrl: metadata.serverUrl, urlBase: metadata.urlBase, account: metadata.account)!
  934. let favorite = !metadata.favorite
  935. let ocId = metadata.ocId
  936. NCCommunication.shared.setFavorite(fileName: fileName, favorite: favorite) { account, errorCode, errorDescription in
  937. if errorCode == 0 && metadata.account == account {
  938. NCManageDatabase.shared.setMetadataFavorite(ocId: metadata.ocId, favorite: favorite)
  939. #if !EXTENSION
  940. if favorite {
  941. NCOperationQueue.shared.synchronizationMetadata(metadata, selector: NCGlobal.shared.selectorReadFile)
  942. }
  943. #endif
  944. if let metadata = NCManageDatabase.shared.getMetadataFromOcId(ocId) {
  945. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterFavoriteFile, userInfo: ["ocId": metadata.ocId])
  946. }
  947. }
  948. completion(errorCode, errorDescription)
  949. }
  950. }
  951. @objc func listingFavoritescompletion(selector: String, completion: @escaping (_ account: String, _ metadatas: [tableMetadata]?, _ errorCode: Int, _ errorDescription: String) -> Void) {
  952. NCCommunication.shared.listingFavorites(showHiddenFiles: CCUtility.getShowHiddenFiles(), queue: NCCommunicationCommon.shared.backgroundQueue) { account, files, errorCode, errorDescription in
  953. guard errorCode == 0 else {
  954. completion(account, nil, errorCode, errorDescription)
  955. return
  956. }
  957. NCManageDatabase.shared.convertNCCommunicationFilesToMetadatas(files, useMetadataFolder: false, account: account) { _, _, metadatas in
  958. NCManageDatabase.shared.updateMetadatasFavorite(account: account, metadatas: metadatas)
  959. if selector != NCGlobal.shared.selectorListingFavorite {
  960. #if !EXTENSION
  961. for metadata in metadatas {
  962. NCOperationQueue.shared.synchronizationMetadata(metadata, selector: selector)
  963. }
  964. #endif
  965. }
  966. completion(account, metadatas, errorCode, errorDescription)
  967. }
  968. }
  969. }
  970. // MARK: - Lock Files
  971. @objc func lockUnlockFile(_ metadata: tableMetadata, shoulLock: Bool) {
  972. NCCommunication.shared.lockUnlockFile(serverUrlFileName: metadata.serverUrl + "/" + metadata.fileName, shouldLock: shoulLock) { errorCode, errorDescription in
  973. // 0: lock was successful; 412: lock did not change, no error, refresh
  974. guard errorCode == 0 || errorCode == 412 else {
  975. NCContentPresenter.shared.messageNotification(metadata.fileName, description: "_files_lock_error_", delay: NCGlobal.shared.dismissAfterSecond, type: NCContentPresenter.messageType.error, errorCode: errorCode, priority: .max)
  976. return
  977. }
  978. NCNetworking.shared.readFile(serverUrlFileName: metadata.serverUrl + "/" + metadata.fileName) { account, metadata, errorCode, errorDescription in
  979. guard errorCode == 0, let metadata = metadata else { return }
  980. NCManageDatabase.shared.addMetadata(metadata)
  981. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterReloadDataSource)
  982. }
  983. }
  984. }
  985. // MARK: - WebDav Rename
  986. @objc func renameMetadata(_ metadata: tableMetadata, fileNameNew: String, viewController: UIViewController?, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  987. let isDirectoryEncrypted = CCUtility.isFolderEncrypted(metadata.serverUrl, e2eEncrypted: metadata.e2eEncrypted, account: metadata.account, urlBase: metadata.urlBase)
  988. let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata)
  989. let fileNameNew = fileNameNew.trimmingCharacters(in: .whitespacesAndNewlines)
  990. let fileNameNewLive = (fileNameNew as NSString).deletingPathExtension + ".mov"
  991. if isDirectoryEncrypted {
  992. #if !EXTENSION
  993. if metadataLive == nil {
  994. NCNetworkingE2EE.shared.renameMetadata(metadata, fileNameNew: fileNameNew, completion: completion)
  995. } else {
  996. NCNetworkingE2EE.shared.renameMetadata(metadataLive!, fileNameNew: fileNameNewLive) { errorCode, errorDescription in
  997. if errorCode == 0 {
  998. NCNetworkingE2EE.shared.renameMetadata(metadata, fileNameNew: fileNameNew, completion: completion)
  999. } else {
  1000. completion(errorCode, errorDescription)
  1001. }
  1002. }
  1003. }
  1004. #endif
  1005. } else {
  1006. if metadataLive == nil {
  1007. renameMetadataPlain(metadata, fileNameNew: fileNameNew, completion: completion)
  1008. } else {
  1009. renameMetadataPlain(metadataLive!, fileNameNew: fileNameNewLive) { errorCode, errorDescription in
  1010. if errorCode == 0 {
  1011. self.renameMetadataPlain(metadata, fileNameNew: fileNameNew, completion: completion)
  1012. } else {
  1013. completion(errorCode, errorDescription)
  1014. }
  1015. }
  1016. }
  1017. }
  1018. }
  1019. private func renameMetadataPlain(_ metadata: tableMetadata, fileNameNew: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1020. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanRename)
  1021. if !(metadata.permissions == "") && !permission {
  1022. return completion(NCGlobal.shared.errorInternalError, "_no_permission_modify_file_")
  1023. }
  1024. guard let fileNameNew = CCUtility.removeForbiddenCharactersServer(fileNameNew) else {
  1025. return completion(0, "")
  1026. }
  1027. if fileNameNew.count == 0 || fileNameNew == metadata.fileNameView {
  1028. return completion(0, "")
  1029. }
  1030. let fileNamePath = metadata.serverUrl + "/" + metadata.fileName
  1031. let fileNameToPath = metadata.serverUrl + "/" + fileNameNew
  1032. let ocId = metadata.ocId
  1033. NCCommunication.shared.moveFileOrFolder(serverUrlFileNameSource: fileNamePath, serverUrlFileNameDestination: fileNameToPath, overwrite: false) { account, errorCode, errorDescription in
  1034. if errorCode == 0 {
  1035. NCManageDatabase.shared.renameMetadata(fileNameTo: fileNameNew, ocId: ocId)
  1036. if metadata.directory {
  1037. let serverUrl = CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: metadata.fileName)!
  1038. let serverUrlTo = CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: fileNameNew)!
  1039. if let directory = NCManageDatabase.shared.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, metadata.serverUrl)) {
  1040. NCManageDatabase.shared.setDirectory(serverUrl: serverUrl, serverUrlTo: serverUrlTo, etag: "", ocId: nil, fileId: nil, encrypted: directory.e2eEncrypted, richWorkspace: nil, account: metadata.account)
  1041. }
  1042. } else {
  1043. let ext = (metadata.fileName as NSString).pathExtension
  1044. let extNew = (fileNameNew as NSString).pathExtension
  1045. if ext != extNew {
  1046. if let path = CCUtility.getDirectoryProviderStorageOcId(ocId) {
  1047. NCUtilityFileSystem.shared.deleteFile(filePath: path)
  1048. }
  1049. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterReloadDataSourceNetworkForced, userInfo: ["serverUrl": metadata.serverUrl])
  1050. } else {
  1051. NCManageDatabase.shared.setLocalFile(ocId: ocId, fileName: fileNameNew, etag: nil)
  1052. // Move file system
  1053. let atPath = CCUtility.getDirectoryProviderStorageOcId(ocId) + "/" + metadata.fileName
  1054. let toPath = CCUtility.getDirectoryProviderStorageOcId(ocId) + "/" + fileNameNew
  1055. do {
  1056. try FileManager.default.moveItem(atPath: atPath, toPath: toPath)
  1057. } catch { }
  1058. }
  1059. }
  1060. if let metadata = NCManageDatabase.shared.getMetadataFromOcId(ocId) {
  1061. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterRenameFile, userInfo: ["ocId": metadata.ocId])
  1062. }
  1063. }
  1064. completion(errorCode, errorDescription)
  1065. }
  1066. }
  1067. // MARK: - WebDav Move
  1068. @objc func moveMetadata(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1069. if let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata) {
  1070. moveMetadataPlain(metadataLive, serverUrlTo: serverUrlTo, overwrite: overwrite) { errorCode, errorDescription in
  1071. if errorCode == 0 {
  1072. self.moveMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1073. } else {
  1074. completion(errorCode, errorDescription)
  1075. }
  1076. }
  1077. } else {
  1078. moveMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1079. }
  1080. }
  1081. private func moveMetadataPlain(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1082. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanRename)
  1083. if !(metadata.permissions == "") && !permission {
  1084. return completion(NCGlobal.shared.errorInternalError, "_no_permission_modify_file_")
  1085. }
  1086. let serverUrlFrom = metadata.serverUrl
  1087. let serverUrlFileNameSource = metadata.serverUrl + "/" + metadata.fileName
  1088. let serverUrlFileNameDestination = serverUrlTo + "/" + metadata.fileName
  1089. NCCommunication.shared.moveFileOrFolder(serverUrlFileNameSource: serverUrlFileNameSource, serverUrlFileNameDestination: serverUrlFileNameDestination, overwrite: overwrite) { account, errorCode, errorDescription in
  1090. if errorCode == 0 {
  1091. if metadata.directory {
  1092. NCManageDatabase.shared.deleteDirectoryAndSubDirectory(serverUrl: CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: metadata.fileName), account: account)
  1093. }
  1094. NCManageDatabase.shared.moveMetadata(ocId: metadata.ocId, serverUrlTo: serverUrlTo)
  1095. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterMoveFile, userInfo: ["ocId": metadata.ocId, "serverUrlFrom": serverUrlFrom])
  1096. }
  1097. completion(errorCode, errorDescription)
  1098. }
  1099. }
  1100. // MARK: - WebDav Copy
  1101. @objc func copyMetadata(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1102. if let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata) {
  1103. copyMetadataPlain(metadataLive, serverUrlTo: serverUrlTo, overwrite: overwrite) { errorCode, errorDescription in
  1104. if errorCode == 0 {
  1105. self.copyMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1106. } else {
  1107. completion(errorCode, errorDescription)
  1108. }
  1109. }
  1110. } else {
  1111. copyMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1112. }
  1113. }
  1114. private func copyMetadataPlain(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1115. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanRename)
  1116. if !(metadata.permissions == "") && !permission {
  1117. return completion(NCGlobal.shared.errorInternalError, "_no_permission_modify_file_")
  1118. }
  1119. let serverUrlFileNameSource = metadata.serverUrl + "/" + metadata.fileName
  1120. let serverUrlFileNameDestination = serverUrlTo + "/" + metadata.fileName
  1121. NCCommunication.shared.copyFileOrFolder(serverUrlFileNameSource: serverUrlFileNameSource, serverUrlFileNameDestination: serverUrlFileNameDestination, overwrite: overwrite) { _, errorCode, errorDescription in
  1122. if errorCode == 0 {
  1123. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterCopyFile, userInfo: ["ocId": metadata.ocId, "serverUrlTo": serverUrlTo])
  1124. }
  1125. completion(errorCode, errorDescription)
  1126. }
  1127. }
  1128. // MARK: - Direct Download
  1129. func getVideoUrl(metadata: tableMetadata, completition: @escaping (_ url: URL?) -> Void) {
  1130. if CCUtility.fileProviderStorageExists(metadata) {
  1131. completition(URL(fileURLWithPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileNameView)))
  1132. } else {
  1133. NCCommunication.shared.getDirectDownload(fileId: metadata.fileId) { _, url, errorCode, _ in
  1134. if errorCode == 0 && url != nil {
  1135. if let url = URL(string: url!) {
  1136. completition(url)
  1137. } else {
  1138. completition(nil)
  1139. }
  1140. } else {
  1141. completition(nil)
  1142. }
  1143. }
  1144. }
  1145. }
  1146. // MARK: - TEST API
  1147. /*
  1148. @objc public func getDirectDownload(urlBase: String, username: String, password: String, fileId: String, customUserAgent: String? = nil, completionHandler: @escaping (_ token: String?, _ errorCode: Int, _ errorDescription: String) -> Void) {
  1149. let endpoint = "/ocs/v2.php/apps/dav/api/v1/direct"
  1150. let url:URLConvertible = try! (urlBase + endpoint).asURL() as URLConvertible
  1151. var headers: HTTPHeaders = [.authorization(username: username, password: password)]
  1152. if customUserAgent != nil {
  1153. headers.update(.userAgent(customUserAgent!))
  1154. }
  1155. //headers.update(.contentType("application/json"))
  1156. headers.update(name: "OCS-APIRequest", value: "true")
  1157. let method = HTTPMethod(rawValue: "POST")
  1158. let parameters = [
  1159. "fileId": fileId,
  1160. ]
  1161. AF.request(url, method: method, parameters: parameters, headers: headers).validate(statusCode: 200..<300).response { (response) in
  1162. debugPrint(response)
  1163. switch response.result {
  1164. case .failure(let error):
  1165. completionHandler(nil, 0, "")
  1166. case .success(let data):
  1167. if let data = data {
  1168. completionHandler("", 0, "")
  1169. } else {
  1170. completionHandler(nil, NSURLErrorBadServerResponse, NSLocalizedString("_error_decode_xml_", value: "Invalid response, error decode XML", comment: ""))
  1171. }
  1172. }
  1173. }
  1174. }
  1175. */
  1176. }
  1177. extension Array where Element == URLQueryItem {
  1178. subscript(name: String) -> URLQueryItem? {
  1179. first(where: { $0.name == name })
  1180. }
  1181. }