Improved updateDevicesInfo() efficiency

server/src/index.js

@@ -10,7 +10,7 @@ import { server } from './server'
 import { runTasks } from './tasks'
 import './cronTasks'
 
-server.listen().then(options => {
+server.listen().then(async options => {
   logSuccess({
     tags: ['server'],
     message: `Servidor pronto!`,
@@ -23,6 +23,6 @@ server.listen().then(options => {
           : 'Rodando em modo de desenvolvimento'
     }
   })
-})
 
-runTasks()
+  runTasks()
+})

server/src/lib/wifiDevices.js

@@ -7,7 +7,6 @@ import prisma from '../prisma'
 import { pubsub, USER_PRESENCE_UPDATED } from '../pubsub'
 import { logError, logSuccess } from './logger'
 
-const DEBOUNCE_TIME_MS = 3000
 const RECENT_THRESHOLD_IN_MINUTES = 5
 
 let working = false
@@ -69,8 +68,8 @@ function mockHostName({ mac, oui }) {
 }
 
 async function updateDB(onlineDevices) {
-  for (const device of onlineDevices) {
+  onlineDevices.map(device => {
-    if (!device.user) await forceUserDisconnect(device.mac)
+    if (!device.user) forceUserDisconnect(device.mac)
     else device.user = device.user.replace('IFMS\\', '')
 
     const user = device.user
@@ -79,8 +78,8 @@ async function updateDB(onlineDevices) {
 
     const hostname = device.hostname || mockHostName(device)
 
-    try {
+    prisma.wifiDevice
-      await prisma.wifiDevice.upsert({
+      .upsert({
         where: { mac: device.mac },
         create: {
           ...device,
@@ -94,40 +93,40 @@ async function updateDB(onlineDevices) {
           user
         }
       })
-    } catch (e) {
+      .catch(async e => {
-      // If is a binding problem, probably the device has an user outside of AD, so save it anyway...
+        // If is a binding problem, probably the device has an user outside of AD, so save it anyway...
-      if (e.code == 'P2016')
+        if (e.code == 'P2016')
-        try {
+          try {
-          await forceUserDisconnect(device.mac)
+            await forceUserDisconnect(device.mac)
-          await prisma.wifiDevice.upsert({
+            await prisma.wifiDevice.upsert({
-            where: { mac: device.mac },
+              where: { mac: device.mac },
-            create: {
+              create: {
-              ...device,
+                ...device,
-              hostname,
+                hostname,
-              firstSeen: device.firstSeen || new Date(),
+                firstSeen: device.firstSeen || new Date(),
-              user: undefined
+                user: undefined
-            },
+              },
-            update: {
+              update: {
-              ...device,
+                ...device,
-              hostname,
+                hostname,
-              user: undefined
+                user: undefined
-            }
+              }
-          })
+            })
-        } catch (e) {
+          } catch (e) {
+            logError({
+              tags: ['wifiDevices'],
+              message: `Erro tentando adicionar o dispositivo "${device.mac}". Ele tinha um usuário fora do AD que foi ignorado, mas falhou mesmo assim`,
+              data: { error: e, device }
+            })
+          }
+        else
           logError({
             tags: ['wifiDevices'],
-            message: `Erro tentando adicionar o dispositivo "${device.mac}". Ele tinha um usuário fora do AD que foi ignorado, mas falhou mesmo assim`,
+            message: `Erro tentando adicionar o dispositivo "${device.mac}".`,
             data: { error: e, device }
           })
-        }
+      })
-      else
+  })
-        logError({
-          tags: ['wifiDevices'],
-          message: `Erro tentando adicionar o dispositivo "${device.mac}".`,
-          data: { error: e, device }
-        })
-    }
-  }
 }
 
 async function updateDevicesInfo() {
@@ -162,9 +161,7 @@ async function updateDevicesInfo() {
 
     return 0
   } finally {
-    setTimeout(() => {
+    working = false
-      working = false
-    }, DEBOUNCE_TIME_MS)
   }
 }
 

server/src/tasks.js

@@ -13,9 +13,8 @@ async function updateDevicesTask() {
   try {
     const devicesQnt = await updateDevicesInfo()
 
-    if (devicesQnt > 0) {
+    if (devicesQnt > 0) updateUserIdMappings()
-      updateUserIdMappings()
+    else throw new Error('Já há uma tarefa em andamento.')
-    }
   } catch (e) {
     logError({
       tags: ['task', 'wifiDevices', 'user-id'],