refactor: PoseService 책임 분리 + 관리자 업로드용 userId nullable화

apps/api/src/main/kotlin/com/neki/api/pose/application/GetPoseUseCase.kt

@@ -6,20 +6,22 @@ import com.neki.core.transaction.TransactionRunner
 import com.neki.domain.pose.client.MediaClient
 import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.MediaMetadata
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
+import com.neki.domain.pose.service.PoseViewService
 
 @UseCase
 class GetPoseUseCase(
-    private val poseService: PoseService,
+    private val poseScrapService: PoseScrapService,
+    private val poseViewService: PoseViewService,
     private val mediaClient: MediaClient,
     private val transactionRunner: TransactionRunner,
 ) {
 
     fun execute(query: PoseQuery.GetPose): PoseResult.GetPose {
-        val (pose, isScraped) = poseService.getOwnedPoseWithScrap(query)
+        val (pose, isScraped) = poseScrapService.getOwnedPoseWithScrap(query)
 
-        if (poseService.isFirstViewOf(query)) {
-            transactionRunner.run { poseService.incrementViewCount(query) }
+        if (poseViewService.isFirstViewOf(query)) {
+            transactionRunner.run { poseViewService.incrementViewCount(query) }
         }
 
         val mediaInfo: MediaMetadata = mediaClient.getMediaMetadata(pose.mediaId)

apps/api/src/main/kotlin/com/neki/api/pose/application/GetPosesUseCase.kt

@@ -9,7 +9,7 @@ import com.neki.domain.pose.client.MediaClient
 import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.PoseWithScrap
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
 
 /**
  * fileName       : GetPosesUseCase
@@ -19,14 +19,14 @@ import com.neki.domain.pose.service.PoseService
  */
 @UseCase
 class GetPosesUseCase(
-    private val poseService: PoseService,
+    private val poseScrapService: PoseScrapService,
     private val mediaClient: MediaClient,
     private val transactionRunner: TransactionRunner,
 ) {
 
     fun execute(query: PoseQuery.GetPoses): PoseResult.GetPoses {
         val page: Page<PoseWithScrap> = transactionRunner.readOnly {
-            poseService.listPosesWithScrap(query)
+            poseScrapService.listPosesWithScrap(query)
         }
 
         if (page.items.isEmpty()) {

apps/api/src/main/kotlin/com/neki/api/pose/application/GetScrapPosesUseCase.kt

@@ -9,7 +9,7 @@ import com.neki.domain.pose.client.MediaClient
 import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.Pose
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
 
 /**
  * fileName       : GetScrapPosesUseCase
@@ -19,14 +19,14 @@ import com.neki.domain.pose.service.PoseService
  */
 @UseCase
 class GetScrapPosesUseCase(
-    private val poseService: PoseService,
+    private val poseScrapService: PoseScrapService,
     private val mediaClient: MediaClient,
     private val transactionRunner: TransactionRunner,
 ) {
 
     fun execute(query: PoseQuery.GetScrapPoses): PoseResult.GetPoses {
         val page: Page<Pose> = transactionRunner.readOnly {
-            poseService.listOwnedScrapPoses(query)
+            poseScrapService.listOwnedScrapPoses(query)
         }
 
         if (page.items.isEmpty()) {

apps/api/src/main/kotlin/com/neki/api/pose/application/RandomPoseUseCase.kt

@@ -6,15 +6,20 @@ import com.neki.domain.pose.client.MediaClient
 import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.Pose
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
+import com.neki.domain.pose.service.RandomPoseService
 
 @UseCase
-class RandomPoseUseCase(private val poseService: PoseService, private val mediaClient: MediaClient) {
+class RandomPoseUseCase(
+    private val randomPoseService: RandomPoseService,
+    private val poseScrapService: PoseScrapService,
+    private val mediaClient: MediaClient,
+) {
 
     fun execute(query: PoseQuery.GetRandomPose): PoseResult.GetPose {
-        val pose: Pose = poseService.pickRandomPose(query)
+        val pose: Pose = randomPoseService.pickRandomPose(query)
 
-        val isScraped: Boolean = poseService.isScraped(query, pose)
+        val isScraped: Boolean = poseScrapService.isScraped(query, pose)
 
         val mediaInfo: MediaMetadata = mediaClient.getMediaMetadata(pose.mediaId)
 

apps/api/src/main/kotlin/com/neki/api/pose/application/UpdatePoseScrapUseCase.kt

@@ -2,12 +2,12 @@ package com.neki.api.pose.application
 
 import com.neki.core.annotation.UseCase
 import com.neki.domain.pose.dto.PoseCommand
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
 import org.springframework.transaction.annotation.Transactional
 
 @UseCase
-class UpdatePoseScrapUseCase(private val poseService: PoseService) {
+class UpdatePoseScrapUseCase(private val poseScrapService: PoseScrapService) {
 
     @Transactional
-    fun execute(command: PoseCommand.UpdatePoseScrap) = poseService.updateScrap(command)
+    fun execute(command: PoseCommand.UpdatePoseScrap) = poseScrapService.updateScrap(command)
 }

apps/api/src/main/kotlin/com/neki/api/pose/application/UploadPosesUseCase.kt

@@ -24,15 +24,18 @@ class UploadPosesUseCase(
 ) {
 
     fun execute(command: PoseCommand.UploadPoses) {
+        // apps:api 업로드는 인증된 사용자만 호출한다. userId가 없는 업로드는 apps:admin 전용이다.
+        val userId: Long = requireNotNull(command.userId)
+
         val poses: List<Pose> = poseService.createPoses(command)
 
         val mediaIds: List<Long> = command.uploads.map { it.mediaId }
-        verifyUploadedOrRollback(command.userId, mediaIds)
+        verifyUploadedOrRollback(userId, mediaIds)
 
         try {
             transactionRunner.run { poseService.saveAll(poses) }
         } catch (e: Exception) {
-            mediaClient.rollbackMediasUploaded(command.userId, mediaIds)
+            mediaClient.rollbackMediasUploaded(userId, mediaIds)
             throw e
         }
     }

apps/api/src/test/kotlin/com/neki/api/pose/application/usecase/GetPoseUseCaseTest.kt

@@ -11,7 +11,8 @@ import com.neki.domain.pose.external.PoseViewCache
 import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.PoseWithScrap
 import com.neki.domain.pose.repository.PoseRepository
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
+import com.neki.domain.pose.service.PoseViewService
 import io.kotest.assertions.throwables.shouldThrow
 import io.kotest.matchers.shouldBe
 import io.mockk.every
@@ -37,7 +38,8 @@ class GetPoseUseCaseTest {
         poseViewCache = mockk()
         transactionRunner = FakeTransactionRunner()
         useCase = GetPoseUseCase(
-            PoseService(poseRepository, mockk(), poseViewCache, mockk()),
+            PoseScrapService(poseRepository, mockk()),
+            PoseViewService(poseRepository, poseViewCache),
             mediaClient,
             transactionRunner,
         )

apps/api/src/test/kotlin/com/neki/api/pose/application/usecase/GetPosesUseCaseTest.kt

@@ -10,7 +10,7 @@ import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.PoseWithScrap
 import com.neki.domain.pose.repository.PoseRepository
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
 import io.kotest.matchers.shouldBe
 import io.mockk.every
 import io.mockk.mockk
@@ -32,7 +32,7 @@ class GetPosesUseCaseTest {
         mediaClient = mockk()
         transactionRunner = FakeTransactionRunner()
         useCase = GetPosesUseCase(
-            PoseService(poseRepository, mockk(), mockk(), mockk()),
+            PoseScrapService(poseRepository, mockk()),
             mediaClient,
             transactionRunner,
         )

apps/api/src/test/kotlin/com/neki/api/pose/application/usecase/GetScrapPosesUseCaseTest.kt

@@ -10,7 +10,7 @@ import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.Pose
 import com.neki.domain.pose.repository.PoseRepository
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
 import io.kotest.matchers.shouldBe
 import io.mockk.every
 import io.mockk.mockk
@@ -32,7 +32,7 @@ class GetScrapPosesUseCaseTest {
         mediaClient = mockk()
         transactionRunner = FakeTransactionRunner()
         useCase = GetScrapPosesUseCase(
-            PoseService(poseRepository, mockk(), mockk(), mockk()),
+            PoseScrapService(poseRepository, mockk()),
             mediaClient,
             transactionRunner,
         )

apps/api/src/test/kotlin/com/neki/api/pose/application/usecase/RandomPoseUseCaseTest.kt

@@ -12,7 +12,8 @@ import com.neki.domain.pose.models.MediaMetadata
 import com.neki.domain.pose.models.ScrapPoseId
 import com.neki.domain.pose.repository.PoseRepository
 import com.neki.domain.pose.repository.ScrapPoseRepository
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
+import com.neki.domain.pose.service.RandomPoseService
 import io.kotest.assertions.throwables.shouldThrow
 import io.kotest.matchers.shouldBe
 import io.mockk.every
@@ -38,7 +39,8 @@ class RandomPoseUseCaseTest {
         randomGenerator = mockk()
         useCase =
             RandomPoseUseCase(
-                PoseService(poseRepository, scrapPoseRepository, mockk(), randomGenerator),
+                RandomPoseService(poseRepository, randomGenerator),
+                PoseScrapService(poseRepository, scrapPoseRepository),
                 mediaClient,
             )
     }

apps/api/src/test/kotlin/com/neki/api/pose/application/usecase/UpdatePoseScrapUseCaseTest.kt

@@ -7,7 +7,7 @@ import com.neki.domain.pose.dto.PoseCommand
 import com.neki.domain.pose.models.ScrapPose
 import com.neki.domain.pose.repository.PoseRepository
 import com.neki.domain.pose.repository.ScrapPoseRepository
-import com.neki.domain.pose.service.PoseService
+import com.neki.domain.pose.service.PoseScrapService
 import io.kotest.assertions.throwables.shouldThrow
 import io.kotest.matchers.shouldBe
 import io.mockk.Runs
@@ -30,7 +30,7 @@ class UpdatePoseScrapUseCaseTest {
     fun setUp() {
         poseRepository = mockk()
         scrapPoseRepository = mockk()
-        useCase = UpdatePoseScrapUseCase(PoseService(poseRepository, scrapPoseRepository, mockk(), mockk()))
+        useCase = UpdatePoseScrapUseCase(PoseScrapService(poseRepository, scrapPoseRepository))
     }
 
     @Test

apps/api/src/test/kotlin/com/neki/api/pose/application/usecase/UploadPosesUseCaseTest.kt

@@ -34,7 +34,7 @@ class UploadPosesUseCaseTest {
         poseRepository = mockk()
         transactionRunner = FakeTransactionRunner()
         useCase = UploadPosesUseCase(
-            PoseService(poseRepository, mockk(), mockk(), mockk()),
+            PoseService(poseRepository),
             mediaClient,
             transactionRunner,
         )

domain/src/main/kotlin/com/neki/domain/pose/dto/PoseCommand.kt

@@ -9,7 +9,7 @@ import com.neki.domain.pose.models.HeadCount
  * description    : Pose domain command
  */
 object PoseCommand {
-    data class UploadPoses(val userId: Long, val uploads: List<Item>) {
+    data class UploadPoses(val userId: Long?, val uploads: List<Item>) {
         data class Item(val mediaId: Long, val headCount: HeadCount, val memo: String?)
     }
 

domain/src/main/kotlin/com/neki/domain/pose/dto/PoseQuery.kt

@@ -12,6 +12,11 @@ import com.neki.domain.pose.models.HeadCount
 object PoseQuery {
     data class GetPoses(val userId: Long, val headCount: HeadCount?, val pagination: Pagination)
 
+    /**
+     * 사용자 컨텍스트 없이 전체 포즈를 조회한다. headCount 는 null 이면 거르지 않는다.
+     */
+    data class GetAllPoses(val headCount: HeadCount?, val pagination: Pagination)
+
     data class GetScrapPoses(val userId: Long, val headCount: HeadCount?, val pagination: Pagination)
 
     data class GetPose(val userId: Long, val poseId: Long)

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

@@ -1,6 +1,7 @@
 package com.neki.domain.pose.infra.persist
 
 import com.neki.core.domain.vo.SortOrder
+import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.infra.persist.jpa.JpaPoseRepository
 import com.neki.domain.pose.infra.persist.jpa.PosesQueryRepository
 import com.neki.domain.pose.models.HeadCount
@@ -37,6 +38,13 @@ class PoseRepositoryAdapter(
     override fun listOwnedScrapPoses(userId: Long, offset: Int, limit: Int, sortOrder: SortOrder): List<Pose> =
         queryRepository.findOwnedScrapPoses(userId, offset, limit, sortOrder)
 
+    // 어드민 목록 조회 전용이라 apps:api 에서는 호출 경로가 없다.
+    override fun findAll(query: PoseQuery.GetAllPoses): List<Pose> =
+        throw UnsupportedOperationException("어드민 전용 조회다. apps:admin 의 어댑터를 쓴다.")
+
+    override fun count(query: PoseQuery.GetAllPoses): Long =
+        throw UnsupportedOperationException("어드민 전용 조회다. apps:admin 의 어댑터를 쓴다.")
+
     override fun existsPose(poseId: Long): Boolean = jpaRepository.existsById(poseId)
 
     override fun countPoses(headCount: HeadCount, excludeIds: List<Long>): Long =

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

@@ -25,7 +25,8 @@ class Pose(
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     val id: Long? = null,
 
-    @Column(name = "user_id", nullable = false)
+    // 관리자 업로드는 귀속 사용자가 없어 null 이다
+    @Column(name = "user_id", nullable = true)
     val userId: Long? = null,
 
     @Column(name = "media_id", nullable = false)

domain/src/main/kotlin/com/neki/domain/pose/repository/PoseRepository.kt

@@ -1,6 +1,7 @@
 package com.neki.domain.pose.repository
 
 import com.neki.core.domain.vo.SortOrder
+import com.neki.domain.pose.dto.PoseQuery
 import com.neki.domain.pose.models.HeadCount
 import com.neki.domain.pose.models.Pose
 import com.neki.domain.pose.models.PoseWithScrap
@@ -27,6 +28,10 @@ interface PoseRepository {
 
     fun listOwnedScrapPoses(userId: Long, offset: Int, limit: Int, sortOrder: SortOrder): List<Pose>
 
+    fun findAll(query: PoseQuery.GetAllPoses): List<Pose>
+
+    fun count(query: PoseQuery.GetAllPoses): Long
+
     fun existsPose(poseId: Long): Boolean
 
     fun countPoses(headCount: HeadCount, excludeIds: List<Long>): Long

domain/src/main/kotlin/com/neki/domain/pose/service/PoseScrapService.kt

@@ -0,0 +1,68 @@
+package com.neki.domain.pose.service
+
+import com.neki.core.code.ResultCode
+import com.neki.core.domain.vo.Page
+import com.neki.core.exception.BusinessException
+import com.neki.domain.pose.dto.PoseCommand
+import com.neki.domain.pose.dto.PoseQuery
+import com.neki.domain.pose.models.Pose
+import com.neki.domain.pose.models.PoseWithScrap
+import com.neki.domain.pose.models.ScrapPose
+import com.neki.domain.pose.repository.PoseRepository
+import com.neki.domain.pose.repository.ScrapPoseRepository
+import org.springframework.stereotype.Component
+
+/**
+ * fileName       : PoseScrapService
+ * author         : koo
+ * date           : 2026. 8. 10.
+ * description    : 스크랩 상태 변경과, 스크랩 여부가 붙은 조회
+ */
+@Component
+class PoseScrapService(
+    private val poseRepository: PoseRepository,
+    private val scrapPoseRepository: ScrapPoseRepository,
+) {
+
+    fun getOwnedPoseWithScrap(query: PoseQuery.GetPose): PoseWithScrap =
+        poseRepository.getOwnedPoseWithScrap(query.userId, query.poseId)
+            ?: throw BusinessException(ResultCode.NOT_FOUND)
+
+    fun listPosesWithScrap(query: PoseQuery.GetPoses): Page<PoseWithScrap> = query.pagination.slice(
+        poseRepository.listPosesWithScrap(
+            userId = query.userId,
+            offset = query.pagination.offset,
+            limit = query.pagination.limit,
+            headCount = query.headCount,
+            sortOrder = query.pagination.sortOrder,
+        ),
+    )
+
+    fun listOwnedScrapPoses(query: PoseQuery.GetScrapPoses): Page<Pose> = query.pagination.slice(
+        poseRepository.listOwnedScrapPoses(
+            userId = query.userId,
+            offset = query.pagination.offset,
+            limit = query.pagination.limit,
+            sortOrder = query.pagination.sortOrder,
+        ),
+    )
+
+    /**
+     * 무작위로 고른 포즈는 query에 없으므로 함께 받는다.
+     */
+    fun isScraped(query: PoseQuery.GetRandomPose, pose: Pose): Boolean =
+        scrapPoseRepository.existsOwnedPoseScrap(ScrapPose(query.userId, pose.id!!))
+
+    fun updateScrap(command: PoseCommand.UpdatePoseScrap) {
+        if (!poseRepository.existsPose(command.poseId)) {
+            throw BusinessException(ResultCode.NOT_FOUND)
+        }
+
+        val scrapPose = ScrapPose(command.userId, command.poseId)
+        if (command.scrap) {
+            scrapPoseRepository.add(scrapPose)
+        } else {
+            scrapPoseRepository.delete(scrapPose)
+        }
+    }
+}