#2 Add an aggregated metric record counting all connected players

Author: jmderuty

src/Stormancer.Plugins/Users/Stormancer.Server.Plugins.Users/Changelog.rst

@@ -25,6 +25,7 @@ Added
 - Dimensions are saved in the analytics system on login
 - Added GetSelectedPlatformForPseudo to get the platform the profile system should use when computing the pseudonym.
 - Added platform as a default dimension for the connected users metric.
+- Added an aggregated `total connection users value` accross all dimensions metrics record to the list of metrics records generated by the sessions system. (Issue #2)
 
 Fixed
 *****

src/Stormancer.Plugins/Users/Stormancer.Server.Plugins.Users/Stormancer.Server.Plugins.Users.csproj

@@ -5,7 +5,7 @@
 		<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
 		<Company>Stormancer</Company>
 		<Authors>Stormancer</Authors>
-		<Version>10.0.2.44</Version>
+		<Version>10.0.2.45</Version>
 		<IncludeSymbols>true</IncludeSymbols>
 		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
 		<GenerateDocumentationFile>true</GenerateDocumentationFile>

src/Stormancer.Plugins/Users/Stormancer.Server.Plugins.Users/UserSessions.cs

@@ -175,7 +175,7 @@ private IEnumerable<IIndexableField> MapSessionRecord(SessionRecord record)
                 yield return new StringField("user.id", user.Id, Field.Store.NO);
                 yield return new StringField("platformUserId.platform", record.platformId.Platform, Field.Store.NO);
                 yield return new StringField("platformUserId.id", record.platformId.PlatformUserId, Field.Store.NO);
-                yield return new StringField("platformUserId",record.platformId.ToString(), Field.Store.NO);
+                yield return new StringField("platformUserId", record.platformId.ToString(), Field.Store.NO);
                 foreach (var field in DefaultMapper.JsonMapper("user.auth", user.Auth))
                 {
                     yield return field;
@@ -512,7 +512,7 @@ public async Task CreateSessionForPeer(IScenePeerClient peer, User? user, Platfo
 
                 await _eventHandlers().RunEventHandler(h => h.OnLoggedIn(loginContext), ex => logger.Log(LogLevel.Error, "userSessions", "An error occurred while running LoggedIn event handlers", ex));
 
-                foreach (var (oldPeer,s) in currentSessions.Select(s =>( _scene.TryGetPeer(s.SessionId, out var peer) ? peer : null,s)))
+                foreach (var (oldPeer, s) in currentSessions.Select(s => (_scene.TryGetPeer(s.SessionId, out var peer) ? peer : null, s)))
                 {
                     if (peer != oldPeer)
                     {
@@ -1096,23 +1096,43 @@ public int AuthenticatedUsersCount
 
         public ValueTask<IEnumerable<AuthenticatedUsersCount>> GetAuthenticatedUsersByDimensionsAsync()
         {
-            var time = DateTime.UtcNow;
-            return ValueTask.FromResult(repository
-            .All
-            .Select(d => d.Source)
-            .WhereNotNull()
-            .GroupBy(s => s.Dimensions, _dimensionsComparer)
-            .Select(g => new AuthenticatedUsersCount
+
+            static IEnumerable<AuthenticatedUsersCount> GetAuthenticatedUsersByDimensions(SessionsRepository repository)
             {
-                Timestamp = time,
-                Count = g.Count(),
-                Dimensions = g.Key
-            }));
+                var time = DateTime.UtcNow;
+
+                var total = 0;
+                foreach (var g in repository
+                    .All
+                    .Select(d => d.Source)
+                    .WhereNotNull()
+                    .GroupBy(s => s.Dimensions, _dimensionsComparer))
+                {
+                    var count = g.Count();
+                    total += count;
+                    yield return new AuthenticatedUsersCount
+                    {
+                        Timestamp = time,
+                        Count = count,
+                        Dimensions = g.Key
+                    }
+;
+                }
+
+                yield return new AuthenticatedUsersCount
+                {
+                    Timestamp = time,
+                    Count = total,
+                    Dimensions = FrozenDictionary<string, string>.Empty
+                };
+            }
+
+            return ValueTask.FromResult(GetAuthenticatedUsersByDimensions(repository));
         }
 
         public async Task UpdateUserOptionsAsync(string userId, string key, JObject value, CancellationToken cancellationToken)
         {
-            var sessions = await GetSession(new PlatformId { Platform = Constants.PROVIDER_TYPE_STORMANCER, PlatformUserId = userId}, cancellationToken);
+            var sessions = await GetSession(new PlatformId { Platform = Constants.PROVIDER_TYPE_STORMANCER, PlatformUserId = userId }, cancellationToken);
             bool first = true;
             foreach (var session in sessions)
             {