10-11차 배포

[HeeMang-Lee]

🔎 작업 내용

• Resilience4J를 활용한 CB,Retry 추가

---

Summary by CodeRabbit

• New Features
  • Brave 검색 결과를 표준화된 JSON(results 배열)으로 제공하여 일관된 표시와 활용이 가능해졌습니다.
  • 검색 결과 해석 및 문서화(RAG) 파이프라인을 강화해 더 안정적이고 관련성 높은 응답을 제공합니다.
• Improvements
  • AI 대화/스트리밍 요청에 회로 차단기와 재시도 정책을 적용해 안정성과 내고장을 향상했습니다.
• Chores
  • 의존성 추가 및 설정 반영(Resilience4j), Docker 이미지 빌드 최적화.
• Documentation
  • 설정 주석 정리.

[coderabbitai]

Walkthrough

Resilience4j를 도입하고 AiResilience 컴포넌트를 추가했다. OpenAI/Claude 클라이언트 호출을 동기/스트림 모두 회로차단기와 재시도로 감쌌다. Brave MCP 검색은 초기화 재시도와 결과 정규화 파이프라인을 추가했다. Gradle 의존성과 application.properties에 회복력 설정을 반영하고 Dockerfile의 MCP 설치/래퍼 생성을 단순화했다.

Changes

Cohort / File(s)	Summary of changes
Docker 이미지 빌드 정리 cs25-service/Dockerfile	RUN 단계 간소화, set -eux 추가, wrapper를 printf로 생성하고 PATH 의존 실행, --help로 산출 검증, npm/apt 캐시 정리 강화.
Resilience4j 의존성 추가 cs25-service/build.gradle	resilience4j-spring-boot3, circuitbreaker, retry, reactor(v2.3.0) 추가.
AI 호출 회복력 래핑: OpenAI/Claude .../domain/ai/client/OpenAiChatClient.java, .../domain/ai/client/ClaudeChatClient.java	생성자에 AiResilience 주입 추가. 동기 호출은 executeSync("openai"/"claude"), 스트리밍은 executeStream으로 래핑. 스트림 에러 onErrorResume → onErrorMap으로 변경.
Resilience 유틸 컴포넌트 추가 .../domain/ai/resilience/AiResilience.java	CircuitBreakerRegistry/RetryRegistry 주입. executeSync/executeStream 제공. Retry→CircuitBreaker 순서로 적용(reactor는 Operator 사용).
Brave MCP 검색 정규화/초기화 보강 .../domain/ai/service/BraveSearchMcpService.java	다양한 형태의 응답을 {results:[...]}로 정규화(배열/중첩 JSON/레거시 텍스트). JSON 탐지/파싱/트렁케이션 헬퍼 추가. MCP 클라이언트 초기화 감지 및 1회 재시도. 로깅 확장.
Brave RAG 변환 로직 강화 .../domain/ai/service/BraveSearchRagService.java	ObjectMapper 도입. 결과에서 url/title/description 추출 실패 시 텍스트 내 JSON/레거시 블록 파싱으로 보강. 단일 Document 생성 파이프라인으로 통일. 파싱 실패는 무시하고 진행.
애플리케이션 설정 업데이트 cs25-service/src/main/resources/application.properties	MCP 초기화 플래그 제거. CircuitBreaker/Retry 기본 및 openai/claude 인스턴스 설정 추가. 주석/포맷 수정.

Sequence Diagram(s)

sequenceDiagram
  participant C as Controller/Service
  participant OC as OpenAiChatClient
  participant AR as AiResilience
  participant OA as OpenAI SDK

  C->>OC: chat(prompt) / stream(prompt)
  OC->>AR: executeSync/executeStream("openai", supplier)
  AR->>OA: 호출 (Retry→CircuitBreaker)
  OA-->>AR: 응답 또는 오류
  AR-->>OC: 결과 Flux/값
  OC-->>C: 콘텐츠 또는 AiException(onErrorMap)

Loading

