Adds licensing data store

Adds data store and entities required for persisting licensing and throughput data.

This includes adding new tables for licensing metadata, throughput endpoints, and daily throughput data, as well as configurations and a data store implementation to interact with these tables.

Author: johnsimons

src/ProjectReferences.Persisters.Primary.props

@@ -2,7 +2,9 @@
 
   <ItemGroup Label="Persisters">
     <ProjectReference Include="..\ServiceControl.Persistence.RavenDB\ServiceControl.Persistence.RavenDB.csproj" ReferenceOutputAssembly="false" Private="false" />
-    <ProjectReference Include="..\ServiceControl.Persistence.Sql\ServiceControl.Persistence.Sql.csproj" ReferenceOutputAssembly="false" Private="false" />
+    <ProjectReference Include="..\ServiceControl.Persistence.Sql\ServiceControl.Persistence.Sql.SqlServer.csproj" ReferenceOutputAssembly="false" Private="false" />
+    <ProjectReference Include="..\ServiceControl.Persistence.Sql\ServiceControl.Persistence.Sql.PostgreSQL.csproj" ReferenceOutputAssembly="false" Private="false" />
+    <ProjectReference Include="..\ServiceControl.Persistence.Sql\ServiceControl.Persistence.Sql.MySQL.csproj" ReferenceOutputAssembly="false" Private="false" />
   </ItemGroup>
 
 </Project>

src/ServiceControl.Persistence.Sql.Core/Abstractions/BasePersistence.cs

@@ -6,6 +6,7 @@ namespace ServiceControl.Persistence.Sql.Core.Abstractions;
 using ServiceControl.Persistence.UnitOfWork;
 using Implementation;
 using Implementation.UnitOfWork;
+using Particular.LicensingComponent.Persistence;
 
 public abstract class BasePersistence
 {
@@ -37,5 +38,6 @@ protected static void RegisterDataStores(IServiceCollection services, bool maint
         services.AddSingleton<INotificationsManager, NotificationsManager>();
         services.AddSingleton<IIngestionUnitOfWorkFactory, IngestionUnitOfWorkFactory>();
         services.AddSingleton<IErrorMessageDataStore, ErrorMessageDataStore>();
+        services.AddSingleton<ILicensingDataStore, LicensingDataStore>();
     }
 }

src/ServiceControl.Persistence.Sql.Core/DbContexts/ServiceControlDbContextBase.cs

@@ -29,6 +29,9 @@ protected ServiceControlDbContextBase(DbContextOptions options) : base(options)
     public DbSet<GroupCommentEntity> GroupComments { get; set; }
     public DbSet<RetryBatchNowForwardingEntity> RetryBatchNowForwarding { get; set; }
     public DbSet<NotificationsSettingsEntity> NotificationsSettings { get; set; }
+    public DbSet<LicensingMetadataEntity> LicensingMetadata { get; set; }
+    public DbSet<ThroughputEndpointEntity> Endpoints { get; set; }
+    public DbSet<DailyThroughputEntity> Throughput { get; set; }
 
     protected override void OnModelCreating(ModelBuilder modelBuilder)
     {
@@ -53,6 +56,9 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
         modelBuilder.ApplyConfiguration(new GroupCommentConfiguration());
         modelBuilder.ApplyConfiguration(new RetryBatchNowForwardingConfiguration());
         modelBuilder.ApplyConfiguration(new NotificationsSettingsConfiguration());
+        modelBuilder.ApplyConfiguration(new LicensingMetadataEntityConfiguration());
+        modelBuilder.ApplyConfiguration(new ThroughputEndpointConfiguration());
+        modelBuilder.ApplyConfiguration(new DailyThroughputConfiguration());
 
         OnModelCreatingProvider(modelBuilder);
     }

src/ServiceControl.Persistence.Sql.Core/Entities/DailyThroughputEntity.cs

