MultiCompiler with compilers depend on other

sokra · sokra · commit e896d14829d0 · 2016-09-16T01:20:34.000+02:00
diff --git a/lib/MultiCompiler.js b/lib/MultiCompiler.js
@@ -90,19 +90,89 @@ module.exports = MultiCompiler;
 MultiCompiler.prototype = Object.create(Tapable.prototype);
 MultiCompiler.prototype.constructor = MultiCompiler;
 
-MultiCompiler.prototype.watch = function(watchDelay, handler) {
-	var watchings = this.compilers.map(function(compiler) {
-		return compiler.watch(watchDelay, handler);
+function runWithDependencies(compilers, fn, callback) {
+	var fulfilledNames = {};
+	var remainingCompilers = compilers;
+
+	function isDependencyFulfilled(d) {
+		return fulfilledNames[d];
+	}
+
+	function getReadyCompilers() {
+		var readyCompilers = [];
+		var list = remainingCompilers;
+		remainingCompilers = [];
+		for(var i = 0; i < list.length; i++) {
+			var c = list[i];
+			var ready = !c.dependencies || c.dependencies.every(isDependencyFulfilled);
+			if(ready)
+				readyCompilers.push(c);
+			else
+				remainingCompilers.push(c);
+		}
+		return readyCompilers;
+	}
+
+	function runCompilers(callback) {
+		if(remainingCompilers.length === 0) return callback();
+		async.map(getReadyCompilers(), function(compiler, callback) {
+			fn(compiler, function(err) {
+				if(err) return callback(err);
+				fulfilledNames[compiler.name] = true;
+				runCompilers(callback);
+			});
+		}, callback);
+	}
+	runCompilers(callback);
+}
+
+MultiCompiler.prototype.watch = function(watchOptions, handler) {
+	var watchings = [];
+	var allStats = [];
+	var compilerStatus = this.compilers.map(function() {
+		return false;
 	});
+
+	runWithDependencies(this.compilers, function(compiler, callback) {
+		var compilerIdx = this.compilers.indexOf(compiler);
+		var firstRun = true;
+		var watching = compiler.watch(watchOptions, function(err, stats) {
+			if(err)
+				handler(err);
+			if(stats) {
+				allStats.push(stats);
+				compilerStatus[compilerIdx] = true;
+				if(compilerStatus.every(Boolean)) {
+					var multiStats = new MultiStats(allStats);
+					allStats = [];
+					handler(null, multiStats)
+				}
+			}
+			if(firstRun && !err) {
+				firstRun = false;
+				callback();
+			}
+		});
+		watchings.push(watching);
+	}.bind(this), function() {
+		// ignore
+	});
+
 	return new MultiWatching(watchings);
 };
 
 MultiCompiler.prototype.run = function(callback) {
-	async.map(this.compilers, function(compiler, callback) {
-		compiler.run(callback);
-	}, function(err, stats) {
+	var allStats = [];
+
+	runWithDependencies(this.compilers, function(compiler, callback) {
+		compiler.run(function(err, stats) {
+			if(err) return callback(err);
+			allStats.push(stats);
+			callback();
+		});
+	}, function(err) {
 		if(err) return callback(err);
-		callback(null, new MultiStats(stats));
+		callback(null, new MultiStats(allStats));
 	});
 };
 
diff --git a/lib/WebpackOptionsApply.js b/lib/WebpackOptionsApply.js
@@ -62,6 +62,7 @@ WebpackOptionsApply.prototype.process = function(options, compiler) {
 	compiler.recordsInputPath = options.recordsInputPath || options.recordsPath;
 	compiler.recordsOutputPath = options.recordsOutputPath || options.recordsPath;
 	compiler.name = options.name;
+	compiler.dependencies = options.dependencies;
 	if(typeof options.target === "string") {
 		var JsonpTemplatePlugin;
 		var NodeSourcePlugin;
