aboutsummaryrefslogtreecommitdiff
path: root/src/server/ProcessManager.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2019-12-11 13:54:28 -0500
committerSam Wilkins <samwilkins333@gmail.com>2019-12-11 13:54:28 -0500
commitae3603e26adb635380d530b84cb9d6f1284066ef (patch)
tree8d2a84489765126c6246281f55f9cf7c3957c5fe /src/server/ProcessManager.ts
parentad079a088ae9262a4a40a2f0d2a2c5d948140492 (diff)
process factory refactor
Diffstat (limited to 'src/server/ProcessManager.ts')
-rw-r--r--src/server/ProcessManager.ts60
1 files changed, 0 insertions, 60 deletions
diff --git a/src/server/ProcessManager.ts b/src/server/ProcessManager.ts
deleted file mode 100644
index 671f0a234..000000000
--- a/src/server/ProcessManager.ts
+++ /dev/null
@@ -1,60 +0,0 @@
-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();
- }
- }
-
-} \ No newline at end of file