Skip to content

Commit

Permalink
Fix HTTP Partitions tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@jr-araujo
jr-araujo committed Sep 11, 2024
1 parent a5ee663 commit de13120
Showing 1 changed file with 82 additions and 37 deletions.
119 changes: 82 additions & 37 deletions Iggy_SDK_Tests/E2ETests/PartitionsE2E.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,56 +25,101 @@ public PartitionsE2E(IggyPartitionFixture fixture)
(int)PartitionsFixtureBootstrap.TopicRequest.TopicId, _partitionsRequest.PartitionsCount);
}

[Fact(Skip = SkipMessage), TestPriority(1)]
[Fact, TestPriority(1)]
public async Task CreatePartition_HappyPath_Should_CreatePartition_Successfully()
{
var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
{
await sut.Invoking(x => x.CreatePartitionsAsync(_partitionsRequest))
.Should()
.NotThrowAsync();
})).ToArray();
await Task.WhenAll(tasks);
// act & assert
await _fixture.HttpSut.Invoking(y =>
y.CreatePartitionsAsync(_partitionsRequest)
).Should()
.NotThrowAsync();

// TODO: This code block is commmented bacause TCP implementation is not working properly.
// var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
// {
// await sut.Invoking(x => x.CreatePartitionsAsync(_partitionsRequest))
// .Should()
// .NotThrowAsync();
// })).ToArray();
//
// await Task.WhenAll(tasks);
}

[Fact(Skip = SkipMessage), TestPriority(2)]
[Fact, TestPriority(2)]
public async Task DeletePartition_Should_DeletePartition_Successfully()
{
var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
{
await sut.Invoking(x => x.DeletePartitionsAsync(_deletePartitionsRequest))
.Should()
.NotThrowAsync();
})).ToArray();
await Task.WhenAll(tasks);
// act & assert
await _fixture.HttpSut.Invoking(y =>
y.DeletePartitionsAsync(_deletePartitionsRequest)
).Should()
.NotThrowAsync();

// TODO: This code block is commmented bacause TCP implementation is not working properly.
// var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
// {
// await sut.Invoking(x => x.DeletePartitionsAsync(_deletePartitionsRequest))
// .Should()
// .NotThrowAsync();
// })).ToArray();
//
// await Task.WhenAll(tasks);
}

[Fact(Skip = SkipMessage), TestPriority(3)]
[Fact, TestPriority(3)]
public async Task DeletePartition_Should_Throw_WhenTopic_DoesNotExist()
{
var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
{
await sut.CreatePartitionsAsync(_partitionsRequest);
await sut.DeleteTopicAsync(Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId!),
Identifier.Numeric((int)PartitionsFixtureBootstrap.TopicRequest.TopicId!));
await sut.Invoking(x => x.DeletePartitionsAsync(_deletePartitionsRequest))
.Should()
.ThrowExactlyAsync<InvalidResponseException>();
})).ToArray();
await Task.WhenAll(tasks);
// act & assert
await _fixture.HttpSut.CreatePartitionsAsync(_partitionsRequest);

await _fixture.HttpSut.DeleteTopicAsync(
Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId!),
Identifier.Numeric((int)PartitionsFixtureBootstrap.TopicRequest.TopicId!));

await _fixture.HttpSut.Invoking(y =>
y.DeletePartitionsAsync(_deletePartitionsRequest)
).Should()
.ThrowExactlyAsync<InvalidResponseException>();

// TODO: This code block is commmented bacause TCP implementation is not working properly.
// var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
// {
// await sut.CreatePartitionsAsync(_partitionsRequest);
// await sut.DeleteTopicAsync(Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId!),
// Identifier.Numeric((int)PartitionsFixtureBootstrap.TopicRequest.TopicId!));
// await sut.Invoking(x => x.DeletePartitionsAsync(_deletePartitionsRequest))
// .Should()
// .ThrowExactlyAsync<InvalidResponseException>();
// })).ToArray();
//
// await Task.WhenAll(tasks);
}

[Fact(Skip = SkipMessage), TestPriority(4)]
[Fact, TestPriority(4)]
public async Task DeletePartition_Should_Throw_WhenStream_DoesNotExist()
{
var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
{
await sut.CreateTopicAsync(Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId!), PartitionsFixtureBootstrap.TopicRequest);
await sut.DeleteStreamAsync(Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId));
await sut.Invoking(x => x.DeletePartitionsAsync(_deletePartitionsRequest))
.Should()
.ThrowExactlyAsync<InvalidResponseException>();
})).ToArray();
await Task.WhenAll(tasks);
// act & assert
await _fixture.HttpSut.CreateTopicAsync(
Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId!),
PartitionsFixtureBootstrap.TopicRequest);

await _fixture.HttpSut.DeleteStreamAsync(
Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId));

await _fixture.HttpSut.Invoking(y =>
y.DeletePartitionsAsync(_deletePartitionsRequest)
).Should()
.ThrowExactlyAsync<InvalidResponseException>();

// TODO: This code block is commmented bacause TCP implementation is not working properly.
// var tasks = _fixture.SubjectsUnderTest.Select( sut => Task.Run(async () =>
// {
// await sut.CreateTopicAsync(Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId!), PartitionsFixtureBootstrap.TopicRequest);
// await sut.DeleteStreamAsync(Identifier.Numeric((int)PartitionsFixtureBootstrap.StreamRequest.StreamId));
// await sut.Invoking(x => x.DeletePartitionsAsync(_deletePartitionsRequest))
// .Should()
// .ThrowExactlyAsync<InvalidResponseException>();
// })).ToArray();
//
// await Task.WhenAll(tasks);
}
}

0 comments on commit de13120

Please sign in to comment.