chore(release): 0.0.1-alpha.1

.vscode/settings.json

@@ -54,6 +54,7 @@
 		"alpla",
 		"alplamart",
 		"alplaprod",
+		"alplapurchase",
 		"bookin",
 		"Datamart",
 		"dotenvx",

CHANGELOG.md

@@ -0,0 +1,69 @@
+# All Changes to LST can be found below.
+
+## [0.0.1-alpha.1](https://git.tuffraid.net/cowch/lst_v3/compare/v0.0.1-alpha.0...v0.0.1-alpha.1) (2026-04-08)
+
+
+* **notifcaion:** style changes to the notificaion card and started the table ([7d6c2db](https://git.tuffraid.net/cowch/lst_v3/commits/7d6c2db89cae1f137f126f5814dccd373f7ccb76))
+
+
+### 🌟 Enhancements
+
+* **notification:** base notifcaiton sub and admin compelted ([5865ac3](https://git.tuffraid.net/cowch/lst_v3/commits/5865ac3b99d60005c4245740369b0e0789c8fbbd))
+* **notification:** reprint added ([a17787e](https://git.tuffraid.net/cowch/lst_v3/commits/a17787e85217f1fa4a5e5389e29c33ec09c286c5))
+* **puchase history:** purhcase history changed to long running no notification ([34b0aba](https://git.tuffraid.net/cowch/lst_v3/commits/34b0abac36f645d0fe5f508881ddbef81ff04b7c))
+* **purchase:** historical data capture for alpla purchase ([42861cc](https://git.tuffraid.net/cowch/lst_v3/commits/42861cc69e8d4aba5a9670aaed55417efda2b505))
+* **user notifications:** added the ability for users to sub to notifications and add multi email ([637de85](https://git.tuffraid.net/cowch/lst_v3/commits/637de857f99499a41f7175181523f5d809d95d7e))
+
+
+### 🐛 Bug fixes
+
+* **build:** issue with how i wrote the release token ([fe889ca](https://git.tuffraid.net/cowch/lst_v3/commits/fe889ca75731af08c42ec714b7f2abf17cd1ee40))
+* **build:** type in how we pushed the header over ([83a94ca](https://git.tuffraid.net/cowch/lst_v3/commits/83a94cacf3fc87287cdc0c0cc861b339e72e4b83))
+* **build:** typo ([860207a](https://git.tuffraid.net/cowch/lst_v3/commits/860207a60b6e04b15736cba631be6c7eab74d020))
+* **i suck:** more learning experance ([9ceba8b](https://git.tuffraid.net/cowch/lst_v3/commits/9ceba8b5bba17959f27b16b28f50a83c044863fb))
+* **lala:** something here ([17aed6c](https://git.tuffraid.net/cowch/lst_v3/commits/17aed6cb89f8220570f6c66f78dba6bb202c1aaa))
+* **release:** typo that caused errors ([76747cf](https://git.tuffraid.net/cowch/lst_v3/commits/76747cf91738bd0d0530afcf7b4f51f0db11ca98))
+* **typo:** more dam typos ([079478f](https://git.tuffraid.net/cowch/lst_v3/commits/079478f93217dea31c9a1e8ffed85d2381a6977d))
+* **wrelease:** forgot to save ([3775760](https://git.tuffraid.net/cowch/lst_v3/commits/377576073449e95d315defb913dc317759cc3f43))
+
+
+### 📝 Chore
+
+* **release:** 0.1.0-alpha.10 ([98e408c](https://git.tuffraid.net/cowch/lst_v3/commits/98e408cb8577da18e24821b55474198439434f3e))
+* **release:** 0.1.0-alpha.11 ([d6d5b45](https://git.tuffraid.net/cowch/lst_v3/commits/d6d5b451cd9aeba642ef94654ca20f4acd0b827c))
+* **release:** 0.1.0-alpha.12 ([1ad789b](https://git.tuffraid.net/cowch/lst_v3/commits/1ad789b2b91a20a2f5a8dc9e6f39af2e19ec9cdc))
+* **release:** 0.1.0-alpha.9 ([8f59bba](https://git.tuffraid.net/cowch/lst_v3/commits/8f59bba614a8eaa3105bb56f0db36013d5e68485))
+* **release:** version packages ([fb2c560](https://git.tuffraid.net/cowch/lst_v3/commits/fb2c5609aa12ea7823783c364d5bd029c48a64bd))
+* **release:** version packages ([b02b93b](https://git.tuffraid.net/cowch/lst_v3/commits/b02b93b83f488fbcee6d24db080ad0d1fe1c5f59))
+* **release:** version packages ([2c0dbf9](https://git.tuffraid.net/cowch/lst_v3/commits/2c0dbf95c7b8dfd2c98b476d3f44bc8929668c88))
+* **release:** version packages ([5c64600](https://git.tuffraid.net/cowch/lst_v3/commits/5c6460012aa70d336fbc9702240b4f19262a6b41))
+* **release:** version packages ([0ce3790](https://git.tuffraid.net/cowch/lst_v3/commits/0ce3790675bc408762eafe76cbd5ab496fd06e73))
+* **release:** version packages ([4caaf74](https://git.tuffraid.net/cowch/lst_v3/commits/4caaf745693d4df847aefd3721ac5d0ae792114a))
+* **release:** version packages ([699c124](https://git.tuffraid.net/cowch/lst_v3/commits/699c124b0efba8282e436210619504bda8878e90))
+* **release:** version packages ([c4fd74f](https://git.tuffraid.net/cowch/lst_v3/commits/c4fd74fc93226cffd9e39602f507a05cd8ea628b))
+
+
+### 📚 Documentation
+
+* **readme:** updated progress data ([92ba3ef](https://git.tuffraid.net/cowch/lst_v3/commits/92ba3ef5121afd0d82d4f40a5a985e1fdc081011))
+* **sop:** added more info ([be1d408](https://git.tuffraid.net/cowch/lst_v3/commits/be1d4081e07b0982b355a270b7850a852a4398f5))
+
+
+### 🛠️ Code Refactor
+
+* **build:** added in more info to the relase section ([5854889](https://git.tuffraid.net/cowch/lst_v3/commits/5854889eb5398feebda50a5d256ce7aec39ce112))
+* **build:** changes to auto release when we cahnge version ([643d12f](https://git.tuffraid.net/cowch/lst_v3/commits/643d12ff182827e724e1569a583bd625a0d1dd0c))
+* **build:** changes to the way we do release so it builds as well ([7d55c5f](https://git.tuffraid.net/cowch/lst_v3/commits/7d55c5f43173edb48d8709adcb972b7d8fbc3ebd))
+* **changelog:** reverted back to commit-chagnelog, like more than changeset for solo dev ([ed052df](https://git.tuffraid.net/cowch/lst_v3/commits/ed052dff3c81a7064660a7d25685e0505065252c))
+* **notification:** reprint - removed a console log as it shouldnt bc there ([5f3d683](https://git.tuffraid.net/cowch/lst_v3/commits/5f3d683a13c831229674166cced699e373131316))
+* **notification:** select menu looks propper now ([74262be](https://git.tuffraid.net/cowch/lst_v3/commits/74262beb6596ddc971971cc9214a2688accf3a8e))
+* **opendock refactor on how releases are posted:** this was a bug maybe just a better refactory ([0880298](https://git.tuffraid.net/cowch/lst_v3/commits/0880298cf53d83e487c706e73854e0874ae2d9da))
+* **queries:** changed dev version to be 1500ms vs 5000ms ([f3b8dd9](https://git.tuffraid.net/cowch/lst_v3/commits/f3b8dd94e5ebae0cc4dd0a2689a19051942e94b8))
+* **release:** changes to only have the changelog in the release ([6e85991](https://git.tuffraid.net/cowch/lst_v3/commits/6e8599106298ed13febd069d6fda8b354efb5b7b))
+* **userprofile:** changes to have the table be blank and say nothing subscribed ([3ecf5fb](https://git.tuffraid.net/cowch/lst_v3/commits/3ecf5fb916d5dc1b1ffb224e2142d94f7a9cb126))
+
+
+### 📈 Project Builds
+
+* **agent:** added westbend into the flow ([28c226d](https://git.tuffraid.net/cowch/lst_v3/commits/28c226ddbc37ab85cd6a9a6aec091def3e5623d6))
+* **changelog:** reset the change log after all crap testing ([0059b9b](https://git.tuffraid.net/cowch/lst_v3/commits/0059b9b850c9647695a3fecaf5927c2e3ee7b192))

backend/app.ts

@@ -26,7 +26,7 @@ const createApp = async () => {
 	const __dirname = dirname(__filename);
 
 	// well leave this active so we can monitor it to validate
-	app.use(morgan("tiny"));
+	app.use(morgan("dev"));
 	app.set("trust proxy", true);
 	app.use(lstCors());
 	app.all(`${baseUrl}/api/auth/*splat`, toNodeHandler(auth));
@@ -34,11 +34,11 @@ const createApp = async () => {
 	setupRoutes(baseUrl, app);
 
 	app.use(
-		baseUrl + "/app",
+		`${baseUrl}/app`,
 		express.static(join(__dirname, "../frontend/dist")),
 	);
 
-	app.get(baseUrl + "/app/*splat", (_, res) => {
+	app.get(`${baseUrl}/app/*splat`, (_, res) => {
 		res.sendFile(join(__dirname, "../frontend/dist/index.html"));
 	});
 

backend/db/schema/alplapurchase.schema.ts

@@ -0,0 +1,38 @@
+import {
+	integer,
+	jsonb,
+	pgTable,
+	text,
+	timestamp,
+	uuid,
+} from "drizzle-orm/pg-core";
+import { createInsertSchema, createSelectSchema } from "drizzle-zod";
+import type { z } from "zod";
+
+export const alplaPurchaseHistory = pgTable("alpla_purchase_history", {
+	id: uuid("id").defaultRandom().primaryKey(),
+	apo: integer("apo"),
+	revision: integer("revision"),
+	confirmed: integer("confirmed"),
+	status: integer("status"),
+	statusText: text("status_text"),
+	journalNum: integer("journal_num"),
+	add_date: timestamp("add_date").defaultNow(),
+	add_user: text("add_user"),
+	upd_user: text("upd_user"),
+	upd_date: timestamp("upd_date").defaultNow(),
+	remark: text("remark"),
+	approvedStatus: text("approved_status").default("pending"),
+	position: jsonb("position").default([]),
+	createdAt: timestamp("created_at").defaultNow(),
+});
+
+export const alplaPurchaseHistorySchema =
+	createSelectSchema(alplaPurchaseHistory);
+export const newAlplaPurchaseHistorySchema =
+	createInsertSchema(alplaPurchaseHistory);
+
+export type AlplaPurchaseHistory = z.infer<typeof alplaPurchaseHistorySchema>;
+export type NewAlplaPurchaseHistory = z.infer<
+	typeof newAlplaPurchaseHistorySchema
+>;

backend/db/schema/opendock.schema.ts

@@ -1,4 +1,5 @@
 import {
+	index,
 	integer,
 	jsonb,
 	pgTable,
@@ -9,14 +10,23 @@ import {
 import { createInsertSchema, createSelectSchema } from "drizzle-zod";
 import type { z } from "zod";
 
-export const opendockApt = pgTable("opendock_apt", {
-	id: uuid("id").defaultRandom().primaryKey(),
-	release: integer("release").unique(),
-	openDockAptId: text("open_dock_apt_id").notNull(),
-	appointment: jsonb("appointment").default([]),
-	upd_date: timestamp("upd_date").defaultNow(),
-	createdAt: timestamp("created_at").defaultNow(),
-});
+export const opendockApt = pgTable(
+	"opendock_apt",
+	{
+		id: uuid("id").defaultRandom().primaryKey(),
+		release: integer("release").notNull().unique(),
+		openDockAptId: text("open_dock_apt_id").notNull(),
+		appointment: jsonb("appointment").notNull().default([]),
+		upd_date: timestamp("upd_date").notNull().defaultNow(),
+		createdAt: timestamp("created_at").notNull().defaultNow(),
+	},
+	(table) => ({
+		releaseIdx: index("opendock_apt_release_idx").on(table.release),
+		openDockAptIdIdx: index("opendock_apt_opendock_id_idx").on(
+			table.openDockAptId,
+		),
+	}),
+);
 
 export const opendockAptSchema = createSelectSchema(opendockApt);
 export const newOpendockAptSchema = createInsertSchema(opendockApt);

backend/notification/notification.alplapurchase.ts

@@ -0,0 +1,113 @@
+import { eq } from "drizzle-orm";
+import { db } from "../db/db.controller.js";
+import { notifications } from "../db/schema/notifications.schema.js";
+import { prodQuery } from "../prodSql/prodSqlQuery.controller.js";
+import {
+	type SqlQuery,
+	sqlQuerySelector,
+} from "../prodSql/prodSqlQuerySelector.utils.js";
+import { returnFunc } from "../utils/returnHelper.utils.js";
+import { sendEmail } from "../utils/sendEmail.utils.js";
+import { tryCatch } from "../utils/trycatch.utils.js";
+
+/**
+ *
+ */
+const func = async (data: any, emails: string) => {
+	// get the actual notification as items will be updated between intervals if no one touches
+	const { data: l, error: le } = (await tryCatch(
+		db.select().from(notifications).where(eq(notifications.id, data.id)),
+	)) as any;
+
+	if (le) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "notification",
+			subModule: "query",
+			message: `${data.name} encountered an error while trying to get initial info`,
+			data: [le],
+			notify: true,
+		});
+	}
+
+	// search the query db for the query by name
+	const sqlQuery = sqlQuerySelector(`${data.name}`) as SqlQuery;
+	// create the ignore audit logs ids
+	const ignoreIds = l[0].options[0]?.auditId
+		? `${l[0].options[0]?.auditId}`
+		: "0";
+
+	// run the check
+	const { data: queryRun, error } = await tryCatch(
+		prodQuery(
+			sqlQuery.query
+				.replace("[intervalCheck]", l[0].interval)
+				.replace("[ignoreList]", ignoreIds),
+			`Running notification query: ${l[0].name}`,
+		),
+	);
+
+	if (error) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "notification",
+			subModule: "query",
+			message: `Data for: ${l[0].name} encountered an error while trying to get it`,
+			data: [error],
+			notify: true,
+		});
+	}
+
+	if (queryRun.data.length > 0) {
+		// update the latest audit id
+		const { error: dbe } = await tryCatch(
+			db
+				.update(notifications)
+				.set({ options: [{ auditId: `${queryRun.data[0].id}` }] })
+				.where(eq(notifications.id, data.id)),
+		);
+
+		if (dbe) {
+			return returnFunc({
+				success: false,
+				level: "error",
+				module: "notification",
+				subModule: "query",
+				message: `Data for: ${l[0].name} encountered an error while trying to get it`,
+				data: [dbe],
+				notify: true,
+			});
+		}
+
+		// send the email
+
+		const sentEmail = await sendEmail({
+			email: emails,
+			subject: "Alert! Label Reprinted",
+			template: "reprintLabels",
+			context: {
+				items: queryRun.data,
+			},
+		});
+
+		if (!sentEmail?.success) {
+			return returnFunc({
+				success: false,
+				level: "error",
+				module: "email",
+				subModule: "notification",
+				message: `${l[0].name} failed to send the email`,
+				data: [sentEmail],
+				notify: true,
+			});
+		}
+	} else {
+		console.log("doing nothing as there is nothing to do.");
+	}
+	// TODO send the error to systemAdmin users so they do not always need to be on the notifications.
+	// these errors are defined per notification.
+};
+
+export default func;

backend/notification/notification.reprintLabels.ts

@@ -100,11 +100,7 @@ const reprint = async (data: any, emails: string) => {
 				notify: true,
 			});
 		}
-	} else {
-		console.log("doing nothing as there is nothing to do.");
 	}
-	// TODO send the error to systemAdmin users so they do not always need to be on the notifications.
-	// these errors are defined per notification.
 };
 
 export default reprint;

backend/notification/notifications.master.ts

@@ -16,6 +16,26 @@ const note: NewNotification[] = [
 		interval: "10",
 		options: [{ auditId: [0] }],
 	},
+	{
+		name: "qualityBlocking",
+		description:
+			"Checks for new blocking orders that have been entered, recommend to get the most recent order in here before activating.",
+		active: false,
+		interval: "10",
+		options: [{ sentBlockingOrders: [{ timeStamp: "0", blockingOrder: 1 }] }],
+	},
+	{
+		name: "alplaPurchaseHistory",
+		description:
+			"Will check the alpla purchase data for any changes, if the req has not been sent already then we will send this, for a po or fresh order we will ignore. ",
+		active: false,
+		interval: "5",
+		options: [
+			{ sentReqs: [{ timeStamp: "0", req: 1, approved: false }] },
+			{ sentAPOs: [{ timeStamp: "0", apo: 1 }] },
+			{ sentRCT: [{ timeStamp: "0", rct: 1 }] },
+		],
+	},
 ];
 
 export const createNotifications = async () => {

backend/opendock/openDockRreleaseMonitor.utils.ts

@@ -17,15 +17,6 @@ import { returnFunc } from "../utils/returnHelper.utils.js";
 import { tryCatch } from "../utils/trycatch.utils.js";
 import { getToken, odToken } from "./opendock.utils.js";
 
-let lastCheck = formatInTimeZone(
-	new Date().toISOString(),
-	"America/New_York",
-	"yyyy-MM-dd HH:mm:ss",
-);
-
-//const queue: unknown[] = [];
-//const isProcessing: boolean = false;
-
 type Releases = {
 	ReleaseNumber: number;
 	DeliveryState: number;
@@ -37,10 +28,38 @@ type Releases = {
 	LineItemArticleWeight: number;
 	CustomerReleaseNumber: string;
 };
-
+const timeZone = process.env.TIMEZONE as string;
 const TWENTY_FOUR_HOURS = 24 * 60 * 60 * 1000;
 const log = createLogger({ module: "opendock", subModule: "releaseMonitor" });
 
+// making the cron more safe when it comes to buffer stuff
+let opendockSyncRunning = false;
+
+let lastCheck = formatInTimeZone(
+	new Date().toISOString(),
+	timeZone,
+	"yyyy-MM-dd HH:mm:ss",
+);
+
+// const lastCheck = formatInTimeZone(
+// 	new Date().toISOString(),
+// 	`America/New_York`, //TODO: Pull timezone from the .env last as process.env.TIME_ZONE is not working so need to figure itout
+// 	"yyyy-MM-dd HH:mm:ss",
+// );
+
+//const queue: unknown[] = [];
+//const isProcessing: boolean = false;
+
+// const parseDbDate = (value: string | Date) => {
+// 	if (value instanceof Date) return value;
+
+// 	// normalize "2026-04-08 13:10:43.280" -> "2026-04-08T13:10:43.280"
+// 	const normalized = value.replace(" ", "T");
+
+// 	// interpret that wall-clock time as America/New_York
+// 	return fromZonedTime(normalized, timeZone);
+// };
+
 const postRelease = async (release: Releases) => {
 	if (!odToken.odToken) {
 		log.info({}, "Getting Auth Token");
@@ -152,22 +171,25 @@ const postRelease = async (release: Releases) => {
 	};
 
 	// TODO: pull the current added releases from the db and if one matches then we want to get its id and run the update vs create
-	const { data: apt, error: aptError } = await tryCatch(
-		db.select().from(opendockApt),
+	const { data: existingApt, error: aptError } = await tryCatch(
+		db
+			.select()
+			.from(opendockApt)
+			.where(eq(opendockApt.release, release.ReleaseNumber))
+			.limit(1),
 	);
-
 	if (aptError) {
 		log.error({ error: aptError }, "Error getting apt data");
 		// TODO: send an error email on this one as it will cause issues
 		return;
 	}
 
-	const releaseCheck = apt.filter((r) => r.release === release.ReleaseNumber);
+	const existing = existingApt[0];
 
 	//console.log(releaseCheck);
 
-	if (releaseCheck.length > 0) {
-		const id = releaseCheck[0]?.openDockAptId;
+	if (existing) {
+		const id = existing.openDockAptId;
 		try {
 			const response = await axios.patch(
 				`${process.env.OPENDOCK_URL}/appointment/${id}`,
@@ -196,7 +218,11 @@ const postRelease = async (release: Releases) => {
 					})
 					.onConflictDoUpdate({
 						target: opendockApt.release,
-						set: { appointment: response.data.data, upd_date: sql`NOW()` },
+						set: {
+							openDockAptId: response.data.data.id,
+							appointment: response.data.data,
+							upd_date: sql`NOW()`,
+						},
 					})
 					.returning();
 
@@ -250,8 +276,12 @@ const postRelease = async (release: Releases) => {
 						appointment: response.data.data,
 					})
 					.onConflictDoUpdate({
-						target: opendockApt.id,
-						set: { appointment: response.data.data, upd_date: sql`NOW()` },
+						target: opendockApt.release,
+						set: {
+							openDockAptId: response.data.data.id,
+							appointment: response.data.data,
+							upd_date: sql`NOW()`,
+						},
 					})
 					.returning();
 
@@ -270,7 +300,7 @@ const postRelease = async (release: Releases) => {
 		}
 	}
 
-	await delay(500); // rate limit protection
+	await delay(750); // rate limit protection
 };
 
 export const monitorReleaseChanges = async () => {
@@ -298,184 +328,66 @@ export const monitorReleaseChanges = async () => {
 	}
 
 	if (openDockMonitor[0]?.active) {
-		createCronJob("opendock_sync", "*/15 * * * * *", async () => {
-			try {
-				const result = await prodQuery(
-					sqlQuery.query.replace("[dateCheck]", `'${lastCheck}'`),
-					"Get release info",
-				);
+		// const BUFFER_MS =
+		// 	Math.floor(parseInt(openDockMonitor[0]?.value, 10) || 30) * 1.5 * 1000; // this should be >= to the interval we set in the cron TODO: should pull the buffer from the setting and give it an extra 10% then round to nearest int.
 
-				if (result.data.length) {
-					for (const release of result.data) {
-						await postRelease(release);
-
-						lastCheck = formatInTimeZone(
-							new Date(release.Upd_Date).toISOString(),
-							"UTC",
-							"yyyy-MM-dd HH:mm:ss",
-						);
-
-						await delay(500);
-					}
+		createCronJob(
+			"opendock_sync",
+			`*/${parseInt(openDockMonitor[0]?.value, 10) || 30} * * * * *`,
+			async () => {
+				if (opendockSyncRunning) {
+					log.warn(
+						{},
+						"Skipping opendock_sync because previous run is still active",
+					);
+					return;
 				}
-			} catch (e) {
-				console.error(
-					{ error: e },
-					"Error occurred while running the monitor job",
-				);
-				log.error({ error: e }, "Error occurred while running the monitor job");
-			}
-		});
+
+				opendockSyncRunning = true;
+				try {
+					// set this to the latest time.
+
+					const result = await prodQuery(
+						sqlQuery.query.replace("[dateCheck]", `'${lastCheck}'`),
+						"Get release info",
+					);
+
+					log.debug(
+						{ lastCheck },
+						`${result.data.length} Changes to a release have been made`,
+					);
+
+					if (result.data.length) {
+						for (const release of result.data) {
+							await postRelease(release);
+
+							// add a 2 seconds to account for a massive influx of orders and when we dont finish in 1 go it wont try to grab the same amount again
+							const nDate = new Date(release.Upd_Date);
+							nDate.setSeconds(nDate.getSeconds() + 2);
+
+							lastCheck = formatInTimeZone(
+								nDate.toISOString(),
+								"UTC",
+								"yyyy-MM-dd HH:mm:ss",
+							);
+							log.debug({ lastCheck }, "Changes to a release have been made");
+							await delay(500);
+						}
+					}
+				} catch (e) {
+					console.error(
+						{ error: e },
+						"Error occurred while running the monitor job",
+					);
+					log.error(
+						{ error: e },
+						"Error occurred while running the monitor job",
+					);
+				} finally {
+					opendockSyncRunning = false;
+				}
+			},
+			"monitorReleaseChanges",
+		);
 	}
-
-	// run the main game loop
-	// while (openDockSetting) {
-	// 	try {
-	// 		const result = await prodQuery(
-	// 			sqlQuery.query.replace("[dateCheck]", `'${lastCheck}'`),
-	// 			"Get release info",
-	// 		);
-
-	// 		if (result.data.length) {
-	// 			for (const release of result.data) {
-	// 				// potentially move this to a buffer table to easy up on memory
-	// 				await postRelease(release);
-
-	// 				// Move checkpoint AFTER successful post
-	// 				lastCheck = formatInTimeZone(
-	// 					new Date(release.Upd_Date).toISOString(),
-	// 					"UTC",
-	// 					"yyyy-MM-dd HH:mm:ss",
-	// 				);
-
-	// 				await delay(500);
-	// 			}
-	// 		}
-	// 	} catch (e) {
-	// 		console.error("Monitor error:", e);
-	// 	}
-
-	// 	await delay(15 * 1000); // making this 15 seconds as we would really only see issues if we have a mass burst.
-	// }
 };
-
-// export const monitorReleaseChanges = async () => {
-// 	console.log("Starting release monitor", lastCheck);
-// 	setInterval(async () => {
-// 		try {
-// 			const result = await prodQuery(
-// 				releaseQuery.replace("[dateCheck]", `'${lastCheck}'`),
-// 				"get last release change",
-// 			);
-
-// 			//console.log(releaseQuery.replace("[dateCheck]", `'${lastCheck}'`));
-// 			if (result.data.length > 0) {
-// 				console.log(
-// 					formatInTimeZone(
-// 						result.data[result.data.length - 1].Upd_Date,
-// 						"UTC",
-// 						"yyyy-MM-dd HH:mm:ss",
-// 					),
-// 					lastCheck,
-// 				);
-// 				lastCheck = formatInTimeZone(
-// 					result.data[result.data.length - 1].Upd_Date,
-// 					"UTC",
-// 					"yyyy-MM-dd HH:mm:ss",
-// 				);
-// 				const releases = result.data;
-// 				for (let i = 0; i < releases.length; i++) {
-// 					const newDockApt = {
-// 						status: "Scheduled",
-// 						userId: "ee956455-e193-47fc-b53b-dff30fabdf4b", // this should be the carrierid
-// 						loadTypeId: "0aa7988e-b17b-4f10-acdd-3d029b44a773", // well get this and make it a default one
-// 						dockId: "00ba4386-ce5a-4dd1-9356-6e6d10a24609", // this the warehouse we want it in to start out
-// 						refNumbers: [releases[i].ReleaseNumber],
-// 						refNumber: releases[i].ReleaseNumber,
-// 						start: releases[i].DeliveryDate,
-// 						end: addHours(releases[i].DeliveryDate, 1),
-// 						notes: "",
-// 						ccEmails: [""],
-// 						muteNotifications: true,
-// 						metadata: {
-// 							externalValidationFailed: false,
-// 							externalValidationErrorMessage: null,
-// 						},
-// 						units: null,
-// 						customFields: [
-// 							{
-// 								name: "strArticle",
-// 								type: "str",
-// 								label: "Article",
-// 								value: `${releases[i].LineItemHumanReadableId} - ${releases[i].ArticleAlias}`,
-// 								description: "What bottle are we sending ",
-// 								placeholder: "",
-// 								dropDownValues: [],
-// 								minLengthOrValue: 1,
-// 								hiddenFromCarrier: false,
-// 								requiredForCarrier: false,
-// 								requiredForWarehouse: false,
-// 							},
-// 							{
-// 								name: "intPallet Count",
-// 								type: "int",
-// 								label: "Pallet Count",
-// 								value: parseInt(releases[i].LoadingUnits, 10),
-// 								description: "How many pallets",
-// 								placeholder: "22",
-// 								dropDownValues: [],
-// 								minLengthOrValue: 1,
-// 								hiddenFromCarrier: false,
-// 								requiredForCarrier: false,
-// 								requiredForWarehouse: false,
-// 							},
-// 							{
-// 								name: "strTotal Weight",
-// 								type: "str",
-// 								label: "Total Weight",
-// 								value: `${(((releases[i].Quantity * releases[i].LineItemArticleWeight) / 1000) * 2.20462).toFixed(2)}`,
-// 								description: "What is the total weight of the load",
-// 								placeholder: "",
-// 								dropDownValues: [],
-// 								minLengthOrValue: 1,
-// 								hiddenFromCarrier: false,
-// 								requiredForCarrier: false,
-// 								requiredForWarehouse: false,
-// 							},
-// 							{
-// 								name: "strCustomer ReleaseNumber",
-// 								type: "str",
-// 								label: "Customer Release Number",
-// 								value: `${releases[i].CustomerReleaseNumber}`,
-// 								description: "What is the customer release number",
-// 								placeholder: "",
-// 								dropDownValues: [],
-// 								minLengthOrValue: 1,
-// 								hiddenFromCarrier: false,
-// 								requiredForCarrier: false,
-// 								requiredForWarehouse: false,
-// 							},
-// 						],
-// 					};
-
-// 					//console.log(newDockApt);
-
-// 					const newDockResult = await axios.post(
-// 						"https://neutron.staging.opendock.com/appointment",
-// 						newDockApt,
-// 						{
-// 							headers: {
-// 								"content-type": "application/json; charset=utf-8",
-// 								},
-// 						},
-// 					);
-
-// 					console.log(newDockResult.statusText);
-// 					await delay(500);
-// 				}
-// 			}
-// 		} catch (e) {
-// 			console.log(e);
-// 		}
-// 	}, 5 * 1000);
-// };

backend/opendock/opendock.utils.ts

@@ -28,7 +28,7 @@ export const getToken = async () => {
 		}
 
 		odToken = { odToken: data.access_token, tokenDate: new Date() };
-		log.info({}, "Token added");
+		log.info({ odToken }, "Token added");
 	} catch (e) {
 		log.error({ error: e }, "Error getting/refreshing token");
 	}

backend/opendock/opendockSocketMonitor.utils.ts

@@ -36,12 +36,12 @@ export const opendockSocketMonitor = async () => {
 	// 	console.log(data);
 	// });
 
-	socket.on("create-Appointment", (data) => {
-		console.log("appt create:", data);
+	socket.on("create-Appointment", () => {
+		//console.log("appt create:", data);
 	});
 
-	socket.on("update-Appointment", (data) => {
-		console.log("appt update:", data);
+	socket.on("update-Appointment", () => {
+		//console.log("appt update:", data);
 	});
 
 	socket.on("error", (data) => {

backend/prodSql/queries/alplapurchase.sql

@@ -0,0 +1,63 @@
+use AlplaPROD_test1
+declare @intervalCheck as int = '[interval]'
+
+/*
+Monitors alpla purchase for thing new. this will not update unless the order status is updated.
+this means if a user just reopens the order it will update but everything changed in the position will not be updated until the user reorders or cancels the po
+*/
+
+select
+IdBestellung as apo
+,po.revision as revision
+,po.Bestaetigt as confirmed
+,po.status
+,case po.Status
+	when 1 then 'Created'
+	when 2 then 'Ordered'
+	when 22 then 'Reopened'
+	when 11 then 'Reopened'
+	when 4 then 'Planned'
+	when 5 then 'Partly Delivered'
+	when 6 then 'Delivered'
+	when 7 then 'Canceled'
+	when 8 then 'Closed'
+	else 'Unknown' end as statusText
+,po.IdJournal as journalNum   -- use this to validate if we used it already.
+,po.Add_User as add_user
+,po.Add_Date as add_date
+,po.Upd_User as upd_user
+,po.Upd_Date as upd_Date
+,po.Bemerkung as remark
+,po.IdJournal as journal  -- use this to validate if we used it already.
+,isnull((
+select 
+	o.IdArtikelVarianten as av
+	,a.Bezeichnung as alias
+	,Lieferdatum as deliveryDate
+	,cast(BestellMenge as decimal(18,2)) as qty
+	,cast(BestellMengeVPK as decimal(18,0)) as pkg
+	,cast(PreisProEinheit  as decimal(18,0)) as price
+	,PositionsStatus
+	,case PositionsStatus
+		when 1 then 'Created'
+		when 2 then 'Ordered'
+		when 22 then 'Reopened'
+		when 4 then 'Planned'
+		when 5 then 'Partly Delivered'
+		when 6 then 'Delivered'
+		when 7 then 'Canceled'
+		when 8 then 'Closed'
+		else 'Unknown' end as statusText
+	,o.upd_user
+	,o.upd_date
+from T_Bestellpositionen (nolock) as o
+
+left join
+	T_Artikelvarianten as a on 
+	a.IdArtikelvarianten = o.IdArtikelVarianten
+where o.IdBestellung = po.IdBestellung
+for json path
+), '[]') as position
+--,* 
+from T_Bestellungen (nolock) as po
+where po.Upd_Date > dateadd(MINUTE, -@intervalCheck, getdate()) 

backend/purchase/purchase.controller.ts

@@ -0,0 +1,97 @@
+/**
+ * This will monitor alpla purchase
+ */
+
+import { eq } from "drizzle-orm";
+import { db } from "../db/db.controller.js";
+import {
+	alplaPurchaseHistory,
+	type NewAlplaPurchaseHistory,
+} from "../db/schema/alplapurchase.schema.js";
+import { settings } from "../db/schema/settings.schema.js";
+import { createLogger } from "../logger/logger.controller.js";
+import { prodQuery } from "../prodSql/prodSqlQuery.controller.js";
+import {
+	type SqlQuery,
+	sqlQuerySelector,
+} from "../prodSql/prodSqlQuerySelector.utils.js";
+import { createCronJob } from "../utils/croner.utils.js";
+import { delay } from "../utils/delay.utils.js";
+import { returnFunc } from "../utils/returnHelper.utils.js";
+import { tryCatch } from "../utils/trycatch.utils.js";
+
+const log = createLogger({ module: "purchase", subModule: "purchaseMonitor" });
+
+export const monitorAlplaPurchase = async () => {
+	const purchaseMonitor = await db
+		.select()
+		.from(settings)
+		.where(eq(settings.name, "purchaseMonitor"));
+
+	const sqlQuery = sqlQuerySelector(`alplapurchase`) as SqlQuery;
+
+	if (!sqlQuery.success) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "purchase",
+			subModule: "query",
+			message: `Error getting alpla purchase info`,
+			data: [sqlQuery.message],
+			notify: false,
+		});
+	}
+
+	if (purchaseMonitor[0]?.active) {
+		createCronJob("purchaseMonitor", "0 */5 * * * *", async () => {
+			try {
+				const result = await prodQuery(
+					sqlQuery.query.replace(
+						"[interval]",
+						`${purchaseMonitor[0]?.value || "5"}`,
+					),
+					"Get release info",
+				);
+
+				log.debug(
+					{},
+					`There are ${result.data.length} pending to be updated from the last ${purchaseMonitor[0]?.value}`,
+				);
+				if (result.data.length) {
+					const convertedData = result.data.map((i) => ({
+						...i,
+						position: JSON.parse(i.position),
+					})) as NewAlplaPurchaseHistory;
+
+					const { data, error } = await tryCatch(
+						db.insert(alplaPurchaseHistory).values(convertedData).returning(),
+					);
+
+					if (data) {
+						log.debug(
+							{ data },
+							"New data was just added to alpla purchase history",
+						);
+					}
+
+					if (error) {
+						log.error(
+							{ error },
+							"There was an error adding alpla purchase history",
+						);
+					}
+
+					await delay(500);
+				}
+			} catch (e) {
+				console.error(
+					{ error: e },
+					"Error occurred while running the monitor job",
+				);
+				log.error({ error: e }, "Error occurred while running the monitor job");
+
+				return;
+			}
+		});
+	}
+};

backend/server.ts

@@ -10,6 +10,7 @@ import { createNotifications } from "./notification/notifications.master.js";
 import { monitorReleaseChanges } from "./opendock/openDockRreleaseMonitor.utils.js";
 import { opendockSocketMonitor } from "./opendock/opendockSocketMonitor.utils.js";
 import { connectProdSql } from "./prodSql/prodSqlConnection.controller.js";
+import { monitorAlplaPurchase } from "./purchase/purchase.controller.js";
 import { setupSocketIORoutes } from "./socket.io/serverSetup.js";
 import { baseSettingValidationCheck } from "./system/settingsBase.controller.js";
 import { createCronJob } from "./utils/croner.utils.js";
@@ -36,7 +37,7 @@ const start = async () => {
 	// also we always want to have long lived processes inside a setting check.
 	setTimeout(() => {
 		if (systemSettings.filter((n) => n.name === "opendock_sync")[0]?.active) {
-			log.info({}, "Opendock is not active");
+			log.info({}, "Opendock is active");
 			monitorReleaseChanges(); // this is od monitoring the db for all new releases
 			opendockSocketMonitor();
 			createCronJob("opendockAptCleanup", "0 30 5 * * *", () =>
@@ -44,6 +45,10 @@ const start = async () => {
 			);
 		}
 
+		if (systemSettings.filter((n) => n.name === "purchaseMonitor")[0]?.active) {
+			monitorAlplaPurchase();
+		}
+
 		// these jobs below are system jobs and should run no matter what.
 		createCronJob("JobAuditLogCleanUp", "0 0 5 * * *", () =>
 			dbCleanup("jobs", 30),

backend/system/settingsBase.controller.ts

@@ -8,7 +8,7 @@ const newSettings: NewSetting[] = [
 	// feature settings
 	{
 		name: "opendock_sync",
-		value: "0",
+		value: "15",
 		active: false,
 		description: "Dock Scheduling system",
 		moduleName: "opendock",
@@ -66,6 +66,16 @@ const newSettings: NewSetting[] = [
 		roles: ["admin"],
 		seedVersion: 1,
 	},
+	{
+		name: "purchaseMonitor",
+		value: "5",
+		active: true,
+		description: "Monitors alpla purchase fo all changes",
+		moduleName: "purchase",
+		settingType: "feature",
+		roles: ["admin"],
+		seedVersion: 1,
+	},
 
 	// standard settings
 	{

backend/system/settingsFeatures.controller.ts

@@ -10,6 +10,7 @@ import {
 	killOpendockSocket,
 	opendockSocketMonitor,
 } from "../opendock/opendockSocketMonitor.utils.js";
+import { monitorAlplaPurchase } from "../purchase/purchase.controller.js";
 import {
 	createCronJob,
 	resumeCronJob,
@@ -31,8 +32,24 @@ export const featureControl = async (data: Setting) => {
 		createCronJob("opendockAptCleanup", "0 30 5 * * *", () =>
 			dbCleanup("opendockApt", 90),
 		);
-	} else {
+	}
+
+	if (data.name === "opendock_sync" && !data.active) {
 		killOpendockSocket();
 		stopCronJob("opendockAptCleanup");
 	}
+
+	// purchase stuff
+	if (data.name === "purchaseMonitor" && data.active) {
+		monitorAlplaPurchase();
+	}
+
+	if (data.name === "purchaseMonitor" && !data.active) {
+		stopCronJob("purchaseMonitor");
+	}
+
+	// this means the data time has changed
+	if (data.name === "purchaseMonitor" && data.value) {
+		monitorAlplaPurchase();
+	}
 };

backend/utils/croner.utils.ts

@@ -18,7 +18,9 @@ export interface JobInfo {
 
 // Store running cronjobs
 export const runningCrons: Record<string, Cron> = {};
+const activeRuns = new Set<string>();
 const log = createLogger({ module: "system", subModule: "croner" });
+const cronStats: Record<string, { created: number; replaced: number }> = {};
 
 // how to se the times
 //  * ┌──────────────── (optional) second (0 - 59)
@@ -38,17 +40,36 @@ const log = createLogger({ module: "system", subModule: "croner" });
  * @param name Name of the job we want to run
  * @param schedule Cron expression (example: `*\/5 * * * * *`)
  * @param task Async function that will run
+ * @param source we can add where it came from to assist in getting this tracked down, more for debugging
  */
 export const createCronJob = async (
 	name: string,
 	schedule: string, // cron string with 8 8 IE: */5 * * * * * every 5th second
 	task: () => Promise<void>, // what function are we passing over
+	source = "unknown",
 ) => {
 	// get the timezone based on the os timezone set
 	const timeZone = Intl.DateTimeFormat().resolvedOptions().timeZone;
 
+	// initial go so just store it this is more for debugging to see if something crazy keeps happening
+	if (!cronStats[name]) {
+		cronStats[name] = { created: 0, replaced: 0 };
+	}
+
 	// Destroy existing job if it exist
 	if (runningCrons[name]) {
+		cronStats[name].replaced += 1;
+		log.warn(
+			{
+				job: name,
+				source,
+				oldSchedule: runningCrons[name].getPattern?.(),
+				newSchedule: schedule,
+				replaceCount: cronStats[name].replaced,
+			},
+			`Cron job "${name}" already existed and is being replaced`,
+		);
+
 		runningCrons[name].stop();
 	}
 
@@ -61,6 +82,13 @@ export const createCronJob = async (
 			name: name,
 		},
 		async () => {
+			if (activeRuns.has(name)) {
+				log.warn({ jobName: name }, "Skipping overlapping cron execution");
+				return;
+			}
+
+			activeRuns.add(name);
+
 			const startedAt = new Date();
 			const start = Date.now();
 
@@ -91,14 +119,19 @@ export const createCronJob = async (
 					.where(eq(jobAuditLog.id, executionId));
 			} catch (e: any) {
 				if (executionId) {
-					await db.update(jobAuditLog).set({
-						finishedAt: new Date(),
-						durationMs: Date.now() - start,
-						status: "error",
-						errorMessage: e.message,
-						errorStack: e.stack,
-					});
+					await db
+						.update(jobAuditLog)
+						.set({
+							finishedAt: new Date(),
+							durationMs: Date.now() - start,
+							status: "error",
+							errorMessage: e.message,
+							errorStack: e.stack,
+						})
+						.where(eq(jobAuditLog.id, executionId));
 				}
+			} finally {
+				activeRuns.delete(name);
 			}
 		},
 	);

backend/utils/returnHelper.utils.ts

@@ -11,7 +11,8 @@ interface Data<T = unknown[]> {
 		| "utils"
 		| "opendock"
 		| "notification"
-		| "email";
+		| "email"
+		| "purchase";
 	subModule:
 		| "db"
 		| "labeling"

frontend/src/routes/admin/notifications.tsx

@@ -7,12 +7,7 @@ import { Suspense, useState } from "react";
 import { toast } from "sonner";
 import type { Notifications } from "../../../types/notifications";
 import { Button } from "../../components/ui/button";
-import {
-	Card,
-	CardContent,
-	CardHeader,
-	CardTitle,
-} from "../../components/ui/card";
+import { Card, CardContent } from "../../components/ui/card";
 import { Label } from "../../components/ui/label";
 import { Switch } from "../../components/ui/switch";
 import {
@@ -297,16 +292,13 @@ function RouteComponent() {
 	return (
 		<div className="space-y-6">
 			<div className="space-y-2">
-				<h1 className="text-2xl font-semibold">Settings</h1>
+				<h1 className="text-2xl font-semibold">Notifications</h1>
 				<p className="text-sm text-muted-foreground">
-					Manage you settings and related data.
+					Manage all notification settings and user subs.
 				</p>
 			</div>
 
 			<Card>
-				<CardHeader>
-					<CardTitle>System Settings</CardTitle>
-				</CardHeader>
 				<CardContent>
 					<Tabs defaultValue="notifications" className="w-full">
 						<TabsList>

migrations/0020_stale_ma_gnuci.sql

@@ -0,0 +1,15 @@
+CREATE TABLE "alpla_purchase_history" (
+	"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
+	"apo" integer,
+	"revision" integer,
+	"confirmed" integer,
+	"status" integer,
+	"status_text" integer,
+	"add_date" timestamp DEFAULT now(),
+	"upd_date" timestamp DEFAULT now(),
+	"add_user" text,
+	"upd_user" text,
+	"remark" text,
+	"position" jsonb DEFAULT '[]'::jsonb,
+	"created_at" timestamp DEFAULT now()
+);

migrations/0021_slimy_master_mold.sql

@@ -0,0 +1,2 @@
+ALTER TABLE "alpla_purchase_history" ADD COLUMN "journal_num" integer;--> statement-breakpoint
+ALTER TABLE "alpla_purchase_history" ADD COLUMN "approved_status" text;

migrations/0022_large_sumo.sql

@@ -0,0 +1 @@
+ALTER TABLE "alpla_purchase_history" ALTER COLUMN "approved_status" SET DEFAULT 'pending';

migrations/0023_normal_hellion.sql

@@ -0,0 +1 @@
+ALTER TABLE "alpla_purchase_history" ALTER COLUMN "status_text" SET DATA TYPE text;

migrations/0024_absent_barracuda.sql

@@ -0,0 +1,6 @@
+ALTER TABLE "opendock_apt" ALTER COLUMN "release" SET NOT NULL;--> statement-breakpoint
+ALTER TABLE "opendock_apt" ALTER COLUMN "appointment" SET NOT NULL;--> statement-breakpoint
+ALTER TABLE "opendock_apt" ALTER COLUMN "upd_date" SET NOT NULL;--> statement-breakpoint
+ALTER TABLE "opendock_apt" ALTER COLUMN "created_at" SET NOT NULL;--> statement-breakpoint
+CREATE INDEX "opendock_apt_release_idx" ON "opendock_apt" USING btree ("release");--> statement-breakpoint
+CREATE INDEX "opendock_apt_opendock_id_idx" ON "opendock_apt" USING btree ("open_dock_apt_id");

migrations/meta/_journal.json

@@ -141,6 +141,41 @@
       "when": 1775159956510,
       "tag": "0019_large_thunderbird",
       "breakpoints": true
+    },
+    {
+      "idx": 20,
+      "version": "7",
+      "when": 1775566910220,
+      "tag": "0020_stale_ma_gnuci",
+      "breakpoints": true
+    },
+    {
+      "idx": 21,
+      "version": "7",
+      "when": 1775647109925,
+      "tag": "0021_slimy_master_mold",
+      "breakpoints": true
+    },
+    {
+      "idx": 22,
+      "version": "7",
+      "when": 1775649219780,
+      "tag": "0022_large_sumo",
+      "breakpoints": true
+    },
+    {
+      "idx": 23,
+      "version": "7",
+      "when": 1775650901523,
+      "tag": "0023_normal_hellion",
+      "breakpoints": true
+    },
+    {
+      "idx": 24,
+      "version": "7",
+      "when": 1775661516749,
+      "tag": "0024_absent_barracuda",
+      "breakpoints": true
     }
   ]
 }

package-lock.json

@@ -1,12 +1,12 @@
 {
 	"name": "lst_v3",
-	"version": "0.1.0-alpha.12",
+	"version": "0.0.1-alpha.1",
 	"lockfileVersion": 3,
 	"requires": true,
 	"packages": {
 		"": {
 			"name": "lst_v3",
-			"version": "0.1.0-alpha.12",
+			"version": "0.0.1-alpha.1",
 			"license": "ISC",
 			"dependencies": {
 				"@dotenvx/dotenvx": "^1.57.0",

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "lst_v3",
-	"version": "0.0.1-alpha.0",
+	"version": "0.0.1-alpha.1",
 	"description": "The tool that supports us in our everyday alplaprod",
 	"main": "index.js",
 	"scripts": {

scripts/agentController.ps1

@@ -37,12 +37,15 @@ $Servers = @(
         token  = "test2"
         loc    = "E$\LST_V3"
     }
-    #@{ server = "usmcd1vms036"; token = "test1"; loc = "E$\LST\lst_backend"; }
-    #@{ server = "usiow1vms036"; token = "test1"; loc = "E$\LST\lst_backend"; }
+    ,
+    [PSCustomObject]@{
+        server = "usweb1vms006"
+        token  = "usweb1"
+        loc    = "D$\LST_V3"
+    }
     #@{ server = "usbet1vms006"; token = "usbet1";loc = "C$\Users\adm_matthes01\Desktop\lst_backend"; }
     #@{ server = "usbow1vms006"; token = "usbow1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ; }
     #@{ server = "usbow2vms006"; token = "usbow2"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ; }
-    #@{ server = "usday1vms006"; token = "usday1"; loc = "E$\LST\lst_backend" ; }
     #@{ server = "usflo1vms006"; token = "usflo1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ; }
     #@{ server = "ushou1vms006"; token = "ushou1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ;}
     #@{ server = "usiow1vms006"; token = "usiow1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ; }
@@ -53,7 +56,6 @@ $Servers = @(
     #@{ server = "usshe1vms006"; token = "usshe1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ;}
     #@{ server = "usslc1vms006"; token = "usslc1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ;}
     #@{ server = "usstp1vms006"; token = "usstp1"; loc = "E$\LST\lst_backend" ; }
-    #@{ server = "usweb1vms006"; token = "usweb1"; loc = "C$\Users\adm_matthes01\Desktop\lst_backend" ;}
     #@{ server = "usmar1vms006"; token = "test1"; loc = "E$\LST\lst_backend"; }
     
 )   
@@ -339,7 +341,7 @@ function Update-Server {
         # do the install/update
             Push-Location $LocalPath
             Write-Host "Running install/update in: $LocalPath"
-            npm install
+            npm install --omit=dev
             Start-Sleep -Seconds 3
             Write-Host "Install/update completed."   
         # do the migrations