Merge pull request #15 from Amitpnk/feature/CQRS

Feature/cqrs

OnionArchitecture/.template.config/template.vstemplate

@@ -4,7 +4,7 @@
     <Name>Onion Architecture</Name>
     <Description>WhiteApp or QuickApp API solution template which is built on Onion Architecture using .NET Core</Description>
     <TemplateID>OnionArchitecture.CSharp</TemplateID>
-    <DefaultName>OA</DefaultName>
+    <DefaultName>OnionArchitecture</DefaultName>
 
     <Icon>project-icon.png</Icon>
 

OnionArchitecture/OA.Data/ApplicationContext.cs → OnionArchitecture/OA.Data/ApplicationDbContext.cs

@@ -4,14 +4,14 @@
 
 namespace OA.Data
 {
-    public class ApplicationContext : DbContext, IApplicationContext
+    public class ApplicationDbContext : DbContext, IApplicationDbContext
     {
         // This constructor is used of runit testing
-        public ApplicationContext()
+        public ApplicationDbContext()
         {
 
         }
-        public ApplicationContext(DbContextOptions options) : base(options)
+        public ApplicationDbContext(DbContextOptions options) : base(options)
         {
             ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
         }

OnionArchitecture/OA.Data/IApplicationContext.cs → OnionArchitecture/OA.Data/IApplicationDbContext.cs

@@ -4,7 +4,7 @@
 
 namespace OA.Data
 {
-    public interface IApplicationContext
+    public interface IApplicationDbContext
     {
         DbSet<Category> Categories { get; set; }
         DbSet<Customer> Customers { get; set; }

OnionArchitecture/OA.Data/Migrations/CustomerContextModelSnapshot.cs

@@ -8,7 +8,7 @@
 
 namespace OA.Data.Migrations
 {
-    [DbContext(typeof(ApplicationContext))]
+    [DbContext(typeof(ApplicationDbContext))]
     partial class CustomerContextModelSnapshot : ModelSnapshot
     {
         protected override void BuildModel(ModelBuilder modelBuilder)

OnionArchitecture/OA.Infrastructure/Extension/ConfigureContainer.cs

@@ -1,5 +1,7 @@
 using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.Logging;
 using OA.Infrastructure.Middleware;
+using Serilog;
 
 namespace OA.Infrastructure.Extension
 {
@@ -21,5 +23,10 @@ public static void ConfigureSwagger(this IApplicationBuilder app)
             });
         }
 
+        public static void ConfigureSwagger(this ILoggerFactory loggerFactory)
+        {
+            loggerFactory.AddSerilog();
+        }
+
     }
 }

OnionArchitecture/OA.Infrastructure/Extension/ConfigureServiceContainer.cs

@@ -1,4 +1,5 @@
 using AutoMapper;
+using MediatR;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
@@ -12,7 +13,6 @@
 using System;
 using System.IO;
 using System.Reflection;
-using Microsoft.AspNetCore.Mvc.NewtonsoftJson;
 
 namespace OA.Infrastructure.Extension
 {
@@ -21,7 +21,7 @@ public static class ConfigureServiceContainer
         public static void AddDbContext(this IServiceCollection serviceCollection,
              IConfiguration configuration, IConfigurationRoot configRoot)
         {
-            serviceCollection.AddDbContext<ApplicationContext>(options =>
+            serviceCollection.AddDbContext<ApplicationDbContext>(options =>
                    options.UseSqlServer(configuration.GetConnectionString("OnionArchConn") ?? configRoot["ConnectionStrings:OnionArchConn"])
                 );
         }
@@ -36,15 +36,15 @@ public static void AddAutoMapper(this IServiceCollection serviceCollection)
             serviceCollection.AddSingleton(mapper);
         }
 
-        public static void AddRepository(this IServiceCollection serviceCollection)
+        public static void AddAddScopedServices(this IServiceCollection serviceCollection)
         {
             serviceCollection.AddScoped(typeof(IGenericRepository<>), typeof(GenericRepository<>));
             serviceCollection.AddScoped<ICustomerRepository, CustomerRepository>();
+            serviceCollection.AddScoped<IApplicationDbContext>(provider => provider.GetService<ApplicationDbContext>());
         }
 
         public static void AddTransientServices(this IServiceCollection serviceCollection)
         {
-            serviceCollection.AddTransient<ICustomerService, CustomerService>();
             serviceCollection.AddTransient<IMailService, MailService>();
         }
 
@@ -90,5 +90,11 @@ public static void AddController(this IServiceCollection serviceCollection)
             serviceCollection.AddControllers().AddNewtonsoftJson();
         }
 
+        //public static void AddMediatorCQRS(this IServiceCollection services)
+        //{
+        //    //var assembly = AppDomain.CurrentDomain.Load("OA.Service");
+        //    services.AddMediatR(Assembly.GetExecutingAssembly());
+        //}
+
     }
 }

