feat/#146 -> staging merge commit

* feat: 포즈 조회시 view count 증가

* ref: GetPoseUseCase 쓰기 트랜잭션 범위 축소

* fix: pose view ttl 자정으로 수정

Author: koosco

src/main/kotlin/com/neki/pose/application/port/PoseRepositoryPort.kt

@@ -32,4 +32,6 @@ interface PoseRepositoryPort {
     fun countPoses(headCount: HeadCount, excludeIds: List<Long>): Long
 
     fun findPoseByOffset(offset: Long, headCount: HeadCount, excludeIds: List<Long>): Pose?
+
+    fun incrementViewCount(poseId: Long)
 }

src/main/kotlin/com/neki/pose/application/port/PoseViewCachePort.kt

@@ -0,0 +1,6 @@
+package com.neki.pose.application.port
+
+interface PoseViewCachePort {
+
+    fun addViewer(poseId: Long, userId: Long): Boolean
+}

src/main/kotlin/com/neki/pose/application/usecase/GetPoseUseCase.kt

@@ -3,19 +3,30 @@ package com.neki.pose.application.usecase
 import com.neki.common.annotation.UseCase
 import com.neki.common.api.dto.ResultCode
 import com.neki.common.exception.BusinessException
+import com.neki.common.transaction.TransactionRunner
 import com.neki.pose.application.command.GetPoseCommand
 import com.neki.pose.application.contract.MediaStorageInfo
 import com.neki.pose.application.port.MediaClientPort
 import com.neki.pose.application.port.PoseRepositoryPort
+import com.neki.pose.application.port.PoseViewCachePort
 import com.neki.pose.application.result.GetPoseResult
 
 @UseCase
-class GetPoseUseCase(private val poseRepository: PoseRepositoryPort, private val mediaClient: MediaClientPort) {
+class GetPoseUseCase(
+    private val poseRepository: PoseRepositoryPort,
+    private val mediaClient: MediaClientPort,
+    private val poseViewCache: PoseViewCachePort,
+    private val transactionRunner: TransactionRunner,
+) {
 
     fun execute(command: GetPoseCommand): GetPoseResult {
         val (pose, isScraped) = poseRepository.getOwnedPoseWithScrap(command.userId, command.poseId)
             ?: throw BusinessException(ResultCode.NOT_FOUND)
 
+        if (poseViewCache.addViewer(command.poseId, command.userId)) {
+            transactionRunner.run { poseRepository.incrementViewCount(command.poseId) }
+        }
+
         val mediaInfo: MediaStorageInfo = mediaClient.getMediaStorageInfo(pose.mediaId)
 
         return GetPoseResult(

src/main/kotlin/com/neki/pose/domain/entity/Pose.kt

@@ -38,4 +38,7 @@ class Pose(
 
     @Column(name = "memo", nullable = true)
     var memo: String? = null,
+
+    @Column(name = "view_count", nullable = false)
+    var viewCount: Long = 0,
 ) : BaseTimeEntity()

src/main/kotlin/com/neki/pose/infra/cache/fake/FakePoseViewCacheAdapter.kt

@@ -0,0 +1,22 @@
+package com.neki.pose.infra.cache.fake
+
+import com.neki.pose.application.port.PoseViewCachePort
+import org.springframework.context.annotation.Profile
+import org.springframework.stereotype.Component
+import java.util.concurrent.ConcurrentHashMap
+
+@Component
+@Profile("test")
+class FakePoseViewCacheAdapter : PoseViewCachePort {
+
+    private val viewers = ConcurrentHashMap<Long, MutableSet<Long>>()
+
+    override fun addViewer(poseId: Long, userId: Long): Boolean {
+        val userSet = viewers.computeIfAbsent(poseId) { ConcurrentHashMap.newKeySet() }
+        return userSet.add(userId)
+    }
+
+    fun clearAll() {
+        viewers.clear()
+    }
+}

src/main/kotlin/com/neki/pose/infra/cache/redis/PoseViewRedisCacheKey.kt

@@ -0,0 +1,7 @@
+package com.neki.pose.infra.cache.redis
+
+internal object PoseViewRedisCacheKey {
+    private const val VIEW_PREFIX = "pose:view:"
+
+    fun viewKey(poseId: Long): String = "$VIEW_PREFIX$poseId"
+}

src/main/kotlin/com/neki/pose/infra/cache/redis/RedisPoseViewCacheAdapter.kt

@@ -0,0 +1,44 @@
+package com.neki.pose.infra.cache.redis
+
+import com.neki.pose.application.port.PoseViewCachePort
+import org.slf4j.LoggerFactory
+import org.springframework.context.annotation.Primary
+import org.springframework.context.annotation.Profile
+import org.springframework.data.redis.core.RedisTemplate
+import org.springframework.stereotype.Component
+import java.time.Instant
+import java.time.LocalDate
+import java.time.ZoneId
+
+@Component
+@Primary
+@Profile("!test")
+class RedisPoseViewCacheAdapter(private val redisTemplate: RedisTemplate<String, Any>) : PoseViewCachePort {
+
+    private val log = LoggerFactory.getLogger(javaClass)
+
+    override fun addViewer(poseId: Long, userId: Long): Boolean {
+        val key = PoseViewRedisCacheKey.viewKey(poseId)
+        return try {
+            val added = redisTemplate.opsForSet().add(key, userId) ?: 0
+            if (added > 0) {
+                redisTemplate.expireAt(key, getMidnight())
+                true
+            } else {
+                false
+            }
+        } catch (e: Exception) {
+            log.warn("[PoseViewCache] Failed to check viewer for pose: $poseId, user: $userId", e)
+            true // fail-open: Redis 장애 시 신규 조회로 처리
+        }
+    }
+
+    private fun getMidnight(): Instant {
+        val tomorrow = LocalDate.now(KOREA_ZONE).plusDays(1)
+        return tomorrow.atStartOfDay(KOREA_ZONE).toInstant()
+    }
+
+    companion object {
+        private val KOREA_ZONE = ZoneId.of("Asia/Seoul")
+    }
+}

src/main/kotlin/com/neki/pose/infra/persist/PoseRepositoryAdapter.kt

@@ -44,4 +44,8 @@ class PoseRepositoryAdapter(
 
     override fun findPoseByOffset(offset: Long, headCount: HeadCount, excludeIds: List<Long>): Pose? =
         queryRepository.findPoseByOffset(offset, headCount, excludeIds)
+
+    override fun incrementViewCount(poseId: Long) {
+        queryRepository.incrementViewCount(poseId)
+    }
 }

src/main/kotlin/com/neki/pose/infra/persist/jpa/PosesQueryRepository.kt

@@ -110,4 +110,10 @@ class PosesQueryRepository(private val queryFactory: JPAQueryFactory) {
         .offset(offset)
         .limit(1)
         .fetchOne()
+
+    fun incrementViewCount(poseId: Long): Long = queryFactory
+        .update(pose)
+        .set(pose.viewCount, pose.viewCount.add(1))
+        .where(pose.id.eq(poseId))
+        .execute()
 }

src/main/resources/db/migration/V12__add_view_count_to_pose.sql

@@ -0,0 +1 @@
+ALTER TABLE TB_POSE ADD COLUMN view_count BIGINT NOT NULL DEFAULT 0;