foreign/csharp/Iggy_SDK_Tests/E2ETests/ConsumerGroupE2E.cs

using FluentAssertions;
using Iggy_SDK;
using Iggy_SDK_Tests.E2ETests.Fixtures;
using Iggy_SDK_Tests.E2ETests.Fixtures.Bootstraps;
using Iggy_SDK_Tests.Utils;
using Iggy_SDK_Tests.Utils.Groups;
using Iggy_SDK.Contracts.Http;
using Iggy_SDK.Exceptions;

namespace Iggy_SDK_Tests.E2ETests;

[TestCaseOrderer("Iggy_SDK_Tests.Utils.PriorityOrderer", "Iggy_SDK_Tests")]
public sealed class ConsumerGroupE2E : IClassFixture<IggyConsumerGroupFixture>
{
    private const string SkipMessage = "TCP implementation needs to be aligned with Iggyrs core changes";
    
    private readonly IggyConsumerGroupFixture _fixture;

    private const int GROUP_ID = 1;
    
    private static readonly CreateConsumerGroupRequest _createConsumerGroupRequest =
        ConsumerGroupFactory.CreateRequest(
            (int)ConsumerGroupFixtureBootstrap.StreamRequest.StreamId!,
            (int)ConsumerGroupFixtureBootstrap.TopicRequest.TopicId!, GROUP_ID);

    private static readonly JoinConsumerGroupRequest _joinConsumerGroupRequest =
        ConsumerGroupFactory.CreateJoinGroupRequest(
            (int)ConsumerGroupFixtureBootstrap.StreamRequest.StreamId,
            (int)ConsumerGroupFixtureBootstrap.TopicRequest.TopicId, GROUP_ID);

    private static readonly LeaveConsumerGroupRequest _leaveConsumerGroupRequest =
        ConsumerGroupFactory.CreateLeaveGroupRequest(
            (int)ConsumerGroupFixtureBootstrap.StreamRequest.StreamId,
            (int)ConsumerGroupFixtureBootstrap.TopicRequest.TopicId, GROUP_ID);

    private static readonly DeleteConsumerGroupRequest _deleteConsumerGroupRequest =
        ConsumerGroupFactory.CreateDeleteGroupRequest(
            (int)ConsumerGroupFixtureBootstrap.StreamRequest.StreamId,
            (int)ConsumerGroupFixtureBootstrap.TopicRequest.TopicId, GROUP_ID);
    
    private Identifier ConsumerGroupId = Identifier.Numeric(GROUP_ID);

    public ConsumerGroupE2E(IggyConsumerGroupFixture fixture)
    {
        _fixture = fixture;
    }

