Feedback

.gitignore

@@ -0,0 +1,8 @@
+node_modules
+dist
+
+.github
+
+.env
+backend/*/combined.log
+backend/*/error.log

.prettierrc

@@ -0,0 +1,6 @@
+{
+    "semi": false,
+    "singleQuote": true,
+    "tabWidth": 4,
+    "printWidth": 80
+}

README.md

@@ -1,7 +1,16 @@
+[![Review Assignment Due Date](https://classroom.github.com/assets/deadline-readme-button-22041afd0340ce965d47ae6ef1cefeee28c7c493a6346c4f15d667ab976d596c.svg)](https://classroom.github.com/a/bzPrOe11)
+
 # CS3219 Project (PeerPrep) - AY2425S1
-## Group: Gxx
 
-### Note: 
-- You can choose to develop individual microservices within separate folders within this repository **OR** use individual repositories (all public) for each microservice. 
-- In the latter scenario, you should enable sub-modules on this GitHub classroom repository to manage the development/deployment **AND** add your mentor to the individual repositories as a collaborator. 
-- The teaching team should be given access to the repositories as we may require viewing the history of the repository in case of any disputes or disagreements. 
+## Group: G18
+
+Ensure Docker has been installed before running the following commands:
+```
+docker-compose up --build
+```
+
+### Note:
+
+-   You can choose to develop individual microservices within separate folders within this repository **OR** use individual repositories (all public) for each microservice.
+-   In the latter scenario, you should enable sub-modules on this GitHub classroom repository to manage the development/deployment **AND** add your mentor to the individual repositories as a collaborator.
+-   The teaching team should be given access to the repositories as we may require viewing the history of the repository in case of any disputes or disagreements.

backend/code-execution-service/Dockerfile

@@ -0,0 +1,13 @@
+FROM node:20-alpine
+
+WORKDIR /app
+
+COPY package*.json ./
+
+RUN npm install
+
+COPY . .
+
+EXPOSE 5005
+
+CMD ["npm", "run", "dev"]

backend/code-execution-service/execute-code/executeCodeController.ts

@@ -0,0 +1,130 @@
+import axios from 'axios'
+import { Response } from 'express'
+import logger from '../utils/logger'
+import {
+    CodeExecutionRequest,
+    ExecutionResult,
+    TestCase,
+    languageExtensions,
+} from '../models/types'
+import {
+    formatTestInput,
+    countNumberOfPassedTestCases,
+    passedAllTestCases
+} from '../utils/utils'
+import { error } from 'winston'
+
+const executeUserCode = async (
+    req: CodeExecutionRequest,
+    res: Response,
+): Promise<Response> => {
+    const { questionId, code, language } = req.body
+
+    if (!questionId || !code || !language) {
+        return res
+            .status(400)
+            .json({ message: 'Question ID, code and language are required' })
+    }
+
+    let question: any
+    let testCases: TestCase[]
+    try {
+        const getQuestionRes = await axios.get(
+            `${process.env.QUESTION_SERVICE_URL}/get-questions`,
+            {
+                params: { questionId },
+                validateStatus: (status) => status >= 200 && status < 500,
+            },
+        )
+
+        if (!getQuestionRes.data || getQuestionRes.data.length === 0) {
+            logger.error('Question not found')
+            return res.status(400).json({ message: 'Question not found' })
+        }
+
+        question = getQuestionRes.data[0]
+        testCases = question.testCases
+    } catch (e) {
+        logger.error('Error fetching question details', e)
+        return res
+            .status(500)
+            .json({ message: 'Error fetching question details' })
+    }
+
+    const formattedInput = testCases
+        .map((tc) => formatTestInput(tc.input))
+        .join('\n')
+
+    const fileName = `q${questionId}.${languageExtensions.get(language == 'Cpp' ? 'c++' : language.toLowerCase())}`
+    let payload = {
+        language: language.toLowerCase(),
+        stdin: formattedInput,
+        files: [
+            {
+                name: fileName,
+                content: code,
+            },
+        ],
+        compileOnly: false,
+        wait: true,
+    }
+
+    try {
+        const executeCodeRes = await axios.post(
+            `${process.env.CODE_COMPILER_URL}`,
+            payload,
+            {
+                headers: {
+                    'Content-Type': 'application/json',
+                    'x-rapidapi-host': 'onecompiler-apis.p.rapidapi.com',
+                    'x-rapidapi-key': process.env.ACCESS_TOKEN,
+                },
+                validateStatus: (status) => status >= 200 && status < 500,
+            },
+        )
+
+        if (executeCodeRes.data.stderr) {
+            let errorMsg = executeCodeRes.data.stderr
+            console.log(errorMsg)
+            logger.error(
+                'Error appeared when executing code',
+                { error: errorMsg },
+            )
+            return res.status(400).json({
+                success: false,
+                error: executeCodeRes.data.stderr,
+                compilationOutput: executeCodeRes.data.compilationOutput,
+            })
+        }
+
+        const codeOutput = (executeCodeRes.data.stdout || '').trim().split('\n')
+        const results: ExecutionResult[] = testCases.map((tc, i) => ({
+            input: tc.input,
+            expected: tc.expected,
+            output: codeOutput[i]?.trim() || '',
+            passed: String(tc.expected) == codeOutput[i]?.trim(),
+        }))
+
+        const response = {
+            success: passedAllTestCases(results),
+            results,
+            testCasesPassed: countNumberOfPassedTestCases(results),
+            testCasesTotal: testCases.length,
+            compilationOutput: executeCodeRes.data.compilationOutput,
+            error: executeCodeRes.data.stderr,
+        }
+
+        const submissionOutcomeMsg = response.success
+            ? 'All test cases passed'
+            : 'Some test cases failed'
+        logger.info(`Code execution results: ${submissionOutcomeMsg}`)
+        return res.status(200).json(response)
+    } catch (e) {
+        logger.error('Error executing code', e)
+        return res
+            .status(500)
+            .json({ message: 'Error executing code with OneCompiler' })
+    }
+}
+
+export { executeUserCode }

backend/code-execution-service/execute-code/executeCodeRoute.ts

@@ -0,0 +1,7 @@
+import { RequestHandler, Router } from 'express'
+import { executeUserCode } from './executeCodeController'
+
+const router = Router()
+router.post('/execute-code', executeUserCode as unknown as RequestHandler)
+
+export { router }

backend/code-execution-service/get-code/getCodeController.ts

@@ -0,0 +1,19 @@
+import { Response } from "express"
+import Submission from "../models/submission"
+import logger from "../utils/logger"
+import { GetCodeRequest } from "../models/types"
+
+const getUserCode = async (req: GetCodeRequest, res: Response) => {
+    const { matchId } = req.params
+
+    try {
+        const submissions = await Submission.find({ matchId })
+        logger.info(`Successfully fetched submissions for match ${matchId}`)
+        return res.status(200).json(submissions)
+    } catch (e) {
+        logger.error(`Error fetching submissions for match ${matchId}`)
+        return res.status(500).json({ message: 'Error fetching submissions' })
+    }
+}
+
+export { getUserCode }

backend/code-execution-service/get-code/getCodeRoute.ts

@@ -0,0 +1,7 @@
+import { RequestHandler, Router } from 'express'
+import { getUserCode } from './getCodeController'
+
+const router = Router()
+router.get('/get-code/:matchId', getUserCode as unknown as RequestHandler)
+
+export { router }

backend/code-execution-service/models/submission.ts

@@ -0,0 +1,30 @@
+import { Schema, model, models, Document } from 'mongoose';
+
+export interface ISubmission extends Document {
+    matchId: string,
+    questionId: number
+    language: string
+    code: string
+    solved: boolean
+    testCasesPassed: number
+    testCasesTotal: number
+}   
+
+const SubmissionSchema = new Schema<ISubmission>(
+    {
+        matchId: { type: String, required: true, unique: true, index: true },
+        questionId: { type: Number, required: true, index: true },
+        language: { type: String, required: true },
+        code: { type: String, required: true, default: '' },
+        solved: { type: Boolean },
+        testCasesPassed: { type: Number, default: 0 },
+        testCasesTotal: { type: Number, default: 0 },
+    },
+    {
+        timestamps: true,
+    }
+);
+
+const Submission = models.Submission || model<ISubmission>('Submission', SubmissionSchema);
+
+export default Submission;

backend/code-execution-service/models/types.ts

@@ -0,0 +1,47 @@
+import  { Request, Response } from 'express'
+import { Types } from 'mongoose'
+
+export interface CodeExecutionRequest extends Request {
+    body: {
+        questionId: number
+        code: string
+        language: string
+    }
+}
+
+export interface CodeSubmissionRequest extends Request {
+    body: {
+        questionId: number
+        matchId: number
+        code: string
+        language: string
+    }
+}
+
+export interface GetCodeRequest extends Request {
+    params: {
+        matchId: string
+    }
+}
+
+export interface TestCase {
+    input: any
+    expected: any
+}
+
+export interface ExecutionResult {
+    input: any,
+    expected: any,
+    output: any
+    passed: boolean
+}
+
+export const languageExtensions = new Map([
+    ['javascript', 'js'],
+    ['python', 'py'],
+    ['java', 'java'],
+    ['c', 'c'],
+    ['c++', 'cpp'],
+    ['go', 'go'],
+    ['typescript', 'ts']
+])