provide monthly throughput values to the licensing API (#5532)

Author: PhilBastian

src/Particular.LicensingComponent.Contracts/EndpointThroughputSummary.cs

@@ -7,11 +7,14 @@ public class EndpointThroughputSummary
     public bool IsKnownEndpoint { get; set; }
     public string UserIndicator { get; set; }
     public long MaxDailyThroughput { get; set; }
+    public MonthlyThroughput[] MonthlyThroughput { get; set; }
     public long MaxMonthlyThroughput { get; set; }
 }
 
 public class UpdateUserIndicator
 {
     public string Name { get; set; }
     public string UserIndicator { get; set; }
-}
+}
+
+public record MonthlyThroughput(string Month, long Throughput);

src/Particular.LicensingComponent/ThroughputCollector.cs

@@ -73,6 +73,7 @@ public async Task<List<EndpointThroughputSummary>> GetThroughputSummary(Cancella
                 UserIndicator = endpointData.UserIndicator ?? (endpointData.IsKnownEndpoint ? Contracts.UserIndicator.NServiceBusEndpoint.ToString() : string.Empty),
                 IsKnownEndpoint = endpointData.IsKnownEndpoint,
                 MaxDailyThroughput = endpointData.ThroughputData.MaxDailyThroughput(),
+                MonthlyThroughput = endpointData.ThroughputData.MonthlyThroughput(),
                 MaxMonthlyThroughput = endpointData.ThroughputData.MaxMonthlyThroughput()
             };
 

src/Particular.LicensingComponent/ThroughputDataExtensions.cs

@@ -23,6 +23,11 @@ public static long MaxDailyThroughput(this List<ThroughputData> throughputs)
         return 0;
     }
 
+    public static MonthlyThroughput[] MonthlyThroughput(this List<ThroughputData> throughputs) => [.. throughputs
+            .SelectMany(data => data)
+            .GroupBy(kvp => $"{kvp.Key:yyyy-MM}")
+            .Select(group => new MonthlyThroughput(group.Key, group.Sum(kvp => kvp.Value)))];
+
     public static long MaxMonthlyThroughput(this List<ThroughputData> throughputs)
     {
         var monthlySums = throughputs

src/ServiceControl.Persistence.RavenDB/Throughput/LicensingDataStore.cs

@@ -140,7 +140,7 @@ public async Task<IDictionary<string, IEnumerable<ThroughputData>>> GetEndpointT
                 .IncrementalTimeSeriesFor(document.GenerateDocumentId(), ThroughputTimeSeriesName)
                 .GetAsync(from, token: cancellationToken);
 
-            if (results.TryGetValue(document.SanitizedName, out var throughputDatas) &&
+            if (timeSeries is not null && results.TryGetValue(document.SanitizedName, out var throughputDatas) &&
                 throughputDatas is List<ThroughputData> throughputDataList)
             {
                 var endpointDailyThroughputs = timeSeries.Select(entry => new EndpointDailyThroughput(DateOnly.FromDateTime(entry.Timestamp), (long)entry.Value));