IO-3210 Podium Datapump

Signed-off-by: Allan Carr <allan.carr@thinkimex.com>

server/data/data.js

@@ -4,5 +4,4 @@ exports.chatter = require("./chatter").default;
 exports.claimscorp = require("./claimscorp").default;
 exports.kaizen = require("./kaizen").default;
 exports.usageReport = require("./usageReport").default;
-exports.podium = require("./podium").default;
-exports.emsUpload = require("./emsUpload").default;
+exports.podium = require("./podium").default;

server/data/emsUpload.js

@@ -1,22 +0,0 @@
-const moment = require("moment-timezone");
-const logger = require("../utils/logger");
-const s3Client = require("../utils/s3"); // Using the S3 client utilities with LocalStack support
-
-const emsUpload = async (req, res) => {
-    try {
-        const { bodyshopid, ciecaid, clm_no, ownr_ln } = req.body;
-        const presignedUrl = await s3Client.getPresignedUrl({
-            bucketName: process.env.S3_EMS_UPLOAD_BUCKET,
-            key: `${bodyshopid}/${ciecaid}-${clm_no}-${ownr_ln}-${moment().format("YYYY-MM-DD--HH-mm-ss")}.zip`
-        });
-        res.status(200).json({ presignedUrl });
-    } catch (error) {
-        logger.log("ems-upload-presign-error", "ERROR", req?.user?.email, null, {
-            error: error.message,
-            stack: error.stack
-        });
-        res.status(500).json({ error: error.message, stack: error.stack });
-    }
-};
-
-exports.default = emsUpload;

server/data/podium.js

@@ -185,7 +185,7 @@ async function uploadViaSFTP(csvObj) {
     await sftp.connect(ftpSetup);
 
     try {
-      csvObj.result = await sftp.put(Buffer.from(csvObj.xml), `${csvObj.filename}`);
+      csvObj.result = await sftp.put(Buffer.from(csvObj.csv), `${csvObj.filename}`);
       logger.log("podium-sftp-upload", "DEBUG", "api", csvObj.bodyshopid, {
         imexshopid: csvObj.imexshopid,
         filename: csvObj.filename,

server/routes/miscellaneousRoutes.js

@@ -138,9 +138,6 @@ router.post("/canvastest", validateFirebaseIdTokenMiddleware, canvastest);
 // Alert Check
 router.post("/alertcheck", eventAuthorizationMiddleware, alertCheck);
 
-//EMS Upload
-router.post("/emsupload", validateFirebaseIdTokenMiddleware, data.emsUpload);
-
 // Redis Cache Routes
 router.post("/bodyshop-cache", eventAuthorizationMiddleware, updateBodyshopCache);
 

server/utils/s3.js

@@ -9,7 +9,6 @@ const {
 const { defaultProvider } = require("@aws-sdk/credential-provider-node");
 const { InstanceRegion } = require("./instanceMgr");
 const { isString, isEmpty } = require("lodash");
-const { getSignedUrl } = require("@aws-sdk/s3-request-presigner");
 
 const createS3Client = () => {
   const S3Options = {
@@ -96,17 +95,6 @@ const createS3Client = () => {
       throw error;
     }
   };
-
-  const getPresignedUrl = async ({ bucketName, key }) => {
-    const command = new PutObjectCommand({
-      Bucket: bucketName,
-      Key: key,
-      StorageClass: "INTELLIGENT_TIERING"
-    });
-    const presignedUrl = await getSignedUrl(s3Client, command, { expiresIn: 360 });
-    return presignedUrl;
-  }
-
   return {
     uploadFileToS3,
     downloadFileFromS3,
@@ -114,12 +102,8 @@ const createS3Client = () => {
     deleteFileFromS3,
     copyFileInS3,
     fileExistsInS3,
-    getPresignedUrl,
     ...s3Client
   };
 };
 
-
-
-
 module.exports = createS3Client();