jiazhizhong/OpenIsle
1
0
Fork 0
mirror of https://github.com/nagisa77/OpenIsle.git synced 2026-02-19 05:21:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: add debug logging for comments

Browse Source
This commit is contained in:
Tim
2025-08-04 12:06:51 +08:00
parent 9b840ca769
commit 8a2adc5632
5 changed files with 67 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
backend/src/main/java/com/openisle/service/CommentService.java
View File

@@ -16,6 +16,7 @@ import com.openisle.service.SubscriptionService;
import com.openisle.model.Role;
import com.openisle.exception.RateLimitException;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.List;
@@ -25,6 +26,7 @@ import org.springframework.transaction.annotation.Transactional;
@Service
@RequiredArgsConstructor
@Slf4j
public class CommentService {
private final CommentRepository commentRepository;
private final PostRepository postRepository;
@@ -38,9 +40,11 @@ public class CommentService {
@Transactional
public Comment addComment(String username, Long postId, String content) {
log.debug("addComment called by user {} for post {}", username, postId);
long recent = commentRepository.countByAuthorAfter(username,
java.time.LocalDateTime.now().minusMinutes(1));
if (recent >= 3) {
log.debug("Rate limit exceeded for user {}", username);
throw new RateLimitException("Too many comments");
}
User author = userRepository.findByUsername(username)
@@ -52,6 +56,7 @@ public class CommentService {
comment.setPost(post);
comment.setContent(content);
comment = commentRepository.save(comment);
log.debug("Comment {} saved for post {}", comment.getId(), postId);
imageUploader.addReferences(imageUploader.extractUrls(content));
if (!author.getId().equals(post.getAuthor().getId())) {
notificationService.createNotification(post.getAuthor(), NotificationType.COMMENT_REPLY, post, comment, null, null, null, null);
@@ -67,14 +72,17 @@ public class CommentService {
}
}
notificationService.notifyMentions(content, author, post, comment);
log.debug("addComment finished for comment {}", comment.getId());
return comment;
}
@Transactional
public Comment addReply(String username, Long parentId, String content) {
log.debug("addReply called by user {} for parent comment {}", username, parentId);
long recent = commentRepository.countByAuthorAfter(username,
java.time.LocalDateTime.now().minusMinutes(1));
if (recent >= 3) {
log.debug("Rate limit exceeded for user {}", username);
throw new RateLimitException("Too many comments");
}
User author = userRepository.findByUsername(username)
@@ -87,6 +95,7 @@ public class CommentService {
comment.setParent(parent);
comment.setContent(content);
comment = commentRepository.save(comment);
log.debug("Reply {} saved for parent {}", comment.getId(), parentId);
imageUploader.addReferences(imageUploader.extractUrls(content));
if (!author.getId().equals(parent.getAuthor().getId())) {
notificationService.createNotification(parent.getAuthor(), NotificationType.COMMENT_REPLY, parent.getPost(), comment, null, null, null, null);
@@ -107,10 +116,12 @@ public class CommentService {
}
}
notificationService.notifyMentions(content, author, parent.getPost(), comment);
log.debug("addReply finished for comment {}", comment.getId());
return comment;
}
public List<Comment> getCommentsForPost(Long postId, CommentSort sort) {
log.debug("getCommentsForPost called for post {} with sort {}", postId, sort);
Post post = postRepository.findById(postId)
.orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
List<Comment> list = commentRepository.findByPostAndParentIsNullOrderByCreatedAtAsc(post);
@@ -119,56 +130,76 @@ public class CommentService {
} else if (sort == CommentSort.MOST_INTERACTIONS) {
list.sort((a, b) -> Integer.compare(interactionCount(b), interactionCount(a)));
}
log.debug("getCommentsForPost returning {} comments", list.size());
return list;
}
public List<Comment> getReplies(Long parentId) {
log.debug("getReplies called for parent {}", parentId);
Comment parent = commentRepository.findById(parentId)
.orElseThrow(() -> new IllegalArgumentException("Comment not found"));
return commentRepository.findByParentOrderByCreatedAtAsc(parent);
List<Comment> replies = commentRepository.findByParentOrderByCreatedAtAsc(parent);
log.debug("getReplies returning {} replies for parent {}", replies.size(), parentId);
return replies;
}
public List<Comment> getRecentCommentsByUser(String username, int limit) {
log.debug("getRecentCommentsByUser called for user {} with limit {}", username, limit);
User user = userRepository.findByUsername(username)
.orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
Pageable pageable = PageRequest.of(0, limit);
return commentRepository.findByAuthorOrderByCreatedAtDesc(user, pageable);
List<Comment> comments = commentRepository.findByAuthorOrderByCreatedAtDesc(user, pageable);
log.debug("getRecentCommentsByUser returning {} comments for user {}", comments.size(), username);
return comments;
}
public java.util.List<User> getParticipants(Long postId, int limit) {
log.debug("getParticipants called for post {} with limit {}", postId, limit);
Post post = postRepository.findById(postId)
.orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
java.util.LinkedHashSet<User> set = new java.util.LinkedHashSet<>();
set.add(post.getAuthor());
set.addAll(commentRepository.findDistinctAuthorsByPost(post));
java.util.List<User> list = new java.util.ArrayList<>(set);
return list.subList(0, Math.min(limit, list.size()));
java.util.List<User> result = list.subList(0, Math.min(limit, list.size()));
log.debug("getParticipants returning {} users for post {}", result.size(), postId);
return result;
}
public java.util.List<Comment> getCommentsByIds(java.util.List<Long> ids) {
return commentRepository.findAllById(ids);
log.debug("getCommentsByIds called for ids {}", ids);
java.util.List<Comment> comments = commentRepository.findAllById(ids);
log.debug("getCommentsByIds returning {} comments", comments.size());
return comments;
}
public java.time.LocalDateTime getLastCommentTime(Long postId) {
log.debug("getLastCommentTime called for post {}", postId);
Post post = postRepository.findById(postId)
.orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
return commentRepository.findLastCommentTime(post);
java.time.LocalDateTime time = commentRepository.findLastCommentTime(post);
log.debug("getLastCommentTime for post {} is {}", postId, time);
return time;
}
@Transactional
public void deleteComment(String username, Long id) {
log.debug("deleteComment called by user {} for comment {}", username, id);
User user = userRepository.findByUsername(username)
.orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
Comment comment = commentRepository.findById(id)
.orElseThrow(() -> new IllegalArgumentException("Comment not found"));
if (!user.getId().equals(comment.getAuthor().getId()) && user.getRole() != Role.ADMIN) {
log.debug("User {} not authorized to delete comment {}", username, id);
throw new IllegalArgumentException("Unauthorized");
}
deleteCommentCascade(comment);
log.debug("deleteComment completed for comment {}", id);
}
@Transactional
public void deleteCommentCascade(Comment comment) {
log.debug("deleteCommentCascade called for comment {}", comment.getId());
List<Comment> replies = commentRepository.findByParentOrderByCreatedAtAsc(comment);
for (Comment c : replies) {
deleteCommentCascade(c);
@@ -178,6 +209,7 @@ public class CommentService {
notificationRepository.deleteAll(notificationRepository.findByComment(comment));
imageUploader.removeReferences(imageUploader.extractUrls(comment.getContent()));
commentRepository.delete(comment);
log.debug("deleteCommentCascade removed comment {}", comment.getId());
}
private int interactionCount(Comment comment) {