index.js

var helper = require('./libs/helper');
var istanbul = require('istanbul');
var instrumenter = new istanbul.Instrumenter();
var through = require('through');

function instrument(file, content) {
    return instrumenter.instrumentSync(content, file);
}

module.exports = function (file, options) {
    var config = options || {};
    var content = '';
    var ignoredFile = false;
    var patternsToBeIgnored = config.ignores || [];
    var patternsToBeContained = config.contains || [];

    if (patternsToBeIgnored.length) {
        ignoredFile = (helper.containsPatterns(file, patternsToBeIgnored) || ignoredFile);
    }

    if (patternsToBeContained.length) {
        ignoredFile = (helper.doNotContainsPatterns(file, patternsToBeContained) || ignoredFile);
    }

    function write (buffer) {
        content += buffer;
    }

    function end () {
        var code = helper.getCode(content);
        var ignoredInCoverage = helper.hasCommentWith(code, new RegExp('ignored +by +test +coverage'));
        var src = (ignoredInCoverage) ? content : instrument(file, content);

        this.queue(src);
        this.queue(null);
    }

    return (ignoredFile) ? through() : through(write, end);
};