From 5c54cf6c44d466398e77a5b2da171b8c709f1f20 Mon Sep 17 00:00:00 2001
From: Dave Richer <dave@imexsystems.ca>
Date: Mon, 16 Sep 2024 11:48:17 -0400
Subject: [PATCH] feature/IO-2924-Refactor-Production-Board-For-Sockets  -
 Checkpoint

Signed-off-by: Dave Richer <dave@imexsystems.ca>
---
 .../dms-allocations-summary-ap.component.jsx  | 13 +----------
 .../dms-allocations-summary.component.jsx     |  2 +-
 .../dms-payables/dms-payables.container.jsx   |  2 +-
 client/src/pages/dms/dms.container.jsx        |  4 ++--
 .../pages/manage/manage.page.component.jsx    | 12 ++++++++++
 server.js                                     |  4 +++-
 server/web-sockets/web-socket.js              | 22 +++++++++----------
 7 files changed, 30 insertions(+), 29 deletions(-)

diff --git a/client/src/components/dms-allocations-summary-ap/dms-allocations-summary-ap.component.jsx b/client/src/components/dms-allocations-summary-ap/dms-allocations-summary-ap.component.jsx
index abbde7277..0125191dd 100644
--- a/client/src/components/dms-allocations-summary-ap/dms-allocations-summary-ap.component.jsx
+++ b/client/src/components/dms-allocations-summary-ap/dms-allocations-summary-ap.component.jsx
@@ -20,7 +20,7 @@ export function DmsAllocationsSummaryAp({ bodyshop, billids, title }) {
   const { socket } = useContext(SocketContext);
 
   useEffect(() => {
-    if (!socket) return;
+    if (!socket || !socket.connected) return;
 
     const handleSuccess = async (billid) => {
       setAllocationsSummary((allocationsSummary) =>
@@ -45,21 +45,10 @@ export function DmsAllocationsSummaryAp({ bodyshop, billids, title }) {
       }
     };
 
-    const handleFailure = ({ billid, error }) => {
-      setAllocationsSummary((allocationsSummary) =>
-        allocationsSummary.map((a) => {
-          if (a.billid !== billid) return a;
-          return { ...a, status: error };
-        })
-      );
-    };
-
     socket.on("ap-export-success", handleSuccess);
-    socket.on("ap-export-failure", handleFailure);
 
     return () => {
       socket.off("ap-export-success", handleSuccess);
-      socket.off("ap-export-failure", handleFailure);
     };
   }, [socket]);
 
diff --git a/client/src/components/dms-allocations-summary/dms-allocations-summary.component.jsx b/client/src/components/dms-allocations-summary/dms-allocations-summary.component.jsx
index 3551cc6e3..cbc2680dd 100644
--- a/client/src/components/dms-allocations-summary/dms-allocations-summary.component.jsx
+++ b/client/src/components/dms-allocations-summary/dms-allocations-summary.component.jsx
@@ -24,7 +24,7 @@ export function DmsAllocationsSummary({ socket, bodyshop, jobId, title }) {
   const [allocationsSummary, setAllocationsSummary] = useState([]);
 
   useEffect(() => {
-    if (socket.connected) {
+    if (socket && socket.connected) {
       socket.emit("cdk-calculate-allocations", jobId, (ack) => {
         setAllocationsSummary(ack);
         socket.allocationsSummary = ack;
diff --git a/client/src/pages/dms-payables/dms-payables.container.jsx b/client/src/pages/dms-payables/dms-payables.container.jsx
index 15117c94d..c354687fb 100644
--- a/client/src/pages/dms-payables/dms-payables.container.jsx
+++ b/client/src/pages/dms-payables/dms-payables.container.jsx
@@ -60,7 +60,7 @@ export function DmsContainer({ setBreadcrumbs, setSelectedHeader }) {
           {
             timestamp: new Date(),
             level: "WARNING",
-            message: "Reconnected to CDK Export Service"
+            message: "Reconnected to DMS Export Service"
           }
         ]);
       };
diff --git a/client/src/pages/dms/dms.container.jsx b/client/src/pages/dms/dms.container.jsx
index ab1d40f95..1328595cc 100644
--- a/client/src/pages/dms/dms.container.jsx
+++ b/client/src/pages/dms/dms.container.jsx
@@ -90,7 +90,7 @@ export function DmsContainer({ bodyshop, setBreadcrumbs, setSelectedHeader, inse
           {
             timestamp: new Date(),
             level: "WARNING",
-            message: "Reconnected to CDK Export Service"
+            message: "Reconnected to DMS Export Service"
           }
         ]);
       };
@@ -201,7 +201,7 @@ export function DmsContainer({ bodyshop, setBreadcrumbs, setSelectedHeader, inse
                     <Select.Option key="WARNING">WARNING</Select.Option>
                     <Select.Option key="ERROR">ERROR</Select.Option>
                   </Select>
-                  4<Button onClick={() => setLogs([])}>Clear Logs</Button>
+                  <Button onClick={() => setLogs([])}>Clear Logs</Button>
                   <Button
                     onClick={() => {
                       setLogs([]);
diff --git a/client/src/pages/manage/manage.page.component.jsx b/client/src/pages/manage/manage.page.component.jsx
index b91e61d61..26085f723 100644
--- a/client/src/pages/manage/manage.page.component.jsx
+++ b/client/src/pages/manage/manage.page.component.jsx
@@ -24,6 +24,7 @@ import UpdateAlert from "../../components/update-alert/update-alert.component";
 import InstanceRenderManager from "../../utils/instanceRenderMgr.js";
 import "./manage.page.styles.scss";
 import SocketContext from "../../contexts/SocketIO/socketContext.jsx";
+import { requestForToken } from "../../firebase/firebase.utils.js";
 
 const JobsPage = lazy(() => import("../jobs/jobs.page"));
 
@@ -112,6 +113,17 @@ export function Manage({ conflict, bodyshop }) {
   const [chatVisible] = useState(false);
   const { socket, clientId } = useContext(SocketContext);
 
+  useEffect(() => {
+    const widgetId = InstanceRenderManager({
+      imex: "IABVNO4scRKY11XBQkNr",
+      rome: "mQdqARMzkZRUVugJ6TdS"
+    });
+    window.noticeable.render("widget", widgetId);
+    requestForToken().catch((error) => {
+      console.error(`Unable to request for token.`, error);
+    });
+  }, []);
+
   useEffect(() => {
     document.title = InstanceRenderManager({
       imex: t("titles.imexonline"),
diff --git a/server.js b/server.js
index 98e20fa9d..e7a82c507 100644
--- a/server.js
+++ b/server.js
@@ -38,7 +38,9 @@ const SOCKETIO_CORS_ORIGIN = [
   "https://www.test.promanager.web-est.com",
   "https://test.promanager.web-est.com",
   "https://www.promanager.web-est.com",
-  "https://www.promanager.web-est.com"
+  "https://www.promanager.web-est.com",
+  "https://old.imex.online",
+  "https://www.old.imex.online"
 ];
 
 /**
diff --git a/server/web-sockets/web-socket.js b/server/web-sockets/web-socket.js
index 708398829..4aa55d741 100644
--- a/server/web-sockets/web-socket.js
+++ b/server/web-sockets/web-socket.js
@@ -60,12 +60,11 @@ async function registerSocketEvents(socket) {
 // CDK-specific socket events
 function registerCdkEvents(socket) {
   socket.on("cdk-export-job", (jobid) => CdkJobExport(socket, jobid));
+
   socket.on("cdk-selected-customer", async (selectedCustomerId) => {
     await createLogEvent(socket, "DEBUG", `User selected customer ID ${selectedCustomerId}`);
-    CdkSelectedCustomer(socket, selectedCustomerId).catch((err) =>
-      console.error(`Error in cdk-selected-customer: ${err}`)
-    );
-    await setSessionData(socket.id, "selectedCustomer", selectedCustomerId);
+    CdkSelectedCustomer(socket, selectedCustomerId);
+    await setSessionData(socket.id, "selectedCustomerId ", selectedCustomerId);
   });
 
   socket.on("cdk-get-makes", async (cdk_dealerid, callback) => {
@@ -73,16 +72,15 @@ function registerCdkEvents(socket) {
       const makes = await CdkGetMakes(socket, cdk_dealerid);
       callback(makes);
     } catch (error) {
-      await createLogEvent(socket, "ERROR", `Error in cdk-get-makes WS call. ${JSON.stringify(error)}`);
+      await createLogEvent(socket, "ERROR", `Error in cdk-get-makes WS call. ${JSON.stringify(error, null, 2)}`);
     }
   });
 
   socket.on("cdk-calculate-allocations", async (jobid, callback) => {
     const allocations = await CdkCalculateAllocations(socket, jobid);
     await createLogEvent(socket, "DEBUG", `Allocations calculated.`);
-    await createLogEvent(socket, "TRACE", `Allocations details: ${JSON.stringify(allocations)}`);
+    await createLogEvent(socket, "TRACE", `Allocations details: ${JSON.stringify(allocations, null, 2)}`);
     callback(allocations);
-    await setSessionData(socket.id, "cdk_allocations", allocations);
   });
 }
 
@@ -91,18 +89,18 @@ function registerPbsArEvents(socket) {
   socket.on("pbs-calculate-allocations", async (jobid, callback) => {
     const allocations = await CdkCalculateAllocations(socket, jobid);
     await createLogEvent(socket, "DEBUG", `PBS AR allocations calculated.`);
-    await createLogEvent(socket, "TRACE", `Allocations details: ${JSON.stringify(allocations)}`);
+    await createLogEvent(socket, "TRACE", `Allocations details: ${JSON.stringify(allocations, null, 2)}`);
     callback(allocations);
-    await setSessionData(socket.id, "pbs_allocations", allocations);
   });
 
   socket.on("pbs-export-job", (jobid) => PbsExportJob(socket, jobid));
+
   socket.on("pbs-selected-customer", async (selectedCustomerId) => {
     await createLogEvent(socket, "DEBUG", `PBS AR selected customer ID ${selectedCustomerId}`);
     PbsSelectedCustomer(socket, selectedCustomerId).catch((err) =>
       console.error(`Error in pbs-selected-customer: ${err}`)
     );
-    await setSessionData(socket.id, "selectedCustomer", selectedCustomerId);
+    await setSessionData(socket.id, "selectedCustomerId", selectedCustomerId);
   });
 }
 
@@ -111,13 +109,13 @@ function registerPbsApEvents(socket) {
   socket.on("pbs-calculate-allocations-ap", async (billids, callback) => {
     const allocations = await PbsCalculateAllocationsAp(socket, billids);
     await createLogEvent(socket, "DEBUG", `PBS AP allocations calculated.`);
-    await createLogEvent(socket, "TRACE", `Allocations details: ${JSON.stringify(allocations)}`);
+    await createLogEvent(socket, "TRACE", `Allocations details: ${JSON.stringify(allocations, null, 2)}`);
     callback(allocations);
     await setSessionData(socket.id, "pbs_ap_allocations", allocations);
   });
 
   socket.on("pbs-export-ap", async ({ billids, txEnvelope }) => {
-    await setSessionData(socket.id, "pbs_txEnvelope", txEnvelope);
+    await setSessionData(socket.id, "txEnvelope", txEnvelope);
     PbsExportAp(socket, {
       billids,
       txEnvelope