Refactor question controller and services

This commit refactors the question controller and services in the backend. It introduces new functions for creating, updating, and deleting questions. The code changes include adding new imports, defining new payload interfaces, and implementing the corresponding service functions. This refactoring improves the organization and maintainability of the codebase.

Author: anunayajoshi

backend/question/src/controller/question-controller.ts

@@ -7,6 +7,17 @@ import {
   getRandomQuestionService,
   searchQuestionsByTitleService,
 } from '@/services/get/index';
+import {
+  ICreateQuestionPayload,
+  IDeleteQuestionPayload,
+  IUpdateQuestionPayload,
+} from '../services/post/types';
+
+import {
+  createQuestionService,
+  deleteQuestionService,
+  updateQuestionService,
+} from '../services/post';
 import type {
   IGetQuestionsPayload,
   IGetQuestionPayload,
@@ -87,6 +98,52 @@ export const searchQuestionsByTitle = async (req: Request, res: Response): Promi
   try {
     const result = await searchQuestionsByTitleService(title.toString(), page, limit);
     return res.status(result.code).json(result);
+  } catch (error) {
+    return res.status(500).json({ success: false, message: 'An error occurred', error });
+  }
+};
+
+export const createQuestion = async (req: Request, res: Response): Promise<Response> => {
+  const payload: ICreateQuestionPayload = {
+    title: req.body.title,
+    description: req.body.description,
+    difficulty: req.body.difficulty,
+    topics: req.body.topics,
+  };
+
+  try {
+    const result = await createQuestionService(payload);
+    return res.status(result.code).json(result);
+  } catch (error) {
+    return res.status(500).json({ success: false, message: 'An error occurred', error });
+  }
+};
+
+export const updateQuestion = async (req: Request, res: Response): Promise<Response> => {
+  const payload: IUpdateQuestionPayload = {
+    id: parseInt(req.params.questionId),
+    title: req.body.title,
+    description: req.body.description,
+    difficulty: req.body.difficulty,
+    topics: req.body.topics,
+  };
+
+  try {
+    const result = await updateQuestionService(payload);
+    return res.status(result.code).json(result);
+  } catch (error) {
+    return res.status(500).json({ success: false, message: 'An error occurred', error });
+  }
+};
+
+export const deleteQuestion = async (req: Request, res: Response): Promise<Response> => {
+  const payload: IDeleteQuestionPayload = {
+    id: parseInt(req.params.questionId),
+  };
+
+  try {
+    const result = await deleteQuestionService(payload);
+    return res.status(result.code).json(result);
   } catch (error) {
     return res
       .status(StatusCodes.INTERNAL_SERVER_ERROR)

backend/question/src/routes/question.ts

@@ -5,6 +5,9 @@ import {
   getQuestions,
   getQuestionDetails,
   getRandomQuestion,
+  createQuestion,
+  updateQuestion,
+  deleteQuestion,
 } from '@/controller/question-controller';
 
 const router = Router();
@@ -17,4 +20,8 @@ router.get('/:questionId', getQuestionDetails);
 
 router.post('/random', getRandomQuestion);
 
+router.post('/questions', createQuestion);
+router.put('/questions/:questionId', updateQuestion);
+router.delete('/questions/:questionId', deleteQuestion);
+
 export default router;

backend/question/src/services/post/index.ts

@@ -0,0 +1,65 @@
+import { db } from '../../lib/db/index';
+import { eq } from 'drizzle-orm';
+import { questions } from '../../lib/db/schema';
+import { ICreateQuestionPayload, IUpdateQuestionPayload, IDeleteQuestionPayload } from './types';
+
+export const createQuestionService = async (payload: ICreateQuestionPayload) => {
+  try {
+    const [newQuestion] = await db
+      .insert(questions)
+      .values({
+        title: payload.title,
+        description: payload.description,
+        difficulty: payload.difficulty,
+        topic: payload.topics.map(String),
+      })
+      .returning();
+
+    return { success: true, code: 201, data: newQuestion };
+  } catch (error) {
+    console.error('Error creating question:', error);
+    return { success: false, code: 500, message: 'Failed to create question' };
+  }
+};
+
+export const updateQuestionService = async (payload: IUpdateQuestionPayload) => {
+  try {
+    const [updatedQuestion] = await db
+      .update(questions)
+      .set({
+        title: payload.title,
+        description: payload.description,
+        difficulty: payload.difficulty,
+        topic: payload.topics.map(String),
+      })
+      .where(eq(questions.id, String(payload.id)))
+      .returning();
+
+    if (!updatedQuestion) {
+      return { success: false, code: 404, message: 'Question not found' };
+    }
+
+    return { success: true, code: 200, data: updatedQuestion };
+  } catch (error) {
+    console.error('Error updating question:', error);
+    return { success: false, code: 500, message: 'Failed to update question' };
+  }
+};
+
+export const deleteQuestionService = async (payload: IDeleteQuestionPayload) => {
+  try {
+    const [deletedQuestion] = await db
+      .delete(questions)
+      .where(eq(questions.id, String(payload.id)))
+      .returning();
+
+    if (!deletedQuestion) {
+      return { success: false, code: 404, message: 'Question not found' };
+    }
+
+    return { success: true, code: 200, message: 'Question deleted successfully' };
+  } catch (error) {
+    console.error('Error deleting question:', error);
+    return { success: false, code: 500, message: 'Failed to delete question' };
+  }
+};

backend/question/src/services/post/types.ts

@@ -0,0 +1,14 @@
+export interface ICreateQuestionPayload {
+  title: string;
+  description: string;
+  difficulty: string;
+  topics: number[];
+}
+
+export interface IUpdateQuestionPayload extends ICreateQuestionPayload {
+  id: number;
+}
+
+export interface IDeleteQuestionPayload {
+  id: number;
+}