23 lines
1.1 KiB
C#
23 lines
1.1 KiB
C#
|
using FrontOffice.BFF.Protobuf.Protos.Products;
|
||
|
|
using FrontOffice.BFF.WebApi.Common.Services;
|
||
|
|
using FrontOffice.BFF.Application.ProductsCQ.Queries.GetProducts;
|
||
|
|
using FrontOffice.BFF.Application.ProductsCQ.Queries.GetAllProductsByFilter;
|
||
|
|
namespace FrontOffice.BFF.WebApi.Services;
|
||
|
|
public class ProductsService : ProductsContract.ProductsContractBase
|
||
|
|
{
|
||
|
|
private readonly IDispatchRequestToCQRS _dispatchRequestToCQRS;
|
||
|
|
|
||
|
|
public ProductsService(IDispatchRequestToCQRS dispatchRequestToCQRS)
|
||
|
|
{
|
||
|
|
_dispatchRequestToCQRS = dispatchRequestToCQRS;
|
||
|
|
}
|
||
|
|
public override async Task<GetProductsResponse> GetProducts(GetProductsRequest request, ServerCallContext context)
|
||
|
|
{
|
||
|
|
return await _dispatchRequestToCQRS.Handle<GetProductsRequest, GetProductsQuery, GetProductsResponse>(request, context);
|
||
|
|
}
|
||
|
|
public override async Task<GetAllProductsByFilterResponseModel> GetAllProductsByFilter(GetAllProductsByFilterFilter request, ServerCallContext context)
|
||
|
|
{
|
||
|
|
return await _dispatchRequestToCQRS.Handle<GetAllProductsByFilterFilter, GetAllProductsByFilterQuery, GetAllProductsByFilterResponseModel>(request, context);
|
||
|
|
}
|
||
|
|
}
|