Merge pull request #5 from eduardoconti/mongo

feat: adiciona mongo e cria userMongoRepository

Author: eduardoconti

docker-compose.yml

@@ -78,10 +78,25 @@ services:
       - api-pix
     dns:
       - 8.8.8.8
+
+  mongo:
+    image: mongo
+    container_name: mongo
+    ports:
+      - ${DB_MONGO_PORT}:${DB_MONGO_PORT}
+    volumes:
+      - mongo-apipix-data:/data/db
+    networks:
+     - api-pix
+    restart: always
+    dns:
+     - 8.8.8.8
+    
 networks:
   api-pix:
 
 volumes:
   pg-apipix-data:
   redis:
   es-data:
+  mongo-apipix-data:

package.json

@@ -34,6 +34,7 @@
     "@nestjs/elasticsearch": "8.0.0",
     "@nestjs/event-emitter": "^1.4.1",
     "@nestjs/jwt": "^10.0.2",
+    "@nestjs/mongoose": "^9.2.2",
     "@nestjs/passport": "^9.0.3",
     "@nestjs/platform-express": "^9.0.0",
     "@nestjs/schedule": "^2.2.0",
@@ -54,6 +55,7 @@
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",
     "joi": "^17.8.3",
+    "mongoose": "^7.0.3",
     "nanoid": "3.3.4",
     "passport": "^0.6.0",
     "passport-jwt": "^4.0.1",
@@ -126,7 +128,6 @@
       "!<rootDir>/infra/strategy/**",
       "!<rootDir>/infra/guard/**",
       "!<rootDir>/infra/decorators/**"
-      
     ],
     "coverageDirectory": "../coverage",
     "testEnvironment": "node",

src/app/app.provider.ts

@@ -10,12 +10,12 @@ import { IQueue } from '@domain/core/queue';
 import { IChargeRepository, IWebhookRepository } from '@domain/core/repository';
 
 import { CelcoinApi, ICelcoinApi } from '@infra/celcoin';
+import { UserRepositoryMongo } from '@infra/database/mongo';
 import {
   ChargeRepository,
   UserWebhookNotificationRepository,
   WebhookRepository,
-} from '@infra/prisma';
-import { UserRepository } from '@infra/prisma/user.repository';
+} from '@infra/database/prisma';
 
 import { IPspService } from './contracts';
 import { ChargeCreatedListener, ChargePayedListener } from './event-handler';
