Increase message count in end2end test

iggy-rs · Oct 18, 2023 · 20f2b57 · 20f2b57
1 parent b69471b
commit 20f2b57
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/Iggy_SDK_Tests/E2ETests/Fixtures/Tcp/IggyTcpFetchMessagesFixture.cs b/Iggy_SDK_Tests/E2ETests/Fixtures/Tcp/IggyTcpFetchMessagesFixture.cs
@@ -1,4 +1,5 @@
 using DotNet.Testcontainers.Builders;
+using DotNet.Testcontainers.Configurations;
 using Iggy_SDK;
 using Iggy_SDK.Contracts.Http;
 using Iggy_SDK.Enums;
@@ -14,9 +15,10 @@ namespace Iggy_SDK_Tests.E2ETests.Fixtures.Tcp;
 
 public sealed class IggyTcpFetchMessagesFixture : IAsyncLifetime
 {
- private readonly IContainer _container = new ContainerBuilder().WithImage("iggyrs/iggy:latest")
+ public readonly IContainer _container = new ContainerBuilder().WithImage("iggyrs/iggy:latest")
  //.WithPortBinding(3000, true)
  .WithPortBinding(8090, true)
+ .WithOutputConsumer(Consume.RedirectStdoutAndStderrToConsole())
  .WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(8090))
  //.WithPortBinding(8080, true)
  .Build();

diff --git a/Iggy_SDK_Tests/E2ETests/Fixtures/Tcp/IggyTcpPollMessagesFixture.cs b/Iggy_SDK_Tests/E2ETests/Fixtures/Tcp/IggyTcpPollMessagesFixture.cs
@@ -16,9 +16,10 @@ namespace Iggy_SDK_Tests.E2ETests.Fixtures.Tcp;
 
 public sealed class IggyTcpPollMessagesFixture : IAsyncLifetime
 {
- private readonly IContainer _container = new ContainerBuilder().WithImage("iggyrs/iggy:latest")
+ public readonly IContainer _container = new ContainerBuilder().WithImage("iggyrs/iggy:latest")
  //.WithPortBinding(3000, true)
  .WithPortBinding(8090, true)
+ .WithOutputConsumer(Consume.RedirectStdoutAndStderrToConsole())
  .WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(8090))
  //.WithPortBinding(8080, true)
  .Build();
@@ -29,7 +30,7 @@ public sealed class IggyTcpPollMessagesFixture : IAsyncLifetime
  private static readonly StreamRequest StreamRequest = StreamFactory.CreateStreamRequest();
  private static readonly TopicRequest TopicRequest = TopicFactory.CreateTopicRequest();
  private static readonly TopicRequest HeadersTopicRequest = TopicFactory.CreateTopicRequest();
- public const int MessageCount = 1000;
+ public const int MessageCount = 1000000;
 
  public readonly int StreamId = StreamRequest.StreamId;
  public readonly int TopicId = TopicRequest.TopicId;

diff --git a/Iggy_SDK_Tests/E2ETests/Messaging/FetchMessagesE2ETcp.cs b/Iggy_SDK_Tests/E2ETests/Messaging/FetchMessagesE2ETcp.cs
@@ -1,3 +1,4 @@
+using DotNet.Testcontainers.Builders;
 using FluentAssertions;
 using Iggy_SDK.Contracts.Http;
 using Iggy_SDK.Enums;
@@ -6,6 +7,7 @@
 using Iggy_SDK_Tests.Utils;
 using Iggy_SDK_Tests.Utils.DummyObj;
 using Iggy_SDK_Tests.Utils.Messages;
+using Xunit.Abstractions;
 
 namespace Iggy_SDK_Tests.E2ETests.Messaging;