From db5b11f6d3f5baa25797c25c30c889d97578a06e Mon Sep 17 00:00:00 2001
From: Patrick Fic <>
Date: Tue, 24 Aug 2021 18:14:41 -0700
Subject: [PATCH] IO-233 Vehicle and Customer posting unit testing completed.

---
 .../dms-customer-selector.component.jsx       |  10 +-
 .../dms-post-form/dms-post-form.component.jsx |   7 +-
 server/cdk/cdk-job-export.js                  | 230 ++++++++++++------
 server/graphql-client/queries.js              |   1 +
 server/web-sockets/web-socket.js              |  12 +-
 5 files changed, 179 insertions(+), 81 deletions(-)

diff --git a/client/src/components/dms-customer-selector/dms-customer-selector.component.jsx b/client/src/components/dms-customer-selector/dms-customer-selector.component.jsx
index 3ff30fb00..46be3d6d3 100644
--- a/client/src/components/dms-customer-selector/dms-customer-selector.component.jsx
+++ b/client/src/components/dms-customer-selector/dms-customer-selector.component.jsx
@@ -38,7 +38,7 @@ export function DmsCustomerSelector({ bodyshop }) {
     setVisible(false);
     socket.emit(
       "cdk-selected-customer",
-      bodyshop.cdk_configuration.generic_customer_umber
+      bodyshop.cdk_configuration.generic_customer_number
     );
   };
 
@@ -69,14 +69,16 @@ export function DmsCustomerSelector({ bodyshop }) {
     <Table
       title={() => (
         <div>
-          <Button onClick={onUseSelected}>
+          <Button onClick={onUseSelected} disabled={!selectedCustomer}>
             {t("jobs.actions.dms.useselected")}
           </Button>
           <Button
             onClick={onUseGeneric}
             disabled={
-              !bodyshop.cdk_configuration &&
-              !bodyshop.cdk_configuration.generic_customer_umber
+              !(
+                bodyshop.cdk_configuration &&
+                bodyshop.cdk_configuration.generic_customer_number
+              )
             }
           >
             {t("jobs.actions.dms.usegeneric")}
diff --git a/client/src/components/dms-post-form/dms-post-form.component.jsx b/client/src/components/dms-post-form/dms-post-form.component.jsx
index 27bffaf00..5e0df3c0a 100644
--- a/client/src/components/dms-post-form/dms-post-form.component.jsx
+++ b/client/src/components/dms-post-form/dms-post-form.component.jsx
@@ -49,10 +49,11 @@ export function DmsPostForm({ bodyshop, socket, job }) {
       }),
     });
   };
+  console.log("🚀  ~ file: dms-post-form.component.jsx  ~ line 58  ~ job", job);
 
   const handleFinish = (values) => {
     socket.emit(`${determineDmsType(bodyshop)}-export-job`, {
-      jobId: job.id,
+      jobid: job.id,
       txEnvelope: values,
     });
   };
@@ -274,7 +275,9 @@ export function DmsPostForm({ bodyshop, socket, job }) {
                 }}
                 value={discrep.toFormat()}
               />
-              <Button disabled={discrep.getAmount() !== 0} htmlType="submit">
+              <Button //disabled={discrep.getAmount() !== 0} //TODO: REMOVE THIS COMMENT.
+                htmlType="submit"
+              >
                 {t("jobs.actions.dms.post")}
               </Button>
               <Button
diff --git a/server/cdk/cdk-job-export.js b/server/cdk/cdk-job-export.js
index 4434a3d6a..c7a2266a8 100644
--- a/server/cdk/cdk-job-export.js
+++ b/server/cdk/cdk-job-export.js
@@ -26,16 +26,17 @@ exports.default = async function (socket, { txEnvelope, jobid }) {
     );
 
     const JobData = await QueryJobData(socket, jobid);
+    socket.JobData = JobData;
     const DealerId = JobData.bodyshop.cdk_dealerid;
     CdkBase.createLogEvent(
       socket,
-      "TRACE",
+      "DEBUG",
       `Dealer ID detected: ${JSON.stringify(DealerId)}`
     );
 
     CdkBase.createLogEvent(
       socket,
-      "TRACE",
+      "DEBUG",
       `{1} Begin Calculate DMS Vehicle ID using VIN: ${JobData.v_vin}`
     );
     socket.DMSVid = await CalculateDmsVid(socket, JobData);
