feat(app-load-balancing): add start and stop polling and listen to st…

…atus

packages/game-app/src/gameView/components/GameView/GameView.tsx

@@ -13,6 +13,7 @@ import { PanelMode } from '../DeckPanel/DeckPanel';
 import TopWidgetsRow from '../TopWidgetsRow';
 import ZoomPanContainer from '../ZoomPanContainer';
 import ZoomPanContext from '../ZoomPanContext';
+import useStopPollingOnlineStatus from '../../hooks/useStopPollingOnlineStatus';
 
 type GameProps = {
   zoomIn: () => void;
@@ -42,6 +43,8 @@ const GameView: React.FC<GameProps> = ({ zoomIn, zoomOut }) => {
     setBackGround(s => !s);
   }, []);
 
+  useStopPollingOnlineStatus();
+
   return (
     <ZoomPanContext initialPan={initialPan}>
       <CardsGameListeners panelModeRef={panelModeRef} onEvent={onCardEvent} currentGameState={state}>

packages/game-app/src/gameView/hooks/useStopPollingOnlineStatus.ts

@@ -0,0 +1,16 @@
+import { batch, useDispatch } from 'react-redux';
+import { actions as loadBalancerActions } from '../../loadBalancer/slice';
+import { useEffect } from 'react';
+
+export default function useStopPollingOnlineStatus() {
+  const dispatch = useDispatch();
+
+  useEffect(() => {
+    return () => {
+      batch(() => {
+        dispatch(loadBalancerActions.stopPollingOnlineStatus());
+        dispatch(loadBalancerActions.stopListenToOnlineStatus());
+      });
+    };
+  }, [dispatch]);
+}

packages/game-app/src/loadBalancer/sagas/index.ts

@@ -5,7 +5,8 @@ import {
   stopListenToOnlineStatusSaga,
   updateOnlineStatusSaga,
   watchStatusChannel,
-} from './updateOnlineStatus';
+  startPolling,
+} from './loadBalancer';
 import { all } from 'redux-saga/effects';
 
 export default function* loadBalancerSaga() {
@@ -16,5 +17,6 @@ export default function* loadBalancerSaga() {
     stopListenToOnlineStatusSaga(),
     pollUpdateStatusSagaWatcher(),
     watchStatusChannel(),
+    startPolling(),
   ]);
 }

packages/game-app/src/loadBalancer/sagas/loadBalancer.ts

@@ -96,3 +96,12 @@ function* executeInitializeRTDB(action: ReturnType<typeof loadGameActions.saveGa
 export function* initializeRTDB() {
   yield takeEvery(loadGameActions.saveGame, executeInitializeRTDB);
 }
+
+function* executeStartPolling(action: ReturnType<typeof actions.updateRTDB>) {
+  yield put(actions.startPollingOnlineStatus());
+  yield put(actions.startListenToOnlineStatus());
+}
+
+export function* startPolling() {
+  yield takeEvery(actions.updateRTDB, executeStartPolling);
+}