feat(api): add questions voting (#409)

* feat(api): add questions voting

* refactor(api): refactor questions upvoting

* feat(openapi-types): generate new openapi types

Author: xStrixU

apps/api/modules/questions/questions.routes.ts

@@ -1,11 +1,15 @@
 import { TypeBoxTypeProvider } from "@fastify/type-provider-typebox";
-import { FastifyInstance, FastifyPluginAsync } from "fastify";
+import { FastifyPluginAsync } from "fastify";
+import { isPrismaError } from "../db/prismaErrors.util.js";
+import { PrismaErrorCode } from "../db/prismaErrors.js";
 import {
 	deleteQuestionByIdSchema,
 	generateGetQuestionsSchema,
 	generatePatchQuestionByIdSchema,
 	generatePostQuestionsSchema,
 	generateGetQuestionByIdSchema,
+	upvoteQuestionSchema,
+	downvoteQuestionSchema,
 } from "./questions.schemas.js";
 
 const questionsPlugin: FastifyPluginAsync = async (fastify) => {
@@ -251,6 +255,89 @@ const questionsPlugin: FastifyPluginAsync = async (fastify) => {
 			return reply.status(204);
 		},
 	});
+
+	fastify.withTypeProvider<TypeBoxTypeProvider>().route({
+		url: "/questions/:id/votes",
+		method: "POST",
+		schema: upvoteQuestionSchema,
+		async handler(request, reply) {
+			const {
+				params: { id },
+				session: { data: sessionData },
+			} = request;
+
+			if (!sessionData) {
+				throw fastify.httpErrors.unauthorized();
+			}
+
+			try {
+				const questionVote = await fastify.db.questionVote.upsert({
+					where: {
+						userId_questionId: {
+							userId: sessionData._user.id,
+							questionId: id,
+						},
+					},
+					update: {},
+					create: {
+						userId: sessionData._user.id,
+						questionId: id,
+					},
+				});
+
+				return {
+					data: {
+						userId: questionVote.userId,
+						questionId: questionVote.questionId,
+					},
+				};
+			} catch (err) {
+				if (isPrismaError(err)) {
+					switch (err.code) {
+						case PrismaErrorCode.ForeignKeyViolation:
+							throw fastify.httpErrors.notFound(`Question with id: ${id} not found!`);
+					}
+				}
+
+				throw err;
+			}
+		},
+	});
+
+	fastify.withTypeProvider<TypeBoxTypeProvider>().route({
+		url: "/questions/:id/votes",
+		method: "DELETE",
+		schema: downvoteQuestionSchema,
+		async handler(request, reply) {
+			const {
+				params: { id },
+				session: { data: sessionData },
+			} = request;
+
+			if (!sessionData) {
+				throw fastify.httpErrors.unauthorized();
+			}
+
+			const question = await fastify.db.question.findFirst({
+				where: {
+					id,
+				},
+			});
+
+			if (!question) {
+				throw fastify.httpErrors.notFound(`Question with id: ${id} not found!`);
+			}
+
+			await fastify.db.questionVote.deleteMany({
+				where: {
+					userId: sessionData._user.id,
+					questionId: id,
+				},
+			});
+
+			return reply.status(204).send();
+		},
+	});
 };
 
 export default questionsPlugin;

apps/api/modules/questions/questions.schemas.ts

@@ -166,3 +166,26 @@ export const deleteQuestionByIdSchema = {
 		id: Type.Integer(),
 	}),
 };
+
+export const upvoteQuestionSchema = {
+	params: Type.Object({
+		id: Type.Integer(),
+	}),
+	response: {
+		200: Type.Object({
+			data: Type.Object({
+				userId: Type.Integer(),
+				questionId: Type.Integer(),
+			}),
+		}),
+	},
+};
+
+export const downvoteQuestionSchema = {
+	params: Type.Object({
+		id: Type.Integer(),
+	}),
+	response: {
+		204: Type.Never(),
+	},
+};

packages/openapi-types/types.ts

@@ -216,6 +216,43 @@ export interface paths {
 			};
 		};
 	};
+	"/questions/{id}/votes": {
+		post: {
+			parameters: {
+				path: {
+					id: number;
+				};
+			};
+			responses: {
+				/** @description Default Response */
+				200: {
+					content: {
+						"application/json": {
+							data: {
+								userId: number;
+								questionId: number;
+							};
+						};
+					};
+				};
+			};
+		};
+		delete: {
+			parameters: {
+				path: {
+					id: number;
+				};
+			};
+			responses: {
+				/** @description Default Response */
+				204: {
+					content: {
+						"application/json": boolean & true;
+					};
+				};
+			};
+		};
+	};
 	"/": {
 		get: {
 			responses: {
@@ -233,7 +270,7 @@ export interface paths {
 export type webhooks = Record<string, never>;
 
 export interface components {
-	schemas: {};
+	schemas: never;
 	responses: never;
 	parameters: never;
 	requestBodies: never;