test: create first tests

Author: deal-machine

jest.config.js

@@ -14,7 +14,7 @@ module.exports = {
     collectCoverageFrom: [
     "**/*.(t|j)s"
     ],
-    coverageDirectory: "../coverage",
+    coverageDirectory: "./coverage",
     "moduleNameMapper": {
         "^src/(.*)$": "<rootDir>/$1"
       }

package.json

@@ -11,8 +11,7 @@
     "start:debug": "nest start --debug --watch",
     "start:prod": "node dist/main",
     "lint": "eslint \"{src,apps,libs,test}/**/*.ts\" --fix",
-    "test": "cross-env NODE_ENV=test jest",
-    "test:coverage": "cross-env NODE_ENV=test jest --coverage"
+    "test": "cross-env NODE_ENV=test jest"
   },
   "engines": {
     "node": ">=18.16.0",

src/external/adapters/checkout/order.controller.ts

@@ -1,30 +1,37 @@
 import { Controller, Post, Body, Get, Param, Query } from '@nestjs/common';
-import { OrdersService } from './order.service';
+import { ApiBody, ApiOperation, ApiResponse, ApiTags } from '@nestjs/swagger';
+import { responseError } from 'src/external/infra/errors/reponse.error';
+import {
+  CreateOrderSwagger,
+  CreatedOrderSwagger,
+} from 'src/internal/application/docs/swagger/checkout/create-order.dto';
 import { CreateOrderDto } from 'src/internal/domain/checkout/dto/create-order.dto';
+
 import { ProductsService } from '../product/product.service';
-import { responseError } from 'src/external/infra/errors/reponse.error';
-import { ApiBody, ApiOperation, ApiResponse, ApiTags } from '@nestjs/swagger';
-import { CreateOrderSwagger, CreatedOrderSwagger } from 'src/internal/application/docs/swagger/checkout/create-order.dto';
+import { OrdersService } from './order.service';
 
 @ApiTags('Order')
 @Controller('orders')
 export class OrderController {
-
   constructor(
     private readonly ordersService: OrdersService,
     private readonly productsService: ProductsService,
   ) {}
 
   @ApiOperation({ summary: 'Create Order' })
   @ApiBody({ type: CreateOrderSwagger })
-  @ApiResponse({ status: 201, description: 'Order successfully created.', type: CreatedOrderSwagger  })
+  @ApiResponse({
+    status: 201,
+    description: 'Order successfully created.',
+    type: CreatedOrderSwagger,
+  })
   @Post()
   async create(@Body() createOrderDto: CreateOrderDto) {
     try {
       await this.productsService.verifyProductQuantity(createOrderDto.products);
       return this.ordersService.create(createOrderDto);
-    } catch (err: any) {
-      responseError(err);
+    } catch (err) {
+      return responseError(err);
     }
   }
 
@@ -34,8 +41,8 @@ export class OrderController {
   prepare(@Param('orderId') orderId: string) {
     try {
       return this.ordersService.prepare(orderId);
-    } catch (err: any) {
-      responseError(err);
+    } catch (err) {
+      return responseError(err);
     }
   }
 
@@ -45,8 +52,8 @@ export class OrderController {
   withdrawn(@Param('orderId') orderId: string) {
     try {
       return this.ordersService.withdrawn(orderId);
-    } catch (err: any) {
-      responseError(err);
+    } catch (err) {
+      return responseError(err);
     }
   }
 
@@ -59,8 +66,8 @@ export class OrderController {
   ) {
     try {
       return this.ordersService.findAll(customerId, status);
-    } catch (err: any) {
-      responseError(err);
+    } catch (err) {
+      return responseError(err);
     }
   }
 }

src/external/adapters/checkout/order.module.ts

@@ -1,19 +1,20 @@
-import { Module } from '@nestjs/common';
-import { SequelizeModule } from '@nestjs/sequelize';
 import { BullModule } from '@nestjs/bull';
-import { OrderController } from './order.controller';
-import { OrdersService } from './order.service';
+import { Module } from '@nestjs/common';
 import { EventEmitter2 } from '@nestjs/event-emitter';
+import { SequelizeModule } from '@nestjs/sequelize';
 import { Uuid } from 'src/external/infra/tokens/uuid/uuid';
-import { PublishOrderRequestListener } from './bullmq/listeners/publish-order-request.listener';
+
+import { ProductsService } from '../product/product.service';
+import { ProductSequelizeRepository } from '../product/sequelize/product-sequelize.repository';
+import { ProductModel } from '../product/sequelize/product.model';
 import { OrderConsumer } from './bullmq/consumers/order.consumer';
 import { ChangeOrderStatusListener } from './bullmq/listeners/change-order-status.listener';
-import { OrderSequelizeRepository } from './sequelize/order-sequelize.repository';
+import { PublishOrderRequestListener } from './bullmq/listeners/publish-order-request.listener';
+import { OrderController } from './order.controller';
+import { OrdersService } from './order.service';
 import { OrderItemModel } from './sequelize/order-item-model';
 import { OrderModel } from './sequelize/order-model';
-import { ProductsService } from '../product/product.service';
-import { ProductSequelizeRepository } from '../product/sequelize/product-sequelize.repository';
-import { ProductModel } from '../product/sequelize/product.model';
+import { OrderSequelizeRepository } from './sequelize/order-sequelize.repository';
 
 @Module({
   imports: [

src/external/adapters/checkout/order.service.ts

@@ -23,9 +23,9 @@ export class OrdersService {
   ) {}
 
   async create(createOrderDto: CreateOrderDto) {
-    const products = createOrderDto.products;
+    const { products } = createOrderDto;
 
-    const orderItems = products.map((product) => {
+    const orderItems = products.map(product => {
       return new OrderItem({
         id: this.idGenerator.generate(),
         productId: product.id,

src/external/adapters/customer/customer.controller.ts

@@ -1,24 +1,41 @@
-import { Controller, Post, Body } from '@nestjs/common';
-import { CustomersService } from './customer.service';
-import { CreateCustomerDto } from 'src/internal/domain/customers/dto/create-customer.dto';
-import { responseError } from 'src/external/infra/errors/reponse.error';
+import { Controller, Post, Body, Get, Param } from '@nestjs/common';
 import { ApiBody, ApiOperation, ApiResponse, ApiTags } from '@nestjs/swagger';
-import { CreatedCustomerSwagger, CreateCustomerSwagger } from 'src/internal/application/docs/swagger/customers/create-customer.dto';
+import { responseError } from 'src/external/infra/errors/reponse.error';
+import {
+  CreatedCustomerSwagger,
+  CreateCustomerSwagger,
+} from 'src/internal/application/docs/swagger/customers/create-customer.dto';
+import { CreateCustomerDto } from 'src/internal/domain/customers/dto/create-customer.dto';
+
+import { CustomersService } from './customer.service';
 
 @ApiTags('Customers')
 @Controller('customers')
 export class CustomerController {
-  constructor(private readonly customersService: CustomersService) { }
+  constructor(private readonly customersService: CustomersService) {}
 
   @ApiOperation({ summary: 'Create Customer' })
   @ApiBody({ type: CreateCustomerSwagger })
-  @ApiResponse({ status: 201, description: 'Customer successfully created.', type: CreatedCustomerSwagger })
+  @ApiResponse({
+    status: 201,
+    description: 'Customer successfully created.',
+    type: CreatedCustomerSwagger,
+  })
   @Post()
   create(@Body() createCustomerDto: CreateCustomerDto) {
     try {
       return this.customersService.create(createCustomerDto);
-    } catch (err: any) {
-      responseError(err);
+    } catch (err) {
+      return responseError(err);
+    }
+  }
+
+  @Get(':cpf')
+  async getCustomer(@Param('cpf') cpf: string) {
+    try {
+      return await this.customersService.findByCpf(cpf);
+    } catch (err) {
+      return responseError(err);
     }
   }
 }

src/external/adapters/customer/customer.service.ts

@@ -1,4 +1,5 @@
 import { Inject, Injectable } from '@nestjs/common';
+import { NotFoundException } from 'src/internal/application/errors';
 import { IIdentifierGenerator } from 'src/internal/application/ports/tokens/id-generator';
 import { CreateCustomerDto } from 'src/internal/domain/customers/dto/create-customer.dto';
 import { Customer } from 'src/internal/domain/customers/entities/customer.entity';
@@ -52,4 +53,10 @@ export class CustomersService {
   async findById(id: string) {
     return this.customerRepository.findOne(id);
   }
+
+  async findByCpf(cpf: string): Promise<Customer> {
+    const customer = await this.customerRepository.findByCpf(cpf);
+    if (!customer) throw new NotFoundException('Customer not exists.');
+    return customer;
+  }
 }

src/external/adapters/product/product.module.ts

@@ -1,12 +1,13 @@
 import { Module } from '@nestjs/common';
-import { SequelizeModule } from '@nestjs/sequelize';
 import { EventEmitter2 } from '@nestjs/event-emitter';
-import { ProductsService } from './product.service';
+import { SequelizeModule } from '@nestjs/sequelize';
+import { Uuid } from 'src/external/infra/tokens/uuid/uuid';
+
+import { DecrementProductListener } from './listeners/decrement-product.listener';
 import { ProductController } from './product.controller';
+import { ProductsService } from './product.service';
 import { ProductSequelizeRepository } from './sequelize/product-sequelize.repository';
 import { ProductModel } from './sequelize/product.model';
-import { Uuid } from 'src/external/infra/tokens/uuid/uuid';
-import { DecrementProductListener } from './listeners/decrement-product.listener';
 
 @Module({
   imports: [SequelizeModule.forFeature([ProductModel])],

src/external/adapters/product/sequelize/product-sequelize.repository.spec.ts

@@ -0,0 +1,43 @@
+import {
+  closeDatabase,
+  initDatabase,
+} from 'src/external/infra/database/sequelize';
+import { IProductRepository } from 'src/internal/domain/product/repositories/product.repository';
+
+import { ProductSequelizeRepository } from './product-sequelize.repository';
+import { ProductModel } from './product.model';
+
+let model: typeof ProductModel;
+let repository: IProductRepository;
+
+describe('Product Sequelize Repository', () => {
+  beforeAll(async () => {
+    await initDatabase();
+    model = ProductModel;
+    repository = new ProductSequelizeRepository(model);
+  });
+  afterAll(async () => closeDatabase());
+
+  describe('updateQuantity', () => {
+    it('should update product quantity by id', async () => {
+      // arrange
+      const productId = 'abcd-efgh-ijkl';
+      const quantity = 1;
+      await model.create({
+        id: productId,
+        name: 'product-name-test',
+        category: 'category-name-test',
+        description: 'description-name-test',
+        price: 140,
+        quantity,
+      });
+      // act
+      const newQuantity = await repository.updateQuantity(productId, 2);
+      const productModel = await model.findOne({ where: { id: productId } });
+      // assert
+      expect(newQuantity).toBe(2);
+      expect(newQuantity).not.toBe(quantity);
+      expect(productModel.quantity).toBe(newQuantity);
+    });
+  });
+});

src/external/adapters/product/sequelize/product-sequelize.repository.ts

@@ -1,9 +1,10 @@
+import { NotFoundException } from '@nestjs/common';
 import { InjectModel } from '@nestjs/sequelize';
+import { Op } from 'sequelize';
 import { Product } from 'src/internal/domain/product/entities/product.entity';
 import { IProductRepository } from 'src/internal/domain/product/repositories/product.repository';
+
 import { ProductModel } from './product.model';
-import { NotFoundException } from '@nestjs/common';
-import { Op } from 'sequelize';
 
 export class ProductSequelizeRepository implements IProductRepository {
   constructor(
@@ -23,7 +24,7 @@ export class ProductSequelizeRepository implements IProductRepository {
     if (!productModel)
       throw new NotFoundException('product category not exists.');
 
-    return productModel.map((pm) => {
+    return productModel.map(pm => {
       return new Product({
         id: pm.id,
         category: pm.category,
@@ -52,7 +53,7 @@ export class ProductSequelizeRepository implements IProductRepository {
   async findAll(): Promise<Product[]> {
     const productsModel = await this.model.findAll();
 
-    return productsModel.map((p) => {
+    return productsModel.map(p => {
       return new Product({
         id: p.id,
         name: p.name,