refactor(ocp): moved printers to there own folder to keep everything clean

.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
+    }
 }

database/migrations/0026_daily_the_twelve.sql

@@ -0,0 +1,17 @@
+CREATE TABLE "printers" (
+	"printer_id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
+	"humanReadableId" text,
+	"name" text NOT NULL,
+	"ipAddress" text,
+	"port" numeric NOT NULL,
+	"status" text,
+	"statusText" text NOT NULL,
+	"lastTimePrinted" text,
+	"assigned" boolean DEFAULT false NOT NULL,
+	"remark" text,
+	"monitorState" boolean DEFAULT false NOT NULL,
+	"add_Date" timestamp DEFAULT now(),
+	"upd_date" timestamp DEFAULT now()
+);
+--> statement-breakpoint
+CREATE UNIQUE INDEX "humanReadableId" ON "printers" USING btree ("name");

database/migrations/0027_needy_sleepwalker.sql

@@ -0,0 +1,3 @@
+ALTER TABLE "printers" ALTER COLUMN "statusText" DROP NOT NULL;--> statement-breakpoint
+ALTER TABLE "printers" ALTER COLUMN "assigned" DROP NOT NULL;--> statement-breakpoint
+ALTER TABLE "printers" ALTER COLUMN "monitorState" DROP NOT NULL;

database/migrations/0028_fast_wong.sql

@@ -0,0 +1 @@
+ALTER TABLE "printers" ALTER COLUMN "port" DROP NOT NULL;

database/migrations/0029_giant_blue_blade.sql

@@ -0,0 +1,2 @@
+DROP INDEX "humanReadableId";--> statement-breakpoint
+CREATE UNIQUE INDEX "humanReadableId" ON "printers" USING btree ("humanReadableId");

database/migrations/meta/_journal.json

@@ -183,6 +183,34 @@
       "when": 1742655504936,
       "tag": "0025_amusing_sugar_man",
       "breakpoints": true
+    },
+    {
+      "idx": 26,
+      "version": "7",
+      "when": 1742914066219,
+      "tag": "0026_daily_the_twelve",
+      "breakpoints": true
+    },
+    {
+      "idx": 27,
+      "version": "7",
+      "when": 1742917145140,
+      "tag": "0027_needy_sleepwalker",
+      "breakpoints": true
+    },
+    {
+      "idx": 28,
+      "version": "7",
+      "when": 1742917676211,
+      "tag": "0028_fast_wong",
+      "breakpoints": true
+    },
+    {
+      "idx": 29,
+      "version": "7",
+      "when": 1742917978318,
+      "tag": "0029_giant_blue_blade",
+      "breakpoints": true
     }
   ]
 }

database/schema/printers.ts

@@ -0,0 +1,42 @@
+import {
+    text,
+    pgTable,
+    numeric,
+    index,
+    timestamp,
+    boolean,
+    uuid,
+    uniqueIndex,
+} from "drizzle-orm/pg-core";
+import { createInsertSchema, createSelectSchema } from "drizzle-zod";
+import { z } from "zod";
+
+export const printers = pgTable(
+    "printers",
+    {
+        printer_id: uuid("printer_id").defaultRandom().primaryKey(),
+        humanReadableId: text("humanReadableId"),
+        name: text("name").notNull(),
+        ipAddress: text("ipAddress"),
+        port: numeric("port"),
+        status: text("status"),
+        statusText: text("statusText"),
+        lastTimePrinted: text("lastTimePrinted"),
+        assigned: boolean("assigned").default(false),
+        remark: text("remark"),
+        monitorState: boolean("monitorState").default(false),
+        add_Date: timestamp("add_Date").defaultNow(),
+        upd_date: timestamp("upd_date").defaultNow(),
+    },
+    (table) => [
+        //uniqueIndex("emailUniqueIndex").on(sql`lower(${table.email})`),
+        uniqueIndex("humanReadableId").on(table.humanReadableId),
+    ]
+);
+
+// Schema for inserting a user - can be used to validate API requests
+// export const insertRolesSchema = createInsertSchema(roles, {
+//     name: z.string().min(3, {message: "Role name must be more than 3 letters"}),
+// });
+// Schema for selecting a Expenses - can be used to validate API responses
+export const selectRolesSchema = createSelectSchema(printers);

frontend/package-lock.json

@@ -16,6 +16,7 @@
                 "@radix-ui/react-dropdown-menu": "^2.1.6",
                 "@radix-ui/react-label": "^2.1.2",
                 "@radix-ui/react-popover": "^1.1.6",
+                "@radix-ui/react-scroll-area": "^1.2.3",
                 "@radix-ui/react-select": "^2.1.6",
                 "@radix-ui/react-separator": "^1.1.2",
                 "@radix-ui/react-slot": "^1.1.2",
@@ -1740,6 +1741,37 @@
                 }
             }
         },
