/
server-worker-main.ts
50 lines (41 loc) · 1.5 KB
/
server-worker-main.ts
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
import type * as d from '../declarations';
import { fork } from 'child_process';
import path from 'path';
export function initServerProcessWorkerProxy(sendToMain: (msg: d.DevServerMessage) => void) {
const workerPath = require.resolve(path.join(__dirname, 'server-worker-thread.js'));
const filteredExecArgs = process.execArgv.filter(v => !/^--(debug|inspect)/.test(v));
const forkOpts: any = {
execArgv: filteredExecArgs,
env: process.env,
cwd: process.cwd(),
stdio: ['pipe', 'pipe', 'pipe', 'ipc'],
};
// start a new child process of the CLI process
// for the http and web socket server
let serverProcess = fork(workerPath, [], forkOpts);
const receiveFromMain = (msg: d.DevServerMessage) => {
// get a message from main to send to the worker
if (serverProcess) {
serverProcess.send(msg);
} else if (msg.closeServer) {
sendToMain({ serverClosed: true });
}
};
// get a message from the worker and send it to main
serverProcess.on('message', (msg: d.DevServerMessage) => {
if (msg.serverClosed && serverProcess) {
serverProcess.kill();
serverProcess = null;
}
sendToMain(msg);
});
serverProcess.stdout.on('data', (data: any) => {
// the child server process has console logged data
console.log(`dev server: ${data}`);
});
serverProcess.stderr.on('data', (data: any) => {
// the child server process has console logged an error
sendToMain({ error: { message: 'stderr: ' + data } });
});
return receiveFromMain;
}