aboutsummaryrefslogtreecommitdiff
path: root/src/server/session_manager/session_manager.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/session_manager/session_manager.ts')
-rw-r--r--src/server/session_manager/session_manager.ts7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/server/session_manager/session_manager.ts b/src/server/session_manager/session_manager.ts
index 6084d9a77..97c2ab214 100644
--- a/src/server/session_manager/session_manager.ts
+++ b/src/server/session_manager/session_manager.ts
@@ -9,13 +9,18 @@ import { ChildProcess, exec, execSync } from "child_process";
import InputManager from "./input_manager";
import { identifier, logPath, crashPath, onWindows, pid, ports, heartbeat, recipient, latency, SessionState } from "./config";
const killport = require("kill-port");
+import * as io from "socket.io";
process.on('SIGINT', endPrevious);
let state: SessionState = SessionState.STARTING;
const is = (...reference: SessionState[]) => reference.includes(state);
const set = (reference: SessionState) => state = reference;
+const endpoint = io();
+endpoint.on("connection", socket => {
+});
+endpoint.listen(process.env.PORT);
const { registerCommand } = new InputManager({ identifier });
@@ -116,7 +121,7 @@ function timestamp() {
async function endPrevious() {
identifiedLog(yellow("Cleaning up previous connections..."));
- current_backup?.kill("SIGKILL");
+ current_backup?.kill();
await Promise.all(ports.map(port => {
const task = killport(port, 'tcp');
return task.catch((error: any) => identifiedLog(red(error)));