kr-phim/server/api/comments/index.get.ts

import { eq, and, desc, sql, or, isNull } from 'drizzle-orm'
import { comments, users, commentVotes } from '../../database/schema'

export default defineEventHandler(async (event) => {
  const query = getQuery(event)
  const { source = '', slug, userId, limit = '20', offset = '0' } = query
  const pageLimit = Math.min(Math.max(Number(limit), 1), 100)
  const pageOffset = Math.max(Number(offset), 0)

  if (!slug) {
    throw createError({ statusCode: 400, message: 'Thiếu slug phim' })
  }

  const db = useDb()

  const whereConditions = [
    eq(comments.slug, String(slug)),
    isNull(comments.parentId),
  ]

  if (source) {
    whereConditions.push(eq(comments.source, String(source)))
  }

  // Count total comments
  const [{ count }] = await db
    .select({ count: sql<number>`count(*)` })
    .from(comments)
    .where(and(...whereConditions))

  // Fetch pinned comments first, then regular ones
  const results = await db
    .select({
      id: comments.id,
      userId: comments.userId,
      userName: users.name,
      userAvatar: users.avatar,
      userRole: users.role,
      userGender: users.gender,
      source: comments.source,
      slug: comments.slug,
      movieName: comments.movieName,
      content: comments.content,
      pinned: comments.pinned,
      spoiler: comments.spoiler,
      anonymous: comments.anonymous,
      likeCount: comments.likeCount,
      dislikeCount: comments.dislikeCount,
      createdAt: comments.createdAt,
    })
    .from(comments)
    .leftJoin(users, eq(comments.userId, users.id))
    .where(and(...whereConditions))
    .orderBy(sql`${comments.pinned} DESC, ${comments.createdAt} DESC`)
    .limit(pageLimit)
    .offset(pageOffset)

  const commentIds = results.map(r => r.id)

  let userVotes: Record<number, number> = {}
  if (userId && commentIds.length > 0) {
    const votes = await db
      .select()
      .from(commentVotes)
      .where(and(
        eq(commentVotes.userId, Number(userId)),
        or(...commentIds.map(id => eq(commentVotes.commentId, id)))
      ))
    userVotes = Object.fromEntries(votes.map(v => [v.commentId, v.vote]))
  }

  function mapReply(rep: any) {
    return {
      id: rep.id,
      userId: rep.userId,
      userName: rep.userName || 'Ẩn danh',
      userAvatar: rep.userAvatar,
      userRole: rep.userRole,
      userGender: rep.userGender,
      parentId: rep.parentId,
      content: rep.content,
      pinned: rep.pinned || false,
      spoiler: rep.spoiler || false,
      anonymous: rep.anonymous || false,
      likeCount: rep.likeCount,
      dislikeCount: rep.dislikeCount,
      createdAt: rep.createdAt,
      userVote: userVotes[rep.id] || 0,
      replies: [],
    }
  }

  async function fetchRepliesByParentIds(parentIds: number[]): Promise<any[]> {
    if (parentIds.length === 0) return []
    const fetched = await db
      .select({
        id: comments.id,
        userId: comments.userId,
        userName: users.name,
        userAvatar: users.avatar,
        userRole: users.role,
        userGender: users.gender,
        parentId: comments.parentId,
        content: comments.content,
        pinned: comments.pinned,
        spoiler: comments.spoiler,
        anonymous: comments.anonymous,
        likeCount: comments.likeCount,
        dislikeCount: comments.dislikeCount,
        createdAt: comments.createdAt,
      })
      .from(comments)
      .leftJoin(users, eq(comments.userId, users.id))
      .where(
        and(
          or(...parentIds.map(id => eq(comments.parentId, id)))
        )
      )
      .orderBy(comments.createdAt)
    return fetched
  }

  let allReplies: any[] = []
  if (commentIds.length > 0) {
    let currentParentIds = [...commentIds]
    const maxDepth = 10
    let depth = 0
    while (currentParentIds.length > 0 && depth < maxDepth) {
      const replies = await fetchRepliesByParentIds(currentParentIds)
      if (replies.length === 0) break
      allReplies = allReplies.concat(replies)
      currentParentIds = replies.map(r => r.id)
      depth++
    }
  }

  const repliesByParent: Record<number, any[]> = {}
  for (const reply of allReplies) {
    const parentId = reply.parentId!
    if (!repliesByParent[parentId]) {
      repliesByParent[parentId] = []
    }
    repliesByParent[parentId].push(mapReply(reply))
  }

  function attachChildren(mappedReply: any): any {
    const children = repliesByParent[mappedReply.id] || []
    return {
      ...mappedReply,
      replies: children.map(attachChildren),
    }
  }

  return {
    items: results.map(r => ({
      ...r,
      userName: r.userName || 'Ẩn danh',
      userAvatar: r.userAvatar,
      pinned: r.pinned || false,
      spoiler: r.spoiler || false,
      anonymous: r.anonymous || false,
      userVote: userVotes[r.id] || 0,
      replies: (repliesByParent[r.id] || []).map(attachChildren),
    })),
    total: Number(count),
  }
})