feat: connection closed dev resource

.github/workflows/gradle.yml

@@ -56,6 +56,8 @@ jobs:
           # Encrypt 환경 변수 주입
           encrypt.key: ${{ secrets.ENCRYPT_KEY }}
           encrypt.algorithm: ${{ secrets.ENCRYPT_ALGORITHM }}
+          # dev resource 환경 변수 주입
+          hero-alignlab.dev.resource.key: ${{ secrets.HERO_ALIGNLAB_DEV_RESOURCE_KEY }}
 
       # Secret Setup - application-prod.yml
       - name: Inject env-values to application-prod.yml

src/main/kotlin/com/hero/alignlab/config/dev/DevResourceCheckConfig.kt

@@ -0,0 +1,37 @@
+package com.hero.alignlab.config.dev
+
+import com.hero.alignlab.exception.ErrorCode
+import com.hero.alignlab.exception.NoAuthorityException
+import jakarta.validation.constraints.NotBlank
+import org.springframework.boot.context.properties.ConfigurationProperties
+import org.springframework.boot.context.properties.EnableConfigurationProperties
+import org.springframework.context.annotation.Configuration
+
+@Configuration
+@EnableConfigurationProperties(DevResourceCheckConfig.DevResourceCheckProperties::class)
+class DevResourceCheckConfig(
+    _devResourceCheckProperties: DevResourceCheckProperties
+) {
+    @ConfigurationProperties(prefix = "hero-alignlab.dev.resource")
+    data class DevResourceCheckProperties(
+        @field:NotBlank
+        var key: String = "",
+    )
+
+    init {
+        devResourceCheckProperties = _devResourceCheckProperties
+    }
+
+    companion object {
+        const val DEV_AUTH_TOKEN_KEY = "X-HERO-DEV-AUTH-TOKEN"
+
+        private lateinit var devResourceCheckProperties: DevResourceCheckProperties
+
+        suspend fun <T> devResource(key: String, function: suspend () -> T): T {
+            if (devResourceCheckProperties.key == key) {
+                return function.invoke()
+            }
+            throw NoAuthorityException(ErrorCode.NO_AUTHORITY_ERROR)
+        }
+    }
+}

src/main/kotlin/com/hero/alignlab/config/swagger/SpringDocConfig.kt

@@ -1,5 +1,6 @@
 package com.hero.alignlab.config.swagger
 
+import com.hero.alignlab.config.dev.DevResourceCheckConfig.Companion.DEV_AUTH_TOKEN_KEY
 import com.hero.alignlab.domain.auth.model.AUTH_TOKEN_KEY
 import com.hero.alignlab.domain.auth.model.AuthUser
 import io.swagger.v3.oas.models.Components

src/main/kotlin/com/hero/alignlab/config/web/ReactiveConcurrentUserWebSocketHandler.kt

@@ -181,6 +181,16 @@ class ReactiveConcurrentUserWebSocketHandler(
         }
     }
 
+    fun forceCloseAllSessions() {
+        concurrentUserMap.forEach { (_, sessions) ->
+            sessions.forEach { (_, session) ->
+                session.close().subscribe()
+            }
+        }
+
+        // 모든 세션이 종료된 후, 맵을 비울 수 있습니다.
+        concurrentUserMap.clear()
+    }
 }
 
 data class ConcurrentMessage(

src/main/kotlin/com/hero/alignlab/domain/user/resource/DevUserInfoResource.kt → src/main/kotlin/com/hero/alignlab/domain/dev/resource/DevUserInfoResource.kt

@@ -1,15 +1,13 @@
-package com.hero.alignlab.domain.user.resource
+package com.hero.alignlab.domain.dev.resource
 
 import com.hero.alignlab.common.extension.wrapOk
+import com.hero.alignlab.config.dev.DevResourceCheckConfig.Companion.devResource
 import com.hero.alignlab.config.swagger.SwaggerTag.DEV_TAG
 import com.hero.alignlab.domain.user.application.UserInfoService
 import io.swagger.v3.oas.annotations.Operation
 import io.swagger.v3.oas.annotations.tags.Tag
 import org.springframework.http.MediaType
-import org.springframework.web.bind.annotation.GetMapping
-import org.springframework.web.bind.annotation.PathVariable
-import org.springframework.web.bind.annotation.RequestMapping
-import org.springframework.web.bind.annotation.RestController
+import org.springframework.web.bind.annotation.*
 
 @Tag(name = DEV_TAG)
 @RestController
@@ -21,5 +19,8 @@ class DevUserInfoResource(
     @GetMapping("/api/dev/v1/users/{id}")
     suspend fun getUserInfo(
         @PathVariable id: Long,
-    ) = userInfoService.getUserInfo(id).wrapOk()
+        @RequestHeader("X-HERO-DEV-TOKEN") token: String
+    ) = devResource(token) {
+        userInfoService.getUserInfo(id).wrapOk()
+    }
 }

src/main/kotlin/com/hero/alignlab/domain/dev/resource/DevWebsocketResource.kt

@@ -0,0 +1,27 @@
+package com.hero.alignlab.domain.dev.resource
+
+import com.hero.alignlab.config.dev.DevResourceCheckConfig.Companion.devResource
+import com.hero.alignlab.config.swagger.SwaggerTag.DEV_TAG
+import com.hero.alignlab.config.web.ReactiveConcurrentUserWebSocketHandler
+import io.swagger.v3.oas.annotations.Operation
+import io.swagger.v3.oas.annotations.tags.Tag
+import org.springframework.http.MediaType
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestHeader
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+@Tag(name = DEV_TAG)
+@RestController
+@RequestMapping(produces = [MediaType.APPLICATION_JSON_VALUE])
+class DevWebsocketResource(
+    private val reactiveConcurrentUserWebSocketHandler: ReactiveConcurrentUserWebSocketHandler
+) {
+    @Operation(summary = "websocket connection closed")
+    @PostMapping("/api/dev/v1/websocket/connection-closed")
+    suspend fun closedConnection(
+        @RequestHeader("X-HERO-DEV-TOKEN") token: String
+    ) = devResource(token) {
+        reactiveConcurrentUserWebSocketHandler.forceCloseAllSessions()
+    }
+}

src/main/resources/config/application.yml

@@ -50,3 +50,8 @@ auth:
 encrypt:
   key:
   algorithm:
+
+hero-alignlab:
+  dev:
+    resource:
+      key: