fix(tcp): added in a catch if ocme is not active and we dont have a zebra camera

This commit is contained in:
2025-04-03 06:08:15 -05:00
parent 7e34d42fda
commit b9397c029f

View File

@@ -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<net.Socket> = 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);
});