    [Fact, TestPriority(1)]
    public async Task CreateConsumerGroup_HappyPath_Should_CreateConsumerGroup_Successfully()
    {
        // act & assert
        await _fixture.HttpSut.Invoking(y =>
                y.CreateConsumerGroupAsync(_createConsumerGroupRequest)
            ).Should()
            .NotThrowAsync();
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var tasks = _fixture.SubjectsUnderTest.Select(sut => Task.Run(async () =>
        // {
        //     await sut.CreateConsumerGroupAsync(_createConsumerGroupRequest);
        // })).ToArray();
        //
        // await Task.WhenAll(tasks);
    }

    [Fact, TestPriority(2)]
    public async Task CreateConsumerGroup_Should_Throw_InvalidResponse()
    {
        // act & assert
        await _fixture.HttpSut.Invoking(y =>
                y.CreateConsumerGroupAsync(_createConsumerGroupRequest)
            ).Should()
            .ThrowExactlyAsync<InvalidResponseException>();
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var tasks = _fixture.SubjectsUnderTest.Select(sut => Task.Run(async () =>
        // {
        //     await sut.Invoking(x => x.CreateConsumerGroupAsync(_createConsumerGroupRequest))
        //         .Should()
        //         .ThrowExactlyAsync<InvalidResponseException>();
        // })).ToArray();
        //
        // await Task.WhenAll(tasks);
    }

    [Fact, TestPriority(3)]
    public async Task GetConsumerGroupById_Should_Return_ValidResponse()
    {
        // act
        var response = await _fixture.HttpSut
                .GetConsumerGroupByIdAsync(
                    Identifier.Numeric((int)ConsumerGroupFixtureBootstrap.StreamRequest.StreamId!),
                    Identifier.Numeric((int)ConsumerGroupFixtureBootstrap.TopicRequest.TopicId!),
                    ConsumerGroupId);
        
        // assert
        response.Should().NotBeNull();
        
        response!.Id.Should().Be(GROUP_ID);
        
        response.PartitionsCount
            .Should()
            .Be(ConsumerGroupFixtureBootstrap.TopicRequest.PartitionsCount);
        
        response.MembersCount.Should().Be(0);
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var tasks = _fixture.SubjectsUnderTest.Select(sut => Task.Run(async () =>
        // {
        //     var response = await sut.GetConsumerGroupByIdAsync(
        //         Identifier.Numeric((int)ConsumerGroupFixtureBootstrap.StreamRequest.StreamId!), Identifier.Numeric((int)ConsumerGroupFixtureBootstrap.TopicRequest.TopicId!),
        //         ConsumerGroupId);
        //
        //     response.Should().NotBeNull();
        //     response!.Id.Should().Be(GROUP_ID);
        //     response.PartitionsCount.Should().Be(ConsumerGroupFixtureBootstrap.TopicRequest.PartitionsCount);
        //     response.MembersCount.Should().Be(0);
        // })).ToArray();
        //
        // await Task.WhenAll(tasks);
    }

    [Fact, TestPriority(4)]
    public async Task JoinConsumerGroup_Should_JoinConsumerGroup_Successfully()
    {
        // act & assert
        await _fixture.HttpSut.Invoking(y =>
                y.JoinConsumerGroupAsync(_joinConsumerGroupRequest)
            ).Should()
            .ThrowExactlyAsync<FeatureUnavailableException>();
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var sut = _fixture.SubjectsUnderTest[0];
        // await sut.Invoking(x => x.JoinConsumerGroupAsync(_joinConsumerGroupRequest))
        //     .Should()
        //     .NotThrowAsync();
    }

    [Fact, TestPriority(5)]
    public async Task LeaveConsumerGroup_Should_LeaveConsumerGroup_Successfully()
    {
        // act & assert
        await _fixture.HttpSut.Invoking(x => x.LeaveConsumerGroupAsync(_leaveConsumerGroupRequest))
            .Should()
            .ThrowAsync<FeatureUnavailableException>();
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var sut = _fixture.SubjectsUnderTest[0];
        // await sut.Invoking(x => x.LeaveConsumerGroupAsync(_leaveConsumerGroupRequest))
        //     .Should()
        //     .ThrowAsync<FeatureUnavailableException>();
    }

    [Fact, TestPriority(6)]
    public async Task DeleteConsumerGroup_Should_DeleteConsumerGroup_Successfully()
    {
        var tasks = _fixture.SubjectsUnderTest.Select(sut => Task.Run(async () =>
        {
            await sut.Invoking(x => x.DeleteConsumerGroupAsync(_deleteConsumerGroupRequest))
                .Should()
                .NotThrowAsync();
        })).ToArray();
        await Task.WhenAll(tasks);
    }

    [Fact, TestPriority(7)]
    public async Task JoinConsumerGroup_Should_Throw_InvalidResponse()
    {
        // act & assert
        await _fixture.HttpSut.Invoking(x => x.LeaveConsumerGroupAsync(_leaveConsumerGroupRequest))
            .Should()
            .ThrowAsync<FeatureUnavailableException>();
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var sut = _fixture.SubjectsUnderTest[0];
        // await sut.Invoking(x => x.JoinConsumerGroupAsync(_joinConsumerGroupRequest))
        //     .Should()
        //     .ThrowExactlyAsync<FeatureUnavailableException>();
    }

    [Fact, TestPriority(8)]
    public async Task DeleteConsumerGroup_Should_Throw_InvalidResponse()
    {
        // act & assert
        await _fixture.HttpSut.Invoking(x => x.DeleteConsumerGroupAsync(_deleteConsumerGroupRequest))
            .Should()
            .ThrowExactlyAsync<InvalidResponseException>();
        
        // TODO: This code block is commented because TCP implementation is not working properly.
        // var tasks = _fixture.SubjectsUnderTest.Select(sut => Task.Run(async () =>
        // {
        //     await sut.Invoking(x => x.DeleteConsumerGroupAsync(_deleteConsumerGroupRequest))
        //         .Should()
        //         .ThrowExactlyAsync<InvalidResponseException>();
        // })).ToArray();
        //
        // await Task.WhenAll(tasks);
    }
}