refactor(tcpserver): just the tcp server doing something

.vscode/settings.json

@@ -1,26 +1,28 @@
 {
-  "editor.defaultFormatter": "esbenp.prettier-vscode",
-
-  "editor.formatOnSave": true,
-  "[javascript]": {
-    "editor.formatOnSave": true
-  },
-  "[javascriptreact]": {
-    "editor.formatOnSave": true
-  },
-  "[typescript]": {
-    "editor.formatOnSave": true
-  },
-  "[typescriptreact]": {
-    "editor.formatOnSave": true
-  },
-  "[json]": {
-    "editor.formatOnSave": true
-  },
-  "[graphql]": {
-    "editor.formatOnSave": true
-  },
-  "[handlebars]": {
-    "editor.formatOnSave": true
-  }
+    "editor.defaultFormatter": "esbenp.prettier-vscode",
+    "workbench.colorTheme": "Default Dark+",
+    "prettier.tabWidth": 4,
+    "terminal.integrated.env.windows": {},
+    "editor.formatOnSave": true,
+    "[javascript]": {
+        "editor.formatOnSave": true
+    },
+    "[javascriptreact]": {
+        "editor.formatOnSave": true
+    },
+    "[typescript]": {
+        "editor.formatOnSave": true
+    },
+    "[typescriptreact]": {
+        "editor.formatOnSave": true
+    },
+    "[json]": {
+        "editor.formatOnSave": true
+    },
+    "[graphql]": {
+        "editor.formatOnSave": true
+    },
+    "[handlebars]": {
+        "editor.formatOnSave": true
+    }
 }

frontend/src/components/ocme/ocmeCycleCount.tsx

