PSForever/PSF-BotServer
1
0
Fork 0
mirror of https://github.com/2revoemag/PSF-BotServer.git synced 2026-01-19 18:14:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

added schedule to update materialized view outfitpoint_mv

Browse source 
added concurrently option to query
This commit is contained in:
Resaec 2025-08-31 23:43:02 +02:00
parent 474993a4e2
commit 1556025ce6
1 changed files with 20 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
src/main/scala/net/psforever/actors/session/support/SessionOutfitHandlers.scala
View file

@ -14,6 +14,7 @@ import net.psforever.types.ChatMessageType
import net.psforever.util.Config import net.psforever.util.Config
import java.time.LocalDateTime import java.time.LocalDateTime
import java.util.concurrent.Executors
import scala.util.{Failure, Success} import scala.util.{Failure, Success}
object SessionOutfitHandlers { object SessionOutfitHandlers {
@ -561,7 +562,25 @@ object SessionOutfitHandlers {
} }
} }
private var outfitPointSheduleStarted = false
def HandleLoginOutfitCheck(player: Player, session: SessionData): Unit = { def HandleLoginOutfitCheck(player: Player, session: SessionData): Unit = {
// TODO: implement this the proper way, please
// start the shedule on first run of the function
if (!outfitPointSheduleStarted) {
outfitPointSheduleStarted = true
Executors.newSingleThreadScheduledExecutor.scheduleAtFixedRate(
() => {
ctx.run(updateOutfitPointMV())
},
0,
5,
java.util.concurrent.TimeUnit.MINUTES
)
}
ctx.run(getOutfitOnLogin(player.avatar.id)).flatMap { memberships => ctx.run(getOutfitOnLogin(player.avatar.id)).flatMap { memberships =>
memberships.headOption match { memberships.headOption match {
case Some(membership) => case Some(membership) =>
@ -847,6 +866,6 @@ object SessionOutfitHandlers {
} }
def updateOutfitPointMV(): Quoted[Action[Unit]] = quote( def updateOutfitPointMV(): Quoted[Action[Unit]] = quote(
infix"REFRESH MATERIALIZED VIEW outfitpoint_mv".as[Action[Unit]] infix"REFRESH MATERIALIZED VIEW CONCURRENTLY outfitpoint_mv".as[Action[Unit]]
) )
} }