NCManageDatabase+Metadata.swift 52 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242
  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 UIKit
  25. import RealmSwift
  26. import NextcloudKit
  27. class tableMetadata: Object {
  28. override func isEqual(_ object: Any?) -> Bool {
  29. if let object = object as? tableMetadata,
  30. self.account == object.account,
  31. self.etag == object.etag,
  32. self.fileId == object.fileId,
  33. self.path == object.path,
  34. self.fileName == object.fileName,
  35. self.fileNameView == object.fileNameView,
  36. self.date == object.date,
  37. self.datePhotosOriginal == object.datePhotosOriginal,
  38. self.permissions == object.permissions,
  39. self.hasPreview == object.hasPreview,
  40. self.note == object.note,
  41. self.lock == object.lock,
  42. self.favorite == object.favorite,
  43. self.livePhotoFile == object.livePhotoFile,
  44. self.sharePermissionsCollaborationServices == object.sharePermissionsCollaborationServices,
  45. self.height == object.height,
  46. self.width == object.width,
  47. self.latitude == object.latitude,
  48. self.longitude == object.longitude,
  49. self.altitude == object.altitude,
  50. self.status == object.status,
  51. Array(self.tags).elementsEqual(Array(object.tags)),
  52. Array(self.shareType).elementsEqual(Array(object.shareType)),
  53. Array(self.sharePermissionsCloudMesh).elementsEqual(Array(object.sharePermissionsCloudMesh)) {
  54. return true
  55. } else {
  56. return false
  57. }
  58. }
  59. @objc dynamic var account = ""
  60. @objc dynamic var assetLocalIdentifier = ""
  61. @objc dynamic var checksums = ""
  62. @objc dynamic var chunk: Int = 0
  63. @objc dynamic var classFile = ""
  64. @objc dynamic var commentsUnread: Bool = false
  65. @objc dynamic var contentType = ""
  66. @objc dynamic var creationDate = NSDate()
  67. @objc dynamic var dataFingerprint = ""
  68. @objc dynamic var date = NSDate()
  69. @objc dynamic var datePhotosOriginal = NSDate()
  70. @objc dynamic var directory: Bool = false
  71. @objc dynamic var downloadURL = ""
  72. @objc dynamic var e2eEncrypted: Bool = false
  73. @objc dynamic var edited: Bool = false
  74. @objc dynamic var etag = ""
  75. @objc dynamic var etagResource = ""
  76. let exifPhotos = List<NCKeyValue>()
  77. @objc dynamic var favorite: Bool = false
  78. @objc dynamic var fileId = ""
  79. @objc dynamic var fileName = ""
  80. @objc dynamic var fileNameView = ""
  81. @objc dynamic var hasPreview: Bool = false
  82. @objc dynamic var hidden: Bool = false
  83. @objc dynamic var iconName = ""
  84. @objc dynamic var iconUrl = ""
  85. @objc dynamic var isFlaggedAsLivePhotoByServer: Bool = false // Indicating if the file is sent as a live photo from the server, or if we should detect it as such and convert it client-side
  86. @objc dynamic var isExtractFile: Bool = false
  87. @objc dynamic var livePhotoFile = "" // If this is not empty, the media is a live photo. New media gets this straight from server, but old media needs to be detected as live photo (look isFlaggedAsLivePhotoByServer)
  88. @objc dynamic var mountType = ""
  89. @objc dynamic var name = "" // for unifiedSearch is the provider.id
  90. @objc dynamic var note = ""
  91. @objc dynamic var ocId = ""
  92. @objc dynamic var ocIdTransfer = ""
  93. @objc dynamic var ownerId = ""
  94. @objc dynamic var ownerDisplayName = ""
  95. @objc public var lock = false
  96. @objc public var lockOwner = ""
  97. @objc public var lockOwnerEditor = ""
  98. @objc public var lockOwnerType = 0
  99. @objc public var lockOwnerDisplayName = ""
  100. @objc public var lockTime: Date?
  101. @objc public var lockTimeOut: Date?
  102. @objc dynamic var path = ""
  103. @objc dynamic var permissions = ""
  104. @objc dynamic var placePhotos: String?
  105. @objc dynamic var quotaUsedBytes: Int64 = 0
  106. @objc dynamic var quotaAvailableBytes: Int64 = 0
  107. @objc dynamic var resourceType = ""
  108. @objc dynamic var richWorkspace: String?
  109. @objc dynamic var sceneIdentifier: String?
  110. @objc dynamic var serverUrl = ""
  111. @objc dynamic var serveUrlFileName = ""
  112. @objc dynamic var serverUrlTo = ""
  113. @objc dynamic var session = ""
  114. @objc dynamic var sessionDate: Date?
  115. @objc dynamic var sessionError = ""
  116. @objc dynamic var sessionSelector = ""
  117. @objc dynamic var sessionTaskIdentifier: Int = 0
  118. @objc dynamic var sharePermissionsCollaborationServices: Int = 0
  119. let sharePermissionsCloudMesh = List<String>()
  120. let shareType = List<Int>()
  121. @objc dynamic var size: Int64 = 0
  122. @objc dynamic var status: Int = 0
  123. @objc dynamic var storeFlag: String?
  124. @objc dynamic var subline: String?
  125. let tags = List<String>()
  126. @objc dynamic var trashbinFileName = ""
  127. @objc dynamic var trashbinOriginalLocation = ""
  128. @objc dynamic var trashbinDeletionTime = NSDate()
  129. @objc dynamic var uploadDate = NSDate()
  130. @objc dynamic var url = ""
  131. @objc dynamic var urlBase = ""
  132. @objc dynamic var user = ""
  133. @objc dynamic var userId = ""
  134. @objc dynamic var latitude: Double = 0
  135. @objc dynamic var longitude: Double = 0
  136. @objc dynamic var altitude: Double = 0
  137. @objc dynamic var height: Int = 0
  138. @objc dynamic var width: Int = 0
  139. @objc dynamic var errorCode: Int = 0
  140. override static func primaryKey() -> String {
  141. return "ocId"
  142. }
  143. }
  144. extension tableMetadata {
  145. var fileExtension: String {
  146. (fileNameView as NSString).pathExtension
  147. }
  148. var fileNoExtension: String {
  149. (fileNameView as NSString).deletingPathExtension
  150. }
  151. var isRenameable: Bool {
  152. if lock {
  153. return false
  154. }
  155. if !isDirectoryE2EE && e2eEncrypted {
  156. return false
  157. }
  158. return true
  159. }
  160. var isPrintable: Bool {
  161. if isDocumentViewableOnly {
  162. return false
  163. }
  164. if ["application/pdf", "com.adobe.pdf"].contains(contentType) || contentType.hasPrefix("text/") || classFile == NKCommon.TypeClassFile.image.rawValue {
  165. return true
  166. }
  167. return false
  168. }
  169. var isSavebleInCameraRoll: Bool {
  170. return (classFile == NKCommon.TypeClassFile.image.rawValue && contentType != "image/svg+xml") || classFile == NKCommon.TypeClassFile.video.rawValue
  171. }
  172. var isDocumentViewableOnly: Bool {
  173. sharePermissionsCollaborationServices == NCPermissions().permissionReadShare && classFile == NKCommon.TypeClassFile.document.rawValue
  174. }
  175. var isAudioOrVideo: Bool {
  176. return classFile == NKCommon.TypeClassFile.audio.rawValue || classFile == NKCommon.TypeClassFile.video.rawValue
  177. }
  178. var isImageOrVideo: Bool {
  179. return classFile == NKCommon.TypeClassFile.image.rawValue || classFile == NKCommon.TypeClassFile.video.rawValue
  180. }
  181. var isVideo: Bool {
  182. return classFile == NKCommon.TypeClassFile.video.rawValue
  183. }
  184. var isAudio: Bool {
  185. return classFile == NKCommon.TypeClassFile.audio.rawValue
  186. }
  187. var isImage: Bool {
  188. return classFile == NKCommon.TypeClassFile.image.rawValue
  189. }
  190. var isSavebleAsImage: Bool {
  191. classFile == NKCommon.TypeClassFile.image.rawValue && contentType != "image/svg+xml"
  192. }
  193. var isCopyableInPasteboard: Bool {
  194. !isDocumentViewableOnly && !directory
  195. }
  196. var isCopyableMovable: Bool {
  197. !isDocumentViewableOnly && !isDirectoryE2EE && !e2eEncrypted
  198. }
  199. var isModifiableWithQuickLook: Bool {
  200. if directory || isDocumentViewableOnly || isDirectoryE2EE {
  201. return false
  202. }
  203. return isPDF || isImage
  204. }
  205. var isDeletable: Bool {
  206. if !isDirectoryE2EE && e2eEncrypted {
  207. return false
  208. }
  209. return true
  210. }
  211. var canSetAsAvailableOffline: Bool {
  212. return session.isEmpty && !isDirectoryE2EE && !e2eEncrypted
  213. }
  214. var canShare: Bool {
  215. return session.isEmpty && !isDocumentViewableOnly && !directory && !NCBrandOptions.shared.disable_openin_file
  216. }
  217. var canSetDirectoryAsE2EE: Bool {
  218. return directory && size == 0 && !e2eEncrypted && NCKeychain().isEndToEndEnabled(account: account)
  219. }
  220. var canUnsetDirectoryAsE2EE: Bool {
  221. return !isDirectoryE2EE && directory && size == 0 && e2eEncrypted && NCKeychain().isEndToEndEnabled(account: account)
  222. }
  223. var isDownload: Bool {
  224. status == NCGlobal.shared.metadataStatusWaitDownload || status == NCGlobal.shared.metadataStatusDownloading
  225. }
  226. var isUpload: Bool {
  227. status == NCGlobal.shared.metadataStatusWaitUpload || status == NCGlobal.shared.metadataStatusUploading
  228. }
  229. @objc var isDirectoryE2EE: Bool {
  230. let session = NCSession.Session(account: account, urlBase: urlBase, user: user, userId: userId)
  231. return NCUtilityFileSystem().isDirectoryE2EE(session: session, serverUrl: serverUrl)
  232. }
  233. var isDirectoryE2EETop: Bool {
  234. NCUtilityFileSystem().isDirectoryE2EETop(account: account, serverUrl: serverUrl)
  235. }
  236. var isLivePhoto: Bool {
  237. !livePhotoFile.isEmpty
  238. }
  239. var isNotFlaggedAsLivePhotoByServer: Bool {
  240. !isFlaggedAsLivePhotoByServer
  241. }
  242. var imageSize: CGSize {
  243. CGSize(width: width, height: height)
  244. }
  245. var hasPreviewBorder: Bool {
  246. !isImage && !isAudioOrVideo && hasPreview && NCUtilityFileSystem().fileProviderStorageImageExists(ocId, etag: etag, ext: NCGlobal.shared.previewExt1024)
  247. }
  248. var isAvailableEditorView: Bool {
  249. guard !isPDF,
  250. classFile == NKCommon.TypeClassFile.document.rawValue,
  251. NextcloudKit.shared.isNetworkReachable() else { return false }
  252. let utility = NCUtility()
  253. let directEditingEditors = utility.editorsDirectEditing(account: account, contentType: contentType)
  254. let richDocumentEditor = utility.isTypeFileRichDocument(self)
  255. if NCCapabilities.shared.getCapabilities(account: account).capabilityRichDocumentsEnabled && richDocumentEditor && directEditingEditors.isEmpty {
  256. // RichDocument: Collabora
  257. return true
  258. } else if directEditingEditors.contains(NCGlobal.shared.editorText) || directEditingEditors.contains(NCGlobal.shared.editorOnlyoffice) {
  259. // DirectEditing: Nextcloud Text - OnlyOffice
  260. return true
  261. }
  262. return false
  263. }
  264. var isAvailableRichDocumentEditorView: Bool {
  265. guard (classFile == NKCommon.TypeClassFile.document.rawValue),
  266. NCCapabilities.shared.getCapabilities(account: account).capabilityRichDocumentsEnabled,
  267. NextcloudKit.shared.isNetworkReachable() else { return false }
  268. if NCUtility().isTypeFileRichDocument(self) {
  269. return true
  270. }
  271. return false
  272. }
  273. var isAvailableDirectEditingEditorView: Bool {
  274. guard (classFile == NKCommon.TypeClassFile.document.rawValue) && NextcloudKit.shared.isNetworkReachable() else { return false }
  275. let editors = NCUtility().editorsDirectEditing(account: account, contentType: contentType)
  276. if editors.contains(NCGlobal.shared.editorText) || editors.contains(NCGlobal.shared.editorOnlyoffice) {
  277. return true
  278. }
  279. return false
  280. }
  281. var isPDF: Bool {
  282. return (contentType == "application/pdf" || contentType == "com.adobe.pdf")
  283. }
  284. /// Returns false if the user is lokced out of the file. I.e. The file is locked but by somone else
  285. func canUnlock(as user: String) -> Bool {
  286. return !lock || (lockOwner == user && lockOwnerType == 0)
  287. }
  288. // Return if is sharable
  289. func isSharable() -> Bool {
  290. if !NCCapabilities.shared.getCapabilities(account: account).capabilityFileSharingApiEnabled || (NCCapabilities.shared.getCapabilities(account: account).capabilityE2EEEnabled && isDirectoryE2EE) {
  291. return false
  292. }
  293. return true
  294. }
  295. }
  296. extension NCManageDatabase {
  297. func convertFileToMetadata(_ file: NKFile, isDirectoryE2EE: Bool) -> tableMetadata {
  298. let metadata = tableMetadata()
  299. metadata.account = file.account
  300. metadata.checksums = file.checksums
  301. metadata.commentsUnread = file.commentsUnread
  302. metadata.contentType = file.contentType
  303. if let date = file.creationDate {
  304. metadata.creationDate = date as NSDate
  305. } else {
  306. metadata.creationDate = file.date as NSDate
  307. }
  308. metadata.dataFingerprint = file.dataFingerprint
  309. metadata.date = file.date as NSDate
  310. if let datePhotosOriginal = file.datePhotosOriginal {
  311. metadata.datePhotosOriginal = datePhotosOriginal as NSDate
  312. } else {
  313. metadata.datePhotosOriginal = metadata.date
  314. }
  315. metadata.directory = file.directory
  316. metadata.downloadURL = file.downloadURL
  317. metadata.e2eEncrypted = file.e2eEncrypted
  318. metadata.etag = file.etag
  319. for dict in file.exifPhotos {
  320. for (key, value) in dict {
  321. let keyValue = NCKeyValue()
  322. keyValue.key = key
  323. keyValue.value = value
  324. metadata.exifPhotos.append(keyValue)
  325. }
  326. }
  327. metadata.favorite = file.favorite
  328. metadata.fileId = file.fileId
  329. metadata.fileName = file.fileName
  330. metadata.fileNameView = file.fileName
  331. metadata.hasPreview = file.hasPreview
  332. metadata.hidden = file.hidden
  333. metadata.iconName = file.iconName
  334. metadata.mountType = file.mountType
  335. metadata.name = file.name
  336. metadata.note = file.note
  337. metadata.ocId = file.ocId
  338. metadata.ocIdTransfer = file.ocId
  339. metadata.ownerId = file.ownerId
  340. metadata.ownerDisplayName = file.ownerDisplayName
  341. metadata.lock = file.lock
  342. metadata.lockOwner = file.lockOwner
  343. metadata.lockOwnerEditor = file.lockOwnerEditor
  344. metadata.lockOwnerType = file.lockOwnerType
  345. metadata.lockOwnerDisplayName = file.lockOwnerDisplayName
  346. metadata.lockTime = file.lockTime
  347. metadata.lockTimeOut = file.lockTimeOut
  348. metadata.path = file.path
  349. metadata.permissions = file.permissions
  350. metadata.placePhotos = file.placePhotos
  351. metadata.quotaUsedBytes = file.quotaUsedBytes
  352. metadata.quotaAvailableBytes = file.quotaAvailableBytes
  353. metadata.richWorkspace = file.richWorkspace
  354. metadata.resourceType = file.resourceType
  355. metadata.serverUrl = file.serverUrl
  356. metadata.serveUrlFileName = file.serverUrl + "/" + file.fileName
  357. metadata.sharePermissionsCollaborationServices = file.sharePermissionsCollaborationServices
  358. for element in file.sharePermissionsCloudMesh {
  359. metadata.sharePermissionsCloudMesh.append(element)
  360. }
  361. for element in file.shareType {
  362. metadata.shareType.append(element)
  363. }
  364. for element in file.tags {
  365. metadata.tags.append(element)
  366. }
  367. metadata.size = file.size
  368. metadata.classFile = file.classFile
  369. // iOS 12.0,* don't detect UTI text/markdown, text/x-markdown
  370. if (metadata.contentType == "text/markdown" || metadata.contentType == "text/x-markdown") && metadata.classFile == NKCommon.TypeClassFile.unknow.rawValue {
  371. metadata.classFile = NKCommon.TypeClassFile.document.rawValue
  372. }
  373. if let date = file.uploadDate {
  374. metadata.uploadDate = date as NSDate
  375. } else {
  376. metadata.uploadDate = file.date as NSDate
  377. }
  378. metadata.urlBase = file.urlBase
  379. metadata.user = file.user
  380. metadata.userId = file.userId
  381. metadata.latitude = file.latitude
  382. metadata.longitude = file.longitude
  383. metadata.altitude = file.altitude
  384. metadata.height = Int(file.height)
  385. metadata.width = Int(file.width)
  386. metadata.livePhotoFile = file.livePhotoFile
  387. metadata.isFlaggedAsLivePhotoByServer = file.isFlaggedAsLivePhotoByServer
  388. // E2EE find the fileName for fileNameView
  389. if isDirectoryE2EE || file.e2eEncrypted {
  390. if let tableE2eEncryption = getE2eEncryption(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameIdentifier == %@", file.account, file.serverUrl, file.fileName)) {
  391. metadata.fileNameView = tableE2eEncryption.fileName
  392. let results = NextcloudKit.shared.nkCommonInstance.getInternalType(fileName: metadata.fileNameView, mimeType: file.contentType, directory: file.directory, account: file.account)
  393. metadata.contentType = results.mimeType
  394. metadata.iconName = results.iconName
  395. metadata.classFile = results.classFile
  396. }
  397. }
  398. return metadata
  399. }
  400. func convertFilesToMetadatas(_ files: [NKFile], useFirstAsMetadataFolder: Bool, completion: @escaping (_ metadataFolder: tableMetadata, _ metadatas: [tableMetadata]) -> Void) {
  401. var counter: Int = 0
  402. var isDirectoryE2EE: Bool = false
  403. let listServerUrl = ThreadSafeDictionary<String, Bool>()
  404. var metadataFolder = tableMetadata()
  405. var metadatas: [tableMetadata] = []
  406. for file in files {
  407. if let key = listServerUrl[file.serverUrl] {
  408. isDirectoryE2EE = key
  409. } else {
  410. isDirectoryE2EE = NCUtilityFileSystem().isDirectoryE2EE(file: file)
  411. listServerUrl[file.serverUrl] = isDirectoryE2EE
  412. }
  413. let metadata = convertFileToMetadata(file, isDirectoryE2EE: isDirectoryE2EE)
  414. if counter == 0 && useFirstAsMetadataFolder {
  415. metadataFolder = tableMetadata(value: metadata)
  416. } else {
  417. metadatas.append(metadata)
  418. }
  419. counter += 1
  420. }
  421. completion(metadataFolder, metadatas)
  422. }
  423. func getMetadataDirectoryFrom(files: [NKFile]) -> tableMetadata? {
  424. guard let file = files.first else { return nil }
  425. let isDirectoryE2EE = NCUtilityFileSystem().isDirectoryE2EE(file: file)
  426. let metadata = convertFileToMetadata(file, isDirectoryE2EE: isDirectoryE2EE)
  427. return metadata
  428. }
  429. func convertFilesToMetadatas(_ files: [NKFile], useFirstAsMetadataFolder: Bool) async -> (metadataFolder: tableMetadata, metadatas: [tableMetadata]) {
  430. await withUnsafeContinuation({ continuation in
  431. convertFilesToMetadatas(files, useFirstAsMetadataFolder: useFirstAsMetadataFolder) { metadataFolder, metadatas in
  432. continuation.resume(returning: (metadataFolder, metadatas))
  433. }
  434. })
  435. }
  436. func createMetadata(fileName: String, fileNameView: String, ocId: String, serverUrl: String, url: String, contentType: String, isUrl: Bool = false, name: String = NCGlobal.shared.appName, subline: String? = nil, iconName: String? = nil, iconUrl: String? = nil, directory: Bool = false, session: NCSession.Session, sceneIdentifier: String?) -> tableMetadata {
  437. let metadata = tableMetadata()
  438. if isUrl {
  439. metadata.contentType = "text/uri-list"
  440. if let iconName = iconName {
  441. metadata.iconName = iconName
  442. } else {
  443. metadata.iconName = NKCommon.TypeClassFile.url.rawValue
  444. }
  445. metadata.classFile = NKCommon.TypeClassFile.url.rawValue
  446. } else {
  447. let (mimeType, classFile, iconName, _, _, _) = NextcloudKit.shared.nkCommonInstance.getInternalType(fileName: fileName, mimeType: contentType, directory: directory, account: session.account)
  448. metadata.contentType = mimeType
  449. metadata.iconName = iconName
  450. metadata.classFile = classFile
  451. // iOS 12.0,* don't detect UTI text/markdown, text/x-markdown
  452. if classFile == NKCommon.TypeClassFile.unknow.rawValue && (mimeType == "text/x-markdown" || mimeType == "text/markdown") {
  453. metadata.iconName = NKCommon.TypeIconFile.txt.rawValue
  454. metadata.classFile = NKCommon.TypeClassFile.document.rawValue
  455. }
  456. }
  457. if let iconUrl = iconUrl {
  458. metadata.iconUrl = iconUrl
  459. }
  460. let fileName = fileName.trimmingCharacters(in: .whitespacesAndNewlines)
  461. metadata.account = session.account
  462. metadata.creationDate = Date() as NSDate
  463. metadata.date = Date() as NSDate
  464. metadata.directory = directory
  465. metadata.hasPreview = true
  466. metadata.etag = ocId
  467. metadata.fileName = fileName
  468. metadata.fileNameView = fileName
  469. metadata.name = name
  470. metadata.ocId = ocId
  471. metadata.ocIdTransfer = ocId
  472. metadata.permissions = "RGDNVW"
  473. metadata.serverUrl = serverUrl
  474. metadata.serveUrlFileName = serverUrl + "/" + fileName
  475. metadata.subline = subline
  476. metadata.uploadDate = Date() as NSDate
  477. metadata.url = url
  478. metadata.urlBase = session.urlBase
  479. metadata.user = session.user
  480. metadata.userId = session.userId
  481. metadata.sceneIdentifier = sceneIdentifier
  482. if !metadata.urlBase.isEmpty, metadata.serverUrl.hasPrefix(metadata.urlBase) {
  483. metadata.path = String(metadata.serverUrl.dropFirst(metadata.urlBase.count)) + "/"
  484. }
  485. return metadata
  486. }
  487. func isMetadataShareOrMounted(metadata: tableMetadata, metadataFolder: tableMetadata?) -> Bool {
  488. let permissions = NCPermissions()
  489. var isShare = false
  490. var isMounted = false
  491. if metadataFolder != nil {
  492. isShare = metadata.permissions.contains(permissions.permissionShared) && !metadataFolder!.permissions.contains(permissions.permissionShared)
  493. isMounted = metadata.permissions.contains(permissions.permissionMounted) && !metadataFolder!.permissions.contains(permissions.permissionMounted)
  494. } else if let directory = getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, metadata.serverUrl)) {
  495. isShare = metadata.permissions.contains(permissions.permissionShared) && !directory.permissions.contains(permissions.permissionShared)
  496. isMounted = metadata.permissions.contains(permissions.permissionMounted) && !directory.permissions.contains(permissions.permissionMounted)
  497. }
  498. if isShare || isMounted {
  499. return true
  500. } else {
  501. return false
  502. }
  503. }
  504. // MARK: - Set
  505. @discardableResult
  506. func addMetadata(_ metadata: tableMetadata) -> tableMetadata? {
  507. do {
  508. let realm = try Realm()
  509. try realm.write {
  510. realm.add(tableMetadata(value: metadata), update: .all)
  511. }
  512. } catch let error {
  513. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  514. return nil
  515. }
  516. return tableMetadata(value: metadata)
  517. }
  518. func addMetadatas(_ metadatas: [tableMetadata]) {
  519. do {
  520. let realm = try Realm()
  521. try realm.write {
  522. realm.add(metadatas, update: .all)
  523. }
  524. } catch let error {
  525. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  526. }
  527. }
  528. func deleteMetadata(predicate: NSPredicate) {
  529. do {
  530. let realm = try Realm()
  531. try realm.write {
  532. let results = realm.objects(tableMetadata.self).filter(predicate)
  533. realm.delete(results)
  534. }
  535. } catch let error {
  536. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  537. }
  538. }
  539. func deleteMetadataOcId(_ ocId: String?) {
  540. guard let ocId else { return }
  541. do {
  542. let realm = try Realm()
  543. try realm.write {
  544. let results = realm.objects(tableMetadata.self).filter("ocId == %@", ocId)
  545. realm.delete(results)
  546. }
  547. } catch let error as NSError {
  548. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  549. }
  550. }
  551. func deleteMetadatas(_ metadatas: [tableMetadata]) {
  552. do {
  553. let realm = try Realm()
  554. try realm.write {
  555. realm.delete(metadatas)
  556. }
  557. } catch let error {
  558. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  559. }
  560. }
  561. func renameMetadata(fileNameNew: String, ocId: String, status: Int = NCGlobal.shared.metadataStatusNormal) {
  562. do {
  563. let realm = try Realm()
  564. try realm.write {
  565. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  566. let fileNameView = result.fileNameView
  567. let fileIdMOV = result.livePhotoFile
  568. let directoryServerUrl = self.utilityFileSystem.stringAppendServerUrl(result.serverUrl, addFileName: fileNameView)
  569. let resultsType = NextcloudKit.shared.nkCommonInstance.getInternalType(fileName: fileNameNew, mimeType: "", directory: result.directory, account: result.account)
  570. result.fileName = fileNameNew
  571. result.fileNameView = fileNameNew
  572. result.iconName = resultsType.iconName
  573. result.contentType = resultsType.mimeType
  574. result.classFile = resultsType.classFile
  575. result.status = status
  576. if status == NCGlobal.shared.metadataStatusNormal {
  577. result.sessionDate = nil
  578. } else {
  579. result.sessionDate = Date()
  580. }
  581. if result.directory,
  582. let resultDirectory = realm.objects(tableDirectory.self).filter("account == %@ AND serverUrl == %@", result.account, directoryServerUrl).first {
  583. let serverUrlTo = self.utilityFileSystem.stringAppendServerUrl(result.serverUrl, addFileName: fileNameNew)
  584. resultDirectory.serverUrl = serverUrlTo
  585. } else {
  586. let atPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(result.ocId) + "/" + fileNameView
  587. let toPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(result.ocId) + "/" + fileNameNew
  588. self.utilityFileSystem.moveFile(atPath: atPath, toPath: toPath)
  589. }
  590. if result.isLivePhoto,
  591. let resultMOV = realm.objects(tableMetadata.self).filter("fileId == %@ AND account == %@", fileIdMOV, result.account).first {
  592. let fileNameView = resultMOV.fileNameView
  593. let fileName = (fileNameNew as NSString).deletingPathExtension
  594. let ext = (resultMOV.fileName as NSString).pathExtension
  595. resultMOV.fileName = fileName + "." + ext
  596. resultMOV.fileNameView = fileName + "." + ext
  597. let atPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(resultMOV.ocId) + "/" + fileNameView
  598. let toPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(resultMOV.ocId) + "/" + fileName + "." + ext
  599. self.utilityFileSystem.moveFile(atPath: atPath, toPath: toPath)
  600. }
  601. }
  602. }
  603. } catch let error {
  604. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  605. }
  606. }
  607. func restoreMetadataFileName(ocId: String) {
  608. do {
  609. let realm = try Realm()
  610. try realm.write {
  611. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first,
  612. let encodedURLString = result.serveUrlFileName.addingPercentEncoding(withAllowedCharacters: .urlQueryAllowed),
  613. let url = URL(string: encodedURLString) {
  614. let fileIdMOV = result.livePhotoFile
  615. let directoryServerUrl = self.utilityFileSystem.stringAppendServerUrl(result.serverUrl, addFileName: result.fileNameView)
  616. let lastPathComponent = url.lastPathComponent
  617. let fileName = lastPathComponent.removingPercentEncoding ?? lastPathComponent
  618. let fileNameView = result.fileNameView
  619. result.fileName = fileName
  620. result.fileNameView = fileName
  621. result.status = NCGlobal.shared.metadataStatusNormal
  622. result.sessionDate = nil
  623. if result.directory,
  624. let resultDirectory = realm.objects(tableDirectory.self).filter("account == %@ AND serverUrl == %@", result.account, directoryServerUrl).first {
  625. let serverUrlTo = self.utilityFileSystem.stringAppendServerUrl(result.serverUrl, addFileName: fileName)
  626. resultDirectory.serverUrl = serverUrlTo
  627. } else {
  628. let atPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(result.ocId) + "/" + fileNameView
  629. let toPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(result.ocId) + "/" + fileName
  630. self.utilityFileSystem.moveFile(atPath: atPath, toPath: toPath)
  631. }
  632. if result.isLivePhoto,
  633. let resultMOV = realm.objects(tableMetadata.self).filter("fileId == %@ AND account == %@", fileIdMOV, result.account).first {
  634. let fileNameView = resultMOV.fileNameView
  635. let fileName = (fileName as NSString).deletingPathExtension
  636. let ext = (resultMOV.fileName as NSString).pathExtension
  637. resultMOV.fileName = fileName + "." + ext
  638. resultMOV.fileNameView = fileName + "." + ext
  639. let atPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(resultMOV.ocId) + "/" + fileNameView
  640. let toPath = self.utilityFileSystem.getDirectoryProviderStorageOcId(resultMOV.ocId) + "/" + fileName + "." + ext
  641. self.utilityFileSystem.moveFile(atPath: atPath, toPath: toPath)
  642. }
  643. }
  644. }
  645. } catch let error {
  646. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  647. }
  648. }
  649. func setMetadataServeUrlFileNameStatusNormal(ocId: String) {
  650. do {
  651. let realm = try Realm()
  652. try realm.write {
  653. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  654. result.serveUrlFileName = self.utilityFileSystem.stringAppendServerUrl(result.serverUrl, addFileName: result.fileName)
  655. result.status = NCGlobal.shared.metadataStatusNormal
  656. result.sessionDate = nil
  657. }
  658. }
  659. } catch let error {
  660. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  661. }
  662. }
  663. func setMetadataEtagResource(ocId: String, etagResource: String?) {
  664. guard let etagResource else { return }
  665. do {
  666. let realm = try Realm()
  667. try realm.write {
  668. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  669. result?.etagResource = etagResource
  670. }
  671. } catch let error {
  672. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  673. }
  674. }
  675. func setMetadataLivePhotoByServer(account: String, ocId: String, livePhotoFile: String) {
  676. do {
  677. let realm = try Realm()
  678. try realm.write {
  679. if let result = realm.objects(tableMetadata.self).filter("account == %@ AND ocId == %@", account, ocId).first {
  680. result.isFlaggedAsLivePhotoByServer = true
  681. result.livePhotoFile = livePhotoFile
  682. }
  683. }
  684. } catch let error {
  685. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  686. }
  687. }
  688. func updateMetadatasFavorite(account: String, metadatas: [tableMetadata]) {
  689. do {
  690. let realm = try Realm()
  691. try realm.write {
  692. let results = realm.objects(tableMetadata.self).filter("account == %@ AND favorite == true", account)
  693. for result in results {
  694. result.favorite = false
  695. }
  696. for metadata in metadatas {
  697. if let result = realm.objects(tableMetadata.self).filter("account == %@ AND ocId == %@", account, metadata.ocId).first {
  698. result.favorite = true
  699. } else {
  700. realm.add(metadata, update: .modified)
  701. }
  702. }
  703. }
  704. } catch let error {
  705. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  706. }
  707. }
  708. func updateMetadatasFiles(_ metadatas: [tableMetadata], serverUrl: String, account: String) {
  709. do {
  710. let realm = try Realm()
  711. try realm.write {
  712. let results = realm.objects(tableMetadata.self).filter(NSPredicate(format: "account == %@ AND serverUrl == %@ AND status == %d", account, serverUrl, NCGlobal.shared.metadataStatusNormal))
  713. realm.delete(results)
  714. for metadata in metadatas {
  715. if realm.objects(tableMetadata.self).filter(NSPredicate(format: "ocId == %@ AND status != %d", metadata.ocId, NCGlobal.shared.metadataStatusNormal)).first != nil {
  716. continue
  717. }
  718. realm.add(tableMetadata(value: metadata), update: .all)
  719. }
  720. }
  721. } catch let error {
  722. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  723. }
  724. }
  725. func setMetadataEncrypted(ocId: String, encrypted: Bool) {
  726. do {
  727. let realm = try Realm()
  728. try realm.write {
  729. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  730. result?.e2eEncrypted = encrypted
  731. }
  732. } catch let error {
  733. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  734. }
  735. }
  736. func setMetadataFileNameView(serverUrl: String, fileName: String, newFileNameView: String, account: String) {
  737. do {
  738. let realm = try Realm()
  739. try realm.write {
  740. let result = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName == %@", account, serverUrl, fileName).first
  741. result?.fileNameView = newFileNameView
  742. }
  743. } catch let error {
  744. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  745. }
  746. }
  747. func moveMetadata(ocId: String, serverUrlTo: String) {
  748. do {
  749. let realm = try Realm()
  750. try realm.write {
  751. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  752. result.serverUrl = serverUrlTo
  753. }
  754. }
  755. } catch let error {
  756. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  757. }
  758. }
  759. func clearAssetLocalIdentifiers(_ assetLocalIdentifiers: [String]) {
  760. do {
  761. let realm = try Realm()
  762. try realm.write {
  763. let results = realm.objects(tableMetadata.self).filter("assetLocalIdentifier IN %@", assetLocalIdentifiers)
  764. for result in results {
  765. result.assetLocalIdentifier = ""
  766. }
  767. }
  768. } catch let error {
  769. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  770. }
  771. }
  772. func setMetadataFavorite(ocId: String, favorite: Bool?, saveOldFavorite: String?, status: Int) {
  773. do {
  774. let realm = try Realm()
  775. try realm.write {
  776. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  777. if let favorite {
  778. result?.favorite = favorite
  779. }
  780. result?.storeFlag = saveOldFavorite
  781. result?.status = status
  782. if status == NCGlobal.shared.metadataStatusNormal {
  783. result?.sessionDate = nil
  784. } else {
  785. result?.sessionDate = Date()
  786. }
  787. }
  788. } catch let error {
  789. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  790. }
  791. }
  792. func setMetadataCopyMove(ocId: String, serverUrlTo: String, overwrite: String?, status: Int) {
  793. do {
  794. let realm = try Realm()
  795. try realm.write {
  796. let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  797. result?.serverUrlTo = serverUrlTo
  798. result?.storeFlag = overwrite
  799. result?.status = status
  800. if status == NCGlobal.shared.metadataStatusNormal {
  801. result?.sessionDate = nil
  802. } else {
  803. result?.sessionDate = Date()
  804. }
  805. }
  806. } catch let error {
  807. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  808. }
  809. }
  810. // MARK: - GetMetadata
  811. func getMetadata(predicate: NSPredicate) -> tableMetadata? {
  812. do {
  813. let realm = try Realm()
  814. guard let result = realm.objects(tableMetadata.self).filter(predicate).first else { return nil }
  815. return tableMetadata(value: result)
  816. } catch let error as NSError {
  817. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  818. }
  819. return nil
  820. }
  821. func getMetadatas(predicate: NSPredicate) -> [tableMetadata] {
  822. do {
  823. let realm = try Realm()
  824. let results = realm.objects(tableMetadata.self).filter(predicate)
  825. return Array(results.map { tableMetadata(value: $0) })
  826. } catch let error as NSError {
  827. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  828. }
  829. return []
  830. }
  831. func getMetadatas(predicate: NSPredicate, sortedByKeyPath: String, ascending: Bool = false) -> [tableMetadata]? {
  832. do {
  833. let realm = try Realm()
  834. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sortedByKeyPath, ascending: ascending)
  835. return Array(results.map { tableMetadata(value: $0) })
  836. } catch let error as NSError {
  837. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  838. }
  839. return nil
  840. }
  841. func getMetadatas(predicate: NSPredicate, numItems: Int, sorted: String, ascending: Bool) -> [tableMetadata] {
  842. var counter: Int = 0
  843. var metadatas: [tableMetadata] = []
  844. do {
  845. let realm = try Realm()
  846. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sorted, ascending: ascending)
  847. for result in results where counter < numItems {
  848. metadatas.append(tableMetadata(value: result))
  849. counter += 1
  850. }
  851. } catch let error as NSError {
  852. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  853. }
  854. return metadatas
  855. }
  856. func getMetadataFromOcId(_ ocId: String?) -> tableMetadata? {
  857. guard let ocId else { return nil }
  858. do {
  859. let realm = try Realm()
  860. guard let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first else { return nil }
  861. return tableMetadata(value: result)
  862. } catch let error as NSError {
  863. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  864. }
  865. return nil
  866. }
  867. func getMetadataFromOcIdAndocIdTransfer(_ ocId: String?) -> tableMetadata? {
  868. guard let ocId else { return nil }
  869. do {
  870. let realm = try Realm()
  871. if let result = realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first {
  872. return tableMetadata(value: result)
  873. }
  874. if let result = realm.objects(tableMetadata.self).filter("ocIdTransfer == %@", ocId).first {
  875. return tableMetadata(value: result)
  876. }
  877. } catch let error as NSError {
  878. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  879. }
  880. return nil
  881. }
  882. func getMetadataFolder(session: NCSession.Session, serverUrl: String) -> tableMetadata? {
  883. var serverUrl = serverUrl
  884. var fileName = ""
  885. let serverUrlHome = utilityFileSystem.getHomeServer(session: session)
  886. if serverUrlHome == serverUrl {
  887. fileName = "."
  888. serverUrl = ".."
  889. } else {
  890. fileName = (serverUrl as NSString).lastPathComponent
  891. if let path = utilityFileSystem.deleteLastPath(serverUrlPath: serverUrl) {
  892. serverUrl = path
  893. }
  894. }
  895. do {
  896. let realm = try Realm()
  897. guard let result = realm.objects(tableMetadata.self).filter("account == %@ AND serverUrl == %@ AND fileName == %@", session.account, serverUrl, fileName).first else { return nil }
  898. return tableMetadata(value: result)
  899. } catch let error as NSError {
  900. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  901. }
  902. return nil
  903. }
  904. func getMetadataLivePhoto(metadata: tableMetadata) -> tableMetadata? {
  905. guard metadata.isLivePhoto else { return nil }
  906. do {
  907. let realm = try Realm()
  908. guard let result = realm.objects(tableMetadata.self).filter(NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileId == %@",
  909. metadata.account,
  910. metadata.serverUrl,
  911. metadata.livePhotoFile)).first else { return nil }
  912. return tableMetadata(value: result)
  913. } catch let error as NSError {
  914. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  915. }
  916. return nil
  917. }
  918. func getMetadataConflict(account: String, serverUrl: String, fileNameView: String) -> tableMetadata? {
  919. let fileNameExtension = (fileNameView as NSString).pathExtension.lowercased()
  920. let fileNameNoExtension = (fileNameView as NSString).deletingPathExtension
  921. var fileNameConflict = fileNameView
  922. if fileNameExtension == "heic", NCKeychain().formatCompatibility {
  923. fileNameConflict = fileNameNoExtension + ".jpg"
  924. }
  925. return getMetadata(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND fileNameView == %@",
  926. account,
  927. serverUrl,
  928. fileNameConflict))
  929. }
  930. // MARK: - GetResult(s)Metadata
  931. func getResultsMetadatasPredicate(_ predicate: NSPredicate, layoutForView: NCDBLayoutForView?) -> Results<tableMetadata>? {
  932. do {
  933. let realm = try Realm()
  934. var results = realm.objects(tableMetadata.self).filter(predicate)
  935. if let layoutForView {
  936. if layoutForView.directoryOnTop {
  937. results = results.sorted(byKeyPath: layoutForView.sort, ascending: layoutForView.ascending).sorted(byKeyPath: "directory", ascending: false).sorted(byKeyPath: "favorite", ascending: false)
  938. } else {
  939. results = results.sorted(byKeyPath: layoutForView.sort, ascending: layoutForView.ascending).sorted(byKeyPath: "favorite", ascending: false)
  940. }
  941. }
  942. return results
  943. } catch let error as NSError {
  944. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  945. }
  946. return nil
  947. }
  948. func getResultsMetadatas(predicate: NSPredicate, sortedByKeyPath: String, ascending: Bool, arraySlice: Int) -> [tableMetadata] {
  949. do {
  950. let realm = try Realm()
  951. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sortedByKeyPath, ascending: ascending).prefix(arraySlice)
  952. return Array(results)
  953. } catch let error as NSError {
  954. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  955. }
  956. return []
  957. }
  958. func getResultMetadata(predicate: NSPredicate) -> tableMetadata? {
  959. do {
  960. let realm = try Realm()
  961. return realm.objects(tableMetadata.self).filter(predicate).first
  962. } catch let error as NSError {
  963. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  964. }
  965. return nil
  966. }
  967. func getResultMetadataFromFileName(_ fileName: String, serverUrl: String, sessionTaskIdentifier: Int) -> tableMetadata? {
  968. do {
  969. let realm = try Realm()
  970. return realm.objects(tableMetadata.self).filter("fileName == %@ AND serverUrl == %@ AND sessionTaskIdentifier == %d", fileName, serverUrl, sessionTaskIdentifier).first
  971. } catch let error as NSError {
  972. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  973. }
  974. return nil
  975. }
  976. func getResultsMetadatasFromGroupfolders(session: NCSession.Session) -> Results<tableMetadata>? {
  977. var ocId: [String] = []
  978. let homeServerUrl = utilityFileSystem.getHomeServer(session: session)
  979. do {
  980. let realm = try Realm()
  981. let groupfolders = realm.objects(TableGroupfolders.self).filter("account == %@", session.account).sorted(byKeyPath: "mountPoint", ascending: true)
  982. for groupfolder in groupfolders {
  983. let mountPoint = groupfolder.mountPoint.hasPrefix("/") ? groupfolder.mountPoint : "/" + groupfolder.mountPoint
  984. let serverUrlFileName = homeServerUrl + mountPoint
  985. if let directory = realm.objects(tableDirectory.self).filter("account == %@ AND serverUrl == %@", session.account, serverUrlFileName).first,
  986. let result = realm.objects(tableMetadata.self).filter("ocId == %@", directory.ocId).first {
  987. ocId.append(result.ocId)
  988. }
  989. }
  990. return realm.objects(tableMetadata.self).filter("ocId IN %@", ocId)
  991. } catch let error as NSError {
  992. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  993. }
  994. return nil
  995. }
  996. func getResultsImageCacheMetadatas(predicate: NSPredicate) -> Results<tableMetadata>? {
  997. do {
  998. let realm = try Realm()
  999. return realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: "date", ascending: false)
  1000. } catch let error as NSError {
  1001. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1002. }
  1003. return nil
  1004. }
  1005. func getTableMetadatasDirectoryFavoriteIdentifierRank(account: String) -> [String: NSNumber] {
  1006. var listIdentifierRank: [String: NSNumber] = [:]
  1007. var counter = 10 as Int64
  1008. do {
  1009. let realm = try Realm()
  1010. let results = realm.objects(tableMetadata.self).filter("account == %@ AND directory == true AND favorite == true", account).sorted(byKeyPath: "fileNameView", ascending: true)
  1011. for result in results {
  1012. counter += 1
  1013. listIdentifierRank[result.ocId] = NSNumber(value: Int64(counter))
  1014. }
  1015. } catch let error as NSError {
  1016. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1017. }
  1018. return listIdentifierRank
  1019. }
  1020. func clearMetadatasUpload(account: String) {
  1021. do {
  1022. let realm = try Realm()
  1023. try realm.write {
  1024. let results = realm.objects(tableMetadata.self).filter("account == %@ AND (status == %d OR status == %d)", account, NCGlobal.shared.metadataStatusWaitUpload, NCGlobal.shared.metadataStatusUploadError)
  1025. realm.delete(results)
  1026. }
  1027. } catch let error {
  1028. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not write to database: \(error)")
  1029. }
  1030. }
  1031. func getAssetLocalIdentifiersUploaded() -> [String]? {
  1032. var assetLocalIdentifiers: [String] = []
  1033. do {
  1034. let realm = try Realm()
  1035. let results = realm.objects(tableMetadata.self).filter("assetLocalIdentifier != ''")
  1036. for result in results {
  1037. assetLocalIdentifiers.append(result.assetLocalIdentifier)
  1038. }
  1039. return assetLocalIdentifiers
  1040. } catch let error as NSError {
  1041. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1042. }
  1043. return nil
  1044. }
  1045. func getMetadataFromDirectory(account: String, serverUrl: String) -> Bool {
  1046. do {
  1047. let realm = try Realm()
  1048. guard let directory = realm.objects(tableDirectory.self).filter("account == %@ AND serverUrl == %@", account, serverUrl).first,
  1049. realm.objects(tableMetadata.self).filter("ocId == %@", directory.ocId).first != nil else { return false }
  1050. return true
  1051. } catch let error as NSError {
  1052. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1053. }
  1054. return false
  1055. }
  1056. func getResultMetadataFromFileId(_ fileId: String?) -> tableMetadata? {
  1057. guard let fileId else { return nil }
  1058. do {
  1059. let realm = try Realm()
  1060. return realm.objects(tableMetadata.self).filter("fileId == %@", fileId).first
  1061. } catch let error as NSError {
  1062. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1063. }
  1064. return nil
  1065. }
  1066. func getResultMetadataFromOcId(_ ocId: String?) -> tableMetadata? {
  1067. guard let ocId else { return nil }
  1068. do {
  1069. let realm = try Realm()
  1070. return realm.objects(tableMetadata.self).filter("ocId == %@", ocId).first
  1071. } catch let error as NSError {
  1072. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1073. }
  1074. return nil
  1075. }
  1076. func getResultsMetadatas(predicate: NSPredicate, sortedByKeyPath: String? = nil, ascending: Bool = false, freeze: Bool = false) -> Results<tableMetadata>? {
  1077. do {
  1078. let realm = try Realm()
  1079. realm.refresh()
  1080. if let sortedByKeyPath {
  1081. let results = realm.objects(tableMetadata.self).filter(predicate).sorted(byKeyPath: sortedByKeyPath, ascending: ascending)
  1082. if freeze {
  1083. return results.freeze()
  1084. }
  1085. return results
  1086. } else {
  1087. let results = realm.objects(tableMetadata.self).filter(predicate)
  1088. if freeze {
  1089. return results.freeze()
  1090. }
  1091. return results
  1092. }
  1093. } catch let error as NSError {
  1094. NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Could not access database: \(error)")
  1095. }
  1096. return nil
  1097. }
  1098. func getCalculateCumulativeHash(for metadatas: [tableMetadata], account: String, serverUrl: String) -> String {
  1099. let concatenatedEtags = metadatas.map { $0.etag }.joined(separator: "-")
  1100. return sha256Hash(concatenatedEtags)
  1101. }
  1102. }