refactor: [ALT-270] 채팅 개선 그룹 단톡·읽음처리·presence·이미지·RabbitMQ relay

.gitignore

@@ -58,3 +58,6 @@ CLAUDE.md
 .codex
 .agents/*
 AGENTS.md
+
+# graphify 지식그래프 산출물
+graphify-out/

build.gradle

@@ -51,6 +51,9 @@ dependencies {
 	implementation 'software.amazon.awssdk:s3:2.34.0'
 	implementation 'com.fasterxml.uuid:java-uuid-generator:5.1.0'
 
+	// STOMP broker relay (RabbitMQ) — 런타임 relay 연결용
+	implementation 'io.projectreactor.netty:reactor-netty'
+
 	compileOnly 'org.projectlombok:lombok'
 
 	developmentOnly 'org.springframework.boot:spring-boot-devtools'

src/main/java/com/dreamteam/alter/adapter/inbound/general/chat/controller/UserChatController.java

@@ -8,13 +8,18 @@
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.ChatRoomResponseDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomRequestDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomResponseDto;
+import com.dreamteam.alter.adapter.inbound.general.chat.dto.MarkChatRoomReadRequestDto;
 import com.dreamteam.alter.application.aop.AppActionContext;
+import com.dreamteam.alter.domain.auth.type.TokenScope;
 import com.dreamteam.alter.domain.chat.port.inbound.CreateOrGetChatRoomUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.GetChatMessagesUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.GetChatRoomInfoUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.GetMyChatRoomListUseCase;
+import com.dreamteam.alter.domain.chat.port.inbound.GetWorkspaceGroupChatRoomUseCase;
+import com.dreamteam.alter.domain.chat.port.inbound.MarkChatRoomReadUseCase;
 import com.dreamteam.alter.domain.user.context.AppActor;
 import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -40,6 +45,12 @@ public class UserChatController implements UserChatControllerSpec {
     @Resource(name = "getChatRoomInfo")
     private final GetChatRoomInfoUseCase getChatRoomInfo;
 
+    @Resource(name = "markChatRoomRead")
+    private final MarkChatRoomReadUseCase markChatRoomRead;
+
+    @Resource(name = "getWorkspaceGroupChatRoom")
+    private final GetWorkspaceGroupChatRoomUseCase getWorkspaceGroupChatRoom;
+
     @Override
     @PostMapping("/rooms")
     public ResponseEntity<CommonApiResponse<CreateChatRoomResponseDto>> createOrGetChatRoom(
@@ -78,4 +89,25 @@ public ResponseEntity<CursorPaginatedApiResponse<ChatMessageResponseDto>> getCha
         AppActor actor = AppActionContext.getInstance().getActor();
         return ResponseEntity.ok(getChatMessages.execute(actor, chatRoomId, pageRequest));
     }
+
+    @Override
+    @PostMapping("/rooms/{chatRoomId}/read")
+    public ResponseEntity<CommonApiResponse<Void>> markChatRoomRead(
+        @PathVariable Long chatRoomId,
+        @Valid @RequestBody MarkChatRoomReadRequestDto request
+    ) {
+        AppActor actor = AppActionContext.getInstance().getActor();
+        markChatRoomRead.execute(actor.getUserId(), TokenScope.APP, chatRoomId, request.getLastReadMessageId());
+        return ResponseEntity.ok(CommonApiResponse.empty());
+    }
+
+    @Override
+    @GetMapping("/workspace/{workspaceId}/room")
+    public ResponseEntity<CommonApiResponse<CreateChatRoomResponseDto>> getWorkspaceGroupChatRoom(
+        @PathVariable Long workspaceId
+    ) {
+        AppActor actor = AppActionContext.getInstance().getActor();
+        Long roomId = getWorkspaceGroupChatRoom.execute(actor.getUserId(), TokenScope.APP, workspaceId);
+        return ResponseEntity.ok(CommonApiResponse.of(CreateChatRoomResponseDto.of(roomId)));
+    }
 }

src/main/java/com/dreamteam/alter/adapter/inbound/general/chat/controller/UserChatControllerSpec.java

@@ -8,6 +8,7 @@
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.ChatRoomResponseDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomRequestDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomResponseDto;
+import com.dreamteam.alter.adapter.inbound.general.chat.dto.MarkChatRoomReadRequestDto;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.responses.ApiResponse;
 import io.swagger.v3.oas.annotations.responses.ApiResponses;
@@ -52,4 +53,21 @@ ResponseEntity<CursorPaginatedApiResponse<ChatMessageResponseDto>> getChatMessag
         @PathVariable Long chatRoomId,
         CursorPageRequestDto pageRequest
     );
+
+    @Operation(summary = "채팅방 읽음 처리", description = "특정 채팅방을 마지막으로 읽은 메시지까지 읽음 처리합니다.")
+    @ApiResponses(value = {
+        @ApiResponse(responseCode = "200", description = "읽음 처리 성공")
+    })
+    ResponseEntity<CommonApiResponse<Void>> markChatRoomRead(
+        @PathVariable Long chatRoomId,
+        @Valid @RequestBody MarkChatRoomReadRequestDto request
+    );
+
+    @Operation(summary = "업장 그룹 채팅방 조회", description = "업장의 그룹 채팅방 ID를 조회합니다. 해당 채팅방의 활성 멤버인 경우에만 조회됩니다.")
+    @ApiResponses(value = {
+        @ApiResponse(responseCode = "200", description = "업장 그룹 채팅방 조회 성공")
+    })
+    ResponseEntity<CommonApiResponse<CreateChatRoomResponseDto>> getWorkspaceGroupChatRoom(
+        @PathVariable Long workspaceId
+    );
 }

src/main/java/com/dreamteam/alter/adapter/inbound/general/chat/dto/ChatMessageResponseDto.java

@@ -1,12 +1,14 @@
 package com.dreamteam.alter.adapter.inbound.general.chat.dto;
 
 import com.dreamteam.alter.adapter.inbound.common.dto.DescribedEnumDto;
+import com.dreamteam.alter.adapter.inbound.common.dto.FileResponseDto;
 import com.dreamteam.alter.adapter.outbound.chat.persistence.readonly.ChatMessageResponse;
 import com.dreamteam.alter.domain.auth.type.TokenScope;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.*;
 
 import java.time.LocalDateTime;
+import java.util.List;
 
 @Getter
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
@@ -33,6 +35,12 @@ public class ChatMessageResponseDto {
     @Schema(description = "본인이 보낸 메시지 여부")
     private Boolean isMine;
 
+    @Schema(description = "안 읽은 사람 수")
+    private Integer unreadCount;
+
+    @Schema(description = "첨부 파일 목록")
+    private List<FileResponseDto> attachments;
+
     public static ChatMessageResponseDto from(ChatMessageResponse response) {
         return ChatMessageResponseDto.builder()
             .id(response.getId())
@@ -58,4 +66,25 @@ public static ChatMessageResponseDto from(ChatMessageResponse response, Long cur
             .build();
     }
 
+    public static ChatMessageResponseDto from(
+        ChatMessageResponse response,
+        Long currentUserId,
+        TokenScope currentUserScope,
+        Integer unreadCount
+    ) {
+        boolean isMine = response.getSenderId().equals(currentUserId)
+            && response.getSenderScope().equals(currentUserScope);
+
+        return ChatMessageResponseDto.builder()
+            .id(response.getId())
+            .senderId(response.getSenderId())
+            .senderScope(DescribedEnumDto.of(response.getSenderScope(), TokenScope.describe()))
+            .content(response.getContent())
+            .createdAt(response.getCreatedAt())
+            .isMine(isMine)
+            .unreadCount(unreadCount)
+            .attachments(response.getAttachments())
+            .build();
+    }
+
 }

src/main/java/com/dreamteam/alter/adapter/inbound/general/chat/dto/MarkChatRoomReadRequestDto.java

@@ -0,0 +1,19 @@
+package com.dreamteam.alter.adapter.inbound.general.chat.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@Schema(description = "채팅방 읽음 처리 요청 DTO")
+public class MarkChatRoomReadRequestDto {
+
+    @NotNull
+    @Schema(description = "마지막으로 읽은 메시지 ID")
+    private Long lastReadMessageId;
+
+}

src/main/java/com/dreamteam/alter/adapter/inbound/general/chat/dto/SendChatMessageRequestDto.java

@@ -1,15 +1,23 @@
 package com.dreamteam.alter.adapter.inbound.general.chat.dto;
 
+import com.dreamteam.alter.domain.chat.type.ChatMessageType;
 import io.swagger.v3.oas.annotations.media.Schema;
-import jakarta.validation.constraints.NotBlank;
+import java.util.List;
 import lombok.*;
 
 @Getter
 @NoArgsConstructor
 @AllArgsConstructor
 @Schema(description = "채팅 메시지 전송 요청 DTO")
 public class SendChatMessageRequestDto {
-    @NotBlank
+    public static final int MAX_ATTACHMENTS = 10;
+
     @Schema(description = "메시지 내용")
     private String content;
+
+    @Schema(description = "메시지 타입(NORMAL/NOTICE), 기본 NORMAL)")
+    private ChatMessageType type;
+
+    @Schema(description = "첨부 이미지 fileId 목록", example = "[\"...\"]")
+    private List<String> fileIds;
 }

src/main/java/com/dreamteam/alter/adapter/inbound/manager/chat/controller/ManagerChatController.java

@@ -8,13 +8,18 @@
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.ChatRoomResponseDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomRequestDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomResponseDto;
+import com.dreamteam.alter.adapter.inbound.general.chat.dto.MarkChatRoomReadRequestDto;
 import com.dreamteam.alter.application.aop.ManagerActionContext;
+import com.dreamteam.alter.domain.auth.type.TokenScope;
+import com.dreamteam.alter.domain.chat.port.inbound.GetWorkspaceGroupChatRoomUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.ManagerCreateOrGetChatRoomUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.ManagerGetChatMessagesUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.ManagerGetChatRoomUseCase;
 import com.dreamteam.alter.domain.chat.port.inbound.ManagerGetMyChatRoomListUseCase;
+import com.dreamteam.alter.domain.chat.port.inbound.MarkChatRoomReadUseCase;
 import com.dreamteam.alter.domain.user.context.ManagerActor;
 import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -40,6 +45,12 @@ public class ManagerChatController implements ManagerChatControllerSpec {
     @Resource(name = "managerGetChatRoom")
     private final ManagerGetChatRoomUseCase managerGetChatRoomUseCase;
 
+    @Resource(name = "markChatRoomRead")
+    private final MarkChatRoomReadUseCase markChatRoomRead;
+
+    @Resource(name = "getWorkspaceGroupChatRoom")
+    private final GetWorkspaceGroupChatRoomUseCase getWorkspaceGroupChatRoom;
+
     @Override
     @PostMapping("/rooms")
     public ResponseEntity<CommonApiResponse<CreateChatRoomResponseDto>> createOrGetChatRoom(
@@ -77,4 +88,25 @@ public ResponseEntity<CursorPaginatedApiResponse<ChatMessageResponseDto>> getCha
         ManagerActor actor = ManagerActionContext.getInstance().getActor();
         return ResponseEntity.ok(managerGetChatMessagesUseCase.execute(actor, chatRoomId, pageRequest));
     }
+
+    @Override
+    @PostMapping("/rooms/{chatRoomId}/read")
+    public ResponseEntity<CommonApiResponse<Void>> markChatRoomRead(
+        @PathVariable Long chatRoomId,
+        @Valid @RequestBody MarkChatRoomReadRequestDto request
+    ) {
+        ManagerActor actor = ManagerActionContext.getInstance().getActor();
+        markChatRoomRead.execute(actor.getUserId(), TokenScope.MANAGER, chatRoomId, request.getLastReadMessageId());
+        return ResponseEntity.ok(CommonApiResponse.empty());
+    }
+
+    @Override
+    @GetMapping("/workspace/{workspaceId}/room")
+    public ResponseEntity<CommonApiResponse<CreateChatRoomResponseDto>> getWorkspaceGroupChatRoom(
+        @PathVariable Long workspaceId
+    ) {
+        ManagerActor actor = ManagerActionContext.getInstance().getActor();
+        Long roomId = getWorkspaceGroupChatRoom.execute(actor.getUserId(), TokenScope.MANAGER, workspaceId);
+        return ResponseEntity.ok(CommonApiResponse.of(CreateChatRoomResponseDto.of(roomId)));
+    }
 }

src/main/java/com/dreamteam/alter/adapter/inbound/manager/chat/controller/ManagerChatControllerSpec.java

@@ -8,6 +8,7 @@
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.ChatRoomResponseDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomRequestDto;
 import com.dreamteam.alter.adapter.inbound.general.chat.dto.CreateChatRoomResponseDto;
+import com.dreamteam.alter.adapter.inbound.general.chat.dto.MarkChatRoomReadRequestDto;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.responses.ApiResponse;
 import io.swagger.v3.oas.annotations.responses.ApiResponses;
@@ -52,5 +53,22 @@ ResponseEntity<CursorPaginatedApiResponse<ChatMessageResponseDto>> getChatMessag
         @PathVariable Long chatRoomId,
         CursorPageRequestDto pageRequest
     );
+
+    @Operation(summary = "채팅방 읽음 처리", description = "특정 채팅방을 마지막으로 읽은 메시지까지 읽음 처리합니다.")
+    @ApiResponses(value = {
+        @ApiResponse(responseCode = "200", description = "읽음 처리 성공")
+    })
+    ResponseEntity<CommonApiResponse<Void>> markChatRoomRead(
+        @PathVariable Long chatRoomId,
+        @Valid @RequestBody MarkChatRoomReadRequestDto request
+    );
+
+    @Operation(summary = "업장 그룹 채팅방 조회", description = "업장의 그룹 채팅방 ID를 조회합니다. 해당 채팅방의 활성 멤버인 경우에만 조회됩니다.")
+    @ApiResponses(value = {
+        @ApiResponse(responseCode = "200", description = "업장 그룹 채팅방 조회 성공")
+    })
+    ResponseEntity<CommonApiResponse<CreateChatRoomResponseDto>> getWorkspaceGroupChatRoom(
+        @PathVariable Long workspaceId
+    );
 }
 

src/main/java/com/dreamteam/alter/adapter/outbound/chat/persistence/ChatRoomMemberJpaRepository.java

@@ -0,0 +1,7 @@
+package com.dreamteam.alter.adapter.outbound.chat.persistence;
+
+import com.dreamteam.alter.domain.chat.entity.ChatRoomMember;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ChatRoomMemberJpaRepository extends JpaRepository<ChatRoomMember, Long> {
+}

src/main/java/com/dreamteam/alter/adapter/outbound/chat/persistence/ChatRoomMemberQueryRepositoryImpl.java

@@ -0,0 +1,47 @@
+package com.dreamteam.alter.adapter.outbound.chat.persistence;
+
+import com.dreamteam.alter.domain.auth.type.TokenScope;
+import com.dreamteam.alter.domain.chat.entity.ChatRoomMember;
+import com.dreamteam.alter.domain.chat.entity.QChatRoomMember;
+import com.dreamteam.alter.domain.chat.port.outbound.ChatRoomMemberQueryRepository;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+@RequiredArgsConstructor
+public class ChatRoomMemberQueryRepositoryImpl implements ChatRoomMemberQueryRepository {
+
+    private final JPAQueryFactory queryFactory;
+
+    @Override
+    public List<ChatRoomMember> findActiveByRoom(Long chatRoomId) {
+        QChatRoomMember m = QChatRoomMember.chatRoomMember;
+        return queryFactory.selectFrom(m)
+            .where(m.chatRoomId.eq(chatRoomId), m.leftAt.isNull())
+            .fetch();
+    }
+
+    @Override
+    public Optional<ChatRoomMember> findByRoomAndMember(Long chatRoomId, Long memberId, TokenScope memberScope) {
+        QChatRoomMember m = QChatRoomMember.chatRoomMember;
+        return Optional.ofNullable(
+            queryFactory.selectFrom(m)
+                .where(m.chatRoomId.eq(chatRoomId), m.memberId.eq(memberId), m.memberScope.eq(memberScope))
+                .fetchOne()
+        );
+    }
+
+    @Override
+    public boolean existsActive(Long chatRoomId, Long memberId, TokenScope memberScope) {
+        QChatRoomMember m = QChatRoomMember.chatRoomMember;
+        Integer hit = queryFactory.selectOne().from(m)
+            .where(m.chatRoomId.eq(chatRoomId), m.memberId.eq(memberId),
+                m.memberScope.eq(memberScope), m.leftAt.isNull())
+            .fetchFirst();
+        return hit != null;
+    }
+}

src/main/java/com/dreamteam/alter/adapter/outbound/chat/persistence/ChatRoomMemberRepositoryImpl.java

@@ -0,0 +1,25 @@
+package com.dreamteam.alter.adapter.outbound.chat.persistence;
+
+import com.dreamteam.alter.domain.chat.entity.ChatRoomMember;
+import com.dreamteam.alter.domain.chat.port.outbound.ChatRoomMemberRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class ChatRoomMemberRepositoryImpl implements ChatRoomMemberRepository {
+
+    private final ChatRoomMemberJpaRepository jpaRepository;
+
+    @Override
+    public ChatRoomMember save(ChatRoomMember member) {
+        return jpaRepository.save(member);
+    }
+
+    @Override
+    public List<ChatRoomMember> saveAll(List<ChatRoomMember> members) {
+        return jpaRepository.saveAll(members);
+    }
+}