Added Products and Categories to DB of Warehouse module

src/Common/SharedKernel/Domain/Base/AggregateRoot.cs → src/Common/Common.SharedKernel/Domain/Base/AggregateRoot.cs

@@ -1,7 +1,7 @@
-using SharedKernel.Domain.Interfaces;
+using Common.SharedKernel.Domain.Interfaces;
 using System.ComponentModel.DataAnnotations.Schema;
 
-namespace SharedKernel.Domain.Base;
+namespace Common.SharedKernel.Domain.Base;
 
 public abstract class AggregateRoot<TId> : Entity<TId>, IDomainEvents
 {

src/Common/SharedKernel/Domain/Base/DomainEvent.cs → src/Common/Common.SharedKernel/Domain/Base/DomainEvent.cs

@@ -1,4 +1,4 @@
-namespace SharedKernel.Domain.Base;
+namespace Common.SharedKernel.Domain.Base;
 
 //public record DomainEvent : INotification { }
 

src/Common/SharedKernel/Domain/Base/Entity.cs → src/Common/Common.SharedKernel/Domain/Base/Entity.cs

@@ -1,6 +1,6 @@
-using SharedKernel.Domain.Interfaces;
+using Common.SharedKernel.Domain.Interfaces;
 
-namespace SharedKernel.Domain.Base;
+namespace Common.SharedKernel.Domain.Base;
 
 public abstract class Entity<TId> : IAuditableEntity
 {

src/Common/Common.SharedKernel/Domain/Base/ValueObject.cs

@@ -0,0 +1,3 @@
+namespace Common.SharedKernel.Domain.Base;
+
+public record ValueObject { }

src/Common/SharedKernel/Domain/Entities/Currency.cs → src/Common/Common.SharedKernel/Domain/Entities/Currency.cs

@@ -1,6 +1,6 @@
-using SharedKernel.Domain.Exceptions;
+using Common.SharedKernel.Domain.Exceptions;
 
-namespace SharedKernel.Domain.Entities;
+namespace Common.SharedKernel.Domain.Entities;
 
 public record Currency
 {

src/Common/SharedKernel/Domain/Entities/Money.cs → src/Common/Common.SharedKernel/Domain/Entities/Money.cs

@@ -1,4 +1,4 @@
-namespace SharedKernel.Domain.Entities;
+namespace Common.SharedKernel.Domain.Entities;
 
 public record Money(Currency Currency, decimal Amount)
 {

src/Common/SharedKernel/Domain/Exceptions/DomainException.cs → src/Common/Common.SharedKernel/Domain/Exceptions/DomainException.cs

@@ -1,4 +1,4 @@
-namespace SharedKernel.Domain.Exceptions;
+namespace Common.SharedKernel.Domain.Exceptions;
 
 public class DomainException : Exception
 {

src/Common/SharedKernel/Domain/Exceptions/GuardClausesExt.cs → src/Common/Common.SharedKernel/Domain/Exceptions/GuardClausesExt.cs

@@ -1,6 +1,7 @@
-using System.Runtime.CompilerServices;
+using Ardalis.GuardClauses;
+using System.Runtime.CompilerServices;
 
-namespace Ardalis.GuardClauses;
+namespace Common.SharedKernel.Domain.Exceptions;
 
 public static class FooGuard
 {

src/Common/Common.SharedKernel/Domain/Identifiers/ProductId.cs

@@ -0,0 +1,3 @@
+namespace Common.SharedKernel.Domain.Identifiers;
+
+public record ProductId(Guid Value);

src/Common/SharedKernel/Domain/Interfaces/IAuditableEntity.cs → src/Common/Common.SharedKernel/Domain/Interfaces/IAuditableEntity.cs

@@ -1,4 +1,4 @@
-namespace SharedKernel.Domain.Interfaces;
+namespace Common.SharedKernel.Domain.Interfaces;
 
 public interface IAuditableEntity
 {

src/Common/SharedKernel/Domain/Interfaces/IDomainEvents.cs → src/Common/Common.SharedKernel/Domain/Interfaces/IDomainEvents.cs

@@ -1,6 +1,6 @@
-using SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Base;
 
-namespace SharedKernel.Domain.Interfaces;
+namespace Common.SharedKernel.Domain.Interfaces;
 
 public interface IDomainEvents
 {

src/Modules/Orders/Modules.Orders.Domain/Customers/Customer.cs

@@ -1,5 +1,5 @@
 using Ardalis.GuardClauses;
-using SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Base;
 
 namespace Modules.Orders.Domain.Customers;
 

src/Modules/Orders/Modules.Orders.Domain/Customers/CustomerCreatedEvent.cs

@@ -1,4 +1,4 @@
-using SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Base;
 
 namespace Modules.Orders.Domain.Customers;
 

src/Modules/Orders/Modules.Orders.Domain/Modules.Orders.Domain.csproj

@@ -7,7 +7,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <ProjectReference Include="..\..\..\Common\SharedKernel\SharedKernel.csproj"/>
+        <ProjectReference Include="..\..\..\Common\Common.SharedKernel\Common.SharedKernel.csproj" />
     </ItemGroup>
 
     <ItemGroup>

src/Modules/Orders/Modules.Orders.Domain/Orders/LineItem.cs

@@ -1,7 +1,8 @@
 using Ardalis.GuardClauses;
-using SharedKernel.Domain.Base;
-using SharedKernel.Domain.Entities;
-using SharedKernel.Domain.Identifiers;
+using Common.SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Entities;
+using Common.SharedKernel.Domain.Exceptions;
+using Common.SharedKernel.Domain.Identifiers;
 
 namespace Modules.Orders.Domain.Orders;
 

src/Modules/Orders/Modules.Orders.Domain/Orders/LineItemCreatedEvent.cs

@@ -1,4 +1,4 @@
-using SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Base;
 
 namespace Modules.Orders.Domain.Orders;
 
@@ -7,4 +7,4 @@ public record LineItemCreatedEvent(LineItemId LineItemId, OrderId Order) : Domai
     public LineItemCreatedEvent(LineItem lineItem) : this(lineItem.Id, lineItem.OrderId) { }
 
     public static LineItemCreatedEvent Create(LineItem lineItem) => new(lineItem.Id, lineItem.OrderId);
-}
+}

src/Modules/Orders/Modules.Orders.Domain/Orders/Order.cs

@@ -1,9 +1,9 @@
 using Ardalis.GuardClauses;
+using Common.SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Entities;
+using Common.SharedKernel.Domain.Exceptions;
+using Common.SharedKernel.Domain.Identifiers;
 using Modules.Orders.Domain.Customers;
-using SharedKernel.Domain.Base;
-using SharedKernel.Domain.Entities;
-using SharedKernel.Domain.Exceptions;
-using SharedKernel.Domain.Identifiers;
 
 namespace Modules.Orders.Domain.Orders;
 

src/Modules/Orders/Modules.Orders.Domain/Orders/OrderCreatedEvent.cs

@@ -1,5 +1,5 @@
-using Modules.Orders.Domain.Customers;
-using SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Base;
+using Modules.Orders.Domain.Customers;
 
 namespace Modules.Orders.Domain.Orders;
 

src/Modules/Orders/Modules.Orders.Domain/Orders/OrderReadyForShippingEvent.cs

@@ -1,4 +1,4 @@
-using SharedKernel.Domain.Base;
+using Common.SharedKernel.Domain.Base;
 
 namespace Modules.Orders.Domain.Orders;
 

src/Modules/Warehouse/Modules.Warehouse.Application/Categories/CategoryService.cs

@@ -0,0 +1,19 @@
+using Modules.Warehouse.Application.Common.Interfaces;
+using Modules.Warehouse.Domain.Categories;
+
+namespace Modules.Warehouse.Application.Categories;
+
+public class CategoryRepository : ICategoryRepository
+{
+    private readonly IWarehouseDbContext _dbContext;
+
+    public CategoryRepository(IWarehouseDbContext dbContext)
+    {
+        _dbContext = dbContext;
+    }
+
+    public bool CategoryExists(string categoryName)
+    {
+        return _dbContext.Categories.Any(c => c.Name == categoryName);
+    }
+}

src/Modules/Warehouse/Modules.Warehouse.Application/Common/Interfaces/IWarehouseDbContext.cs

@@ -0,0 +1,12 @@
+using Microsoft.EntityFrameworkCore;
+using Modules.Warehouse.Domain.Categories;
+using Modules.Warehouse.Domain.Products;
+
+namespace Modules.Warehouse.Application.Common.Interfaces;
+
+public interface IWarehouseDbContext
+{
+    public DbSet<Category> Categories { get; }
+
+    public DbSet<Product> Products { get; }
+}

src/Modules/Warehouse/Modules.Warehouse.Application/Modules.Warehouse.Application.csproj

@@ -6,6 +6,15 @@
         <Nullable>enable</Nullable>
     </PropertyGroup>
 
+    <ItemGroup>
+        <PackageReference Include="Ardalis.Specification.EntityFrameworkCore" Version="8.0.0" />
+        <PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="11.9.0" />
+        <PackageReference Include="MediatR" Version="12.2.0" />
+        <PackageReference Include="Microsoft.EntityFrameworkCore" Version="8.0.0" />
+        <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="8.0.0" />
+        <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="8.0.0" />
+    </ItemGroup>
+
     <ItemGroup>
       <ProjectReference Include="..\Modules.Warehouse.Domain\Modules.Warehouse.Domain.csproj" />
     </ItemGroup>

src/Modules/Warehouse/Modules.Warehouse.Application/Products/Queries/GetProducts/GetProductsQuery.cs

@@ -0,0 +1,26 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using Modules.Warehouse.Application.Common.Interfaces;
+
+namespace Modules.Warehouse.Application.Products.Queries.GetProducts;
+
+public record GetProductsQuery : IRequest<IEnumerable<ProductDto>>;
+
+public record ProductDto(Guid Id, string Sku, string Name, decimal Price);
+
+public class GetProductsQueryHandler : IRequestHandler<GetProductsQuery, IEnumerable<ProductDto>>
+{
+    private readonly IWarehouseDbContext _dbContext;
+
+    public GetProductsQueryHandler(IWarehouseDbContext dbContext)
+    {
+        _dbContext = dbContext;
+    }
+
+    public async Task<IEnumerable<ProductDto>> Handle(GetProductsQuery request, CancellationToken cancellationToken)
+    {
+        return await _dbContext.Products
+            .Select(p => new ProductDto(p.Id.Value, p.Sku.Value, p.Name, p.Price.Amount))
+            .ToListAsync(cancellationToken: cancellationToken);
+    }
+}