// // NCManageDatabase.swift // Crypto Cloud Technology Nextcloud // // Created by Marino Faggiana on 06/05/17. // Copyright © 2017 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 RealmSwift class NCManageDatabase: NSObject { static let sharedInstance: NCManageDatabase = { let instance = NCManageDatabase() return instance }() override init() { let dirGroup = FileManager.default.containerURL(forSecurityApplicationGroupIdentifier: NCBrandOptions.sharedInstance.capabilitiesGroups) let config = Realm.Configuration( fileURL: dirGroup?.appendingPathComponent("\(appDatabaseNextcloud)/\(k_databaseDefault)"), schemaVersion: 1, migrationBlock: { migration, oldSchemaVersion in // We haven’t migrated anything yet, so oldSchemaVersion == 0 if (oldSchemaVersion < 1) { // Nothing to do! // Realm will automatically detect new properties and removed properties // And will update the schema on disk automatically } }) Realm.Configuration.defaultConfiguration = config _ = try! Realm() } //MARK: - //MARK: Utility Database func clearTable(_ table : Object.Type, account: String?) { let results : Results let realm = try! Realm() realm.beginWrite() if account != nil { results = realm.objects(table).filter("account = %@", account!) } else { results = realm.objects(table) } realm.delete(results) try! realm.commitWrite() } func removeDB() { let realmURL = Realm.Configuration.defaultConfiguration.fileURL! let realmURLs = [ realmURL, realmURL.appendingPathExtension("lock"), realmURL.appendingPathExtension("note"), realmURL.appendingPathExtension("management") ] for URL in realmURLs { do { try FileManager.default.removeItem(at: URL) } catch { // handle error } } } func getThreadConfined(_ table: Object) -> Any { // id tradeReference = [[NCManageDatabase sharedInstance] getThreadConfined:metadata]; return ThreadSafeReference(to: table) } func putThreadConfined(_ tableRef: Any) -> Object? { //tableMetadata *metadataThread = (tableMetadata *)[[NCManageDatabase sharedInstance] putThreadConfined:tradeReference]; let realm = try! Realm() return realm.resolve(tableRef as! ThreadSafeReference) } func isTableInvalidated(_ table: Object) -> Bool { return table.isInvalidated } //MARK: - //MARK: Table Account func addAccount(_ account: String, url: String, user: String, password: String) { let realm = try! Realm() realm.beginWrite() let addAccount = tableAccount() addAccount.account = account // Brand if NCBrandOptions.sharedInstance.use_default_automatic_upload { addAccount.autoUpload = true addAccount.autoUploadPhoto = true addAccount.autoUploadVideo = true addAccount.autoUploadWWAnVideo = true } addAccount.password = password addAccount.url = url addAccount.user = user realm.add(addAccount) try! realm.commitWrite() } func setAccountPassword(_ account: String, password: String) { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("account = %@", account).first if result != nil { try! realm.write { result?.password = password } } } func deleteAccount(_ account: String) { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("account = %@", account).first if result != nil { try! realm.write { realm.delete(result!) } } } func getAccountActive() -> tableAccount? { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("active = true").first if result != nil { return result } else { return nil } } func getAccounts() -> [String] { let realm = try! Realm() let results : Results var accounts = [String]() results = realm.objects(tableAccount.self).sorted(byKeyPath: "account", ascending: true) for result in results { accounts.append(result.account) } return Array(accounts) } func getAccountAutoUploadFileName() -> String { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("active = true").first if result != nil { if result!.autoUploadFileName.characters.count > 0 { return result!.autoUploadFileName } else { return NCBrandOptions.sharedInstance.folderDefaultAutoUpload } } return "" } func getAccountAutoUploadDirectory(_ activeUrl : String) -> String { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("active = true").first if result != nil { if result!.autoUploadDirectory.characters.count > 0 { return result!.autoUploadDirectory } else { return CCUtility.getHomeServerUrlActiveUrl(activeUrl) } } return "" } func getAccountAutoUploadPath(_ activeUrl : String) -> String { let cameraFileName = self.getAccountAutoUploadFileName() let cameraDirectory = self.getAccountAutoUploadDirectory(activeUrl) let folderPhotos = CCUtility.stringAppendServerUrl(cameraDirectory, addFileName: cameraFileName)! return folderPhotos } func setAccountActive(_ account: String) -> tableAccount { let realm = try! Realm() var activeAccount = tableAccount() let results = realm.objects(tableAccount.self) try! realm.write { for result in results { if result.account == account { result.active = true activeAccount = result } else { result.active = false } } } return activeAccount } func setAccountAutoUploadFiled(_ field: String, state: Bool) { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("active = true").first if result != nil { try! realm.write { switch field { case "autoUpload": result?.autoUpload = state case "autoUploadBackground": result?.autoUploadBackground = state case "autoUploadCreateSubfolder": result?.autoUploadCreateSubfolder = state case "autoUploadFull": result?.autoUploadFull = state case "autoUploadPhoto": result?.autoUploadPhoto = state case "autoUploadVideo": result?.autoUploadVideo = state case "autoUploadWWAnPhoto": result?.autoUploadWWAnPhoto = state case "autoUploadWWAnVideo": result?.autoUploadWWAnVideo = state default: print("No founfd field") } } } } func setAccountAutoUploadDateAssetType(_ assetMediaType: PHAssetMediaType, assetDate: NSDate?) { let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("active = true").first try! realm.write { if (assetMediaType == PHAssetMediaType.image && result != nil) { result?.autoUploadDatePhoto = assetDate } if (assetMediaType == PHAssetMediaType.video && result != nil) { result?.autoUploadDateVideo = assetDate } } } func setAccountAutoUploadFileName(_ fileName: String?) { let realm = try! Realm() var fileName : String? = fileName if fileName == nil { fileName = self.getAccountAutoUploadFileName() } let result = realm.objects(tableAccount.self).filter("active = true").first if result != nil { try! realm.write { result?.autoUploadFileName = fileName! } } } func setAccountAutoUploadDirectory(_ serverUrl: String?, activeUrl: String) { let realm = try! Realm() var serverUrl : String? = serverUrl if serverUrl == nil { serverUrl = self.getAccountAutoUploadDirectory(activeUrl) } let result = realm.objects(tableAccount.self).filter("active = true").first if result != nil { try! realm.write { result?.autoUploadDirectory = serverUrl! } } } func setAccountsUserProfile(_ userProfile: OCUserProfile) { let tblAccount = self.getAccountActive() if tblAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableAccount.self).filter("account = %@", tblAccount!.account).first if result != nil { try! realm.write { result?.enabled = userProfile.enabled result?.address = userProfile.address result?.displayName = userProfile.displayName result?.email = userProfile.email result?.phone = userProfile.phone result?.twitter = userProfile.twitter result?.webpage = userProfile.webpage result?.quota = userProfile.quota result?.quotaFree = userProfile.quotaFree result?.quotaRelative = userProfile.quotaRelative result?.quotaTotal = userProfile.quotaTotal result?.quotaUsed = userProfile.quotaUsed } } } //MARK: - //MARK: Table Activity func getActivity(predicate: NSPredicate) -> [tableActivity] { let realm = try! Realm() let results = realm.objects(tableActivity.self).filter(predicate).sorted(byKeyPath: "date", ascending: false) return Array(results) } func addActivityServer(_ listOfActivity: [OCActivity]) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() try! realm.write { for activity in listOfActivity { let result = realm.objects(tableActivity.self).filter("idActivity = %d", activity.idActivity).first if result != nil { continue } // Add new Activity let addActivity = tableActivity() addActivity.account = tableAccount!.account if activity.date != nil { addActivity.date = activity.date! as NSDate } addActivity.idActivity = Double(activity.idActivity) addActivity.link = activity.link addActivity.note = activity.subject addActivity.type = k_activityTypeInfo realm.add(addActivity) } } } func addActivityClient(_ file: String, fileID: String, action: String, selector: String, note: String, type: String, verbose: Bool, activeUrl: String?) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } var noteReplacing : String = "" if (activeUrl != nil) { noteReplacing = note.replacingOccurrences(of: "\(activeUrl!)\(webDAV)", with: "") } noteReplacing = note.replacingOccurrences(of: "\(k_domain_session_queue).", with: "") let realm = try! Realm() try! realm.write { // Add new Activity let addActivity = tableActivity() addActivity.account = tableAccount!.account addActivity.action = action addActivity.file = file addActivity.fileID = fileID addActivity.note = noteReplacing addActivity.selector = selector addActivity.type = type addActivity.verbose = verbose realm.add(addActivity) } } //MARK: - //MARK: Table Automatic Upload func addAutoUpload(metadataNet: CCMetadataNet) -> Bool { let tableAccount = self.getAccountActive() if tableAccount == nil { return false } let realm = try! Realm() let result = realm.objects(tableAutoUpload.self).filter("account = %@ AND assetLocalIdentifier = %@", tableAccount!.account, metadataNet.assetLocalIdentifier).first if result != nil { return false } try! realm.write { // Add new Auto Upload let addAutoUpload = tableAutoUpload() addAutoUpload.account = tableAccount!.account addAutoUpload.assetLocalIdentifier = metadataNet.assetLocalIdentifier addAutoUpload.fileName = metadataNet.fileName addAutoUpload.selector = metadataNet.selector if (metadataNet.selectorPost != nil) { addAutoUpload.selectorPost = metadataNet.selectorPost } addAutoUpload.serverUrl = metadataNet.serverUrl addAutoUpload.session = metadataNet.session addAutoUpload.priority = metadataNet.priority realm.add(addAutoUpload) } return true } func getAutoUpload(selector: String) -> CCMetadataNet? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let result = realm.objects(tableAutoUpload.self).filter("account = %@ AND selector = %@ AND lock == false", tableAccount!.account, selector).first if result == nil { return nil } let metadataNet = CCMetadataNet() metadataNet.action = actionUploadAsset metadataNet.assetLocalIdentifier = result?.assetLocalIdentifier metadataNet.fileName = result?.fileName metadataNet.priority = result!.priority metadataNet.selector = result?.selector metadataNet.selectorPost = result?.selectorPost metadataNet.serverUrl = result?.serverUrl metadataNet.session = result?.session metadataNet.taskStatus = Int(k_taskStatusResume) // Lock try! realm.write { result?.lock = true } return metadataNet } func getLockAutoUpload() -> [tableAutoUpload]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let results = realm.objects(tableAutoUpload.self).filter("account = %@ AND lock = true", tableAccount!.account) return Array(results) } func unlockAutoUpload(assetLocalIdentifier: String) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableAutoUpload.self).filter("account = %@ AND assetLocalIdentifier = %@", tableAccount!.account, assetLocalIdentifier).first if result != nil { // UnLock try! realm.write { result?.lock = false } } } func deleteAutoUpload(assetLocalIdentifier: String) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableAutoUpload.self).filter("account = %@ AND assetLocalIdentifier = %@", tableAccount!.account, assetLocalIdentifier).first if result != nil { try! realm.write { realm.delete(result!) } } } func countAutoUpload(session: String?) -> Int { let tableAccount = self.getAccountActive() if tableAccount == nil { return 0 } let realm = try! Realm() let results : Results if (session == nil) { results = realm.objects(tableAutoUpload.self).filter("account = %@", tableAccount!.account) } else { results = realm.objects(tableAutoUpload.self).filter("account = %@ AND session = %@", tableAccount!.account, session!) } return results.count } //MARK: - //MARK: Table Capabilities func addCapabilities(_ capabilities: OCCapabilities) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableCapabilities.self).filter("account = %@", tableAccount!.account).first try! realm.write { var resultCapabilities = tableCapabilities() if result != nil { resultCapabilities = result! } resultCapabilities.account = tableAccount!.account resultCapabilities.themingBackground = capabilities.themingBackground resultCapabilities.themingColor = capabilities.themingColor resultCapabilities.themingLogo = capabilities.themingLogo resultCapabilities.themingName = capabilities.themingName resultCapabilities.themingSlogan = capabilities.themingSlogan resultCapabilities.themingUrl = capabilities.themingUrl resultCapabilities.versionMajor = capabilities.versionMajor resultCapabilities.versionMinor = capabilities.versionMinor resultCapabilities.versionMicro = capabilities.versionMicro resultCapabilities.versionString = capabilities.versionString if result == nil { realm.add(resultCapabilities) } } } func getCapabilites() -> tableCapabilities? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let result = realm.objects(tableCapabilities.self).filter("account = %@", tableAccount!.account).first if result != nil { return result } else { return nil } } func getServerVersion() -> Int { let tableAccount = self.getAccountActive() if tableAccount == nil { return 0 } let realm = try! Realm() let result = realm.objects(tableCapabilities.self).filter("account = %@", tableAccount!.account).first if result != nil { return result!.versionMajor } else { return 0 } } //MARK: - //MARK: Table Certificates func addCertificates(_ certificateLocation: String) { let realm = try! Realm() try! realm.write { let addCertificates = tableCertificates() addCertificates.certificateLocation = certificateLocation realm.add(addCertificates) } } func getCertificatesLocation(_ localCertificatesFolder: String) -> [String] { let realm = try! Realm() let results = realm.objects(tableCertificates.self) var arraycertificatePath = [String]() for result in results { arraycertificatePath.append("\(localCertificatesFolder)\(result.certificateLocation)") } return arraycertificatePath } //MARK: - //MARK: Table Directory func addDirectory(serverUrl: String, permissions: String) -> String { let tableAccount = self.getAccountActive() if tableAccount == nil { return "" } let realm = try! Realm() let result = realm.objects(tableDirectory.self).filter("serverUrl = %@", serverUrl).first var directoryID: String = "" try! realm.write { if result == nil || (result?.isInvalidated)! { let addDirectory = tableDirectory() addDirectory.account = tableAccount!.account directoryID = NSUUID().uuidString addDirectory.directoryID = directoryID addDirectory.permissions = permissions addDirectory.serverUrl = serverUrl realm.add(addDirectory, update: true) } else { result?.permissions = permissions directoryID = result!.directoryID realm.add(result!, update: true) } } return directoryID } func deleteDirectoryAndSubDirectory(serverUrl: String) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableDirectory.self).filter("account = %@ AND serverUrl BEGINSWITH %@", tableAccount!.account, serverUrl) for result in results { // delete metadata self.deleteMetadata(predicate: NSPredicate(format: "directoryID = %@", result.directoryID), clearDateReadDirectoryID: result.directoryID) // delete local file self.deleteLocalFile(predicate: NSPredicate(format: "fileID = %@", result.fileID)) /* // remove if in session if ([recordMetadata.session length] >0) { if (recordMetadata.sessionTaskIdentifier >= 0) [[CCNetworking sharedNetworking] settingSession:recordMetadata.session sessionTaskIdentifier:[recordMetadata.sessionTaskIdentifier integerValue] taskStatus: k_taskStatusCancel]; if (recordMetadata.sessionTaskIdentifierPlist >= 0) [[CCNetworking sharedNetworking] settingSession:recordMetadata.session sessionTaskIdentifier:[recordMetadata.sessionTaskIdentifierPlist integerValue] taskStatus: k_taskStatusCancel]; } */ } // Delete table Dirrectory try! realm.write { realm.delete(results) } } func setDirectory(serverUrl: String, serverUrlTo: String?, etag: String?) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() try! realm.write { let result = realm.objects(tableDirectory.self).filter("serverUrl = %@", serverUrl).first if result != nil { if serverUrlTo != nil { result?.serverUrl = serverUrlTo! } if etag != nil { result?.etag = etag! } } } } func clearDateRead(serverUrl: String?, directoryID: String?) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() try! realm.write { var results : Results? if serverUrl != nil { results = realm.objects(tableDirectory.self).filter("serverUrl = %@", serverUrl!) } if directoryID != nil { results = realm.objects(tableDirectory.self).filter("directoryID = %@", directoryID!) } if results != nil { if results!.count > 0 { results![0].dateReadDirectory = nil results![0].etag = "" realm.add(results!, update: true) } } } } func getTableDirectory(predicate: NSPredicate) -> tableDirectory? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let result = realm.objects(tableDirectory.self).filter(predicate).first if result != nil { return result } else { return nil } } func getTablesDirectory(predicate: NSPredicate, sorted: String?, ascending: Bool) -> [tableDirectory]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let results : Results if sorted == nil { results = realm.objects(tableDirectory.self).filter(predicate) } else { results = realm.objects(tableDirectory.self).filter(predicate).sorted(byKeyPath: sorted!, ascending: ascending) } if (results.count > 0) { return Array(results) } else { return nil } } func getDirectoryID(_ serverUrl: String) -> String { let tableAccount = self.getAccountActive() if tableAccount == nil { return "" } let realm = try! Realm() let result = realm.objects(tableDirectory.self).filter("serverUrl = %@", serverUrl).first if result != nil { return (result?.directoryID)! } else { return self.addDirectory(serverUrl: serverUrl, permissions: "") } } func getServerUrl(_ directoryID: String) -> String { let tableAccount = self.getAccountActive() if tableAccount == nil { return "" } let realm = try! Realm() let result = realm.objects(tableDirectory.self).filter("directoryID = %@", directoryID).first if result != nil { return (result?.serverUrl)! } else { return "" } } func setDateReadDirectory(directoryID: String) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() realm.beginWrite() let result = realm.objects(tableDirectory.self).filter("account = %@ AND directoryID = %@", tableAccount!.account, directoryID).first if result != nil { result?.dateReadDirectory = NSDate() } try! realm.commitWrite() } func setClearAllDateReadDirectory() { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableDirectory.self) try! realm.write { for result in results { result.dateReadDirectory = nil; result.etag = "" } } } func setDirectoryLock(serverUrl: String, lock: Bool) -> Bool { var update = false let tableAccount = self.getAccountActive() if tableAccount == nil { return update } let realm = try! Realm() try! realm.write { let result = realm.objects(tableDirectory.self).filter("account = %@ AND serverUrl = %@", tableAccount!.account, serverUrl).first if result != nil { result?.lock = lock update = true } } return update } func setAllDirectoryUnLock() { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableDirectory.self).filter("account = %@", tableAccount!.account) try! realm.write { for result in results { result.lock = false; } } } //MARK: - //MARK: Table External Sites func addExternalSites(_ externalSites: OCExternalSites) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() try! realm.write { let addExternalSite = tableExternalSites() addExternalSite.account = tableAccount!.account addExternalSite.idExternalSite = externalSites.idExternalSite addExternalSite.icon = externalSites.icon addExternalSite.lang = externalSites.lang addExternalSite.name = externalSites.name addExternalSite.url = externalSites.url addExternalSite.type = externalSites.type realm.add(addExternalSite) } } func deleteExternalSites() { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableExternalSites.self).filter("account = %@", tableAccount!.account) try! realm.write { realm.delete(results) } } func getAllExternalSites(predicate: NSPredicate) -> [tableExternalSites] { let realm = try! Realm() let results = realm.objects(tableExternalSites.self).filter(predicate).sorted(byKeyPath: "idExternalSite", ascending: true) return Array(results) } //MARK: - //MARK: Table GPS func addGeocoderLocation(_ location: String, placemarkAdministrativeArea: String, placemarkCountry: String, placemarkLocality: String, placemarkPostalCode: String, placemarkThoroughfare: String, latitude: String, longitude: String) { let realm = try! Realm() // Verify if exists let result = realm.objects(tableGPS.self).filter("latitude = %@ AND longitude = %@", latitude, longitude).first if result != nil { return } try! realm.write { // Add new GPS let addGPS = tableGPS() addGPS.latitude = latitude addGPS.location = location addGPS.longitude = longitude addGPS.placemarkAdministrativeArea = placemarkAdministrativeArea addGPS.placemarkCountry = placemarkCountry addGPS.placemarkLocality = placemarkLocality addGPS.placemarkPostalCode = placemarkPostalCode addGPS.placemarkThoroughfare = placemarkThoroughfare realm.add(addGPS) } } func getLocationFromGeoLatitude(_ latitude: String, longitude: String) -> String? { let realm = try! Realm() let result = realm.objects(tableGPS.self).filter("latitude = %@ AND longitude = %@", latitude, longitude).first if result == nil { return nil } else { return result!.location } } //MARK: - //MARK: Table LocalFile func addLocalFile(metadata: tableMetadata) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() try! realm.write { let addLocaFile = tableLocalFile() addLocaFile.account = tableAccount!.account addLocaFile.date = metadata.date addLocaFile.etag = metadata.etag addLocaFile.exifDate = NSDate() addLocaFile.exifLatitude = "-1" addLocaFile.exifLongitude = "-1" addLocaFile.fileID = metadata.fileID addLocaFile.fileName = metadata.fileName addLocaFile.fileNamePrint = metadata.fileNamePrint addLocaFile.size = metadata.size realm.add(addLocaFile, update: true) } } func deleteLocalFile(predicate: NSPredicate) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableLocalFile.self).filter(predicate) try! realm.write { realm.delete(results) } } func setLocalFile(fileID: String, date: NSDate?, exifDate: NSDate?, exifLatitude: String?, exifLongitude: String?, fileName: String?, fileNamePrint: String?) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableLocalFile.self).filter("fileID = %@", fileID).first if result != nil { try! realm.write { if date != nil { result?.date = date! } if exifDate != nil { result?.exifDate = exifDate! } if exifLatitude != nil { result?.exifLatitude = exifLatitude! } if exifLongitude != nil { result?.exifLongitude = exifLongitude! } if fileName != nil { result?.fileName = fileName! } if fileNamePrint != nil { result?.fileNamePrint = fileNamePrint! } } } } func getTableLocalFile(predicate: NSPredicate) -> tableLocalFile? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() return realm.objects(tableLocalFile.self).filter(predicate).first } //MARK: - //MARK: Table Metadata func addMetadata(_ metadata: tableMetadata, activeUrl: String, serverUrl: String) -> tableMetadata? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let autoUploadFileName = self.getAccountAutoUploadFileName() let autoUploadDirectory = self.getAccountAutoUploadDirectory(activeUrl) let realm = try! Realm() realm.beginWrite() if (metadata.realm == nil) { let metadataWithIcon = CCUtility.insertTypeFileIconName(metadata, serverUrl: serverUrl, autoUploadFileName: autoUploadFileName, autoUploadDirectory: autoUploadDirectory) realm.add(metadataWithIcon!, update: true) } else { realm.add(metadata, update: true) } try! realm.commitWrite() if metadata.isInvalidated { return nil } self.setDateReadDirectory(directoryID: metadata.directoryID) if metadata.isInvalidated { return nil } else { return tableMetadata.init(value: metadata) } } func addMetadatas(_ metadatas: [tableMetadata], activeUrl: String, serverUrl: String) -> [tableMetadata] { let autoUploadFileName = self.getAccountAutoUploadFileName() let autoUploadDirectory = self.getAccountAutoUploadDirectory(activeUrl) var arrayMetadatas = [tableMetadata]() let realm = try! Realm() try! realm.write { for metadata in metadatas { if metadata.realm == nil { let metadataWithIcon = CCUtility.insertTypeFileIconName(metadata, serverUrl: serverUrl, autoUploadFileName: autoUploadFileName, autoUploadDirectory: autoUploadDirectory) realm.add(metadataWithIcon!, update: true) } else { realm.add(metadata, update: true) } arrayMetadatas.append(tableMetadata.init(value: metadata)) } } let directoryID = self.getDirectoryID(serverUrl) self.setDateReadDirectory(directoryID: directoryID) return arrayMetadatas } func deleteMetadata(predicate: NSPredicate, clearDateReadDirectoryID: String?) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableMetadata.self).filter(predicate) if clearDateReadDirectoryID == nil { for result in results { self.setDateReadDirectory(directoryID: result.directoryID) } } else { self.setDateReadDirectory(directoryID: clearDateReadDirectoryID!) } try! realm.write { realm.delete(results) } } func moveMetadata(fileName: String, directoryID: String, directoryIDTo: String) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableMetadata.self).filter("account = %@ AND fileName = %@ AND directoryID = %@", tableAccount!.account, fileName, directoryID) try! realm.write { for result in results { result.directoryID = directoryIDTo } } self.setDateReadDirectory(directoryID: directoryID) self.setDateReadDirectory(directoryID: directoryIDTo) } func updateMetadata(_ metadata: tableMetadata, activeUrl: String) -> tableMetadata { let autoUploadFileName = self.getAccountAutoUploadFileName() let autoUploadDirectory = self.getAccountAutoUploadDirectory(activeUrl) let serverUrl = self.getServerUrl(metadata.directoryID) let metadataWithIcon = CCUtility.insertTypeFileIconName(metadata, serverUrl: serverUrl, autoUploadFileName: autoUploadFileName, autoUploadDirectory: autoUploadDirectory) let realm = try! Realm() try! realm.write { realm.add(metadataWithIcon!, update: true) } self.setDateReadDirectory(directoryID: metadata.directoryID) return tableMetadata.init(value: metadata) } func setMetadataSession(_ session: String?, sessionError: String?, sessionSelector: String?, sessionSelectorPost: String?, sessionTaskIdentifier: Int, sessionTaskIdentifierPlist: Int, predicate: NSPredicate) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableMetadata.self).filter(predicate).first if result != nil { try! realm.write { if session != nil { result?.session = session! } if sessionError != nil { result?.sessionError = sessionError! } if sessionSelector != nil { result?.sessionSelector = sessionSelector! } if sessionSelectorPost != nil { result?.sessionSelectorPost = sessionSelectorPost! } if sessionTaskIdentifier != Int(k_taskIdentifierNULL) { result?.sessionTaskIdentifier = sessionTaskIdentifier } if sessionTaskIdentifierPlist != Int(k_taskIdentifierNULL) { result?.sessionTaskIdentifierPlist = sessionTaskIdentifierPlist } } } // Update Date Read Directory if result != nil { self.setDateReadDirectory(directoryID: (result?.directoryID)!) } } func setMetadataFavorite(fileID: String, favorite: Bool) { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let result = realm.objects(tableMetadata.self).filter("account = %@ AND fileID = %@", tableAccount!.account, fileID).first if result != nil { try! realm.write { result?.favorite = favorite } self.setDateReadDirectory(directoryID: result!.directoryID) } } func getMetadata(predicate: NSPredicate) -> tableMetadata? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let result = realm.objects(tableMetadata.self).filter(predicate).first if result != nil { return tableMetadata.init(value: result!) } else { return nil } } func getMetadatas(predicate: NSPredicate, sorted: String?, ascending: Bool) -> [tableMetadata]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let results : Results if sorted == nil { results = realm.objects(tableMetadata.self).filter(predicate) } else { results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted!, ascending: ascending) } if (results.count > 0) { return Array(convertMetadataToUnmanagedMetadata(results)) } else { return nil } } func getMetadataAtIndex(predicate: NSPredicate, sorted: String?, ascending: Bool, index: Int) -> tableMetadata? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted!, ascending: ascending) if (results.count > 0 && results.count > index) { return tableMetadata.init(value: results[index]) } else { return nil } } func getMetadataFromFileName(_ fileName: String, directoryID: String) -> tableMetadata? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let result = realm.objects(tableMetadata.self).filter("account = %@ AND directoryID = %@ AND (fileName = %@ OR fileNameData = %@)", tableAccount!.account, directoryID, fileName, fileName).first if result != nil { return tableMetadata.init(value: result!) } else { return nil } } func getTableMetadataDownload() -> [tableMetadata]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let predicate = NSPredicate(format: "account = %@ AND (session = %@ OR session = %@) AND (sessionTaskIdentifier != %i OR sessionTaskIdentifierPlist != %i)", tableAccount!.account, k_download_session, k_download_session_foreground, k_taskIdentifierDone, k_taskIdentifierDone) return self.getMetadatas(predicate: predicate, sorted: nil, ascending: false) } func getTableMetadataDownloadWWan() -> [tableMetadata]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let predicate = NSPredicate(format: "account = %@ AND session = %@ AND (sessionTaskIdentifier != %i OR sessionTaskIdentifierPlist != %i)", tableAccount!.account, k_download_session_wwan, k_taskIdentifierDone, k_taskIdentifierDone) return self.getMetadatas(predicate: predicate, sorted: nil, ascending: false) } func getTableMetadataUpload() -> [tableMetadata]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let predicate = NSPredicate(format: "account = %@ AND (session = %@ OR session = %@) AND (sessionTaskIdentifier != %i OR sessionTaskIdentifierPlist != %i)", tableAccount!.account, k_upload_session, k_upload_session_foreground, k_taskIdentifierDone, k_taskIdentifierDone) return self.getMetadatas(predicate: predicate, sorted: nil, ascending: false) } func getTableMetadataUploadWWan() -> [tableMetadata]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let predicate = NSPredicate(format: "account = %@ AND session = %@ AND (sessionTaskIdentifier != %i OR sessionTaskIdentifierPlist != %i)", tableAccount!.account, k_upload_session_wwan, k_taskIdentifierDone, k_taskIdentifierDone) return self.getMetadatas(predicate: predicate, sorted: nil, ascending: false) } func getTableMetadatasPhotos(serverUrl: String) -> [tableMetadata]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let sorted = CCUtility.getOrderSettings() let ascending = CCUtility.getAscendingSettings() var recordsPhotosAutoUpload = [tableMetadata]() let directories = self.getTablesDirectory(predicate: NSPredicate(format: "account = %@ AND serverUrl BEGINSWITH %@", tableAccount!.account, serverUrl), sorted: "serverUrl", ascending: true) if directories != nil { for directory in directories! { let predicate = NSPredicate(format: "account = %@ AND directoryID = %@ AND session = '' AND type = 'file' AND (typeFile = %@ OR typeFile = %@)", tableAccount!.account, directory.directoryID, k_metadataTypeFile_image, k_metadataTypeFile_video) let metadatas = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted!, ascending: ascending) if metadatas.count > 0 { for metadata in metadatas { recordsPhotosAutoUpload.append(tableMetadata.init(value: metadata)) } } } } if recordsPhotosAutoUpload.count > 0 { return Array(recordsPhotosAutoUpload) } else { return nil } } func convertMetadataToUnmanagedMetadata(_ metadatas: Results) -> [tableMetadata] { var unmanageMetadatas = [tableMetadata]() for metadata in metadatas { unmanageMetadatas.append(tableMetadata.init(value: metadata)) } return unmanageMetadatas } //MARK: - //MARK: Table Share func addShareLink(_ share: String, fileName: String, serverUrl: String) -> [String:String]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() // Verify if exists let result = realm.objects(tableShare.self).filter("account = %@ AND fileName = %@ AND serverUrl = %@", tableAccount!.account, fileName, serverUrl).first if result != nil { try! realm.write { result?.shareLink = share } } else { // Add new record try! realm.write { let addShare = tableShare() addShare.account = tableAccount!.account addShare.fileName = fileName addShare.serverUrl = serverUrl addShare.shareLink = share realm.add(addShare) } } return ["\(serverUrl)\(fileName)" : share] } func addShareUserAndGroup(_ share: String, fileName: String, serverUrl: String) -> [String:String]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() // Verify if exists let result = realm.objects(tableShare.self).filter("account = %@ AND fileName = %@ AND serverUrl = %@", tableAccount!.account, fileName, serverUrl).first if result != nil { try! realm.write { result?.shareUserAndGroup = share } } else { // Add new record try! realm.write { let addShare = tableShare() addShare.account = tableAccount!.account addShare.fileName = fileName addShare.serverUrl = serverUrl addShare.shareUserAndGroup = share realm.add(addShare) } } return ["\(serverUrl)\(fileName)" : share] } func unShare(_ share: String, fileName: String, serverUrl: String, sharesLink: [String:String], sharesUserAndGroup: [String:String]) -> [Any]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } var sharesLink = sharesLink var sharesUserAndGroup = sharesUserAndGroup let realm = try! Realm() let results = realm.objects(tableShare.self).filter("account = %@ AND (shareLink CONTAINS %@ OR shareUserAndGroup CONTAINS %@)", tableAccount!.account, share, share) if (results.count > 0) { let result = results[0] realm.beginWrite() if (result.shareLink.contains(share)) { result.shareLink = "" } if (result.shareUserAndGroup.contains(share)) { var shares : [String] = result.shareUserAndGroup.components(separatedBy: ",") if let index = shares.index(of:share) { shares.remove(at: index) } result.shareUserAndGroup = shares.joined(separator: ",") } if (result.shareLink.characters.count > 0) { sharesLink.updateValue(result.shareLink, forKey:"\(serverUrl)\(fileName)") } else { sharesLink.removeValue(forKey: "\(serverUrl)\(fileName)") } if (result.shareUserAndGroup.characters.count > 0) { sharesUserAndGroup.updateValue(result.shareUserAndGroup, forKey:"\(serverUrl)\(fileName)") } else { sharesUserAndGroup.removeValue(forKey: "\(serverUrl)\(fileName)") } if (result.shareLink.characters.count == 0 && result.shareUserAndGroup.characters.count == 0) { realm.delete(result) } try! realm.commitWrite() } return [sharesLink, sharesUserAndGroup] } func removeShareActiveAccount() { let tableAccount = self.getAccountActive() if tableAccount == nil { return } let realm = try! Realm() let results = realm.objects(tableShare.self).filter("account = %@", tableAccount!.account) try! realm.write { realm.delete(results) } } func updateShare(_ items: [String:OCSharedDto], activeUrl: String) -> [Any]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } var sharesLink = [String:String]() var sharesUserAndGroup = [String:String]() self.removeShareActiveAccount() var itemsLink = [OCSharedDto]() var itemsUsersAndGroups = [OCSharedDto]() for (_, itemOCSharedDto) in items { if (itemOCSharedDto.shareType == Int(shareTypeLink.rawValue)) { itemsLink.append(itemOCSharedDto) } if (itemOCSharedDto.shareWith.characters.count > 0 && (itemOCSharedDto.shareType == Int(shareTypeUser.rawValue) || itemOCSharedDto.shareType == Int(shareTypeGroup.rawValue) || itemOCSharedDto.shareType == Int(shareTypeRemote.rawValue) )) { itemsUsersAndGroups.append(itemOCSharedDto) } } // Manage sharesLink for itemOCSharedDto in itemsLink { let fullPath = CCUtility.getHomeServerUrlActiveUrl(activeUrl) + "\(itemOCSharedDto.path!)" let fileName = NSString(string: fullPath).lastPathComponent var serverUrl = NSString(string: fullPath).substring(to: (fullPath.characters.count - fileName.characters.count - 1)) if serverUrl.hasSuffix("/") { serverUrl = NSString(string: serverUrl).substring(to: (serverUrl.characters.count - 1)) } if itemOCSharedDto.idRemoteShared > 0 { let sharesLinkReturn = self.addShareLink("\(itemOCSharedDto.idRemoteShared)", fileName: fileName, serverUrl: serverUrl) if sharesLinkReturn != nil { for (key,value) in sharesLinkReturn! { sharesLink.updateValue(value, forKey:key) } } } } // Manage sharesUserAndGroup var paths = [String:[String]]() for itemOCSharedDto in itemsUsersAndGroups { if paths[itemOCSharedDto.path] != nil { var share : [String] = paths[itemOCSharedDto.path]! share.append("\(itemOCSharedDto.idRemoteShared)") paths[itemOCSharedDto.path] = share } else { paths[itemOCSharedDto.path] = ["\(itemOCSharedDto.idRemoteShared)"] } } for (path, idsRemoteSharedArray) in paths { let idsRemoteShared = idsRemoteSharedArray.joined(separator: ",") print("[LOG] share \(String(describing: idsRemoteShared))") let fullPath = CCUtility.getHomeServerUrlActiveUrl(activeUrl) + "\(path)" let fileName = NSString(string: fullPath).lastPathComponent var serverUrl = NSString(string: fullPath).substring(to: (fullPath.characters.count - fileName.characters.count - 1)) if serverUrl.hasSuffix("/") { serverUrl = NSString(string: serverUrl).substring(to: (serverUrl.characters.count - 1)) } let sharesUserAndGroupReturn = self.addShareUserAndGroup(idsRemoteShared, fileName: fileName, serverUrl: serverUrl) if sharesUserAndGroupReturn != nil { for (key,value) in sharesUserAndGroupReturn! { sharesUserAndGroup.updateValue(value, forKey:key) } } } return [sharesLink, sharesUserAndGroup] } func getShares() -> [Any]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } var sharesLink = [String:String]() var sharesUserAndGroup = [String:String]() let realm = try! Realm() let results = realm.objects(tableShare.self).filter("account = %@", tableAccount!.account) for resultShare in results { if (resultShare.shareLink.characters.count > 0) { sharesLink = [resultShare.shareLink: "\(resultShare.serverUrl)\(resultShare.fileName)"] } if (resultShare.shareUserAndGroup.characters.count > 0) { sharesUserAndGroup = [resultShare.shareUserAndGroup: "\(resultShare.serverUrl)\(resultShare.fileName)"] } } return [sharesLink, sharesUserAndGroup] } func getTableShares() -> [tableShare]? { let tableAccount = self.getAccountActive() if tableAccount == nil { return nil } let realm = try! Realm() let results = realm.objects(tableShare.self).filter("account = %@", tableAccount!.account).sorted(byKeyPath: "fileName", ascending: true) return Array(results) } //MARK: - //MARK: Migrate func func addTableAccountFromCoredata(_ table: TableAccount) { let realm = try! Realm() let results = realm.objects(tableAccount.self).filter("account = %@", table.account!) if (results.count == 0) { try! realm.write { let addAccount = tableAccount() addAccount.account = table.account! if table.active == 1 { addAccount.active = true } if table.cameraUpload == 1 { addAccount.autoUpload = true } if table.cameraUploadBackground == 1 { addAccount.autoUploadBackground = true } if table.cameraUploadCreateSubfolder == 1 { addAccount.autoUploadCreateSubfolder = true } if table.cameraUploadDatePhoto != nil { addAccount.autoUploadDatePhoto = table.cameraUploadDatePhoto! as NSDate } if table.cameraUploadDateVideo != nil { addAccount.autoUploadDateVideo = table.cameraUploadDateVideo! as NSDate } if table.cameraUploadFolderName != nil { addAccount.autoUploadFileName = table.cameraUploadFolderName! } if table.cameraUploadFolderPath != nil { addAccount.autoUploadDirectory = table.cameraUploadFolderPath! } if table.cameraUploadFull == 1 { addAccount.autoUploadFull = true } if table.cameraUploadPhoto == 1 { addAccount.autoUploadPhoto = true } if table.cameraUploadVideo == 1 { addAccount.autoUploadVideo = true } if table.cameraUploadWWAnPhoto == 1 { addAccount.autoUploadWWAnPhoto = true } if table.cameraUploadWWAnVideo == 1 { addAccount.autoUploadWWAnVideo = true } addAccount.password = table.password! addAccount.url = table.url! addAccount.user = table.user! realm.add(addAccount) } } } func addTableDirectoryFromCoredata(_ table: TableDirectory) { let realm = try! Realm() let results = realm.objects(tableDirectory.self).filter("directoryID = %@", table.directoryID!) if (results.count == 0) { try! realm.write { let addDirectory = tableDirectory() addDirectory.account = table.account! addDirectory.directoryID = table.directoryID! addDirectory.etag = table.rev! if table.favorite == 1 { addDirectory.favorite = true } addDirectory.fileID = table.fileID! if table.lock == 1 { addDirectory.lock = true } addDirectory.permissions = table.permissions! addDirectory.serverUrl = table.serverUrl! realm.add(addDirectory) } } } func addTableLocalFileFromCoredata(_ table: TableLocalFile) { let realm = try! Realm() let results = realm.objects(tableLocalFile.self).filter("fileID = %@", table.fileID!) if (results.count == 0) { try! realm.write { let addLocalFile = tableLocalFile() addLocalFile.account = table.account! addLocalFile.date = table.date! as NSDate addLocalFile.etag = table.rev! if table.exifDate != nil { addLocalFile.exifDate = table.exifDate! as NSDate } addLocalFile.exifLatitude = table.exifLatitude! addLocalFile.exifLongitude = table.exifLongitude! if table.favorite == 1 { addLocalFile.favorite = true } addLocalFile.fileID = table.fileID! addLocalFile.fileName = table.fileName! addLocalFile.fileNamePrint = table.fileNamePrint! addLocalFile.size = table.size as! Double realm.add(addLocalFile) } } } //MARK: - }