问题描述
我正在尝试为我的状态机创建单元测试,以检查每个状态是否都在做它应该做的事情。
通过发布启动状态机的事件并创建达到所需状态所需的所有变量,我可以使状态机进入任何状态。
简化状态机:
dec=dec+(bin[i]-'0')*k ;
我编写了一些单元测试,我可以启动机器(遵循 Masstransit 文档中的 this guide),但我想检查状态是否 CheckingForFiles 和 ValidatingFiles 正在做他们应该独立做的事情。
到目前为止,我可以通过遵循状态机的流程模拟 IDataService 方法以达到所需的状态,但是有没有办法启动状态机并跳转到特定状态?
更新
假设我在那里有另一个状态:
public class CheckFilesstateMachine : MasstransitStateMachine<DataState>,ICheckFilesstateMachine
{
#region Events
public Event<IEventCheckFile> CheckFile { get; private set; }
#endregion
#region States
public State CheckingForFiles { get; }
public State ValidatingFiles { get; }
public State NoFilesFound { get; }
public State Validated { get; }
public State FilesProcessed { get; }
public State ValidationFailed{ get; }
#endregion
public DataStateMachine(IDataService dataService)
{
InstanceState(x => x.CurrentState);
Event(() => CheckFile,x => x.CorrelateById(context => context.Message.Id));
Initially(When(CheckFile).TransitionTo(CheckingForFiles));
WhenEnter(CheckingForFiles,binder => binder
.Then(x => x.Instance.Files= dataService.GetFiles())
.IfElse(x => dataService.HasFiles(),x => x.TransitionTo(ValidatingFiles),x => x.TransitionTo(NoFilesFound))
.Catch<Exception>(ex => ex
.Then(x => Console.WriteLine(x.Exception.Message))));
WhenEnter(ValidatingFiles,binder => binder
.IfElse(x => dataService.ValidateFiles(),x => x.TransitionTo(Validated),x => x.TransitionTo(ValidationFailed))
.Catch<Exception>(ex => ex
.Then(x => Console.WriteLine(x.Exception.Message))));
WhenEnter(NoFilesFound,binder => binder.Then(x => Console.WriteLine("No Files found")).Finalize());
WhenEnter(Validated,binder => binder.Then(x => Console.WriteLine("Validated")).Finalize());
WhenEnter(ValidationFailed,binder => binder.Then(x => Console.WriteLine("Validation Failed")).Finalize());
SetCompletedWhenFinalized();
}
}
在这种情况下,我可以输入CheckingForFiles然后跳转到DeletingFiles吗?可能吗?
解决方法
如果您使用的是基于容器的内存中测试工具,您可以从容器解析 saga 字典并添加一个实例:
var dictionary = provider.GetRequiredService<IndexedSagaDictionary<DataState>>();
dictionary.Add(new SagaInstance<DataState>(new DataState()
{
CorrelationId = dataId,CurrentState = "CheckingForFiles"
}));