+        "node_modules/@radix-ui/react-scroll-area": {
+            "version": "1.2.3",
+            "resolved": "https://registry.npmjs.org/@radix-ui/react-scroll-area/-/react-scroll-area-1.2.3.tgz",
+            "integrity": "sha512-l7+NNBfBYYJa9tNqVcP2AGvxdE3lmE6kFTBXdvHgUaZuy+4wGCL1Cl2AfaR7RKyimj7lZURGLwFO59k4eBnDJQ==",
+            "license": "MIT",
+            "dependencies": {
+                "@radix-ui/number": "1.1.0",
+                "@radix-ui/primitive": "1.1.1",
+                "@radix-ui/react-compose-refs": "1.1.1",
+                "@radix-ui/react-context": "1.1.1",
+                "@radix-ui/react-direction": "1.1.0",
+                "@radix-ui/react-presence": "1.1.2",
+                "@radix-ui/react-primitive": "2.0.2",
+                "@radix-ui/react-use-callback-ref": "1.1.0",
+                "@radix-ui/react-use-layout-effect": "1.1.0"
+            },
+            "peerDependencies": {
+                "@types/react": "*",
+                "@types/react-dom": "*",
+                "react": "^16.8 || ^17.0 || ^18.0 || ^19.0 || ^19.0.0-rc",
+                "react-dom": "^16.8 || ^17.0 || ^18.0 || ^19.0 || ^19.0.0-rc"
+            },
+            "peerDependenciesMeta": {
+                "@types/react": {
+                    "optional": true
+                },
+                "@types/react-dom": {
+                    "optional": true
+                }
+            }
+        },
         "node_modules/@radix-ui/react-select": {
             "version": "2.1.6",
             "resolved": "https://registry.npmjs.org/@radix-ui/react-select/-/react-select-2.1.6.tgz",

frontend/package.json

@@ -20,6 +20,7 @@
         "@radix-ui/react-dropdown-menu": "^2.1.6",
         "@radix-ui/react-label": "^2.1.2",
         "@radix-ui/react-popover": "^1.1.6",
+        "@radix-ui/react-scroll-area": "^1.2.3",
         "@radix-ui/react-select": "^2.1.6",
         "@radix-ui/react-separator": "^1.1.2",
         "@radix-ui/react-slot": "^1.1.2",

frontend/src/components/ocme/ocmeCycleCount.tsx

@@ -1,14 +1,27 @@
-import {toast} from "sonner";
-import {LstCard} from "../extendedUI/LstCard";
-import {Button} from "../ui/button";
-import {Input} from "../ui/input";
-import {Table, TableBody, TableCell, TableHead, TableHeader, TableRow} from "../ui/table";
-import {Skeleton} from "../ui/skeleton";
+import { toast } from "sonner";
+import { LstCard } from "../extendedUI/LstCard";
+import { Button } from "../ui/button";
+import { Input } from "../ui/input";
+import {
+    Table,
+    TableBody,
+    TableCell,
+    TableHead,
+    TableHeader,
+    TableRow,
+} from "../ui/table";
+import { Skeleton } from "../ui/skeleton";
 //import CycleCountLog from "./CycleCountLog";
-import {Select, SelectContent, SelectItem, SelectTrigger, SelectValue} from "../ui/select";
-import {Controller, useForm} from "react-hook-form";
+import {
+    Select,
+    SelectContent,
+    SelectItem,
+    SelectTrigger,
+    SelectValue,
+} from "../ui/select";
+import { Controller, useForm } from "react-hook-form";
 import axios from "axios";
-import {useState} from "react";
+import { useState } from "react";
 
 export default function OcmeCycleCount() {
     const token = localStorage.getItem("auth_token");
@@ -18,7 +31,7 @@ export default function OcmeCycleCount() {
         register,
         handleSubmit,
         //watch,
-        formState: {errors},
+        formState: { errors },
         reset,
         control,
     } = useForm();
@@ -29,7 +42,7 @@ export default function OcmeCycleCount() {
         toast.success(`Cycle count started`);
         try {
             const res = await axios.post("/ocme/api/v1/cyclecount", data, {
-                headers: {Authorization: `Bearer ${token}`},
+                headers: { Authorization: `Bearer ${token}` },
             });
             toast.success(res.data.message);
             setData(res.data.data);
@@ -45,20 +58,25 @@ export default function OcmeCycleCount() {
         <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>
+                    <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" : ""}
+                                        className={
+                                            errors.lane ? "border-red-500" : ""
+                                        }
                                         aria-invalid={!!errors.lane}
                                         {...register("lane", {
                                             required: true,
                                             minLength: {
                                                 value: 3,
-                                                message: "The lane is too short!",
+                                                message:
+                                                    "The lane is too short!",
                                             },
                                         })}
                                     />
@@ -68,25 +86,39 @@ export default function OcmeCycleCount() {
                                             name="laneType"
                                             defaultValue={""}
                                             render={({
-                                                field: {onChange},
+                                                field: { onChange },
                                                 fieldState: {},
                                                 //formState,
                                             }) => (
-                                                <Select onValueChange={onChange}>
+                                                <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>
+                                                        <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
+                                    className="m-2"
+                                    type="submit"
+                                    disabled={counting}
+                                >
+                                    {counting ? (
+                                        <span>Counting...</span>
+                                    ) : (
+                                        <span>CycleCount</span>
+                                    )}
                                 </Button>
                             </div>
                         </form>
@@ -108,41 +140,43 @@ export default function OcmeCycleCount() {
                             {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>
-                                    ))}
+                                        .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") {
+                                        if (
+                                            i.info === "Quality Check Required"
+                                        ) {
                                             classname = `bg-red-500`;
                                         }
                                         if (i.info === "Sent to Inv") {
@@ -150,24 +184,46 @@ export default function OcmeCycleCount() {
                                         }
                                         return (
                                             <TableRow key={i.runningNumber}>
-                                                <TableCell className={`font-medium ${classname}`}>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
                                                     {i.alpla_laneID}
                                                 </TableCell>
-                                                <TableCell className={`font-medium ${classname}`}>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
                                                     {i.alpla_laneDescription}
                                                 </TableCell>
-                                                <TableCell className={`font-medium ${classname}`}>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
                                                     {i.Article}
                                                 </TableCell>
-                                                <TableCell className={`font-medium ${classname}`}>
+                                                <TableCell
+                                                    className={`font-medium ${classname}`}
+                                                >
                                                     {i.alpla_laneDescription}
                                                 </TableCell>
-                                                <TableCell className={`font-medium ${classname}`}>
+                                                <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>
+                                                <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>
                                         );
                                     })}

frontend/src/components/production/ocp/Lots.tsx

@@ -1,14 +1,22 @@
-import {LstCard} from "@/components/extendedUI/LstCard";
+import { LstCard } from "@/components/extendedUI/LstCard";
 
-import {Skeleton} from "@/components/ui/skeleton";
-import {Table, TableBody, TableCell, TableHead, TableHeader, TableRow} from "@/components/ui/table";
-import {useSessionStore} from "@/lib/store/sessionStore";
-import {useSettingStore} from "@/lib/store/useSettings";
-import {LotType} from "@/types/lots";
-import {getlots} from "@/utils/querys/production/lots";
-import {useQuery} from "@tanstack/react-query";
+import { Skeleton } from "@/components/ui/skeleton";
+import {
+    Table,
+    TableBody,
+    TableCell,
+    TableHead,
+    TableHeader,
+    TableRow,
+} from "@/components/ui/table";
+import { useSessionStore } from "@/lib/store/sessionStore";
+import { useSettingStore } from "@/lib/store/useSettings";
+import { LotType } from "@/types/lots";
+import { getlots } from "@/utils/querys/production/lots";
+import { useQuery } from "@tanstack/react-query";
 import ManualPrint from "./ManualPrinting/ManualPrint";
 import ManualPrintForm from "./ManualPrinting/ManualPrintForm";
+import { ScrollArea } from "@/components/ui/scroll-area";
 
 let lotColumns = [
     {
@@ -57,12 +65,12 @@ let lotColumns = [
     // },
 ];
 export default function Lots() {
-    const {data, isError, isLoading} = useQuery(getlots());
-    const {user} = useSessionStore();
-    const {settings} = useSettingStore();
+    const { data, isError, isLoading } = useQuery(getlots());
+    const { user } = useSessionStore();
+    const { settings } = useSettingStore();
     const server = settings.filter((n) => n.name === "server")[0]?.value || "";
 
-    console.log(server);
+    console.log(data);
 
     const roles = ["admin", "manager", "operator"];
 
@@ -83,140 +91,167 @@ export default function Lots() {
     if (isError) {
         return (
             <div className="m-2 p-2 min-h-2/5">
-                <LstCard>
-                    <p className="text-center">Current Assigned lots</p>
-                    <Table>
-                        <TableHeader>
-                            <TableRow>
-                                {lotColumns.map((l) => (
-                                    <TableHead key={l.key}>{l.label}</TableHead>
-                                ))}
-                            </TableRow>
-                        </TableHeader>
-
-                        <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>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
-                                    </TableCell>
+                <ScrollArea className="max-h-1/2 rounded-md border p-4">
+                    <LstCard>
+                        <p className="text-center">Current Assigned lots</p>
+                        <Table>
+                            <TableHeader>
+                                <TableRow>
+                                    {lotColumns.map((l) => (
+                                        <TableHead key={l.key}>
+                                            {l.label}
+                                        </TableHead>
+                                    ))}
                                 </TableRow>
-                            ))}
-                        </TableBody>
-                    </Table>
-                </LstCard>
+                            </TableHeader>
+
+                            <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>
+                                            <TableCell>
+                                                <Skeleton className="h-4" />
+                                            </TableCell>
+                                        </TableRow>
+                                    ))}
+                            </TableBody>
+                        </Table>
+                    </LstCard>
+                </ScrollArea>
             </div>
         );
     }
 
     return (
         <LstCard className="m-2 p-2 min-h-2/5">
-            <p className="text-center">Current Assigned lots</p>
-            <Table>
-                <TableHeader>
-                    <TableRow>
-                        {lotColumns.map((l) => (
-                            <TableHead key={l.key}>{l.label}</TableHead>
-                        ))}
-                    </TableRow>
-                </TableHeader>
-                {isLoading ? (
-                    <>
+            <ScrollArea className="h-[400px]">
+                <p className="text-center">Current Assigned lots</p>
+                <Table>
+                    <TableHeader>
+                        <TableRow>
+                            {lotColumns.map((l) => (
+                                <TableHead key={l.key}>{l.label}</TableHead>
+                            ))}
+                        </TableRow>
+                    </TableHeader>
+                    {isLoading ? (
+                        <>
+                            <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>
+                                            <TableCell>
+                                                <Skeleton className="h-4" />
+                                            </TableCell>
+                                        </TableRow>
+                                    ))}
+                            </TableBody>
+                        </>
+                    ) : (
                         <TableBody>
-                            {Array(10)
-                            .fill(0)
-                            .map((_, i) => (
-                                <TableRow key={i}>
+                            {data?.map((lot: LotType) => (
+                                <TableRow key={lot.LabelOnlineID}>
                                     <TableCell className="font-medium">
-                                        <Skeleton className="h-4" />
+                                        {lot.MachineLocation}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.AV}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.Alias}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.LOT}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.ProlinkLot}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.PlannedQTY}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.Produced}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.Remaining}
                                     </TableCell>
-                                    <TableCell>
-                                        <Skeleton className="h-4" />
+                                    <TableCell className="font-medium">
+                                        {lot.overPrinting}
                                     </TableCell>
+                                    {user && roles.includes(user.role) && (
+                                        <>
+                                            {server === "usday1vms006" ||
+                                            server === "localhost" ? (
+                                                <>
+                                                    <TableCell className="flex justify-center">
+                                                        <ManualPrintForm
+                                                            lot={lot}
+                                                        />
+                                                    </TableCell>
+                                                </>
+                                            ) : (
+                                                <TableCell className="flex justify-center">
+                                                    <ManualPrint lot={lot} />
+                                                </TableCell>
+                                            )}
+                                        </>
+                                    )}
                                 </TableRow>
                             ))}
                         </TableBody>
-                    </>
-                ) : (
-                    <TableBody>
-                        {data?.map((lot: LotType) => (
-                            <TableRow key={lot.LabelOnlineID}>
-                                <TableCell className="font-medium">{lot.MachineLocation}</TableCell>
-                                <TableCell className="font-medium">{lot.AV}</TableCell>
-                                <TableCell className="font-medium">{lot.Alias}</TableCell>
-                                <TableCell className="font-medium">{lot.LOT}</TableCell>
-                                <TableCell className="font-medium">{lot.ProlinkLot}</TableCell>
-                                <TableCell className="font-medium">{lot.PlannedQTY}</TableCell>
-                                <TableCell className="font-medium">{lot.Produced}</TableCell>
-                                <TableCell className="font-medium">{lot.Remaining}</TableCell>
-                                <TableCell className="font-medium">{lot.overPrinting}</TableCell>
-                                {user && roles.includes(user.role) && (
-                                    <>
-                                        {server === "usday1vms006" || server === "localhost" ? (
-                                            <>
-                                                <TableCell className="flex justify-center">
-                                                    <ManualPrintForm lot={lot} />
-                                                </TableCell>
-                                            </>
-                                        ) : (
-                                            <TableCell className="flex justify-center">
-                                                <ManualPrint lot={lot} />
-                                            </TableCell>
-                                        )}
-                                    </>
-                                )}
-                            </TableRow>
-                        ))}
-                    </TableBody>
-                )}
-            </Table>
+                    )}
+                </Table>
+            </ScrollArea>
         </LstCard>
     );
 }

