refactor(es6): Upgrade CachePlugin to es6 (#3680)

webpack · Jan 2, 2017 · 9f3b868 · 9f3b868
1 parent b1c7d5c
commit 9f3b868
Showing 1 changed file with 65 additions and 62 deletions.
diff --git a/lib/CachePlugin.js b/lib/CachePlugin.js
@@ -2,75 +2,78 @@
 	MIT License http://www.opensource.org/licenses/mit-license.php
 	Author Tobias Koppers @sokra
 */
-var async = require("async");
+"use strict";
 
-function CachePlugin(cache) {
-	this.cache = cache || {};
-	this.FS_ACCURENCY = 2000;
-}
-module.exports = CachePlugin;
+const async = require("async");
 
-CachePlugin.prototype.apply = function(compiler) {
-	if(Array.isArray(compiler.compilers)) {
-		compiler.compilers.forEach(function(c, idx) {
-			c.apply(new CachePlugin(this.cache[idx] = this.cache[idx] || {}));
-		}, this);
-	} else {
-		var _this = this;
-		compiler.plugin("compilation", function(compilation) {
-			if(!compilation.notCacheable) {
-				compilation.cache = _this.cache;
-			} else if(_this.watching) {
-				compilation.warnings.push(
-					new Error("CachePlugin - Cache cannot be used because of: " + compilation.notCacheable)
-				);
-			}
-		});
-		compiler.plugin("watch-run", function(compiler, callback) {
-			_this.watching = true;
-			callback();
-		});
-		compiler.plugin("run", function(compiler, callback) {
-			if(!compiler._lastCompilationFileDependencies) return callback();
-			var fs = compiler.inputFileSystem;
-			var fileTs = compiler.fileTimestamps = {};
-			async.forEach(compiler._lastCompilationFileDependencies, function(file, callback) {
-				fs.stat(file, function(err, stat) {
-					if(err) {
-						if(err.code === "ENOENT") return callback();
-						return callback(err);
-					}
+class CachePlugin {
+	constructor(cache) {
+		this.cache = cache || {};
+		this.FS_ACCURENCY = 2000;
+	}
 
-					if(stat.mtime)
-						_this.applyMtime(+stat.mtime);
+	apply(compiler) {
+		if(Array.isArray(compiler.compilers)) {
+			compiler.compilers.forEach((c, idx) => {
+				c.apply(new CachePlugin(this.cache[idx] = this.cache[idx] || {}));
+			});
+		} else {
+			compiler.plugin("compilation", compilation => {
+				if(!compilation.notCacheable) {
+					compilation.cache = this.cache;
+				} else if(this.watching) {
+					compilation.warnings.push(
+						new Error(`CachePlugin - Cache cannot be used because of: ${compilation.notCacheable}`)
+					);
+				}
+			});
+			compiler.plugin("watch-run", (compiler, callback) => {
+				this.watching = true;
+				callback();
+			});
+			compiler.plugin("run", (compiler, callback) => {
+				if(!compiler._lastCompilationFileDependencies) return callback();
+				const fs = compiler.inputFileSystem;
+				const fileTs = compiler.fileTimestamps = {};
+				async.forEach(compiler._lastCompilationFileDependencies, (file, callback) => {
+					fs.stat(file, (err, stat) => {
+						if(err) {
+							if(err.code === "ENOENT") return callback();
+							return callback(err);
+						}
 
-					fileTs[file] = +stat.mtime || Infinity;
+						if(stat.mtime)
+							this.applyMtime(+stat.mtime);
+
+						fileTs[file] = +stat.mtime || Infinity;
+						callback();
+					});
+				}, err => {
+					if(err) return callback(err);
+					Object.keys(fileTs).forEach(key => {
+						fileTs[key] += this.FS_ACCURENCY;
+					});
 					callback();
 				});
-			}, function(err) {
-				if(err) return callback(err);
-				Object.keys(fileTs).forEach(function(key) {
-					fileTs[key] += _this.FS_ACCURENCY;
-				});
+			});
+			compiler.plugin("after-compile", function(compilation, callback) {
+				compilation.compiler._lastCompilationFileDependencies = compilation.fileDependencies;
+				compilation.compiler._lastCompilationContextDependencies = compilation.contextDependencies;
 				callback();
 			});
-		});
-		compiler.plugin("after-compile", function(compilation, callback) {
-			compilation.compiler._lastCompilationFileDependencies = compilation.fileDependencies;
-			compilation.compiler._lastCompilationContextDependencies = compilation.contextDependencies;
-			callback();
-		});
+		}
 	}
-};
 
-/* istanbul ignore next */
-CachePlugin.prototype.applyMtime = function applyMtime(mtime) {
-	if(this.FS_ACCURENCY > 1 && mtime % 2 !== 0)
-		this.FS_ACCURENCY = 1;
-	else if(this.FS_ACCURENCY > 10 && mtime % 20 !== 0)
-		this.FS_ACCURENCY = 10;
-	else if(this.FS_ACCURENCY > 100 && mtime % 200 !== 0)
-		this.FS_ACCURENCY = 100;
-	else if(this.FS_ACCURENCY > 1000 && mtime % 2000 !== 0)
-		this.FS_ACCURENCY = 1000;
-};
+	/* istanbul ignore next */
+	applyMtime(mtime) {
+		if(this.FS_ACCURENCY > 1 && mtime % 2 !== 0)
+			this.FS_ACCURENCY = 1;
+		else if(this.FS_ACCURENCY > 10 && mtime % 20 !== 0)
+			this.FS_ACCURENCY = 10;
+		else if(this.FS_ACCURENCY > 100 && mtime % 200 !== 0)
+			this.FS_ACCURENCY = 100;
+		else if(this.FS_ACCURENCY > 1000 && mtime % 2000 !== 0)
+			this.FS_ACCURENCY = 1000;
+	}
+}
+module.exports = CachePlugin;