V14: Move towards get guid

src/Umbraco.Cms.Api.Management/Controllers/AuditLog/CurrentUserAuditLogController.cs

@@ -8,6 +8,7 @@
 using Umbraco.Cms.Core.Exceptions;
 using Umbraco.Cms.Core.Models;
 using Umbraco.Cms.Core.Models.Membership;
+using Umbraco.Cms.Core.Security;
 using Umbraco.Cms.Core.Services;
 
 namespace Umbraco.Cms.Api.Management.Controllers.AuditLog;
@@ -17,28 +18,24 @@ public class CurrentUserAuditLogController : AuditLogControllerBase
 {
     private readonly IAuditService _auditService;
     private readonly IAuditLogPresentationFactory _auditLogPresentationFactory;
-    private readonly IUserService _userService;
+    private readonly IBackOfficeSecurityAccessor _backOfficeSecurityAccessor;
 
     public CurrentUserAuditLogController(
         IAuditService auditService,
         IAuditLogPresentationFactory auditLogPresentationFactory,
-        IUserService userService)
+        IBackOfficeSecurityAccessor backOfficeSecurityAccessor)
     {
         _auditService = auditService;
         _auditLogPresentationFactory = auditLogPresentationFactory;
-        _userService = userService;
+        _backOfficeSecurityAccessor = backOfficeSecurityAccessor;
     }
 
     [HttpGet]
     [MapToApiVersion("1.0")]
     [ProducesResponseType(typeof(PagedViewModel<AuditLogWithUsernameResponseModel>), StatusCodes.Status200OK)]
     public async Task<IActionResult> CurrentUser(Direction orderDirection = Direction.Descending, DateTime? sinceDate = null, int skip = 0, int take = 100)
     {
-        // FIXME: Pull out current backoffice user when its implemented.
-        // var userId = _backOfficeSecurityAccessor.BackOfficeSecurity?.GetUserId().Result ?? -1;
-        var userId = Constants.Security.SuperUserId;
-
-        IUser? user = _userService.GetUserById(userId);
+        IUser? user = _backOfficeSecurityAccessor.BackOfficeSecurity?.CurrentUser;
 
         if (user is null)
         {

src/Umbraco.Cms.Api.Management/Factories/AuditLogPresentationFactory.cs

@@ -17,14 +17,16 @@
     private readonly MediaFileManager _mediaFileManager;
     private readonly IImageUrlGenerator _imageUrlGenerator;
     private readonly IEntityService _entityService;
+    private readonly IUserIdKeyResolver _userIdKeyResolver;
 
-    public AuditLogPresentationFactory(IUserService userService, AppCaches appCaches, MediaFileManager mediaFileManager, IImageUrlGenerator imageUrlGenerator, IEntityService entityService)
+    public AuditLogPresentationFactory(IUserService userService, AppCaches appCaches, MediaFileManager mediaFileManager, IImageUrlGenerator imageUrlGenerator, IEntityService entityService, IUserIdKeyResolver userIdKeyResolver)
     {
         _userService = userService;
         _appCaches = appCaches;
         _mediaFileManager = mediaFileManager;
         _imageUrlGenerator = imageUrlGenerator;
         _entityService = entityService;
+        _userIdKeyResolver = userIdKeyResolver;
     }
 
     public IEnumerable<AuditLogResponseModel> CreateAuditLogViewModel(IEnumerable<IAuditItem> auditItems) => auditItems.Select(CreateAuditLogViewModel);
@@ -46,7 +48,8 @@
     private T CreateResponseModel<T>(IAuditItem auditItem, out IUser user)
         where T : AuditLogBaseModel, new()
     {
-        user = _userService.GetUserById(auditItem.UserId)
+        Guid userKey = _userIdKeyResolver.GetAsync(auditItem.UserId).GetAwaiter().GetResult();
+        user = _userService.GetAsync(userKey).GetAwaiter().GetResult()
                ?? throw new ArgumentException($"Could not find user with id {auditItem.UserId}");
 
         IEntitySlim? entitySlim = _entityService.Get(auditItem.Id);

src/Umbraco.Cms.Api.Management/Install/CreateUnattendedUserNotificationHandler.cs

@@ -52,7 +52,7 @@ public async Task HandleAsync(UnattendedInstallNotification notification, Cancel
             return;
         }
 
-        IUser? admin = _userService.GetUserById(Constants.Security.SuperUserId);
+        IUser? admin = await _userService.GetAsync(Constants.Security.SuperUserKey);
         if (admin == null)
         {
             throw new InvalidOperationException("Could not find the super user!");

src/Umbraco.Core/Cache/DistributedCacheExtensions.cs

@@ -32,7 +32,13 @@ public static void RefreshUserCache(this DistributedCache dc, int userId)
         => dc.Refresh(UserCacheRefresher.UniqueId, userId);
 
     public static void RefreshUserCache(this DistributedCache dc, IEnumerable<IUser> users)
-        => dc.Refresh(UserCacheRefresher.UniqueId, users.Select(x => x.Id).Distinct().ToArray());
+    {
+        foreach (IUser user in users)
+        {
+            dc.Refresh(UserCacheRefresher.UniqueId, user.Key);
+            dc.Refresh(UserCacheRefresher.UniqueId, user.Key);
+        }
+    }
 
     public static void RefreshAllUserCache(this DistributedCache dc)
         => dc.RefreshAll(UserCacheRefresher.UniqueId);

src/Umbraco.Core/Cache/Refreshers/Implement/UserCacheRefresher.cs

@@ -36,6 +36,21 @@ public override void Refresh(int id)
         base.Refresh(id);
     }
 
+    public override void Refresh(Guid id)
+    {
+        Attempt<IAppPolicyCache?> userCache = AppCaches.IsolatedCaches.Get<IUser>();
+        if (userCache.Success)
+        {
+            userCache.Result?.Clear(RepositoryCacheKeys.GetKey<IUser, Guid>(id));
+            userCache.Result?.ClearByKey(CacheKeys.UserContentStartNodePathsPrefix + id);
+            userCache.Result?.ClearByKey(CacheKeys.UserMediaStartNodePathsPrefix + id);
+            userCache.Result?.ClearByKey(CacheKeys.UserAllContentStartNodesPrefix + id);
+            userCache.Result?.ClearByKey(CacheKeys.UserAllMediaStartNodesPrefix + id);
+        }
+
+        base.Refresh(id);
+    }
+
     public override void Remove(int id)
     {
         Attempt<IAppPolicyCache?> userCache = AppCaches.IsolatedCaches.Get<IUser>();

src/Umbraco.Core/Events/UserNotificationsHandler.cs

@@ -197,7 +197,7 @@ public void Notify(IAction? action, params IContent[] entities)
                     _logger.LogDebug(
                     "There is no current Umbraco user logged in, the notifications will be sent from the administrator");
                 }
-                user = _userService.GetUserById(Constants.Security.SuperUserId);
+                user = _userService.GetAsync(Constants.Security.SuperUserKey).GetAwaiter().GetResult();
                 if (user == null)
                 {
                     _logger.LogWarning(

src/Umbraco.Core/Handlers/AuditNotificationsHandler.cs

@@ -82,7 +82,7 @@ private IUser CurrentPerformingUser
         get
         {
             IUser? identity = _backOfficeSecurityAccessor.BackOfficeSecurity?.CurrentUser;
-            IUser? user = identity == null ? null : _userService.GetUserById(Convert.ToInt32(identity.Id));
+            IUser? user = identity == null ? null : _userService.GetAsync(identity.Key).GetAwaiter().GetResult();
             return user ?? UnknownUser(_globalSettings);
         }
     }

src/Umbraco.Core/Persistence/Repositories/IUserRepository.cs

@@ -4,7 +4,7 @@
 
 namespace Umbraco.Cms.Core.Persistence.Repositories;
 
-public interface IUserRepository : IReadWriteQueryRepository<int, IUser>
+public interface IUserRepository : IReadWriteQueryRepository<Guid, IUser>
 {
     /// <summary>
     ///     Gets the count of items based on a complex query
@@ -142,5 +142,5 @@ IEnumerable<IUser> GetPagedResultsByQuery(
 
     void ClearLoginSession(Guid sessionId);
 
-    IEnumerable<IUser> GetNextUsers(int id, int count);
+    IEnumerable<IUser> GetNextUsers(Guid key, int count);
 }

src/Umbraco.Core/Services/IUserService.cs

@@ -322,7 +322,7 @@ IEnumerable<IUser> GetAll(
     /// </returns>
     IEnumerable<IUser> GetAllNotInGroup(int groupId);
 
-    IEnumerable<IUser> GetNextUsers(int id, int count);
+    IEnumerable<IUser> GetNextUsers(Guid key, int count);
 
     #region User groups
 

src/Umbraco.Core/Services/MemberService.cs

@@ -1,4 +1,4 @@
 using Microsoft.Extensions.Logging;
 using Umbraco.Cms.Core.Events;
 using Umbraco.Cms.Core.Models;
 using Umbraco.Cms.Core.Models.Membership;
@@ -20,8 +20,8 @@
         private readonly IMemberTypeRepository _memberTypeRepository;
         private readonly IMemberGroupRepository _memberGroupRepository;
         private readonly IAuditRepository _auditRepository;
-
         private readonly IMemberGroupService _memberGroupService;
+        private readonly Lazy<IIdKeyMap> _idKeyMap;
 
         #region Constructor
 
@@ -33,13 +33,15 @@
             IMemberRepository memberRepository,
             IMemberTypeRepository memberTypeRepository,
             IMemberGroupRepository memberGroupRepository,
-            IAuditRepository auditRepository)
+            IAuditRepository auditRepository,
+            Lazy<IIdKeyMap> idKeyMap)
             : base(provider, loggerFactory, eventMessagesFactory)
         {
             _memberRepository = memberRepository;
             _memberTypeRepository = memberTypeRepository;
             _memberGroupRepository = memberGroupRepository;
             _auditRepository = auditRepository;
+            _idKeyMap = idKeyMap;
             _memberGroupService = memberGroupService ?? throw new ArgumentNullException(nameof(memberGroupService));
         }
 
@@ -333,8 +335,7 @@
         {
             using ICoreScope scope = ScopeProvider.CreateCoreScope(autoComplete: true);
             scope.ReadLock(Constants.Locks.MemberTree);
-            IQuery<IMember> query = Query<IMember>().Where(x => x.Key == id);
-            return _memberRepository.Get(query)?.FirstOrDefault();
+            return GetMemberFromRepository(id);
         }
 
         [Obsolete($"Use {nameof(GetById)}. Will be removed in V15.")]
@@ -1069,6 +1070,12 @@
 
         private void Audit(AuditType type, int userId, int objectId, string? message = null) => _auditRepository.Save(new AuditItem(objectId, type, userId, ObjectTypes.GetName(UmbracoObjectTypes.Member), message));
 
+        private IMember? GetMemberFromRepository(Guid id)
+            => _idKeyMap.Value.GetIdForKey(id, UmbracoObjectTypes.Member) switch
+            {
+                { Success: false } => null,
+                { Result: var intId } => _memberRepository.Get(intId),
+            };
         #endregion
 
         #region Membership

src/Umbraco.Core/Services/MetricsConsentService.cs

@@ -71,7 +71,7 @@ public void SetConsentLevel(TelemetryLevel telemetryLevel)
         IUser? currentUser = _backOfficeSecurityAccessor.BackOfficeSecurity?.CurrentUser;
         if (currentUser is null)
         {
-            currentUser = _userService.GetUserById(Constants.Security.SuperUserId);
+            currentUser = _userService.GetAsync(Constants.Security.SuperUserKey).GetAwaiter().GetResult();
         }
 
         _logger.LogInformation("Telemetry level set to {telemetryLevel} by {username}", telemetryLevel, currentUser?.Username);

src/Umbraco.Core/Services/NotificationService.cs

@@ -94,52 +94,41 @@
         // lazily get versions
         var prevVersionDictionary = new Dictionary<int, IContentBase?>();
 
-        // see notes above
-        var id = Constants.Security.SuperUserId;
-        const int pagesz = 400; // load batches of 400 users
-        do
+        var notifications = GetUsersNotifications(new List<int>(), action, Enumerable.Empty<int>(), Constants.ObjectTypes.Document)?.ToList();
+        if (notifications is null || notifications.Count == 0)
         {
-            var notifications = GetUsersNotifications(new List<int>(), action, Enumerable.Empty<int>(), Constants.ObjectTypes.Document)?.ToList();
-            if (notifications is null || notifications.Count == 0)
-            {
-                break;
-            }
+            return;
+        }
 
-            // users are returned ordered by id, notifications are returned ordered by user id
-            var users = _userService.GetNextUsers(id, pagesz).Where(x => x.IsApproved).ToList();
-            foreach (IUser user in users)
+        IUser[] users = _userService.GetAll(0, int.MaxValue, out _).ToArray();
+        foreach (IUser user in users)
+        {
+            Notification[] userNotifications = notifications.Where(n => n.UserId == user.Id).ToArray();
+            foreach (Notification notification in userNotifications)
             {
-                Notification[] userNotifications = notifications.Where(n => n.UserId == user.Id).ToArray();
-                foreach (Notification notification in userNotifications)
+                // notifications are inherited down the tree - find the topmost entity
+                // relevant to this notification (entity list is sorted by path)
+                IContent? entityForNotification = entitiesL
+                    .FirstOrDefault(entity =>
+                        pathsByEntityId.TryGetValue(entity.Id, out var path) &&
+                        path.Contains(notification.EntityId));
+
+                if (entityForNotification == null)
                 {
-                    // notifications are inherited down the tree - find the topmost entity
-                    // relevant to this notification (entity list is sorted by path)
-                    IContent? entityForNotification = entitiesL
-                        .FirstOrDefault(entity =>
-                            pathsByEntityId.TryGetValue(entity.Id, out var path) &&
-                            path.Contains(notification.EntityId));
-
-                    if (entityForNotification == null)
-                    {
-                        continue;
-                    }
-
-                    if (prevVersionDictionary.ContainsKey(entityForNotification.Id) == false)
-                    {
-                        prevVersionDictionary[entityForNotification.Id] = GetPreviousVersion(entityForNotification.Id);
-                    }
+                    continue;
+                }
 
-                    // queue notification
-                    NotificationRequest req = CreateNotificationRequest(operatingUser, user, entityForNotification, prevVersionDictionary[entityForNotification.Id], actionName, siteUri, createSubject, createBody);
-                    Enqueue(req);
-                    break;
+                if (prevVersionDictionary.ContainsKey(entityForNotification.Id) == false)
+                {
+                    prevVersionDictionary[entityForNotification.Id] = GetPreviousVersion(entityForNotification.Id);
                 }
-            }
 
-            // load more users if any
-            id = users.Count == pagesz ? users.Last().Id + 1 : -1;
+                // queue notification
+                NotificationRequest req = CreateNotificationRequest(operatingUser, user, entityForNotification, prevVersionDictionary[entityForNotification.Id], actionName, siteUri, createSubject, createBody);
+                Enqueue(req);
+                break;
+            }
         }
-        while (id > 0);
     }
 
     /// <summary>