frontend/src/components/ui/scroll-area.tsx

@@ -0,0 +1,56 @@
+import * as React from "react"
+import * as ScrollAreaPrimitive from "@radix-ui/react-scroll-area"
+
+import { cn } from "@/lib/utils"
+
+function ScrollArea({
+  className,
+  children,
+  ...props
+}: React.ComponentProps<typeof ScrollAreaPrimitive.Root>) {
+  return (
+    <ScrollAreaPrimitive.Root
+      data-slot="scroll-area"
+      className={cn("relative", className)}
+      {...props}
+    >
+      <ScrollAreaPrimitive.Viewport
+        data-slot="scroll-area-viewport"
+        className="ring-ring/10 dark:ring-ring/20 dark:outline-ring/40 outline-ring/50 size-full rounded-[inherit] transition-[color,box-shadow] focus-visible:ring-4 focus-visible:outline-1"
+      >
+        {children}
+      </ScrollAreaPrimitive.Viewport>
+      <ScrollBar />
+      <ScrollAreaPrimitive.Corner />
+    </ScrollAreaPrimitive.Root>
+  )
+}
+
+function ScrollBar({
+  className,
+  orientation = "vertical",
+  ...props
+}: React.ComponentProps<typeof ScrollAreaPrimitive.ScrollAreaScrollbar>) {
+  return (
+    <ScrollAreaPrimitive.ScrollAreaScrollbar
+      data-slot="scroll-area-scrollbar"
+      orientation={orientation}
+      className={cn(
+        "flex touch-none p-px transition-colors select-none",
+        orientation === "vertical" &&
+          "h-full w-2.5 border-l border-l-transparent",
+        orientation === "horizontal" &&
+          "h-2.5 flex-col border-t border-t-transparent",
+        className
+      )}
+      {...props}
+    >
+      <ScrollAreaPrimitive.ScrollAreaThumb
+        data-slot="scroll-area-thumb"
+        className="bg-border relative flex-1 rounded-full"
+      />
+    </ScrollAreaPrimitive.ScrollAreaScrollbar>
+  )
+}
+
+export { ScrollArea, ScrollBar }

frontend/src/utils/querys/production/lots.tsx

