Feat/#34 group chat

src/main/java/com/chat/liveon/auth/controller/AuthController.java

@@ -18,7 +18,7 @@
 @RestController
 @RequestMapping("/api")
 @Slf4j
-@Tag(name = "Auth API", description = "가입, 로그인, 로그이웃 API")
+@Tag(name = "Auth API", description = "가입, 로그인, 로그아웃 API")
 public class AuthController {
     private final AuthService authService;
 

src/main/java/com/chat/liveon/auth/entity/Person.java

@@ -1,19 +1,23 @@
 package com.chat.liveon.auth.entity;
 
-import jakarta.persistence.Entity;
-import jakarta.persistence.GeneratedValue;
-import jakarta.persistence.GenerationType;
-import jakarta.persistence.Id;
+import com.chat.liveon.chat.entity.ChatMessage;
+import com.chat.liveon.chat.entity.ChatRoom;
+import jakarta.persistence.*;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.ArrayList;
+import java.util.List;
 
 @Entity
 @Getter
+@NoArgsConstructor
 public class Person {
     @Id
     @GeneratedValue(strategy = GenerationType.AUTO)
-    private Long Id;
+    private Long id;
     private String personId;
     private String personName;
     private String personPassword;
@@ -27,8 +31,4 @@ public Person(String personId, String personName, String encodedPassword, Role r
         this.role = Role.ROLE_USER;
         this.profilePicture = profilePicture;
     }
-
-    public Person() {
-    }
-
 }

src/main/java/com/chat/liveon/auth/service/AuthService.java

@@ -6,15 +6,18 @@
 import com.chat.liveon.auth.entity.Role;
 import com.chat.liveon.auth.exception.AuthenticationFailureException;
 import com.chat.liveon.auth.repository.PersonRepository;
+import jakarta.servlet.http.Cookie;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import jakarta.servlet.http.HttpSession;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.io.UnsupportedEncodingException;
 import java.security.NoSuchAlgorithmException;
 
+@Slf4j
 @Service
 public class AuthService {
     private final PasswordEncoder passwordEncoder;
@@ -43,10 +46,9 @@ public void login(LoginRequest loginRequest, HttpServletRequest request, HttpSer
         }
             HttpSession session = request.getSession(true);
             session.setAttribute("personId", loginRequest.personId());
-
             String sessionId = session.getId();
 
-            jakarta.servlet.http.Cookie sessionCookie = new jakarta.servlet.http.Cookie("SESSIONID", sessionId);
+            Cookie sessionCookie = new Cookie("JSESSIONID", sessionId);
             sessionCookie.setHttpOnly(true);
             sessionCookie.setPath("/");
             sessionCookie.setMaxAge(60 * 60);

src/main/java/com/chat/liveon/chat/config/WebSocketConfig.java

@@ -0,0 +1,24 @@
+package com.chat.liveon.chat.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
+@Configuration
+@EnableWebSocketMessageBroker
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+    @Override
+    public void configureMessageBroker(MessageBrokerRegistry config) {
+        config.enableSimpleBroker("/topic");
+        config.setApplicationDestinationPrefixes("/app");
+    }
+
+    @Override
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        registry.addEndpoint("/ws")
+                .setAllowedOriginPatterns("*")
+                .withSockJS();
+    }
+}

src/main/java/com/chat/liveon/chat/controller/ChatMessageController.java

@@ -0,0 +1,25 @@
+package com.chat.liveon.chat.controller;
+
+import com.chat.liveon.chat.dto.request.ChatMessageRequest;
+import com.chat.liveon.chat.service.ChatMessageService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+@Controller
+@RequestMapping("/api")
+@RequiredArgsConstructor
+public class ChatMessageController {
+
+    private final ChatMessageService chatMessageService;
+
+    @MessageMapping("/chat/{roomId}")
+    @SendTo("/topic/public/{roomId}")
+    public ChatMessageRequest sendMessage(@DestinationVariable Long roomId, ChatMessageRequest message) {
+        return chatMessageService.sendMessage(roomId, message);
+    }
+
+}

src/main/java/com/chat/liveon/chat/controller/ChatRoomController.java

@@ -0,0 +1,39 @@
+package com.chat.liveon.chat.controller;
+
+import com.chat.liveon.chat.dto.request.ChatRoomRequest;
+import com.chat.liveon.chat.dto.response.AllChatRoomResponse;
+import com.chat.liveon.chat.dto.response.ChatRoomResponse;
+import com.chat.liveon.chat.service.ChatRoomService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.servlet.http.HttpSession;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@Tag(name = "ChatRoom API", description = "채팅방 API")
+@RequestMapping("/api")
+@RequiredArgsConstructor
+@RestController
+public class ChatRoomController {
+
+    private final ChatRoomService chatRoomService;
+
+    @PostMapping("/chat-room")
+    @Operation(summary = "채팅방 생성 API")
+    public ResponseEntity<ChatRoomResponse> createChatRoom(@RequestBody ChatRoomRequest chatRoomRequest,
+                                                           HttpSession session) {
+        String personId = (String) session.getAttribute("personId");
+        ChatRoomResponse response = chatRoomService.createChatRoom(chatRoomRequest, personId);
+        return ResponseEntity.ok(response);
+    }
+
+    @GetMapping("/chat-room")
+    @Operation(summary = "채팅방 조회 API")
+    public ResponseEntity<List<AllChatRoomResponse>> getChatRoom() {
+        List<AllChatRoomResponse> response = chatRoomService.getAllChatRoom();
+        return ResponseEntity.ok(response);
+    }
+}

src/main/java/com/chat/liveon/chat/dto/request/ChatMessageRequest.java

