feat: balancer

isd-sgcu · Mar 31, 2024 · 6df3b82 · 6df3b82
1 parent d74614a
commit 6df3b82
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 5 deletions.
diff --git a/apps/server/src/models/history.model.ts b/apps/server/src/models/history.model.ts
@@ -15,7 +15,8 @@ import { Game } from './game.model'
 
 export class GameHistory
   extends Model<GameHistoryAttributes, GameHistoryInput>
-  implements GameHistoryAttributes {
+  implements GameHistoryAttributes
+{
   public game_id!: string
   public player_id!: string
   public key!: string
@@ -58,16 +59,24 @@ export class GameHistoryRepository {
       RedisFunctions,
       RedisScripts
     >,
-  ) { }
+  ) {}
 
   async createHistory(game_id: string, key: string, vote: number) {
     const total = await this.redis.incrBy(`game::${game_id}::${key}`, vote)
     this.redis.keys(`game::${game_id}::*`).then(async (keys) => {
       keys.forEach(async (k) => {
         if (k !== `game::${game_id}::${key}`) {
           const kTotal = parseInt((await this.redis.get(k)) || '0')
-          if (kTotal < total - vote) {
-            this.redis.incrBy(k, Math.round((0.5 - (kTotal / (total + kTotal))) * vote))
+          if (kTotal < total) {
+            this.redis.incrBy(
+              k,
+              Math.round((0.5 - kTotal / (total + kTotal)) * vote),
+            )
+          } else {
+            this.redis.incrBy(
+              `game::${game_id}::${key}`,
+              Math.round((0.5 - total / (total + kTotal)) * vote),
+            )
           }
         }
       })

diff --git a/apps/server/src/service/player.service.ts b/apps/server/src/service/player.service.ts
@@ -11,7 +11,7 @@ export class PlayerService {
     private readonly gameRepository: GameRepository,
     private readonly clientRepository: ClientRepository,
     private readonly gameHistoryRepository: GameHistoryRepository,
-  ) { }
+  ) {}
 
   async getGame(id: string) {
     return await this.gameRepository.getGameById(id).catch((err) => ({ err }))