@@ -1,4 +1,4 @@
-import {queryOptions} from "@tanstack/react-query";
+import { queryOptions } from "@tanstack/react-query";
 import axios from "axios";
 
 export function getlots() {
@@ -13,7 +13,7 @@ export function getlots() {
 }
 
 const fetchSettings = async () => {
-    const {data} = await axios.get("/api/v1/ocp/lots");
+    const { data } = await axios.get("/api/ocp/getlots");
     // if we are not localhost ignore the devDir setting.
     //const url: string = window.location.host.split(":")[0];
     let lotData = data.data;

package.json

@@ -21,7 +21,7 @@
     "deploy": "standard-version --conventional-commits && npm run prodBuild",
     "zipServer": "dotenvx run -f .env -- tsx server/scripts/zipUpBuild.ts \"C:\\Users\\matthes01\\Documents\\lstv2\"",
     "v1Build": "cd C:\\Users\\matthes01\\Documents\\logisticsSupportTool && npm run oldBuilder",
-    "prodBuild": "npm run v1Build && powershell -ExecutionPolicy Bypass -File server/scripts/build.ps1 -dir \"C:\\Users\\matthes01\\Documents\\lstv2\" && npm run zipServer",
+    "prodBuild": "npm run v1Build && powershell -ExecutionPolicy Bypass -File server/scripts/build.ps1 -dir \"C:\\Users\\matthes01\\Documents\\lstv2-dev\" && npm run zipServer",
     "commit": "cz",
     "prodinstall": "npm i --omit=dev && npm run db:migrate",
     "checkupdates": "npx npm-check-updates"
@@ -32,7 +32,7 @@
     }
   },
   "admConfig": {
-    "build": 50,
+    "build": 76,
     "oldBuild": "backend-0.1.3.zip"
   },
   "devDependencies": {

server/index.ts

@@ -1,12 +1,12 @@
 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
 import { serve } from "@hono/node-server";
 import { OpenAPIHono } from "@hono/zod-openapi";
-import { proxy } from "hono/proxy";
+
 import { serveStatic } from "@hono/node-server/serve-static";
 import { logger } from "hono/logger";
 import { cors } from "hono/cors";
 import { createLog } from "./services/logger/logger.js";
-import { WebSocketServer } from "ws";
+
 // custom routes
 import scalar from "./services/general/route/scalar.js";
 import system from "./services/server/systemServer.js";
@@ -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) {
-    return next();
-  }
+// 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();
+//   //   }
 
-  // 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/update.ps1

@@ -415,10 +415,10 @@ try {
     Start-Service -DisplayName  $serviceLstV2
     Start-Sleep -Seconds 1
     Write-Host "$($server) finished updating"
-    if($token -eq "usday1"){
-        Write-Host "Starting $($serviceOcme)"
-        Start-Service -DisplayName  $serviceOcme 
-    }
+    # if($token -eq "usday1"){
+    #     Write-Host "Starting $($serviceOcme)"
+    #     Start-Service -DisplayName  $serviceOcme 
+    # }
 
 }
 Invoke-Command -ComputerName $server -ScriptBlock $plantFunness -ArgumentList $server, $token, $location, $buildZip, $buildLoc, $obslst, $obsBuild -Credential $credentials

server/scripts/updateServers.ts

@@ -1,21 +1,24 @@
-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";
+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;
 };
 
