Added inner exception to ConcurrentModificationException thrown by Az…

…ureBlobEventStore
stidsborg · Nov 15, 2023 · e85c000 · e85c000
1 parent 7f0407e
commit e85c000
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/Core/Cleipnir.ResilientFunctions/Domain/Exceptions/ConcurrentModificationException.cs b/Core/Cleipnir.ResilientFunctions/Domain/Exceptions/ConcurrentModificationException.cs
@@ -1,4 +1,6 @@
-namespace Cleipnir.ResilientFunctions.Domain.Exceptions;
+using System;
+
+namespace Cleipnir.ResilientFunctions.Domain.Exceptions;
 
 public sealed class ConcurrentModificationException : RFunctionException
 {
@@ -9,4 +11,11 @@ public ConcurrentModificationException(FunctionId functionId)
             functionId.TypeId,
             $"Unable to persist state for '{functionId}' due to concurrent modification"
         ) => FunctionId = functionId;
+
+    public ConcurrentModificationException(FunctionId functionId, Exception innerException)
+        : base(
+            functionId.TypeId,
+            $"Unable to persist state for '{functionId}' due to concurrent modification",
+            innerException
+        ) => FunctionId = functionId;
 }
diff --git a/Stores/AzureBlob/Cleipnir.ResilientFunctions.AzureBlob/AzureBlobEventStore.cs b/Stores/AzureBlob/Cleipnir.ResilientFunctions.AzureBlob/AzureBlobEventStore.cs
@@ -261,14 +261,14 @@ private async Task<FunctionStatus> AppendOrCreate(FunctionId functionId, string
             }
             catch (RequestFailedException exception)
             {
-                if (exception.Status == 404) throw new ConcurrentModificationException(functionId);
+                if (exception.Status == 404) throw new ConcurrentModificationException(functionId, exception);
                 throw;
             }
         }
         catch (RequestFailedException e)
         {
             if (e.ErrorCode != "BlobNotFound") throw;
-            throw new ConcurrentModificationException(functionId);
+            throw new ConcurrentModificationException(functionId, e);
         }
     }