fix: AI 서버 요청에 Presigned URL 전달 방식 수정

Author: lilloo04

src/main/java/com/quadcore/voiceandtext/infrastructure/analysis/AiService.java

@@ -8,8 +8,10 @@
 import org.springframework.boot.web.client.RestTemplateBuilder;
 import org.springframework.http.*;
 import org.springframework.stereotype.Service;
+import org.springframework.web.client.HttpStatusCodeException;
 import org.springframework.web.client.RestTemplate;
 
+import java.net.URI;
 import java.time.Duration;
 import java.util.Map;
 
@@ -37,31 +39,86 @@ private void init() {
     }
 
     public void requestAnalysis(AnalysisRequest analysisRequest) {
-        String presignedUrl = s3Service.generatePresignedUrl(analysisRequest.getAudioFile().getStorageLocation(), Duration.ofMinutes(10));
+        String key = null;
+        if (analysisRequest.getAudioFile() != null) {
+            key = analysisRequest.getAudioFile().getStorageLocation();
+            if (key == null || key.isBlank()) {
+                key = extractKeyFromFileUrl(analysisRequest.getAudioFile().getFileUrl());
+            }
+        }
+
+        if (key == null || key.isBlank()) {
+            throw new RuntimeException("AudioFile storage location or S3 key is missing for analysisRequest=" + analysisRequest.getId());
+        }
+
+        String presignedUrl = s3Service.generatePresignedUrl(key, Duration.ofMinutes(10));
+        boolean hasSignature = presignedUrl.contains("X-Amz-Signature");
+
+        log.info("AI 서버 요청 URL 생성: analysisRequestId={}, presignedUrl.length={}, hasSignature={}",
+                analysisRequest.getId(), presignedUrl.length(), hasSignature);
 
         Map<String, Object> requestBody = Map.of(
-                "analysisRequestId", analysisRequest.getId(),
-                "audioUrl", presignedUrl,
-                "durationSeconds", analysisRequest.getAudioFile().getDurationSeconds()
-                // callbackUrl은 나중에 추가
+                "file_url", presignedUrl
         );
 
         HttpHeaders headers = new HttpHeaders();
         headers.setContentType(MediaType.APPLICATION_JSON);
 
         HttpEntity<Map<String, Object>> entity = new HttpEntity<>(requestBody, headers);
 
-        ResponseEntity<String> response = restTemplate.exchange(
-                aiServerUrl + "/api/analyze",
-                HttpMethod.POST,
-                entity,
-                String.class
-        );
+        try {
+            ResponseEntity<String> response = restTemplate.exchange(
+                    URI.create(aiServerUrl),
+                    HttpMethod.POST,
+                    entity,
+                    String.class
+            );
+
+            if (!response.getStatusCode().equals(HttpStatus.OK)) {
+                log.error("AI 서버 요청 실패: analysisRequestId={}, status={}, body={}",
+                        analysisRequest.getId(), response.getStatusCodeValue(), response.getBody());
+                throw new RuntimeException("AI 서버 요청 실패: " + response.getStatusCodeValue());
+            }
 
-        if (response.getStatusCode() != HttpStatus.OK) {
-            throw new RuntimeException("AI 서버 요청 실패: " + response.getStatusCode());
+            log.info("AI 서버 요청 성공: {}", analysisRequest.getId());
+        } catch (HttpStatusCodeException e) {
+            log.error("AI 서버 요청 실패: analysisRequestId={}, status={}, responseBody={}",
+                    analysisRequest.getId(), e.getRawStatusCode(), e.getResponseBodyAsString(), e);
+            throw new RuntimeException("AI 서버 요청 실패: " + e.getRawStatusCode(), e);
+        } catch (Exception e) {
+            log.error("AI 서버 요청 중 예외 발생: analysisRequestId={}, message={}",
+                    analysisRequest.getId(), e.getMessage(), e);
+            throw new RuntimeException("AI 서버 요청 실패", e);
+        }
+    }
+
+    private String extractKeyFromFileUrl(String fileUrl) {
+        if (fileUrl == null || fileUrl.isBlank()) {
+            return null;
         }
 
-        log.info("AI 서버 요청 성공: {}", analysisRequest.getId());
+        try {
+            URI uri = URI.create(fileUrl);
+            String path = uri.getPath();
+            if (path == null || path.isBlank()) {
+                return null;
+            }
+            if (path.startsWith("/")) {
+                path = path.substring(1);
+            }
+
+            String host = uri.getHost();
+            if (host != null && host.contains("s3")) {
+                if (path.contains("/")) {
+                    return path.startsWith("/") ? path.substring(1) : path;
+                }
+                return path;
+            }
+
+            return path;
+        } catch (Exception e) {
+            log.warn("fileUrl에서 S3 키 추출 실패: {}", fileUrl);
+            return null;
+        }
     }
 }