corefx got throughput working using grpc, removed unused session nodes menu option

corefx/src/main/java/com/core/Controller.java

@@ -400,11 +400,6 @@ public class Controller implements Initializable {
         }
     }
 
-    @FXML
-    private void onSessionNodesMenu(ActionEvent event) {
-
-    }
-
     @FXML
     private void onSessionHooksMenu(ActionEvent event) {
         hooksDialog.showDialog();
@@ -505,7 +500,7 @@ public class Controller implements Initializable {
         @Override
         protected Boolean call() throws Exception {
             if (throughputMenuItem.isSelected()) {
-                return coreClient.startThroughput();
+                return coreClient.startThroughput(Controller.this);
             } else {
                 return coreClient.stopThroughput();
             }

corefx/src/main/java/com/core/client/ICoreClient.java

@@ -19,7 +19,7 @@ public interface ICoreClient {
 
     Integer currentSession();
 
-    boolean startThroughput() throws IOException;
+    boolean startThroughput(Controller controller) throws IOException;
 
     boolean stopThroughput() throws IOException;
 

corefx/src/main/java/com/core/client/grpc/CoreGrpcClient.java

@@ -7,6 +7,7 @@ import com.core.client.rest.WlanConfig;
 import com.core.data.*;
 import com.core.ui.dialogs.MobilityPlayerDialog;
 import com.google.protobuf.ByteString;
+import io.grpc.Context;
 import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;
 import io.grpc.StatusRuntimeException;
@@ -31,6 +32,7 @@ public class CoreGrpcClient implements ICoreClient {
     private ManagedChannel channel;
     private final ExecutorService executorService = Executors.newFixedThreadPool(6);
     private boolean handlingEvents = false;
+    private boolean handlingThroughputs = false;
 
     private CoreProto.Node nodeToProto(CoreNode node) {
         CoreProto.Position position = CoreProto.Position.newBuilder()
@@ -226,15 +228,54 @@ public class CoreGrpcClient implements ICoreClient {
     }
 
     @Override
-    public boolean startThroughput() throws IOException {
+    public boolean startThroughput(Controller controller) throws IOException {
-        // TODO: convert throughput
+        CoreProto.ThroughputsRequest request = CoreProto.ThroughputsRequest.newBuilder().build();
-        return false;
+        try {
+            handlingThroughputs = true;
+            executorService.submit(() -> {
+                Context.CancellableContext context = Context.current().withCancellation();
+                context.run(() -> {
+                    try {
+                        Iterator<CoreProto.ThroughputsEvent> iterator = blockingStub.throughputs(request);
+                        while (handlingThroughputs) {
+                            CoreProto.ThroughputsEvent event = iterator.next();
+                            logger.info("handling throughputs: {}", event);
+                            Throughputs throughputs = new Throughputs();
+                            for (CoreProto.BridgeThroughput protoBridge : event.getBridgeThroughputsList()) {
+                                BridgeThroughput bridge = new BridgeThroughput();
+                                bridge.setNode(protoBridge.getNodeId());
+                                bridge.setThroughput(protoBridge.getThroughput());
+                                throughputs.getBridges().add(bridge);
+                            }
+                            for (CoreProto.InterfaceThroughput protoInterface : event.getInterfaceThroughputsList()) {
+                                InterfaceThroughput interfaceThroughput = new InterfaceThroughput();
+                                interfaceThroughput.setNode(protoInterface.getNodeId());
+                                interfaceThroughput.setNodeInterface(protoInterface.getInterfaceId());
+                                interfaceThroughput.setThroughput(protoInterface.getThroughput());
+                                throughputs.getInterfaces().add(interfaceThroughput);
+                            }
+                            controller.handleThroughputs(throughputs);
+                        }
+                        logger.info("exiting handling throughputs");
+                    } catch (StatusRuntimeException ex) {
+                        logger.error("error handling session events", ex);
+                    } finally {
+                        context.cancel(null);
+                        context.close();
+                    }
+                });
+            });
+            return true;
+        } catch (StatusRuntimeException ex) {
+            throw new IOException("setup event handlers error", ex);
+        }
     }
 
     @Override
     public boolean stopThroughput() throws IOException {
-        // TODO: convert throughput
+        logger.info("cancelling throughputs");
-        return false;
+        handlingThroughputs = false;
+        return true;
     }
 
     @Override

corefx/src/main/java/com/core/client/rest/CoreRestClient.java

@@ -149,7 +149,7 @@ public class CoreRestClient implements ICoreClient {
     }
 
     @Override
-    public boolean startThroughput() throws IOException {
+    public boolean startThroughput(Controller controller) throws IOException {
         String url = getUrl("throughput/start");
         return WebUtils.putJson(url);
     }

corefx/src/main/resources/fxml/main.fxml

@@ -35,7 +35,6 @@
                         </Menu>
                         <Menu mnemonicParsing="false" text="Session">
                           <items>
-                              <MenuItem mnemonicParsing="false" onAction="#onSessionNodesMenu" text="Nodes" />
                               <MenuItem mnemonicParsing="false" onAction="#onSessionHooksMenu" text="Hooks" />
                               <MenuItem mnemonicParsing="false" onAction="#onOptionsMenuLocation" text="Location" />
                               <MenuItem mnemonicParsing="false" onAction="#onOptionsMenuBackground" text="Background" />