// // FileProviderExtension+Network.swift // PickerFileProvider // // Created by Marino Faggiana on 28/05/18. // Copyright © 2018 TWS. All rights reserved. // // Author Marino Faggiana // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program. If not, see . // import FileProvider extension FileProviderExtension { // -------------------------------------------------------------------------------------------- // MARK: - Delete // -------------------------------------------------------------------------------------------- func deleteFile(withIdentifier itemIdentifier: NSFileProviderItemIdentifier, parentItemIdentifier: NSFileProviderItemIdentifier, metadata: tableMetadata) { /* ONLY iOS 11*/ guard #available(iOS 11, *) else { return } guard let serverUrl = NCManageDatabase.sharedInstance.getServerUrl(metadata.directoryID) else { return } ocNetworking?.deleteFileOrFolder(metadata.fileName, serverUrl: serverUrl, success: { let fileNamePath = self.providerData.directoryUser + "/" + metadata.fileID do { try self.fileManager.removeItem(atPath: fileNamePath) } catch let error { print("error: \(error)") } do { try self.fileManager.removeItem(atPath: fileNamePath + ".ico") } catch let error { print("error: \(error)") } do { try self.fileManager.removeItem(atPath: self.providerData.fileProviderStorageURL!.path + "/" + itemIdentifier.rawValue) } catch let error { print("error: \(error)") } if metadata.directory { let dirForDelete = CCUtility.stringAppendServerUrl(serverUrl, addFileName: metadata.fileName) NCManageDatabase.sharedInstance.deleteDirectoryAndSubDirectory(serverUrl: dirForDelete!) } NCManageDatabase.sharedInstance.deleteLocalFile(predicate: NSPredicate(format: "fileID == %@", metadata.fileID)) NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "fileID == %@", metadata.fileID), clearDateReadDirectoryID: nil) }, failure: { (errorMessage, errorCode) in let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier, providerData: self.providerData) fileProviderSignalUpdateItem.append(item) self.signalEnumerator(for: [item.parentItemIdentifier, .workingSet]) }) } // -------------------------------------------------------------------------------------------- // MARK: - Upload // -------------------------------------------------------------------------------------------- func uploadFileSuccessFailure(_ fileName: String!, fileID: String!, identifier: String!, assetLocalIdentifier: String!, serverUrl: String!, selector: String!, selectorPost: String!, errorMessage: String!, errorCode: Int) { /* ONLY iOS 11*/ guard #available(iOS 11, *) else { return } if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "fileID = %@", assetLocalIdentifier)) { let parentItemIdentifier = providerData.getParentItemIdentifier(metadata: metadata) let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier!, providerData: providerData) fileProviderSignalDeleteItemIdentifier.append(item.itemIdentifier) signalEnumerator(for: [item.parentItemIdentifier, .workingSet]) } NCManageDatabase.sharedInstance.deleteMetadata(predicate: NSPredicate(format: "fileID = %@", assetLocalIdentifier), clearDateReadDirectoryID: nil) if errorCode == 0 { NCManageDatabase.sharedInstance.deleteQueueUpload(assetLocalIdentifier: assetLocalIdentifier, selector: selector) if let metadata = NCManageDatabase.sharedInstance.getMetadata(predicate: NSPredicate(format: "account = %@ AND fileID = %@", providerData.account, fileID)) { // Rename directory file if fileManager.fileExists(atPath: providerData.fileProviderStorageURL!.path + "/" + assetLocalIdentifier) { let itemIdentifier = providerData.getItemIdentifier(metadata: metadata) _ = moveFile(providerData.fileProviderStorageURL!.path + "/" + assetLocalIdentifier, toPath: providerData.fileProviderStorageURL!.path + "/" + itemIdentifier.rawValue) } NCManageDatabase.sharedInstance.setLocalFile(fileID: fileID, date: nil, exifDate: nil, exifLatitude: nil, exifLongitude: nil, fileName: nil, etag: metadata.etag, etagFPE: metadata.etag) let parentItemIdentifier = providerData.getParentItemIdentifier(metadata: metadata) if parentItemIdentifier != nil { let item = FileProviderItem(metadata: metadata, parentItemIdentifier: parentItemIdentifier!, providerData: providerData) fileProviderSignalUpdateItem.append(item) signalEnumerator(for: [item.parentItemIdentifier, .workingSet]) } } } else { NCManageDatabase.sharedInstance.unlockQueueUpload(assetLocalIdentifier: assetLocalIdentifier) } uploadFile() } func uploadFile() { let queueInLock = NCManageDatabase.sharedInstance.getQueueUploadInLock() if queueInLock != nil && queueInLock!.count == 0 { let metadataNetQueue = NCManageDatabase.sharedInstance.lockQueueUpload(selector: selectorUploadFile, withPath: true) if metadataNetQueue != nil { if self.copyFile(metadataNetQueue!.path, toPath: providerData.directoryUser + "/" + metadataNetQueue!.fileName) == nil { CCNetworking.shared().uploadFile(metadataNetQueue!.fileName, serverUrl: metadataNetQueue!.serverUrl, identifier: metadataNetQueue!.identifier, assetLocalIdentifier: metadataNetQueue!.assetLocalIdentifier ,session: metadataNetQueue!.session, taskStatus: metadataNetQueue!.taskStatus, selector: metadataNetQueue!.selector, selectorPost: metadataNetQueue!.selectorPost, errorCode: 0, delegate: self) } else { // file not present, delete record Upload Queue NCManageDatabase.sharedInstance.deleteQueueUpload(path: metadataNetQueue!.path) } } } } func verifyUploadQueueInLock() { let tasks = CCNetworking.shared().getUploadTasksExtensionSession() if tasks!.count == 0 { let records = NCManageDatabase.sharedInstance.getQueueUpload(predicate: NSPredicate(format: "account = %@ AND selector = %@ AND lock == true AND path != nil", providerData.account, selectorUploadFile)) if records != nil && records!.count > 0 { NCManageDatabase.sharedInstance.unlockAllQueueUploadWithPath() } } } }