98 lines
3.2 KiB
Swift
98 lines
3.2 KiB
Swift
//
|
|
// DriveService+Versions.swift
|
|
// Harmony-Drive
|
|
//
|
|
// Created by Hthik on 11/20/18.
|
|
// Copyright © 2018 Hthik. All rights reserved.
|
|
//
|
|
|
|
import Foundation
|
|
import CoreData
|
|
|
|
import Harmony
|
|
import Roxas
|
|
|
|
import GoogleAPIClientForREST
|
|
|
|
public extension DriveService
|
|
{
|
|
func fetchVersions(for record: AnyRecord, completionHandler: @escaping (Result<[Version], RecordError>) -> Void) -> Progress
|
|
{
|
|
let progress = Progress.discreteProgress(totalUnitCount: 1)
|
|
|
|
do
|
|
{
|
|
try record.perform { (managedRecord) -> Void in
|
|
guard let remoteRecord = managedRecord.remoteRecord else { throw ValidationError.nilRemoteRecord }
|
|
|
|
let query = GTLRDriveQuery_RevisionsList.query(withFileId: remoteRecord.identifier)
|
|
|
|
let ticket = self.service.executeQuery(query) { (ticket, object, error) in
|
|
do
|
|
{
|
|
let revisions = try self.process(Result((object as? GTLRDrive_RevisionList)?.revisions, error))
|
|
|
|
let versions = revisions.lazy.compactMap(Version.init(revision:)).reversed()
|
|
completionHandler(.success(Array(versions)))
|
|
|
|
progress.completedUnitCount = 1
|
|
}
|
|
catch
|
|
{
|
|
completionHandler(.failure(RecordError(record, error)))
|
|
}
|
|
}
|
|
|
|
progress.cancellationHandler = {
|
|
ticket.cancel()
|
|
completionHandler(.failure(.other(record, GeneralError.cancelled)))
|
|
}
|
|
}
|
|
}
|
|
catch
|
|
{
|
|
completionHandler(.failure(RecordError(record, error)))
|
|
}
|
|
|
|
return progress
|
|
}
|
|
|
|
func fetchVersions(for remoteFile: RemoteFile, completionHandler: @escaping (Result<[Version], FileError>) -> Void) -> Progress
|
|
{
|
|
let progress = Progress.discreteProgress(totalUnitCount: 1)
|
|
let fileIdentifier = remoteFile.identifier
|
|
|
|
do
|
|
{
|
|
let query = GTLRDriveQuery_RevisionsList.query(withFileId: remoteFile.remoteIdentifier)
|
|
|
|
let ticket = self.service.executeQuery(query) { (ticket, object, error) in
|
|
do
|
|
{
|
|
let revisions = try self.process(Result((object as? GTLRDrive_RevisionList)?.revisions, error))
|
|
|
|
let versions = revisions.lazy.compactMap(Version.init(revision:)).reversed()
|
|
completionHandler(.success(Array(versions)))
|
|
|
|
progress.completedUnitCount = 1
|
|
}
|
|
catch
|
|
{
|
|
completionHandler(.failure(FileError(fileIdentifier, error)))
|
|
}
|
|
}
|
|
|
|
progress.cancellationHandler = {
|
|
ticket.cancel()
|
|
completionHandler(.failure(FileError(fileIdentifier, GeneralError.cancelled)))
|
|
}
|
|
}
|
|
catch
|
|
{
|
|
completionHandler(.failure(FileError(fileIdentifier, error)))
|
|
}
|
|
|
|
return progress
|
|
}
|
|
}
|