#135 - 익명 프로필 조회 기능을 구현합니다.

app/src/main/kotlin/com/wespot/message/v2/GetAnonymousProfileController.kt

@@ -0,0 +1,26 @@
+package com.wespot.message.v2
+
+import com.wespot.message.dto.response.AnonymousProfileResponse
+import com.wespot.message.port.`in`.GetAnonymousProfileUseCase
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+@RequestMapping("/api/v1/messages")
+class GetAnonymousProfileController(
+    private val getAnonymousProfileUseCase: GetAnonymousProfileUseCase,
+) {
+
+    @GetMapping("/receiver/{receiverId}/profiles")
+    fun getAnonymousProfileByReceiverId(
+        @PathVariable receiverId: Long
+    ): ResponseEntity<List<AnonymousProfileResponse>> {
+        val response = getAnonymousProfileUseCase.getAnonymousProfileByReceiverId(receiverId)
+
+        return ResponseEntity.ok()
+            .body(response)
+    }
+}

app/src/main/kotlin/com/wespot/user/AnonymousProfileController.kt → app/src/main/kotlin/com/wespot/user/CreatedAnonymousProfileController.kt

@@ -8,20 +8,20 @@ import org.springframework.http.ResponseEntity
 import org.springframework.web.bind.annotation.*
 
 @RestController
-@RequestMapping("/api/v1/messages/profiles")
-class AnonymousProfileController(
+@RequestMapping("/api/v1/messages")
+class CreatedAnonymousProfileController(
     private val anonymousProfileUseCase: AnonymousProfileUseCase
 ) {
 
-    @PostMapping
+    @PostMapping("/profiles")
     fun createAnonymousProfile(@RequestBody createdAnonymousProfileRequest: CreatedAnonymousProfileRequest): ResponseEntity<Unit> {
         anonymousProfileUseCase.createAnonymousProfile(createdAnonymousProfileRequest)
 
         return ResponseEntity.status(HttpStatus.CREATED)
             .build()
     }
 
-    @PutMapping("/{id}")
+    @PutMapping("/profiles/{id}")
     fun unblockUser(
         @PathVariable id: Long,
         @RequestBody updatedAnonymousProfileRequest: UpdatedAnonymousProfileRequest

core/src/main/kotlin/com/wespot/message/dto/response/AnonymousProfileResponse.kt

@@ -0,0 +1,32 @@
+package com.wespot.message.dto.response
+
+import com.fasterxml.jackson.annotation.JsonFormat
+import com.wespot.message.v2.UserProfile
+import java.time.LocalDateTime
+
+data class AnonymousProfileResponse(
+    val id: Long,
+    val image: String,
+    val name: String,
+    val isAnonymous: Boolean,
+    @JsonFormat(pattern = "yyyy.MM.dd HH:mm:ss")
+    val recentlyTalk: LocalDateTime?,
+    val myTurnToAnswer: Boolean
+) {
+
+    companion object {
+        fun from(
+            userProfile: UserProfile
+        ): AnonymousProfileResponse {
+            return AnonymousProfileResponse(
+                id = userProfile.profileId,
+                image = userProfile.image,
+                name = userProfile.name,
+                isAnonymous = userProfile.isAnonymous,
+                recentlyTalk = userProfile.recentlyTalk(),
+                myTurnToAnswer = userProfile.isAbleToAnswer()
+            )
+        }
+    }
+
+}

core/src/main/kotlin/com/wespot/message/port/in/GetAnonymousProfileUseCase.kt

@@ -0,0 +1,9 @@
+package com.wespot.message.port.`in`
+
+import com.wespot.message.dto.response.AnonymousProfileResponse
+
+interface GetAnonymousProfileUseCase {
+
+    fun getAnonymousProfileByReceiverId(receiverId: Long): List<AnonymousProfileResponse>
+
+}

core/src/main/kotlin/com/wespot/message/port/out/MessageV2Port.kt

@@ -22,4 +22,6 @@ interface MessageV2Port {
 
     fun findAllByMessageRoomId(messageRoomId: Long): List<MessageV2>
 
+    fun findAllMessageRoomBySenderIdAndReceiverId(senderId: Long, receiverId: Long): List<MessageV2>
+
 }

core/src/main/kotlin/com/wespot/message/service/v2/GetAnonymousProfileService.kt

@@ -0,0 +1,36 @@
+package com.wespot.message.service.v2
+
+import com.wespot.auth.service.SecurityUtils
+import com.wespot.message.dto.response.AnonymousProfileResponse
+import com.wespot.message.port.`in`.GetAnonymousProfileUseCase
+import com.wespot.message.port.out.MessageV2Port
+import com.wespot.message.v2.MessageRooms
+import com.wespot.message.v2.UserProfiles
+import com.wespot.user.port.out.UserPort
+import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
+
+@Service
+class GetAnonymousProfileService(
+    private val userPort: UserPort,
+    private val messagePort: MessageV2Port,
+) : GetAnonymousProfileUseCase {
+
+    @Transactional(readOnly = true)
+    override fun getAnonymousProfileByReceiverId(receiverId: Long): List<AnonymousProfileResponse> {
+        val sender = SecurityUtils.getLoginUser(userPort = userPort)
+        val messageRooms =
+            messagePort.findAllMessageRoomBySenderIdAndReceiverId(senderId = sender.id, receiverId = receiverId)
+        val messageRoomIds = messageRooms.map { it.id }
+        val messageDetails = messagePort.findAllLastMessageOfRoomByRoomIdIn(messageRoomIds)
+
+        val rooms =
+            MessageRooms.createOverview(user = sender, rooms = messageRooms, messageDetails = messageDetails)
+
+        return UserProfiles.of(messageRooms = rooms)
+            .asList()
+            .map { AnonymousProfileResponse.from(it) }
+    }
+
+}
+

core/src/main/kotlin/com/wespot/user/service/AnonymousProfileService.kt

@@ -9,6 +9,7 @@ import com.wespot.image.event.DeletedImageEvent
 import com.wespot.image.event.SavedImageEvent
 import com.wespot.user.dto.request.CreatedAnonymousProfileRequest
 import com.wespot.user.dto.request.UpdatedAnonymousProfileRequest
+import com.wespot.message.dto.response.AnonymousProfileResponse
 import com.wespot.user.message.AnonymousProfile
 import com.wespot.user.message.ProfileName
 import com.wespot.user.port.`in`.AnonymousProfileUseCase
@@ -90,4 +91,5 @@ class AnonymousProfileService(
         EventUtils.publish(DeletedImageEvent(savedAnonymousProfile.imageUrl))
         return savedAnonymousProfileAfterUpdate
     }
+
 }

domain/src/main/kotlin/com/wespot/message/v2/MessageDetails.kt

@@ -36,4 +36,8 @@ data class MessageDetails(
         return messages
     }
 
+    fun isAbleToAnswer(): Boolean {
+        return messages.any { it.isAbleToAnswer }
+    }
+
 }

domain/src/main/kotlin/com/wespot/message/v2/MessageRoom.kt

@@ -3,6 +3,7 @@ package com.wespot.message.v2
 import com.wespot.exception.CustomException
 import com.wespot.exception.ExceptionView
 import com.wespot.user.User
+import com.wespot.user.message.AnonymousProfile
 import org.springframework.http.HttpStatus
 import java.time.LocalDateTime
 
@@ -94,4 +95,23 @@ data class MessageRoom(
         return roomMessage.isReportedByReceiver(viewer = viewer)
     }
 
+    fun isAbleToAnswer(): Boolean {
+        return messages.isAbleToAnswer()
+    }
+
+    fun isSameUserProfileAndNotAnonymous(viewer: User): Boolean {
+        if (roomMessage.isSameUserProfileAndNotAnonymous(viewer = viewer)) {
+            return true
+        }
+        return false
+    }
+
+    fun isSameAnonymousProfile(anonymousProfileId: Long): Boolean {
+        return roomMessage.isSameAnonymousProfile(anonymousProfileId = anonymousProfileId)
+    }
+
+    fun anonymousProfile(): AnonymousProfile? {
+        return roomMessage.anonymousProfile
+    }
+
 }

