mirror of https://github.com/webpack/webpack.git
57 lines
1.4 KiB
JavaScript
57 lines
1.4 KiB
JavaScript
|
/*
|
||
|
|
MIT License http://www.opensource.org/licenses/mit-license.php
|
||
|
|
Author Tobias Koppers @sokra
|
||
|
|
*/
|
||
|
|
var Watchpack = require("watchpack");
|
||
|
|
|
||
|
|
function NewWatchingPlugin() {
|
||
|
|
}
|
||
|
|
module.exports = NewWatchingPlugin;
|
||
|
|
|
||
|
|
NewWatchingPlugin.prototype.apply = function(compiler) {
|
||
|
|
compiler.plugin("environment", function() {
|
||
|
|
compiler.watchFileSystem = new NodeWatchFileSystem(compiler.inputFileSystem);
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
function NodeWatchFileSystem(inputFileSystem) {
|
||
|
|
this.inputFileSystem = inputFileSystem;
|
||
|
|
this.watcherOptions = {
|
||
|
|
aggregateTimeout: 0
|
||
|
|
};
|
||
|
|
this.watcher = new Watchpack(this.watcherOptions);
|
||
|
|
}
|
||
|
|
|
||
|
|
NodeWatchFileSystem.prototype.watch = function watch(files, dirs, startTime, delay, callback, callbackUndelayed) {
|
||
|
|
var oldWatcher = this.watcher;
|
||
|
|
this.watcher = new Watchpack({
|
||
|
|
aggregateTimeout: delay
|
||
|
|
});
|
||
|
|
|
||
|
|
var onChange = function() {
|
||
|
|
callbackUndelayed();
|
||
|
|
}.bind(this);
|
||
|
|
this.watcher.once("change", onChange);
|
||
|
|
this.watcher.once("aggregated", function(changes) {
|
||
|
|
if(this.inputFileSystem && this.inputFileSystem.purge) {
|
||
|
|
this.inputFileSystem.purge(changes);
|
||
|
|
}
|
||
|
|
var times = this.watcher.getTimes();
|
||
|
|
callback(null, changes.filter(function(file) {
|
||
|
|
return files.indexOf(file) >= 0;
|
||
|
|
}).sort(), changes.filter(function(file) {
|
||
|
|
return dirs.indexOf(file) >= 0;
|
||
|
|
}).sort(), times, times);
|
||
|
|
}.bind(this));
|
||
|
|
|
||
|
|
this.watcher.watch(files, dirs, startTime);
|
||
|
|
|
||
|
|
if(oldWatcher) {
|
||
|
|
oldWatcher.close();
|
||
|
|
}
|
||
|
|
return {
|
||
|
|
close: function() {
|
||
|
|
this.watcher.pause();
|
||
|
|
}.bind(this)
|
||
|
|
}
|
||
|
|
};
|