refactor: update product queries to use GetAllProductsWithoutSellerListing and add response headers for data source

Author: dagweg

Source/Ecommerce.Api/Controllers/MeController.cs

@@ -6,7 +6,7 @@ namespace Ecommerce.Api.Controllers;
 using Ecommerce.Api.Utilities;
 using Ecommerce.Application.Common.Models;
 using Ecommerce.Application.Common.Utilities;
-using Ecommerce.Application.UseCases.Products.Queries.GetAllProducts;
+using Ecommerce.Application.UseCases.Products.Queries.GetAllProductsWithoutSellerListing;
 using Ecommerce.Application.UseCases.Products.Queries.GetFilteredProducts;
 using Ecommerce.Application.UseCases.Users.Commands.AddToCart;
 using Ecommerce.Application.UseCases.Users.Commands.ChangePassword;
@@ -235,6 +235,8 @@ public async Task<IActionResult> GetMyProducts(
       return new ObjectResult(result);
     }
 
+    Response.Headers.Add("X-Data-Source", result.Value.DataSourceType.ToString());
+    Response.Headers.Add("X-Data-SourceId", result.Value.DataSourceId.ToString());
     return Ok(result.Value);
   }
 

Source/Ecommerce.Api/Controllers/OrderController.cs

@@ -34,8 +34,6 @@ public async Task<IActionResult> GetOrders()
     if (result.IsFailed)
       return new ObjectResult(result);
 
-    LogPretty.Log(result);
-
     return Ok(result.Value);
   }
 }

Source/Ecommerce.Api/Controllers/ProductController.cs

@@ -7,7 +7,7 @@
 using Ecommerce.Application.UseCases.Products.Commands.CreateReview;
 using Ecommerce.Application.UseCases.Products.Commands.DeleteProduct;
 using Ecommerce.Application.UseCases.Products.CreateUser.Commands;
-using Ecommerce.Application.UseCases.Products.Queries.GetAllProducts;
+using Ecommerce.Application.UseCases.Products.Queries.GetAllProductsWithoutSellerListing;
 using Ecommerce.Application.UseCases.Products.Queries.GetCategories;
 using Ecommerce.Application.UseCases.Products.Queries.GetFilteredProducts;
 using Ecommerce.Application.UseCases.Products.Queries.GetProductBySlug;
@@ -57,18 +57,34 @@ [FromForm] CreateProductRequest createProductRequest
 
   [AllowAnonymous]
   [HttpGet]
-  public async Task<IActionResult> GetProducts([FromQuery] PaginationParams paginationParams)
+  public async Task<IActionResult> GetProducts(
+    [FromQuery] PaginationParams paginationParams,
+    [FromQuery] FilterProductsQuery? filterBy = null
+  )
   {
     var result = await _mediator.Send(
-      new GetAllProductsQuery(paginationParams.PageNumber, paginationParams.PageSize)
+      new GetAllProductsWithoutSellerListingQuery()
+      {
+        FilterQuery = filterBy is null
+          ? filterBy
+          : filterBy with
+          {
+            PaginationParameters = new PaginationParameters
+            {
+              PageNumber = paginationParams.PageNumber,
+              PageSize = paginationParams.PageSize,
+            },
+          },
+      }
     );
 
     if (result.IsFailed)
     {
       _logger.LogError("Failed to get all products: {@result}", result);
       return new ObjectResult(result);
     }
-
+    Response.Headers.Add("X-Data-Source", result.Value.DataSourceType.ToString());
+    Response.Headers.Add("X-Data-SourceId", result.Value.DataSourceId.ToString());
     return Ok(result.Value);
   }
 

Source/Ecommerce.Api/Controllers/UserController.cs

@@ -7,7 +7,7 @@ namespace Ecommerce.Api.Controllers;
 using Ecommerce.Api.Attributes;
 using Ecommerce.Api.Utilities;
 using Ecommerce.Application.Common.Models;
-using Ecommerce.Application.UseCases.Products.Queries.GetAllProducts;
+using Ecommerce.Application.UseCases.Products.Queries.GetAllProductsWithoutSellerListing;
 using Ecommerce.Application.UseCases.Products.Queries.GetFilteredProducts;
 using Ecommerce.Application.UseCases.Users.Commands.AddToCart;
 using Ecommerce.Application.UseCases.Users.Commands.ChangePassword;