Feat/#33 notification

build.gradle

@@ -103,6 +103,9 @@ dependencies {
 	// Reactive 웹 프레임워크 WebFlux
 	implementation 'org.springframework.boot:spring-boot-starter-webflux'
 
+	// Email
+	implementation 'org.springframework.boot:spring-boot-starter-mail'
+
 	// test
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
 	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

src/main/java/com/teamEWSN/gitdeun/codereference/entity/CodeReference.java

@@ -1,6 +1,6 @@
 package com.teamEWSN.gitdeun.codereference.entity;
 
-import com.teamEWSN.gitdeun.mindmapnode.entity.MindmapNode;
+import com.teamEWSN.gitdeun.mindmap.entity.Mindmap;
 import jakarta.persistence.*;
 import lombok.AccessLevel;
 import lombok.Getter;
@@ -17,8 +17,8 @@ public class CodeReference {
     private Long id;
 
     @ManyToOne(fetch = FetchType.LAZY)
-    @JoinColumn(name = "node_id", nullable = false)
-    private MindmapNode node;
+    @JoinColumn(name = "mindmap_id", nullable = false)
+    private Mindmap mindmap;
 
     @Column(name = "file_path", columnDefinition = "TEXT", nullable = false)
     private String filePath;

src/main/java/com/teamEWSN/gitdeun/codereview/entity/CodeReview.java

@@ -1,7 +1,7 @@
 package com.teamEWSN.gitdeun.codereview.entity;
 
 import com.teamEWSN.gitdeun.common.util.AuditedEntity;
-import com.teamEWSN.gitdeun.mindmapnode.entity.MindmapNode;
+import com.teamEWSN.gitdeun.mindmap.entity.Mindmap;
 import com.teamEWSN.gitdeun.user.entity.User;
 import jakarta.persistence.*;
 import lombok.AccessLevel;
@@ -23,9 +23,9 @@ public class CodeReview extends AuditedEntity {
     @JoinColumn(name = "author_id", nullable = false)
     private User author;
 
-    @ManyToOne(fetch = FetchType.LAZY)
-    @JoinColumn(name = "node_id", nullable = false)
-    private MindmapNode node;
+    @OneToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "mindmap_id", nullable = false)
+    private Mindmap mindmap;
 
     @Column(name = "ref_id")
     private Long refId;

src/main/java/com/teamEWSN/gitdeun/common/exception/ErrorCode.java

@@ -51,7 +51,11 @@ public enum ErrorCode {
     INVITATION_ALREADY_EXISTS(HttpStatus.CONFLICT, "INVITE-003", "이미 초대 대기 중인 사용자입니다."),
     CANNOT_INVITE_SELF(HttpStatus.BAD_REQUEST, "INVITE-004", "자기 자신을 초대할 수 없습니다."),
     INVITATION_REJECTED_USER(HttpStatus.FORBIDDEN, "INVITE-005", "초대를 거절한 사용자이므로 초대할 수 없습니다."),
-
+
+    // 알림 관련
+    NOTIFICATION_NOT_FOUND(HttpStatus.NOT_FOUND, "NOTIFICATION-001", "알림을 찾을 수 없습니다."),
+    CANNOT_ACCESS_NOTIFICATION(HttpStatus.FORBIDDEN, "NOTIFICATION-002", "해당 알림에 접근할 권한이 없습니다."),
+
     // 방문기록 관련
     HISTORY_NOT_FOUND(HttpStatus.NOT_FOUND, "VISITHISTORY-001", "방문 기록을 찾을 수 없습니다."),
 

src/main/java/com/teamEWSN/gitdeun/common/fastapi/dto/AnalysisResultDto.java

@@ -8,8 +8,8 @@
 @Getter
 public class AnalysisResultDto {
     // FastAPI가 반환하는 Repo 관련 정보
+    private String language;
     private String defaultBranch;
-    private String description;
     private LocalDateTime githubLastUpdatedAt;
 
     // FastAPI가 반환하는 Mindmap 관련 정보

src/main/java/com/teamEWSN/gitdeun/invitation/service/InvitationService.java

@@ -16,6 +16,7 @@
 import com.teamEWSN.gitdeun.mindmapmember.entity.MindmapRole;
 import com.teamEWSN.gitdeun.mindmapmember.repository.MindmapMemberRepository;
 import com.teamEWSN.gitdeun.mindmapmember.service.MindmapAuthService;
+import com.teamEWSN.gitdeun.notification.service.NotificationService;
 import com.teamEWSN.gitdeun.user.entity.User;
 import com.teamEWSN.gitdeun.user.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
@@ -36,7 +37,7 @@ public class InvitationService {
     private final MindmapRepository mindmapRepository;
     private final MindmapMemberRepository mindmapMemberRepository;
     private final MindmapAuthService mindmapAuthService;
-    // private final NotificationService notificationService;
+    private final NotificationService notificationService;
     private final InvitationMapper invitationMapper;
 
     private static final String INVITATION_BASE_URL = "http://localhost:8080/invitations/";
@@ -90,7 +91,7 @@ public void inviteUserByEmail(Long mapId, InviteRequestDto requestDto, Long invi
         invitationRepository.save(invitation);
 
         // 알림 전송 + 이메일 전송
-        // notificationService.sendInvitation(invitation);
+        notificationService.notifyInvitation(invitation);
     }
 
     // 초대한 목록 조회(member)
@@ -125,7 +126,7 @@ public void acceptInvitation(Long invitationId, Long userId) {
         MindmapMember newMember = MindmapMember.of(newInvitation.getMindmap(), newInvitation.getInvitee(), newInvitation.getRole());
         mindmapMemberRepository.save(newMember);
 
-        // notificationService.sendAcceptance(invitation);
+        notificationService.notifyAcceptance(invitation);
     }
 
     // 초대 거절
@@ -144,7 +145,6 @@ public void rejectInvitation(Long invitationId, Long userId) {
         }
 
         invitation.reject();
-        // notificationService.sendRejection(invitation);
     }
 
     // 초대 링크 생성(owner)
@@ -197,7 +197,7 @@ public void acceptInvitationByLink(String token, Long userId) {
             .build();
         invitationRepository.save(updatedInvitation);
 
-        // notificationService.sendLinkApprovalRequest(invitation);
+        notificationService.notifyLinkApprovalRequest(invitation);
     }
 
     // 초대 링크 수락(owner)

src/main/java/com/teamEWSN/gitdeun/meeting/entity/Meeting.java

@@ -1,7 +1,7 @@
 package com.teamEWSN.gitdeun.meeting.entity;
 
 import com.teamEWSN.gitdeun.common.util.CreatedEntity;
-import com.teamEWSN.gitdeun.mindmapnode.entity.MindmapNode;
+import com.teamEWSN.gitdeun.mindmap.entity.Mindmap;
 import jakarta.persistence.*;
 import lombok.AccessLevel;
 import lombok.Getter;
@@ -21,8 +21,8 @@ public class Meeting extends CreatedEntity {
     private Long id;
 
     @OneToOne(fetch = FetchType.LAZY)
-    @JoinColumn(name = "node_id", nullable = false)
-    private MindmapNode node;
+    @JoinColumn(name = "mindmap_id", nullable = false)
+    private Mindmap mindmap;
 
     @Column(name = "room_name", length = 255, nullable = false)
     private String roomName;

src/main/java/com/teamEWSN/gitdeun/notification/controller/NotificationController.java

@@ -0,0 +1,56 @@
+package com.teamEWSN.gitdeun.notification.controller;
+
+import com.teamEWSN.gitdeun.common.jwt.CustomUserDetails;
+import com.teamEWSN.gitdeun.notification.dto.NotificationResponseDto;
+import com.teamEWSN.gitdeun.notification.dto.UnreadNotificationCountDto;
+import com.teamEWSN.gitdeun.notification.service.NotificationService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.web.PageableDefault;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/api/notifications")
+@RequiredArgsConstructor
+public class NotificationController {
+
+    private final NotificationService notificationService;
+
+    // 현재 사용자의 모든 알림 조회
+    @GetMapping
+    public ResponseEntity<Page<NotificationResponseDto>> getMyNotifications(
+        @AuthenticationPrincipal CustomUserDetails userDetails,
+        @PageableDefault(size = 10, sort = "createdAt,desc") Pageable pageable) {
+        Page<NotificationResponseDto> notifications = notificationService.getNotifications(userDetails.getId(), pageable);
+        return ResponseEntity.ok(notifications);
+    }
+
+    // 읽지 않은 알림 개수 조회
+    @GetMapping("/unread-count")
+    public ResponseEntity<UnreadNotificationCountDto> getUnreadNotificationCount(
+        @AuthenticationPrincipal CustomUserDetails userDetails) {
+        UnreadNotificationCountDto countDto = notificationService.getUnreadNotificationCount(userDetails.getId());
+        return ResponseEntity.ok(countDto);
+    }
+
+    // 알림 읽음 처리
+    @PatchMapping("/{notificationId}/read")
+    public ResponseEntity<Void> markNotificationAsRead(
+        @PathVariable Long notificationId,
+        @AuthenticationPrincipal CustomUserDetails userDetails) {
+        notificationService.markAsRead(notificationId, userDetails.getId());
+        return ResponseEntity.noContent().build();
+    }
+
+    // 알림 삭제
+    @DeleteMapping("/{notificationId}")
+    public ResponseEntity<Void> deleteNotification(
+        @PathVariable Long notificationId,
+        @AuthenticationPrincipal CustomUserDetails userDetails) {
+        notificationService.deleteNotification(notificationId, userDetails.getId());
+        return ResponseEntity.noContent().build();
+    }
+}

src/main/java/com/teamEWSN/gitdeun/notification/controller/NotificationSseController.java

@@ -0,0 +1,25 @@
+package com.teamEWSN.gitdeun.notification.controller;
+
+import com.teamEWSN.gitdeun.common.jwt.CustomUserDetails;
+import com.teamEWSN.gitdeun.notification.service.NotificationSseService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.MediaType;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+@RestController
+@RequestMapping("/api/notifications")
+@RequiredArgsConstructor
+public class NotificationSseController {
+
+    private final NotificationSseService notificationSseService;
+
+    // 클라이언트의 알림 구독
+    @GetMapping(value = "/subscribe", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter subscribe(@AuthenticationPrincipal CustomUserDetails userDetails) {
+        return notificationSseService.subscribe(userDetails.getId());
+    }
+}

src/main/java/com/teamEWSN/gitdeun/notification/dto/NotificationResponseDto.java

@@ -0,0 +1,17 @@
+package com.teamEWSN.gitdeun.notification.dto;
+
+import com.teamEWSN.gitdeun.notification.entity.NotificationType;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Builder
+public class NotificationResponseDto {
+    private Long notificationId;
+    private String message;
+    private boolean read;
+    private NotificationType notificationType;
+    private LocalDateTime createdAt;
+}