feat(analysis): 인메모리 락 추가, 요청 시 버튼 비활성화로 중복 요청 방지

Hyeseung-OH · Hyeseung-OH · commit 17f8efa97158 · 2025-10-24T00:02:21.000+09:00
diff --git a/backend/src/main/java/com/backend/domain/analysis/service/AnalysisService.java b/backend/src/main/java/com/backend/domain/analysis/service/AnalysisService.java
@@ -15,6 +15,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
 
 @Slf4j
 @Service
@@ -26,6 +27,9 @@ public class AnalysisService {
     private final RepositoryJpaRepository repositoryJpaRepository;
     private final SseProgressNotifier sseProgressNotifier;
 
+    // 인메모리 락
+    private final ConcurrentHashMap<String, Boolean> processingRepositories = new ConcurrentHashMap<>();
+
     /* Analysis 분석 프로세스 오케스트레이션 담당
     * 1. GitHub URL 파싱 및 검증
     * 2. Repository 도메인을 통한 데이터 수집
@@ -38,35 +42,49 @@ public Long analyze(String githubUrl, Long userId) {
         String owner = repoInfo[0];
         String repo = repoInfo[1];
 
-        sseProgressNotifier.notify(userId, "status", "분석 시작");
+        String cacheKey = userId + ":" + githubUrl;
 
-        // Repository 데이터 수집
-        RepositoryData repositoryData;
+        // 현재 처리 중인지 체크
+        if (processingRepositories.putIfAbsent(cacheKey, true) != null) {
+            log.warn("⚠중복 분석 요청 차단: userId={}, url={}", userId, githubUrl);
+            throw new BusinessException(ErrorCode.ANALYSIS_IN_PROGRESS);
+        }
 
         try {
-            repositoryData = repositoryService.fetchAndSaveRepository(owner, repo, userId);
-            log.info("🫠 Repository Data 수집 완료: {}", repositoryData);
-        } catch (BusinessException e) {
-            log.error("Repository 데이터 수집 실패: {}/{}", owner, repo, e);
-            throw handleRepositoryFetchError(e, owner, repo);
-        }
+            sseProgressNotifier.notify(userId, "status", "분석 시작");
 
-        Repositories savedRepository = repositoryJpaRepository
-                .findByHtmlUrl(repositoryData.getRepositoryUrl())
-                .orElseThrow(() -> new BusinessException(ErrorCode.GITHUB_REPO_NOT_FOUND));
+            // Repository 데이터 수집
+            RepositoryData repositoryData;
 
-        Long repositoryId = savedRepository.getId();
+            try {
+                repositoryData = repositoryService.fetchAndSaveRepository(owner, repo, userId);
+                log.info("🫠 Repository Data 수집 완료: {}", repositoryData);
+            } catch (BusinessException e) {
+                log.error("Repository 데이터 수집 실패: {}/{}", owner, repo, e);
+                throw handleRepositoryFetchError(e, owner, repo);
+            }
 
-        // OpenAI API 데이터 분석 및 저장
-        try {
-            evaluationService.evaluateAndSave(repositoryData);
-        } catch (BusinessException e) {
-            sseProgressNotifier.notify(userId, "error", "AI 평가 실패: " + e.getMessage());
-            throw e;
-        }
+            Repositories savedRepository = repositoryJpaRepository
+                    .findByHtmlUrl(repositoryData.getRepositoryUrl())
+                    .orElseThrow(() -> new BusinessException(ErrorCode.GITHUB_REPO_NOT_FOUND));
+
+            Long repositoryId = savedRepository.getId();
 
-        sseProgressNotifier.notify(userId, "complete", "최종 리포트 생성");
-        return repositoryId;
+            // OpenAI API 데이터 분석 및 저장
+            try {
+                evaluationService.evaluateAndSave(repositoryData);
+            } catch (BusinessException e) {
+                sseProgressNotifier.notify(userId, "error", "AI 평가 실패: " + e.getMessage());
+                throw e;
+            }
+
+            sseProgressNotifier.notify(userId, "complete", "최종 리포트 생성");
+            return repositoryId;
+        } finally {
+            // 락 해제
+            processingRepositories.remove(cacheKey);
+            log.info("분석 락 해제: cacheKey={}", cacheKey);
+        }
     }
 
     private String[] parseGitHubUrl(String githubUrl) {
diff --git a/backend/src/main/java/com/backend/global/exception/ErrorCode.java b/backend/src/main/java/com/backend/global/exception/ErrorCode.java
@@ -27,6 +27,7 @@ public enum ErrorCode {
     ANALYSIS_NOT_FOUND("A003", HttpStatus.BAD_REQUEST, "분석 결과를 찾을 수 없습니다."),
     USER_NOT_FOUND("A004", HttpStatus.FORBIDDEN, "사용자 정보를 찾을 수 없습니다."),
     FORBIDDEN("A005", HttpStatus.FORBIDDEN, "접근 권한이 없습니다."),
+    ANALYSIS_IN_PROGRESS("A006", HttpStatus.CONFLICT, "이미 분석이 진행 중입니다. 잠시 후 다시 시도해주세요."),
 
     // ========== repository 도메인 에러 ==========
     GITHUB_REPO_NOT_FOUND("G001", HttpStatus.BAD_REQUEST, "GitHub 저장소를 찾을 수 없습니다."),
diff --git a/front/src/app/(dashboard)/analysis/page.tsx b/front/src/app/(dashboard)/analysis/page.tsx
@@ -17,10 +17,24 @@ import { useRequireAuth } from "@/hooks/auth/useRequireAuth"
 export default function AnalyzePage() {
   const [repoUrl, setRepoUrl] = useState("")
   const [isValidUrl, setIsValidUrl] = useState(true)
+  const [isSubmitting, setIsSubmitting] = useState(false) 
   const router = useRouter()
-  const { requestAnalysis, isLoading, error } = useAnalysis()
-
+  const { error } = useAnalysis()
   const { user } = useRequireAuth()
+
+  useEffect(() => {
+    // 페이지 포커스 시 상태 초기화 (뒤로가기 대응)
+    const handleVisibilityChange = () => {
+      if (document.visibilityState === 'visible') {
+        setIsSubmitting(false)
+      }
+    }
+    
+    document.addEventListener('visibilitychange', handleVisibilityChange)
+    return () => document.removeEventListener('visibilitychange', handleVisibilityChange)
+  }, [])
+
+  
   if (!user) return null
 
   const handleSubmit = (e: React.FormEvent) => {
@@ -32,6 +46,7 @@ export default function AnalyzePage() {
     }
   
     setIsValidUrl(true);
+    setIsSubmitting(true); 
     
     // 여기서 API 요청하지 않고 repoUrl만 전달
     const encodedUrl = encodeURIComponent(repoUrl);
@@ -75,7 +90,7 @@ export default function AnalyzePage() {
                     value={repoUrl}
                     onChange={handleUrlChange}
                     className={`pl-10 h-12 text-base ${!isValidUrl ? "border-destructive" : ""}`}
-                    disabled={isLoading}
+                    disabled={isSubmitting}
                     required
                   />
                 </div>
@@ -88,14 +103,13 @@ export default function AnalyzePage() {
               </div>
 
               <Button
-                type="button"  // ✅ form submit 방지
-                onClick={handleSubmit}  // ✅ 직접 이벤트 트리거
+                type="submit"  // ← type="submit"으로 변경 (form 제출 사용)
                 className="w-full"
                 size="lg"
-                disabled={isLoading}
+                disabled={isSubmitting || !repoUrl}  // ← 수정: 제출 중이거나 URL 없으면 비활성화
               >
                 <Search className="mr-2 h-5 w-5" />
-                {isLoading ? "분석 요청 중..." : "분석 시작하기"}
+                {isSubmitting ? "분석 페이지로 이동 중..." : "분석 시작하기"}
               </Button>
             </form>
           </Card>
diff --git a/front/src/components/analysis/LoadingContent.tsx b/front/src/components/analysis/LoadingContent.tsx
@@ -2,6 +2,7 @@
 
 import { useSearchParams } from "next/navigation"
 import { Progress } from "@/components/ui/progress"
+import { AlertCircle } from "lucide-react"
 import LoadingHeader from "@/components/analysis/LoadingHeader"
 import LoadingStepList from "@/components/analysis/LoadingStepList"
 import LoadingInfoBox from "@/components/analysis/LoadingInfoBox"
@@ -12,36 +13,61 @@ export default function LoadingContent() {
   const repoUrl = searchParams.get("repoUrl") // ✅ 'repo' → 'repoUrl'로 수정
 
   // ✅ repoUrl을 훅에 전달해야 실제 API 요청이 실행됨
-  const { progress, currentStep, steps, statusMessage } = useAnalysisProgress(repoUrl)
+  const { progress, currentStep, steps, statusMessage, error } = useAnalysisProgress(repoUrl)
 
   return (
     <div className="min-h-screen bg-background">
       <div className="container mx-auto px-4 sm:px-6 lg:px-8 py-16">
         <div className="mx-auto max-w-2xl">
           {/* 분석 중인 저장소 URL 헤더 */}
           <LoadingHeader repoUrl={repoUrl} />
