NCManageDatabase+Metadata.swift 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997
  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 NextcloudKit
  26. class tableMetadata: Object, NCUserBaseUrl {
  27. override func isEqual(_ object: Any?) -> Bool {
  28. if let object = object as? tableMetadata {
  29. return self.fileId == object.fileId && self.account == object.account
  30. && self.path == object.path && self.fileName == object.fileName
  31. } else {
  32. return false
  33. }
  34. }
  35. @objc dynamic var account = ""
  36. @objc dynamic var assetLocalIdentifier = ""
  37. @objc dynamic var checksums = ""
  38. @objc dynamic var chunk: Bool = false
  39. @objc dynamic var classFile = ""
  40. @objc dynamic var commentsUnread: Bool = false
  41. @objc dynamic var contentType = ""
  42. @objc dynamic var creationDate = NSDate()
  43. @objc dynamic var dataFingerprint = ""
  44. @objc dynamic var date = NSDate()
  45. @objc dynamic var directory: Bool = false
  46. @objc dynamic var deleteAssetLocalIdentifier: Bool = false
  47. @objc dynamic var downloadURL = ""
  48. @objc dynamic var e2eEncrypted: Bool = false
  49. @objc dynamic var edited: Bool = false
  50. @objc dynamic var etag = ""
  51. @objc dynamic var etagResource = ""
  52. @objc dynamic var favorite: Bool = false
  53. @objc dynamic var fileId = ""
  54. @objc dynamic var fileName = ""
  55. @objc dynamic var fileNameView = ""
  56. @objc dynamic var hasPreview: Bool = false
  57. @objc dynamic var iconName = ""
  58. @objc dynamic var iconUrl = ""
  59. @objc dynamic var isExtractFile: Bool = false
  60. @objc dynamic var livePhoto: Bool = false
  61. @objc dynamic var mountType = ""
  62. @objc dynamic var name = "" // for unifiedSearch is the provider.id
  63. @objc dynamic var note = ""
  64. @objc dynamic var ocId = ""
  65. @objc dynamic var ownerId = ""
  66. @objc dynamic var ownerDisplayName = ""
  67. @objc public var lock = false
  68. @objc public var lockOwner = ""
  69. @objc public var lockOwnerEditor = ""
  70. @objc public var lockOwnerType = 0
  71. @objc public var lockOwnerDisplayName = ""
  72. @objc public var lockTime: Date?
  73. @objc public var lockTimeOut: Date?
  74. @objc dynamic var path = ""
  75. @objc dynamic var permissions = ""
  76. @objc dynamic var quotaUsedBytes: Int64 = 0
  77. @objc dynamic var quotaAvailableBytes: Int64 = 0
  78. @objc dynamic var resourceType = ""
  79. @objc dynamic var richWorkspace: String?
  80. @objc dynamic var serverUrl = ""
  81. @objc dynamic var session = ""
  82. @objc dynamic var sessionError = ""
  83. @objc dynamic var sessionSelector = ""
  84. @objc dynamic var sessionTaskIdentifier: Int = 0
  85. @objc dynamic var sharePermissionsCollaborationServices: Int = 0
  86. let sharePermissionsCloudMesh = List<String>()
  87. let shareType = List<Int>()
  88. @objc dynamic var size: Int64 = 0
  89. @objc dynamic var status: Int = 0
  90. @objc dynamic var subline: String?
  91. @objc dynamic var trashbinFileName = ""
  92. @objc dynamic var trashbinOriginalLocation = ""
  93. @objc dynamic var trashbinDeletionTime = NSDate()
  94. @objc dynamic var uploadDate = NSDate()
  95. @objc dynamic var url = ""
  96. @objc dynamic var urlBase = ""
  97. @objc dynamic var user = ""
  98. @objc dynamic var userId = ""
  99. override static func primaryKey() -> String {
  100. return "ocId"
  101. }
  102. }
  103. extension tableMetadata {
  104. var fileExtension: String { (fileNameView as NSString).pathExtension }
  105. var fileNoExtension: String { (fileNameView as NSString).deletingPathExtension }
  106. var isPrintable: Bool {
  107. classFile == NKCommon.typeClassFile.image.rawValue || ["application/pdf", "com.adobe.pdf"].contains(contentType) || contentType.hasPrefix("text/")
  108. }
  109. var isViewOnly: Bool {
  110. sharePermissionsCollaborationServices == NCGlobal.shared.permissionReadShare && classFile == NKCommon.typeClassFile.document.rawValue
  111. }
  112. var isDownloadUpload: Bool {
  113. status == NCGlobal.shared.metadataStatusInDownload || status == NCGlobal.shared.metadataStatusDownloading || status == NCGlobal.shared.metadataStatusInUpload || status == NCGlobal.shared.metadataStatusUploading
  114. }
  115. var isDownload: Bool {
  116. status == NCGlobal.shared.metadataStatusInDownload || status == NCGlobal.shared.metadataStatusDownloading
  117. }
  118. var isUpload: Bool {
  119. status == NCGlobal.shared.metadataStatusInUpload || status == NCGlobal.shared.metadataStatusUploading
  120. }
  121. @objc var isDirectorE2EE: Bool {
  122. NCUtility.shared.isDirectoryE2EE(serverUrl: serverUrl, account: account, urlBase: urlBase, userId: userId)
  123. }
  124. /// Returns false if the user is lokced out of the file. I.e. The file is locked but by somone else
  125. func canUnlock(as user: String) -> Bool {
  126. return !lock || (lockOwner == user && lockOwnerType == 0)
  127. }
  128. }
  129. extension NCManageDatabase {
  130. @objc func copyObject(metadata: tableMetadata) -> tableMetadata {
  131. return tableMetadata.init(value: metadata)
  132. }
  133. @objc func convertFileToMetadata(_ file: NKFile, isDirectoryE2EE: Bool) -> tableMetadata {
  134. let metadata = tableMetadata()
  135. metadata.account = file.account
  136. metadata.checksums = file.checksums
  137. metadata.commentsUnread = file.commentsUnread
  138. metadata.contentType = file.contentType
  139. if let date = file.creationDate {
  140. metadata.creationDate = date
  141. } else {
  142. metadata.creationDate = file.date
  143. }
  144. metadata.dataFingerprint = file.dataFingerprint
  145. metadata.date = file.date
  146. metadata.directory = file.directory
  147. metadata.downloadURL = file.downloadURL
  148. metadata.e2eEncrypted = file.e2eEncrypted
  149. metadata.etag = file.etag
  150. metadata.favorite = file.favorite
  151. metadata.fileId = file.fileId
  152. metadata.fileName = file.fileName
  153. metadata.fileNameView = file.fileName
  154. metadata.hasPreview = file.hasPreview
  155. metadata.iconName = file.iconName
  156. metadata.mountType = file.mountType
  157. metadata.name = file.name
  158. metadata.note = file.note
  159. metadata.ocId = file.ocId
  160. metadata.ownerId = file.ownerId
  161. metadata.ownerDisplayName = file.ownerDisplayName
  162. metadata.lock = file.lock
  163. metadata.lockOwner = file.lockOwner
  164. metadata.lockOwnerEditor = file.lockOwnerEditor
  165. metadata.lockOwnerType = file.lockOwnerType
  166. metadata.lockOwnerDisplayName = file.lockOwnerDisplayName
  167. metadata.lockTime = file.lockTime
  168. metadata.lockTimeOut = file.lockTimeOut
  169. metadata.path = file.path
  170. metadata.permissions = file.permissions
  171. metadata.quotaUsedBytes = file.quotaUsedBytes
  172. metadata.quotaAvailableBytes = file.quotaAvailableBytes
  173. metadata.richWorkspace = file.richWorkspace
  174. metadata.resourceType = file.resourceType
  175. metadata.serverUrl = file.serverUrl
  176. metadata.sharePermissionsCollaborationServices = file.sharePermissionsCollaborationServices
  177. for element in file.sharePermissionsCloudMesh {
  178. metadata.sharePermissionsCloudMesh.append(element)
  179. }
  180. for element in file.shareType {
  181. metadata.shareType.append(element)
  182. }
  183. metadata.size = file.size
  184. metadata.classFile = file.classFile
  185. //FIXME: iOS 12.0,* don't detect UTI text/markdown, text/x-markdown
  186. if (metadata.contentType == "text/markdown" || metadata.contentType == "text/x-markdown") && metadata.classFile == NKCommon.typeClassFile.unknow.rawValue {
  187. metadata.classFile = NKCommon.typeClassFile.document.rawValue
  188. }
  189. if let date = file.uploadDate {
  190. metadata.uploadDate = date
  191. } else {
  192. metadata.uploadDate = file.date
  193. }
  194. metadata.urlBase = file.urlBase
  195. metadata.user = file.user
  196. metadata.userId = file.userId
  197. // E2EE find the fileName for fileNameView
  198. if isDirectoryE2EE || file.e2eEncrypted {
  199. if let tableE2eEncryption = NCManageDatabase.shared.getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameIdentifier == %@", file.account, file.serverUrl, file.fileName)) {
  200. metadata.fileNameView = tableE2eEncryption.fileName
  201. let results = NKCommon.shared.getInternalType(fileName: metadata.fileNameView, mimeType: file.contentType, directory: file.directory)
  202. metadata.contentType = results.mimeType
  203. metadata.iconName = results.iconName
  204. metadata.classFile = results.classFile
  205. }
  206. }
  207. return metadata
  208. }
  209. @objc func convertFilesToMetadatas(_ files: [NKFile], useMetadataFolder: Bool, completion: @escaping (_ metadataFolder: tableMetadata, _ metadatasFolder: [tableMetadata], _ metadatas: [tableMetadata]) -> Void) {
  210. var counter: Int = 0
  211. var isDirectoryE2EE: Bool = false
  212. let listServerUrl = ThreadSafeDictionary<String,Bool>()
  213. var metadataFolder = tableMetadata()
  214. var metadataFolders: [tableMetadata] = []
  215. var metadatas: [tableMetadata] = []
  216. for file in files {
  217. if let key = listServerUrl[file.serverUrl] {
  218. isDirectoryE2EE = key
  219. } else {
  220. isDirectoryE2EE = NCUtility.shared.isDirectoryE2EE(file: file)
  221. listServerUrl[file.serverUrl] = isDirectoryE2EE
  222. }
  223. let metadata = convertFileToMetadata(file, isDirectoryE2EE: isDirectoryE2EE)
  224. if counter == 0 && useMetadataFolder {
  225. metadataFolder = tableMetadata.init(value: metadata)
  226. } else {
  227. metadatas.append(metadata)
  228. if metadata.directory {
  229. metadataFolders.append(metadata)
  230. }
  231. }
  232. counter += 1
  233. }
  234. //
  235. // Detect Live photo
  236. //
  237. var metadataOutput: [tableMetadata] = []
  238. metadatas = metadatas.sorted(by: {$0.fileNameView < $1.fileNameView})
  239. for index in metadatas.indices {
  240. let metadata = metadatas[index]
  241. if index < metadatas.count - 1,
  242. metadata.fileNoExtension == metadatas[index+1].fileNoExtension,
  243. ((metadata.classFile == NKCommon.typeClassFile.image.rawValue && metadatas[index+1].classFile == NKCommon.typeClassFile.video.rawValue) || (metadata.classFile == NKCommon.typeClassFile.video.rawValue && metadatas[index+1].classFile == NKCommon.typeClassFile.image.rawValue)){
  244. metadata.livePhoto = true
  245. metadatas[index+1].livePhoto = true
  246. }
  247. metadataOutput.append(metadata)
  248. }
  249. completion(metadataFolder, metadataFolders, metadataOutput)
  250. }
  251. @objc func createMetadata(account: String, user: String, userId: String, fileName: String, fileNameView: String, ocId: String, serverUrl: String, urlBase: String, url: String, contentType: String, isLivePhoto: Bool = false, isUrl: Bool = false, name: String = NCGlobal.shared.appName, subline: String? = nil, iconName: String? = nil, iconUrl: String? = nil) -> tableMetadata {
  252. let metadata = tableMetadata()
  253. if isUrl {
  254. metadata.contentType = "text/uri-list"
  255. if let iconName = iconName {
  256. metadata.iconName = iconName
  257. } else {
  258. metadata.iconName = NKCommon.typeIconFile.url.rawValue
  259. }
  260. metadata.classFile = NKCommon.typeClassFile.url.rawValue
  261. } else {
  262. let (mimeType, classFile, iconName, _, _, _) = NKCommon.shared.getInternalType(fileName: fileName, mimeType: contentType, directory: false)
  263. metadata.contentType = mimeType
  264. metadata.iconName = iconName
  265. metadata.classFile = classFile
  266. //FIXME: iOS 12.0,* don't detect UTI text/markdown, text/x-markdown
  267. if classFile == NKCommon.typeClassFile.unknow.rawValue && (mimeType == "text/x-markdown" || mimeType == "text/markdown") {
  268. metadata.iconName = NKCommon.typeIconFile.txt.rawValue
  269. metadata.classFile = NKCommon.typeClassFile.document.rawValue
  270. }
  271. }
  272. if let iconUrl = iconUrl {
  273. metadata.iconUrl = iconUrl
  274. }
  275. let fileName = fileName.trimmingCharacters(in: .whitespacesAndNewlines)
  276. metadata.account = account
  277. metadata.chunk = false
  278. metadata.creationDate = Date() as NSDate
  279. metadata.date = Date() as NSDate
  280. metadata.hasPreview = true
  281. metadata.etag = ocId
  282. metadata.fileName = fileName
  283. metadata.fileNameView = fileName
  284. metadata.livePhoto = isLivePhoto
  285. metadata.name = name
  286. metadata.ocId = ocId
  287. metadata.permissions = "RGDNVW"
  288. metadata.serverUrl = serverUrl
  289. metadata.subline = subline
  290. metadata.uploadDate = Date() as NSDate
  291. metadata.url = url
  292. metadata.urlBase = urlBase
  293. metadata.user = user
  294. metadata.userId = userId
  295. if !metadata.urlBase.isEmpty, metadata.serverUrl.hasPrefix(metadata.urlBase) {
  296. metadata.path = String(metadata.serverUrl.dropFirst(metadata.urlBase.count)) + "/"
  297. }
  298. return metadata
  299. }
  300. @discardableResult
  301. @objc func addMetadata(_ metadata: tableMetadata) -> tableMetadata? {
  302. let realm = try! Realm()
  303. let result = tableMetadata.init(value: metadata)
  304. do {
  305. try realm.write {
  306. realm.add(result, update: .all)
  307. }
  308. } catch let error {
  309. NKCommon.shared.writeLog("Could not write to database: \(error)")
  310. return nil
  311. }
  312. return tableMetadata.init(value: result)
  313. }
  314. @objc func addMetadatas(_ metadatas: [tableMetadata]) {
  315. let realm = try! Realm()
  316. do {
  317. try realm.write {
  318. for metadata in metadatas {
  319. realm.add(metadata, update: .all)
  320. }
  321. }
  322. } catch let error {
  323. NKCommon.shared.writeLog("Could not write to database: \(error)")
  324. }
  325. }
  326. @objc func deleteMetadata(predicate: NSPredicate) {
  327. let realm = try! Realm()
  328. do {
  329. try realm.write {
  330. let results = realm.objects(tableMetadata.self).filter(predicate)
  331. realm.delete(results)
  332. }
  333. } catch let error {
  334. NKCommon.shared.writeLog("Could not write to database: \(error)")
  335. }
  336. }
  337. @objc func moveMetadata(ocId: String, serverUrlTo: String) {
  338. let realm = try! Realm()
  339. do {
  340. try realm.write {
  341. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  342. result.serverUrl = serverUrlTo
  343. }
  344. }
  345. } catch let error {
  346. NKCommon.shared.writeLog("Could not write to database: \(error)")
  347. }
  348. }
  349. @objc func renameMetadata(fileNameTo: String, ocId: String) {
  350. let realm = try! Realm()
  351. do {
  352. try realm.write {
  353. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  354. let resultsType = NKCommon.shared.getInternalType(fileName: fileNameTo, mimeType: "", directory: result.directory)
  355. result.fileName = fileNameTo
  356. result.fileNameView = fileNameTo
  357. result.iconName = resultsType.iconName
  358. result.contentType = resultsType.mimeType
  359. result.classFile = resultsType.classFile
  360. }
  361. }
  362. } catch let error {
  363. NKCommon.shared.writeLog("Could not write to database: \(error)")
  364. }
  365. }
  366. @discardableResult
  367. func updateMetadatas(_ metadatas: [tableMetadata], metadatasResult: [tableMetadata], addCompareLivePhoto: Bool = true, addExistsInLocal: Bool = false, addCompareEtagLocal: Bool = false, addDirectorySynchronized: Bool = false) -> (metadatasUpdate: [tableMetadata], metadatasLocalUpdate: [tableMetadata], metadatasDelete: [tableMetadata]) {
  368. let realm = try! Realm()
  369. var ocIdsUdate: [String] = []
  370. var ocIdsLocalUdate: [String] = []
  371. var metadatasDelete: [tableMetadata] = []
  372. var metadatasUpdate: [tableMetadata] = []
  373. var metadatasLocalUpdate: [tableMetadata] = []
  374. do {
  375. try realm.write {
  376. // DELETE
  377. for metadataResult in metadatasResult {
  378. if metadatas.firstIndex(where: { $0.ocId == metadataResult.ocId }) == nil {
  379. if let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@", metadataResult.ocId)).first {
  380. metadatasDelete.append(tableMetadata.init(value: result))
  381. realm.delete(result)
  382. }
  383. }
  384. }
  385. // UPDATE/NEW
  386. for metadata in metadatas {
  387. if let result = metadatasResult.first(where: { $0.ocId == metadata.ocId }) {
  388. // update
  389. // Workaround: check lock bc no etag changes if lock runs out in directory
  390. // https://github.com/nextcloud/server/issues/8477
  391. 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 || result.lock != metadata.lock || result.shareType != metadata.shareType || result.sharePermissionsCloudMesh != metadata.sharePermissionsCloudMesh || result.sharePermissionsCollaborationServices != metadata.sharePermissionsCollaborationServices || result.favorite != metadata.favorite) {
  392. ocIdsUdate.append(metadata.ocId)
  393. realm.add(tableMetadata.init(value: metadata), update: .all)
  394. } else if result.status == NCGlobal.shared.metadataStatusNormal && addCompareLivePhoto && result.livePhoto != metadata.livePhoto {
  395. ocIdsUdate.append(metadata.ocId)
  396. realm.add(tableMetadata.init(value: metadata), update: .all)
  397. }
  398. } else {
  399. // new
  400. ocIdsUdate.append(metadata.ocId)
  401. realm.add(tableMetadata.init(value: metadata), update: .all)
  402. }
  403. if metadata.directory && !ocIdsUdate.contains(metadata.ocId) {
  404. let table = realm.objects(tableDirectory.self).filter(NSPredicate(format: "ocId == %@", metadata.ocId)).first
  405. if table?.etag != metadata.etag {
  406. ocIdsUdate.append(metadata.ocId)
  407. }
  408. }
  409. // Local
  410. if !metadata.directory && (addExistsInLocal || addCompareEtagLocal) {
  411. let localFile = realm.objects(tableLocalFile.self).filter(NSPredicate(format: "ocId == %@", metadata.ocId)).first
  412. if addCompareEtagLocal && localFile != nil && localFile?.etag != metadata.etag {
  413. ocIdsLocalUdate.append(metadata.ocId)
  414. }
  415. if addExistsInLocal && (localFile == nil || localFile?.etag != metadata.etag) && !ocIdsLocalUdate.contains(metadata.ocId) {
  416. ocIdsLocalUdate.append(metadata.ocId)
  417. }
  418. }
  419. }
  420. }
  421. } catch let error {
  422. NKCommon.shared.writeLog("Could not write to database: \(error)")
  423. }
  424. for ocId in ocIdsUdate {
  425. if let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@", ocId)).first {
  426. metadatasUpdate.append(tableMetadata.init(value: result))
  427. }
  428. }
  429. for ocId in ocIdsLocalUdate {
  430. if let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@", ocId)).first {
  431. metadatasLocalUpdate.append(tableMetadata.init(value: result))
  432. }
  433. }
  434. return (metadatasUpdate, metadatasLocalUpdate, metadatasDelete)
  435. }
  436. func setMetadataSession(ocId: String, newFileName: String? = nil, session: String? = nil, sessionError: String? = nil, sessionSelector: String? = nil, sessionTaskIdentifier: Int? = nil, status: Int? = nil, etag: String? = nil) {
  437. let realm = try! Realm()
  438. do {
  439. try realm.write {
  440. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  441. if let newFileName = newFileName {
  442. result?.fileName = newFileName
  443. result?.fileNameView = newFileName
  444. }
  445. if let session = session {
  446. result?.session = session
  447. }
  448. if let sessionError = sessionError {
  449. result?.sessionError = sessionError
  450. }
  451. if let sessionSelector = sessionSelector {
  452. result?.sessionSelector = sessionSelector
  453. }
  454. if let sessionTaskIdentifier = sessionTaskIdentifier {
  455. result?.sessionTaskIdentifier = sessionTaskIdentifier
  456. }
  457. if let status = status {
  458. result?.status = status
  459. }
  460. if let etag = etag {
  461. result?.etag = etag
  462. }
  463. }
  464. } catch let error {
  465. NKCommon.shared.writeLog("Could not write to database: \(error)")
  466. }
  467. }
  468. @discardableResult
  469. func setMetadataStatus(ocId: String, status: Int) -> tableMetadata? {
  470. let realm = try! Realm()
  471. var result: tableMetadata?
  472. do {
  473. try realm.write {
  474. result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  475. result?.status = status
  476. }
  477. } catch let error {
  478. NKCommon.shared.writeLog("Could not write to database: \(error)")
  479. }
  480. if let result = result {
  481. return tableMetadata.init(value: result)
  482. } else {
  483. return nil
  484. }
  485. }
  486. func setMetadataEtagResource(ocId: String, etagResource: String?) {
  487. let realm = try! Realm()
  488. var result: tableMetadata?
  489. guard let etagResource = etagResource else { return }
  490. do {
  491. try realm.write {
  492. result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  493. result?.etagResource = etagResource
  494. }
  495. } catch let error {
  496. NKCommon.shared.writeLog("Could not write to database: \(error)")
  497. }
  498. }
  499. @objc func setMetadataFavorite(ocId: String, favorite: Bool) {
  500. let realm = try! Realm()
  501. do {
  502. try realm.write {
  503. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  504. result?.favorite = favorite
  505. }
  506. } catch let error {
  507. NKCommon.shared.writeLog("Could not write to database: \(error)")
  508. }
  509. }
  510. @objc func updateMetadatasFavorite(account: String, metadatas: [tableMetadata]) {
  511. let realm = try! Realm()
  512. do {
  513. try realm.write {
  514. let results = realm.objects(tableMetadata.self).filter("account == %@ AND favorite == true", account)
  515. for result in results {
  516. result.favorite = false
  517. }
  518. for metadata in metadatas {
  519. realm.add(metadata, update: .all)
  520. }
  521. }
  522. } catch let error {
  523. NKCommon.shared.writeLog("Could not write to database: \(error)")
  524. }
  525. }
  526. @objc func setMetadataEncrypted(ocId: String, encrypted: Bool) {
  527. let realm = try! Realm()
  528. do {
  529. try realm.write {
  530. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  531. result?.e2eEncrypted = encrypted
  532. }
  533. } catch let error {
  534. NKCommon.shared.writeLog("Could not write to database: \(error)")
  535. }
  536. }
  537. @objc func setMetadataFileNameView(serverUrl: String, fileName: String, newFileNameView: String, account: String) {
  538. let realm = try! Realm()
  539. do {
  540. try realm.write {
  541. let result = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName == %@", account, serverUrl, fileName).first
  542. result?.fileNameView = newFileNameView
  543. }
  544. } catch let error {
  545. NKCommon.shared.writeLog("Could not write to database: \(error)")
  546. }
  547. }
  548. @objc func getMetadata(predicate: NSPredicate) -> tableMetadata? {
  549. let realm = try! Realm()
  550. realm.refresh()
  551. guard let result = realm.objects(tableMetadata.self).filter(predicate).first else {
  552. return nil
  553. }
  554. return tableMetadata.init(value: result)
  555. }
  556. @objc func getMetadata(predicate: NSPredicate, sorted: String, ascending: Bool) -> tableMetadata? {
  557. let realm = try! Realm()
  558. realm.refresh()
  559. guard let result = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending).first else {
  560. return nil
  561. }
  562. return tableMetadata.init(value: result)
  563. }
  564. @objc func getMetadatasViewer(predicate: NSPredicate, sorted: String, ascending: Bool) -> [tableMetadata]? {
  565. let realm = try! Realm()
  566. realm.refresh()
  567. let results: Results<tableMetadata>
  568. var finals: [tableMetadata] = []
  569. if (tableMetadata().objectSchema.properties.contains { $0.name == sorted }) {
  570. results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  571. } else {
  572. results = realm.objects(tableMetadata.self).filter(predicate)
  573. }
  574. // For Live Photo
  575. var fileNameImages: [String] = []
  576. let filtered = results.filter { $0.classFile.contains(NKCommon.typeClassFile.image.rawValue) }
  577. filtered.forEach { print($0)
  578. let fileName = ($0.fileNameView as NSString).deletingPathExtension
  579. fileNameImages.append(fileName)
  580. }
  581. for result in results {
  582. let ext = (result.fileNameView as NSString).pathExtension.uppercased()
  583. let fileName = (result.fileNameView as NSString).deletingPathExtension
  584. if !(ext == "MOV" && fileNameImages.contains(fileName)) {
  585. finals.append(result)
  586. }
  587. }
  588. if finals.count > 0 {
  589. return Array(finals.map { tableMetadata.init(value: $0) })
  590. } else {
  591. return nil
  592. }
  593. }
  594. @objc func getMetadatas(predicate: NSPredicate) -> [tableMetadata] {
  595. let realm = try! Realm()
  596. realm.refresh()
  597. let results = realm.objects(tableMetadata.self).filter(predicate)
  598. return Array(results.map { tableMetadata.init(value: $0) })
  599. }
  600. @objc func getAdvancedMetadatas(predicate: NSPredicate, page: Int = 0, limit: Int = 0, sorted: String, ascending: Bool) -> [tableMetadata] {
  601. let realm = try! Realm()
  602. realm.refresh()
  603. var metadatas: [tableMetadata] = []
  604. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  605. if results.count > 0 {
  606. if page == 0 || limit == 0 {
  607. return Array(results.map { tableMetadata.init(value: $0) })
  608. } else {
  609. let nFrom = (page - 1) * limit
  610. let nTo = nFrom + (limit - 1)
  611. for n in nFrom...nTo {
  612. if n == results.count {
  613. break
  614. }
  615. metadatas.append(tableMetadata.init(value: results[n]))
  616. }
  617. }
  618. }
  619. return metadatas
  620. }
  621. @objc func getMetadataAtIndex(predicate: NSPredicate, sorted: String, ascending: Bool, index: Int) -> tableMetadata? {
  622. let realm = try! Realm()
  623. realm.refresh()
  624. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  625. if results.count > 0 && results.count > index {
  626. return tableMetadata.init(value: results[index])
  627. } else {
  628. return nil
  629. }
  630. }
  631. @objc func getMetadataFromOcId(_ ocId: String?) -> tableMetadata? {
  632. let realm = try! Realm()
  633. realm.refresh()
  634. guard let ocId = ocId else { return nil }
  635. guard let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first else { return nil }
  636. return tableMetadata.init(value: result)
  637. }
  638. @objc func getMetadataFolder(account: String, urlBase: String, userId: String, serverUrl: String) -> tableMetadata? {
  639. let realm = try! Realm()
  640. realm.refresh()
  641. var serverUrl = serverUrl
  642. var fileName = ""
  643. let serverUrlHome = NCUtilityFileSystem.shared.getHomeServer(urlBase: urlBase, userId: userId)
  644. if serverUrlHome == serverUrl {
  645. fileName = "."
  646. serverUrl = ".."
  647. } else {
  648. fileName = (serverUrl as NSString).lastPathComponent
  649. if let path = NCUtilityFileSystem.shared.deleteLastPath(serverUrlPath: serverUrl) {
  650. serverUrl = path
  651. }
  652. }
  653. guard let result = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName == %@", account, serverUrl, fileName).first else { return nil }
  654. return tableMetadata.init(value: result)
  655. }
  656. @objc func getTableMetadatasDirectoryFavoriteIdentifierRank(account: String) -> [String: NSNumber] {
  657. var listIdentifierRank: [String: NSNumber] = [:]
  658. let realm = try! Realm()
  659. var counter = 10 as Int64
  660. let results = realm.objects(tableMetadata.self).filter("account == %@ AND directory == true AND favorite == true", account).sorted(byKeyPath: "fileNameView", ascending: true)
  661. for result in results {
  662. counter += 1
  663. listIdentifierRank[result.ocId] = NSNumber(value: Int64(counter))
  664. }
  665. return listIdentifierRank
  666. }
  667. @objc func clearMetadatasUpload(account: String) {
  668. let realm = try! Realm()
  669. realm.refresh()
  670. do {
  671. try realm.write {
  672. let results = realm.objects(tableMetadata.self).filter("account == %@ AND (status == %d OR status == %@)", account, NCGlobal.shared.metadataStatusWaitUpload, NCGlobal.shared.metadataStatusUploadError)
  673. realm.delete(results)
  674. }
  675. } catch let error {
  676. NKCommon.shared.writeLog("Could not write to database: \(error)")
  677. }
  678. }
  679. @objc func readMarkerMetadata(account: String, fileId: String) {
  680. let realm = try! Realm()
  681. do {
  682. try realm.write {
  683. let results = realm.objects(tableMetadata.self).filter("account == %@ AND fileId == %@", account, fileId)
  684. for result in results {
  685. result.commentsUnread = false
  686. }
  687. }
  688. } catch let error {
  689. NKCommon.shared.writeLog("Could not write to database: \(error)")
  690. }
  691. }
  692. @objc func getAssetLocalIdentifiersUploaded(account: String) -> [String] {
  693. let realm = try! Realm()
  694. realm.refresh()
  695. var assetLocalIdentifiers: [String] = []
  696. let results = realm.objects(tableMetadata.self).filter("account == %@ AND assetLocalIdentifier != '' AND deleteAssetLocalIdentifier == true", account)
  697. for result in results {
  698. assetLocalIdentifiers.append(result.assetLocalIdentifier)
  699. }
  700. return assetLocalIdentifiers
  701. }
  702. @objc func clearAssetLocalIdentifiers(_ assetLocalIdentifiers: [String], account: String) {
  703. let realm = try! Realm()
  704. do {
  705. try realm.write {
  706. let results = realm.objects(tableMetadata.self).filter("account == %@ AND assetLocalIdentifier IN %@", account, assetLocalIdentifiers)
  707. for result in results {
  708. result.assetLocalIdentifier = ""
  709. result.deleteAssetLocalIdentifier = false
  710. }
  711. }
  712. } catch let error {
  713. NKCommon.shared.writeLog("Could not write to database: \(error)")
  714. }
  715. }
  716. @objc func getMetadataLivePhoto(metadata: tableMetadata) -> tableMetadata? {
  717. let realm = try! Realm()
  718. var classFile = metadata.classFile
  719. var fileName = (metadata.fileNameView as NSString).deletingPathExtension
  720. if !metadata.livePhoto || !CCUtility.getLivePhoto() {
  721. return nil
  722. }
  723. if classFile == NKCommon.typeClassFile.image.rawValue {
  724. classFile = NKCommon.typeClassFile.video.rawValue
  725. fileName = fileName + ".mov"
  726. } else {
  727. classFile = NKCommon.typeClassFile.image.rawValue
  728. fileName = fileName + ".jpg"
  729. }
  730. guard let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameView CONTAINS[cd] %@ AND ocId != %@ AND classFile == %@", metadata.account, metadata.serverUrl, fileName, metadata.ocId, classFile)).first else {
  731. return nil
  732. }
  733. return tableMetadata.init(value: result)
  734. }
  735. func getMetadatasMedia(predicate: NSPredicate, livePhoto: Bool) -> [tableMetadata] {
  736. let realm = try! Realm()
  737. var metadatas: [tableMetadata] = []
  738. do {
  739. try realm.write {
  740. let sortProperties = [SortDescriptor(keyPath: "serverUrl", ascending: false), SortDescriptor(keyPath: "fileNameView", ascending: false)]
  741. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(by: sortProperties)
  742. if livePhoto {
  743. for index in results.indices {
  744. let metadata = results[index]
  745. if index < results.count - 1, metadata.fileNoExtension == results[index+1].fileNoExtension {
  746. if !metadata.livePhoto {
  747. metadata.livePhoto = true
  748. }
  749. if !results[index+1].livePhoto {
  750. results[index+1].livePhoto = true
  751. }
  752. }
  753. if metadata.livePhoto {
  754. if metadata.classFile == NKCommon.typeClassFile.image.rawValue {
  755. metadatas.append(tableMetadata.init(value: metadata))
  756. }
  757. continue
  758. } else {
  759. metadatas.append(tableMetadata.init(value: metadata))
  760. }
  761. }
  762. } else {
  763. metadatas = Array(results.map { tableMetadata.init(value: $0) })
  764. }
  765. }
  766. } catch let error {
  767. NKCommon.shared.writeLog("Could not write to database: \(error)")
  768. }
  769. return metadatas
  770. }
  771. func isMetadataShareOrMounted(metadata: tableMetadata, metadataFolder: tableMetadata?) -> Bool {
  772. var isShare = false
  773. var isMounted = false
  774. if metadataFolder != nil {
  775. isShare = metadata.permissions.contains(NCGlobal.shared.permissionShared) && !metadataFolder!.permissions.contains(NCGlobal.shared.permissionShared)
  776. isMounted = metadata.permissions.contains(NCGlobal.shared.permissionMounted) && !metadataFolder!.permissions.contains(NCGlobal.shared.permissionMounted)
  777. } else if let directory = NCManageDatabase.shared.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, metadata.serverUrl)) {
  778. isShare = metadata.permissions.contains(NCGlobal.shared.permissionShared) && !directory.permissions.contains(NCGlobal.shared.permissionShared)
  779. isMounted = metadata.permissions.contains(NCGlobal.shared.permissionMounted) && !directory.permissions.contains(NCGlobal.shared.permissionMounted)
  780. }
  781. if isShare || isMounted {
  782. return true
  783. } else {
  784. return false
  785. }
  786. }
  787. func isDownloadMetadata(_ metadata: tableMetadata, download: Bool) -> Bool {
  788. let localFile = getTableLocalFile(predicate: NSPredicate(format: "ocId == %@", metadata.ocId))
  789. let fileSize = CCUtility.fileProviderStorageSize(metadata.ocId, fileNameView: metadata.fileNameView)
  790. if (localFile != nil || download) && (localFile?.etag != metadata.etag || fileSize == 0) {
  791. return true
  792. }
  793. return false
  794. }
  795. func getMetadataConflict(account: String, serverUrl: String, fileNameView: String) -> tableMetadata? {
  796. // verify exists conflict
  797. let fileNameExtension = (fileNameView as NSString).pathExtension.lowercased()
  798. let fileNameNoExtension = (fileNameView as NSString).deletingPathExtension
  799. var fileNameConflict = fileNameView
  800. if fileNameExtension == "heic" && CCUtility.getFormatCompatibility() {
  801. fileNameConflict = fileNameNoExtension + ".jpg"
  802. }
  803. return getMetadata(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameView == %@", account, serverUrl, fileNameConflict))
  804. }
  805. func getSubtitles(account: String, serverUrl: String, fileName: String) -> (all:[tableMetadata], existing:[tableMetadata]) {
  806. let realm = try! Realm()
  807. let nameOnly = (fileName as NSString).deletingPathExtension + "."
  808. var metadatas: [tableMetadata] = []
  809. let results = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName BEGINSWITH[c] %@ AND fileName ENDSWITH[c] '.srt'", account, serverUrl, nameOnly)
  810. for result in results {
  811. if CCUtility.fileProviderStorageExists(result) {
  812. metadatas.append(result)
  813. }
  814. }
  815. return(Array(results.map { tableMetadata.init(value: $0) }), Array(metadatas.map { tableMetadata.init(value: $0) }))
  816. }
  817. func getNumMetadatasInUpload() -> Int {
  818. let realm = try! Realm()
  819. let num = realm.objects(tableMetadata.self).filter(NSPredicate(format: "status == %i || status == %i", NCGlobal.shared.metadataStatusInUpload, NCGlobal.shared.metadataStatusUploading)).count
  820. return num
  821. }
  822. }