feat: read course (#77)

* feat: add read course

* fix: add course filtering

src/modules/courses/courses.controller.ts

@@ -1,4 +1,4 @@
-import { Controller, Get, Param, Query } from '@nestjs/common';
+import { Controller, Get, Param, Post, Query } from '@nestjs/common';
 import { session_userprofile } from '@prisma/client';
 import { GetUser } from 'src/common/decorators/get-user.decorator';
 import { Public } from 'src/common/decorators/skip-auth.decorator';
@@ -50,4 +50,12 @@ export class CourseController {
   ) {
     return await this.CoursesService.getReviewsByCourseId(query, id, user);
   }
+
+  @Post(':id/read')
+  async readCourse(
+    @Param('id') id: number,
+    @GetUser() user: session_userprofile,
+  ) {
+    await this.CoursesService.readCourse(user.id, id);
+  }
 }

src/modules/courses/courses.service.ts

@@ -2,6 +2,7 @@ import { Injectable, NotFoundException } from '@nestjs/common';
 import { session_userprofile } from '@prisma/client';
 import { ECourse } from 'src/common/entities/ECourse';
 import { ICourse } from 'src/common/interfaces';
+import { CourseQueryDto } from 'src/common/interfaces/dto/course/course.request.dto';
 import { CourseReviewQueryDto } from 'src/common/interfaces/dto/course/course.review.request.dto';
 import { toJsonLecture } from 'src/common/interfaces/serializer/lecture.serializer';
 import { toJsonReview } from 'src/common/interfaces/serializer/review.serializer';
@@ -15,7 +16,7 @@ export class CoursesService {
   constructor(private readonly CourseRepository: CourseRepository) {}
 
   public async getCourseByFilter(
-    query: any,
+    query: CourseQueryDto,
     user: session_userprofile,
   ): Promise<(CourseResponseDtoNested & { userspecific_is_read: boolean })[]> {
     const queryResult = await this.CourseRepository.filterByRequest(query);
@@ -32,9 +33,9 @@ export class CoursesService {
       );
 
       if (user) {
-        const latestReadDatetime = course.subject_courseuser.find(
-          (x) => (x.user_profile_id = user.id),
-        )?.latest_read_datetime;
+        const latestReadDatetime = course.subject_courseuser.find((x) => {
+          return x.user_profile_id === user.id && x.course_id === course.id;
+        })?.latest_read_datetime;
         const latestWrittenDatetime = course.latest_written_datetime;
         return Object.assign(result, {
           userspecific_is_read:
@@ -150,4 +151,8 @@ export class CoursesService {
         return professor.professor.professor_name_en;
     }
   }
+
+  async readCourse(userId: number, courseId: number) {
+    await this.CourseRepository.readCourse(userId, courseId);
+  }
 }

src/prisma/repositories/course.repository.ts

@@ -456,4 +456,24 @@ export class CourseRepository {
     });
     return candidate;
   }
+
+  async readCourse(userId: number, courseId: number) {
+    const now = new Date();
+    return await this.prisma.subject_courseuser.upsert({
+      create: {
+        latest_read_datetime: now,
+        user_profile_id: userId,
+        course_id: courseId,
+      },
+      update: {
+        latest_read_datetime: now,
+      },
+      where: {
+        course_id_user_profile_id: {
+          course_id: courseId,
+          user_profile_id: userId,
+        },
+      },
+    });
+  }
 }