fix: 사용하지 않는 메소드 및 서비스 삭제

Author: whale22

src/main/java/cmf/commitField/domain/commit/sinceCommit/controller/SinceCommitController.java

@@ -2,13 +2,11 @@
 
 import cmf.commitField.domain.commit.sinceCommit.dto.CommitAnalysisResponseDto;
 import cmf.commitField.domain.commit.sinceCommit.dto.SinceCommitResponseDto;
-import cmf.commitField.domain.commit.sinceCommit.service.GithubService;
 import cmf.commitField.domain.commit.sinceCommit.service.SinceCommitService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -20,7 +18,6 @@
 @RequiredArgsConstructor
 public class SinceCommitController {
     private final SinceCommitService sinceCommitService;
-    private final GithubService githubService;
 
     @GetMapping("/api/github/commits-since")
     public ResponseEntity<List<SinceCommitResponseDto>> getCommits(
@@ -104,11 +101,4 @@ public ResponseEntity<CommitAnalysisResponseDto> getWinterSeasonCommits(
         return ResponseEntity.ok(analysis);
     }
 
-    // api 테스트 메소드 추가
-    @GetMapping("/api/commit-count/{username}")
-    public ResponseEntity<Integer> getCommitCount(@PathVariable String username) {
-        System.out.println("⚡ API 엔드포인트 호출: " + username);
-        int commitCount = githubService.getUserCommitCount(username);
-        return ResponseEntity.ok(commitCount);
-    }
 }

src/main/java/cmf/commitField/domain/commit/sinceCommit/service/CommitCacheService.java

@@ -14,7 +14,7 @@ public class CommitCacheService {
     private final StringRedisTemplate redisTemplate;
 
     public Integer getCachedCommitCount(String username) {
-        String key = "commit_active:" + username; // Redis 키 생성 (ex: commit:hongildong)
+        String key = "commit_active:" + username; // Redis 키 생성
         String value = redisTemplate.opsForValue().get(key); // Redis에서 값 가져오기
 
         if (value != null) {

src/main/java/cmf/commitField/domain/commit/sinceCommit/service/GithubService.java

@@ -0,0 +1,28 @@
+package cmf.commitField.domain.redpanda;
+
+import cmf.commitField.domain.redpanda.dto.CommitUpdateMessageDto;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Service;
+
+@Service
+public class RedpandaConsumer {
+
+    private final ObjectMapper objectMapper;
+
+    public RedpandaConsumer(ObjectMapper objectMapper) {
+        this.objectMapper = objectMapper;
+    }
+
+    @KafkaListener(topics = "commit-topic", groupId = "commit-group")
+    public void listen(ConsumerRecord<String, String> record) {
+        try {
+            String message = record.value();
+            CommitUpdateMessageDto commitUpdate = objectMapper.readValue(message, CommitUpdateMessageDto.class);
+            System.out.println("✅ Received commit update: " + commitUpdate);
+        } catch (Exception e) {
+            System.err.println("❌ Failed to parse commit update: " + e.getMessage());
+        }
+    }
+}

src/main/java/cmf/commitField/domain/redpanda/KafkaConsumer.java

@@ -0,0 +1,19 @@
+package cmf.commitField.domain.redpanda;
+
+import cmf.commitField.domain.commit.scheduler.CommitScheduler;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api/kafka")
+public class RedpandaController {
+
+    private final RedpandaProducer redpandaProducer;
+    private final CommitScheduler commitScheduler;
+
+    public RedpandaController(RedpandaProducer redpandaProducer, CommitScheduler commitScheduler) {
+        this.redpandaProducer = redpandaProducer;
+        this.commitScheduler = commitScheduler;
+    }
+
+}

src/main/java/cmf/commitField/domain/redpanda/RedpandaConsumer.java

@@ -1,28 +1,31 @@
 package cmf.commitField.domain.redpanda;
 
+import cmf.commitField.domain.redpanda.dto.CommitUpdateMessageDto;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Service;
 
 @Service
 public class RedpandaProducer {
 
     private final KafkaTemplate<String, String> kafkaTemplate;
-    private static final String TOPIC = "commit-topic"; // Redpanda에서 사용할 토픽명
+    private final ObjectMapper objectMapper; // JSON 변환을 위한 ObjectMapper
+    private static final String TOPIC = "commit-topic";
 
-    public RedpandaProducer(KafkaTemplate<String, String> kafkaTemplate) {
+    public RedpandaProducer(KafkaTemplate<String, String> kafkaTemplate, ObjectMapper objectMapper) {
         this.kafkaTemplate = kafkaTemplate;
+        this.objectMapper = objectMapper;
     }
 
-    // 메시지 전송 메서드
-    public void sendMessage(String message) {
-        kafkaTemplate.send(TOPIC, message);
-        System.out.println("📨 Sent message to Redpanda: " + message);
-    }
-
-    // 커밋 업데이트 전송 메서드
+    // 🔹 커밋 업데이트 전송 메서드
     public void sendCommitUpdate(String username, long commitCount) {
-        String message = String.format("{\"user\": \"%s\", \"update-commits\": %d}", username, commitCount);
-        kafkaTemplate.send(TOPIC, message);
-        System.out.println("📨 Sent commit update to Redpanda: " + message);
+        try {
+            CommitUpdateMessageDto message = new CommitUpdateMessageDto(username, commitCount);
+            String jsonMessage = objectMapper.writeValueAsString(message); // DTO를 JSON으로 변환
+            kafkaTemplate.send(TOPIC, jsonMessage);
+            System.out.println("📨 Sent commit update to Redpanda: " + jsonMessage);
+        } catch (Exception e) {
+            System.err.println("❌ Failed to send commit update: " + e.getMessage());
+        }
     }
 }

src/main/java/cmf/commitField/domain/redpanda/RedpandaController.java

@@ -0,0 +1,27 @@
+package cmf.commitField.domain.redpanda.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Setter
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+public class CommitUpdateMessageDto {
+    @JsonProperty("user")
+    private String username;
+
+    @JsonProperty("update-commits")
+    private long commitCount;
+
+    @Override
+    public String toString() {
+        return "CommitUpdateMessage{" +
+                "username='" + username + '\'' +
+                ", updateCommitCount=" + commitCount +
+                '}';
+    }
+}