fix: 코드스멜 제거

Author: HYEONSIKOH

src/main/java/org/dfbf/soundlink/domain/alert/controller/AlertController.java

@@ -4,7 +4,6 @@
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
 import org.dfbf.soundlink.domain.alert.service.AlertService;
-import org.dfbf.soundlink.global.exception.ResponseResult;
 import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
@@ -32,10 +31,4 @@ public SseEmitter subscribeTest(
             @RequestHeader(value = "Last-Event-ID", required = false, defaultValue = "") String lastEventId) {
         return alertService.connectAlarm(id, lastEventId);
     }
-
-//    @PostMapping("")
-//    @Operation(summary = "알림 전송 API", description = "알림을 전송하는 기능 (CHAT 서버에서 사용하는 기능입니다.)")
-//    public ResponseResult send(@RequestParam("id") Long id, @RequestParam("msg") String msg) {
-//        return alertService.send(id,"test" ,msg);
-//    }
 }

src/main/java/org/dfbf/soundlink/domain/alert/dto/AlertReq.java

@@ -1,7 +1,5 @@
 package org.dfbf.soundlink.domain.alert.dto;
 
-import com.fasterxml.jackson.annotation.JsonProperty;
-
 public record AlertReq(
         String type,
         String timestamp,

src/main/java/org/dfbf/soundlink/domain/alert/entity/Alert.java

@@ -1,13 +1,10 @@
 package org.dfbf.soundlink.domain.alert.entity;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
-
-import jakarta.persistence.Column;
-import jakarta.persistence.Entity;
-import jakarta.persistence.Id;
-import jakarta.persistence.Lob;
 import lombok.*;
-import java.time.*;
+
+import java.time.Instant;
+import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
 
 @Data

src/main/java/org/dfbf/soundlink/domain/chat/service/ChatRoomService.java

@@ -51,6 +51,7 @@ public class ChatRoomService {
     private final KafkaProducer kafkaProducer;
 
     private static final String CHAT_REQUEST_KEY = "chatRequest";
+    private static final String TOPIC = "alert-topic";
 
     // 요청을 Redis에 저장 (TTL: 60초)
     public ResponseResult saveRequestToRedis(Long requestUserId, Long emotionRecordId) {
@@ -98,7 +99,7 @@ public ResponseResult saveRequestToRedis(Long requestUserId, Long emotionRecordI
                     .orElseThrow(UserNotFoundException::new);
             AlertChatRequest alertChatRequest = new AlertChatRequest(emotionRecordId, requestUser.getNickname());
             Alert alert = alertService.createAlert(responseUserId, "alarm", alertChatRequest);
-            kafkaProducer.send("alert-topic", alert);
+            kafkaProducer.send(TOPIC, alert);
 
             return new ResponseResult(ErrorCode.SUCCESS);
         } catch (EmotionRecordNotFoundException e) {
@@ -124,7 +125,7 @@ public ResponseResult deleteRequestFromRedis(Long userId, Long emotionRecordId)
             if (Boolean.TRUE.equals(redisTemplate.hasKey(key))) {
                 redisTemplate.delete(key);
                 Alert alert = alertService.createAlert(recordIdInUserId, "cancel", "Chat request has been canceled.");
-                kafkaProducer.send("alert-topic", alert);
+                kafkaProducer.send(TOPIC, alert);
                 log.info("tset");
                 return new ResponseResult(ErrorCode.SUCCESS);
             } else {
@@ -160,7 +161,7 @@ public ResponseResult requestRejected(Long responseUserId, ChatRejectDto chatRej
             if (Boolean.TRUE.equals(redisTemplate.hasKey(key))) {
                 redisTemplate.delete(key);
                 Alert alert = alertService.createAlert(requestUserId, "fail", "채팅 요청을 거부했습니다");
-                kafkaProducer.send("alert-topic", alert);
+                kafkaProducer.send(TOPIC, alert);
                 return new ResponseResult(ErrorCode.SUCCESS);
             } else {
                 return new ResponseResult(400, "ChatRequest not found or expired.");
@@ -210,7 +211,7 @@ public ResponseResult createChatRoom(Long userId, Long recordId, String requestN
                     Map<String, Object> map = new HashMap<>();
                     map.put("chatRoomId", chatRoomId.get());
                     Alert alert = alertService.createAlert(requestUserId, "accept", map);
-                    kafkaProducer.send("alert-topic", alert);
+                    kafkaProducer.send(TOPIC, alert);
                     return new ResponseResult(map);
                 }
 
@@ -238,7 +239,7 @@ public ResponseResult createChatRoom(Long userId, Long recordId, String requestN
 
                 // 요청자에게 방번호를 보냄
                 Alert alert = alertService.createAlert(requestUserId, "accept", map);
-                kafkaProducer.send("alert-topic", alert);
+                kafkaProducer.send(TOPIC, alert);
 
                 return new ResponseResult(map);
             } else {