Add IS_LOCAL to /metadata/endpoints response (fixes #372) (#373)

Author: olim7t

management-api-agent-3.x/src/main/java/com/datastax/mgmtapi/shim/CassandraAPI3x.java

@@ -218,10 +218,12 @@ public List<Map<String, String>> getEndpointStates() {
         states.put(s.getKey().name(), value);
       }
 
-      states.put("ENDPOINT_IP", entry.getKey().getHostAddress());
+      InetAddress endpoint = entry.getKey();
+      states.put("ENDPOINT_IP", endpoint.getHostAddress());
       states.put("IS_ALIVE", Boolean.toString(entry.getValue().isAlive()));
       states.put("PARTITIONER", partitioner.getClass().getName());
       states.put("CLUSTER_NAME", getStorageService().getClusterName());
+      states.put("IS_LOCAL", Boolean.toString(endpoint.equals(FBUtilities.getBroadcastAddress())));
 
       result.add(states);
     }

management-api-agent-4.1.x/src/main/java/com/datastax/mgmtapi/shim/CassandraAPI41x.java

@@ -256,6 +256,8 @@ public List<Map<String, String>> getEndpointStates() {
       states.put("IS_ALIVE", Boolean.toString(state.isAlive()));
       states.put("PARTITIONER", partitioner.getClass().getName());
       states.put("CLUSTER_NAME", getStorageService().getClusterName());
+      states.put(
+          "IS_LOCAL", Boolean.toString(endpoint.equals(FBUtilities.getBroadcastAddressAndPort())));
       result.add(states);
     }
 

management-api-agent-4.x/src/main/java/com/datastax/mgmtapi/shim/CassandraAPI4x.java

@@ -256,6 +256,8 @@ public List<Map<String, String>> getEndpointStates() {
       states.put("IS_ALIVE", Boolean.toString(state.isAlive()));
       states.put("PARTITIONER", partitioner.getClass().getName());
       states.put("CLUSTER_NAME", getStorageService().getClusterName());
+      states.put(
+          "IS_LOCAL", Boolean.toString(endpoint.equals(FBUtilities.getBroadcastAddressAndPort())));
       result.add(states);
     }
 

management-api-agent-5.0.x/src/main/java/com/datastax/mgmtapi/shim/CassandraAPI50x.java

@@ -256,6 +256,8 @@ public List<Map<String, String>> getEndpointStates() {
       states.put("IS_ALIVE", Boolean.toString(state.isAlive()));
       states.put("PARTITIONER", partitioner.getClass().getName());
       states.put("CLUSTER_NAME", getStorageService().getClusterName());
+      states.put(
+          "IS_LOCAL", Boolean.toString(endpoint.equals(FBUtilities.getBroadcastAddressAndPort())));
       result.add(states);
     }
 

management-api-agent-dse-6.8/src/main/java/com/datastax/mgmtapi/shim/DseAPI68.java

@@ -230,6 +230,7 @@ public List<Map<String, String>> getEndpointStates() {
       states.put("IS_ALIVE", Boolean.toString(state.isAlive()));
       states.put("PARTITIONER", partitioner.getClass().getName());
       states.put("CLUSTER_NAME", getStorageService().getClusterName());
+      states.put("IS_LOCAL", Boolean.toString(endpoint.equals(FBUtilities.getBroadcastAddress())));
       result.add(states);
     }
 

management-api-agent-dse7/src/main/java/com/datastax/mgmtapi/shim/CassandraAPIDse7.java

@@ -256,6 +256,8 @@ public List<Map<String, String>> getEndpointStates() {
       states.put("IS_ALIVE", Boolean.toString(state.isAlive()));
       states.put("PARTITIONER", partitioner.getClass().getName());
       states.put("CLUSTER_NAME", getStorageService().getClusterName());
+      states.put(
+          "IS_LOCAL", Boolean.toString(endpoint.equals(FBUtilities.getBroadcastAddressAndPort())));
       result.add(states);
     }
 

management-api-server/src/test/java/com/datastax/mgmtapi/NonDestructiveOpsIT.java

@@ -350,6 +350,7 @@ public void testGetEndpoints() throws IOException, URISyntaxException {
     Map<String, String> endpoint = entity.get(0);
     assertThat(endpoint.get("PARTITIONER")).endsWith("Murmur3Partitioner");
     assertThat(endpoint.get("CLUSTER_NAME")).matches("Test Cluster");
+    assertThat(endpoint.get("IS_LOCAL")).isEqualTo("true");
     Iterable<String> tokens = Splitter.on(",").split(endpoint.get("TOKENS"));
     assertThat(tokens)
         .allSatisfy(