Added GetStatus-method to ExistingEffects

stidsborg · Aug 10, 2024 · 9f3a45f · 9f3a45f
1 parent a5f90ef
commit 9f3a45f
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/RFunctionTests/ControlPanelTests.cs b/Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/RFunctionTests/ControlPanelTests.cs
@@ -1359,6 +1359,7 @@ protected async Task EffectsAreUpdatedAfterRefresh(Task<IFunctionStore> storeTas
 
         await secondControlPanel.Refresh();
         await secondControlPanel.Effects.GetValue<string>("Id").ShouldBeAsync("SomeResult");
+        await secondControlPanel.Effects.GetStatus("Id").ShouldBeAsync(WorkStatus.Completed);
 
         unhandledExceptionCatcher.ShouldNotHaveExceptions();
     }

diff --git a/Core/Cleipnir.ResilientFunctions/Domain/ExistingEffects.cs b/Core/Cleipnir.ResilientFunctions/Domain/ExistingEffects.cs
@@ -36,7 +36,13 @@ public Task<IEnumerable<EffectId>> AllIds
         return storedEffect.Result == null 
             ? default 
             : serializer.DeserializeEffectResult<TResult>(storedEffects[effectId].Result!);
-    } 
+    }
+
+    public async Task<WorkStatus> GetStatus(EffectId effectId)
+    {
+        var storedEffects = await GetStoredEffects();
+        return storedEffects[effectId].WorkStatus;
+    }
 
     public async Task Remove(string effectId)
     {