Catalog Api - Refactor (#102)

Author: behdad088

src/Services/Basket/Basket.API/Authorization/UserAuthorizationHandler.cs

@@ -17,37 +17,21 @@ protected override Task HandleRequirementAsync(
         UserIdRequirement requirement,
         string username)
     {
-
         var userRole = GetUserRole(context.User);
-        if (userRole == string.Empty)
-        {
-            context.Fail();
-            return Task.CompletedTask;
-        }
 
-        if (userRole == "admin")
+        if (userRole != "admin")
         {
-            if (!ValidateUserPermissions(
-                    context.User.Claims.ToList(),
-                    requirement.Requirements.ToList()))
+            var usernameInClaim = GetUsername(context.User);
+            if (string.IsNullOrEmpty(usernameInClaim) || username != usernameInClaim)
             {
                 context.Fail();
                 return Task.CompletedTask;
             }
-            context.Succeed(requirement);
-            return Task.CompletedTask;
         }
 
-        var usernameInClaim = GetUsername(context.User);
-        if (username != usernameInClaim)
-        {
-            context.Fail();
-            return Task.CompletedTask;
-        }
-        
         if (!ValidateUserPermissions(
-                context.User.Claims.ToList(),
-                requirement.Requirements.ToList()))
+                context.User.Claims.ToArray(),
+                requirement.Requirements.ToArray()))
         {
             context.Fail();
             return Task.CompletedTask;

src/Services/Catalog/Catalog.API.IntegrationTests/ApiFactory.cs

@@ -20,7 +20,7 @@ protected override void ConfigureWebHost(IWebHostBuilder builder)
                 service.AddMarten(options =>
                 {
                     options.Connection(postgresConnection);
-                    options.Schema.For<Product>().UseNumericRevisions(true);
+                    options.Schema.For<ProductDocument>().UseNumericRevisions(true);
                 }).UseLightweightSessions();
 
                 service

src/Services/Catalog/Catalog.API.IntegrationTests/Database/DataSeeder.cs

@@ -12,18 +12,18 @@ public async Task SeedDataBaseAsync(Action<ProductConfiguration>? productConfigu
         var products = productConfiguration is null ? GetListOfProducts() : [product.ToDbProduct()];
 
         await using var session = store.LightweightSession();
-        session.Store<Product>(products);
+        session.Store<ProductDocument>(products);
         await session.SaveChangesAsync();
     }
 
-    public async Task<IReadOnlyList<Product>> GetAllData()
+    public async Task<IReadOnlyList<ProductDocument>> GetAllData()
     {
         await using var session = store.LightweightSession();
-        var data = await session.Query<Product>().ToListAsync();
+        var data = await session.Query<ProductDocument>().ToListAsync();
         return data;
     }
 
-    private static IEnumerable<Product> GetListOfProducts()
+    private static IEnumerable<ProductDocument> GetListOfProducts()
     {
         return
         [

src/Services/Catalog/Catalog.API.IntegrationTests/Database/ProductConfiguration.cs

@@ -15,9 +15,9 @@ public record ProductConfiguration
 
 public static class CreateProductConfiguration
 {
-    public static Product ToDbProduct(this ProductConfiguration configuration)
+    public static ProductDocument ToDbProduct(this ProductConfiguration configuration)
     {
-        return new Product
+        return new ProductDocument
         {
             Id = configuration.Id,
             Name = configuration.Name,

src/Services/Catalog/Catalog.API.IntegrationTests/Features/CreateProducts/CreateProductsTests.cs

@@ -152,7 +152,7 @@ public async Task CreateProduct_With_Valid_Object_Return_Created(CreateProductRe
 
         result.StatusCode.ShouldBe(HttpStatusCode.Created);
         await using var session = apiSpecification.GetDocumentStore().LightweightSession();
-        var valueInDb = session.Query<Product>().First(x => x.Id == createProductRequest.Id);
+        var valueInDb = session.Query<ProductDocument>().First(x => x.Id == createProductRequest.Id);
         valueInDb.ShouldNotBeNull();
         valueInDb.Id.ShouldBe(productId);
     }

src/Services/Catalog/Catalog.API.IntegrationTests/Features/GetProductById/GetProductByIdTests.cs

@@ -23,13 +23,12 @@ public async Task GetProductById_Product_NotFound_Returns_NotFound()
 
             // Act
             var result = await _client.GetAsync($"api/v1/catalog/products/{productId}");
-            var response = await result.Content.ReadFromJsonAsync<ProblemDetails>();
+            var response = await result.Content.ReadFromJsonAsync<string>();
 
             // Assert
-            result.StatusCode.ShouldBe(System.Net.HttpStatusCode.NotFound);
+            result.StatusCode.ShouldBe(HttpStatusCode.NotFound);
             response.ShouldNotBeNull();
-            response.Detail.ShouldNotBeNull();
-            response.Detail.ShouldBe($"Entity \"Product\" ({productId}) was not found.");
+            response.ShouldBe(productId.ToString());
         }
 
         [Fact]

src/Services/Catalog/Catalog.API.IntegrationTests/Features/GetProducts/GetProductsTests.cs

@@ -96,7 +96,7 @@ public async Task DisposeAsync()
             await Task.CompletedTask;
         }
 
-        private static List<ProductResponse> GetProductsModules(IReadOnlyList<Product> products)
+        private static List<ProductResponse> GetProductsModules(IReadOnlyList<ProductDocument> products)
         {
             return products.Select(x => new ProductResponse(
                 Id: Ulid.Parse(x.Id),

src/Services/Catalog/Catalog.API.IntegrationTests/Features/GetProductsByCategory/GetProductsByCategoryTests.cs

@@ -56,15 +56,15 @@ public async Task DisposeAsync()
             await Task.CompletedTask;
         }
 
-        private static ProductModule ToProductModule(Product product)
+        private static ProductModule ToProductModule(ProductDocument productDocument)
         {
             return new ProductModule(
-                Id: Ulid.Parse(product.Id),
-                Name: product.Name,
-                Category: product.Category,
-                Description: product.Description,
-                ImageFile: product.ImageFile,
-                Price: product.Price);
+                Id: Ulid.Parse(productDocument.Id),
+                Name: productDocument.Name,
+                Category: productDocument.Category,
+                Description: productDocument.Description,
+                ImageFile: productDocument.ImageFile,
+                Price: productDocument.Price);
         }
     }
 }

src/Services/Catalog/Catalog.API.IntegrationTests/Features/UpdateProduct/UpdateProductTests.cs

@@ -147,13 +147,12 @@ public async Task UpdateProduct_ProductId_NotFound_Returns_NotFound(UpdateProduc
             var result = await _client
                 .SetFakeBearerToken(FakePermission.GetPermissions([Policies.CatalogProductUpdatePermission]))
                 .PutAsJsonAsync("api/v1/catalog/products", updateProductRequest);
-            var response = await result.Content.ReadFromJsonAsync<ProblemDetails>();
+            var response = await result.Content.ReadFromJsonAsync<string>();
 
             // Assert
             result.StatusCode.ShouldBe(HttpStatusCode.NotFound);
             response.ShouldNotBeNull();
-            response.Detail.ShouldNotBeNull();
-            response.Detail.ShouldContain($"Entity \"Product\" ({updateProductRequest.Id}) was not found.");
+            response.ShouldBe(updateProductRequest.Id);
         }
 
         [Theory, CatalogRequestAutoData]
@@ -206,7 +205,7 @@ await _dataSeeder.SeedDataBaseAsync(x =>
             result.StatusCode.ShouldBe(HttpStatusCode.NoContent);
 
             await using var session = apiSpecification.GetDocumentStore().LightweightSession();
-            var valueInDb = session.Query<Product>().FirstOrDefault(x => x.Id == updateProductRequest.Id);
+            var valueInDb = session.Query<ProductDocument>().FirstOrDefault(x => x.Id == updateProductRequest.Id);
 
             valueInDb!.Name.ShouldBe(updateProductRequest.Name);
             valueInDb.Description.ShouldBe(updateProductRequest.Description);

src/Services/Catalog/Catalog.API/Data/CatalogInitialDataMigration.cs

@@ -28,7 +28,7 @@ public async Task Populate(IDocumentStore store, CancellationToken cancellation)
             await policy.ExecuteAsync(async () =>
             {
                 await using var session = store.LightweightSession();
-                if (await session.Query<Product>().AnyAsync(cancellation))
+                if (await session.Query<ProductDocument>().AnyAsync(cancellation))
                     return;
 
                 session.Store(GetPreConfiguredProducts());
@@ -41,7 +41,7 @@ await policy.ExecuteAsync(async () =>
         }
     }
 
-    private static IEnumerable<Product> GetPreConfiguredProducts()
+    private static IEnumerable<ProductDocument> GetPreConfiguredProducts()
     {
         return
         [