Add test for ResetInterrupted method

Author: stidsborg

Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/StoreTests.cs

@@ -98,6 +98,10 @@ public override Task RestartingExecutionShouldFailWhenExpectedEpochDoesNotMatch(
     public override Task RestartingFunctionShouldSetInterruptedToFalse()
         => RestartingFunctionShouldSetInterruptedToFalse(FunctionStoreFactory.Create());
 
+    [TestMethod]
+    public override Task ResetInterruptedClearsInterruptedFlag()
+        => ResetInterruptedClearsInterruptedFlag(FunctionStoreFactory.Create());
+
     [TestMethod]
     public override Task MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated()
         => MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated(FunctionStoreFactory.Create());

Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/StoreTests.cs

@@ -698,7 +698,49 @@ await store.RestartExecution(
 
         (await store.GetInterruptedFunctions()).Any(id => id == functionId).ShouldBeFalse();
     }
-    
+
+    public abstract Task ResetInterruptedClearsInterruptedFlag();
+    protected async Task ResetInterruptedClearsInterruptedFlag(Task<IFunctionStore> storeTask)
+    {
+        var store = await storeTask;
+        var functionId1 = TestStoredId.Create();
+        var functionId2 = StoredId.Create(functionId1.Type, Guid.NewGuid().ToString());
+
+        await store.CreateFunction(
+            functionId1,
+            "humanInstanceId1",
+            param: Test.SimpleStoredParameter,
+            leaseExpiration: DateTime.UtcNow.Ticks,
+            postponeUntil: null,
+            timestamp: DateTime.UtcNow.Ticks,
+            parent: null,
+            owner: null
+        );
+
+        await store.CreateFunction(
+            functionId2,
+            "humanInstanceId2",
+            param: Test.SimpleStoredParameter,
+            leaseExpiration: DateTime.UtcNow.Ticks,
+            postponeUntil: null,
+            timestamp: DateTime.UtcNow.Ticks,
+            parent: null,
+            owner: null
+        );
+
+        await store.Interrupt(functionId1).ShouldBeTrueAsync();
+        await store.Interrupt(functionId2).ShouldBeTrueAsync();
+
+        (await store.GetInterruptedFunctions()).Count.ShouldBe(2);
+
+        await store.ResetInterrupted([functionId1]);
+
+        var interrupted = await store.GetInterruptedFunctions();
+        interrupted.Count.ShouldBe(1);
+        interrupted.Any(id => id == functionId2).ShouldBeTrue();
+        interrupted.Any(id => id == functionId1).ShouldBeFalse();
+    }
+
     public abstract Task MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated();
     public async Task MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated(Task<IFunctionStore> storeTask)
     {

Stores/MariaDB/Cleipnir.ResilientFunctions.MariaDB.Tests/StoreTests.cs

@@ -87,6 +87,10 @@ public override Task RestartingExecutionShouldFailWhenExpectedEpochDoesNotMatch(
     public override Task RestartingFunctionShouldSetInterruptedToFalse()
         => RestartingFunctionShouldSetInterruptedToFalse(FunctionStoreFactory.Create());
 
+    [TestMethod]
+    public override Task ResetInterruptedClearsInterruptedFlag()
+        => ResetInterruptedClearsInterruptedFlag(FunctionStoreFactory.Create());
+
     [TestMethod]
     public override Task MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated()
         => MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated(FunctionStoreFactory.Create());

Stores/PostgreSQL/Cleipnir.ResilientFunctions.PostgreSQL.Tests/StoreTests.cs

@@ -90,6 +90,10 @@ public override Task RestartingExecutionShouldFailWhenExpectedEpochDoesNotMatch(
     public override Task RestartingFunctionShouldSetInterruptedToFalse()
         => RestartingFunctionShouldSetInterruptedToFalse(FunctionStoreFactory.Create());
 
+    [TestMethod]
+    public override Task ResetInterruptedClearsInterruptedFlag()
+        => ResetInterruptedClearsInterruptedFlag(FunctionStoreFactory.Create());
+
     [TestMethod]
     public override Task MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated()
         => MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated(FunctionStoreFactory.Create());

Stores/SqlServer/Cleipnir.ResilientFunctions.SqlServer.Tests/StoreTests.cs

@@ -90,6 +90,10 @@ public override Task RestartingExecutionShouldFailWhenExpectedEpochDoesNotMatch(
     public override Task RestartingFunctionShouldSetInterruptedToFalse()
         => RestartingFunctionShouldSetInterruptedToFalse(FunctionStoreFactory.Create());
 
+    [TestMethod]
+    public override Task ResetInterruptedClearsInterruptedFlag()
+        => ResetInterruptedClearsInterruptedFlag(FunctionStoreFactory.Create());
+
     [TestMethod]
     public override Task MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated()
         => MessagesCanBeFetchedAfterFunctionWithInitialMessagesHasBeenCreated(FunctionStoreFactory.Create());