release: 1.2.7 (#137)

Author: devxb

src/main/kotlin/org/gitanimals/core/HttpClientErrorHandler.kt

@@ -0,0 +1,28 @@
+package org.gitanimals.core
+
+import org.springframework.http.HttpMethod
+import org.springframework.http.HttpStatus
+import org.springframework.http.client.ClientHttpResponse
+import org.springframework.web.client.ResponseErrorHandler
+import java.net.URI
+
+
+class HttpClientErrorHandler : ResponseErrorHandler {
+
+    override fun hasError(response: ClientHttpResponse): Boolean {
+        return response.statusCode.isError
+    }
+
+    override fun handleError(url: URI, method: HttpMethod, response: ClientHttpResponse) {
+        val body = response.body.bufferedReader().use { it.readText() }
+        when {
+            response.statusCode.isSameCodeAs(HttpStatus.UNAUTHORIZED) ->
+                throw AuthorizationException(body)
+
+            response.statusCode.is4xxClientError ->
+                throw IllegalArgumentException(body)
+
+            else -> error(body)
+        }
+    }
+}

src/main/kotlin/org/gitanimals/inbox/app/IdentityApi.kt

@@ -1,7 +1,10 @@
 package org.gitanimals.inbox.app
 
+import org.springframework.web.service.annotation.GetExchange
+
 fun interface IdentityApi {
 
+    @GetExchange("/users")
     fun getUserByToken(token: String): UserResponse
 
     data class UserResponse(

src/main/kotlin/org/gitanimals/inbox/infra/InboxHttpClientConfigurer.kt

@@ -0,0 +1,50 @@
+package org.gitanimals.inbox.infra
+
+import org.gitanimals.core.HttpClientErrorHandler
+import org.gitanimals.core.filter.MDCFilter
+import org.gitanimals.inbox.app.IdentityApi
+import org.slf4j.MDC
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.web.client.RestClient
+import org.springframework.web.client.support.RestClientAdapter
+import org.springframework.web.service.invoker.HttpServiceProxyFactory
+
+@Configuration
+class InboxHttpClientConfigurer(
+    @Value("\${internal.secret}") private val internalSecret: String,
+) {
+
+    @Bean
+    fun inboxIdentityApi(token: String): IdentityApi {
+        val restClient = RestClient
+            .builder()
+            .requestInterceptor { request, body, execution ->
+                request.headers.add(MDCFilter.TRACE_ID, MDC.get(MDCFilter.TRACE_ID))
+                if (request.uri.path.startsWith("/internals")) {
+                    request.headers.add(
+                        INTERNAL_SECRET_KEY,
+                        internalSecret
+                    )
+                }
+                execution.execute(request, body)
+            }
+            .defaultStatusHandler(inboxHttpClientErrorHandler())
+            .baseUrl("https://api.gitanimals.org")
+            .build()
+
+        val httpServiceProxyFactory = HttpServiceProxyFactory
+            .builderFor(RestClientAdapter.create(restClient))
+            .build()
+
+        return httpServiceProxyFactory.createClient(IdentityApi::class.java)
+    }
+
+    @Bean
+    fun inboxHttpClientErrorHandler(): HttpClientErrorHandler = HttpClientErrorHandler()
+
+    private companion object {
+        private const val INTERNAL_SECRET_KEY = "Internal-Secret"
+    }
+}

src/main/kotlin/org/gitanimals/inbox/infra/RestIdentityApi.kt

@@ -2,6 +2,7 @@ package org.gitanimals.quiz.domain.infra
 
 import com.fasterxml.jackson.databind.ObjectMapper
 import io.kotest.core.spec.style.StringSpec
+import org.gitanimals.notification.domain.Notification
 import org.gitanimals.notification.infra.GitAnimalsNewQuizCreatedSlackNotification
 
 
@@ -33,9 +34,21 @@ internal class SlackNotificationTest : StringSpec({
 
         // when
         slackNotificationWithToken.notifyWithActions(
-            "xb test",
-            whenApprovedButtonClicked,
-            whenNotApprovedButtonClicked,
+            message = "xb test",
+            actions = listOf(
+                Notification.ActionRequest(
+                    id = "approve_action",
+                    style = Notification.ActionRequest.Style.PRIMARY,
+                    name = "Approve",
+                    interaction = whenApprovedButtonClicked,
+                ),
+                Notification.ActionRequest(
+                    id = "delete_action",
+                    style = Notification.ActionRequest.Style.DANGER,
+                    name = "Deny",
+                    interaction = whenNotApprovedButtonClicked,
+                )
+            ),
         )
     }
 })