NCManageDatabse+Metadata.swift 31 KB

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