🔀 :: (#212) 테스트 알림 발송 API

🔀 :: (#212) 테스트 알림 발송 API

notification-domain/src/main/kotlin/io/github/v1servicenotification/detail/service/DetailApiImpl.kt

@@ -23,7 +23,7 @@ class DetailApiImpl(
     private val queryCategoryRepositorySpi: QueryCategoryRepositorySpi,
     private val postDetailFcmSpi: PostDetailFcmSpi,
     private val postDetailUserSpi: PostDetailUserSpi,
-    private val queryDetailRepositorySpi: QueryDetailRepositorySpi
+    private val queryDetailRepositorySpi: QueryDetailRepositorySpi,
 ): DetailApi {
 
     override fun postGroupNotification(categoryId: UUID, title: String, content: String) {

notification-infrastructure/src/main/kotlin/io/github/v1servicenotification/domain/detail/presentation/DetailController.kt

@@ -3,11 +3,15 @@ package io.github.v1servicenotification.domain.detail.presentation
 import io.github.v1servicenotification.detail.api.DetailApi
 import io.github.v1servicenotification.detail.api.dto.response.DetailResponse
 import io.github.v1servicenotification.detail.api.dto.response.NotificationCountResponse
+import io.github.v1servicenotification.domain.detail.presentation.dto.request.PostTestNotificationRequset
 import io.github.v1servicenotification.global.extension.getUserId
 import io.swagger.v3.oas.annotations.Operation
 import io.swagger.v3.oas.annotations.tags.Tag
 import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
 import org.springframework.web.bind.annotation.RestController
+import javax.validation.Valid
 
 @Tag(name = "알림 상세", description = "알림 상세 Api입니다.")
 @RestController
@@ -26,4 +30,10 @@ class DetailController(
     fun queryUnreadNotificationCount(): NotificationCountResponse {
         return detailApi.queryUnreadNotificationCount(getUserId())
     }
+
+    @Operation(summary = "테스트 알림 전송")
+    @PostMapping("/test")
+    fun postNotification(@RequestBody @Valid request: PostTestNotificationRequset) {
+        detailApi.postNotification(request.userId, request.categoryId, request.title, request.content)
+    }
 }

notification-infrastructure/src/main/kotlin/io/github/v1servicenotification/domain/detail/presentation/dto/request/PostTestNotificationRequset.kt

@@ -0,0 +1,19 @@
+package io.github.v1servicenotification.domain.detail.presentation.dto.request
+
+import java.util.UUID
+import javax.validation.constraints.NotBlank
+
+data class PostTestNotificationRequset(
+
+    @field:NotBlank
+    val userId: UUID,
+
+    @field:NotBlank
+    val categoryId: UUID,
+
+    @field:NotBlank
+    val title: String,
+
+    @field:NotBlank
+    val content: String,
+)

notification-infrastructure/src/main/kotlin/io/github/v1servicenotification/domain/notification/presentation/QueueController.kt

@@ -23,5 +23,4 @@ class QueueController(
     fun notification(@Payload @Valid personal: Personal) {
         detailApi.postNotification(personal.userId, personal.categoryId, personal.title, personal.content)
     }
-
 }

notification-infrastructure/src/main/kotlin/io/github/v1servicenotification/domain/user/domain/repository/CustomPostDetailUserImpl.kt

@@ -16,6 +16,7 @@ class CustomPostDetailUserImpl(
 
     override fun getDeviceToken(userId: UUID): String {
         val result = userClient.token(listOf(userId)).tokens
+
         if(result.isEmpty()) {
             throw FeignBadRequestException.EXCEPTION
         }

notification-infrastructure/src/main/kotlin/io/github/v1servicenotification/infrastructure/feign/client/UserClient.kt

@@ -7,12 +7,12 @@ import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.RequestParam
 import java.util.UUID
 
-@FeignClient(name = "UserClient", url = "\${user.url}")
+@FeignClient(name = "UserClient", url = "\${service.scheme}://\${service.user.host}")
 interface UserClient {
 
-    @GetMapping("/device-token")
+    @GetMapping("/users/device-token")
     fun token(@RequestParam("users") userList: List<UUID>): TokenResponse
 
-    @GetMapping("/exclude")
+    @GetMapping("/users/exclude")
     fun getExcludeUserIdList(@RequestParam("users") userList: List<UUID>): UserIdListResponse
 }