JCBC-2199 :- improve cluster.toString()

	cluster.toString() current returns something useless like com.couchbase.client.java.Cluster@138a7441.

	Improve this behavior, so cluster.toString() returns the same information we see in the logs for a CoreCreatedEvent. So, something like:

	Cluster{"clientVersion":"3.9.0-SNAPSHOT", etc...}

Change-Id: Ibe4e8082e9b699798060dd543159b22527d55c68
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/229655
Reviewed-by: David Nault <[email protected]>
Tested-by: Build Bot <[email protected]>

Author: CosmicSaaurabh

java-client/src/main/java/com/couchbase/client/java/AsyncCluster.java

@@ -23,8 +23,10 @@
 import com.couchbase.client.core.api.search.CoreSearchOps;
 import com.couchbase.client.core.api.search.CoreSearchQuery;
 import com.couchbase.client.core.api.search.queries.CoreSearchRequest;
+import com.couchbase.client.core.cnc.Context;
 import com.couchbase.client.core.cnc.RequestSpan;
 import com.couchbase.client.core.cnc.TracingIdentifiers;
+import com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode;
 import com.couchbase.client.core.diagnostics.ClusterState;
 import com.couchbase.client.core.diagnostics.DiagnosticsResult;
 import com.couchbase.client.core.diagnostics.EndpointDiagnostics;
@@ -41,6 +43,7 @@
 import com.couchbase.client.core.error.context.ReducedAnalyticsErrorContext;
 import com.couchbase.client.core.error.context.ReducedQueryErrorContext;
 import com.couchbase.client.core.error.context.ReducedSearchErrorContext;
+import com.couchbase.client.core.json.Mapper;
 import com.couchbase.client.core.msg.analytics.AnalyticsRequest;
 import com.couchbase.client.core.retry.RetryStrategy;
 import com.couchbase.client.core.util.ClusterCleanupTask;
@@ -151,6 +154,8 @@ public class AsyncCluster {
    */
   final CoreSearchOps searchOps;
 
+  final ConnectionString connectionString;
+
   /**
    * Connect to a Couchbase cluster with a username and a password as authentication credentials.
    *
@@ -225,6 +230,13 @@ static OwnedOrExternal<ClusterEnvironment> extractClusterEnvironment(final Conne
     return env;
   }
 
+  String clusterToStringHelper(Class clusterClass) {
+    String json = environment.get().exportAsString(Context.ExportFormat.JSON);
+    ObjectNode jsonObject = (ObjectNode) Mapper.decodeIntoTree(json);
+    jsonObject.put("connectionString", connectionString.original());
+    return clusterClass.getSimpleName() + jsonObject;
+  }
+
   /**
    * Creates a new cluster from a {@link ClusterEnvironment}.
    *
@@ -236,6 +248,7 @@ static OwnedOrExternal<ClusterEnvironment> extractClusterEnvironment(final Conne
     final ConnectionString connectionString
   ) {
     this.environment = environment;
+    this.connectionString = connectionString;
     this.couchbaseOps = CoreCouchbaseOps.create(environment.get(), authenticator, connectionString);
     this.authenticator = authenticator;
     this.queryOps = couchbaseOps.queryOps();
@@ -662,4 +675,9 @@ public CompletableFuture<Void> waitUntilReady(final Duration timeout, final Wait
     return couchbaseOps.waitUntilReady(opts.serviceTypes(), timeout, opts.desiredState(), null);
   }
 
+  @Override
+  public String toString() {
+    return clusterToStringHelper(getClass());
+  }
+
 }

java-client/src/main/java/com/couchbase/client/java/Cluster.java

@@ -703,5 +703,10 @@ public void close() {
     disconnect();
   }
 
+  @Override
+  public String toString() {
+    return asyncCluster.clusterToStringHelper(getClass());
+  }
+
 }
 

java-client/src/main/java/com/couchbase/client/java/ReactiveCluster.java

@@ -521,4 +521,9 @@ public Mono<Void> waitUntilReady(final Duration timeout, final WaitUntilReadyOpt
   public ReactiveTransactions transactions() {
     return new ReactiveTransactions(core(), environment().jsonSerializer());
   }
+
+  @Override
+  public String toString() {
+    return asyncCluster.clusterToStringHelper(getClass());
+  }
 }