Clear expired tokens

Author: adborbas

Sources/Grodt/Application/routes.swift

@@ -84,6 +84,11 @@ func routes(_ app: Application) async throws {
             .daily()
             .at(3, 0)
         app.queues.add(LoggingJobEventDelegate(logger: app.logger))
+        
+        let userTokenCleanerJob = UserTokenClearUpJob(userTokenClearing: UserTokenClearer(database: app.db))
+        app.queues.schedule(userTokenCleanerJob)
+            .hourly()
+        
         try app.queues.startScheduledJobs()
         try app.queues.startInProcessJobs()
     }

Sources/Grodt/BusinessLogic/UserTokenClearUp/UserTokenClearUpJob.swift

@@ -0,0 +1,14 @@
+import Vapor
+import Queues
+
+struct UserTokenClearUpJob: AsyncScheduledJob, @unchecked Sendable {
+    private let userTokenClearer: UserTokenClearing
+    
+    init(userTokenClearing: UserTokenClearing) {
+        self.userTokenClearer = userTokenClearing
+    }
+    
+    func run(context: Queues.QueueContext) async throws {
+        try await userTokenClearer.clearExpiredTokens()
+    }
+}

Sources/Grodt/BusinessLogic/UserTokenClearUp/UserTokenClearing.swift

@@ -0,0 +1,22 @@
+import Fluent
+import Foundation
+
+protocol UserTokenClearing {
+    func clearExpiredTokens() async throws
+}
+
+class UserTokenClearer: UserTokenClearing {
+    private let database: Database
+    
+    init(database: Database) {
+        self.database = database
+    }
+    
+    func clearExpiredTokens() async throws {
+        let allTokens = try await UserToken.query(on: database).all()
+        let expiredTokens = allTokens.filter { !$0.isValid }
+        for token in expiredTokens {
+            try await token.delete(on: database)
+        }
+    }
+}