+          {/* 에러 표시 */}
+          {error && (
+            <div className="mb-6 rounded-lg border border-destructive/50 bg-destructive/10 p-4">
+              <div className="flex items-start gap-3">
+                <AlertCircle className="h-5 w-5 text-destructive flex-shrink-0 mt-0.5" />
+                <div className="flex-1">
+                  <h4 className="font-semibold text-destructive mb-1">
+                    분석 요청 실패
+                  </h4>
+                  <p className="text-sm text-destructive/90">
+                    {error}
+                  </p>
+                  <p className="text-xs text-muted-foreground mt-2">
+                    잠시 후 자동으로 분석 페이지로 돌아갑니다...
+                  </p>
+                </div>
+              </div>
+            </div>
+          )}
 
-          <div className="mb-12 space-y-3">
-            {/* 진행률 바 + 퍼센트 표시 */}
-            <Progress value={progress} className="h-2" />
-            <div className="flex items-center justify-between text-sm">
-              <span className="text-muted-foreground">
-                {Math.round(progress)}% 완료
-              </span>
-              <span className="text-muted-foreground">
-                {currentStep + 1} / {steps.length} 단계
-              </span>
+          {/* 에러가 없을 때만 진행률 표시 */}
+          {!error && (
+          <> 
+            <div className="mb-12 space-y-3">
+              {/* 진행률 바 + 퍼센트 표시 */}
+              <Progress value={progress} className="h-2" />
+              <div className="flex items-center justify-between text-sm">
+                <span className="text-muted-foreground">
+                  {Math.round(progress)}% 완료
+                </span>
+                <span className="text-muted-foreground">
+                  {currentStep + 1} / {steps.length} 단계
+                </span>
+              </div>
             </div>
-          </div>
 
-          {/* 상태 메시지 출력 (선택) */}
-          <p className="text-center text-sm text-muted-foreground mb-4">
-            {statusMessage}
-          </p>
+            {/* 상태 메시지 출력 (선택) */}
+            <p className="text-center text-sm text-muted-foreground mb-4">
+              {statusMessage}
+            </p>
 
-          {/* 단계 리스트 및 추가 정보 */}
-          <LoadingStepList steps={steps} currentStep={currentStep} />
-          <LoadingInfoBox />
+            {/* 단계 리스트 및 추가 정보 */}
+            <LoadingStepList steps={steps} currentStep={currentStep} />
+            <LoadingInfoBox />
+          </>
+          
+          )}
         </div>
       </div>
     </div>
