Source: data/WatcherOqt.js

  1. import React, { useContext, useEffect } from "react";
  2. import { useReactorNavigation, booleanString, SignalRContext, useHooks } from "../..";
  3. import { useCallback } from "react";
  4. const signalR = require("@microsoft/signalr");
  6. /**
  7.  * Componente que crea una subscripcion SignalR al renderizarse y la desubscripcion al desmontarse del DOM, 
  8.  * y llama a uno o varios hooks al producirse un cambio en el monitor que va a observar
  9.  * @name Reactor.Components.Data.WatcherOqt
  10.  * @param {string} monitor Nombre del monitor
  11.  * @param {string} hooks Nombre de los hooks que se van a llamar al producirse un cambio
  12.  * @param {string} [delay = null] Tiempo de espera antes de subscribirse en ms 
  13.  * @param {BooleanString} [silent = "true"] Establece modo silencioso (no usa spinner) 
  14.  * @param {BooleanString} [debug = "false"] 
  15.  * @class
  16.  * @example
  17. <signalr url="http://www.orquesta.com.ar/signalr"> 
  18.   <watcher monitor="mensajes" hooks="ActualizarMensajes"></watcher>
  19.   <div>
  20.     ...lista de mensajes
  21.   </div>
  22. </signalr>
  23. */
  25. const WatcherOqt = ({monitor, hooks, silent = "true", delay = "", debug = "false", children}) => {
  27.   const { subscribe, unsubscribe } = useContext(SignalRContext);
  28.   const { procesarHooks } = useHooks({silent, hooks, debug});
  30.   const callback = useCallback(() => {
  31.     booleanString(debug) && console.log("Watcher", {event: "execute callback", delay, monitor, hooks})
  32.     procesarHooks();
  33.   }, [procesarHooks]);
  35.   const reconnectCallback = useCallback(() => {
  36.     booleanString(debug) && console.log("Watcher", {event: "execute reconnect callback", delay, monitor, hooks})
  37.     subscribe({monitor, callback, reconnectCallback});
  38.   }, [monitor, callback]);
  40.   useEffect(()=>{
  41.     booleanString(debug) && console.log("Watcher", {event: "subscribe", delay, monitor, hooks})
  42.     let timer = 0;
  43.     if (delay !== undefined && delay !== 0 && delay !== "0"){
  44.       timer = setTimeout(
  45.         () => subscribe({monitor, callback, reconnectCallback}), 
  46.         delay * 1
  47.       );
  48.     }else{
  49.       subscribe({monitor, callback, reconnectCallback});
  50.     }
  51.     return () => {
  52.       booleanString(debug) && console.log("Watcher", {event: "unsubscribe", delay, monitor, hooks})
  53.       unsubscribe({monitor});
  54.       clearTimeout(timer);
  55.     }
  56.   }, [debug, monitor, delay, reconnectCallback, callback]);
  58.   return (
  59.     <> 
  60.       {children}
  61.     </>
  62.   );
  63. }
  65. export default WatcherOqt;