NCOperationQueue.swift 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683
  1. //
  2. // NCOperationQueue.swift
  3. // Nextcloud
  4. //
  5. // Created by Marino Faggiana on 03/06/2020.
  6. // Copyright © 2020 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 UIKit
  24. import Queuer
  25. import NextcloudKit
  26. @objc class NCOperationQueue: NSObject {
  27. @objc public static let shared: NCOperationQueue = {
  28. let instance = NCOperationQueue()
  29. return instance
  30. }()
  31. private var downloadQueue = Queuer(name: "downloadQueue", maxConcurrentOperationCount: 5, qualityOfService: .default)
  32. private let deleteQueue = Queuer(name: "deleteQueue", maxConcurrentOperationCount: 10, qualityOfService: .default)
  33. private let deleteQueueE2EE = Queuer(name: "deleteQueue", maxConcurrentOperationCount: 1, qualityOfService: .default)
  34. private let copyMoveQueue = Queuer(name: "copyMoveQueue", maxConcurrentOperationCount: 1, qualityOfService: .default)
  35. private let synchronizationQueue = Queuer(name: "synchronizationQueue", maxConcurrentOperationCount: 1, qualityOfService: .default)
  36. private let downloadThumbnailQueue = Queuer(name: "downloadThumbnailQueue", maxConcurrentOperationCount: 10, qualityOfService: .default)
  37. private let downloadThumbnailActivityQueue = Queuer(name: "downloadThumbnailActivityQueue", maxConcurrentOperationCount: 10, qualityOfService: .default)
  38. private let downloadAvatarQueue = Queuer(name: "downloadAvatarQueue", maxConcurrentOperationCount: 10, qualityOfService: .default)
  39. private let unifiedSearchQueue = Queuer(name: "unifiedSearchQueue", maxConcurrentOperationCount: 1, qualityOfService: .default)
  40. private let readFileQueue = Queuer(name: "unifiedSearchQueue", maxConcurrentOperationCount: 10, qualityOfService: .default)
  41. @objc func cancelAllQueue() {
  42. downloadCancelAll()
  43. deleteCancelAll()
  44. copyMoveCancelAll()
  45. synchronizationCancelAll()
  46. downloadThumbnailCancelAll()
  47. downloadThumbnailActivityCancelAll()
  48. downloadAvatarCancelAll()
  49. unifiedSearchCancelAll()
  50. readFileCancelAll()
  51. }
  52. // MARK: - Download file
  53. func download(metadata: tableMetadata, selector: String) {
  54. for case let operation as NCOperationDownload in downloadQueue.operations where operation.metadata.ocId == metadata.ocId {
  55. return
  56. }
  57. downloadQueue.addOperation(NCOperationDownload(metadata: metadata, selector: selector))
  58. }
  59. func downloadCancelAll() {
  60. downloadQueue.cancelAll()
  61. }
  62. func downloadQueueCount() -> Int {
  63. return downloadQueue.operationCount
  64. }
  65. func downloadExists(metadata: tableMetadata) -> Bool {
  66. for case let operation as NCOperationDownload in downloadQueue.operations where operation.metadata.ocId == metadata.ocId {
  67. return true
  68. }
  69. return false
  70. }
  71. // MARK: - Delete file
  72. func delete(metadata: tableMetadata, onlyLocalCache: Bool) {
  73. if metadata.isDirectoryE2EE {
  74. for case let operation as NCOperationDelete in deleteQueueE2EE.operations where operation.metadata.ocId == metadata.ocId {
  75. return
  76. }
  77. deleteQueueE2EE.addOperation(NCOperationDelete(metadata: metadata, onlyLocalCache: onlyLocalCache))
  78. } else {
  79. for case let operation as NCOperationDelete in deleteQueue.operations where operation.metadata.ocId == metadata.ocId {
  80. return
  81. }
  82. deleteQueue.addOperation(NCOperationDelete(metadata: metadata, onlyLocalCache: onlyLocalCache))
  83. }
  84. }
  85. func deleteCancelAll() {
  86. deleteQueue.cancelAll()
  87. }
  88. // MARK: - Copy Move file
  89. func copyMove(metadata: tableMetadata, serverUrl: String, overwrite: Bool, move: Bool) {
  90. for case let operation as NCOperationCopyMove in copyMoveQueue.operations where operation.metadata.ocId == metadata.ocId {
  91. return
  92. }
  93. copyMoveQueue.addOperation(NCOperationCopyMove(metadata: metadata, serverUrlTo: serverUrl, overwrite: overwrite, move: move))
  94. }
  95. func copyMoveCancelAll() {
  96. copyMoveQueue.cancelAll()
  97. }
  98. // MARK: - Synchronization
  99. func synchronizationMetadata(_ metadata: tableMetadata, selector: String) {
  100. for case let operation as NCOperationSynchronization in synchronizationQueue.operations where operation.metadata.ocId == metadata.ocId {
  101. return
  102. }
  103. synchronizationQueue.addOperation(NCOperationSynchronization(metadata: metadata, selector: selector))
  104. }
  105. func synchronizationCancelAll() {
  106. synchronizationQueue.cancelAll()
  107. }
  108. // MARK: - Download Thumbnail
  109. func downloadThumbnail(metadata: tableMetadata, placeholder: Bool, cell: UIView?, view: UIView?) {
  110. let cell: NCCellProtocol? = cell as? NCCellProtocol
  111. if placeholder {
  112. if metadata.iconName.isEmpty {
  113. cell?.filePreviewImageView?.image = NCBrandColor.cacheImages.file
  114. } else {
  115. cell?.filePreviewImageView?.image = UIImage(named: metadata.iconName)
  116. }
  117. }
  118. if metadata.hasPreview && metadata.status == NCGlobal.shared.metadataStatusNormal && (!CCUtility.fileProviderStoragePreviewIconExists(metadata.ocId, etag: metadata.etag)) {
  119. for case let operation as NCOperationDownloadThumbnail in downloadThumbnailQueue.operations where operation.metadata.ocId == metadata.ocId {
  120. return
  121. }
  122. downloadThumbnailQueue.addOperation(NCOperationDownloadThumbnail(metadata: metadata, cell: cell, view: view))
  123. }
  124. }
  125. func cancelDownloadThumbnail(metadata: tableMetadata) {
  126. for case let operation as NCOperationDownloadThumbnail in downloadThumbnailQueue.operations where operation.metadata.ocId == metadata.ocId {
  127. operation.cancel()
  128. }
  129. }
  130. func downloadThumbnailCancelAll() {
  131. downloadThumbnailQueue.cancelAll()
  132. }
  133. // MARK: - Download Thumbnail Activity
  134. func downloadThumbnailActivity(fileNamePathOrFileId: String, fileNamePreviewLocalPath: String, fileId: String, cell: NCActivityCollectionViewCell, collectionView: UICollectionView?) {
  135. cell.imageView?.image = UIImage(named: "file_photo")
  136. cell.fileId = fileId
  137. if !FileManager.default.fileExists(atPath: fileNamePreviewLocalPath) {
  138. for case let operation as NCOperationDownloadThumbnailActivity in downloadThumbnailActivityQueue.operations where operation.fileId == fileId {
  139. return
  140. }
  141. downloadThumbnailActivityQueue.addOperation(NCOperationDownloadThumbnailActivity(fileNamePathOrFileId: fileNamePathOrFileId, fileNamePreviewLocalPath: fileNamePreviewLocalPath, fileId: fileId, cell: cell, collectionView: collectionView))
  142. }
  143. }
  144. func cancelDownloadThumbnailActivity(fileId: String) {
  145. for case let operation as NCOperationDownloadThumbnailActivity in downloadThumbnailActivityQueue.operations where operation.fileId == fileId {
  146. operation.cancel()
  147. }
  148. }
  149. func downloadThumbnailActivityCancelAll() {
  150. downloadThumbnailActivityQueue.cancelAll()
  151. }
  152. // MARK: - Download Avatar
  153. func downloadAvatar(user: String, dispalyName: String?, fileName: String, cell: NCCellProtocol, view: UIView?, cellImageView: UIImageView?) {
  154. let fileNameLocalPath = String(CCUtility.getDirectoryUserData()) + "/" + fileName
  155. if let image = NCManageDatabase.shared.getImageAvatarLoaded(fileName: fileName) {
  156. cellImageView?.image = image
  157. cell.fileAvatarImageView?.image = image
  158. return
  159. }
  160. if let account = NCManageDatabase.shared.getActiveAccount() {
  161. cellImageView?.image = NCUtility.shared.loadUserImage(
  162. for: user,
  163. displayName: dispalyName,
  164. userBaseUrl: account)
  165. }
  166. for case let operation as NCOperationDownloadAvatar in downloadAvatarQueue.operations where operation.fileName == fileName {
  167. return
  168. }
  169. downloadAvatarQueue.addOperation(NCOperationDownloadAvatar(user: user, fileName: fileName, fileNameLocalPath: fileNameLocalPath, cell: cell, view: view, cellImageView: cellImageView))
  170. }
  171. func cancelDownloadAvatar(user: String) {
  172. for case let operation as NCOperationDownloadAvatar in downloadAvatarQueue.operations where operation.user == user {
  173. operation.cancel()
  174. }
  175. }
  176. func downloadAvatarCancelAll() {
  177. downloadAvatarQueue.cancelAll()
  178. }
  179. // MARK: - Unified Search
  180. func unifiedSearchAddSection(collectionViewCommon: NCCollectionViewCommon, metadatas: [tableMetadata], searchResult: NKSearchResult) {
  181. unifiedSearchQueue.addOperation(NCOperationUnifiedSearch.init(collectionViewCommon: collectionViewCommon, metadatas: metadatas, searchResult: searchResult))
  182. }
  183. func unifiedSearchCancelAll() {
  184. unifiedSearchQueue.cancelAll()
  185. }
  186. // MARK: - Read file
  187. func readFile(serverUrlFileName: String) {
  188. for case let operation as NCOperationReadFile in readFileQueue.operations where operation.serverUrlFileName == serverUrlFileName {
  189. return
  190. }
  191. readFileQueue.addOperation(NCOperationReadFile(serverUrlFileName: serverUrlFileName))
  192. }
  193. func readFileCancelAll() {
  194. readFileQueue.cancelAll()
  195. }
  196. }
  197. // MARK: -
  198. class NCOperationDownload: ConcurrentOperation {
  199. var metadata: tableMetadata
  200. var selector: String
  201. init(metadata: tableMetadata, selector: String) {
  202. self.metadata = tableMetadata.init(value: metadata)
  203. self.selector = selector
  204. }
  205. override func start() {
  206. if isCancelled {
  207. self.finish()
  208. } else {
  209. NCNetworking.shared.download(metadata: metadata, selector: self.selector) { _, _ in
  210. self.finish()
  211. }
  212. }
  213. }
  214. }
  215. // MARK: -
  216. class NCOperationDelete: ConcurrentOperation {
  217. var metadata: tableMetadata
  218. var onlyLocalCache: Bool
  219. init(metadata: tableMetadata, onlyLocalCache: Bool) {
  220. self.metadata = tableMetadata.init(value: metadata)
  221. self.onlyLocalCache = onlyLocalCache
  222. }
  223. override func start() {
  224. if isCancelled {
  225. self.finish()
  226. } else {
  227. NCNetworking.shared.deleteMetadata(metadata, onlyLocalCache: onlyLocalCache) { error in
  228. if error != .success {
  229. NCContentPresenter.shared.showError(error: error)
  230. }
  231. self.finish()
  232. }
  233. }
  234. }
  235. }
  236. // MARK: -
  237. class NCOperationCopyMove: ConcurrentOperation {
  238. var metadata: tableMetadata
  239. var serverUrlTo: String
  240. var overwrite: Bool
  241. var move: Bool
  242. init(metadata: tableMetadata, serverUrlTo: String, overwrite: Bool, move: Bool) {
  243. self.metadata = tableMetadata.init(value: metadata)
  244. self.serverUrlTo = serverUrlTo
  245. self.overwrite = overwrite
  246. self.move = move
  247. }
  248. override func start() {
  249. if isCancelled {
  250. self.finish()
  251. } else {
  252. if move {
  253. NCNetworking.shared.moveMetadata(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite) { error in
  254. if error != .success {
  255. NCContentPresenter.shared.showError(error: error)
  256. }
  257. self.finish()
  258. }
  259. } else {
  260. NCNetworking.shared.copyMetadata(metadata, serverUrlTo: serverUrlTo, overwrite: overwrite) { error in
  261. if error != .success {
  262. NCContentPresenter.shared.showError(error: error)
  263. }
  264. self.finish()
  265. }
  266. }
  267. }
  268. }
  269. }
  270. // MARK: -
  271. class NCOperationSynchronization: ConcurrentOperation {
  272. var metadata: tableMetadata
  273. var selector: String
  274. var download: Bool
  275. init(metadata: tableMetadata, selector: String) {
  276. self.metadata = tableMetadata.init(value: metadata)
  277. self.selector = selector
  278. if selector == NCGlobal.shared.selectorDownloadFile || selector == NCGlobal.shared.selectorDownloadAllFile {
  279. self.download = true
  280. } else {
  281. self.download = false
  282. }
  283. }
  284. override func start() {
  285. if isCancelled {
  286. self.finish()
  287. } else {
  288. if metadata.directory {
  289. let serverUrl = metadata.serverUrl + "/" + metadata.fileName
  290. let directory = NCManageDatabase.shared.getTableDirectory(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", metadata.account, serverUrl))
  291. NextcloudKit.shared.readFileOrFolder(serverUrlFileName: serverUrl, depth: "0", showHiddenFiles: CCUtility.getShowHiddenFiles()) { account, files, _, error in
  292. if (error == .success) && (directory?.etag != files.first?.etag || self.selector == NCGlobal.shared.selectorDownloadAllFile) {
  293. let options = NKRequestOptions(queue: NextcloudKit.shared.nkCommonInstance.backgroundQueue)
  294. NextcloudKit.shared.readFileOrFolder(serverUrlFileName: serverUrl, depth: "1", showHiddenFiles: CCUtility.getShowHiddenFiles(), options: options) { account, files, _, error in
  295. if error == .success {
  296. NCManageDatabase.shared.convertFilesToMetadatas(files, useMetadataFolder: true) { metadataFolder, _, metadatas in
  297. let metadatasResult = NCManageDatabase.shared.getMetadatas(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@ AND status == %d", account, serverUrl, NCGlobal.shared.metadataStatusNormal))
  298. if self.selector == NCGlobal.shared.selectorDownloadAllFile {
  299. NCManageDatabase.shared.updateMetadatas(metadatas, metadatasResult: metadatasResult)
  300. for metadata in metadatas {
  301. if metadata.directory {
  302. NCOperationQueue.shared.synchronizationMetadata(metadata, selector: self.selector)
  303. } else {
  304. if NCManageDatabase.shared.isDownloadMetadata(metadata, download: true) {
  305. NCOperationQueue.shared.download(metadata: metadata, selector: self.selector)
  306. }
  307. }
  308. }
  309. } else {
  310. let metadatasChanged = NCManageDatabase.shared.updateMetadatas(metadatas, metadatasResult: metadatasResult, addExistsInLocal: self.download, addCompareEtagLocal: true, addDirectorySynchronized: true)
  311. for metadata in metadatasChanged.metadatasUpdate {
  312. if metadata.directory {
  313. NCOperationQueue.shared.synchronizationMetadata(metadata, selector: self.selector)
  314. }
  315. }
  316. for metadata in metadatasChanged.metadatasLocalUpdate {
  317. NCOperationQueue.shared.download(metadata: metadata, selector: self.selector)
  318. }
  319. }
  320. // Update etag directory
  321. NCManageDatabase.shared.addDirectory(encrypted: metadataFolder.e2eEncrypted, favorite: metadataFolder.favorite, ocId: metadataFolder.ocId, fileId: metadataFolder.fileId, etag: metadataFolder.etag, permissions: metadataFolder.permissions, serverUrl: serverUrl, account: metadataFolder.account)
  322. }
  323. } else if error.errorCode == NCGlobal.shared.errorResourceNotFound && self.metadata.directory {
  324. NCManageDatabase.shared.deleteDirectoryAndSubDirectory(serverUrl: self.metadata.serverUrl, account: self.metadata.account)
  325. }
  326. self.finish()
  327. }
  328. } else {
  329. let metadatas = NCManageDatabase.shared.getMetadatas(predicate: NSPredicate(format: "account == %@ AND serverUrl == %@", account, serverUrl))
  330. for metadata in metadatas {
  331. if metadata.directory {
  332. NCOperationQueue.shared.synchronizationMetadata(metadata, selector: self.selector)
  333. } else {
  334. if NCManageDatabase.shared.isDownloadMetadata(metadata, download: self.download) {
  335. NCOperationQueue.shared.download(metadata: metadata, selector: self.selector)
  336. }
  337. }
  338. }
  339. self.finish()
  340. }
  341. }
  342. } else {
  343. if NCManageDatabase.shared.isDownloadMetadata(metadata, download: self.download) {
  344. NCOperationQueue.shared.download(metadata: metadata, selector: self.selector)
  345. }
  346. self.finish()
  347. }
  348. }
  349. }
  350. }
  351. // MARK: -
  352. class NCOperationDownloadThumbnail: ConcurrentOperation {
  353. var metadata: tableMetadata
  354. var cell: NCCellProtocol?
  355. var view: UIView?
  356. var fileNamePath: String
  357. var fileNamePreviewLocalPath: String
  358. var fileNameIconLocalPath: String
  359. init(metadata: tableMetadata, cell: NCCellProtocol?, view: UIView?) {
  360. self.metadata = tableMetadata.init(value: metadata)
  361. self.cell = cell
  362. self.view = view
  363. self.fileNamePath = CCUtility.returnFileNamePath(fromFileName: metadata.fileName, serverUrl: metadata.serverUrl, urlBase: metadata.urlBase, userId: metadata.userId, account: metadata.account)!
  364. self.fileNamePreviewLocalPath = CCUtility.getDirectoryProviderStoragePreviewOcId(metadata.ocId, etag: metadata.etag)!
  365. self.fileNameIconLocalPath = CCUtility.getDirectoryProviderStorageIconOcId(metadata.ocId, etag: metadata.etag)!
  366. }
  367. override func start() {
  368. if isCancelled {
  369. self.finish()
  370. } else {
  371. var etagResource: String?
  372. if FileManager.default.fileExists(atPath: fileNameIconLocalPath) && FileManager.default.fileExists(atPath: fileNamePreviewLocalPath) {
  373. etagResource = metadata.etagResource
  374. }
  375. let options = NKRequestOptions(queue: NextcloudKit.shared.nkCommonInstance.backgroundQueue)
  376. NextcloudKit.shared.downloadPreview(
  377. fileNamePathOrFileId: fileNamePath,
  378. fileNamePreviewLocalPath: fileNamePreviewLocalPath,
  379. widthPreview: NCGlobal.shared.sizePreview,
  380. heightPreview: NCGlobal.shared.sizePreview,
  381. fileNameIconLocalPath: fileNameIconLocalPath,
  382. sizeIcon: NCGlobal.shared.sizeIcon,
  383. etag: etagResource,
  384. options: options) { _, _, imageIcon, _, etag, error in
  385. if error == .success, let imageIcon = imageIcon {
  386. NCManageDatabase.shared.setMetadataEtagResource(ocId: self.metadata.ocId, etagResource: etag)
  387. DispatchQueue.main.async {
  388. if self.metadata.ocId == self.cell?.fileObjectId, let filePreviewImageView = self.cell?.filePreviewImageView {
  389. UIView.transition(with: filePreviewImageView,
  390. duration: 0.75,
  391. options: .transitionCrossDissolve,
  392. animations: { filePreviewImageView.image = imageIcon },
  393. completion: nil)
  394. } else {
  395. if self.view is UICollectionView {
  396. (self.view as? UICollectionView)?.reloadData()
  397. } else if self.view is UITableView {
  398. (self.view as? UITableView)?.reloadData()
  399. }
  400. }
  401. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterDownloadedThumbnail, userInfo: ["ocId": self.metadata.ocId])
  402. }
  403. }
  404. self.finish()
  405. }
  406. }
  407. }
  408. }
  409. // MARK: -
  410. class NCOperationDownloadThumbnailActivity: ConcurrentOperation {
  411. var cell: NCActivityCollectionViewCell?
  412. var collectionView: UICollectionView?
  413. var fileNamePathOrFileId: String
  414. var fileNamePreviewLocalPath: String
  415. var fileId: String
  416. init(fileNamePathOrFileId: String, fileNamePreviewLocalPath: String, fileId: String, cell: NCActivityCollectionViewCell?, collectionView: UICollectionView?) {
  417. self.fileNamePathOrFileId = fileNamePathOrFileId
  418. self.fileNamePreviewLocalPath = fileNamePreviewLocalPath
  419. self.fileId = fileId
  420. self.cell = cell
  421. self.collectionView = collectionView
  422. }
  423. override func start() {
  424. if isCancelled {
  425. self.finish()
  426. } else {
  427. let options = NKRequestOptions(queue: NextcloudKit.shared.nkCommonInstance.backgroundQueue)
  428. NextcloudKit.shared.downloadPreview(
  429. fileNamePathOrFileId: fileNamePathOrFileId,
  430. fileNamePreviewLocalPath: fileNamePreviewLocalPath,
  431. widthPreview: 0,
  432. heightPreview: 0,
  433. etag: nil,
  434. useInternalEndpoint: false,
  435. options: options) { _, imagePreview, _, _, _, error in
  436. if error == .success, let imagePreview = imagePreview {
  437. DispatchQueue.main.async {
  438. if self.fileId == self.cell?.fileId, let imageView = self.cell?.imageView {
  439. UIView.transition(with: imageView,
  440. duration: 0.75,
  441. options: .transitionCrossDissolve,
  442. animations: { imageView.image = imagePreview },
  443. completion: nil)
  444. } else {
  445. self.collectionView?.reloadData()
  446. }
  447. }
  448. }
  449. self.finish()
  450. }
  451. }
  452. }
  453. }
  454. // MARK: -
  455. class NCOperationDownloadAvatar: ConcurrentOperation {
  456. var user: String
  457. var fileName: String
  458. var etag: String?
  459. var fileNameLocalPath: String
  460. var cell: NCCellProtocol!
  461. var view: UIView?
  462. var cellImageView: UIImageView?
  463. init(user: String, fileName: String, fileNameLocalPath: String, cell: NCCellProtocol, view: UIView?, cellImageView: UIImageView?) {
  464. self.user = user
  465. self.fileName = fileName
  466. self.fileNameLocalPath = fileNameLocalPath
  467. self.cell = cell
  468. self.view = view
  469. self.etag = NCManageDatabase.shared.getTableAvatar(fileName: fileName)?.etag
  470. self.cellImageView = cellImageView
  471. }
  472. override func start() {
  473. if isCancelled {
  474. self.finish()
  475. } else {
  476. let options = NKRequestOptions(queue: NextcloudKit.shared.nkCommonInstance.backgroundQueue)
  477. NextcloudKit.shared.downloadAvatar(user: user, fileNameLocalPath: fileNameLocalPath, sizeImage: NCGlobal.shared.avatarSize, avatarSizeRounded: NCGlobal.shared.avatarSizeRounded, etag: self.etag, options: options) { _, imageAvatar, _, etag, error in
  478. if error == .success, let imageAvatar = imageAvatar, let etag = etag {
  479. NCManageDatabase.shared.addAvatar(fileName: self.fileName, etag: etag)
  480. DispatchQueue.main.async {
  481. if self.user == self.cell.fileUser, let avatarImageView = self.cellImageView {
  482. UIView.transition(with: avatarImageView,
  483. duration: 0.75,
  484. options: .transitionCrossDissolve,
  485. animations: { avatarImageView.image = imageAvatar },
  486. completion: nil)
  487. } else {
  488. if self.view is UICollectionView {
  489. (self.view as? UICollectionView)?.reloadData()
  490. } else if self.view is UITableView {
  491. (self.view as? UITableView)?.reloadData()
  492. }
  493. }
  494. }
  495. } else if error.errorCode == NCGlobal.shared.errorNotModified {
  496. NCManageDatabase.shared.setAvatarLoaded(fileName: self.fileName)
  497. }
  498. self.finish()
  499. }
  500. }
  501. }
  502. }
  503. // MARK: -
  504. class NCOperationUnifiedSearch: ConcurrentOperation {
  505. var collectionViewCommon: NCCollectionViewCommon
  506. var metadatas: [tableMetadata]
  507. var searchResult: NKSearchResult
  508. init(collectionViewCommon: NCCollectionViewCommon, metadatas: [tableMetadata], searchResult: NKSearchResult) {
  509. self.collectionViewCommon = collectionViewCommon
  510. self.metadatas = metadatas
  511. self.searchResult = searchResult
  512. }
  513. func reloadDataThenPerform(_ closure: @escaping (() -> Void)) {
  514. DispatchQueue.main.asyncAfter(deadline: .now() + 0.1) {
  515. CATransaction.begin()
  516. CATransaction.setCompletionBlock(closure)
  517. self.collectionViewCommon.collectionView.reloadData()
  518. CATransaction.commit()
  519. }
  520. }
  521. override func start() {
  522. if isCancelled {
  523. self.finish()
  524. } else {
  525. self.collectionViewCommon.dataSource.addSection(metadatas: metadatas, searchResult: searchResult)
  526. self.collectionViewCommon.searchResults?.append(self.searchResult)
  527. reloadDataThenPerform {
  528. self.finish()
  529. }
  530. }
  531. }
  532. }
  533. // MARK: -
  534. class NCOperationReadFile: ConcurrentOperation {
  535. var serverUrlFileName: String
  536. init(serverUrlFileName: String) {
  537. self.serverUrlFileName = serverUrlFileName
  538. }
  539. override func start() {
  540. if isCancelled {
  541. self.finish()
  542. } else {
  543. NCNetworking.shared.readFile(serverUrlFileName: serverUrlFileName) { account, metadata, error in
  544. if error == .success, let metadata = metadata {
  545. NCManageDatabase.shared.addMetadata(metadata)
  546. if metadata.directory {
  547. NCManageDatabase.shared.addDirectory(encrypted: metadata.e2eEncrypted, favorite: metadata.favorite, ocId: metadata.ocId, fileId: metadata.fileId, etag: nil, permissions: metadata.permissions, serverUrl: self.serverUrlFileName, account: account)
  548. }
  549. NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterOperationReadFile, userInfo: ["ocId": metadata.ocId])
  550. }
  551. }
  552. }
  553. }
  554. }