feat: Add module connection string provider

.devcontainer/devcontainer.json

@@ -13,7 +13,7 @@
     "ghcr.io/devcontainers/features/docker-in-docker:2": {
       "moby": true
     },
-    "ghcr.io/devcontainers/features/dotnet:2.4.1": {
+    "ghcr.io/devcontainers/features/dotnet:2.4.2": {
       "version": "10.0",
       "installUsingApt": false
     }

src/Testcontainers.ActiveMq/ActiveMqConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.ActiveMq;
+
+/// <summary>
+/// Provides the ActiveMq connection string.
+/// </summary>
+internal sealed class ActiveMqConnectionStringProvider : ContainerConnectionStringProvider<ArtemisContainer, ActiveMqConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetBrokerAddress();
+    }
+}

src/Testcontainers.ActiveMq/ArtemisBuilder.cs

@@ -106,6 +106,7 @@ protected override ArtemisBuilder Init()
             .WithPortBinding(ArtemisConsolePort, true)
             .WithUsername(DefaultUsername)
             .WithPassword(DefaultPassword)
+            .WithConnectionStringProvider(new ActiveMqConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("HTTP Server started"));
     }
 

src/Testcontainers.ArangoDb/ArangoDbBuilder.cs

@@ -91,6 +91,7 @@ protected override ArangoDbBuilder Init()
         return base.Init()
             .WithPortBinding(ArangoDbPort, true)
             .WithPassword(DefaultPassword)
+            .WithConnectionStringProvider(new ArangoDbConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("Have fun!"));
     }
 

src/Testcontainers.ArangoDb/ArangoDbConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.ArangoDb;
+
+/// <summary>
+/// Provides the ArangoDb connection string.
+/// </summary>
+internal sealed class ArangoDbConnectionStringProvider : ContainerConnectionStringProvider<ArangoDbContainer, ArangoDbConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetTransportAddress();
+    }
+}

src/Testcontainers.Azurite/AzuriteBuilder.cs

@@ -132,7 +132,8 @@ protected override AzuriteBuilder Init()
             .WithPortBinding(QueuePort, true)
             .WithPortBinding(TablePort, true)
             .WithEntrypoint("azurite")
-            .WithCommand("--blobHost", "0.0.0.0", "--queueHost", "0.0.0.0", "--tableHost", "0.0.0.0");
+            .WithCommand("--blobHost", "0.0.0.0", "--queueHost", "0.0.0.0", "--tableHost", "0.0.0.0")
+            .WithConnectionStringProvider(new AzuriteConnectionStringProvider());
     }
 
     /// <inheritdoc />

src/Testcontainers.Azurite/AzuriteConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Azurite;
+
+/// <summary>
+/// Provides the Azurite connection string.
+/// </summary>
+internal sealed class AzuriteConnectionStringProvider : ContainerConnectionStringProvider<AzuriteContainer, AzuriteConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.BigQuery/BigQueryBuilder.cs

@@ -88,6 +88,7 @@ protected override BigQueryBuilder Init()
         return base.Init()
             .WithPortBinding(BigQueryPort, true)
             .WithProject(DefaultProjectId)
+            .WithConnectionStringProvider(new BigQueryConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("(?s).*listening.*$"));
     }
 

src/Testcontainers.BigQuery/BigQueryConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.BigQuery;
+
+/// <summary>
+/// Provides the BigQuery connection string.
+/// </summary>
+internal sealed class BigQueryConnectionStringProvider : ContainerConnectionStringProvider<BigQueryContainer, BigQueryConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetEmulatorEndpoint();
+    }
+}

src/Testcontainers.Bigtable/BigtableBuilder.cs

@@ -77,6 +77,7 @@ protected override BigtableBuilder Init()
             .WithPortBinding(BigtablePort, true)
             .WithEntrypoint("gcloud")
             .WithCommand("beta", "emulators", "bigtable", "start", "--host-port", "0.0.0.0:" + BigtablePort)
+            .WithConnectionStringProvider(new BigtableConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("(?s).*running.*$"));
     }
 

src/Testcontainers.Bigtable/BigtableConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Bigtable;
+
+/// <summary>
+/// Provides the Bigtable connection string.
+/// </summary>
+internal sealed class BigtableConnectionStringProvider : ContainerConnectionStringProvider<BigtableContainer, BigtableConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetEmulatorEndpoint();
+    }
+}

src/Testcontainers.Cassandra/CassandraBuilder.cs

@@ -83,6 +83,7 @@ protected override CassandraBuilder Init()
             .WithEnvironment("CASSANDRA_SNITCH", "GossipingPropertyFileSnitch")
             .WithEnvironment("CASSANDRA_ENDPOINT_SNITCH", "GossipingPropertyFileSnitch")
             .WithEnvironment("CASSANDRA_DC", DefaultDatacenterName)
