update

Author: Jang4360

server/src/main/java/dev/interview/server/ai/controller/AiController.java

@@ -18,13 +18,21 @@
 public class AiController {
     private final QuestionGenerationServiceImpl questionGenerationService;
 
-    // 질문 생성 API
+// 질문 생성 API
     @PostMapping("/generate-questions")
-    public Mono<ResponseEntity<?>> generateQuestions(@RequestBody GenerateQuestionRequest request) {
-        return questionGenerationService.generateQuestionsAsync(request) // 비동기 메서드 직접 반환
-                .map(ResponseEntity::ok)
-                .onErrorResume(IllegalStateException.class, e ->
-                        Mono.just(ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS)
-                                .body(new ErrorResponse("중복 요청입니다. 잠시 후 다시 시도해 주세요"))));
+    public ResponseEntity<?> generateQuestions(@RequestBody GenerateQuestionRequest request) {
+        try {
+
+            GeneratedQnaResponse response = questionGenerationService.generateQuestions(request);
+
+            return ResponseEntity.ok(response);
+
+        } catch (IllegalStateException e) {
+
+            return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS)
+
+                    .body(new ErrorResponse("중복 요청입니다. 잠시 후 다시 시도해 주세요"));
+
+        }
     }
 }

server/src/main/java/dev/interview/server/ai/service/EmbeddingService.java

@@ -5,5 +5,6 @@
 import java.util.List;
 
 public interface EmbeddingService {
+    List<Float> createEmbedding(String text);
     Mono<List<Float>> createEmbeddingAsync(String text);
 }

server/src/main/java/dev/interview/server/ai/service/EmbeddingServiceImpl.java

@@ -23,6 +23,14 @@ public class EmbeddingServiceImpl implements EmbeddingService{
     @Value("${openai.api.key}")
     private String openAiApiKey;
 
+    @Override
+    public List<Float> createEmbedding(String text) {
+        return createEmbeddingAsync(text)
+                .doOnError(e -> log.error("Embedding 처리 오류: {}", e.getMessage()))
+                .blockOptional()
+                .orElse(Collections.emptyList());
+    }
+
     // 글 요약 -> 임베딩 벡터 생성 (OpenAI API 사용)
     @Override
     public Mono<List<Float>> createEmbeddingAsync(String text) {

server/src/main/java/dev/interview/server/ai/service/QuestionGenerationService.java

@@ -5,5 +5,6 @@
 import reactor.core.publisher.Mono;
 
 public interface QuestionGenerationService {
+    GeneratedQnaResponse generateQuestions(GenerateQuestionRequest request);
     Mono<GeneratedQnaResponse> generateQuestionsAsync(GenerateQuestionRequest request);
 }

server/src/main/java/dev/interview/server/ai/service/QuestionGenerationServiceImpl.java

@@ -22,6 +22,14 @@ public class QuestionGenerationServiceImpl implements QuestionGenerationService
     private final EmbeddingService embeddingService; // 임베딩 생성
     private final RedisLockService redisLockService;
 
+    @Override
+    public GeneratedQnaResponse generateQuestions(GenerateQuestionRequest request) {
+        return generateQuestionsAsync(request)
+                .doOnError(e -> log.error("질문 생성 실패: {}", e.getMessage()))
+                .blockOptional()
+                .orElseThrow(() -> new RuntimeException("질문 생성 실패"));
+    }
+
     // 전체 질문 생성 프로세스
     @Override
     public Mono<GeneratedQnaResponse> generateQuestionsAsync(GenerateQuestionRequest request) {

server/src/test/java/dev/interview/server/ai/AiControllerTest.java

@@ -50,7 +50,7 @@ void generatedQuestions_success() throws Exception {
         ));
 
         // test용 config에 등록된 gptClient mock이 사용됨
-        when(gptClient.generateQuestions(any(), any())).thenReturn(response);
+//        when(gptClient.generateQuestions(any(), any())).thenReturn(response);
 
         // when & then
         mockMvc.perform(post("/api/ai/generate-questions")