120 lines
3.5 KiB
Swift
120 lines
3.5 KiB
Swift
import Combine
|
|
import CoreData
|
|
import Foundation
|
|
import Models
|
|
import SwiftGraphQL
|
|
|
|
public extension DataService {
|
|
// swiftlint:disable:next function_body_length
|
|
func libraryItemsPublisher(
|
|
limit: Int,
|
|
sortDescending: Bool,
|
|
searchQuery: String?,
|
|
cursor: String?
|
|
) -> AnyPublisher<HomeFeedData, ServerError> {
|
|
enum QueryResult {
|
|
case success(result: HomeFeedData)
|
|
case error(error: String)
|
|
}
|
|
|
|
let selection = Selection<QueryResult, Unions.ArticlesResult> {
|
|
try $0.on(
|
|
articlesSuccess: .init {
|
|
QueryResult.success(
|
|
result: HomeFeedData(
|
|
items: try $0.edges(selection: articleEdgeSelection.list),
|
|
cursor: try $0.pageInfo(selection: Selection.PageInfo {
|
|
try $0.endCursor()
|
|
})
|
|
)
|
|
)
|
|
},
|
|
articlesError: .init {
|
|
QueryResult.error(error: try $0.errorCodes().description)
|
|
}
|
|
)
|
|
}
|
|
|
|
let query = Selection.Query {
|
|
try $0.articles(
|
|
sharedOnly: .present(false),
|
|
sort: OptionalArgument(
|
|
InputObjects.SortParams(
|
|
order: .present(sortDescending ? .descending : .ascending),
|
|
by: .updatedTime
|
|
)
|
|
),
|
|
after: OptionalArgument(cursor),
|
|
first: OptionalArgument(limit),
|
|
query: OptionalArgument(searchQuery),
|
|
selection: selection
|
|
)
|
|
}
|
|
|
|
let path = appEnvironment.graphqlPath
|
|
let headers = networker.defaultHeaders
|
|
|
|
return Deferred {
|
|
Future { promise in
|
|
send(query, to: path, headers: headers) { result in
|
|
switch result {
|
|
case let .success(payload):
|
|
switch payload.data {
|
|
case let .success(result: result):
|
|
// save items to coredata
|
|
_ = result.items.persist(context: self.backgroundContext)
|
|
promise(.success(result))
|
|
case .error:
|
|
promise(.failure(.unknown))
|
|
}
|
|
case .failure:
|
|
promise(.failure(.unknown))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
.receive(on: DispatchQueue.main)
|
|
.eraseToAnyPublisher()
|
|
}
|
|
|
|
func cachedFeedItems() -> [FeedItemDep] {
|
|
var result = [FeedItemDep]()
|
|
|
|
backgroundContext.performAndWait {
|
|
let fetchRequest: NSFetchRequest<Models.LinkedItem> = LinkedItem.fetchRequest()
|
|
fetchRequest.sortDescriptors = [NSSortDescriptor(keyPath: \LinkedItem.savedAt, ascending: false)]
|
|
let items = (try? backgroundContext.fetch(fetchRequest)) ?? []
|
|
result = items.map { FeedItemDep.make(from: $0) }
|
|
}
|
|
|
|
return result
|
|
}
|
|
}
|
|
|
|
let homeFeedItemSelection = Selection.Article {
|
|
FeedItemDep(
|
|
id: try $0.id(),
|
|
title: try $0.title(),
|
|
createdAt: try $0.createdAt().value ?? Date(),
|
|
savedAt: try $0.savedAt().value ?? Date(),
|
|
readingProgress: try $0.readingProgressPercent(),
|
|
readingProgressAnchor: try $0.readingProgressAnchorIndex(),
|
|
imageURLString: try $0.image(),
|
|
onDeviceImageURLString: nil,
|
|
documentDirectoryPath: nil,
|
|
pageURLString: try $0.url(),
|
|
descriptionText: try $0.description(),
|
|
publisherURLString: try $0.originalArticleUrl(),
|
|
author: try $0.author(),
|
|
publishDate: try $0.publishedAt()?.value,
|
|
slug: try $0.slug(),
|
|
isArchived: try $0.isArchived(),
|
|
contentReader: try $0.contentReader().rawValue,
|
|
labels: try $0.labels(selection: feedItemLabelSelection.list.nullable) ?? []
|
|
)
|
|
}
|
|
|
|
private let articleEdgeSelection = Selection.ArticleEdge {
|
|
try $0.node(selection: homeFeedItemSelection)
|
|
}
|