release: 1.5.6 (#168)

Author: devxb

docs/api/rank/get_total_rank_count.md

@@ -0,0 +1,17 @@
+# Get rank
+
+type에 해당하는 랭킹의 카운트를 응답합니다.
+
+## Request
+### Http method: `GET`
+### URL: `https://render.gitanimals.org/ranks/total`
+### Parameter
+- type: WEEKLY_GUILD_CONTRIBUTIONS, WEEKLY_USER_CONTRIBUTIONS // 조회할 랭크의 타입을 입력합니다.
+
+## Response
+
+```json
+{
+  "count": 1999
+}
+```

src/main/kotlin/org/gitanimals/core/redis/RedisPubSubChannel.kt

@@ -9,4 +9,6 @@ object RedisPubSubChannel {
     const val SLACK_REPLIED = "SLACK_REPLIED"
 
     const val DEAD_LETTER_OCCURRED = "DEAD_LETTER_OCCURRED"
+
+    const val NEW_PET_DROP_RATE_DISTRIBUTION = "NEW_PET_DROP_RATE_DISTRIBUTION"
 }

src/main/kotlin/org/gitanimals/notification/app/NewPetDropRateDistributionMessageListener.kt

@@ -0,0 +1,43 @@
+package org.gitanimals.notification.app
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import org.gitanimals.core.redis.TraceableMessageListener
+import org.gitanimals.notification.app.event.NewPetDropRateDistributionEvent
+import org.gitanimals.notification.domain.Notification
+import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Qualifier
+import org.springframework.data.redis.connection.Message
+import org.springframework.data.redis.core.StringRedisTemplate
+import org.springframework.stereotype.Component
+
+@Component
+class NewPetDropRateDistributionMessageListener(
+    private val redisTemplate: StringRedisTemplate,
+    private val objectMapper: ObjectMapper,
+    @Qualifier("gitAnimalsReportSlackNotification") private val dailyReportSlackNotification: Notification,
+) : TraceableMessageListener(redisTemplate, objectMapper) {
+
+    private val logger = LoggerFactory.getLogger(this::class.simpleName)
+
+    override fun onMessage(message: Message) {
+        runCatching {
+            val newPetDropRateDistributionEvent = objectMapper.readValue(
+                redisTemplate.stringSerializer.deserialize(message.body),
+                NewPetDropRateDistributionEvent::class.java,
+            )
+
+            dailyReportSlackNotification.notify(
+                message = """
+                    :pepe: *${newPetDropRateDistributionEvent.type} drop rate distribution reports* :pepe:
+                    ${
+                        newPetDropRateDistributionEvent.distributions.sortedBy { it.dropRate }
+                        .joinToString("\n") { "- ${it.dropRate}: ${it.count}" }
+                    }
+                """.trimIndent()
+            )
+        }.onFailure {
+            logger.error("[NewPetDropRateDistributionMessageListener] Fail to notify dropRate message: $message", it)
+        }
+    }
+}
+

src/main/kotlin/org/gitanimals/notification/app/SlackNotificationHandler.kt

@@ -13,7 +13,7 @@ import org.springframework.beans.factory.annotation.Qualifier
 @SagaHandler
 class SlackNotificationHandler(
     @Qualifier("gitAnimalsNewUserSlackNotification") private val newUserSlackNotification: Notification,
-    @Qualifier("gitAnimalsDailyReportSlackNotification") private val dailyReportSlackNotification: Notification,
+    @Qualifier("gitAnimalsReportSlackNotification") private val dailyReportSlackNotification: Notification,
 ) {
 
     @SagaStartListener(event = NewUserCreated::class, successWith = SuccessWith.END)

src/main/kotlin/org/gitanimals/notification/app/event/NewPetDropRateDistributionEvent.kt

@@ -0,0 +1,12 @@
+package org.gitanimals.notification.app.event
+
+data class NewPetDropRateDistributionEvent(
+    val traceId: Long,
+    val type: String,
+    val distributions: List<Distribution>,
+) {
+    data class Distribution(
+        val dropRate: Double,
+        val count: Int,
+    )
+}

src/main/kotlin/org/gitanimals/notification/infra/RedisMessageListenerConfiguration.kt

@@ -1,10 +1,7 @@
 package org.gitanimals.notification.infra
 
 import org.gitanimals.core.redis.RedisPubSubChannel
-import org.gitanimals.notification.app.NotApprovedQuizCreatedMessageListener
-import org.gitanimals.notification.app.QuizCreatedMessageListener
-import org.gitanimals.notification.app.SlackDeadLetterMessageListener
-import org.gitanimals.notification.app.SlackRepliedMessageListener
+import org.gitanimals.notification.app.*
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.data.redis.connection.RedisConnectionFactory
@@ -18,6 +15,7 @@ class RedisMessageListenerConfiguration(
     private val notApprovedQuizCreatedMessageListener: NotApprovedQuizCreatedMessageListener,
     private val slackRepliedMessageListener: SlackRepliedMessageListener,
     private val slackDeadLetterMessageListener: SlackDeadLetterMessageListener,
+    private val newPetDropRateDistributionMessageListener: NewPetDropRateDistributionMessageListener,
 ) {
 
     @Bean
@@ -40,6 +38,10 @@ class RedisMessageListenerConfiguration(
                 slackDeadLetterMessageListener,
                 ChannelTopic(RedisPubSubChannel.DEAD_LETTER_OCCURRED),
             )
+            this.addMessageListener(
+                newPetDropRateDistributionMessageListener,
+                ChannelTopic(RedisPubSubChannel.NEW_PET_DROP_RATE_DISTRIBUTION)
+            )
         }
     }
 }

src/main/kotlin/org/gitanimals/notification/infra/SlackNotifiactions.kt

@@ -81,7 +81,7 @@ class GitAnimalsNewUserSlackNotification(
 ) : SlackNotification(token, "C079NJ6PVBQ", objectMapper)
 
 @Component
-class GitAnimalsDailyReportSlackNotification(
+class GitAnimalsReportSlackNotification(
     objectMapper: ObjectMapper,
     @Value(value = "\${slack.token}") token: String,
 ) : SlackNotification(token, "C07BPB42R8D", objectMapper)