sequenceDiagram
  participant S as BraveSearchMcpService
  participant M as MCP Client
  participant N as Normalizer

  S->>M: resolveBraveClient()
  alt not initialized
    M--x S: McpError (uninitialized)
    S->>M: initialize() 재시도(1회)
  end
  S->>M: search(query)
  M-->>S: raw content (varied shapes)
  S->>N: normalize(raw)
  N-->>S: { "results": [...] }
  S-->>Caller: 정규화된 JSON

Loading

Estimated code review effort

🎯 4 (Complex) | ⏱️ ~60 minutes

Possibly related PRs

• Feat/414 : Ai피드백 Resilence4j를 활용한 CB,Retry 적용 #415: 동일한 Resilience4j 통합(의존성, AiResilience, 클라이언트 래핑, 설정) 변경과 중복되는 코드 수준 수정.
• Refactor : deprecated 패키지 제거, 공식 Brave MCP 서버 설치, 래퍼 스크립트로 server-brave-search 제공 #407: Dockerfile에서 Brave MCP 설치/래퍼 생성 단순화 및 헬프 체크 추가와 직접적으로 동일한 영역 수정.
• Refactor: Json파싱 표준화로 MCP Servie 리팩토링 #412: BraveSearchMcpService/RagService의 JSON 정규화와 초기화/재시도 로직을 유사하게 변경.

Suggested reviewers

• crocusia
• Kimyoonbeom
• Ksr-ccb

Poem

토끼는 귀를 세우고 빌드를 톡톡톡—
회로는 닫혔다 열리고, 재시도는 콩콩콩!
용감한 검색은 결과를 예쁘게 정렬하고,
구름과 열쇠(Open/Claude)는 안전망 속 반짝—
당근 같은 로그, 부드러운 스트림 흘러간다. 🥕✨

Tip

🔌 Remote MCP (Model Context Protocol) integration is now available!

Pro plan users can now connect to remote MCP servers from the Integrations page. Connect with popular remote MCPs such as Notion and Linear to add more context to your reviews and chats.

✨ Finishing Touches

• 📝 Generate Docstrings

🧪 Generate unit tests

• Create PR with unit tests
• Post copyable unit tests in a comment
• Commit unit tests in branch dev

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

🪧 Tips

Chat

There are 3 ways to chat with CodeRabbit:

• Review comments: Directly reply to a review comment made by CodeRabbit. Example:
  • I pushed a fix in commit <commit_id>, please review it.
  • Open a follow-up GitHub issue for this discussion.
• Files and specific lines of code (under the "Files changed" tab): Tag @coderabbitai in a new review comment at the desired location with your query.
• PR comments: Tag @coderabbitai in a new PR comment to ask questions about the PR branch. For the best results, please provide a very specific query, as very limited context is provided in this mode. Examples:
  • @coderabbitai gather interesting stats about this repository and render them as a table. Additionally, render a pie chart showing the language distribution in the codebase.
  • @coderabbitai read the files in the src/scheduler package and generate a class diagram using mermaid and a README in the markdown format.

Support

Need help? Create a ticket on our support page for assistance with any issues or questions.

CodeRabbit Commands (Invoked using PR/Issue comments)

Type @coderabbitai help to get the list of available commands.

Other keywords and placeholders

• Add @coderabbitai ignore anywhere in the PR description to prevent this PR from being reviewed.
• Add @coderabbitai summary to generate the high-level summary at a specific location in the PR description.
• Add @coderabbitai anywhere in the PR title to generate the title automatically.

CodeRabbit Configuration File (.coderabbit.yaml)

• You can programmatically configure CodeRabbit by adding a .coderabbit.yaml file to the root of your repository.
• Please see the configuration documentation for more information.
• If your editor has YAML language server enabled, you can add the path at the top of this file to enable auto-completion and validation: # yaml-language-server: $schema=https://coderabbit.ai/integrations/schema.v2.json

Status, Documentation and Community

