// // DiscoveryCommunityViewModel+State.swift // Mastodon // // Created by MainasuK on 2022-4-29. // import os.log import Foundation import GameplayKit import MastodonSDK extension DiscoveryCommunityViewModel { class State: GKState, NamingState { let logger = Logger(subsystem: "DiscoveryCommunityViewModel.State", category: "StateMachine") let id = UUID() var name: String { String(describing: Self.self) } weak var viewModel: DiscoveryCommunityViewModel? init(viewModel: DiscoveryCommunityViewModel) { self.viewModel = viewModel } override func didEnter(from previousState: GKState?) { super.didEnter(from: previousState) let previousState = previousState as? DiscoveryCommunityViewModel.State logger.log(level: .debug, "\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public): [\(self.id.uuidString)] enter \(self.name), previous: \(previousState?.name ?? "")") } @MainActor func enter(state: State.Type) { stateMachine?.enter(state) } deinit { logger.log(level: .debug, "\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public): [\(self.id.uuidString)] \(self.name)") } } } extension DiscoveryCommunityViewModel.State { class Initial: DiscoveryCommunityViewModel.State { override func isValidNextState(_ stateClass: AnyClass) -> Bool { switch stateClass { case is Reloading.Type: return true default: return false } } } class Reloading: DiscoveryCommunityViewModel.State { override func isValidNextState(_ stateClass: AnyClass) -> Bool { switch stateClass { case is Loading.Type: return true default: return false } } override func didEnter(from previousState: GKState?) { super.didEnter(from: previousState) guard let _ = viewModel, let stateMachine = stateMachine else { return } stateMachine.enter(Loading.self) } } class Fail: DiscoveryCommunityViewModel.State { override func isValidNextState(_ stateClass: AnyClass) -> Bool { switch stateClass { case is Loading.Type: return true default: return false } } override func didEnter(from previousState: GKState?) { super.didEnter(from: previousState) guard let _ = viewModel, let stateMachine = stateMachine else { return } os_log(.info, log: .debug, "%{public}s[%{public}ld], %{public}s: retry loading 3s later…", ((#file as NSString).lastPathComponent), #line, #function) DispatchQueue.main.asyncAfter(deadline: .now() + 3) { os_log(.info, log: .debug, "%{public}s[%{public}ld], %{public}s: retry loading", ((#file as NSString).lastPathComponent), #line, #function) stateMachine.enter(Loading.self) } } } class Idle: DiscoveryCommunityViewModel.State { override func isValidNextState(_ stateClass: AnyClass) -> Bool { switch stateClass { case is Reloading.Type, is Loading.Type: return true default: return false } } } class Loading: DiscoveryCommunityViewModel.State { var maxID: String? override func isValidNextState(_ stateClass: AnyClass) -> Bool { switch stateClass { case is Fail.Type: return true case is Idle.Type: return true case is NoMore.Type: return true default: return false } } override func didEnter(from previousState: GKState?) { super.didEnter(from: previousState) guard let viewModel = viewModel, let stateMachine = stateMachine else { return } switch previousState { case is Reloading: maxID = nil default: break } guard let authenticationBox = viewModel.context.authenticationService.activeMastodonAuthenticationBox.value else { stateMachine.enter(Fail.self) return } let maxID = self.maxID let isReloading = maxID == nil Task { do { let response = try await viewModel.context.apiService.publicTimeline( query: .init( local: true, remote: nil, onlyMedia: nil, maxID: maxID, sinceID: nil, minID: nil, limit: 20 ), authenticationBox: authenticationBox ) let newMaxID = response.link?.maxID let hasMore = newMaxID != nil self.maxID = newMaxID var hasNewStatusesAppend = false var statusIDs = isReloading ? [] : viewModel.statusFetchedResultsController.statusIDs.value for status in response.value { guard !statusIDs.contains(status.id) else { continue } statusIDs.append(status.id) hasNewStatusesAppend = true } if hasNewStatusesAppend, hasMore { self.maxID = response.link?.maxID await enter(state: Idle.self) } else { await enter(state: NoMore.self) } viewModel.statusFetchedResultsController.statusIDs.value = statusIDs viewModel.didLoadLatest.send() } catch { logger.log(level: .debug, "\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public): fetch user timeline fail: \(error.localizedDescription)") await enter(state: Fail.self) } } // end Task } // end func } class NoMore: DiscoveryCommunityViewModel.State { override func isValidNextState(_ stateClass: AnyClass) -> Bool { switch stateClass { case is Reloading.Type: return true default: return false } } override func didEnter(from previousState: GKState?) { super.didEnter(from: previousState) } } }