[Feat/#139] 구독시 디스코드 훅 / 신규 구독 안되는 문제 해결

api-repo/src/main/kotlin/com/few/api/repo/dao/subscription/SubscriptionDao.kt

@@ -6,6 +6,7 @@ import com.few.api.repo.dao.subscription.command.UpdateDeletedAtInWorkbookSubscr
 import com.few.api.repo.dao.subscription.query.SelectAllWorkbookSubscriptionStatusQueryNotConsiderDeletedAt
 import com.few.api.repo.dao.subscription.record.WorkbookSubscriptionStatus
 import com.few.api.repo.dao.subscription.query.CountWorkbookMappedArticlesQuery
+import com.few.api.repo.dao.subscription.record.CountAllSubscriptionStatusRecord
 import jooq.jooq_dsl.Tables.MAPPING_WORKBOOK_ARTICLE
 import jooq.jooq_dsl.Tables.SUBSCRIPTION
 import org.jooq.DSLContext
@@ -68,4 +69,15 @@ class SubscriptionDao(
             .where(MAPPING_WORKBOOK_ARTICLE.WORKBOOK_ID.eq(query.workbookId))
             .fetchOne(0, Int::class.java)
     }
+
+    fun countAllSubscriptionStatus(): CountAllSubscriptionStatusRecord {
+        val total = dslContext.selectCount()
+            .from(SUBSCRIPTION)
+            .fetchOne(0, Int::class.java)!!
+        val active = dslContext.selectCount()
+            .from(SUBSCRIPTION)
+            .where(SUBSCRIPTION.DELETED_AT.isNull)
+            .fetchOne(0, Int::class.java)!!
+        return CountAllSubscriptionStatusRecord(total.toLong(), active.toLong())
+    }
 }

api-repo/src/main/kotlin/com/few/api/repo/dao/subscription/record/CountAllSubscriptionStatusRecord.kt

@@ -0,0 +1,6 @@
+package com.few.api.repo.dao.subscription.record
+
+data class CountAllSubscriptionStatusRecord(
+    val totalSubscriptions: Long,
+    val activeSubscriptions: Long
+)

api/src/main/kotlin/com/few/api/client/config/ClientConfig.kt

@@ -0,0 +1,24 @@
+package com.few.api.client.config
+
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.boot.web.client.RestTemplateBuilder
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.web.client.RestTemplate
+import java.time.Duration
+
+@Configuration
+class ClientConfig {
+
+    @Bean
+    fun restTemplate(
+        restTemplateBuilder: RestTemplateBuilder,
+        @Value("\${client.timeout.connect}") connectTimeout: Int,
+        @Value("\${client.timeout.read}") readTimeout: Int
+    ): RestTemplate {
+        return restTemplateBuilder
+            .setConnectTimeout(Duration.ofSeconds(connectTimeout.toLong()))
+            .setReadTimeout(Duration.ofSeconds(readTimeout.toLong()))
+            .build()
+    }
+}

api/src/main/kotlin/com/few/api/client/config/properties/DiscordBodyProperty.kt

@@ -0,0 +1,11 @@
+package com.few.api.client.config.properties
+
+data class DiscordBodyProperty(
+    val content: String,
+    val embeds: List<Embed>
+)
+
+data class Embed(
+    val title: String,
+    val description: String
+)

api/src/main/kotlin/com/few/api/client/subscription/SubscriptionClient.kt

@@ -0,0 +1,45 @@
+package com.few.api.client.subscription
+
+import com.few.api.client.config.properties.DiscordBodyProperty
+import com.few.api.client.config.properties.Embed
+import com.few.api.client.subscription.dto.WorkbookSubscriptionArgs
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.http.HttpEntity
+import org.springframework.http.HttpMethod
+import org.springframework.stereotype.Service
+import org.springframework.web.client.RestTemplate
+
+@Service
+class SubscriptionClient(
+    private val restTemplate: RestTemplate,
+    @Value("\${webhook.discord}") private val discordWebhook: String
+) {
+    fun announceWorkbookSubscription(args: WorkbookSubscriptionArgs) {
+        args.let {
+            DiscordBodyProperty(
+                content = "🎉 신규 구독 알림 ",
+                embeds = listOf(
+                    Embed(
+                        title = "Total Subscriptions",
+                        description = it.totalSubscriptions.toString()
+                    ),
+                    Embed(
+                        title = "Active Subscriptions",
+                        description = it.activeSubscriptions.toString()
+                    ),
+                    Embed(
+                        title = "Workbook Title",
+                        description = it.workbookTitle
+                    )
+                )
+            )
+        }.let { body ->
+            restTemplate.exchange(
+                discordWebhook,
+                HttpMethod.POST,
+                HttpEntity(body),
+                String::class.java
+            )
+        }
+    }
+}