diff --git a/front/src/components/analysis/RepositoryPublicSection.tsx b/front/src/components/analysis/RepositoryPublicSection.tsx
@@ -104,10 +104,6 @@ export function RepositoryPublicSection({ userId, repoId, initialPublic }: Props
                 <p className="text-sm text-muted-foreground">다른 개발자들과 소통하세요.</p>
               </div>
               <div className="flex gap-2">
-                <Button variant="outline" size="sm" className="gap-2 bg-transparent">
-                  <MessageSquare className="h-4 w-4" />
-                  댓글 (n)
-                </Button>
                 <ShareButton />
               </div>
             </div>
diff --git a/front/src/hooks/analysis/useLoadingProgress.ts b/front/src/hooks/analysis/useLoadingProgress.ts
@@ -61,9 +61,38 @@ export function useAnalysisProgress(repoUrl?: string | null) {
             headers: { "Content-Type": "application/json" },
             body: JSON.stringify({ githubUrl: repoUrl }),
           })
-          const data = await res.json()
+          
+          if (!res.ok) {
+            const errorData = await res.json()
+            
+            // 409 Conflict: 중복 요청
+            if (res.status === 409) {
+              console.warn("⚠️ 중복 분석 요청 감지")
+              setError("이미 분석이 진행 중입니다. 잠시 후 다시 시도해주세요.")
+              setStatusMessage("중복 요청이 감지되었습니다")
+              eventSource.close()
+              
+              // 3초 후 분석 페이지로 돌아가기
+              setTimeout(() => {
+                router.push("/analysis")
+              }, 3000)
+              return
+            }
+            
+            // 기타 에러 (400, 500 등)
+            console.error("❌ 분석 요청 실패:", errorData)
+            setError(errorData.message || "분석 요청에 실패했습니다")
+            setStatusMessage("요청 처리 중 오류가 발생했습니다")
+            eventSource.close()
+            
+            // 3초 후 분석 페이지로 돌아가기
+            setTimeout(() => {
+              router.push("/analysis")
+            }, 3000)
+            return
+          }
 
