Merge branch 'dev' of github.com:Leon-OnlineLearning/Leon-Serverside …

…into dev

.gitignore

@@ -7,4 +7,5 @@ todo
 localhost.pem
 localhost-key.pem
 lectures/
-ormconfig.json
+ormconfig.json
+recordings/

controller/BusinessLogic/Event/Exam/exam-logic-impl.ts

@@ -2,7 +2,12 @@ import Exam from "@models/Events/Exam";
 import UserInputError from "@services/utils/UserInputError";
 import { getRepository } from "typeorm";
 import ExamsLogic from "./exam-logic";
+import { promises } from 'fs'
+const mkdir = promises.mkdir
+const appendFile = promises.appendFile
+import { join } from 'path'
 
+let upload_folder = process.env['UPLOADED_RECORDING_PATH'] || 'recordings';
 export default class ExamsLogicImpl implements ExamsLogic {
     async getExamById(examId: string): Promise<Exam> {
         const res = await getRepository(Exam).findOne(examId)
@@ -34,4 +39,12 @@ export default class ExamsLogicImpl implements ExamsLogic {
     async createExam(exam: Exam): Promise<Exam> {
         return await getRepository(Exam).save(exam)
     }
+    async saveRecording(chunk: Buffer, examId: string, userId: string): Promise<void> {
+        let video_dir = join(upload_folder, examId)
+
+        await mkdir(video_dir, { recursive: true })
+
+        // TODO make sure the chunk order is right
+        await appendFile(join(video_dir, `${userId}.webm`), chunk)
+    }
 }

controller/BusinessLogic/Event/Exam/exam-logic.ts

@@ -6,4 +6,5 @@ export default interface ExamsLogic {
     updateExam(examId: string, newData: Exam) : Promise<Exam>;
     deleteExamById(examId: string) : Promise<void>;
     getExamsByYear(year: number): Promise<Exam[]>;
+    saveRecording(chunk: Buffer, examId: string, userId: string) : Promise<void>;
 }

services/Routes/Event/Exam/index.ts

@@ -5,6 +5,8 @@ import ExamParser, { ExamRequest } from "@services/Routes/BodyParserMiddleware/E
 import ExamsLogic from "@controller/BusinessLogic/Event/Exam/exam-logic"
 import ExamsLogicImpl from "@controller/BusinessLogic/Event/Exam/exam-logic-impl"
 import simpleFinalMWDecorator from "@services/utils/RequestDecorator"
+import multer from "multer"
+import { onlyStudents } from "@services/Routes/User/AuthorizationMiddleware"
 
 const router = Router()
 
@@ -13,6 +15,26 @@ router.use(passport.authenticate('access-token', { session: false }))
 
 const parser: BodyParserMiddleware = new ExamParser()
 
+var storage = multer.memoryStorage();
+var upload = multer({ storage: storage });
+
+/**
+ * save exam recording
+ * 
+ * req body must contain
+ * - usedId 
+ * - examId
+ * - chunckIndex : number of current chunk
+ * - chuck : actual recorded chunk in webm format
+ // TODO add parser to validate the exam info fields
+ */
+router.put('/record',onlyStudents, upload.single('chuck'), async (req, res) => {
+    simpleFinalMWDecorator(res, async () => {
+        const logic: ExamsLogic = new ExamsLogicImpl()
+        await logic.saveRecording(req.file.buffer, req.body.examId, req.body.userId);
+    })
+})
+
 router.get('/:examId', async (req, res) => {
     simpleFinalMWDecorator(res, async () => {
         const logic: ExamsLogic = new ExamsLogicImpl()