ifms-pti/server/src/tasks.js

import { logError, logInfo } from './lib/logger'
import { updateUserIdMappings } from './lib/paloalto'
import { updateDevicesInfo } from './lib/wifiDevices'

const SLEEP_IN_MILLISECONDS = process.env.TASK_SLEEP || 10000

async function updateDevicesTask() {
  logInfo({
    tags: ['task', 'wifiDevices', 'user-id'],
    message: 'Atualização de dispositivos iniciou.'
  })

  try {
    await updateDevicesInfo()
    updateUserIdMappings()
  } catch (e) {
    logError({
      tags: ['task', 'wifiDevices', 'user-id'],
      message: `Erro executando tarefa: ${e}`,
      data: e
    })
  } finally {
    setTimeout(updateDevicesTask, SLEEP_IN_MILLISECONDS)
  }
}

function runTasks() {
  logInfo({
    tags: ['task'],
    message: `Rodando tarefas com ${SLEEP_IN_MILLISECONDS}ms de intervalo.`
  })

  updateDevicesTask()
}

export { runTasks }