Merge pull request #29 from TeamMiso/feat/discord-setting

🔀 :: Discord 세팅

src/main/kotlin/andreas311/miso/domain/inquiry/application/port/output/DiscordMessageSendPort.kt

@@ -0,0 +1,9 @@
+package andreas311.miso.domain.inquiry.application.port.output
+
+interface DiscordMessageSendPort {
+    fun sendDiscordMessage(message: String)
+
+    fun toSingleDiscordMessage(string: String): String
+
+    fun createInquiryMessage(inquiryName: String): String
+}

src/main/kotlin/andreas311/miso/global/config/QuerydslConfig.kt → src/main/kotlin/andreas311/miso/global/querydsl/QuerydslConfig.kt

@@ -1,4 +1,4 @@
-package andreas311.miso.global.config
+package andreas311.miso.global.querydsl
 
 import com.querydsl.jpa.impl.JPAQueryFactory
 import org.springframework.context.annotation.Bean

src/main/kotlin/andreas311/miso/global/webhook/WebHookConfig.kt

@@ -0,0 +1,13 @@
+package andreas311.miso.global.webhook
+
+import okhttp3.OkHttpClient
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+
+@Configuration
+class WebHookConfig {
+    private val httpClient = OkHttpClient()
+
+    @Bean
+    fun httpClient() = httpClient
+}

src/main/kotlin/andreas311/miso/thirdparty/discord/DiscordMessageSendAdapter.kt

@@ -0,0 +1,70 @@
+package andreas311.miso.thirdparty.discord
+
+import andreas311.miso.domain.inquiry.application.port.output.DiscordMessageSendPort
+import okhttp3.MediaType.Companion.toMediaType
+import okhttp3.OkHttpClient
+import okhttp3.Request
+import okhttp3.RequestBody.Companion.toRequestBody
+import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.stereotype.Component
+
+@Component
+class DiscordMessageSendAdapter(
+    private val okHttpClient: OkHttpClient
+): DiscordMessageSendPort {
+
+    @Value("\${discord.webhook.url}")
+    private lateinit var discordWebhookUrl: String
+
+    private val log = LoggerFactory.getLogger(this.javaClass.simpleName)
+
+    override fun sendDiscordMessage(message: String) {
+
+        val requestBody = message.toRequestBody("application/json; charset=utf-8".toMediaType())
+
+        val request = Request.Builder()
+            .url(discordWebhookUrl)
+            .post(requestBody)
+            .build()
+
+        okHttpClient.newCall(request).execute().use { response ->
+            if (response.isSuccessful) {
+                log.trace("문의봇이 문의사항 요청을 성공적으로 전달했어요!")
+            } else {
+                log.error(response.body?.string())
+                log.error("문의봇이 문의사항 요청 대신 ${response.code} 코드를 보냈어요!")
+            }
+        }
+    }
+
+    override fun toSingleDiscordMessage(string: String): String {
+        return """
+            {
+                "content":"$string"
+            }
+        """.trimIndent()
+    }
+
+    override fun createInquiryMessage(inquiryName: String): String {
+        return """
+            {
+                "content": "문의사항 요청이 들어왔어요!",
+                "embeds": [
+                    {
+                        "title": "문의사항을 확인해주세요!",
+                        "color": 5725911,
+                        "fields": [
+                            {
+                                "name": "문의사항 제목",
+                                "value": "$inquiryName",
+                                "inline": true
+                            }
+                        ]
+                    }
+                ],
+                "attachments": []
+            }
+        """.trimIndent()
+    }
+}