diff options
Diffstat (limited to 'node_modules/cache-loader/dist/index.js')
| -rw-r--r-- | node_modules/cache-loader/dist/index.js | 227 |
1 files changed, 0 insertions, 227 deletions
diff --git a/node_modules/cache-loader/dist/index.js b/node_modules/cache-loader/dist/index.js deleted file mode 100644 index 93cb6b96..00000000 --- a/node_modules/cache-loader/dist/index.js +++ /dev/null @@ -1,227 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); - -var _slicedToArray = function () { function sliceIterator(arr, i) { var _arr = []; var _n = true; var _d = false; var _e = undefined; try { for (var _i = arr[Symbol.iterator](), _s; !(_n = (_s = _i.next()).done); _n = true) { _arr.push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } finally { try { if (!_n && _i["return"]) _i["return"](); } finally { if (_d) throw _e; } } return _arr; } return function (arr, i) { if (Array.isArray(arr)) { return arr; } else if (Symbol.iterator in Object(arr)) { return sliceIterator(arr, i); } else { throw new TypeError("Invalid attempt to destructure non-iterable instance"); } }; }(); - -function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } } - -/* eslint-disable - import/order -*/ -var fs = require('fs'); -var path = require('path'); -var async = require('neo-async'); -var crypto = require('crypto'); -var mkdirp = require('mkdirp'); - -var _require = require('loader-utils'), - getOptions = _require.getOptions; - -var validateOptions = require('schema-utils'); - -var pkg = require('../package.json'); - -var env = process.env.NODE_ENV || 'development'; - -var schema = require('./options.json'); - -var defaults = { - cacheDirectory: path.resolve('.cache-loader'), - cacheIdentifier: `cache-loader:${pkg.version} ${env}`, - cacheKey, - read, - write -}; - -function loader() { - for (var _len = arguments.length, args = Array(_len), _key = 0; _key < _len; _key++) { - args[_key] = arguments[_key]; - } - - var options = Object.assign({}, defaults, getOptions(this)); - - validateOptions(schema, options, 'Cache Loader'); - - var writeFn = options.write; - - - var callback = this.async(); - var data = this.data; - - var dependencies = this.getDependencies().concat(this.loaders.map(function (l) { - return l.path; - })); - var contextDependencies = this.getContextDependencies(); - - // Should the file get cached? - var cache = true; - // this.fs can be undefined - // e.g when using the thread-loader - // fallback to the fs module - var FS = this.fs || fs; - var toDepDetails = function toDepDetails(dep, mapCallback) { - FS.stat(dep, function (err, stats) { - if (err) { - mapCallback(err); - return; - } - - var mtime = stats.mtime.getTime(); - - if (mtime / 1000 >= Math.floor(data.startTime / 1000)) { - // Don't trust mtime. - // File was changed while compiling - // or it could be an inaccurate filesystem. - cache = false; - } - - mapCallback(null, { - path: dep, - mtime - }); - }); - }; - - async.parallel([function (cb) { - return async.mapLimit(dependencies, 20, toDepDetails, cb); - }, function (cb) { - return async.mapLimit(contextDependencies, 20, toDepDetails, cb); - }], function (err, taskResults) { - if (err) { - callback.apply(undefined, [null].concat(args)); - return; - } - if (!cache) { - callback.apply(undefined, [null].concat(args)); - return; - } - - var _taskResults = _slicedToArray(taskResults, 2), - deps = _taskResults[0], - contextDeps = _taskResults[1]; - - writeFn(data.cacheKey, { - remainingRequest: data.remainingRequest, - dependencies: deps, - contextDependencies: contextDeps, - result: args - }, function () { - // ignore errors here - callback.apply(undefined, [null].concat(args)); - }); - }); -} - -function pitch(remainingRequest, prevRequest, dataInput) { - var _this = this; - - var options = Object.assign({}, defaults, getOptions(this)); - - validateOptions(schema, options, 'Cache Loader (Pitch)'); - - var readFn = options.read, - cacheKeyFn = options.cacheKey; - - - var callback = this.async(); - var data = dataInput; - - data.remainingRequest = remainingRequest; - data.cacheKey = cacheKeyFn(options, remainingRequest); - readFn(data.cacheKey, function (readErr, cacheData) { - if (readErr) { - callback(); - return; - } - if (cacheData.remainingRequest !== remainingRequest) { - // in case of a hash conflict - callback(); - return; - } - var FS = _this.fs || fs; - async.each(cacheData.dependencies.concat(cacheData.contextDependencies), function (dep, eachCallback) { - FS.stat(dep.path, function (statErr, stats) { - if (statErr) { - eachCallback(statErr); - return; - } - if (stats.mtime.getTime() !== dep.mtime) { - eachCallback(true); - return; - } - eachCallback(); - }); - }, function (err) { - if (err) { - data.startTime = Date.now(); - callback(); - return; - } - cacheData.dependencies.forEach(function (dep) { - return _this.addDependency(dep.path); - }); - cacheData.contextDependencies.forEach(function (dep) { - return _this.addContextDependency(dep.path); - }); - callback.apply(undefined, [null].concat(_toConsumableArray(cacheData.result))); - }); - }); -} - -function digest(str) { - return crypto.createHash('md5').update(str).digest('hex'); -} - -var directories = new Set(); - -function write(key, data, callback) { - var dirname = path.dirname(key); - var content = JSON.stringify(data); - - if (directories.has(dirname)) { - // for performance skip creating directory - fs.writeFile(key, content, 'utf-8', callback); - } else { - mkdirp(dirname, function (mkdirErr) { - if (mkdirErr) { - callback(mkdirErr); - return; - } - - directories.add(dirname); - - fs.writeFile(key, content, 'utf-8', callback); - }); - } -} - -function read(key, callback) { - fs.readFile(key, 'utf-8', function (err, content) { - if (err) { - callback(err); - return; - } - - try { - var data = JSON.parse(content); - callback(null, data); - } catch (e) { - callback(e); - } - }); -} - -function cacheKey(options, request) { - var cacheIdentifier = options.cacheIdentifier, - cacheDirectory = options.cacheDirectory; - - var hash = digest(`${cacheIdentifier}\n${request}`); - - return path.join(cacheDirectory, `${hash}.json`); -} - -exports.default = loader; -exports.pitch = pitch;
\ No newline at end of file |