IO-1269

server/data/autohouse.js

@@ -4,7 +4,7 @@ const Dinero = require("dinero.js");
 const moment = require("moment");
 var builder = require("xmlbuilder2");
 const _ = require("lodash");
-
+const logger = require("../utils/logger");
 require("dotenv").config({
   path: path.resolve(
     process.cwd(),
@@ -25,7 +25,7 @@ const ftpSetup = {
   port: process.env.AUTOHOUSE_PORT,
   username: process.env.AUTOHOUSE_USER,
   password: process.env.AUTOHOUSE_PASSWORD,
-  debug: console.log,
+  debug: (message, ...data) => logger.log(message, "DEBUG", "api", null, data),
   algorithms: {
     serverHostKey: ["ssh-rsa", "ssh-dss"],
   },
@@ -33,14 +33,16 @@ const ftpSetup = {
 
 exports.default = async (req, res) => {
   //Query for the List of Bodyshop Clients.
-  console.log("Starting Autohouse datapump request.");
+  logger.log("autohouse-start", "DEBUG", "api", null, null);
   const { bodyshops } = await client.request(queries.GET_AUTOHOUSE_SHOPS);
 
   const allxmlsToUpload = [];
   const allErrors = [];
   try {
     for (const bodyshop of bodyshops) {
-      console.log("Starting extract for ", bodyshop.shopname);
+      logger.log("autohouse-start-shop-extract", "DEBUG", "api", bodyshop.id, {
+        shopname: bodyshop.shopname,
+      });
       const erroredJobs = [];
       try {
         const { jobs } = await client.request(queries.AUTOHOUSE_QUERY, {
@@ -60,12 +62,12 @@ exports.default = async (req, res) => {
           },
         };
 
-        console.log(
-          bodyshop.shopname,
-          "***Number of Failed jobs***: ",
-          erroredJobs.length,
-          JSON.stringify(erroredJobs.map((j) => j.job.ro_number))
-        );
+        if (erroredJobs.length > 0) {
+          logger.log("autohouse-failed-jobs", "ERROR", "api", bodyshop.id, {
+            count: erroredJobs.length,
+            jobs: JSON.stringify(erroredJobs.map((j) => j.job.ro_number)),
+          });
+        }
 
         var ret = builder
           .create(autoHouseObject, {
@@ -81,10 +83,15 @@ exports.default = async (req, res) => {
           )}.xml`,
         });
 
-        console.log("Finished extract for shop ", bodyshop.shopname);
+        logger.log("autohouse-end-shop-extract", "DEBUG", "api", bodyshop.id, {
+          shopname: bodyshop.shopname,
+        });
       } catch (error) {
         //Error at the shop level.
-        console.log("Error at shop level", bodyshop.shopname, error);
+        logger.log("autohouse-error-shop", "ERROR", "api", bodyshop.id, {
+          error,
+        });
+
         allErrors.push({
           bodyshopid: bodyshop.id,
           imexshopid: bodyshop.imexshopid,
@@ -102,7 +109,9 @@ exports.default = async (req, res) => {
 
     let sftp = new Client();
     sftp.on("error", (errors) =>
-      console.log("Error in FTP client", JSON.stringify(errors))
+      logger.log("autohouse-sftp-error", "ERROR", "api", null, {
+        errors,
+      })
     );
     try {
       //Connect to the FTP and upload all.
@@ -110,20 +119,24 @@ exports.default = async (req, res) => {
       await sftp.connect(ftpSetup);
 
       for (const xmlObj of allxmlsToUpload) {
-        console.log("Uploading", xmlObj.filename);
+        logger.log("autohouse-sftp-upload", "DEBUG", "api", null, {
+          filename: xmlObj.filename,
+        });
+
         const uploadResult = await sftp.put(
           Buffer.from(xmlObj.xml),
           `/${xmlObj.filename}`
         );
-        console.log(
-          "🚀  ~ file: autohouse.js  ~ line 94  ~ uploadResult",
-          uploadResult
-        );
+        logger.log("autohouse-sftp-upload-result", "DEBUG", "api", null, {
+          uploadResult,
+        });
       }
 
       //***TODO  Change filing naming when creating the cron job. IM_ShopInternalName_DDMMYYYY_HHMMSS.xml
     } catch (error) {
-      console.log("Error when connecting to FTP", error);
+      logger.log("autohouse-sftp-error", "ERROR", "api", null, {
+        error,
+      });
     } finally {
       sftp.end();
     }
@@ -498,7 +511,10 @@ const CreateRepairOrderTag = (job, errorCallback) => {
     };
     return ret;
   } catch (error) {
-    console.log("Error calculating job", error);
+    logger.log("autohouse-job-calculate-error", "ERROR", "api", null, {
+      error,
+    });
+
     errorCallback({ job, error });
   }
 };
@@ -510,7 +526,7 @@ const CreateCosts = (job) => {
     //At the bill level.
     bill_val.billlines.map((line_val) => {
       //At the bill line level.
-      //console.log("JobCostingPartsTable -> line_val", line_val);
+
       if (!bill_acc[line_val.cost_center])
         bill_acc[line_val.cost_center] = Dinero();