• Visit our Status Page to check the current availability of CodeRabbit.
• Visit our Documentation for detailed information on how to use CodeRabbit.
• Join our Discord Community to get help, request features, and share feedback.
• Follow us on X/Twitter for updates and announcements.

[coderabbitai]

Actionable comments posted: 3

🧹 Nitpick comments (15)

cs25-service/build.gradle (1)

36-40: Resilience4j 의존성 추가는 적절합니다만, 약간의 중복 가능성 점검 권장

resilience4j-spring-boot3 스타터가 다수 모듈을 전이로 끌어오므로 circuitbreaker/retry 직접 선언은 중복일 수 있습니다. 기능상 문제는 없지만 의존성 표면을 최소화하려면 아래처럼 스타터 + 리액터만 유지하는 구성을 고려해보세요.

예시(선택):

     // resilience4j
     implementation 'io.github.resilience4j:resilience4j-spring-boot3:2.3.0'
-    implementation 'io.github.resilience4j:resilience4j-circuitbreaker:2.3.0'
-    implementation 'io.github.resilience4j:resilience4j-retry:2.3.0'
     implementation 'io.github.resilience4j:resilience4j-reactor:2.3.0'

또한 Spring Boot 3.5.0과 Resilience4j 2.3.0의 조합은 일반적으로 호환되지만, 런타임 충돌 여부를 한 번 통합 테스트로 확인하는 것을 권장합니다.

cs25-service/src/main/resources/application.properties (3)

76-88: CircuitBreaker 기본값 미세 조정 제안(특히 Half-Open 샘플 수와 Open 대기시간)

현재 설정은 전형적이지만, 다음 사항을 검토하면 불필요한 플랩을 줄일 수 있습니다.

• permittedNumberOfCallsInHalfOpenState=1 → 3 내외 권장: 일시적 회복/노이즈에 더 견고.
• waitDurationInOpenState=30m → 1~5m 검토: 장시간 차단은 사용자 경험에 영향 가능.
• 인스턴스별 튜닝: openai/claude의 특성(모델 레이트리밋, API SLA)에 맞춰 별도 임계치 적용 고려.

원하시면 openai/claude 인스턴스에만 상이한 기본값을 두는 예시 패치를 제안드리겠습니다.

---

88-91: 429(TooManyRequests)를 CB 집계에서 제외하는 것을 고려

4xx는 무시 목록에 있으나 429는 빠져 있습니다. 레이트리밋 상황은 장애가 아니라 용량 이슈이므로 서킷브레이커 failure 집계에서 제외하는 편이 흔합니다(재시도는 별도 정책으로 처리).

예시(선택):

 resilience4j.circuitbreaker.configs.default.ignoreExceptions[0]=org.springframework.web.reactive.function.client.WebClientResponseException.BadRequest
 resilience4j.circuitbreaker.configs.default.ignoreExceptions[1]=org.springframework.web.reactive.function.client.WebClientResponseException.Unauthorized
 resilience4j.circuitbreaker.configs.default.ignoreExceptions[2]=org.springframework.web.reactive.function.client.WebClientResponseException.Forbidden
 resilience4j.circuitbreaker.configs.default.ignoreExceptions[3]=org.springframework.web.reactive.function.client.WebClientResponseException.NotFound
+resilience4j.circuitbreaker.configs.default.ignoreExceptions[4]=org.springframework.web.reactive.function.client.WebClientResponseException.TooManyRequests

주의: Retry 쪽에서는 429를 “무시”하지 않고(즉, 재시도 대상 유지) 백오프/재시도 정책으로 다루는 것이 일반적입니다.

---

93-102: Retry 정책 미세 조정: 시도 횟수, 지터 추가

• maxAttempts=2는 다소 보수적입니다. 네트워크/일시 오류 대응을 위해 3~4 시도를 고려해보세요.
• 대규모 동시 재시도를 완화하려면 지터(randomized wait)를 켜는 것이 유용합니다.

간단 조정 예시(선택):

