feat: add notification system

src/main/java/com/openisle/controller/AdminPostController.java

@@ -31,6 +31,11 @@ public class AdminPostController {
         return toDto(postService.approvePost(id));
     }
 
+    @PostMapping("/{id}/reject")
+    public PostDto reject(@PathVariable Long id) {
+        return toDto(postService.rejectPost(id));
+    }
+
     private PostDto toDto(Post post) {
         PostDto dto = new PostDto();
         dto.setId(post.getId());

src/main/java/com/openisle/controller/NotificationController.java

@@ -0,0 +1,62 @@
+package com.openisle.controller;
+
+import com.openisle.model.Notification;
+import com.openisle.model.NotificationType;
+import com.openisle.service.NotificationService;
+import lombok.Data;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.core.Authentication;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/** Endpoints for user notifications. */
+@RestController
+@RequestMapping("/api/notifications")
+@RequiredArgsConstructor
+public class NotificationController {
+    private final NotificationService notificationService;
+
+    @GetMapping
+    public List<NotificationDto> list(@RequestParam(value = "read", required = false) Boolean read,
+                                      Authentication auth) {
+        return notificationService.listNotifications(auth.getName(), read).stream()
+                .map(this::toDto)
+                .collect(Collectors.toList());
+    }
+
+    @PostMapping("/read")
+    public void markRead(@RequestBody MarkReadRequest req, Authentication auth) {
+        notificationService.markRead(auth.getName(), req.getIds());
+    }
+
+    private NotificationDto toDto(Notification n) {
+        NotificationDto dto = new NotificationDto();
+        dto.setId(n.getId());
+        dto.setType(n.getType());
+        dto.setPostId(n.getPost() != null ? n.getPost().getId() : null);
+        dto.setCommentId(n.getComment() != null ? n.getComment().getId() : null);
+        dto.setApproved(n.getApproved());
+        dto.setRead(n.isRead());
+        dto.setCreatedAt(n.getCreatedAt());
+        return dto;
+    }
+
+    @Data
+    private static class MarkReadRequest {
+        private List<Long> ids;
+    }
+
+    @Data
+    private static class NotificationDto {
+        private Long id;
+        private NotificationType type;
+        private Long postId;
+        private Long commentId;
+        private Boolean approved;
+        private boolean read;
+        private LocalDateTime createdAt;
+    }
+}

src/main/java/com/openisle/controller/PostController.java

@@ -44,8 +44,9 @@ public class PostController {
     }
 
     @GetMapping("/{id}")
-    public ResponseEntity<PostDto> getPost(@PathVariable Long id) {
+    public ResponseEntity<PostDto> getPost(@PathVariable Long id, Authentication auth) {
-        Post post = postService.getPost(id);
+        String viewer = auth != null ? auth.getName() : null;
+        Post post = postService.viewPost(id, viewer);
         return ResponseEntity.ok(toDto(post));
     }
 

src/main/java/com/openisle/model/Notification.java

@@ -0,0 +1,52 @@
+package com.openisle.model;
+
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+/**
+ * Entity representing a user notification.
+ */
+@Entity
+@Getter
+@Setter
+@NoArgsConstructor
+@Table(name = "notifications")
+public class Notification {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Enumerated(EnumType.STRING)
+    @Column(nullable = false)
+    private NotificationType type;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "user_id")
+    private User user;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "post_id")
+    private Post post;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "comment_id")
+    private Comment comment;
+
+    @Column
+    private Boolean approved;
+
+    @Column(nullable = false)
+    private boolean read = false;
+
+    @Column(nullable = false)
+    private LocalDateTime createdAt;
+
+    @PrePersist
+    protected void onCreate() {
+        this.createdAt = LocalDateTime.now();
+    }
+}

src/main/java/com/openisle/model/NotificationType.java

@@ -0,0 +1,15 @@
+package com.openisle.model;
+
+/**
+ * Types of user notifications.
+ */
+public enum NotificationType {
+    /** Someone viewed your post */
+    POST_VIEWED,
+    /** Someone replied to your post or comment */
+    COMMENT_REPLY,
+    /** Someone reacted to your post or comment */
+    REACTION,
+    /** Your post under review was approved or rejected */
+    POST_REVIEWED
+}

src/main/java/com/openisle/model/PostStatus.java

@@ -5,5 +5,6 @@ package com.openisle.model;
  */
 public enum PostStatus {
     PUBLISHED,
-    PENDING
+    PENDING,
+    REJECTED
 }