domain/src/main/kotlin/com/wespot/message/v2/MessageRooms.kt

@@ -1,6 +1,9 @@
 package com.wespot.message.v2
 
+import com.wespot.exception.CustomException
+import com.wespot.exception.ExceptionView
 import com.wespot.user.User
+import org.springframework.http.HttpStatus
 
 data class MessageRooms(
     val rooms: List<MessageRoom>
@@ -30,4 +33,19 @@ data class MessageRooms(
         return rooms
     }
 
+    fun viewer(): User {
+        val viewerSet = rooms.map { it.viewer }
+            .toSet()
+
+        if (viewerSet.size != 1) {
+            throw CustomException(
+                message = "조회자는 무조건 1명을 초과할 수 없습니다.",
+                status = HttpStatus.BAD_REQUEST,
+                view = ExceptionView.TOAST,
+            )
+        }
+
+        return viewerSet.first()
+    }
+
 }

domain/src/main/kotlin/com/wespot/message/v2/MessageV2.kt

@@ -270,5 +270,17 @@ data class MessageV2(
         return false
     }
 
+    fun isSameUserProfileAndNotAnonymous(viewer: User): Boolean {
+        return isRoom() && viewer.isMeSender(senderId = sender.id) && anonymousProfile == null
+    }
+
+    fun isSameAnonymousProfile(anonymousProfileId: Long): Boolean {
+        if (anonymousProfile == null) {
+            return false
+        }
+
+        return anonymousProfile.id == anonymousProfileId
+    }
+
 
 }

domain/src/main/kotlin/com/wespot/message/v2/UserProfile.kt

