1

New/Payeh.SharedKernel/EntityFrameworkCore/Domain/DomainModelBuilderExtensions.cs

@@ -25,10 +25,23 @@ public static PropertyBuilder<TBussinedId> HasBusinessIdConversion<TBussinedId,
                 convertFromProviderExpression
             );
         }
+        public static PropertyBuilder<TBussinedId> HasEnumeration<TBussinedId>(
+            this PropertyBuilder<TBussinedId> propertyBuilder)
+            where TBussinedId : Enumeration
+        {
+            Expression<Func<TBussinedId, int>> convertToProviderExpression = c => c.Id;
 
+            // Convert TKey to BusinessId using the FromValue method of the BusinessId class
+            Expression<Func<int, TBussinedId>> convertFromProviderExpression = v => Enumeration.FromId<TBussinedId>(v)!;
+
+            return propertyBuilder.HasConversion(
+                convertToProviderExpression,
+                convertFromProviderExpression
+            );
+        }
         public static PropertyBuilder<TBussinedId> HasBusinessIdConversion<TBussinedId>(
             this PropertyBuilder<TBussinedId> propertyBuilder)
-            where TBussinedId : GuidBusinessId<TBussinedId>, new()
+            where TBussinedId : GuidBusinessId<TBussinedId>?, new()
         {
             return propertyBuilder.HasBusinessIdConversion<TBussinedId, Guid>();
         }

New/Payeh.SharedKernel/EntityFrameworkCore/Domain/EfCoreReadOnlyRepository.cs

@@ -3,7 +3,6 @@
 using Payeh.SharedKernel.Domain;
 using Payeh.SharedKernel.Domain.Repositories;
 using Payeh.SharedKernel.EntityFrameworkCore.UnitofWork;
-using Payeh.SharedKernel.EntityFrameworkCore.UnitOfWork;
 
 namespace Payeh.SharedKernel.EntityFrameworkCore.Domain;
 

New/Payeh.SharedKernel/EntityFrameworkCore/EntityFrameworkCoreExtensions.cs

@@ -2,7 +2,6 @@
 using System.Linq;
 using Payeh.SharedKernel.EntityFrameworkCore.Domain;
 using Payeh.SharedKernel.EntityFrameworkCore.UnitofWork;
-using Payeh.SharedKernel.EntityFrameworkCore.UnitOfWork;
 using Payeh.SharedKernel.UnitOfWork;
 
 namespace Payeh.SharedKernel.EntityFrameworkCore;

New/Payeh.SharedKernel/EntityFrameworkCore/UnitofWork/EfCoreDbContextProvider.cs

@@ -1,9 +1,9 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging.Abstractions;
-using Payeh.SharedKernel.EntityFrameworkCore.UnitofWork;
 using Payeh.SharedKernel.UnitOfWork;
+using Payeh.SharedKernel.UnitOfWork.Null;
 
-namespace Payeh.SharedKernel.EntityFrameworkCore.UnitOfWork;
+namespace Payeh.SharedKernel.EntityFrameworkCore.UnitofWork;
 
 /// <summary>
 ///     Provides a DbContext instance tied to the current Unit of Work.

New/Payeh.SharedKernel/UnitOfWork/IUnitOfWorkOptions.cs

@@ -1,6 +1,8 @@
 
 using System.Data;
 
+namespace Payeh.SharedKernel.UnitOfWork;
+
 public interface IUnitOfWorkOptions
 {
         public bool IsUnitOfWorkEnabled { get; set; } 

New/Payeh.SharedKernel/UnitOfWork/Null/NullUnitOfWorkManager.cs

@@ -1,6 +1,4 @@
-using Payeh.SharedKernel.UnitOfWork.Null;
-
-namespace Payeh.SharedKernel.UnitOfWork;
+namespace Payeh.SharedKernel.UnitOfWork.Null;
 
 /// <summary>
 ///     A null implementation of the Unit of Work Manager that returns a NullUnitOfWork.

New/Payeh.SharedKernel/UnitOfWork/UnitOfWorkOptions.cs

@@ -1,6 +1,8 @@
 
 using System.Data;
 
+namespace Payeh.SharedKernel.UnitOfWork;
+
 public class UnitOfWorkOptions : IUnitOfWorkOptions
 {
     public bool IsUnitOfWorkEnabled { get; set; } = true;

Nezam.EES.Service.Identity/Application/Dto/Users/UserDto.cs → Nezam.EES.Slice.Identity/Application/Dto/Users/UserDto.cs

@@ -1,3 +1,4 @@
+using Nezam.EES.Service.Identity.Application.Dto.Roles;
 using Nezam.EES.Service.Identity.Domains.Users;
 using Nezam.EEs.Shared.Domain.Identity.User;
 using Nezam.EEs.Shared.Domain.Identity.User.ValueObjects;
@@ -10,6 +11,7 @@ public class UserDto
     public UserNameId UserName { get; set; } 
     public UserEmailValue? Email { get; set; } 
     public UserProfileValue Profile { get; set; } // Optional profile info
+    public List<RoleDto> Roles { get; set; } // Optional profile info
 
     // Static method for mapping UserEntity to UserDto
     public static UserDto FromEntity(UserEntity user)
@@ -19,7 +21,8 @@ public static UserDto FromEntity(UserEntity user)
             UserId = user.UserId,
             UserName = user.UserName, // Assuming UserName is a value object
             Email = user.Email,      // Assuming Email is a value object
-            Profile = user.Profile
+            Profile = user.Profile,
+            Roles = user.Roles.Select(x => RoleDto.FromEntity(x)).ToList()
         };
     }
 }

Nezam.EES.Service.Identity/Application/UseCases/Roles/CreateRole/CreateRoleEndpoint.cs → Nezam.EES.Slice.Identity/Application/UseCases/Roles/CreateRole/CreateRoleEndpoint.cs

