implemented new connection listening - helps a lot for the app and its ui

Author: thsc42

src/main/java/net/sharksystem/hub/HubConnectionManager.java

@@ -10,7 +10,7 @@
 /**
  * Interface for applications. It allows connection management with hubs.
  */
-public interface HubConnectionManager {
+public interface HubConnectionManager extends NewHubConnectionListenerManagement {
     /**
      * Connect a hub
      * @param hcd Hub description

src/main/java/net/sharksystem/hub/HubConnectionManagerImpl.java

@@ -9,8 +9,11 @@
 
 import java.io.IOException;
 
+/**
+ * That class merges encounter and asap hub management
+ */
 public class HubConnectionManagerImpl extends BasicHubConnectionManager
-        implements HubConnectionManager, HubConnectionManagerMessageHandler {
+        implements HubConnectionManagerMessageHandler {
     private final ASAPPeer asapPeer;
     private ASAPHubManagerImpl hubManager;
 
@@ -40,6 +43,20 @@ public HubConnector getHubConnector(HubConnectorDescription hcd) throws SharkExc
     }
 
     private Thread hubManangerThread = null;
+
+    //////////////// hub new connection listener management
+    public void addNewConnectedHubListener(NewHubConnectedListener connectedHubListener) {
+        if(this.hubManager != null) {
+            this.hubManager.addNewConnectedHubListener(connectedHubListener);
+        }
+    }
+
+    public void removeNewConnectedHubListener(NewHubConnectedListener connectedHubListener) {
+        if(this.hubManager != null) {
+            this.hubManager.removeNewConnectedHubListener(connectedHubListener);
+        }
+    }
+
     public HubConnectionManagerImpl(
             ASAPEncounterManager encounterManager, ASAPPeer asapPeer, int waitIntervalInSeconds) {
         this.asapPeer = asapPeer;

src/main/java/net/sharksystem/hub/NewHubConnectedListener.java

@@ -0,0 +1,7 @@
+package net.sharksystem.hub;
+
+import net.sharksystem.hub.peerside.HubConnectorDescription;
+
+public interface NewHubConnectedListener {
+    void newHubConnected(HubConnectorDescription hcd);
+}

src/main/java/net/sharksystem/hub/NewHubConnectionListenerManagement.java

@@ -0,0 +1,6 @@
+package net.sharksystem.hub;
+
+public interface NewHubConnectionListenerManagement {
+    void addNewConnectedHubListener(NewHubConnectedListener connectedHubListener);
+    void removeNewConnectedHubListener(NewHubConnectedListener connectedHubListener);
+}

src/main/java/net/sharksystem/hub/peerside/ASAPHubManagerImpl.java

@@ -2,7 +2,7 @@
 
 import net.sharksystem.SharkException;
 import net.sharksystem.asap.*;
-import net.sharksystem.hub.Connector;
+import net.sharksystem.hub.*;
 import net.sharksystem.utils.AlarmClock;
 import net.sharksystem.utils.AlarmClockListener;
 import net.sharksystem.utils.Log;
@@ -11,7 +11,8 @@
 import java.io.IOException;
 import java.util.*;
 
-public class ASAPHubManagerImpl implements ASAPHubManager, Runnable, NewConnectionListener, AlarmClockListener,
+public class ASAPHubManagerImpl implements ASAPHubManager, NewHubConnectionListenerManagement,
+        Runnable, NewConnectionListener, AlarmClockListener,
         HubConnectorStatusListener {
     private static final int FORCE_NEW_ROUND_KEY = 1;
     private final ASAPEncounterManager asapEncounterManager;
@@ -135,6 +136,29 @@ public HubConnector getHubConnector(HubConnectorDescription hcd) throws SharkExc
         throw new SharkException("no connection to described hub available");
     }
 
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////
+    //                                 new hub connector listener management                              //
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////
+    private Set<NewHubConnectedListener> connectedHubListenerList = new HashSet<>();
+    public void addNewConnectedHubListener(NewHubConnectedListener connectedHubListener) {
+        this.connectedHubListenerList.add(connectedHubListener);
+    }
+
+    public void removeNewConnectedHubListener(NewHubConnectedListener connectedHubListener) {
+        this.connectedHubListenerList.remove(connectedHubListener);
+    }
+
+    private void notifyNewHubConnectionListener(HubConnectorDescription hcd) {
+        for(NewHubConnectedListener connectedHubListener : this.connectedHubListenerList) {
+            connectedHubListener.newHubConnected(hcd);
+        }
+    }
+
+    private void hubConnectorStarted(HubConnectorDescription hcd) {
+        this.runningConnectorDescriptions.add(hcd);
+        this.notifyNewHubConnectionListener(hcd);
+    }
+
     public void connectASAPHubs(Collection<HubConnectorDescription> descriptions,
                                 ASAPPeer asapPeer, boolean killConnectionIfNotInList) {
         // for each description
@@ -164,7 +188,8 @@ public void run() {
                             Log.writeLog(ASAPHubManagerImpl.this,ASAPHubManagerImpl.this.toString(),
                                     "hub connector initialized: " + hcd);
                             // remember - it is running now
-                            ASAPHubManagerImpl.this.runningConnectorDescriptions.add(hcd);
+//                            ASAPHubManagerImpl.this.runningConnectorDescriptions.add(hcd);
+                            ASAPHubManagerImpl.this.hubConnectorStarted(hcd);
                         } catch (IOException | ASAPException e) {
                             Log.writeLog(ASAPHubManagerImpl.this,ASAPHubManagerImpl.this.toString(),
                                     "cannot create hub connector: " + e.getLocalizedMessage());