using System; using System.Collections.Generic; using System.Drawing; using System.Drawing.Imaging; using System.IO; using System.Linq; using System.Net; using System.Net.Mail; using System.Security; using ASC.Api.Core; using ASC.Common; using ASC.Common.Logging; using ASC.Common.Utils; using ASC.Common.Web; using ASC.Core; using ASC.Core.Common.Settings; using ASC.Core.Tenants; using ASC.Core.Users; using ASC.Data.Reassigns; using ASC.FederatedLogin; using ASC.FederatedLogin.Profile; using ASC.MessagingSystem; using ASC.People; using ASC.People.Models; using ASC.People.Resources; using ASC.Security.Cryptography; using ASC.Web.Api.Models; using ASC.Web.Api.Routing; using ASC.Web.Core; using ASC.Web.Core.PublicResources; using ASC.Web.Core.Users; using ASC.Web.Studio.Core; using ASC.Web.Studio.Core.Notify; using ASC.Web.Studio.UserControls.Statistics; using ASC.Web.Studio.Utility; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http.Extensions; using Microsoft.AspNetCore.Mvc; using Microsoft.Extensions.Options; using SecurityContext = ASC.Core.SecurityContext; namespace ASC.Employee.Core.Controllers { [DefaultRoute] [ApiController] public class PeopleController : ControllerBase { public Tenant Tenant { get { return ApiContext.Tenant; } } private ApiContext ApiContext { get; } private MessageService MessageService { get; } private QueueWorkerReassign QueueWorkerReassign { get; } private QueueWorkerRemove QueueWorkerRemove { get; } private StudioNotifyService StudioNotifyService { get; } private UserManagerWrapper UserManagerWrapper { get; } private UserManager UserManager { get; } private TenantExtra TenantExtra { get; } private TenantStatisticsProvider TenantStatisticsProvider { get; } private UserPhotoManager UserPhotoManager { get; } private SecurityContext SecurityContext { get; } private CookiesManager CookiesManager { get; } private WebItemSecurity WebItemSecurity { get; } private PermissionContext PermissionContext { get; } private AuthContext AuthContext { get; } private WebItemManager WebItemManager { get; } private CustomNamingPeople CustomNamingPeople { get; } private TenantUtil TenantUtil { get; } private CoreBaseSettings CoreBaseSettings { get; } private SetupInfo SetupInfo { get; } private FileSizeComment FileSizeComment { get; } private DisplayUserSettingsHelper DisplayUserSettingsHelper { get; } private Signature Signature { get; } private InstanceCrypto InstanceCrypto { get; } private WebItemSecurityCache WebItemSecurityCache { get; } private MessageTarget MessageTarget { get; } private SettingsManager SettingsManager { get; } private IOptionsSnapshot AccountLinker { get; } private EmployeeWraperFullHelper EmployeeWraperFullHelper { get; } private EmployeeWraperHelper EmployeeWraperHelper { get; } private UserFormatter UserFormatter { get; } public PasswordHasher PasswordHasher { get; } public ILog Log { get; } public PeopleController( MessageService messageService, QueueWorkerReassign queueWorkerReassign, QueueWorkerRemove queueWorkerRemove, StudioNotifyService studioNotifyService, UserManagerWrapper userManagerWrapper, ApiContext apiContext, UserManager userManager, TenantExtra tenantExtra, TenantStatisticsProvider tenantStatisticsProvider, UserPhotoManager userPhotoManager, SecurityContext securityContext, CookiesManager cookiesManager, WebItemSecurity webItemSecurity, PermissionContext permissionContext, AuthContext authContext, WebItemManager webItemManager, CustomNamingPeople customNamingPeople, TenantUtil tenantUtil, CoreBaseSettings coreBaseSettings, SetupInfo setupInfo, FileSizeComment fileSizeComment, DisplayUserSettingsHelper displayUserSettingsHelper, Signature signature, InstanceCrypto instanceCrypto, WebItemSecurityCache webItemSecurityCache, MessageTarget messageTarget, SettingsManager settingsManager, IOptionsMonitor option, IOptionsSnapshot accountLinker, EmployeeWraperFullHelper employeeWraperFullHelper, EmployeeWraperHelper employeeWraperHelper, UserFormatter userFormatter, PasswordHasher passwordHasher) { Log = option.Get("ASC.Api"); MessageService = messageService; QueueWorkerReassign = queueWorkerReassign; QueueWorkerRemove = queueWorkerRemove; StudioNotifyService = studioNotifyService; UserManagerWrapper = userManagerWrapper; ApiContext = apiContext; UserManager = userManager; TenantExtra = tenantExtra; TenantStatisticsProvider = tenantStatisticsProvider; UserPhotoManager = userPhotoManager; SecurityContext = securityContext; CookiesManager = cookiesManager; WebItemSecurity = webItemSecurity; PermissionContext = permissionContext; AuthContext = authContext; WebItemManager = webItemManager; CustomNamingPeople = customNamingPeople; TenantUtil = tenantUtil; CoreBaseSettings = coreBaseSettings; SetupInfo = setupInfo; FileSizeComment = fileSizeComment; DisplayUserSettingsHelper = displayUserSettingsHelper; Signature = signature; InstanceCrypto = instanceCrypto; WebItemSecurityCache = webItemSecurityCache; MessageTarget = messageTarget; SettingsManager = settingsManager; AccountLinker = accountLinker; EmployeeWraperFullHelper = employeeWraperFullHelper; EmployeeWraperHelper = employeeWraperHelper; UserFormatter = userFormatter; PasswordHasher = passwordHasher; } [Read("info")] public Module GetModule() { var product = new PeopleProduct(); product.Init(); return new Module(product, true); } [Read] public IQueryable GetAll() { return GetByStatus(EmployeeStatus.Active); } [Read("status/{status}")] public IQueryable GetByStatus(EmployeeStatus status) { if (CoreBaseSettings.Personal) throw new Exception("Method not available"); Guid? groupId = null; if ("group".Equals(ApiContext.FilterBy, StringComparison.OrdinalIgnoreCase) && !string.IsNullOrEmpty(ApiContext.FilterValue)) { groupId = new Guid(ApiContext.FilterValue); ApiContext.SetDataFiltered(); } return GetFullByFilter(status, groupId, null, null, null); } [Read("@self")] public EmployeeWraper Self() { return EmployeeWraperFullHelper.GetFull(UserManager.GetUser(SecurityContext.CurrentAccount.ID, EmployeeWraperFullHelper.GetExpression(ApiContext))); } [Read("email")] public EmployeeWraperFull GetByEmail([FromQuery] string email) { if (CoreBaseSettings.Personal && !UserManager.GetUsers(SecurityContext.CurrentAccount.ID).IsOwner(Tenant)) throw new MethodAccessException("Method not available"); var user = UserManager.GetUserByEmail(email); if (user.ID == Constants.LostUser.ID) { throw new ItemNotFoundException("User not found"); } return EmployeeWraperFullHelper.GetFull(user); } [Read("{username}", order: int.MaxValue)] public EmployeeWraperFull GetById(string username) { if (CoreBaseSettings.Personal) throw new MethodAccessException("Method not available"); var user = UserManager.GetUserByUserName(username); if (user.ID == Constants.LostUser.ID) { if (Guid.TryParse(username, out var userId)) { user = UserManager.GetUsers(userId); } else { Log.Error(string.Format("Account {0} сould not get user by name {1}", SecurityContext.CurrentAccount.ID, username)); } } if (user.ID == Constants.LostUser.ID) { throw new ItemNotFoundException("User not found"); } return EmployeeWraperFullHelper.GetFull(user); } [Read("@search/{query}")] public IEnumerable GetSearch(string query) { if (CoreBaseSettings.Personal) throw new MethodAccessException("Method not available"); try { var groupId = Guid.Empty; if ("group".Equals(ApiContext.FilterBy, StringComparison.OrdinalIgnoreCase) && !string.IsNullOrEmpty(ApiContext.FilterValue)) { groupId = new Guid(ApiContext.FilterValue); } return UserManager.Search(query, EmployeeStatus.Active, groupId).Select(EmployeeWraperFullHelper.GetFull); } catch (Exception error) { Log.Error(error); } return null; } [Read("search")] public IEnumerable GetPeopleSearch([FromQuery] string query) { return GetSearch(query); } [Read("status/{status}/search")] public IEnumerable GetAdvanced(EmployeeStatus status, [FromQuery] string query) { if (CoreBaseSettings.Personal) throw new MethodAccessException("Method not available"); try { var list = UserManager.GetUsers(status).AsEnumerable(); if ("group".Equals(ApiContext.FilterBy, StringComparison.OrdinalIgnoreCase) && !string.IsNullOrEmpty(ApiContext.FilterValue)) { var groupId = new Guid(ApiContext.FilterValue); //Filter by group list = list.Where(x => UserManager.IsUserInGroup(x.ID, groupId)); ApiContext.SetDataFiltered(); } list = list.Where(x => x.FirstName != null && x.FirstName.IndexOf(query, StringComparison.OrdinalIgnoreCase) > -1 || (x.LastName != null && x.LastName.IndexOf(query, StringComparison.OrdinalIgnoreCase) != -1) || (x.UserName != null && x.UserName.IndexOf(query, StringComparison.OrdinalIgnoreCase) != -1) || (x.Email != null && x.Email.IndexOf(query, StringComparison.OrdinalIgnoreCase) != -1) || (x.ContactsList != null && x.ContactsList.Any(y => y.IndexOf(query, StringComparison.OrdinalIgnoreCase) != -1))); return list.Select(EmployeeWraperFullHelper.GetFull); } catch (Exception error) { Log.Error(error); } return null; } ///// ///// Adds a new portal user from import with the first and last name, email address ///// ///// ///// Add new import user ///// ///// The list of users to add ///// Add users as guests (bool type: false|true) ///// Newly created users //[Create("import/save")] //public void SaveUsers(string userList, bool importUsersAsCollaborators) //{ // lock (progressQueue.SynchRoot) // { // var task = progressQueue.GetItems().OfType().FirstOrDefault(t => (int)t.Id == TenantProvider.CurrentTenantID); // if (task != null && task.IsCompleted) // { // progressQueue.Remove(task); // task = null; // } // if (task == null) // { // progressQueue.Add(new ImportUsersTask(userList, importUsersAsCollaborators, GetHttpHeaders(HttpContext.Current.Request)) // { // Id = TenantProvider.CurrentTenantID, // UserId = SecurityContext.CurrentAccount.ID, // Percentage = 0 // }); // } // } //} //[Read("import/status")] //public object GetStatus() //{ // lock (progressQueue.SynchRoot) // { // var task = progressQueue.GetItems().OfType().FirstOrDefault(t => (int)t.Id == TenantProvider.CurrentTenantID); // if (task == null) return null; // return new // { // Completed = task.IsCompleted, // Percents = (int)task.Percentage, // UserCounter = task.GetUserCounter, // Status = (int)task.Status, // Error = (string)task.Error, // task.Data // }; // } //} [Read("filter")] public IQueryable GetFullByFilter(EmployeeStatus? employeeStatus, Guid? groupId, EmployeeActivationStatus? activationStatus, EmployeeType? employeeType, bool? isAdministrator) { var users = GetByFilter(employeeStatus, groupId, activationStatus, employeeType, isAdministrator); return users.Select(r => EmployeeWraperFullHelper.GetFull(r)); } [Read("simple/filter")] public IEnumerable GetSimpleByFilter(EmployeeStatus? employeeStatus, Guid? groupId, EmployeeActivationStatus? activationStatus, EmployeeType? employeeType, bool? isAdministrator) { var users = GetByFilter(employeeStatus, groupId, activationStatus, employeeType, isAdministrator); return users.Select(EmployeeWraperHelper.Get); } private IQueryable GetByFilter(EmployeeStatus? employeeStatus, Guid? groupId, EmployeeActivationStatus? activationStatus, EmployeeType? employeeType, bool? isAdministrator) { if (CoreBaseSettings.Personal) throw new MethodAccessException("Method not available"); var isAdmin = UserManager.GetUsers(SecurityContext.CurrentAccount.ID).IsAdmin(UserManager) || WebItemSecurity.IsProductAdministrator(WebItemManager.PeopleProductID, SecurityContext.CurrentAccount.ID); var includeGroups = new List>(); if (groupId.HasValue) { includeGroups.Add(new List { groupId.Value }); } var excludeGroups = new List(); if (employeeType != null) { switch (employeeType) { case EmployeeType.User: excludeGroups.Add(Constants.GroupVisitor.ID); break; case EmployeeType.Visitor: includeGroups.Add(new List { Constants.GroupVisitor.ID }); break; } } if (isAdministrator.HasValue && isAdministrator.Value) { var adminGroups = new List { Constants.GroupAdmin.ID }; var products = WebItemManager.GetItemsAll().Where(i => i is IProduct || i.ID == WebItemManager.MailProductID); adminGroups.AddRange(products.Select(r => r.ID)); includeGroups.Add(adminGroups); } var users = UserManager.GetUsers(isAdmin, employeeStatus, includeGroups, excludeGroups, activationStatus, ApiContext.FilterValue, ApiContext.SortBy, !ApiContext.SortDescending, ApiContext.Count, ApiContext.StartIndex, out var total, out var count); ApiContext.SetTotalCount(total).SetCount(count); return users; } [Create] [Authorize(AuthenticationSchemes = "confirm", Roles = "LinkInvite,Administrators")] public EmployeeWraperFull AddMember(MemberModel memberModel) { ApiContext.AuthByClaim(); PermissionContext.DemandPermissions(Constants.Action_AddRemoveUser); memberModel.PasswordHash = (memberModel.PasswordHash ?? "").Trim(); if (string.IsNullOrEmpty(memberModel.PasswordHash)) { memberModel.Password = (memberModel.Password ?? "").Trim(); if (string.IsNullOrEmpty(memberModel.Password)) { memberModel.Password = UserManagerWrapper.GeneratePassword(); } else { UserManagerWrapper.CheckPasswordPolicy(memberModel.Password); } memberModel.PasswordHash = PasswordHasher.GetClientPassword(memberModel.Password); } var user = new UserInfo(); //Validate email var address = new MailAddress(memberModel.Email); user.Email = address.Address; //Set common fields user.FirstName = memberModel.Firstname; user.LastName = memberModel.Lastname; user.Title = memberModel.Title; user.Location = memberModel.Location; user.Notes = memberModel.Comment; user.Sex = "male".Equals(memberModel.Sex, StringComparison.OrdinalIgnoreCase) ? true : ("female".Equals(memberModel.Sex, StringComparison.OrdinalIgnoreCase) ? (bool?)false : null); user.BirthDate = memberModel.Birthday != null && memberModel.Birthday != DateTime.MinValue ? TenantUtil.DateTimeFromUtc(Convert.ToDateTime(memberModel.Birthday)) : (DateTime?)null; user.WorkFromDate = memberModel.Worksfrom != null && memberModel.Worksfrom != DateTime.MinValue ? TenantUtil.DateTimeFromUtc(Convert.ToDateTime(memberModel.Worksfrom)) : DateTime.UtcNow.Date; UpdateContacts(memberModel.Contacts, user); user = UserManagerWrapper.AddUser(user, memberModel.PasswordHash, false, true, memberModel.IsVisitor); var messageAction = memberModel.IsVisitor ? MessageAction.GuestCreated : MessageAction.UserCreated; MessageService.Send(messageAction, MessageTarget.Create(user.ID), user.DisplayUserName(false, DisplayUserSettingsHelper)); UpdateDepartments(memberModel.Department, user); if (memberModel.Files != UserPhotoManager.GetDefaultPhotoAbsoluteWebPath()) { UpdatePhotoUrl(memberModel.Files, user); } return EmployeeWraperFullHelper.GetFull(user); } [Create("active")] public EmployeeWraperFull AddMemberAsActivated(MemberModel memberModel) { PermissionContext.DemandPermissions(Constants.Action_AddRemoveUser); var user = new UserInfo(); memberModel.Password = (memberModel.Password ?? "").Trim(); if (string.IsNullOrEmpty(memberModel.Password)) { memberModel.Password = UserManagerWrapper.GeneratePassword(); } else { UserManagerWrapper.CheckPasswordPolicy(memberModel.Password); } var passwordHash = PasswordHasher.GetClientPassword(memberModel.Password); //Validate email var address = new MailAddress(memberModel.Email); user.Email = address.Address; //Set common fields user.FirstName = memberModel.Firstname; user.LastName = memberModel.Lastname; user.Title = memberModel.Title; user.Location = memberModel.Location; user.Notes = memberModel.Comment; user.Sex = "male".Equals(memberModel.Sex, StringComparison.OrdinalIgnoreCase) ? true : ("female".Equals(memberModel.Sex, StringComparison.OrdinalIgnoreCase) ? (bool?)false : null); user.BirthDate = memberModel.Birthday != null ? TenantUtil.DateTimeFromUtc(Convert.ToDateTime(memberModel.Birthday)) : (DateTime?)null; user.WorkFromDate = memberModel.Worksfrom != null ? TenantUtil.DateTimeFromUtc(Convert.ToDateTime(memberModel.Worksfrom)) : DateTime.UtcNow.Date; UpdateContacts(memberModel.Contacts, user); user = UserManagerWrapper.AddUser(user, memberModel.Password, false, false, memberModel.IsVisitor); user.ActivationStatus = EmployeeActivationStatus.Activated; UpdateDepartments(memberModel.Department, user); if (memberModel.Files != UserPhotoManager.GetDefaultPhotoAbsoluteWebPath()) { UpdatePhotoUrl(memberModel.Files, user); } return EmployeeWraperFullHelper.GetFull(user); } [Update("{userid}/culture")] public EmployeeWraperFull UpdateMemberCulture(string userid, UpdateMemberModel memberModel) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); var curLng = user.CultureName; if (SetupInfo.EnabledCultures.Find(c => string.Equals(c.Name, memberModel.CultureName, StringComparison.InvariantCultureIgnoreCase)) != null) { if (curLng != memberModel.CultureName) { user.CultureName = memberModel.CultureName; try { UserManager.SaveUserInfo(user); } catch (Exception ex) { user.CultureName = curLng; throw ex; } MessageService.Send(MessageAction.UserUpdatedLanguage, MessageTarget.Create(user.ID), user.DisplayUserName(false, DisplayUserSettingsHelper)); } } return EmployeeWraperFullHelper.GetFull(user); } [Update("{userid}")] public EmployeeWraperFull UpdateMember(string userid, UpdateMemberModel memberModel) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); var self = SecurityContext.CurrentAccount.ID.Equals(user.ID); var resetDate = new DateTime(1900, 01, 01); //Update it var isLdap = user.IsLDAP(); var isSso = user.IsSSO(); var isAdmin = WebItemSecurity.IsProductAdministrator(WebItemManager.PeopleProductID, SecurityContext.CurrentAccount.ID); if (!isLdap && !isSso) { //Set common fields user.FirstName = memberModel.Firstname ?? user.FirstName; user.LastName = memberModel.Lastname ?? user.LastName; user.Location = memberModel.Location ?? user.Location; if (isAdmin) { user.Title = memberModel.Title ?? user.Title; } } if (!UserFormatter.IsValidUserName(user.FirstName, user.LastName)) throw new Exception(Resource.ErrorIncorrectUserName); user.Notes = memberModel.Comment ?? user.Notes; user.Sex = ("male".Equals(memberModel.Sex, StringComparison.OrdinalIgnoreCase) ? true : ("female".Equals(memberModel.Sex, StringComparison.OrdinalIgnoreCase) ? (bool?)false : null)) ?? user.Sex; user.BirthDate = memberModel.Birthday != null ? TenantUtil.DateTimeFromUtc(Convert.ToDateTime(memberModel.Birthday)) : user.BirthDate; if (user.BirthDate == resetDate) { user.BirthDate = null; } user.WorkFromDate = memberModel.Worksfrom != null ? TenantUtil.DateTimeFromUtc(Convert.ToDateTime(memberModel.Worksfrom)) : user.WorkFromDate; if (user.WorkFromDate == resetDate) { user.WorkFromDate = null; } //Update contacts UpdateContacts(memberModel.Contacts, user); UpdateDepartments(memberModel.Department, user); if (memberModel.Files != UserPhotoManager.GetPhotoAbsoluteWebPath(user.ID)) { UpdatePhotoUrl(memberModel.Files, user); } if (memberModel.Disable.HasValue) { user.Status = memberModel.Disable.Value ? EmployeeStatus.Terminated : EmployeeStatus.Active; user.TerminatedDate = memberModel.Disable.Value ? DateTime.UtcNow : (DateTime?)null; } if (self && !isAdmin) { StudioNotifyService.SendMsgToAdminAboutProfileUpdated(); } // change user type var canBeGuestFlag = !user.IsOwner(Tenant) && !user.IsAdmin(UserManager) && !user.GetListAdminModules(WebItemSecurity).Any() && !user.IsMe(AuthContext); if (memberModel.IsVisitor && !user.IsVisitor(UserManager) && canBeGuestFlag) { UserManager.AddUserIntoGroup(user.ID, Constants.GroupVisitor.ID); WebItemSecurityCache.ClearCache(Tenant.TenantId); } if (!self && !memberModel.IsVisitor && user.IsVisitor(UserManager)) { var usersQuota = TenantExtra.GetTenantQuota().ActiveUsers; if (TenantStatisticsProvider.GetUsersCount() < usersQuota) { UserManager.RemoveUserFromGroup(user.ID, Constants.GroupVisitor.ID); WebItemSecurityCache.ClearCache(Tenant.TenantId); } else { throw new TenantQuotaException(string.Format("Exceeds the maximum active users ({0})", usersQuota)); } } UserManager.SaveUserInfo(user, memberModel.IsVisitor); MessageService.Send(MessageAction.UserUpdated, MessageTarget.Create(user.ID), user.DisplayUserName(false, DisplayUserSettingsHelper)); if (memberModel.Disable.HasValue && memberModel.Disable.Value) { CookiesManager.ResetUserCookie(user.ID); MessageService.Send(MessageAction.CookieSettingsUpdated); } return EmployeeWraperFullHelper.GetFull(user); } [Delete("{userid}")] public EmployeeWraperFull DeleteMember(string userid) { PermissionContext.DemandPermissions(Constants.Action_AddRemoveUser); var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID) || user.IsLDAP()) throw new SecurityException(); if (user.Status != EmployeeStatus.Terminated) throw new Exception("The user is not suspended"); CheckReassignProccess(new[] { user.ID }); var userName = user.DisplayUserName(false, DisplayUserSettingsHelper); UserPhotoManager.RemovePhoto(user.ID); UserManager.DeleteUser(user.ID); QueueWorkerRemove.Start(Tenant.TenantId, user, SecurityContext.CurrentAccount.ID, false); MessageService.Send(MessageAction.UserDeleted, MessageTarget.Create(user.ID), userName); return EmployeeWraperFullHelper.GetFull(user); } [Delete("@self")] [Authorize(AuthenticationSchemes = "confirm", Roles = "ProfileRemove")] public EmployeeWraperFull DeleteProfile() { ApiContext.AuthByClaim(); if (UserManager.IsSystemUser(SecurityContext.CurrentAccount.ID)) throw new SecurityException(); var user = GetUserInfo(SecurityContext.CurrentAccount.ID.ToString()); if (!UserManager.UserExists(user)) throw new Exception(Resource.ErrorUserNotFound); if (user.IsLDAP()) throw new SecurityException(); _ = SecurityContext.AuthenticateMe(ASC.Core.Configuration.Constants.CoreSystem); user.Status = EmployeeStatus.Terminated; UserManager.SaveUserInfo(user); var userName = user.DisplayUserName(false, DisplayUserSettingsHelper); MessageService.Send(MessageAction.UsersUpdatedStatus, MessageTarget.Create(user.ID), userName); CookiesManager.ResetUserCookie(user.ID); MessageService.Send(MessageAction.CookieSettingsUpdated); if (CoreBaseSettings.Personal) { UserPhotoManager.RemovePhoto(user.ID); UserManager.DeleteUser(user.ID); MessageService.Send(MessageAction.UserDeleted, MessageTarget.Create(user.ID), userName); } else { //StudioNotifyService.Instance.SendMsgProfileHasDeletedItself(user); //StudioNotifyService.SendMsgProfileDeletion(Tenant.TenantId, user); } return EmployeeWraperFullHelper.GetFull(user); } [Update("{userid}/contacts")] public EmployeeWraperFull UpdateMemberContacts(string userid, UpdateMemberModel memberModel) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); UpdateContacts(memberModel.Contacts, user); UserManager.SaveUserInfo(user); return EmployeeWraperFullHelper.GetFull(user); } [Create("{userid}/contacts")] public EmployeeWraperFull SetMemberContacts(string userid, UpdateMemberModel memberModel) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); UpdateContacts(memberModel.Contacts, user); UserManager.SaveUserInfo(user); return EmployeeWraperFullHelper.GetFull(user); } [Delete("{userid}/contacts")] public EmployeeWraperFull DeleteMemberContacts(string userid, UpdateMemberModel memberModel) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); DeleteContacts(memberModel.Contacts, user); UserManager.SaveUserInfo(user); return EmployeeWraperFullHelper.GetFull(user); } [Read("{userid}/photo")] public ThumbnailsDataWrapper GetMemberPhoto(string userid) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); return new ThumbnailsDataWrapper(user.ID, UserPhotoManager); } [Create("{userid}/photo")] public FileUploadResult UploadMemberPhoto(string userid, IFormCollection model) { var result = new People.Models.FileUploadResult(); var autosave = bool.Parse(model["Autosave"]); try { if (model.Files.Count != 0) { Guid userId; try { userId = new Guid(userid); } catch { userId = SecurityContext.CurrentAccount.ID; } PermissionContext.DemandPermissions(new UserSecurityProvider(userId), Constants.Action_EditUser); var userPhoto = model.Files[0]; if (userPhoto.Length > SetupInfo.MaxImageUploadSize) { result.Success = false; result.Message = FileSizeComment.FileImageSizeExceptionString; return result; } var data = new byte[userPhoto.Length]; using var inputStream = userPhoto.OpenReadStream(); var br = new BinaryReader(inputStream); br.Read(data, 0, (int)userPhoto.Length); br.Close(); CheckImgFormat(data); if (autosave) { if (data.Length > SetupInfo.MaxImageUploadSize) throw new ImageSizeLimitException(); var mainPhoto = UserPhotoManager.SaveOrUpdatePhoto(userId, data); result.Data = new { main = mainPhoto, retina = UserPhotoManager.GetRetinaPhotoURL(userId), max = UserPhotoManager.GetMaxPhotoURL(userId), big = UserPhotoManager.GetBigPhotoURL(userId), medium = UserPhotoManager.GetMediumPhotoURL(userId), small = UserPhotoManager.GetSmallPhotoURL(userId), }; } else { result.Data = UserPhotoManager.SaveTempPhoto(data, SetupInfo.MaxImageUploadSize, UserPhotoManager.OriginalFotoSize.Width, UserPhotoManager.OriginalFotoSize.Height); } result.Success = true; } else { result.Success = false; result.Message = PeopleResource.ErrorEmptyUploadFileSelected; } } catch (UnknownImageFormatException) { result.Success = false; result.Message = PeopleResource.ErrorUnknownFileImageType; } catch (ImageWeightLimitException) { result.Success = false; result.Message = PeopleResource.ErrorImageWeightLimit; } catch (ImageSizeLimitException) { result.Success = false; result.Message = PeopleResource.ErrorImageSizetLimit; } catch (Exception ex) { result.Success = false; result.Message = ex.Message.HtmlEncode(); } return result; } [Update("{userid}/photo")] public ThumbnailsDataWrapper UpdateMemberPhoto(string userid, UpdateMemberModel model) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); if (model.Files != UserPhotoManager.GetPhotoAbsoluteWebPath(user.ID)) { UpdatePhotoUrl(model.Files, user); } UserManager.SaveUserInfo(user); MessageService.Send(MessageAction.UserAddedAvatar, MessageTarget.Create(user.ID), user.DisplayUserName(false, DisplayUserSettingsHelper)); return new ThumbnailsDataWrapper(user.ID, UserPhotoManager); } [Delete("{userid}/photo")] public ThumbnailsDataWrapper DeleteMemberPhoto(string userid) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); UserPhotoManager.RemovePhoto(user.ID); UserManager.SaveUserInfo(user); MessageService.Send(MessageAction.UserDeletedAvatar, MessageTarget.Create(user.ID), user.DisplayUserName(false, DisplayUserSettingsHelper)); return new ThumbnailsDataWrapper(user.ID, UserPhotoManager); } [Create("{userid}/photo/thumbnails")] public ThumbnailsDataWrapper CreateMemberPhotoThumbnails(string userid, ThumbnailsModel thumbnailsModel) { var user = GetUserInfo(userid); if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); if (!string.IsNullOrEmpty(thumbnailsModel.TmpFile)) { var fileName = Path.GetFileName(thumbnailsModel.TmpFile); var data = UserPhotoManager.GetTempPhotoData(fileName); var settings = new UserPhotoThumbnailSettings(thumbnailsModel.X, thumbnailsModel.Y, thumbnailsModel.Width, thumbnailsModel.Height); SettingsManager.SaveForUser(settings, user.ID); UserPhotoManager.RemovePhoto(user.ID); UserPhotoManager.SaveOrUpdatePhoto(user.ID, data); UserPhotoManager.RemoveTempPhoto(fileName); } else { UserPhotoThumbnailManager.SaveThumbnails(UserPhotoManager, SettingsManager, thumbnailsModel.X, thumbnailsModel.Y, thumbnailsModel.Width, thumbnailsModel.Height, user.ID); } UserManager.SaveUserInfo(user); MessageService.Send(MessageAction.UserUpdatedAvatarThumbnails, MessageTarget.Create(user.ID), user.DisplayUserName(false, DisplayUserSettingsHelper)); return new ThumbnailsDataWrapper(user.ID, UserPhotoManager); } [AllowAnonymous] [Create("password", false)] public string SendUserPassword(MemberModel memberModel) { string error; if (!string.IsNullOrEmpty(error = UserManagerWrapper.SendUserPassword(memberModel.Email))) { Log.ErrorFormat("Password recovery ({0}): {1}", memberModel.Email, error); } return string.Format(Resource.MessageYourPasswordSendedToEmail, memberModel.Email); } [Update("{userid}/password")] [Authorize(AuthenticationSchemes = "confirm", Roles = "PasswordChange,EmailChange,Activation,Administrators")] public EmployeeWraperFull ChangeUserPassword(Guid userid, MemberModel memberModel) { ApiContext.AuthByClaim(); PermissionContext.DemandPermissions(new UserSecurityProvider(userid), Constants.Action_EditUser); var user = UserManager.GetUsers(userid); if (!UserManager.UserExists(user)) return null; if (UserManager.IsSystemUser(user.ID)) throw new SecurityException(); if (!string.IsNullOrEmpty(memberModel.Email)) { var address = new MailAddress(memberModel.Email); if (!string.Equals(address.Address, user.Email, StringComparison.OrdinalIgnoreCase)) { user.Email = address.Address.ToLowerInvariant(); user.ActivationStatus = EmployeeActivationStatus.Activated; UserManager.SaveUserInfo(user); } } if (!string.IsNullOrEmpty(memberModel.Password)) { var passwordHash = PasswordHasher.GetClientPassword(memberModel.Password); SecurityContext.SetUserPasswordHash(userid, passwordHash); MessageService.Send(MessageAction.UserUpdatedPassword); CookiesManager.ResetUserCookie(userid); MessageService.Send(MessageAction.CookieSettingsUpdated); } return EmployeeWraperFullHelper.GetFull(GetUserInfo(userid.ToString())); } [Create("email", false)] public string SendEmailChangeInstructions(UpdateMemberModel model) { Guid.TryParse(model.UserId, out var userid); if (userid == Guid.Empty) throw new ArgumentNullException("userid"); var email = (model.Email ?? "").Trim(); if (string.IsNullOrEmpty(email)) throw new Exception(Resource.ErrorEmailEmpty); if (!email.TestEmailRegex()) throw new Exception(Resource.ErrorNotCorrectEmail); var viewer = UserManager.GetUsers(SecurityContext.CurrentAccount.ID); var user = UserManager.GetUsers(userid); if (user == null) throw new Exception(Resource.ErrorUserNotFound); if (viewer == null || (user.IsOwner(Tenant) && viewer.ID != user.ID)) throw new Exception(Resource.ErrorAccessDenied); var existentUser = UserManager.GetUserByEmail(email); if (existentUser.ID != Constants.LostUser.ID) throw new Exception(CustomNamingPeople.Substitute("ErrorEmailAlreadyExists")); if (!viewer.IsAdmin(UserManager)) { StudioNotifyService.SendEmailChangeInstructions(user, email); } else { if (email == user.Email) throw new Exception(Resource.ErrorEmailsAreTheSame); user.Email = email; user.ActivationStatus = EmployeeActivationStatus.NotActivated; UserManager.SaveUserInfo(user); StudioNotifyService.SendEmailActivationInstructions(user, email); } MessageService.Send(MessageAction.UserSentEmailChangeInstructions, user.DisplayUserName(false, DisplayUserSettingsHelper)); return string.Format(Resource.MessageEmailChangeInstuctionsSentOnEmail, email); } private UserInfo GetUserInfo(string userNameOrId) { UserInfo user; try { var userId = new Guid(userNameOrId); user = UserManager.GetUsers(userId); } catch (FormatException) { user = UserManager.GetUserByUserName(userNameOrId); } if (user == null || user.ID == Constants.LostUser.ID) throw new ItemNotFoundException("user not found"); return user; } [Update("activationstatus/{activationstatus}")] [Authorize(AuthenticationSchemes = "confirm", Roles = "Activation,Administrators")] public IEnumerable UpdateEmployeeActivationStatus(EmployeeActivationStatus activationstatus, UpdateMembersModel model) { ApiContext.AuthByClaim(); var retuls = new List(); foreach (var id in model.UserIds.Where(userId => !UserManager.IsSystemUser(userId))) { PermissionContext.DemandPermissions(new UserSecurityProvider(id), Constants.Action_EditUser); var u = UserManager.GetUsers(id); if (u.ID == Constants.LostUser.ID || u.IsLDAP()) continue; u.ActivationStatus = activationstatus; UserManager.SaveUserInfo(u); retuls.Add(EmployeeWraperFullHelper.GetFull(u)); } return retuls; } [Update("type/{type}")] public IEnumerable UpdateUserType(EmployeeType type, UpdateMembersModel model) { var users = model.UserIds .Where(userId => !UserManager.IsSystemUser(userId)) .Select(userId => UserManager.GetUsers(userId)) .ToList(); foreach (var user in users) { if (user.IsOwner(Tenant) || user.IsAdmin(UserManager) || user.IsMe(AuthContext) || user.GetListAdminModules(WebItemSecurity).Any()) continue; switch (type) { case EmployeeType.User: if (user.IsVisitor(UserManager)) { if (TenantStatisticsProvider.GetUsersCount() < TenantExtra.GetTenantQuota().ActiveUsers) { UserManager.RemoveUserFromGroup(user.ID, Constants.GroupVisitor.ID); WebItemSecurityCache.ClearCache(Tenant.TenantId); } } break; case EmployeeType.Visitor: UserManager.AddUserIntoGroup(user.ID, Constants.GroupVisitor.ID); WebItemSecurityCache.ClearCache(Tenant.TenantId); break; } } MessageService.Send(MessageAction.UsersUpdatedType, MessageTarget.Create(users.Select(x => x.ID)), users.Select(x => x.DisplayUserName(false, DisplayUserSettingsHelper))); return users.Select(EmployeeWraperFullHelper.GetFull); } [Update("status/{status}")] public IEnumerable UpdateUserStatus(EmployeeStatus status, UpdateMembersModel model) { PermissionContext.DemandPermissions(Constants.Action_EditUser); var users = model.UserIds.Select(userId => UserManager.GetUsers(userId)) .Where(u => !UserManager.IsSystemUser(u.ID) && !u.IsLDAP()) .ToList(); foreach (var user in users) { if (user.IsOwner(Tenant) || user.IsMe(AuthContext)) continue; switch (status) { case EmployeeStatus.Active: if (user.Status == EmployeeStatus.Terminated) { if (TenantStatisticsProvider.GetUsersCount() < TenantExtra.GetTenantQuota().ActiveUsers || user.IsVisitor(UserManager)) { user.Status = EmployeeStatus.Active; UserManager.SaveUserInfo(user); } } break; case EmployeeStatus.Terminated: user.Status = EmployeeStatus.Terminated; UserManager.SaveUserInfo(user); CookiesManager.ResetUserCookie(user.ID); MessageService.Send(MessageAction.CookieSettingsUpdated); break; } } MessageService.Send(MessageAction.UsersUpdatedStatus, MessageTarget.Create(users.Select(x => x.ID)), users.Select(x => x.DisplayUserName(false, DisplayUserSettingsHelper))); return users.Select(EmployeeWraperFullHelper.GetFull); } [Update("invite")] public IEnumerable ResendUserInvites(UpdateMembersModel model) { var users = model.UserIds .Where(userId => !UserManager.IsSystemUser(userId)) .Select(userId => UserManager.GetUsers(userId)) .ToList(); foreach (var user in users) { if (user.IsActive) continue; if (user.ActivationStatus == EmployeeActivationStatus.Pending) { if (user.IsVisitor(UserManager)) { StudioNotifyService.GuestInfoActivation(user); } else { StudioNotifyService.UserInfoActivation(user); } } else { StudioNotifyService.SendEmailActivationInstructions(user, user.Email); } } MessageService.Send(MessageAction.UsersSentActivationInstructions, MessageTarget.Create(users.Select(x => x.ID)), users.Select(x => x.DisplayUserName(false, DisplayUserSettingsHelper))); return users.Select(EmployeeWraperFullHelper.GetFull); } [Update("delete", Order = -1)] public IEnumerable RemoveUsers(UpdateMembersModel model) { PermissionContext.DemandPermissions(Constants.Action_AddRemoveUser); CheckReassignProccess(model.UserIds); var users = model.UserIds.Select(userId => UserManager.GetUsers(userId)) .Where(u => !UserManager.IsSystemUser(u.ID) && !u.IsLDAP()) .ToList(); var userNames = users.Select(x => x.DisplayUserName(false, DisplayUserSettingsHelper)).ToList(); foreach (var user in users) { if (user.Status != EmployeeStatus.Terminated) continue; UserPhotoManager.RemovePhoto(user.ID); UserManager.DeleteUser(user.ID); QueueWorkerRemove.Start(Tenant.TenantId, user, SecurityContext.CurrentAccount.ID, false); } MessageService.Send(MessageAction.UsersDeleted, MessageTarget.Create(users.Select(x => x.ID)), userNames); return users.Select(EmployeeWraperFullHelper.GetFull); } [Update("self/delete")] public string SendInstructionsToDelete() { var user = UserManager.GetUsers(SecurityContext.CurrentAccount.ID); if (user.IsLDAP()) throw new SecurityException(); StudioNotifyService.SendMsgProfileDeletion(user); MessageService.Send(MessageAction.UserSentDeleteInstructions); return string.Format(Resource.SuccessfullySentNotificationDeleteUserInfoMessage, "" + user.Email + ""); } [Update("thirdparty/linkaccount")] public void LinkAccount(string serializedProfile) { var profile = new LoginProfile(Signature, InstanceCrypto, serializedProfile); if (string.IsNullOrEmpty(profile.AuthorizationError)) { GetLinker().AddLink(SecurityContext.CurrentAccount.ID.ToString(), profile); MessageService.Send(MessageAction.UserLinkedSocialAccount, GetMeaningfulProviderName(profile.Provider)); } else { // ignore cancellation if (profile.AuthorizationError != "Canceled at provider") { throw new Exception(profile.AuthorizationError); } } } [Delete("thirdparty/unlinkaccount")] public void UnlinkAccount(string provider) { GetLinker().RemoveProvider(SecurityContext.CurrentAccount.ID.ToString(), provider); MessageService.Send(MessageAction.UserUnlinkedSocialAccount, GetMeaningfulProviderName(provider)); } private AccountLinker GetLinker() { return AccountLinker.Get("webstudio"); } private static string GetMeaningfulProviderName(string providerName) { switch (providerName) { case "google": case "openid": return "Google"; case "facebook": return "Facebook"; case "twitter": return "Twitter"; case "linkedin": return "LinkedIn"; default: return "Unknown Provider"; } } [Read(@"reassign/progress")] public ReassignProgressItem GetReassignProgress(Guid userId) { PermissionContext.DemandPermissions(Constants.Action_EditUser); return QueueWorkerReassign.GetProgressItemStatus(Tenant.TenantId, userId); } [Update(@"reassign/terminate")] public void TerminateReassign(Guid userId) { PermissionContext.DemandPermissions(Constants.Action_EditUser); QueueWorkerReassign.Terminate(Tenant.TenantId, userId); } [Create(@"reassign/start")] public ReassignProgressItem StartReassign(Guid fromUserId, Guid toUserId, bool deleteProfile) { PermissionContext.DemandPermissions(Constants.Action_EditUser); var fromUser = UserManager.GetUsers(fromUserId); if (fromUser == null || fromUser.ID == Constants.LostUser.ID) throw new ArgumentException("User with id = " + fromUserId + " not found"); if (fromUser.IsOwner(Tenant) || fromUser.IsMe(AuthContext) || fromUser.Status != EmployeeStatus.Terminated) throw new ArgumentException("Can not delete user with id = " + fromUserId); var toUser = UserManager.GetUsers(toUserId); if (toUser == null || toUser.ID == Constants.LostUser.ID) throw new ArgumentException("User with id = " + toUserId + " not found"); if (toUser.IsVisitor(UserManager) || toUser.Status == EmployeeStatus.Terminated) throw new ArgumentException("Can not reassign data to user with id = " + toUserId); return QueueWorkerReassign.Start(Tenant.TenantId, fromUserId, toUserId, SecurityContext.CurrentAccount.ID, deleteProfile); } private void CheckReassignProccess(IEnumerable userIds) { foreach (var userId in userIds) { var reassignStatus = QueueWorkerReassign.GetProgressItemStatus(Tenant.TenantId, userId); if (reassignStatus == null || reassignStatus.IsCompleted) continue; var userName = UserManager.GetUsers(userId).DisplayUserName(DisplayUserSettingsHelper); throw new Exception(string.Format(Resource.ReassignDataRemoveUserError, userName)); } } //#endregion #region Remove user data [Read(@"remove/progress")] public RemoveProgressItem GetRemoveProgress(Guid userId) { PermissionContext.DemandPermissions(Constants.Action_EditUser); return QueueWorkerRemove.GetProgressItemStatus(Tenant.TenantId, userId); } [Update(@"remove/terminate")] public void TerminateRemove(Guid userId) { PermissionContext.DemandPermissions(Constants.Action_EditUser); QueueWorkerRemove.Terminate(Tenant.TenantId, userId); } [Create(@"remove/start")] public RemoveProgressItem StartRemove(Guid userId) { PermissionContext.DemandPermissions(Constants.Action_EditUser); var user = UserManager.GetUsers(userId); if (user == null || user.ID == Constants.LostUser.ID) throw new ArgumentException("User with id = " + userId + " not found"); if (user.IsOwner(Tenant) || user.IsMe(AuthContext) || user.Status != EmployeeStatus.Terminated) throw new ArgumentException("Can not delete user with id = " + userId); return QueueWorkerRemove.Start(Tenant.TenantId, user, SecurityContext.CurrentAccount.ID, true); } #endregion private void UpdateDepartments(IEnumerable department, UserInfo user) { if (!PermissionContext.CheckPermissions(Constants.Action_EditGroups)) return; if (department == null) return; var groups = UserManager.GetUserGroups(user.ID); var managerGroups = new List(); foreach (var groupInfo in groups) { UserManager.RemoveUserFromGroup(user.ID, groupInfo.ID); var managerId = UserManager.GetDepartmentManager(groupInfo.ID); if (managerId == user.ID) { managerGroups.Add(groupInfo.ID); UserManager.SetDepartmentManager(groupInfo.ID, Guid.Empty); } } foreach (var guid in department) { var userDepartment = UserManager.GetGroupInfo(guid); if (userDepartment != Constants.LostGroupInfo) { UserManager.AddUserIntoGroup(user.ID, guid); if (managerGroups.Contains(guid)) { UserManager.SetDepartmentManager(guid, user.ID); } } } } private void UpdateContacts(IEnumerable contacts, UserInfo user) { PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); if (contacts == null) return; var values = contacts.Where(r => !string.IsNullOrEmpty(r.Value)).Select(r => $"{r.Type}|{r.Value}"); user.Contacts = string.Join('|', values); } private void DeleteContacts(IEnumerable contacts, UserInfo user) { PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); if (contacts == null) return; if (user.ContactsList == null) { user.ContactsList = new List(); } foreach (var contact in contacts) { var index = user.ContactsList.IndexOf(contact.Type); if (index != -1) { //Remove existing user.ContactsList.RemoveRange(index, 2); } } } private void UpdatePhotoUrl(string files, UserInfo user) { if (string.IsNullOrEmpty(files)) { return; } PermissionContext.DemandPermissions(new UserSecurityProvider(user.ID), Constants.Action_EditUser); if (!files.StartsWith("http://") && !files.StartsWith("https://")) { files = new Uri(ApiContext.HttpContextAccessor.HttpContext.Request.GetDisplayUrl()).GetLeftPart(UriPartial.Scheme | UriPartial.Authority) + "/" + files.TrimStart('/'); } var request = WebRequest.Create(files); using var response = (HttpWebResponse)request.GetResponse(); using var inputStream = response.GetResponseStream(); using var br = new BinaryReader(inputStream); var imageByteArray = br.ReadBytes((int)response.ContentLength); UserPhotoManager.SaveOrUpdatePhoto(user.ID, imageByteArray); } private static void CheckImgFormat(byte[] data) { ImageFormat imgFormat; try { using var stream = new MemoryStream(data); using var img = new Bitmap(stream); imgFormat = img.RawFormat; } catch (OutOfMemoryException) { throw new ImageSizeLimitException(); } catch (ArgumentException error) { throw new UnknownImageFormatException(error); } if (!imgFormat.Equals(ImageFormat.Png) && !imgFormat.Equals(ImageFormat.Jpeg)) { throw new UnknownImageFormatException(); } } } public static class PeopleControllerExtention { public static DIHelper AddPeopleController(this DIHelper services) { return services .AddAccountLinker() .AddMessageTargetService() .AddAccountLinkerStorageService() .AddFileSizeCommentService() .AddCookiesManagerService() .AddUserPhotoManagerService() .AddCustomNamingPeopleService() .AddSignatureService() .AddApiContextService() .AddUserManagerWrapperService() .AddInstanceCryptoService() .AddTenantUtilService() .AddSecurityContextService() .AddWebItemSecurityCache() .AddDisplayUserSettingsService() .AddTenantManagerService() .AddSetupInfo() .AddCommonLinkUtilityService() .AddCoreBaseSettingsService() .AddWebItemManager() .AddAuthContextService() .AddWebItemSecurity() .AddPermissionContextService() .AddTenantStatisticsProviderService() .AddTenantExtraService() .AddMessageServiceService() .AddQueueWorkerRemoveService() .AddQueueWorkerReassignService() .AddStudioNotifyServiceService() .AddUserManagerService() .AddSettingsManagerService() .AddEmployeeWraperFull() .AddEmployeeWraper() .AddUserFormatter() .AddPasswordHasherService(); } } }