add create user

Author: TranHuyThang9999

Controllers/UsersController.cs

@@ -1,4 +1,5 @@
 using MediatR;
+using Microsoft.AspNetCore.Http.HttpResults;
 using Microsoft.AspNetCore.Mvc;
 using PaymentCoreServiceApi.Features.Users.Commands;
 
@@ -18,7 +19,7 @@ public UsersController(IMediator mediator)
     [HttpPost]
     public async Task<IActionResult> Create([FromBody] CreateUserCommand command)
     {
-        var userId = await _mediator.Send(command);
-        return CreatedAtAction(nameof(Create), new { id = userId }, userId);
+        var user = await _mediator.Send(command);
+        return Ok(user);
     }
 }

Core/Interfaces/Repositories/IUnitOfWork/IUnitOfWork.cs

@@ -1,6 +1,7 @@
 namespace PaymentCoreServiceApi.Core.Interfaces.Repositories.IUnitOfWork;
 
-public interface IUnitOfWork
+public interface IDbUnitOfWork
 {
     Task CommitAsync(CancellationToken cancellationToken = default);
+    void Commit();
 }

Core/Interfaces/Repositories/Write/IBaseWriteOnlyRepository.cs

@@ -1,6 +1,8 @@
+using PaymentCoreServiceApi.Core.Interfaces.Repositories.IUnitOfWork;
+
 namespace PaymentCoreServiceApi.Core.Interfaces.Repositories.Write
 {
-    public interface IBaseWriteOnlyRepository<TEntity> where TEntity : class
+    public interface IBaseWriteOnlyRepository<TEntity> : IDbUnitOfWork where TEntity : class
     {
         Task<TEntity> AddAsync(TEntity entity, string[]? excludeProperties = null);
         Task<List<TEntity>> AddRangeAsync(IEnumerable<TEntity> entities);

Features/Users/Commands/CreateUserCommandHandler.cs

@@ -15,26 +15,32 @@ public CreateUserCommandHandler(IUserWriteRepository userWriteRepository)
 
     public async Task<User> Handle(CreateUserCommand request, CancellationToken cancellationToken)
     {
-        var user = new User
+        try
         {
-            NickName = request.NickName,
-            Avatar = request.Avatar,
-            Gender = request.Gender,
-            BirthDate = request.BirthDate,
-            Age = request.Age,
-            Email = request.Email,
-            UserName = request.UserName,
-            Password = request.Password,
-            PhoneNumber = request.PhoneNumber,
-            Address = request.Address,
-            Active = true,
-        };
+            var user = new User
+            {
+                NickName = request.NickName,
+                Avatar = request.Avatar,
+                Gender = request.Gender,
+                BirthDate = request.BirthDate,
+                Age = request.Age,
+                Email = request.Email,
+                UserName = request.UserName,
+                Password = request.Password, // Note: In production, hash this password
+                PhoneNumber = request.PhoneNumber,
+                Address = request.Address,
+                Active = true
+            };
 
-
-        var result = await _userWriteRepository.AddAsync(user);
+            // Add the user without auto-commit
+            var result = await _userWriteRepository.AddAsync(user);
+            await _userWriteRepository.CommitAsync();
+            return result;
+        }
+        catch (Exception ex)
+        {
+            throw;
+        }
 
-        return result;
     }
-
-    public IUserWriteRepository UserWriteRepository => _userWriteRepository;
 }

Infrastructure/Repositories/UnitOfWork/UnitOfWork.cs

@@ -3,18 +3,23 @@
 
 namespace PaymentCoreServiceApi.Infrastructure.Repositories.UnitOfWork
 {
-    public class UnitOfWork(AppDbContext context) : IUnitOfWork, IDisposable
+    public class UnitOfWork(AppDbContext context) : IDbUnitOfWork, IDisposable
     {
         private readonly AppDbContext _context = context ?? throw new ArgumentNullException(nameof(context));
 
-        public async Task CommitAsync(CancellationToken cancellationToken = default)
-        {
-            await _context.SaveChangesAsync(cancellationToken);
-        }
+    public async Task CommitAsync(CancellationToken cancellationToken = default)
+    {
+        await _context.SaveChangesAsync(cancellationToken);
+    }
 
-        public void Dispose()
-        {
-            _context.Dispose();
+    public void Commit()
+    {
+        _context.SaveChanges();
+    }
+
+    public void Dispose()
+    {
+        _context.Dispose();
         }
     }
 }

Infrastructure/Repositories/Write/EfBaseWriteOnlyRepository.cs

@@ -1,5 +1,6 @@
 using PaymentCoreServiceApi.Core.Entities.BaseModel;
 using PaymentCoreServiceApi.Core.Interfaces.Repositories.Write;
+using PaymentCoreServiceApi.Core.Interfaces.Repositories.IUnitOfWork;
 using PaymentCoreServiceApi.Infrastructure.DbContexts;
 using Microsoft.EntityFrameworkCore;
 
@@ -14,45 +15,39 @@ public class EfBaseWriteOnlyRepository<TEntity>(AppDbContext context) : IBaseWri
     public async Task<TEntity> AddAsync(TEntity entity, string[]? excludeProperties = null)
     {
         await DbSet.AddAsync(entity);
-        await Context.SaveChangesAsync();
         return entity;
     }
 
     public async Task<List<TEntity>> AddRangeAsync(IEnumerable<TEntity> entities)
     {
         var entityBases = entities as TEntity[] ?? entities.ToArray();
         await DbSet.AddRangeAsync(entityBases);
-        await Context.SaveChangesAsync();
         return entityBases.ToList();
     }
 
     public async Task<TEntity> UpdateAsync(TEntity entity, string[]? excludeProperties = null)
     {
         DbSet.Update(entity);
-        await Context.SaveChangesAsync();
         return entity;
     }
 
     public async Task<List<TEntity>> UpdateBatchAsync(IEnumerable<TEntity> entities, string[]? excludeProperties = null)
     {
         var entityBases = entities as TEntity[] ?? entities.ToArray();
         DbSet.UpdateRange(entityBases);
-        await Context.SaveChangesAsync();
         return entityBases.ToList();
     }
 
     public async Task<TEntity> DeleteAsync(TEntity entity)
     {
         DbSet.Remove(entity);
-        await Context.SaveChangesAsync();
         return entity;
     }
 
     public async Task<List<TEntity>> DeleteBatchAsync(IEnumerable<TEntity> entities)
     {
         IEnumerable<TEntity> entityBases = entities.ToList();
         DbSet.RemoveRange(entityBases);
-        await Context.SaveChangesAsync();
         return entityBases.ToList();
     }
 
@@ -70,4 +65,14 @@ public void Dispose()
     {
         Context.Dispose();
     }
+
+    public async Task CommitAsync(CancellationToken cancellationToken = default)
+    {
+        await Context.SaveChangesAsync(cancellationToken);
+    }
+
+    public void Commit()
+    {
+        Context.SaveChanges();
+    }
 }

Program.cs

@@ -2,7 +2,9 @@
 using Microsoft.EntityFrameworkCore;
 using PaymentCoreServiceApi.Infrastructure.DbContexts;
 using PaymentCoreServiceApi.Core.Interfaces.Repositories.Write;
+using PaymentCoreServiceApi.Core.Interfaces.Repositories.IUnitOfWork;
 using PaymentCoreServiceApi.Infrastructure.Repositories.Write;
+using PaymentCoreServiceApi.Infrastructure.Repositories.UnitOfWork;
 using MediatR;
 
 var builder = WebApplication.CreateBuilder(args);