@@ -3,210 +3,239 @@ import { LstCard } from "../extendedUI/LstCard";
 import { Button } from "../ui/button";
 import { Input } from "../ui/input";
 import {
-  Table,
-  TableBody,
-  TableCell,
-  TableHead,
-  TableHeader,
-  TableRow,
+    Table,
+    TableBody,
+    TableCell,
+    TableHead,
+    TableHeader,
+    TableRow,
 } from "../ui/table";
 import { Skeleton } from "../ui/skeleton";
 //import CycleCountLog from "./CycleCountLog";
 import {
-  Select,
-  SelectContent,
-  SelectItem,
-  SelectTrigger,
-  SelectValue,
+    Select,
+    SelectContent,
+    SelectItem,
+    SelectTrigger,
+    SelectValue,
 } from "../ui/select";
 import { Controller, useForm } from "react-hook-form";
 import axios from "axios";
 import { useState } from "react";
 
 export default function OcmeCycleCount() {
-  const token = localStorage.getItem("auth_token");
-  const [data, setData] = useState([]);
-  const [counting, setCounting] = useState(false);
-  const {
-    register,
-    handleSubmit,
-    //watch,
-    formState: { errors },
-    reset,
-    control,
-  } = useForm();
+    const token = localStorage.getItem("auth_token");
+    const [data, setData] = useState([]);
+    const [counting, setCounting] = useState(false);
+    const {
+        register,
+        handleSubmit,
+        //watch,
+        formState: { errors },
+        reset,
+        control,
+    } = useForm();
 
-  const onSubmit = async (data: any) => {
-    setData([]);
-    setCounting(true);
-    toast.success(`Cycle count started`);
-    try {
-      const res = await axios.post("/ocme/api/v1/cycleCount", data, {
-        headers: { Authorization: `Bearer ${token}` },
-      });
-      console.log(data);
-      toast.success(res.data.message);
-      setData(res.data.data);
-      setCounting(false);
-      reset();
-    } catch (error) {
-      toast.error("There was an error cycle counting");
-      setCounting(false);
-      reset();
-    }
-  };
-
-  return (
-    <div className="flex flex-row w-screen">
-      <div className="m-2 w-5/6">
-        <LstCard>
-          <p className="ml-2">
-            Please enter the name or laneID you want to cycle count.
-          </p>
-          <div>
-            <form onSubmit={handleSubmit(onSubmit)}>
-              <div className="flex justify-between">
-                <div className="m-2 flex flex-row">
-                  <Input
-                    placeholder="enter lane: L064"
-                    className={errors.lane ? "border-red-500" : ""}
-                    aria-invalid={!!errors.lane}
-                    {...register("lane", {
-                      required: true,
-                      minLength: {
-                        value: 3,
-                        message: "The lane is too short!",
-                      },
-                    })}
-                  />
-                  <div className="ml-2">
-                    <Controller
-                      control={control}
-                      name="laneType"
-                      defaultValue={""}
-                      render={({
-                        field: { onChange },
-                        fieldState: {},
-                        //formState,
-                      }) => (
-                        <Select onValueChange={onChange}>
-                          <SelectTrigger className="w-[180px]">
-                            <SelectValue placeholder="Select name or id" />
-                          </SelectTrigger>
-                          <SelectContent>
-                            <SelectItem value="name">Name</SelectItem>
-                            <SelectItem value="laneId">Lane ID</SelectItem>
-                          </SelectContent>
-                        </Select>
-                      )}
-                    />
-                  </div>
-                </div>
-                <Button className="m-2" type="submit" disabled={counting}>
-                  {counting ? (
-                    <span>Counting...</span>
-                  ) : (
-                    <span>CycleCount</span>
-                  )}
-                </Button>
-              </div>
-            </form>
-          </div>
-          <div>
-            <Table>
-              <TableHeader>
-                <TableRow>
-                  <TableHead>LaneID</TableHead>
-                  <TableHead>Lane</TableHead>
-                  <TableHead>AV</TableHead>
-                  <TableHead>Description</TableHead>
-                  <TableHead>Running Number</TableHead>
-                  <TableHead>In Ocme</TableHead>
-                  <TableHead>In Stock</TableHead>
-                  <TableHead>Result</TableHead>
-                </TableRow>
-              </TableHeader>
-              {data?.length === 0 ? (
-                <TableBody>
-                  {Array(10)
-                    .fill(0)
-                    .map((_, i) => (
-                      <TableRow key={i}>
-                        <TableCell className="font-medium">
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                        <TableCell>
-                          <Skeleton className="h-4" />
-                        </TableCell>
-                      </TableRow>
-                    ))}
-                </TableBody>
-              ) : (
-                <>
-                  {data?.map((i: any) => {
-                    let classname = ``;
-                    if (i.info === "Quality Check Required") {
-                      classname = `bg-red-500`;
-                    }
-                    if (i.info === "Sent to Inv") {
-                      classname = `bg-amber-700`;
-                    }
-                    return (
-                      <TableRow key={i.runningNumber}>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.alpla_laneID}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.alpla_laneDescription}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.Article}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.alpla_laneDescription}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.runningNumber}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.ocme}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.stock}
-                        </TableCell>
-                        <TableCell className={`font-medium ${classname}`}>
-                          {i.info}
-                        </TableCell>
-                      </TableRow>
-                    );
-                  })}
-                </>
-              )}
-            </Table>
-          </div>
-        </LstCard>
-      </div>
-      {/* <div className="m-2">
+    const onSubmit = async (data: any) => {
+        setData([]);
+        setCounting(true);
+        toast.success(`Cycle count started`);
+        try {
+            const res = await axios.post("/ocme/api/v1/cyclecount", data, {
+                headers: { Authorization: `Bearer ${token}` },
+            });
+            toast.success(res.data.message);
+            setData(res.data.data);
+            setCounting(false);
+            reset();
+        } catch (error) {
+            toast.error("There was an error cycle counting");
+            setCounting(false);
+            reset();
+        }
+    };
+    return (
+        <div className="flex flex-row w-screen">
+            <div className="m-2 w-5/6">
+                <LstCard>
+                    <p className="ml-2">
+                        Please enter the name or laneID you want to cycle count.
+                    </p>
+                    <div>
+                        <form onSubmit={handleSubmit(onSubmit)}>
+                            <div className="flex justify-between">
+                                <div className="m-2 flex flex-row">
+                                    <Input
+                                        placeholder="enter lane: L064"
+                                        className={
+                                            errors.lane ? "border-red-500" : ""
+                                        }
+                                        aria-invalid={!!errors.lane}
+                                        {...register("lane", {
+                                            required: true,
+                                            minLength: {
+                                                value: 3,
+                                                message:
+                                                    "The lane is too short!",
+                                            },
+                                        })}
+                                    />
+                                    <div className="ml-2">
+                                        <Controller
+                                            control={control}
+                                            name="laneType"
+                                            defaultValue={""}
+                                            render={({
+                                                field: { onChange },
+                                                fieldState: {},
+                                                //formState,
+                                            }) => (
+                                                <Select
+                                                    onValueChange={onChange}
+                                                >
+                                                    <SelectTrigger className="w-[180px]">
+                                                        <SelectValue placeholder="Select name or id" />
+                                                    </SelectTrigger>
+                                                    <SelectContent>
+                                                        <SelectItem value="name">
+                                                            Name
+                                                        </SelectItem>
+                                                        <SelectItem value="laneId">
+                                                            Lane ID
+                                                        </SelectItem>
+                                                    </SelectContent>
+                                                </Select>
+                                            )}
+                                        />
+                                    </div>
+                                </div>
+                                <Button
+                                    className="m-2"
+                                    type="submit"
+                                    disabled={counting}
+                                >
+                                    {counting ? (
+                                        <span>Counting...</span>
+                                    ) : (
+                                        <span>CycleCount</span>
+                                    )}
+                                </Button>
+                            </div>
+                        </form>
+                    </div>
+                    <div>
+                        <Table>
+                            <TableHeader>
+                                <TableRow>
+                                    <TableHead>LaneID</TableHead>
+                                    <TableHead>Lane</TableHead>
+                                    <TableHead>AV</TableHead>
+                                    <TableHead>Description</TableHead>
+                                    <TableHead>Running Number</TableHead>
+                                    <TableHead>In Ocme</TableHead>
+                                    <TableHead>In Stock</TableHead>
+                                    <TableHead>Result</TableHead>
+                                </TableRow>
+                            </TableHeader>
+                            {data.length === 0 ? (
+                                <TableBody>
+                                    {Array(10)
+                                        .fill(0)
+                                        .map((_, i) => (
+                                            <TableRow key={i}>
+                                                <TableCell className="font-medium">
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                                <TableCell>
+                                                    <Skeleton className="h-4" />
+                                                </TableCell>
+                                            </TableRow>
+                                        ))}
+                                </TableBody>
+                            ) : (
+                                <>
+                                    {data.map((i: any) => {
+                                        let classname = ``;
+                                        if (
+                                            i.info === "Quality Check Required"
+                                        ) {
+                                            classname = `bg-red-500`;
+                                        }
+                                        if (i.info === "Sent to Inv") {
+                                            classname = `bg-amber-700`;
+                                        }
+                                        return (
+                                            <TableRow key={i.runningNumber}>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.alpla_laneID}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.alpla_laneDescription}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.Article}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.alpla_laneDescription}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.runningNumber}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.ocme}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.stock}
+                                                </TableCell>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
+                                                    {i.info}
+                                                </TableCell>
+                                            </TableRow>
+                                        );
+                                    })}
+                                </>
+                            )}
+                        </Table>
+                    </div>
+                </LstCard>
+            </div>
+            {/* <div className="m-2">
                 <CycleCountLog />
             </div> */}
-    </div>
-  );
+        </div>
+    );
 }

package.json

