IO-233 Beging get vehicle makes

server/cdk/cdk-calculate-allocations.js

@@ -6,11 +6,10 @@ require("dotenv").config({
   ),
 });
 const GraphQLClient = require("graphql-request").GraphQLClient;
-const soap = require("soap");
+
 const queries = require("../graphql-client/queries");
 const CdkBase = require("../web-sockets/web-socket");
-const CdkWsdl = require("./cdk-wsdl").default;
-const logger = require("../utils/logger");
+
 const Dinero = require("dinero.js");
 const _ = require("lodash");
 

server/cdk/cdk-get-makes.js

@@ -0,0 +1,80 @@
+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 CdkWsdl = require("./cdk-wsdl").default;
+const logger = require("../utils/logger");
+const Dinero = require("dinero.js");
+const _ = require("lodash");
+const {
+  CDK_CREDENTIALS,
+  CheckCdkResponseForError,
+  checkIndividualResult,
+} = require("./cdk-wsdl");
+
+exports.default = async function (socket, cdk_dealerid) {
+  try {
+    CdkBase.createLogEvent(
+      socket,
+      "DEBUG",
+      `Getting makes and models list from CDK.`
+    );
+    const t = await GetCdkMakes(socket, cdk_dealerid);
+    console.log(t);
+    return [];
+  } catch (error) {
+    CdkBase.createLogEvent(
+      socket,
+      "ERROR",
+      `Error encountered in CdkGetMakes. ${error}`
+    );
+  }
+};
+
+async function GetCdkMakes(socket, cdk_dealerid) {
+  CdkBase.createLogEvent(socket, "TRACE", `{1} Begin GetCDkMakes WSDL Call`);
+
+  try {
+    const soapClientVehicleSearch = await soap.createClientAsync(
+      CdkWsdl.VehicleSearch
+    );
+    const soapResponseVehicleSearch =
+      await soapClientVehicleSearch.getVehIdsAsync(
+        {
+          arg0: CDK_CREDENTIALS,
+          arg1: { id: cdk_dealerid },
+        },
+
+        {}
+      );
+    CheckCdkResponseForError(socket, soapResponseVehicleSearch);
+    const [
+      result, //rawResponse, soapheader, rawRequest
+    ] = soapResponseVehicleSearch;
+    CdkBase.createLogEvent(
+      socket,
+      "TRACE",
+      `soapResponseVehicleSearch.searchIDsByVINAsync Result ${JSON.stringify(
+        result,
+        null,
+        2
+      )}`
+    );
+    const DmsVehicle = result && result.return && result.return[0];
+    return DmsVehicle;
+  } catch (error) {
+    CdkBase.createLogEvent(
+      socket,
+      "ERROR",
+      `Error in CalculateDmsVid - ${JSON.stringify(error, null, 2)}`
+    );
+    throw new Error(error);
+  }
+}

server/cdk/cdk-job-export.js

@@ -11,13 +11,11 @@ const queries = require("../graphql-client/queries");
 const CdkBase = require("../web-sockets/web-socket");
 const CdkWsdl = require("./cdk-wsdl").default;
 const logger = require("../utils/logger");
-
-const IMEX_CDK_USER = process.env.IMEX_CDK_USER,
-  IMEX_CDK_PASSWORD = process.env.IMEX_CDK_PASSWORD;
-const CDK_CREDENTIALS = {
-  password: IMEX_CDK_PASSWORD,
-  username: IMEX_CDK_USER,
-};
+const {
+  CDK_CREDENTIALS,
+  CheckCdkResponseForError,
+  checkIndividualResult,
+} = require("./cdk-wsdl");
 
 exports.default = async function (socket, jobid) {
   socket.logEvents = [];
@@ -458,55 +456,3 @@ async function CalculateDmsVid(socket, JobData) {
     throw new Error(error);
   }
 }
-
-function CheckCdkResponseForError(socket, soapResponse) {
-  if (!soapResponse[0]) {
-    //The response was null, this might be ok, it might not.
-    CdkBase.createLogEvent(
-      socket,
-      "WARNING",
-      `Warning detected in CDK Response - it appears to be null. Stack: ${
-        new Error().stack
-      }`
-    );
-    return;
-  }
-
-  const ResultToCheck = soapResponse[0].return;
-
-  if (Array.isArray(ResultToCheck)) {
-    ResultToCheck.forEach((result) => checkIndividualResult(socket, result));
-  } else {
-    checkIndividualResult(socket, ResultToCheck);
-  }
-}
-
-function checkIndividualResult(socket, ResultToCheck) {
-  if (
-    ResultToCheck.errorLevel === 0 ||
-    ResultToCheck.errorLevel === "0" ||
-    ResultToCheck.code === "success" ||
-    (!ResultToCheck.code && !ResultToCheck.errorLevel)
-  )
-    //TODO:  Verify that this is the best way to detect errors.
-    return;
-  else {
-    CdkBase.createLogEvent(
-      socket,
-      "ERROR",
-      `Error detected in CDK Response - ${JSON.stringify(
-        ResultToCheck,
-        null,
-        2
-      )}`
-    );
-
-    throw new Error(
-      `Error found while validating CDK response for ${JSON.stringify(
-        ResultToCheck,
-        null,
-        2
-      )}:`
-    );
-  }
-}