-          // ✅ repositoryId를 즉시 ref에 저장
+          const data = await res.json()
           const repoId = data.data.repositoryId
           setRepositoryId(repoId)
           repositoryIdRef.current = repoId
diff --git a/front/src/hooks/auth/useAuth.ts b/front/src/hooks/auth/useAuth.ts
@@ -8,20 +8,23 @@ export function useAuth() {
   const [token, setToken] = useState<string | null>(null);
   const [user, setUser] = useState<GetUserResponse | null>(null);
   const [isLoadingUser, setIsLoadingUser] = useState(false);
+  const [isInitializing, setIsInitializing] = useState(true); 
 
   const fetchUserInfo = async () => {
     const token = localStorage.getItem('accessToken');
     if (!token) return;
 
     try {
       setIsLoadingUser(true);
-      console.log('사용자 정보 요청 시작');
       const userData = await authApi.getCurrentUser();
-      console.log('사용자 정보 받음:', userData);
       setUser(userData);
+      localStorage.setItem('user', JSON.stringify(userData));
     } catch (error) {
       console.error('사용자 정보 가져오기 실패:', error);
-      // 에러 발생 시 로그아웃하지 않고 그냥 넘어감 (무한 루프 방지)
+      localStorage.removeItem('accessToken');
+      localStorage.removeItem('user');
+      setToken(null);
+      setUser(null);
     } finally {
       setIsLoadingUser(false);
     }
@@ -41,8 +44,10 @@ export function useAuth() {
           const parsedUser = JSON.parse(savedUser);
           console.log('저장된 사용자 정보 복원:', parsedUser);
           setUser(parsedUser);
+          setIsInitializing(false);
         } catch (error) {
           console.error('사용자 정보 파싱 실패:', error);
+          setIsInitializing(false);
         }
       } else if (t) {
         // 토큰은 있는데 사용자 정보가 없으면 가져오기
@@ -70,7 +75,7 @@ export function useAuth() {
       return () => clearTimeout(logoutTimer);
     }, [token]); // token이 새로 설정될 때마다 타이머 재설정
 
-  const isAuthed = useMemo(() => !!token, [token]);
+  const isAuthed = useMemo(() => !!token && !!user, [token, user]);
 
   function loginWithToken(userData: GetUserResponse) {
     console.log('loginWithToken 호출됨, userData:', userData);
@@ -109,6 +114,7 @@ export function useAuth() {
     token, 
     user, 
     isLoadingUser,
+    isInitializing,
     loginWithToken, 
     logout,
     fetchUserInfo 
diff --git a/front/src/hooks/auth/useRequireAuth.ts b/front/src/hooks/auth/useRequireAuth.ts
@@ -6,13 +6,23 @@ import { useAuth } from "@/hooks/auth/useAuth"
 
 export function useRequireAuth() {
   const router = useRouter()
-  const { isAuthed, user } = useAuth()
+  const { isAuthed, user, isInitializing } = useAuth()
 
   useEffect(() => {
+    // ⬇️ 초기화 중이면 리다이렉트하지 않음
+    if (isInitializing) {
+      console.log("인증 상태 확인 중...")
+      return
+    }
+    
+    // ⬇️ 초기화 완료 후 인증 실패 시에만 리다이렉트
     if (!isAuthed || !user) {
+      console.log("인증 실패, /login으로 리다이렉트")
       router.replace("/login")
+    } else {
+      console.log("인증 성공:", user)
     }
-  }, [isAuthed, user, router])
+  }, [isAuthed, user, isInitializing, router])
 
-  return { user, isAuthed }
-}
+  return { user, isAuthed, isInitializing }
+}
