FreshRSS/NetNewsWire
1
0
Fork 0
mirror of https://github.com/Ranchero-Software/NetNewsWire.git synced 2024-12-23 08:09:41 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix article status delete

Browse Source
This commit is contained in:
Maurice Parker 2020-04-27 19:07:14 -05:00
parent 5e18b2b569
commit 0944264326
2 changed files with 21 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Frameworks/Account/CloudKit/CloudKitAccountDelegate.swift
View File

@ -255,7 +255,12 @@ final class CloudKitAccountDelegate: AccountDelegate {
self.refreshProgress.completeTask()
switch result {
case .success:
self.articlesZone.deleteArticles(feed.url) { result in
guard let webFeedExternalID = feed.externalID else {
completion(.success(()))
return
}
self.articlesZone.deleteArticles(webFeedExternalID) { result in
self.refreshProgress.completeTask()
switch result {
case .success:
@ -267,6 +272,7 @@ final class CloudKitAccountDelegate: AccountDelegate {
}
}
case .failure(let error):
self.refreshProgress.completeTask()
self.processAccountError(account, error)
completion(.failure(error))
}

37
Frameworks/Account/CloudKit/CloudKitArticlesZone.swift
View File

@ -97,9 +97,9 @@ final class CloudKitArticlesZone: CloudKitZone {
saveIfNew(records, completion: completion)
}
func deleteArticles(_ webFeedURL: String, completion: @escaping ((Result<Void, Error>) -> Void)) {
let predicate = NSPredicate(format: "webFeedURL = %@", webFeedURL)
let ckQuery = CKQuery(recordType: CloudKitArticle.recordType, predicate: predicate)
func deleteArticles(_ webFeedExternalID: String, completion: @escaping ((Result<Void, Error>) -> Void)) {
let predicate = NSPredicate(format: "webFeedExternalID = %@", webFeedExternalID)
let ckQuery = CKQuery(recordType: CloudKitArticleStatus.recordType, predicate: predicate)
delete(ckQuery: ckQuery, completion: completion)
}
@ -134,18 +134,24 @@ final class CloudKitArticlesZone: CloudKitZone {
}
saveIfNew(newRecords) { result in
switch result {
case .success:
if case .failure(let error) = result, case CloudKitZoneError.userDeletedZone = error {
self.createZoneRecord() { result in
switch result {
case .success:
self.modifyArticles(statusArticles, completion: completion)
case .failure(let error):
completion(.failure(error))
}
}
} else {
self.modify(recordsToSave: modifyRecords, recordIDsToDelete: deleteRecordIDs) { result in
switch result {
case .success:
completion(.success(()))
case .failure(let error):
self.handleSendArticleStatusError(error, statusArticles: statusArticles, completion: completion)
completion(.failure(error))
}
}
case .failure(let error):
self.handleSendArticleStatusError(error, statusArticles: statusArticles, completion: completion)
}
}
}
@ -153,21 +159,6 @@ final class CloudKitArticlesZone: CloudKitZone {
}
private extension CloudKitArticlesZone {
func handleSendArticleStatusError(_ error: Error, statusArticles: [(status: SyncStatus, article: Article?)], completion: @escaping ((Result<Void, Error>) -> Void)) {
if case CloudKitZoneError.userDeletedZone = error {
self.createZoneRecord() { result in
switch result {
case .success:
self.modifyArticles(statusArticles, completion: completion)
case .failure(let error):
completion(.failure(error))
}
}
} else {
completion(.failure(error))
}
}
func statusID(_ id: String) -> String {
return "s|\(id)"