-resilience4j.retry.configs.default.maxAttempts=2
-resilience4j.retry.configs.default.waitDuration=200ms
+resilience4j.retry.configs.default.maxAttempts=3
+resilience4j.retry.configs.default.waitDuration=300ms
 resilience4j.retry.configs.default.enableExponentialBackoff=true
 resilience4j.retry.configs.default.exponentialBackoffMultiplier=2

지터는 프로퍼티만으로 제한적일 수 있어, 필요 시 코드 기반 IntervalFunction(지수+지터)로 인스턴스별 세밀 제어를 도와드릴 수 있습니다.

cs25-service/Dockerfile (1)

25-45: Brave MCP 서버 설치/래퍼 생성: 버전 고정 및 잔여 패키지 정리 제안

현재 최신 태그 설치(@brave/brave-search-mcp-server)는 재현성과 공급망 리스크 관점에서 변동성이 있습니다. 명시 버전 고정과 빌드 후 불필요 패키지 추가 정리를 추천합니다.

예시:

-    npm install -g @brave/brave-search-mcp-server; \
+    npm install -g @brave/brave-search-mcp-server@<고정_버전>; \
@@
-    apt-get purge -y gnupg; \
+    apt-get purge -y gnupg curl bash; \
     apt-get autoremove -y --purge; \
     rm -rf /var/lib/apt/lists/*

필요 시 server-brave-search --version 체크도 sanity check에 포함할 수 있습니다.

cs25-service/src/main/java/com/example/cs25service/domain/ai/service/BraveSearchRagService.java (2)

17-18: ObjectMapper 직접 생성 대신 빈 주입 권장

Spring Boot의 전역 ObjectMapper 커스터마이징(모듈 등록, 직렬화 옵션 등)을 활용하려면 직접 생성 대신 주입받는 편이 좋습니다. 현재 @RequiredArgsConstructor이므로 final 필드를 생성자 주입으로 바꾸면 됩니다.

-    private final ObjectMapper objectMapper = new ObjectMapper();
+    private final ObjectMapper objectMapper;

(필요 시 import 변경 없음. 스프링 컨텍스트에 기본 ObjectMapper 빈이 존재합니다.)

---

33-39: JSON 파싱 실패 시 디버그 로그 남기기 제안

예외를 완전히 무시하면 원인 파악이 어려울 수 있습니다. 디버그 레벨로 짧게 남기는 정도를 권합니다.

-                        } catch (Exception ignored) { /* fall back below */ }
+                        } catch (Exception ex) {
+                            // fall back below
+                            if (org.slf4j.LoggerFactory.getLogger(BraveSearchRagService.class).isDebugEnabled()) {
+                                org.slf4j.LoggerFactory.getLogger(BraveSearchRagService.class)
+                                    .debug("inner JSON parse failed: {}", ex.toString());
+                            }
+                        }

cs25-service/src/main/java/com/example/cs25service/domain/ai/service/BraveSearchMcpService.java (4)

30-37: 유사 JSON 감지 로직 중복 최소화(선택)

looksLikeJson 유틸이 Rag 서비스에도 유사하게 존재합니다. 공용 유틸 클래스로 추출해 중복을 제거하면 유지보수가 수월합니다.

원하시면 두 서비스가 공유하는 AiJsonUtils(가칭) 클래스로 리팩터를 제안드릴 수 있습니다.

---

67-78: 원시 응답 로그 레벨을 debug로 낮추는 것을 권장

검색 결과 원문은 길고 빈번할 수 있어 info 로그는 과도할 수 있습니다. 운영 환경에서는 debug가 적절합니다.

-        log.info("[Brave MCP Response Raw content]: {}", raw);
+        log.debug("[Brave MCP Response Raw content]: {}", raw);
@@
-        log.info("Brave 검색 결과 정규화 완료: {}건", normalized.size());
+        log.debug("Brave 검색 결과 정규화 완료: {}건", normalized.size());

---

80-116: 비초기화 MCP 클라이언트 자동 initialize 재시도: 예외 로깅 개선 제안

