Feat: 카드뉴스 템플릿 자동 생성 기능 구현

.github/workflows/ci.yml

@@ -104,4 +104,4 @@ jobs:
             ${{ runner.os }}-gradle-
 
       - name: Run platform tests
-        run: ./gradlew :platform-api:test :auth-domain:test :auth-application:test :auth-adapter:test :member-domain:test :member-application:test :member-adapter:test
+        run: ./gradlew :platform-api:test :auth-domain:test :auth-application:test :auth-adapter:test :member-domain:test :member-application:test :member-adapter:test :template-adapter:test :template-application:test :template-domain:test :ai-adapter:test :ai-application:test :ai-domain:test

libs/security/src/main/kotlin/app/cardcapture/lib/security/SecurityConfig.kt

@@ -22,7 +22,7 @@ class SecurityConfig(
         private val WHITE_LIST = arrayOf(
             "/actuator/**",
             "/api/v1/dev/auth/**",
-            "/api/v1/auth/**"
+            "/api/v1/auth/**",
         )
     }
     @Bean

platform/ai/adapter/build.gradle.kts

@@ -0,0 +1,27 @@
+plugins {
+    kotlin("jvm")
+    kotlin("plugin.spring")
+    kotlin("plugin.jpa")
+    id("io.spring.dependency-management")
+}
+
+dependencies {
+
+    implementation(project(":ai-domain"))
+    implementation(project(":ai-application"))
+    implementation(project(":security"))
+
+    implementation("org.springframework.boot:spring-boot-starter-web")
+    implementation("org.springframework.boot:spring-boot-starter-webflux")
+    implementation("org.springframework.boot:spring-boot-starter-data-jpa")
+    implementation("io.awspring.cloud:spring-cloud-aws-s3:3.4.0")
+    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+    implementation("org.jetbrains.kotlin:kotlin-reflect")
+
+    // --- test ---
+    testImplementation("org.springframework.boot:spring-boot-starter-test") {
+        exclude(group = "org.mockito")
+    }
+    testImplementation("com.ninja-squad:springmockk:latest.release")
+
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/imageai/google/GoogleAiConfig.kt

@@ -0,0 +1,31 @@
+package app.cardcapture.ai.outbound.imageai.google
+
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.web.reactive.function.client.ExchangeStrategies
+import org.springframework.web.reactive.function.client.WebClient
+
+@Configuration
+class GoogleAiConfig (
+    @Value("\${google.key}") private val apiKey: String
+){
+
+    private val baseUrl = "https://generativelanguage.googleapis.com"
+    private val keyHeader = "x-goog-api-key"
+
+    @Bean
+    fun googleImageWebClient(): WebClient{
+        val strategies = ExchangeStrategies.builder()
+            .codecs { config ->
+                config.defaultCodecs().maxInMemorySize(10 * 1024 * 1024)
+            }
+            .build()
+
+        return WebClient.builder()
+            .defaultHeader(keyHeader, apiKey)
+            .baseUrl(baseUrl)
+            .exchangeStrategies(strategies)
+            .build()
+    }
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/imageai/google/ImageModelAdapter.kt

@@ -0,0 +1,51 @@
+package app.cardcapture.ai.outbound.imageai.google
+
+import app.cardcapture.ai.outbound.imageai.google.dto.GeminiPreviewImageRequest
+import app.cardcapture.ai.outbound.imageai.google.dto.GeminiPreviewImageResponse
+import app.cardcapture.ai.port.outbound.ImageModelPort
+import org.springframework.http.HttpStatusCode
+import org.springframework.stereotype.Component
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.core.publisher.Mono
+import java.util.*
+
+@Component
+class ImageModelAdapter(
+    private val googleImageWebClient: WebClient,
+) : ImageModelPort {
+
+    override fun generate(prompt: String, model: String): ByteArray {
+
+        val request = GeminiPreviewImageRequest(
+            contents = listOf(
+                GeminiPreviewImageRequest.ImagerPartsBlock(
+                    parts = listOf(GeminiPreviewImageRequest.TextBlock(prompt)),
+                ),
+            ),
+        )
+
+        val response = googleImageWebClient.post()
+            .uri("v1beta/models/gemini-2.5-flash-image-preview:generateContent")
+            .bodyValue(request)
+            .retrieve()
+            .onStatus(HttpStatusCode::isError) { res ->
+                res.bodyToMono(String::class.java).flatMap { body ->
+                    val msg = "Gemini image API error: ${res.statusCode()} body=$body"
+                    Mono.error(IllegalStateException(msg))
+                }
+            }
+            .bodyToMono(GeminiPreviewImageResponse::class.java)
+            .block() ?: error("Empty response from Gemini image API")
+
+
+        val base64Data = response.candidates
+            .firstOrNull()
+            ?.content
+            ?.parts
+            ?.firstOrNull { it.inlineData != null }
+            ?.inlineData
+            ?.data
+            ?: error("Image data missing")
+        return Base64.getDecoder().decode(base64Data)
+    }
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/imageai/google/dto/GeminiPreviewImageRequest.kt

@@ -0,0 +1,14 @@
+package app.cardcapture.ai.outbound.imageai.google.dto
+
+data class GeminiPreviewImageRequest(
+    val contents: List<ImagerPartsBlock>
+) {
+
+    data class ImagerPartsBlock(
+        val parts: List<TextBlock>
+    )
+
+    data class TextBlock(
+        val text: String
+    )
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/imageai/google/dto/GeminiPreviewImageResponse.kt

@@ -0,0 +1,25 @@
+package app.cardcapture.ai.outbound.imageai.google.dto
+
+
+data class GeminiPreviewImageResponse(
+    val candidates: List<Candidate>,
+    val modelVersion: String? = null
+) {
+    data class Candidate(
+        val content: Content?
+    )
+
+    data class Content(
+        val parts: List<Part>?
+    )
+
+    data class Part(
+        val text: String? = null,
+        val inlineData: InlineData? = null
+    )
+
+    data class InlineData(
+        val mimeType: String? = null,
+        val data: String? = null
+    )
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/llm/openai/LlmSenderAdapter.kt

@@ -0,0 +1,67 @@
+package app.cardcapture.ai.outbound.llm.openai
+
+import app.cardcapture.ai.domain.LlmRequest
+import app.cardcapture.ai.domain.LlmResponse
+import app.cardcapture.ai.outbound.llm.openai.dto.GptCompletionMessageRequest
+import app.cardcapture.ai.outbound.llm.openai.dto.GptCompletionRequest
+import app.cardcapture.ai.outbound.llm.openai.dto.GptMessageRole
+import app.cardcapture.ai.outbound.llm.openai.dto.GptResponseFormat
+import app.cardcapture.ai.port.outbound.LlmSenderPort
+import com.fasterxml.jackson.databind.ObjectMapper
+import org.springframework.http.HttpStatusCode
+import org.springframework.stereotype.Component
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.core.publisher.Mono
+
+
+@Component
+class LlmSenderAdapter(
+    private val openAiWebClient: WebClient,
+    private val objectMapper: ObjectMapper
+) : LlmSenderPort {
+
+    override fun send(request: LlmRequest): LlmResponse {
+
+
+        val request = GptCompletionRequest(
+            model = request.model.model,
+            stream = false,
+            messages = listOf(
+                GptCompletionMessageRequest(
+                    role = GptMessageRole.SYSTEM,
+                    content = request.system,
+                ),
+                GptCompletionMessageRequest(
+                    role = GptMessageRole.USER,
+                    content = request.user,
+                ),
+            ),
+            response_format = GptResponseFormat(
+                type = "json_object",
+            ),
+        )
+
+        val result = openAiWebClient.post()
+            .uri("/chat/completions")
+            .bodyValue(request)
+            .retrieve()
+            .onStatus(HttpStatusCode::isError) { res ->
+                res.bodyToMono(String::class.java).flatMap { body ->
+                    val msg = "Open AI error : ${res.statusCode()}  body = $body"
+                    Mono.error(IllegalStateException(msg))
+                }
+            }
+            .bodyToMono(String::class.java)
+            .block()
+        val content = objectMapper.readTree(result)["choices"][0]["message"]["content"].asText()
+
+        /*
+        *  TODO: content error handling ( empty value )
+        */
+
+        return LlmResponse(
+            jsonValueRaw = content,
+            resourceUsage = null,
+        )
+    }
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/llm/openai/OpenAiConfig.kt

@@ -0,0 +1,27 @@
+package app.cardcapture.ai.outbound.llm.openai
+
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.http.HttpHeaders
+import org.springframework.web.reactive.function.client.WebClient
+
+@Configuration
+class OpenAiConfig (
+    @Value("\${openai.key}") private val apiKey: String
+){
+
+    private val baseUrl = "https://api.openai.com/v1"
+
+    @Bean
+    fun openAiWebClient(): WebClient {
+        /*
+        *  @TODO: exception Handling
+        */
+        return WebClient.builder()
+            .defaultHeader(HttpHeaders.AUTHORIZATION, "Bearer $apiKey")
+            .baseUrl(baseUrl)
+            .build()
+    }
+
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/llm/openai/dto/GptCompletionMessageRequest.kt

@@ -0,0 +1,7 @@
+package app.cardcapture.ai.outbound.llm.openai.dto
+
+data class GptCompletionMessageRequest(
+    val role : GptMessageRole,
+    val content: String,
+) {
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/llm/openai/dto/GptCompletionRequest.kt

@@ -0,0 +1,9 @@
+package app.cardcapture.ai.outbound.llm.openai.dto
+
+data class GptCompletionRequest(
+    val messages: List<GptCompletionMessageRequest>,
+    val model: String,
+    val stream: Boolean,
+    val response_format: GptResponseFormat
+) {
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/llm/openai/dto/GptMessageRole.kt

@@ -0,0 +1,14 @@
+package app.cardcapture.ai.outbound.llm.openai.dto
+
+import com.fasterxml.jackson.annotation.JsonValue
+
+enum class GptMessageRole {
+    SYSTEM,
+    USER,
+    ASSISTANT;
+
+    @JsonValue
+    override fun toString(): String {
+        return name.lowercase()
+    }
+}

platform/ai/adapter/src/main/kotlin/app/cardcapture/ai/outbound/llm/openai/dto/GptResponseFormat.kt

@@ -0,0 +1,6 @@
+package app.cardcapture.ai.outbound.llm.openai.dto
+
+data class GptResponseFormat (
+    val type: String
+){
+}