Uecko_ERP/modules/customers/src/api/infrastructure/dependencies.ts

import type { IMapperRegistry, IPresenterRegistry, ModuleParams } from "@erp/core/api";
import { InMemoryMapperRegistry, SequelizeTransactionManager } from "@erp/core/api";

import {
  CreateCustomerUseCase,
  DeleteCustomerUseCase,
  GetCustomerUseCase,
  ListCustomersUseCase,
  UpdateCustomerUseCase,
} from "../application";
import { CustomerService } from "../domain";
import { CustomerMapper } from "./mappers";
import { CustomerRepository } from "./sequelize";

type CustomerDeps = {
  transactionManager: SequelizeTransactionManager;
  mapperRegistry: IMapperRegistry;
  presenterRegistry: IPresenterRegistry;
  repo: CustomerRepository;
  service: CustomerService;
  build: {
    list: () => ListCustomersUseCase;
    get: () => GetCustomerUseCase;
    create: () => CreateCustomerUseCase;
    update: () => UpdateCustomerUseCase;
    delete: () => DeleteCustomerUseCase;
  };
};

const _presenterRegistry: IPresenterRegistry | null = null;
let _mapperRegistry: IMapperRegistry | null = null;

let _repo: CustomerRepository | null = null;
let _service: CustomerService | null = null;

export function getCustomerDependencies(params: ModuleParams): CustomerDeps {
  const { database } = params;
  const transactionManager = new SequelizeTransactionManager(database);

  if (!_mapperRegistry) {
    _mapperRegistry = new InMemoryMapperRegistry();
    _mapperRegistry.registerDomainMapper("FULL", new CustomerMapper());
  }

  if (!_repo) _repo = new CustomerRepository({ mapperRegistry: _mapperRegistry });
  if (!_service) _service = new CustomerService(_repo);

  /*if (!_presenterRegistry) {
    _presenterRegistry = new InMemoryPresenterRegistry();

    _presenterRegistry.registerPresenters([
      {
        key: { resource: "customer", projection: "FULL" },
        presenter: new ListCustomersAssembler(),
      },
      {
        key: { resource: "customer", projection: "LIST" },
        presenter: new GetCustomerAssembler(),
      },
    ]);
  }*/

  return {
    transactionManager,
    repo: _repo,
    mapperRegistry: _mapperRegistry,
    //presenterRegistry: _presenterRegistry,
    service: _service,

    build: {
      /*list: () => new ListCustomersUseCase(_service!, transactionManager!, presenterRegistry!),
      get: () => new GetCustomerUseCase(_service!, transactionManager!, presenterRegistry!),
      create: () => new CreateCustomerUseCase(_service!, transactionManager!, presenterRegistry!),
      update: () => new UpdateCustomerUseCase(_service!, transactionManager!, presenterRegistry!),
      delete: () => new DeleteCustomerUseCase(_service!, transactionManager!),*/
    },
  };
}