@@ -0,0 +1,63 @@
+package com.wespot.message.v2
+
+import com.wespot.user.User
+import com.wespot.user.message.AnonymousProfile
+import java.time.LocalDateTime
+
+data class UserProfile(
+    val profileId: Long,
+    val image: String,
+    val name: String,
+    val isAnonymous: Boolean,
+    val messageRoom: MessageRoom?
+) {
+
+    companion object {
+
+        private val EMPTY_MESSAGE_ROOM = null
+
+        fun createByAnonymousProfile(
+            anonymousProfile: AnonymousProfile,
+            messageRoom: List<MessageRoom>
+        ): UserProfile {
+            return UserProfile(
+                profileId = anonymousProfile.id,
+                image = anonymousProfile.imageUrl,
+                name = anonymousProfile.name,
+                isAnonymous = true,
+                messageRoom = messageRoom.find { it.isSameAnonymousProfile(anonymousProfile.id) }
+            )
+        }
+
+        fun createByUserProfile(
+            user: User,
+            messageRoom: List<MessageRoom>
+        ): UserProfile {
+            return UserProfile(
+                profileId = user.profile.id,
+                image = user.profile.iconUrl,
+                name = user.name,
+                isAnonymous = false,
+                messageRoom = messageRoom.find { it.isSameUserProfileAndNotAnonymous(viewer = user) }
+            )
+        }
+
+    }
+
+    fun recentlyTalk(): LocalDateTime? {
+        if (messageRoom == EMPTY_MESSAGE_ROOM) {
+            return null
+        }
+
+        return messageRoom.latestChatTime()
+    }
+
+    fun isAbleToAnswer(): Boolean {
+        if (messageRoom == EMPTY_MESSAGE_ROOM) {
+            return false
+        }
+
+        return messageRoom.isAbleToAnswer()
+    }
+
+}

domain/src/main/kotlin/com/wespot/message/v2/UserProfiles.kt

@@ -0,0 +1,50 @@
+package com.wespot.message.v2
+
+import com.wespot.exception.CustomException
+import com.wespot.exception.ExceptionView
+import org.springframework.http.HttpStatus
+
+data class UserProfiles(
+    val userProfiles: List<UserProfile>
+) {
+
+    companion object {
+
+        fun of(messageRooms: MessageRooms): UserProfiles {
+            val isContainsOwnerIsNotViewer = messageRooms.asList()
+                .any { !it.isViewerOwnerOfMessageRoom() }
+            if (isContainsOwnerIsNotViewer) {
+                throw CustomException(
+                    message = "익명 프로필을 조회한자가 소유한 쪽지방이 아닌 쪽지를 가져왔습니다.",
+                    status = HttpStatus.BAD_REQUEST,
+                    view = ExceptionView.TOAST,
+                )
+            }
+
+            val anonymousProfiles = messageRooms.asList()
+                .filter { it.isAnonymous() }
+                .map { it.anonymousProfile()!! }
+
+            val resultOfUserProfiles = anonymousProfiles.map { anonymousProfile ->
+                UserProfile.createByAnonymousProfile(
+                    anonymousProfile = anonymousProfile,
+                    messageRoom = messageRooms.asList()
+                )
+            } + UserProfile.createByUserProfile(
+                user = messageRooms.viewer(),
+                messageRoom = messageRooms.asList()
+            )
+
+            return UserProfiles(
+                userProfiles = resultOfUserProfiles.sortedBy { it.recentlyTalk() }
+                    .reversed()
+            )
+        }
+
+    }
+
+    fun asList(): List<UserProfile> {
+        return userProfiles
+    }
+
+}

domain/src/main/kotlin/com/wespot/user/User.kt

@@ -301,4 +301,14 @@ data class User(
         return name == EVER_NAME
     }
 
+    override fun equals(other: Any?): Boolean {
+        if (this === other) return true
+        if (other !is User) return false
+        return id == other.id
+    }
+
+    override fun hashCode(): Int {
+        return id.hashCode()
+    }
+
 }

infrastructure/mysql/src/main/kotlin/com/wespot/message/v2/MessageV2JpaRepository.kt

@@ -32,4 +32,9 @@ interface MessageV2JpaRepository : JpaRepository<MessageJpaEntityV2, Long> {
 
     fun findAllByMessageRoomId(messageRoomId: Long): List<MessageJpaEntityV2>
 
+    fun findAllByMessageRoomIdIsNullAndSenderIdAndReceiverId(
+        senderId: Long,
+        receiverId: Long,
+    ): List<MessageJpaEntityV2>
+
 }

infrastructure/mysql/src/main/kotlin/com/wespot/message/v2/MessageV2PersistenceAdapter.kt

@@ -126,4 +126,13 @@ class MessageV2PersistenceAdapter(
         return getCompleteMessageV2(messages)
     }
 
+    override fun findAllMessageRoomBySenderIdAndReceiverId(senderId: Long, receiverId: Long): List<MessageV2> {
+        val messageRooms = messageV2JpaRepository.findAllByMessageRoomIdIsNullAndSenderIdAndReceiverId(
+            senderId = senderId,
+            receiverId = receiverId
+        )
+
+        return getCompleteMessageV2(messageRooms)
+    }
+
 }