index.js

'use strict';

var gutil = require('gulp-util');
var File = require('vinyl');
var MemoryFileSystem = require('memory-fs');
var through = require('through');
var ProgressPlugin = require('webpack/lib/ProgressPlugin');

var PLUGIN_NAME = 'gulp-webpack';
var defaultStatsOptions = {
  colors: gutil.colors.supportsColor,
  hash: false,
  timings: false,
  chunks: false,
  chunkModules: false,
  modules: false,
  children: true,
  version: true,
  cached: false,
  cachedAssets: false,
  reasons: false,
  source: false,
  errorDetails: false,
};

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

  var callingDone = false;
  var webpackDone = function(err, stats) {
    stats = stats || {};
    if (options.quiet || callingDone) {
      return;
    }
    // Debounce output a little for when in watch mode
    if (options.watch) {
      callingDone = true;
      setTimeout(function() { callingDone = false; }, 500);
    }
    if (options.verbose) {
      gutil.log(stats.toString({
        colors: gutil.colors.supportsColor,
      }));
    } else {
      var statsOptions = options && options.stats || {};

      Object.keys(defaultStatsOptions).forEach(function(key) {
        if (typeof statsOptions[key] === 'undefined') {
          statsOptions[key] = defaultStatsOptions[key];
        }
      });

      gutil.log(stats.toString(statsOptions));
    }
  };
  if (typeof done === 'function') {
    done = done.bind({ 'webpackDone': webpackDone });
  } else {
    done = webpackDone;
  }

  var webpack = wp || require('webpack');
  var entry = [];
  var entries = Object.create(null);

  var stream = through(function(file) {
    if (file.isNull()) {
      return;
    }
    if ('named' in file) {
      if (!Array.isArray(entries[file.named])) {
        entries[file.named] = [];
      }
      entries[file.named].push(file.path);
    } else {
      entry = entry || [];
      entry.push(file.path);
    }
  }, function() {
    var self = this;
    options.output = options.output || {};

    // Determine pipe'd in entry
    if (Object.keys(entries).length > 0) {
      entry = entries;
      if (!options.output.filename) {
        // Better output default for multiple chunks
        options.output.filename = '[name].js'
      }
    } else if (entry.length < 2) {
      entry = entry[0] || entry;
    }

    options.entry           = options.entry           || entry;
    options.output.path     = options.output.path     || process.cwd();
    options.output.filename = options.output.filename || '[hash].js';
    entry = [];

    if (!options.entry) {
      gutil.log('gulp-webpack - No files given; aborting compilation');
      return;
    }

    var compiler = webpack(options, function(err, stats) {
      if (err) {
        self.emit('error', new gutil.PluginError(PLUGIN_NAME, err));
      }
      if (!options.watch) {
        self.queue(null);
      }
      done(err, stats);
      if (options.watch && !options.quiet) {
        gutil.log('webpack is watching for changes');
      }
    });

    // In watch mode webpack returns a wrapper object so we need to get
    // the underlying compiler
    if (options.watch) {
      compiler = compiler.compiler;
    }

    if (options.progress) {
      compiler.apply(new ProgressPlugin(function(percentage, msg) {
        percentage = Math.floor(percentage * 100);
        msg = percentage + '% ' + msg;
        if (percentage < 10) msg = ' ' + msg;
        gutil.log('webpack', msg);
      }));
    }

    var fs = compiler.outputFileSystem = new MemoryFileSystem();
    compiler.plugin('after-emit', function(compilation, callback) {
      Object.keys(compilation.assets).forEach(function(outname) {
        if (compilation.assets[outname].emitted) {
          var path = fs.join(compiler.outputPath, outname);
          if (path.indexOf('?') !== -1) {
            path = path.split('?')[0];
          }
          var contents = fs.readFileSync(path);
          self.queue(new File({
            base: compiler.outputPath,
            path: path,
            contents: contents,
          }));
        }
      });
      callback();
    });
  });

  // If entry point manually specified, trigger that
  if (options.entry) {
    stream.end();
  }

  return stream;
};

// Expose webpack if asked
Object.defineProperty(module.exports, 'webpack', {
  get: function() {
    return require('webpack');
  }
});