doFetchActiveLivestreams: add interval check

- Added a default minimum of 5 minutes between fetches. Clients can bypass this through `forceFetch` if needed.

flow-typed/livestream.js

@@ -26,6 +26,7 @@ declare type LivestreamState = {
   viewersById: {},
   fetchingActiveLivestreams: boolean,
   activeLivestreams: ?LivestreamInfo,
+  lastFetchedActiveLivestreams: number,
 }
 
 declare type LivestreamInfo = {

ui/constants/action_types.js

@@ -354,4 +354,5 @@ export const FETCH_NO_SOURCE_CLAIMS_FAILED = 'FETCH_NO_SOURCE_CLAIMS_FAILED';
 export const VIEWERS_RECEIVED = 'VIEWERS_RECEIVED';
 export const FETCH_ACTIVE_LIVESTREAMS_STARTED = 'FETCH_ACTIVE_LIVESTREAMS_STARTED';
 export const FETCH_ACTIVE_LIVESTREAMS_FAILED = 'FETCH_ACTIVE_LIVESTREAMS_FAILED';
+export const FETCH_ACTIVE_LIVESTREAMS_SKIPPED = 'FETCH_ACTIVE_LIVESTREAMS_SKIPPED';
 export const FETCH_ACTIVE_LIVESTREAMS_COMPLETED = 'FETCH_ACTIVE_LIVESTREAMS_COMPLETED';

ui/redux/actions/livestream.js

@@ -33,19 +33,26 @@ export const doFetchNoSourceClaims = (channelId: string) => async (dispatch: Dis
   }
 };
 
-export const doFetchActiveLivestreams = () => {
+const FETCH_ACTIVE_LIVESTREAMS_MIN_INTERVAL_MS = 5 * 60 * 1000;
-  return async (dispatch: Dispatch) => {
+
-    dispatch({
+export const doFetchActiveLivestreams = (forceFetch: boolean) => {
-      type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_STARTED,
+  return async (dispatch: Dispatch, getState: GetState) => {
-    });
+    const state = getState();
+    const now = Date.now();
+    const timeDelta = now - state.livestream.lastFetchedActiveLivestreams;
+
+    if (!forceFetch && timeDelta < FETCH_ACTIVE_LIVESTREAMS_MIN_INTERVAL_MS) {
+      dispatch({ type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_SKIPPED });
+      return;
+    }
+
+    dispatch({ type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_STARTED });
 
     fetch(LIVESTREAM_LIVE_API)
       .then((res) => res.json())
       .then((res) => {
         if (!res.data) {
-          dispatch({
+          dispatch({ type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_FAILED });
-            type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_FAILED,
-          });
           return;
         }
 
@@ -88,19 +95,18 @@ export const doFetchActiveLivestreams = () => {
 
             dispatch({
               type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_COMPLETED,
-              data: activeLivestreams,
+              data: {
+                activeLivestreams,
+                lastFetchedActiveLivestreams: now,
+              },
             });
           })
           .catch(() => {
-            dispatch({
+            dispatch({ type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_FAILED });
-              type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_FAILED,
-            });
           });
       })
       .catch((err) => {
-        dispatch({
+        dispatch({ type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_FAILED });
-          type: ACTIONS.FETCH_ACTIVE_LIVESTREAMS_FAILED,
-        });
       });
   };
 };

ui/redux/reducers/livestream.js

@@ -7,6 +7,7 @@ const defaultState: LivestreamState = {
   viewersById: {},
   fetchingActiveLivestreams: false,
   activeLivestreams: null,
+  lastFetchedActiveLivestreams: 0,
 };
 
 export default handleActions(
@@ -45,8 +46,13 @@ export default handleActions(
       return { ...state, fetchingActiveLivestreams: false };
     },
     [ACTIONS.FETCH_ACTIVE_LIVESTREAMS_COMPLETED]: (state: LivestreamState, action: any) => {
-      const activeLivestreams: LivestreamInfo = action.data;
+      const { activeLivestreams, lastFetchedActiveLivestreams } = action.data;
-      return { ...state, fetchingActiveLivestreams: false, activeLivestreams };
+      return {
+        ...state,
+        fetchingActiveLivestreams: false,
+        activeLivestreams,
+        lastFetchedActiveLivestreams,
+      };
     },
   },
   defaultState