Cleanup, and run all, integrated.

Still gotta actuall use the assignments data in the
ingestion.

.ci/Jenkinsfile_coverage

@@ -12,10 +12,10 @@ kibanaPipeline(timeoutMinutes: 240) {
     ]) {
       workers.base(name: 'coverage-worker', size: 'l', ramDisk: false, bootstrapped: false) {
         catchError {
-//          kibanaTeamAssign.generateCodeOwners('.github/CODEOWNERS', "### Generate CODEOWNERS")
-//          kibanaCoverage.runTests()
-//          handleIngestion(TIME_STAMP)
-          kibanaTeamAssign.generateTeamAssignments("### Generate CODEOWNERS")
+          kibanaTeamAssign.generateCodeOwners('.github/CODEOWNERS', "### Generate CODEOWNERS")
+          kibanaCoverage.runTests()
+          handleIngestion(TIME_STAMP)
+//          kibanaTeamAssign.generateTeamAssignments("### Generate Team Assignments")
         }
         handleFail()
       }

src/dev/code_coverage/ingest_coverage/team_assignment/enumerate_patterns.js

@@ -36,7 +36,7 @@ import {
 export const enumeratePatterns = (rootPath) => (log) => (patternsMap) => {
   const res = [];
   const resPush = push(res);
-  const logNotFound = notFound(log)
+  const logNotFound = notFound(log);
 
   for (const pattern of patternsMap) {
     const [pathPattern, meta] = pattern;
@@ -53,11 +53,9 @@ export const enumeratePatterns = (rootPath) => (log) => (patternsMap) => {
 
     const pluckMeta = flip2(pluck)(meta);
     const [owner, exclusions] = ['coverageOwner', 'excludeFiles'].map(pluckMeta);
+    const creeper = (x) => creepFsSync(x, [], rootPath, owner, exclusions);
 
     return function creepAllAsGlobs (pathPattern) {
-
-      const creeper = (x) => creepFsSync(x, [], rootPath, owner, exclusions);
-
       return prokGlob(pathPattern)
         .map(creeper)
         .filter(dropEmpty);
@@ -72,18 +70,18 @@ function creepFsSync (dir, xs, rootPath, owner, exclusions) {
   const trimRoot = trim(rootPath);
   const aJoined = joinRoot(dir);
   const isADir = isDir(aJoined);
-  const entries = isADir ? readdirSync(joinRoot(dir)) : [dir];
 
-  entries.forEach((entry) => {
+  (isADir ? readdirSync(joinRoot(dir)) : [dir])
+    .forEach(maybeRecurse);
+
+  return xs;
+
+  function maybeRecurse (entry) {
     const full = isADir ? join(dir, entry) : entry;
 
-    if (statSync(full).isDirectory() && !isBlackListedDir(full)) {
+    if (statSync(full).isDirectory() && !isBlackListedDir(full))
       xs = creepFsSync(full, xs, rootPath, owner, exclusions);
-    } else {
-      if (isWhiteListedFile(full) && !isExcluded(full, exclusions))
-        xs.push(`${trimRoot(full)} ${owner}`);
-    }
-  });
-
-  return xs;
+    else if (isWhiteListedFile(full) && !isExcluded(full, exclusions))
+      xs.push(`${trimRoot(full)} ${owner}`);
+  }
 }

src/dev/code_coverage/ingest_coverage/transforms.js

@@ -20,7 +20,6 @@
 import * as Either from './either';
 import { fromNullable, just } from './maybe';
 import { always, id, noop } from './utils';
-import { exactMatch, rootMatch, isGlob, globMatch } from './matching';
 
 const maybeTotal = (x) => (x === 'total' ? Either.left(x) : Either.right(x));
 
@@ -99,10 +98,9 @@ export const coveredFilePath = (obj) => {
 };
 
 export const teamAssignment = (teamAssignments) => (obj) => {
-  const name = rootMatch(2)(teamAssignments)(obj);
-
+  console.log(`\n### teamAssignments: \n\t${teamAssignments}`);
   return {
-    team: name,
+    team: '### Write something to grep the assignments :)',
     ...obj,
   };
 };

src/dev/code_coverage/shell_scripts/ingest_coverage.sh

@@ -30,7 +30,7 @@ export DELAY
 TEAM_ASSIGN_PATH=src/dev/code_coverage/ingest_coverage/team_assignment/team_assignments.txt
 
 # Build team assignments dat file
-node scripts/generate_team_assignments.js --dest $TEAM_ASSIGN_PATH
+node scripts/generate_team_assignments.js --verbose --dest $TEAM_ASSIGN_PATH
 
 for x in jest functional; do
   echo "### Ingesting coverage for ${x}"

vars/kibanaTeamAssign.groovy

@@ -41,6 +41,8 @@ def generateTeamAssignments(title) {
 
     # Build team assignments dat file
     node scripts/generate_team_assignments.js --dest src/dev/code_coverage/ingest_coverage/team_assignment/team_assignments.txt
+
+    cat src/dev/code_coverage/ingest_coverage/team_assignment/team_assignments.txt
   """, title)
 }