api/src/main/kotlin/com/few/api/client/subscription/dto/WorkbookSubscriptionArgs.kt

@@ -0,0 +1,7 @@
+package com.few.api.client.subscription.dto
+
+data class WorkbookSubscriptionArgs(
+    val totalSubscriptions: Long,
+    val activeSubscriptions: Long,
+    val workbookTitle: String
+)

api/src/main/kotlin/com/few/api/config/ApiConfig.kt

@@ -7,12 +7,14 @@ import com.few.storage.image.config.ImageStorageConfig
 import org.springframework.context.annotation.ComponentScan
 import org.springframework.context.annotation.Configuration
 import org.springframework.context.annotation.Import
+import org.springframework.scheduling.annotation.EnableAsync
 import org.springframework.web.servlet.config.annotation.EnableWebMvc
 
 @Configuration
 @ComponentScan(basePackages = [ApiConfig.BASE_PACKAGE])
 @Import(ApiRepoConfig::class, BatchConfig::class, ImageStorageConfig::class, DocumentStorageConfig::class)
 @EnableWebMvc
+@EnableAsync
 class ApiConfig {
     companion object {
         const val BASE_PACKAGE = "com.few.api"

api/src/main/kotlin/com/few/api/domain/subscription/event/WorkbookSubscriptionEventListener.kt

@@ -0,0 +1,37 @@
+package com.few.api.domain.subscription.event
+
+import com.few.api.client.subscription.SubscriptionClient
+import com.few.api.client.subscription.dto.WorkbookSubscriptionArgs
+import com.few.api.domain.subscription.event.dto.WorkbookSubscriptionEvent
+import com.few.api.domain.subscription.service.WorkbookService
+import com.few.api.domain.subscription.service.dto.ReadWorkbookTitleDto
+import com.few.api.repo.dao.subscription.SubscriptionDao
+import org.springframework.context.event.EventListener
+import org.springframework.scheduling.annotation.Async
+import org.springframework.stereotype.Component
+
+@Component
+class WorkbookSubscriptionEventListener(
+    private val subscriptionDao: SubscriptionDao,
+    private val subscriptionClient: SubscriptionClient,
+    private val workbookService: WorkbookService
+) {
+
+    @Async
+    @EventListener
+    fun handleWorkbookSubscriptionEvent(event: WorkbookSubscriptionEvent) {
+        val title = ReadWorkbookTitleDto(event.workbookId).let { dto ->
+            workbookService.readWorkbookTitle(dto)
+                ?: throw RuntimeException("Workbook not found")
+        }
+        subscriptionDao.countAllSubscriptionStatus().let { record ->
+            WorkbookSubscriptionArgs(
+                totalSubscriptions = record.totalSubscriptions,
+                activeSubscriptions = record.activeSubscriptions,
+                workbookTitle = title
+            ).let { args ->
+                subscriptionClient.announceWorkbookSubscription(args)
+            }
+        }
+    }
+}

api/src/main/kotlin/com/few/api/domain/subscription/event/dto/WorkbookSubscriptionEvent.kt

@@ -0,0 +1,5 @@
+package com.few.api.domain.subscription.event.dto
+
+data class WorkbookSubscriptionEvent(
+    val workbookId: Long
+)

api/src/main/kotlin/com/few/api/domain/subscription/service/WorkbookService.kt

@@ -0,0 +1,18 @@
+package com.few.api.domain.subscription.service
+
+import com.few.api.domain.subscription.service.dto.ReadWorkbookTitleDto
+import com.few.api.repo.dao.workbook.WorkbookDao
+import com.few.api.repo.dao.workbook.query.SelectWorkBookRecordQuery
+import org.springframework.stereotype.Service
+
+@Service
+class WorkbookService(
+    private val workbookDao: WorkbookDao
+) {
+
+    fun readWorkbookTitle(dto: ReadWorkbookTitleDto): String? {
+        return SelectWorkBookRecordQuery(dto.workbookId).let { query ->
+            workbookDao.selectWorkBook(query)?.title
+        }
+    }
+}

api/src/main/kotlin/com/few/api/domain/subscription/service/dto/ReadWorkbookTitleDto.kt

@@ -0,0 +1,5 @@
+package com.few.api.domain.subscription.service.dto
+
+data class ReadWorkbookTitleDto(
+    val workbookId: Long
+)

api/src/main/kotlin/com/few/api/domain/subscription/usecase/SubscribeWorkbookUseCase.kt

@@ -1,5 +1,6 @@
 package com.few.api.domain.subscription.usecase
 
+import com.few.api.domain.subscription.event.dto.WorkbookSubscriptionEvent
 import com.few.api.domain.subscription.service.MemberService
 import com.few.api.domain.subscription.service.dto.InsertMemberDto
 import com.few.api.domain.subscription.service.dto.ReadMemberIdDto
@@ -9,13 +10,15 @@ import com.few.api.repo.dao.subscription.query.SelectAllWorkbookSubscriptionStat
 import com.few.api.domain.subscription.usecase.`in`.SubscribeWorkbookUseCaseIn
 import com.few.api.repo.dao.subscription.query.CountWorkbookMappedArticlesQuery
 import com.few.data.common.code.MemberType
+import org.springframework.context.ApplicationEventPublisher
 import org.springframework.stereotype.Component
 import org.springframework.transaction.annotation.Transactional
 
 @Component
 class SubscribeWorkbookUseCase(
     private val subscriptionDao: SubscriptionDao,
-    private val memberService: MemberService
+    private val memberService: MemberService,
+    private val applicationEventPublisher: ApplicationEventPublisher
 ) {
 
     // todo 이미 가입된 경우
@@ -28,28 +31,37 @@ class SubscribeWorkbookUseCase(
         )
 
         val subTargetWorkbookId = useCaseIn.workbookId
+        val command = InsertWorkbookSubscriptionCommand(
+            memberId = memberId,
+            workbookId = subTargetWorkbookId
+        )
+
+        /** 구독 히스토리가 있는지 확인 */
         SelectAllWorkbookSubscriptionStatusQueryNotConsiderDeletedAt(memberId = memberId, workbookId = subTargetWorkbookId).let { query ->
             subscriptionDao.selectAllWorkbookSubscriptionStatus(query).let { subscriptionStatusList ->
+                /** 이미 구독한 경우가 있는 경우 */
                 if (subscriptionStatusList.isNotEmpty()) {
                     subscriptionStatusList.stream().filter { status ->
                         status.id == query.workbookId
                     }.findAny().get().let { status ->
-                        InsertWorkbookSubscriptionCommand(memberId = memberId, workbookId = subTargetWorkbookId).let { command ->
-                            if (status.subHistory) {
-                                CountWorkbookMappedArticlesQuery(subTargetWorkbookId).let { query ->
-                                    subscriptionDao.countWorkbookMappedArticles(query)
-                                }?.let { lastDay ->
-                                    if (lastDay <= (status.day)) {
-                                        throw RuntimeException("이미 학습을 완료한 워크북입니다.")
-                                    }
-                                    subscriptionDao.reSubscribeWorkbookSubscription(command)
+                        if (status.subHistory) {
+                            CountWorkbookMappedArticlesQuery(subTargetWorkbookId).let { query ->
+                                subscriptionDao.countWorkbookMappedArticles(query)
+                            }?.let { lastDay ->
+                                /** 이미 학습을 완료한 경우 */
+                                if (lastDay <= (status.day)) {
+                                    throw RuntimeException("이미 학습을 완료한 워크북입니다.")
                                 }
-                            } else {
-                                subscriptionDao.insertWorkbookSubscription(command)
+                                /** 재구독 */
+                                subscriptionDao.reSubscribeWorkbookSubscription(command)
                             }
                         }
                     }
+                } else {
+                    /** 구독한 경우가 없는 경우 */
+                    subscriptionDao.insertWorkbookSubscription(command)
                 }
+                applicationEventPublisher.publishEvent(WorkbookSubscriptionEvent(workbookId = subTargetWorkbookId))
             }
         }
     }

api/src/main/resources/application-client-local.yml

@@ -0,0 +1,7 @@
+client:
+    timeout:
+        connect: 5000
+        read: 5000
+
+webhook:
+    discord: ${WEBHOOK_DISCORD}

api/src/main/resources/application-client-prd.yml

@@ -0,0 +1,7 @@
+client:
+    timeout:
+        connect: ${TIMEOUT_CONNECT:5000}
+        read: ${TIMEOUT_READ:5000}
+
+webhook:
+    discord: ${WEBHOOK_DISCORD}

api/src/main/resources/application.yml

@@ -5,10 +5,12 @@ spring:
     profiles:
         group:
             local:
+                - client-local
                 - api-repo-local
                 - email-local
                 - storage-local
             prd:
+                - client-prd
                 - api-repo-prd
                 - email-prd
                 - storage-prd

resources/docker/docker-compose-api.yml

@@ -19,3 +19,6 @@ services:
             IMAGE_STORE_BUCKET_NAME: ${IMAGE_STORE_BUCKET_NAME}
             DOCUMENT_STORE_BUCKET_NAME: ${DOCUMENT_STORE_BUCKET_NAME}
             CDN_URL: ${CDN_URL}
+            WEBHOOK_DISCORD: ${WEBHOOK_DISCORD}
+            TIMEOUT_CONNECT: ${TIMEOUT_CONNECT}
+            TIMEOUT_READ: ${TIMEOUT_READ}