Implement MediatR, Refactor CreateCommunity

src/LinkMe/LinkMe.Api/Controllers/CommunitiesController.cs

@@ -1,25 +1,20 @@
-using LinkMe.ApplicationServices;
+using LinkMe.ApplicationServices.Communities;
 using LinkMe.Domain;
 
+using MediatR;
+
 using Microsoft.AspNetCore.Mvc;
 
 namespace LinkMe.Api.Controllers
 {
     [ApiController]
     [Route("[controller]")]
-    public class CommunitiesController: ControllerBase
-    {
-        private readonly CreateCommunity.Handler _createCommunityHandler;
-
-        public CommunitiesController(CreateCommunity.Handler createCommunityHandler)
-        {
-            _createCommunityHandler = createCommunityHandler;
-        }
 
+
+    public class CommunitiesController(ISender sender) : ControllerBase
+    {
         [HttpPost]
-        public Community RegisterCommunity(CreateCommunity.Command community)
-        {
-            return _createCommunityHandler.Handle(community);
-        }
+        public async Task<Community> RegisterCommunity(RegisterCommunity.Request request) => 
+            await sender.Send(request);
     }
 }

src/LinkMe/LinkMe.Api/LinkMe.Api.csproj

@@ -8,6 +8,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="MediatR" Version="12.4.1" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="8.0.7">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

src/LinkMe/LinkMe.Api/LinkMe.Api.http

@@ -1,6 +1,6 @@
 @LinkMe.Api_HostAddress = http://localhost:5143
 
-GET {{LinkMe.Api_HostAddress}}/weatherforecast/
+GET {{LinkMe.Api_HostAddress}}/communities/
 Accept: application/json
 
 ###

src/LinkMe/LinkMe.Api/Program.cs

@@ -1,18 +1,13 @@
 
 using LinkMe.ApplicationServices;
+using LinkMe.ApplicationServices.Communities;
 using LinkMe.Domain.Contracts;
 using LinkMe.Infrastructure;
 using LinkMe.Infrastructure.Database;
 using LinkMe.Infrastructure.Sqlite;
 using LinkMe.Infrastructure.SqlServer;
 
-using Microsoft.Data.Sqlite;
 using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore.Design;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-
-using static Microsoft.EntityFrameworkCore.DbLoggerCategory.Database;
 
 namespace LinkMe.Api
 {
@@ -22,6 +17,8 @@ public static void Main(string[] args)
         {
             var builder = WebApplication.CreateBuilder(args);
 
+            builder.Services.AddMediatR(configuration=>configuration.RegisterServicesFromAssembly(typeof(RegisterCommunity).Assembly));
+
             //Add services to the container.
 
             if (builder.Environment.IsDevelopment())
@@ -51,8 +48,6 @@ public static void Main(string[] args)
                 builder.Services.AddDbContext<LinkMeDbContext, LinkMeSqlServerDbContext>();
 
             builder.Services.AddScoped(typeof(IBaseRepository<>), typeof(BaseRepository<>));
-            builder.Services.AddScoped<CreateCommunity.Handler>();
-
 
             builder.Services.AddControllers();
             // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle

src/LinkMe/LinkMe.ApplicationServices/Communities/RegisterCommunity.cs

@@ -0,0 +1,29 @@
+using LinkMe.Domain;
+using LinkMe.Domain.Contracts;
+
+using MediatR;
+
+namespace LinkMe.ApplicationServices.Communities
+{
+    public class RegisterCommunity
+    {
+        public record Request(string Name, string Description)
+        : IRequest<Community>
+        {
+            //public string Category { get; set; }
+            public Community ToCommunity() =>
+                new() { Name = Name, Description = Description };
+        }
+
+        public class Handler(IBaseRepository<Community> _repository)
+            : IRequestHandler<Request, Community>
+        {
+            public async Task<Community> Handle(Request request, CancellationToken cancellationToken)
+            {
+                var entity = request.ToCommunity();
+                var result = await _repository.AddAsync(entity);
+                return result;
+            }
+        }
+    }
+}

src/LinkMe/LinkMe.ApplicationServices/LinkMe.ApplicationServices.csproj

@@ -6,6 +6,10 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="MediatR" Version="12.4.1" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\LinkMe.Domain\LinkMe.Domain.csproj" />
   </ItemGroup>

src/LinkMe/LinkMe.Domain/Contracts/IBaseRepository.cs

@@ -4,7 +4,7 @@ public interface IBaseRepository<T> where T : DomainEntity
     {
         T Get(int id);
         //ICollection<T> GetMany(int id);
-        T Add(T item);
+        Task<T> AddAsync(T item);
         T Update(T item);
         void Delete(T item);
     }

src/LinkMe/LinkMe.Infrastructure/BaseRepository.cs

@@ -13,10 +13,10 @@ public BaseRepository(LinkMeDbContext dbContext)
             _dbContext = dbContext;
         }
 
-        public T Add(T item)
+        public async Task<T> AddAsync(T item)
         {
             var entity = _dbContext.Add(item).Entity;
-            _dbContext.SaveChanges();
+            await _dbContext.SaveChangesAsync();
             return entity;
         }
 

src/LinkMe/LinkMe.sln

@@ -21,7 +21,7 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "LinkMe.Infrastructure.SqlSe
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tests", "tests", "{FF07EE0E-7140-4398-A94C-B14117492853}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LinkMe.Architecture.Tests", "LinkMe.Architecture.Tests\LinkMe.Architecture.Tests.csproj", "{C5347917-E6BE-45B9-93D9-5D05E70AFDB6}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "LinkMe.Architecture.Tests", "LinkMe.Architecture.Tests\LinkMe.Architecture.Tests.csproj", "{C5347917-E6BE-45B9-93D9-5D05E70AFDB6}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution