Merge pull request #7 from Axel77g/feature/create-use-case-implementation-and-refacto-express-part

Feature/create use case implementation and refacto express part

Author: Insane-Bob

backend/src/application/inventoryManagement/usecases/order/UpdateOrderStatusUseCase.ts

@@ -9,13 +9,13 @@ interface UpdateOrderInput extends IInputUseCase{
     orderId: string,
     status : OrderStatusEnum
 }
-export type RegisterOrderUseCase = IUseCase<UpdateOrderInput, Result>
+export type UpdateOrderStatusUseCase = IUseCase<UpdateOrderInput, Result>
 
 const registerOrderErrors = {
     NOT_FOUND_ORDER: NotFoundEntityException.create("Cannot update status for not found order"),
 }
 
-export const createUpdateOrderStatusUseCase = (_eventRepository : EventRepository, _orderRepository: OrderRepository) : RegisterOrderUseCase => {
+export const createUpdateOrderStatusUseCase = (_eventRepository : EventRepository, _orderRepository: OrderRepository) : UpdateOrderStatusUseCase => {
     return async (input: UpdateOrderInput) => {
         const orderResponse = await _orderRepository.findOrderById(input.orderId);
         if(!orderResponse.success) return orderResponse

backend/src/infrastructure/common/entityMappers/IncidentMapper.ts

@@ -5,7 +5,7 @@ import {ApplicationException} from "@shared/ApplicationException";
 
 export class IncidentMapper {
     static toDomain(incidentEventRaw: any) : Incident | ApplicationException {
-        const driverLicenceId = DriverLicenseId.create(incidentEventRaw.driverLicenceId)
+        const driverLicenceId = DriverLicenseId.create(incidentEventRaw.driverLicenseId)
         if(driverLicenceId instanceof ApplicationException) return driverLicenceId
         return Incident.create({
             incidentId: incidentEventRaw.incidentId,

backend/src/infrastructure/common/repositories/mongo/AbstractMongoRepository.ts

@@ -1,6 +1,6 @@
 import {MongoClient} from 'mongodb'
 import {Result} from "@shared/Result";
-import {InternalErrorException} from "@shared/ApplicationException";
+import {InternalException} from "@shared/ApplicationException";
 export abstract class AbstractMongoRepository {
     protected abstract collectionName: string;
     public constructor(
@@ -22,7 +22,7 @@ export abstract class AbstractMongoRepository {
             await onError();
             const message = e instanceof Error ? e.message : defaultMessageError;
             console.error("[MONGO ERROR]", e);
-            return Result.Failure(InternalErrorException.create(message)) as T;
+            return Result.Failure(InternalException.create(message)) as T;
         }
     }
 

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/addSparePartInStockUseCase.ts

@@ -0,0 +1,28 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {updateStockRequest} from "@infrastructureCore/requests/inventoryManagement/updateStockRequest";
+import {
+    AddSparePartInStockUseCase,
+    createAddSparePartInStockUseCase
+} from "@application/inventoryManagement/usecases/stock/AddSparePartInStockUseCase";
+import {Siret} from "@domain/shared/value-object/Siret";
+import {Result} from "@shared/Result";
+import {
+    createGetInventorySparePartUseCase
+} from "@application/inventoryManagement/usecases/inventorySparePart/GetInventorySparePartUseCase";
+import {
+    inventorySparePartRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventorySparePartRepository";
+import {
+    inventoryManagementEventRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventoryManagementEventRepository";
+
+export const addSparePartInStockUseCase : UseCaseImplementation<typeof updateStockRequest, AddSparePartInStockUseCase> = async (input) =>{
+    const siret = Siret.create(input.siret)
+    if(siret instanceof Error) return Result.Failure(siret)
+    const _getInventorySparePartUseCase = createGetInventorySparePartUseCase(inventorySparePartRepository)
+    const useCase = createAddSparePartInStockUseCase(inventoryManagementEventRepository, _getInventorySparePartUseCase)
+    return useCase({
+        ...input,
+        siret
+    })
+}

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/getInventorySparePartUseCase.ts

@@ -0,0 +1,14 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {sparePartReferenceRequest} from "@infrastructureCore/requests/inventoryManagement/sparePartReferenceRequest";
+import {
+    createGetInventorySparePartUseCase,
+    GetInventorySparePartUseCase
+} from "@application/inventoryManagement/usecases/inventorySparePart/GetInventorySparePartUseCase";
+import {
+    inventorySparePartRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventorySparePartRepository";
+
+export const getInventorySparePartUseCase : UseCaseImplementation<typeof sparePartReferenceRequest,  GetInventorySparePartUseCase> = async (input) => {
+    const useCase = createGetInventorySparePartUseCase(inventorySparePartRepository)
+    return useCase(input)
+}

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/listDealersUseCase.ts

@@ -0,0 +1,12 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {paginatedRequest} from "@infrastructureCore/requests/paginatedRequest";
+import {
+    createListDealerUseCase,
+    ListDealerUseCase
+} from "@application/inventoryManagement/usecases/dealer/listDealerUseCase";
+import {dealerRepository} from "@infrastructureCore/repositories/inventoryManagement/dealerRepository";
+
+export const listDealersUseCase : UseCaseImplementation<typeof paginatedRequest, ListDealerUseCase> = async (input) =>{
+    const useCase = createListDealerUseCase(dealerRepository)
+    return useCase(input)
+}

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/listInventorySparePartUseCase.ts

@@ -0,0 +1,14 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {paginatedRequest} from "@infrastructureCore/requests/paginatedRequest";
+import {
+    createListInventorySparePartUseCase,
+    ListInventorySparePartUseCase
+} from "@application/inventoryManagement/usecases/inventorySparePart/ListInventorySparePartUseCase";
+import {
+    inventorySparePartRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventorySparePartRepository";
+
+export const listInventorySparePartUseCase : UseCaseImplementation<typeof paginatedRequest, ListInventorySparePartUseCase> = async (input) => {
+    const useCase = createListInventorySparePartUseCase(inventorySparePartRepository);
+    return useCase(input);
+}

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/registerDealerUseCase.ts

@@ -0,0 +1,28 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {registerDealerRequest} from "@infrastructureCore/requests/inventoryManagement/registerDealerRequest";
+import {
+    createRegisterDealerUseCase,
+    RegisterDealerUseCase
+} from "@application/inventoryManagement/usecases/dealer/RegisterDealerUseCase";
+import {Address} from "@domain/shared/value-object/Address";
+import {ApplicationException} from "@shared/ApplicationException";
+import {Result} from "@shared/Result";
+import {Siret} from "@domain/shared/value-object/Siret";
+import {
+    inventoryManagementEventRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventoryManagementEventRepository";
+import {dealerRepository} from "@infrastructureCore/repositories/inventoryManagement/dealerRepository";
+
+export const registerDealerUseCase : UseCaseImplementation<typeof registerDealerRequest, RegisterDealerUseCase> = async (input) =>{
+    const address = Address.create(input.address)
+    if(address instanceof ApplicationException) return Result.Failure(address)
+    const siret = Siret.create(input.siret)
+    if(siret instanceof ApplicationException) return Result.Failure(siret)
+    const useCase = createRegisterDealerUseCase(inventoryManagementEventRepository,dealerRepository)
+    return useCase({
+        siret,
+        name: input.name,
+        address,
+        phoneNumber: input.phoneNumber
+    })
+}

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/registerOrderUseCase.ts

@@ -0,0 +1,31 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {
+    createRegisterOrderUseCase,
+    RegisterOrderUseCase
+} from "@application/inventoryManagement/usecases/order/RegisterOrderUseCase";
+import {registerOrderRequest} from "@infrastructureCore/requests/inventoryManagement/registerOrderRequest";
+import {Siret} from "@domain/shared/value-object/Siret";
+import {ApplicationException} from "@shared/ApplicationException";
+import {Result} from "@shared/Result";
+import {OrderLine} from "@domain/inventoryManagement/value-object/OrderLine";
+import {
+    inventoryManagementEventRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventoryManagementEventRepository";
+import {dealerRepository} from "@infrastructureCore/repositories/inventoryManagement/dealerRepository";
+import {
+    inventorySparePartRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventorySparePartRepository";
+
+export const registerOrderUseCase : UseCaseImplementation<typeof registerOrderRequest, RegisterOrderUseCase> = async (input) =>{
+    const dealerSiret = Siret.create(input.dealerSiret)
+    if(dealerSiret instanceof ApplicationException) return Result.Failure(dealerSiret)
+    const orderLines = input.orderLines.map((line) =>  OrderLine.create(line))
+    const error = orderLines.find(line => line instanceof ApplicationException) as ApplicationException | undefined
+    if(error) return Result.Failure(error)
+    const useCase = createRegisterOrderUseCase(inventoryManagementEventRepository, dealerRepository, inventorySparePartRepository)
+    return useCase({
+        ...input,
+        dealer: dealerSiret,
+        orderLines: orderLines as OrderLine[]
+    })
+}

backend/src/infrastructure/frameworks/core/useCaseImplementation/InventoryManagement/removeSparePartInStockUseCase.ts

@@ -0,0 +1,32 @@
+import {UseCaseImplementation} from "@infrastructureCore/useCaseImplementation/UseCaseImplementation";
+import {updateStockRequest} from "@infrastructureCore/requests/inventoryManagement/updateStockRequest";
+import {
+    createRemoveSparePartInStockUseCase,
+    RemoveSparePartInStockUseCase
+} from "@application/inventoryManagement/usecases/stock/RemoveSparePartInStockUseCase";
+import {Siret} from "@domain/shared/value-object/Siret";
+import {Result} from "@shared/Result";
+import {ApplicationException} from "@shared/ApplicationException";
+import {
+    inventoryManagementEventRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventoryManagementEventRepository";
+import {stockRepository} from "@infrastructureCore/repositories/inventoryManagement/stockRepository";
+import {
+    inventorySparePartRepository
+} from "@infrastructureCore/repositories/inventoryManagement/inventorySparePartRepository";
+import {notificationServices} from "@infrastructureCore/services/notificationServices";
+
+export const removeSparePartInStockUseCase : UseCaseImplementation<typeof updateStockRequest, RemoveSparePartInStockUseCase> = async (input) =>{
+    const siret = Siret.create(input.siret)
+    if(siret instanceof ApplicationException) return Result.Failure(siret)
+    const useCase = createRemoveSparePartInStockUseCase(
+        inventoryManagementEventRepository,
+        stockRepository,
+        inventorySparePartRepository,
+        notificationServices
+    )
+    return useCase({
+        ...input,
+        siret
+    })
+}