@@ -43,38 +44,38 @@ exports.default = async function (socket, { txEnvelope, jobid }) {
     if (socket.DMSVid.newId === "N") {
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
-        `{2.1} Querying the Vehicle using the DMSVid: ${socket.DmsVid}`
+        "DEBUG",
+        `{2.1} Querying the Vehicle using the DMSVid: ${socket.DMSVid}`
       );
       socket.DMSVeh = await QueryDmsVehicleById(socket, JobData, socket.DMSVid);
 
-      const DmsVehCustomerId =
+      const DMSVehCustomer =
         socket.DMSVeh &&
-        socket.DMSVeh.owners.find((o) => o.assigningPartyId === "CURRENT");
+        socket.DMSVeh.owners.find((o) => o.id.assigningPartyId === "CURRENT");
 
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
-        `{2.2} Querying the Customer using the ID from DMSVeh: ${DmsVehCustomerId}`
+        "DEBUG",
+        `{2.2} Querying the Customer using the ID from DMSVeh: ${DMSVehCustomer.id.value}`
       );
-      socket.DmsVehCustomer = await QueryDmsCustomerById(
+      socket.DMSVehCustomer = await QueryDmsCustomerById(
         socket,
         JobData,
-        DmsVehCustomerId
+        DMSVehCustomer.id.value
       );
     }
 
     CdkBase.createLogEvent(
       socket,
-      "TRACE",
+      "DEBUG",
       `{2.3} Querying the Customer using the name.`
     );
 
-    socket.DmsCustList = await QueryDmsCustomerByName(socket, JobData);
+    socket.DMSCustList = await QueryDmsCustomerByName(socket, JobData);
 
     socket.emit("cdk-select-customer", [
-      ...(socket.DmsVehCustomer ? socket.DmsVehCustomer : []),
-      ...socket.DmsCustList,
+      ...(socket.DMSVehCustomer ? [socket.DMSVehCustomer] : []),
+      ...socket.DMSCustList,
     ]);
   } catch (error) {
     CdkBase.createLogEvent(
@@ -98,45 +99,55 @@ async function CdkSelectedCustomer(socket, selectedCustomerId) {
     if (selectedCustomerId) {
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
+        "DEBUG",
         `{3.1} Querying the Customer using Customer ID: ${selectedCustomerId}`
       );
       socket.DMSCust = await QueryDmsCustomerById(socket, selectedCustomerId);
     } else {
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
+        "DEBUG",
         `{3.2} Generating a new customer ID.`
       );
-      const newCustomerId = await GenerateDmsCustomerNumber(
-        socket,
-        socket.JobData
-      );
+      const newCustomerId = await GenerateDmsCustomerNumber(socket);
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
+        "DEBUG",
         `{3.3} Inserting new customer with ID: ${newCustomerId}`
       );
-      socket.DMSCust = await InsertDmsCustomer(
-        socket,
-        socket.JobData,
-        newCustomerId
-      );
+      socket.DMSCust = await InsertDmsCustomer(socket, newCustomerId);
     }
 
     if (socket.DMSVid.newId === "Y") {
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
+        "DEBUG",
         `{4.1} Inserting new vehicle with ID: ID ${socket.DMSVid.vehiclesVehId}`
       );
+      socket.DMSVeh = await InsertDmsVehicle(socket);
     } else {
       CdkBase.createLogEvent(
         socket,
-        "TRACE",
+        "DEBUG",
         `{4.2} Querying Existing Vehicle using ID ${socket.DMSVid.vehiclesVehId}`
       );
+      socket.DMSVeh = await QueryDmsVehicleById(
+        socket,
+        socket.JobData,
+        socket.DMSVid
+      );
+      CdkBase.createLogEvent(
+        socket,
+        "DEBUG",
+        `{4.3} Updating Existing Vehicle to associate to owner.`
+      );
+      socket.DMSVeh = await UpdateDmsVehicle(socket);
     }