@@ -0,0 +1,11 @@
+package com.chat.liveon.chat.dto.request;
+
+import java.time.LocalDateTime;
+
+public record ChatMessageRequest(
+        Long messageId,
+        Long chatRoomId,
+        String senderName,
+        String message,
+        LocalDateTime timestamp
+) {}

src/main/java/com/chat/liveon/chat/dto/request/ChatRoomRequest.java

@@ -0,0 +1,5 @@
+package com.chat.liveon.chat.dto.request;
+
+public record ChatRoomRequest(
+        String chatRoomName
+) {}

src/main/java/com/chat/liveon/chat/dto/response/AllChatRoomResponse.java

@@ -0,0 +1,6 @@
+package com.chat.liveon.chat.dto.response;
+
+public record AllChatRoomResponse(
+        Long chatRoomId,
+        String chatRoomName
+) {}

src/main/java/com/chat/liveon/chat/dto/response/ChatMessageResponse.java

@@ -0,0 +1,4 @@
+package com.chat.liveon.chat.dto.response;
+
+public class ChatMessageResponse {
+}

src/main/java/com/chat/liveon/chat/dto/response/ChatRoomResponse.java

@@ -0,0 +1,7 @@
+package com.chat.liveon.chat.dto.response;
+
+public record ChatRoomResponse(
+        Long chatRoomId,
+        String chatRoomName,
+        Long creatorId
+) {}

src/main/java/com/chat/liveon/chat/entity/ChatMessage.java

@@ -0,0 +1,48 @@
+package com.chat.liveon.chat.entity;
+
+import com.chat.liveon.auth.entity.Person;
+import jakarta.persistence.*;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Getter
+@NoArgsConstructor
+@Entity
+public class ChatMessage {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "chat_message_id")
+    private Long id;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "chat_room_id")
+    private ChatRoom chatRoom;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "sender_id")
+    private Person sender;
+
+    private String message;
+
+    private LocalDateTime sendDate;
+
+    @Builder
+    public ChatMessage(Person sender, String message, ChatRoom chatRoom) {
+        this.sender = sender;
+        this.message = message;
+        this.chatRoom = chatRoom;
+        this.sendDate = LocalDateTime.now();
+    }
+
+    public static ChatMessage createChatMessage(Person sender, String message, ChatRoom chatRoom) {
+        ChatMessage chatMessage = ChatMessage.builder()
+                .sender(sender)
+                .message(message)
+                .chatRoom(chatRoom)
+                .build();
+        return chatMessage;
+    }
+}

src/main/java/com/chat/liveon/chat/entity/ChatRoom.java

@@ -0,0 +1,29 @@
+package com.chat.liveon.chat.entity;
+
+import com.chat.liveon.auth.entity.Person;
+import jakarta.persistence.*;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+@Entity
+public class ChatRoom {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "chat_room_id")
+    private Long id;
+
+    private String chatRoomName;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "person_id")
+    private Person person;
+
+    @Builder
+    public ChatRoom(String chatRoomName, Person person) {
+        this.chatRoomName = chatRoomName;
+        this.person = person;
+    }
+}

src/main/java/com/chat/liveon/chat/repository/ChatMessageRepository.java

@@ -0,0 +1,7 @@
+package com.chat.liveon.chat.repository;
+
+import com.chat.liveon.chat.entity.ChatMessage;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ChatMessageRepository extends JpaRepository<ChatMessage, Long> {
+}

src/main/java/com/chat/liveon/chat/repository/ChatRoomRepository.java

@@ -0,0 +1,7 @@
+package com.chat.liveon.chat.repository;
+
+import com.chat.liveon.chat.entity.ChatRoom;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ChatRoomRepository extends JpaRepository<ChatRoom, Long> {
+}

src/main/java/com/chat/liveon/chat/service/ChatMessageService.java

@@ -0,0 +1,51 @@
+package com.chat.liveon.chat.service;
+
+import com.chat.liveon.auth.entity.Person;
+import com.chat.liveon.auth.repository.PersonRepository;
+import com.chat.liveon.chat.dto.request.ChatMessageRequest;
+import com.chat.liveon.chat.entity.ChatMessage;
+import com.chat.liveon.chat.entity.ChatRoom;
+import com.chat.liveon.chat.repository.ChatMessageRepository;
+import com.chat.liveon.chat.repository.ChatRoomRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Slf4j
+@RequiredArgsConstructor
+@Service
+public class ChatMessageService {
+
+    private final ChatMessageRepository chatMessageRepository;
+    private final ChatRoomRepository chatRoomRepository;
+    private final PersonRepository personRepository;
+
+    @Transactional
+    public ChatMessageRequest sendMessage(Long roomId, ChatMessageRequest messageRequest) {
+        ChatRoom chatRoom = chatRoomRepository.findById(roomId)
+                .orElseThrow(() -> new RuntimeException("ChatRoom not found"));
+
+        Person sender = personRepository.findByPersonId(messageRequest.senderName())
+                .orElseThrow(() -> new RuntimeException("Sender not found"));
+
+        ChatMessage chatMessage = ChatMessage.builder()
+                .chatRoom(chatRoom)
+                .message(messageRequest.message())
+                .sender(sender)
+                .build();
+
+        chatMessage = chatMessageRepository.save(chatMessage);
+
+        log.info("[메시지 전송 성공] 채팅방: {}, 사용자: {}, 메시지: {}", roomId, sender.getPersonName(), messageRequest.message());
+
+        return new ChatMessageRequest(
+                chatMessage.getId(),
+                chatMessage.getChatRoom().getId(),
+                sender.getPersonName(),
+                chatMessage.getMessage(),
+                chatMessage.getSendDate()
+        );
+
+    }
+}