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
|
import { existsSync, mkdirSync, createWriteStream } from "fs";
import { pathFromRoot, log_execution } from './ActionUtilities';
import { red, green } from "colors";
import rimraf = require("rimraf");
import { ChildProcess, spawn } from "child_process";
import { Stream } from "stream";
const daemonPath = pathFromRoot("./src/server/daemon/persistence_daemon.ts");
export namespace ProcessManager {
export async function initialize() {
const logPath = pathFromRoot("./logs");
if (existsSync(logPath)) {
if (!process.env.SPAWNED) {
await new Promise<any>(resolve => rimraf(logPath, resolve));
}
}
mkdirSync(logPath);
}
function generate_log_name(command: string, args?: readonly string[]) {
return pathFromRoot(`./logs/${command}-${args?.length}-${new Date().toUTCString()}.log`);
}
export type Sink = "pipe" | "ipc" | "ignore" | "inherit" | Stream | number | null | undefined;
export async function spawn_detached(command: string, args?: readonly string[], out?: Sink): Promise<ChildProcess> {
if (!out) {
const logStream = createWriteStream(generate_log_name(command, args));
out = await new Promise<number>(resolve => logStream.on("open", resolve));
}
const child = spawn(command, args, { detached: true, stdio: ["ignore", out, out] });
child.unref();
return child;
}
let daemonInitialized = false;
export async function trySpawnDaemon() {
if (!process.env.SPAWNED && !daemonInitialized) {
daemonInitialized = true;
await log_execution({
startMessage: "\ninitializing persistence daemon",
endMessage: ({ result, error }) => {
const success = error === null && result !== undefined;
if (!success) {
console.log(red("failed to initialize the persistance daemon"));
console.log(error);
process.exit(0);
}
return "failsafe daemon process successfully spawned";
},
action: () => spawn_detached('npx', ['ts-node', daemonPath], process.stdout),
color: green
});
console.log();
}
}
}
|
