chore(release): 0.0.1-alpha.3

refactor(send email): changes the error message to show the true message in the error
refactor(reprints): changes the module and submodule around to be more accurate
2026-04-10 08:22:16 -05:00 · 2026-04-09 21:15:26 -05:00 · 2026-04-09 21:14:36 -05:00 · 2026-04-09 21:13:38 -05:00 · 2026-04-09 21:12:43 -05:00 · 2026-04-08 16:13:38 -05:00
72 changed files with 12467 additions and 403 deletions
--- a/.gitea/workflows/release.yml
+++ b/.gitea/workflows/release.yml
@@ -9,6 +9,18 @@ jobs:
  release:
    runs-on: ubuntu-latest

+    env:
+      # Internal/origin Gitea URL. Do NOT use the Cloudflare fronted URL here.
+      # Examples:
+      #   http://gitea.internal.lan:3000
+      #   https://gitea-origin.yourdomain.local
+      GITEA_INTERNAL_URL: "https://git.tuffraid.net"
+
+      # Internal/origin registry host. Usually same host as above, but without protocol.
+      # Example:
+      #   gitea.internal:3000
+      REGISTRY_HOST: "git.tuffraid.net"
+
    steps:
      - name: Check out repository
        uses: actions/checkout@v4
@@ -16,12 +28,11 @@ jobs:
      - name: Prepare release metadata
        shell: bash
        run: |
+          set -euo pipefail
+
          TAG="${GITHUB_REF_NAME:-${GITHUB_REF##refs/tags/}}"
          VERSION="${TAG#v}"
-          IMAGE_REGISTRY="${{ gitea.server_url }}"
-          IMAGE_REGISTRY="${IMAGE_REGISTRY#http://}"
-          IMAGE_REGISTRY="${IMAGE_REGISTRY#https://}"
-          IMAGE_NAME="${IMAGE_REGISTRY}/${{ gitea.repository }}"
+          IMAGE_NAME="${REGISTRY_HOST}/${{ gitea.repository }}"

          echo "TAG=$TAG" >> "$GITHUB_ENV"
          echo "VERSION=$VERSION" >> "$GITHUB_ENV"
@@ -33,17 +44,23 @@ jobs:
            echo "PRERELEASE=false" >> "$GITHUB_ENV"
          fi

+          echo "Resolved TAG=$TAG"
+          echo "Resolved VERSION=$VERSION"
+          echo "Resolved IMAGE_NAME=$IMAGE_NAME"
+
      - name: Log in to Gitea container registry
        shell: bash
        env:
          REGISTRY_USERNAME: ${{ secrets.REGISTRY_USERNAME }}
          REGISTRY_TOKEN: ${{ secrets.RELEASE_TOKEN }}
        run: |
-          echo "$REGISTRY_TOKEN" | docker login "${IMAGE_NAME%%/*}" -u "$REGISTRY_USERNAME" --password-stdin
+          set -euo pipefail
+          echo "$REGISTRY_TOKEN" | docker login "$REGISTRY_HOST" -u "$REGISTRY_USERNAME" --password-stdin

      - name: Build Docker image
        shell: bash
        run: |
+          set -euo pipefail
          docker build \
            -t "$IMAGE_NAME:$TAG" \
            -t "$IMAGE_NAME:latest" \
@@ -52,26 +69,37 @@ jobs:
      - name: Push version tag
        shell: bash
        run: |
+          set -euo pipefail
          docker push "$IMAGE_NAME:$TAG"

      - name: Push latest tag
        if: ${{ !contains(env.TAG, '-') }}
        shell: bash
        run: |
+          set -euo pipefail
          docker push "$IMAGE_NAME:latest"

      - name: Push prerelease channel tag
        if: ${{ contains(env.TAG, '-') }}
        shell: bash
+        env:
+          TAG: ${{ env.TAG }}
        run: |
+          set -euo pipefail
          CHANNEL="${TAG#*-}"
          CHANNEL="${CHANNEL%%.*}"
+
+          echo "Resolved prerelease channel: $CHANNEL"
+
          docker tag "$IMAGE_NAME:$TAG" "$IMAGE_NAME:$CHANNEL"
          docker push "$IMAGE_NAME:$CHANNEL"

      - name: Extract matching CHANGELOG section
        shell: bash
+        env:
+          VERSION: ${{ env.VERSION }}
        run: |
+          set -euo pipefail
          python3 - <<'PY'
          import os
          import re
@@ -86,8 +114,12 @@ jobs:

          text = changelog_path.read_text(encoding="utf-8")

+          # Matches headings like:
+          # ## [0.1.0]
+          # ## 0.1.0
+          # ## [0.1.0-alpha.1]
          pattern = re.compile(
-              rf"^##\s+\[?{re.escape(version)}\]?[^\n]*\n(.*?)(?=^##\s+\[?[0-9]|\Z)",
+              rf"^##\s+\[?{re.escape(version)}\]?[^\n]*\n(.*?)(?=^##\s+\[?[^\n]+|\Z)",
              re.MULTILINE | re.DOTALL,
          )

@@ -101,16 +133,21 @@ jobs:
              body = f"Release {version}"

          Path("release_body.md").write_text(body + "\n", encoding="utf-8")
+          print("----- release_body.md -----")
          print(body)
+          print("---------------------------")
          PY

      - name: Create Gitea release
+        shell: bash
        env:
          RELEASE_TOKEN: ${{ secrets.RELEASE_TOKEN }}
-          GITEA_SERVER_URL: ${{ gitea.server_url }}
          GITEA_REPOSITORY: ${{ gitea.repository }}
-        shell: bash
+          GITEA_INTERNAL_URL: ${{ env.GITEA_INTERNAL_URL }}
+          TAG: ${{ env.TAG }}
+          PRERELEASE: ${{ env.PRERELEASE }}
        run: |
+          set -euo pipefail
          python3 - <<'PY'
          import json
          import os
@@ -120,13 +157,35 @@ jobs:

          tag = os.environ["TAG"]
          prerelease = os.environ["PRERELEASE"].lower() == "true"
-          server_url = os.environ["GITEA_SERVER_URL"].rstrip("/")
+          server_url = os.environ["GITEA_INTERNAL_URL"].rstrip("/")
          repo = os.environ["GITEA_REPOSITORY"]
          token = os.environ["RELEASE_TOKEN"]

          body = Path("release_body.md").read_text(encoding="utf-8").strip()

-          url = f"{server_url}/api/v1/repos/{repo}/releases"
+          # Check if the release already exists for this tag
+          get_url = f"{server_url}/api/v1/repos/{repo}/releases/tags/{tag}"
+          get_req = urllib.request.Request(
+              get_url,
+              method="GET",
+              headers={
+                  "Authorization": f"token {token}",
+                  "Accept": "application/json",
+                  "User-Agent": "lst-release-workflow/1.0",
+              },
+          )
+
+          existing_release = None
+          try:
+              with urllib.request.urlopen(get_req) as resp:
+                  existing_release = json.loads(resp.read().decode("utf-8"))
+          except urllib.error.HTTPError as e:
+              if e.code != 404:
+                  details = e.read().decode("utf-8", errors="replace")
+                  print("Failed checking existing release:")
+                  print(details)
+                  raise
+
          payload = {
              "tag_name": tag,
              "name": tag,
@@ -136,14 +195,26 @@ jobs:
          }

          data = json.dumps(payload).encode("utf-8")
+
+          if existing_release:
+              release_id = existing_release["id"]
+              url = f"{server_url}/api/v1/repos/{repo}/releases/{release_id}"
+              method = "PATCH"
+              print(f"Release already exists for tag {tag}, updating release id {release_id}")
+          else:
+              url = f"{server_url}/api/v1/repos/{repo}/releases"
+              method = "POST"
+              print(f"No release exists for tag {tag}, creating a new one")
+
          req = urllib.request.Request(
              url,
              data=data,
-              method="POST",
+              method=method,
              headers={
                  "Authorization": f"token {token}",
                  "Content-Type": "application/json",
                  "Accept": "application/json",
+                  "User-Agent": "lst-release-workflow/1.0",
              },
          )

@@ -152,6 +223,7 @@ jobs:
                  print(resp.read().decode("utf-8"))
          except urllib.error.HTTPError as e:
              details = e.read().decode("utf-8", errors="replace")
+              print("Release create/update failed:")
              print(details)
              raise
          PY
--- a/.gitignore
+++ b/.gitignore
@@ -4,6 +4,7 @@ builds
 .includes
 .buildNumber
 temp
+brunoApi
 .scriptCreds
 node-v24.14.0-x64.msi
 postgresql-17.9-2-windows-x64.exe
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@@ -54,8 +54,10 @@
 		"alpla",
 		"alplamart",
 		"alplaprod",
+		"alplapurchase",
 		"bookin",
 		"Datamart",
+		"dotenvx",
 		"dyco",
 		"intiallally",
 		"manadatory",
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,98 +1,90 @@
 # All Changes to LST can be found below.

