All files / crons/jobs reportDelete.js

0% Statements 0/20
0% Branches 0/5
0% Functions 0/5
0% Lines 0/16

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31                                                             
require('babel-register');
require('babel-polyfill');
 
const fs = require('fs');
const path = require('path');
 
const { parentPort } = require('worker_threads');
const { PATH_REPORT } = require('../../../root');
 
// Funcao de envio de mensagem utilizada para logging
function sendMessage(message = '') {
  if (parentPort) parentPort.postMessage(message);
}
 
const jobExec = async () => {
  sendMessage('Removendo relatórios baixados...');
 
  let files = fs.readdirSync(PATH_REPORT);
  files = files.filter((file) => file.startsWith('downloaded_'));
  files.forEach((file) => fs.unlink(path.join(PATH_REPORT, file)));
};
 
(async () => {
  // funcao que executa o job
  await jobExec();
 
  // processo necessario para informar a conclusao do job
  if (parentPort) sendMessage('done');
  else process.exit(0);
})();