How do you jump to any step?

[Hiprox]

The problem is that there are steps where you can't get an object from the database because it may not already exist and this logic is repeated in different steps.

The solutions I see are:

• Make typed exceptions so that you can distinguish them in OnStepError and call host.TerminateWorkflow(workflowId);
• Create a step, for example RecordNotFoundStep and use it after each it is required. But this is not convenient, as another developer needs to understand where this step is required, and the workflow configuration will look like something messy.

Ideal solution: have it possible to call a step that will execute and the workflow will finish.

public class RequestBuffersStep(
    ISender mediator,
    IMarkingDbContext dbContext,
    ILogger? logger = default) : StepBodyAsync
{
    public int OrganizationId { get; set; }

    public override async Task<ExecutionResult> RunAsync(IStepExecutionContext context)
    {
        var query = new GetOrganizationQuery(OrganizationId: OrganizationId);

        var getOrganizationResponse = await mediator.Send(query)
            .ConfigureAwait(false);

        // If there is an error when trying to get the organization from the database
        if (getOrganizationResponse.IsError)
        {
            await SetErrorMessageToOrderAndThrowExceptionAsync(getOrganizationResponse.FirstError.Description,
                context.CancellationToken);
        }

        var organization = getOrganizationResponse.Value;

        // ...

        return ExecutionResult.Next();
    }

    private async Task SetErrorMessageToOrderAndThrowExceptionAsync(string message, CancellationToken cancellationToken)
    {
        var order = await dbContext.Orders.Where(o => o.Id == OrderData.Id)
            .FirstOrDefaultAsync(cancellationToken)
            .ConfigureAwait(false);

        if (order is null)
        {
            logger?.Error("Order with ID {Id} not found in database.", OrderData.Id);
            throw new Exception($"Order with ID {OrderData.Id} not found in database."); // throw exception and terminate workflow in OnStepError
        }

        var error = new Error(message);

        order.SetError(error);

        await dbContext.SaveChangesAsync(cancellationToken);

        throw new Exception(message); // throw exception and terminate workflow in OnStepError
    }
}