+            .WithConnectionStringProvider(new CassandraConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("Startup complete"));
     }
 

src/Testcontainers.Cassandra/CassandraConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Cassandra;
+
+/// <summary>
+/// Provides the Cassandra connection string.
+/// </summary>
+internal sealed class CassandraConnectionStringProvider : ContainerConnectionStringProvider<CassandraContainer, CassandraConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.ClickHouse/ClickHouseBuilder.cs

@@ -120,6 +120,7 @@ protected override ClickHouseBuilder Init()
             .WithDatabase(DefaultDatabase)
             .WithUsername(DefaultUsername)
             .WithPassword(DefaultPassword)
+            .WithConnectionStringProvider(new ClickHouseConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilHttpRequestIsSucceeded(request =>
                 request.ForPort(HttpPort).ForResponseMessageMatching(IsNodeReadyAsync)));
     }

src/Testcontainers.ClickHouse/ClickHouseConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.ClickHouse;
+
+/// <summary>
+/// Provides the ClickHouse connection string.
+/// </summary>
+internal sealed class ClickHouseConnectionStringProvider : ContainerConnectionStringProvider<ClickHouseContainer, ClickHouseConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.CockroachDb/CockroachDbBuilder.cs

@@ -122,6 +122,7 @@ protected override CockroachDbBuilder Init()
             .WithPassword(DefaultPassword)
             .WithCommand("start-single-node")
             .WithCommand("--insecure")
+            .WithConnectionStringProvider(new CockroachDbConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilHttpRequestIsSucceeded(request =>
                 request.ForPort(CockroachDbRestPort).ForPath("/health")));
     }

src/Testcontainers.CockroachDb/CockroachDbConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.CockroachDb;
+
+/// <summary>
+/// Provides the CockroachDb connection string.
+/// </summary>
+internal sealed class CockroachDbConnectionStringProvider : ContainerConnectionStringProvider<CockroachDbContainer, CockroachDbConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.Consul/ConsulBuilder.cs

@@ -80,6 +80,7 @@ protected override ConsulBuilder Init()
             .WithPortBinding(ConsulGrpcPort, true)
             .WithCommand("agent", "-dev", "-client", "0.0.0.0")
             .WithCreateParameterModifier(cmd => cmd.HostConfig.CapAdd = new[] { "IPC_LOCK" })
+            .WithConnectionStringProvider(new ConsulConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilHttpRequestIsSucceeded(request =>
                 request.ForPath("/v1/status/leader").ForPort(ConsulHttpPort)));
     }

src/Testcontainers.Consul/ConsulConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Consul;
+
+/// <summary>
+/// Provides the Consul connection string.
+/// </summary>
+internal sealed class ConsulConnectionStringProvider : ContainerConnectionStringProvider<ConsulContainer, ConsulConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetBaseAddress();
+    }
+}

src/Testcontainers.CosmosDb/CosmosDbBuilder.cs

@@ -77,6 +77,7 @@ protected override CosmosDbBuilder Init()
     {
         return base.Init()
             .WithPortBinding(CosmosDbPort, true)
+            .WithConnectionStringProvider(new CosmosDbConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().AddCustomWaitStrategy(new WaitUntil()));
     }
 

src/Testcontainers.CosmosDb/CosmosDbConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.CosmosDb;
+
+/// <summary>
+/// Provides the CosmosDb connection string.
+/// </summary>
+internal sealed class CosmosDbConnectionStringProvider : ContainerConnectionStringProvider<CosmosDbContainer, CosmosDbConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.CouchDb/CouchDbBuilder.cs

@@ -103,6 +103,7 @@ protected override CouchDbBuilder Init()
             .WithPortBinding(CouchDbPort, true)
             .WithUsername(DefaultUsername)
             .WithPassword(DefaultPassword)
+            .WithConnectionStringProvider(new CouchDbConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilHttpRequestIsSucceeded(request =>
                 request.ForPath("/").ForPort(CouchDbPort)));
     }

src/Testcontainers.CouchDb/CouchDbConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.CouchDb;
+
+/// <summary>
+/// Provides the CouchDb connection string.
+/// </summary>
+internal sealed class CouchDbConnectionStringProvider : ContainerConnectionStringProvider<CouchDbContainer, CouchDbConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.Couchbase/CouchbaseBuilder.cs

@@ -175,6 +175,7 @@ protected override CouchbaseBuilder Init()
             .WithPortBinding(KvPort, true)
             .WithPortBinding(KvSslPort, true)
             .WithBucket(CouchbaseBucket.Default)