+    CdkBase.createLogEvent(
+      socket,
+      "DEBUG",
+      `{5} Updating Service Vehicle History.`
+    );
   } catch (error) {
     CdkBase.createLogEvent(
       socket,
@@ -181,7 +192,7 @@ async function CalculateDmsVid(socket, JobData) {
         arg1: { id: JobData.bodyshop.cdk_dealerid },
         arg2: { VIN: JobData.v_vin },
       });
-    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
+
     const [result, rawResponse, , rawRequest] = soapResponseVehicleInsertUpdate;
     CdkBase.createXmlEvent(
       socket,
@@ -204,9 +215,8 @@ async function CalculateDmsVid(socket, JobData) {
         2
       )}`
     );
-
-    const DmsVid = result && result.return && result.return[0];
-    return DmsVid;
+    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
+    return result && result.return && result.return[0];
   } catch (error) {
     CdkBase.createXmlEvent(
       socket,
@@ -217,7 +227,7 @@ async function CalculateDmsVid(socket, JobData) {
 
     CdkBase.createXmlEvent(
       socket,
-      error.response.data,
+      error.response && error.response.data,
       `soapClientVehicleInsertUpdate.getVehIdsAsync response.`,
       true
     );
@@ -245,7 +255,7 @@ async function QueryDmsVehicleById(socket, JobData, DMSVid) {
           vehiclesVehicleId: DMSVid.vehiclesVehId,
         },
       });
-    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
+
     const [result, rawResponse, , rawRequest] = soapResponseVehicleInsertUpdate;
 
     CdkBase.createXmlEvent(
@@ -268,6 +278,7 @@ async function QueryDmsVehicleById(socket, JobData, DMSVid) {
       rawResponse,
       `soapClientVehicleInsertUpdate.readAsync response.`
     );
+    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
     const VehicleFromDMS = result && result.return && result.return.vehicle;
     return VehicleFromDMS;
   } catch (error) {
@@ -290,10 +301,11 @@ async function QueryDmsCustomerById(socket, JobData, CustomerId) {
         arg0: CDK_CREDENTIALS,
         arg1: { dealerId: JobData.bodyshop.cdk_dealerid }, //TODO: Verify why this does not follow the other standards.
         arg2: {
-          userId: CustomerId,
+          // userId: CustomerId,
         },
+        arg3: CustomerId,
       });
-    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
+
     const [result, rawResponse, , rawRequest] =
       soapResponseCustomerInsertUpdate;
 
@@ -317,7 +329,7 @@ async function QueryDmsCustomerById(socket, JobData, CustomerId) {
         2
       )}`
     );
-
+    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
     const CustomersFromDms =
       result && result.return && result.return.customerParty;
     return CustomersFromDms;
@@ -331,7 +343,7 @@ async function QueryDmsCustomerById(socket, JobData, CustomerId) {
 
     CdkBase.createXmlEvent(
       socket,
-      error.response.data,
+      error.response && error.response.data,
       `soapClientCustomerInsertUpdate.readAsync response.`,
       true
     );
@@ -366,7 +378,7 @@ async function QueryDmsCustomerByName(socket, JobData) {
           key: ownerName,
         },
       });
-    CheckCdkResponseForError(socket, soapResponseCustomerSearch);
+
     const [result, rawResponse, , rawRequest] = soapResponseCustomerSearch;
 
     CdkBase.createXmlEvent(
@@ -390,6 +402,7 @@ async function QueryDmsCustomerByName(socket, JobData) {
         2
       )}`
     );
+    CheckCdkResponseForError(socket, soapResponseCustomerSearch);
     const CustomersFromDms = (result && result.return) || [];
     return CustomersFromDms;
   } catch (error) {
@@ -402,7 +415,7 @@ async function QueryDmsCustomerByName(socket, JobData) {
 
     CdkBase.createXmlEvent(
       socket,
-      error.response.data,
+      error.response && error.response.data,
       `soapClientCustomerSearch.executeSearchBulkAsync response.`,
       true
     );
@@ -416,7 +429,7 @@ async function QueryDmsCustomerByName(socket, JobData) {
   }
 }
 
-async function GenerateDmsCustomerNumber(socket, JobData) {
+async function GenerateDmsCustomerNumber(socket) {
   try {
     const soapClientCustomerInsertUpdate = await soap.createClientAsync(
       CdkWsdl.CustomerInsertUpdate
@@ -425,13 +438,13 @@ async function GenerateDmsCustomerNumber(socket, JobData) {
       await soapClientCustomerInsertUpdate.getCustomerNumberAsync(
         {
           arg0: CDK_CREDENTIALS,
-          arg1: { dealerId: JobData.bodyshop.cdk_dealerid }, //TODO: Verify why this does not follow the other standards.
+          arg1: { dealerId: socket.JobData.bodyshop.cdk_dealerid }, //TODO: Verify why this does not follow the other standards.
           arg2: { userId: null },
         },
 
         {}
       );
-    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
+
     const [result, rawResponse, , rawRequest] =
       soapResponseCustomerInsertUpdate;
 
@@ -456,6 +469,7 @@ async function GenerateDmsCustomerNumber(socket, JobData) {
         2
       )}`
     );
+    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
     const customerNumber =
       result && result.return && result.return.customerNumber;
     return customerNumber;
