build-scripts/eslint-filter.js

   1 'use strict';
   2
   3 var path = require('path');
   4 var simpleGit = require('simple-git')();
   5 var parse = require('parse-diff');
   6 var es = require('event-stream');
   7 var vinylFile = require('vinyl-file');
   8 var Promise = require('bluebird');
   9
  10 function filterFiles(baseBranch) {
  11   var changedPromise = new Promise(function(resolve, reject) {
  12     simpleGit.diff([baseBranch], function(err, diff) {
  13       if (err) return reject(err);
  14
  15       var result = parse(diff);
  16
  17       var changedLines = {};
  18       result.forEach(function(file) {
  19         var absPath = path.resolve(file.to);
  20         var diffLine = 0;
  21         changedLines[absPath] = {};
  22         file.chunks.forEach(function(chunk) {
  23           chunk.changes.forEach(function(change) {
  24             diffLine++;
  25             if (change.add) {
  26               changedLines[absPath][change.ln] = diffLine;
  27             }
  28           });
  29         });
  30       });
  31
  32       return resolve(changedLines);
  33     });
  34   });
  35
  36   return es.map(function(data, callback) {
  37     changedPromise
  38       .then(function(changedLines) {
  39         if (!changedLines[data.path]) return;
  40         if (data.content) {
  41           data.eslintFileChanges = changedLines[data.path];
  42           return data;
  43         }
  44
  45         return vinylFile.read(data.path).then(function(data) {
  46           data.eslintFileChanges = changedLines[data.path];
  47           return data;
  48         });
  49       })
  50       .then(function(result) {
  51         return callback(null, result);
  52       }, callback);
  53   });
  54 }
  55
  56 function filterMessages() {
  57   return es.map(function(data, callback) {
  58     var eslintData = data.eslint;
  59     var eslintFileChanges = data.eslintFileChanges;
  60     var messages = eslintData && eslintData.messages;
  61
  62     if (!eslintFileChanges) {
  63       return callback(null, data);
  64     }
  65
  66     if (messages && messages.length) {
  67       messages = messages.filter(function(message) {
  68         return eslintFileChanges[message.line];
  69       });
  70
  71       eslintData.messages = messages;
  72       var counts = messages.reduce(
  73         function(memo, message) {
  74           switch (message.severity) {
  75             case 1:
  76               memo.warningCount++;
  77               break;
  78
  79             case 2:
  80               memo.errorCount++;
  81               break;
  82           }
  83           return memo;
  84         },
  85         {
  86           errorCount: 0,
  87           warningCount: 0
  88         }
  89       );
  90
  91       eslintData.errorCount = counts.errorCount;
  92       eslintData.warningCount = counts.warningCount;
  93     }
  94
  95     callback(null, data);
  96   });
  97 }
  98
  99 module.exports = {
 100   filterFiles: filterFiles,
 101   filterMessages: filterMessages
 102 };