+            .WithConnectionStringProvider(new CouchbaseConnectionStringProvider())
             .WithStartupCallback(ConfigureCouchbaseAsync);
     }
 

src/Testcontainers.Couchbase/CouchbaseConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Couchbase;
+
+/// <summary>
+/// Provides the Couchbase connection string.
+/// </summary>
+internal sealed class CouchbaseConnectionStringProvider : ContainerConnectionStringProvider<CouchbaseContainer, CouchbaseConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.Db2/Db2Builder.cs

@@ -139,6 +139,7 @@ protected override Db2Builder Init() => base.Init()
         .WithUsername(DefaultUsername)
         .WithPassword(DefaultPassword)
         .WithPrivileged(true)
+        .WithConnectionStringProvider(new Db2ConnectionStringProvider())
         .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("Setup has completed."));
 
     /// <inheritdoc />

src/Testcontainers.Db2/Db2ConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Db2;
+
+/// <summary>
+/// Provides the Db2 connection string.
+/// </summary>
+internal sealed class Db2ConnectionStringProvider : ContainerConnectionStringProvider<Db2Container, Db2Configuration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.DynamoDb/DynamoDbBuilder.cs

@@ -75,6 +75,7 @@ protected override DynamoDbBuilder Init()
     {
         return base.Init()
             .WithPortBinding(DynamoDbPort, true)
+            .WithConnectionStringProvider(new DynamoDbConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilHttpRequestIsSucceeded(request =>
                 request.ForPath("/").ForPort(DynamoDbPort).ForStatusCode(HttpStatusCode.BadRequest)));
     }

src/Testcontainers.DynamoDb/DynamoDbConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.DynamoDb;
+
+/// <summary>
+/// Provides the DynamoDb connection string.
+/// </summary>
+internal sealed class DynamoDbConnectionStringProvider : ContainerConnectionStringProvider<DynamoDbContainer, DynamoDbConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.Elasticsearch/ElasticsearchBuilder.cs

@@ -107,7 +107,8 @@ protected override ElasticsearchBuilder Init()
             .WithPassword(DefaultPassword)
             .WithEnvironment("discovery.type", "single-node")
             .WithEnvironment("ingest.geoip.downloader.enabled", "false")
-            .WithResourceMapping(DefaultMemoryVmOption, ElasticsearchDefaultMemoryVmOptionFilePath);
+            .WithResourceMapping(DefaultMemoryVmOption, ElasticsearchDefaultMemoryVmOptionFilePath)
+            .WithConnectionStringProvider(new ElasticsearchConnectionStringProvider());
     }
 
     /// <inheritdoc />

src/Testcontainers.Elasticsearch/ElasticsearchConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.Elasticsearch;
+
+/// <summary>
+/// Provides the Elasticsearch connection string.
+/// </summary>
+internal sealed class ElasticsearchConnectionStringProvider : ContainerConnectionStringProvider<ElasticsearchContainer, ElasticsearchConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.EventHubs/EventHubsBuilder.cs

@@ -168,6 +168,7 @@ protected override EventHubsBuilder Init()
         return base.Init()
             .WithPortBinding(EventHubsPort, true)
             .WithPortBinding(EventHubsHttpPort, true)
+            .WithConnectionStringProvider(new EventHubsConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer()
                 // https://github.com/Azure/azure-event-hubs-emulator-installer/issues/69#issuecomment-3762895979.
                 .UntilMessageIsLogged("Emulator Service is Successfully Up!")

src/Testcontainers.EventHubs/EventHubsConnectionStringProvider.cs

@@ -0,0 +1,13 @@
+namespace Testcontainers.EventHubs;
+
+/// <summary>
+/// Provides the Event Hubs connection string.
+/// </summary>
+internal sealed class EventHubsConnectionStringProvider : ContainerConnectionStringProvider<EventHubsContainer, EventHubsConfiguration>
+{
+    /// <inheritdoc />
+    protected override string GetHostConnectionString()
+    {
+        return Container.GetConnectionString();
+    }
+}

src/Testcontainers.FakeGcsServer/FakeGcsServerBuilder.cs

@@ -79,6 +79,7 @@ protected override FakeGcsServerBuilder Init()
             .WithPortBinding(FakeGcsServerPort, true)
             .WithEntrypoint("/bin/sh", "-c")
             .WithCommand("while [ ! -f " + StartupScriptFilePath + " ]; do sleep 0.1; done; " + StartupScriptFilePath)
+            .WithConnectionStringProvider(new FakeGcsServerConnectionStringProvider())
             .WithWaitStrategy(Wait.ForUnixContainer().UntilMessageIsLogged("server started"))
             .WithStartupCallback((container, ct) =>
             {