feat: add admin dashboard for managing answers

.all-contributorsrc

@@ -117,14 +117,14 @@
       "login": "AdiPol1359",
       "name": "Adrian Polak",
       "avatar_url": "https://avatars.githubusercontent.com/u/27779154?v=4",
-      "profile": "https://projectcode.pl/",
+      "profile": "https://github.com/AdiPol1359",
       "contributions": [
         "code"
       ]
     },
     {
       "login": "xStrixU",
-      "name": "xStrixU",
+      "name": "Kacper Polak",
       "avatar_url": "https://avatars.githubusercontent.com/u/41890821?v=4",
       "profile": "https://github.com/xStrixU",
       "contributions": [

.vscode/settings.json

@@ -10,5 +10,9 @@
 		"titleBar.inactiveBackground": "#401886",
 		"titleBar.activeForeground": "#ffffff",
 		"titleBar.inactiveForeground": "#ffffff"
-	}
+	},
+	"[prisma]": {
+		"editor.defaultFormatter": "Prisma.prisma"
+	},
+	"prettier.configPath": "prettier.config.js"
 }

apps/api/modules/answers/answers.mapper.ts

@@ -6,13 +6,17 @@ export const dbAnswerToDto = ({
 	content,
 	sources,
 	createdAt,
+	QuestionAnswerVote,
 	CreatedBy: { socialLogin, ...createdBy },
-}: Prisma.QuestionAnswerGetPayload<{ select: typeof answerSelect }>) => {
+	_count,
+}: Prisma.QuestionAnswerGetPayload<{ select: ReturnType<typeof answerSelect> }>) => {
 	return {
 		id,
 		content,
 		sources,
 		createdAt: createdAt.toISOString(),
+		votesCount: _count.QuestionAnswerVote,
+		currentUserVotedOn: QuestionAnswerVote.length > 0,
 		createdBy: {
 			socialLogin: socialLogin as Record<string, string | number>,
 			...createdBy,

apps/api/modules/answers/answers.params.ts

@@ -0,0 +1,22 @@
+import { Prisma } from "@prisma/client";
+import { kv } from "../../utils.js";
+import { GetAnswersQuery } from "./answers.schemas";
+
+export const getAnswersPrismaParams = ({ limit, offset, order, orderBy }: GetAnswersQuery) => {
+	return {
+		take: limit,
+		skip: offset,
+		...(order &&
+			orderBy && {
+				orderBy: {
+					...(orderBy === "votesCount"
+						? {
+								QuestionAnswerVote: {
+									_count: order,
+								},
+						  }
+						: kv(orderBy, order)),
+				},
+			}),
+	} satisfies Prisma.QuestionAnswerFindManyArgs;
+};

apps/api/modules/answers/answers.routes.ts

@@ -4,22 +4,37 @@ import { FastifyPluginAsync, preHandlerAsyncHookHandler, preHandlerHookHandler }
 import { PrismaErrorCode } from "../db/prismaErrors.js";
 import { isPrismaError } from "../db/prismaErrors.util.js";
 import { dbAnswerToDto } from "./answers.mapper.js";
+import { getAnswersPrismaParams } from "./answers.params.js";
 import {
-	getAnswersSchema,
+	getAnswersRelatedToPostSchema,
 	createAnswerSchema,
 	deleteAnswerSchema,
 	updateAnswerSchema,
+	upvoteAnswerSchema,
+	getAnswersSchema,
 } from "./answers.schemas.js";
 
-export const answerSelect = {
-	id: true,
-	content: true,
-	sources: true,
-	createdAt: true,
-	CreatedBy: {
-		select: { id: true, firstName: true, lastName: true, socialLogin: true },
-	},
-} satisfies Prisma.QuestionAnswerSelect;
+export const answerSelect = (userId: number) => {
+	return {
+		id: true,
+		content: true,
+		sources: true,
+		createdAt: true,
+		CreatedBy: {
+			select: { id: true, firstName: true, lastName: true, socialLogin: true },
+		},
+		_count: {
+			select: {
+				QuestionAnswerVote: true,
+			},
+		},
+		QuestionAnswerVote: {
+			where: {
+				userId: userId,
+			},
+		},
+	} satisfies Prisma.QuestionAnswerSelect;
+};
 
 const answersPlugin: FastifyPluginAsync = async (fastify) => {
 	const checkAnswerUserHook: preHandlerAsyncHookHandler = async (request) => {
@@ -47,21 +62,72 @@ const answersPlugin: FastifyPluginAsync = async (fastify) => {
 	};
 
 	fastify.withTypeProvider<TypeBoxTypeProvider>().route({
-		url: "/questions/:id/answers",
+		url: "/answers",
 		method: "GET",
 		schema: getAnswersSchema,
+		async handler(request) {
+			const params = getAnswersPrismaParams(request.query);
+			const [total, answers] = await Promise.all([
+				fastify.db.questionAnswer.count(),
+				fastify.db.questionAnswer.findMany({
+					...params,
+					select: {
+						id: true,
+						content: true,
+						sources: true,
+						createdAt: true,
+						updatedAt: true,
+						CreatedBy: {
+							select: { id: true, firstName: true, lastName: true, socialLogin: true },
+						},
+						_count: {
+							select: {
+								QuestionAnswerVote: true,
+							},
+						},
+					},
+				}),
+			]);
+
+			return {
+				data: answers.map((a) => {
+					return {
+						id: a.id,
+						content: a.content,
+						sources: a.sources,
+						createdAt: a.createdAt.toISOString(),
+						updatedAt: a.createdAt.toISOString(),
+						createdBy: {
+							id: a.CreatedBy.id,
+							firstName: a.CreatedBy.firstName,
+							lastName: a.CreatedBy.lastName,
+							socialLogin: a.CreatedBy.socialLogin as Record<string, string | number>,
+						},
+						votesCount: a._count.QuestionAnswerVote,
+					};
+				}),
+				meta: { total },
+			};
+		},
+	});
+
+	fastify.withTypeProvider<TypeBoxTypeProvider>().route({
+		url: "/questions/:id/answers",
+		method: "GET",
+		schema: getAnswersRelatedToPostSchema,
 		async handler(request) {
 			const {
 				params: { id },
+				session: { data: sessionData },
 			} = request;
 
 			const answers = await fastify.db.questionAnswer.findMany({
 				where: { questionId: id },
-				select: answerSelect,
+				select: answerSelect(request.session.data?._user.id || 0),
 			});
 
 			return {
-				data: answers.map(dbAnswerToDto),
+				data: answers.map((answer) => dbAnswerToDto(answer)),
 			};
 		},
 	});
@@ -84,7 +150,7 @@ const answersPlugin: FastifyPluginAsync = async (fastify) => {
 			try {
 				const answer = await fastify.db.questionAnswer.create({
 					data: { questionId: id, createdById: sessionData._user.id, content, sources },
-					select: answerSelect,
+					select: answerSelect(request.session.data?._user.id || 0),
 				});
 
 				return { data: dbAnswerToDto(answer) };
@@ -109,12 +175,13 @@ const answersPlugin: FastifyPluginAsync = async (fastify) => {
 			const {
 				params: { id },
 				body: { content, sources },
+				session: { data: sessionData },
 			} = request;
 
 			const answer = await fastify.db.questionAnswer.update({
 				where: { id },
 				data: { content, sources },
-				select: answerSelect,
+				select: answerSelect(request.session.data?._user.id || 0),
 			});
 
 			return { data: dbAnswerToDto(answer) };
@@ -138,6 +205,89 @@ const answersPlugin: FastifyPluginAsync = async (fastify) => {
 			return reply.status(204).send();
 		},
 	});
+
+	fastify.withTypeProvider<TypeBoxTypeProvider>().route({
+		url: "/answers/:id/votes",
+		method: "POST",
+		schema: upvoteAnswerSchema,
+		async handler(request, reply) {
+			const {
+				params: { id },
+				session: { data: sessionData },
+			} = request;
+
+			if (!sessionData) {
+				throw fastify.httpErrors.unauthorized();
+			}
+
+			try {
+				const questionAnswerVote = await fastify.db.questionAnswerVote.upsert({
+					where: {
+						userId_questionAnswerId: {
+							userId: sessionData._user.id,
+							questionAnswerId: id,
+						},
+					},
+					create: {
+						userId: sessionData._user.id,
+						questionAnswerId: id,
+					},
+					update: {
+						userId: sessionData._user.id,
+						questionAnswerId: id,
+					},
+				});
+
+				return {
+					data: {
+						userId: sessionData._user.id,
+						answerId: id,
+					},
+				};
+			} catch (err) {
+				if (isPrismaError(err) && PrismaErrorCode.ForeignKeyViolation) {
+					throw fastify.httpErrors.notFound(`Answer vote with id: ${id} not found!`);
+				}
+
+				throw err;
+			}
+		},
+	});
+
+	fastify.withTypeProvider<TypeBoxTypeProvider>().route({
+		url: "/answers/:id/votes",
+		method: "DELETE",
+		schema: deleteAnswerSchema,
+		async handler(request, reply) {
+			const {
+				params: { id },
+				session: { data: sessionData },
+			} = request;
+
+			if (!sessionData) {
+				throw fastify.httpErrors.unauthorized();
+			}
+
+			const questionAnswer = await fastify.db.questionAnswer.findFirst({
+				where: {
+					id,
+				},
+			});
+
+			if (!questionAnswer) {
+				throw fastify.httpErrors.notFound(`Answer vote with id: ${id} not found!`);
+			}
+
+			await fastify.db.questionAnswerVote.deleteMany({
+				where: {
+					userId: sessionData._user.id,
+					questionAnswerId: id,
+				},
+			});
+
+			return reply.status(204).send();
+		},
+	});
 };
 
 export default answersPlugin;

apps/api/modules/answers/answers.schemas.ts

@@ -1,10 +1,12 @@
-import { Type } from "@sinclair/typebox";
+import { Static, Type } from "@sinclair/typebox";
 
 const answerSchema = Type.Object({
 	id: Type.Number(),
 	content: Type.String(),
 	sources: Type.Array(Type.String()),
 	createdAt: Type.String({ format: "date-time" }),
+	votesCount: Type.Integer(),
+	currentUserVotedOn: Type.Boolean(),
 	createdBy: Type.Object({
 		id: Type.Integer(),
 		firstName: Type.Union([Type.String(), Type.Null()]),
@@ -13,7 +15,7 @@ const answerSchema = Type.Object({
 	}),
 });
 
-export const getAnswersSchema = {
+export const getAnswersRelatedToPostSchema = {
 	params: Type.Object({
 		id: Type.Integer(),
 	}),
@@ -64,3 +66,68 @@ export const deleteAnswerSchema = {
 		204: Type.Never(),
 	},
 };
+
+export const upvoteAnswerSchema = {
+	params: Type.Object({
+		id: Type.Integer(),
+	}),
+	response: {
+		200: Type.Object({
+			data: Type.Object({
+				userId: Type.Integer(),
+				answerId: Type.Integer(),
+			}),
+		}),
+	},
+};
+
+export const downvoteAnswerSchema = {
+	params: Type.Object({
+		id: Type.Integer(),
+	}),
+	response: {
+		204: Type.Never(),
+	},
+};
+
+const generateGetAnswersQuerySchema = Type.Partial(
+	Type.Object({
+		limit: Type.Integer(),
+		offset: Type.Integer(),
+		orderBy: Type.Union([
+			Type.Literal("createdAt"),
+			Type.Literal("updatedAt"),
+			Type.Literal("votesCount"),
+		]),
+		order: Type.Union([Type.Literal("asc"), Type.Literal("desc")]),
+	}),
+);
+
+export const getAnswersSchema = {
+	querystring: generateGetAnswersQuerySchema,
+	response: {
+		200: Type.Object({
+			data: Type.Array(
+				Type.Object({
+					id: Type.Number(),
+					content: Type.String(),
+					sources: Type.Array(Type.String()),
+					createdAt: Type.String({ format: "date-time" }),
+					updatedAt: Type.String({ format: "date-time" }),
+					createdBy: Type.Object({
+						id: Type.Integer(),
+						firstName: Type.Union([Type.String(), Type.Null()]),
+						lastName: Type.Union([Type.String(), Type.Null()]),
+						socialLogin: Type.Record(Type.String(), Type.Union([Type.String(), Type.Number()])),
+					}),
+					votesCount: Type.Integer(),
+				}),
+			),
+			meta: Type.Object({
+				total: Type.Integer(),
+			}),
+		}),
+	},
+};
+
+export type GetAnswersQuery = Static<typeof generateGetAnswersQuerySchema>;