@@ -70,18 +70,18 @@ export const provideChargeCreatedListener: Provider<ChargeCreatedListener> = {
 
 export const provideRegisterUserUseCase: Provider<RegisterUserUseCase> = {
   provide: RegisterUserUseCase,
-  useFactory: (userRepository: IUserRepository) => {
-    return new RegisterUserUseCase(userRepository);
+  useFactory: (mongo: IUserRepository) => {
+    return new RegisterUserUseCase(mongo);
   },
-  inject: [UserRepository],
+  inject: [UserRepositoryMongo],
 };
 
 export const provideUserAuthUseCase: Provider<UserAuthUseCase> = {
   provide: UserAuthUseCase,
   useFactory: (userRepository: IUserRepository) => {
     return new UserAuthUseCase(userRepository);
   },
-  inject: [UserRepository],
+  inject: [UserRepositoryMongo],
 };
 
 export const provideChargePayedListener: Provider<ChargePayedListener> = {
@@ -95,5 +95,5 @@ export const provideChargePayedListener: Provider<ChargePayedListener> = {
       userRepository,
     );
   },
-  inject: [UserWebhookNotificationRepository, UserRepository],
+  inject: [UserWebhookNotificationRepository, UserRepositoryMongo],
 };

src/app/event-handler/charge-payed.event-handler.spec.ts

@@ -14,10 +14,8 @@ import {
 import { ArgumentInvalidException } from '@domain/exceptions';
 import { UUID } from '@domain/value-objects';
 
-import {
-  UserRepository,
-  UserWebhookNotificationRepository,
-} from '@infra/prisma';
+import { UserRepositoryMongo } from '@infra/database/mongo';
+import { UserWebhookNotificationRepository } from '@infra/database/prisma';
 
 import { ChargePayedListener } from './charge-payed.event-handler';
 
@@ -30,7 +28,7 @@ describe('ChargePayedListener', () => {
       providers: [
         provideChargePayedListener,
         {
-          provide: UserRepository,
+          provide: UserRepositoryMongo,
           useValue: {
             findOne: jest.fn(),
           },
@@ -48,7 +46,7 @@ describe('ChargePayedListener', () => {
     userWebhookNotificationRepository = module.get(
       UserWebhookNotificationRepository,
     );
-    userRepository = module.get(UserRepository);
+    userRepository = module.get(UserRepositoryMongo);
   });
 
   afterEach(() => {

src/app/use-cases/create-immediate-charge.use-case.spec.ts

@@ -22,8 +22,8 @@ import {
 import { IEventEmitter } from '@domain/core';
 import { IChargeRepository } from '@domain/core/repository';
 
+import { ChargeRepository } from '@infra/database/prisma';
 import { CreateImmediateChargeException } from '@infra/exceptions';
-import { ChargeRepository } from '@infra/prisma';
 
 describe('CreateImmediateChargeUseCase', () => {
   let pspService: IPspService;

src/app/use-cases/receive-webhook.use-case.spec.ts

@@ -6,7 +6,7 @@ import { mockWebhookEntity } from '@domain/__mocks__/webhook.mock';
 import { IWebhookRepository } from '@domain/core/repository';
 
 import { mockCelcoinWebhook } from '@infra/__mocks__/celcoin.mock';
-import { WebhookRepository } from '@infra/prisma/webhook.repository';
+import { WebhookRepository } from '@infra/database/prisma/webhook.repository';
 
 import { WebhookCelcoinInput } from '@presentation/dto';
 

src/app/use-cases/receive-webhook.use-case.ts

@@ -8,7 +8,7 @@ import {
   WebhookTypes,
 } from '@domain/entities';
 
-import { WebhookModel } from '@infra/prisma/models';
+import { WebhookModel } from '@infra/database/models';
 
 export type ReceiveWebhookUseCaseOutput = string;
 export type ReceiveWebhookUseCaseInput = {

src/app/use-cases/register-user.use-case.spec.ts

@@ -11,7 +11,7 @@ import { mockUserEntity, mockUserEntityWithoutHost } from '@domain/__mocks__';
 import { IUserRepository } from '@domain/core';
 import { ArgumentInvalidException } from '@domain/exceptions';
 
-import { UserRepository } from '@infra/prisma';
+import { UserRepositoryMongo } from '@infra/database/mongo';
 
 import {
   IRegisterUserUseCase,
@@ -27,7 +27,7 @@ describe('RegisterUserUseCase', () => {
       providers: [
         provideRegisterUserUseCase,
         {
-          provide: UserRepository,
+          provide: UserRepositoryMongo,
           useValue: {
             exists: jest.fn(),
             save: jest.fn(),
@@ -37,7 +37,7 @@ describe('RegisterUserUseCase', () => {
     }).compile();
 
     registerUserUseCase = app.get<IRegisterUserUseCase>(RegisterUserUseCase);
-    userRepository = app.get<IUserRepository>(UserRepository);
+    userRepository = app.get<IUserRepository>(UserRepositoryMongo);
   });
 
   it('should defined', () => {

src/app/use-cases/user-auth.use-case.spec.ts

@@ -6,8 +6,8 @@ import { provideUserAuthUseCase } from '@app/app.provider';
 import { mockUserEntity } from '@domain/__mocks__';
 import { IUserRepository } from '@domain/core';
 
+import { UserRepositoryMongo } from '@infra/database/mongo';
 import { UnauthorizedException } from '@infra/exceptions';
-import { UserRepository } from '@infra/prisma';
 
 import { UserAuthUseCase, IUserAuthUseCase } from './user-auth.use-case';
 
@@ -20,7 +20,7 @@ describe('userAuthUseCase', () => {
       providers: [
         provideUserAuthUseCase,
         {
-          provide: UserRepository,
+          provide: UserRepositoryMongo,
           useValue: {
             findOne: jest.fn(),
           },
@@ -29,7 +29,7 @@ describe('userAuthUseCase', () => {
     }).compile();
 
     userAuthUseCase = app.get<IUserAuthUseCase>(UserAuthUseCase);
-    userRepository = app.get<IUserRepository>(UserRepository);
+    userRepository = app.get<IUserRepository>(UserRepositoryMongo);
   });
 
   it('should be defined', () => {