FrontOffice.BFF/src/FrontOffice.BFF.WebApi/Services/ProductsService.cs

using FrontOffice.BFF.WebApi.Common.Services;
using FrontOffice.BFF.Application.ProductsCQ.Queries.GetProducts;
using FrontOffice.BFF.Application.ProductsCQ.Queries.GetAllProductsByFilter;
using FrontOffice.BFF.Products.Protobuf.Protos.Products;

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<GetAllProductsByFilterResponse> GetAllProductsByFilter(GetAllProductsByFilterRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<GetAllProductsByFilterRequest, GetAllProductsByFilterQuery, GetAllProductsByFilterResponse>(request, context);
    }
}