feat(analysis[fe], user[be]): [fe] 분석 진행 화면, [be] sse 로직 추가, jwt 토큰에 userId 추가

feat(analysis[fe], user[be]): [fe] 분석 진행 화면, [be] sse 로직 추가, jwt 토큰에 userId 추가

Author: Hyeseung-OH

backend/src/main/java/com/backend/domain/analysis/controller/AnalysisController.java

@@ -2,19 +2,24 @@
 
 import com.backend.domain.analysis.dto.request.AnalysisRequest;
 import com.backend.domain.analysis.dto.response.AnalysisResultResponseDto;
+import com.backend.domain.analysis.dto.response.AnalysisStartResponse;
 import com.backend.domain.analysis.dto.response.HistoryResponseDto;
 import com.backend.domain.analysis.entity.AnalysisResult;
+import com.backend.domain.analysis.service.AnalysisProgressService;
 import com.backend.domain.analysis.service.AnalysisService;
 import com.backend.domain.repository.dto.response.RepositoryResponse;
 import com.backend.domain.repository.entity.Repositories;
 import com.backend.domain.repository.service.RepositoryService;
+import com.backend.domain.user.util.JwtUtil;
 import com.backend.global.exception.BusinessException;
 import com.backend.global.exception.ErrorCode;
 import com.backend.global.response.ApiResponse;
