Add PBS Logging.

server/web-sockets/web-socket.js

@@ -17,7 +17,10 @@ const CdkCalculateAllocations =
   require("../cdk/cdk-calculate-allocations").default;
 const { isArray } = require("lodash");
 const logger = require("../utils/logger");
-const {default: PbsExportJob, PbsSelectedCustomer} = require("../accounting/pbs/pbs-job-export");
+const {
+  default: PbsExportJob,
+  PbsSelectedCustomer,
+} = require("../accounting/pbs/pbs-job-export");
 
 io.use(function (socket, next) {
   try {
@@ -159,6 +162,37 @@ function createLogEvent(socket, level, message) {
   }
 }
 
+function createJsonEvent(socket, level, message, json) {
+  if (LogLevelHierarchy(socket.log_level) >= LogLevelHierarchy(level)) {
+    console.log(
+      `[WS LOG EVENT] ${level} - ${new Date()} - ${socket.user.email} - ${
+        socket.id
+      } - ${message}`
+    );
+    socket.emit("log-event", {
+      timestamp: new Date(),
+      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);
+    // }
+  }
+}
+
 function createXmlEvent(socket, xml, message, isError = false) {
   if (LogLevelHierarchy(socket.log_level) >= LogLevelHierarchy("TRACE")) {
     socket.emit("log-event", {
@@ -210,3 +244,4 @@ function LogLevelHierarchy(level) {
 
 exports.createLogEvent = createLogEvent;
 exports.createXmlEvent = createXmlEvent;
+exports.createJsonEvent = createJsonEvent;