//
//  CloudKitReceiveStatusOperation.swift
//  Account
//
//  Created by Maurice Parker on 5/2/20.
//  Copyright © 2020 Ranchero Software, LLC. All rights reserved.
//

import Foundation
import os.log
import Core

@MainActor public final class CloudKitReceiveStatusOperation: MainThreadOperation {

	private var log = OSLog(subsystem: Bundle.main.bundleIdentifier!, category: "CloudKit")

	// MainThreadOperation
	public var isCanceled = false
	public var id: Int?
	public weak var operationDelegate: MainThreadOperationDelegate?
	public var name: String? = "CloudKitReceiveStatusOperation"
	public var completionBlock: MainThreadOperation.MainThreadOperationCompletionBlock?

	private weak var articlesZone: CloudKitArticlesZone?
	
	public init(articlesZone: CloudKitArticlesZone) {
		self.articlesZone = articlesZone
	}
	
	@MainActor public func run() {

		guard let articlesZone else {
			operationDelegate?.operationDidComplete(self)
			return
		}
		
		os_log(.debug, log: log, "Refreshing article statuses...")
		
		Task { @MainActor in
			do {
				try await articlesZone.refreshArticles()
				self.operationDelegate?.operationDidComplete(self)
			} catch {
				os_log(.error, log: self.log, "Receive status error: %@.", error.localizedDescription)
				self.operationDelegate?.cancelOperation(self)
			}

			os_log(.debug, log: self.log, "Done refreshing article statuses.")
		}
	}
}