NCManageDatabase+Metadata.swift 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831
  1. //
  2. // NCManageDatabase+Metadata.swift
  3. // Nextcloud
  4. //
  5. // Created by Henrik Storch on 30.11.21.
  6. // Copyright © 2021 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 Foundation
  24. import RealmSwift
  25. import NCCommunication
  26. extension NCManageDatabase {
  27. @objc func copyObject(metadata: tableMetadata) -> tableMetadata {
  28. return tableMetadata.init(value: metadata)
  29. }
  30. @objc func convertNCFileToMetadata(_ file: NCCommunicationFile, isEncrypted: Bool, account: String) -> tableMetadata {
  31. let metadata = tableMetadata()
  32. metadata.account = account
  33. metadata.checksums = file.checksums
  34. metadata.commentsUnread = file.commentsUnread
  35. metadata.contentType = file.contentType
  36. if let date = file.creationDate {
  37. metadata.creationDate = date
  38. } else {
  39. metadata.creationDate = file.date
  40. }
  41. metadata.dataFingerprint = file.dataFingerprint
  42. metadata.date = file.date
  43. metadata.directory = file.directory
  44. metadata.downloadURL = file.downloadURL
  45. metadata.e2eEncrypted = file.e2eEncrypted
  46. metadata.etag = file.etag
  47. metadata.ext = file.ext
  48. metadata.favorite = file.favorite
  49. metadata.fileId = file.fileId
  50. metadata.fileName = file.fileName
  51. metadata.fileNameView = file.fileName
  52. metadata.fileNameWithoutExt = file.fileNameWithoutExt
  53. metadata.hasPreview = file.hasPreview
  54. metadata.iconName = file.iconName
  55. metadata.livePhoto = file.livePhoto
  56. metadata.mountType = file.mountType
  57. metadata.note = file.note
  58. metadata.ocId = file.ocId
  59. metadata.ownerId = file.ownerId
  60. metadata.ownerDisplayName = file.ownerDisplayName
  61. metadata.lock = file.lock
  62. metadata.lockOwner = file.lockOwner
  63. metadata.lockOwnerType = file.lockOwnerType
  64. metadata.lockOwnerDisplayName = file.lockOwnerDisplayName
  65. metadata.lockTime = file.lockTime
  66. metadata.lockTimeOut = file.lockTimeOut
  67. metadata.path = file.path
  68. metadata.permissions = file.permissions
  69. metadata.quotaUsedBytes = file.quotaUsedBytes
  70. metadata.quotaAvailableBytes = file.quotaAvailableBytes
  71. metadata.richWorkspace = file.richWorkspace
  72. metadata.resourceType = file.resourceType
  73. metadata.serverUrl = file.serverUrl
  74. metadata.sharePermissionsCollaborationServices = file.sharePermissionsCollaborationServices
  75. for element in file.sharePermissionsCloudMesh {
  76. metadata.sharePermissionsCloudMesh.append(element)
  77. }
  78. for element in file.shareType {
  79. metadata.shareType.append(element)
  80. }
  81. metadata.size = file.size
  82. metadata.classFile = file.classFile
  83. if let date = file.uploadDate {
  84. metadata.uploadDate = date
  85. } else {
  86. metadata.uploadDate = file.date
  87. }
  88. metadata.urlBase = file.urlBase
  89. metadata.user = file.user
  90. metadata.userId = file.userId
  91. // E2EE find the fileName for fileNameView
  92. if isEncrypted || metadata.e2eEncrypted {
  93. if let tableE2eEncryption = NCManageDatabase.shared.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameIdentifier == %@", account, file.serverUrl, file.fileName)) {
  94. metadata.fileNameView = tableE2eEncryption.fileName
  95. let results = NCCommunicationCommon.shared.getInternalType(fileName: metadata.fileNameView, mimeType: file.contentType, directory: file.directory)
  96. metadata.contentType = results.mimeType
  97. metadata.iconName = results.iconName
  98. metadata.classFile = results.classFile
  99. }
  100. }
  101. // Live Photo "DETECT"
  102. if !metadata.directory && !metadata.livePhoto && (metadata.classFile == NCCommunicationCommon.typeClassFile.video.rawValue || metadata.classFile == NCCommunicationCommon.typeClassFile.image.rawValue) {
  103. var classFile = metadata.classFile
  104. if classFile == NCCommunicationCommon.typeClassFile.image.rawValue {
  105. classFile = NCCommunicationCommon.typeClassFile.video.rawValue
  106. } else {
  107. classFile = NCCommunicationCommon.typeClassFile.image.rawValue
  108. }
  109. if getMetadata(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameWithoutExt == %@ AND ocId != %@ AND classFile == %@", metadata.account, metadata.serverUrl, metadata.fileNameWithoutExt, metadata.ocId, classFile)) != nil {
  110. metadata.livePhoto = true
  111. }
  112. }
  113. return metadata
  114. }
  115. @objc func convertNCCommunicationFilesToMetadatas(_ files: [NCCommunicationFile], useMetadataFolder: Bool, account: String, completion: @escaping (_ metadataFolder: tableMetadata, _ metadatasFolder: [tableMetadata], _ metadatas: [tableMetadata]) -> Void) {
  116. var counter: Int = 0
  117. var isEncrypted: Bool = false
  118. var listServerUrl: [String: Bool] = [:]
  119. var metadataFolder = tableMetadata()
  120. var metadataFolders: [tableMetadata] = []
  121. var metadatas: [tableMetadata] = []
  122. for file in files {
  123. if let key = listServerUrl[file.serverUrl] {
  124. isEncrypted = key
  125. } else {
  126. isEncrypted = CCUtility.isFolderEncrypted(file.serverUrl, e2eEncrypted: file.e2eEncrypted, account: account, urlBase: file.urlBase)
  127. listServerUrl[file.serverUrl] = isEncrypted
  128. }
  129. let metadata = convertNCFileToMetadata(file, isEncrypted: isEncrypted, account: account)
  130. if counter == 0 && useMetadataFolder {
  131. metadataFolder = tableMetadata.init(value: metadata)
  132. } else {
  133. metadatas.append(metadata)
  134. if metadata.directory {
  135. metadataFolders.append(metadata)
  136. }
  137. }
  138. counter += 1
  139. }
  140. completion(metadataFolder, metadataFolders, metadatas)
  141. }
  142. @objc func createMetadata(account: String, user: String, userId: String, fileName: String, fileNameView: String, ocId: String, serverUrl: String, urlBase: String, url: String, contentType: String, livePhoto: Bool) -> tableMetadata {
  143. let metadata = tableMetadata()
  144. let resultInternalType = NCCommunicationCommon.shared.getInternalType(fileName: fileName, mimeType: contentType, directory: false)
  145. let fileName = fileName.trimmingCharacters(in: .whitespacesAndNewlines)
  146. metadata.account = account
  147. metadata.chunk = false
  148. metadata.contentType = resultInternalType.mimeType
  149. metadata.creationDate = Date() as NSDate
  150. metadata.date = Date() as NSDate
  151. metadata.hasPreview = true
  152. metadata.iconName = resultInternalType.iconName
  153. metadata.etag = ocId
  154. metadata.ext = (fileName as NSString).pathExtension.lowercased()
  155. metadata.fileName = fileName
  156. metadata.fileNameView = fileName
  157. metadata.fileNameWithoutExt = (fileName as NSString).deletingPathExtension
  158. metadata.livePhoto = livePhoto
  159. metadata.ocId = ocId
  160. metadata.permissions = "RGDNVW"
  161. metadata.serverUrl = serverUrl
  162. metadata.classFile = resultInternalType.classFile
  163. metadata.uploadDate = Date() as NSDate
  164. metadata.url = url
  165. metadata.urlBase = urlBase
  166. metadata.user = user
  167. metadata.userId = userId
  168. if !metadata.urlBase.isEmpty, metadata.serverUrl.hasPrefix(metadata.urlBase) {
  169. metadata.path = String(metadata.serverUrl.dropFirst(metadata.urlBase.count)) + "/"
  170. }
  171. return metadata
  172. }
  173. @objc func addMetadata(_ metadata: tableMetadata) {
  174. let realm = try! Realm()
  175. do {
  176. try realm.safeWrite {
  177. realm.add(metadata, update: .all)
  178. }
  179. } catch let error {
  180. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  181. }
  182. }
  183. @objc func addMetadatas(_ metadatas: [tableMetadata]) {
  184. let realm = try! Realm()
  185. do {
  186. try realm.safeWrite {
  187. for metadata in metadatas {
  188. realm.add(metadata, update: .all)
  189. }
  190. }
  191. } catch let error {
  192. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  193. }
  194. }
  195. @objc func deleteMetadata(predicate: NSPredicate) {
  196. let realm = try! Realm()
  197. do {
  198. try realm.safeWrite {
  199. let results = realm.objects(tableMetadata.self).filter(predicate)
  200. realm.delete(results)
  201. }
  202. } catch let error {
  203. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  204. }
  205. }
  206. @objc func moveMetadata(ocId: String, serverUrlTo: String) {
  207. let realm = try! Realm()
  208. do {
  209. try realm.safeWrite {
  210. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  211. result.serverUrl = serverUrlTo
  212. }
  213. }
  214. } catch let error {
  215. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  216. }
  217. }
  218. @objc func addMetadataServerUrl(ocId: String, serverUrl: String) {
  219. let realm = try! Realm()
  220. do {
  221. try realm.safeWrite {
  222. let results = realm.objects(tableMetadata.self).filter("ocId == %@", ocId)
  223. for result in results {
  224. result.serverUrl = serverUrl
  225. }
  226. }
  227. } catch let error {
  228. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  229. }
  230. }
  231. @objc func renameMetadata(fileNameTo: String, ocId: String) {
  232. let realm = try! Realm()
  233. do {
  234. try realm.safeWrite {
  235. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  236. let resultsType = NCCommunicationCommon.shared.getInternalType(fileName: fileNameTo, mimeType: "", directory: result.directory)
  237. result.fileName = fileNameTo
  238. result.fileNameView = fileNameTo
  239. if result.directory {
  240. result.fileNameWithoutExt = fileNameTo
  241. result.ext = ""
  242. } else {
  243. result.fileNameWithoutExt = (fileNameTo as NSString).deletingPathExtension
  244. result.ext = resultsType.ext
  245. }
  246. result.iconName = resultsType.iconName
  247. result.contentType = resultsType.mimeType
  248. result.classFile = resultsType.classFile
  249. }
  250. }
  251. } catch let error {
  252. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  253. }
  254. }
  255. @discardableResult
  256. func updateMetadatas(_ metadatas: [tableMetadata], metadatasResult: [tableMetadata], addCompareLivePhoto: Bool = true, addExistsInLocal: Bool = false, addCompareEtagLocal: Bool = false, addDirectorySynchronized: Bool = false) -> (metadatasUpdate: [tableMetadata], metadatasLocalUpdate: [tableMetadata], metadatasDelete: [tableMetadata]) {
  257. let realm = try! Realm()
  258. var ocIdsUdate: [String] = []
  259. var ocIdsLocalUdate: [String] = []
  260. var metadatasDelete: [tableMetadata] = []
  261. var metadatasUpdate: [tableMetadata] = []
  262. var metadatasLocalUpdate: [tableMetadata] = []
  263. realm.refresh()
  264. do {
  265. try realm.safeWrite {
  266. // DELETE
  267. for metadataResult in metadatasResult {
  268. if metadatas.firstIndex(where: { $0.ocId == metadataResult.ocId }) == nil {
  269. if let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@", metadataResult.ocId)).first {
  270. metadatasDelete.append(tableMetadata.init(value: result))
  271. realm.delete(result)
  272. }
  273. }
  274. }
  275. // UPDATE/NEW
  276. for metadata in metadatas {
  277. if let result = metadatasResult.first(where: { $0.ocId == metadata.ocId }) {
  278. // update
  279. if result.status == NCGlobal.shared.metadataStatusNormal && (result.etag != metadata.etag || result.fileNameView != metadata.fileNameView || result.date != metadata.date || result.permissions != metadata.permissions || result.hasPreview != metadata.hasPreview || result.note != metadata.note) {
  280. ocIdsUdate.append(metadata.ocId)
  281. realm.add(tableMetadata.init(value: metadata), update: .all)
  282. } else if result.status == NCGlobal.shared.metadataStatusNormal && addCompareLivePhoto && result.livePhoto != metadata.livePhoto {
  283. ocIdsUdate.append(metadata.ocId)
  284. realm.add(tableMetadata.init(value: metadata), update: .all)
  285. }
  286. } else {
  287. // new
  288. ocIdsUdate.append(metadata.ocId)
  289. realm.add(tableMetadata.init(value: metadata), update: .all)
  290. }
  291. if metadata.directory && !ocIdsUdate.contains(metadata.ocId) {
  292. let table = realm.objects(tableDirectory.self).filter(NSPredicate(format: "ocId == %@", metadata.ocId)).first
  293. if table?.etag != metadata.etag {
  294. ocIdsUdate.append(metadata.ocId)
  295. }
  296. }
  297. // Local
  298. if !metadata.directory && (addExistsInLocal || addCompareEtagLocal) {
  299. let localFile = realm.objects(tableLocalFile.self).filter(NSPredicate(format: "ocId == %@", metadata.ocId)).first
  300. if addCompareEtagLocal && localFile != nil && localFile?.etag != metadata.etag {
  301. ocIdsLocalUdate.append(metadata.ocId)
  302. }
  303. if addExistsInLocal && (localFile == nil || localFile?.etag != metadata.etag) && !ocIdsLocalUdate.contains(metadata.ocId) {
  304. ocIdsLocalUdate.append(metadata.ocId)
  305. }
  306. }
  307. }
  308. }
  309. } catch let error {
  310. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  311. }
  312. for ocId in ocIdsUdate {
  313. if let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@", ocId)).first {
  314. metadatasUpdate.append(tableMetadata.init(value: result))
  315. }
  316. }
  317. for ocId in ocIdsLocalUdate {
  318. if let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@", ocId)).first {
  319. metadatasLocalUpdate.append(tableMetadata.init(value: result))
  320. }
  321. }
  322. return (metadatasUpdate, metadatasLocalUpdate, metadatasDelete)
  323. }
  324. func setMetadataSession(ocId: String, session: String? = nil, sessionError: String? = nil, sessionSelector: String? = nil, sessionTaskIdentifier: Int? = nil, status: Int? = nil, etag: String? = nil) {
  325. let realm = try! Realm()
  326. realm.refresh()
  327. do {
  328. try realm.safeWrite {
  329. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  330. if let session = session {
  331. result?.session = session
  332. }
  333. if let sessionError = sessionError {
  334. result?.sessionError = sessionError
  335. }
  336. if let sessionSelector = sessionSelector {
  337. result?.sessionSelector = sessionSelector
  338. }
  339. if let sessionTaskIdentifier = sessionTaskIdentifier {
  340. result?.sessionTaskIdentifier = sessionTaskIdentifier
  341. }
  342. if let status = status {
  343. result?.status = status
  344. }
  345. if let etag = etag {
  346. result?.etag = etag
  347. }
  348. }
  349. } catch let error {
  350. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  351. }
  352. }
  353. @discardableResult
  354. func setMetadataStatus(ocId: String, status: Int) -> tableMetadata? {
  355. let realm = try! Realm()
  356. var result: tableMetadata?
  357. do {
  358. try realm.safeWrite {
  359. result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  360. result?.status = status
  361. }
  362. } catch let error {
  363. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  364. }
  365. if let result = result {
  366. return tableMetadata.init(value: result)
  367. } else {
  368. return nil
  369. }
  370. }
  371. func setMetadataEtagResource(ocId: String, etagResource: String?) {
  372. let realm = try! Realm()
  373. var result: tableMetadata?
  374. guard let etagResource = etagResource else { return }
  375. do {
  376. try realm.safeWrite {
  377. result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  378. result?.etagResource = etagResource
  379. }
  380. } catch let error {
  381. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  382. }
  383. }
  384. @objc func setMetadataFavorite(ocId: String, favorite: Bool) {
  385. let realm = try! Realm()
  386. do {
  387. try realm.safeWrite {
  388. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  389. result?.favorite = favorite
  390. }
  391. } catch let error {
  392. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  393. }
  394. }
  395. @objc func updateMetadatasFavorite(account: String, metadatas: [tableMetadata]) {
  396. let realm = try! Realm()
  397. do {
  398. try realm.safeWrite {
  399. let results = realm.objects(tableMetadata.self).filter("account == %@ AND favorite == true", account)
  400. for result in results {
  401. result.favorite = false
  402. }
  403. for metadata in metadatas {
  404. realm.add(metadata, update: .all)
  405. }
  406. }
  407. } catch let error {
  408. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  409. }
  410. }
  411. @objc func setMetadataEncrypted(ocId: String, encrypted: Bool) {
  412. let realm = try! Realm()
  413. do {
  414. try realm.safeWrite {
  415. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  416. result?.e2eEncrypted = encrypted
  417. }
  418. } catch let error {
  419. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  420. }
  421. }
  422. @objc func setMetadataFileNameView(serverUrl: String, fileName: String, newFileNameView: String, account: String) {
  423. let realm = try! Realm()
  424. do {
  425. try realm.safeWrite {
  426. let result = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName == %@", account, serverUrl, fileName).first
  427. result?.fileNameView = newFileNameView
  428. }
  429. } catch let error {
  430. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  431. }
  432. }
  433. @objc func getMetadata(predicate: NSPredicate) -> tableMetadata? {
  434. let realm = try! Realm()
  435. realm.refresh()
  436. guard let result = realm.objects(tableMetadata.self).filter(predicate).first else {
  437. return nil
  438. }
  439. return tableMetadata.init(value: result)
  440. }
  441. @objc func getMetadata(predicate: NSPredicate, sorted: String, ascending: Bool) -> tableMetadata? {
  442. let realm = try! Realm()
  443. realm.refresh()
  444. guard let result = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending).first else {
  445. return nil
  446. }
  447. return tableMetadata.init(value: result)
  448. }
  449. @objc func getMetadatasViewer(predicate: NSPredicate, sorted: String, ascending: Bool) -> [tableMetadata]? {
  450. let realm = try! Realm()
  451. realm.refresh()
  452. let results: Results<tableMetadata>
  453. var finals: [tableMetadata] = []
  454. if (tableMetadata().objectSchema.properties.contains { $0.name == sorted }) {
  455. results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  456. } else {
  457. results = realm.objects(tableMetadata.self).filter(predicate)
  458. }
  459. // For Live Photo
  460. var fileNameImages: [String] = []
  461. let filtered = results.filter { $0.classFile.contains(NCCommunicationCommon.typeClassFile.image.rawValue) }
  462. filtered.forEach { print($0)
  463. let fileName = ($0.fileNameView as NSString).deletingPathExtension
  464. fileNameImages.append(fileName)
  465. }
  466. for result in results {
  467. let ext = (result.fileNameView as NSString).pathExtension.uppercased()
  468. let fileName = (result.fileNameView as NSString).deletingPathExtension
  469. if !(ext == "MOV" && fileNameImages.contains(fileName)) {
  470. finals.append(result)
  471. }
  472. }
  473. if finals.count > 0 {
  474. return Array(finals.map { tableMetadata.init(value: $0) })
  475. } else {
  476. return nil
  477. }
  478. }
  479. @objc func getMetadatas(predicate: NSPredicate) -> [tableMetadata] {
  480. let realm = try! Realm()
  481. realm.refresh()
  482. let results = realm.objects(tableMetadata.self).filter(predicate)
  483. return Array(results.map { tableMetadata.init(value: $0) })
  484. }
  485. @objc func getAdvancedMetadatas(predicate: NSPredicate, page: Int = 0, limit: Int = 0, sorted: String, ascending: Bool) -> [tableMetadata] {
  486. let realm = try! Realm()
  487. realm.refresh()
  488. var metadatas: [tableMetadata] = []
  489. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  490. if results.count > 0 {
  491. if page == 0 || limit == 0 {
  492. return Array(results.map { tableMetadata.init(value: $0) })
  493. } else {
  494. let nFrom = (page - 1) * limit
  495. let nTo = nFrom + (limit - 1)
  496. for n in nFrom...nTo {
  497. if n == results.count {
  498. break
  499. }
  500. metadatas.append(tableMetadata.init(value: results[n]))
  501. }
  502. }
  503. }
  504. return metadatas
  505. }
  506. @objc func getMetadataAtIndex(predicate: NSPredicate, sorted: String, ascending: Bool, index: Int) -> tableMetadata? {
  507. let realm = try! Realm()
  508. realm.refresh()
  509. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  510. if results.count > 0 && results.count > index {
  511. return tableMetadata.init(value: results[index])
  512. } else {
  513. return nil
  514. }
  515. }
  516. @objc func getMetadataFromOcId(_ ocId: String?) -> tableMetadata? {
  517. let realm = try! Realm()
  518. realm.refresh()
  519. guard let ocId = ocId else { return nil }
  520. guard let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first else { return nil }
  521. return tableMetadata.init(value: result)
  522. }
  523. @objc func getMetadataFolder(account: String, urlBase: String, serverUrl: String) -> tableMetadata? {
  524. let realm = try! Realm()
  525. realm.refresh()
  526. var serverUrl = serverUrl
  527. var fileName = ""
  528. let serverUrlHome = NCUtilityFileSystem.shared.getHomeServer(account: account)
  529. if serverUrlHome == serverUrl {
  530. fileName = "."
  531. serverUrl = ".."
  532. } else {
  533. fileName = (serverUrl as NSString).lastPathComponent
  534. serverUrl = NCUtilityFileSystem.shared.deletingLastPathComponent(account: account, serverUrl: serverUrl)
  535. }
  536. guard let result = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName == %@", account, serverUrl, fileName).first else { return nil }
  537. return tableMetadata.init(value: result)
  538. }
  539. @objc func getTableMetadatasDirectoryFavoriteIdentifierRank(account: String) -> [String: NSNumber] {
  540. var listIdentifierRank: [String: NSNumber] = [:]
  541. let realm = try! Realm()
  542. var counter = 10 as Int64
  543. let results = realm.objects(tableMetadata.self).filter("account == %@ AND directory == true AND favorite == true", account).sorted(byKeyPath: "fileNameView", ascending: true)
  544. for result in results {
  545. counter += 1
  546. listIdentifierRank[result.ocId] = NSNumber(value: Int64(counter))
  547. }
  548. return listIdentifierRank
  549. }
  550. @objc func clearMetadatasUpload(account: String) {
  551. let realm = try! Realm()
  552. realm.refresh()
  553. do {
  554. try realm.safeWrite {
  555. let results = realm.objects(tableMetadata.self).filter("account == %@ AND (status == %d OR status == %@)", account, NCGlobal.shared.metadataStatusWaitUpload, NCGlobal.shared.metadataStatusUploadError)
  556. realm.delete(results)
  557. }
  558. } catch let error {
  559. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  560. }
  561. }
  562. @objc func readMarkerMetadata(account: String, fileId: String) {
  563. let realm = try! Realm()
  564. do {
  565. try realm.safeWrite {
  566. let results = realm.objects(tableMetadata.self).filter("account == %@ AND fileId == %@", account, fileId)
  567. for result in results {
  568. result.commentsUnread = false
  569. }
  570. }
  571. } catch let error {
  572. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  573. }
  574. }
  575. @objc func getAssetLocalIdentifiersUploaded(account: String, sessionSelector: String) -> [String] {
  576. let realm = try! Realm()
  577. realm.refresh()
  578. var assetLocalIdentifiers: [String] = []
  579. let results = realm.objects(tableMetadata.self).filter("account == %@ AND assetLocalIdentifier != '' AND deleteAssetLocalIdentifier == true AND sessionSelector == %@", account, sessionSelector)
  580. for result in results {
  581. assetLocalIdentifiers.append(result.assetLocalIdentifier)
  582. }
  583. return assetLocalIdentifiers
  584. }
  585. @objc func clearAssetLocalIdentifiers(_ assetLocalIdentifiers: [String], account: String) {
  586. let realm = try! Realm()
  587. do {
  588. try realm.safeWrite {
  589. let results = realm.objects(tableMetadata.self).filter("account == %@ AND assetLocalIdentifier IN %@", account, assetLocalIdentifiers)
  590. for result in results {
  591. result.assetLocalIdentifier = ""
  592. result.deleteAssetLocalIdentifier = false
  593. }
  594. }
  595. } catch let error {
  596. NCCommunicationCommon.shared.writeLog("Could not write to database: \(error)")
  597. }
  598. }
  599. @objc func getMetadataLivePhoto(metadata: tableMetadata) -> tableMetadata? {
  600. let realm = try! Realm()
  601. var classFile = metadata.classFile
  602. realm.refresh()
  603. if !metadata.livePhoto || !CCUtility.getLivePhoto() {
  604. return nil
  605. }
  606. if classFile == NCCommunicationCommon.typeClassFile.image.rawValue {
  607. classFile = NCCommunicationCommon.typeClassFile.video.rawValue
  608. } else {
  609. classFile = NCCommunicationCommon.typeClassFile.image.rawValue
  610. }
  611. guard let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameWithoutExt == %@ AND ocId != %@ AND classFile == %@", metadata.account, metadata.serverUrl, metadata.fileNameWithoutExt, metadata.ocId, classFile)).first else {
  612. return nil
  613. }
  614. return tableMetadata.init(value: result)
  615. }
  616. func getMetadatasMedia(predicate: NSPredicate, sort: String, ascending: Bool = false) -> [tableMetadata] {
  617. let realm = try! Realm()
  618. realm.refresh()
  619. let sortProperties = [SortDescriptor(keyPath: sort, ascending: ascending), SortDescriptor(keyPath: "fileNameView", ascending: false)]
  620. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(by: sortProperties)
  621. return Array(results.map { tableMetadata.init(value: $0) })
  622. }
  623. func isMetadataShareOrMounted(metadata: tableMetadata, metadataFolder: tableMetadata?) -> Bool {
  624. var isShare = false
  625. var isMounted = false
  626. if metadataFolder != nil {
  627. isShare = metadata.permissions.contains(NCGlobal.shared.permissionShared) && !metadataFolder!.permissions.contains(NCGlobal.shared.permissionShared)
  628. isMounted = metadata.permissions.contains(NCGlobal.shared.permissionMounted) && !metadataFolder!.permissions.contains(NCGlobal.shared.permissionMounted)
  629. } else if let directory = NCManageDatabase.shared.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, metadata.serverUrl)) {
  630. isShare = metadata.permissions.contains(NCGlobal.shared.permissionShared) && !directory.permissions.contains(NCGlobal.shared.permissionShared)
  631. isMounted = metadata.permissions.contains(NCGlobal.shared.permissionMounted) && !directory.permissions.contains(NCGlobal.shared.permissionMounted)
  632. }
  633. if isShare || isMounted {
  634. return true
  635. } else {
  636. return false
  637. }
  638. }
  639. func isDownloadMetadata(_ metadata: tableMetadata, download: Bool) -> Bool {
  640. let localFile = getTableLocalFile(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  641. let fileSize = CCUtility.fileProviderStorageSize(metadata.ocId, fileNameView: metadata.fileNameView)
  642. if (localFile != nil || download) && (localFile?.etag != metadata.etag || fileSize == 0) {
  643. return true
  644. }
  645. return false
  646. }
  647. func getMetadataConflict(account: String, serverUrl: String, fileName: String) -> tableMetadata? {
  648. // verify exists conflict
  649. let fileNameExtension = (fileName as NSString).pathExtension.lowercased()
  650. let fileNameWithoutExtension = (fileName as NSString).deletingPathExtension
  651. var fileNameConflict = fileName
  652. if fileNameExtension == "heic" && CCUtility.getFormatCompatibility() {
  653. fileNameConflict = fileNameWithoutExtension + ".jpg"
  654. }
  655. return getMetadata(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameView == %@", account, serverUrl, fileNameConflict))
  656. }
  657. func getSubtitles(account: String, serverUrl: String, fileName: String) -> (all:[tableMetadata], existing:[tableMetadata]) {
  658. let realm = try! Realm()
  659. let nameOnly = (fileName as NSString).deletingPathExtension + "."
  660. var metadatas: [tableMetadata] = []
  661. let results = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName BEGINSWITH[c] %@ AND fileName ENDSWITH[c] '.srt'", account, serverUrl, nameOnly)
  662. for result in results {
  663. if CCUtility.fileProviderStorageExists(result) {
  664. metadatas.append(result)
  665. }
  666. }
  667. return(Array(results.map { tableMetadata.init(value: $0) }), Array(metadatas.map { tableMetadata.init(value: $0) }))
  668. }
  669. }