OnionArchitecture/OA.Persistence/Repository/CustomerRepository.cs

@@ -10,8 +10,8 @@ namespace OA.Persistence.Repository
 {
     public class CustomerRepository : ICustomerRepository
     {
-        private readonly ApplicationContext _context;
-        public CustomerRepository(ApplicationContext context)
+        private readonly ApplicationDbContext _context;
+        public CustomerRepository(ApplicationDbContext context)
         {
             _context = context;
         }

OnionArchitecture/OA.Persistence/Repository/GenericRepository.cs

@@ -9,9 +9,9 @@ namespace OA.Persistence.Repository
     public class GenericRepository<T> : IGenericRepository<T> where T : class
     {
         private readonly DbSet<T> entities;
-        private readonly ApplicationContext _context;
+        private readonly ApplicationDbContext _context;
 
-        public GenericRepository(ApplicationContext context)
+        public GenericRepository(ApplicationDbContext context)
         {
             _context = context;
             entities = _context.Set<T>();

OnionArchitecture/OA.Service/DependencyInjection.cs

@@ -0,0 +1,23 @@
+using MediatR;
+using Microsoft.Extensions.DependencyInjection;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Reflection;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OA.Service
+{
+    public static  class DependencyInjection
+    {
+        public static void AddMediatorCQRS(this IServiceCollection services)
+        {
+            // or you can use assembly in Extension method in Infra layer with below command
+            // var assembly = AppDomain.CurrentDomain.Load("OA.Service");
+            services.AddMediatR(Assembly.GetExecutingAssembly());
+        }
+    }
+}
+
+

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

@@ -0,0 +1,40 @@
+using MediatR;
+using OA.Data;
+using OA.Domain.Entities;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace OA.Service.Features.CustomerFeatures.Commands
+{
+    public class CreateCustomerCommand : IRequest<int>
+    {
+        public string CustomerName { get; set; }
+        public string ContactName { get; set; }
+        public string ContactTitle { get; set; }
+        public string Address { get; set; }
+        public string City { get; set; }
+        public string Region { get; set; }
+        public string PostalCode { get; set; }
+        public string Country { get; set; }
+        public string Phone { get; set; }
+        public string Fax { get; set; }
+        public class CreateCustomerCommandHandler : IRequestHandler<CreateCustomerCommand, int>
+        {
+            private readonly IApplicationDbContext _context;
+            public CreateCustomerCommandHandler(IApplicationDbContext context)
+            {
+                _context = context;
+            }
+            public async Task<int> Handle(CreateCustomerCommand request, CancellationToken cancellationToken)
+            {
+                var customer = new Customer();
+                customer.CustomerName = request.CustomerName;
+                customer.ContactName = request.ContactName;
+
+                _context.Customers.Add(customer);
+                await _context.SaveChangesAsync();
+                return customer.Id;
+            }
+        }
+    }
+}

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

@@ -0,0 +1,30 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using OA.Data;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace OA.Service.Features.CustomerFeatures.Commands
+{
+    public class DeleteCustomerByIdCommand : IRequest<int>
+    {
+        public int Id { get; set; }
+        public class DeleteCustomerByIdCommandHandler : IRequestHandler<DeleteCustomerByIdCommand, int>
+        {
+            private readonly IApplicationDbContext _context;
+            public DeleteCustomerByIdCommandHandler(IApplicationDbContext context)
+            {
+                _context = context;
+            }
+            public async Task<int> Handle(DeleteCustomerByIdCommand request, CancellationToken cancellationToken)
+            {
+                var customer = await _context.Customers.Where(a => a.Id == request.Id).FirstOrDefaultAsync();
+                if (customer == null) return default;
+                _context.Customers.Remove(customer);
+                await _context.SaveChangesAsync();
+                return customer.Id;
+            }
+        }
+    }
+}

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

@@ -0,0 +1,49 @@
+using MediatR;
+using OA.Data;
+using OA.Domain.Entities;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace OA.Service.Features.CustomerFeatures.Commands
+{
+    public class UpdateCustomerCommand : IRequest<int>
+    {
+        public int Id { get; set; }
+        public string CustomerName { get; set; }
+        public string ContactName { get; set; }
+        public string ContactTitle { get; set; }
+        public string Address { get; set; }
+        public string City { get; set; }
+        public string Region { get; set; }
+        public string PostalCode { get; set; }
+        public string Country { get; set; }
+        public string Phone { get; set; }
+        public string Fax { get; set; }
+        public class UpdateCustomerCommandHandler : IRequestHandler<UpdateCustomerCommand, int>
+        {
+            private readonly IApplicationDbContext _context;
+            public UpdateCustomerCommandHandler(IApplicationDbContext context)
+            {
+                _context = context;
+            }
+            public async Task<int> Handle(UpdateCustomerCommand request, CancellationToken cancellationToken)
+            {
+                var cust = _context.Customers.Where(a => a.Id == request.Id).FirstOrDefault();
+
+                if (cust == null)
+                {
+                    return default;
+                }
+                else
+                {
+                    var customer = new Customer();
+                    customer.CustomerName = request.CustomerName;
+                    customer.ContactName = request.ContactName;
+                    await _context.SaveChangesAsync();
+                    return cust.Id;
+                }
+            }
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using OA.Data;
+using OA.Domain.Entities;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace OA.Service.Features.CustomerFeatures.Queries
+{
+    public class GetAllCustomerQuery : IRequest<IEnumerable<Customer>>
+    {
+
+        public class GetAllCustomerQueryHandler : IRequestHandler<GetAllCustomerQuery, IEnumerable<Customer>>
+        {
+            private readonly IApplicationDbContext _context;
+            public GetAllCustomerQueryHandler(IApplicationDbContext context)
+            {
+                _context = context;
+            }
+            public async Task<IEnumerable<Customer>> Handle(GetAllCustomerQuery request, CancellationToken cancellationToken)
+            {
+                var customerList = await _context.Customers.ToListAsync();
+                if (customerList == null)
+                {
+                    return null;
+                }
+                return customerList.AsReadOnly();
+            }
+        }
+    }
+}

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

@@ -0,0 +1,28 @@
+using MediatR;
+using OA.Data;
+using OA.Domain.Entities;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace OA.Service.Features.CustomerFeatures.Queries
+{
+    public class GetCustomerByIdQuery : IRequest<Customer>
+    {
+        public int Id { get; set; }
+        public class GetCustomerByIdQueryHandler : IRequestHandler<GetCustomerByIdQuery, Customer>
+        {
+            private readonly IApplicationDbContext _context;
+            public GetCustomerByIdQueryHandler(IApplicationDbContext context)
+            {
+                _context = context;
+            }
+            public async Task<Customer> Handle(GetCustomerByIdQuery request, CancellationToken cancellationToken)
+            {
+                var customer = _context.Customers.Where(a => a.Id == request.Id).FirstOrDefault();
+                if (customer == null) return null;
+                return customer;
+            }
+        }
+    }
+}