Uecko_ERP/modules/customers/src/api/application/get-customer/get-customer.use-case.ts

50 lines
1.3 KiB
TypeScript
Raw Normal View History

2025-08-11 17:49:52 +00:00
import { ITransactionManager } from "@erp/core/api";
import { UniqueID } from "@repo/rdx-ddd";
import { Result } from "@repo/rdx-utils";
2025-09-01 14:07:59 +00:00
import { CustomerService } from "../../domain";
import { GetCustomerAssembler } from "./assembler";
2025-08-11 17:49:52 +00:00
2025-08-25 17:42:56 +00:00
type GetCustomerUseCaseInput = {
2025-09-01 14:07:59 +00:00
companyId: UniqueID;
2025-09-02 08:57:41 +00:00
customer_id: string;
2025-08-25 17:42:56 +00:00
};
2025-08-11 17:49:52 +00:00
export class GetCustomerUseCase {
constructor(
2025-09-01 14:07:59 +00:00
private readonly service: CustomerService,
2025-08-11 17:49:52 +00:00
private readonly transactionManager: ITransactionManager,
private readonly assembler: GetCustomerAssembler
2025-08-11 17:49:52 +00:00
) {}
2025-08-25 17:42:56 +00:00
public execute(params: GetCustomerUseCaseInput) {
2025-09-02 08:57:41 +00:00
const { customer_id, companyId } = params;
2025-08-25 17:42:56 +00:00
2025-09-02 08:57:41 +00:00
const idOrError = UniqueID.create(customer_id);
2025-08-11 17:49:52 +00:00
if (idOrError.isFailure) {
return Result.fail(idOrError.error);
}
2025-09-02 08:57:41 +00:00
const customerId = idOrError.data;
2025-08-11 17:49:52 +00:00
return this.transactionManager.complete(async (transaction) => {
try {
2025-08-25 17:42:56 +00:00
const customerOrError = await this.service.getCustomerByIdInCompany(
2025-09-01 14:07:59 +00:00
companyId,
2025-09-02 08:57:41 +00:00
customerId,
2025-08-25 17:42:56 +00:00
transaction
);
2025-09-01 14:07:59 +00:00
2025-08-21 07:44:07 +00:00
if (customerOrError.isFailure) {
return Result.fail(customerOrError.error);
2025-08-11 17:49:52 +00:00
}
2025-08-21 07:44:07 +00:00
const getDTO = this.assembler.toDTO(customerOrError.data);
2025-08-11 17:49:52 +00:00
return Result.ok(getDTO);
} catch (error: unknown) {
return Result.fail(error as Error);
}
});
}
}