/
loader.js
68 lines (57 loc) · 1.52 KB
/
loader.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
/* eslint-disable no-implicit-coercion, no-shadow */
var Promise = require('lie');
var loader = require('little-loader');
var cache = global.__requireAsyncCache = global.__requireAsyncCache || {};
function createBundlePromise ( opts, _require, urlRoot ) {
return Promise.resolve()
.then(function () {
return _require('' + opts.name);
})
.catch(function () {
return new Promise(function ( resolve, reject ) {
loader(urlRoot + opts.url, function ( err ) {
if ( err ) {
return reject(err);
}
try {
resolve(_require('' + opts.name));
} catch ( err1 ) {
if ( /require.async/.test(err1) ) {
return reject(Error(err1));
}
try {
resolve(_require('' + opts.hash));
} catch ( err2 ) {
reject(Error(err1));
}
}
});
});
});
}
module.exports = function ( _require, options ) {
return function ( el, cb, errCb ) {
var bundles = [].concat(el);
var promises = [];
var bundle, i, bundlesLength;
for ( i = 0, bundlesLength = bundles.length; i < bundlesLength; i++ ) {
bundle = bundles[i];
if ( !cache[bundle.hash] ) {
cache[bundle.hash] = createBundlePromise(bundle, _require, options.urlRoot);
}
promises.push(cache[bundle.hash]);
}
return Promise.all(promises)
.then(function ( reqs ) {
return cb && cb.apply(null, reqs);
})
.catch(function ( err ) {
if ( options.rethrowError ) {
return setTimeout(function () {
throw err;
}, 0);
}
return errCb && errCb(err);
});
};
};