Add send sync database contents to Feedbin

Frameworks/SyncDatabase/SyncDatabase.swift

@@ -27,6 +27,18 @@ public final class SyncDatabase {
 		syncStatusTable.insertStatuses(statuses)
 	}
 	
+	public func selectForProcessing() -> [SyncStatus] {
+		return syncStatusTable.selectForProcessing()
+	}
+	
+	public func resetSelectedForProcessing(_ articleIDs: [String]) {
+		syncStatusTable.resetSelectedForProcessing(articleIDs)
+	}
+	
+	public func deleteSelectedForProcessing(_ articleIDs: [String]) {
+		syncStatusTable.deleteSelectedForProcessing(articleIDs)
+	}
+	
 }
 
 // MARK: - Private

Frameworks/SyncDatabase/SyncStatus.swift

@@ -10,7 +10,7 @@ import Foundation
 import Articles
 import RSDatabase
 
-public struct SyncStatus {
+public struct SyncStatus: Hashable, Equatable {
 	
 	public let articleID: String
 	public let key: ArticleStatus.Key
@@ -24,7 +24,7 @@ public struct SyncStatus {
 		self.selected = selected
 	}
 	
-	public func databaseDictionary() -> DatabaseDictionary? {
+	public func databaseDictionary() -> DatabaseDictionary {
 		return [DatabaseKey.articleID: articleID, DatabaseKey.key: key.rawValue, DatabaseKey.flag: flag, DatabaseKey.selected: selected]
 	}
 	

Frameworks/SyncDatabase/SyncStatusTable.swift

@@ -7,6 +7,7 @@
 //
 
 import Foundation
+import Articles
 import RSDatabase
 
 final class SyncStatusTable: DatabaseTable {
@@ -18,11 +19,67 @@ final class SyncStatusTable: DatabaseTable {
 		self.queue = queue
 	}
 
+	func selectForProcessing() -> [SyncStatus] {
+
+		var statuses: Set<SyncStatus>? = nil
+		
+		self.queue.updateSync { database in
+			
+			let updateSQL = "update syncStatus set selected = true"
+			database.executeUpdate(updateSQL, withArgumentsIn: nil)
+			
+			let selectSQL = "select * from syncStatus where selected == true"
+			if let resultSet = database.executeQuery(selectSQL, withArgumentsIn: nil) {
+				statuses = resultSet.mapToSet(self.statusWithRow)
+			}
+			
+		}
+
+		return statuses != nil ? Array(statuses!) : [SyncStatus]()
+		
+	}
+	
+	func resetSelectedForProcessing(_ articleIDs: [String]) {
+		self.queue.update { database in
+			let parameters = articleIDs.map { $0 as AnyObject }
+			let placeholders = NSString.rs_SQLValueList(withPlaceholders: UInt(articleIDs.count))!
+			let updateSQL = "update syncStatus set selected = false where articleID in \(placeholders)"
+			database.executeUpdate(updateSQL, withArgumentsIn: parameters)
+		}
+	}
+	
+	func deleteSelectedForProcessing(_ articleIDs: [String]) {
+		self.queue.update { database in
+			let parameters = articleIDs.map { $0 as AnyObject }
+			let placeholders = NSString.rs_SQLValueList(withPlaceholders: UInt(articleIDs.count))!
+			let deleteSQL = "delete from syncStatus where articleID in \(placeholders)"
+			database.executeUpdate(deleteSQL, withArgumentsIn: parameters)
+		}
+	}
+	
 	func insertStatuses(_ statuses: [SyncStatus]) {
 		self.queue.update { database in
-			let statusArray = statuses.map { $0.databaseDictionary()! }
+			let statusArray = statuses.map { $0.databaseDictionary() }
 			self.insertRows(statusArray, insertType: .orReplace, in: database)
 		}
 	}
 	
 }
+
+private extension SyncStatusTable {
+
+	func statusWithRow(_ row: FMResultSet) -> SyncStatus? {
+		
+		guard let articleID = row.string(forColumn: DatabaseKey.articleID),
+			let rawKey = row.string(forColumn: DatabaseKey.key),
+			let key = ArticleStatus.Key(rawValue: rawKey) else {
+				return nil
+		}
+		
+		let flag = row.bool(forColumn: DatabaseKey.flag)
+		let selected = row.bool(forColumn: DatabaseKey.selected)
+		
+		return SyncStatus(articleID: articleID, key: key, flag: flag, selected: selected)
+		
+	}
+}