src/main/java/com/openisle/repository/NotificationRepository.java

@@ -0,0 +1,13 @@
+package com.openisle.repository;
+
+import com.openisle.model.Notification;
+import com.openisle.model.User;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+/** Repository for Notification entities. */
+public interface NotificationRepository extends JpaRepository<Notification, Long> {
+    List<Notification> findByUserOrderByCreatedAtDesc(User user);
+    List<Notification> findByUserAndReadOrderByCreatedAtDesc(User user, boolean read);
+}

src/main/java/com/openisle/service/CommentService.java

@@ -3,9 +3,11 @@ package com.openisle.service;
 import com.openisle.model.Comment;
 import com.openisle.model.Post;
 import com.openisle.model.User;
+import com.openisle.model.NotificationType;
 import com.openisle.repository.CommentRepository;
 import com.openisle.repository.PostRepository;
 import com.openisle.repository.UserRepository;
+import com.openisle.service.NotificationService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -19,6 +21,7 @@ public class CommentService {
     private final CommentRepository commentRepository;
     private final PostRepository postRepository;
     private final UserRepository userRepository;
+    private final NotificationService notificationService;
 
     public Comment addComment(String username, Long postId, String content) {
         User author = userRepository.findByUsername(username)
@@ -29,7 +32,11 @@ public class CommentService {
         comment.setAuthor(author);
         comment.setPost(post);
         comment.setContent(content);
-        return commentRepository.save(comment);
+        comment = commentRepository.save(comment);
+        if (!author.getId().equals(post.getAuthor().getId())) {
+            notificationService.createNotification(post.getAuthor(), NotificationType.COMMENT_REPLY, post, comment, null);
+        }
+        return comment;
     }
 
     public Comment addReply(String username, Long parentId, String content) {
@@ -42,7 +49,11 @@ public class CommentService {
         comment.setPost(parent.getPost());
         comment.setParent(parent);
         comment.setContent(content);
-        return commentRepository.save(comment);
+        comment = commentRepository.save(comment);
+        if (!author.getId().equals(parent.getAuthor().getId())) {
+            notificationService.createNotification(parent.getAuthor(), NotificationType.COMMENT_REPLY, parent.getPost(), comment, null);
+        }
+        return comment;
     }
 
     public List<Comment> getCommentsForPost(Long postId) {

src/main/java/com/openisle/service/NotificationService.java

@@ -0,0 +1,48 @@
+package com.openisle.service;
+
+import com.openisle.model.*;
+import com.openisle.repository.NotificationRepository;
+import com.openisle.repository.UserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/** Service for creating and retrieving notifications. */
+@Service
+@RequiredArgsConstructor
+public class NotificationService {
+    private final NotificationRepository notificationRepository;
+    private final UserRepository userRepository;
+
+    public Notification createNotification(User user, NotificationType type, Post post, Comment comment, Boolean approved) {
+        Notification n = new Notification();
+        n.setUser(user);
+        n.setType(type);
+        n.setPost(post);
+        n.setComment(comment);
+        n.setApproved(approved);
+        return notificationRepository.save(n);
+    }
+
+    public List<Notification> listNotifications(String username, Boolean read) {
+        User user = userRepository.findByUsername(username)
+                .orElseThrow(() -> new IllegalArgumentException("User not found"));
+        if (read == null) {
+            return notificationRepository.findByUserOrderByCreatedAtDesc(user);
+        }
+        return notificationRepository.findByUserAndReadOrderByCreatedAtDesc(user, read);
+    }
+
+    public void markRead(String username, List<Long> ids) {
+        User user = userRepository.findByUsername(username)
+                .orElseThrow(() -> new IllegalArgumentException("User not found"));
+        List<Notification> notifs = notificationRepository.findAllById(ids);
+        for (Notification n : notifs) {
+            if (n.getUser().getId().equals(user.getId())) {
+                n.setRead(true);
+            }
+        }
+        notificationRepository.saveAll(notifs);
+    }
+}

src/main/java/com/openisle/service/PostService.java

@@ -5,6 +5,7 @@ import com.openisle.model.PostStatus;
 import com.openisle.model.PublishMode;
 import com.openisle.model.User;
 import com.openisle.model.Category;
+import com.openisle.model.NotificationType;
 import com.openisle.repository.PostRepository;
 import com.openisle.repository.UserRepository;
 import com.openisle.repository.CategoryRepository;
@@ -23,17 +24,20 @@ public class PostService {
     private final CategoryRepository categoryRepository;
     private final TagRepository tagRepository;
     private final PublishMode publishMode;
+    private final NotificationService notificationService;
 
     @org.springframework.beans.factory.annotation.Autowired
     public PostService(PostRepository postRepository,
                        UserRepository userRepository,
                        CategoryRepository categoryRepository,
                        TagRepository tagRepository,
+                       NotificationService notificationService,
                        @Value("${app.post.publish-mode:DIRECT}") PublishMode publishMode) {
         this.postRepository = postRepository;
         this.userRepository = userRepository;
         this.categoryRepository = categoryRepository;
         this.tagRepository = tagRepository;
+        this.notificationService = notificationService;
         this.publishMode = publishMode;
     }
 
@@ -63,14 +67,18 @@ public class PostService {
         return postRepository.save(post);
     }
 
-    public Post getPost(Long id) {
+    public Post viewPost(Long id, String viewer) {
         Post post = postRepository.findById(id)
                 .orElseThrow(() -> new IllegalArgumentException("Post not found"));
         if (post.getStatus() != PostStatus.PUBLISHED) {
             throw new IllegalArgumentException("Post not found");
         }
         post.setViews(post.getViews() + 1);
-        return postRepository.save(post);
+        post = postRepository.save(post);
+        if (viewer != null && !viewer.equals(post.getAuthor().getUsername())) {
+            notificationService.createNotification(post.getAuthor(), NotificationType.POST_VIEWED, post, null, null);
+        }
+        return post;
     }
 
     public List<Post> listPosts() {
@@ -137,6 +145,17 @@ public class PostService {
         Post post = postRepository.findById(id)
                 .orElseThrow(() -> new IllegalArgumentException("Post not found"));
         post.setStatus(PostStatus.PUBLISHED);
-        return postRepository.save(post);
+        post = postRepository.save(post);
+        notificationService.createNotification(post.getAuthor(), NotificationType.POST_REVIEWED, post, null, true);
+        return post;
+    }
+
+    public Post rejectPost(Long id) {
+        Post post = postRepository.findById(id)
+                .orElseThrow(() -> new IllegalArgumentException("Post not found"));
+        post.setStatus(PostStatus.REJECTED);
+        post = postRepository.save(post);
+        notificationService.createNotification(post.getAuthor(), NotificationType.POST_REVIEWED, post, null, false);
+        return post;
     }
 }

src/main/java/com/openisle/service/ReactionService.java

@@ -5,10 +5,12 @@ import com.openisle.model.Post;
 import com.openisle.model.Reaction;
 import com.openisle.model.ReactionType;
 import com.openisle.model.User;
+import com.openisle.model.NotificationType;
 import com.openisle.repository.CommentRepository;
 import com.openisle.repository.PostRepository;
 import com.openisle.repository.ReactionRepository;
 import com.openisle.repository.UserRepository;
+import com.openisle.service.NotificationService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -19,6 +21,7 @@ public class ReactionService {
     private final UserRepository userRepository;
     private final PostRepository postRepository;
     private final CommentRepository commentRepository;
+    private final NotificationService notificationService;
 
     public Reaction reactToPost(String username, Long postId, ReactionType type) {
         User user = userRepository.findByUsername(username)
@@ -30,7 +33,11 @@ public class ReactionService {
         reaction.setUser(user);
         reaction.setPost(post);
         reaction.setType(type);
-        return reactionRepository.save(reaction);
+        reaction = reactionRepository.save(reaction);
+        if (!user.getId().equals(post.getAuthor().getId())) {
+            notificationService.createNotification(post.getAuthor(), NotificationType.REACTION, post, null, null);
+        }
+        return reaction;
     }
 
     public Reaction reactToComment(String username, Long commentId, ReactionType type) {
@@ -44,7 +51,11 @@ public class ReactionService {
         reaction.setComment(comment);
         reaction.setPost(null);
         reaction.setType(type);
-        return reactionRepository.save(reaction);
+        reaction = reactionRepository.save(reaction);
+        if (!user.getId().equals(comment.getAuthor().getId())) {
+            notificationService.createNotification(comment.getAuthor(), NotificationType.REACTION, null, comment, null);
+        }
+        return reaction;
     }
 
     public java.util.List<Reaction> getReactionsForPost(Long postId) {