Merge pull request #88 from sgdevcamp2025/be/faet/84-direct

[BE] feat: Direct create API

Author: toychip

src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/config/WebSocketConfig.kt

@@ -1,7 +1,7 @@
 package com.asyncgate.chat_server.config
 
 import com.asyncgate.chat_server.filter.FilterChannelInterceptor
-import com.asyncgate.chat_server.filter.JwtHandshakeInterceptor
+import com.asyncgate.chat_server.filter.WebSocketHandshakeInterceptor
 import org.springframework.context.annotation.Configuration
 import org.springframework.messaging.simp.config.ChannelRegistration
 import org.springframework.messaging.simp.config.MessageBrokerRegistry
@@ -13,13 +13,13 @@ import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerCo
 @EnableWebSocketMessageBroker
 class WebSocketConfig(
     private val filterChannelInterceptor: FilterChannelInterceptor,
-    private val jwtHandshakeInterceptor: JwtHandshakeInterceptor,
+    private val webSocketHandshakeInterceptor: WebSocketHandshakeInterceptor,
 ) : WebSocketMessageBrokerConfigurer {
 
     override fun registerStompEndpoints(registry: StompEndpointRegistry) {
         registry.addEndpoint("/asyncgate-chat")
             .setAllowedOriginPatterns("*")
-            .addInterceptors(jwtHandshakeInterceptor)
+            .addInterceptors(webSocketHandshakeInterceptor)
     }
 
     override fun configureMessageBroker(registry: MessageBrokerRegistry) {

src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/controller/HealthCheckController.kt

@@ -0,0 +1,15 @@
+package com.asyncgate.chat_server.controller
+
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+@RequestMapping("/health")
+class HealthCheckController {
+
+    @GetMapping
+    fun healthCheck(): Map<String, String> {
+        return mapOf("status" to "UP")
+    }
+}

src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/exception/ChatServerErrorHandler.kt

@@ -0,0 +1,34 @@
+package com.asyncgate.chat_server.exception
+
+import com.asyncgate.chat_server.support.response.FailResponse
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.ControllerAdvice
+import org.springframework.web.bind.annotation.ExceptionHandler
+import org.springframework.web.servlet.resource.NoResourceFoundException
+
+@ControllerAdvice
+class ChatServerErrorHandler {
+    private val log: Logger = LoggerFactory.getLogger(ChatServerErrorHandler::class.java)
+
+    @ExceptionHandler(ChatServerException::class)
+    fun handleApiException(e: ChatServerException): ResponseEntity<FailResponse> {
+        val errorType: FailType = e.failType
+        val response: FailResponse = FailResponse.of(
+            errorType.errorCode,
+            errorType.message,
+            errorType.status.value()
+        )
+        return ResponseEntity.status(errorType.status).body(response)
+    }
+
+    @ExceptionHandler(Exception::class)
+    fun handleException(exception: Exception) {
+        log.error("🚨 [Global Error] ${exception.message}", exception)
+    }
+
+    @ExceptionHandler(NoResourceFoundException::class)
+    fun handleResourceException(exception: NoResourceFoundException) {
+    }
+}

src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/exception/WebSocketErrorHandler.kt

@@ -10,12 +10,12 @@ import org.springframework.web.socket.WebSocketHandler
 import org.springframework.web.socket.server.HandshakeInterceptor
 
 @Component
-class JwtHandshakeInterceptor(
+class WebSocketHandshakeInterceptor(
     private val jwtTokenProvider: JwtTokenProvider,
 ) : HandshakeInterceptor {
 
     companion object {
-        private val log: Logger = LoggerFactory.getLogger(JwtHandshakeInterceptor::class.java)
+        private val log: Logger = LoggerFactory.getLogger(WebSocketHandshakeInterceptor::class.java)
     }
 
     /**

…erver/filter/FilterChannelInterceptor.kt …e/chat_server/filter/StompInterceptor.ktsrc/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/FilterChannelInterceptor.kt renamed to src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/StompInterceptor.kt src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/FilterChannelInterceptor.kt renamed to src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/StompInterceptor.kt

@@ -0,0 +1,15 @@
+package com.asyncgate.guild_server.client;
+
+import com.asyncgate.guild_server.support.response.SuccessResponse;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+
+@FeignClient(name = "user-server")
+public interface UserClient {
+
+    @GetMapping("/users")
+    SuccessResponse<UserClientInfoResponses> getUsersInfo(@RequestParam(required = false) List<String> memberIds);
+}

…server/filter/JwtHandshakeInterceptor.kt …/filter/WebSocketHandshakeInterceptor.ktsrc/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/JwtHandshakeInterceptor.kt renamed to src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/WebSocketHandshakeInterceptor.kt src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/JwtHandshakeInterceptor.kt renamed to src/backend/chat-server/src/main/kotlin/com/asyncgate/chat_server/filter/WebSocketHandshakeInterceptor.kt

@@ -0,0 +1,8 @@
+package com.asyncgate.guild_server.client;
+
+import java.util.List;
+
+public record UserClientInfoResponses(List<UserClientInfoResponse> responses) {
+    public record UserClientInfoResponse(String userId, String name, String nickname, String profileImageUrl) {
+    }
+}

src/backend/guild-server/src/main/java/com/asyncgate/guild_server/client/UserClient.java

@@ -6,7 +6,7 @@
 import org.springframework.context.annotation.Configuration;
 
 @Configuration
-@EnableFeignClients
+@EnableFeignClients(basePackages = "com.asyncgate.guild_server.client")
 public class FeignClientConfig {
 
     @Bean

src/backend/guild-server/src/main/java/com/asyncgate/guild_server/client/UserClientInfoResponses.java

@@ -0,0 +1,30 @@
+package com.asyncgate.guild_server.controller;
+
+import com.asyncgate.guild_server.dto.request.DirectChannelCreateRequest;
+import com.asyncgate.guild_server.dto.response.DirectResponse;
+import com.asyncgate.guild_server.service.DirectService;
+import com.asyncgate.guild_server.support.response.SuccessResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/direct")
+public class DirectController {
+
+    private final DirectService directService;
+
+    @PostMapping
+    public SuccessResponse<DirectResponse> create(
+            final @AuthenticationPrincipal String currentUserId,
+            final @RequestBody DirectChannelCreateRequest request
+    ) {
+        return SuccessResponse.created(
+                directService.create(currentUserId, request)
+        );
+    }
+}