Merge branch 'feature/pbs' into release/2021-10-22

server/accounting/pbs/pbs-constants.js

@@ -0,0 +1,21 @@
+const path = require("path");
+require("dotenv").config({
+  path: path.resolve(
+    process.cwd(),
+    `.env.${process.env.NODE_ENV || "development"}`
+  ),
+});
+const CdkBase = require("../web-sockets/web-socket");
+
+const IMEX_PBS_USER = process.env.IMEX_PBS_USER,
+  IMEX_PBS_PASSWORD = process.env.IMEX_PBS_PASSWORD;
+const PBS_CREDENTIALS = {
+  password: IMEX_PBS_PASSWORD,
+  username: IMEX_PBS_USER,
+};
+
+exports.PBS_CREDENTIALS = PBS_CREDENTIALS;
+// const cdkDomain =
+//   process.env.NODE_ENV === "production"
+//     ? "https://3pa.dmotorworks.com"
+//     : "https://uat-3pa.dmotorworks.com";

server/accounting/pbs/pbs-job-export.js

@@ -0,0 +1,35 @@
+const path = require("path");
+require("dotenv").config({
+  path: path.resolve(
+    process.cwd(),
+    `.env.${process.env.NODE_ENV || "development"}`
+  ),
+});
+const GraphQLClient = require("graphql-request").GraphQLClient;
+const soap = require("soap");
+const queries = require("../../graphql-client/queries");
+const CdkBase = require("../../web-sockets/web-socket");
+
+//const { CDK_CREDENTIALS, CheckCdkResponseForError } = require("./cdk-wsdl");
+//const CalcualteAllocations = require("./cdk-calculate-allocations").default;
+
+const moment = require("moment");
+
+exports.default = async function (socket, jobid) {
+  socket.logEvents = [];
+  socket.recordid = jobid;
+
+  try {
+    CdkBase.createLogEvent(
+      socket,
+      "DEBUG",
+      `Received Job export request for id ${jobid}`
+    );
+  } catch (error) {
+    CdkBase.createLogEvent(
+      socket,
+      "ERROR",
+      `Error encountered in PbsJobExport. ${error}`
+    );
+  }
+};

server/web-sockets/web-socket.js

@@ -17,6 +17,7 @@ const CdkCalculateAllocations =
   require("../cdk/cdk-calculate-allocations").default;
 const { isArray } = require("lodash");
 const logger = require("../utils/logger");
+const PbsExportJob = require("../accounting/pbs/pbs-job-export");
 
 io.use(function (socket, next) {
   try {
@@ -57,6 +58,7 @@ io.on("connection", (socket) => {
     });
   });
 
+  ///CDK
   socket.on("cdk-export-job", (jobid) => {
     CdkJobExport(socket, jobid);
   });
@@ -94,6 +96,13 @@ io.on("connection", (socket) => {
 
     callback(allocations);
   });
+  //END CDK
+
+  //PBS
+  socket.on("pbs-export-job", (jobid) => {
+    PbsExportJob(socket, jobid);
+  });
+  //End PBS
 
   socket.on("disconnect", () => {
     createLogEvent(socket, "DEBUG", `User disconnected.`);