mirror of
https://github.com/metabolist/metatext.git
synced 2024-09-27 14:00:05 +00:00
153 lines
5.5 KiB
Swift
153 lines
5.5 KiB
Swift
// Copyright © 2020 Metabolist. All rights reserved.
|
|
|
|
import Combine
|
|
import Foundation
|
|
import Mastodon
|
|
import ServiceLayer
|
|
|
|
public final class NavigationViewModel: ObservableObject {
|
|
public let identityContext: IdentityContext
|
|
public let timelineNavigations: AnyPublisher<Timeline, Never>
|
|
public let followRequestNavigations: AnyPublisher<CollectionViewModel, Never>
|
|
|
|
@Published public private(set) var recentIdentities = [Identity]()
|
|
@Published public var presentingSecondaryNavigation = false
|
|
@Published public var alertItem: AlertItem?
|
|
|
|
public lazy var exploreViewModel: ExploreViewModel = {
|
|
let exploreViewModel = ExploreViewModel(
|
|
service: identityContext.service.exploreService(),
|
|
identityContext: identityContext)
|
|
|
|
// TODO: initial request
|
|
|
|
return exploreViewModel
|
|
}()
|
|
|
|
public lazy var conversationsViewModel: CollectionViewModel? = {
|
|
if identityContext.identity.authenticated {
|
|
let conversationsViewModel = CollectionItemsViewModel(
|
|
collectionService: identityContext.service.conversationsService(),
|
|
identityContext: identityContext)
|
|
|
|
conversationsViewModel.request(maxId: nil, minId: nil, search: nil)
|
|
|
|
return conversationsViewModel
|
|
} else {
|
|
return nil
|
|
}
|
|
}()
|
|
|
|
private let timelineNavigationsSubject = PassthroughSubject<Timeline, Never>()
|
|
private let followRequestNavigationsSubject = PassthroughSubject<CollectionViewModel, Never>()
|
|
private var cancellables = Set<AnyCancellable>()
|
|
|
|
public init(identityContext: IdentityContext) {
|
|
self.identityContext = identityContext
|
|
timelineNavigations = timelineNavigationsSubject.eraseToAnyPublisher()
|
|
followRequestNavigations = followRequestNavigationsSubject.eraseToAnyPublisher()
|
|
|
|
identityContext.$identity
|
|
.sink { [weak self] _ in self?.objectWillChange.send() }
|
|
.store(in: &cancellables)
|
|
|
|
identityContext.service.recentIdentitiesPublisher()
|
|
.assignErrorsToAlertItem(to: \.alertItem, on: self)
|
|
.assign(to: &$recentIdentities)
|
|
}
|
|
}
|
|
|
|
public extension NavigationViewModel {
|
|
enum Tab: CaseIterable {
|
|
case timelines
|
|
case explore
|
|
case notifications
|
|
case messages
|
|
}
|
|
|
|
var tabs: [Tab] {
|
|
if identityContext.identity.authenticated {
|
|
return Tab.allCases
|
|
} else {
|
|
return [.timelines, .explore]
|
|
}
|
|
}
|
|
|
|
var timelines: [Timeline] {
|
|
if identityContext.identity.authenticated {
|
|
return Timeline.authenticatedDefaults
|
|
} else {
|
|
return Timeline.unauthenticatedDefaults
|
|
}
|
|
}
|
|
|
|
func refreshIdentity() {
|
|
if identityContext.identity.pending {
|
|
identityContext.service.verifyCredentials()
|
|
.collect()
|
|
.map { _ in () }
|
|
.flatMap(identityContext.service.confirmIdentity)
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
} else if identityContext.identity.authenticated {
|
|
identityContext.service.verifyCredentials()
|
|
.assignErrorsToAlertItem(to: \.alertItem, on: self)
|
|
.sink { _ in }
|
|
.store(in: &cancellables)
|
|
identityContext.service.refreshLists()
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
identityContext.service.refreshFilters()
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
identityContext.service.refreshEmojis()
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
identityContext.service.refreshAnnouncements()
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
|
|
if identityContext.identity.preferences.useServerPostingReadingPreferences {
|
|
identityContext.service.refreshServerPreferences()
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
}
|
|
}
|
|
|
|
identityContext.service.refreshInstance()
|
|
.sink { _ in } receiveValue: { _ in }
|
|
.store(in: &cancellables)
|
|
}
|
|
|
|
func navigate(timeline: Timeline) {
|
|
presentingSecondaryNavigation = false
|
|
timelineNavigationsSubject.send(timeline)
|
|
}
|
|
|
|
func navigateToFollowerRequests() {
|
|
let followRequestsViewModel = CollectionItemsViewModel(
|
|
collectionService: identityContext.service.service(
|
|
accountList: .followRequests,
|
|
titleComponents: ["follow-requests"]),
|
|
identityContext: identityContext)
|
|
|
|
presentingSecondaryNavigation = false
|
|
followRequestNavigationsSubject.send(followRequestsViewModel)
|
|
}
|
|
|
|
func viewModel(timeline: Timeline) -> CollectionItemsViewModel {
|
|
CollectionItemsViewModel(
|
|
collectionService: identityContext.service.service(timeline: timeline),
|
|
identityContext: identityContext)
|
|
}
|
|
|
|
func notificationsViewModel(excludeTypes: Set<MastodonNotification.NotificationType>) -> CollectionItemsViewModel {
|
|
let viewModel = CollectionItemsViewModel(
|
|
collectionService: identityContext.service.notificationsService(excludeTypes: excludeTypes),
|
|
identityContext: identityContext)
|
|
|
|
viewModel.request(maxId: nil, minId: nil, search: nil)
|
|
|
|
return viewModel
|
|
}
|
|
}
|