Merge branch 'feature/cdk-cert' into feature/qbo

server/cdk/cdk-get-makes.js

@@ -15,32 +15,101 @@ const Dinero = require("dinero.js");
 const _ = require("lodash");
 const { CDK_CREDENTIALS, CheckCdkResponseForError } = require("./cdk-wsdl");
 const { performance } = require("perf_hooks");
+const apiGqlClient = require("../graphql-client/graphql-client").client;
 
-exports.default = async function (socket, cdk_dealerid) {
+// exports.default = async function (socket, cdk_dealerid) {
+//   try {
+//     CdkBase.createLogEvent(
+//       socket,
+//       "DEBUG",
+//       `Getting makes and models list from CDK.`
+//     );
+//     return await GetCdkMakes(socket, cdk_dealerid);
+//   } catch (error) {
+//     CdkBase.createLogEvent(
+//       socket,
+//       "ERROR",
+//       `Error encountered in CdkGetMakes. ${error}`
+//     );
+//   }
+// };
+
+exports.default = async function ReloadCdkMakes(req, res) {
+  const { bodyshopid, cdk_dealerid } = req.body;
   try {
-    CdkBase.createLogEvent(
-      socket,
-      "DEBUG",
-      `Getting makes and models list from CDK.`
+    const BearerToken = req.headers.authorization;
+    //Query all CDK Models
+    const newList = await GetCdkMakes(req, cdk_dealerid);
+    console.log("🚀  ~ file: cdk-get-makes.js  ~ line 40  ~ newList", newList);
+
+    //Clear out the existing records
+    const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+      headers: {
+        Authorization: BearerToken,
+      },
+    });
+
+    const deleteResult = await client
+      .setHeaders({ Authorization: BearerToken })
+      .request(queries.DELETE_ALL_DMS_VEHICLES, {});
+    console.log(
+      "🚀  ~ file: cdk-get-makes.js  ~ line 53  ~ deleteResult",
+      deleteResult
+    );
+
+    //Insert the new ones.
+
+    const insertResult = await client
+      .setHeaders({ Authorization: BearerToken })
+      .request(queries.INSERT_DMS_VEHICLES, {
+        vehicles: newList.map((i) => {
+          return {
+            bodyshopid,
+            makecode: i.makeCode,
+            modelcode: i.modelCode,
+            make: i.makeFullName,
+            model: i.modelFullName,
+          };
+        }),
+      });
+    console.log(
+      "🚀  ~ file: cdk-get-makes.js  ~ line 66  ~ insertResult",
+      insertResult
+    );
+
+    logger.log(
+      "cdk-replace-makes-models-success",
+      "DEBUG",
+      req.user.email,
+      null,
+      {
+        cdk_dealerid,
+        count: newList.length,
+      }
     );
-    return await GetCdkMakes(socket, cdk_dealerid);
   } catch (error) {
-    CdkBase.createLogEvent(
-      socket,
+    logger.log(
+      "cdk-replace-makes-models-error",
       "ERROR",
-      `Error encountered in CdkGetMakes. ${error}`
+      req.user.email,
+      null,
+      {
+        cdk_dealerid,
+        error,
+      }
     );
   }
 };
 
-async function GetCdkMakes(socket, cdk_dealerid) {
-  CdkBase.createLogEvent(socket, "TRACE", `{1} Begin GetCDkMakes WSDL Call`);
+async function GetCdkMakes(req, cdk_dealerid) {
+  logger.log("cdk-replace-makes-models", "DEBUG", req.user.email, null, {
+    cdk_dealerid,
+  });
 
   try {
     const soapClientVehicleInsert = await soap.createClientAsync(
       CdkWsdl.VehicleInsert
     );
-    const start = performance.now();
 
     const soapResponseVehicleSearch =
       await soapClientVehicleInsert.getMakeModelAsync(
@@ -51,28 +120,25 @@ async function GetCdkMakes(socket, cdk_dealerid) {
 
         {}
       );
-    CheckCdkResponseForError(socket, soapResponseVehicleSearch);
+
+    CheckCdkResponseForError(null, soapResponseVehicleSearch);
     const [
       result, //rawResponse, soapheader, rawRequest
     ] = soapResponseVehicleSearch;
-    const end = performance.now();
-    CdkBase.createLogEvent(
-      socket,
-      "TRACE",
-      `soapClientVehicleInsert.getMakeModelAsync Result Length ${
-        result.return.length
-      } and took ${end - start}ms`
+
+    return result.return;
+  } catch (error) {
+    logger.log(
+      "cdk-replace-makes-models-error",
+      "ERROR",
+      req.user.email,
+      null,
+      {
+        cdk_dealerid,
+        error,
+      }
     );
 
-    return result.return.map((element, index) => {
-      return { id: index, ...element };
-    });
-  } catch (error) {
-    CdkBase.createLogEvent(
-      socket,
-      "ERROR",
-      `Error in GetCdkMakes - ${JSON.stringify(error, null, 2)}`
-    );
     throw new Error(error);
   }
 }

server/cdk/cdk-wsdl.js

@@ -78,11 +78,11 @@ exports.checkIndividualResult = checkIndividualResult;
 const cdkDomain = "https://uat-3pa.dmotorworks.com";
 exports.default = {
   // VehicleSearch: `${cdkDomain}/pip-vehicle/services/VehicleSearch?wsdl`,
+  AccountingGLInsertUpdate: `${cdkDomain}/pip-accounting-gl/services/AccountingGLInsertUpdate?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`,
-  VehicleInsert: `${cdkDomain}/pip-vehicle/services/VehicleInsertUpdate?wsdl`,
 };
 
 // The following login credentials will be used for all PIPs and all environments (User Acceptance Testing and Production).

server/graphql-client/queries.js

@@ -133,6 +133,7 @@ query QUERY_JOBS_FOR_CDK_EXPORT($id: uuid!) {
     ownr_fn
     ownr_addr1
     ownr_addr2
+    ownr_ph1
     ownr_zip
     ownr_city
     ownr_st
@@ -932,6 +933,19 @@ exports.GET_AUTOHOUSE_SHOPS = `query GET_AUTOHOUSE_SHOPS {
       imexshopid
   }
 }
+`;
+exports.DELETE_ALL_DMS_VEHICLES = `mutation DELETE_ALL_DMS_VEHICLES{
+  delete_dms_vehicles(where: {}) {
+    affected_rows
+  }
+}
+`;
+exports.INSERT_DMS_VEHICLES = `mutation INSERT_DMS_VEHICLES($vehicles: [dms_vehicles_insert_input!]!) {
+  insert_dms_vehicles(objects: $vehicles) {
+affected_rows
+  }
+}
+
 `;
 
 exports.GET_CDK_ALLOCATIONS = `

server/web-sockets/web-socket.js

@@ -8,7 +8,10 @@ require("dotenv").config({
 
 const { io } = require("../../server");
 const { admin } = require("../firebase/firebase-handler");
-const CdkJobExport = require("../cdk/cdk-job-export").default;
+const {
+  default: CdkJobExport,
+  CdkSelectedCustomer,
+} = require("../cdk/cdk-job-export");
 const CdkGetMakes = require("../cdk/cdk-get-makes").default;
 const CdkCalculateAllocations =
   require("../cdk/cdk-calculate-allocations").default;
@@ -60,7 +63,7 @@ io.on("connection", (socket) => {
       `User selected customer ID  ${selectedCustomerId}`
     );
     socket.selectedCustomerId = selectedCustomerId;
-    //CdkJobExport(socket, jobid);
+    CdkSelectedCustomer(socket, selectedCustomerId);
   });
 
   socket.on("cdk-get-makes", async (cdk_dealerid, callback) => {
@@ -123,8 +126,40 @@ function createLogEvent(socket, level, message) {
   }
 }
 
+function createXmlEvent(socket, xml, message, isError = false) {
+  if (LogLevelHierarchy(socket.log_level) >= LogLevelHierarchy("TRACE")) {
+    socket.emit("log-event", {
+      timestamp: new Date(),
+      level: isError ? "ERROR" : "TRACE",
+      message: `${message}: ${xml}`,
+    });
+  }
+
+  logger.log(
+    isError ? "ws-log-event-xml-error" : "ws-log-event-xml",
+    isError ? "ERROR" : "TRACE",
+    socket.user.email,
+    socket.recordid,
+    {
+      wsmessage: message,
+      xml,
+    }
+  );
+
+  if (socket.logEvents && isArray(socket.logEvents)) {
+    socket.logEvents.push({
+      timestamp: new Date(),
+      level: isError ? "ERROR" : "TRACE",
+      message,
+      xml,
+    });
+  }
+}
+
 function LogLevelHierarchy(level) {
   switch (level) {
+    case "XML":
+      return 5;
     case "TRACE":
       return 5;
     case "DEBUG":
@@ -141,3 +176,4 @@ function LogLevelHierarchy(level) {
 }
 
 exports.createLogEvent = createLogEvent;
+exports.createXmlEvent = createXmlEvent;