Skip to content

Commit 0b84f1f

Browse files
committed
✨ feat: SSE 인원 입퇴장 이벤트 추가
1 parent d9c79cb commit 0b84f1f

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

backend/src/main/java/io/f1/backend/domain/game/app/RoomService.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import io.f1.backend.domain.game.dto.response.SystemNoticeResponse;
3030
import io.f1.backend.domain.game.event.RoomCreatedEvent;
3131
import io.f1.backend.domain.game.event.RoomDeletedEvent;
32+
import io.f1.backend.domain.game.event.RoomUpdatedEvent;
3233
import io.f1.backend.domain.game.model.ConnectionState;
3334
import io.f1.backend.domain.game.model.GameSetting;
3435
import io.f1.backend.domain.game.model.Player;
@@ -229,6 +230,8 @@ public void initializeRoomSocket(Long roomId, UserPrincipal principal) {
229230
destination,
230231
MessageType.SYSTEM_NOTICE,
231232
systemNoticeResponse);
233+
234+
eventPublisher.publishEvent(new RoomUpdatedEvent(room, quiz));
232235
});
233236
});
234237
}
@@ -470,6 +473,11 @@ private void cleanRoom(Room room, Player player) {
470473

471474
/* 플레이어 삭제 */
472475
room.removePlayer(player);
476+
477+
Long quizId = room.getQuizId();
478+
Quiz quiz = quizService.getQuizWithQuestionsById(quizId);
479+
480+
eventPublisher.publishEvent(new RoomUpdatedEvent(room, quiz));
473481
}
474482

475483
public void handleDisconnectedPlayers(Room room, List<Player> disconnectedPlayers) {

0 commit comments

Comments
 (0)