YAPP-Github
diff --git a/‎src/main/kotlin/com/yapp2app/auth/infra/oauth/OidcTokenValidator.kt‎
Lines changed: 0 additions & 2 deletions b/‎src/main/kotlin/com/yapp2app/auth/infra/oauth/OidcTokenValidator.kt‎
Lines changed: 0 additions & 2 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/common/config/RedisCacheConfig.kt‎
Lines changed: 28 additions & 0 deletions b/‎src/main/kotlin/com/yapp2app/common/config/RedisCacheConfig.kt‎
Lines changed: 28 additions & 0 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/common/exception/handler/ExceptionHandler.kt‎
Lines changed: 2 additions & 2 deletions b/‎src/main/kotlin/com/yapp2app/common/exception/handler/ExceptionHandler.kt‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/common/filter/RequestLoggingFilter.kt‎
Lines changed: 53 additions & 0 deletions b/‎src/main/kotlin/com/yapp2app/common/filter/RequestLoggingFilter.kt‎
Lines changed: 53 additions & 0 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/common/filter/ServletFilterConfig.kt‎
Lines changed: 9 additions & 0 deletions b/‎src/main/kotlin/com/yapp2app/common/filter/ServletFilterConfig.kt‎
Lines changed: 9 additions & 0 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/media/api/converter/MediaCommandConverter.kt‎
Lines changed: 3 additions & 0 deletions b/‎src/main/kotlin/com/yapp2app/media/api/converter/MediaCommandConverter.kt‎
Lines changed: 3 additions & 0 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/media/api/dto/UploadTicketRequest.kt‎
Lines changed: 13 additions & 0 deletions b/‎src/main/kotlin/com/yapp2app/media/api/dto/UploadTicketRequest.kt‎
Lines changed: 13 additions & 0 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/media/application/command/MediaCommand.kt‎
Lines changed: 9 additions & 2 deletions b/‎src/main/kotlin/com/yapp2app/media/application/command/MediaCommand.kt‎
Lines changed: 9 additions & 2 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/media/application/port/DistributedLockPort.kt‎
Lines changed: 13 additions & 0 deletions b/‎src/main/kotlin/com/yapp2app/media/application/port/DistributedLockPort.kt‎
Lines changed: 13 additions & 0 deletions
diff --git a/‎src/main/kotlin/com/yapp2app/media/application/port/MediaBinaryCachePort.kt‎
Lines changed: 3 additions & 1 deletion b/‎src/main/kotlin/com/yapp2app/media/application/port/MediaBinaryCachePort.kt‎
Lines changed: 3 additions & 1 deletion
@@ -42,12 +42,10 @@ class OidcTokenValidator(
             // 1차 시도: 캐시된 공개키로 토큰 검증
             validateTokenWithPublicKeys(idToken, oidcAdapter, oauthHelperAdapter, platform)
         } catch (e: BusinessException) {
-            log.info("Kakao OIDC token expired. 갱신 로직")
             // 캐시 무효화 후 재시도
             authRedisCacheAdapter.clearPublicKeys(AuthCacheKeys.KAKAO_OIDC_KEY)
             validateTokenWithPublicKeys(idToken, oidcAdapter, oauthHelperAdapter, platform)
         } catch (e: Exception) {
-            e.printStackTrace() // TODO 인증 실패 예외 로그 모니터링용
             throw e
         }
     }
 
@@ -6,6 +6,7 @@ import org.springframework.context.annotation.Configuration
 import org.springframework.data.redis.connection.RedisConnectionFactory
 import org.springframework.data.redis.core.RedisTemplate
 import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer
+import org.springframework.data.redis.serializer.RedisSerializer
 import org.springframework.data.redis.serializer.StringRedisSerializer
 
 /**
@@ -48,4 +49,31 @@ class RedisCacheConfig(private val objectMapper: ObjectMapper) {
 
         return template
     }
+
+    /**
+     * 이미지 바이너리 데이터 전용 RedisTemplate
+     * - Key: String 직렬화
+     * - Value: ByteArray 직렬화 (JSON 직렬화 시 타입 변환 문제 발생)
+     *
+     * ByteArrayRedisSerializer 사용으로:
+     * - 바이너리 데이터를 그대로 저장/조회
+     * - 타입 변환 없이 ByteArray로 직접 반환
+     * - 캐시 정상 동작
+     */
+    @Bean
+    fun binaryRedisTemplate(redisConnectionFactory: RedisConnectionFactory): RedisTemplate<String, ByteArray> {
+        val template = RedisTemplate<String, ByteArray>()
+        template.connectionFactory = redisConnectionFactory
+
+        // Key는 String으로 직렬화
+        template.keySerializer = StringRedisSerializer()
+        template.hashKeySerializer = StringRedisSerializer()
+
+        // Value는 ByteArray로 직렬화 (이미지 바이너리 데이터)
+        val byteArraySerializer = RedisSerializer.byteArray()
+        template.valueSerializer = byteArraySerializer
+        template.hashValueSerializer = byteArraySerializer
+
+        return template
+    }
 }