server/cdk/cdk-wsdl.js

@@ -5,18 +5,83 @@ require("dotenv").config({
     `.env.${process.env.NODE_ENV || "development"}`
   ),
 });
+const CdkBase = require("../web-sockets/web-socket");
 
+const IMEX_CDK_USER = process.env.IMEX_CDK_USER,
+  IMEX_CDK_PASSWORD = process.env.IMEX_CDK_PASSWORD;
+const CDK_CREDENTIALS = {
+  password: IMEX_CDK_PASSWORD,
+  username: IMEX_CDK_USER,
+};
+
+exports.CDK_CREDENTIALS = CDK_CREDENTIALS;
 // const cdkDomain =
 //   process.env.NODE_ENV === "production"
 //     ? "https://3pa.dmotorworks.com"
 //     : "https://uat-3pa.dmotorworks.com";
 
+function CheckCdkResponseForError(socket, soapResponse) {
+  if (!soapResponse[0]) {
+    //The response was null, this might be ok, it might not.
+    CdkBase.createLogEvent(
+      socket,
+      "WARNING",
+      `Warning detected in CDK Response - it appears to be null. Stack: ${
+        new Error().stack
+      }`
+    );
+    return;
+  }
+
+  const ResultToCheck = soapResponse[0].return;
+
+  if (Array.isArray(ResultToCheck)) {
+    ResultToCheck.forEach((result) => checkIndividualResult(socket, result));
+  } else {
+    checkIndividualResult(socket, ResultToCheck);
+  }
+}
+exports.CheckCdkResponseForError = CheckCdkResponseForError;
+
+function checkIndividualResult(socket, ResultToCheck) {
+  if (
+    ResultToCheck.errorLevel === 0 ||
+    ResultToCheck.errorLevel === "0" ||
+    ResultToCheck.code === "success" ||
+    (!ResultToCheck.code && !ResultToCheck.errorLevel)
+  )
+    //TODO:  Verify that this is the best way to detect errors.
+    return;
+  else {
+    CdkBase.createLogEvent(
+      socket,
+      "ERROR",
+      `Error detected in CDK Response - ${JSON.stringify(
+        ResultToCheck,
+        null,
+        2
+      )}`
+    );
+
+    throw new Error(
+      `Error found while validating CDK response for ${JSON.stringify(
+        ResultToCheck,
+        null,
+        2
+      )}:`
+    );
+  }
+}
+
+exports.checkIndividualResult = checkIndividualResult;
+
 const cdkDomain = "https://uat-3pa.dmotorworks.com";
 exports.default = {
   // VehicleSearch: `${cdkDomain}/pip-vehicle/services/VehicleSearch?wsdl`,
   VehicleInsertUpdate: `${cdkDomain}/pip-vehicle/services/VehicleInsertUpdate?wsdl`,
   CustomerInsertUpdate: `${cdkDomain}/pip-customer/services/CustomerInsertUpdate?wsdl`,
   CustomerSearch: `${cdkDomain}/pip-customer/services/CustomerSearch?wsdl`,
+  VehicleSearch: `${cdkDomain}/pip-vehicle/services/VehicleSearch?wsdl`,
 };
 
 // The following login credentials will be used for all PIPs and all environments (User Acceptance Testing and Production).

server/web-sockets/web-socket.js

@@ -9,6 +9,7 @@ require("dotenv").config({
 const { io } = require("../../server");
 const { admin } = require("../firebase/firebase-handler");
 const CdkJobExport = require("../cdk/cdk-job-export").default;
+const CdkGetMakes = require("../cdk/cdk-get-makes").default;
 const CdkCalculateAllocations =
   require("../cdk/cdk-calculate-allocations").default;
 const { isArray } = require("lodash");
@@ -62,6 +63,11 @@ io.on("connection", (socket) => {
     //CdkJobExport(socket, jobid);
   });
 
+  socket.on("cdk-get-makes", async (cdk_dealerid, callback) => {
+    const makes = await CdkGetMakes(socket, cdk_dealerid);
+    callback(makes);
+  });
+
   socket.on("cdk-calculate-allocations", async (jobid, callback) => {
     const allocations = await CdkCalculateAllocations(socket, jobid);
     createLogEvent(socket, "DEBUG", `Allocations calculated.`);