NCManageDatabase+Metadata.swift 44 KB

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