Function createCommentHandler

src/actions/comment/index.ts:133–244

(
  data: InputTypeCreateComment,
)

  return segments;
};
const createCommentHandler = async (
  data: InputTypeCreateComment,
): Promise<ReturnTypeCreateComment> => {
  const session = await getServerSession(authOptions);

  if (!session || !session.user) {
    return { error: 'Unauthorized or insufficient permissions' };
  }

  const { content, contentId, parentId } = data;
  const userId = session.user.id;

  if (!rateLimit(userId)) {
    return { error: 'Rate limit exceeded. Please try again later.' };
  }

  try {
    // Check if the parent comment exists and is a top-level comment
    // Only top-level comments can have replies like youtube comments otherwise it would be a thread
    let parentComment;
    if (parentId) {
      parentComment = await prisma.comment.findUnique({
        where: { id: parentId },
      });

      if (!parentComment) {
        return { error: 'Parent comment not found.' };
      }

      if (parentComment.parentId) {
        return { error: 'Cannot reply to a nested comment.' };
      }
    }

    // Check if the related content exists and is not a folder
    // We only allow comments on videos and Notion pages
    const relatedContent = await prisma.content.findUnique({
      where: { id: contentId },
    });

    if (!relatedContent || relatedContent.type === 'folder') {
      return { error: 'Invalid content for commenting.' };
    }
    let comment;
    if (parentComment) {
      await prisma.$transaction(async (prisma) => {
        comment = await prisma.comment.create({
          data: {
            content,
            contentId,
            parentId, // undefined if its a comment without parent (top level)
            userId,
          },
        });
        await prisma.comment.update({
          where: { id: parentId },
          data: {
            repliesCount: { increment: 1 },