feat: Add SubjectResource entity and db migration

Digdir.Domain.Dialogporten.sln

@@ -59,6 +59,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Digdir.Domain.Dialogporten.
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Digdir.Domain.Dialogporten.GraphQl.Unit.Tests", "tests\Digdir.Domain.Dialogporten.GraphQl.Unit.Tests\Digdir.Domain.Dialogporten.GraphQl.Unit.Tests.csproj", "{AF35FFCA-1206-4C08-A003-DA4A1344CCD5}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Digdir.Domain.Dialogporten.Janitor", "src\Digdir.Domain.Dialogporten.Janitor\Digdir.Domain.Dialogporten.Janitor.csproj", "{0900E3CF-F9D8-4B29-957F-484B3B028D6D}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -141,6 +143,10 @@ Global
 		{AF35FFCA-1206-4C08-A003-DA4A1344CCD5}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{AF35FFCA-1206-4C08-A003-DA4A1344CCD5}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{AF35FFCA-1206-4C08-A003-DA4A1344CCD5}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0900E3CF-F9D8-4B29-957F-484B3B028D6D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0900E3CF-F9D8-4B29-957F-484B3B028D6D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0900E3CF-F9D8-4B29-957F-484B3B028D6D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0900E3CF-F9D8-4B29-957F-484B3B028D6D}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -168,6 +174,7 @@ Global
 		{234FE24D-1047-4E29-A625-1EB406C37A2D} = {320B47A0-5EB8-4B6E-8C84-90633A1849CA}
 		{1EF1AE42-17F1-4761-ACFE-DF8E8A9B9429} = {CADB8189-4AA1-4732-844A-C41DBF3EC8B7}
 		{AF35FFCA-1206-4C08-A003-DA4A1344CCD5} = {CADB8189-4AA1-4732-844A-C41DBF3EC8B7}
+		{0900E3CF-F9D8-4B29-957F-484B3B028D6D} = {320B47A0-5EB8-4B6E-8C84-90633A1849CA}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {B2FE67FF-7622-4AFB-AD8E-961B6A39D888}

src/Digdir.Domain.Dialogporten.Application/Externals/IDialogDbContext.cs

@@ -8,6 +8,7 @@
 using Digdir.Domain.Dialogporten.Domain.Dialogs.Entities.Contents;
 using Digdir.Domain.Dialogporten.Domain.Dialogs.Entities.Transmissions;
 using Digdir.Domain.Dialogporten.Domain.Dialogs.Entities.Transmissions.Contents;
+using Digdir.Domain.Dialogporten.Domain.SubjectResources;
 
 namespace Digdir.Domain.Dialogporten.Application.Externals;
 
@@ -40,6 +41,8 @@ public interface IDialogDbContext
 
     DbSet<OutboxMessage> OutboxMessages { get; }
     DbSet<OutboxMessageConsumer> OutboxMessageConsumers { get; }
+    DbSet<SubjectResource> SubjectResources { get; }
+    DbSet<SubjectResourceLastUpdate> SubjectResourceLastUpdates { get; }
 
     /// <summary>
     /// Validate a property on the <typeparamref name="TEntity"/> using a lambda

src/Digdir.Domain.Dialogporten.Application/Externals/IResourceRegistry.cs

@@ -4,6 +4,7 @@ public interface IResourceRegistry
 {
     Task<IReadOnlyCollection<ServiceResourceInformation>> GetResourceInformationForOrg(string orgNumber, CancellationToken cancellationToken);
     Task<ServiceResourceInformation?> GetResourceInformation(string serviceResourceId, CancellationToken cancellationToken);
+    Task<List<UpdatedSubjectResource>> GetUpdatedSubjectResources(DateTimeOffset since, CancellationToken cancellationToken);
 }
 
 public sealed record ServiceResourceInformation
@@ -19,3 +20,11 @@ public ServiceResourceInformation(string resourceId, string resourceType, string
         OwnerOrgNumber = ownerOrgNumber.ToLowerInvariant();
     }
 }
+
+public sealed record UpdatedSubjectResource
+{
+    public Uri Subject { get; set; } = null!;
+    public Uri Resource { get; set; } = null!;
+    public DateTimeOffset UpdatedAt { get; set; }
+    public bool Deleted { get; set; }
+}

src/Digdir.Domain.Dialogporten.Domain/SubjectResources/SubjectResource.cs

