Merge branch 'master' of http://git.dd:3000/AppStd/ReC

Updated <Version>, <AssemblyVersion>, <FileVersion>, and <InformationalVersion> fields in the project file from 1.0.2-beta to 1.0.3-beta. No other changes were made.

src/ReC.API/ReC.API.csproj

@@ -10,10 +10,10 @@
 	<Product>ReC.API</Product>
 	<PackageIcon>Assets\icon.ico</PackageIcon>
 	<PackageTags>digital data rest-caller rec api</PackageTags>
-	<Version>1.0.2-beta</Version>
-	<AssemblyVersion>1.0.2.0</AssemblyVersion>
-	<FileVersion>1.0.2.0</FileVersion>
-    <InformationalVersion>1.0.0-beta</InformationalVersion>
+	<Version>1.0.3-beta</Version>
+	<AssemblyVersion>1.0.3.0</AssemblyVersion>
+	<FileVersion>1.0.3.0</FileVersion>
+	<InformationalVersion>1.0.3-beta</InformationalVersion>
 	<Copyright>Copyright © 2025 Digital Data GmbH. All rights reserved.</Copyright>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <NoWarn>$(NoWarn);1591</NoWarn>

src/ReC.Application/Common/Dto/RecActionDto.cs

@@ -62,6 +62,8 @@ public record RecActionDto
 
     public string? PostprocessingQuery { get; init; }
 
+    public string? ErrorAction { get; init; }
+
     public UriBuilder ToEndpointUriBuilder()
     {
         var builder = EndpointUri is null ? new UriBuilder() : new UriBuilder(EndpointUri);

src/ReC.Application/OutResults/Commands/CreateOutResCommand.cs

@@ -8,6 +8,10 @@ public class CreateOutResCommand : IRequest
 {
     public required long ActionId { get; set; }
 
+    public short? Status { get; set; }
+
+    public string? Message { get; set; }
+
     public string? Header { get; set; }
 
     public string? Body { get; set; }

src/ReC.Application/RecActions/Commands/InvokeBatchRecActionsCommand.cs

@@ -18,6 +18,16 @@ public class InvokeRecActionsCommandHandler(ISender sender) : IRequestHandler<In
         var actions = await sender.Send(request.ToReadQuery(q => q.Invoked = false), cancel);
 
         foreach (var action in actions)
-            await sender.Send(action.ToInvokeCommand(), cancel);
+        {
+            var ok = await sender.Send(action.ToInvokeCommand(), cancel);
+            if (!ok)
+                switch (action.ErrorAction?.ToLowerInvariant())
+                {
+                    case "continue":
+                        break;
+                    default:
+                        return;
+                }
+        }
     }
 }

src/ReC.Application/RecActions/Commands/InvokeRecActionCommand.cs

@@ -8,7 +8,7 @@ using System.Text.Json;
 
 namespace ReC.Application.RecActions.Commands;
 
-public record InvokeRecActionCommand : IRequest
+public record InvokeRecActionCommand : IRequest<bool>
 {
     public RecActionDto Action { get; set; } = null!;
 }
@@ -22,9 +22,9 @@ public class InvokeRecActionCommandHandler(
     ISender sender,
     IHttpClientFactory clientFactory,
     IConfiguration? config = null
-    ) : IRequestHandler<InvokeRecActionCommand>
+    ) : IRequestHandler<InvokeRecActionCommand, bool>
 {
-    public async Task Handle(InvokeRecActionCommand request, CancellationToken cancel)
+    public async Task<bool> Handle(InvokeRecActionCommand request, CancellationToken cancel)
     {
         var action = request.Action;
         using var http = clientFactory.CreateClient();
@@ -54,12 +54,17 @@ public class InvokeRecActionCommandHandler(
         var resBody = await response.Content.ReadAsStringAsync(cancel);
         var resHeaders = response.Headers.ToDictionary();
 
+        var statusCode = (short)response.StatusCode;
+
         await sender.Send(new CreateOutResCommand
         {
+            Status = statusCode,
             ActionId = action.Id,
             Header = JsonSerializer.Serialize(resHeaders, options: new() { WriteIndented = false }),
             Body = resBody,
             AddedWho = config?["AddedWho"]
         }, cancel);
+
+        return response.IsSuccessStatusCode;
     }
 }

src/ReC.Domain/Entities/OutRes.cs

@@ -8,6 +8,10 @@ public class OutRes
 
     public RecAction? Action { get; set; }
 
+    public short? Status { get; set; }
+
+    public string? Message { get; set; }
+
     public string? Header { get; set; }
 
     public string? Body { get; set; }

src/ReC.Domain/Entities/RecAction.cs

@@ -36,6 +36,8 @@ public class RecAction
 
     public string? PostprocessingQuery { get; set; }
 
+    public string? ErrorAction { get; set; }
+
     public string? AddedWho { get; set; }
 
     public DateTime? AddedWhen { get; set; }

src/ReC.Infrastructure/RecDbContext.cs

@@ -131,6 +131,8 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
                 .ValueGeneratedOnAdd();
 
             b.Property(e => e.ActionId).HasColumnName("ACTION_ID");
+            b.Property(e => e.Status).HasColumnName("STATUS");
+            b.Property(e => e.Message).HasColumnName("MESSAGE");
             b.Property(e => e.Header).HasColumnName("RESULT_HEADER");
             b.Property(e => e.Body).HasColumnName("RESULT_BODY");
             b.Property(e => e.AddedWho).HasColumnName("ADDED_WHO");
@@ -181,6 +183,7 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
             b.Property(e => e.HeaderQuery).HasColumnName("HEADER_QUERY");
             b.Property(e => e.BodyQuery).HasColumnName("BODY_QUERY");
             b.Property(e => e.PostprocessingQuery).HasColumnName("POSTPROCESSING_QUERY");
+            b.Property(e => e.ErrorAction).HasColumnName("ERROR_ACTION");
             b.Property(e => e.AddedWho).HasColumnName("ADDED_WHO");
             b.Property(e => e.AddedWhen).HasColumnName("ADDED_WHEN");
             b.Property(e => e.ChangedWho).HasColumnName("CHANGED_WHO");