registration of pg cache

backend/packagegroups/NuGet.props

@@ -40,6 +40,7 @@
     <PackageReference Update="DotNetEnv" Version="3.1.1" />
     <PackageReference Update="NuGet.Versioning" Version="6.11.1" />
     <PackageReference Update="DistributedLock.Postgres" Version="1.2.0" />
+    <PackageReference Update="Community.Microsoft.Extensions.Caching.PostgreSql" Version="4.0.6" />
   </ItemGroup>
 
   <ItemGroup Label="Packages used for testing">

backend/src/Designer/Designer.csproj

@@ -26,6 +26,7 @@
     <PackageReference Include="Altinn.Common.AccessTokenClient" />
     <PackageReference Include="Altinn.Platform.Storage.Interface" />
     <PackageReference Include="Azure.Security.KeyVault.Secrets" />
+    <PackageReference Include="Community.Microsoft.Extensions.Caching.PostgreSql" />
     <PackageReference Include="CompilerAttributes" />
     <PackageReference Include="DistributedLock.Postgres" />
     <PackageReference Include="DotNetEnv" />

backend/src/Designer/Infrastructure/Models/PostgreSQLSettings.cs

@@ -16,5 +16,10 @@ public class PostgreSQLSettings : ISettingsMarker
         /// Password for app user for the postgres db
         /// </summary>
         public string DesignerDbPwd { get; set; }
+
+        public string FormattedConnectionString()
+        {
+            return string.Format(ConnectionString, DesignerDbPwd);
+        }
     }
 }

backend/src/Designer/Infrastructure/ServiceRegistration.cs

@@ -48,10 +48,7 @@ public static IServiceCollection RegisterServiceImplementations(this IServiceCol
             services.AddDbContext<DesignerdbContext>(options =>
             {
                 PostgreSQLSettings postgresSettings = configuration.GetSection(nameof(PostgreSQLSettings)).Get<PostgreSQLSettings>();
-                string connectionString = string.Format(
-                    postgresSettings.ConnectionString,
-                    postgresSettings.DesignerDbPwd);
-                options.UseNpgsql(connectionString);
+                options.UseNpgsql(postgresSettings.FormattedConnectionString());
             });
 
             services.AddScoped<IReleaseRepository, ORMReleaseRepository>();

backend/src/Designer/Middleware/UserRequestSynchronization/RequestSyncExtensions.cs

@@ -24,10 +24,7 @@ public static IServiceCollection RegisterSynchronizationServices(this IServiceCo
         services.AddSingleton<IDistributedLockProvider>(_ =>
         {
             PostgreSQLSettings postgresSettings = configuration.GetSection(nameof(PostgreSQLSettings)).Get<PostgreSQLSettings>();
-            string connectionString = string.Format(
-                postgresSettings.ConnectionString,
-                postgresSettings.DesignerDbPwd);
-            return new PostgresDistributedSynchronizationProvider(connectionString);
+            return new PostgresDistributedSynchronizationProvider(postgresSettings.FormattedConnectionString());
         });
         return services;
     }

backend/src/Designer/Migrations/SqlScripts/DistributedCache/Down/01-drop-distributedcache-table.sql

@@ -1 +1 @@
-DROP TABLE IF EXISTS designer.distribuedcache;
+DROP TABLE IF EXISTS designer.distributedcache;

backend/src/Designer/Migrations/SqlScripts/DistributedCache/Up/01-setup-distributedcache-table.sql

@@ -1,4 +1,4 @@
-CREATE TABLE IF NOT EXISTS designer.distribuedcache
+CREATE TABLE IF NOT EXISTS designer.distributedcache
 (
     "Id" text COLLATE pg_catalog."default" NOT NULL,
     "Value" bytea,

backend/src/Designer/Program.cs

@@ -19,6 +19,7 @@
 using Altinn.Studio.Designer.Services.Interfaces;
 using Altinn.Studio.Designer.Tracing;
 using Altinn.Studio.Designer.TypedHttpClients;
+using Community.Microsoft.Extensions.Caching.PostgreSql;
 using Microsoft.ApplicationInsights.Extensibility;
 using Microsoft.ApplicationInsights.Extensibility.EventCounterCollector;
 using Microsoft.AspNetCore.Builder;
@@ -264,6 +265,19 @@ void ConfigureServices(IServiceCollection services, IConfiguration configuration
     services.AddFeatureManagement();
     services.RegisterSynchronizationServices(configuration);
 
+    // Override the default distributed cache with a PostgreSQL implementation
+    services.AddDistributedPostgreSqlCache(setup =>
+    {
+        PostgreSQLSettings postgresSettings =
+            configuration.GetSection(nameof(PostgreSQLSettings)).Get<PostgreSQLSettings>();
+
+        setup.ConnectionString = postgresSettings.FormattedConnectionString();
+        setup.SchemaName = "designer";
+        setup.TableName = "distributedcache";
+        setup.DisableRemoveExpired = false;
+        setup.CreateInfrastructure = false;
+        setup.ExpiredItemsDeletionInterval = TimeSpan.FromMinutes(30);
+    });
 
     if (!env.IsDevelopment())
     {

backend/src/Designer/Repository/DeploymentRepository.cs

@@ -32,9 +32,7 @@ public class DeploymentRepository : IDeploymentRepository
         /// </summary>
         public DeploymentRepository(PostgreSQLSettings postgresSettings, ILogger<DeploymentRepository> logger)
         {
-            _connectionString = string.Format(
-                postgresSettings.ConnectionString,
-                postgresSettings.DesignerDbPwd);
+            _connectionString = postgresSettings.FormattedConnectionString();
             _logger = logger;
         }
 

backend/src/Designer/Repository/ReleaseRepository.cs

@@ -34,9 +34,7 @@ public class ReleaseRepository : IReleaseRepository
         /// </summary>
         public ReleaseRepository(PostgreSQLSettings postgresSettings, ILogger<ReleaseRepository> logger)
         {
-            _connectionString = string.Format(
-                postgresSettings.ConnectionString,
-                postgresSettings.DesignerDbPwd);
+            _connectionString = postgresSettings.FormattedConnectionString();
             _logger = logger;
         }