backgroundWorker.js

import axios from "axios";
import async from "async";
const targetURL = process.env.TARGET_URL || "https://hasura.upsmfac.org";
const notificationURL = process.env.REACT_APP_API_URL || "https://uphrh.in/api/api";
const emailAuthToken = process.env.REACT_APP_AUTH_TOKEN;

const getBulkUploadAssessorSchedule = '/api/rest/getBulkUploadAssessorSchedule';
const filterAssessments = '/api/rest/filterAssessments';
const getUsersForSchedulingAssessment = '/api/rest/getUsersForSchedulingAssessment';
const addAssessmentSchedule = '/api/rest/addAssessmentSchedule';
const addInstituteCourse = '/api/rest/addInstituteCourse';
const addEvents = '/api/rest/addEvents';
const updateForm = '/api/rest/updateForm';
const getApplicantDeviceId = '/api/rest/getApplicantDeviceId';
const notify = '/email/notify';
const getFormSubmissionsByFormIds = '/api/rest/getFormSubmissionsByFormIds';
const updateStatusToBulkUpload = '/api/rest/updateStatusToBulkUpload';
const getAllAssessorsAPI = '/api/rest/getAllAssessors';
const getAdminDetailsById = '/api/rest/getRegulator';

// Creating an Axios instance with custom headers
const axiosInstance = axios.create({
  baseURL: targetURL,
  headers: {
    "x-hasura-admin-secret": "myadminsecretkey",
    "Hasura-Client-Name": "hasura-console"
    // Add any other headers you need
  },
});

const getBulkUpload = (processStr) => {
  return new Promise(async(resolve) => {
          try {
              //console.log(processStr);
              const response = await axiosInstance.post(targetURL + getBulkUploadAssessorSchedule, processStr);
              //console.log(response.data);
              resolve(response.data.assessor_schedule_bulk_upload); 
          } catch (error) {
              console.error('Error getBulkUpload:', error.message);
              throw error;
          }
  });
};

 const getAllAssessors = () => {
  return new Promise(async(resolve) => {
          try {
            const processStr = {"offsetNo":0,"limit": 100000}
             //console.log(processStr);
             const response = await axiosInstance.post(targetURL + getAllAssessorsAPI, processStr);
             //console.log(response.data.assessors);
             const assessors = response.data.assessors;
             const users = assessors.filter(obj => obj["workingstatus"] == "Valid");
             resolve(users); 
          } catch (error) {
              console.error('Error getUsersForScheduling:', error.message);
              throw error;
          }
 });
};
 
const addAssessmentScheduleToDB = (scheduleStr) => {
  return new Promise(async(resolve) => {
          try {
              //console.log(scheduleStr);
              const response = await axiosInstance.post(targetURL + addAssessmentSchedule, scheduleStr);
              //console.log(response.data);
             resolve(response.data); 
     
          } catch (error) {