feat: Add idempotentId

docs/schema/V1/schema.verified.graphql

@@ -458,4 +458,4 @@ scalar DateTime @specifiedBy(url: "https:\/\/www.graphql-scalars.com\/date-time"
 
 scalar URL @specifiedBy(url: "https:\/\/tools.ietf.org\/html\/rfc3986")
 
-scalar UUID @specifiedBy(url: "https:\/\/tools.ietf.org\/html\/rfc4122")
+scalar UUID @specifiedBy(url: "https:\/\/tools.ietf.org\/html\/rfc4122")

docs/schema/V1/swagger.verified.json

@@ -2352,6 +2352,11 @@
             "nullable": true,
             "type": "string"
           },
+          "idempotentKey": {
+            "description": "A self-defined Id may be provided to support idempotent creation of dialogs.",
+            "nullable": true,
+            "type": "string"
+          },
           "party": {
             "description": "The party code representing the organization or person that the dialog belongs to in URN format.",
             "example": "urn:altinn:person:identifier-no:01125512345\nurn:altinn:organization:identifier-no:912345678",
@@ -3451,6 +3456,11 @@
             "format": "guid",
             "type": "string"
           },
+          "idempotentKey": {
+            "description": "A self-defined Id may be provided to support idempotent creation of dialogs.\n            ",
+            "nullable": true,
+            "type": "string"
+          },
           "org": {
             "description": "The service owner code representing the organization (service owner) related to this dialog.",
             "example": "ske",
@@ -4102,6 +4112,11 @@
             "format": "guid",
             "type": "string"
           },