@@ -0,0 +1,13 @@
+using Digdir.Library.Entity.Abstractions;
+using Digdir.Library.Entity.Abstractions.Features.Updatable;
+
+namespace Digdir.Domain.Dialogporten.Domain.SubjectResources;
+
+public class SubjectResource : IEntity
+{
+    public Guid Id { get; set; }
+    public string Subject { get; set; } = null!;
+    public string Resource { get; set; } = null!;
+    public DateTimeOffset UpdatedAt { get; set; }
+    public DateTimeOffset CreatedAt { get; set; }
+}

src/Digdir.Domain.Dialogporten.Domain/SubjectResources/SubjectResourceLastUpdate.cs

@@ -0,0 +1,9 @@
+using Digdir.Library.Entity.Abstractions.Features.Identifiable;
+
+namespace Digdir.Domain.Dialogporten.Domain.SubjectResources;
+
+public class SubjectResourceLastUpdate : IIdentifiableEntity
+{
+    public Guid Id { get; set; }
+    public DateTimeOffset LastUpdate { get; set; }
+}

src/Digdir.Domain.Dialogporten.Infrastructure/Altinn/ResourceRegistry/LocalDevelopmentResourceRegistry.cs

@@ -36,6 +36,13 @@ public async Task<IReadOnlyCollection<ServiceResourceInformation>> GetResourceIn
             new ServiceResourceInformation(serviceResourceId, LocalResourceType, LocalOrgId));
     }
 
+#pragma warning disable CA1822
+    public async Task<List<UpdatedSubjectResource>> GetUpdatedSubjectResources(DateTimeOffset _, CancellationToken __)
+#pragma warning restore CA1822
+    {
+        return await Task.FromResult(new List<UpdatedSubjectResource>());
+    }
+
     private sealed class ServiceResourceInformationEqualityComparer : IEqualityComparer<ServiceResourceInformation>
     {
         public bool Equals(ServiceResourceInformation? x, ServiceResourceInformation? y)

src/Digdir.Domain.Dialogporten.Infrastructure/Altinn/ResourceRegistry/ResourceRegistryClient.cs

@@ -43,6 +43,33 @@ public async Task<IReadOnlyCollection<ServiceResourceInformation>> GetResourceIn
         return resource;
     }
 
+    public async Task<List<UpdatedSubjectResource>> GetUpdatedSubjectResources(DateTimeOffset since, CancellationToken cancellationToken)
+    {
+        const string searchEndpoint = "resourceregistry/api/v1/resource/updated";
+        var resources = new List<UpdatedSubjectResource>();
+        var nextUrl = searchEndpoint + "?since=" + Uri.EscapeDataString(since.ToString("O"));
+        do
+        {
+            var response = await _client
+                .GetFromJsonEnsuredAsync<UpdatedResponse>(nextUrl,
+                    cancellationToken: cancellationToken);
+
+            resources.AddRange(response.Data.Select(item =>
+                new UpdatedSubjectResource
+                {
+                    Resource = item.ResourceUrn,
+                    Subject = item.SubjectUrn,
+                    UpdatedAt = item.UpdatedAt,
+                    Deleted = item.Deleted
+                }));
+
+            nextUrl = response.Links.Next?.ToString();
+
+        } while (nextUrl is not null);
+
+        return resources;
+    }
+
     private async Task<Dictionary<string, ServiceResourceInformation[]>> GetOrSetResourceInformationByOrg(
         CancellationToken cancellationToken)
     {
@@ -76,7 +103,7 @@ private async Task<ServiceResourceInformation[]> FetchServiceResourceInformation
         const string searchEndpoint = "resourceregistry/api/v1/resource/resourcelist";
 
         var response = await _client
-            .GetFromJsonEnsuredAsync<List<ResourceRegistryResponse>>(searchEndpoint,
+            .GetFromJsonEnsuredAsync<List<ResourceListResponse>>(searchEndpoint,
                 cancellationToken: cancellationToken);
 
         return response
@@ -92,7 +119,7 @@ ResourceTypeAltinnApp or
             .ToArray();
     }
 
-    private sealed class ResourceRegistryResponse
+    private sealed class ResourceListResponse
     {
         public required string Identifier { get; init; }
         public required CompetentAuthority HasCompetentAuthority { get; init; }
@@ -106,5 +133,23 @@ private sealed class CompetentAuthority
         public string? Organization { get; init; }
         public required string OrgCode { get; init; }
     }
-}
 
