chore: Java 스타일 수정

Author: github-actions

backend/src/main/java/io/f1/backend/domain/stat/app/StatKafkaConsumer.java

@@ -1,5 +1,7 @@
 package io.f1.backend.domain.stat.app;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+
 import io.f1.backend.domain.stat.dao.StatBatchRepository;
 import io.f1.backend.domain.stat.dto.StatChangeEvent;
 
@@ -10,8 +12,6 @@
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
-
 import java.util.ArrayList;
 import java.util.List;
 
@@ -27,18 +27,18 @@ public class StatKafkaConsumer {
     @KafkaListener(topics = "stat-changes")
     public void handleStatChanges(List<String> messages) {
         log.info("Received {} messages from Kafka", messages.size());
-        
+
         try {
             // JSON 문자열을 StatChangeEvent 객체로 변환
             List<StatChangeEvent> events = new ArrayList<>();
             for (String message : messages) {
                 StatChangeEvent event = objectMapper.readValue(message, StatChangeEvent.class);
                 events.add(event);
             }
-            
+
             log.info("Processing {} stat change events", events.size());
             statBatchRepository.batchUpdateStats(events);
-            
+
         } catch (Exception e) {
             log.error("Failed to process stat change events", e);
             throw new RuntimeException("Failed to process stat change events", e);

backend/src/main/java/io/f1/backend/domain/stat/dao/StatBatchRepository.java

@@ -1,8 +1,10 @@
 package io.f1.backend.domain.stat.dao;
 
 import io.f1.backend.domain.stat.dto.StatChangeEvent;
+
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Repository;
 
@@ -21,13 +23,9 @@ public void batchUpdateStats(List<StatChangeEvent> events) {
             return;
         }
 
-        List<StatChangeEvent> winEvents = events.stream()
-                .filter(StatChangeEvent::isWin)
-                .toList();
-        
-        List<StatChangeEvent> loseEvents = events.stream()
-                .filter(e -> !e.isWin())
-                .toList();
+        List<StatChangeEvent> winEvents = events.stream().filter(StatChangeEvent::isWin).toList();
+
+        List<StatChangeEvent> loseEvents = events.stream().filter(e -> !e.isWin()).toList();
 
         if (!winEvents.isEmpty()) {
             batchUpdateWinStats(winEvents);
@@ -39,46 +37,51 @@ public void batchUpdateStats(List<StatChangeEvent> events) {
     }
 
     private void batchUpdateWinStats(List<StatChangeEvent> events) {
-        StringBuilder sql = new StringBuilder("""
-            UPDATE stat SET
-                total_games = total_games + 1,
-                winning_games = winning_games + 1,
-                score = score + CASE user_id
-            """);
+        StringBuilder sql =
+                new StringBuilder(
+                        """
+                        UPDATE stat SET
+                            total_games = total_games + 1,
+                            winning_games = winning_games + 1,
+                            score = score + CASE user_id
+                        """);
 
         for (StatChangeEvent event : events) {
             sql.append(String.format("WHEN %d THEN %d ", event.getUserId(), event.getDeltaScore()));
         }
-        
+
         sql.append("END WHERE user_id IN (");
-        sql.append(events.stream()
-                .map(e -> String.valueOf(e.getUserId()))
-                .collect(Collectors.joining(",")));
+        sql.append(
+                events.stream()
+                        .map(e -> String.valueOf(e.getUserId()))
+                        .collect(Collectors.joining(",")));
         sql.append(")");
 
         int updatedRows = jdbcTemplate.update(sql.toString());
         log.debug("Batch updated {} win stats", updatedRows);
     }
 
     private void batchUpdateLoseStats(List<StatChangeEvent> events) {
-        StringBuilder sql = new StringBuilder("""
-            UPDATE stat SET
-                total_games = total_games + 1,
-                score = score + CASE user_id
-            """);
+        StringBuilder sql =
+                new StringBuilder(
+                        """
+                        UPDATE stat SET
+                            total_games = total_games + 1,
+                            score = score + CASE user_id
+                        """);
 
         for (StatChangeEvent event : events) {
             sql.append(String.format("WHEN %d THEN %d ", event.getUserId(), event.getDeltaScore()));
         }
-        
+
         sql.append("END WHERE user_id IN (");
-        sql.append(events.stream()
-                .map(e -> String.valueOf(e.getUserId()))
-                .collect(Collectors.joining(",")));
+        sql.append(
+                events.stream()
+                        .map(e -> String.valueOf(e.getUserId()))
+                        .collect(Collectors.joining(",")));
         sql.append(")");
 
         int updatedRows = jdbcTemplate.update(sql.toString());
         log.debug("Batch updated {} lose stats", updatedRows);
     }
 }
-

backend/src/main/java/io/f1/backend/domain/stat/dto/StatChangeEvent.java

@@ -6,16 +6,12 @@
 @Getter
 @Builder
 public class StatChangeEvent {
-    
+
     private Long userId;
     private boolean win;
     private int deltaScore;
-    
+
     public static StatChangeEvent of(Long userId, boolean win, int deltaScore) {
-        return StatChangeEvent.builder()
-                .userId(userId)
-                .win(win)
-                .deltaScore(deltaScore)
-                .build();
+        return StatChangeEvent.builder().userId(userId).win(win).deltaScore(deltaScore).build();
     }
 }

backend/src/main/java/io/f1/backend/global/config/KafkaConfig.java

@@ -1,5 +1,7 @@
 package io.f1.backend.global.config;
 
+import lombok.RequiredArgsConstructor;
+
 import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -9,8 +11,6 @@
 import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
 import org.springframework.kafka.listener.ContainerProperties;
 
-import lombok.RequiredArgsConstructor;
-
 @EnableKafka
 @Configuration
 @RequiredArgsConstructor
@@ -20,16 +20,16 @@ public class KafkaConfig {
 
     @Bean
     public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
-        ConcurrentKafkaListenerContainerFactory<String, String> factory = 
-            new ConcurrentKafkaListenerContainerFactory<>();
+        ConcurrentKafkaListenerContainerFactory<String, String> factory =
+                new ConcurrentKafkaListenerContainerFactory<>();
+
+        ConsumerFactory<String, String> consumerFactory =
+                new DefaultKafkaConsumerFactory<>(kafkaProperties.buildConsumerProperties());
 
-        ConsumerFactory<String, String> consumerFactory = 
-            new DefaultKafkaConsumerFactory<>(kafkaProperties.buildConsumerProperties());
-        
         factory.setConsumerFactory(consumerFactory);
         factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.BATCH);
         factory.setBatchListener(true);
-        
+
         return factory;
     }
 }

backend/src/main/java/io/f1/backend/global/util/kafka/KafkaProducer.java

@@ -1,13 +1,14 @@
 package io.f1.backend.global.util.kafka;
 
-import org.springframework.kafka.core.KafkaTemplate;
-import org.springframework.stereotype.Component;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Component;
+
 @Slf4j
 @Component
 @RequiredArgsConstructor

backend/src/test/java/io/f1/backend/domain/stat/KafkaStatTest.java

@@ -11,12 +11,14 @@
 import io.f1.backend.domain.user.dao.UserRepository;
 import io.f1.backend.global.config.KafkaTestContainerConfig;
 import io.f1.backend.global.util.kafka.KafkaProducer;
+
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Import;
+
 import java.time.Duration;
 
 @DBRider
@@ -34,7 +36,8 @@ class KafkaStatTest {
     void kafkaConsumerProcessesGameResultAsynchronously() throws Exception {
         // given
         long userId = 1L;
-        StatWithUserSummary originalStat = statJpaRepository.findStatWithUserSummary(userId).orElseThrow(AssertionError::new);
+        StatWithUserSummary originalStat =
+                statJpaRepository.findStatWithUserSummary(userId).orElseThrow(AssertionError::new);
 
         int deltaScore = 100;
         StatChangeEvent event = StatChangeEvent.of(userId, true, deltaScore);
@@ -47,15 +50,20 @@ void kafkaConsumerProcessesGameResultAsynchronously() throws Exception {
                 .until(() -> isStatUpdated(userId, originalStat.score() + deltaScore));
 
         // then
-        StatWithUserSummary updatedStat = statJpaRepository.findStatWithUserSummary(userId).orElseThrow(AssertionError::new);
+        StatWithUserSummary updatedStat =
+                statJpaRepository.findStatWithUserSummary(userId).orElseThrow(AssertionError::new);
         assertThat(updatedStat.score()).isEqualTo(originalStat.score() + deltaScore);
         assertThat(updatedStat.totalGames()).isEqualTo(originalStat.totalGames() + 1);
         assertThat(updatedStat.winningGames()).isEqualTo(originalStat.winningGames() + 1);
     }
 
     private boolean isStatUpdated(long userId, long expectedScore) {
         try {
-            return statJpaRepository.findStatWithUserSummary(userId).orElseThrow(AssertionError::new).score() == expectedScore;
+            return statJpaRepository
+                            .findStatWithUserSummary(userId)
+                            .orElseThrow(AssertionError::new)
+                            .score()
+                    == expectedScore;
         } catch (Exception e) {
             return false;
         }

backend/src/test/java/io/f1/backend/global/config/KafkaTestContainerConfig.java

@@ -6,19 +6,19 @@
 import org.testcontainers.kafka.ConfluentKafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
-
 @Testcontainers
 @TestConfiguration
 public class KafkaTestContainerConfig {
 
     @Container
     public static ConfluentKafkaContainer kafkaContainer =
-        new ConfluentKafkaContainer(
-            DockerImageName.parse("confluentinc/cp-kafka:7.6.1"))
-            .withExposedPorts(9092);
+            new ConfluentKafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.6.1"))
+                    .withExposedPorts(9092);
 
     static {
         kafkaContainer.start();
-        System.setProperty("spring.kafka.bootstrap-servers", kafkaContainer.getHost() + ":" + kafkaContainer.getMappedPort(9092));
+        System.setProperty(
+                "spring.kafka.bootstrap-servers",
+                kafkaContainer.getHost() + ":" + kafkaContainer.getMappedPort(9092));
     }
 }