import { JsonTaxCatalogProvider, spainTaxCatalogProvider } from "@erp/core"; import type { IMapperRegistry, ModuleParams } from "@erp/core/api"; import { InMemoryMapperRegistry, SequelizeTransactionManager } from "@erp/core/api"; import { CreateCustomerInvoiceAssembler, CreateCustomerInvoiceUseCase, DeleteCustomerInvoiceUseCase, GetCustomerInvoiceAssembler, GetCustomerInvoiceUseCase, ListCustomerInvoicesAssembler, ListCustomerInvoicesUseCase, UpdateCustomerInvoiceAssembler, UpdateCustomerInvoiceUseCase, } from "../application"; import { CustomerInvoiceService } from "../domain"; import { CustomerInvoiceFullMapper, CustomerInvoiceListMapper } from "./mappers"; import { CustomerInvoiceRepository } from "./sequelize"; type InvoiceDeps = { transactionManager: SequelizeTransactionManager; mapperRegistry: IMapperRegistry; repo: CustomerInvoiceRepository; service: CustomerInvoiceService; catalogs: { taxes: JsonTaxCatalogProvider; }; assemblers: { list: ListCustomerInvoicesAssembler; get: GetCustomerInvoiceAssembler; create: CreateCustomerInvoiceAssembler; update: UpdateCustomerInvoiceAssembler; }; build: { list: () => ListCustomerInvoicesUseCase; get: () => GetCustomerInvoiceUseCase; create: () => CreateCustomerInvoiceUseCase; update: () => UpdateCustomerInvoiceUseCase; delete: () => DeleteCustomerInvoiceUseCase; }; presenters: { // list: (res: Response) => ListPresenter; }; }; let _repo: CustomerInvoiceRepository | null = null; let _mapperRegistry: IMapperRegistry | null = null; let _service: CustomerInvoiceService | null = null; let _assemblers: InvoiceDeps["assemblers"] | null = null; let _catalogs: InvoiceDeps["catalogs"] | null = null; export function getInvoiceDependencies(params: ModuleParams): InvoiceDeps { const { database } = params; const transactionManager = new SequelizeTransactionManager(database); if (!_catalogs) _catalogs = { taxes: spainTaxCatalogProvider }; const fullMapper: CustomerInvoiceFullMapper = new CustomerInvoiceFullMapper({ taxCatalog: _catalogs!.taxes, }); const listMapper = new CustomerInvoiceListMapper(); if (!_mapperRegistry) { _mapperRegistry = new InMemoryMapperRegistry(); _mapperRegistry.registerDomainMapper("FULL", fullMapper); _mapperRegistry.registerReadModelMapper("LIST", listMapper); } if (!_repo) _repo = new CustomerInvoiceRepository({ mapperRegistry: _mapperRegistry, database }); if (!_service) _service = new CustomerInvoiceService(_repo); if (!_assemblers) { _assemblers = { list: new ListCustomerInvoicesAssembler(), // transforma domain → ListDTO get: new GetCustomerInvoiceAssembler(), // transforma domain → DetailDTO create: new CreateCustomerInvoiceAssembler(), // transforma domain → CreatedDTO update: new UpdateCustomerInvoiceAssembler(), // transforma domain -> UpdateDTO }; } return { transactionManager, repo: _repo, mapperRegistry: _mapperRegistry, service: _service, assemblers: _assemblers, catalogs: _catalogs, build: { list: () => new ListCustomerInvoicesUseCase(_service!, transactionManager!, _assemblers!.list), get: () => new GetCustomerInvoiceUseCase(_service!, transactionManager!, _assemblers!.get), create: () => new CreateCustomerInvoiceUseCase( _service!, transactionManager!, _assemblers!.create, _catalogs!.taxes ), update: () => new UpdateCustomerInvoiceUseCase( _service!, transactionManager!, _assemblers!.update, _catalogs!.taxes ), delete: () => new DeleteCustomerInvoiceUseCase(_service!, transactionManager!), }, presenters: { //list: (res: Response) => createListPresenter(res), //json: (res: Response, status: number = 200) => createJsonPresenter(res, status), }, }; }