2013-01-31 01:49:25 +08:00
|
|
|
/*
|
|
|
|
MIT License http://www.opensource.org/licenses/mit-license.php
|
|
|
|
Author Tobias Koppers @sokra
|
|
|
|
*/
|
2017-01-11 20:08:28 +08:00
|
|
|
"use strict";
|
2013-01-31 01:49:25 +08:00
|
|
|
|
2017-01-11 20:08:28 +08:00
|
|
|
const Watchpack = require("watchpack");
|
2013-02-11 07:17:29 +08:00
|
|
|
|
2017-01-11 20:08:28 +08:00
|
|
|
class NodeWatchFileSystem {
|
|
|
|
constructor(inputFileSystem) {
|
|
|
|
this.inputFileSystem = inputFileSystem;
|
|
|
|
this.watcherOptions = {
|
|
|
|
aggregateTimeout: 0
|
|
|
|
};
|
|
|
|
this.watcher = new Watchpack(this.watcherOptions);
|
|
|
|
}
|
2013-02-11 07:17:29 +08:00
|
|
|
|
2017-01-11 20:08:28 +08:00
|
|
|
watch(files, dirs, missing, startTime, options, callback, callbackUndelayed) {
|
|
|
|
if(!Array.isArray(files))
|
|
|
|
throw new Error("Invalid arguments: 'files'");
|
|
|
|
if(!Array.isArray(dirs))
|
|
|
|
throw new Error("Invalid arguments: 'dirs'");
|
|
|
|
if(!Array.isArray(missing))
|
|
|
|
throw new Error("Invalid arguments: 'missing'");
|
|
|
|
if(typeof callback !== "function")
|
|
|
|
throw new Error("Invalid arguments: 'callback'");
|
|
|
|
if(typeof startTime !== "number" && startTime)
|
|
|
|
throw new Error("Invalid arguments: 'startTime'");
|
|
|
|
if(typeof options !== "object")
|
|
|
|
throw new Error("Invalid arguments: 'options'");
|
|
|
|
if(typeof callbackUndelayed !== "function" && callbackUndelayed)
|
|
|
|
throw new Error("Invalid arguments: 'callbackUndelayed'");
|
|
|
|
const oldWatcher = this.watcher;
|
|
|
|
this.watcher = new Watchpack(options);
|
2013-02-01 01:00:22 +08:00
|
|
|
|
2017-01-11 20:08:28 +08:00
|
|
|
if(callbackUndelayed)
|
|
|
|
this.watcher.once("change", callbackUndelayed);
|
2015-01-18 06:43:25 +08:00
|
|
|
|
2017-01-18 05:26:38 +08:00
|
|
|
this.watcher.once("aggregated", (changes, removals) => {
|
|
|
|
changes = changes.concat(removals);
|
2017-01-11 20:08:28 +08:00
|
|
|
if(this.inputFileSystem && this.inputFileSystem.purge) {
|
|
|
|
this.inputFileSystem.purge(changes);
|
|
|
|
}
|
|
|
|
const times = this.watcher.getTimes();
|
|
|
|
callback(null,
|
|
|
|
changes.filter(file => files.indexOf(file) >= 0).sort(),
|
|
|
|
changes.filter(file => dirs.indexOf(file) >= 0).sort(),
|
|
|
|
changes.filter(file => missing.indexOf(file) >= 0).sort(), times, times);
|
2017-01-26 06:39:32 +08:00
|
|
|
});
|
2015-01-18 04:55:44 +08:00
|
|
|
|
2017-07-15 16:27:01 +08:00
|
|
|
this.watcher.watch(files.concat(missing), dirs.concat(missing), startTime);
|
2015-01-18 04:55:44 +08:00
|
|
|
|
2017-01-11 20:08:28 +08:00
|
|
|
if(oldWatcher) {
|
|
|
|
oldWatcher.close();
|
|
|
|
}
|
|
|
|
return {
|
2017-01-26 06:39:32 +08:00
|
|
|
close: () => {
|
2017-02-22 17:45:49 +08:00
|
|
|
if(this.watcher) {
|
|
|
|
this.watcher.close();
|
|
|
|
this.watcher = null;
|
|
|
|
}
|
2017-01-26 06:39:32 +08:00
|
|
|
},
|
|
|
|
pause: () => {
|
2017-02-22 17:45:49 +08:00
|
|
|
if(this.watcher) {
|
|
|
|
this.watcher.pause();
|
|
|
|
}
|
2017-01-26 06:39:32 +08:00
|
|
|
}
|
2017-01-11 20:08:28 +08:00
|
|
|
};
|
2013-02-01 01:00:22 +08:00
|
|
|
}
|
2017-01-11 20:08:28 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = NodeWatchFileSystem;
|