Handle Missing external reference in manual publish (#1900)

Author: axely123

src/Altinn.Correspondence.Application/ManualRetryNotPublishedCorrespondences/ManualRetryNotPublishedCorrespondencesHandler.cs

@@ -1,13 +1,17 @@
 using OneOf;
 using System.Security.Claims;
+using Altinn.Correspondence.Application.InitializeCorrespondences;
 using Altinn.Correspondence.Application.PublishCorrespondence;
+using Altinn.Correspondence.Core.Models.Enums;
+using Altinn.Correspondence.Core.Repositories;
 using Hangfire;
 using Microsoft.Extensions.Logging;
 
 namespace Altinn.Correspondence.Application.ManualRetryNotPublishedCorrespondences;
 
 public class ManualRetryNotPublishedCorrespondencesHandler(
     IBackgroundJobClient backgroundJobClient,
+    ICorrespondenceRepository correspondenceRepository,
     ILogger<ManualRetryNotPublishedCorrespondencesHandler> logger) : IHandler<ManualRetryNotPublishedCorrespondencesRequest, ManualRetryNotPublishedCorrespondencesResponse>
 
 {
@@ -17,8 +21,29 @@ public async Task<OneOf<ManualRetryNotPublishedCorrespondencesResponse, Error>>
         foreach (var correspondenceId in request.CorrespondenceIds)
         {
             logger.LogInformation("Retrying publish for correspondence {CorrespondenceId}", correspondenceId);
-            var jobId = backgroundJobClient.Enqueue<PublishCorrespondenceHandler>(handler => handler.Process(correspondenceId, null, CancellationToken.None));
-            response.RetriedCorrespondenceIds[correspondenceId] = $"Enqueued (jobId: {jobId})";
+
+            var correspondence = await correspondenceRepository.GetCorrespondenceById(correspondenceId, false, false, false, cancellationToken);
+            if (correspondence is null)
+            {
+                response.RetriedCorrespondenceIds[correspondenceId] = "Not found";
+                continue;
+            }
+
+            var hasDialogportenReference = correspondence.ExternalReferences
+                .Any(r => r.ReferenceType == ReferenceType.DialogportenDialogId);
+
+            string jobId;
+            if (!hasDialogportenReference)
+            {
+                var dialogJobId = backgroundJobClient.Enqueue<InitializeCorrespondencesHandler>(h => h.CreateDialogportenDialog(correspondenceId));
+                jobId = backgroundJobClient.ContinueJobWith<PublishCorrespondenceHandler>(dialogJobId, handler => handler.Process(correspondenceId, null, CancellationToken.None));
+                response.RetriedCorrespondenceIds[correspondenceId] = $"Enqueued create dialog then publish (jobId: {jobId})";
+            }
+            else
+            {
+                jobId = backgroundJobClient.Enqueue<PublishCorrespondenceHandler>(handler => handler.Process(correspondenceId, null, CancellationToken.None));
+                response.RetriedCorrespondenceIds[correspondenceId] = $"Enqueued (jobId: {jobId})";
+            }
         }
         return response;
     }