Cleipnir.ResilientFunctions/Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/RFunctionTests/SuspensionTests.cs at a108d84f61f0b0044a1981329562ff739accb3e7 · stidsborg/Cleipnir.ResilientFunctions · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
using System.Threading.Tasks;
using Microsoft.VisualStudio.TestTools.UnitTesting;

namespace Cleipnir.ResilientFunctions.Tests.InMemoryTests.RFunctionTests;

[TestClass]
public class SuspensionTests : TestTemplates.FunctionTests.SuspensionTests
{
    [TestMethod]
    public override Task ActionCanBeSuspended()
        => ActionCanBeSuspended(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task FunctionCanBeSuspended()
        => FunctionCanBeSuspended(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task DetectionOfEligibleSuspendedFunctionSucceedsAfterEventAdded()
        => DetectionOfEligibleSuspendedFunctionSucceedsAfterEventAdded(
            FunctionStoreFactory.Create()
        );

    [TestMethod]
    public override Task PostponedFunctionIsResumedAfterEventIsAppendedToMessages()
        => PostponedFunctionIsResumedAfterEventIsAppendedToMessages(
            FunctionStoreFactory.Create()
        );

    [TestMethod]
    public override Task EligibleSuspendedFunctionIsPickedUpByWatchdog()
        => EligibleSuspendedFunctionIsPickedUpByWatchdog(
            FunctionStoreFactory.Create()
        );

    [TestMethod]
    public override Task SuspendedFunctionIsAutomaticallyReInvokedWhenEligibleAndWriteHasTrueBoolFlag()
        => SuspendedFunctionIsAutomaticallyReInvokedWhenEligibleAndWriteHasTrueBoolFlag(
            FunctionStoreFactory.Create()
        );

    [TestMethod]
    public override Task SuspendedFunctionIsAutomaticallyReInvokedWhenEligibleByWatchdog()
        => SuspendedFunctionIsAutomaticallyReInvokedWhenEligibleByWatchdog(
            FunctionStoreFactory.Create()
        );

    [TestMethod]
    public override Task ParamlessFunctionWithPrefilledMessageCompletes()
        => ParamlessFunctionWithPrefilledMessageCompletes(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task StartedParentCanWaitForChildActionCompletion()
        => StartedParentCanWaitForChildActionCompletion(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task ChildCanReturnResultToParent()
        => ChildCanReturnResultToParent(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task ParentCanWaitForChildAction()
        => ParentCanWaitForChildAction(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task ParentCanWaitForFailedChildAction()
        => ParentCanWaitForFailedChildAction(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task PublishFromChildActionStressTest()
        => PublishFromChildActionStressTest(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task ParentCanWaitForBulkScheduledChildren()
        => ParentCanWaitForBulkScheduledChildren(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task ChildIsCreatedWithParentsId()
        => ChildIsCreatedWithParentsId(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task DelayedFlowIsRestartedOnce()
        => DelayedFlowIsRestartedOnce(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task TwoDelaysFlowCompletesSuccessfully()
        => TwoDelaysFlowCompletesSuccessfully(FunctionStoreFactory.Create());

    [TestMethod]
    public override Task NonSuspendingDelayCompletesViaFlowsManagerSignal()
        => NonSuspendingDelayCompletesViaFlowsManagerSignal(FunctionStoreFactory.Create());
}