feat(tcp crud): tcp server start, stop, restart endpoints + status check

backend/tcpServer/tcp.server.ts

@@ -3,13 +3,14 @@ import { eq } from "drizzle-orm";
 import { db } from "../db/db.controller.js";
 import { printerData } from "../db/schema/printers.schema.js";
 import { createLogger } from "../logger/logger.controller.js";
+import { delay } from "../utils/delay.utils.js";
 import { returnFunc } from "../utils/returnHelper.utils.js";
 import { tryCatch } from "../utils/trycatch.utils.js";
 import { type PrinterData, printerListen } from "./tcp.printerListener.js";
 
 let tcpServer: net.Server;
 const tcpSockets: Set<net.Socket> = new Set();
-//let isServerRunning = false;
+export let isServerRunning = false;
 
 const port = parseInt(process.env.TCP_PORT ?? "2222", 10);
 
@@ -39,9 +40,8 @@ const parseTcpAlert = (input: string) => {
 		name,
 	};
 };
-
-export const startTCPServer = () => {
-	const log = createLogger({ module: "tcp", submodule: "create_server" });
+const log = createLogger({ module: "tcp", submodule: "create_server" });
+export const startTCPServer = async () => {
 	tcpServer = net.createServer(async (socket) => {
 		tcpSockets.add(socket);
 		socket.on("data", async (data: Buffer) => {
@@ -103,7 +103,7 @@ export const startTCPServer = () => {
 		log.info({}, `TCP Server listening on port ${port}`);
 	});
 
-	//isServerRunning = true;
+	isServerRunning = true;
 	return returnFunc({
 		success: true,
 		level: "info",
@@ -115,3 +115,66 @@ export const startTCPServer = () => {
 		room: "",
 	});
 };
+
+export const stopTCPServer = async () => {
+	if (!isServerRunning)
+		return { success: false, message: "Server is not running" };
+	for (const socket of tcpSockets) {
+		socket.destroy();
+	}
+	tcpSockets.clear();
+	tcpServer.close(() => {
+		log.info({}, "TCP Server stopped");
+	});
+	isServerRunning = false;
+	return returnFunc({
+		success: true,
+		level: "info",
+		module: "tcp",
+		subModule: "create_server",
+		message: "TCP server stopped.",
+		data: [],
+		notify: false,
+		room: "",
+	});
+};
+
+export const restartTCPServer = async () => {
+	if (!isServerRunning) {
+		startTCPServer();
+		return returnFunc({
+			success: false,
+			level: "warn",
+			module: "tcp",
+			subModule: "create_server",
+			message: "Server is not running will try to start it",
+			data: [],
+			notify: false,
+			room: "",
+		});
+	} else {
+		for (const socket of tcpSockets) {
+			socket.destroy();
+		}
+		tcpSockets.clear();
+		tcpServer.close(() => {
+			log.info({}, "TCP Server stopped");
+		});
+		isServerRunning = false;
+
+		await delay(1500);
+
+		startTCPServer();
+	}
+
+	return returnFunc({
+		success: true,
+		level: "info",
+		module: "tcp",
+		subModule: "create_server",
+		message: "TCP server has been restarted.",
+		data: [],
+		notify: false,
+		room: "",
+	});
+};