FreshRSS/NetNewsWire
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Delete last completion-based method in SyncDatabase.

Browse Source
This commit is contained in:
Brent Simmons 2024-03-25 22:47:43 -07:00
parent c50ac0c84b
commit 4a5cb237a0
6 changed files with 79 additions and 117 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
Account/Sources/Account/CloudKit/CloudKitSendStatusOperation.swift
View File

@ -69,37 +69,33 @@ class CloudKitSendStatusOperation: MainThreadOperation {
private extension CloudKitSendStatusOperation { private extension CloudKitSendStatusOperation {
func selectForProcessing() { func selectForProcessing() {
database.selectForProcessing(limit: blockSize) { result in
MainActor.assumeIsolated { Task { @MainActor in
switch result {
case .success(let syncStatuses):
@MainActor func stopProcessing() { @MainActor func stopProcessing() {
if self.showProgress { if self.showProgress {
self.refreshProgress?.completeTask() self.refreshProgress?.completeTask()
}
os_log(.debug, log: self.log, "Done sending article statuses.")
self.operationDelegate?.operationDidComplete(self)
}
guard syncStatuses.count > 0 else {
stopProcessing()
return
}
self.processStatuses(syncStatuses) { stop in
if stop {
stopProcessing()
} else {
self.selectForProcessing()
}
}
case .failure(let databaseError):
os_log(.error, log: self.log, "Send status error: %@.", databaseError.localizedDescription)
self.operationDelegate?.cancelOperation(self)
} }
os_log(.debug, log: self.log, "Done sending article statuses.")
self.operationDelegate?.operationDidComplete(self)
}
do {
guard let syncStatuses = try await self.database.selectForProcessing(limit: blockSize), !syncStatuses.isEmpty else {
stopProcessing()
return
}
self.processStatuses(Array(syncStatuses)) { stop in
if stop {
stopProcessing()
} else {
self.selectForProcessing()
}
}
} catch {
os_log(.error, log: self.log, "Send status error: %@.", error.localizedDescription)
self.operationDelegate?.cancelOperation(self)
} }
} }
} }

17
Account/Sources/Account/Feedbin/FeedbinAccountDelegate.swift
View File

@ -134,9 +134,12 @@ final class FeedbinAccountDelegate: AccountDelegate {
os_log(.debug, log: log, "Sending article statuses...") os_log(.debug, log: log, "Sending article statuses...")
database.selectForProcessing { result in Task { @MainActor in
do {
let syncStatuses = (try await self.database.selectForProcessing()) ?? Set<SyncStatus>()
MainActor.assumeIsolated {
@MainActor func processStatuses(_ syncStatuses: [SyncStatus]) { @MainActor func processStatuses(_ syncStatuses: [SyncStatus]) {
let createUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == false } let createUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == false }
let deleteUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == true } let deleteUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == true }
@ -188,12 +191,10 @@ final class FeedbinAccountDelegate: AccountDelegate {
} }
} }
switch result { processStatuses(Array(syncStatuses))
case .success(let syncStatuses):
processStatuses(syncStatuses) } catch {
case .failure(let databaseError): completion(.failure(error))
completion(.failure(databaseError))
}
} }
} }
} }

18
Account/Sources/Account/Feedly/Operations/FeedlySendArticleStatusesOperation.swift
View File