-export const updateServer = async (devApp: string, server: string | null): Promise<UpdateServerResponse> => {
+export const updateServer = async (
+    devApp: string,
+    server: string | null
+): Promise<UpdateServerResponse> => {
     const app = await getAppInfo(devApp);
     const serverInfo = await db
-    .select()
-    .from(serverData)
-    .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
+        .select()
+        .from(serverData)
+        .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
 
     if (serverInfo.length === 0) {
         createLog(
@@ -26,7 +29,8 @@ export const updateServer = async (devApp: string, server: string | null): Promi
         );
         return {
             success: false,
-            message: "Looks like you are missing the plant token or have entered an incorrect one please try again.",
+            message:
+                "Looks like you are missing the plant token or have entered an incorrect one please try again.",
         };
     }
 
@@ -77,9 +81,9 @@ export const updateServer = async (devApp: string, server: string | null): Promi
         const process = spawn("powershell", args);
         // change the server to upgradeing
         await db
-        .update(serverData)
-        .set({isUpgrading: true})
-        .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
+            .update(serverData)
+            .set({ isUpgrading: true })
+            .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
         //let stdout = "";
         //let stderr = "";
 
@@ -108,9 +112,14 @@ export const updateServer = async (devApp: string, server: string | null): Promi
                 //update the last build.
                 try {
                     await db
-                    .update(serverData)
-                    .set({lastUpdated: sql`NOW()`, isUpgrading: false})
-                    .where(eq(serverData.plantToken, server?.toLowerCase() ?? ""));
+                        .update(serverData)
+                        .set({ lastUpdated: sql`NOW()`, isUpgrading: false })
+                        .where(
+                            eq(
+                                serverData.plantToken,
+                                server?.toLowerCase() ?? ""
+                            )
+                        );
                     createLog(
                         "info",
                         "lst",
@@ -156,17 +165,35 @@ export const updateServer = async (devApp: string, server: string | null): Promi
 export async function processAllServers(devApp: string) {
     const servers = await db.select().from(serverData);
 
-    createLog("info", "lst", "serverUpdater", `Running the update on all servers`);
+    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.`);
+            const updateToServer = await updateServer(
+                devApp,
+                server.plantToken
+            );
+            createLog(
+                "info",
+                "lst",
+                "serverUpdater",
+                `${server.sName} was updated.`
+            );
             count = count + 1;
 
             //return {success: true, message: `${server.sName} was updated.`, data: updateToServer};
         } catch (error: any) {
-            createLog("info", "lst", "serverUpdater", `Error updating ${server.sName}: ${error.message}`);
+            createLog(
+                "info",
+                "lst",
+                "serverUpdater",
+                `Error updating ${server.sName}: ${error.message}`
+            );
             //return {success: false, message: `Error updating ${server.sName}: ${error.message}`};
         }
     }

server/scripts/zipUpBuild.ts

@@ -99,7 +99,7 @@ const updateBuildNumber = (appLock: string) => {
       // Auto-commit changes
       execSync("git add package.json");
       execSync(
-        `git commit -m "build: bump build number to ${pkgJson.admConfig.build}"`
+        `git commit -m "chore(release): bump build number to ${pkgJson.admConfig.build}"`
       );
     } else {
       createLog(

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

@@ -3,9 +3,14 @@ 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"}}
+            "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);
 

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

@@ -1,43 +1,76 @@
-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";
+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) => {
-    // if we have sscc we will do everything here and ignore the rn even it its sent over
-    if (data.sscc && !data.runningNr) {
-        data.runningNr = data.sscc.slice(10, -1);
+    console.log(data);
+    let newData = data;
+    if (Array.isArray(data)) {
+        newData = {
+            sscc: data[1],
+            areaFrom: data[0],
+            completed: true,
+        };
     }
 
-    if (!data.sscc && !data.runningNr) {
-        // data.runningNr = data.sscc.slice(10, -1);
-        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]", data.runningNr);
-
+    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");
+        createLog(
+            "error",
+            "ocme",
+            "ocme",
+            "There was an error getting the labelData"
+        );
     }
     const newPost = {
-        sscc: data.sscc ? data.sscc : await createSSCC(data.runningNr),
-        runningNr: data.runningNr,
-        completed: data.completed,
-        lineNum: label[0].machineLocation,
-        areaFrom: data.areaFrom,
+        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,
     };
-
     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};
+        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: newPost};
+        //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/cycleCount.ts

@@ -1,60 +1,71 @@
-import {createRoute, OpenAPIHono, z} from "@hono/zod-openapi";
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
 
-import {apiHit} from "../../../globalUtils/apiHits.js";
-import {responses} from "../../../globalUtils/routeDefs/responses.js";
-import {authMiddleware} from "../../auth/middleware/authMiddleware.js";
-import {cycleCount} from "../controller/cycleCount.js";
-import type {User} from "../../../types/users.js";
-import {verify} from "hono/jwt";
+import { apiHit } from "../../../globalUtils/apiHits.js";
+import { responses } from "../../../globalUtils/routeDefs/responses.js";
+import { authMiddleware } from "../../auth/middleware/authMiddleware.js";
+import { cycleCount } from "../controller/cycleCount.js";
+import type { User } from "../../../types/users.js";
+import { verify } from "hono/jwt";
 
-const app = new OpenAPIHono({strict: false});
+const app = new OpenAPIHono({ strict: false });
 
 const AddSetting = z.object({
-    lane: z.string().openapi({example: "L064"}),
+  lane: z.string().openapi({ example: "L064" }),
 });
 
 app.openapi(
-    createRoute({
-        tags: ["ocme"],
-        summary: "Cycle counts a lane based on the lane Alias",
-        method: "post",
-        path: "/cyclecount",
-        middleware: authMiddleware,
-        request: {
-            body: {
-                content: {
-                    "application/json": {schema: AddSetting},
-                },
-            },
+  createRoute({
+    tags: ["ocme"],
+    summary: "Cycle counts a lane based on the lane Alias",
+    method: "post",
+    path: "/cycleCount",
+    middleware: authMiddleware,
+    request: {
+      body: {
+        content: {
+          "application/json": { schema: AddSetting },
         },
-        responses: responses(),
-    }),
-    async (c) => {
-        apiHit(c, {endpoint: "api/auth/register"});
-        // make sure we have a vaid user being accessed thats really logged in
-        const body = await c.req.json();
+      },
+    },
+    responses: responses(),
+  }),
+  async (c) => {
+    apiHit(c, { endpoint: "api/auth/register" });
+    // make sure we have a vaid user being accessed thats really logged in
+    const body = await c.req.json();
 
-        const authHeader = c.req.header("Authorization");
+    const authHeader = c.req.header("Authorization");
 
-        const token = authHeader?.split("Bearer ")[1] || "";
-        let user: User;
+    const token = authHeader?.split("Bearer ")[1] || "";
+    let user: User;
 
-        try {
-            const payload = await verify(token, process.env.JWT_SECRET!);
-            user = payload.user as User;
-        } catch (error) {
-            return c.json({message: "Unauthorized"}, 401);
-        }
-
-        try {
-            const cycleData = await cycleCount(body, user);
-            return c.json({success: true, message: `${body.lane} was just cycle counted.`, data: cycleData}, 200);
-        } catch (error) {
-            return c.json(
-                {success: false, message: `There was an error cycle counting ${body.lane}`, data: error},
-                400
-            );
-        }
+    try {
+      const payload = await verify(token, process.env.JWT_SECRET!);
+      user = payload.user as User;
+    } catch (error) {
+      return c.json({ message: "Unauthorized" }, 401);
     }
+
+    try {
+      const cycleData = await cycleCount(body, user);
+      return c.json(
+        {
+          success: true,
+          message: `${body.lane} was just cycle counted.`,
+          data: cycleData,
+        },
+        200
+      );
+    } catch (error) {
+      return c.json(
+        {
+          success: false,
+          message: `There was an error cycle counting ${body.lane}`,
+          data: error,
+        },
+        400
+      );
+    }
+  }
 );
 export default app;

server/services/ocme/route/getInfo.ts

@@ -1,80 +1,36 @@
-import {createRoute, OpenAPIHono, z} from "@hono/zod-openapi";
-import {getInfo} from "../controller/getInfo.js";
-import {apiHit} from "../../../globalUtils/apiHits.js";
+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"}),
-});
+const app = new OpenAPIHono({ strict: false });
 
 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",
-            // },
-        },
+        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"});
+        apiHit(c, { endpoint: "api/auth/register" });
         try {
-            return c.json({success: true, message: "Ocme Info", data: await getInfo()}, 200);
+            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);
+            return c.json(
+                {
+                    success: false,
+                    message: "There was an error getting ocmeInfo data",
+                    data: error,
+                },
+                400
+            );
         }
     }
 );

server/services/ocme/route/getShipmentPallets.ts

@@ -1,94 +1,114 @@
-import {createRoute, OpenAPIHono, z} from "@hono/zod-openapi";
-import {apiHit} from "../../../globalUtils/apiHits.js";
-import {getShipmentPallets} from "../controller/getShipmentPallets.js";
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { apiHit } from "../../../globalUtils/apiHits.js";
+import { getShipmentPallets } from "../controller/getShipmentPallets.js";
 
 const app = new OpenAPIHono();
 
 const ShipmentID = z.object({
-    shipmentID: z.string().optional().openapi({example: "14558"}),
+  shipmentID: z.string().optional().openapi({ example: "14558" }),
 });
 
 app.openapi(
-    createRoute({
-        tags: ["ocme"],
-        summary: "Post New running number to be picked up.",
-        method: "post",
-        path: "/getshipmentpallets",
-        request: {
-            body: {
-                content: {
-                    "application/json": {schema: ShipmentID},
-                },
-            },
+  createRoute({
+    tags: ["ocme"],
+    summary: "Post New running number to be picked up.",
+    method: "post",
+    path: "/GetShipmentPallets",
+    request: {
+      body: {
+        content: {
+          "application/json": { schema: ShipmentID },
         },
-        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/getshipmentpallets", lastBody: data});
+        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/getshipmentpallets", lastBody: data });
 
-            if (!data.shipmentID) {
-                return c.json(
-                    {success: false, message: "You are missing the shipment id please try again.", data: []},
-                    400
-                );
-            }
+      console.log;
 
-            const shiptmentData = await getShipmentPallets(data.shipmentID);
+      if (!data.shipmentID) {
+        return c.json(
+          {
+            success: false,
+            message: "You are missing the shipment id please try again.",
+            data: [],
+          },
+          400
+        );
+      }
 
-            return c.json(
-                {success: shiptmentData.success, message: shiptmentData.message, data: shiptmentData.data ?? []},
-                200
-            );
-        } catch (error) {
-            return c.json({success: false, message: "There was an error getting the shipment data.", data: error}, 400);
-        }
+      const shiptmentData = await getShipmentPallets(data.shipmentID);
+
+      return c.json(
+        {
+          success: shiptmentData.success,
+          message: shiptmentData.message,
+          data: shiptmentData.data ?? [],
+        },
+        200
+      );
+    } catch (error) {
+      return c.json(
+        {
+          success: false,
+          message: "There was an error getting the shipment data.",
+          data: error,
+        },
+        400
+      );
     }
+  }
 );
 export default app;

server/services/ocme/route/pickedUp.ts

@@ -1,89 +1,114 @@
-import {createRoute, OpenAPIHono, z} from "@hono/zod-openapi";
-import {postLabelData} from "../controller/postRunningNr.js";
-import {apiHit} from "../../../globalUtils/apiHits.js";
-import {pickedup} from "../controller/pickedup.js";
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { postLabelData } from "../controller/postRunningNr.js";
+import { apiHit } from "../../../globalUtils/apiHits.js";
+import { pickedup } from "../controller/pickedup.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}),
-    all: z.boolean().optional().openapi({example: false}),
+  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 }),
+  all: z.boolean().optional().openapi({ example: false }),
 });
 
 app.openapi(
-    createRoute({
-        tags: ["ocme"],
-        summary: "Picks up a pallet in the system.",
-        method: "patch",
-        description:
-            "removes the pallet(s) from showing as needed to be picked up, we clear everything related to the pallet number to reduce the risk of a mix, passing `all` will just clear everything that is pending.",
-        path: "/pickedup",
-        request: {
-            body: {
-                content: {
-                    "application/json": {schema: PostRunningNr},
-                },
-            },
+  createRoute({
+    tags: ["ocme"],
+    summary: "Picks up a pallet in the system.",
+    method: "patch",
+    description:
+      "removes the pallet(s) from showing as needed to be picked up, we clear everything related to the pallet number to reduce the risk of a mix, passing `all` will just clear everything that is pending.",
+    path: "/pickedUp",
+    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/pickedup", lastBody: data});
-            const postPallet = await pickedup(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/pickedup", lastBody: data });
+      const postPallet = await pickedup(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/postRunningNumber.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: "/postrunningnumber",
-        request: {
-            body: {
-                content: {
-                    "application/json": {schema: PostRunningNr},
-                },
-            },
+  createRoute({
+    tags: ["ocme"],
+    summary: "Post New running number to be picked up.",
+    method: "post",
+    path: "/postRunningNumber",
+    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/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/ocp/controller/lots/lots.ts

@@ -0,0 +1,23 @@
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { query } from "../../../sqlServer/prodSqlServer.js";
+import { lotQuery } from "../../../sqlServer/querys/ocp/lots.js";
+
+export const getLots = async () => {
+    const { data: lotInfo, error: lotError } = await tryCatch(
+        query(lotQuery, "Alplalabel online lots")
+    );
+
+    if (lotError) {
+        return {
+            success: false,
+            message: "There was an error getting the lots",
+            data: lotError,
+        };
+    }
+
+    return {
+        success: true,
+        message: "Current active lots that are technically released.",
+        data: lotInfo,
+    };
+};

server/services/ocp/controller/manualLabelLog.ts

@@ -1,20 +1,44 @@
-import {db} from "../../../../database/dbclient.js";
-import {manualPrinting} from "../../../../database/schema/ocpManualPrint.js";
+import { db } from "../../../../database/dbclient.js";
+import { manualPrinting } from "../../../../database/schema/ocpManualPrint.js";
+import { tryCatch } from "../../../globalUtils/tryCatch.js";
 
-export const manualPrint = async (data: any) => {
+export const manualPrint = async (manualPrint: any) => {
     /**
      * add the reason we did a manual print.
      */
 
     const manualPrintData = {
-        line: data.line,
-        printReason: data.printReason,
-        initials: data.initials,
-        additionalComments: data?.additionalComments,
+        line: manualPrint.line,
+        printReason: manualPrint.printReason,
+        initials: manualPrint.initials,
+        additionalComments: manualPrint?.additionalComments,
         add_user: "lst",
     };
 
-    try {
-        const manualPrint = await db.insert(manualPrinting).values(manualPrintData);
-    } catch (error) {}
+    const { data, error } = await tryCatch(
+        db
+            .insert(manualPrinting)
+            .values(manualPrintData)
+            .returning({
+                line: manualPrinting.line,
+                printReason: manualPrinting.printReason,
+                initials: manualPrinting.initials,
+                additionalComments: manualPrinting?.additionalComments,
+                add_user: manualPrinting.add_user,
+            })
+    );
+
+    if (error) {
+        return {
+            success: false,
+            message: "There was an error posting the manualPrintData",
+            data: error,
+        };
+    }
+
+    return {
+        success: true,
+        message: "There was an error posting the manualPrintData",
+        data,
+    };
 };

server/services/ocp/controller/printers/getPrinters.ts

@@ -0,0 +1,21 @@
+import { db } from "../../../../../database/dbclient.js";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { printers } from "../../../../../database/schema/printers.js";
+
+export const getPrinters = async () => {
+    const currentTime = new Date(Date.now());
+
+    const { data: printerData, error: printerError } = await tryCatch(
+        db.select().from(printers)
+    );
+
+    if (printerError) {
+        return {
+            success: false,
+            message: "there was an error getting the printers",
+            data: printerError,
+        };
+    }
+
+    return { success: true, message: "Printers", data: printerData };
+};

server/services/ocp/controller/printers/updatePrinters.ts

@@ -0,0 +1,84 @@
+import { printers } from "../../../../../database/schema/printers.js";
+import axios from "axios";
+
+import { sql } from "drizzle-orm";
+import { prodEndpointCreation } from "../../../../globalUtils/createUrl.js";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { lstAuth } from "../../../../index.js";
+import { db } from "../../../../../database/dbclient.js";
+import { createLog } from "../../../logger/logger.js";
+
+export const updatePrinters = async () => {
+    const currentTime = new Date(Date.now());
+
+    // get the printers from prod
+    let url = await prodEndpointCreation(
+        "/public/v1.0/Administration/Printers"
+    );
+
+    const { data: prodPrinters, error: prodError } = await tryCatch(
+        axios.get(url, {
+            headers: {
+                Authorization: `Basic ${lstAuth}`,
+                "Content-Type": "application/json",
+            },
+        })
+    );
+
+    if (prodError) {
+        console.log(prodError);
+        return {
+            success: false,
+            message: "there was an error getting the printers.",
+            data: prodError,
+        };
+    }
+
+    // do the printer update into our db
+    const prodPrinterInfo = prodPrinters.data;
+
+    for (let i = 0; i < prodPrinterInfo.length; i++) {
+        const printerStuff: any = {
+            humanReadableId: prodPrinterInfo[i].humanReadableId,
+            name: prodPrinterInfo[i].name,
+            ipAddress: prodPrinterInfo[i].ipAddress,
+            port: prodPrinterInfo[i].port,
+            remark: prodPrinterInfo[i].remark,
+        };
+        const { data, error } = await tryCatch(
+            db
+                .insert(printers)
+                .values(printerStuff)
+                .onConflictDoUpdate({
+                    target: printers.humanReadableId,
+                    set: {
+                        //humanReadableId: prodPrinterInfo[i].humanReadableId,
+                        name: prodPrinterInfo[i].name,
+                        ipAddress: prodPrinterInfo[i].ipAddress,
+                        port: prodPrinterInfo[i].port,
+                        remark: prodPrinterInfo[i].remark,
+                        upd_date: sql`NOW()`,
+                    },
+                })
+        );
+
+        if (error) {
+            createLog(
+                "error",
+                "lst",
+                "ocp",
+                `${
+                    prodPrinterInfo[i].name
+                } encoutered and error adding/updating ${JSON.stringify(error)}`
+            );
+        }
+        createLog(
+            "info",
+            "lst",
+            "ocp",
+            `${prodPrinterInfo[i].name} were just added/updated.`
+        );
+    }
+
+    return { success: true, message: "Printers were just added or updated." };
+};

server/services/ocp/ocpService.ts

@@ -1,14 +1,24 @@
-import {OpenAPIHono} from "@hono/zod-openapi";
+import { OpenAPIHono } from "@hono/zod-openapi";
 
 // routes
 import manualLabelLog from "./routes/manualPrintLog.js";
-
-import {db} from "../../../database/dbclient.js";
-import {settings} from "../../../database/schema/settings.js";
+import getPrinters from "./routes/printers/getPritners.js";
+import { db } from "../../../database/dbclient.js";
+import { settings } from "../../../database/schema/settings.js";
+import updateprinters from "./routes/printers/updatePrinters.js";
+import { updatePrinters } from "./controller/printers/updatePrinters.js";
+import getLots from "./routes/lots/getLots.js";
 
 const app = new OpenAPIHono();
 
-const routes = [manualLabelLog] as const;
+const routes = [
+    manualLabelLog,
+    //printer
+    getPrinters,
+    updateprinters,
+    // lots
+    getLots,
+] as const;
 const setting = await db.select().from(settings);
 
 const appRoutes = routes.forEach((route) => {
@@ -16,7 +26,13 @@ const appRoutes = routes.forEach((route) => {
 });
 
 app.all("/ocp/*", (c) => {
-    return c.json({success: false, message: "You have encounters a ocp route that dose not exist."});
+    return c.json({
+        success: false,
+        message: "You have encounters a ocp route that dose not exist.",
+    });
 });
 
+// run the printer update on restart just to keep everything good
+updatePrinters();
+
 export default app;

server/services/ocp/routes/lots/getLots.ts

@@ -0,0 +1,35 @@
+// an external way to creating logs
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { responses } from "../../../../globalUtils/routeDefs/responses.js";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { getPrinters } from "../../controller/printers/getPrinters.js";
+import { getLots } from "../../controller/lots/lots.js";
+
+const app = new OpenAPIHono({ strict: false });
+
+app.openapi(
+    createRoute({
+        tags: ["ocp"],
+        summary: "Returns current active lots that are tech released",
+        method: "get",
+        path: "/getlots",
+        responses: responses(),
+    }),
+    async (c) => {
+        const { data: lotData, error: lotError } = await tryCatch(getLots());
+
+        if (lotError) {
+            return c.json({
+                success: false,
+                message: "There was an error getting the printers",
+            });
+        }
+
+        return c.json({
+            success: lotData.success,
+            message: lotData.message,
+            data: lotData.data,
+        });
+    }
+);
+export default app;

server/services/ocp/routes/manualPrintLog.ts

@@ -1,18 +1,21 @@
 // an external way to creating logs
-import {createRoute, OpenAPIHono, z} from "@hono/zod-openapi";
-import {apiHit} from "../../../globalUtils/apiHits.js";
-import {responses} from "../../../globalUtils/routeDefs/responses.js";
-import type {User} from "../../../types/users.js";
-import {verify} from "hono/jwt";
-import {manualPrint} from "../controller/manualLabelLog.js";
-import {authMiddleware} from "../../auth/middleware/authMiddleware.js";
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { apiHit } from "../../../globalUtils/apiHits.js";
+import { responses } from "../../../globalUtils/routeDefs/responses.js";
+import type { User } from "../../../types/users.js";
+import { verify } from "hono/jwt";
+import { manualPrint } from "../controller/manualLabelLog.js";
+import { authMiddleware } from "../../auth/middleware/authMiddleware.js";
 
-const app = new OpenAPIHono({strict: false});
+const app = new OpenAPIHono({ strict: false });
 const CreateLog = z.object({
-    line: z.string().openapi({example: "info"}),
-    initials: z.string().openapi({example: "server"}),
-    printReason: z.string().openapi({example: "This is a new log posted"}),
-    additionalComments: z.string().optional().openapi({example: "Some reason why we did this."}),
+    line: z.string().openapi({ example: "info" }),
+    initials: z.string().openapi({ example: "server" }),
+    printReason: z.string().openapi({ example: "This is a new log posted" }),
+    additionalComments: z
+        .string()
+        .optional()
+        .openapi({ example: "Some reason why we did this." }),
 });
 
 app.openapi(
@@ -24,32 +27,33 @@ app.openapi(
         //middleware: authMiddleware,
         //description: "This might be a temp soltuin during the transtion between versions",
         request: {
-            body: {content: {"application/json": {schema: CreateLog}}},
+            body: { content: { "application/json": { schema: CreateLog } } },
         },
         responses: responses(),
     }),
     async (c) => {
         const body = await c.req.json();
-        apiHit(c, {endpoint: `api/logger/logs/id`});
-        // const authHeader = c.req.header("Authorization");
-
-        // const token = authHeader?.split("Bearer ")[1] || "";
-        // let user: User;
-
-        // try {
-        //     const payload = await verify(token, process.env.JWT_SECRET!);
-        //     user = payload.user as User;
-        // } catch (error) {
-        //     console.log(error);
-        //     return c.json({message: "Unauthorized"}, 401);
-        // }
-
+        apiHit(c, { endpoint: `api/logger/logs/id` });
         try {
             //const data = {...body, add_user: user.username};
-            await manualPrint(body);
-            return c.json({success: true, message: "Manual Print was added.", data: []}, 200);
+            const printLog: any = await manualPrint(body);
+            return c.json(
+                {
+                    success: printLog.success,
+                    message: printLog.message,
+                    data: printLog.data ?? [],
+                },
+                200
+            );
         } catch (error) {
-            return c.json({success: false, message: "There was an error clearing the log.", data: error}, 400);
+            return c.json(
+                {
+                    success: false,
+                    message: "There was an error clearing the log.",
+                    data: error,
+                },
+                400
+            );
         }
     }
 );

server/services/ocp/routes/printers/getPritners.ts

@@ -0,0 +1,50 @@
+// an external way to creating logs
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { responses } from "../../../../globalUtils/routeDefs/responses.js";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { getPrinters } from "../../controller/printers/getPrinters.js";
+
+const app = new OpenAPIHono({ strict: false });
+const CreateLog = z.object({
+    line: z.string().openapi({ example: "info" }),
+    initials: z.string().openapi({ example: "server" }),
+    printReason: z.string().openapi({ example: "This is a new log posted" }),
+    additionalComments: z
+        .string()
+        .optional()
+        .openapi({ example: "Some reason why we did this." }),
+});
+
+app.openapi(
+    createRoute({
+        tags: ["ocp"],
+        summary: "Prints a label.",
+        method: "get",
+        path: "/getprinters",
+        //middleware: authMiddleware,
+        //description: "This might be a temp soltuin during the transtion between versions",
+        request: {
+            body: { content: { "application/json": { schema: CreateLog } } },
+        },
+        responses: responses(),
+    }),
+    async (c) => {
+        const { data: printData, error: printError } = await tryCatch(
+            getPrinters()
+        );
+
+        if (printError) {
+            return c.json({
+                success: false,
+                message: "There was an error getting the printers",
+            });
+        }
+
+        return c.json({
+            success: printData.success,
+            message: printData.message,
+            data: printData.data,
+        });
+    }
+);
+export default app;

server/services/ocp/routes/printers/updatePrinters.ts

@@ -0,0 +1,50 @@
+// an external way to creating logs
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { responses } from "../../../../globalUtils/routeDefs/responses.js";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { updatePrinters } from "../../controller/printers/updatePrinters.js";
+
+const app = new OpenAPIHono({ strict: false });
+const CreateLog = z.object({
+    line: z.string().openapi({ example: "info" }),
+    initials: z.string().openapi({ example: "server" }),
+    printReason: z.string().openapi({ example: "This is a new log posted" }),
+    additionalComments: z
+        .string()
+        .optional()
+        .openapi({ example: "Some reason why we did this." }),
+});
+
+app.openapi(
+    createRoute({
+        tags: ["ocp"],
+        summary: "Prints a label.",
+        method: "get",
+        path: "/updateprinters",
+        //middleware: authMiddleware,
+        //description: "This might be a temp soltuin during the transtion between versions",
+        request: {
+            body: { content: { "application/json": { schema: CreateLog } } },
+        },
+        responses: responses(),
+    }),
+    async (c) => {
+        const { data: printData, error: printError } = await tryCatch(
+            updatePrinters()
+        );
+
+        if (printError) {
+            return c.json({
+                success: false,
+                message: "There was an error getting the printers",
+            });
+        }
+
+        return c.json({
+            success: printData.success,
+            message: printData.message,
+            data: printData.data,
+        });
+    }
+);
+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/sqlServer/querys/ocp/lots.ts

@@ -0,0 +1,55 @@
+export const lotQuery = `
+select IdMaschinen_ProdPlanung as LabelOnlineID, 
+    IdMaschine as machineID, 
+    MaschinenStandort as MachineLocation, 
+    MaschinenBez as MachineDescription,
+    IdProdPlanung as LOT,
+	prolink.lot as ProlinkLot,
+    IdArtikelvarianten as AV,
+    ArtikelVariantenBez as Alias,
+    convert(varchar, add_date, 20) as Add_Date,
+    Add_user,
+    idEtikettenDrucker as printerID,
+	b.name as PrinterName,
+    CAST(TotalPlannedLoadingUnits as float) as PlannedQTY,
+    CAST(TotalProducedLoadingUnits as float) as Produced,
+    ROUND(CAST(TotalPlannedLoadingUnits as float) - CAST(TotalProducedLoadingUnits as float),2) as Remaining,
+        case 
+	-- checks if someone changed the criteria to something else to trigger the over run 
+	when  x.ProzentReserveAnzahlPaletten > 0 then 'yes'
+
+	-- if the lot has a decimal in it to allow over running with no intervention 
+	when CAST(TotalPlannedLoadingUnits as float) - floor(CAST(TotalPlannedLoadingUnits as float)) > 0 then 'yes' 
+	else 'no' end as overPrinting,
+	CustomerHumanReadableId as CustomerId,
+	CustomerName as CustomerName,
+	idMaschine as MachineID,
+	prolink.lastProlinkUpdate as lastProlinkUpdate,
+    IdEtikettenLayoutPalette as palletLabel,
+	AnzahlKopienPalette as pallerCopies,
+	IdEtikettenLayoutKarton as cartonLabel,
+	AnzahlKopienKarton as cartonCopies,
+	IsTechnicallyReleased
+	--*
+    from AlplaPROD_test1.dbo.V_Maschinen_ProdPlanungen x (nolock)
+    join
+    [test1_AlplaPROD2.0_Read].[productionControlling].[ProducedLot] on  
+    x.IdProdPlanung = 
+    [test1_AlplaPROD2.0_Read].[productionControlling].[ProducedLot].ProductionLotHumanReadableId
+	left join
+	[test1_AlplaPROD2.0_Read].masterData.Printer as b on
+	x.IdEtikettenDrucker = b.HumanReadableId
+	-- adding in prolink lot
+	left join
+	(SELECT * from (SELECT IdMaschine as prolinkMachineId, 
+    Produktionslos as lot,  
+	Upd_Date as lastProlinkUpdate,
+    ROW_NUMBER() OVER (PARTITION BY IdMaschine ORDER BY Upd_Date DESC) RN_Prolink
+    FROM AlplaPROD_test1.dbo.T_HistoryProduktionsdaten (nolock)
+    WHERE Upd_Date BETWEEN DATEADD(DD, - 300, getdate()) AND DATEADD(DD, 1, getdate())) p
+	WHERE RN_Prolink = 1
+     ) as prolink on
+	 x.idMaschine = prolink.prolinkMachineId 
+
+     where IsTechnicallyReleased = 1
+`;

server/services/tcpServer/tcpServer.ts

@@ -1,23 +1,28 @@
 import net from "net";
-import {OpenAPIHono} from "@hono/zod-openapi";
-import {createLog} from "../logger/logger.js";
+import { OpenAPIHono } from "@hono/zod-openapi";
+import { createLog } from "../logger/logger.js";
 
 import startTCP from "./route/startServer.js";
 import stopTCP from "./route/stopServer.js";
 import restartTCP from "./route/restartServer.js";
-import {db} from "../../../database/dbclient.js";
-import {settings} from "../../../database/schema/settings.js";
-import {eq} from "drizzle-orm";
+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";
 
 let tcpServer: net.Server;
 let tcpSockets: Set<net.Socket> = new Set();
 let isServerRunning = false;
 
-const tcpPort = await db.select().from(settings).where(eq(settings.name, "tcpPort"));
+const tcpPort = await db
+    .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");
@@ -25,7 +30,19 @@ export const startTCPServer = () => {
         tcpSockets.add(socket);
         socket.on("data", (data: Buffer) => {
             console.log("Received:", data.toString());
-            socket.write("Message received");
+            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", () => {
@@ -40,16 +57,22 @@ export const startTCPServer = () => {
     });
 
     tcpServer.listen(tcpPort[0]?.value ?? 2222, () => {
-        createLog("info", "lst", "tcp", `TCP Server listening on port ${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"};
+    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"};
+    if (!isServerRunning)
+        return { success: false, message: "Server is not running" };
     for (const socket of tcpSockets) {
         socket.destroy();
     }
@@ -58,7 +81,7 @@ export const stopTCPServer = () => {
         console.log("TCP Server stopped");
     });
     isServerRunning = false;
-    return {success: true, message: "TCP Server stopped"};
+    return { success: true, message: "TCP Server stopped" };
 };
 
 app.route("/tcpserver/start", startTCP);