Changeset d300631 for ChapterX.Application/Auth/RegisterHandler.cs

Timestamp:

04/28/26 14:53:32 (2 months ago)

Author:

kikisrbinoska <srbinoskakristina07@…>

Branches:

main

Children:

b373fea

Parents:

dc383dd

Message:

Added transactions and pooling

File:

• ChapterX.Application/Auth/RegisterHandler.cs (modified) (3 diffs)

ChapterX.Application/Auth/RegisterHandler.cs

@@ +1 @@
+using ChapterX.Application.Abstractions;
 using ChapterX.Domain.Repositories;
 using MediatR;
@@ -8 +9 @@
         private readonly IUserRepository _userRepository;
         private readonly IWriterRepository _writerRepository;
+        private readonly IApplicationDbContext _context;
 
-        public RegisterHandler(IUserRepository userRepository, IWriterRepository writerRepository)
+        public RegisterHandler(IUserRepository userRepository, IWriterRepository writerRepository, IApplicationDbContext context)
         {
             _userRepository = userRepository;
             _writerRepository = writerRepository;
+            _context = context;
         }
 
@@ -21 +24 @@
                 throw new InvalidOperationException("Email already in use.");
 
-            var user = new Domain.Entities.User
+            await using var transaction = await _context.BeginTransactionAsync(cancellationToken);
+            try
             {
-                Username = request.Username,
-                Email = request.Email,
-                Name = request.Name,
-                Surname = request.Surname,
-                Password = BCrypt.Net.BCrypt.HashPassword(request.Password),
-                CreatedAt = DateTime.UtcNow,
-                UpdatedAt = DateTime.UtcNow
-            };
+                var user = new Domain.Entities.User
+                {
+                    Username = request.Username,
+                    Email = request.Email,
+                    Name = request.Name,
+                    Surname = request.Surname,
+                    Password = BCrypt.Net.BCrypt.HashPassword(request.Password),
+                    CreatedAt = DateTime.UtcNow,
+                    UpdatedAt = DateTime.UtcNow
+                };
 
-            await _userRepository.AddAsync(user, cancellationToken);
+                await _userRepository.AddAsync(user, cancellationToken);
 
-            var writer = new Domain.Entities.Writer { Id = user.Id };
-            await _writerRepository.AddAsync(writer, cancellationToken);
+                var writer = new Domain.Entities.Writer { Id = user.Id };
+                await _writerRepository.AddAsync(writer, cancellationToken);
 
-            return new RegisterResponse(user.Id, user.Username, user.Email);
+                await transaction.CommitAsync(cancellationToken);
+                return new RegisterResponse(user.Id, user.Username, user.Email);
+            }
+            catch
+            {
+                await transaction.RollbackAsync(cancellationToken);
+                throw;
+            }
         }
     }