@ -28,19 +28,13 @@ final class FeedlySendArticleStatusesOperation: FeedlyOperation {
override func run() { override func run() {
os_log(.debug, log: log, "Sending article statuses...") os_log(.debug, log: log, "Sending article statuses...")
database.selectForProcessing { result in Task { @MainActor in
MainActor.assumeIsolated {
if self.isCanceled {
self.didFinish()
return
}
switch result { do {
case .success(let syncStatuses): let syncStatuses = (try await self.database.selectForProcessing()) ?? Set<SyncStatus>()
self.processStatuses(syncStatuses) self.processStatuses(Array(syncStatuses))
case .failure: } catch {
self.didFinish() self.didFinish()
}
} }
} }
} }

14
Account/Sources/Account/NewsBlur/NewsBlurAccountDelegate.swift
View File

@ -134,9 +134,10 @@ final class NewsBlurAccountDelegate: AccountDelegate {
func sendArticleStatus(for account: Account, completion: @escaping (Result<Void, Error>) -> ()) { func sendArticleStatus(for account: Account, completion: @escaping (Result<Void, Error>) -> ()) {
os_log(.debug, log: log, "Sending story statuses...") os_log(.debug, log: log, "Sending story statuses...")
database.selectForProcessing { result in Task { @MainActor in
MainActor.assumeIsolated { do {
let syncStatuses = (try await self.database.selectForProcessing()) ?? Set<SyncStatus>()
@MainActor func processStatuses(_ syncStatuses: [SyncStatus]) { @MainActor func processStatuses(_ syncStatuses: [SyncStatus]) {
let createUnreadStatuses = syncStatuses.filter { let createUnreadStatuses = syncStatuses.filter {
@ -197,12 +198,9 @@ final class NewsBlurAccountDelegate: AccountDelegate {
} }
} }
switch result { processStatuses(Array(syncStatuses))
case .success(let syncStatuses): } catch {
processStatuses(syncStatuses) completion(.failure(error))
case .failure(let databaseError):
completion(.failure(databaseError))
}
} }
} }
} }

17
Account/Sources/Account/ReaderAPI/ReaderAPIAccountDelegate.swift
View File

@ -199,13 +199,17 @@ final class ReaderAPIAccountDelegate: AccountDelegate {
} }
func sendArticleStatus(for account: Account, completion: @escaping ((Result<Void, Error>) -> Void)) { func sendArticleStatus(for account: Account, completion: @escaping ((Result<Void, Error>) -> Void)) {
os_log(.debug, log: log, "Sending article statuses...") os_log(.debug, log: log, "Sending article statuses...")
database.selectForProcessing { result in Task { @MainActor in
MainActor.assumeIsolated { do {
let syncStatuses = (try await self.database.selectForProcessing()) ?? Set<SyncStatus>()
@MainActor func processStatuses(_ syncStatuses: [SyncStatus]) { @MainActor func processStatuses(_ syncStatuses: [SyncStatus]) {
let createUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == false } let createUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == false }
let deleteUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == true } let deleteUnreadStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.read && $0.flag == true }
let createStarredStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.starred && $0.flag == true } let createStarredStatuses = syncStatuses.filter { $0.key == SyncStatus.Key.starred && $0.flag == true }
@ -239,12 +243,9 @@ final class ReaderAPIAccountDelegate: AccountDelegate {
} }
} }
switch result { processStatuses(Array(syncStatuses))
case .success(let syncStatuses): } catch {
processStatuses(syncStatuses) completion(.failure(error))
case .failure(let databaseError):
completion(.failure(databaseError))
}
} }
} }
} }

28
SyncDatabase/Sources/SyncDatabase/SyncDatabase.swift
View File

@ -110,34 +110,6 @@ public actor SyncDatabase {
} }
} }
// MARK: - Compatibility
// Use the below until switching to the async version of the API.
public typealias SyncStatusesResult = Result<Array<SyncStatus>, DatabaseError>
public typealias SyncStatusesCompletionBlock = @Sendable (SyncStatusesResult) -> Void
public typealias SyncStatusArticleIDsResult = Result<Set<String>, DatabaseError>
public typealias SyncStatusArticleIDsCompletionBlock = @Sendable (SyncStatusArticleIDsResult) -> Void
public extension SyncDatabase {
nonisolated func selectForProcessing(limit: Int? = nil, completion: @escaping SyncStatusesCompletionBlock) {
Task { @MainActor in
do {
if let syncStatuses = try await self.selectForProcessing(limit: limit) {
completion(.success(Array(syncStatuses)))
} else {
completion(.success([SyncStatus]()))
}
} catch {
completion(.failure(DatabaseError.suspended))
}
}
}
}
private extension SyncDatabase { private extension SyncDatabase {
static let creationStatements = """ static let creationStatements = """