Try this

Author: enchantinggg4

session-draft.md

@@ -11,8 +11,23 @@ GameSessionState
     GameComplete
 
 
+```js
+class GameSessionModel {
+    @Column
+    server_url: string;
 
-## RoomReady
-1) create game session
-2) populate players
-3) 
+    @PrimaryColumn
+    match_id: number;
+}
+
+class GameSessionPlayer {
+  @ManyToOne(match_id)
+  session: GameSessionModel;
+  
+  connected: boolean;
+  
+  abandoned: boolean;
+}
+
+
+```

src/app.service.ts

@@ -16,6 +16,7 @@ import { ReplayEntity } from 'gameserver/model/replay.entity';
 import { GameServerEntity } from 'gameserver/model/game-server.entity';
 import { PlayerNotLoadedEvent } from 'gateway/events/bans/player-not-loaded.event';
 import { AchievementCompleteEvent } from 'gateway/events/gs/achievement-complete.event';
+import { GameServerSessionEntity } from 'gameserver/model/game-server-session.entity';
 
 @Injectable()
 export class AppService {
@@ -25,19 +26,27 @@ export class AppService {
     private readonly gameServerEntityRepository: Repository<GameServerEntity>,
     @InjectRepository(ReplayEntity)
     private readonly replayEntityRepository: Repository<ReplayEntity>,
-    @Inject('QueryCore') private readonly redisEventQueue: ClientProxy,
+    @InjectRepository(GameServerSessionEntity)
+    private readonly gameServerSessionEntityRepository: Repository<GameServerSessionEntity>,
+    @Inject("QueryCore") private readonly redisEventQueue: ClientProxy,
   ) {}
 
-
-  @Cron('*/30 * * * * *')
+  @Cron("*/30 * * * * *")
   async actualizeServers() {
     // for all servers
     const all = await this.gameServerEntityRepository.find();
 
+    const all2 = await this.gameServerSessionEntityRepository.find();
+
+    await Promise.all(
+      all.map(async (gs) => {
+        await this.ebus.publish(new ServerActualizationRequestedEvent(gs.url));
+      }),
+    );
+
     await Promise.all(
-      all.map(async gs => {
+      all2.map(async (gs) => {
         await this.ebus.publish(new ServerActualizationRequestedEvent(gs.url));
-        await new Promise(r => setTimeout(r, 1000)) // spread them a little
       }),
     );
   }
@@ -57,11 +66,11 @@ export class AppService {
       KillServerRequestedEvent,
       BanSystemEvent,
       PlayerNotLoadedEvent,
-      AchievementCompleteEvent
+      AchievementCompleteEvent,
     ];
 
     this.ebus
       .pipe(ofType(...publicEvents))
-      .subscribe(t => this.redisEventQueue.emit(t.constructor.name, t));
+      .subscribe((t) => this.redisEventQueue.emit(t.constructor.name, t));
   }
 }