[Feat] veo로 비디오 생성

Author: sunwon12

.github/workflows/main-server.yml

@@ -25,6 +25,12 @@ jobs:
           echo "${{ secrets.APPLICATION_YML }}" | base64 --decode > src/main/resources/application.yml
           cat src/main/resources/application.yml
 
+      - name: 구글 키 정보 넣기
+        run: |
+          echo "${{ secrets.GOOGLE_KEY_JSON }}" | base64 --decode > src/main/resources/service-account-key.json
+          cat src/main/resources/service-account-key.json
+
+
       - name: Gradle Caching
         uses: actions/cache@v3
         with:

.gitignore

@@ -10,6 +10,7 @@ build/
 
 **/firebase-account.json
 **/application.yml
+**/service-account-key.json
 
 ### STS ###
 .apt_generated

build.gradle

@@ -22,58 +22,69 @@ repositories {
 }
 
 dependencies {
-    implementation 'org.springframework.boot:spring-boot-starter-web'
-    annotationProcessor 'org.projectlombok:lombok'
-    testCompileOnly 'org.projectlombok:lombok'
-    testAnnotationProcessor 'org.projectlombok:lombok'
+    // Spring Boot Starters
+    implementation 'org.springframework.boot:spring-boot-starter-web'  
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
-    implementation 'org.springframework.boot:spring-boot-starter-security'
     implementation 'org.springframework.boot:spring-boot-starter-validation'
+    implementation 'org.springframework.boot:spring-boot-starter-security'
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis' 
     implementation 'org.springframework.boot:spring-boot-starter-mail'
+    
+    // 데이터베이스
     runtimeOnly 'com.mysql:mysql-connector-j'
-    testImplementation 'org.springframework.security:spring-security-test'
-
+    
     // JWT
     implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
     runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
     runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
-
-
-    //Oauth2
+    
+    // OAuth2
     implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
-
-    //swagger
-    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.2.0'
-
-    //QueryDSL 추가
+    
+    // WebClient (HTTP 클라이언트)
+    implementation 'org.springframework.boot:spring-boot-starter-webflux'  // ✅ WebClient용으로만 유지
+    
+    // Apple 로그인
+    implementation 'org.bouncycastle:bcpkix-jdk15on:1.69'
+    
+    // Querydsl
     implementation 'com.querydsl:querydsl-jpa:5.0.0:jakarta'
     annotationProcessor "com.querydsl:querydsl-apt:5.0.0:jakarta"
     annotationProcessor "jakarta.annotation:jakarta.annotation-api"
     annotationProcessor "jakarta.persistence:jakarta.persistence-api"
-
-    //AWS
+    
+    // Lombok
+    compileOnly 'org.projectlombok:lombok'
+    annotationProcessor 'org.projectlombok:lombok'
+    testCompileOnly 'org.projectlombok:lombok'
+    testAnnotationProcessor 'org.projectlombok:lombok'
+    
+    // Swagger (Spring Web용)
+    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.2.0'  // ✅ WebFlux -> WebMVC로 롤백
+    
+    // AWS
     implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
-
-    //webclient
-    implementation 'org.springframework.boot:spring-boot-starter-webflux'
-
-    // apple로그인을 위한
-    implementation 'org.bouncycastle:bcpkix-jdk15on:1.69'
-
-    // 레디스
-    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
-
+    
     // 모니터링
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
     implementation 'io.micrometer:micrometer-registry-prometheus'
-
+    
     // Ably
     implementation 'io.ably:ably-java:1.2.16'
-
-    //fcm
+    
+    // FCM
     implementation 'com.google.firebase:firebase-admin:9.2.0'
     implementation 'com.google.api-client:google-api-client:2.2.0'
-
+    
+    // Google Gen AI SDK (Veo 비디오 생성용)
+    implementation 'com.google.genai:google-genai:1.10.0'
+    
+    // Google Cloud Storage (Veo 이미지 업로드용)
+    implementation 'com.google.cloud:google-cloud-storage:2.36.1'
+    
+    // ✅ Servlet API 추가 (호환성)
+    implementation 'jakarta.servlet:jakarta.servlet-api:6.0.0'
+    
     // 테스트 의존성
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.security:spring-security-test'
@@ -95,6 +106,8 @@ def generated = 'src/main/generated'
 // querydsl QClass 파일 생성 위치를 지정
 tasks.withType(JavaCompile) {
     options.getGeneratedSourceOutputDirectory().set(file(generated))
+    // Gen AI Function Calling을 위한 매개변수 이름 보존
+    options.compilerArgs += ["-parameters"]
 }
 
 // java source set 에 querydsl QClass 위치 추가

src/main/java/server/common/ErrorCode.java

@@ -130,7 +130,19 @@ public enum ErrorCode {
     YOUTUBE_API_FORBIDDEN("B1705", "YouTube API에 대한 접근 권한이 없습니다.", HttpStatus.INTERNAL_SERVER_ERROR),
 
     // 외부 API
-    DISCORD_NOTIFICATION_FAILED("B1800", "디스코드 알림 전송에 실패했습니다.", HttpStatus.INTERNAL_SERVER_ERROR);
+    DISCORD_NOTIFICATION_FAILED("B1800", "디스코드 알림 전송에 실패했습니다.", HttpStatus.INTERNAL_SERVER_ERROR),
+
+    // B19xx: Veo 비디오 생성 예외
+    VEO_CLIENT_INITIALIZATION_FAILED("B1900", "Veo 클라이언트 초기화에 실패했습니다.", HttpStatus.INTERNAL_SERVER_ERROR),
+    VEO_VIDEO_GENERATION_FAILED("B1901", "비디오 생성에 실패했습니다.", HttpStatus.INTERNAL_SERVER_ERROR),
+    VEO_OPERATION_NOT_FOUND("B1902", "비디오 생성 작업을 찾을 수 없습니다.", HttpStatus.NOT_FOUND),
+    VEO_OPERATION_TIMEOUT("B1903", "비디오 생성 작업이 시간 초과되었습니다.", HttpStatus.REQUEST_TIMEOUT),
+    VEO_INVALID_PROMPT("B1904", "프롬프트가 유효하지 않습니다.", HttpStatus.BAD_REQUEST),
+    VEO_INVALID_IMAGE_URL("B1905", "이미지 URL이 유효하지 않습니다.", HttpStatus.BAD_REQUEST),
+    VEO_API_QUOTA_EXCEEDED("B1906", "Veo API 할당량을 초과했습니다.", HttpStatus.TOO_MANY_REQUESTS),
+    VEO_API_UNAUTHORIZED("B1907", "Veo API 인증에 실패했습니다.", HttpStatus.UNAUTHORIZED),
+    VEO_OPERATION_INTERRUPTED("B1908", "비디오 생성 작업이 중단되었습니다.", HttpStatus.INTERNAL_SERVER_ERROR),
+    VEO_INSUFFICIENT_CREDITS("B1909", "비디오 생성을 위한 크레딧이 부족합니다.", HttpStatus.PAYMENT_REQUIRED);
 
     private final String code;
     private final String message;

src/main/java/server/common/error_notification/ErrorNotificationDto.java

@@ -71,6 +71,28 @@ public static ErrorNotificationDto create(ErrorCode errorCode, Exception excepti
                 .build();
     }
 
+    /**
+     * ✅ WebFlux 호환용 - HttpServletRequest 없이 ErrorNotificationDto 생성
+     */
+    public static ErrorNotificationDto createWithoutRequest(ErrorCode errorCode, Exception exception) {
+        return ErrorNotificationDto.builder()
+                .timestamp(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")))
+                .errorCode(errorCode.getCode())
+                .errorMessage(errorCode.getMessage())
+                .exceptionType(exception.getClass().getSimpleName())
+                .exceptionMessage(exception.getMessage())
+                .requestUri("WebFlux Request")
+                .requestMethod("UNKNOWN")
+                .userAgent("N/A")
+                .clientIp("UNKNOWN")
+                .requestParams("N/A")
+                .requestBody("")
+                .requestHeaders("N/A")
+                .stackTrace(getStackTraceAsString(exception))
+                .exceptionChain(buildExceptionChain(exception))
+                .build();
+    }
+
     /**
      * 예외 체인을 분석하여 상위 예외부터 하위 원인 예외까지 순서대로 구성
      */

src/main/java/server/common/error_notification/SenderToDiscord.java

@@ -16,6 +16,7 @@
 
 /**
  * 디스코드 웹훅을 통한 에러 알림 서비스
+ * ✅ WebFlux 호환을 위해 HttpServletRequest를 nullable로 처리합니다.
  */
 @Slf4j
 @Service
@@ -26,15 +27,18 @@ public class SenderToDiscord implements ErrorNotificationService {
     private final ErrorNotificationConfig errorNotificationConfig;
     private final WebClient webClient;
 
+    /**
+     * ✅ WebFlux 호환 - request가 null일 수 있습니다
+     */
     @Override
     public void sendErrorNotification(ErrorCode errorCode, Exception exception, HttpServletRequest request) {
         // 알림이 비활성화되어 있으면 전송하지 않음
         if (!errorNotificationConfig.isEnabled()) {
             return;
         }
 
-        // 경로가 제외 목록에 있으면 전송하지 않음
-        if (errorNotificationConfig.isPathExcluded(request.getRequestURI())) {
+        // ✅ request가 null이 아닌 경우에만 경로 체크
+        if (request != null && errorNotificationConfig.isPathExcluded(request.getRequestURI())) {
             return;
         }
 
@@ -45,7 +49,10 @@ public void sendErrorNotification(ErrorCode errorCode, Exception exception, Http
         }
 
         try {
-            ErrorNotificationDto notificationDto = ErrorNotificationDto.create(errorCode, exception, request);
+            // ✅ request가 null인 경우를 고려하여 ErrorNotificationDto 생성
+            ErrorNotificationDto notificationDto = request != null 
+                ? ErrorNotificationDto.create(errorCode, exception, request)
+                : ErrorNotificationDto.createWithoutRequest(errorCode, exception);
 
             sendDiscordNotification(notificationDto);
         } catch (Exception e) {
@@ -137,35 +144,14 @@ public void sendLog(String title, String message, int color) {
     }
 
     /**
-     * 간단한 embed 객체 생성
+     * 간단한 embed 생성
      */
     private Map<String, Object> createSimpleEmbed(String title, String message, int color) {
         Map<String, Object> embed = new HashMap<>();
         embed.put("title", title);
-        embed.put("description", truncateMessage(message, 1000)); // 디스코드 description 제한
+        embed.put("description", message);
         embed.put("color", color);
-        embed.put("timestamp", getIsoTimestamp());
+        embed.put("timestamp", ZonedDateTime.now().format(DateTimeFormatter.ISO_INSTANT));
         return embed;
     }
-
-    /**
-     * 메시지 길이 제한
-     */
-    private String truncateMessage(String message, int maxLength) {
-        if (message == null) {
-            return "";
-        }
-        if (message.length() <= maxLength) {
-            return message;
-        }
-        return message.substring(0, maxLength - 3) + "...";
-    }
-
-    /**
-     * ISO 타임스탬프 생성
-     */
-    private String getIsoTimestamp() {
-        return ZonedDateTime.now(java.time.ZoneOffset.UTC)
-                .format(DateTimeFormatter.ISO_INSTANT);
-    }
 }

src/main/java/server/config/AblyConfig.java

@@ -5,20 +5,19 @@
 import org.springframework.web.servlet.config.annotation.CorsRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
+/**
+ * Spring Web CORS 설정 (해커톤용 단순화)
+ */
 @Configuration
-public class CorsConfig implements WebMvcConfigurer {
+public class CorsConfig {
 
     @Bean
     public WebMvcConfigurer corsConfigurer() {
         return new WebMvcConfigurer() {
             @Override
             public void addCorsMappings(CorsRegistry registry) {
                 registry.addMapping("/**")
-                        .allowedOriginPatterns(
-                                "http://localhost:5000",
-                                "http://localhost:3000",
-                                "http://172.31.35.182:8080"
-                        )
+                        .allowedOriginPatterns("*")  // ✅ 해커톤용 모든 Origin 허용
                         .allowedHeaders("*")
                         .exposedHeaders("ACCESS_KEY", "Authorization", "RefreshToken")
                         .allowedMethods("GET", "POST", "PUT", "DELETE", "HEAD", "OPTIONS", "PATCH")