refactored CQRS

Author: Amitpnk

OnionArchitecture/OA.Service/Features/CustomerFeatures/Commands/CreateCustomerCommand.cs

@@ -4,7 +4,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Application.Features.ProductFeatures.Commands
+namespace OA.Service.Features.CustomerFeatures.Commands
 {
     public class CreateCustomerCommand : IRequest<int>
     {
@@ -18,10 +18,10 @@ public class CreateCustomerCommand : IRequest<int>
         public string Country { get; set; }
         public string Phone { get; set; }
         public string Fax { get; set; }
-        public class CreateProductCommandHandler : IRequestHandler<CreateCustomerCommand, int>
+        public class CreateCustomerCommandHandler : IRequestHandler<CreateCustomerCommand, int>
         {
             private readonly IApplicationDbContext _context;
-            public CreateProductCommandHandler(IApplicationDbContext context)
+            public CreateCustomerCommandHandler(IApplicationDbContext context)
             {
                 _context = context;
             }

OnionArchitecture/OA.Service/Features/CustomerFeatures/Commands/DeleteCustomerByIdCommand.cs

@@ -5,15 +5,15 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Application.Features.ProductFeatures.Commands
+namespace OA.Service.Features.CustomerFeatures.Commands
 {
     public class DeleteCustomerByIdCommand : IRequest<int>
     {
         public int Id { get; set; }
-        public class DeleteProductByIdCommandHandler : IRequestHandler<DeleteCustomerByIdCommand, int>
+        public class DeleteCustomerByIdCommandHandler : IRequestHandler<DeleteCustomerByIdCommand, int>
         {
             private readonly IApplicationDbContext _context;
-            public DeleteProductByIdCommandHandler(IApplicationDbContext context)
+            public DeleteCustomerByIdCommandHandler(IApplicationDbContext context)
             {
                 _context = context;
             }

OnionArchitecture/OA.Service/Features/CustomerFeatures/Commands/UpdateCustomerCommand.cs

@@ -5,7 +5,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Application.Features.ProductFeatures.Commands
+namespace OA.Service.Features.CustomerFeatures.Commands
 {
     public class UpdateCustomerCommand : IRequest<int>
     {
@@ -20,18 +20,18 @@ public class UpdateCustomerCommand : IRequest<int>
         public string Country { get; set; }
         public string Phone { get; set; }
         public string Fax { get; set; }
-        public class UpdateProductCommandHandler : IRequestHandler<UpdateCustomerCommand, int>
+        public class UpdateCustomerCommandHandler : IRequestHandler<UpdateCustomerCommand, int>
         {
             private readonly IApplicationDbContext _context;
-            public UpdateProductCommandHandler(IApplicationDbContext context)
+            public UpdateCustomerCommandHandler(IApplicationDbContext context)
             {
                 _context = context;
             }
             public async Task<int> Handle(UpdateCustomerCommand request, CancellationToken cancellationToken)
             {
-                var product = _context.Products.Where(a => a.Id == request.Id).FirstOrDefault();
+                var cust = _context.Customers.Where(a => a.Id == request.Id).FirstOrDefault();
 
-                if (product == null)
+                if (cust == null)
                 {
                     return default;
                 }
@@ -41,7 +41,7 @@ public async Task<int> Handle(UpdateCustomerCommand request, CancellationToken c
                     customer.CustomerName = request.CustomerName;
                     customer.ContactName = request.ContactName;
                     await _context.SaveChangesAsync();
-                    return product.Id;
+                    return cust.Id;
                 }
             }
         }

OnionArchitecture/OA.Service/Features/CustomerFeatures/Queries/GetAllCustomerQuery.cs

@@ -6,15 +6,15 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Application.Features.ProductFeatures.Queries
+namespace OA.Service.Features.CustomerFeatures.Queries
 {
     public class GetAllCustomerQuery : IRequest<IEnumerable<Customer>>
     {
 
-        public class GetAllProductsQueryHandler : IRequestHandler<GetAllCustomerQuery, IEnumerable<Customer>>
+        public class GetAllCustomerQueryHandler : IRequestHandler<GetAllCustomerQuery, IEnumerable<Customer>>
         {
             private readonly IApplicationDbContext _context;
-            public GetAllProductsQueryHandler(IApplicationDbContext context)
+            public GetAllCustomerQueryHandler(IApplicationDbContext context)
             {
                 _context = context;
             }

OnionArchitecture/OA.Service/Features/CustomerFeatures/Queries/GetCustomerByIdQuery.cs

@@ -5,15 +5,15 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Application.Features.ProductFeatures.Queries
+namespace OA.Service.Features.CustomerFeatures.Queries
 {
     public class GetCustomerByIdQuery : IRequest<Customer>
     {
         public int Id { get; set; }
-        public class GetProductByIdQueryHandler : IRequestHandler<GetCustomerByIdQuery, Customer>
+        public class GetCustomerByIdQueryHandler : IRequestHandler<GetCustomerByIdQuery, Customer>
         {
             private readonly IApplicationDbContext _context;
-            public GetProductByIdQueryHandler(IApplicationDbContext context)
+            public GetCustomerByIdQueryHandler(IApplicationDbContext context)
             {
                 _context = context;
             }

OnionArchitecture/OA/Controllers/CustomerController.cs

@@ -1,5 +1,5 @@
-using Application.Features.ProductFeatures.Commands;
-using Application.Features.ProductFeatures.Queries;
+using OA.Service.Features.CustomerFeatures.Commands;
+using OA.Service.Features.CustomerFeatures.Queries;
 using MediatR;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.DependencyInjection;