feat: add ncu-ci cigtm <jobid>

Author: codebytere

bin/ncu-ci

@@ -6,13 +6,19 @@ const {
   JobParser,
   parseJobFromURL,
   CI_TYPES_KEYS: {
-    PR, COMMIT, BENCHMARK
+    PR, COMMIT, BENCHMARK, CITGM
   }
 } = require('../lib/ci/ci_type_parser');
 
 const {
-  PRBuild, BenchmarkRun, CommitBuild, HealthBuild,
-  listBuilds, FailureAggregator, jobCache
+  PRBuild,
+  BenchmarkRun,
+  CommitBuild,
+  CITGMBuild,
+  HealthBuild,
+  listBuilds,
+  FailureAggregator,
+  jobCache
 } = require('../lib/ci/ci_result_parser');
 const clipboardy = require('clipboardy');
 const { writeJson, writeFile } = require('../lib/file');
@@ -28,7 +34,8 @@ const commandKeys = [
   'walk',
   'url',
   'pr',
-  'commit'
+  'commit',
+  'citgm'
 ];
 
 // eslint-disable-next-line no-unused-vars
@@ -118,6 +125,18 @@ const argv = yargs
     },
     handler
   })
+  .command({
+    command: 'citgm <jobid>',
+    desc: 'Show results of a citgm-smoker CI job',
+    builder: (yargs) => {
+      yargs
+        .positional('jobid', {
+          describe: 'id of the job',
+          type: 'number'
+        });
+    },
+    handler
+  })
   .demandCommand(1, 'must provide a valid command')
   .option('copy', {
     default: false,
@@ -144,7 +163,8 @@ const argv = yargs
 const commandToType = {
   commit: COMMIT,
   pr: PR,
-  benchmark: BENCHMARK
+  benchmark: BENCHMARK,
+  citgm: CITGM
 };
 
 class CICommand {
@@ -188,6 +208,9 @@ class CICommand {
         case COMMIT:
           build = new CommitBuild(cli, request, job.jobid);
           break;
+        case CITGM:
+          build = new CITGMBuild(cli, request, job.jobid);
+          break;
         case BENCHMARK:
           build = new BenchmarkRun(cli, request, job.jobid);
           break;
@@ -208,8 +231,7 @@ class CICommand {
     }
   }
 
-  async aggregate() {  // noop
-  }
+  async aggregate() {}  // noop
 
   async serialize() {
     const { argv, cli } = this;
@@ -357,6 +379,7 @@ async function main(command, argv) {
     }
     case 'pr':
     case 'commit':
+    case 'citgm':
     case 'benchmark': {
       commandHandler = new JobCommand(cli, request, argv, command);
       break;

docs/ncu-ci.md

@@ -21,6 +21,7 @@ Commands:
   ncu-ci commit <jobid>     Show results of a node-test-commit CI job
   ncu-ci benchmark <jobid>  Show results of a benchmark-node-micro-benchmarks CI
                             job
+  ncu-ci citgm <jobid>      Show results of a citgm-smoker job
 
 Options:
   --version   Show version number                                      [boolean]

lib/ci/ci_result_parser.js

@@ -50,15 +50,25 @@ const PR_TREE =
 const COMMIT_TREE =
   `result,url,number,${ACTION_TREE},${CHANGE_TREE},builtOn,` +
   `subBuilds[${BUILD_FIELDS}]`;
+const CITGM_MAIN_TREE =
+  `result,url,number,${ACTION_TREE},${CHANGE_TREE},builtOn`;
+
 // com.tikal.jenkins.plugins.multijob.MultiJobBuild
 const FANNED_TREE =
   `result,url,number,subBuilds[phaseName,${BUILD_FIELDS}]`;
+
 // hudson.matrix.MatrixBuild
 const BUILD_TREE = 'result,runs[url,number,result],builtOn';
 const LINTER_TREE = 'result,url,number,builtOn';
 const CAUSE_TREE = 'upstreamBuild,upstreamProject,shortDescription,_class';
 const RUN_TREE = `actions[causes[${CAUSE_TREE}]],builtOn`;
 
+// hudson.tasks.test.MatrixTestResult
+
+const RESULT_TREE = 'result[suites[cases[name,status]]]';
+const CITGM_REPORT_TREE =
+  `failCount,skipCount,totalCount,childReports[child[url],${RESULT_TREE}]`;
+
 function getPath(url) {
   return url.replace(`https://${CI_DOMAIN}/`, '').replace('api/json', '');
 }
@@ -133,13 +143,13 @@ class Job {
   async getAPIData() {
     const { cli, request, path } = this;
     const url = this.apiUrl;
-    cli.updateSpinner(`Querying API of ${path}`);
+    cli.updateSpinner(`Querying API for ${path}`);
     return request.json(url);
   }
 
   async getConsoleText() {
     const { cli, request, path } = this;
-    cli.updateSpinner(`Querying console text of ${path}`);
+    cli.updateSpinner(`Querying console text for ${path}`);
     const data = await request.text(this.consoleUrl);
     return data.replace(/\r/g, '');
   }
@@ -740,6 +750,102 @@ class PRBuild extends TestBuild {
   }
 }
 
+class CITGMBuild extends TestBuild {
+  constructor(cli, request, id) {
+    const path = `job/citgm-smoker/${id}/`;
+    const tree = CITGM_MAIN_TREE;
+
+    super(cli, request, path, tree);
+
+    this.id = id;
+  }
+
+  async getResults() {
+    let headerData;
+    try {
+      headerData = await this.getBuildData();
+    } catch (err) {
+      this.failures = [
+        new NCUFailure({ url: this.apiUrl }, err.message)
+      ];
+      return this.failures;
+    }
+    const { result } = headerData;
+
+    this.setBuildData(headerData);
+
+    this.updateAPIVariables();
+
+    let resultData;
+    try {
+      resultData = await this.getBuildData();
+    } catch (err) {
+      this.failures = [
+        new NCUFailure({ url: this.apiUrl }, err.message)
+      ];
+      return this.failures;
+    }
+
+    const { childReports } = resultData;
+
+    this.results = this.parseResults(childReports);
+
+    return { result };
+  }
+
+  parseResults(data) {
+    const results = { passes: [], failures: [], skips: [], fixes: [] };
+    data.forEach(platform => {
+      const cases = flatten(platform.result.suites[0].cases);
+      const nodeName = getNodeName(platform.child.url);
+
+      const passedModules = cases.filter(c => c.status === 'PASSED');
+      results.passes.push({ [nodeName]: passedModules });
+
+      const failedModules = cases.filter(c => c.status === 'FAILED');
+      results.failures.push({ [nodeName]: failedModules });
+
+      const skippedModules = cases.filter(c => c.status === 'SKIPPED');
+      results.skips.push({ [nodeName]: skippedModules });
+
+      const fixedModules = cases.filter(c => c.status === 'FIXED');
+      results.fixes.push({ [nodeName]: fixedModules });
+    });
+    return results;
+  }
+
+  displayBuilds() {
+    const { cli, results } = this;
+
+    cli.separator('Failures');
+    for (const failure of results.failures) {
+      const platform = Object.keys(failure)[0];
+      const modules = failure[platform].map(f => f.name);
+
+      cli.table(platform, `${modules.length} Failures`, 25);
+      cli.write('\n');
+      cli.table(' '.repeat(11), modules.join('\n' + ' '.repeat(11)));
+      cli.write('\n\n');
+    }
+
+    // TODO(codebytere): how to display other builds?
+  }
+
+  updateAPIVariables() {
+    this.tree = CITGM_REPORT_TREE;
+    this.path = `job/citgm-smoker/${this.id}/testReport/`;
+  }
+
+  display() {
+    this.displayHeader();
+    this.displayBuilds();
+  }
+
+  formatAsMarkdown() {
+    // TODO(codebytere): implement.
+  }
+}
+
 function filterBuild(builds, type) {
   return builds
     .filter(build => build.result === type)
@@ -1034,6 +1140,7 @@ module.exports = {
   PRBuild,
   BenchmarkRun,
   CommitBuild,
+  CITGMBuild,
   HealthBuild,
   jobCache,
   parseJobFromURL,