FarmBot/Farmbot-Web-App

import { store } from "../redux/store";
import { networkUp, networkDown } from "./actions";
import { Edge } from "./interfaces";
import { Actions } from "../constants";
import { UnknownAction } from "redux";

/* ABOUT THIS FILE: These functions allow us to mark the network as up or
down from anywhere within the app (even outside of React-Redux). I usually avoid
directly importing `store`, but in this particular instance it might be
unavoidable. */

/** throttle calls to these functions to avoid unnecessary re-paints. */
const SLOWDOWN_TIME = 1500;

export const networkUptimeThrottleStats: Record<Edge, number> = {
  "user.api": 0,
  "user.mqtt": 0,
  "bot.mqtt": 0
};

function shouldThrottle(edge: Edge, now: number): boolean {
  if (edge === "bot.mqtt") {
    return true; // Let PING_OK / PING_NO handle bot.mqtt stuff.
  }
  const then = networkUptimeThrottleStats[edge];
  const diff = now - then;
  return diff < SLOWDOWN_TIME;
}

function bumpThrottle(edge: Edge, now: number) {
  networkUptimeThrottleStats[edge] = now;
}

export const dispatchQosStart = (id: string) => {
  store.dispatch({
    type: Actions.PING_START,
    payload: { id }
  });
};

export const dispatchNetworkUp = (edge: Edge, at: number) => {
  if (shouldThrottle(edge, at)) { return; }
  store.dispatch(networkUp(edge, at) as unknown as UnknownAction);
  bumpThrottle(edge, at);
};

export const dispatchNetworkDown = (edge: Edge, at: number) => {
  if (shouldThrottle(edge, at)) { return; }
  store.dispatch(networkDown(edge, at) as unknown as UnknownAction);
  bumpThrottle(edge, at);
};

export const pingOK = (id: string, at: number) => {
  const action = { type: Actions.PING_OK, payload: { id, at } };
  store.dispatch(action);
};

export const pingNO = (id: string, at: number) => {
  const action = { type: Actions.PING_NO, payload: { id, at } };
  store.dispatch(action);
};