@@ -32,7 +32,7 @@
     }
   },
   "admConfig": {
-    "build": 54,
+    "build": 76,
     "oldBuild": "backend-0.1.3.zip"
   },
   "devDependencies": {

server/index.ts

@@ -31,64 +31,67 @@ export const lstAuth = btoa(`${username}:${password}`);
 // checking to make sure we have the settings intialized
 const serverIntialized = await db.select({ count: count() }).from(settings);
 export const installed =
-  serverIntialized[0].count === 0 && process.env.NODE_ENV !== "development"
-    ? false
-    : true;
+    serverIntialized[0].count === 0 && process.env.NODE_ENV !== "development"
+        ? false
+        : true;
 createLog("info", "LST", "server", `Server is installed: ${installed}`);
 
 const app = new OpenAPIHono({ strict: false });
 
 // middle ware
-app.use("*", logger());
+if (process.env.NODE_ENV === "development") {
+    app.use("*", logger());
+}
+
 app.use(
-  "*",
-  cors({
-    origin: "*", // Allow all origins
-    allowHeaders: ["Content-Type", "Authorization", "X-Requested-With"],
-    allowMethods: ["GET", "POST", "PUT", "DELETE", "OPTIONS", "PATCH"],
-    //exposeHeaders: ["Content-Length", "X-Kuma-Revision"],
-    credentials: true, // Allow credentials if needed
-    maxAge: 600,
-  })
+    "*",
+    cors({
+        origin: "*", // Allow all origins
+        allowHeaders: ["Content-Type", "Authorization", "X-Requested-With"],
+        allowMethods: ["GET", "POST", "PUT", "DELETE", "OPTIONS", "PATCH"],
+        //exposeHeaders: ["Content-Length", "X-Kuma-Revision"],
+        credentials: true, // Allow credentials if needed
+        maxAge: 600,
+    })
 );
 
 // Middleware to normalize route case
 // app.use("*", async (c, next) => {
-//   const lowercasedUrl = c.req.url.toLowerCase();
-//   //console.log("Incoming Request:", c.req.url, c.req.method);
-//   // If the URL is already lowercase, continue as usual
-//   if (c.req.url === lowercasedUrl) {
-//     await next();
-//   }
+//   //   const lowercasedUrl = c.req.url.toLowerCase();
+//   console.log("Incoming Request:", c.req.url, c.req.method);
+//   //   // If the URL is already lowercase, continue as usual
+//   //   if (c.req.url === lowercasedUrl) {
+//   await next();
+//   //   }
 
-//   // Otherwise, re-route internally
-//   return c.redirect(lowercasedUrl, 308); // 308 preserves the HTTP method
+//   //   // Otherwise, re-route internally
+//   //   return c.redirect(lowercasedUrl, 308); // 308 preserves the HTTP method
 // });
 
 app.doc("/api/ref", {
-  openapi: "3.0.0",
-  info: {
-    version: "2.0.0",
-    title: "LST API",
-  },
+    openapi: "3.0.0",
+    info: {
+        version: "2.0.0",
+        title: "LST API",
+    },
 });
 
 const routes = [
-  scalar,
-  auth,
-  // apiHits,
-  system,
-  tcpServer,
-  sqlService,
-  logistics,
-  rfid,
-  printers,
-  loggerService,
-  ocpService,
+    scalar,
+    auth,
+    // apiHits,
+    system,
+    tcpServer,
+    sqlService,
+    logistics,
+    rfid,
+    printers,
+    loggerService,
+    ocpService,
 ] as const;
 
 const appRoutes = routes.forEach((route) => {
-  app.route("/api/", route);
+    app.route("/api/", route);
 });
 
 app.route("/ocme/", ocme);
@@ -129,48 +132,48 @@ app.use("*", serveStatic({ path: "./frontend/dist/index.html" }));
 
 // Handle app exit signals
 process.on("SIGINT", async () => {
-  console.log("\nGracefully shutting down...");
-  //await closePool();
-  process.exit(0);
+    console.log("\nGracefully shutting down...");
+    //await closePool();
+    process.exit(0);
 });
 
 process.on("SIGTERM", async () => {
-  console.log("Received termination signal, closing database...");
-  //await closePool();
-  process.exit(0);
+    console.log("Received termination signal, closing database...");
+    //await closePool();
+    process.exit(0);
 });
 
 process.on("uncaughtException", async (err) => {
-  console.log("Uncaught Exception:", err);
-  //await closePool();
-  process.exit(1);
+    console.log("Uncaught Exception:", err);
+    //await closePool();
+    process.exit(1);
 });
 
 process.on("beforeExit", async () => {
-  console.log("Process is about to exit...");
-  //await closePool();
-  process.exit(0);
+    console.log("Process is about to exit...");
+    //await closePool();
+    process.exit(0);
 });
 
 const port =
-  process.env.NODE_ENV === "development"
-    ? process.env.VITE_SERVER_PORT
-    : process.env.PROD_PORT;
+    process.env.NODE_ENV === "development"
+        ? process.env.VITE_SERVER_PORT
+        : process.env.PROD_PORT;
 
 serve(
-  {
-    fetch: app.fetch,
-    port: Number(port),
-    hostname: "0.0.0.0",
-  },
-  (info) => {
-    createLog(
-      "info",
-      "LST",
-      "server",
-      `Server is running on http://${info.address}:${info.port}`
-    );
-  }
+    {
+        fetch: app.fetch,
+        port: Number(port),
+        hostname: "0.0.0.0",
+    },
+    (info) => {
+        createLog(
+            "info",
+            "LST",
+            "server",
+            `Server is running on http://${info.address}:${info.port}`
+        );
+    }
 );
 
 export type AppRoutes = typeof appRoutes;

server/scripts/updateServers.ts

@@ -4,12 +4,26 @@ import { db } from "../../database/dbclient.js";
 import { serverData } from "../../database/schema/serverData.js";
 import { eq, sql } from "drizzle-orm";
 import { createLog } from "../services/logger/logger.js";
+import { spawn } from "child_process";
+import { getAppInfo } from "../globalUtils/appInfo.js";
+import { db } from "../../database/dbclient.js";
+import { serverData } from "../../database/schema/serverData.js";
+import { eq, sql } from "drizzle-orm";
+import { createLog } from "../services/logger/logger.js";
 
 type UpdateServerResponse = {
   success: boolean;
   message: string;
+  success: boolean;
+  message: string;
 };
 
+export const updateServer = async (
+  devApp: string,
+  server: string | null
+): Promise<UpdateServerResponse> => {
+  const app = await getAppInfo(devApp);
+  const serverInfo = await db
 export const updateServer = async (
   devApp: string,
   server: string | null
@@ -33,7 +47,32 @@ export const updateServer = async (
         "Looks like you are missing the plant token or have entered an incorrect one please try again.",
     };
   }
+  if (serverInfo.length === 0) {
+    createLog(
+      "error",
+      "lst",
+      "serverUpdater",
+      `Looks like you are missing the plant token or have entered an incorrect one please try again.`
+    );
+    return {
+      success: false,
+      message:
+        "Looks like you are missing the plant token or have entered an incorrect one please try again.",
+    };
+  }
 
+  if (serverInfo[0].isUpgrading) {
+    createLog(
+      "error",
+      "lst",
+      "serverUpdater",
+      `Looks like ${serverInfo[0].plantToken} is upgrading already you cant do this again.`
+    );
+    return {
+      success: false,
+      message: `Looks like ${serverInfo[0].plantToken} is upgrading already you cant do this again.`,
+    };
+  }
   if (serverInfo[0].isUpgrading) {
     createLog(
       "error",
@@ -77,8 +116,15 @@ export const updateServer = async (
     ,
   ];
 
-  console.log(args);
-
+  return new Promise(async (resolve, reject) => {
+    const process = spawn("powershell", args);
+    // change the server to upgradeing
+    await db
+      .update(serverData)
+      .set({ isUpgrading: true })
+      .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
+    //let stdout = "";
+    //let stderr = "";
   return new Promise(async (resolve, reject) => {
     const process = spawn("powershell", args);
     // change the server to upgradeing
@@ -89,6 +135,12 @@ export const updateServer = async (
     //let stdout = "";
     //let stderr = "";
 
+    // Collect stdout data
+    process.stdout.on("data", (data) => {
+      const output = data.toString().trim();
+      createLog("info", "lst", "serverUpdater", `${output}`);
+      //onData(output);
+    });
     // Collect stdout data
     process.stdout.on("data", (data) => {
       const output = data.toString().trim();
@@ -96,6 +148,12 @@ export const updateServer = async (
       //onData(output);
     });
 
+    // Collect stderr data
+    process.stderr.on("data", (data) => {
+      const output = data.toString().trim();
+      createLog("info", "lst", "serverUpdater", `${output}`);
+      //onData(output);
+    });
     // Collect stderr data
     process.stderr.on("data", (data) => {
       const output = data.toString().trim();
@@ -103,6 +161,13 @@ export const updateServer = async (
       //onData(output);
     });
 
+    // Handle process close
+    process.on("close", async (code) => {
+      if (code === 0) {
+        // if (count >= servers) {
+        //     //onClose(`Server completed with code: ${code}`);
+        // }
+        createLog("info", "lst", "serverUpdater", `${server}`);
     // Handle process close
     process.on("close", async (code) => {
       if (code === 0) {
@@ -111,6 +176,26 @@ export const updateServer = async (
         // }
         createLog("info", "lst", "serverUpdater", `${server}`);
 
+        //update the last build.
+        try {
+          await db
+            .update(serverData)
+            .set({ lastUpdated: sql`NOW()`, isUpgrading: false })
+            .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
+          createLog(
+            "info",
+            "lst",
+            "serverUpdater",
+            `${server?.toLowerCase()}, has been updated and can now be used again.`
+          );
+        } catch (error) {
+          createLog(
+            "error",
+            "lst",
+            "serverUpdater",
+            `There was an error updating the last time the server was updated: ${error}`
+          );
+        }
         //update the last build.
         try {
           await db
@@ -132,6 +217,12 @@ export const updateServer = async (
           );
         }
 
+        resolve({
+          success: true,
+          message: `${server?.toLowerCase()}, has been updated and can now be used again.`,
+        });
+      } else {
+        const errorMessage = `Process exited with code ${code}`;
         resolve({
           success: true,
           message: `${server?.toLowerCase()}, has been updated and can now be used again.`,
@@ -139,6 +230,9 @@ export const updateServer = async (
       } else {
         const errorMessage = `Process exited with code ${code}`;
 
+        // if (count >= servers) {
+        //     //onClose(code);
+        // }
         // if (count >= servers) {
         //     //onClose(code);
         // }
@@ -149,6 +243,12 @@ export const updateServer = async (
         });
       }
     });
+        reject({
+          success: false,
+          message: `${server?.toLowerCase()}, Has encounted an error while updating.`,
+        });
+      }
+    });
 
     // Handle errors with the process itself
     process.on("error", (error) => {
@@ -157,11 +257,31 @@ export const updateServer = async (
       reject(error);
     });
   });
+    // Handle errors with the process itself
+    process.on("error", (error) => {
+      //onError(err.message);
+      createLog("error", "lst", "serverUpdater", `${error}`);
+      reject(error);
+    });
+  });
 };
 
 export async function processAllServers(devApp: string) {
   const servers = await db.select().from(serverData);
+  const servers = await db.select().from(serverData);
 
+  createLog(
+    "info",
+    "lst",
+    "serverUpdater",
+    `Running the update on all servers`
+  );
+  let count = 1;
+  for (const server of servers) {
+    try {
+      const updateToServer = await updateServer(devApp, server.plantToken);
+      createLog("info", "lst", "serverUpdater", `${server.sName} was updated.`);
+      count = count + 1;
   createLog(
     "info",
     "lst",
@@ -186,4 +306,15 @@ export async function processAllServers(devApp: string) {
       //return {success: false, message: `Error updating ${server.sName}: ${error.message}`};
     }
   }
+      //return {success: true, message: `${server.sName} was updated.`, data: updateToServer};
+    } catch (error: any) {
+      createLog(
+        "info",
+        "lst",
+        "serverUpdater",
+        `Error updating ${server.sName}: ${error.message}`
+      );
+      //return {success: false, message: `Error updating ${server.sName}: ${error.message}`};
+    }
+  }
 }

server/services/ocme/controller/cycleCount/ocmeInventory.ts

@@ -1,21 +1,21 @@
 import axios from "axios";
 
 export const ocmeInv = async (data: any) => {
-  try {
-    const res = await axios.post(
-      "http://usday1vms010:3250/api/v1/getlanedata",
-      { lane: data.lane, laneType: data.laneType },
-      {
-        headers: {
-          "Content-Type": "application/json",
-          Connection: "keep-alive",
-        },
-      }
-    );
-    // console.log(res.data.data);
+    try {
+        const res = await axios.post(
+            "http://usday1vms010:3250/api/v1/getlanedata",
+            { lane: data.lane, laneType: data.laneType },
+            {
+                headers: {
+                    "Content-Type": "application/json",
+                    Connection: "keep-alive",
+                },
+            }
+        );
+        // console.log(res.data.data);
 
-    return res.data.data;
-  } catch (error: any) {
-    console.log(error.code);
-  }
+        return res.data.data;
+    } catch (error: any) {
+        console.log(error.code);
+    }
 };

server/services/ocme/controller/getInfo.ts

@@ -1,25 +1,39 @@
-import {db} from "../../../../database/dbclient.js";
-import {ocmeData} from "../../../../database/schema/ocme.js";
-import {differenceInMinutes} from "date-fns";
-import {createLog} from "../../logger/logger.js";
-import {eq} from "drizzle-orm";
+import { db } from "../../../../database/dbclient.js";
+import { ocmeData } from "../../../../database/schema/ocme.js";
+import { differenceInMinutes } from "date-fns";
+import { createLog } from "../../logger/logger.js";
+import { eq } from "drizzle-orm";
 
 export const getInfo = async () => {
-    let ocmeInfo: any = [];
-    try {
-        ocmeInfo = await db.select().from(ocmeData).where(eq(ocmeData.pickedUp, false));
+  let ocmeInfo: any = [];
+  try {
+    ocmeInfo = await db
+      .select()
+      .from(ocmeData)
+      .where(eq(ocmeData.pickedUp, false));
 
-        // add in the time difference
-        ocmeInfo = ocmeInfo.map((o: any) => {
-            const now = new Date(Date.now());
-            const diff = differenceInMinutes(now, o.add_Date!);
-            return {...o, waitingFor: diff};
-        });
-        createLog("info", "ocme", "ocme", `There are ${ocmeInfo.length} pallet(s) to be picked up.`);
-    } catch (error) {
-        createLog("error", "ocme", "ocme", "There was an error trying to retrive the ocmeInfo.");
-        throw Error("There was an error trying to retrive the.");
-    }
+    // add in the time difference
+    ocmeInfo = ocmeInfo.map((o: any) => {
+      const now = new Date(Date.now());
+      //const strippedDate = o.add_Date.replace("Z", "");
+      const diff = differenceInMinutes(now, o.add_Date);
+      return { ...o, waitingFor: diff };
+    });
+    createLog(
+      "info",
+      "ocme",
+      "ocme",
+      `There are ${ocmeInfo.length} pallet(s) to be picked up.`
+    );
+  } catch (error) {
+    createLog(
+      "error",
+      "ocme",
+      "ocme",
+      "There was an error trying to retrive the ocmeInfo."
+    );
+    throw Error("There was an error trying to retrive the.");
+  }
 
-    return ocmeInfo;
+  return ocmeInfo;
 };

server/services/ocme/controller/postRunningNr.ts

@@ -4,64 +4,79 @@ import { createSSCC } from "../../../globalUtils/createSSCC.js";
 import { createLog } from "../../logger/logger.js";
 import { query } from "../../sqlServer/prodSqlServer.js";
 import { labelData } from "../../sqlServer/querys/materialHelpers/labelInfo.js";
+import { db } from "../../../../database/dbclient.js";
+import { ocmeData } from "../../../../database/schema/ocme.js";
+import { createSSCC } from "../../../globalUtils/createSSCC.js";
+import { createLog } from "../../logger/logger.js";
+import { query } from "../../sqlServer/prodSqlServer.js";
+import { labelData } from "../../sqlServer/querys/materialHelpers/labelInfo.js";
 
 export const postLabelData = async (data: any) => {
-  console.log(data);
-  let newData = data;
-  if (Array.isArray(data)) {
-    newData = {
-      sscc: data[1],
-      areaFrom: data[0],
-      completed: true,
-    };
-  }
+    console.log(data);
+    let newData = data;
+    if (Array.isArray(data)) {
+        newData = {
+            sscc: data[1],
+            areaFrom: data[0],
+            completed: true,
+        };
+    }
 
-  if (newData.sscc && !newData.runningNr) {
-    newData.runningNr = newData.sscc.slice(10, -1);
-  }
-  if (!newData.sscc && !newData.runningNr) {
-    return {
-      success: false,
-      message: "Missing data please try again",
-      data: [],
+    if (newData.sscc && !newData.runningNr) {
+        newData.runningNr = newData.sscc.slice(10, -1);
+    }
+    if (!newData.sscc && !newData.runningNr) {
+        return {
+            success: false,
+            message: "Missing data please try again",
+            data: [],
+        };
+    }
+    let label;
+    const filterQuery = labelData.replaceAll("[rn]", newData.runningNr);
+    try {
+        label = await query(filterQuery, "Label data");
+    } catch (error) {
+        createLog(
+            "error",
+            "ocme",
+            "ocme",
+            "There was an error getting the labelData"
+        );
+    }
+    const newPost = {
+        sscc: newData.sscc ? newData.sscc : await createSSCC(newData.runningNr),
+        runningNr: newData.runningNr,
+        completed: newData.completed ? newData.completed : true,
+        lineNum: label[0]?.machineLocation,
+        areaFrom: newData.areaFrom,
+        pickedUp: false,
     };
-  }
-  let label;
-  const filterQuery = labelData.replaceAll("[rn]", newData.runningNr);
-  try {
-    label = await query(filterQuery, "Label data");
-  } catch (error) {
-    createLog(
-      "error",
-      "ocme",
-      "ocme",
-      "There was an error getting the labelData"
-    );
-  }
-  const newPost = {
-    sscc: newData.sscc ? newData.sscc : await createSSCC(newData.runningNr),
-    runningNr: newData.runningNr,
-    completed: newData.completed,
-    lineNum: label[0].machineLocation,
-    areaFrom: newData.areaFrom,
-    pickedUp: false,
-  };
-  try {
-    const enterNewData = await db
-      .insert(ocmeData)
-      .values(newPost)
-      .returning({ sscc: ocmeData.sscc });
-    return {
-      success: true,
-      message: "Data was posted to ocme info",
-      data: enterNewData,
-    };
-  } catch (error) {
-    console.log(error);
-    return {
-      success: false,
-      message: "Data was posted to ocme info",
-      data: newPost,
-    };
-  }
+    try {
+        const enterNewData = await db
+            .insert(ocmeData)
+            .values(newPost)
+            .returning({
+                sscc: ocmeData.sscc,
+                runningNr: ocmeData.runningNr,
+                areaFrom: ocmeData.areaFrom,
+                lineNum: ocmeData.lineNum,
+                completed: ocmeData.completed,
+                pickedUp: ocmeData.pickedUp,
+            });
+
+        //console.log(enterNewData);
+        return {
+            success: true,
+            message: "Data was posted to ocme info",
+            data: enterNewData,
+        };
+    } catch (error) {
+        //console.log(error);
+        return {
+            success: false,
+            message: "Data was posted to ocme info",
+            data: [],
+        };
+    }
 };

server/services/ocme/controller/triggerCamera.ts

@@ -0,0 +1,49 @@
+import net from "net";
+import { db } from "../../../../database/dbclient.js";
+import { settings } from "../../../../database/schema/settings.js";
+import { eq } from "drizzle-orm";
+import { createLog } from "../../logger/logger.js";
+
+export const triggerScanner = async () => {
+    const camera = new net.Socket();
+    let setting = await db
+        .select()
+        .from(settings)
+        .where(eq(settings.name, "zebraScanners"));
+    if (setting.length === 0) {
+        return {
+            success: false,
+            message: "Looks like the setting is missing.",
+        };
+    }
+    const scannerData = JSON.parse(setting[0]?.value);
+    let data = scannerData.filter((n: any) => n.name === "wrapper1");
+    let port = data[0].port;
+    console.log(data);
+    createLog(
+        "info",
+        "wrapperScanner",
+        "ocme",
+        `End of line Camera was triggered`
+    );
+    return new Promise((resolve, reject) => {
+        camera.connect(port, data[0].ip, async () => {
+            createLog("info", "wrapperScanner", "ocme", `Triggered`);
+            camera.write("TRIGGER", "utf8");
+            camera.end();
+            resolve({ success: true, message: "Camera was triggered." });
+        });
+
+        camera.on("error", (error) => {
+            createLog("error", "wrapperScanner", "ocme", `${error}`);
+            resolve({
+                success: false,
+                message: `There was an error triggering the camera: ${JSON.stringify(
+                    error
+                )}`,
+            });
+        });
+
+        resolve({ success: true, message: "Camera was triggered." });
+    });
+};

server/services/ocme/ocmeService.ts

@@ -1,4 +1,4 @@
-import {OpenAPIHono} from "@hono/zod-openapi";
+import { OpenAPIHono } from "@hono/zod-openapi";
 
 // routes
 import getInfo from "./route/getInfo.js";
@@ -7,35 +7,52 @@ import pickedup from "./route/pickedUp.js";
 import postsscc from "./route/postSSCC.js";
 import getShipments from "./route/getShipmentPallets.js";
 import cycleCount from "./route/cycleCount.js";
-import {serve} from "@hono/node-server";
-import {createLog} from "../logger/logger.js";
-import {db} from "../../../database/dbclient.js";
-import {settings} from "../../../database/schema/settings.js";
+import { serve } from "@hono/node-server";
+import { createLog } from "../logger/logger.js";
+import { db } from "../../../database/dbclient.js";
+import { settings } from "../../../database/schema/settings.js";
+import manualTrigger from "./route/triggerCamera.js";
 
 const app = new OpenAPIHono();
 const port = process.env.OCME_PORT;
-const routes = [getInfo, postRunningNr, postsscc, pickedup, getShipments, cycleCount] as const;
+const routes = [
+  getInfo,
+  postRunningNr,
+  postsscc,
+  pickedup,
+  getShipments,
+  cycleCount,
+  manualTrigger,
+] as const;
 const setting = await db.select().from(settings);
 
 const isActive = setting.filter((n) => n.name === "ocmeService");
 const appRoutes = routes.forEach((route) => {
-    app.route("/api/v1", route);
+  app.route("/api/v1", route);
 });
 
 app.all("/api/v1/*", (c) => {
-    return c.json({success: false, message: "you have encounted an ocme route that dose not exist."});
+  return c.json({
+    success: false,
+    message: "you have encounted an ocme route that dose not exist.",
+  });
 });
 if (port && isActive[0]?.value === "1") {
-    serve(
-        {
-            fetch: app.fetch,
-            port: Number(port),
-            hostname: "0.0.0.0",
-        },
-        (info) => {
-            createLog("info", "LST", "server", `Ocme section is listening on http://${info.address}:${info.port}`);
-        }
-    );
+  serve(
+    {
+      fetch: app.fetch,
+      port: Number(port),
+      hostname: "0.0.0.0",
+    },
+    (info) => {
+      createLog(
+        "info",
+        "LST",
+        "server",
+        `Ocme section is listening on http://${info.address}:${info.port}`
+      );
+    }
+  );
 }
 
 export default app;

server/services/ocme/route/getInfo.ts

@@ -1,96 +1,37 @@
 import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
 import { getInfo } from "../controller/getInfo.js";
 import { apiHit } from "../../../globalUtils/apiHits.js";
+import { responses } from "../../../globalUtils/routeDefs/responses.js";
 
 const app = new OpenAPIHono({ strict: false });
 
-const AddSetting = z.object({
-  name: z.string().openapi({ example: "server" }),
-  value: z.string().openapi({ example: "localhost" }),
-  description: z
-    .string()
-    .openapi({ example: "The server we are going to connect to" }),
-  roles: z.string().openapi({ example: "admin" }),
-  module: z.string().openapi({ example: "production" }),
-});
-
 app.openapi(
-  createRoute({
-    tags: ["ocme"],
-    summary: "Get all current info",
-    method: "get",
-    path: "/getInfo",
-    request: {
-      body: {
-        content: {
-          "application/json": { schema: AddSetting },
-        },
-      },
-    },
-    responses: {
-      200: {
-        content: {
-          "application/json": {
-            schema: z.object({
-              success: z.boolean().openapi({ example: true }),
-              message: z.string().openapi({ example: "Starter" }),
-              data: z.array(z.object({})).optional().openapi({ example: [] }),
-            }),
-          },
-        },
-        description: "Response message",
-      },
-      400: {
-        content: {
-          "application/json": {
-            schema: z.object({
-              success: z.boolean().openapi({ example: false }),
-              message: z
-                .string()
-                .optional()
-                .openapi({ example: "Internal Server error" }),
-              data: z.array(z.object({})).optional().openapi({ example: [] }),
-            }),
-          },
-        },
-        description: "Internal Server Error",
-      },
-      // 401: {
-      //     content: {
-      //         "application/json": {
-      //             schema: z.object({message: z.string().optional().openapi({example: "Unauthenticated"})}),
-      //         },
-      //     },
-      //     description: "Unauthorized",
-      // },
-      // 500: {
-      //     content: {
-      //         "application/json": {
-      //             schema: z.object({message: z.string().optional().openapi({example: "Internal Server error"})}),
-      //         },
-      //     },
-      //     description: "Internal Server Error",
-      // },
-    },
-  }),
-  async (c) => {
-    // make sure we have a vaid user being accessed thats really logged in
-    apiHit(c, { endpoint: "api/auth/register" });
-    try {
-      return c.json(
-        { success: true, message: "Ocme Info", data: await getInfo() },
-        200
-      );
-    } catch (error) {
-      return c.json(
-        {
-          success: false,
-          message: "There was an error getting ocmeInfo data",
-          data: error,
-        },
-        400
-      );
+    createRoute({
+        tags: ["ocme"],
+        summary: "Get all current info",
+        method: "get",
+        path: "/getInfo",
+
+        responses: responses(),
+    }),
+    async (c) => {
+        // make sure we have a vaid user being accessed thats really logged in
+        apiHit(c, { endpoint: "api/auth/register" });
+        try {
+            return c.json(
+                { success: true, message: "Ocme Info", data: await getInfo() },
+                200
+            );
+        } catch (error) {
+            return c.json(
+                {
+                    success: false,
+                    message: "There was an error getting ocmeInfo data",
+                    data: error,
+                },
+                400
+            );
+        }
     }
-  }
 );
 export default app;

server/services/ocme/route/postSSCC.ts

@@ -1,86 +1,106 @@
-import {createRoute, OpenAPIHono, z} from "@hono/zod-openapi";
-import {getInfo} from "../controller/getInfo.js";
-import {postLabelData} from "../controller/postRunningNr.js";
-import {apiHit} from "../../../globalUtils/apiHits.js";
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { getInfo } from "../controller/getInfo.js";
+import { postLabelData } from "../controller/postRunningNr.js";
+import { apiHit } from "../../../globalUtils/apiHits.js";
 
 const app = new OpenAPIHono();
 
 const PostRunningNr = z.object({
-    sscc: z.string().optional().openapi({example: "00090103830005710997"}),
-    runningNr: z.string().optional().openapi({example: "localhost"}),
-    areaFrom: z.string().optional().openapi({example: "The server we are going to connect to"}),
-    completed: z.boolean().optional().openapi({example: true}),
+  sscc: z.string().optional().openapi({ example: "00090103830005710997" }),
+  runningNr: z.string().optional().openapi({ example: "localhost" }),
+  areaFrom: z
+    .string()
+    .optional()
+    .openapi({ example: "The server we are going to connect to" }),
+  completed: z.boolean().optional().openapi({ example: true }),
 });
 
 app.openapi(
-    createRoute({
-        tags: ["ocme"],
-        summary: "Post New running number to be picked up.",
-        method: "post",
-        path: "/postsscc",
-        request: {
-            body: {
-                content: {
-                    "application/json": {schema: PostRunningNr},
-                },
-            },
+  createRoute({
+    tags: ["ocme"],
+    summary: "Post New running number to be picked up.",
+    method: "post",
+    path: "/postSSCC",
+    request: {
+      body: {
+        content: {
+          "application/json": { schema: PostRunningNr },
         },
-        responses: {
-            200: {
-                content: {
-                    "application/json": {
-                        schema: z.object({
-                            success: z.boolean().openapi({example: true}),
-                            message: z.string().openapi({example: "Starter"}),
-                            // data: z
-                            // .array(z.object({sscc: z.string().optional()}))
-                            // .optional()
-                            // .openapi({example: []}),
-                        }),
-                    },
-                },
-                description: "Response message",
-            },
-            400: {
-                content: {
-                    "application/json": {
-                        schema: z.object({
-                            success: z.boolean().openapi({example: false}),
-                            message: z.string().optional().openapi({example: "Internal Server error"}),
-                            data: z.array(z.object({})).optional().openapi({example: []}),
-                        }),
-                    },
-                },
-                description: "Internal Server Error",
-            },
-            // 401: {
-            //     content: {
-            //         "application/json": {
-            //             schema: z.object({message: z.string().optional().openapi({example: "Unauthenticated"})}),
-            //         },
-            //     },
-            //     description: "Unauthorized",
-            // },
-            // 500: {
-            //     content: {
-            //         "application/json": {
-            //             schema: z.object({message: z.string().optional().openapi({example: "Internal Server error"})}),
-            //         },
-            //     },
-            //     description: "Internal Server Error",
-            // },
+      },
+    },
+    responses: {
+      200: {
+        content: {
+          "application/json": {
+            schema: z.object({
+              success: z.boolean().openapi({ example: true }),
+              message: z.string().openapi({ example: "Starter" }),
+              // data: z
+              // .array(z.object({sscc: z.string().optional()}))
+              // .optional()
+              // .openapi({example: []}),
+            }),
+          },
         },
-    }),
-    async (c) => {
-        // make sure we have a vaid user being accessed thats really logged in
-        try {
-            const data = await c.req.json();
-            apiHit(c, {endpoint: "api/ocme/postRunningNumber", lastBody: data});
-            const postPallet = await postLabelData(data);
-            return c.json({success: postPallet.success, message: postPallet.message, data: postPallet.data ?? []}, 200);
-        } catch (error) {
-            return c.json({success: false, message: "There was an error getting ocmeInfo data", data: error}, 400);
-        }
+        description: "Response message",
+      },
+      400: {
+        content: {
+          "application/json": {
+            schema: z.object({
+              success: z.boolean().openapi({ example: false }),
+              message: z
+                .string()
+                .optional()
+                .openapi({ example: "Internal Server error" }),
+              data: z.array(z.object({})).optional().openapi({ example: [] }),
+            }),
+          },
+        },
+        description: "Internal Server Error",
+      },
+      // 401: {
+      //     content: {
+      //         "application/json": {
+      //             schema: z.object({message: z.string().optional().openapi({example: "Unauthenticated"})}),
+      //         },
+      //     },
+      //     description: "Unauthorized",
+      // },
+      // 500: {
+      //     content: {
+      //         "application/json": {
+      //             schema: z.object({message: z.string().optional().openapi({example: "Internal Server error"})}),
+      //         },
+      //     },
+      //     description: "Internal Server Error",
+      // },
+    },
+  }),
+  async (c) => {
+    // make sure we have a vaid user being accessed thats really logged in
+    try {
+      const data = await c.req.json();
+      apiHit(c, { endpoint: "api/ocme/postRunningNumber", lastBody: data });
+      const postPallet = await postLabelData(data);
+      return c.json(
+        {
+          success: postPallet.success,
+          message: postPallet.message,
+          data: postPallet.data ?? [],
+        },
+        200
+      );
+    } catch (error) {
+      return c.json(
+        {
+          success: false,
+          message: "There was an error getting ocmeInfo data",
+          data: error,
+        },
+        400
+      );
     }
+  }
 );
 export default app;

server/services/ocme/route/triggerCamera.ts

@@ -0,0 +1,25 @@
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { getInfo } from "../controller/getInfo.js";
+import { apiHit } from "../../../globalUtils/apiHits.js";
+import { responses } from "../../../globalUtils/routeDefs/responses.js";
+import { triggerScanner } from "../controller/triggerCamera.js";
+
+const app = new OpenAPIHono({ strict: false });
+
+app.openapi(
+  createRoute({
+    tags: ["ocme"],
+    summary: "Triggers the camera at the end of the dyco.",
+    method: "get",
+    path: "/manualCameraTrigger",
+    responses: responses(),
+  }),
+  async (c) => {
+    // make sure we have a vaid user being accessed thats really logged in
+    apiHit(c, { endpoint: "api/auth/register" });
+    const manualTrigger = await triggerScanner();
+    console.log(manualTrigger);
+    return c.json({ success: true, message: "Manual triggered" });
+  }
+);
+export default app;

server/services/rfid/controller/stations/wrappers.ts

@@ -3,44 +3,64 @@
  * Phase 2 we will just reprint the tag that was generated at the line
  */
 
-import {createLog} from "../../../logger/logger.js";
-import type {TagData} from "../tagData.js";
-import {tagStuff} from "../tags/crudTag.js";
+import { createLog } from "../../../logger/logger.js";
+import type { TagData } from "../tagData.js";
+import { tagStuff } from "../tags/crudTag.js";
 
 export const wrapperStuff = async (tagData: TagData[]) => {
-    if (tagData.length != 1) {
-        createLog(
-            "error",
-            "rfid",
-            "rfid",
-            `There are ${tagData.length} tags and this ${tagData[0].reader} only allows 1 tag to create a label.`
-        );
-        tagStuff(tagData);
-    } else {
-        const tagdata = await tagStuff(tagData);
-
-        /**
-         * we want to make sure this pallet came from a line as its last spot if not we need to have a manual check.
-         */
-        const station3 = tagdata.some((n: any) => n.lastareaIn.includes("line3"));
-
-        if (!station3) {
-            createLog(
-                "error",
-                "rfid",
-                "rfid",
-                `${tagdata.tag}, Did not come from a line please check the pallet and manually print the label.`
-            );
-
-            // when we manually run again we want to make sure we read from the 3rd antenna this way we do not get the wrong info.
-            // more testing will need to be done on this.
-        }
-
-        // check if a running number exists
-        if (station3.runningNumber) {
-            createLog("info", "rfid", "rfid", `Reprint label ${station3.runningNumber}`);
-        } else {
-            createLog("info", "rfid", "rfid", `A new labels will be created and linked to this ${tagdata.tag} tag`);
-        }
+  if (tagData.length != 1) {
+    createLog(
+      "error",
+      "rfid",
+      "rfid",
+      `There are ${tagData.length} tags and this ${tagData[0].reader} only allows 1 tag to create a label.`
+    );
+    tagStuff(tagData);
+  } else {
+    const tagdata = await tagStuff(tagData);
+    if (!tagData) {
+      createLog("error", "rfid", "rfid", `No tagData was grabbed.`);
     }
+
+    /**
+     * we want to make sure this pallet came from a line as its last spot if not we need to have a manual check.
+     */
+    if (
+      !Array.isArray(tagdata) &&
+      tagdata?.some((n: any) => n.lastareaIn.includes("line3"))
+    ) {
+      createLog("error", "rfid", "rfid", `Data passed over is not an array.`);
+      return;
+    }
+    const station3 = tagdata; //?.some((n: any) => n.lastareaIn.includes("line3"));
+
+    if (!station3) {
+      createLog(
+        "error",
+        "rfid",
+        "rfid",
+        `${tagdata[0].tag}, Did not come from a line please check the pallet and manually print the label.`
+      );
+
+      // when we manually run again we want to make sure we read from the 3rd antenna this way we do not get the wrong info.
+      // more testing will need to be done on this.
+    }
+
+    // check if a running number exists
+    if (station3.runningNumber) {
+      createLog(
+        "info",
+        "rfid",
+        "rfid",
+        `Reprint label ${station3.runningNumber}`
+      );
+    } else {
+      createLog(
+        "info",
+        "rfid",
+        "rfid",
+        `A new labels will be created and linked to this ${tagdata.tag} tag`
+      );
+    }
+  }
 };

server/services/tcpServer/tcpServer.ts

@@ -15,65 +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(" ");
-      if (parseData[0] === "HB") {
-        return;
-      }
-      postLabelData(parseData);
+        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;
+            }
+
+            // 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);
@@ -82,7 +90,7 @@ app.route("/tcpserver/restart", restartTCP);
 
 // start the server after on system start up
 setTimeout(() => {
-  startTCPServer();
+    startTCPServer();
 }, 5000);
 
 export default app;