feat(webapi): Add option to disable event generation

docs/schema/V1/swagger.verified.json

@@ -2255,7 +2255,7 @@
         },
         "type": "object"
       },
-      "V1ServiceOwnerDialogsCommandsCreate_DialogCommand": {
+      "V1ServiceOwnerDialogsCommandsCreate_Dialog": {
         "additionalProperties": false,
         "properties": {
           "activities": {
@@ -3233,6 +3233,15 @@
         },
         "type": "object"
       },
+      "V1ServiceOwnerDialogsCreate_DialogRequest": {
+        "additionalProperties": false,
+        "properties": {
+          "dto": {
+            "$ref": "#/components/schemas/V1ServiceOwnerDialogsCommandsCreate_Dialog"
+          }
+        },
+        "type": "object"
+      },
       "V1ServiceOwnerDialogSeenLogsQueriesGet_SeenLog": {
         "additionalProperties": false,
         "properties": {
@@ -5844,14 +5853,12 @@
           "content": {
             "application/json": {
               "schema": {
-                "$ref": "#/components/schemas/V1ServiceOwnerDialogsCommandsCreate_DialogCommand"
+                "$ref": "#/components/schemas/V1ServiceOwnerDialogsCommandsCreate_Dialog"
               }
             }
           },
-          "description": "",
           "required": true,
-          "x-name": "CreateDialogCommand",
-          "x-position": 1
+          "x-name": "dto"
         },
         "responses": {
           "201": {

src/Digdir.Domain.Dialogporten.Application/ApplicationExtensions.cs

@@ -9,6 +9,7 @@
 using Microsoft.Extensions.Hosting;
 using System.Reflection;
 using Digdir.Domain.Dialogporten.Application.Common.Authorization;
+using Digdir.Domain.Dialogporten.Domain;
 using MediatR.NotificationPublishers;
 
 namespace Digdir.Domain.Dialogporten.Application;
@@ -31,6 +32,9 @@ public static IServiceCollection AddApplication(this IServiceCollection services
         // 'CreatedAt', not 'Created At'.
         ValidatorOptions.Global.DisplayNameResolver = (_, member, _) => member?.Name;
 
+        // AddDomain
+        // Lag lik extension i domain
+
         services
             // Framework
             .AddAutoMapper(thisAssembly)
@@ -47,6 +51,7 @@ public static IServiceCollection AddApplication(this IServiceCollection services
             .AddSingleton<ICompactJwsGenerator, Ed25519Generator>()
 
             // Scoped
+            .AddDomain()
             .AddScoped<IDomainContext, DomainContext>()
             .AddScoped<ITransactionTime, TransactionTime>()
             .AddScoped<IDialogTokenGenerator, DialogTokenGenerator>()
@@ -59,7 +64,8 @@ public static IServiceCollection AddApplication(this IServiceCollection services
             .AddTransient<IUserParties, UserParties>()
             .AddTransient<IClock, Clock>()
             .AddTransient(typeof(IPipelineBehavior<,>), typeof(ValidationBehaviour<,>))
-            .AddTransient(typeof(IPipelineBehavior<,>), typeof(DomainContextBehaviour<,>));
+            .AddTransient(typeof(IPipelineBehavior<,>), typeof(DomainContextBehaviour<,>))
+            .AddTransient(typeof(IPipelineBehavior<,>), typeof(DomainAltinnEventOptOutBehaviour<,>));
 
         if (!environment.IsDevelopment())
         {

src/Digdir.Domain.Dialogporten.Application/Common/Authorization/IServiceResourceAuthorizer.cs

@@ -75,7 +75,7 @@ public async Task<SetResourceTypeResult> SetResourceType(DialogEntity dialog, Ca
         if (serviceResourceInformation is null)
         {
             var supportedResourceTypes = string.Join(", ", Constants.SupportedResourceTypes);
-            _domainContext.AddError(nameof(CreateDialogCommand.ServiceResource),
+            _domainContext.AddError(nameof(CreateDialogDto.ServiceResource),
                 $"Service resource '{dialog.ServiceResource}' does not exist in the resource " +
                 $"registry, or is not of the following supported resource types: " +
                 $"[{supportedResourceTypes}].");

src/Digdir.Domain.Dialogporten.Application/Common/Behaviours/DomainAltinnEventOptOutBehaviour.cs

@@ -0,0 +1,30 @@
+using Digdir.Domain.Dialogporten.Domain.Common.DomainEvents;
+using MediatR;
+
+namespace Digdir.Domain.Dialogporten.Application.Common.Behaviours;
+
+internal sealed class DomainAltinnEventOptOutBehaviour<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : IRequest<TResponse>, IAltinnEventDisabler
+{
+    private readonly IDomainEventContext _domainEventContext;
+
+    public DomainAltinnEventOptOutBehaviour(IDomainEventContext domainEventContext)
+    {
+        _domainEventContext = domainEventContext;
+    }
+
+    public Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
+    {
+        if (request.DisableAltinnEvents)
+        {
+            _domainEventContext.AddMetadata("DisableEvents", "true");
+        }
+
+        return next();
+    }
+}
+
+public interface IAltinnEventDisabler
+{
+    bool DisableAltinnEvents { get; }
+}

src/Digdir.Domain.Dialogporten.Application/Features/V1/Common/Events/DialogEventToAltinnForwarder.cs

@@ -18,6 +18,7 @@ public DialogEventToAltinnForwarder(ICloudEventBus cloudEventBus, IOptions<Appli
     [EndpointName("DialogEventToAltinnForwarder_DialogCreatedDomainEvent")]
     public async Task Handle(DialogCreatedDomainEvent domainEvent, CancellationToken cancellationToken)
     {
+        domainEvent.Metadata.TryGetValue("DisableEvents", out var value);
         var cloudEvent = new CloudEvent
         {
             Id = domainEvent.EventId,

src/Digdir.Domain.Dialogporten.Application/Features/V1/EndUser/DialogSystemLabels/Commands/Set/SystemLabelCommand.cs

@@ -63,7 +63,7 @@ public async Task<SetSystemLabelResult> Handle(
 
         var saveResult = await _unitOfWork
                                .EnableConcurrencyCheck(dialog.DialogEndUserContext, request.IfMatchDialogRevision)
-                               .SaveChangesAsync(cancellationToken);
+                               .SaveChangesAsync(cancellationToken: cancellationToken);
         return saveResult.Match<SetSystemLabelResult>(
             success => success,
             domainError => domainError,

src/Digdir.Domain.Dialogporten.Application/Features/V1/EndUser/Dialogs/Queries/Get/GetDialogQuery.cs

@@ -127,7 +127,7 @@ public async Task<GetDialogResult> Handle(GetDialogQuery request, CancellationTo
 
         var saveResult = await _unitOfWork
             .WithoutAggregateSideEffects()
-            .SaveChangesAsync(cancellationToken);
+            .SaveChangesAsync(cancellationToken: cancellationToken);
 
         saveResult.Switch(
             success => { },

src/Digdir.Domain.Dialogporten.Application/Features/V1/ResourceRegistry/Commands/SyncSubjectMap/SyncSubjectMapCommand.cs

@@ -62,7 +62,7 @@ public async Task<SyncSubjectMapResult> Handle(SyncSubjectMapCommand request, Ca
                 mergeCount += batchMergeCount;
             }
 
-            await _unitOfWork.SaveChangesAsync(cancellationToken);
+            await _unitOfWork.SaveChangesAsync(cancellationToken: cancellationToken);
             if (mergeCount > 0)
             {
                 _logger.LogInformation("Successfully synced {UpdatedAmount} total subject-resources. Changes committed.", mergeCount);

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Commands/Create/CreateDialogCommand.cs

@@ -2,6 +2,7 @@
 using AutoMapper;
 using Digdir.Domain.Dialogporten.Application.Common;
 using Digdir.Domain.Dialogporten.Application.Common.Authorization;
+using Digdir.Domain.Dialogporten.Application.Common.Behaviours;
 using Digdir.Domain.Dialogporten.Application.Common.Extensions;
 using Digdir.Domain.Dialogporten.Application.Common.ReturnTypes;
 using Digdir.Domain.Dialogporten.Application.Externals;
@@ -15,11 +16,14 @@
 using Digdir.Library.Entity.Abstractions.Features.Identifiable;
 using MediatR;
 using OneOf;
-using OneOf.Types;
 
 namespace Digdir.Domain.Dialogporten.Application.Features.V1.ServiceOwner.Dialogs.Commands.Create;
 
-public sealed class CreateDialogCommand : CreateDialogDto, IRequest<CreateDialogResult>;
+public sealed class CreateDialogCommand : IRequest<CreateDialogResult>, IAltinnEventDisabler
+{
+    public bool DisableAltinnEvents { get; init; }
+    public CreateDialogDto Dto { get; set; } = null!;
+}
 
 public sealed record CreateDialogSuccess(Guid DialogId, Guid Revision);
 
@@ -56,7 +60,7 @@ public CreateDialogCommandHandler(
 
     public async Task<CreateDialogResult> Handle(CreateDialogCommand request, CancellationToken cancellationToken)
     {
-        var dialog = _mapper.Map<DialogEntity>(request);
+        var dialog = _mapper.Map<DialogEntity>(request.Dto);
 
         await _serviceResourceAuthorizer.SetResourceType(dialog, cancellationToken);
         var serviceResourceAuthorizationResult = await _serviceResourceAuthorizer.AuthorizeServiceResources(dialog, cancellationToken);
@@ -88,7 +92,7 @@ public async Task<CreateDialogResult> Handle(CreateDialogCommand request, Cancel
         _domainContext.AddErrors(dialog.Transmissions.ValidateReferenceHierarchy(
             keySelector: x => x.Id,
             parentKeySelector: x => x.RelatedTransmissionId,
-            propertyName: nameof(CreateDialogCommand.Transmissions),
+            propertyName: nameof(CreateDialogDto.Transmissions),
             maxDepth: 100,
             maxWidth: 1));
 
@@ -103,7 +107,7 @@ public async Task<CreateDialogResult> Handle(CreateDialogCommand request, Cancel
     private void CreateDialogEndUserContext(CreateDialogCommand request, DialogEntity dialog)
     {
         dialog.DialogEndUserContext = new();
-        if (!request.SystemLabel.HasValue)
+        if (!request.Dto.SystemLabel.HasValue)
         {
             return;
         }
@@ -115,7 +119,7 @@ private void CreateDialogEndUserContext(CreateDialogCommand request, DialogEntit
         }
 
         dialog.DialogEndUserContext.UpdateLabel(
-            request.SystemLabel.Value,
+            request.Dto.SystemLabel.Value,
             $"{NorwegianOrganizationIdentifier.PrefixWithSeparator}{organizationNumber}",
             ActorType.Values.ServiceOwner);
     }

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Commands/Create/CreateDialogCommandValidator.cs

@@ -17,7 +17,17 @@ namespace Digdir.Domain.Dialogporten.Application.Features.V1.ServiceOwner.Dialog
 
 internal sealed class CreateDialogCommandValidator : AbstractValidator<CreateDialogCommand>
 {
-    public CreateDialogCommandValidator(
+    public CreateDialogCommandValidator(IValidator<CreateDialogDto> createDialogDtoValidator)
+    {
+        RuleFor(x => x.Dto)
+            .NotEmpty()
+            .SetValidator(createDialogDtoValidator);
+    }
+}
+
+internal sealed class CreateDialogDtoValidator : AbstractValidator<CreateDialogDto>
+{
+    public CreateDialogDtoValidator(
         IValidator<TransmissionDto> transmissionValidator,
         IValidator<AttachmentDto> attachmentValidator,
         IValidator<GuiActionDto> guiActionValidator,
@@ -35,13 +45,13 @@ public CreateDialogCommandValidator(
 
         RuleFor(x => x.CreatedAt)
             .NotEmpty()
-                .WithMessage($"{{PropertyName}} must not be empty when '{nameof(CreateDialogCommand.UpdatedAt)} is set.")
+                .WithMessage($"{{PropertyName}} must not be empty when '{nameof(CreateDialogDto.UpdatedAt)} is set.")
                 .When(x => x.UpdatedAt != default);
 
         RuleFor(x => x.UpdatedAt)
             .IsInPast()
             .GreaterThanOrEqualTo(x => x.CreatedAt)
-                .WithMessage($"'{{PropertyName}}' must be greater than or equal to '{nameof(CreateDialogCommand.CreatedAt)}'.")
+                .WithMessage($"'{{PropertyName}}' must be greater than or equal to '{nameof(CreateDialogDto.CreatedAt)}'.")
                 .When(x => x.CreatedAt != default && x.UpdatedAt != default);
 
         RuleFor(x => x.ServiceResource)
@@ -136,7 +146,7 @@ public CreateDialogCommandValidator(
 
         RuleFor(x => x.Process)
             .NotEmpty()
-            .WithMessage($"{{PropertyName}} must not be empty when {nameof(CreateDialogCommand.PrecedingProcess)} is set.")
+            .WithMessage($"{{PropertyName}} must not be empty when {nameof(CreateDialogDto.PrecedingProcess)} is set.")
             .When(x => x.PrecedingProcess is not null);
 
         RuleFor(x => x.PrecedingProcess)

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Commands/Create/CreateDialogDto.cs

@@ -11,7 +11,7 @@
 
 namespace Digdir.Domain.Dialogporten.Application.Features.V1.ServiceOwner.Dialogs.Commands.Create;
 
-public class CreateDialogDto
+public sealed class CreateDialogDto
 {
     /// <summary>
     /// A self-defined UUIDv7 may be provided to support idempotent creation of dialogs. If not provided, a new UUIDv7 will be generated.

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Commands/Delete/DeleteDialogCommand.cs

@@ -69,7 +69,7 @@ public async Task<DeleteDialogResult> Handle(DeleteDialogCommand request, Cancel
         _db.Dialogs.SoftRemove(dialog);
         var saveResult = await _unitOfWork
             .EnableConcurrencyCheck(dialog, request.IfMatchDialogRevision)
-            .SaveChangesAsync(cancellationToken);
+            .SaveChangesAsync(cancellationToken: cancellationToken);
 
         return saveResult.Match<DeleteDialogResult>(
             success => new DeleteDialogSuccess(dialog.Revision),

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Commands/Purge/PurgeDialogCommand.cs

@@ -60,7 +60,7 @@ public async Task<PurgeDialogResult> Handle(PurgeDialogCommand request, Cancella
         _db.Dialogs.HardRemove(dialog);
         var saveResult = await _unitOfWork
             .EnableConcurrencyCheck(dialog, request.IfMatchDialogRevision)
-            .SaveChangesAsync(cancellationToken);
+            .SaveChangesAsync(cancellationToken: cancellationToken);
 
         return saveResult.Match<PurgeDialogResult>(
             success => success,

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Commands/Update/UpdateDialogCommand.cs

@@ -1,6 +1,7 @@
 using AutoMapper;
 using Digdir.Domain.Dialogporten.Application.Common;
 using Digdir.Domain.Dialogporten.Application.Common.Authorization;
+using Digdir.Domain.Dialogporten.Application.Common.Behaviours;
 using Digdir.Domain.Dialogporten.Application.Common.Extensions;
 using Digdir.Domain.Dialogporten.Application.Common.Extensions.Enumerables;
 using Digdir.Domain.Dialogporten.Application.Common.ReturnTypes;
@@ -22,11 +23,12 @@
 
 namespace Digdir.Domain.Dialogporten.Application.Features.V1.ServiceOwner.Dialogs.Commands.Update;
 
-public sealed class UpdateDialogCommand : IRequest<UpdateDialogResult>
+public sealed class UpdateDialogCommand : IRequest<UpdateDialogResult>, IAltinnEventDisabler
 {
     public Guid Id { get; set; }
     public Guid? IfMatchDialogRevision { get; set; }
     public UpdateDialogDto Dto { get; set; } = null!;
+    public bool DisableAltinnEvents { get; set; }
 }
 
 [GenerateOneOf]
@@ -163,6 +165,7 @@ public async Task<UpdateDialogResult> Handle(UpdateDialogCommand request, Cancel
         }
 
         UpdateLabel(dialog);
+
         var saveResult = await _unitOfWork
             .EnableConcurrencyCheck(dialog, request.IfMatchDialogRevision)
             .SaveChangesAsync(cancellationToken);

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Queries/Get/GetDialogQuery.cs

@@ -116,7 +116,7 @@ public async Task<GetDialogResult> Handle(GetDialogQuery request, CancellationTo
 
             var saveResult = await _unitOfWork
                 .WithoutAggregateSideEffects()
-                .SaveChangesAsync(cancellationToken);
+                .SaveChangesAsync(cancellationToken: cancellationToken);
 
             saveResult.Switch(
                 success => { },

src/Digdir.Domain.Dialogporten.Domain/Common/DomainEvent.cs → src/Digdir.Domain.Dialogporten.Domain/Common/DomainEvents/DomainEvent.cs

@@ -1,7 +1,8 @@
-using System.Text.Json.Serialization;
+using System.Collections.Frozen;
+using System.Text.Json.Serialization;
 using Digdir.Domain.Dialogporten.Domain.Common.EventPublisher;
 
-namespace Digdir.Domain.Dialogporten.Domain.Common;
+namespace Digdir.Domain.Dialogporten.Domain.Common.DomainEvents;
 
 public abstract record DomainEvent : IDomainEvent
 {
@@ -10,4 +11,7 @@ public abstract record DomainEvent : IDomainEvent
 
     [JsonInclude]
     public DateTimeOffset OccuredAt { get; set; }
+
+    [JsonInclude]
+    public FrozenDictionary<string, string> Metadata { get; set; } = FrozenDictionary<string, string>.Empty;
 }

src/Digdir.Domain.Dialogporten.Domain/Common/DomainEvents/DomainEventContext.cs

@@ -0,0 +1,13 @@
+using System.Collections.Frozen;
+
+namespace Digdir.Domain.Dialogporten.Domain.Common.DomainEvents;
+
+public sealed class DomainEventContext : IDomainEventContext
+{
+    private readonly Dictionary<string, string> _metadata = new();
+
+    public FrozenDictionary<string, string> GetMetadata() => _metadata.ToFrozenDictionary();
+
+    public void AddMetadata(string key, string value) => _metadata[key] = value;
+
+}

src/Digdir.Domain.Dialogporten.Domain/Common/DomainEvents/IDomainEventContext.cs

@@ -0,0 +1,9 @@
+using System.Collections.Frozen;
+
+namespace Digdir.Domain.Dialogporten.Domain.Common.DomainEvents;
+
+public interface IDomainEventContext
+{
+    FrozenDictionary<string, string> GetMetadata();
+    void AddMetadata(string key, string value);
+}

src/Digdir.Domain.Dialogporten.Domain/Common/EventPublisher/IDomainEvent.cs

@@ -1,3 +1,4 @@
+using System.Collections.Frozen;
 using MediatR;
 
 namespace Digdir.Domain.Dialogporten.Domain.Common.EventPublisher;
@@ -16,4 +17,9 @@ public interface IDomainEvent : INotification
     /// The time in which the event, as well as all the actual changes occured.
     /// </summary>
     DateTimeOffset OccuredAt { get; set; }
+
+    /// <summary>
+    /// Read-only dictionary of metadata.
+    /// </summary>
+    public FrozenDictionary<string, string> Metadata { get; set; }
 }

src/Digdir.Domain.Dialogporten.Domain/Dialogs/Entities/Activities/DialogActivity.cs

@@ -31,7 +31,7 @@ public sealed class DialogActivity : IImmutableEntity, IAggregateCreatedHandler,
     [AggregateChild]
     public DialogActivityPerformedByActor PerformedBy { get; set; } = null!;
 
-    public void OnCreate(AggregateNode self, DateTimeOffset utcNow)
+    public void OnCreate(AggregateNode self, DateTimeOffset utcNow, bool disableEvents = false)
     {
         _domainEvents.Add(new DialogActivityCreatedDomainEvent(
             DialogId, Id, TypeId, Dialog.Party,