Изучаем NestJS: примеры и инструкции для серверной разработки

Расширенные примеры кода для NestJS

Ниже приведены углублённые примеры, которые помогут освоить более редкие сценарии.

1. Пример создания полноценного CRUD с пагинацией и фильтрацией

Сервис Users с методами findAll с пагинацией (page, limit) и фильтром по имени:

import { Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { User } from './entities/user.entity';
import { CreateUserDto } from './dto/create-user.dto';

@Injectable()
export class UsersService {
  constructor(
    @InjectRepository(User)
    private usersRepository: Repository,
  ) {}

  async findAll(page: number = 1, limit: number = 10, name?: string) {
    const query = this.usersRepository.createQueryBuilder('user');
    if (name) {
      query.where('user.name LIKE :name', { name: `%${name}%` });
    }
    const total = await query.getCount();
    const users = await query.skip((page - 1) * limit).take(limit).getMany();
    return { data: users, total, page, limit };
  }

  async create(createUserDto: CreateUserDto) {
    const user = this.usersRepository.create(createUserDto);
    return this.usersRepository.save(user);
  }
}

Запрос через curl:

curl "http://localhost:3000/users?page=1&limit=5&name=john"

Ответ:
{
  "data": [
    {
      "id": 1,
      "name": "John Doe",
      "email": "john@example.com",
      "createdAt": "2025-03-01T12:00:00.000Z"
    }
  ],
  "total": 1,
  "page": 1,
  "limit": 5
}

2. Использование декоратора @UseInterceptors для логирования

Создадим интерсептор, который логирует время выполнения запроса:

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable } from 'rxjs';
import { tap } from 'rxjs/operators';

@Injectable()
export class LoggingInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable {
    const now = Date.now();
    return next.handle().pipe(
      tap(() => console.log(`Request took ${Date.now() - now}ms`)),
    );
  }
}

Применяем интерсептор к контроллеру:

import { Controller, Get, UseInterceptors } from '@nestjs/common';
import { LoggingInterceptor } from './logging.interceptor';

@Controller('users')
@UseInterceptors(LoggingInterceptor)
export class UsersController {
  @Get()
  findAll() {
    return [];
  }
}

Результат в консоли сервера:

Request took 12ms

3. Настройка глобального фильтра исключений

Создадим фильтр, который форматирует ошибки в едином формате:

import { ExceptionFilter, Catch, ArgumentsHost, HttpException } from '@nestjs/common';
import { Response } from 'express';

@Catch(HttpException)
export class HttpExceptionFilter implements ExceptionFilter {
  catch(exception: HttpException, host: ArgumentsHost) {
    const ctx = host.switchToHttp();
    const response = ctx.getResponse<Response>();
    const status = exception.getStatus();
    const message = exception.getResponse();

    response.status(status).json({
      statusCode: status,
      timestamp: new Date().toISOString(),
      message: typeof message === 'string' ? message : (message as any).message,
    });
  }
}

Подключаем глобально в main.ts:

import { HttpExceptionFilter } from './filters/http-exception.filter';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  app.useGlobalFilters(new HttpExceptionFilter());
  await app.listen(3000);
}

Результат (например, при обращении к несуществующему роуту):

{
  "statusCode": 404,
  "timestamp": "2025-03-01T14:30:00.000Z",
  "message": "Cannot GET /nonexistent"
}

4. Пример миграции TypeORM с помощью CLI

Настроим синхронизацию через миграции. Сначала изменяем app.module.ts, убираем synchronize.

TypeOrmModule.forRoot({
  type: 'postgres',
  host: 'localhost',
  port: 5432,
  username: 'user',
  password: 'pass',
  database: 'test',
  entities: [__dirname + '/**/*.entity{.ts,.js}'],
  migrations: [__dirname + '/migrations/*{.ts,.js}'],
  cli: {
    migrationsDir: 'src/migrations',
  },
})

Создаём миграцию:

npx ts-node node_modules/.bin/typeorm migration:create -n AddUserAge

Редактируем миграционный файл:

import { MigrationInterface, QueryRunner, TableColumn } from 'typeorm';

export class AddUserAge1234567890 implements MigrationInterface {
  public async up(queryRunner: QueryRunner): Promise<void> {
    await queryRunner.addColumn('user', new TableColumn({
      name: 'age',
      type: 'int',
      isNullable: true,
    }));
  }

  public async down(queryRunner: QueryRunner): Promise<void> {
    await queryRunner.dropColumn('user', 'age');
  }
}

Запускаем миграцию:

npx ts-node node_modules/.bin/typeorm migration:run

Результат в консоли:

Migration AddUserAge1234567890 has been executed successfully.