+          "idempotentKey": {
+            "description": "A self-defined Id may be provided to support idempotent creation of dialogs.\n            ",
+            "nullable": true,
+            "type": "string"
+          },
           "latestActivity": {
             "description": "The latest entry in the dialog\u0027s activity log.",
             "nullable": true,
@@ -5614,6 +5629,15 @@
         "description": "Performs a search for dialogs, returning a paginated list of dialogs. For more information see the documentation (link TBD).\n\n* All date parameters must contain explicit time zone. Example: 2023-10-27T10:00:00Z or 2023-10-27T10:00:00\u002B01:00\n* See \u0022continuationToken\u0022 in the response for how to get the next page of results.\n* hasNextPage will be set to true if there are more items to get.",
         "operationId": "V1ServiceOwnerDialogsSearch_SearchDialog",
         "parameters": [
+          {
+            "description": "Filter by IdempotentKey ",
+            "in": "query",
+            "name": "idempotentKey",
+            "schema": {
+              "nullable": true,
+              "type": "string"
+            }
+          },
           {
             "description": "Filter by one or more service resources",
             "explode": true,
@@ -5924,6 +5948,9 @@
           "403": {
             "description": "Unauthorized to create a dialog for the given serviceResource (not owned by authenticated organization or has additional scope requirements defined in policy)."
           },
+          "409": {
+            "description": "Dialog with IdempotentKey 01941821-ffca-73a1-9335-435a882be014 has already been created."
+          },
           "422": {
             "content": {
               "application/problem\u002Bjson": {

src/Digdir.Domain.Dialogporten.Application/Common/ReturnTypes/Conflict.cs

@@ -0,0 +1,13 @@
+using FluentValidation.Results;
+
+namespace Digdir.Domain.Dialogporten.Application.Common.ReturnTypes;
+
+public sealed record Conflict(IEnumerable<ConflictError> Conflicts)
+{
+    public Conflict(ConflictError error) : this([error]) { }
+    public List<ValidationFailure> ToValidationResults() => Conflicts
+        .Select(x => new ValidationFailure(x.PropertyName, x.ErrorMessage))
+        .ToList();
+}
+
+public sealed record ConflictError(string PropertyName, string ErrorMessage);

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

@@ -45,6 +45,7 @@ public interface IDialogDbContext
     DbSet<LabelAssignmentLog> LabelAssignmentLogs { get; }
     DbSet<ResourcePolicyInformation> ResourcePolicyInformation { get; }
 
+
     /// <summary>
     /// Validate a property on the <typeparamref name="TEntity"/> using a lambda
     /// expression to specify the predicate only when the property is modified.

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

@@ -16,6 +16,8 @@
 using Digdir.Domain.Dialogporten.Domain.Parties;
 using Digdir.Library.Entity.Abstractions.Features.Identifiable;
 using MediatR;
+using Microsoft.EntityFrameworkCore;
+using Npgsql;
 using OneOf;
 
 namespace Digdir.Domain.Dialogporten.Application.Features.V1.ServiceOwner.Dialogs.Commands.Create;
@@ -29,7 +31,7 @@ public sealed class CreateDialogCommand : IRequest<CreateDialogResult>, IAltinnE
 public sealed record CreateDialogSuccess(Guid DialogId, Guid Revision);
 
 [GenerateOneOf]
-public sealed partial class CreateDialogResult : OneOfBase<CreateDialogSuccess, DomainError, ValidationError, Forbidden>;
+public sealed partial class CreateDialogResult : OneOfBase<CreateDialogSuccess, DomainError, ValidationError, Forbidden, Conflict>;
 
 internal sealed class CreateDialogCommandHandler : IRequestHandler<CreateDialogCommand, CreateDialogResult>
 {
@@ -81,6 +83,7 @@ public async Task<CreateDialogResult> Handle(CreateDialogCommand request, Cancel
             dialog.Org = serviceResourceInformation.OwnOrgShortName;
         }
 
+
         CreateDialogEndUserContext(request, dialog);
         await EnsureNoExistingUserDefinedIds(dialog, cancellationToken);
 
@@ -98,7 +101,27 @@ public async Task<CreateDialogResult> Handle(CreateDialogCommand request, Cancel
             maxWidth: 1));
 
         await _db.Dialogs.AddAsync(dialog, cancellationToken);
-        var saveResult = await _unitOfWork.SaveChangesAsync(cancellationToken);
+
+        SaveChangesResult saveResult;
+        try
+        {
+            saveResult = await _unitOfWork.SaveChangesAsync(cancellationToken);
+        }
+        catch (DbUpdateException e)
+            when (e.InnerException is PostgresException
+            {
+                SqlState: "23505", // unique violation
+                ConstraintName: "IX_Dialog_Org_IdempotentKey"
+            })
+        {
+            var dialogId = await _db.Dialogs
+                .Where(x => x.IdempotentKey == request.Dto.IdempotentKey && x.Org == dialog.Org)
+                .Select(x => x.Id)
+                .FirstOrDefaultAsync(cancellationToken);
+
+            return new Conflict(new ConflictError(nameof(request.Dto.IdempotentKey), $"'{request.Dto.IdempotentKey}' already exists with DialogId '{dialogId}'"));
+        }
+
         return saveResult.Match<CreateDialogResult>(
             success => new CreateDialogSuccess(dialog.Id, dialog.Revision),
             domainError => domainError,

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

@@ -54,6 +54,9 @@ public CreateDialogDtoValidator(
                 .WithMessage($"'{{PropertyName}}' must be greater than or equal to '{nameof(CreateDialogDto.CreatedAt)}'.")
                 .When(x => x.CreatedAt != default && x.UpdatedAt != default);
 
+        RuleFor(x => x.IdempotentKey)
+            .MaximumLength(36);
+
         RuleFor(x => x.ServiceResource)
             .NotNull()
             .IsValidUri()

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

@@ -19,6 +19,11 @@ public sealed class CreateDialogDto
     /// <example>01913cd5-784f-7d3b-abef-4c77b1f0972d</example>
     public Guid? Id { get; set; }
 
+    /// <summary>
+    /// A self-defined Id may be provided to support idempotent creation of dialogs.
+    /// </summary>
+    public string? IdempotentKey { get; set; }
+
     /// <summary>
     /// The service identifier for the service that the dialog is related to in URN-format.
     /// This corresponds to a resource in the Altinn Resource Registry, which the authenticated organization

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

@@ -58,7 +58,6 @@ public async Task<PurgeDialogResult> Handle(PurgeDialogCommand request, Cancella
         {
             return new Forbidden($"User cannot modify resource type {dialog.ServiceResourceType}.");
         }
-
         _db.Dialogs.HardRemove(dialog);
         var saveResult = await _unitOfWork
             .EnableConcurrencyCheck(dialog, request.IfMatchDialogRevision)

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

@@ -1,4 +1,5 @@
-using AutoMapper;
+using System.Diagnostics;
+using AutoMapper;
 using Digdir.Domain.Dialogporten.Application.Common;
 using Digdir.Domain.Dialogporten.Application.Common.Authorization;
 using Digdir.Domain.Dialogporten.Application.Common.Behaviours;

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

@@ -19,6 +19,11 @@ public sealed class DialogDto
     /// <example>01913cd5-784f-7d3b-abef-4c77b1f0972d</example>
     public Guid Id { get; set; }
 
+    /// <summary>
+    ///  A self-defined Id may be provided to support idempotent creation of dialogs.
+    /// </summary>
+    public string? IdempotentKey { get; set; }
+
     /// <summary>
     /// The unique identifier for the revision in UUIDv4 format.
     /// </summary>
@@ -270,7 +275,6 @@ public sealed class DialogSeenLogDto
     public bool IsCurrentEndUser { get; set; }
 }
 
-
 public sealed class ContentDto
 {
     /// <summary>
@@ -372,7 +376,6 @@ public sealed class DialogActivityDto
     public List<LocalizationDto> Description { get; set; } = [];
 }
 
-
 public sealed class DialogApiActionDto
 {
     /// <summary>

src/Digdir.Domain.Dialogporten.Application/Features/V1/ServiceOwner/Dialogs/Queries/Search/DialogDtoBase.cs

@@ -14,6 +14,11 @@ public class DialogDtoBase
     /// <example>01913cd5-784f-7d3b-abef-4c77b1f0972d</example>
     public Guid Id { get; set; }
 
+    /// <summary>
+    ///  A self-defined Id may be provided to support idempotent creation of dialogs.
+    /// </summary>
+    public string? IdempotentKey { get; set; }
+
     /// <summary>
     /// The service owner code representing the organization (service owner) related to this dialog.
     /// </summary>
@@ -158,7 +163,6 @@ public sealed class DialogSeenLogDto
     public bool IsCurrentEndUser { get; set; }
 }
 
-
 public sealed class DialogActivityDto
 {
     /// <summary>
@@ -198,4 +202,3 @@ public sealed class DialogActivityDto
     /// </summary>
     public List<LocalizationDto> Description { get; set; } = [];
 }
-

src/Digdir.Domain.Dialogporten.Domain/Dialogs/Entities/DialogEntity.cs

@@ -23,6 +23,7 @@ public sealed class DialogEntity :
 {
     public Guid Id { get; set; }
     public Guid Revision { get; set; }
+    public string? IdempotentKey { get; set; }
     public DateTimeOffset CreatedAt { get; set; }
     public DateTimeOffset UpdatedAt { get; set; }
     public bool Deleted { get; set; }

src/Digdir.Domain.Dialogporten.Infrastructure/Persistence/Configurations/Dialogs/DialogEntityConfiguration.cs

@@ -22,5 +22,7 @@ public void Configure(EntityTypeBuilder<DialogEntity> builder)
         builder.HasIndex(x => x.ServiceResource);
         builder.HasIndex(x => x.Party);
         builder.HasIndex(x => x.Process);
+        builder.Property(x => x.IdempotentKey).HasMaxLength(36);
+        builder.HasIndex(x => new { x.Org, x.IdempotentKey }).IsUnique().HasFilter($"\"{nameof(DialogEntity.IdempotentKey)}\" is not null");
     }
 }

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

@@ -110,6 +110,7 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
         // Explicitly configure the Actor entity so that it will register as TPH in the database
         modelBuilder.Entity<Actor>();
 
+
         modelBuilder
             .RemovePluralizingTableNameConvention()
             .AddAuditableEntities()