fix: setup the persons by audience custom result as model the efcore can handle

Author: lsipii

VirtualFinland.UserAPI/src/VirtualFinland.UsersAPI/Data/UsersDBContext.cs

@@ -1,6 +1,7 @@
 using Microsoft.AspNetCore.DataProtection.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore;
 using VirtualFinland.UserAPI.Data.Configuration;
+using VirtualFinland.UserAPI.Data.Virtual;
 using VirtualFinland.UserAPI.Models.UsersDatabase;
 using VirtualFinland.UserAPI.Security.Models;
 
@@ -33,6 +34,7 @@ public UsersDbContext(DbContextOptions options, bool isTesting) : base(options)
     public DbSet<TermsOfService> TermsOfServices => Set<TermsOfService>();
     public DbSet<PersonTermsOfServiceAgreement> PersonTermsOfServiceAgreements => Set<PersonTermsOfServiceAgreement>();
     public DbSet<DataProtectionKey> DataProtectionKeys { get; set; } = null!;
+    public DbSet<PersonsByAudiencesResult> PersonsByAudiencesResults => Set<PersonsByAudiencesResult>();
 
     protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
     {

VirtualFinland.UserAPI/src/VirtualFinland.UsersAPI/Data/Virtual/PersonsByAudiencesResult.cs

@@ -0,0 +1,11 @@
+
+using Microsoft.EntityFrameworkCore;
+
+namespace VirtualFinland.UserAPI.Data.Virtual;
+
+[Keyless]
+public class PersonsByAudiencesResult
+{
+    public string? Audience { get; set; }
+    public int Amount { get; set; }
+}

VirtualFinland.UsersAPI.AdminFunction/AdminApp/Actions/UpdateAnalyticsAction.cs

@@ -74,14 +74,12 @@ public async Task Execute(string? _)
             });
         }
 
-        var personsCountByAudiences = await _dataContext.ExternalIdentities
-            .SelectMany(e => e.Audiences, (entity, textValue) => new { entity, textValue })
-                .GroupBy(x => x.textValue)
-                .Select(group => new
-                {
-                    Audience = group.Key,
-                    Count = group.Count()
-                }).ToListAsync();
+        var rawQuery = @"
+            SELECT COUNT(*) AS Amount, regexp_split_to_table(""Audiences"", ',') AS Audience  
+            FROM ""ExternalIdentities""
+            GROUP BY Audience;
+        ";
+        var personsCountByAudiences = _dataContext.PersonsByAudiencesResults.FromSqlRaw(rawQuery).ToList();
 
         foreach (var personsCountByAudience in personsCountByAudiences)
         {
@@ -90,11 +88,11 @@ public async Task Execute(string? _)
                 continue;
             }
 
-            _logger.LogInformation("PersonsCountByAudience: {Audience} {Count}", personsCountByAudience.Audience, personsCountByAudience.Count);
+            _logger.LogInformation("PersonsCountByAudience: {Audience} {Amount}", personsCountByAudience.Audience, personsCountByAudience.Amount);
             metricData.Add(new()
             {
                 MetricName = "PersonsCountByAudience",
-                Value = personsCountByAudience.Count,
+                Value = personsCountByAudience.Amount,
                 Unit = StandardUnit.None,
                 TimestampUtc = DateTime.UtcNow,
                 Dimensions = new List<Dimension>()