Correção no online/offiline para não sobrecarregar o servidor com emitters e evitar o memery leak(vazamento de memória)

backend/src/controllers/ReportController.ts

@@ -27,6 +27,7 @@ import ShowQueuesByUser from "../services/UserServices/ShowQueuesByUser";
 // import { filter } from "bluebird"; 
 
 import { getIO } from "../libs/socket";
+import { Json } from "sequelize/types/lib/utils";
 
 type IndexQuery = {
   userId: string;
@@ -87,6 +88,10 @@ export const reportUserService = async (req: Request, res: Response): Promise<Re
   let openCloseOnQueue = openByUserOnQueue.concat(closedByUserOnQueue)
   let openCloseOutQueue = openByUserOutQueue.concat(closedUserOutQueue)
 
+
+  // console.log('onlineUsers: ',JSON.parse(JSON.stringify(onlineUsers)))
+  // console.log('sumUserOlineTime: ', JSON.parse(JSON.stringify(sumUserOlineTime)))
+
   for (let i = 0; i < queuesByUser.length; i++) {
 
     queuesByUser[i].countOpen = 0
@@ -113,6 +118,8 @@ export const reportUserService = async (req: Request, res: Response): Promise<Re
 
     if (index != -1) {
       user.sumOnlineTime = sumUserOlineTime[index];
+
+      // console.log('user.sumOlineTime: 'user.sumOnlineTime)
     }
 
     index = closedByUser.findIndex((e: any) => e.userId == user.id)
@@ -169,7 +176,7 @@ export const reportUserService = async (req: Request, res: Response): Promise<Re
 
   })
 
-  return res.status(200).json(usersProfile);
+  return res.status(200).json({usersProfile: usersProfile});
 
 };
 

backend/src/helpers/WhoIsOnlineMonitor.ts

@@ -23,7 +23,7 @@ let whoIsOnline_monitor: any;
 // const listUserId:any[] = [{'id':8, status: 'offline'},{'id':3,  status: 'offline'},{'id':5,  status: 'offline'}] 
 let listUserId: any[] = []
 let count = 0
-let countTest = 0
+// let countTest = 0
 let uuid: any = 0
 let dateTime = splitDateTime(new Date(format(new Date(), 'yyyy-MM-dd HH:mm:ss', { locale: ptBR })))
 let timeInterval = 5
@@ -51,6 +51,10 @@ const emitterOnline = (user: any, status: string, showOnlineTime: boolean = true
         }
     }
 
