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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
let fs = require("fs-extra");
let spawn = require("child_process");
class RuntimeProcess {
constructor(_modePath, _eventEmitter) {
this.modePath = _modePath;
this.logfile = `${this.modePath}/mode.log`;
this.errfile = `${this.modePath}/mode.error`;
this.stdout = "";
this.stderr = "";
this.fl = false;
this.proc = null;
this.isRunning = false;
this.exitCode = null;
this.eventEmitter = _eventEmitter;
}
start() {
if (this.isRunning) {
console.log("PROCESS ALREADY RUNNING");
return;
}
this.isRunning = true;
this.proc = spawn.spawn(
"python3",
[
"-u", // This makes us able to get real-time output
`${__basedir}/NeoRuntime/Runtime/neo_runtime.py`,
`--strip-config="${__datadir}/config/strip.ini"`,
`--mode-path="${this.modePath}"`,
`--mode-entry=script`
]
);
this.proc.on('error', (err) => {
console.log(err);
});
fs.ensureFileSync(this.logfile);
fs.ensureFileSync(this.errfile);
this.eventEmitter.emit("proc:start");
this.proc.stdout.on('data', (_stdout) => {
let stdout_str = _stdout.toString();
fs.appendFile(this.logfile, `[${timestamp()}]: ` + stdout_str);
this.eventEmitter.emit("proc:stdout", stdout_str);
});
this.proc.stdout.on('end', () => {
fs.appendFile(this.logfile, "\n");
});
this.proc.stderr.on('data', (_stderr) => {
let stderr_str = _stderr.toString();
fs.appendFile(this.errfile, `[${timestamp()}]: ` + stderr_str);
this.eventEmitter.emit("proc:stderr", stderr_str);
});
this.proc.stderr.on('end', () => {
fs.appendFile(this.logfile, "\n");
});
this.proc.on('close', (code) => {
if (code) {
fs.appendFile(this.logfile, `[${timestamp()}]: ` + "Script exited with code " + code.toString());
}
this.eventEmitter.emit("proc:exit", 0);
this.isRunning = false;
this.exitCode = code;
});
}
stop(restart=false) {
try {
if (restart) {
this.proc.once("close", () => {
setTimeout(() => this.start(), 500);
});
}
this.proc.kill("SIGINT");
} catch (err) {
console.log(err);
}
}
}
/**
* Creates and returns a timestamp that can be used in logfiles.
*
* @return {string} timestamp
*/
function timestamp() {
return (new Date()).toISOString();
}
module.exports = RuntimeProcess;
|
