/** * @copyright 2026 NHCarrigan * @license Naomi's Public License * @author Naomi Carrigan */ import { FastifyPluginAsync } from "fastify"; import { Show, CreateShowDto, UpdateShowDto, Comment, CreateCommentDto, AuditAction, AuditCategory } from "@library/shared-types"; import { ShowService } from "../../services/show.service"; import { CommentService } from "../../services/comment.service"; import { AuditService } from "../../services/audit.service"; import { adminGuard } from "../../middleware/admin-guard"; import { bannedGuard } from "../../middleware/banned-guard"; const showsRoutes: FastifyPluginAsync = async (app) => { const showService = new ShowService(); const commentService = new CommentService(); app.get<{ Reply: Show[] }>("/", async () => { return showService.getAllShows(); }); app.get<{ Params: { id: string }; Reply: Show | null }>( "/:id", async (request) => { const { id } = request.params; return showService.getShowById(id); } ); app.post<{ Body: CreateShowDto; Reply: Show }>( "/", { preValidation: [app.authenticate, adminGuard], preHandler: [app.csrfProtection], }, async (request) => { const show = await showService.createShow(request.body); await AuditService.logFromRequest(request, { action: AuditAction.ENTRY_CREATE, category: AuditCategory.CONTENT, resourceType: "show", resourceId: show.id, details: `Created show: ${show.title}`, }); return show; } ); app.put<{ Params: { id: string }; Body: UpdateShowDto; Reply: Show | null; }>( "/:id", { preValidation: [app.authenticate, adminGuard], preHandler: [app.csrfProtection], }, async (request) => { const { id } = request.params; const show = await showService.updateShow(id, request.body); if (show) { await AuditService.logFromRequest(request, { action: AuditAction.ENTRY_UPDATE, category: AuditCategory.CONTENT, resourceType: "show", resourceId: id, details: `Updated show: ${show.title}`, }); } return show; } ); app.delete<{ Params: { id: string }; Reply: { success: boolean } }>( "/:id", { preValidation: [app.authenticate, adminGuard], preHandler: [app.csrfProtection], }, async (request) => { const { id } = request.params; await showService.deleteShow(id); await AuditService.logFromRequest(request, { action: AuditAction.ENTRY_DELETE, category: AuditCategory.CONTENT, resourceType: "show", resourceId: id, details: `Deleted show with ID: ${id}`, }); return { success: true }; } ); app.get<{ Params: { id: string }; Reply: Comment[] }>( "/:id/comments", async (request) => { const { id } = request.params; return commentService.getCommentsForShow(id); } ); app.post<{ Params: { id: string }; Body: CreateCommentDto; Reply: Comment }>( "/:id/comments", { preValidation: [app.authenticate, bannedGuard], preHandler: [app.csrfProtection], }, async (request) => { const { id } = request.params; const userId = request.user.id; const comment = await commentService.createCommentForShow(id, userId, request.body); await AuditService.logFromRequest(request, { action: AuditAction.COMMENT_CREATE, category: AuditCategory.CONTENT, resourceType: "show", resourceId: id, details: `Added comment to show`, }); return comment; } ); app.put<{ Params: { id: string; commentId: string }; Body: CreateCommentDto; Reply: Comment | { error: string } }>( "/:id/comments/:commentId", { preValidation: [app.authenticate], preHandler: [app.csrfProtection], }, async (request, reply) => { const { id, commentId } = request.params; const userId = request.user.id; const isAdmin = request.user.isAdmin; const verification = await commentService.verifyCommentOwnership(commentId, "show", id); if (!verification.exists) { return reply.code(404).send({ error: "Comment not found" }); } if (verification.comment?.userId !== userId && !isAdmin) { return reply.code(403).send({ error: "You can only edit your own comments" }); } const comment = await commentService.updateComment(commentId, request.body.content); await AuditService.logFromRequest(request, { action: AuditAction.COMMENT_UPDATE, category: AuditCategory.CONTENT, resourceType: "show", resourceId: id, details: `Updated comment ${commentId} on show`, }); return comment; } ); app.delete<{ Params: { id: string; commentId: string }; Reply: { success: boolean } | { error: string } }>( "/:id/comments/:commentId", { preValidation: [app.authenticate], preHandler: [app.csrfProtection], }, async (request, reply) => { const { id, commentId } = request.params; const userId = request.user.id; const isAdmin = request.user.isAdmin; const verification = await commentService.verifyCommentOwnership(commentId, "show", id); if (!verification.exists) { return reply.code(404).send({ error: "Comment not found" }); } if (verification.comment?.userId !== userId && !isAdmin) { return reply.code(403).send({ error: "You can only delete your own comments" }); } await commentService.deleteComment(commentId); await AuditService.logFromRequest(request, { action: AuditAction.COMMENT_DELETE, category: isAdmin && verification.comment?.userId !== userId ? AuditCategory.ADMIN : AuditCategory.CONTENT, resourceType: "show", resourceId: id, details: `Deleted comment ${commentId} from show`, }); return { success: true }; } ); }; export default showsRoutes;