metatext/ServiceLayer/Sources/ServiceLayer/Services/TimelineService.swift

49 lines
1.8 KiB
Swift
Raw Normal View History

2020-10-05 07:04:15 +00:00
// Copyright © 2020 Metabolist. All rights reserved.
import Combine
import DB
import Foundation
import Mastodon
import MastodonAPI
2020-10-05 19:11:41 +00:00
public struct TimelineService {
2020-10-05 07:04:15 +00:00
public let sections: AnyPublisher<[[CollectionItem]], Error>
public let navigationService: NavigationService
2020-10-05 20:21:06 +00:00
public let nextPageMaxIDs: AnyPublisher<String, Never>
public let title: AnyPublisher<String, Never>
2020-10-05 07:04:15 +00:00
public let contextParentID: String? = nil
private let timeline: Timeline
private let mastodonAPIClient: MastodonAPIClient
private let contentDatabase: ContentDatabase
2020-10-05 20:21:06 +00:00
private let nextPageMaxIDsSubject = PassthroughSubject<String, Never>()
2020-10-05 07:04:15 +00:00
init(timeline: Timeline, mastodonAPIClient: MastodonAPIClient, contentDatabase: ContentDatabase) {
self.timeline = timeline
self.mastodonAPIClient = mastodonAPIClient
self.contentDatabase = contentDatabase
sections = contentDatabase.observation(timeline: timeline)
2020-10-05 19:58:03 +00:00
navigationService = NavigationService(mastodonAPIClient: mastodonAPIClient, contentDatabase: contentDatabase)
2020-10-05 07:04:15 +00:00
nextPageMaxIDs = nextPageMaxIDsSubject.eraseToAnyPublisher()
if case let .tag(tag) = timeline {
2020-10-05 20:21:06 +00:00
title = Just("#".appending(tag)).eraseToAnyPublisher()
2020-10-05 07:04:15 +00:00
} else {
2020-10-05 20:21:06 +00:00
title = Empty().eraseToAnyPublisher()
2020-10-05 07:04:15 +00:00
}
}
2020-10-05 19:11:41 +00:00
}
2020-10-05 07:04:15 +00:00
2020-10-05 19:11:41 +00:00
extension TimelineService: CollectionService {
2020-10-05 07:04:15 +00:00
public func request(maxID: String?, minID: String?) -> AnyPublisher<Never, Error> {
mastodonAPIClient.pagedRequest(timeline.endpoint, maxID: maxID, minID: minID)
2020-10-05 20:21:06 +00:00
.handleEvents(receiveOutput: {
guard let maxID = $0.info.maxID else { return }
nextPageMaxIDsSubject.send(maxID)
})
2020-10-05 07:04:15 +00:00
.flatMap { contentDatabase.insert(statuses: $0.result, timeline: timeline) }
.eraseToAnyPublisher()
}
}