asessorScheduler.js

import cron from "node-cron";
import axios from "axios";

// Replace 'YOUR_API_ENDPOINT' with the actual API endpoint for updating status
const GET_THRESHOLD_DAYS = '/api/rest/config/search';
const GET_FORM_SUBMISSIONS_BY_STATUS = '/api/rest/getFormSubmissionsByStatus';
const UPDATE_ENDPOINT = "/api/rest/UpdateFormSubmissionStatus";
const UPDATE_ASSESSMENT_ENDPOINT = "/rest/assessorUpdateForm"
const SCHEDULES_ENDPOINT = "/rest/getAssessmentSchedule";
const TARGET_URL = process.env.TARGET_URL ;
const REACT_APP_NODE_URL = process.env.REACT_APP_API_URL ;
const AUTH_TOKEN = process.env.REACT_APP_AUTH_TOKEN;

const hasuraClientName = process.env.HASURA_CLIENT_NAME ;
const hasuraAdminSecret = process.env.HASURA_ADMIN_SECRET ;

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

//Get threshold days from DB
const fetchThreshold = () => {
    return new Promise(async(resolve) => {
            try {
                const reqData = {"searchString" : {"status": {"_eq": true}, "type": {"_eq": "scheduler"}},"offSet":0,"limit": 100};
                const response = await axiosInstance.post(TARGET_URL+GET_THRESHOLD_DAYS,reqData);
                resolve( response.data.config); 
            } catch (error) {
                console.error('Error fetching threshold days:', error.message);
                throw error;
            }
      });
    
};

//Get submitted date and reviewed date from DB
const fetchData = (arr) => {
    return new Promise(async(resolve) => {
            try {
                const reqData = {"params": arr};
                const response = await axiosInstance.post(TARGET_URL+GET_FORM_SUBMISSIONS_BY_STATUS, reqData);
                resolve(response.data.form_submissions); 
            } catch (error) {
                console.error('Error fetching application data:', error.message);
                throw error;
            }
    });
};

// Update status using the API
const updateStatus = (updateStr) => {
    return new Promise(async(resolve) => {
            try {
                console.log(updateStr);
                const response = await axiosInstance.post(TARGET_URL+UPDATE_ENDPOINT, updateStr);
                resolve(response.data.update_form_submissions.returning); 
            } catch (error) {
                console.error('Error updating status:', error.message);
                throw error;
            }
    });
  };

  const sendEmailNotification = async (postData) => {