@@ -30,7 +30,7 @@ class ExceptionHandler {
 
     @ExceptionHandler(BusinessException::class)
     fun businessExceptionHandler(ex: BusinessException): ResponseEntity<ExceptionMsg> {
-        log.error("{} message = {}", ex.resultCode.code, ex.resultCode.message)
+        log.error("[BUSINESS_ERROR] code={} | message={}", ex.resultCode.code, ex.resultCode.message)
 
         if (ex.resultCode == ResultCode.INVALID_TOKEN_ERROR) {
             return ResponseEntity(
@@ -55,7 +55,7 @@ class ExceptionHandler {
 
     @ExceptionHandler(Exception::class)
     fun exceptionHandler(ex: Exception): ResponseEntity<ExceptionMsg> {
-        log.error("No Handler ex message = {}", ex)
+        log.error("[SYSTEM_ERROR] unhandled exception", ex)
 
         val temp = ResponseEntity(
             ExceptionMsg(
 
@@ -0,0 +1,53 @@
+package com.yapp2app.common.filter
+
+import jakarta.servlet.FilterChain
+import jakarta.servlet.http.HttpServletRequest
+import jakarta.servlet.http.HttpServletResponse
+import org.slf4j.LoggerFactory
+import org.slf4j.MDC
+import org.springframework.web.filter.OncePerRequestFilter
+
+/**
+ * API 요청의 수명주기(응답 시간, 상태 코드)를 로깅하는 필터.
+ * RequestMdcFilter 이후에 실행되어 MDC 컨텍스트(requestId, userId)를 활용한다.
+ *
+ * JSON 로그: message는 간결하게, 상세 정보는 MDC 필드(durationMs, responseStatus, logCategory)로 분리.
+ * 콘솔 로그: [API_REQUEST] POST /api/auth/kakao/login | status=200 | duration=342ms
+ */
+class RequestLoggingFilter : OncePerRequestFilter() {
+
+    private val log = LoggerFactory.getLogger(javaClass)
+
+    override fun doFilterInternal(
+        request: HttpServletRequest,
+        response: HttpServletResponse,
+        filterChain: FilterChain,
+    ) {
+        val startTime = System.currentTimeMillis()
+
+        try {
+            filterChain.doFilter(request, response)
+        } finally {
+            val duration = System.currentTimeMillis() - startTime
+            val status = response.status
+
+            MDC.put("logCategory", "API_REQUEST")
+            MDC.put("durationMs", duration.toString())
+            MDC.put("responseStatus", status.toString())
+
+            log.info("[API_REQUEST]")
+
+            MDC.remove("logCategory")
+            MDC.remove("durationMs")
+            MDC.remove("responseStatus")
+        }
+    }
+
+    override fun shouldNotFilter(request: HttpServletRequest): Boolean {
+        val uri = request.requestURI
+        return uri.startsWith("/actuator") ||
+            uri.startsWith("/swagger-ui") ||
+            uri.startsWith("/v3/api-docs") ||
+            uri.startsWith("/file")
+    }
+}
@@ -19,6 +19,15 @@ class ServletFilterConfig {
 
     @Bean
     fun requestMdcFilterRegistration(filter: RequestMdcFilter): FilterRegistrationBean<RequestMdcFilter> =
+        FilterRegistrationBean(filter).apply {
+            order = SecurityProperties.DEFAULT_FILTER_ORDER - 2
+        }
+
+    @Bean
+    fun requestLoggingFilter(): RequestLoggingFilter = RequestLoggingFilter()
+
+    @Bean
+    fun requestLoggingFilterRegistration(filter: RequestLoggingFilter): FilterRegistrationBean<RequestLoggingFilter> =
         FilterRegistrationBean(filter).apply {
             order = SecurityProperties.DEFAULT_FILTER_ORDER - 1
         }
 
@@ -21,6 +21,9 @@ class MediaCommandConverter {
                     filename = item.filename!!,
                     contentType = item.contentType!!,
                     mediaType = item.mediaType!!,
+                    width = item.width,
+                    height = item.height,
+                    size = item.size,
                 )
             },
         )
 
@@ -1,6 +1,7 @@
 package com.yapp2app.media.api.dto
 
 import com.yapp2app.media.domain.MediaType
+import io.swagger.v3.oas.annotations.media.Schema
 import jakarta.validation.Valid
 import jakarta.validation.constraints.NotBlank
 import jakarta.validation.constraints.NotEmpty
@@ -20,13 +21,25 @@ data class UploadTicketRequest(
     val items: List<UploadTicketItem>,
 ) {
     data class UploadTicketItem(
+        @field:Schema(description = "파일명", example = "abc.png")
         @field:NotBlank(message = "파일명은 필수 입력값입니다.")
         val filename: String?,
 
+        @field:Schema(description = "ContentType", example = "image/png")
         @field:NotBlank(message = "Content type은 필수 입력값입니다.")
         val contentType: String?,
 
+        @field:Schema(description = "미디어타입", example = "PHOTO_BOOTH")
         @field:NotNull(message = "미디어 타입은 필수 입력값입니다.")
         val mediaType: MediaType?,
+
+        @field:Schema(description = "너비", example = "1920")
+        val width: Int? = null,
+
+        @field:Schema(description = "높이", example = "1080")
+        val height: Int? = null,
+
+        @field:Schema(description = "byte 단위", example = "2048576")
+        val size: Long? = null,
     )
 }
@@ -11,7 +11,14 @@ import com.yapp2app.media.domain.MediaType
 data class ConfirmMediasUploadedCommand(val ownerId: Long, val mediaIds: List<Long>)
 
 data class GenerateUploadTicketCommand(val ownerId: Long, val items: List<UploadTicketItem>) {
-    data class UploadTicketItem(val filename: String, val contentType: String, val mediaType: MediaType)
+    data class UploadTicketItem(
+        val filename: String,
+        val contentType: String,
+        val mediaType: MediaType,
+        val width: Int? = null,
+        val height: Int? = null,
+        val size: Long? = null,
+    )
 }
 
 data class DeleteMediaCommand(val ownerId: Long, val mediaId: Long)
@@ -22,6 +29,6 @@ data class GetMediasCommand(val ownerId: Long, val mediaIds: List<Long>)
 
 data class GetImageByKeyCommand(val objectKey: String)
 
-data class GetMediaStorageInfoCommand(val ownerId: Long, val mediaId: Long)
+data class GetMediaStorageInfoCommand(val ownerId: Long?, val mediaId: Long)
 
 data class GetMediaStorageInfosCommand(val ownerId: Long?, val mediaIds: List<Long>)
@@ -0,0 +1,13 @@
+package com.yapp2app.media.application.port
+
+import java.time.Duration
+
+/**
+ * 분산 락 포트
+ *
+ * 여러 인스턴스 간 동시성 제어를 위한 분산 락 인터페이스입니다.
+ */
+interface DistributedLockPort {
+
+    fun <T> executeWithLock(key: String, ttl: Duration, action: () -> T): T?
+}
@@ -1,5 +1,7 @@
 package com.yapp2app.media.application.port
 
+import java.time.Duration
+
 /**
  * fileName       : MediaBinaryCachePort
  * author         : koo
@@ -10,7 +12,7 @@ interface MediaBinaryCachePort {
 
     fun get(key: String): ByteArray?
 
-    fun put(key: String, value: ByteArray)
+    fun put(key: String, value: ByteArray, ttl: Duration)
 
     fun evict(key: String)
 }
Original file line number	Diff line number	Diff line change
`@@ -42,12 +42,10 @@ class OidcTokenValidator(`
`42`	`42`	`// 1차 시도: 캐시된 공개키로 토큰 검증`
`43`	`43`	`validateTokenWithPublicKeys(idToken, oidcAdapter, oauthHelperAdapter, platform)`
`44`	`44`	`} catch (e: BusinessException) {`
`45`		`- log.info("Kakao OIDC token expired. 갱신 로직")`
`46`	`45`	`// 캐시 무효화 후 재시도`
`47`	`46`	`authRedisCacheAdapter.clearPublicKeys(AuthCacheKeys.KAKAO_OIDC_KEY)`
`48`	`47`	`validateTokenWithPublicKeys(idToken, oidcAdapter, oauthHelperAdapter, platform)`
`49`	`48`	`} catch (e: Exception) {`
`50`		`- e.printStackTrace() // TODO 인증 실패 예외 로그 모니터링용`
`51`	`49`	`throw e`
`52`	`50`	`}`
`53`	`51`	`}`
Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,9 @@ class MediaCommandConverter {`
`21`	`21`	`filename = item.filename!!,`
`22`	`22`	`contentType = item.contentType!!,`
`23`	`23`	`mediaType = item.mediaType!!,`
	`24`	`+ width = item.width,`
	`25`	`+ height = item.height,`
	`26`	`+ size = item.size,`
`24`	`27`	`)`
`25`	`28`	`},`
`26`	`29`	`)`