현재 initError.getMessage()만 출력해 스택트레이스가 손실됩니다. 장애 분석을 위해 예외 객체 자체를 로깅하는 편이 좋습니다.

-                    } catch (Exception initError) {
-                        log.error("MCP 클라이언트 초기화 실패: {}", initError.getMessage());
-                    }
+                    } catch (Exception initError) {
+                        log.error("MCP 클라이언트 초기화 실패", initError);
+                    }

또한 IllegalStateException 메시지에 사용한 MCP 클라이언트 수/식별자 등을 포함하면 원인 추적에 도움이 됩니다.

---

168-210: JSON 블록 파싱: 재귀 제한과 로깅이 적절합니다

MAX_JSON_RECURSION_DEPTH=3와 truncation 기반 경고 로그는 방어적으로 잘 설정되어 있습니다. 추후 운영 데이터에 따라 depth를 프로퍼티화하는 것도 고려해볼 수 있습니다.

cs25-service/src/main/java/com/example/cs25service/domain/ai/client/OpenAiChatClient.java (2)

26-34: 동기 호출을 회복성 래퍼로 감싼 구조는 적절합니다. 다만 클로드와의 출력 정규화 일관성 확인 권장

OpenAI 쪽은 .trim()으로 후처리를 하고 있는데, ClaudeChatClient.call()에는 동일 처리가 없습니다. 두 클라이언트 간 출력 포맷의 일관성을 위해 Claude 측에도 동일 정규화를 적용하는 것이 좋습니다.

---

43-49: onErrorMap 예외 원인 유지 및 회로 차단 예외 매핑 검토

설정 검증 결과:
• cs25-service/src/main/resources/application.properties에 이미
– resilience4j.circuitbreaker.instances.openai.baseConfig=default
– resilience4j.retry.instances.openai.baseConfig=default
설정이 존재합니다.

개선 제안 (선택적 리팩터):
• 파일: cs25-service/src/main/java/com/example/cs25service/domain/ai/client/OpenAiChatClient.java (43–49행)
현재
java …).onErrorMap(e -> new AiException(AiExceptionCode.INTERNAL_SERVER_ERROR));
를 아래와 같이 변경하면, 이미 AiException인 경우는 유지하고 그 외 예외만 원인(cause)을 포함해 래핑합니다.
diff - ).onErrorMap(e -> new AiException(AiExceptionCode.INTERNAL_SERVER_ERROR)); + ).onErrorMap(e -> (e instanceof AiException) + ? e + : new AiException(AiExceptionCode.INTERNAL_SERVER_ERROR, e));

• Resilience4j 회로 차단 예외(예: CallNotPermittedException)를 별도 코드(AiExceptionCode.SERVICE_UNAVAILABLE 등)로 매핑할지 정책 검토 바랍니다.
• 해당 생성자가 없을 경우 기존 구현을 유지하거나, 적절한 로깅을 추가하는 방안도 고려해주세요.

cs25-service/src/main/java/com/example/cs25service/domain/ai/client/ClaudeChatClient.java (2)

25-31: 동기 경로 출력 정규화 일관성 부족 — OpenAI와 동일하게 trim 적용 권장

OpenAI 클라이언트는 .trim()으로 공백을 제거하지만, 여기에는 없습니다. 동일한 사용자 경험을 위해 아래처럼 정규화를 맞추는 것을 제안합니다.

     public String call(String systemPrompt, String userPrompt) {
         return resilience.executeSync("claude", () ->
             anthropicChatClient.prompt()
                 .system(systemPrompt)
                 .user(userPrompt)
                 .call()
-                .content()
+                .content()
+                .trim()
         );
     }

---

41-47: 스트리밍 에러 매핑 개선 제안

아래처럼 onErrorMap에서 이미 던져진 AiException은 그대로 전달하고, 그 외 에러에 한해 원인(cause)을 포함해 감싸도록 변경을 권장합니다.

• 대상 파일:
  – cs25-service/src/main/java/com/example/cs25service/domain/ai/client/ClaudeChatClient.java (41–47행)