+    console.log('ENTROU NO EMMITER ONLINE: ', user.id)
+
+    // console.log('-------------> onlineTime: ', onlineTime)
+
     const io = getIO();
     io.emit("onlineStatus", {
         action: "update",
@@ -113,12 +117,14 @@ const monitor = async () => {
 
                     }
 
+                    // console.log('el: ', el)
+
                     if (el.status == 'waiting...') {
                         emitterOnline(el, el.status, false)
                     }
-                    else {
+                    // else {
-                        emitterOnline(el, el.status)
+                    //     emitterOnline(el, el.status)
-                    }
+                    // }
 
 
 
@@ -150,36 +156,12 @@ const monitor = async () => {
         } 
          
 
-        if (countTest > 5) {
-            countTest = 0
-        }
-
-        if (countTest == 0) {
-            try {
-                console.log(' Carregando usuarios no listUserId...')
-                listUserId = await ListUserParamiterService({ profile: 'user' })
-
-            } catch (error) {
-                console.log('There was an erro on ListUserParamiterService:  ', error)
-                return
-            }
-
-        }
-
-        countTest = 1
-
-        listUserId.forEach((u) => {
-
-            const io = getIO();
-            io.emit("isOnline", { action: "online", userId: u.id });
-        });
-
     } catch (error) {
         console.log('>>> There was an error no WhoIsOnlineMonitor.ts: ', error)
 
         listUserId = []
         count = 0
-        countTest = 0
+        // countTest = 0
         uuid = 0
     }
 
@@ -211,7 +193,7 @@ const startWhoIsOnlineMonitor = async (mileseconds?: number) => {
 
     listUserId = []
     count = 0
-    countTest = 0
+    // countTest = 0
     uuid = 0
 
     clearInterval(_fifo);

backend/src/libs/socket.ts

@@ -48,6 +48,8 @@ export const initIO = (httpServer: Server): SocketIO => {
 
     socket.on("online", (userId: any) => {
  
+      // console.log('userId: ', userId)
+
       obj.uuid = uuidv4()
 
       if (userId.logoutUserId) {

frontend/src/components/NotificationsPopOver/index.js

@@ -40,6 +40,29 @@ const useStyles = makeStyles(theme => ({
 	},
 }));
 
+
+let _fifo
+
+// const onlineEmitter = async (socket, user) => {
+
+// 	try {
+// 		clearInterval(_fifo);
+
+// 		socket.emit("online", user.id)
+
+// 	} catch (error) {
+// 		console.log('error on onlineEmitter: ', error)
+// 	}
+// 	finally {
+// 		_fifo = setInterval(onlineEmitter, 3000);
+// 	}
+// }
+
+// _fifo = setInterval(onlineEmitter, 3000);
+
+
+
+
 const NotificationsPopOver = () => {
 	const classes = useStyles();
 
@@ -110,20 +133,37 @@ const NotificationsPopOver = () => {
 
 		});
 
-		socket.on("isOnline", (data) => {  
+		// socket.on("isOnline", (data) => {
+
+		// 	if (data.action === "online") {
+
+		// 		if (data.userId === user.id) {
+
+		// 			socket.emit("online", user.id)
+		// 		}
+
+		// 	}
+
+		// }); 
 
 
+		if(user.profile === 'user'){
 
-		  if(data.action === "online"){    
+			if(_fifo){
-		 
+				clearInterval(_fifo); 
-			if(data.userId === user.id){ 
+			}
 	
+			_fifo = setInterval(()=>{
+				console.log('user.id: ', user.id)
 				socket.emit("online", user.id)
-			} 
+			}, 3000);
 
 		} 
 
-		});
+
+	
+
+
 
 		return () => {
 			socket.disconnect();

frontend/src/pages/Dashboard/index.js

@@ -1,5 +1,7 @@
 import React, { useContext, useReducer, useEffect, useState } from "react";
 
+import { addHours, addMinutes, addSeconds, intervalToDuration, add } from "date-fns";
+
 import Paper from "@material-ui/core/Paper";
 import Container from "@material-ui/core/Container";
 import Grid from "@material-ui/core/Grid";
@@ -104,6 +106,36 @@ const useStyles = makeStyles((theme) => ({
   },
 }));
 
+var _fifo
+
+const sumOnlineTimeNow = (oldOnlineTimeSum) => {
+
+  let onlineTime = new Date()
+
+  onlineTime.setUTCHours(new Date(oldOnlineTimeSum.onlineTime).getHours())
+  onlineTime.setUTCMinutes(new Date(oldOnlineTimeSum.onlineTime).getMinutes())
+  onlineTime.setUTCSeconds(new Date(oldOnlineTimeSum.onlineTime).getSeconds())
+
+
+  let newtTime = intervalToDuration({ start: new Date(oldOnlineTimeSum.updatedAt), end: new Date() })
+
+
+  if (newtTime.hours && +newtTime.hours > 0) {
+    onlineTime = addHours(onlineTime, newtTime.hours)
+  }
+  if (newtTime.minutes && +newtTime.minutes > 0) {
+    onlineTime = addMinutes(onlineTime, newtTime.minutes)
+  }
+  if (newtTime.seconds && +newtTime.seconds > 0) {
+    onlineTime = addSeconds(onlineTime, newtTime.seconds)
+  }
+
+  const isoDate = new Date(onlineTime);
+  const newOnlinetime = isoDate.toJSON().slice(0, 19).replace('T', ' ');
+
+  return newOnlinetime
+}
+
 const reducer = (state, action) => {
   if (action.type === "DELETE_USER_STATUS") {
     const userId = action.payload;
@@ -138,6 +170,8 @@ const reducer = (state, action) => {
     let onlineUser = action.payload;
     let index = -1;
 
+    // console.log('UPDATE_STATUS_ONLINE: ', onlineUser)
+
     let onlySumOpenClosed = false;
 
     if (onlineUser.sumOpen || onlineUser.sumClosed) {
@@ -157,18 +191,27 @@ const reducer = (state, action) => {
         if (!("statusOnline" in state[index])) {
           state[index].statusOnline = onlineUser;
         } else if ("statusOnline" in state[index]) {
+
           state[index].statusOnline["status"] = onlineUser.status;
+
         }
       }
  
+
       if ("onlineTime" in onlineUser) {
+
         if ("sumOnlineTime" in state[index]) {
-          state[index].sumOnlineTime["sum"] = onlineUser.onlineTime.split(" ")[1];
+
+          // console.log(' ffffffffffffffffffffffffffff ')
+          state[index].sumOnlineTime.sum = onlineUser.onlineTime.split(" ")[1]
+
         } else if (!("sumOnlineTime" in state[index])) { 
+
           state[index].sumOnlineTime = {
             userId: onlineUser.userId,
             sum: onlineUser.onlineTime.split(" ")[1],
           };
+
         }
       }
 
@@ -235,11 +278,14 @@ const Dashboard = () => {
           let date = new Date().toLocaleDateString("pt-BR").split("/");
           let dateToday = `${date[2]}-${date[1]}-${date[0]}`;
 
-          const dataQuery = await api.get("/reports/user/services", {
+          const { data } = await api.get("/reports/user/services", {
             params: { userId: null, startDate: dateToday, endDate: dateToday },
           });
+
+          // console.log('data.data: ', data.usersProfile)
+
           dispatch({ type: "RESET" });
-          dispatch({ type: "LOAD_QUERY", payload: dataQuery.data });
+          dispatch({ type: "LOAD_QUERY", payload: data.usersProfile });
         } catch (err) {
 
         }
@@ -250,6 +296,37 @@ const Dashboard = () => {
     return () => clearTimeout(delayDebounceFn);
   }, []);
 
+
+  useEffect(() => {
+
+
+    if (!usersOnlineInfo || usersOnlineInfo.length == 0) return  
+
+    if (_fifo) {
+      clearInterval(_fifo);
+    }
+
+    _fifo = setInterval(() => {
+ 
+      usersOnlineInfo.map((e) => {
+
+        if (e.statusOnline && e.statusOnline.status === 'online') { 
+            
+          let onlineTimeCurrent =   sumOnlineTimeNow({onlineTime: e.statusOnline.onlineTime, updatedAt: e.statusOnline.updatedAt}) 
+
+          dispatch({ type: "UPDATE_STATUS_ONLINE", payload: { userId: e.id, status: e.statusOnline.status, onlineTime: onlineTimeCurrent } }); 
+
+        }
+
+      })
+ 
+
+    }, 3000);
+
+
+  }, [usersOnlineInfo])
+
+
   useEffect(() => {
     const socket = openSocket(process.env.REACT_APP_BACKEND_URL);
 

frontend/src/pages/Report/index.js

@@ -728,7 +728,7 @@ const Report = () => {
 
                       { title: 'Tempo online', field: 'sumOnlineTime.sum' },
                       { title: `${i18n.t("reports.dateStart")}`, field: 'startDate' },
-                      { title: `${i18n.t("reports.dateStart")}`, field: 'endDate' },
+                      { title: `${i18n.t("reports.dateEnd")}`, field: 'endDate' },
                       { title: 'Em atendimento', field: 'sumOpen.count' },
                       { title: 'Finalizado', field: 'sumClosed.count' },