Sync item read state to server

Fervor/FervorClient.swift

@@ -119,6 +119,18 @@ public class FervorClient {
         }
     }
     
+    public func read(item id: FervorID) async throws -> Item {
+        var request = URLRequest(url: buildURL(path: "/api/v1/items/\(id)/read"))
+        request.httpMethod = "POST"
+        return try await performRequest(request)
+    }
+    
+    public func unread(item id: FervorID) async throws -> Item {
+        var request = URLRequest(url: buildURL(path: "/api/v1/items/\(id)/unread"))
+        request.httpMethod = "POST"
+        return try await performRequest(request)
+    }
+    
     public struct Auth {
         public let accessToken: String
         public let refreshToken: String?

Reader/FervorController.swift

@@ -66,4 +66,16 @@ class FervorController {
         try! await persistentContainer.updateLastSyncDate(update.syncTimestamp)
     }
     
+    @MainActor
+    func syncReadToServer() async throws {
+        var count = 0
+        for case let item as Item in self.persistentContainer.viewContext.updatedObjects {
+            count += 1
+            let f = item.read ? client.read(item:) : client.unread(item:)
+            let _ = try await f(item.id!)
+        }
+        logger.info("Synced \(count, privacy: .public) read/unread to server")
+        try self.persistentContainer.viewContext.save()
+    }
+    
 }

Reader/SceneDelegate.swift

@@ -49,6 +49,10 @@ class SceneDelegate: UIResponder, UIWindowSceneDelegate {
     func sceneWillResignActive(_ scene: UIScene) {
         // Called when the scene will move from an active state to an inactive state.
         // This may occur due to temporary interruptions (ex. an incoming phone call).
+        
+        Task(priority: .userInitiated) {
+            try await self.fervorController.syncReadToServer()
+        }
     }
 
     func sceneWillEnterForeground(_ scene: UIScene) {