diff --git a/nise-backend/src/main/kotlin/com/nisemoe/nise/service/UpdateUserQueueService.kt b/nise-backend/src/main/kotlin/com/nisemoe/nise/service/UpdateUserQueueService.kt index 0d2a886..95164c7 100644 --- a/nise-backend/src/main/kotlin/com/nisemoe/nise/service/UpdateUserQueueService.kt +++ b/nise-backend/src/main/kotlin/com/nisemoe/nise/service/UpdateUserQueueService.kt @@ -72,6 +72,9 @@ class UpdateUserQueueService( ) } + /** + * Retrieves the full update queue, only pending users. + */ fun getQueue(): List { return dslContext.select(UPDATE_USER_QUEUE.USER_ID) .from(UPDATE_USER_QUEUE) @@ -99,6 +102,11 @@ class UpdateUserQueueService( return insertedRows == 1 } + /** + * Sets the given user as processed in the update queue. + * + * @param userId The user ID of the user to set as processed. + */ fun setUserAsProcessed(userId: Long) { dslContext.update(UPDATE_USER_QUEUE) .set(UPDATE_USER_QUEUE.PROCESSED, true) @@ -110,7 +118,7 @@ class UpdateUserQueueService( // Notify the user that their queue has been processed with fresh info messagingTemplate.convertAndSend( "/topic/live-user/${userId}", - UpdateUserQueueService.UserQueueWebsocketPacket(message = "UPDATE_PROGRESS", data = this.getUserQueueDetails(userId)) + UserQueueWebsocketPacket(message = "UPDATE_PROGRESS", data = this.getUserQueueDetails(userId)) ) }