@@ -35,7 +35,7 @@ public override async Task HandleAsync(CreateRoleRequest req, CancellationToken
         {
             // شروع تراکنش
 
-            // ایجاد نقش جدید با استفاده از Domain Service
+            // ایجاد نقش جدید با استفاده از Domains Service
             var roleResult = await _roleDomainService.CreateRoleAsync(new RoleEntity(req.Id, req.Title));
 
             if (roleResult.IsFailure)

Nezam.EES.Slice.Identity/Application/UseCases/Users/AssignRoles/AssignRolesEndpoint.cs

@@ -0,0 +1,76 @@
+using Consul;
+using FastEndpoints;
+using Nezam.EES.Service.Identity.Domains.Roles.DomainServices;
+using Nezam.EES.Service.Identity.Domains.Users;
+using Nezam.EES.Service.Identity.Domains.Users.DomainServices;
+using Nezam.EEs.Shared.Domain.Identity.Roles;
+using Nezam.EEs.Shared.Domain.Identity.User;
+using Payeh.SharedKernel.UnitOfWork;
+
+namespace Nezam.EES.Service.Identity.Application.UseCases.Users.AssignRoles;
+
+public class AssignRolesEndpoint : Endpoint<AssignRolesRecord>
+{
+    private readonly IUserDomainService _userDomainService;
+    private readonly IRoleDomainService _roleDomainService;
+    private readonly IUnitOfWorkManager _unitOfWork;
+
+    public AssignRolesEndpoint(IUserDomainService userDomainService, IRoleDomainService roleDomainService, IUnitOfWorkManager unitOfWork)
+    {
+        _userDomainService = userDomainService;
+        _roleDomainService = roleDomainService;
+        _unitOfWork = unitOfWork;
+    }
+
+    public override void Configure()
+    {
+        Put("/api/users/{id:guid}/assign-roles");
+    }
+
+    public override async Task HandleAsync(AssignRolesRecord req, CancellationToken ct)
+    {
+        var userIdGuid = Route<Guid>("id", true);
+        var userId = UserId.NewId(userIdGuid);
+
+        using var uow = _unitOfWork.Begin();
+        try
+        {
+            var existingUserResult = await _userDomainService.GetUserByIdAsync(userId);
+
+            if (existingUserResult.IsFailure)
+            {
+                ThrowError("User not found.");
+            }
+
+            var existingUser = existingUserResult.Data;
+
+            // Retrieve roles by IDs from the request
+            var roleIds = req.Roles.Select(RoleId.NewId).ToArray();
+
+
+
+
+            var updateResult = await _userDomainService.AssignRoleAsync(existingUser,roleIds);
+
+            if (updateResult.IsFailure)
+            {
+                await SendErrorsAsync(cancellation: ct);
+                return;
+            }
+
+            await uow.CommitAsync(ct);
+
+            await SendOkAsync(ct);
+        }
+        catch (Exception ex)
+        {
+            await uow.RollbackAsync(ct);
+            ThrowError($"Error while assigning roles to user: {ex.Message}");
+        }
+    }
+}
+
+public record AssignRolesRecord
+{
+    public List<string> Roles { get; set; } = new();
+}

Nezam.EES.Slice.Identity/Application/UseCases/Users/CreateUser/CreateUserEndpoint.cs

@@ -0,0 +1,57 @@
+using FastEndpoints;
+using Nezam.EES.Service.Identity.Domains.Users;
+using Nezam.EES.Service.Identity.Domains.Users.DomainServices;
+using Nezam.EEs.Shared.Domain.Identity.User;
+using Nezam.EEs.Shared.Domain.Identity.User.ValueObjects;
+using Payeh.SharedKernel.UnitOfWork;
+
+namespace Nezam.EES.Service.Identity.Application.UseCases.Users.CreateUser;
+
+public class CreateUserEndpoint : Endpoint<CreateUserRecord>
+{
+    private readonly IUserDomainService _userDomainService;
+    private readonly IUnitOfWorkManager _unitOfWork;
+
+    public CreateUserEndpoint(IUserDomainService roleDomainService, IUnitOfWorkManager unitOfWork)
+    {
+        _userDomainService = roleDomainService;
+        _unitOfWork = unitOfWork;
+    }
+
+    public override void Configure()
+    {
+        Post("/api/users");
+
+    }
+
+    public override async Task HandleAsync(CreateUserRecord req, CancellationToken ct)
+    {
+        if (string.IsNullOrWhiteSpace(req.UserName))
+        {
+            ThrowError("UserName cannot be empty.");
+        }
+
+        using var uow = _unitOfWork.Begin();
+        try
+        {
+
+            var user = new UserEntity(UserId.NewId(), UserNameId.NewId(req.UserName),new UserPasswordValue(req.Password),new UserProfileValue(req.FirstName,req.LastName),new UserEmailValue(req.Email));
+            var createResult = await _userDomainService.Create(user);
+
+            if (createResult.IsFailure)
+            {
+                await SendErrorsAsync(cancellation: ct);
+                return;
+            }
+            // ذخیره تغییرات
+            await uow.CommitAsync(ct);
+
+            await SendOkAsync(ct);
+        }
+        catch (Exception ex)
+        {
+            await uow.RollbackAsync(ct);
+            ThrowError($"Error while updating role: {ex.Message}");
+        }
+    }
+}

Nezam.EES.Slice.Identity/Application/UseCases/Users/CreateUser/CreateUserRecord.cs

@@ -0,0 +1,3 @@
+namespace Nezam.EES.Service.Identity.Application.UseCases.Users.CreateUser;
+
+public record CreateUserRecord(string UserName,string Password,string FirstName,string LastName,string Email);