+import jakarta.servlet.http.HttpServletRequest;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -25,45 +30,59 @@
 public class AnalysisController {
     private final AnalysisService analysisService;
     private final RepositoryService repositoryService;
+    private final AnalysisProgressService analysisProgressService;
+    private final JwtUtil jwtUtil;
 
     // POST: 분석 요청
     @PostMapping
-    public ResponseEntity<ApiResponse<Void>> analyzeRepository(@RequestBody AnalysisRequest request) {
+    public ResponseEntity<ApiResponse<AnalysisStartResponse>> analyzeRepository(
+            @RequestBody AnalysisRequest request,
+            HttpServletRequest httpRequest
+    ) {
         if (request == null) {
             throw new BusinessException(ErrorCode.INVALID_INPUT_VALUE);
         }
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
 
-        analysisService.analyze(request.githubUrl());
-        return ResponseEntity.ok(ApiResponse.success());
+        Long repositoryId  = analysisService.analyze(request.githubUrl(), jwtUserId);
+        AnalysisStartResponse response = new AnalysisStartResponse(repositoryId);
+
+        return ResponseEntity.ok(ApiResponse.success(response));
     }
 
     // GET: 사용자의 모든 Repository 목록 조회
-    @GetMapping("/{memberId}/repositories")
+    @GetMapping("/{userId}/repositories")
     @Transactional(readOnly = true)
-    public ResponseEntity<List<RepositoryResponse>> getMemberHistory(
-            @PathVariable Long memberId
+    public ResponseEntity<ApiResponse<List<RepositoryResponse>>> getMemberHistory(
+            @PathVariable Long userId,
+            HttpServletRequest httpRequest
     ){
-        if (memberId == null) {
-            throw new BusinessException(ErrorCode.INVALID_INPUT_VALUE);
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
         }
 
         List<RepositoryResponse> repositories = repositoryService
-                .findRepositoryByMember(memberId)
+                .findRepositoryByUser(userId)
                 .stream()
                 .map(RepositoryResponse::new)
                 .toList();
 
-        return ResponseEntity.ok(repositories);
+        return ResponseEntity.ok(ApiResponse.success(repositories));
     }
 
     // GET: 특정 Repository의 분석 히스토리 조회, 모든 분석 결과 조회
-    @GetMapping("/{memberId}/repositories/{repositoriesId}")
+    @GetMapping("/{userId}/repositories/{repositoriesId}")
     @Transactional(readOnly = true)
-    public ResponseEntity<HistoryResponseDto> getAnalysisByRepositoriesId(
-            @PathVariable("memberId") Long memberId,
-            @PathVariable("repositoriesId") Long repoId
+    public ResponseEntity<ApiResponse<HistoryResponseDto>> getAnalysisByRepositoriesId(
+            @PathVariable("userId") Long userId,
+            @PathVariable("repositoriesId") Long repoId,
+            HttpServletRequest httpRequest
     ){
-        // TODO: 추후 인증/인가 기능 완성 후 소유권 검증 로직 추가
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
+        }
 
         // 1. Repository 정보 조회
         Repositories repository = repositoryService.findById(repoId)
@@ -87,18 +106,22 @@ public ResponseEntity<HistoryResponseDto> getAnalysisByRepositoriesId(
         // 4. 응답 조합
         HistoryResponseDto response = HistoryResponseDto.of(repositoryResponse, versions);
 
-        return ResponseEntity.ok(response);
+        return ResponseEntity.ok(ApiResponse.success(response));
     }
 
     // GET: 특정 분석 결과 상세 조회
-    @GetMapping("/{memberId}/repositories/{repositoryId}/results/{analysisId}")
+    @GetMapping("/{userId}/repositories/{repositoryId}/results/{analysisId}")
     @Transactional(readOnly = true)
-    public ResponseEntity<AnalysisResultResponseDto> getAnalysisDetail(
-            @PathVariable Long memberId,
+    public ResponseEntity<ApiResponse<AnalysisResultResponseDto>> getAnalysisDetail(
+            @PathVariable Long userId,
             @PathVariable Long repositoryId,
-            @PathVariable Long analysisId
+            @PathVariable Long analysisId,
+            HttpServletRequest httpRequest
     ) {
-        // TODO: 추후 인증/인가 검증
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
+        }
 
         // 분석 결과 조회
         AnalysisResult analysisResult = analysisService.getAnalysisById(analysisId);
@@ -110,33 +133,64 @@ public ResponseEntity<AnalysisResultResponseDto> getAnalysisDetail(
         AnalysisResultResponseDto response =
                 new AnalysisResultResponseDto(analysisResult, analysisResult.getScore());
 
-        return ResponseEntity.ok(response);
+        return ResponseEntity.ok(ApiResponse.success(response));
     }
 
     // Repository 삭제
-    @DeleteMapping("/{memberId}/repositories/{repositoriesId}")
-    public void deleteRepository(@PathVariable("repositoriesId") Long repositoriesId){
-        analysisService.delete(repositoriesId);
+    @DeleteMapping("/{userId}/repositories/{repositoriesId}")
+    public ResponseEntity<ApiResponse<Void>> deleteRepository(
+            @PathVariable("repositoriesId") Long repositoriesId,
+            @PathVariable Long userId,
+            HttpServletRequest httpRequest){
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
+        }
+
+        analysisService.delete(repositoriesId, userId);
+        return ResponseEntity.ok(ApiResponse.success());
     }
 
     // 특정 AnalysisResult 삭제
-    @DeleteMapping("/{memberId}/repositories/{repositoryId}/results/{analysisId}")
+    @DeleteMapping("/{userId}/repositories/{repositoryId}/results/{analysisId}")
     public ResponseEntity<ApiResponse<Void>> deleteAnalysisResult(
-            @PathVariable Long memberId,
+            @PathVariable Long userId,
             @PathVariable Long repositoryId,
-            @PathVariable Long analysisId
-    ) {
-        analysisService.deleteAnalysisResult(analysisId, memberId);
+            @PathVariable Long analysisId,
+            HttpServletRequest httpRequest){
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
+        }
+
+        analysisService.deleteAnalysisResult(analysisId, userId);
         return ResponseEntity.ok(ApiResponse.success());
     }
 
     // 분석 결과 공개 여부 변경
-    @PutMapping("/{memberId}/repositories/{repositoryId}/public")
-    public ResponseEntity updatePublicStatus(
-            @PathVariable Long memberId,
-            @PathVariable Long repositoryId
-    ) {
-        analysisService.updatePublicStatus(repositoryId, memberId);
+    @PutMapping("/{userId}/repositories/{repositoryId}/public")
+    public ResponseEntity<ApiResponse<Void>> updatePublicStatus(
+            @PathVariable Long userId,
+            @PathVariable Long repositoryId,
+            HttpServletRequest httpRequest){
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
+        }
+
+        analysisService.updatePublicStatus(repositoryId, userId);
         return ResponseEntity.ok(ApiResponse.success());
     }
+
+    // 분석 현황 Sse
+    @GetMapping("/stream/{userId}")
+    public SseEmitter stream(@PathVariable Long userId,
+                             HttpServletRequest httpRequest){
+        Long jwtUserId = jwtUtil.getUserId(httpRequest);
+        if (!jwtUserId.equals(userId)) {
+            throw new BusinessException(ErrorCode.FORBIDDEN);
+        }
+
+        return analysisProgressService.connect(userId);
+    }
 }

backend/src/main/java/com/backend/domain/analysis/dto/response/AnalysisResultResponseDto.java

@@ -13,7 +13,7 @@ public record AnalysisResultResponseDto(
     int testScore,
     int commitScore,
     int cicdScore,
-    String summery,
+    String summary,
     String strengths,
     String improvements
 ) {

backend/src/main/java/com/backend/domain/analysis/dto/response/AnalysisStartResponse.java

@@ -0,0 +1,6 @@
+package com.backend.domain.analysis.dto.response;
+
+public record AnalysisStartResponse(
+        Long repositoryId
+) {}
+

backend/src/main/java/com/backend/domain/analysis/entity/AnalysisResult.java

@@ -1,13 +1,10 @@
 package com.backend.domain.analysis.entity;
 
-import com.backend.domain.community.entity.Comment;
 import com.backend.domain.repository.entity.Repositories;
 import jakarta.persistence.*;
 import lombok.*;
 
 import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.List;
 
 @Entity
 @Table (name = "analysis_result")
@@ -24,13 +21,13 @@ public class AnalysisResult {
     @JoinColumn(name = "repository_id", nullable = false)
     private Repositories repositories;
 
-    @Column(nullable = false)
+    @Column(nullable = false, columnDefinition = "TEXT")
     private String summary;
 
-    @Column(nullable = false)
+    @Column(nullable = false, columnDefinition = "TEXT")
     private String strengths;
 
-    @Column(nullable = false)
+    @Column(nullable = false, columnDefinition = "TEXT")
     private String improvements;
 
     @Column(nullable = false, name = "createData")

backend/src/main/java/com/backend/domain/analysis/service/AnalysisProgressService.java

@@ -0,0 +1,36 @@
+package com.backend.domain.analysis.service;
+
+import org.springframework.stereotype.Service;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+@Service
+public class AnalysisProgressService {
+    private final Map<Long, SseEmitter> emitters = new ConcurrentHashMap<>();
+
+    public SseEmitter connect(Long userId) {
+        SseEmitter emitter = new SseEmitter(10 * 60 * 1000L);
+        emitters.put(userId, emitter);
+
+        emitter.onCompletion(() -> emitters.remove(userId));
+        emitter.onTimeout(() -> emitters.remove(userId));
+        emitter.onError((e) -> emitters.remove(userId));
+
+        sendEvent(userId, "connected", "SSE 연결 완료");
+        return emitter;
+    }
+
+    public void sendEvent(Long userId, String eventName, String data) {
+        SseEmitter emitter = emitters.get(userId);
+        if(emitter == null) return;
+
+        try {
+            emitter.send(SseEmitter.event().name(eventName).data(data));
+        } catch(IOException e) {
+            emitters.remove(userId);
+        }
+    }
+}