From 070dc794801728f3717c6868ea6204585dd93680 Mon Sep 17 00:00:00 2001 From: malik masis Date: Wed, 9 Nov 2022 17:50:38 +0300 Subject: [PATCH] Fixed space and tab issue --- .../Volo/Abp/Identity/IdentityUserManager.cs | 468 +++++++++--------- .../Users/UserPasswordChangeRequestedEto.cs | 6 +- 2 files changed, 237 insertions(+), 237 deletions(-) diff --git a/modules/identity/src/Volo.Abp.Identity.Domain/Volo/Abp/Identity/IdentityUserManager.cs b/modules/identity/src/Volo.Abp.Identity.Domain/Volo/Abp/Identity/IdentityUserManager.cs index 905745ed21..d0520c9ef9 100644 --- a/modules/identity/src/Volo.Abp.Identity.Domain/Volo/Abp/Identity/IdentityUserManager.cs +++ b/modules/identity/src/Volo.Abp.Identity.Domain/Volo/Abp/Identity/IdentityUserManager.cs @@ -19,238 +19,238 @@ namespace Volo.Abp.Identity; public class IdentityUserManager : UserManager, IDomainService { - protected IIdentityRoleRepository RoleRepository { get; } - protected IIdentityUserRepository UserRepository { get; } - protected IOrganizationUnitRepository OrganizationUnitRepository { get; } - protected ISettingProvider SettingProvider { get; } - protected ICancellationTokenProvider CancellationTokenProvider { get; } - - protected override CancellationToken CancellationToken => CancellationTokenProvider.Token; - - public IdentityUserManager( - IdentityUserStore store, - IIdentityRoleRepository roleRepository, - IIdentityUserRepository userRepository, - IOptions optionsAccessor, - IPasswordHasher passwordHasher, - IEnumerable> userValidators, - IEnumerable> passwordValidators, - ILookupNormalizer keyNormalizer, - IdentityErrorDescriber errors, - IServiceProvider services, - ILogger logger, - ICancellationTokenProvider cancellationTokenProvider, - IOrganizationUnitRepository organizationUnitRepository, - ISettingProvider settingProvider) - : base( - store, - optionsAccessor, - passwordHasher, - userValidators, - passwordValidators, - keyNormalizer, - errors, - services, - logger) - { - OrganizationUnitRepository = organizationUnitRepository; - SettingProvider = settingProvider; - RoleRepository = roleRepository; - UserRepository = userRepository; - CancellationTokenProvider = cancellationTokenProvider; - } - - public virtual async Task CreateAsync(IdentityUser user, string password, bool validatePassword) - { - var result = await UpdatePasswordHash(user, password, validatePassword); - if (!result.Succeeded) - { - return result; - } - - return await CreateAsync(user); - } - - public virtual async Task GetByIdAsync(Guid id) - { - var user = await Store.FindByIdAsync(id.ToString(), CancellationToken); - if (user == null) - { - throw new EntityNotFoundException(typeof(IdentityUser), id); - } - - return user; - } - - public virtual async Task SetRolesAsync([NotNull] IdentityUser user, - [NotNull] IEnumerable roleNames) - { - Check.NotNull(user, nameof(user)); - Check.NotNull(roleNames, nameof(roleNames)); - - var currentRoleNames = await GetRolesAsync(user); - - var result = await RemoveFromRolesAsync(user, currentRoleNames.Except(roleNames).Distinct()); - if (!result.Succeeded) - { - return result; - } - - result = await AddToRolesAsync(user, roleNames.Except(currentRoleNames).Distinct()); - if (!result.Succeeded) - { - return result; - } - - return IdentityResult.Success; - } - - public virtual async Task IsInOrganizationUnitAsync(Guid userId, Guid ouId) - { - var user = await UserRepository.GetAsync(userId, cancellationToken: CancellationToken); - return user.IsInOrganizationUnit(ouId); - } - - public virtual async Task IsInOrganizationUnitAsync(IdentityUser user, OrganizationUnit ou) - { - await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, - CancellationTokenProvider.Token); - return user.IsInOrganizationUnit(ou.Id); - } - - public virtual async Task AddToOrganizationUnitAsync(Guid userId, Guid ouId) - { - await AddToOrganizationUnitAsync( - await UserRepository.GetAsync(userId, cancellationToken: CancellationToken), - await OrganizationUnitRepository.GetAsync(ouId, cancellationToken: CancellationToken) - ); - } - - public virtual async Task AddToOrganizationUnitAsync(IdentityUser user, OrganizationUnit ou) - { - await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, - CancellationTokenProvider.Token); - - if (user.OrganizationUnits.Any(cou => cou.OrganizationUnitId == ou.Id)) - { - return; - } - - await CheckMaxUserOrganizationUnitMembershipCountAsync(user.OrganizationUnits.Count + 1); - - user.AddOrganizationUnit(ou.Id); - await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); - } - - public virtual async Task RemoveFromOrganizationUnitAsync(Guid userId, Guid ouId) - { - var user = await UserRepository.GetAsync(userId, cancellationToken: CancellationToken); - user.RemoveOrganizationUnit(ouId); - await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); - } - - public virtual async Task RemoveFromOrganizationUnitAsync(IdentityUser user, OrganizationUnit ou) - { - await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, - CancellationTokenProvider.Token); - - user.RemoveOrganizationUnit(ou.Id); - await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); - } - - public virtual async Task SetOrganizationUnitsAsync(Guid userId, params Guid[] organizationUnitIds) - { - await SetOrganizationUnitsAsync( - await UserRepository.GetAsync(userId, cancellationToken: CancellationToken), - organizationUnitIds - ); - } - - public virtual async Task SetOrganizationUnitsAsync(IdentityUser user, params Guid[] organizationUnitIds) - { - Check.NotNull(user, nameof(user)); - Check.NotNull(organizationUnitIds, nameof(organizationUnitIds)); - - await CheckMaxUserOrganizationUnitMembershipCountAsync(organizationUnitIds.Length); - - await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, - CancellationTokenProvider.Token); - - //Remove from removed OUs - foreach (var ouId in user.OrganizationUnits.Select(uou => uou.OrganizationUnitId).ToArray()) - { - if (!organizationUnitIds.Contains(ouId)) - { - user.RemoveOrganizationUnit(ouId); - } - } - - //Add to added OUs - foreach (var organizationUnitId in organizationUnitIds) - { - if (!user.IsInOrganizationUnit(organizationUnitId)) - { - user.AddOrganizationUnit(organizationUnitId); - } - } - - await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); - } - - private async Task CheckMaxUserOrganizationUnitMembershipCountAsync(int requestedCount) - { - var maxCount = - await SettingProvider.GetAsync(IdentitySettingNames.OrganizationUnit.MaxUserMembershipCount); - if (requestedCount > maxCount) - { - throw new BusinessException(IdentityErrorCodes.MaxAllowedOuMembership) - .WithData("MaxUserMembershipCount", maxCount); - } - } - - [UnitOfWork] - public virtual async Task> GetOrganizationUnitsAsync(IdentityUser user, - bool includeDetails = false) - { - await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, - CancellationTokenProvider.Token); - - return await OrganizationUnitRepository.GetListAsync( - user.OrganizationUnits.Select(t => t.OrganizationUnitId), - includeDetails, - cancellationToken: CancellationToken - ); - } - - [UnitOfWork] - public virtual async Task> GetUsersInOrganizationUnitAsync( - OrganizationUnit organizationUnit, - bool includeChildren = false) - { - if (includeChildren) - { - return await UserRepository - .GetUsersInOrganizationUnitWithChildrenAsync(organizationUnit.Code, CancellationToken); - } - else - { - return await UserRepository - .GetUsersInOrganizationUnitAsync(organizationUnit.Id, CancellationToken); - } - } - - public virtual async Task AddDefaultRolesAsync([NotNull] IdentityUser user) - { - await UserRepository.EnsureCollectionLoadedAsync(user, u => u.Roles, CancellationToken); - - foreach (var role in await RoleRepository.GetDefaultOnesAsync(cancellationToken: CancellationToken)) - { - if (!user.IsInRole(role.Id)) - { - user.AddRole(role.Id); - } - } - - return await UpdateUserAsync(user); - } + protected IIdentityRoleRepository RoleRepository { get; } + protected IIdentityUserRepository UserRepository { get; } + protected IOrganizationUnitRepository OrganizationUnitRepository { get; } + protected ISettingProvider SettingProvider { get; } + protected ICancellationTokenProvider CancellationTokenProvider { get; } + + protected override CancellationToken CancellationToken => CancellationTokenProvider.Token; + + public IdentityUserManager( + IdentityUserStore store, + IIdentityRoleRepository roleRepository, + IIdentityUserRepository userRepository, + IOptions optionsAccessor, + IPasswordHasher passwordHasher, + IEnumerable> userValidators, + IEnumerable> passwordValidators, + ILookupNormalizer keyNormalizer, + IdentityErrorDescriber errors, + IServiceProvider services, + ILogger logger, + ICancellationTokenProvider cancellationTokenProvider, + IOrganizationUnitRepository organizationUnitRepository, + ISettingProvider settingProvider) + : base( + store, + optionsAccessor, + passwordHasher, + userValidators, + passwordValidators, + keyNormalizer, + errors, + services, + logger) + { + OrganizationUnitRepository = organizationUnitRepository; + SettingProvider = settingProvider; + RoleRepository = roleRepository; + UserRepository = userRepository; + CancellationTokenProvider = cancellationTokenProvider; + } + + public virtual async Task CreateAsync(IdentityUser user, string password, bool validatePassword) + { + var result = await UpdatePasswordHash(user, password, validatePassword); + if (!result.Succeeded) + { + return result; + } + + return await CreateAsync(user); + } + + public virtual async Task GetByIdAsync(Guid id) + { + var user = await Store.FindByIdAsync(id.ToString(), CancellationToken); + if (user == null) + { + throw new EntityNotFoundException(typeof(IdentityUser), id); + } + + return user; + } + + public virtual async Task SetRolesAsync([NotNull] IdentityUser user, + [NotNull] IEnumerable roleNames) + { + Check.NotNull(user, nameof(user)); + Check.NotNull(roleNames, nameof(roleNames)); + + var currentRoleNames = await GetRolesAsync(user); + + var result = await RemoveFromRolesAsync(user, currentRoleNames.Except(roleNames).Distinct()); + if (!result.Succeeded) + { + return result; + } + + result = await AddToRolesAsync(user, roleNames.Except(currentRoleNames).Distinct()); + if (!result.Succeeded) + { + return result; + } + + return IdentityResult.Success; + } + + public virtual async Task IsInOrganizationUnitAsync(Guid userId, Guid ouId) + { + var user = await UserRepository.GetAsync(userId, cancellationToken: CancellationToken); + return user.IsInOrganizationUnit(ouId); + } + + public virtual async Task IsInOrganizationUnitAsync(IdentityUser user, OrganizationUnit ou) + { + await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, + CancellationTokenProvider.Token); + return user.IsInOrganizationUnit(ou.Id); + } + + public virtual async Task AddToOrganizationUnitAsync(Guid userId, Guid ouId) + { + await AddToOrganizationUnitAsync( + await UserRepository.GetAsync(userId, cancellationToken: CancellationToken), + await OrganizationUnitRepository.GetAsync(ouId, cancellationToken: CancellationToken) + ); + } + + public virtual async Task AddToOrganizationUnitAsync(IdentityUser user, OrganizationUnit ou) + { + await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, + CancellationTokenProvider.Token); + + if (user.OrganizationUnits.Any(cou => cou.OrganizationUnitId == ou.Id)) + { + return; + } + + await CheckMaxUserOrganizationUnitMembershipCountAsync(user.OrganizationUnits.Count + 1); + + user.AddOrganizationUnit(ou.Id); + await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); + } + + public virtual async Task RemoveFromOrganizationUnitAsync(Guid userId, Guid ouId) + { + var user = await UserRepository.GetAsync(userId, cancellationToken: CancellationToken); + user.RemoveOrganizationUnit(ouId); + await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); + } + + public virtual async Task RemoveFromOrganizationUnitAsync(IdentityUser user, OrganizationUnit ou) + { + await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, + CancellationTokenProvider.Token); + + user.RemoveOrganizationUnit(ou.Id); + await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); + } + + public virtual async Task SetOrganizationUnitsAsync(Guid userId, params Guid[] organizationUnitIds) + { + await SetOrganizationUnitsAsync( + await UserRepository.GetAsync(userId, cancellationToken: CancellationToken), + organizationUnitIds + ); + } + + public virtual async Task SetOrganizationUnitsAsync(IdentityUser user, params Guid[] organizationUnitIds) + { + Check.NotNull(user, nameof(user)); + Check.NotNull(organizationUnitIds, nameof(organizationUnitIds)); + + await CheckMaxUserOrganizationUnitMembershipCountAsync(organizationUnitIds.Length); + + await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, + CancellationTokenProvider.Token); + + //Remove from removed OUs + foreach (var ouId in user.OrganizationUnits.Select(uou => uou.OrganizationUnitId).ToArray()) + { + if (!organizationUnitIds.Contains(ouId)) + { + user.RemoveOrganizationUnit(ouId); + } + } + + //Add to added OUs + foreach (var organizationUnitId in organizationUnitIds) + { + if (!user.IsInOrganizationUnit(organizationUnitId)) + { + user.AddOrganizationUnit(organizationUnitId); + } + } + + await UserRepository.UpdateAsync(user, cancellationToken: CancellationToken); + } + + private async Task CheckMaxUserOrganizationUnitMembershipCountAsync(int requestedCount) + { + var maxCount = + await SettingProvider.GetAsync(IdentitySettingNames.OrganizationUnit.MaxUserMembershipCount); + if (requestedCount > maxCount) + { + throw new BusinessException(IdentityErrorCodes.MaxAllowedOuMembership) + .WithData("MaxUserMembershipCount", maxCount); + } + } + + [UnitOfWork] + public virtual async Task> GetOrganizationUnitsAsync(IdentityUser user, + bool includeDetails = false) + { + await UserRepository.EnsureCollectionLoadedAsync(user, u => u.OrganizationUnits, + CancellationTokenProvider.Token); + + return await OrganizationUnitRepository.GetListAsync( + user.OrganizationUnits.Select(t => t.OrganizationUnitId), + includeDetails, + cancellationToken: CancellationToken + ); + } + + [UnitOfWork] + public virtual async Task> GetUsersInOrganizationUnitAsync( + OrganizationUnit organizationUnit, + bool includeChildren = false) + { + if (includeChildren) + { + return await UserRepository + .GetUsersInOrganizationUnitWithChildrenAsync(organizationUnit.Code, CancellationToken); + } + else + { + return await UserRepository + .GetUsersInOrganizationUnitAsync(organizationUnit.Id, CancellationToken); + } + } + + public virtual async Task AddDefaultRolesAsync([NotNull] IdentityUser user) + { + await UserRepository.EnsureCollectionLoadedAsync(user, u => u.Roles, CancellationToken); + + foreach (var role in await RoleRepository.GetDefaultOnesAsync(cancellationToken: CancellationToken)) + { + if (!user.IsInRole(role.Id)) + { + user.AddRole(role.Id); + } + } + + return await UpdateUserAsync(user); + } } diff --git a/modules/users/src/Volo.Abp.Users.Abstractions/Volo/Abp/Users/UserPasswordChangeRequestedEto.cs b/modules/users/src/Volo.Abp.Users.Abstractions/Volo/Abp/Users/UserPasswordChangeRequestedEto.cs index 9bd028b5e2..7eb15137cf 100644 --- a/modules/users/src/Volo.Abp.Users.Abstractions/Volo/Abp/Users/UserPasswordChangeRequestedEto.cs +++ b/modules/users/src/Volo.Abp.Users.Abstractions/Volo/Abp/Users/UserPasswordChangeRequestedEto.cs @@ -8,9 +8,9 @@ namespace Volo.Abp.Users; [EventName("Volo.Abp.Users.UserPasswordChangeRequested")] public class UserPasswordChangeRequestedEto : IMultiTenant { - public Guid? TenantId { get; set; } + public Guid? TenantId { get; set; } - public string UserName { get; set; } + public string UserName { get; set; } - public string Password { get; set; } + public string Password { get; set; } }