NCManageDatabase.swift 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784
  1. //
  2. // NCManageDatabase.swift
  3. // Nextcloud
  4. //
  5. // Created by Marino Faggiana on 06/05/17.
  6. // Copyright © 2017 Marino Faggiana. All rights reserved.
  7. //
  8. // Author Marino Faggiana <marino.faggiana@nextcloud.com>
  9. // Author Henrik Storch <henrik.storch@nextcloud.com>
  10. //
  11. // This program is free software: you can redistribute it and/or modify
  12. // it under the terms of the GNU General Public License as published by
  13. // the Free Software Foundation, either version 3 of the License, or
  14. // (at your option) any later version.
  15. //
  16. // This program is distributed in the hope that it will be useful,
  17. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  18. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  19. // GNU General Public License for more details.
  20. //
  21. // You should have received a copy of the GNU General Public License
  22. // along with this program. If not, see <http://www.gnu.org/licenses/>.
  23. //
  24. import UIKit
  25. import RealmSwift
  26. import NextcloudKit
  27. import CoreMedia
  28. import Photos
  29. class NCManageDatabase: NSObject {
  30. @objc static let shared: NCManageDatabase = {
  31. let instance = NCManageDatabase()
  32. return instance
  33. }()
  34. let serialQueue = DispatchQueue(label: "realmSerialQueue")
  35. override init() {
  36. let dirGroup = FileManager.default.containerURL(forSecurityApplicationGroupIdentifier: NCBrandOptions.shared.capabilitiesGroups)
  37. let databaseFileUrlPath = dirGroup?.appendingPathComponent(NCGlobal.shared.appDatabaseNextcloud + "/" + databaseName)
  38. let bundleUrl: URL = Bundle.main.bundleURL
  39. let bundlePathExtension: String = bundleUrl.pathExtension
  40. let isAppex: Bool = bundlePathExtension == "appex"
  41. if let databaseFilePath = databaseFileUrlPath?.path {
  42. if FileManager.default.fileExists(atPath: databaseFilePath) {
  43. NextcloudKit.shared.nkCommonInstance.writeLog("DATABASE FOUND in " + databaseFilePath)
  44. } else {
  45. NextcloudKit.shared.nkCommonInstance.writeLog("DATABASE NOT FOUND in " + databaseFilePath)
  46. }
  47. }
  48. // Disable file protection for directory DB
  49. // https://docs.mongodb.com/realm/sdk/ios/examples/configure-and-open-a-realm/#std-label-ios-open-a-local-realm
  50. if let folderPathURL = dirGroup?.appendingPathComponent(NCGlobal.shared.appDatabaseNextcloud) {
  51. let folderPath = folderPathURL.path
  52. do {
  53. try FileManager.default.setAttributes([FileAttributeKey.protectionKey: FileProtectionType.completeUntilFirstUserAuthentication], ofItemAtPath: folderPath)
  54. } catch {
  55. print("Dangerous error")
  56. }
  57. }
  58. if isAppex {
  59. // App Extension config
  60. let config = Realm.Configuration(
  61. fileURL: dirGroup?.appendingPathComponent(NCGlobal.shared.appDatabaseNextcloud + "/" + databaseName),
  62. schemaVersion: databaseSchemaVersion,
  63. objectTypes: [tableMetadata.self,
  64. tableLocalFile.self,
  65. tableDirectory.self,
  66. tableTag.self,
  67. tableAccount.self,
  68. tableCapabilities.self,
  69. tablePhotoLibrary.self,
  70. tableE2eEncryption.self,
  71. tableE2eEncryptionLock.self,
  72. tableE2eMetadata12.self,
  73. tableE2eMetadata.self,
  74. tableE2eUsers.self,
  75. tableE2eCounter.self,
  76. tableE2eUsersFiledrop.self,
  77. tableShare.self,
  78. tableChunk.self,
  79. tableAvatar.self,
  80. tableDashboardWidget.self,
  81. tableDashboardWidgetButton.self,
  82. NCDBLayoutForView.self,
  83. tableProblems.self]
  84. )
  85. Realm.Configuration.defaultConfiguration = config
  86. } else {
  87. // App config
  88. let configCompact = Realm.Configuration(
  89. fileURL: databaseFileUrlPath,
  90. schemaVersion: databaseSchemaVersion,
  91. migrationBlock: { migration, oldSchemaVersion in
  92. if oldSchemaVersion < 255 {
  93. migration.deleteData(forType: tableActivity.className())
  94. migration.deleteData(forType: tableActivityLatestId.className())
  95. migration.deleteData(forType: tableActivityPreview.className())
  96. migration.deleteData(forType: tableActivitySubjectRich.className())
  97. migration.deleteData(forType: tableDirectory.className())
  98. migration.deleteData(forType: tableMetadata.className())
  99. }
  100. if oldSchemaVersion < 292 {
  101. migration.deleteData(forType: tableVideo.className())
  102. }
  103. if oldSchemaVersion < 319 {
  104. migration.deleteData(forType: tableChunk.className())
  105. migration.deleteData(forType: tableMetadata.className())
  106. migration.deleteData(forType: tableDirectory.className())
  107. migration.deleteData(forType: tableE2eEncryptionLock.className())
  108. migration.deleteData(forType: tableGPS.className())
  109. }
  110. }, shouldCompactOnLaunch: { totalBytes, usedBytes in
  111. // totalBytes refers to the size of the file on disk in bytes (data + free space)
  112. // usedBytes refers to the number of bytes used by data in the file
  113. // Compact if the file is over 100MB in size and less than 50% 'used'
  114. let oneHundredMB = 100 * 1024 * 1024
  115. return (totalBytes > oneHundredMB) && (Double(usedBytes) / Double(totalBytes)) < 0.5
  116. }
  117. )
  118. do {
  119. _ = try Realm(configuration: configCompact)
  120. } catch let error {
  121. if let databaseFileUrlPath = databaseFileUrlPath {
  122. do {
  123. #if !EXTENSION
  124. let nkError = NKError(errorCode: NCGlobal.shared.errorInternalError, errorDescription: error.localizedDescription)
  125. NCContentPresenter.shared.showError(error: nkError, priority: .max)
  126. #endif
  127. NextcloudKit.shared.nkCommonInstance.writeLog("DATABASE ERROR: \(error.localizedDescription)")
  128. try FileManager.default.removeItem(at: databaseFileUrlPath)
  129. } catch {}
  130. }
  131. }
  132. let config = Realm.Configuration(
  133. fileURL: dirGroup?.appendingPathComponent(NCGlobal.shared.appDatabaseNextcloud + "/" + databaseName),
  134. schemaVersion: databaseSchemaVersion
  135. )
  136. Realm.Configuration.defaultConfiguration = config
  137. }
  138. // Verify Database, if corrupt remove it
  139. do {
  140. _ = try Realm()
  141. } catch let error {
  142. if let databaseFileUrlPath = databaseFileUrlPath {
  143. do {
  144. #if !EXTENSION
  145. let nkError = NKError(errorCode: NCGlobal.shared.errorInternalError, errorDescription: error.localizedDescription)
  146. NCContentPresenter.shared.showError(error: nkError, priority: .max)
  147. #endif
  148. NextcloudKit.shared.nkCommonInstance.writeLog("DATABASE ERROR: \(error.localizedDescription)")
  149. try FileManager.default.removeItem(at: databaseFileUrlPath)
  150. } catch { }
  151. }
  152. }
  153. // Open Real
  154. do {
  155. _ = try Realm()
  156. } catch let error as NSError {
  157. NextcloudKit.shared.nkCommonInstance.writeLog("Could not open database: \(error)")
  158. }
  159. }
  160. // MARK: -
  161. // MARK: Utility Database
  162. @objc func clearTable(_ table: Object.Type, account: String? = nil) {
  163. do {
  164. let realm = try Realm()
  165. try realm.write {
  166. var results: Results<Object>
  167. if let account = account {
  168. results = realm.objects(table).filter("account == %@", account)
  169. } else {
  170. results = realm.objects(table)
  171. }
  172. realm.delete(results)
  173. }
  174. } catch let error {
  175. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  176. }
  177. }
  178. @objc func clearDatabase(account: String?, removeAccount: Bool) {
  179. self.clearTable(tableActivity.self, account: account)
  180. self.clearTable(tableActivityLatestId.self, account: account)
  181. self.clearTable(tableActivityPreview.self, account: account)
  182. self.clearTable(tableActivitySubjectRich.self, account: account)
  183. self.clearTable(tableAvatar.self)
  184. self.clearTable(tableCapabilities.self, account: account)
  185. self.clearTable(tableChunk.self, account: account)
  186. self.clearTable(tableComments.self, account: account)
  187. self.clearTable(tableDashboardWidget.self, account: account)
  188. self.clearTable(tableDashboardWidgetButton.self, account: account)
  189. self.clearTable(tableDirectEditingCreators.self, account: account)
  190. self.clearTable(tableDirectEditingEditors.self, account: account)
  191. self.clearTable(tableDirectory.self, account: account)
  192. self.clearTable(tableExternalSites.self, account: account)
  193. self.clearTable(tableGPS.self, account: nil)
  194. self.clearTable(TableGroupfolders.self, account: account)
  195. self.clearTable(TableGroupfoldersGroups.self, account: account)
  196. self.clearTable(NCDBLayoutForView.self, account: account)
  197. self.clearTable(tableLocalFile.self, account: account)
  198. self.clearTable(tableMetadata.self, account: account)
  199. self.clearTable(tablePhotoLibrary.self, account: account)
  200. self.clearTable(tableProblems.self, account: account)
  201. self.clearTable(tableShare.self, account: account)
  202. self.clearTable(tableTag.self, account: account)
  203. self.clearTable(tableTip.self)
  204. self.clearTable(tableTrash.self, account: account)
  205. self.clearTable(tableUserStatus.self, account: account)
  206. self.clearTable(tableVideo.self, account: account)
  207. self.clearTablesE2EE(account: account)
  208. if removeAccount {
  209. self.clearTable(tableAccount.self, account: account)
  210. }
  211. }
  212. func clearTablesE2EE(account: String?) {
  213. self.clearTable(tableE2eEncryption.self, account: account)
  214. self.clearTable(tableE2eEncryptionLock.self, account: account)
  215. self.clearTable(tableE2eMetadata12.self, account: account)
  216. self.clearTable(tableE2eMetadata.self, account: account)
  217. self.clearTable(tableE2eUsers.self, account: account)
  218. self.clearTable(tableE2eCounter.self, account: account)
  219. self.clearTable(tableE2eUsersFiledrop.self, account: account)
  220. }
  221. @objc func removeDB() {
  222. let realmURL = Realm.Configuration.defaultConfiguration.fileURL!
  223. let realmURLs = [
  224. realmURL,
  225. realmURL.appendingPathExtension("lock"),
  226. realmURL.appendingPathExtension("note"),
  227. realmURL.appendingPathExtension("management")
  228. ]
  229. for URL in realmURLs {
  230. do {
  231. try FileManager.default.removeItem(at: URL)
  232. } catch let error {
  233. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  234. }
  235. }
  236. }
  237. func getThreadConfined(_ object: Object) -> Any {
  238. return ThreadSafeReference(to: object)
  239. }
  240. func putThreadConfined(_ tableRef: ThreadSafeReference<Object>) -> Object? {
  241. do {
  242. let realm = try Realm()
  243. return realm.resolve(tableRef)
  244. } catch let error as NSError {
  245. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  246. }
  247. return nil
  248. }
  249. func isTableInvalidated(_ object: Object) -> Bool {
  250. return object.isInvalidated
  251. }
  252. // MARK: -
  253. // MARK: Table Direct Editing
  254. func addDirectEditing(account: String, editors: [NKEditorDetailsEditors], creators: [NKEditorDetailsCreators]) {
  255. do {
  256. let realm = try Realm()
  257. try realm.write {
  258. let resultsCreators = realm.objects(tableDirectEditingCreators.self).filter("account == %@", account)
  259. realm.delete(resultsCreators)
  260. let resultsEditors = realm.objects(tableDirectEditingEditors.self).filter("account == %@", account)
  261. realm.delete(resultsEditors)
  262. for creator in creators {
  263. let addObject = tableDirectEditingCreators()
  264. addObject.account = account
  265. addObject.editor = creator.editor
  266. addObject.ext = creator.ext
  267. addObject.identifier = creator.identifier
  268. addObject.mimetype = creator.mimetype
  269. addObject.name = creator.name
  270. addObject.templates = creator.templates
  271. realm.add(addObject)
  272. }
  273. for editor in editors {
  274. let addObject = tableDirectEditingEditors()
  275. addObject.account = account
  276. for mimeType in editor.mimetypes {
  277. addObject.mimetypes.append(mimeType)
  278. }
  279. addObject.name = editor.name
  280. if editor.name.lowercased() == NCGlobal.shared.editorOnlyoffice {
  281. addObject.editor = NCGlobal.shared.editorOnlyoffice
  282. } else {
  283. addObject.editor = NCGlobal.shared.editorText
  284. }
  285. for mimeType in editor.optionalMimetypes {
  286. addObject.optionalMimetypes.append(mimeType)
  287. }
  288. addObject.secure = editor.secure
  289. realm.add(addObject)
  290. }
  291. }
  292. } catch let error {
  293. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  294. }
  295. }
  296. func getDirectEditingCreators(account: String) -> [tableDirectEditingCreators]? {
  297. do {
  298. let realm = try Realm()
  299. realm.refresh()
  300. let results = realm.objects(tableDirectEditingCreators.self).filter("account == %@", account)
  301. if results.isEmpty {
  302. return nil
  303. } else {
  304. return Array(results.map { tableDirectEditingCreators.init(value: $0) })
  305. }
  306. } catch let error as NSError {
  307. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  308. }
  309. return nil
  310. }
  311. func getDirectEditingCreators(predicate: NSPredicate) -> [tableDirectEditingCreators]? {
  312. do {
  313. let realm = try Realm()
  314. realm.refresh()
  315. let results = realm.objects(tableDirectEditingCreators.self).filter(predicate)
  316. if results.isEmpty {
  317. return nil
  318. } else {
  319. return Array(results.map { tableDirectEditingCreators.init(value: $0) })
  320. }
  321. } catch let error as NSError {
  322. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  323. }
  324. return nil
  325. }
  326. func getDirectEditingEditors(account: String) -> [tableDirectEditingEditors]? {
  327. do {
  328. let realm = try Realm()
  329. realm.refresh()
  330. let results = realm.objects(tableDirectEditingEditors.self).filter("account == %@", account)
  331. if results.isEmpty {
  332. return nil
  333. } else {
  334. return Array(results.map { tableDirectEditingEditors.init(value: $0) })
  335. }
  336. } catch let error as NSError {
  337. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  338. }
  339. return nil
  340. }
  341. // MARK: -
  342. // MARK: Table External Sites
  343. func addExternalSites(_ externalSite: NKExternalSite, account: String) {
  344. do {
  345. let realm = try Realm()
  346. try realm.write {
  347. let addObject = tableExternalSites()
  348. addObject.account = account
  349. addObject.idExternalSite = externalSite.idExternalSite
  350. addObject.icon = externalSite.icon
  351. addObject.lang = externalSite.lang
  352. addObject.name = externalSite.name
  353. addObject.url = externalSite.url
  354. addObject.type = externalSite.type
  355. realm.add(addObject)
  356. }
  357. } catch let error {
  358. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  359. }
  360. }
  361. func deleteExternalSites(account: String) {
  362. do {
  363. let realm = try Realm()
  364. try realm.write {
  365. let results = realm.objects(tableExternalSites.self).filter("account == %@", account)
  366. realm.delete(results)
  367. }
  368. } catch let error {
  369. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  370. }
  371. }
  372. func getAllExternalSites(account: String) -> [tableExternalSites]? {
  373. do {
  374. let realm = try Realm()
  375. realm.refresh()
  376. let results = realm.objects(tableExternalSites.self).filter("account == %@", account).sorted(byKeyPath: "idExternalSite", ascending: true)
  377. if results.isEmpty {
  378. return nil
  379. } else {
  380. return Array(results.map { tableExternalSites.init(value: $0) })
  381. }
  382. } catch let error as NSError {
  383. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  384. }
  385. return nil
  386. }
  387. // MARK: -
  388. // MARK: Table GPS
  389. @objc func addGeocoderLocation(_ location: String, latitude: Double, longitude: Double) {
  390. do {
  391. let realm = try Realm()
  392. realm.refresh()
  393. guard realm.objects(tableGPS.self).filter("latitude == %@ AND longitude == %@", latitude, longitude).first == nil else { return }
  394. try realm.write {
  395. let addObject = tableGPS()
  396. addObject.latitude = latitude
  397. addObject.location = location
  398. addObject.longitude = longitude
  399. realm.add(addObject)
  400. }
  401. } catch let error as NSError {
  402. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  403. }
  404. }
  405. @objc func getLocationFromLatAndLong(latitude: Double, longitude: Double) -> String? {
  406. do {
  407. let realm = try Realm()
  408. realm.refresh()
  409. let result = realm.objects(tableGPS.self).filter("latitude == %@ AND longitude == %@", latitude, longitude).first
  410. return result?.location
  411. } catch let error as NSError {
  412. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  413. }
  414. return nil
  415. }
  416. // MARK: Table Photo Library
  417. @discardableResult
  418. func addPhotoLibrary(_ assets: [PHAsset], account: String) -> Bool {
  419. do {
  420. let realm = try Realm()
  421. try realm.write {
  422. for asset in assets {
  423. var creationDateString = ""
  424. let addObject = tablePhotoLibrary()
  425. addObject.account = account
  426. addObject.assetLocalIdentifier = asset.localIdentifier
  427. addObject.mediaType = asset.mediaType.rawValue
  428. if let creationDate = asset.creationDate {
  429. addObject.creationDate = creationDate as NSDate
  430. creationDateString = String(describing: creationDate)
  431. }
  432. if let modificationDate = asset.modificationDate {
  433. addObject.modificationDate = modificationDate as NSDate
  434. }
  435. addObject.idAsset = account + asset.localIdentifier + creationDateString
  436. realm.add(addObject, update: .all)
  437. }
  438. }
  439. } catch let error {
  440. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  441. return false
  442. }
  443. return true
  444. }
  445. func getPhotoLibraryIdAsset(image: Bool, video: Bool, account: String) -> [String]? {
  446. var predicate = NSPredicate()
  447. if image && video {
  448. predicate = NSPredicate(format: "account == %@ AND (mediaType == %d OR mediaType == %d)", account, PHAssetMediaType.image.rawValue, PHAssetMediaType.video.rawValue)
  449. } else if image {
  450. predicate = NSPredicate(format: "account == %@ AND mediaType == %d", account, PHAssetMediaType.image.rawValue)
  451. } else if video {
  452. predicate = NSPredicate(format: "account == %@ AND mediaType == %d", account, PHAssetMediaType.video.rawValue)
  453. }
  454. do {
  455. let realm = try Realm()
  456. realm.refresh()
  457. let results = realm.objects(tablePhotoLibrary.self).filter(predicate)
  458. let idsAsset = results.map { $0.idAsset }
  459. return Array(idsAsset)
  460. } catch let error as NSError {
  461. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  462. }
  463. return nil
  464. }
  465. // MARK: -
  466. // MARK: Table Tag
  467. func addTag(_ ocId: String, tagIOS: Data?, account: String) {
  468. do {
  469. let realm = try Realm()
  470. try realm.write {
  471. let addObject = tableTag()
  472. addObject.account = account
  473. addObject.ocId = ocId
  474. addObject.tagIOS = tagIOS
  475. realm.add(addObject, update: .all)
  476. }
  477. } catch let error {
  478. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  479. }
  480. }
  481. func deleteTag(_ ocId: String) {
  482. do {
  483. let realm = try Realm()
  484. try realm.write {
  485. let results = realm.objects(tableTag.self).filter("ocId == %@", ocId)
  486. realm.delete(results)
  487. }
  488. } catch let error {
  489. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  490. }
  491. }
  492. func getTags(predicate: NSPredicate) -> [tableTag] {
  493. do {
  494. let realm = try Realm()
  495. realm.refresh()
  496. let results = realm.objects(tableTag.self).filter(predicate)
  497. return Array(results.map { tableTag.init(value: $0) })
  498. } catch let error as NSError {
  499. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  500. }
  501. return []
  502. }
  503. func getTag(predicate: NSPredicate) -> tableTag? {
  504. do {
  505. let realm = try Realm()
  506. realm.refresh()
  507. guard let result = realm.objects(tableTag.self).filter(predicate).first else { return nil }
  508. return tableTag.init(value: result)
  509. } catch let error as NSError {
  510. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  511. }
  512. return nil
  513. }
  514. // MARK: -
  515. // MARK: Table Tip
  516. func tipExists(_ tipName: String) -> Bool {
  517. do {
  518. let realm = try Realm()
  519. guard (realm.objects(tableTip.self).where {
  520. $0.tipName == tipName
  521. }.first) == nil else {
  522. return true
  523. }
  524. } catch let error as NSError {
  525. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  526. }
  527. return false
  528. }
  529. func addTip(_ tipName: String) {
  530. do {
  531. let realm = try Realm()
  532. try realm.write {
  533. let addObject = tableTip()
  534. addObject.tipName = tipName
  535. realm.add(addObject, update: .all)
  536. }
  537. } catch let error {
  538. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  539. }
  540. }
  541. // MARK: -
  542. // MARK: Table Trash
  543. func addTrash(account: String, items: [NKTrash]) {
  544. do {
  545. let realm = try Realm()
  546. try realm.write {
  547. for trash in items {
  548. let object = tableTrash()
  549. object.account = account
  550. object.contentType = trash.contentType
  551. object.date = trash.date
  552. object.directory = trash.directory
  553. object.fileId = trash.fileId
  554. object.fileName = trash.fileName
  555. object.filePath = trash.filePath
  556. object.hasPreview = trash.hasPreview
  557. object.iconName = trash.iconName
  558. object.size = trash.size
  559. object.trashbinDeletionTime = trash.trashbinDeletionTime
  560. object.trashbinFileName = trash.trashbinFileName
  561. object.trashbinOriginalLocation = trash.trashbinOriginalLocation
  562. object.classFile = trash.classFile
  563. realm.add(object, update: .all)
  564. }
  565. }
  566. } catch let error {
  567. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  568. }
  569. }
  570. func deleteTrash(filePath: String?, account: String) {
  571. var predicate = NSPredicate()
  572. do {
  573. let realm = try Realm()
  574. try realm.write {
  575. if filePath == nil {
  576. predicate = NSPredicate(format: "account == %@", account)
  577. } else {
  578. predicate = NSPredicate(format: "account == %@ AND filePath == %@", account, filePath!)
  579. }
  580. let result = realm.objects(tableTrash.self).filter(predicate)
  581. realm.delete(result)
  582. }
  583. } catch let error {
  584. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  585. }
  586. }
  587. func deleteTrash(fileId: String?, account: String) {
  588. var predicate = NSPredicate()
  589. do {
  590. let realm = try Realm()
  591. try realm.write {
  592. if fileId == nil {
  593. predicate = NSPredicate(format: "account == %@", account)
  594. } else {
  595. predicate = NSPredicate(format: "account == %@ AND fileId == %@", account, fileId!)
  596. }
  597. let result = realm.objects(tableTrash.self).filter(predicate)
  598. realm.delete(result)
  599. }
  600. } catch let error {
  601. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  602. }
  603. }
  604. func getTrash(filePath: String, sort: String?, ascending: Bool?, account: String) -> [tableTrash]? {
  605. let sort = sort ?? "date"
  606. let ascending = ascending ?? false
  607. do {
  608. let realm = try Realm()
  609. realm.refresh()
  610. let results = realm.objects(tableTrash.self).filter("account == %@ AND filePath == %@", account, filePath).sorted(byKeyPath: sort, ascending: ascending)
  611. return Array(results.map { tableTrash.init(value: $0) })
  612. } catch let error as NSError {
  613. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  614. }
  615. return nil
  616. }
  617. func getTrashItem(fileId: String, account: String) -> tableTrash? {
  618. do {
  619. let realm = try Realm()
  620. realm.refresh()
  621. guard let result = realm.objects(tableTrash.self).filter("account == %@ AND fileId == %@", account, fileId).first else { return nil }
  622. return tableTrash.init(value: result)
  623. } catch let error as NSError {
  624. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  625. }
  626. return nil
  627. }
  628. // MARK: -
  629. // MARK: Table UserStatus
  630. func addUserStatus(_ userStatuses: [NKUserStatus], account: String, predefined: Bool) {
  631. do {
  632. let realm = try Realm()
  633. try realm.write {
  634. let results = realm.objects(tableUserStatus.self).filter("account == %@ AND predefined == %@", account, predefined)
  635. realm.delete(results)
  636. for userStatus in userStatuses {
  637. let object = tableUserStatus()
  638. object.account = account
  639. object.clearAt = userStatus.clearAt
  640. object.clearAtTime = userStatus.clearAtTime
  641. object.clearAtType = userStatus.clearAtType
  642. object.icon = userStatus.icon
  643. object.id = userStatus.id
  644. object.message = userStatus.message
  645. object.predefined = userStatus.predefined
  646. object.status = userStatus.status
  647. object.userId = userStatus.userId
  648. realm.add(object)
  649. }
  650. }
  651. } catch let error {
  652. NextcloudKit.shared.nkCommonInstance.writeLog("Could not write to database: \(error)")
  653. }
  654. }
  655. }