[+] Analysis: LOC, SLOC e CLOC

TheMarini · TheMarini · commit a37c60c79142 · 2020-10-07T23:41:16.000-03:00
diff --git a/src/analysis.js b/src/analysis.js
@@ -0,0 +1,90 @@
+const d = require('download-git-repo');
+const { exec } = require('child_process');
+const { promisify } = require('util');
+const rimraf = require('rimraf');
+const ObjectsToCsv = require('objects-to-csv');
+const l = require('./utils/logger');
+
+const executeCommand = promisify(exec);
+
+async function store(file, data, tag) {
+  console.log(`${tag} Salvando...`);
+  return new ObjectsToCsv([data])
+    .toDisk(file, {
+      append: true,
+      bom: true,
+    })
+    .then(() => {
+      l.success(`${tag} Salvo em ${file}`);
+    });
+}
+
+function download(nameWithOwner, path) {
+  return new Promise((resolve, reject) => {
+    d(nameWithOwner, path, (err) => {
+      if (err) reject(err);
+      resolve();
+    });
+  });
+}
+
+async function clone(nameWithOwner, tag) {
+  const split = nameWithOwner.split('/');
+  const path = `./temp/${split[0]}-${split[1]}`;
+
+  l.status(`${tag} Baixando ${nameWithOwner} para ${path}`);
+  return download(nameWithOwner, path).then(async () => {
+    l.log(`${tag} Analisando LOC, SLOC e CLOC...`);
+    const { stdout } = await executeCommand(
+      `sloc ${path} --keys total,source,comment`
+    );
+
+    const output = stdout
+      .replace(/\D/gim, ' ')
+      .split(' ')
+      .filter((e) => e);
+
+    const results = {
+      total: parseInt(output[0], 10),
+      source: parseInt(output[1], 10),
+      comments: parseInt(output[2], 10),
+    };
+
+    try {
+      l.log(`${tag} Análise feita. Apagando ${path}`);
+      rimraf.sync(path);
+    } catch (error) {
+      l.error(`${tag} Não foi possível apagar ${path}:`, error.message);
+      l.log(`${tag} Continuando para o próximo...`);
+    }
+
+    return {
+      // eslint-disable-next-line no-restricted-globals
+      total: isNaN(results.total) ? 0 : results.total,
+      // eslint-disable-next-line no-restricted-globals
+      source: isNaN(results.source) ? 0 : results.source,
+      // eslint-disable-next-line no-restricted-globals
+      comments: isNaN(results.comments) ? 0 : results.comments,
+    };
+  });
+}
+
+async function init(repos, tag, file) {
+  for (let i = 0; i < repos.length; i += 1) {
+    const repo = repos[i];
+    // eslint-disable-next-line no-await-in-loop
+    const results = await clone(repo['<usuário>/<repositório>'], tag);
+    // eslint-disable-next-line no-param-reassign
+    repos[i].LOC = results.total;
+    // eslint-disable-next-line no-param-reassign
+    repos[i].SLOC = results.source;
+    // eslint-disable-next-line no-param-reassign
+    repos[i].CLOC = results.comments;
+    // eslint-disable-next-line no-await-in-loop
+    await store(file, repos[i], tag);
+  }
+}
+
+module.exports = (repos, tag, file) => {
+  return init(repos, tag, file);
+};
diff --git a/src/mine.js b/src/mine.js
@@ -2,6 +2,7 @@ const moment = require('moment');
 const ObjectsToCsv = require('objects-to-csv');
 const fetch = require('./utils/fetch');
 const l = require('./utils/logger');
+const analysis = require('./analysis');
 
 class Mine {
   constructor(objective, language) {
@@ -19,7 +20,7 @@ class Mine {
     const digs = [];
     let tag = `[${this.current}/${this.objective}]`;
     while (this.current <= this.objective) {
-      console.log(`${tag} Buscando...`);
+      console.log(`${tag} Buscando página...`);
       // eslint-disable-next-line no-await-in-loop
       await this.dig(token, tag);
       tag = `[${this.current}/${this.objective}]`;
@@ -34,7 +35,8 @@ class Mine {
       await fetch(token, this.cursor, this.language).then((res) => {
         this.cursor = res.pageInfo.endCursor || null;
         this.current += 1;
-        return Mine.store(this.file, Mine.polish(res.nodes, tag), tag);
+        const data = Mine.polish(res.nodes, tag);
+        return analysis(data, tag, this.file);
       });
     } catch (e) {
       l.error(`${tag} Erro na requisição:`, e.message);
@@ -50,12 +52,12 @@ class Mine {
         bom: true,
       })
       .then(() => {
-        l.success(`${tag} Salvo em ${file}`);
+        l.success(`${tag} Resultados da página salvos em ${file}`);
       });
   }
 
   static polish(dirt, tag) {
-    console.log(`${tag} Formatando...`);
+    console.log(`${tag} Formatando página...`);
     return dirt.map((repo) => {
       return {
         '<usuário>/<repositório>': repo.nameWithOwner,
