commit df11ea8e4ec9fe2c460a6c409419e9e2ab823cc6
author Viswanath KSP <kspviswa.github@gmail.com> Tue Oct 25 01:15:16 2016 +0530
committer Gerrit Code Review <gerrit@onlab.us> Tue Oct 25 15:31:41 2016 +0000
tree 928cbee339a71fca6d4515f2470bbcdf3ac92a02
parent 9fcf970942e6f4d984a282924c4b1225532c8744

Pathset-1 pushing changes for onos-5472

Change-Id: If5960883d02375bff3f7b9e5a6092c58c123f5d4

web/gui/src/main/java/org/onosproject/ui/impl/ClusterViewMessageHandler.java

diff --git a/web/gui/src/main/java/org/onosproject/ui/impl/ClusterViewMessageHandler.java b/web/gui/src/main/java/org/onosproject/ui/impl/ClusterViewMessageHandler.java
index 6888951..ff94ff2 100644
--- a/web/gui/src/main/java/org/onosproject/ui/impl/ClusterViewMessageHandler.java
+++ b/web/gui/src/main/java/org/onosproject/ui/impl/ClusterViewMessageHandler.java
@@ -40,6 +40,10 @@
     private static final String CLUSTER_DATA_RESP = "clusterDataResponse";
     private static final String CLUSTERS = "clusters";
 
+    private static final String CLUSTER_DETAILS_REQ = "clusterNodeDetailsRequest";
+    private static final String CLUSTER_DETAILS_RESP = "clusterNodeDetailsResponse";
+    private static final String DETAILS = "details";
+
     private static final String ID = "id";
     private static final String IP = "ip";
     private static final String TCP_PORT = "tcp";
@@ -56,7 +60,9 @@
 
     @Override
     protected Collection<RequestHandler> createRequestHandlers() {
-        return ImmutableSet.of(new ClusterDataRequest());
+        return ImmutableSet.of(
+                new ClusterDataRequest(),
+                new DetailRequestHandler());
     }
 
     // handler for cluster table requests
@@ -108,4 +114,29 @@
                 .cell(UPDATED, lastUpdated);
         }
     }
+
+    private final class DetailRequestHandler extends RequestHandler {
+
+        public DetailRequestHandler() {
+            super(CLUSTER_DETAILS_REQ);
+        }
+
+        @Override
+        public void process(long sid, ObjectNode payload) {
+
+            String id = string(payload, ID);
+            ClusterService cs = get(ClusterService.class);
+            ControllerNode node = cs.getNode(new NodeId(id));
+
+            ObjectNode data = objectNode();
+            data.put(ID, node.id().toString());
+            data.put(IP, node.ip().toString());
+
+            //TODO put more detail info to data
+
+            ObjectNode rootNode = objectNode();
+            rootNode.set(DETAILS, data);
+            sendMessage(CLUSTER_DETAILS_RESP, rootNode);
+        }
+    }
 }