Stedos/nise
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Style fix in UpdateUserQueueService

Browse Source
This commit is contained in:
nise.moe 2024-02-22 15:37:00 +01:00
parent 2d3b7b0817
commit f3d8b69166
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
nise-backend/src/main/kotlin/com/nisemoe/nise/service/UpdateUserQueueService.kt
View File

@ -2,10 +2,8 @@ package com.nisemoe.nise.service
import com.nisemoe.generated.tables.records.UpdateUserQueueRecord import com.nisemoe.generated.tables.records.UpdateUserQueueRecord
import com.nisemoe.generated.tables.references.UPDATE_USER_QUEUE import com.nisemoe.generated.tables.references.UPDATE_USER_QUEUE
import com.nisemoe.generated.tables.references.USERS
import com.nisemoe.nise.UserQueueDetails import com.nisemoe.nise.UserQueueDetails
import org.jooq.DSLContext import org.jooq.DSLContext
import org.springframework.http.ResponseEntity
import org.springframework.messaging.simp.SimpMessagingTemplate import org.springframework.messaging.simp.SimpMessagingTemplate
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
import java.time.Duration import java.time.Duration
@ -18,7 +16,11 @@ class UpdateUserQueueService(
private val messagingTemplate: SimpMessagingTemplate private val messagingTemplate: SimpMessagingTemplate
) { ) {
private val USER_UPDATE_INTERVAL_HOURS = 4 companion object {
const val USER_UPDATE_INTERVAL_HOURS = 4
}
data class UserQueueWebsocketPacket( data class UserQueueWebsocketPacket(
val message: String, val message: String,
@ -44,7 +46,7 @@ class UpdateUserQueueService(
.limit(1) .limit(1)
.fetchOneInto(OffsetDateTime::class.java) .fetchOneInto(OffsetDateTime::class.java)
var canUpdate = !isProcessing; var canUpdate = !isProcessing
if (lastCompletedUpdateQueue != null) { if (lastCompletedUpdateQueue != null) {
val now = OffsetDateTime.now(ZoneOffset.UTC) val now = OffsetDateTime.now(ZoneOffset.UTC)
val duration = Duration.between(lastCompletedUpdateQueue, now) val duration = Duration.between(lastCompletedUpdateQueue, now)