From c962d848c1b9c151bec1a96da2ee7cb36c7d94c2 Mon Sep 17 00:00:00 2001
From: Patrick Fic <snaptsoft@gmail.com>
Date: Fri, 21 Jan 2022 14:34:15 -0800
Subject: [PATCH] PBS Improvements.

---
 server/accounting/pbs/pbs-job-export.js | 12 ++++++++--
 server/web-sockets/web-socket.js        | 31 ++++++++++++-------------
 2 files changed, 25 insertions(+), 18 deletions(-)

diff --git a/server/accounting/pbs/pbs-job-export.js b/server/accounting/pbs/pbs-job-export.js
index 8ba6f8fc1..f9d1cb96e 100644
--- a/server/accounting/pbs/pbs-job-export.js
+++ b/server/accounting/pbs/pbs-job-export.js
@@ -65,7 +65,11 @@ exports.default = async function (socket, { txEnvelope, jobid }) {
 
     const JobData = await QueryJobData(socket, jobid);
     socket.JobData = JobData;
-
+    CdkBase.createLogEvent(
+      socket,
+      "DEBUG",
+      `Querying the DMS for the Vehicle Record.`
+    );
     //Query for the Vehicle record to get the associated customer.
     socket.DmsVeh = await QueryVehicleFromDms(socket);
     //Todo: Need to validate the lines and methods below.
@@ -121,7 +125,11 @@ exports.PbsSelectedCustomer = async function PbsSelectedCustomer(
     );
     await UpsertVehicleData(socket, ownerRef.ReferenceId);
     CdkBase.createLogEvent(socket, "DEBUG", `Inserting account data.`);
-
+    CdkBase.createLogEvent(
+      socket,
+      "DEBUG",
+      `Inserting accounting posting data..`
+    );
     await InsertAccountPostingData(socket);
 
     CdkBase.createLogEvent(socket, "DEBUG", `Marking job as exported.`);
diff --git a/server/web-sockets/web-socket.js b/server/web-sockets/web-socket.js
index e4f3febf9..53076f0cc 100644
--- a/server/web-sockets/web-socket.js
+++ b/server/web-sockets/web-socket.js
@@ -174,23 +174,22 @@ function createJsonEvent(socket, level, message, json) {
       level,
       message,
     });
-
-    logger.log("ws-log-event-json", level, socket.user.email, socket.recordid, {
-      wsmessage: message,
-      json
-    });
-
-    if (socket.logEvents && isArray(socket.logEvents)) {
-      socket.logEvents.push({
-        timestamp: new Date(),
-        level,
-        message,
-      });
-    }
-    // if (level === "ERROR") {
-    //   throw new Error(message);
-    // }
   }
+  logger.log("ws-log-event-json", level, socket.user.email, socket.recordid, {
+    wsmessage: message,
+    json,
+  });
+
+  if (socket.logEvents && isArray(socket.logEvents)) {
+    socket.logEvents.push({
+      timestamp: new Date(),
+      level,
+      message,
+    });
+  }
+  // if (level === "ERROR") {
+  //   throw new Error(message);
+  // }
 }
 
 function createXmlEvent(socket, xml, message, isError = false) {