const path = require("path");
const _ = require("lodash");
const xml2js = require("xml2js");
const queries = require("../graphql-client/queries");
const logger = require("../utils/logger");

require("dotenv").config({
  path: path.resolve(process.cwd(), `.env.${process.env.NODE_ENV || "development"}`)
});

exports.mixdataUpload = async (req, res) => {
  const client = req.userGraphQLClient;

  logger.log("job-mixdata-upload", "DEBUG", req?.user?.email, null, null);

  try {
    for (const element of req.files) {
      const b = Buffer.from(element.buffer);

      const inboundRequest = await xml2js.parseStringPromise(b.toString(), {
        explicitArray: false
      });

      logger.log("job-mixdata-parse", "DEBUG", req?.user?.email, null, { inboundRequest });

      const ScaleType = DetermineScaleType(inboundRequest);
      const RoNumbersFromInboundRequest = GetListOfRos(inboundRequest, ScaleType);

      if (RoNumbersFromInboundRequest.length > 0) {
        //Query the list of ROs based on the RO number.
        const { jobs } = await client.request(queries.QUERY_JOB_ID_MIXDATA, {
          roNumbers: RoNumbersFromInboundRequest
        });

        //Create the hash for faster processing for inserts/updates.
        const jobHash = {};
        jobs.forEach((j) => {
          jobHash[j.ro_number] = {
            jobid: j.id,
            mixdataid: j.mixdata.length > 0 ? j.mixdata[0].id : null
          };
        });
        const MixDataArray = GenerateMixDataArray(inboundRequest, ScaleType, jobHash);
        const foundJobs = MixDataArray.filter((m) => m.jobid);
        const MixDataQuery = `
        mutation UPSERT_MIXDATA{
            ${foundJobs.map((md, idx) => GenerateGqlForMixData(md, idx)).join(" ")}
        }
        `;
        if (foundJobs.length > 1) {
          const resp = await client.request(MixDataQuery);
        }

        //Process the list of ROs and return an object to generate the queries.
      }
    }
    res.sendStatus(200);
  } catch (error) {
    res.status(500).json(error);
    logger.log("job-mixdata-upload-error", "ERROR", null, null, {
      error: error.message,
      stack: error.stack
    });
  }
};

function DetermineScaleType(inboundRequest) {
  const ret = { type: "", verson: 0 };

  //PPG Mix Data
  if (inboundRequest?.PPG?.Header?.Protocol?.Name === "PPG") {
    return {
      type: inboundRequest.PPG.Header.Protocol.Name,
      company: "PPG",
      version: inboundRequest.PPG.Header.Protocol.Version
    };
  }
}

function GetListOfRos(inboundRequest, ScaleType) {
  if (ScaleType?.company === "PPG" && ScaleType?.version === "1.3.0") {
    return inboundRequest.PPG.MixDataInterface.ROData.RepairOrders.RO.map((r) => r.RONumber);
  }
}

function GenerateMixDataArray(inboundRequest, ScaleType, jobHash) {
  if (ScaleType?.company === "PPG" && ScaleType?.version === "1.3.0") {
    return inboundRequest.PPG.MixDataInterface.ROData.RepairOrders.RO.map((r) => {
      return {
        jobid: jobHash[r.RONumber]?.jobid,
        id: jobHash[r.RONumber]?.mixdataid,
        mixdata: r,
        totalliquidcost: r.TotalLiquidCost,
        totalsundrycost: r.TotalSundryCost,
        company: ScaleType.company,
        version: ScaleType.version
      };
    });
  }
}

function GenerateGqlForMixData(mixdata, key) {
  const { id, ...restMixData } = mixdata;

  if (id) {
    //Update.
    return `
   update${key}: update_mixdata_by_pk(pk_columns:{id: "${id}"}, _set: ${JSON.stringify(restMixData).replace(
     /"(\w+)"\s*:/g,
     "$1:"
   )}){
        id
      }
    `;
  } else {
    //Insert
    return `
   insert${key}: insert_mixdata_one(object: ${JSON.stringify(restMixData).replace(/"(\w+)"\s*:/g, "$1:")}){
        id
      }
    `;
  }
}