-        ).onErrorMap(e -> new AiException(AiExceptionCode.INTERNAL_SERVER_ERROR));
+        ).onErrorMap(e -> (e instanceof AiException)
+            ? e
+            : new AiException(AiExceptionCode.INTERNAL_SERVER_ERROR, e))

• 설정 이름 검증:
  – resilience4j.circuitbreaker.instances.claude.baseConfig=default 및
  resilience4j.retry.instances.claude.baseConfig=default가
  cs25-service/src/main/resources/application.properties 87, 98행에 정의되어 있어 정상 확인되었습니다.

• 추가 검토 사항:
  – OpenAI 클라이언트와 동일한 예외 무시/매핑 로직을 적용할지
  – 회로 차단(circuit breaker) 단계에서의 예외 처리 정책(무시 예외, 별도 매핑 등)

📜 Review details

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

💡 Knowledge Base configuration:

• MCP integration is disabled by default for public repositories
• Jira integration is disabled by default for public repositories
• Linear integration is disabled by default for public repositories

You can enable these sources in your CodeRabbit configuration.

📥 Commits

Reviewing files that changed from the base of the PR and between 2cc6c83 and 62dde4e.

📒 Files selected for processing (8)

• cs25-service/Dockerfile (1 hunks)
• cs25-service/build.gradle (1 hunks)
• cs25-service/src/main/java/com/example/cs25service/domain/ai/client/ClaudeChatClient.java (3 hunks)
• cs25-service/src/main/java/com/example/cs25service/domain/ai/client/OpenAiChatClient.java (3 hunks)
• cs25-service/src/main/java/com/example/cs25service/domain/ai/resilience/AiResilience.java (1 hunks)
• cs25-service/src/main/java/com/example/cs25service/domain/ai/service/BraveSearchMcpService.java (3 hunks)
• cs25-service/src/main/java/com/example/cs25service/domain/ai/service/BraveSearchRagService.java (2 hunks)
• cs25-service/src/main/resources/application.properties (1 hunks)

🧰 Additional context used

🧬 Code Graph Analysis (1)

cs25-service/src/main/java/com/example/cs25service/domain/ai/resilience/AiResilience.java (2)

cs25-service/src/main/java/com/example/cs25service/domain/ai/client/OpenAiChatClient.java (1)

• Component (11-51)

cs25-service/src/main/java/com/example/cs25service/domain/ai/client/ClaudeChatClient.java (1)

• Component (11-49)

🔇 Additional comments (7)

cs25-service/src/main/resources/application.properties (2)

63-64: 인스턴스 이름 일치 확인 완료
호출부에서 사용된 "openai"/"claude"와 application.properties의 resilience4j.circuitbreaker.instances 및 resilience4j.retry.instances 정의(openai, claude)가 정확히 일치함을 확인했습니다. 추가 조치는 필요 없습니다.

---

70-75: Brave MCP 설정 및 래퍼 스크립트 정상 확인됨

• application.properties(71–74): Brave Search 관련 프로퍼티 확인됨
• cs25-service/Dockerfile(37–40): server-brave-search 래퍼 설치 및 --help 검증 완료

배포 환경에서 BRAVE_API_KEY 환경변수가 올바르게 설정되어 있는지만 최종 확인 부탁드립니다.

cs25-service/Dockerfile (1)

39-41: 런타임 사전 검증(sanity check) 추가, 좋습니다

래퍼를 즉시 호출해 빌드를 실패시키는 검증은 런타임 이슈를 조기에 차단하는 데 효과적입니다.

cs25-service/src/main/java/com/example/cs25service/domain/ai/service/BraveSearchMcpService.java (2)

236-272: 레거시 블록 파서: 다중 블록 처리 로직 깔끔합니다

중간 flush 조건과 마지막 레코드 커밋 처리 모두 적절합니다. 특수 케이스(Title만 있거나 URL만 있는 경우)는 상위 addObjectToResults 필터링과 상호 보완되어 일관성이 있습니다.

---

