index.js

var through = require('through2');
var gutil = require('gulp-util');
var PluginError = gutil.PluginError;

var ProcessorEngine = require('./lib/ProcessorEngine');
var Angular1Processor = require('./lib/Angular1Processor');
var Angular2TypeScriptTemplateProcessor = require('./lib/Angular2TypeScriptProcessor');
var Angular3TypeScriptTemplateProcessor = require('./lib/Angular3TypeScriptProcessor');
var utils = require('./lib/utils');

const PLUGIN_NAME = 'gulp-angular-embed-template';

module.exports = function (options) {
    options = options || {};

    var sourceType = options.sourceType;
    delete options.sourceType;
    switch (sourceType) {
        case 'ts':
            options.processors = [new Angular1Processor(), new Angular2TypeScriptTemplateProcessor()];
            break;
        case 'js':
        default:
            options.processors = [new Angular1Processor(), new Angular3TypeScriptTemplateProcessor()];
    }

    var logger = options.logger = utils.createLogger();
    if (options.debug !== true) {
        logger.debug = function () {}
    }
    delete options.debug;
    logger.warn = function(msg) {
        gutil.log(
            PLUGIN_NAME,
            gutil.colors.yellow('[Warning]'),
            gutil.colors.magenta(msg)
        );
    };

    var skipFiles = options.skipFiles || function() {return false;};
    delete options.skipFiles;
    if (typeof skipFiles === 'function') {
        /* OK */
    } else if (skipFiles instanceof RegExp) {
        var regexp = skipFiles;
        skipFiles = function(file) {
            return regexp.test(file.path);
        }
    } else {
        logger.warn('"skipFiles" options should be either function or regexp, actual type is ' + typeof skipFiles);
        skipFiles = function() {return false;}
    }

    var processorEngine = new ProcessorEngine();
    processorEngine.init(options);

    /**
     * This function is 'through' callback, so it has predefined arguments
     * @param {File} file file to analyse
     * @param {String} enc encoding (unused)
     * @param {Function} cb callback
     */
    function transform(file, enc, cb) {
        // ignore empty files
        if (file.isNull()) {
            cb(null, file);
            return;
        }

        if (file.isStream()) {
            throw new PluginError(PLUGIN_NAME, 'Streaming not supported. particular file: ' + file.path);
        }

        logger.debug('\n\nfile.path: %s', file.path || 'fake');

        if (skipFiles(file)) {
            logger.info('skip file %s', file.path);
            cb(null, file);
            return;
        }

        var pipe = this;
        processorEngine.process(file, cb, function onErr(msg) {
            pipe.emit('error', new PluginError(PLUGIN_NAME, msg));
        });
    }

    return through.obj(transform);
};