forked from webpack/webpack
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathworker.js
More file actions
71 lines (69 loc) · 1.96 KB
/
worker.js
File metadata and controls
71 lines (69 loc) · 1.96 KB
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
69
70
71
/*
MIT License http://www.opensource.org/licenses/mit-license.php
Author Tobias Koppers @sokra
*/
var buildModule = require("./buildModule");
var resolve = require("enhanced-resolve");
var registers = {};
function applyRegister(arr) {
var regMapping = arr.splice(2, 1)[0];
var regName = arr[1];
if(regMapping) {
var reg = registers[regName];
for(var i = 0; i < regMapping.length; i++) {
if(regMapping[i])
arr[i+2] = reg[i];
}
}
registers[regName] = arr.slice(2);
for(var i = 2; i < arr.length; i++)
arr[i] = JSON.parse(arr[i]);
}
process.on("message", function(msg) {
if(!msg) return process.send("ready");
// setTimeout(function() {
var id = msg[0];
try {
applyRegister(msg);
switch(msg[1]) {
case "buildModule":
var context = msg[2],
filenameWithLoaders = msg[3],
preLoaders = msg[4],
loaders = msg[5],
postLoaders = msg[6],
filename = msg[7],
options = msg[8];
buildModule(context, filenameWithLoaders,
preLoaders, loaders, postLoaders,
filename,
options, function(err, extraResults, source, deps) {
if(err) err = { message: err.message, stack: err.stack, _toString: err.toString() };
process.send([id, err, extraResults, source, deps]);
});
break;
case "resolve":
var context = msg[2];
var module = msg[3];
var options = msg[4];
resolve(context, module, options, function(err, filename) {
if(err) err = { message: err.message, stack: err.stack, _toString: err.toString() };
process.send([id, err, filename]);
})
break;
case "resolve.loaders":
var context = msg[2];
var loaders = msg[3];
var options = msg[4];
resolve.loaders(context, loaders, options, function(err, loaders) {
if(err) err = { message: err.message, stack: err.stack, _toString: err.toString() };
process.send([id, err, loaders]);
})
break;
default: throw new Error("Worker msg type " + msg[1] + " is not supported");
}
} catch(e) {
process.send([id, e]);
}
// }, 2000);
});