NCManageDatabase+Metadata.swift 42 KB

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