refactor(tcpserver): just the tcp server doing something

server/services/tcpServer/tcpServer.ts

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