76-78: BraveSearchMcpService.search 호출부 영향도 검증 완료

AiFeedbackStreamProcessor 내에서 search() 결과는 오직 BraveSearchRagService.toDocuments()로 바로 넘겨지며, 해당 메서드가 root.path("results")를 통해 새로 추가된 results 배열을 정상 처리합니다.
따라서 호출부 파싱 로직에 별도 수정이 필요하지 않습니다.

cs25-service/src/main/java/com/example/cs25service/domain/ai/client/OpenAiChatClient.java (1)

17-22: 생성자에 AiResilience 주입 추가: 잘 반영됨

의존성 주입 확장과 필드 추가가 일관성 있게 적용되었습니다.

cs25-service/src/main/java/com/example/cs25service/domain/ai/client/ClaudeChatClient.java (1)

17-21: 생성자에 AiResilience 주입 추가: 잘 반영됨

변경이 OpenAI 쪽과 대칭적으로 적용되어 이해와 유지보수에 용이합니다.

[coderabbitai]

🛠️ Refactor suggestion

Sync 조합 순서가 반대입니다 — CircuitBreaker를 안쪽, Retry를 바깥으로 감싸야 각 재시도 시도마다 CB가 평가됩니다

현재 구현은 Retry → CircuitBreaker로 데코레이션되어 CB가 재시도 단건만 기록합니다. 일반적으로는 CB가 각 시도별로 실패/성공을 관찰하도록 CB를 안쪽에 두고 Retry가 바깥에서 재호출하도록 조합합니다. 이렇게 해야 실패율/슬라이딩 윈도우 메트릭이 의도대로 집계되고, 열림/닫힘 판단이 정확해집니다.

-    /**
-     * 동기 호출: Retry → CircuitBreaker 순서
-     */
+    /**
+     * 동기 호출: CircuitBreaker → Retry 순서
+     * (각 재시도 시도마다 CB가 권한 확인 및 성공/실패를 기록하도록 CB를 내부에 둡니다)
+     */
     public <T> T executeSync(String name, Supplier<T> supplier) {
         CircuitBreaker cb = cbRegistry.circuitBreaker(name);
         Retry retry = retryRegistry.retry(name);
 
-        Supplier<T> withRetry = Retry.decorateSupplier(retry, supplier);
-        Supplier<T> withCb = CircuitBreaker.decorateSupplier(cb, withRetry);
-
-        return withCb.get();
+        Supplier<T> withCb = CircuitBreaker.decorateSupplier(cb, supplier);
+        Supplier<T> withRetry = Retry.decorateSupplier(retry, withCb);
+        return withRetry.get();
     }

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

	public <T> T executeSync(String name, Supplier<T> supplier) {
	CircuitBreaker cb = cbRegistry.circuitBreaker(name);
	Retry retry = retryRegistry.retry(name);
	Supplier<T> withRetry = Retry.decorateSupplier(retry, supplier);
	Supplier<T> withCb = CircuitBreaker.decorateSupplier(cb, withRetry);
	return withCb.get();
	}
	/**
	* 동기 호출: CircuitBreaker → Retry 순서
	* (각 재시도 시도마다 CB가 권한 확인 및 성공/실패를 기록하도록 CB를 내부에 둡니다)
	*/
	public <T> T executeSync(String name, Supplier<T> supplier) {
	CircuitBreaker cb = cbRegistry.circuitBreaker(name);
	Retry retry = retryRegistry.retry(name);
	Supplier<T> withCb = CircuitBreaker.decorateSupplier(cb, supplier);
	Supplier<T> withRetry = Retry.decorateSupplier(retry, withCb);
	return withRetry.get();
	}

🤖 Prompt for AI Agents

In
cs25-service/src/main/java/com/example/cs25service/domain/ai/resilience/AiResilience.java
around lines 24 to 32, the Supplier decoration order is reversed — currently
Retry wraps CircuitBreaker, so the CB only sees the overall retry result; swap
the order so CircuitBreaker wraps the raw supplier and Retry wraps that
CB-decorated supplier (i.e., apply CircuitBreaker.decorateSupplier(cb, supplier)
first, then Retry.decorateSupplier(retry, <cb-wrapped-supplier>)) so the
CircuitBreaker observes each individual attempt; update variable names
accordingly and keep return as withRetry.get().

