List view

A

test\ModularPipelines.UnitTests\NonIgnoredFailureTests.cs

• 2 Complexity
• 1 Complexity / M
• 0 Duplication
• 11 Churn
• 33 Lines
• 28 Lines of Code
• 2 Methods
• 14 LOC / Method

using Microsoft.Extensions.DependencyInjection;
using ModularPipelines.Context;
using ModularPipelines.Exceptions;
using ModularPipelines.Models;
using ModularPipelines.Modules;
using ModularPipelines.TestHelpers;
using EngineCancellationToken = ModularPipelines.Engine.EngineCancellationToken;

namespace ModularPipelines.UnitTests;

public class NonIgnoredFailureTests : TestBase
{
    private class NonIgnoredFailureModule : Module<CommandResult>
    {
        protected override async Task<CommandResult?> ExecuteAsync(IPipelineContext context, CancellationToken cancellationToken)
        {
            await Task.Yield();
            throw new Exception();
        }
    }

    [Test]
    public async Task Has_Thrown_And_Cancelled_Pipeline()
    {
        var exception = await Assert.ThrowsAsync<ModuleFailedException>(async () => await RunModule<NonIgnoredFailureModule>());

        var serviceProvider = exception.Module.Context.Get<IServiceProvider>()!;
        var engineCancellationToken = serviceProvider.GetRequiredService<EngineCancellationToken>();

        await Task.Delay(TimeSpan.FromSeconds(10));
        await Assert.That(engineCancellationToken.IsCancellationRequested).IsTrue();
    }
}