Merge pull request #245 from BinaryStudioAcademy/task/OV-233-add-endp…

…oint-to-get-video-by-userid OV-233: Add endpoint to get video by userId
BinaryStudioAcademy · Sep 12, 2024 · 93d7f38 · 93d7f38
2 parents 4456f3e + 5c3477a
commit 93d7f38
Show file tree

Hide file tree

Showing 4 changed files with 32 additions and 4 deletions.
diff --git a/backend/src/bundles/videos/types/types.ts b/backend/src/bundles/videos/types/types.ts
@@ -1,6 +1,7 @@
 export {
     type CreateVideoRequestDto,
     type UpdateVideoRequestDto,
+    type UserGetCurrentResponseDto,
     type VideoGetAllItemResponseDto,
     type VideoGetAllResponseDto,
     type VideoGetOneRequestDto,

diff --git a/backend/src/bundles/videos/video.controller.ts b/backend/src/bundles/videos/video.controller.ts
@@ -12,6 +12,7 @@ import { VideosApiPath } from './enums/enums.js';
 import {
     type CreateVideoRequestDto,
     type UpdateVideoRequestDto,
+    type UserGetCurrentResponseDto,
     type VideoGetOneRequestDto,
 } from './types/types.js';
 import {
@@ -49,7 +50,12 @@ class VideoController extends BaseController {
         this.addRoute({
             path: VideosApiPath.ROOT,
             method: HTTPMethod.GET,
-            handler: () => this.findAll(),
+            handler: (options) =>
+                this.findAllByUser(
+                    options as ApiHandlerOptions<{
+                        user: UserGetCurrentResponseDto;
+                    }>,
+                ),
         });
 
         this.addRoute({
@@ -108,7 +114,7 @@ class VideoController extends BaseController {
      * @swagger
      * /videos/:
      *    get:
-     *      description: Get all videos
+     *      description: Get all videos by user
      *      security:
      *       - bearerAuth: []
      *      responses:
@@ -126,10 +132,14 @@ class VideoController extends BaseController {
      *                      $ref: '#/components/schemas/Video'
      */
 
-    private async findAll(): Promise<ApiHandlerResponse> {
+    private async findAllByUser(
+        options: ApiHandlerOptions<{
+            user: UserGetCurrentResponseDto;
+        }>,
+    ): Promise<ApiHandlerResponse> {
         return {
             status: HttpCode.OK,
-            payload: await this.videoService.findAll(),
+            payload: await this.videoService.findByUserId(options.user.id),
         };
     }
 

diff --git a/backend/src/bundles/videos/video.repository.ts b/backend/src/bundles/videos/video.repository.ts
@@ -16,6 +16,15 @@ class VideoRepository implements Repository {
         return video ? VideoEntity.initialize(video) : null;
     }
 
+    public async findByUserId(userId: string): Promise<VideoEntity[]> {
+        const videos = await this.videoModel
+            .query()
+            .where('userId', userId)
+            .execute();
+
+        return videos.map((it) => VideoEntity.initialize(it));
+    }
+
     public async findAll(): Promise<VideoEntity[]> {
         const videos = await this.videoModel.query().execute();
 

diff --git a/backend/src/bundles/videos/video.service.ts b/backend/src/bundles/videos/video.service.ts
@@ -31,6 +31,14 @@ class VideoService implements Service {
         return video.toObject();
     }
 
+    public async findByUserId(userId: string): Promise<VideoGetAllResponseDto> {
+        const items = await this.videoRepository.findByUserId(userId);
+
+        return {
+            items: items.map((it) => it.toObject()),
+        };
+    }
+
     public async findAll(): Promise<VideoGetAllResponseDto> {
         const items = await this.videoRepository.findAll();