@@ -0,0 +1,10 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+public class DailyThroughputEntity
+{
+    public int Id { get; set; }
+    public required string EndpointName { get; set; }
+    public required string ThroughputSource { get; set; }
+    public required DateOnly Date { get; set; }
+    public required long MessageCount { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/LicensingMetadataEntity.cs

@@ -0,0 +1,8 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+public class LicensingMetadataEntity
+{
+    public int Id { get; set; }
+    public required string Key { get; set; }
+    public required string Data { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/ThroughputEndpointEntity.cs

@@ -0,0 +1,13 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+public class ThroughputEndpointEntity
+{
+    public int Id { get; set; }
+    public required string EndpointName { get; set; }
+    public required string ThroughputSource { get; set; }
+    public string? SanitizedEndpointName { get; set; }
+    public string? EndpointIndicators { get; set; }
+    public string? UserIndicator { get; set; }
+    public string? Scope { get; set; }
+    public DateOnly LastCollectedData { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/EntityConfigurations/DailyThroughputConfiguration.cs

@@ -0,0 +1,31 @@
+namespace ServiceControl.Persistence.Sql.Core.EntityConfigurations;
+
+using Entities;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+class DailyThroughputConfiguration : IEntityTypeConfiguration<DailyThroughputEntity>
+{
+    public void Configure(EntityTypeBuilder<DailyThroughputEntity> builder)
+    {
+        builder.ToTable("DailyThroughput")
+            .HasIndex(e => new
+            {
+                e.EndpointName,
+                e.ThroughputSource,
+                e.Date
+            }, "UC_DailyThroughput_EndpointName_ThroughputSource_Date")
+            .IsUnique();
+        builder.HasKey(e => e.Id);
+        builder.Property(e => e.EndpointName)
+            .IsRequired()
+            .HasMaxLength(200);
+        builder.Property(e => e.ThroughputSource)
+            .IsRequired()
+            .HasMaxLength(50);
+        builder.Property(e => e.Date)
+            .IsRequired();
+        builder.Property(e => e.MessageCount)
+            .IsRequired();
+    }
+}

src/ServiceControl.Persistence.Sql.Core/EntityConfigurations/LicensingMetadataEntityConfiguration.cs

@@ -0,0 +1,22 @@
+namespace ServiceControl.Persistence.Sql.Core.EntityConfigurations;
+
+using Entities;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+class LicensingMetadataEntityConfiguration : IEntityTypeConfiguration<LicensingMetadataEntity>
+{
+    public void Configure(EntityTypeBuilder<LicensingMetadataEntity> builder)
+    {
+        builder.ToTable("LicensingMetadata")
+            .HasIndex(e => e.Key)
+            .IsUnique();
+        builder.HasKey(e => e.Id);
+        builder.Property(e => e.Key)
+            .IsRequired()
+            .HasMaxLength(200);
+        builder.Property(e => e.Data)
+            .IsRequired()
+            .HasMaxLength(2000);
+    }
+}

src/ServiceControl.Persistence.Sql.Core/EntityConfigurations/ThroughputEndpointConfiguration.cs

@@ -0,0 +1,32 @@
+namespace ServiceControl.Persistence.Sql.Core.EntityConfigurations;
+
+using Entities;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+class ThroughputEndpointConfiguration : IEntityTypeConfiguration<ThroughputEndpointEntity>
+{
+    public void Configure(EntityTypeBuilder<ThroughputEndpointEntity> builder)
+    {
+        builder.ToTable("ThroughputEndpoint")
+            .HasIndex(e => new
+            {
+                e.EndpointName,
+                e.ThroughputSource
+            }, "UC_ThroughputEndpoint_EndpointName_ThroughputSource")
+            .IsUnique();
+        builder.HasKey(e => e.Id);
+        builder.Property(e => e.EndpointName)
+            .IsRequired()
+            .HasMaxLength(200);
+        builder.Property(e => e.ThroughputSource)
+            .IsRequired()
+            .HasMaxLength(50);
+
+        builder.Property(e => e.SanitizedEndpointName);
+        builder.Property(e => e.EndpointIndicators);
+        builder.Property(e => e.UserIndicator);
+        builder.Property(e => e.Scope);
+        builder.Property(e => e.LastCollectedData);
+    }
+}