fix: List only my vaults (#82)

* feat: Get only my vaults

* fix: Add orderBy in findByUserId

* refactor: Delete findAll in VaultsRepository

* refactor: create CurrentUserService

* refactor: remove import alias

Author: vbetsch

src/modules/api/domain/services/current-user.service.ts

@@ -0,0 +1,35 @@
+import { injectable, inject } from 'tsyringe';
+import { getServerSession, Session } from 'next-auth';
+import { authOptions } from '@lib/auth';
+import { UsersRepository } from '@api/infra/repositories/users.repository';
+import { User as UserModel } from '@prisma/generated';
+import { UnauthorizedError } from '@api/app/errors/unauthorized.error';
+import { ImpossibleCaseError } from '@api/domain/errors/impossible-case.error';
+
+@injectable()
+export class CurrentUserService {
+  public constructor(
+    @inject(UsersRepository)
+    private readonly _usersRepository: UsersRepository
+  ) {}
+
+  public async get(): Promise<UserModel> {
+    const session: Session | null = await getServerSession(authOptions);
+
+    if (!session || !session.user?.email) {
+      throw new UnauthorizedError();
+    }
+
+    const userFound: UserModel | null = await this._usersRepository.findByEmail(
+      {
+        email: session.user.email,
+      }
+    );
+
+    if (!userFound) {
+      throw new ImpossibleCaseError();
+    }
+
+    return userFound;
+  }
+}

src/modules/api/domain/usecases/vaults/create-vault.usecase.ts

@@ -8,11 +8,7 @@ import { VaultAlreadyExistsError } from '@api/domain/errors/vaults/vault-already
 import { RequestedValueTooLongError } from '@api/infra/prisma/errors/requested-value-too-long.error';
 import { VaultLabelTooLongError } from '@api/domain/errors/vaults/vault-label-too-long.error';
 import { CreateVaultPayloadDto } from '@shared/dto/input/payloads/create-vault.payload.dto';
-import { getServerSession, Session } from 'next-auth';
-import { authOptions } from '@lib/auth';
-import { UsersRepository } from '@api/infra/repositories/users.repository';
-import { UnauthorizedError } from '@api/app/errors/unauthorized.error';
-import { ImpossibleCaseError } from '@api/domain/errors/impossible-case.error';
+import { CurrentUserService } from '@api/domain/services/current-user.service';
 
 @injectable()
 export class CreateVaultUseCase
@@ -21,28 +17,12 @@ export class CreateVaultUseCase
   public constructor(
     @inject(VaultsRepository)
     private readonly _vaultsRepository: VaultsRepository,
-    @inject(UsersRepository)
-    private readonly _usersRepository: UsersRepository,
+    @inject(CurrentUserService)
+    private readonly _currentUserService: CurrentUserService,
     @inject(VaultAdapter)
     private readonly _vaultAdapter: VaultAdapter
   ) {}
 
-  private async _getCurrentUser(): Promise<UserModel> {
-    const session: Session | null = await getServerSession(authOptions);
-    if (!session || !session.user || !session.user.email) {
-      throw new UnauthorizedError();
-    }
-    const userFound: UserModel | null = await this._usersRepository.findByEmail(
-      {
-        email: session.user.email,
-      }
-    );
-    if (!userFound) {
-      throw new ImpossibleCaseError();
-    }
-    return userFound;
-  }
-
   private async _testVaultAlreadyExists(label: string): Promise<void> {
     const vaultsFound: number = await this._vaultsRepository.countByLabel({
       label,
@@ -69,7 +49,7 @@ export class CreateVaultUseCase
   }
 
   public async handle(input: CreateVaultPayloadDto): Promise<VaultModelDto> {
-    const currentUser: UserModel = await this._getCurrentUser();
+    const currentUser: UserModel = await this._currentUserService.get();
     await this._testVaultAlreadyExists(input.label);
     const vaultCreated: Vault = await this._createVaultInDatabase(
       input,

src/modules/api/domain/usecases/vaults/get-my-vaults.usecase.ts

@@ -3,20 +3,25 @@ import type { VaultModelDto } from '@shared/dto/models/vault.model.dto';
 import { inject, injectable } from 'tsyringe';
 import { VaultsRepository } from '@api/infra/repositories/vaults.repository';
 import { VaultAdapter } from '@api/app/adapters/vault.adapter';
-import { Vault } from '@prisma/generated';
+import { Vault, User } from '@prisma/generated';
+import { CurrentUserService } from '@api/domain/services/current-user.service';
 
 @injectable()
 export class GetMyVaultsUseCase implements IUseCase<VaultModelDto[]> {
   public constructor(
     @inject(VaultsRepository)
     private readonly _vaultsRepository: VaultsRepository,
+    @inject(CurrentUserService)
+    private readonly _currentUserService: CurrentUserService,
     @inject(VaultAdapter)
     private readonly _vaultAdapter: VaultAdapter
   ) {}
 
   public async handle(): Promise<VaultModelDto[]> {
-    // TODO: To replace by find by user
-    const myVaults: Vault[] = await this._vaultsRepository.findAll();
+    const currentUser: User = await this._currentUserService.get();
+    const myVaults: Vault[] = await this._vaultsRepository.findByUserId({
+      userId: currentUser.id,
+    });
     return this._vaultAdapter.getDtoListFromEntities(myVaults);
   }
 }

src/modules/api/infra/records/vaults/vault-user-id.record.ts

@@ -0,0 +1,3 @@
+export type VaultUserIdRecord = {
+  userId: string;
+};

src/modules/api/infra/repositories/vaults.repository.ts

@@ -5,12 +5,16 @@ import prisma from '@lib/prisma';
 import { SharedUuidRecord } from '@api/infra/records/shared/shared-uuid.record';
 import { VaultLabelRecord } from '@api/infra/records/vaults/vault-label.record';
 import { CreateVaultRecord } from '@api/infra/records/vaults/create-vault.record';
+import { VaultUserIdRecord } from '@api/infra/records/vaults/vault-user-id.record';
 
 @injectable()
 export class VaultsRepository {
-  public async findAll(): Promise<Vault[]> {
+  public async findByUserId(record: VaultUserIdRecord): Promise<Vault[]> {
     return await handlePrismaRequest<Vault[]>(() =>
       prisma.vault.findMany({
+        where: {
+          userId: record.userId,
+        },
         orderBy: { createdAt: 'desc' },
       })
     );