Close simulator connections on logout

src/containers/app.js

@@ -108,6 +108,8 @@ class App extends Component {
       localStorage.setItem('token', '');
 
       this.props.router.push('/login');
+      
+      return;
     }
 
     // open connection to each required simulator

src/data-managers/simulator-data-data-manager.js

@@ -34,6 +34,16 @@ class SimulatorDataDataManager {
     }
   }
 
+  closeAll() {
+    // close every open socket
+    for (var key in this._sockets) {
+      if (this._sockets.hasOwnProperty(key)) {
+        this._sockets[key].close(4000);
+        delete this._sockets[key];
+      }
+    }
+  }
+
   onOpen(event, identifier, signals, firstOpen) {
     AppDispatcher.dispatch({
       type: 'simulatorData/opened',
@@ -46,11 +56,12 @@ class SimulatorDataDataManager {
   onClose(event, identifier) {
     AppDispatcher.dispatch({
       type: 'simulatorData/closed',
-      identifier: identifier
+      identifier: identifier,
+      notification: (event.code !== 4000)
     });
 
     // remove from list, keep null reference for flag detection
-    this._sockets[identifier] = null;
+    delete this._sockets[identifier];
   }
 
   onMessage(event, identifier) {

src/stores/simulator-data-store.js

@@ -62,7 +62,7 @@ class SimulationDataStore extends ReduceStore {
           // explicit call to prevent array copy
           this.__emitChange();
         } else {
-          console.log('same sequence');
+          console.log('same sequence ' + state[action.identifier].sequence + ' ' + action.data.sequence);
         }
 
         return state;

src/stores/simulator-store.js

@@ -74,14 +74,16 @@ class SimulatorStore extends ArrayStore {
         // update running state
         simulator.running = false;
 
-        NotificationsDataManager.addNotification({
-          title: 'Simulator offline',
-          message: 'Simulator \'' + simulator.name + '\' went offline.',
-          level: 'info'
-        });
+        if (action.notification) {
+          NotificationsDataManager.addNotification({
+            title: 'Simulator offline',
+            message: 'Simulator \'' + simulator.name + '\' went offline.',
+            level: 'info'
+          });
 
-        // restart requesting again
-        SimulatorsDataManager.startRunningDetection(simulator);
+          // restart requesting again
+          SimulatorsDataManager.startRunningDetection(simulator);
+        }
 
         return this.updateElements(state, [ simulator ]);
 

src/stores/user-store.js

@@ -12,6 +12,7 @@ import { ReduceStore } from 'flux/utils';
 import AppDispatcher from '../app-dispatcher';
 import UsersDataManager from '../data-managers/users-data-manager';
 import NotificationsDataManager from '../data-managers/notifications-data-manager';
+import SimulatorDataDataManager from '../data-managers/simulator-data-data-manager';
 
 class UserStore extends ReduceStore {
   constructor() {
@@ -33,6 +34,9 @@ class UserStore extends ReduceStore {
         return state;
 
       case 'users/logout':
+        // disconnect from all simulators
+        SimulatorDataDataManager.closeAll();
+
         // delete user and token
         return Object.assign({}, state, { token: null });