Class BaseQueryHandler<TQuery, TResult>Abstract

Example

class GetProductByIdHandler extends BaseQueryHandler<GetProductByIdQuery, Product> {
  constructor(private repository: IProductRepository) {
    super();
  }

  protected validate(query: GetProductByIdQuery): Result<void, DomainError> {
    if (!query.productId) {
      return Failure.create(new DomainError('INVALID_ID', 'Product ID is required'));
    }
    return Success.create(undefined);
  }

  protected async execute(query: GetProductByIdQuery): Promise<Result<Product, DomainError>> {
    const product = await this.repository.findById(query.productId);
    if (!product) {
      return Failure.create(new DomainError('NOT_FOUND', 'Product not found'));
    }
    return Success.create(product);
  }
}
Copy