An error occurred while loading the file. Please try again.
-
Arun Kumar authored0d02a849
import express from "express";import { createProxyMiddleware } from "http-proxy-middleware";import endpoints from "./endpoints/endpoints.js";import easyPay from "./utils/easypay.js";import scheduledJob from "./asessorScheduler.js";import axios from "axios";const app = express();import { v4 as uuidv4 } from 'uuid';import { Worker } from 'worker_threads';//csv parserimport multer from "multer";//const multer = require('multer');import csv from "csv-parser";//const csv = require('csv-parser');import exceljs from "exceljs";//const fs = require('fs');import stream from "stream";// Set up Multer for handling file uploadsconst storage = multer.memoryStorage();const upload = multer({ storage: storage });app.use(express.json());app.use(express.urlencoded({ extended: true }));const port = process.env.PORT || 3000;const targetURL = process.env.TARGET_URL ;const hasuraClientName = process.env.HASURA_CLIENT_NAME ;const hasuraAdminSecret = process.env.HASURA_ADMIN_SECRET ;const REACT_APP_NODE_URL = process.env.REACT_APP_API_URL;// Creating an Axios instance with custom headersconst axiosInstance = axios.create({ baseURL: targetURL, headers: { "x-hasura-admin-secret": hasuraAdminSecret, "Hasura-Client-Name": hasuraClientName // Add any other headers you need },});// Loop through the endpoints and create the corresponding proxy middlewareendpoints.forEach((endpoint) => { app.use( endpoint.route, createProxyMiddleware({ target: targetURL, changeOrigin: true, onProxyReq: (proxyReq, req, res) => { proxyReq.setHeader("x-hasura-admin-secret",hasuraAdminSecret); proxyReq.setHeader("Hasura-Client-Name", hasuraClientName); if (endpoint.requestBody) { const bodyData = JSON.stringify(req.body); proxyReq.setHeader("Content-Length", Buffer.byteLength(bodyData)); } // Set request body if provided if (endpoint.requestBody && req.body) { proxyReq.write(JSON.stringify(req.body)); } proxyReq.end(); }, onError: (err, req, res) => { // Handle errors from the upstream server console.error("Proxy Error:", err.message); res.status(500).send("Proxy Error: " + err.message); }, }) );7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
});
//payment handlers
app.post("/payment/generatelink", (req, res) => {
const payload = req.body;
try {
const response = easyPay.generatePayload(
payload,
process.env.environment === "prod" ? false : true
);
res.status(200).send(response);
} catch (err) {
console.log(err);
res.status(500).send({ message: "Some Error Occured" });
}
});
//payment handlers
app.post("/payment/v2/generatelink", async (req, res) => {
const payload = req.body;
try {
const response = await easyPay.generatePayload(
payload,
process.env.environment === "prod" ? true : true
);
//make api call to insert data
//create payload
const date = new Date();
console.log("date - ", date);
let data = {
object: {
created_by: payload.created_by,
invoice_date: payload.mandatoryFields.invoiceDate,
invoice_id: payload.mandatoryFields.invoiceId,
invoice_time: payload.mandatoryFields.invoiceId,
payer_id: payload.mandatoryFields.payerId,
payer_type: payload.mandatoryFields.payerType,
payment_mode: payload.paymode,
reference_no: response.referenceNo,
transaction_amount: payload.mandatoryFields.transactionAmount,
transaction_date:
date.getDay() + "-" + date.getMonth() + "-" + date.getFullYear(),
transaction_status: "UNPAID",
transaction_time:
date.getHours() + ":" + date.getMinutes(),
},
}
//insert into hasura
console.log("Request payload - ", data);
let config = {
method: "put",
maxBodyLength: Infinity,
url: REACT_APP_NODE_URL+"/rest/saveTransactionRecord",
headers: {
Authorization: "Bearer " + process.env.Authorization,
},
data: data,
};
await axios.request(config)
res.status(200).send(response);
} catch (err) {
console.log(err);
console.error("Error:", err);
console.error("Error message:", err.message);
res.status(500).send({ message: "Some Error Occured" });
}
141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210
});
const bulkUploadAssessorSchedule = '/api/rest/bulkUploadAssessorSchedule';
const bulkUpload = (updateStr) => {
return new Promise(async(resolve) => {
try {
console.log(updateStr);
const response = await axiosInstance.post(targetURL+bulkUploadAssessorSchedule, updateStr);
resolve(response.data.insert_assessor_schedule_bulk_upload.returning);
} catch (error) {
console.error('Error in updating data to bulk upload table:', error.message);
throw error;
}
});
};
// Endpoint for uploading file
app.post('/upload/assessor/schedule', upload.single('file'), async(req, res) => {
if (!req.file) {
return res.status(400).json({ error: 'No file uploaded' });
}
if (!req.body.userId) {
return res.status(400).json({ error: 'UserId is not provided' });
}
try {
const processId = uuidv4();
const validfileHeaders = ["form_id","form_title","application_type","course_type","date","form_status","payment_status","assessor_id"];
const { userId } = req.body;
// Get data from the uploaded file
const fileDataString = req.file.buffer;
const readableStream = stream.Readable.from(fileDataString);
const workbook = new exceljs.Workbook();
await workbook.xlsx.read(readableStream);
const worksheet = workbook.getWorksheet(1); // Assuming the first sheet
const results = [];
const header = [];
// Iterate over rows and columns
worksheet.eachRow((row, rowNumber) => {
const rowData = {};
row.eachCell((cell, colNumber) => {
// Assuming the first row contains headers
if (rowNumber === 1) {
header [colNumber]= cell.value.trim().toLowerCase().replace(/ /g, '_');
} else {
if(validfileHeaders.includes(header [colNumber])) {
var cellValue;
if(header [colNumber] == "form_id"){
cellValue = /\d/.test(cell.value)==true?parseInt(cell.value, 10):0;
rowData["application_id"] = cellValue;
}else if(header [colNumber] == "assessor_id") {
cellValue = /\d/.test(cell.value)==true?parseInt(cell.value, 10):0;
rowData[header [colNumber]] = cellValue;
}else{
cellValue = cell.value;
rowData[header [colNumber]] = cellValue;
}
if(cellValue.length<=1){
console.error("Invalid data format");
throw new BadRequestError("Invalid data format : "+cellValue );
}
}else{
console.error("Invalid file format");
throw new BadRequestError("Invalid file format : "+header [colNumber] );
}
}
});
211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
if(Object.keys(rowData).length !== 0){
if(rowData.assessor_id == undefined){
rowData["assessor_id"]=0;
}
results.push(rowData);
}else{
//Ignore the empty row
}
});
if(results.length===0){
throw new BadRequestError("Invalid file format");
}
results.forEach((item) => {
item["process_id"]=processId;
item["uploaded_by"]=userId;
item["status"]="Pending";
item["uploaded_date"]=new Date().toLocaleString();
});
//{"assessor_schedule_bulk_upload": [{"id": 1,"process_id":1,"uploaded_by":"system","uploaded_date": "2023-11-17","application_id":234,"assessor_id":232}]}
const bulkUploadDetails = bulkUpload({"assessor_schedule_bulk_upload":results});
const worker = new Worker('./backgroundWorker.js');
worker.on('message', (message) => {
console.log(`Background Worker Message: ${message}`);
});
worker.on('error', (error) => {
console.error(`Background Worker Error: ${error}`);
});
worker.on('exit', (code) => {
console.log(`Background Worker exited with code ${code}`);
});
// Process the parsed CSV data
return res.json({ data: results });
} catch (error) {
if (error instanceof BadRequestError) {
console.error(`Caught BadRequestError: ${error.message}`);
console.error(`HTTP Status Code: ${error.statusCode}`);
res.status(400).json({ success: false, error: error.message });
} else {
console.error("Error:", error);
console.error("Error message:", error.message);
res.status(500).json({ success: false, error: error.message });
}
}
});
class BadRequestError extends Error {
constructor(message) {
super(message);
this.name = 'BadRequestError';
this.statusCode = 400; // HTTP status code for Bad Request
Error.captureStackTrace(this, this.constructor);
}
}
// Custom Stream class to create a readable stream from a buffer
class BufferStream {
constructor(buffer) {
this.buffer = buffer;
this.position = 0;
}
read(size) {
if (this.position >= this.buffer.length) {
return null;
}
const chunk = this.buffer.slice(this.position, this.position + size);
this.position += chunk.length;
281282283284285286287288289290291292
return chunk;
}
}
app.listen(port, () => {
console.log(`Server is listening on port ${port}`);
});