stash

Author: andreasisnes

src/apps/Altinn.AccessManagement/src/Altinn.AccessMgmt.PersistenceEF/Configurations/OutboxMessageConfiguration.cs

@@ -0,0 +1,41 @@
+using Altinn.AccessMgmt.PersistenceEF.Extensions;
+using Altinn.AccessMgmt.PersistenceEF.Models;
+using Altinn.AccessMgmt.PersistenceEF.Models.Base;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+namespace Altinn.AccessMgmt.PersistenceEF.Configurations;
+
+public class OutboxMessageConfiguration : IEntityTypeConfiguration<OutboxMessage>
+{
+    public void Configure(EntityTypeBuilder<OutboxMessage> builder)
+    {
+        builder.ToDefaultTable();
+        
+        builder.HasKey(p => p.Id);
+        builder.HasIndex(p => p.RefId);
+
+        builder.Property(p => p.CompletedAt);
+        builder.Property(p => p.CorrelationId);
+        
+        builder.Property(p => p.Data)
+            .HasColumnType("jsonb")
+            .IsRequired();
+
+        builder.Property(p => p.Handler);
+        builder.Property(p => p.Retries)
+            .IsRequired()
+            .HasDefaultValue(0);
+
+        builder.Property(p => p.Schedule);
+        builder.Property(p => p.StartedAt);
+
+        builder.Property(b => b.Status)
+            .HasConversion<string>()
+            .HasDefaultValue(OutboxStatus.Pending)
+            .IsRequired();
+
+        builder.Property(b => b.Timeout)
+            .HasDefaultValue(TimeSpan.FromSeconds(10));
+    }
+}

src/apps/Altinn.AccessManagement/src/Altinn.AccessMgmt.PersistenceEF/Contexts/AppDbContext.cs

@@ -50,6 +50,8 @@ public class AppDbContext(DbContextOptions<AppDbContext> options) : DbContext(op
 
     public DbSet<EntityVariantRole> EntityVariantRoles => Set<EntityVariantRole>();
 
+    public DbSet<OutboxMessage> OutboxMessages => Set<OutboxMessage>();
+
     public DbSet<Package> Packages => Set<Package>();
 
     public DbSet<PackageResource> PackageResources => Set<PackageResource>();
@@ -165,6 +167,7 @@ private void ApplyAuditConfiguration(ModelBuilder modelBuilder)
         modelBuilder.ApplyConfiguration<AuditEntityType>(new AuditEntityTypeConfiguration());
         modelBuilder.ApplyConfiguration<AuditEntityVariant>(new AuditEntityVariantConfiguration());
         modelBuilder.ApplyConfiguration<AuditEntityVariantRole>(new AuditEntityVariantRoleConfiguration());
+        modelBuilder.ApplyConfiguration<OutboxMessage>(new OutboxMessageConfiguration());
         modelBuilder.ApplyConfiguration<AuditPackage>(new AuditPackageConfiguration());
         modelBuilder.ApplyConfiguration<AuditPackageResource>(new AuditPackageResourceConfiguration());
         modelBuilder.ApplyConfiguration<AuditProvider>(new AuditProviderConfiguration());
@@ -317,6 +320,7 @@ public async Task UpsertOutboxAsync<TOutboxData, TData>(
         Func<TData> addValueFactory,
         Func<TData, TOutboxData, TData> updateValueFactory)
     {
+        
         ArgumentException.ThrowIfNullOrEmpty(refId);
         ArgumentNullException.ThrowIfNull(addValueFactory);
         ArgumentNullException.ThrowIfNull(updateValueFactory);

src/apps/Altinn.AccessManagement/src/Altinn.AccessMgmt.PersistenceEF/Extensions/ServiceCollectionExtensions.cs

@@ -4,6 +4,7 @@
 using Altinn.AccessMgmt.PersistenceEF.Constants;
 using Altinn.AccessMgmt.PersistenceEF.Contexts;
 using Altinn.AccessMgmt.PersistenceEF.Data;
+using Altinn.AccessMgmt.PersistenceEF.Outbox;
 using Altinn.AccessMgmt.PersistenceEF.Queries.Connection;
 using Altinn.AccessMgmt.PersistenceEF.Utils;
 using Altinn.Authorization.Host.Database;
@@ -22,6 +23,7 @@ public static class ServiceCollectionExtensions
     public static IServiceCollection AddAccessManagementDatabase(this IServiceCollection services, Action<AccessManagementDatabaseOptions> configureOptions)
     {
         var options = new AccessManagementDatabaseOptions(configureOptions);
+        services.AddKeyedSingleton("handlers", options.Handlers);
         _configureTracing = options.AppConnectionString.Contains("database=authorizationdb", StringComparison.OrdinalIgnoreCase);
         ConstantGuard.ConstantIdsAreUnique();
         services.AddScoped<ReadOnlyInterceptor>();
@@ -226,5 +228,14 @@ public AccessManagementDatabaseOptions(Action<AccessManagementDatabaseOptions> c
         public string MigrationConnectionString { get; set; } = string.Empty;
 
         public string AppConnectionString { get; set; } = string.Empty;
+
+        internal Dictionary<string, Type> Handlers { get; set; } = [];
+
+        public AccessManagementDatabaseOptions AddOutboxHandler<T>(string handlerName)
+            where T : IOutboxHandler
+        {
+            Handlers[handlerName] = typeof(T);
+            return this;
+        }
     }
 }

src/apps/Altinn.AccessManagement/src/Altinn.AccessMgmt.PersistenceEF/Outbox/OutboxHandlerJob.cs

@@ -0,0 +1,34 @@
+using System.Collections.Concurrent;
+using Altinn.AccessMgmt.PersistenceEF.Models;
+
+namespace Altinn.AccessMgmt.PersistenceEF.Outbox;
+
+/// <summary>
+/// 
+/// </summary>
+internal class OutboxRegisterHandlers
+{
+    private ConcurrentDictionary<string, Type> Handlers { get; } = [];
+
+    public OutboxRegisterHandlers AddHandler<THandler>(string handlerName)
+        where THandler : IOutboxHandler
+    {
+        Handlers.AddOrUpdate(
+            handlerName,
+            add => typeof(THandler),
+            (_, oldHandler) =>
+            {
+                return typeof(THandler);
+            });
+
+        return this;
+    }
+
+    public bool TryGetHandler(string handlerName, out Type handler) =>
+        Handlers.TryGetValue(handlerName, out handler);
+}
+
+public interface IOutboxHandler
+{
+    Task Handle<TData>(OutboxMessage message, TData data, IServiceProvider provider, CancellationToken cancellationToken);
+}