[coderabbitai]

🛠️ Refactor suggestion

Reactor 스트림 조합 순서도 반대입니다 — CircuitBreakerOperator 먼저, RetryOperator를 마지막에 적용하세요

지금은 RetryOperator → CircuitBreakerOperator 순서라 CB가 재시도 묶음 전체만 관찰합니다. CB가 각 시도를 관찰하도록 아래처럼 순서를 바꿔 주세요.

     public <T> Flux<T> executeStream(String name, Supplier<Flux<T>> supplier) {
         CircuitBreaker cb = cbRegistry.circuitBreaker(name);
         Retry retry = retryRegistry.retry(name);
 
         return supplier.get()
-            .transformDeferred(RetryOperator.of(retry))
-            .transformDeferred(CircuitBreakerOperator.of(cb));
+            .transformDeferred(CircuitBreakerOperator.of(cb))  // CB를 내부에
+            .transformDeferred(RetryOperator.of(retry));       // Retry를 외부에
     }

🤖 Prompt for AI Agents

In
cs25-service/src/main/java/com/example/cs25service/domain/ai/resilience/AiResilience.java
around lines 37 to 44, the Reactor operator order is reversed: currently
RetryOperator is applied before CircuitBreakerOperator so the CircuitBreaker
observes the whole retry sequence; change the operator application order so the
CircuitBreakerOperator is applied first and the RetryOperator after it (i.e.,
transformDeferred(CircuitBreakerOperator.of(cb)) then
transformDeferred(RetryOperator.of(retry))) so the circuit breaker observes each
individual retry attempt.

[coderabbitai]

⚠️ Potential issue

Document ID가 null/빈 문자열이 될 수 있는 잠재 버그

현재 로직에서는 url/title이 모두 비어 있고 description만 있을 때 id가 null이 될 수 있습니다. Spring AI Document의 id는 null이 아닌 값을 기대합니다.

다음과 같이 body를 먼저 계산한 뒤, id를 body까지 fallback 하여 null/blank를 방지하세요.

-                // 5) Document id는 URL > title 우선
-                String id = !isBlank(url) ? url : title;
-                String body = !isBlank(description) ? description
-                    : (!isBlank(title) ? title : (url != null ? url : ""));
+                // 5) 본문과 ID 계산: body는 description > title > url, ID는 url > title > body
+                String body = !isBlank(description) ? description
+                    : (!isBlank(title) ? title : (!isBlank(url) ? url : ""));
+                String id = !isBlank(url) ? url
+                    : (!isBlank(title) ? title : body);

이전 단계(Line 56-58)에서 최소 하나는 비어있지 않으므로 body는 항상 비어있지 않게 됩니다.

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

	// 5) Document id는 URL > title 우선
	String id = !isBlank(url) ? url : title;
	String body = !isBlank(description) ? description
	: (!isBlank(title) ? title : (url != null ? url : ""));
	documents.add(new Document(
	id,
	body,
	// 5) 본문과 ID 계산: body는 description > title > url, ID는 url > title > body
	String body = !isBlank(description) ? description
	: (!isBlank(title) ? title : (!isBlank(url) ? url : ""));
	String id = !isBlank(url) ? url
	: (!isBlank(title) ? title : body);
	documents.add(new Document(
	id,
	body,

🤖 Prompt for AI Agents

In
cs25-service/src/main/java/com/example/cs25service/domain/ai/service/BraveSearchRagService.java
around lines 60 to 67, the current id calculation can be null/blank when both
url and title are empty while description exists; compute body first (using
description > title > url as already intended), then set id to url if present,
else title, and finally fall back to body to guarantee a non-null/non-blank id;
ensure you trim/check isBlank and pass that id into the Document constructor.