FreshRSS/NetNewsWire
1
0
Fork 0
mirror of https://github.com/Ranchero-Software/NetNewsWire.git synced 2025-02-08 08:08:43 +01:00
Code Issues Packages Projects Releases Wiki Activity

Create syncStreamContents function to replace FeedlySyncStreamContentsOperation.

Browse Source
This commit is contained in:
Brent Simmons 2024-04-28 21:34:12 -07:00
parent c6c457e718
commit 2cde31a523
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
Account/Sources/Account/AccountDelegates/FeedlyAccountDelegate.swift
View File

@ -644,6 +644,12 @@ final class FeedlyAccountDelegate: AccountDelegate {
return articleIDs
}
func updateAccountFeeds(parsedItems: Set<ParsedItem>) async throws {
let feedIDsAndItems = parsedItemsKeyedByFeedURL(parsedItems)
try await updateAccountFeedsWithItems(feedIDsAndItems: feedIDsAndItems)
}
func updateAccountFeedsWithItems(feedIDsAndItems: [String: Set<ParsedItem>]) async throws {
// To replace FeedlyUpdateAccountFeedsWithItemsOperation
@ -722,9 +728,7 @@ final class FeedlyAccountDelegate: AccountDelegate {
for articleIDs in Array(allArticleIDs).chunked(into: feedlyAPILimitBatchSize) {
let parsedItems = try await fetchParsedItems(articleIDs: Set(articleIDs))
let feedIDsAndItems = parsedItemsKeyedByFeedURL(parsedItems)
try await updateAccountFeedsWithItems(feedIDsAndItems: feedIDsAndItems)
try await updateAccountFeeds(parsedItems: parsedItems)
}
}
@ -812,12 +816,12 @@ final class FeedlyAccountDelegate: AccountDelegate {
try await caller.getFeeds(for: url, count: 1, localeIdentifier: Locale.current.identifier)
}
func fetchStreamContents(resource: FeedlyResourceID, continuation: String? = nil, newerThan: Date?, unreadOnly: Bool? = nil) async throws -> Set<ParsedItem> {
func fetchStreamContents(resourceID: FeedlyResourceID, continuation: String? = nil, newerThan: Date?, unreadOnly: Bool? = nil) async throws -> Set<ParsedItem> {
// To replace FeedlyGetStreamContentsOperation
do {
let stream = try await caller.getStreamContents(for: resource, continuation: continuation, newerThan: newerThan, unreadOnly: unreadOnly)
let stream = try await caller.getStreamContents(for: resourceID, continuation: continuation, newerThan: newerThan, unreadOnly: unreadOnly)
return parsedItems(with: Set(stream.items))
} catch {
os_log(.debug, log: self.log, "Unable to get stream contents: %{public}@.", error as NSError)
@ -936,11 +940,19 @@ final class FeedlyAccountDelegate: AccountDelegate {
// To replace FeedlyIngestStreamArticleIDsOperation
guard let account else { return }
let allArticleIDs = try await fetchAllArticleIDs()
try await account.createStatusesIfNeeded(articleIDs: allArticleIDs)
}
func syncStreamContents(feedResourceID: FeedlyFeedResourceID) async throws {
// To replace FeedlySyncStreamContentsOperation
let parsedItems = try await fetchStreamContents(resourceID: feedResourceID, newerThan: nil)
try await updateAccountFeeds(parsedItems: parsedItems)
}
// MARK: Suspend and Resume (for iOS)
/// Suspend all network activity