Merge pull request #2 from Axel77g/feat/customer

feat(customer): implement Customer repository

Author: Insane-Bob

backend/knexfile.js

@@ -1,16 +1,14 @@
-import { Dealer } from "@domain/inventoryManagement/entities/Dealer";
-import { DealerAddress } from "@domain/inventoryManagement/value-object/DealerAddress";
+import { RegisterDealerEvent } from "@domain/inventoryManagement/events/RegisterDealerEvent";
+import { Address } from "@domain/shared/value-object/Address";
 import { Siret } from '@domain/shared/value-object/Siret';
 import { IInputUseCase, IUseCase } from "@shared/IUseCase";
 import { Result } from "@shared/Result";
-import { DealerRepository } from "../../repositories/DealerRepository";
-import {EventRepository} from "../../../shared/repositories/EventRepository";
-import {RegisterDealerEvent} from "@domain/inventoryManagement/events/RegisterDealerEvent";
+import { EventRepository } from "../../../shared/repositories/EventRepository";
 
 interface RegisterDealerInput extends IInputUseCase {
     siret: Siret,
     name: string,
-    address: DealerAddress,
+    address: Address,
     phoneNumber: string
 }
 

backend/migrations/20241222141816_create_dealers_table.js

@@ -0,0 +1,53 @@
+import { AbstractProjection } from "@application/shared/projections/AbstractProjection";
+import { ProjectionJobScheduler } from "@application/shared/projections/ProjectionJobScheduler";
+import { Customer } from "@domain/maintenance/entities/Customer";
+import { RegisterCustomerEvent } from "@domain/maintenance/events/RegisterCustomerEvent";
+import { UnregisterCustomerEvent } from "@domain/maintenance/events/UnregisterCustomerEvent";
+import { UpdateCustomerEvent } from "@domain/maintenance/events/UpdateCustomerEvent";
+import { Result, VoidResult } from "@shared/Result";
+import { CustomerRepository } from "../repositories/CustomerRepository";
+
+export class CustomerProjection extends AbstractProjection {
+    constructor(private _customerRepository: CustomerRepository) {
+        super();
+    }
+
+    init(projectionJobScheduler: ProjectionJobScheduler) {
+        projectionJobScheduler.schedule(RegisterCustomerEvent.type, this.constructor.name)
+        projectionJobScheduler.schedule(UpdateCustomerEvent.type, this.constructor.name)
+        projectionJobScheduler.schedule(UnregisterCustomerEvent.type, this.constructor.name)
+
+    }
+
+    bindEvents() {
+        return {
+            [RegisterCustomerEvent.type]: this.applyRegisterEvent,
+            [UpdateCustomerEvent.type]: this.applyUpdateEvent,
+            [UnregisterCustomerEvent.type]: this.applyUnregisteredEvent
+        }
+    }
+
+    async applyRegisterEvent(event: RegisterCustomerEvent): Promise<VoidResult> {
+        const customer = Customer.fromObject(event.payload)
+        if (customer instanceof Error) return Result.FailureStr("Cannot register customer");
+        return this._customerRepository.store(customer)
+    }
+
+    async applyUnregisteredEvent(event: UnregisterCustomerEvent): Promise<VoidResult> {
+        const response = await this._customerRepository.find(event.payload.customerId)
+        if (!response.success) return Result.FailureStr("Cannot delete customer")
+        return this._customerRepository.delete(event.payload.customerId)
+    }
+
+    async applyUpdateEvent(event: UpdateCustomerEvent): Promise<VoidResult> {
+        const customer = await this._customerRepository.find(event.payload.customerId)
+        if (!customer.success) return Result.FailureStr("Cannot update customer")
+
+        const updatedCustomer = Customer.fromObject({
+            ...customer,
+            ...event.payload
+        })
+        if (updatedCustomer instanceof Error) return Result.FailureStr("Cannot update customer")
+        return this._customerRepository.store(updatedCustomer);
+    }
+}

backend/migrations/20241222141909_create_spare_parts_table.js

@@ -0,0 +1,9 @@
+import { Customer } from "@domain/maintenance/entities/Customer";
+import { IRepository } from "@shared/IRepository";
+import { Result, VoidResult } from "@shared/Result";
+
+export interface CustomerRepository extends IRepository {
+    find(customerId: string): Promise<Result<Customer>>;
+    store(customer: Customer): Promise<VoidResult>;
+    delete(customerId: string): Promise<VoidResult>;
+}

backend/migrations/20241222141910_create_order_table.js

@@ -0,0 +1,10 @@
+import { Garage } from '../../../domain/maintenance/entities/Garage';
+import { Siret } from '../../../domain/shared/value-object/Siret';
+import { IRepository } from '../../../shared/IRepository';
+import { Result, VoidResult } from '../../../shared/Result';
+
+export interface GarageRepository extends IRepository {
+    getBySiret(siret: Siret): Promise<Result<Garage>>
+    store(garage: Garage): Promise<VoidResult>;
+    delete(siret: Siret): Promise<VoidResult>;
+}