-## [0.1.0-alpha.12](https://git.tuffraid.net/cowch/lst_v3/compare/v0.1.0-alpha.11...v0.1.0-alpha.12) (2026-04-03)
-
-
-### 🐛 Bug fixes
-
-* **typo:** more dam typos ([079478f](https://git.tuffraid.net/cowch/lst_v3/commits/079478f93217dea31c9a1e8ffed85d2381a6977d))
-
-## [0.1.0-alpha.11](https://git.tuffraid.net/cowch/lst_v3/compare/v0.1.0-alpha.10...v0.1.0-alpha.11) (2026-04-03)
+## [0.0.1-alpha.3](https://git.tuffraid.net/cowch/lst_v3/compare/v0.0.1-alpha.2...v0.0.1-alpha.3) (2026-04-10)
+
+
+### 🌟 Enhancements
+
+* **puchase hist:** finished up purhcase historical / gp updates ([a691dc2](https://git.tuffraid.net/cowch/lst_v3/commits/a691dc276e8650c669409241f73d7b2d7a1f9176))
+
+
+### 🛠️ Code Refactor
+
+* **gp connect:** gp connect as was added to long live services ([635635b](https://git.tuffraid.net/cowch/lst_v3/commits/635635b356e1262e1c0b063408fe2209e6a8d4ec))
+* **reprints:** changes the module and submodule around to be more accurate ([97f93a1](https://git.tuffraid.net/cowch/lst_v3/commits/97f93a1830761437118863372108df810ce9977a))
+* **send email:** changes the error message to show the true message in the error ([995b1dd](https://git.tuffraid.net/cowch/lst_v3/commits/995b1dda7cdfebf4367d301ccac38fd339fab6dd))
+
+## [0.0.1-alpha.2](https://git.tuffraid.net/cowch/lst_v3/compare/v0.0.1-alpha.1...v0.0.1-alpha.2) (2026-04-08)
+
+
+### 📈 Project Builds
+
+* **release:** docker and release corrections ([103ae77](https://git.tuffraid.net/cowch/lst_v3/commits/103ae77e9f82fc008a8ae143b6feccc3ce802f8c))
+
+## [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

-* **release:** changes to only have the changelog in the release ([6e85991](https://git.tuffraid.net/cowch/lst_v3/commits/6e8599106298ed13febd069d6fda8b354efb5b7b))
-
-## [0.1.0-alpha.10](https://git.tuffraid.net/cowch/lst_v3/compare/v0.1.0-alpha.9...v0.1.0-alpha.10) (2026-04-03)
-
-
-### 🛠️ 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))

-## [0.1.0-alpha.9](https://git.tuffraid.net/cowch/lst_v3/compare/v0.0.1-alpha.8...v0.1.0-alpha.9) (2026-04-03)

-## 0.1.0-alpha.8
+### 📈 Project Builds

-### Patch Changes
-
- something strange in the bushes
-
-## 0.1.0-alpha.7
-
-### Patch Changes
-
- i suck at this so much and half using ai and learning lmao
-
-## 0.1.0-alpha.6
-
-### Patch Changes
-
- grr
-
-## 0.1.0-alpha.5
-
-### Patch Changes
-
- sop stuff
-
-## 0.1.0-alpha.4
-
-### Patch Changes
-
- more info in the change stuff
-
-## 0.1.0-alpha.3
-
-### Patch Changes
-
- changed the password to token
-
-## 0.1.0-alpha.2
-
-### Patch Changes
-
- Changes to the build process
-
-  # Build
-
-  - Added release flow
-  - when new release is in build the docker image
-  - latest will still be built as well
-
-## 0.1.0-alpha.1
-
-### Minor Changes
-
- more build stuff
-  ### Build
-  - changes to now auto release when we push new v\*
-
-## 1.0.2-alpha.0
-
-### Patch Changes
-
- build stuff
- external url added for docker
-
-## 1.0.1
-
-### Patch Changes
-
- cf18e94: core stuff
+* **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))
--- a/README.md
+++ b/README.md
@@ -7,7 +7,7 @@
 Quick summary of current rewrite/migration goal.

 - **Phase:** Backend rewrite
- **Last updated:** 2024-05-01
+- **Last updated:** 2026-04-06

 ---

@@ -16,9 +16,9 @@ Quick summary of current rewrite/migration goal.
 | Feature | Description | Status |
 |----------|--------------|--------|
 | User Authentication | ~~Login~~, ~~Signup~~, API Key | 🟨 In Progress |
-| User Profile | Edit profile, upload avatar | ⏳ Not Started |
+| User Profile | ~~Edit profile~~, upload avatar | 🟨 In Progress |
 | User Admin | Edit user, create user, remove user, alplaprod user integration | ⏳ Not Started |
-| Notifications | Subscribe, Create, Update, Remove, Manual Trigger | ⏳ Not Started |
+| Notifications | ~~Subscribe~~, ~~Create~~, ~~Update~~, ~~~~Remove~~, Manual Trigger | 🟨 In Progress |
 | Datamart | Create, Update, Run, Deactivate | 🔧 In Progress |
 | Frontend | Analytics and charts | ⏳ Not Started |
 | Docs | Instructions and trouble shooting | ⏳ Not Started |
@@ -44,7 +44,7 @@ _Status legend:_
 How to run the current version of the app.

 ```bash
-git clone https://github.com/youruser/yourrepo.git
-cd yourrepo
+git clone https://git.tuffraid.net/cowch/lst_v3.git
+cd lst_v3
 npm install
 npm run dev
--- a/backend/app.ts
+++ b/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"));
 	});

--- a/backend/configs/gpSql.config.ts
+++ b/backend/configs/gpSql.config.ts
@@ -0,0 +1,23 @@
+import type sql from "mssql";
+
+const username = "gpviewer";
+const password = "gp$$ViewOnly!";
+
+export const gpSqlConfig: sql.config = {
+	server: `USMCD1VMS011`,
+	database: `ALPLA`,
+	user: username,
+	password: password,
+	options: {
+		encrypt: true,
+		trustServerCertificate: true,
+	},
+	requestTimeout: 90000, // how long until we kill the query and fail it
+	pool: {
+		max: 20, // Maximum number of connections in the pool
+		min: 0, // Minimum number of connections in the pool
+		idleTimeoutMillis: 10000, // How long a connection is allowed to be idle before being released
+		reapIntervalMillis: 1000, // how often to check for idle resources to destroy
+		acquireTimeoutMillis: 100000, // How long until a complete timeout happens
+	},
+};
--- a/backend/db/schema/alplapurchase.schema.ts
+++ b/backend/db/schema/alplapurchase.schema.ts
@@ -0,0 +1,39 @@
+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("new"),
+	position: jsonb("position").default([]),
+	createdAt: timestamp("created_at").defaultNow(),
+	updatedAt: timestamp("updated_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
+>;
--- a/backend/db/schema/opendock.schema.ts
+++ b/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);
--- a/backend/gpSql/gpSql.routes.ts
+++ b/backend/gpSql/gpSql.routes.ts
@@ -0,0 +1,17 @@
+import { type Express, Router } from "express";
+import { requireAuth } from "../middleware/auth.middleware.js";
+import restart from "./gpSqlRestart.route.js";
+import start from "./gpSqlStart.route.js";
+import stop from "./gpSqlStop.route.js";
+export const setupGPSqlRoutes = (baseUrl: string, app: Express) => {
+	//setup all the routes
+	// Apply auth to entire router
+	const router = Router();
+	router.use(requireAuth);
+
+	router.use(start);
+	router.use(stop);
+	router.use(restart);
+
+	app.use(`${baseUrl}/api/system/gpSql`, router);
+};
--- a/backend/gpSql/gpSqlConnection.controller.ts
+++ b/backend/gpSql/gpSqlConnection.controller.ts
@@ -0,0 +1,155 @@
+import sql from "mssql";
+import { gpSqlConfig } from "../configs/gpSql.config.js";
+import { createLogger } from "../logger/logger.controller.js";
+import { checkHostnamePort } from "../utils/checkHost.utils.js";
+import { returnFunc } from "../utils/returnHelper.utils.js";
+
+export let pool2: sql.ConnectionPool;
+export let connected: boolean = false;
+export let reconnecting = false;
+
+export const connectGPSql = async () => {
+	const serverUp = await checkHostnamePort(`USMCD1VMS011:1433`);
+	if (!serverUp) {
+		// we will try to reconnect
+		connected = false;
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "system",
+			subModule: "db",
+			message: "GP server is offline or unreachable.",
+		});
+	}
+
+	// if we are trying to click restart from the api for some reason we want to kick back and say no
+	if (connected) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "system",
+			subModule: "db",
+			message: "The Sql server is already connected.",
+		});
+	}
+
+	// try to connect to the sql server
+	try {
+		pool2 = new sql.ConnectionPool(gpSqlConfig);
+		await pool2.connect();
+		connected = true;
+		return returnFunc({
+			success: true,
+			level: "info",
+			module: "system",
+			subModule: "db",
+			message: `${gpSqlConfig.server} is connected to ${gpSqlConfig.database}`,
+			data: [],
+			notify: false,
+		});
+	} catch (error) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "system",
+			subModule: "db",
+			message: "Failed to connect to the prod sql server.",
+			data: [error],
+			notify: false,
+		});
+	}
+};
+
+export const closePool = async () => {
+	if (!connected) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "system",
+			subModule: "db",
+			message: "There is no connection to the prod server currently.",
+		});
+	}
+
+	try {
+		await pool2.close();
+		connected = false;
+		return returnFunc({
+			success: true,
+			level: "info",
+			module: "system",
+			subModule: "db",
+			message: "The sql connection has been closed.",
+		});
+	} catch (error) {
+		connected = false;
+
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "system",
+			subModule: "db",
+			message: "There was an error closing the sql connection",
+			data: [error],
+		});
+	}
+};
+export const reconnectToSql = async () => {
+	const log = createLogger({
+		module: "system",
+		subModule: "db",
+	});
+	if (reconnecting) return;
+
+	//set reconnecting to true while we try to reconnect
+	reconnecting = true;
+
+	// start the delay out as 2 seconds
+	let delayStart = 2000;
+	let attempt = 0;
+	const maxAttempts = 10;
+
+	while (!connected && attempt < maxAttempts) {
+		attempt++;
+		log.info(
+			`Reconnect attempt ${attempt}/${maxAttempts} in ${delayStart / 1000}s ...`,
+		);
+
+		await new Promise((res) => setTimeout(res, delayStart));
+
+		const serverUp = await checkHostnamePort(`${process.env.PROD_SERVER}:1433`);
+
+		if (!serverUp) {
+			delayStart = Math.min(delayStart * 2, 30000); // exponential backoff until up to 30000
+			return;
+		}
+
+		try {
+			pool2 = await sql.connect(gpSqlConfig);
+			reconnecting = false;
+			connected = true;
+			log.info(`${gpSqlConfig.server} is connected to ${gpSqlConfig.database}`);
+		} catch (error) {
+			delayStart = Math.min(delayStart * 2, 30000);
+			return returnFunc({
+				success: false,
+				level: "error",
+				module: "system",
+				subModule: "db",
+				message: "Failed to reconnect to the prod sql server.",
+				data: [error],
+				notify: false,
+			});
+		}
+	}
+
+	if (!connected) {
+		log.error(
+			{ notify: true },
+			"Max reconnect attempts reached on the prodSql server. Stopping retries.",
+		);
+
+		reconnecting = false;
+		// TODO: exit alert someone here
+	}
+};
--- a/backend/gpSql/gpSqlQuery.controller.ts
+++ b/backend/gpSql/gpSqlQuery.controller.ts
@@ -0,0 +1,97 @@
+import { returnFunc } from "../utils/returnHelper.utils.js";
+import {
+	connected,
+	pool2,
+	reconnecting,
+	reconnectToSql,
+} from "./gpSqlConnection.controller.js";
+
+interface SqlError extends Error {
+	code?: string;
+	originalError?: {
+		info?: { message?: string };
+	};
+}
+
+/**
+ * Run a prod query
+ * just pass over the query as a string and the name of the query.
+ * Query should be like below.
+ *  * select * from AlplaPROD_test1.dbo.table
+ * You must use test1 always as it will be changed via query
+ */
+export const gpQuery = async (queryToRun: string, name: string) => {
+	if (!connected) {
+		reconnectToSql();
+
+		if (reconnecting) {
+			return returnFunc({
+				success: false,
+				level: "error",
+				module: "system",
+				subModule: "gpSql",
+				message: `The sql ${process.env.PROD_PLANT_TOKEN} is trying to reconnect already`,
+				data: [],
+				notify: false,
+			});
+		} else {
+			return returnFunc({
+				success: false,
+				level: "error",
+				module: "system",
+				subModule: "gpSql",
+				message: `${process.env.PROD_PLANT_TOKEN} is not connected, and failed to connect.`,
+				data: [],
+				notify: true,
+			});
+		}
+	}
+
+	//change to the correct server
+	const query = queryToRun.replaceAll(
+		"test1",
+		`${process.env.PROD_PLANT_TOKEN}`,
+	);
+
+	try {
+		const result = await pool2.request().query(query);
+		return {
+			success: true,
+			message: `Query results for: ${name}`,
+			data: result.recordset ?? [],
+		};
+	} catch (error: unknown) {
+		const err = error as SqlError;
+		if (err.code === "ETIMEOUT") {
+			return returnFunc({
+				success: false,
+				module: "system",
+				subModule: "gpSql",
+				level: "error",
+				message: `${name} did not run due to a timeout.`,
+				notify: false,
+				data: [],
+			});
+		}
+
+		if (err.code === "EREQUEST") {
+			return returnFunc({
+				success: false,
+				module: "system",
+				subModule: "gpSql",
+				level: "error",
+				message: `${name} encountered an error ${err.originalError?.info?.message || "undefined error"}`,
+				data: [],
+			});
+		}
+
+		return returnFunc({
+			success: false,
+			module: "system",
+			subModule: "gpSql",
+			level: "error",
+			message: `${name} encountered an unknown error.`,
+			data: [],
+		});
+	}
+};
--- a/backend/gpSql/gpSqlQuerySelector.utils.ts
+++ b/backend/gpSql/gpSqlQuerySelector.utils.ts
@@ -0,0 +1,29 @@
+import { readFileSync } from "node:fs";
+
+export type SqlGPQuery = {
+	query: string;
+	success: boolean;
+	message: string;
+};
+
+export const sqlGpQuerySelector = (name: string) => {
+	try {
+		const queryFile = readFileSync(
+			new URL(`../gpSql/queries/${name}.sql`, import.meta.url),
+			"utf8",
+		);
+
+		return {
+			success: true,
+			message: `Query for: ${name}`,
+			query: queryFile,
+		};
+	} catch (e) {
+		console.error(e);
+		return {
+			success: false,
+			message:
+				"Error getting the query file, please make sure you have the correct name.",
+		};
+	}
+};
--- a/backend/gpSql/gpSqlRestart.route.ts
+++ b/backend/gpSql/gpSqlRestart.route.ts
@@ -0,0 +1,23 @@
+import { Router } from "express";
+import { apiReturn } from "../utils/returnHelper.utils.js";
+import { closePool, connectGPSql } from "./gpSqlConnection.controller.js";
+
+const r = Router();
+
+r.post("/restart", async (_, res) => {
+	await closePool();
+
+	await new Promise((r) => setTimeout(r, 2000));
+
+	const connect = await connectGPSql();
+	apiReturn(res, {
+		success: connect.success,
+		level: connect.success ? "info" : "error",
+		module: "routes",
+		subModule: "prodSql",
+		message: "Sql Server has been restarted",
+		data: connect.data,
+		status: connect.success ? 200 : 400,
+	});
+});
+export default r;
--- a/backend/gpSql/gpSqlStart.route.ts
+++ b/backend/gpSql/gpSqlStart.route.ts
@@ -0,0 +1,20 @@
+import { Router } from "express";
+import { apiReturn } from "../utils/returnHelper.utils.js";
+import { connectGPSql } from "./gpSqlConnection.controller.js";
+
+const r = Router();
+
+r.post("/start", async (_, res) => {
+	const connect = await connectGPSql();
+	apiReturn(res, {
+		success: connect.success,
+		level: connect.success ? "info" : "error",
+		module: "routes",
+		subModule: "prodSql",
+		message: connect.message,
+		data: connect.data,
+		status: connect.success ? 200 : 400,
+	});
+});
+
+export default r;
--- a/backend/gpSql/gpSqlStop.route.ts
+++ b/backend/gpSql/gpSqlStop.route.ts
@@ -0,0 +1,20 @@
+import { Router } from "express";
+import { apiReturn } from "../utils/returnHelper.utils.js";
+import { closePool } from "./gpSqlConnection.controller.js";
+
+const r = Router();
+
+r.post("/stop", async (_, res) => {
+	const connect = await closePool();
+	apiReturn(res, {
+		success: connect.success,
+		level: connect.success ? "info" : "error",
+		module: "routes",
+		subModule: "prodSql",
+		message: connect.message,
+		data: connect.data,
+		status: connect.success ? 200 : 400,
+	});
+});
+
+export default r;
--- a/backend/gpSql/queries/reqCheck.sql
+++ b/backend/gpSql/queries/reqCheck.sql
@@ -0,0 +1,39 @@
+USE [ALPLA]
+
+SELECT Distinct r.[POPRequisitionNumber] as req, 
+r.[ApprovalStatus] as approvalStatus,
+r.[Requested By] requestedBy,
+format(t.[Created Date], 'yyyy-MM-dd') as  createdAt,
+format(r.[Requisition Date], 'MM/dd/yyyy') as expectedDate,
+r.[Requisition Amount] as glAccount,
+case when r.[Account Segment 2] is null or r.[Account Segment 2] = '' then '999' else cast(r.[Account Segment 2] as varchar) end as plant
+,t.Status as status
+,t.[Document Status] as docStatus
+,t.[Workflow Status] as reqState
+,CASE 
+    WHEN [Workflow Status] = 'Completed' 
+        THEN 'Pending APO convertion'
+    WHEN [Workflow Status] = 'Pending User Action' 
+         AND r.[ApprovalStatus] = 'Pending Approval' 
+        THEN 'Pending plant approver'
+   WHEN [Workflow Status] = '' 
+         AND r.[ApprovalStatus] = 'Not Submitted' 
+        THEN 'Req not submited'
+    ELSE 'Unknown reason' 
+END AS approvedStatus
+
+FROM [dbo].[PORequisitions] r  (nolock)
+
+
+
+left join 
+[dbo].[PurchaseRequisitions] as t (nolock) on
+t.[Requisition Number] = r.[POPRequisitionNumber]
+
+
+--where ApprovalStatus = 'Pending Approval'
+--and [Account Segment 2] = 80
+
+where r.POPRequisitionNumber in ([reqsToCheck])
+
+Order By r.POPRequisitionNumber
--- a/backend/notification/notification.alplapurchase.ts
+++ b/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;
--- a/backend/notification/notification.reprintLabels.ts
+++ b/backend/notification/notification.reprintLabels.ts
@@ -1,10 +1,115 @@
-const reprint = (data: any, emails: string) => {
-	// TODO: do the actual logic for the notification.
-	console.log(data);
-	console.log(emails);
+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";

-	// TODO send the error to systemAdmin users so they do not always need to be on the notifications.
-	// these errors are defined per notification.
+const reprint = async (data: any, emails: string) => {
+	// TODO: do the actual logic for the notification.
+	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) {
+			// sendEmail({
+			// 	email: "Blake.matths@alpla.com",
+			// 	subject: `${os.hostname()} failed to run ${data[0]?.name}.`,
+			// 	template: "serverCrash",
+			// 	context: {
+			// 		error: sentEmail?.data,
+			// 		plant: `${os.hostname()}`,
+			// 	},
+			// });
+			return returnFunc({
+				success: false,
+				level: "error",
+				module: "notification",
+				subModule: "email",
+				message: `${l[0].name} failed to send the email`,
+				data: [sentEmail?.data],
+				notify: true,
+			});
+		}
+	}
 };

 export default reprint;
--- a/backend/notification/notificationSub.delete.route.ts
+++ b/backend/notification/notificationSub.delete.route.ts
@@ -3,12 +3,12 @@ import { type Response, Router } from "express";
 import z from "zod";
 import { db } from "../db/db.controller.js";
 import { notificationSub } from "../db/schema/notifications.sub.schema.js";
+import { auth } from "../utils/auth.utils.js";
 import { apiReturn } from "../utils/returnHelper.utils.js";
 import { tryCatch } from "../utils/trycatch.utils.js";
 import { modifiedNotification } from "./notification.controller.js";

 const newSubscribe = z.object({
-	emails: z.email().array().describe("An array of emails"),
 	userId: z.string().describe("User id."),
 	notificationId: z.string().describe("Notification id"),
 });
@@ -16,14 +16,29 @@ const newSubscribe = z.object({
 const r = Router();

 r.delete("/", async (req, res: Response) => {
+	const hasPermissions = await auth.api.userHasPermission({
+		body: {
+			//userId: req?.user?.id,
+			role: req.user?.roles as any,
+			permissions: {
+				notifications: ["readAll"], // This must match the structure in your access control
+			},
+		},
+	});
+
 	try {
 		const validated = newSubscribe.parse(req.body);
+
 		const { data, error } = await tryCatch(
 			db
 				.delete(notificationSub)
 				.where(
 					and(
-						eq(notificationSub.userId, validated.userId),
+						eq(
+							notificationSub.userId,
+							hasPermissions ? validated.userId : (req?.user?.id ?? ""),
+						), // allows the admin to delete this
+						//eq(notificationSub.userId, req?.user?.id ?? ""),
 						eq(notificationSub.notificationId, validated.notificationId),
 					),
 				)
@@ -44,6 +59,18 @@ r.delete("/", async (req, res: Response) => {
 			});
 		}

+		if (data.length <= 0) {
+			return apiReturn(res, {
+				success: false,
+				level: "info",
+				module: "notification",
+				subModule: "post",
+				message: `Subscription was not deleted invalid data sent over`,
+				data: data ?? [],
+				status: 200,
+			});
+		}
+
 		return apiReturn(res, {
 			success: true,
 			level: "info",
--- a/backend/notification/notificationSub.get.route.ts
+++ b/backend/notification/notificationSub.get.route.ts
@@ -21,12 +21,16 @@ r.get("/", async (req, res: Response) => {
 		},
 	});

+	if (userId) {
+		hasPermissions.success = false;
+	}
+
 	const { data, error } = await tryCatch(
 		db
 			.select()
 			.from(notificationSub)
 			.where(
-				userId || !hasPermissions.success
+				!hasPermissions.success
 					? eq(notificationSub.userId, `${req?.user?.id ?? ""}`)
 					: undefined,
 			),
--- a/backend/notification/notificationSub.post.route.ts
+++ b/backend/notification/notificationSub.post.route.ts
@@ -25,8 +25,25 @@ r.post("/", async (req, res: Response) => {
 	try {
 		const validated = newSubscribe.parse(req.body);

+		const emails = validated.emails
+			.map((e) => e.trim().toLowerCase())
+			.filter(Boolean);
+
+		const uniqueEmails = [...new Set(emails)];
+
 		const { data, error } = await tryCatch(
-			db.insert(notificationSub).values(validated).returning(),
+			db
+				.insert(notificationSub)
+				.values({
+					userId: req?.user?.id ?? "",
+					notificationId: validated.notificationId,
+					emails: uniqueEmails,
+				})
+				.onConflictDoUpdate({
+					target: [notificationSub.userId, notificationSub.notificationId],
+					set: { emails: uniqueEmails },
+				})
+				.returning(),
 		);

 		await modifiedNotification(validated.notificationId);
--- a/backend/notification/notifications.master.ts
+++ b/backend/notification/notifications.master.ts
@@ -14,7 +14,27 @@ const note: NewNotification[] = [
 			"Monitors the labels that are printed and returns a there data, if one falls withing the time frame.",
 		active: false,
 		interval: "10",
-		options: [{ prodID: 1 }],
+		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 }] },
+		],
 	},
 ];

--- a/backend/opendock/openDockRreleaseMonitor.utils.ts
+++ b/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);
-// };
--- a/backend/opendock/opendock.utils.ts
+++ b/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");
 	}
--- a/backend/opendock/opendockSocketMonitor.utils.ts
+++ b/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) => {
--- a/backend/prodSql/queries/alplapurchase.sql
+++ b/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()) 
--- a/backend/prodSql/queries/reprintLabels.sql
+++ b/backend/prodSql/queries/reprintLabels.sql
@@ -0,0 +1,28 @@
+use [test1_AlplaPROD2.0_Read]
+
+SELECT
+	--JSON_VALUE(content, '$.EntityId') as labelId
+	a.id
+	,ActorName
+	,FORMAT(PrintDate, 'yyyy-MM-dd HH:mm') as printDate
+	,FORMAT(CreatedDateTime, 'yyyy-MM-dd HH:mm') createdDateTime
+    ,l.ArticleHumanReadableId as av
+	,l.ArticleDescription as alias
+	,PrintedCopies
+	,p.name as printerName
+	,RunningNumber
+	--,*
+FROM [support].[AuditLog] (nolock) as a
+
+left join
+	[labelling].[InternalLabel] (nolock)  as l on 
+	l.id = JSON_VALUE(content, '$.EntityId')
+
+left join
+	[masterData].[printer] (nolock) as p on
+	p.id = l.PrinterId
+
+where message like '%reprint%'
+	and CreatedDateTime > DATEADD(minute, -[intervalCheck], SYSDATETIMEOFFSET())
+	and a.id > [ignoreList]
+order by CreatedDateTime desc
--- a/backend/purchase/puchase.gpCheck.ts
+++ b/backend/purchase/puchase.gpCheck.ts
@@ -0,0 +1,117 @@
+import { gpQuery } from "../gpSql/gpSqlQuery.controller.js";
+import {
+	type SqlGPQuery,
+	sqlGpQuerySelector,
+} from "../gpSql/gpSqlQuerySelector.utils.js";
+import { createLogger } from "../logger/logger.controller.js";
+import type { GpStatus } from "../types/purhcaseTypes.js";
+import { returnFunc } from "../utils/returnHelper.utils.js";
+
+const log = createLogger({ module: "purchase", subModule: "gp" });
+
+export const gpReqCheck = async (data: GpStatus[]) => {
+	const gpReqCheck = sqlGpQuerySelector("reqCheck") as SqlGPQuery;
+	const reqs = data.map((r) => r.req.trim());
+
+	if (!gpReqCheck.success) {
+		return returnFunc({
+			success: false,
+			level: "error",
+			module: "purchase",
+			subModule: "query",
+			message: `Error getting alpla purchase info`,
+			data: [gpReqCheck.message],
+			notify: false,
+		});
+	}
+
+	try {
+		// check the initial req table
+		const result = await gpQuery(
+			gpReqCheck.query.replace(
+				"[reqsToCheck]",
+				data.map((r) => `'${r.req}'`).join(", ") ?? "",
+			),
+			"Get req info",
+		);
+
+		log.debug(
+			{},
+			`There are ${result.data.length} reqs that need to be updated with there current status`,
+		);
+
+		const firstFound = result.data.map((r) => ({
+			req: r.req.trim(),
+			approvedStatus: r.approvedStatus,
+		}));
+
+		const firstFoundSet = new Set(result.data.map((r) => r.req.trim()));
+
+		const missing1Reqs = reqs.filter((req) => !firstFoundSet.has(req));
+
+		//check if we have a recall on our req
+		const reqCheck = await gpQuery(
+			`select 
+            [Requisition Number] as req
+            ,case when [Workflow Status] = 'recall' then 'returned' else [Workflow Status] end as approvedStatus
+            --,* 
+            from  [dbo].[PurchaseRequisitions] where [Requisition Number] in (${missing1Reqs.map((r) => `'${r}'`).join(", ")})`,
+			"validate req is not in recall",
+		);
+
+		const secondFound = reqCheck.data.map((r) => ({
+			req: r.req.trim(),
+			approvedStatus: r.approvedStatus,
+		}));
+
+		const secondFoundSet =
+			new Set(reqCheck.data.map((r) => r.req.trim())) ?? [];
+
+		const missing2Reqs = missing1Reqs.filter((req) => !secondFoundSet.has(req));
+
+		// check if we have a po already
+		const apoCheck = await gpQuery(
+			`select
+                SOPNUMBE
+                ,PONUMBER
+                ,reqStatus='converted'
+                ,* 
+	        from alpla.dbo.sop60100 (nolock)  where sopnumbe in (${missing2Reqs.map((r) => `'${r}'`).join(", ")})`,
+			"Get release info",
+		);
+
+		const thirdRound = apoCheck.data.map((r) => ({
+			req: r.req.trim(),
+			approvedStatus: r.approvedStatus,
+		}));
+
+		const missing3Reqs = missing2Reqs.filter((req) => !secondFoundSet.has(req));
+
+		// remaining just got canceled or no longer exist
+		const remaining = missing3Reqs.map((m) => ({
+			req: m,
+			approvedStatus: "canceled",
+		}));
+
+		const allFound = [
+			...firstFound,
+			...secondFound,
+			...thirdRound,
+			...remaining,
+		];
+
+		const statusMap = new Map(
+			allFound.map((r: any) => [r.req, r.approvedStatus]),
+		);
+
+		const updateData = data.map((row) => ({
+			id: row.id,
+			//req: row.req,
+			approvedStatus: statusMap.get(row.req.trim()) ?? null,
+		}));
+
+		return updateData;
+	} catch (error) {
+		log.error({ stack: error });
+	}
+};
--- a/backend/purchase/purchase.controller.ts
+++ b/backend/purchase/purchase.controller.ts
@@ -0,0 +1,230 @@
+/**
+ * This will monitor alpla purchase
+ */
+
+import { eq, sql } 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 type { GpStatus, StatusUpdate } from "../types/purhcaseTypes.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";
+import { gpReqCheck } from "./puchase.gpCheck.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) {
+				log.error({ error: e }, "Error occurred while running the monitor job");
+				log.error({ error: e }, "Error occurred while running the monitor job");
+
+				return;
+			}
+
+			// re-pull re-pull everything that has approvedStatus is pending
+
+			const { data: allReq, error: errorReq } = await tryCatch(
+				db
+					.select()
+					.from(alplaPurchaseHistory)
+					.where(eq(alplaPurchaseHistory.approvedStatus, "new")),
+			);
+
+			// if theres no reqs just end meow
+			if (errorReq) {
+				log.error(
+					{ stack: errorReq },
+					"There was an error getting history data",
+				);
+				return;
+			}
+
+			log.debug({}, `There are ${allReq.length} pending reqs to be updated`);
+
+			if (!allReq.length) {
+				log.debug({}, "There are not reqs to be processed");
+				return;
+			}
+			/**
+			 * approvedStatus
+			 * remark = '' then pending req/manual po
+			 * pending = pending
+			 * approved = approved
+			 *
+			 */
+
+			// the flow for all the fun stuff
+
+			const needsGpLookup: GpStatus[] = [];
+			const updates: StatusUpdate[] = [];
+
+			for (const row of allReq ?? []) {
+				const remark = row.remark?.toLowerCase() ?? "";
+
+				if (remark === "") {
+					updates.push({ id: row.id, approvedStatus: "initial" });
+					continue;
+				}
+
+				if (remark.includes("rct")) {
+					updates.push({ id: row.id, approvedStatus: "received" });
+					continue;
+				}
+
+				if (remark.includes("apo")) {
+					updates.push({ id: row.id, approvedStatus: "approved" });
+					continue;
+				}
+
+				// not handled locally, defer to GP lookup
+				needsGpLookup.push({ id: row.id, req: row.remark?.trim() ?? "" });
+			}
+
+			const gpSmash = (await gpReqCheck(needsGpLookup)) as StatusUpdate[];
+
+			const merge = [...updates, ...gpSmash];
+
+			if (merge.length > 0) {
+				await db.execute(sql`
+					UPDATE ${alplaPurchaseHistory}
+					SET approved_status = CASE
+						${sql.join(
+							merge.map(
+								(row) =>
+									sql`WHEN ${alplaPurchaseHistory.id} = ${row.id} THEN ${row.approvedStatus}`,
+							),
+							sql` `,
+						)}
+						ELSE approved_status
+					END,
+					updated_at = NOW()
+					WHERE ${alplaPurchaseHistory.id} IN (
+						${sql.join(
+							merge.map((row) => sql`${row.id}`),
+							sql`, `,
+						)}
+					)
+				`);
+				log.info(
+					{},
+					"All alpla purchase orders have been processed and updated",
+				);
+			}
+
+			// for reqs, create a string of reqs then run them through the gp req table to see there status. then update in lst ass see fit.
+
+			// then double check if we have all reqs covered, for the reqs missing from above restring them and check the po table
+
+			// these ones will be called to as converted to po
+
+			// for the remaining reqs from above check the actual req table to see the status of it if the workflow is set at Recall this means a change was requested from purchasing team and needs to be re approved
+
+			// for all remaining reqs we change them to replace/canceled
+		});
+	}
+};
+
+// const updates = (allReq ?? [])
+// 	.map((row) => {
+// 		const remark = row.remark?.toLowerCase() ?? "";
+
+// 		let approvedStatus: string | null = null;
+
+// 		// priority order matters here
+// 		if (remark === "") {
+// 			approvedStatus = "initial";
+// 		} else if (remark.includes("rct")) {
+// 			approvedStatus = "received";
+// 		} else if (remark.includes("apo")) {
+// 			approvedStatus = "approved";
+// 		}
+
+// 		// add your next 4 checks here
+// 		// else if (...) approvedStatus = "somethingElse";
+
+// 		if (!approvedStatus) return null;
+
+// 		return {
+// 			id: row.id,
+// 			approvedStatus,
+// 		};
+// 	})
+// 	.filter(
+// 		(
+// 			row,
+// 		): row is {
+// 			id: string;
+// 			approvedStatus: string;
+// 		} => row !== null,
+// 	);
--- a/backend/routeHandler.routes.ts
+++ b/backend/routeHandler.routes.ts
@@ -4,6 +4,7 @@ import { setupAuthRoutes } from "./auth/auth.routes.js";
 // import the routes and route setups
 import { setupApiDocsRoutes } from "./configs/scaler.config.js";
 import { setupDatamartRoutes } from "./datamart/datamart.routes.js";
+import { setupGPSqlRoutes } from "./gpSql/gpSql.routes.js";
 import { setupNotificationRoutes } from "./notification/notification.routes.js";
 import { setupOCPRoutes } from "./ocp/ocp.routes.js";
 import { setupOpendockRoutes } from "./opendock/opendock.routes.js";
@@ -16,6 +17,7 @@ export const setupRoutes = (baseUrl: string, app: Express) => {
 	setupSystemRoutes(baseUrl, app);
 	setupApiDocsRoutes(baseUrl, app);
 	setupProdSqlRoutes(baseUrl, app);
+	setupGPSqlRoutes(baseUrl, app);
 	setupDatamartRoutes(baseUrl, app);
 	setupAuthRoutes(baseUrl, app);
 	setupUtilsRoutes(baseUrl, app);
--- a/backend/server.ts
+++ b/backend/server.ts
@@ -4,12 +4,14 @@ import createApp from "./app.js";
 import { db } from "./db/db.controller.js";
 import { dbCleanup } from "./db/dbCleanup.controller.js";
 import { type Setting, settings } from "./db/schema/settings.schema.js";
+import { connectGPSql } from "./gpSql/gpSqlConnection.controller.js";
 import { createLogger } from "./logger/logger.controller.js";
 import { startNotifications } from "./notification/notification.controller.js";
 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";
@@ -27,6 +29,7 @@ const start = async () => {

 	// triggering long lived processes
 	connectProdSql();
+	connectGPSql();

 	// trigger startup processes these must run before anything else can run
 	await baseSettingValidationCheck();
@@ -36,7 +39,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 +47,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),
--- a/backend/system/settingsBase.controller.ts
+++ b/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
 	{
--- a/backend/system/settingsFeatures.controller.ts
+++ b/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();
+	}
 };
--- a/backend/types/purhcaseTypes.ts
+++ b/backend/types/purhcaseTypes.ts
@@ -0,0 +1,9 @@
+export type GpStatus = {
+	id: string;
+	req: string;
+};
+
+export type StatusUpdate = {
+	id: string;
+	approvedStatus: string;
+};
--- a/backend/utils/croner.utils.ts
+++ b/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);
 			}
 		},
 	);
--- a/backend/utils/mailViews/reprintLabels.hbs
+++ b/backend/utils/mailViews/reprintLabels.hbs
@@ -0,0 +1,47 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    {{!-- <link rel="stylesheet" href="styles/styles.css" /> --}}
+    {{> styles}}
+</head>
+<body>
+        <p>All,</p> 
+        <p>The below labels have been reprinted.</p>        
+        <table > 
+        <thead> 
+            <tr> 
+            <th>AV</th> 
+            <th>Description</th> 
+            <th>Label Number</th> 
+            <th>Date Added</th> 
+            <th>Date Reprinted</th> 
+            <th>Who printed/Updated</th> 
+            <th>What printer it came from</th> 
+ 
+            </tr> 
+        </thead> 
+
+        <tbody>
+            {{#each items}}
+                    <tr>
+                        <td>{{av}}</td>
+                        <td>{{alias}}</td>
+                        <td>{{RunningNumber}}</td>
+                        <td>{{printDate}}</td>
+                        <td>{{createdDateTime}}</td>
+                        <td>{{ActorName}}</td>
+                        <td>{{printerName}}</td>
+
+                    </tr>
+                {{/each}}
+        </tbody>
+        </table>
+
+        <div>
+        <p>Thank you,</p>
+        <p>LST Team</p> 
+        </div>
+</body>
+</html>
--- a/backend/utils/returnHelper.utils.ts
+++ b/backend/utils/returnHelper.utils.ts
@@ -10,7 +10,9 @@ interface Data<T = unknown[]> {
 		| "datamart"
 		| "utils"
 		| "opendock"
-		| "notification";
+		| "notification"
+		| "email"
+		| "purchase";
 	subModule:
 		| "db"
 		| "labeling"
@@ -29,7 +31,9 @@ interface Data<T = unknown[]> {
 		| "post"
 		| "notification"
 		| "delete"
-		| "printing";
+		| "printing"
+		| "gpSql"
+		| "email";
 	level: "info" | "error" | "debug" | "fatal";
 	message: string;
 	room?: string;
@@ -61,13 +65,14 @@ export const returnFunc = (data: Data) => {
 			log.info({ notify: notify, room }, data.message);
 			break;
 		case "error":
-			log.error({ notify: notify, error: data.data, room }, data.message);
+			log.error({ notify: notify, stack: data.data ?? [], room }, data.message);
+
 			break;
 		case "debug":
-			log.debug({ notify: notify, room }, data.message);
+			log.debug({ notify: notify, stack: data.data ?? [], room }, data.message);
 			break;
 		case "fatal":
-			log.fatal({ notify: notify, room }, data.message);
+			log.fatal({ notify: notify, stack: data.data ?? [], room }, data.message);
 	}

 	// api section to return
--- a/backend/utils/sendEmail.utils.ts
+++ b/backend/utils/sendEmail.utils.ts
@@ -88,7 +88,7 @@ export const sendEmail = async (data: EmailData) => {
 			level: "error",
 			module: "utils",
 			subModule: "sendmail",
-			message: `Error sending Email to : ${data.email}`,
+			message: `Error sending Email to : ${data.email}, Error: ${error.message}`,
 			data: [{ error: error }],
 			notify: false,
 		});
--- a/brunoApi/environments/lstv3.bru
+++ b/brunoApi/environments/lstv3.bru
@@ -1,5 +1,5 @@
 vars {
-  url: http://localhost:3000/lst
+  url: http://localhost:3600/lst
  readerIp: 10.44.14.215
 }
 vars:secret [
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -11,6 +11,11 @@ services:
        ports:
            #- "${VITE_PORT:-4200}:4200"
            - "3600:3000"
+        dns:
+            - 10.193.9.250
+            - 10.193.9.251   # your internal DNS server
+        dns_search:
+            - alpla.net      # or your internal search suffix
        environment:
            - NODE_ENV=production
            - LOG_LEVEL=info
--- a/frontend/src/components/Sidebar/AdminBar.tsx
+++ b/frontend/src/components/Sidebar/AdminBar.tsx
@@ -1,5 +1,5 @@
 import { Link } from "@tanstack/react-router";
-import { Logs } from "lucide-react";
+import { Bell, Logs, Settings } from "lucide-react";

 import {
 	SidebarGroup,
@@ -24,10 +24,18 @@ import {
 export default function AdminSidebar({ session }: any) {
 	const { setOpen } = useSidebar();
 	const items = [
+		{
+			title: "Notifications",
+			url: "/admin/notifications",
+			icon: Bell,
+			role: ["systemAdmin", "admin"],
+			module: "admin",
+			active: true,
+		},
 		{
 			title: "Settings",
 			url: "/admin/settings",
-			icon: Logs,
+			icon: Settings,
 			role: ["systemAdmin"],
 			module: "admin",
 			active: true,
--- a/frontend/src/lib/formSutff/Select.Field.tsx
+++ b/frontend/src/lib/formSutff/Select.Field.tsx
@@ -42,7 +42,7 @@ export const SelectField = ({
 					>
 						<SelectValue placeholder={placeholder} />
 					</SelectTrigger>
-					<SelectContent>
+					<SelectContent position={"popper"}>
 						{options.map((option) => (
 							<SelectItem key={option.value} value={option.value}>
 								{option.label}
--- a/frontend/src/lib/queries/getSettings.ts
+++ b/frontend/src/lib/queries/getSettings.ts
@@ -13,7 +13,7 @@ export function getSettings() {

 const fetch = async () => {
 	if (window.location.hostname === "localhost") {
-		await new Promise((res) => setTimeout(res, 5000));
+		await new Promise((res) => setTimeout(res, 1500));
 	}

 	const { data } = await axios.get("/lst/api/settings");
--- a/frontend/src/lib/queries/notificationSubs.ts
+++ b/frontend/src/lib/queries/notificationSubs.ts
@@ -13,7 +13,7 @@ export function notificationSubs(userId?: string) {

 const fetch = async (userId?: string) => {
 	if (window.location.hostname === "localhost") {
-		await new Promise((res) => setTimeout(res, 5000));
+		await new Promise((res) => setTimeout(res, 1500));
 	}

 	const { data } = await axios.get(
--- a/frontend/src/lib/queries/notifications.ts
+++ b/frontend/src/lib/queries/notifications.ts
@@ -13,7 +13,7 @@ export function notifications() {

 const fetch = async () => {
 	if (window.location.hostname === "localhost") {
-		await new Promise((res) => setTimeout(res, 5000));
+		await new Promise((res) => setTimeout(res, 1500));
 	}

 	const { data } = await axios.get("/lst/api/notification");
--- a/frontend/src/routeTree.gen.ts
+++ b/frontend/src/routeTree.gen.ts
@@ -12,6 +12,7 @@ import { Route as rootRouteImport } from './routes/__root'
 import { Route as AboutRouteImport } from './routes/about'
 import { Route as IndexRouteImport } from './routes/index'
 import { Route as AdminSettingsRouteImport } from './routes/admin/settings'
+import { Route as AdminNotificationsRouteImport } from './routes/admin/notifications'
 import { Route as AdminLogsRouteImport } from './routes/admin/logs'
 import { Route as authLoginRouteImport } from './routes/(auth)/login'
 import { Route as authUserSignupRouteImport } from './routes/(auth)/user.signup'
@@ -33,6 +34,11 @@ const AdminSettingsRoute = AdminSettingsRouteImport.update({
  path: '/admin/settings',
  getParentRoute: () => rootRouteImport,
 } as any)
+const AdminNotificationsRoute = AdminNotificationsRouteImport.update({
+  id: '/admin/notifications',
+  path: '/admin/notifications',
+  getParentRoute: () => rootRouteImport,
+} as any)
 const AdminLogsRoute = AdminLogsRouteImport.update({
  id: '/admin/logs',
  path: '/admin/logs',
@@ -64,6 +70,7 @@ export interface FileRoutesByFullPath {
  '/about': typeof AboutRoute
  '/login': typeof authLoginRoute
  '/admin/logs': typeof AdminLogsRoute
+  '/admin/notifications': typeof AdminNotificationsRoute
  '/admin/settings': typeof AdminSettingsRoute
  '/user/profile': typeof authUserProfileRoute
  '/user/resetpassword': typeof authUserResetpasswordRoute
@@ -74,6 +81,7 @@ export interface FileRoutesByTo {
  '/about': typeof AboutRoute
  '/login': typeof authLoginRoute
  '/admin/logs': typeof AdminLogsRoute
+  '/admin/notifications': typeof AdminNotificationsRoute
  '/admin/settings': typeof AdminSettingsRoute
  '/user/profile': typeof authUserProfileRoute
  '/user/resetpassword': typeof authUserResetpasswordRoute
@@ -85,6 +93,7 @@ export interface FileRoutesById {
  '/about': typeof AboutRoute
  '/(auth)/login': typeof authLoginRoute
  '/admin/logs': typeof AdminLogsRoute
+  '/admin/notifications': typeof AdminNotificationsRoute
  '/admin/settings': typeof AdminSettingsRoute
  '/(auth)/user/profile': typeof authUserProfileRoute
  '/(auth)/user/resetpassword': typeof authUserResetpasswordRoute
@@ -97,6 +106,7 @@ export interface FileRouteTypes {
    | '/about'
    | '/login'
    | '/admin/logs'
+    | '/admin/notifications'
    | '/admin/settings'
    | '/user/profile'
    | '/user/resetpassword'
@@ -107,6 +117,7 @@ export interface FileRouteTypes {
    | '/about'
    | '/login'
    | '/admin/logs'
+    | '/admin/notifications'
    | '/admin/settings'
    | '/user/profile'
    | '/user/resetpassword'
@@ -117,6 +128,7 @@ export interface FileRouteTypes {
    | '/about'
    | '/(auth)/login'
    | '/admin/logs'
+    | '/admin/notifications'
    | '/admin/settings'
    | '/(auth)/user/profile'
    | '/(auth)/user/resetpassword'
@@ -128,6 +140,7 @@ export interface RootRouteChildren {
  AboutRoute: typeof AboutRoute
  authLoginRoute: typeof authLoginRoute
  AdminLogsRoute: typeof AdminLogsRoute
+  AdminNotificationsRoute: typeof AdminNotificationsRoute
  AdminSettingsRoute: typeof AdminSettingsRoute
  authUserProfileRoute: typeof authUserProfileRoute
  authUserResetpasswordRoute: typeof authUserResetpasswordRoute
@@ -157,6 +170,13 @@ declare module '@tanstack/react-router' {
      preLoaderRoute: typeof AdminSettingsRouteImport
      parentRoute: typeof rootRouteImport
    }
+    '/admin/notifications': {
+      id: '/admin/notifications'
+      path: '/admin/notifications'
+      fullPath: '/admin/notifications'
+      preLoaderRoute: typeof AdminNotificationsRouteImport
+      parentRoute: typeof rootRouteImport
+    }
    '/admin/logs': {
      id: '/admin/logs'
      path: '/admin/logs'
@@ -200,6 +220,7 @@ const rootRouteChildren: RootRouteChildren = {
  AboutRoute: AboutRoute,
  authLoginRoute: authLoginRoute,
  AdminLogsRoute: AdminLogsRoute,
+  AdminNotificationsRoute: AdminNotificationsRoute,
  AdminSettingsRoute: AdminSettingsRoute,
  authUserProfileRoute: authUserProfileRoute,
  authUserResetpasswordRoute: authUserResetpasswordRoute,
--- a/frontend/src/routes/(auth)/-components/NotificationsSubCard.tsx
+++ b/frontend/src/routes/(auth)/-components/NotificationsSubCard.tsx
@@ -1,4 +1,6 @@
 import { useSuspenseQuery } from "@tanstack/react-query";
+import axios from "axios";
+import { toast } from "sonner";
 import {
 	Card,
 	CardContent,
@@ -12,15 +14,32 @@ import { notifications } from "../../../lib/queries/notifications";

 export default function NotificationsSubCard({ user }: any) {
 	const { data } = useSuspenseQuery(notifications());
-	const { data: ns } = useSuspenseQuery(notificationSubs(user.id));
+	const { refetch } = useSuspenseQuery(notificationSubs(user.id));
 	const form = useAppForm({
 		defaultValues: {
 			notificationId: "",
 			emails: [user.email],
 		},
 		onSubmit: async ({ value }) => {
+			if (value.notificationId === "") {
+				toast.error("Please select a notification before trying to subscribe.");
+				return;
+			}
 			const postD = { ...value, userId: user.id };
-			console.log(postD);
+
+			try {
+				const res = await axios.post("/lst/api/notification/sub", postD, {
+					withCredentials: true,
+				});
+
+				if (res.status === 200) {
+					toast.success("Notification Subbed");
+					refetch();
+					form.reset();
+				}
+			} catch (error) {
+				console.error(error);
+			}
 		},
 	});

@@ -32,11 +51,9 @@ export default function NotificationsSubCard({ user }: any) {
 		}));
 	}

-	console.log(ns);
-
 	return (
 		<div>
-			<Card className="p-3 w-128">
+			<Card className="p-3 w-lg">
 				<CardHeader>
 					<CardTitle>Notifications</CardTitle>
 					<CardDescription>
--- a/frontend/src/routes/(auth)/-components/NotificationsTable.tsx
+++ b/frontend/src/routes/(auth)/-components/NotificationsTable.tsx
@@ -0,0 +1,114 @@
+import { useSuspenseQuery } from "@tanstack/react-query";
+import { createColumnHelper } from "@tanstack/react-table";
+import axios from "axios";
+import { Trash } from "lucide-react";
+import { toast } from "sonner";
+import type { Notifications } from "../../../../types/notifications";
+import { Button } from "../../../components/ui/button";
+import { Card, CardContent, CardHeader } from "../../../components/ui/card";
+import {
+	Tooltip,
+	TooltipContent,
+	TooltipTrigger,
+} from "../../../components/ui/tooltip";
+import { notificationSubs } from "../../../lib/queries/notificationSubs";
+import { notifications } from "../../../lib/queries/notifications";
+import LstTable from "../../../lib/tableStuff/LstTable";
+import SearchableHeader from "../../../lib/tableStuff/SearchableHeader";
+
+export default function NotificationsTable({ userId }: any) {
+	const { data: subs, refetch } = useSuspenseQuery(notificationSubs(userId));
+	const { data: note } = useSuspenseQuery(notifications());
+	const columnHelper = createColumnHelper<Notifications>();
+
+	// filter out the current
+	const notificationMap = Object.fromEntries(note.map((n: any) => [n.id, n]));
+
+	const data = subs.map((sub: any) => ({
+		...sub,
+		name: notificationMap[sub.notificationId].name || null,
+		description: notificationMap[sub.notificationId].description || null,
+		emails: sub.emails ? sub.emails.join(",") : null,
+	}));
+
+	const removeNotification = async (ns: any) => {
+		try {
+			const res = await axios.delete(`/lst/api/notification/sub`, {
+				withCredentials: true,
+				data: {
+					userId: ns.userId,
+					notificationId: ns.notificationId,
+				},
+			});
+
+			if (res.data.success) {
+				toast.success(`Subscription removed`);
+				refetch();
+			} else {
+				console.info(res);
+				toast.error(res.data.message);
+			}
+		} catch {
+			toast.error(`There was an error removing subscription.`);
+		}
+	};
+
+	const column = [
+		columnHelper.accessor("name", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Name" searchable={true} />
+			),
+			filterFn: "includesString",
+			cell: (i) => i.getValue(),
+		}),
+		columnHelper.accessor("description", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Description" />
+			),
+			cell: (i) => (
+				<Tooltip>
+					<TooltipTrigger>
+						{i.getValue()?.length > 25 ? (
+							<span>{i.getValue().slice(0, 25)}...</span>
+						) : (
+							<span>{i.getValue()}</span>
+						)}
+					</TooltipTrigger>
+					<TooltipContent>{i.getValue()}</TooltipContent>
+				</Tooltip>
+			),
+		}),
+		columnHelper.accessor("emails", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Emails" searchable={true} />
+			),
+			filterFn: "includesString",
+			cell: (i) => i.getValue(),
+		}),
+		columnHelper.accessor("remove", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Remove" searchable={false} />
+			),
+			filterFn: "includesString",
+			cell: (i) => {
+				return (
+					<Button
+						size="icon"
+						variant={"destructive"}
+						onClick={() => removeNotification(i.row.original)}
+					>
+						<Trash />
+					</Button>
+				);
+			},
+		}),
+	];
+	return (
+		<Card>
+			<CardHeader className="text-center">Subscriptions</CardHeader>
+			<CardContent>
+				<LstTable data={data} columns={column} />
+			</CardContent>
+		</Card>
+	);
+}
--- a/frontend/src/routes/(auth)/user.profile.tsx
+++ b/frontend/src/routes/(auth)/user.profile.tsx
@@ -13,6 +13,7 @@ import { useAppForm } from "@/lib/formSutff";
 import { Spinner } from "../../components/ui/spinner";
 import ChangePassword from "./-components/ChangePassword";
 import NotificationsSubCard from "./-components/NotificationsSubCard";
+import NotificationsTable from "./-components/NotificationsTable";

 export const Route = createFileRoute("/(auth)/user/profile")({
 	beforeLoad: async () => {
@@ -57,51 +58,73 @@ function RouteComponent() {
 		},
 	});
 	return (
-		<div className="flex justify-center flex-col pt-4 gap-2 lg:flex-row">
-			<div>
-				<Card className="p-6 w-96">
-					<CardHeader>
-						<CardTitle>Profile</CardTitle>
-						<CardDescription>
-							Change your profile and password below
-						</CardDescription>
-					</CardHeader>
+		<div className="flex justify-center flex-col pt-4 gap-2">
+			<div className="flex justify-center flex-col pt-4 gap-2 lg:flex-row">
+				<div>
+					<Card className="p-6 w-96">
+						<CardHeader>
+							<CardTitle>Profile</CardTitle>
+							<CardDescription>
+								Change your profile and password below
+							</CardDescription>
+						</CardHeader>

-					<CardContent>
-						<form
-							onSubmit={(e) => {
-								e.preventDefault();
-								form.handleSubmit();
-							}}
-						>
-							<form.AppField name="name">
-								{(field) => (
-									<field.InputField
-										label="Name"
-										inputType="string"
-										required={true}
-									/>
-								)}
-							</form.AppField>
+						<CardContent>
+							<form
+								onSubmit={(e) => {
+									e.preventDefault();
+									form.handleSubmit();
+								}}
+							>
+								<form.AppField name="name">
+									{(field) => (
+										<field.InputField
+											label="Name"
+											inputType="string"
+											required={true}
+										/>
+									)}
+								</form.AppField>

-							<div className="flex justify-end mt-6">
-								<form.AppForm>
-									<form.SubmitButton>Update Profile</form.SubmitButton>
-								</form.AppForm>
-							</div>
-						</form>
-					</CardContent>
-				</Card>
+								<div className="flex justify-end mt-6">
+									<form.AppForm>
+										<form.SubmitButton>Update Profile</form.SubmitButton>
+									</form.AppForm>
+								</div>
+							</form>
+						</CardContent>
+					</Card>
+				</div>
+				<div>
+					<ChangePassword />
+				</div>
+				<div>
+					<Suspense
+						fallback={
+							<Card className="p-3 w-lg">
+								<CardHeader>
+									<CardTitle>Notifications</CardTitle>
+								</CardHeader>
+								<CardContent>
+									<div className="flex justify-center m-auto">
+										<div>
+											<Spinner className="size-32" />
+										</div>
+									</div>
+								</CardContent>
+							</Card>
+						}
+					>
+						{session && <NotificationsSubCard user={session.user} />}
+					</Suspense>
+				</div>
 			</div>
-			<div>
-				<ChangePassword />
-			</div>
-			<div>
+			<div className="w-fill">
 				<Suspense
 					fallback={
-						<Card className="p-3 w-96">
+						<Card className="p-3">
 							<CardHeader>
-								<CardTitle>Notifications</CardTitle>
+								<CardTitle className="text-center">Subscriptions</CardTitle>
 							</CardHeader>
 							<CardContent>
 								<div className="flex justify-center m-auto">
@@ -113,7 +136,7 @@ function RouteComponent() {
 						</Card>
 					}
 				>
-					{session && <NotificationsSubCard user={session.user} />}
+					{session && <NotificationsTable userId={`${session.user.id}`} />}
 				</Suspense>
 			</div>
 		</div>
--- a/frontend/src/routes/admin/notifications.tsx
+++ b/frontend/src/routes/admin/notifications.tsx
@@ -0,0 +1,316 @@
+import { useMutation, useSuspenseQuery } from "@tanstack/react-query";
+import { createFileRoute, redirect } from "@tanstack/react-router";
+import { createColumnHelper } from "@tanstack/react-table";
+import axios from "axios";
+import { Trash } from "lucide-react";
+import { Suspense, useState } from "react";
+import { toast } from "sonner";
+import type { Notifications } from "../../../types/notifications";
+import { Button } from "../../components/ui/button";
+import { Card, CardContent } from "../../components/ui/card";
+import { Label } from "../../components/ui/label";
+import { Switch } from "../../components/ui/switch";
+import {
+	Tabs,
+	TabsContent,
+	TabsList,
+	TabsTrigger,
+} from "../../components/ui/tabs";
+import {
+	Tooltip,
+	TooltipContent,
+	TooltipTrigger,
+} from "../../components/ui/tooltip";
+import { authClient } from "../../lib/auth-client";
+import { notificationSubs } from "../../lib/queries/notificationSubs";
+import { notifications } from "../../lib/queries/notifications";
+import EditableCellInput from "../../lib/tableStuff/EditableCellInput";
+import LstTable from "../../lib/tableStuff/LstTable";
+import SearchableHeader from "../../lib/tableStuff/SearchableHeader";
+import SkellyTable from "../../lib/tableStuff/SkellyTable";
+
+const updateNotifications = async (
+	id: string,
+	data: Record<string, string | number | boolean | null>,
+) => {
+	//console.log(id, data);
+	try {
+		const res = await axios.patch(
+			`/lst/api/notification/${id}`,
+			{ interval: data.interval },
+			{
+				withCredentials: true,
+			},
+		);
+		toast.success(`Notification was just updated`);
+		return res;
+	} catch (err) {
+		toast.error("Error in updating the settings");
+		return err;
+	}
+};
+
+export const Route = createFileRoute("/admin/notifications")({
+	beforeLoad: async ({ location }) => {
+		const { data: session } = await authClient.getSession();
+		const allowedRole = ["systemAdmin", "admin"];
+
+		if (!session?.user) {
+			throw redirect({
+				to: "/",
+				search: {
+					redirect: location.href,
+				},
+			});
+		}
+
+		if (!allowedRole.includes(session.user.role as string)) {
+			throw redirect({
+				to: "/",
+			});
+		}
+
+		return { user: session.user };
+	},
+	component: RouteComponent,
+});
+
+const NotificationTable = () => {
+	const { data, refetch } = useSuspenseQuery(notifications());
+	const { data: subs, refetch: subRefetch } = useSuspenseQuery(
+		notificationSubs(),
+	);
+	const columnHelper = createColumnHelper<Notifications>();
+
+	const notificationMap = Object.fromEntries(data.map((n: any) => [n.id, n]));
+
+	const subData = subs.map((sub: any) => ({
+		...sub,
+		name: notificationMap[sub.notificationId].name || null,
+		description: notificationMap[sub.notificationId].description || null,
+		emails: sub.emails ? sub.emails.join(",") : null,
+	}));
+
+	const updateNotification = useMutation({
+		mutationFn: ({
+			id,
+			field,
+			value,
+		}: {
+			id: string;
+			field: string;
+			value: string | number | boolean | null;
+		}) => updateNotifications(id, { [field]: value }),
+
+		onSuccess: () => {
+			// refetch or update cache
+			refetch();
+		},
+	});
+
+	const removeNotification = async (ns: any) => {
+		try {
+			const res = await axios.delete(`/lst/api/notification/sub`, {
+				withCredentials: true,
+				data: {
+					userId: ns.userId,
+					notificationId: ns.notificationId,
+				},
+			});
+
+			if (res.data.success) {
+				toast.success(`Subscription removed`);
+				subRefetch();
+			} else {
+				console.info(res);
+				toast.error(res.data.message);
+			}
+		} catch {
+			toast.error(`There was an error removing subscription.`);
+		}
+	};
+
+	const column = [
+		columnHelper.accessor("name", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Name" searchable={true} />
+			),
+			filterFn: "includesString",
+			cell: (i) => i.getValue(),
+		}),
+		columnHelper.accessor("description", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Description" />
+			),
+			cell: (i) => (
+				<Tooltip>
+					<TooltipTrigger>
+						{i.getValue()?.length > 25 ? (
+							<span>{i.getValue().slice(0, 25)}...</span>
+						) : (
+							<span>{i.getValue()}</span>
+						)}
+					</TooltipTrigger>
+					<TooltipContent>{i.getValue()}</TooltipContent>
+				</Tooltip>
+			),
+		}),
+		columnHelper.accessor("active", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Active" searchable={false} />
+			),
+			filterFn: "includesString",
+			cell: (i) => {
+				// biome-ignore lint: just removing the lint for now to get this going will maybe fix later
+				const [activeToggle, setActiveToggle] = useState(i.getValue());
+
+				const onToggle = async (e: boolean) => {
+					setActiveToggle(e);
+
+					try {
+						const res = await axios.patch(
+							`/lst/api/notification/${i.row.original.id}`,
+							{
+								active: !activeToggle,
+							},
+							{ withCredentials: true },
+						);
+
+						if (res.data.success) {
+							toast.success(
+								`${i.row.original.name} was set to ${activeToggle ? "Inactive" : "Active"}`,
+							);
+							refetch();
+						}
+					} catch (error) {
+						console.error(error);
+					}
+				};
+
+				return (
+					<div className="w-48">
+						<div className="flex items-center space-x-2">
+							<Switch
+								id={i.row.original.id}
+								checked={activeToggle}
+								onCheckedChange={(e) => onToggle(e)}
+								//onBlur={field.handleBlur}
+							/>
+							<Label htmlFor={i.row.original.id}>
+								{activeToggle ? "Active" : "Deactivated"}
+							</Label>
+						</div>
+					</div>
+				);
+			},
+		}),
+		columnHelper.accessor("interval", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Interval" />
+			),
+
+			filterFn: "includesString",
+			cell: ({ row, getValue }) => {
+				return (
+					<EditableCellInput
+						value={getValue()}
+						id={row.original.id}
+						field="interval"
+						onSubmit={({ id, field, value }) => {
+							updateNotification.mutate({ id, field, value });
+						}}
+					/>
+				);
+			},
+		}),
+	];
+
+	const subsColumn = [
+		columnHelper.accessor("name", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Name" searchable={true} />
+			),
+			filterFn: "includesString",
+			cell: (i) => i.getValue(),
+		}),
+		columnHelper.accessor("description", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Description" />
+			),
+			cell: (i) => (
+				<Tooltip>
+					<TooltipTrigger>
+						{i.getValue()?.length > 25 ? (
+							<span>{i.getValue().slice(0, 25)}...</span>
+						) : (
+							<span>{i.getValue()}</span>
+						)}
+					</TooltipTrigger>
+					<TooltipContent>{i.getValue()}</TooltipContent>
+				</Tooltip>
+			),
+		}),
+		columnHelper.accessor("emails", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Emails" searchable={true} />
+			),
+			filterFn: "includesString",
+			cell: (i) => i.getValue(),
+		}),
+		columnHelper.accessor("remove", {
+			header: ({ column }) => (
+				<SearchableHeader column={column} title="Remove" searchable={false} />
+			),
+			filterFn: "includesString",
+			cell: (i) => {
+				return (
+					<Button
+						size="icon"
+						variant={"destructive"}
+						onClick={() => removeNotification(i.row.original)}
+					>
+						<Trash />
+					</Button>
+				);
+			},
+		}),
+	];
+
+	return (
+		<>
+			<TabsContent value="notifications">
+				<LstTable data={data} columns={column} />
+			</TabsContent>
+			<TabsContent value="subscriptions">
+				<LstTable data={subData} columns={subsColumn} />
+			</TabsContent>
+		</>
+	);
+};
+
+function RouteComponent() {
+	return (
+		<div className="space-y-6">
+			<div className="space-y-2">
+				<h1 className="text-2xl font-semibold">Notifications</h1>
+				<p className="text-sm text-muted-foreground">
+					Manage all notification settings and user subs.
+				</p>
+			</div>
+
+			<Card>
+				<CardContent>
+					<Tabs defaultValue="notifications" className="w-full">
+						<TabsList>
+							<TabsTrigger value="notifications">Notifications</TabsTrigger>
+							<TabsTrigger value="subscriptions">Subscriptions</TabsTrigger>
+						</TabsList>
+						<Suspense fallback={<SkellyTable />}>
+							<NotificationTable />
+						</Suspense>
+					</Tabs>
+				</CardContent>
+			</Card>
+		</div>
+	);
+}
--- a/frontend/src/routes/admin/settings.tsx
+++ b/frontend/src/routes/admin/settings.tsx
@@ -46,7 +46,7 @@ const updateSettings = async (
 	id: string,
 	data: Record<string, string | number | boolean | null>,
 ) => {
-	console.log(id, data);
+	//console.log(id, data);
 	try {
 		const res = await axios.patch(`/lst/api/settings/${id}`, data, {
 			withCredentials: true,
--- a/frontend/src/routes/index.tsx
+++ b/frontend/src/routes/index.tsx
@@ -34,7 +34,7 @@ function Index() {
 			<p>
 				This is active in your plant today due to having warehousing activated
 				and new functions needed to be introduced, you should be still using LST
-				as you were before
+				as you were before.
 			</p>
 			<br></br>
 			<p>
--- a/frontend/types/notifications.ts
+++ b/frontend/types/notifications.ts
@@ -0,0 +1,10 @@
+export type Notifications = {
+	id: string;
+	name: string;
+	emails: string;
+	description: string;
+	remove?: unknown;
+	active?: boolean;
+	interval: number;
+	options: unknown[];
+};
--- a/migrations/0020_stale_ma_gnuci.sql
+++ b/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()
+);
--- a/migrations/0021_slimy_master_mold.sql
+++ b/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;
--- a/migrations/0022_large_sumo.sql
+++ b/migrations/0022_large_sumo.sql
@@ -0,0 +1 @@
+ALTER TABLE "alpla_purchase_history" ALTER COLUMN "approved_status" SET DEFAULT 'pending';
--- a/migrations/0023_normal_hellion.sql
+++ b/migrations/0023_normal_hellion.sql
@@ -0,0 +1 @@
+ALTER TABLE "alpla_purchase_history" ALTER COLUMN "status_text" SET DATA TYPE text;
--- a/migrations/0024_absent_barracuda.sql
+++ b/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");
--- a/migrations/0025_talented_vector.sql
+++ b/migrations/0025_talented_vector.sql
@@ -0,0 +1 @@
+ALTER TABLE "alpla_purchase_history" ADD COLUMN "updated_at" timestamp DEFAULT now();
--- a/migrations/0026_vengeful_wiccan.sql
+++ b/migrations/0026_vengeful_wiccan.sql
@@ -0,0 +1 @@
+ALTER TABLE "alpla_purchase_history" ALTER COLUMN "approved_status" SET DEFAULT 'new';
--- a/migrations/meta/0020_snapshot.json
+++ b/migrations/meta/0020_snapshot.json
--- a/migrations/meta/0021_snapshot.json
+++ b/migrations/meta/0021_snapshot.json
--- a/migrations/meta/0022_snapshot.json
+++ b/migrations/meta/0022_snapshot.json
--- a/migrations/meta/0023_snapshot.json
+++ b/migrations/meta/0023_snapshot.json
--- a/migrations/meta/0024_snapshot.json
+++ b/migrations/meta/0024_snapshot.json
--- a/migrations/meta/0025_snapshot.json
+++ b/migrations/meta/0025_snapshot.json
--- a/migrations/meta/0026_snapshot.json
+++ b/migrations/meta/0026_snapshot.json
--- a/migrations/meta/_journal.json
+++ b/migrations/meta/_journal.json
@@ -141,6 +141,55 @@
      "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
+    },
+    {
+      "idx": 25,
+      "version": "7",
+      "when": 1775755338816,
+      "tag": "0025_talented_vector",
+      "breakpoints": true
+    },
+    {
+      "idx": 26,
+      "version": "7",
+      "when": 1775786221817,
+      "tag": "0026_vengeful_wiccan",
+      "breakpoints": true
    }
  ]
 }
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,12 +1,12 @@
 {
 	"name": "lst_v3",
-	"version": "0.1.0-alpha.12",
+	"version": "0.0.1-alpha.3",
 	"lockfileVersion": 3,
 	"requires": true,
 	"packages": {
 		"": {
 			"name": "lst_v3",
-			"version": "0.1.0-alpha.12",
+			"version": "0.0.1-alpha.3",
 			"license": "ISC",
 			"dependencies": {
 				"@dotenvx/dotenvx": "^1.57.0",
@@ -24,6 +24,7 @@
 				"drizzle-zod": "^0.8.3",
 				"express": "^5.2.1",
 				"husky": "^9.1.7",
+				"ldapts": "^8.1.7",
 				"morgan": "^1.10.1",
 				"mssql": "^12.2.1",
 				"multer": "^2.1.1",
@@ -8063,6 +8064,18 @@
 				"node": ">=20.0.0"
 			}
 		},
+		"node_modules/ldapts": {
+			"version": "8.1.7",
+			"resolved": "https://registry.npmjs.org/ldapts/-/ldapts-8.1.7.tgz",
+			"integrity": "sha512-TJl6T92eIwMf/OJ0hDfKVa6ISwzo+lqCWCI5Mf//ARlKa3LKQZaSrme/H2rCRBhW0DZCQlrsV+fgoW5YHRNLUw==",
+			"license": "MIT",
+			"dependencies": {
+				"strict-event-emitter-types": "2.0.0"
+			},
+			"engines": {
+				"node": ">=20"
+			}
+		},
 		"node_modules/lines-and-columns": {
 			"version": "1.2.4",
 			"resolved": "https://registry.npmjs.org/lines-and-columns/-/lines-and-columns-1.2.4.tgz",
@@ -10422,6 +10435,12 @@
 				"node": ">=10.0.0"
 			}
 		},
+		"node_modules/strict-event-emitter-types": {
+			"version": "2.0.0",
+			"resolved": "https://registry.npmjs.org/strict-event-emitter-types/-/strict-event-emitter-types-2.0.0.tgz",
+			"integrity": "sha512-Nk/brWYpD85WlOgzw5h173aci0Teyv8YdIAEtV+N88nDB0dLlazZyJMIsN6eo1/AR61l+p6CJTG1JIyFaoNEEA==",
+			"license": "ISC"
+		},
 		"node_modules/string_decoder": {
 			"version": "1.3.0",
 			"resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "lst_v3",
-	"version": "0.1.0-alpha.12",
+	"version": "0.0.1-alpha.3",
 	"description": "The tool that supports us in our everyday alplaprod",
 	"main": "index.js",
 	"scripts": {
@@ -10,10 +10,12 @@
 		"dev:frontend": "cd frontend && npm run dev",
 		"dev:db:migrate": "npx drizzle-kit push",
 		"dev:db:generate": "tsc && npx drizzle-kit generate --config=drizzle.config.ts",
-		"build": "rimraf dist && npm run dev:db:generate && npm run dev:db:migrate && npm run build:app && npm run build:copySql && cd frontend && npm run build",
+		"build": "rimraf dist && npm run dev:db:generate && npm run dev:db:migrate && npm run build:app && npm run build:copySql && npm run build:copyGpSql  && npm run build:emailTemplate && cd frontend && npm run build",
 		"build:app": "tsc",
 		"agent": "powershell -ExecutionPolicy Bypass -File scripts/agentController.ps1",
-		"build:docker": "rimraf dist && npm run build:app && npm run build:copySql",
+		"build:docker": "rimraf dist && npm run build:app && npm run build:copySql && npm run build:copyGpSql  && npm run build:emailTemplate",
+		"build:emailTemplate": "cpy \"backend/utils/mailViews/**/*\" dist/utils/mailViews --parents",
+		"build:copyGpSql": "cpy \"backend/gpSql/queries/**/*\" dist/gpSql/queries --parents",
 		"build:copySql": "cpy \"backend/prodSql/queries/**/*\" dist/prodSql/queries --parents",
 		"lint": "tsc && biome lint",
 		"start": "npm run start:server",
@@ -75,6 +77,7 @@
 		"drizzle-zod": "^0.8.3",
 		"express": "^5.2.1",
 		"husky": "^9.1.7",
+		"ldapts": "^8.1.7",
 		"morgan": "^1.10.1",
 		"mssql": "^12.2.1",
 		"multer": "^2.1.1",
--- a/scripts/agentController.ps1
+++ b/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
Author	SHA1	Message	Date
Blake Matthes	d05a0ce930	chore(release): 0.0.1-alpha.3 All checks were successful Build and Push LST Docker Image / docker (push) Successful in 2m1s Details Release and Build Image / release (push) Successful in 11s Details	2026-04-10 08:22:16 -05:00
Blake Matthes	995b1dda7c	refactor(send email): changes the error message to show the true message in the error All checks were successful Build and Push LST Docker Image / docker (push) Successful in 2m3s Details	2026-04-09 21:15:26 -05:00
Blake Matthes	97f93a1830	refactor(reprints): changes the module and submodule around to be more accurate	2026-04-09 21:14:36 -05:00
Blake Matthes	635635b356	refactor(gp connect): gp connect as was added to long live services	2026-04-09 21:13:38 -05:00
Blake Matthes	a691dc276e	feat(puchase hist): finished up purhcase historical / gp updates	2026-04-09 21:12:43 -05:00
Blake Matthes	8dfcbc5720	chore(release): 0.0.1-alpha.2 All checks were successful Build and Push LST Docker Image / docker (push) Successful in 2m29s Details Release and Build Image / release (push) Successful in 17s Details	2026-04-08 16:13:38 -05:00
Blake Matthes	103ae77e9f	build(release): docker and release corrections Some checks failed Build and Push LST Docker Image / docker (push) Has been cancelled Details	2026-04-08 16:12:54 -05:00
Blake Matthes	beeccc6e8d	chore(release): 0.0.1-alpha.1 Some checks failed Build and Push LST Docker Image / docker (push) Has been cancelled Details Release and Build Image / release (push) Failing after 15s Details	2026-04-08 15:58:21 -05:00
Blake Matthes	0880298cf5	refactor(opendock refactor on how releases are posted): this was a bug maybe just a better refactory Some checks failed Build and Push LST Docker Image / docker (push) Has been cancelled Details	2026-04-08 15:57:20 -05:00
Blake Matthes	34b0abac36	feat(puchase history): purhcase history changed to long running no notification	2026-04-08 15:55:25 -05:00
Blake Matthes	28c226ddbc	build(agent): added westbend into the flow	2026-04-07 22:33:38 -05:00
Blake Matthes	42861cc69e	feat(purchase): historical data capture for alpla purchase	2026-04-07 22:33:11 -05:00
Blake Matthes	5f3d683a13	refactor(notification): reprint - removed a console log as it shouldnt bc there	2026-04-06 16:41:39 -05:00
Blake Matthes	a17787e852	feat(notification): reprint added All checks were successful Build and Push LST Docker Image / docker (push) Successful in 2m6s Details	2026-04-06 16:01:06 -05:00
Blake Matthes	5865ac3b99	feat(notification): base notifcaiton sub and admin compelted All checks were successful Build and Push LST Docker Image / docker (push) Successful in 1m59s Details can now sub to a notification and user can remove them selfs plus an admin can remove,updates to add new emails are good as well	2026-04-06 12:59:30 -05:00
Blake Matthes	637de857f9	feat(user notifications): added the ability for users to sub to notifications and add multi email	2026-04-06 09:29:46 -05:00
Blake Matthes	3ecf5fb916	refactor(userprofile): changes to have the table be blank and say nothing subscribed All checks were successful Build and Push LST Docker Image / docker (push) Successful in 2m32s Details later we will leave this off the profile and add it once at least one notification is subscribed	2026-04-05 20:50:27 -05:00
Blake Matthes	92ba3ef512	docs(readme): updated progress data All checks were successful Build and Push LST Docker Image / docker (push) Successful in 1m18s Details	2026-04-05 20:44:49 -05:00
Blake Matthes	7d6c2db89c	style(notifcaion): style changes to the notificaion card and started the table All checks were successful Build and Push LST Docker Image / docker (push) Successful in 1m49s Details	2026-04-03 17:16:58 -05:00
Blake Matthes	74262beb65	refactor(notification): select menu looks propper now	2026-04-03 17:16:31 -05:00
Blake Matthes	f3b8dd94e5	refactor(queries): changed dev version to be 1500ms vs 5000ms	2026-04-03 17:16:02 -05:00
Blake Matthes	0059b9b850	build(changelog): reset the change log after all crap testing	2026-04-03 17:15:22 -05:00
				`@@ -0,0 +1 @@`
				`ALTER TABLE "alpla_purchase_history" ALTER COLUMN "approved_status" SET DEFAULT 'pending';`
				`@@ -0,0 +1 @@`
				`ALTER TABLE "alpla_purchase_history" ADD COLUMN "updated_at" timestamp DEFAULT now();`