NCNetworking.swift 78 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448
  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, "serverUrl": metadata.serverUrl, "account": metadata.account])
  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. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterFavoriteFile, userInfo: ["ocId": ocId, "serverUrl": metadata.serverUrl])
  945. }
  946. completion(errorCode, errorDescription)
  947. }
  948. }
  949. @objc func listingFavoritescompletion(selector: String, completion: @escaping (_ account: String, _ metadatas: [tableMetadata]?, _ errorCode: Int, _ errorDescription: String) -> Void) {
  950. NCCommunication.shared.listingFavorites(showHiddenFiles: CCUtility.getShowHiddenFiles(), queue: NCCommunicationCommon.shared.backgroundQueue) { account, files, errorCode, errorDescription in
  951. guard errorCode == 0 else {
  952. completion(account, nil, errorCode, errorDescription)
  953. return
  954. }
  955. NCManageDatabase.shared.convertNCCommunicationFilesToMetadatas(files, useMetadataFolder: false, account: account) { _, _, metadatas in
  956. NCManageDatabase.shared.updateMetadatasFavorite(account: account, metadatas: metadatas)
  957. if selector != NCGlobal.shared.selectorListingFavorite {
  958. #if !EXTENSION
  959. for metadata in metadatas {
  960. NCOperationQueue.shared.synchronizationMetadata(metadata, selector: selector)
  961. }
  962. #endif
  963. }
  964. completion(account, metadatas, errorCode, errorDescription)
  965. }
  966. }
  967. }
  968. // MARK: - Lock Files
  969. @objc func lockUnlockFile(_ metadata: tableMetadata, shoulLock: Bool) {
  970. NCCommunication.shared.lockUnlockFile(serverUrlFileName: metadata.serverUrl + "/" + metadata.fileName, shouldLock: shoulLock) { errorCode, errorDescription in
  971. // 0: lock was successful; 412: lock did not change, no error, refresh
  972. guard errorCode == 0 || errorCode == 412 else {
  973. NCContentPresenter.shared.messageNotification(metadata.fileName, description: "_files_lock_error_", delay: NCGlobal.shared.dismissAfterSecond, type: NCContentPresenter.messageType.error, errorCode: errorCode, priority: .max)
  974. return
  975. }
  976. NCNetworking.shared.readFile(serverUrlFileName: metadata.serverUrl + "/" + metadata.fileName) { account, metadata, errorCode, errorDescription in
  977. guard errorCode == 0, let metadata = metadata else { return }
  978. NCManageDatabase.shared.addMetadata(metadata)
  979. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterReloadDataSource)
  980. }
  981. }
  982. }
  983. // MARK: - WebDav Rename
  984. @objc func renameMetadata(_ metadata: tableMetadata, fileNameNew: String, viewController: UIViewController?, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  985. let isDirectoryEncrypted = CCUtility.isFolderEncrypted(metadata.serverUrl, e2eEncrypted: metadata.e2eEncrypted, account: metadata.account, urlBase: metadata.urlBase)
  986. let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata)
  987. let fileNameNew = fileNameNew.trimmingCharacters(in: .whitespacesAndNewlines)
  988. let fileNameNewLive = (fileNameNew as NSString).deletingPathExtension + ".mov"
  989. if isDirectoryEncrypted {
  990. #if !EXTENSION
  991. if metadataLive == nil {
  992. NCNetworkingE2EE.shared.renameMetadata(metadata, fileNameNew: fileNameNew, completion: completion)
  993. } else {
  994. NCNetworkingE2EE.shared.renameMetadata(metadataLive!, fileNameNew: fileNameNewLive) { errorCode, errorDescription in
  995. if errorCode == 0 {
  996. NCNetworkingE2EE.shared.renameMetadata(metadata, fileNameNew: fileNameNew, completion: completion)
  997. } else {
  998. completion(errorCode, errorDescription)
  999. }
  1000. }
  1001. }
  1002. #endif
  1003. } else {
  1004. if metadataLive == nil {
  1005. renameMetadataPlain(metadata, fileNameNew: fileNameNew, completion: completion)
  1006. } else {
  1007. renameMetadataPlain(metadataLive!, fileNameNew: fileNameNewLive) { errorCode, errorDescription in
  1008. if errorCode == 0 {
  1009. self.renameMetadataPlain(metadata, fileNameNew: fileNameNew, completion: completion)
  1010. } else {
  1011. completion(errorCode, errorDescription)
  1012. }
  1013. }
  1014. }
  1015. }
  1016. }
  1017. private func renameMetadataPlain(_ metadata: tableMetadata, fileNameNew: String, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1018. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanRename)
  1019. if !(metadata.permissions == "") && !permission {
  1020. return completion(NCGlobal.shared.errorInternalError, "_no_permission_modify_file_")
  1021. }
  1022. guard let fileNameNew = CCUtility.removeForbiddenCharactersServer(fileNameNew) else {
  1023. return completion(0, "")
  1024. }
  1025. if fileNameNew.count == 0 || fileNameNew == metadata.fileNameView {
  1026. return completion(0, "")
  1027. }
  1028. let fileNamePath = metadata.serverUrl + "/" + metadata.fileName
  1029. let fileNameToPath = metadata.serverUrl + "/" + fileNameNew
  1030. let ocId = metadata.ocId
  1031. NCCommunication.shared.moveFileOrFolder(serverUrlFileNameSource: fileNamePath, serverUrlFileNameDestination: fileNameToPath, overwrite: false) { account, errorCode, errorDescription in
  1032. if errorCode == 0 {
  1033. NCManageDatabase.shared.renameMetadata(fileNameTo: fileNameNew, ocId: ocId)
  1034. if metadata.directory {
  1035. let serverUrl = CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: metadata.fileName)!
  1036. let serverUrlTo = CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: fileNameNew)!
  1037. if let directory = NCManageDatabase.shared.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, metadata.serverUrl)) {
  1038. NCManageDatabase.shared.setDirectory(serverUrl: serverUrl, serverUrlTo: serverUrlTo, etag: "", ocId: nil, fileId: nil, encrypted: directory.e2eEncrypted, richWorkspace: nil, account: metadata.account)
  1039. }
  1040. } else {
  1041. let ext = (metadata.fileName as NSString).pathExtension
  1042. let extNew = (fileNameNew as NSString).pathExtension
  1043. if ext != extNew {
  1044. if let path = CCUtility.getDirectoryProviderStorageOcId(ocId) {
  1045. NCUtilityFileSystem.shared.deleteFile(filePath: path)
  1046. }
  1047. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterReloadDataSourceNetworkForced, userInfo: ["serverUrl": metadata.serverUrl])
  1048. } else {
  1049. NCManageDatabase.shared.setLocalFile(ocId: ocId, fileName: fileNameNew, etag: nil)
  1050. // Move file system
  1051. let atPath = CCUtility.getDirectoryProviderStorageOcId(ocId) + "/" + metadata.fileName
  1052. let toPath = CCUtility.getDirectoryProviderStorageOcId(ocId) + "/" + fileNameNew
  1053. do {
  1054. try FileManager.default.moveItem(atPath: atPath, toPath: toPath)
  1055. } catch { }
  1056. }
  1057. }
  1058. if let metadata = NCManageDatabase.shared.getMetadataFromOcId(ocId) {
  1059. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterRenameFile, userInfo: ["ocId": metadata.ocId, "account": metadata.account])
  1060. }
  1061. }
  1062. completion(errorCode, errorDescription)
  1063. }
  1064. }
  1065. // MARK: - WebDav Move
  1066. @objc func moveMetadata(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1067. if let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata) {
  1068. moveMetadataPlain(metadataLive, serverUrlTo: serverUrlTo, overwrite: overwrite) { errorCode, errorDescription in
  1069. if errorCode == 0 {
  1070. self.moveMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1071. } else {
  1072. completion(errorCode, errorDescription)
  1073. }
  1074. }
  1075. } else {
  1076. moveMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1077. }
  1078. }
  1079. private func moveMetadataPlain(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1080. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanRename)
  1081. if !(metadata.permissions == "") && !permission {
  1082. return completion(NCGlobal.shared.errorInternalError, "_no_permission_modify_file_")
  1083. }
  1084. let serverUrlFrom = metadata.serverUrl
  1085. let serverUrlFileNameSource = metadata.serverUrl + "/" + metadata.fileName
  1086. let serverUrlFileNameDestination = serverUrlTo + "/" + metadata.fileName
  1087. NCCommunication.shared.moveFileOrFolder(serverUrlFileNameSource: serverUrlFileNameSource, serverUrlFileNameDestination: serverUrlFileNameDestination, overwrite: overwrite) { account, errorCode, errorDescription in
  1088. if errorCode == 0 {
  1089. if metadata.directory {
  1090. NCManageDatabase.shared.deleteDirectoryAndSubDirectory(serverUrl: CCUtility.stringAppendServerUrl(metadata.serverUrl, addFileName: metadata.fileName), account: account)
  1091. }
  1092. NCManageDatabase.shared.moveMetadata(ocId: metadata.ocId, serverUrlTo: serverUrlTo)
  1093. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterMoveFile, userInfo: ["ocId": metadata.ocId, "account": metadata.account, "serverUrlFrom": serverUrlFrom])
  1094. }
  1095. completion(errorCode, errorDescription)
  1096. }
  1097. }
  1098. // MARK: - WebDav Copy
  1099. @objc func copyMetadata(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1100. if let metadataLive = NCManageDatabase.shared.getMetadataLivePhoto(metadata: metadata) {
  1101. copyMetadataPlain(metadataLive, serverUrlTo: serverUrlTo, overwrite: overwrite) { errorCode, errorDescription in
  1102. if errorCode == 0 {
  1103. self.copyMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1104. } else {
  1105. completion(errorCode, errorDescription)
  1106. }
  1107. }
  1108. } else {
  1109. copyMetadataPlain(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite, completion: completion)
  1110. }
  1111. }
  1112. private func copyMetadataPlain(_ metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, completion: @escaping (_ errorCode: Int, _ errorDescription: String?) -> Void) {
  1113. let permission = NCUtility.shared.permissionsContainsString(metadata.permissions, permissions: NCGlobal.shared.permissionCanRename)
  1114. if !(metadata.permissions == "") && !permission {
  1115. return completion(NCGlobal.shared.errorInternalError, "_no_permission_modify_file_")
  1116. }
  1117. let serverUrlFileNameSource = metadata.serverUrl + "/" + metadata.fileName
  1118. let serverUrlFileNameDestination = serverUrlTo + "/" + metadata.fileName
  1119. NCCommunication.shared.copyFileOrFolder(serverUrlFileNameSource: serverUrlFileNameSource, serverUrlFileNameDestination: serverUrlFileNameDestination, overwrite: overwrite) { _, errorCode, errorDescription in
  1120. if errorCode == 0 {
  1121. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterCopyFile, userInfo: ["ocId": metadata.ocId, "serverUrlTo": serverUrlTo])
  1122. }
  1123. completion(errorCode, errorDescription)
  1124. }
  1125. }
  1126. // MARK: - Direct Download
  1127. func getVideoUrl(metadata: tableMetadata, completition: @escaping (_ url: URL?) -> Void) {
  1128. if CCUtility.fileProviderStorageExists(metadata) {
  1129. completition(URL(fileURLWithPath: CCUtility.getDirectoryProviderStorageOcId(metadata.ocId, fileNameView: metadata.fileNameView)))
  1130. } else {
  1131. NCCommunication.shared.getDirectDownload(fileId: metadata.fileId) { _, url, errorCode, _ in
  1132. if errorCode == 0 && url != nil {
  1133. if let url = URL(string: url!) {
  1134. completition(url)
  1135. } else {
  1136. completition(nil)
  1137. }
  1138. } else {
  1139. completition(nil)
  1140. }
  1141. }
  1142. }
  1143. }
  1144. // MARK: - TEST API
  1145. /*
  1146. @objc public func getDirectDownload(urlBase: String, username: String, password: String, fileId: String, customUserAgent: String? = nil, completionHandler: @escaping (_ token: String?, _ errorCode: Int, _ errorDescription: String) -> Void) {
  1147. let endpoint = "/ocs/v2.php/apps/dav/api/v1/direct"
  1148. let url:URLConvertible = try! (urlBase + endpoint).asURL() as URLConvertible
  1149. var headers: HTTPHeaders = [.authorization(username: username, password: password)]
  1150. if customUserAgent != nil {
  1151. headers.update(.userAgent(customUserAgent!))
  1152. }
  1153. //headers.update(.contentType("application/json"))
  1154. headers.update(name: "OCS-APIRequest", value: "true")
  1155. let method = HTTPMethod(rawValue: "POST")
  1156. let parameters = [
  1157. "fileId": fileId,
  1158. ]
  1159. AF.request(url, method: method, parameters: parameters, headers: headers).validate(statusCode: 200..<300).response { (response) in
  1160. debugPrint(response)
  1161. switch response.result {
  1162. case .failure(let error):
  1163. completionHandler(nil, 0, "")
  1164. case .success(let data):
  1165. if let data = data {
  1166. completionHandler("", 0, "")
  1167. } else {
  1168. completionHandler(nil, NSURLErrorBadServerResponse, NSLocalizedString("_error_decode_xml_", value: "Invalid response, error decode XML", comment: ""))
  1169. }
  1170. }
  1171. }
  1172. }
  1173. */
  1174. }
  1175. extension Array where Element == URLQueryItem {
  1176. subscript(name: String) -> URLQueryItem? {
  1177. first(where: { $0.name == name })
  1178. }
  1179. }