+    private sealed class UpdatedResponse
+    {
+        public required UpdatedResponseLinks Links { get; init; }
+        public required List<UpdatedResponseItem> Data { get; init; }
+    }
+
+    private sealed class UpdatedResponseLinks
+    {
+        public Uri? Next { get; init; }
+    }
+
+    private sealed class UpdatedResponseItem
+    {
+        public required Uri SubjectUrn { get; init; }
+        public required Uri ResourceUrn { get; init; }
+        public required DateTimeOffset UpdatedAt { get; init; }
+        public required bool Deleted { get; init; }
+    }
+}

src/Digdir.Domain.Dialogporten.Infrastructure/InfrastructureExtensions.cs

@@ -255,8 +255,11 @@ private static IServiceCollection ConfigureFusionCache(this IServiceCollection s
                 SkipMemoryCache = settings.SkipMemoryCache
             })
             .WithRegisteredSerializer()
-            .WithRegisteredDistributedCache()
-            .WithRegisteredBackplane();
+            // If Redis is disabled (eg. in local development or non-web runtimes), we must instruct FusionCache to
+            // allow the use of InMemoryDistributedCache (it is by default ignored as a IDistributedCache implementation)
+            // TryWithRegisteredBackplane is used to ensure that we can continue without Redis as backplane
+            .WithRegisteredDistributedCache(ignoreMemoryDistributedCache: false)
+            .TryWithRegisteredBackplane();
 
         return services;
     }

src/Digdir.Domain.Dialogporten.Infrastructure/Persistence/Configurations/SubjectResources/SubjectResourceConfiguration.cs

@@ -0,0 +1,15 @@
+using Digdir.Domain.Dialogporten.Domain.SubjectResources;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+namespace Digdir.Domain.Dialogporten.Infrastructure.Persistence.Configurations.SubjectResources;
+
+internal sealed class SubjectResourceConfiguration : IEntityTypeConfiguration<SubjectResource>
+{
+    public void Configure(EntityTypeBuilder<SubjectResource> builder)
+    {
+        builder.ToTable("SubjectResource");
+        builder.HasIndex("Subject");
+        builder.HasIndex("Resource");
+    }
+}

src/Digdir.Domain.Dialogporten.Infrastructure/Persistence/Configurations/SubjectResources/SubjectResourceLastUpdateConfiguration.cs

@@ -0,0 +1,13 @@
+using Digdir.Domain.Dialogporten.Domain.SubjectResources;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+namespace Digdir.Domain.Dialogporten.Infrastructure.Persistence.Configurations.SubjectResources;
+
+internal sealed class SubjectResourceLastUpdateConfiguration : IEntityTypeConfiguration<SubjectResourceLastUpdate>
+{
+    public void Configure(EntityTypeBuilder<SubjectResourceLastUpdate> builder)
+    {
+        builder.ToTable("SubjectResourceLastUpdate");
+    }
+}

src/Digdir.Domain.Dialogporten.Infrastructure/Persistence/DialogDbContext.cs

@@ -15,6 +15,7 @@
 using Digdir.Domain.Dialogporten.Domain.Dialogs.Entities.Contents;
 using Digdir.Domain.Dialogporten.Domain.Dialogs.Entities.Transmissions;
 using Digdir.Domain.Dialogporten.Domain.Dialogs.Entities.Transmissions.Contents;
+using Digdir.Domain.Dialogporten.Domain.SubjectResources;
 
 namespace Digdir.Domain.Dialogporten.Infrastructure.Persistence;
 
@@ -41,6 +42,8 @@ public DialogDbContext(DbContextOptions<DialogDbContext> options) : base(options
     public DbSet<DialogContentType> DialogContentTypes => Set<DialogContentType>();
     public DbSet<OutboxMessage> OutboxMessages => Set<OutboxMessage>();
     public DbSet<OutboxMessageConsumer> OutboxMessageConsumers => Set<OutboxMessageConsumer>();
+    public DbSet<SubjectResource> SubjectResources => Set<SubjectResource>();
+    public DbSet<SubjectResourceLastUpdate> SubjectResourceLastUpdates => Set<SubjectResourceLastUpdate>();
 
     //protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) =>
     //    optionsBuilder.LogTo(Console.WriteLine);