@@ -469,20 +483,20 @@ async function GenerateDmsCustomerNumber(socket, JobData) {
 
     CdkBase.createXmlEvent(
       socket,
-      error.response.data,
+      error.response && error.response.data,
       `soapClientCustomerInsertUpdate.getCustomerNumberAsync response.`,
       true
     );
     CdkBase.createLogEvent(
       socket,
       "ERROR",
-      `Error in GenerateDmsCustomerNumber - ${JSON.stringify(error, null, 2)}`
+      `Error in GenerateDmsCustomerNumber - ${error}`
     );
     throw new Error(error);
   }
 }
 
-async function InsertDmsCustomer(socket, JobData, newCustomerNumber) {
+async function InsertDmsCustomer(socket, newCustomerNumber) {
   try {
     const soapClientCustomerInsertUpdate = await soap.createClientAsync(
       CdkWsdl.CustomerInsertUpdate
@@ -491,27 +505,31 @@ async function InsertDmsCustomer(socket, JobData, newCustomerNumber) {
       await soapClientCustomerInsertUpdate.insertAsync(
         {
           arg0: CDK_CREDENTIALS,
-          arg1: { dealerId: JobData.bodyshop.cdk_dealerid }, //TODO: Verify why this does not follow the other standards.
+          arg1: { dealerId: socket.JobData.bodyshop.cdk_dealerid }, //TODO: Verify why this does not follow the other standards.
           arg2: { userId: null },
           arg3: {
             //Copied the required fields from the other integration.
             //TODO: Verify whether we need to bring more information in.
             id: { value: newCustomerNumber },
             address: {
-              city: JobData.ownr_city,
+              addressLine: socket.JobData.ownr_addr1,
+              city: socket.JobData.ownr_city,
               country: null,
-              postalcode: JobData.ownr_zip,
-              stateOrProvince: JobData.ownr_st,
+              postalCode: socket.JobData.ownr_zip,
+              stateOrProvince: socket.JobData.ownr_st,
             },
             contactInfo: {
-              mainTelephoneNumber: { main: true, value: JobData.ownr_ph1 },
+              mainTelephoneNumber: {
+                main: true,
+                value: socket.JobData.ownr_ph1,
+              },
             },
             demographics: null,
             name1: {
-              companyname: JobData.ownr_co_nm,
-              firstName: JobData.ownr_fn,
+              companyname: socket.JobData.ownr_co_nm,
+              firstName: socket.JobData.ownr_fn,
               fullname: null,
-              lastName: JobData.ownr_ln,
+              lastName: socket.JobData.ownr_ln,
               middleName: null,
               nameType: "Person",
               suffix: null,
@@ -522,7 +540,7 @@ async function InsertDmsCustomer(socket, JobData, newCustomerNumber) {
 
         {}
       );
-    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
+
     const [result, rawResponse, , rawRequest] =
       soapResponseCustomerInsertUpdate;
     CdkBase.createXmlEvent(
@@ -545,7 +563,8 @@ async function InsertDmsCustomer(socket, JobData, newCustomerNumber) {
         2
       )}`
     );
-    const customer = result && result.return;
+    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
+    const customer = result && result.return && result.return.customerParty;
     return customer;
   } catch (error) {
     CdkBase.createXmlEvent(
@@ -557,7 +576,7 @@ async function InsertDmsCustomer(socket, JobData, newCustomerNumber) {
 
     CdkBase.createXmlEvent(
       socket,
-      error.response.data,
+      error.response && error.response.data,
       `soapClientCustomerInsertUpdate.insertAsync response.`,
       true
     );
@@ -570,7 +589,7 @@ async function InsertDmsCustomer(socket, JobData, newCustomerNumber) {
   }
 }
 
-async function InsertDmsVehicle(socket, JobData) {
+async function InsertDmsVehicle(socket) {
   try {
     const soapClientVehicleInsertUpdate = await soap.createClientAsync(
       CdkWsdl.VehicleInsertUpdate
@@ -579,31 +598,33 @@ async function InsertDmsVehicle(socket, JobData) {
     const soapResponseVehicleInsertUpdate =
       await soapClientVehicleInsertUpdate.insertAsync({
         arg0: CDK_CREDENTIALS,
-        arg1: { id: JobData.bodyshop.cdk_dealerid },
+        arg1: { id: socket.JobData.bodyshop.cdk_dealerid },
         arg2: {
           dealer: {
-            dealerNumber: JobData.bodyshop.cdk_dealerid,
-            VehicleId: socket.DmsVehId.vehiclesVehId,
+            dealerNumber: socket.JobData.bodyshop.cdk_dealerid,
+            inServiceDate: moment().startOf("day").toISOString(),
+            vehicleId: socket.DMSVid.vehiclesVehId,
           },
           manufacturer: {},
           vehicle: {
-            DeliveryDate: moment().format("YYYYMMDD"),
-            Make: socket.txEnvelope.dms_make,
-            Model: socket.txEnvelope.dms_model,
-            ModelYear: JobData.v_model_yr,
-            OdometerStatus: socket.txEnvelope.kmout,
-            SaleClassValue: "MISC",
-            VIN: JobData.v_vin,
+            deliveryDate: moment().format("YYYYMMDD"),
+            make: socket.txEnvelope.dms_make,
+            modelAbrev: socket.txEnvelope.dms_model,
+            modelYear: socket.JobData.v_model_yr,
+            odometerStatus: socket.txEnvelope.kmout,
+            saleClassValue: "MISC",
+            VIN: socket.JobData.v_vin,
           },
           owners: {
             id: {
               assigningPartyId: "CURRENT",
-              value: socket.DmsCust.id.value,
+              value: socket.DMSCust.id.value,
             },
           },
         },
+        arg3: "VEHICLES",
       });
-    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
+
     const [result, rawResponse, , rawRequest] = soapResponseVehicleInsertUpdate;
 
     CdkBase.createXmlEvent(
@@ -626,6 +647,75 @@ async function InsertDmsVehicle(socket, JobData) {
       rawResponse,
       `soapClientVehicleInsertUpdate.insertAsync response.`
     );
+    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
+    const VehicleFromDMS = result && result.return && result.return.vehicle;
+    return VehicleFromDMS;
+  } catch (error) {
+    CdkBase.createLogEvent(
+      socket,
+      "ERROR",
+      `Error in QueryDmsVehicleById - ${error}`
+    );
+    throw new Error(error);
+  }
+}
+
+async function UpdateDmsVehicle(socket) {
+  try {
+    const soapClientVehicleInsertUpdate = await soap.createClientAsync(
+      CdkWsdl.VehicleInsertUpdate
+    );
+
+    const soapResponseVehicleInsertUpdate =
+      await soapClientVehicleInsertUpdate.updateAsync({
+        arg0: CDK_CREDENTIALS,
+        arg1: { id: socket.JobData.bodyshop.cdk_dealerid },
+        arg2: {
+          ...socket.DMSVeh,
+          dealer: {
+            ...socket.DMSVeh.dealer,
+            inServiceDate: moment(
+              socket.DMSVeh.dealer.inServiceDate
+            ).toISOString(),
+          },
+          vehicle: {
+            ...socket.DMSVeh.vehicle,
+            deliveryDate: moment(
+              socket.DMSVeh.vehicle.deliveryDate
+            ).toISOString(),
+          },
+          owners: {
+            id: {
+              assigningPartyId: "CURRENT",
+              value: socket.DMSCust.id.value,
+            },
+          },
+        },
+        arg3: "VEHICLES",
+      });
+    const [result, rawResponse, , rawRequest] = soapResponseVehicleInsertUpdate;
+
+    CdkBase.createXmlEvent(
+      socket,
+      rawRequest,
+      `soapClientVehicleInsertUpdate.updateAsync reqest.`
+    );
+
+    CdkBase.createLogEvent(
+      socket,
+      "TRACE",
+      `soapClientVehicleInsertUpdate.updateAsync Result ${JSON.stringify(
+        result,
+        null,
+        2
+      )}`
+    );
+    CdkBase.createXmlEvent(
+      socket,
+      rawResponse,
+      `soapClientVehicleInsertUpdate.updateAsync response.`
+    );
+    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
     const VehicleFromDMS = result && result.return && result.return.vehicle;
     return VehicleFromDMS;
   } catch (error) {
diff --git a/server/graphql-client/queries.js b/server/graphql-client/queries.js
index 726e34bec..59a886dc1 100644
--- a/server/graphql-client/queries.js
+++ b/server/graphql-client/queries.js
@@ -132,6 +132,7 @@ query QUERY_JOBS_FOR_CDK_EXPORT($id: uuid!) {
     ownr_fn
     ownr_addr1
     ownr_addr2
+    ownr_ph1
     ownr_zip
     ownr_city
     ownr_st
diff --git a/server/web-sockets/web-socket.js b/server/web-sockets/web-socket.js
index 14f615281..c822f42e7 100644
--- a/server/web-sockets/web-socket.js
+++ b/server/web-sockets/web-socket.js
@@ -127,11 +127,13 @@ function createLogEvent(socket, level, message) {
 }
 
 function createXmlEvent(socket, xml, message, isError = false) {
-  socket.emit("log-event", {
-    timestamp: new Date(),
-    level: isError ? "ERROR" : "TRACE",
-    message: `${message}: ${xml}`,
-  });
+  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",