Skip to content

Commit 23f8095

Browse files
committed
Use simple connection string for hosting health checks
1 parent 53ffa9e commit 23f8095

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

src/Couchbase.Aspire.Hosting/CouchbaseBucketBuilderExtensions.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,9 @@ private static IResourceBuilder<T> AddBucket<T>(this IResourceBuilder<CouchbaseC
6464
string? connectionString = null;
6565
builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(bucket.Cluster, async (@event, ct) =>
6666
{
67-
connectionString = await bucket.Cluster.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
67+
// Use the URI, not the connection string, since it is applied directly to ClusterOptions
68+
// The URI doesn't include the Aspire extensions for authentication
69+
connectionString = await bucket.Cluster.UriExpression.GetValueAsync(ct).ConfigureAwait(false);
6870

6971
if (connectionString is null)
7072
{

src/Couchbase.Aspire.Hosting/CouchbaseClusterBuilderExtensions.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,9 @@ public static IResourceBuilder<CouchbaseClusterResource> AddCouchbase(this IDist
6464
string? connectionString = null;
6565
builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(cluster, async (@event, ct) =>
6666
{
67-
connectionString = await cluster.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
67+
// Use the URI, not the connection string, since it is applied directly to ClusterOptions
68+
// The URI doesn't include the Aspire extensions for authentication
69+
connectionString = await cluster.UriExpression.GetValueAsync(ct).ConfigureAwait(false);
6870

6971
if (connectionString is null)
7072
{

0 commit comments

Comments
 (0)