Add Grakn Cluster support (#111)

## What is the goal of this PR?

We have added Grakn Cluster support. A user can connect to a cluster of Grakn Cluster instances using the `--cluster` flag:

```
./grakn console --cluster 172.0.01:1729
```

## What are the changes implemented in this PR?

- Adds a new flag `--cluster` for connecting to Grakn Cluster
- Update client-java to the version which supports Grakn Cluster

Author: Ganeshwara Hananda

.grabl/automation.yml

@@ -47,7 +47,7 @@ build:
         export ARTIFACT_PASSWORD=$REPO_GRAKN_PASSWORD
         bazel run @graknlabs_dependencies//distribution/artifact:create-netrc
         bazel run @graknlabs_dependencies//tool/checkstyle:test-coverage
-        bazel build --config=rbe //...
+        bazel build //...
         dependencies/maven/update.sh
         git diff --exit-code dependencies/maven/artifacts.snapshot
     deploy-artifact-snapshot:

GraknConsole.java

@@ -18,28 +18,29 @@
 package grakn.console;
 
 import grakn.client.Grakn;
+import grakn.client.GraknClient;
 import grakn.client.common.exception.GraknClientException;
 import grakn.client.concept.answer.ConceptMap;
 import grakn.client.concept.answer.ConceptMapGroup;
 import grakn.client.concept.answer.Numeric;
 import grakn.client.concept.answer.NumericGroup;
-import grakn.client.GraknClient;
 import graql.lang.Graql;
 import graql.lang.common.exception.GraqlException;
-import graql.lang.query.GraqlQuery;
+import graql.lang.query.GraqlCompute;
 import graql.lang.query.GraqlDefine;
-import graql.lang.query.GraqlUndefine;
-import graql.lang.query.GraqlInsert;
 import graql.lang.query.GraqlDelete;
+import graql.lang.query.GraqlInsert;
 import graql.lang.query.GraqlMatch;
-import graql.lang.query.GraqlCompute;
+import graql.lang.query.GraqlQuery;
+import graql.lang.query.GraqlUndefine;
 import org.jline.reader.LineReader;
 import org.jline.reader.LineReaderBuilder;
 import org.jline.terminal.Terminal;
 import org.jline.terminal.TerminalBuilder;
 import org.jline.utils.InfoCmp;
 import picocli.CommandLine;
 
+import javax.annotation.Nullable;
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
@@ -53,8 +54,8 @@
 public class GraknConsole {
     private static final String COPYRIGHT =
             "\n" +
-            "Welcome to Grakn Console. You are now in Grakn Wonderland!\n" +
-            "Copyright (C) 2021 Grakn Labs\n";
+                    "Welcome to Grakn Console. You are now in Grakn Wonderland!\n" +
+                    "Copyright (C) 2021 Grakn Labs\n";
     private final CommandLineOptions options;
     private final Printer printer;
     private Terminal terminal;
@@ -72,13 +73,25 @@ public GraknConsole(CommandLineOptions options, Printer printer) {
 
     public void run() {
         printer.info(COPYRIGHT);
-        try (Grakn.Client client = new GraknClient(options.address())) {
+        try (Grakn.Client client = createGraknClient(options)) {
             runRepl(client);
         } catch (GraknClientException e) {
             printer.error(e.getMessage());
         }
     }
 
+    private Grakn.Client createGraknClient(CommandLineOptions options) {
+        Grakn.Client client;
+        if (options.server() != null) {
+            client = GraknClient.core(options.server());
+        } else if (options.cluster() != null) {
+            client = GraknClient.cluster(options.cluster());
+        } else {
+            client = GraknClient.core();
+        }
+        return client;
+    }
+
     private void runRepl(Grakn.Client client) {
         LineReader reader = LineReaderBuilder.builder()
                 .terminal(terminal)
@@ -263,13 +276,25 @@ private static CommandLineOptions parseCommandLine(String[] args) {
 
     @CommandLine.Command(name = "grakn console", mixinStandardHelpOptions = true, version = {grakn.console.Version.VERSION})
     public static class CommandLineOptions {
+
         @CommandLine.Option(names = {"--server"},
-                defaultValue = GraknClient.DEFAULT_URI,
-                description = "Server address to which the console will connect to")
-        private String address;
+                description = "Grakn Core address to which Console will connect to")
+        private @Nullable
+        String server;
+
+        @Nullable
+        public String server() {
+            return server;
+        }
+
+        @CommandLine.Option(names = {"--cluster"},
+                description = "Grakn Cluster address to which Console will connect to")
+        private @Nullable
+        String cluster;
 
-        public String address() {
-            return address;
+        @Nullable
+        public String cluster() {
+            return cluster;
         }
     }
 }

common/Printer.java

@@ -28,8 +28,8 @@
 import grakn.client.concept.thing.Thing;
 import grakn.client.concept.type.RoleType;
 import grakn.client.concept.type.Type;
-import graql.lang.pattern.variable.Reference;
 import graql.lang.common.GraqlToken;
+import graql.lang.pattern.variable.Reference;
 import org.jline.utils.AttributedString;
 import org.jline.utils.AttributedStyle;
 
@@ -60,7 +60,7 @@ public void conceptMap(ConceptMap conceptMap, Grakn.Transaction tx) {
     }
 
     public void conceptMapGroup(ConceptMapGroup answer, Grakn.Transaction tx) {
-        for (ConceptMap conceptMap: answer.conceptMaps()) {
+        for (ConceptMap conceptMap : answer.conceptMaps()) {
             out.println(conceptDisplayString(answer.owner(), tx) + " => " + conceptMapDisplayString(conceptMap, tx));
         }
     }
@@ -76,7 +76,7 @@ public void numericGroup(NumericGroup answer, Grakn.Transaction tx) {
     private String conceptMapDisplayString(ConceptMap conceptMap, Grakn.Transaction tx) {
         StringBuilder sb = new StringBuilder();
         sb.append("{ ");
-        for (Map.Entry<String, Concept> entry: conceptMap.map().entrySet()) {
+        for (Map.Entry<String, Concept> entry : conceptMap.map().entrySet()) {
             Reference.Name variable = Reference.named(entry.getKey());
             Concept concept = entry.getValue();
             sb.append(variable.syntax());

conf/logback/logback.xml

@@ -15,5 +15,5 @@
   ~ along with this program.  If not, see <https://www.gnu.org/licenses/>.
   -->
 <configuration debug="false">
-    <root level="OFF" />
+    <root level="OFF"/>
 </configuration>

dependencies/graknlabs/repositories.bzl

@@ -35,5 +35,5 @@ def graknlabs_client_java():
     git_repository(
         name = "graknlabs_client_java",
         remote = "https://github.com/graknlabs/client-java",
-        commit = "0ae01423da842b47669929975d50de307567fc2e",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @graknlabs_client_java
+        commit = "d41db8972e07b5574482b008137ad152f38e919f",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @graknlabs_client_java
     )