space-ios/iOSClient/Networking/NCNetworking+LivePhoto.swift

//
//  NCNetworking+LivePhoto.swift
//  Nextcloud
//
//  Created by Marino Faggiana on 07/02/24.
//  Copyright © 2024 Marino Faggiana. All rights reserved.
//
//  Author Marino Faggiana <marino.faggiana@nextcloud.com>
//
//  This program is free software: you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  (at your option) any later version.
//
//  This program is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program.  If not, see <http://www.gnu.org/licenses/>.
//

import UIKit
import JGProgressHUD
import NextcloudKit
import Alamofire
import Queuer

extension NCNetworking {
    func uploadLivePhoto(metadata: tableMetadata, userInfo aUserInfo: [AnyHashable: Any]) {
        guard let metadata1 = NCManageDatabase.shared.getMetadata(predicate: NSPredicate(format: "account == %@ AND urlBase == %@ AND path == %@ AND fileName == %@", metadata.account, metadata.urlBase, metadata.path, metadata.livePhotoFile)) else {
            metadata.livePhotoFile = ""
            NCManageDatabase.shared.addMetadata(metadata)
            return NotificationCenter.default.post(name: Notification.Name(rawValue: NCGlobal.shared.notificationCenterUploadedLivePhoto),
                                                   object: nil,
                                                   userInfo: aUserInfo)
        }
        if metadata1.status != NCGlobal.shared.metadataStatusNormal { return }

        Task {
            let serverUrlfileNamePath = metadata.urlBase + metadata.path + metadata.fileName
            var livePhotoFile = metadata1.fileId
            let results = await setLivephoto(serverUrlfileNamePath: serverUrlfileNamePath, livePhotoFile: livePhotoFile, account: metadata.account)
            if results.error == .success {
                NCManageDatabase.shared.setMetadataLivePhotoByServer(account: metadata.account, ocId: metadata.ocId, livePhotoFile: livePhotoFile)
            } else {
                NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Uplod set LivePhoto with error \(results.error.errorCode)")
            }

            let serverUrlfileNamePath1 = metadata1.urlBase + metadata1.path + metadata1.fileName
            livePhotoFile = metadata.fileId
            let results1 = await setLivephoto(serverUrlfileNamePath: serverUrlfileNamePath1, livePhotoFile: livePhotoFile, account: metadata1.account)
            if results1.error == .success {
                NCManageDatabase.shared.setMetadataLivePhotoByServer(account: metadata1.account, ocId: metadata1.ocId, livePhotoFile: livePhotoFile)
            } else {
                NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Upload set LivePhoto with error \(results.error.errorCode)")
            }
            if results.error == .success, results1.error == .success {
                NextcloudKit.shared.nkCommonInstance.writeLog("[INFO] Upload set LivePhoto for files " + (metadata.fileName as NSString).deletingPathExtension)

            }
            NotificationCenter.default.post(name: Notification.Name(rawValue: NCGlobal.shared.notificationCenterUploadedLivePhoto),
                                            object: nil,
                                            userInfo: aUserInfo)
        }
    }

    func convertLivePhoto(metadata: tableMetadata) {
        guard metadata.status == NCGlobal.shared.metadataStatusNormal else { return }
        let account = metadata.account
        let livePhotoFile = metadata.livePhotoFile
        let serverUrlfileNamePath = metadata.urlBase + metadata.path + metadata.fileName
        let ocId = metadata.ocId

        DispatchQueue.global().async {
            if let result = NCManageDatabase.shared.getResultMetadata(predicate: NSPredicate(format: "account == %@ AND status == %d AND (fileName == %@ || fileId == %@)", account, NCGlobal.shared.metadataStatusNormal, livePhotoFile, livePhotoFile)) {
                if livePhotoFile == result.fileId { return }
                for case let operation as NCOperationConvertLivePhoto in self.convertLivePhotoQueue.operations where operation.serverUrlfileNamePath == serverUrlfileNamePath { continue }
                self.convertLivePhotoQueue.addOperation(NCOperationConvertLivePhoto(serverUrlfileNamePath: serverUrlfileNamePath, livePhotoFile: result.fileId, account: account, ocId: ocId))
            }
        }
    }
}

class NCOperationConvertLivePhoto: ConcurrentOperation {
    var serverUrlfileNamePath, livePhotoFile, account, ocId: String

    init(serverUrlfileNamePath: String, livePhotoFile: String, account: String, ocId: String) {
        self.serverUrlfileNamePath = serverUrlfileNamePath
        self.livePhotoFile = livePhotoFile
        self.account = account
        self.ocId = ocId
    }

    override func start() {
        guard !isCancelled else {
            return self.finish()
        }

        NextcloudKit.shared.setLivephoto(serverUrlfileNamePath: serverUrlfileNamePath, livePhotoFile: livePhotoFile, account: account, options: NKRequestOptions(queue: NextcloudKit.shared.nkCommonInstance.backgroundQueue)) { _, error in
            if error == .success {
                NCManageDatabase.shared.setMetadataLivePhotoByServer(account: self.account, ocId: self.ocId, livePhotoFile: self.livePhotoFile)
            } else {
                NextcloudKit.shared.nkCommonInstance.writeLog("[ERROR] Convert LivePhoto with error \(error.errorCode)")
            }
            self.finish()
            if NCNetworking.shared.convertLivePhotoQueue.operationCount == 0 {
                NotificationCenter.default.postOnMainThread(name: NCGlobal.shared.notificationCenterReloadDataSource, second: 0.1)
            }
        }
    }
}