creating endpoints from PurchaseOrder

PyroFetes/Endpoints/PurchaseOrder/DeletePurchaseOrderEndpoint.cs

@@ -0,0 +1,41 @@
+using FastEndpoints;
+using Microsoft.EntityFrameworkCore;
+
+namespace PyroFetes.Endpoints.PurchaseOrder;
+
+public class DeletePurchaseOrderRequest
+{
+    public int Id { get; set; }
+}
+
+public class DeletePurchaseOrderEndpoint(PyroFetesDbContext database) : Endpoint<DeletePurchaseOrderRequest>
+{
+    public override void Configure()
+    {
+        Delete("/api/purchaseOrders/{Id}", x => new {x.Id});
+        AllowAnonymous();
+    }
+
+    public override async Task HandleAsync(DeletePurchaseOrderRequest req, CancellationToken ct)
+    {
+        var purchaseOrder = await database.PurchaseOrders
+            .Include(po => po.PurchaseProducts)
+            .SingleOrDefaultAsync(po => po.Id == req.Id, ct);
+
+        if (purchaseOrder == null)
+        {
+            await Send.NotFoundAsync(ct);
+            return;
+        }
+        
+        if (purchaseOrder.PurchaseProducts != null && purchaseOrder.PurchaseProducts.Any())
+        {
+            database.PurchaseProducts.RemoveRange(purchaseOrder.PurchaseProducts);
+        }
+        
+        database.PurchaseOrders.Remove(purchaseOrder); 
+        await database.SaveChangesAsync(ct);
+        
+        await Send.NoContentAsync(ct);
+    }
+}

PyroFetes/Endpoints/PurchaseOrder/GetAllPurchaseOrderEndpoint.cs

@@ -0,0 +1,45 @@
+using FastEndpoints;
+using Microsoft.EntityFrameworkCore;
+using PyroFetes.DTO.PurchaseOrder.Response;
+using PyroFetes.DTO.PurchaseProduct.Response;
+
+namespace PyroFetes.Endpoints.PurchaseOrder;
+
+public class GetAllPurchaseOrderEndpoint(PyroFetesDbContext database) : EndpointWithoutRequest<List<GetPurchaseOrderDto>>
+{
+    public override void Configure()
+    {
+        Get("/api/purchaseOrders");
+    }
+
+    public override async Task HandleAsync(CancellationToken ct)
+    {
+        var purchaseOrder = await database.PurchaseOrders
+            .Include(p => p.PurchaseProducts)
+            .Select(purchaseOrder => new GetPurchaseOrderDto()
+            {
+                Id = purchaseOrder.Id,
+                PurchaseConditions = purchaseOrder.PurchaseConditions,
+                GetPurchaseProductDto = purchaseOrder.PurchaseProducts
+                    .Select(p => new GetPurchaseProductDto
+                    {
+                        ProductId = p.ProductId,
+                        ProductReferences = p.Product.Reference,
+                        ProductName = p.Product.Name,
+                        ProductDuration = p.Product.Duration,
+                        ProductCaliber = p.Product.Caliber,
+                        ProductApprovalNumber = p.Product.ApprovalNumber,
+                        ProductWeight = p.Product.Weight,
+                        ProductNec = p.Product.Nec,
+                        ProductImage = p.Product.Image,
+                        ProductLink = p.Product.Link,
+                        ProductMinimalQuantity = p.Product.MinimalQuantity,
+                        PurchaseOrderId = p.PurchaseOrderId,
+                        Quantity = p.Quantity,
+                    }).ToList()
+            })
+            .ToListAsync(ct);
+        
+        await Send.OkAsync(purchaseOrder, ct);
+    }
+}

PyroFetes/Endpoints/PurchaseOrder/GetPurchaseOrderEndpoint.cs

@@ -0,0 +1,56 @@
+using FastEndpoints;
+using Microsoft.EntityFrameworkCore;
+using PyroFetes.DTO.PurchaseOrder.Response;
+using PyroFetes.DTO.PurchaseProduct.Response;
+
+namespace PyroFetes.Endpoints.PurchaseOrder;
+
+public class GetPurchaseOrderRequest
+{
+    public int Id { get; set; }
+}
+
+public class GetPurchaseOrderEndpoint(PyroFetesDbContext database) : Endpoint<GetPurchaseOrderRequest, GetPurchaseOrderDto>
+{
+    public override void Configure()
+    {
+        Get("/api/purchaseOrders/{@Id}", x => new {x.Id});
+    }
+
+    public override async Task HandleAsync(GetPurchaseOrderRequest req, CancellationToken ct)
+    {
+        var purchaseOrder = await database.PurchaseOrders
+            .SingleOrDefaultAsync(x => x.Id == req.Id, ct);
+
+        if (purchaseOrder == null)
+        {
+            await Send.NotFoundAsync(ct);
+            return;
+        }
+        
+        GetPurchaseOrderDto responseDto = new()
+        {
+            Id = purchaseOrder.Id,
+            PurchaseConditions = purchaseOrder.PurchaseConditions,
+            GetPurchaseProductDto = purchaseOrder.PurchaseProducts
+                .Select(p => new GetPurchaseProductDto
+            {
+                ProductId = p.ProductId,
+                ProductReferences = p.Product.Reference,
+                ProductName = p.Product.Name,
+                ProductDuration = p.Product.Duration,
+                ProductCaliber = p.Product.Caliber,
+                ProductApprovalNumber = p.Product.ApprovalNumber,
+                ProductWeight = p.Product.Weight,
+                ProductNec = p.Product.Nec,
+                ProductImage = p.Product.Image,
+                ProductLink = p.Product.Link,
+                ProductMinimalQuantity = p.Product.MinimalQuantity,
+                PurchaseOrderId = p.PurchaseOrderId,
+                Quantity = p.Quantity,
+            }).ToList()
+        };
+        
+        await Send.OkAsync(responseDto, ct);
+    }
+}