import { unlink } from 'node:fs/promises'
import { join } from 'node:path'
import { eq, inArray } from 'drizzle-orm'
import { commentAttachments, comments, uploads } from '../../db/schema'

const ID_RE = /^[A-Za-z0-9]{1,16}$/

export default defineEventHandler(async (event) => {
  const actor = await requirePermission(event, 'upload.delete')
  const body = await readBody<{ ids?: unknown }>(event)
  const raw = Array.isArray(body?.ids) ? body.ids : []
  const ids = [...new Set(raw.filter((x): x is string => typeof x === 'string' && ID_RE.test(x)))].slice(0, 200)
  if (!ids.length) {
    throw createError({ statusCode: 400, statusMessage: 'Keine Uploads ausgewählt' })
  }

  const db = useDb()
  const rows = await db
    .select({ id: uploads.id, fileName: uploads.fileName, previewImage: uploads.previewImage })
    .from(uploads)
    .where(inArray(uploads.id, ids))
  if (!rows.length) return { ok: true, deleted: 0 }

  const found = rows.map(r => r.id)
  const attachmentFiles = await db
    .select({ fileName: commentAttachments.fileName, cover: commentAttachments.cover })
    .from(commentAttachments)
    .innerJoin(comments, eq(commentAttachments.commentId, comments.id))
    .where(inArray(comments.uploadId, found))

  await db.delete(uploads).where(inArray(uploads.id, found))

  for (const r of rows) {
    if (r.fileName) {
      await unlink(join(uploadDir(), r.fileName)).catch(() => {})
    }
    if (r.previewImage?.startsWith('/uploads/')) {
      await unlink(join(process.cwd(), 'public', r.previewImage)).catch(() => {})
    }
  }
  for (const f of attachmentFiles) {
    await unlink(join(uploadDir(), 'attachments', f.fileName)).catch(() => {})
    if (f.cover) {
      await unlink(join(process.cwd(), 'public', f.cover)).catch(() => {})
    }
  }
  broadcastToAll({ type: 'upload-deleted', ids: found })
  await logAudit(actor.id, 'bulk_delete_uploads', null, { ids: found, count: found.length })
  return { ok: true, deleted: found.length }
})