diff --git a/server/services/tcpServer/tcpServer.ts b/server/services/tcpServer/tcpServer.ts index e7d5d9b..bee4951 100644 --- a/server/services/tcpServer/tcpServer.ts +++ b/server/services/tcpServer/tcpServer.ts @@ -9,6 +9,7 @@ import { db } from "../../../database/dbclient.js"; import { settings } from "../../../database/schema/settings.js"; import { eq } from "drizzle-orm"; import { postLabelData } from "../ocme/controller/postRunningNr.js"; +import { tryCatch } from "../../globalUtils/tryCatch.js"; let tcpServer: net.Server; let tcpSockets: Set = new Set(); @@ -27,8 +28,23 @@ export const startTCPServer = () => { if (isServerRunning) return { success: false, message: "Server is already running" }; - tcpServer = net.createServer((socket) => { - createLog("info", "tcp", "tcp", "Client connected"); + tcpServer = net.createServer(async (socket) => { + createLog("debug", "tcp", "tcp", "Client connected"); + + const { data: setting, error: settingError } = await tryCatch( + db.select().from(settings) + ); + if (settingError) { + return { + success: false, + message: "Error getting settings", + data: [], + }; + } + + const settingCheck = setting.filter( + (newData) => newData.name === "ocmeService" + ); tcpSockets.add(socket); socket.on("data", (data: Buffer) => { @@ -50,11 +66,14 @@ export const startTCPServer = () => { } // from the wrapper send the data - postLabelData(parseData); + const ocmeSetting: any = settingCheck; + if (ocmeSetting[0]?.value === "1") { + postLabelData(parseData); + } }); socket.on("end", () => { - createLog("info", "tcp", "tcp", "Client disconnected"); + createLog("debug", "tcp", "tcp", "Client disconnected"); tcpSockets.delete(socket); });