How to use Until method of DotNet.Testcontainers.Configurations.UntilMessageIsLogged class

Best Testcontainers-dotnet code snippet using DotNet.Testcontainers.Configurations.UntilMessageIsLogged.Until

BasicContainerTests.cs

Source:BasicContainerTests.cs

...30            .WithPortBinding(8080, 8080)31            .WithCleanUp(true)32            .WithOutputConsumer(fhirServerOutputConsumer)33            .WithWaitStrategy(34                Wait.ForUnixContainer().UntilMessageIsLogged(fhirServerOutputConsumer.Stdout, @".*(Started Application).*"))35            .Build();36        var exporterImage = Environment.GetEnvironmentVariable("FHIR_SERVER_EXPORTER_E2E_TEST_IMAGE") ?? "ghcr.io/chgl/fhir-server-exporter:latest";37        fhirServerExporterOutputConsumer = Consume.RedirectStdoutAndStderrToStream(new MemoryStream(), new MemoryStream());38        fhirServerExporterContainer = new TestcontainersBuilder<TestcontainersContainer>()39            .WithImage(exporterImage)40            .WithName("fhir-server-exporter")41            .WithNetwork(containerNetwork)42            .WithExposedPort(9797)43            .WithPortBinding(9797, 9797)44            .WithCleanUp(true)45            .WithEnvironment("FhirServerUrl", "http://fhir-server:8080/fhir")46            .WithOutputConsumer(fhirServerExporterOutputConsumer)47            .WithWaitStrategy(48                Wait.ForUnixContainer().UntilMessageIsLogged(fhirServerExporterOutputConsumer.Stdout, @".*(FHIR Server Prometheus Exporter running on port 9797).*"))49            .Build();50    }51    [Fact]52    public async Task GetFhirServerCapabilityStatement_ShouldSucceed()53    {54        var fhirClient = new Hl7.Fhir.Rest.FhirClient("http://localhost:8080/fhir");55        _ = await fhirClient.CapabilityStatementAsync();56    }57    [Fact]58    public async Task GetExporterMetricsEndpoint_ShouldSucceed()59    {60        var client = new HttpClient();61        var response = await client.GetAsync("http://localhost:9797/metrics");62        response.EnsureSuccessStatusCode();...

WaitUntilMessageIsLoggedTest.cs

Source:WaitUntilMessageIsLoggedTest.cs

...5  using System.Threading.Tasks;6  using DotNet.Testcontainers.Builders;7  using DotNet.Testcontainers.Configurations;8  using Xunit;9  public sealed class WaitUntilMessageIsLoggedTest10  {11    [Fact]12    public async Task UntilMessageIsLogged()13    {14      // Given15      const string expectedMessage = "Message has been logged.";16      await using var memoryStream = new MemoryStream();17      await using var streamWriter = new StreamWriter(memoryStream);18      // When19      await streamWriter.WriteAsync(expectedMessage);20      await streamWriter.FlushAsync();21      var wait = Wait.ForUnixContainer()22        .UntilMessageIsLogged(memoryStream, expectedMessage)23        .Build()24        .Skip(1)25        .First();26      // Then27      var exception = await Record.ExceptionAsync(() => WaitStrategy.WaitUntil(() => wait.Until(null, null)));28      Assert.Null(exception);29    }30  }31}...

UntilMessageIsLogged.cs

Source:UntilMessageIsLogged.cs

...5  using System.Text.RegularExpressions;6  using System.Threading.Tasks;7  using DotNet.Testcontainers.Containers;8  using Microsoft.Extensions.Logging;9  internal class UntilMessageIsLogged : IWaitUntil10  {11    private readonly string message;12    private readonly Stream stream;13    public UntilMessageIsLogged(Stream stream, string message)14    {15      this.stream = stream;16      this.message = message;17    }18    public async Task<bool> Until(ITestcontainersContainer testcontainers, ILogger logger)19    {20      this.stream.Seek(0, SeekOrigin.Begin);21      using (var streamReader = new StreamReader(this.stream, Encoding.UTF8, false, 4096, true))22      {23        var output = await streamReader.ReadToEndAsync()24          .ConfigureAwait(false);25        return Regex.IsMatch(output, this.message);26      }27    }28  }29}...

Until

Using AI Code Generation

1using System.Threading.Tasks;2using DotNet.Testcontainers.Containers.Builders;3using DotNet.Testcontainers.Containers.Configurations;4using DotNet.Testcontainers.Containers.Modules;5using DotNet.Testcontainers.Containers.WaitStrategies;6using DotNet.Testcontainers.Images.Builders;7{8    {9        public static async Task Main(string[] args)10        {11            var image = new ImageFromDockerfileBuilder()12                .WithName("testcontainers")13                .WithDockerfile("./Dockerfile")14                .Build();15            using var container = new TestcontainersBuilder<GenericContainer>()16                .WithImage(image)17                .WithWaitStrategy(Wait.ForUnixContainer()18                    .UntilMessageIsLogged("Started Application", 30))19                .Build();20            await container.StartAsync();21        }22    }23}24using System.Threading.Tasks;25using DotNet.Testcontainers.Containers.Builders;26using DotNet.Testcontainers.Containers.Configurations;27using DotNet.Testcontainers.Containers.Modules;28using DotNet.Testcontainers.Images.Builders;29{30    {31        public static async Task Main(string[] args)32        {33            var image = new ImageFromDockerfileBuilder()34                .WithName("testcontainers")35                .WithDockerfile("./Dockerfile")36                .Build();37            using var container = new TestcontainersBuilder<GenericContainer>()38                .WithImage(image)39                .WithWaitStrategy(Wait.ForUnixContainer()40                    .UntilUnixSocketIsAvailable("/var/run/docker.sock", 30))41                .Build();42            await container.StartAsync();43        }44    }45}46using System.Threading.Tasks;47using DotNet.Testcontainers.Containers.Builders;48using DotNet.Testcontainers.Containers.Configurations;49using DotNet.Testcontainers.Containers.Modules;50using DotNet.Testcontainers.Images.Builders;51{52    {53        public static async Task Main(string[] args)54        {55            var image = new ImageFromDockerfileBuilder()56                .WithName("testcontainers")57                .WithDockerfile("./Dockerfile")58                .Build();

Until

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers;3using DotNet.Testcontainers.Containers.Builders;4using DotNet.Testcontainers.Containers.Modules;5using DotNet.Testcontainers.Containers.WaitStrategies;6using System;7using System.Threading.Tasks;8{9    {10        static async Task Main(string[] args)11        {12            var testcontainersBuilder = new TestcontainersBuilder<TestcontainersContainer>()13                .WithImage("mcr.microsoft.com/mssql/server")14                .WithEnvironment("ACCEPT_EULA", "Y")15                .WithEnvironment("SA_PASSWORD", "Pass@word")16                .WithPortBinding(1433)17                .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("Service Broker manager has started"));18            using (var container = testcontainersBuilder.Build())19            {20                await container.StartAsync();21                Console.WriteLine(container.Hostname);22            }23        }24    }25}26using DotNet.Testcontainers.Configurations;27using DotNet.Testcontainers.Containers;28using DotNet.Testcontainers.Containers.Builders;29using DotNet.Testcontainers.Containers.Modules;30using DotNet.Testcontainers.Containers.WaitStrategies;31using System;32using System.Threading.Tasks;33{34    {35        static async Task Main(string[] args)36        {37            var testcontainersBuilder = new TestcontainersBuilder<TestcontainersContainer>()38                .WithImage("mcr.microsoft.com/mssql/server")39                .WithEnvironment("ACCEPT_EULA", "Y")40                .WithEnvironment("SA_PASSWORD", "Pass@word")41                .WithPortBinding(1433)42                .WithWaitStrategy(Wait.ForWindowsContainer().UntilMessageIsLogged("Service Broker manager has started"));43            using (var container = testcontainersBuilder.Build())44            {45                await container.StartAsync();46                Console.WriteLine(container.Hostname);47            }48        }49    }50}

Until

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using DotNet.Testcontainers.Containers.Builders;4using DotNet.Testcontainers.Containers.Modules;5using DotNet.Testcontainers.Containers.WaitStrategies;6{7    {8        static async Task Main(string[] args)9        {10            var dockerfile = new DockerfileBuilder()11                .From("mcr.microsoft.com/dotnet/core/sdk:3.1")12                .Run("dotnet new console")13                .Run("dotnet publish -c Release -o /app")14                .Run("dotnet add package Microsoft.EntityFrameworkCore.Design")15                .Run("dotnet add package Microsoft.EntityFrameworkCore.SqlServer")16                .Run("dotnet ef migrations add InitialCreate")17                .Run("dotnet ef database update")18                .Run("dotnet add package Microsoft.VisualStudio.Web.CodeGeneration.Design")19                .Run("dotnet add package Microsoft.EntityFrameworkCore.Tools")20                .Run("dotnet add package Microsoft.VisualStudio.Web.CodeGeneration.Design")21                .Run("dotnet tool install --global dotnet-aspnet-codegenerator")22                .Run("dotnet add package Microsoft.AspNetCore.Mvc.NewtonsoftJson")23                .Run("dotnet add package Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore")24                .Run("dotnet add package Microsoft.AspNetCore.Identity.EntityFrameworkCore")

Until

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers.Builders;3using DotNet.Testcontainers.Containers.Modules;4using System;5using System.Threading.Tasks;6{7    {8        static async Task Main(string[] args)9        {10            var testcontainerBuilder = new TestcontainersBuilder<Testcontainer>()11                .WithImage("redis:5.0.5")12                .WithCommand("redis-server")13                .WithPortBinding(6379)14                .WithEnvironment("REDIS_REPLICATION_MODE", "master")15                .WithEnvironment("REDIS_REPLICATION_ROLE", "master")16                .WithEnvironment("REDIS_REPLICATION_PORT", "6379")17                .WithEnvironment("REDIS_REPLICATION_MASTER_HOST", "

Until

Using AI Code Generation

1var container = new TestcontainersBuilder<OracleTestcontainer>()2    .WithDatabase(new OracleTestcontainerConfiguration())3    .Build();4await container.StartAsync();5var connectionString = container.ConnectionString;6var untilMessageIsLogged = container.UntilMessageIsLogged("Oracle Database 11g Express Edition Release

Until

Using AI Code Generation

1var container = await new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.Databases.MySqlTestcontainer>()2.UseImage("mysql:5.7")3.WaitUntilMessageIsLogged("mysqld: ready for connections.", new DotNet.Testcontainers.Configurations.UntilMessageIsLogged())4.Build()5.StartAsync();6var container = await new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.Databases.MySqlTestcontainer>()7.UseImage("mysql:5.7")8.WaitUntilContainerIsRunning(new DotNet.Testcontainers.Configurations.UntilContainerIsRunning())9.Build()10.StartAsync();11var container = await new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.Databases.MySqlTestcontainer>()12.UseImage("mysql:5.7")13.WaitUntilContainerIsStopped(new DotNet.Testcontainers.Configurations.UntilContainerIsStopped())14.Build()15.StartAsync();16var container = await new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.Databases.MySqlTestcontainer>()17.UseImage("mysql:5.7")18.WaitUntilResponseIsReceived(new DotNet.Testcontainers.Configurations.UntilResponseIsReceived())19.Build()20.StartAsync();21var container = await new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.Databases.MySqlTestcontainer>()22.UseImage("mysql:5.7")23.WaitUntilResponseIsReceived(new DotNet.Testcontainers.Configurations.UntilResponseIsReceived())24.Build()25.StartAsync();

Until

Using AI Code Generation

1var containerBuilder = new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.Databases.MySqlTestcontainer>()2    .WithImage("mysql:latest")3    .WithPortBinding(3306)4    .WithEnvironment("MYSQL_ROOT_PASSWORD", "password")5    .WithEnvironment("MYSQL_DATABASE", "testdb")6    .WithEnvironment("MYSQL_USER", "testuser")7    .WithEnvironment("MYSQL_PASSWORD", "password")8    .WithWaitStrategy(DotNet.Testcontainers.Containers.WaitStrategies.Wait.ForUnixContainer().UntilMessageIsLogged("mysqld: ready for connections."))9    .Build();10await containerBuilder.StartAsync();11var containerBuilder = new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.MessageBrokers.RabbitMQTestcontainer>()12    .WithImage("rabbitmq:3-management")13    .WithPortBinding(5672)14    .WithPortBinding(15672)15    .WithEnvironment("RABBITMQ_DEFAULT_USER", "guest")16    .WithEnvironment("RABBITMQ_DEFAULT_PASS", "guest")17    .WithWaitStrategy(DotNet.Testcontainers.Containers.WaitStrategies.Wait.ForUnixContainer().UntilMessageIsLogged("Server startup complete;"))18    .Build();19await containerBuilder.StartAsync();20var containerBuilder = new DotNet.Testcontainers.Containers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.Modules.MessageBrokers.KafkaTestcontainer>()21    .WithImage("confluentinc/cp-kafka:latest")22    .WithPortBinding(9092)23    .WithPortBinding(2181)24    .WithEnvironment("KAFKA_BROKER_ID", 1)25    .WithEnvironment("KAFKA_ZOOKEEPER_CONNECT", "localhost:2181")26    .WithEnvironment("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", 1)

Until

Using AI Code Generation

1var untilMessageIsLogged = new UntilMessageIsLogged("Started Application in 0.0 seconds");2var container = new TestcontainersBuilder<GenericContainer>()3    .WithImage("nginx:1.17.8")4    .WithCommand("nginx", "-g", "daemon off;")5    .WithPortBinding(80, 8080)6    .WithLogConsumer(new GenericContainerLogConsumer(outputHelper))7    .WithUntil(untilMessageIsLogged)8    .Build();9await container.StartAsync();10var untilMessageIsLogged = new UntilMessageIsLogged("Started Application in 0.0 seconds");11var container = new TestcontainersBuilder<GenericContainer>()12    .WithImage("nginx:1.17.8")13    .WithCommand("nginx", "-g", "daemon off;")14    .WithPortBinding(80, 8080)15    .WithLogConsumer(new GenericContainerLogConsumer(outputHelper))16    .WithUntil(untilMessageIsLogged)17    .Build();18await container.StartAsync();19var untilMessageIsLogged = new UntilMessageIsLogged("Started Application in 0.0 seconds");20var container = new TestcontainersBuilder<GenericContainer>()21    .WithImage("nginx:1.17.8")22    .WithCommand("nginx", "-g", "daemon off;")23    .WithPortBinding(80, 8080)24    .WithLogConsumer(new GenericContainerLogConsumer(outputHelper))25    .WithUntil(untilMessageIsLogged)26    .Build();27await container.StartAsync();28var untilMessageIsLogged = new UntilMessageIsLogged("Started Application in 0.0 seconds");29var container = new TestcontainersBuilder<GenericContainer>()30    .WithImage("nginx:1.17.8")31    .WithCommand("nginx", "-g", "daemon off;")32    .WithPortBinding(80, 8080)33    .WithLogConsumer(new GenericContainerLogConsumer(outputHelper))34    .WithUntil(untilMessageIsLogged)35    .Build();36await container.StartAsync();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.