mirrors/IceCubesApp
1
0
Fork 0
mirror of https://github.com/Dimillian/IceCubesApp.git synced 2024-05-21 01:38:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: concurrency code for RSSTools

Browse source
This commit is contained in:
Duong Thai 2024-03-15 10:41:43 +07:00
parent ff452338dc
commit 1439e29d64
2 changed files with 31 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
Packages/RSS/Sources/RSS/RSSTools.swift
View file

@ -191,7 +191,7 @@ enum RSSTools {
}
@MainActor
static func load(feedURL: URL) async -> RSSFeed? {
static func load(feedURL: URL) async -> Void? {
let sendableFeed = await Task.detached {
await RSSTools.getFeedData(from: feedURL)
}.value
@ -203,15 +203,31 @@ enum RSSTools {
await sendableFeed.getSendableItemData()
}.value
return await backgroundContext.perform {
let rssFeed = RSSFeed(context: backgroundContext, sendableData: sendableFeed)
let rssFeed = RSSFeed(context: backgroundContext, sendableData: sendableFeed)
let rssItems = sendableItems.compactMap {
RSSItem(context: backgroundContext, sendableData: $0)
}
rssFeed.items = NSSet(array: rssItems)
return rssFeed
let rssItems = sendableItems.compactMap {
RSSItem(context: backgroundContext, sendableData: $0)
}
for item in rssItems { item.feed = rssFeed }
return try? backgroundContext.save()
}
@MainActor
static func fetchFeed(url: URL) async -> RSSFeed? {
let request: NSFetchRequest<RSSFeed> = {
let request = RSSFeed.fetchRequest()
request.fetchLimit = 1
request.predicate = NSPredicate(format: "%K = %@",
#keyPath(RSSFeed.feedURL),
url as CVarArg)
request.relationshipKeyPathsForPrefetching = ["items"]
return request
}()
let context = RSSDataController.shared.viewContext
guard let feed = (try? context.fetch(request))?.first else { return nil }
return feed
}
@MainActor

10
Packages/RSS/Sources/RSS/Views/RSSAddNewFeed.swift
View file

@ -66,10 +66,14 @@ public struct RSSAddNewFeed: View {
feed?.managedObjectContext?.rollback()
downloadingTask = Task {
let rssFeed = await RSSTools.load(feedURL: url)
guard let _ = await RSSTools.load(feedURL: url),
let rssFeed = await RSSTools.fetchFeed(url: url)
else {
self.state = .noData(url: url)
return
}
if Task.isCancelled { return }
if let rssFeed { self.state = .downloaded(feed: rssFeed, url: url) }
else { self.state = .noData(url: url) }
self.state = .downloaded(feed: rssFeed, url: url)
}
case .downloaded(let feed, _):
self.feed = feed