feat: add query transfom pipe

Author: mdwitr0

src/common/interfaces/query.interface.ts

@@ -0,0 +1,7 @@
+export interface IQuery {
+  query?: any;
+  sort?: any;
+  select?: any;
+  limit?: number;
+  skip?: number;
+}

src/common/pipes/query.pipe.ts

@@ -0,0 +1,86 @@
+import {
+  PipeTransform,
+  Injectable,
+  ArgumentMetadata,
+  BadRequestException,
+} from '@nestjs/common';
+import { Types } from 'mongoose';
+import { IQuery } from '../interfaces/query.interface';
+
+const SYSTEM_KEYS = [
+  'sortField',
+  'sortType',
+  'selectFields',
+  'page',
+  'limit',
+  'field',
+  'search',
+];
+
+@Injectable()
+export class QueryPipe implements PipeTransform {
+  transform(value: any, metadata: ArgumentMetadata): IQuery {
+    const query: any = {};
+    const sort: any = {};
+    const select: any = {};
+    let page = 1;
+    let limit = 10;
+
+    // Парсим параметры для поиска
+    if (value.search) {
+      if (Array.isArray(value.field) && Array.isArray(value.search)) {
+        value.field.forEach((field: string, index: number) => {
+          query[field] = value.search[index];
+        });
+      } else if (
+        typeof value.field === 'string' &&
+        typeof value.search === 'string'
+      ) {
+        query[value.field] = value.search;
+      } else {
+        throw new BadRequestException('Invalid search parameters');
+      }
+    }
+
+    // Парсим параметры для поиска
+    for (const [key, val] of Object.entries(value)) {
+      if (SYSTEM_KEYS.includes(key)) {
+        query[key] = val;
+      }
+    }
+
+    // Парсим параметры для сортировки
+    if (value.sortField) {
+      const fields = Array.isArray(value.sortField)
+        ? value.sortField
+        : [value.sortField];
+      const types = Array.isArray(value.sortType)
+        ? value.sortType
+        : [value.sortType];
+
+      fields.forEach((field: string, index: number) => {
+        sort[field] = types[index] === '1' ? 1 : -1;
+      });
+    }
+
+    // Парсим параметры для выбора полей
+    if (value.selectFields) {
+      const fields = Array.isArray(value.selectFields)
+        ? value.selectFields.join(' ')
+        : value.selectFields;
+      fields.split(' ').forEach((field: string) => {
+        select[field] = 1;
+      });
+    }
+
+    // Парсим параметры для пагинации
+    if (value.page) {
+      page = parseInt(value.page, 10);
+    }
+    if (value.limit) {
+      limit = parseInt(value.limit, 10);
+    }
+
+    return { query, sort, select, limit, skip: (page - 1) * limit };
+  }
+}

src/movie/movie.controller.ts

@@ -6,6 +6,7 @@ import {
   Query,
   SerializeOptions,
   UseInterceptors,
+  UsePipes,
 } from '@nestjs/common';
 import { MovieService } from './movie.service';
 import { ApiOperation, ApiResponse, ApiTags } from '@nestjs/swagger';
@@ -15,6 +16,7 @@ import { MovieDocsResponseDto } from './dto/movie-docs.response.dto';
 import { Movie } from './schemas/movie.schema';
 import { ToolsQueryDto } from '../common/dto/query/tools.query.dto';
 import { IFindManyMovie } from './interfaces/find-many-movie.interface';
+import { QueryPipe } from 'src/common/pipes/query.pipe';
 
 @UseInterceptors(ClassSerializerInterceptor)
 @SerializeOptions({ excludeExtraneousValues: true })
@@ -24,12 +26,15 @@ export class MovieController {
   constructor(private readonly movieService: MovieService) {}
 
   @Get()
+  @UsePipes(new QueryPipe())
   @ApiOperation({ summary: 'Поиск фильмов' })
   @ApiDotNotationQuery(ToolsQueryDto, PaginatedQueryDto, Movie)
   @ApiResponse({ type: MovieDocsResponseDto, isArray: true })
   async finManyByQuery(
     @Query() filters: IFindManyMovie,
   ): Promise<MovieDocsResponseDto> {
+    console.log(filters);
+
     return this.movieService.findMany(filters);
   }