From 04eb2e3e145ba99b330ab627fcd9bae436e17fcf Mon Sep 17 00:00:00 2001
From: Blake Matthes <cowchmonkey@gmail.com>
Date: Tue, 25 Mar 2025 07:58:37 -0500
Subject: [PATCH] refactor(tcpserver): just the tcp server doing something

---
 server/services/tcpServer/tcpServer.ts | 106 ++++++++++++-------------
 1 file changed, 53 insertions(+), 53 deletions(-)

diff --git a/server/services/tcpServer/tcpServer.ts b/server/services/tcpServer/tcpServer.ts
index 459fec6..4811115 100644
--- a/server/services/tcpServer/tcpServer.ts
+++ b/server/services/tcpServer/tcpServer.ts
@@ -15,73 +15,73 @@ let tcpSockets: Set<net.Socket> = new Set();
 let isServerRunning = false;
 
 const tcpPort = await db
-  .select()
-  .from(settings)
-  .where(eq(settings.name, "tcpPort"));
+    .select()
+    .from(settings)
+    .where(eq(settings.name, "tcpPort"));
 const app = new OpenAPIHono();
 
 export const startTCPServer = () => {
-  if (isServerRunning)
-    return { success: false, message: "Server is already running" };
+    if (isServerRunning)
+        return { success: false, message: "Server is already running" };
 
-  tcpServer = net.createServer((socket) => {
-    console.log("Client connected");
+    tcpServer = net.createServer((socket) => {
+        console.log("Client connected");
 
-    tcpSockets.add(socket);
-    socket.on("data", (data: Buffer) => {
-      console.log("Received:", data.toString());
-      const parseData = data.toString("utf-8").trimEnd().split(" ");
-      // hb from the scanners
-      if (parseData[0] === "HB") {
-        return;
-      }
+        tcpSockets.add(socket);
+        socket.on("data", (data: Buffer) => {
+            console.log("Received:", data.toString());
+            const parseData = data.toString("utf-8").trimEnd().split(" ");
+            // hb from the scanners
+            if (parseData[0] === "HB") {
+                return;
+            }
 
-      // alert from the printers
-      if (parseData[0] === "ALERT:" || parseData[0] === "ALERT") {
-        return;
-      }
+            // alert from the printers
+            if (parseData[0] === "ALERT:" || parseData[0] === "ALERT") {
+                return;
+            }
 
-      // from the wrapper send the data
-      postLabelData(parseData);
+            // from the wrapper send the data
+            postLabelData(parseData);
+        });
+
+        socket.on("end", () => {
+            console.log("Client disconnected");
+            tcpSockets.delete(socket);
+        });
+
+        socket.on("error", (err: Error) => {
+            console.error("Socket error:", err);
+            tcpSockets.delete(socket);
+        });
     });
 
-    socket.on("end", () => {
-      console.log("Client disconnected");
-      tcpSockets.delete(socket);
+    tcpServer.listen(tcpPort[0]?.value ?? 2222, () => {
+        createLog(
+            "info",
+            "lst",
+            "tcp",
+            `TCP Server listening on port ${tcpPort[0]?.value ?? 2222}`
+        );
     });
 
-    socket.on("error", (err: Error) => {
-      console.error("Socket error:", err);
-      tcpSockets.delete(socket);
-    });
-  });
-
-  tcpServer.listen(tcpPort[0]?.value ?? 2222, () => {
-    createLog(
-      "info",
-      "lst",
-      "tcp",
-      `TCP Server listening on port ${tcpPort[0]?.value ?? 2222}`
-    );
-  });
-
-  isServerRunning = true;
-  return { success: true, message: "TCP Server started" };
+    isServerRunning = true;
+    return { success: true, message: "TCP Server started" };
 };
 
 // Function to stop the TCP server
 export const stopTCPServer = () => {
-  if (!isServerRunning)
-    return { success: false, message: "Server is not running" };
-  for (const socket of tcpSockets) {
-    socket.destroy();
-  }
-  tcpSockets.clear();
-  tcpServer.close(() => {
-    console.log("TCP Server stopped");
-  });
-  isServerRunning = false;
-  return { success: true, message: "TCP Server stopped" };
+    if (!isServerRunning)
+        return { success: false, message: "Server is not running" };
+    for (const socket of tcpSockets) {
+        socket.destroy();
+    }
+    tcpSockets.clear();
+    tcpServer.close(() => {
+        console.log("TCP Server stopped");
+    });
+    isServerRunning = false;
+    return { success: true, message: "TCP Server stopped" };
 };
 
 app.route("/tcpserver/start", startTCP);
@@ -90,7 +90,7 @@ app.route("/tcpserver/restart", restartTCP);
 
 // start the server after on system start up
 setTimeout(() => {
-  startTCPServer();
+    startTCPServer();
 }, 5000);
 
 export default app;