reports.js

"use strict";
const axios = require('axios');
const https = require('https')
const async = require('async');
const moment = require('moment')
const logger = require('./winston')
const URI = require('urijs');
const _ = require('lodash');
const { v5: uuid5 } = require('uuid');
const FHIRPath = require('fhirpath');


/**
 * Disable only in development mode
 */
const httpsAgent = new https.Agent({
  rejectUnauthorized: false,
})
axios.defaults.httpsAgent = httpsAgent

class CacheFhirToES {
  constructor({
    ESBaseURL,
    ESUsername,
    ESPassword,
    ESMaxCompilationRate,
    ESMaxScrollContext,
    FHIRBaseURL,
    FHIRUsername,
    FHIRPassword,
    relationshipsIDs = [],
    since,
    reset = false,
    ESModulesBasePath
  }) {
    this.ESBaseURL = ESBaseURL
    this.ESUsername = ESUsername
    this.ESPassword = ESPassword
    this.ESMaxCompilationRate = ESMaxCompilationRate
    this.FHIRBaseURL = FHIRBaseURL
    this.FHIRUsername = FHIRUsername
    this.FHIRPassword = FHIRPassword
    this.relationshipsIDs = relationshipsIDs
    this.ESMaxScrollContext = ESMaxScrollContext
    this.since = since
    this.reset = reset
    this.deletedRelatedDocs = []
    this.ESModulesBasePath = ESModulesBasePath
  }

  flattenComplex(extension) {
    let results = {};
    for (let ext of extension) {
      let value = '';
      for (let key of Object.keys(ext)) {
        if (key !== 'url') {
          value = ext[key];
        }
      }
      if (results[ext.url]) {
        if (Array.isArray(results[ext.url])) {
          results[ext.url].push(value);
        } else {
          results[ext.url] = [results[ext.url], value];
        }
      } else {
        if (Array.isArray(value)) {
          results[ext.url] = [value];
        } else {
          results[ext.url] = value;
        }
      }
    }
    return results;
  };

  /**
   *
   * @param {relativeURL} reference //reference must be a relative url i.e Practioner/10
   */
  getResourceFromReference(reference) {
    return new Promise((resolve) => {
      let url = URI(this.FHIRBaseURL)
        .segment(reference)
        .toString()
      axios.get(url, {
        headers: {
          'Cache-Control': 'no-cache',
        },
        withCredentials: true,
        auth: {
          username: this.FHIRUsername,
          password: this.FHIRPassword
        },
      }).then(response => {
        return resolve(response.data)
      }).catch((err) => {
        logger.error('Error occured while getting resource reference');
        logger.error(err);
        return resolve()
      })
    }).catch((err) => {
      logger.error('Error occured while getting resource reference');
      logger.error(err);
    })
  }

  resourceDisplayName(resource, displayFormat) {
    return new Promise((resolve) => {
      let details = {}
      let valformat = displayFormat && displayFormat.extension.find((ext) => {
        return ext.url === 'format'
      })
      if(valformat) {
        details.format = valformat.valueString
      }
      let valorder = displayFormat && displayFormat.extension.find((ext) => {
        return ext.url === 'order'
      })
      let paths = displayFormat && displayFormat.extension.filter((ext) => {
        return ext.url.startsWith("paths:")
      })
      if(valorder) {
        details.order = valorder.valueString
      } else {
        if(paths) {
          for(let path of paths) {
            path = path.url.split(":")
            if(path.length > 1) {
              if(!details.order) {
                details.order = path[1]
              } else {
                details.order += ',' + path[1]
              }
            }
          }
        }
      }
      if(paths && paths.length > 0) {
        details.paths = {}
        for(let path of paths) {
          let url = path.url.split(":")
          if(url.length > 1) {
            if(!details.paths[url[1]]) {
              details.paths[url[1]] = {}
            }
            details.paths[url[1]][url[2]] = path.valueString
          }
        }
      }
      if(!details.order && !details.paths) {
        let name = resource.name
        if(!name) {
          name = resource.extension && resource.extension.find((ext) => {
            return ext.url === 'http://ihris.org/fhir/StructureDefinition/ihris-basic-name'
          })
          if(name) {
            name = name.valueString
          }
        }
        return resolve(name)
      }
      let format = details.format || "%s"
      let output = []
      let order = details.order.split(',')
      if ( details.fhirpath ) {
        output.push( FHIRPath.evaluate( resource, details.fhirpath ).join( details.join || " " ) )
      } else if ( details.paths ) {
        for ( let ord of order ) {
          ord = ord.trim()
          output.push( FHIRPath.evaluate( resource, details.paths[ ord ].fhirpath ).join( details.paths[ord].join || " " ) )
        }
      }
      for(let val of output) {
        format = format.replace('%s', val)
      }
      return resolve(format)
    })
  }

  /**
 * Retrieves the value of a specific element from the given extension array.
 * 
 * @param {Array} extension - The array of extensions to search for the element value.
 * @param {String} element - The element to retrieve the value for.
 * @returns {Promise} A promise that resolves with the value of the specified element from the extension array.
 * @throws {Error} If an error occurs while retrieving the element value from the extension.
 */
  getElementValFromExtension(extension, element) {
    return new Promise((resolve) => {
      let elementValue = ''
      async.each(extension, (ext, nxtExt) => {
        let value
        for (let key of Object.keys(ext)) {
          if (key !== 'url') {
            value = ext[key];
          }
        }
        if (ext.url === element) {
          elementValue = value
        }
        (async () => {
          if (Array.isArray(value)) {
            let val
            try {
              val = await this.getElementValFromExtension(value, element)
            } catch (error) {
              logger.error(error);
            }
            if (val) {
              elementValue = val
            }
            return nxtExt()
          } else {
            return nxtExt()
          }
        })();
      }, () => {
        resolve(elementValue)
      })
    }).catch((err) => {
      logger.error('Error occured while geting Element value from extension');
      logger.error(err);
    })
  }

  getImmediateLinks(links, callback) {
    if (this.orderedResources.length - 1 === links.length) {
      return callback(this.orderedResources);
    }
    let promises = [];
    for (let link of links) {
      promises.push(
        new Promise((resolve, reject) => {
          link = this.flattenComplex(link.extension);
          let parentOrdered = this.orderedResources.find(orderedResource => {
            let linkToResource = link.linkTo.split('.').shift()
            return orderedResource.name === linkToResource;
          });
          let exists = this.orderedResources.find(orderedResource => {
            return JSON.stringify(orderedResource) === JSON.stringify(link);
          });
          if (parentOrdered && !exists) {
            this.orderedResources.push(link);
          }
          resolve();
        })
      );
    }
    Promise.all(promises).then(() => {
      if (this.orderedResources.length - 1 !== links.length) {
        this.getImmediateLinks(links, () => {
          return callback();
        });
      } else {
        return callback();
      }
    }).catch((err) => {
      logger.error(err);
      return callback();
    });
  };

  getReportRelationship(callback) {
    let url = URI(this.FHIRBaseURL)
      .segment('Basic')
    if(this.relationshipsIDs.length > 0) {
      url.addQuery('_id', this.relationshipsIDs.join(','));
    } else {
      url.addQuery('code', 'iHRISRelationship');
    }
    url = url.toString();
    axios
      .get(url, {
        headers: {
          'Cache-Control': 'no-cache',
        },
        withCredentials: true,
        auth: {
          username: this.FHIRUsername,
          password: this.FHIRPassword,
        },
      })
      .then(relationships => {
        return callback(false, relationships.data);
      })
      .catch(err => {
        logger.error(err);
        return callback(err, false);
      });
  };

  updateESScrollContext() {
    return new Promise((resolve, reject) => {
      logger.info('Setting maximum open scroll context');
      let url = URI(this.ESBaseURL).segment('_cluster').segment('settings').toString();
      let body = {
        "persistent": {
          "search.max_open_scroll_context": this.ESMaxScrollContext
        },
        "transient": {
          "search.max_open_scroll_context": this.ESMaxScrollContext
        }
      };
      axios({
          method: 'PUT',
          url,
          auth: {
            username: this.ESUsername,
            password: this.ESPassword,
          },
          data: body
        })
        .then(response => {
          if (response.status > 199 && response.status < 299) {
            logger.info('maximum open scroll context updated successfully');
            return resolve()
          } else {
            logger.error('An error has occured while setting max open scroll context')
            return reject()
          }
        }).catch((err) => {
          logger.error(err);
          logger.error('An error has occured while setting max open scroll context')
          reject(err)
        })
    })
  }

  updateESCompilationsRate(callback) {
    logger.info('Setting maximum compilation rate');
    let url = URI(this.ESBaseURL).segment('_cluster').segment('settings').toString();
    let body = {
      "transient": {
        "script.max_compilations_rate": this.ESMaxCompilationRate
      }
    };
    axios({
        method: 'PUT',
        url,
        auth: {
          username: this.ESUsername,
          password: this.ESPassword,
        },
        data: body
      })
      .then(response => {
        if (response.status > 199 && response.status < 299) {
          logger.info('maximum compilation rate updated successfully');
          return callback(false)
        } else {
          logger.error('An error has occured while setting max compilation rate')
          return callback(true)
        }
      }).catch((err) => {
        logger.error('An error has occured while setting max compilation rate')
        callback(err)
        throw err
      })
  }

  updateLastIndexingTime(start, ended, index) {
    return new Promise((resolve, reject) => {
      logger.info('Updating lastIndexingTime')
      axios({
        url: URI(this.ESBaseURL).segment('syncdata').segment("_doc").segment(index).toString(),
        method: 'PUT',
        auth: {
          username: this.ESUsername,
          password: this.ESPassword
        },
        data: {
          "lastBeganIndexingTime": start,
          "lastEndedIndexingTime": ended
        }
      }).then((response) => {
        if(response.status < 200 && response.status > 299) {
          logger.error('An error occured while updating lastIndexingTime')
          return reject()
        }
        return resolve(false)
      }).catch((err) => {
        logger.error(err)
        logger.error('An error occured while updating lastIndexingTime')
        return reject(true)
      })
    })
  }

  getLastIndexingTime(index) {
    return new Promise((resolve, reject) => {
      if(this.since && !this.reset) {
        this.lastBeganIndexingTime = this.since
        this.lastEndedIndexingTime = this.since
        return resolve()
      }
      logger.info('Getting lastIndexingTime')
      let query = {
        query: {
          term: {
            _id: index
          }
        }
      }
      axios({
        method: "GET",
        url: URI(this.ESBaseURL).segment('syncdata').segment("_search").toString(),
        data: query,
        auth: {
          username: this.ESUsername,
          password: this.ESPassword
        }
      }).then((response) => {
        if(this.reset) {
          logger.info('Returning lastIndexingTime of 1970-01-01T00:00:00')
          this.lastBeganIndexingTime = '1970-01-01T00:00:00'
          this.lastEndedIndexingTime = '1970-01-01T00:00:00'
          return resolve()
        }
        if(response.data.hits.hits.length === 0) {
          logger.info('Returning lastIndexingTime of 1970-01-01T00:00:00')
          this.lastBeganIndexingTime = '1970-01-01T00:00:00'
          this.lastEndedIndexingTime = '1970-01-01T00:00:00'
          return resolve()
        }
        logger.info('Returning lastBeganIndexingTime of ' + response.data.hits.hits[0]._source.lastBeganIndexingTime)
        this.lastBeganIndexingTime = response.data.hits.hits[0]._source.lastBeganIndexingTime
        this.lastEndedIndexingTime = response.data.hits.hits[0]._source.lastEndedIndexingTime
        return resolve()
      }).catch((err) => {
        if (err.response && err.response.status && err.response.status === 404) {
          this.lastBeganIndexingTime = '1970-01-01T00:00:00'
          this.lastEndedIndexingTime = '1970-01-01T00:00:00'
          logger.info('Index not found, creating index syncData');
          let mappings = {
            mappings: {
              properties: {
                lastBeganIndexingTime: {
                  type: "text"
                },
                lastEndedIndexingTime: {
                  type: "text"
                }
              },
            },
          };
          axios({
              method: 'PUT',
              url: URI(this.ESBaseURL).segment('syncdata').toString(),
              data: mappings,
              auth: {
                username: this.ESUsername,
                password: this.ESPassword,
              }
            })
            .then(response => {
              if (response.status !== 200) {
                logger.error('Something went wrong and index was not created');
                logger.error(response.data);
                logger.info('Returning lastBeganIndexingTime of 1970-01-01T00:00:00')
                return reject()
              } else {
                logger.info('Index syncdata created successfully');
                logger.info('Adding default lastBeganIndexingTime which is 1970-01-01T00:00:00')
                axios({
                  method: 'PUT',
                  auth: {
                    username: this.ESUsername,
                    password: this.ESPassword,
                  },
                  url: URI(this.ESBaseURL).segment('syncdata').segment("_doc").segment(index).toString(),
                  data: {
                    "lastBeganIndexingTime": "1970-01-01T00:00:00",
                    "lastEndedIndexingTime": "1970-01-01T00:00:00"
                  }
                }).then((response) => {
                  if(response.status >= 200 && response.status <= 299) {
                    logger.info('Default lastIndexTime added')
                  } else {
                    logger.error('An error has occured while saving default lastIndexTime');
                    return reject()
                  }
                  logger.info('Returning lastBeganIndexingTime of 1970-01-01T00:00:00')
                  return resolve()
                }).catch((err) => {
                  logger.error('An error has occured while saving default lastIndexTime');
                  if (err.response && err.response.data) {
                    logger.error(err.response.data);
                  }
                  if (err.error) {
                    logger.error(err.error);
                  }
                  if (!err.response) {
                    logger.error(err);
                  }
                  return reject()
                })
              }
            })
            .catch(err => {
              logger.error('Error: ' + err);
              logger.info('Returning lastBeganIndexingTime of 1970-01-01T00:00:00')
              return reject()
            });
        } else {
          logger.error('Error occured while getting last indexing time in ES');
          logger.error(err);
          logger.info('Returning lastBeganIndexingTime of 1970-01-01T00:00:00')
          this.lastBeganIndexingTime = '1970-01-01T00:00:00'
          this.lastEndedIndexingTime = '1970-01-01T00:00:00'
          return reject()
        }
      })
    })
  }

  createESIndex(name, IDFields, callback) {
    logger.info('Checking if index ' + name + ' exists');
    let url = URI(this.ESBaseURL)
      .segment(name.toString().toLowerCase())
      .toString();
    axios({
        method: 'head',
        url,
        auth: {
          username: this.ESUsername,
          password: this.ESPassword,
        },
      })
      .then(response => {
        if (response.status === 200) {
          logger.info('Index ' + name + ' exist, not creating');
          return callback(false);
        } else {
          return callback(true);
        }
      })
      .catch(err => {
        if (err.response && err.response.status && err.response.status === 404) {
          logger.info('Index not found, creating index ' + name);
          let mappings = {
            mappings: {
              properties: {
                lastUpdated: {
                  type: 'date'
                }
              }
            }
          };
          for (let IDField of IDFields) {
            mappings.mappings.properties[IDField.name] = {};
            mappings.mappings.properties[IDField.name].type = IDField.type;
            if(IDField.type === 'text') {
              mappings.mappings.properties[IDField.name].fields = {
                keyword: {
                  type: 'keyword'
                }
              }
            }
          }
          axios({
              method: 'put',
              url: url,
              data: mappings,
              auth: {
                username: this.ESUsername,
                password: this.ESPassword,
              },
            })
            .then(response => {
              if (response.status !== 200) {
                logger.error('Something went wrong and index was not created');
                logger.error(response.data);
                return callback(true);
              } else {
                logger.info('Index ' + name + ' created successfully');
                return callback(false);
              }
            })
            .catch(err => {
              logger.error(err);
              return callback(true);
            });
        } else {
          logger.error('Error occured while creating ES index');
          logger.error(err);
          return callback(true);
        }
      });
  };

  refreshIndex (index) {
    return new Promise((resolve, reject) => {
      logger.info('Refreshing index ' + index);
      const url = URI(this.ESBaseURL)
        .segment(index)
        .segment('_refresh')
        .toString();
      axios({
        method: 'post',
        url,
        auth: {
          username: this.ESUsername,
          password: this.ESPassword,
        },
      }).then(response => {
        logger.info(`index ${index} refreshed`);
        return resolve()
      }).catch((err) => {
        if (err.response && (err.response.statusText === 'Conflict' || err.response.status === 409)) {
          logger.warn('Conflict occured, rerunning this request');
          setTimeout(() => {
            this.refreshIndex(index, (err) => {
              if(err) {
                return reject();
              }
              return resolve();
            })
          }, 2000)
        } else if (err.response && err.response.status === 429) {
          logger.warn('ES is overloaded with too many requests, delaying for 2 seconds');
          setTimeout(() => {
            this.refreshIndex(index, (err) => {
              if(err) {
                return reject();
              }
              return resolve();
            })
          }, 2000)
        } else {
          logger.error('Error Occured while refreshing index');
          if (err.response && err.response.data) {
            logger.error(err.response.data);
          }
          if (err.error) {
            logger.error(err.error);
          }
          if (!err.response) {
            logger.error(err);
          }
          return reject();
        }
      });
    })
  };

  getResourcesFields(resources) {
    let fields = []
    for(let resource of resources) {
      if(resource["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
        for (let element of resource["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
          let fieldName
          let fhirPathValue
          let fieldAutogenerated = false
          for (let el of element) {
            let value = '';
            for (let key of Object.keys(el)) {
              if (key !== 'url') {
                value = el[key];
              }
            }
            if (el.url === "name") {
              let fleldChars = value.split(' ')
              //if name has space then format it
              if (fleldChars.length > 1) {
                fieldName = value.toLowerCase().split(' ').map(word => word.replace(word[0], word[0].toUpperCase())).join('');
              } else {
                fieldName = value
              }
            } else if (el.url === "fhirpath") {
              fhirPathValue = value
            } else if (el.url === "autoGenerated") {
              fieldAutogenerated = value
            }
          }
          fields.push({
            resourceName: resource.name,
            resourceType: resource.resource,
            field: fieldName,
            fhirPath: fhirPathValue,
            fieldAutogenerated
          })
        }
        fields.push({
          resourceName: resource.name,
          resourceType: resource.resource,
          field: resource.name,
          fhirPath: "id",
          fieldAutogenerated: false
        })
      }
    }
    return fields;
  }

  getChildrenResources(resourceName) {
    let childrenResources = []
    for(let orderedResource of this.orderedResources) {
      if(orderedResource.linkTo === resourceName || (orderedResource.linkTo && orderedResource.linkTo.startsWith(resourceName + '.'))) {
        childrenResources.push(orderedResource)
        let grandChildren = this.getChildrenResources(orderedResource.name)
        childrenResources = childrenResources.concat(grandChildren)
      }
    }
    return childrenResources
  }

  getESDocument(index, query, callback) {
    let error = false
    let documents = []
    if(!query) {
      query = {}
    }
    query.size = 10000
    let url = URI(this.ESBaseURL)
      .segment(index)
      .segment('_search')
      .addQuery('scroll', '1m')
      .toString()
    let scroll_id = null
    async.doWhilst(
      (callback) => {
        axios({
          method: 'POST',
          url,
          data: query,
          auth: {
            username: this.ESUsername,
            password: this.ESPassword
          }
        }).then((response) => {
          if(response.data.hits && response.data.hits.hits && Array.isArray(response.data.hits.hits)) {
            documents = documents.concat(response.data.hits.hits)
          }
          if(response.data.hits.hits.length === 0 || !response.data._scroll_id) {
            scroll_id = null
          } else {
            scroll_id = response.data._scroll_id
            url = URI(this.ESBaseURL).segment('_search').segment('scroll').toString()
            query = {
              scroll: '1m',
              scroll_id: scroll_id
            }
          }
          return callback(null)
        }).catch((err) => {
          if(err.response && err.response.status === 429) {
            logger.warn('ES is overloaded with too many requests, delaying for 2 seconds');
            setTimeout(() => {
              return callback(null)
            }, 2000);
          } else {
            error = err
            logger.error(err);
            scroll_id = null
            return callback(null)
          }
        })
      },
      (callback) => {
        return callback(null, scroll_id !== null)
      },
      () => {
        return callback(error, documents)
      }
    )
  }

  deleteESDocument(query, index) {
    return new Promise(async(resolve, reject) => {
      // await this.refreshIndex(index);
      let url = URI(this.ESBaseURL).segment(index).segment('_delete_by_query').toString();
      axios({
        method: 'post',
        url,
        data: query,
        auth: {
          username: this.ESUsername,
          password: this.ESPassword,
        },
      }).then(response => {
        this.refreshIndex(index)
        logger.info(JSON.stringify(response.data,0,2));
        return resolve()
      }).catch((err) => {
        if (err.response && (err.response.statusText === 'Conflict' || err.response.status === 409)) {
          logger.warn('Conflict occured, rerunning this request');
          setTimeout(async() => {
            await this.deleteESDocument(query, index).then(() => {
              return resolve()
            }).catch(() => {
              return reject()
            })
          }, 2000)
        } else if (err.response && err.response.status === 429) {
          logger.warn('ES is overloaded with too many requests, delaying for 2 seconds');
          setTimeout(async() => {
            await this.deleteESDocument(query, index).then(() => {
              return resolve()
            }).catch(() => {
              return reject()
            })
          }, 2000)
        } else {
          logger.error('Error Occured while deleting ES document');
          if (err.response && err.response.data) {
            logger.error(err.response.data);
          }
          if (err.error) {
            logger.error(err.error);
          }
          if (!err.response) {
            logger.error(err);
          }
          return reject()
        }
      });
    })
  };

  sendESRequest({
    url,
    method,
    data
  }) {
    return new Promise((resolve, reject) => {
      let options = {
        url,
        method,
        auth: {
          username: this.ESUsername,
          password: this.ESPassword
        }
      }
      if(data) {
        options.data = data
      }
      axios(options).then((response) => {
        resolve(response)
      }).catch((err) => {
        if (err.response && (err.response.status === 429 || err.response.statusText === 'Conflict' || err.response.status === 409)) {
          if(err.response.status === 429) {
            logger.warn('ES is overloaded with too many requests, delaying for 2 seconds');
          }
          if(err.response.status === 409) {
            logger.warn('Conflict occured, rerunning this request');
          }
          setTimeout(() => {
            this.sendESRequest({url, method, data}).then(() => {
              resolve()
            }).catch((err) => {
              logger.error(err);
              reject()
            })
          }, 700)
        } else {
          let error = {}
          if (err.response && err.response.data) {
            error = {
              error: err.response.data
            }
          } else if(err.error) {
            error.error = err.error
          } else {
            error.error = err
          }
          if(data) {
            error['Req Data'] = data
          }
          error.url = url
          logger.error(JSON.stringify(error, 0, 2));
          reject()
        }
      })
    })
  }

  async updateESDocument(body, record, index, orderedResource, resourceData, tryDeleting, extraTerms, callback) {
    let multiple = orderedResource.multiple
    let allTerms = _.cloneDeep(body.query.terms)
    // await this.refreshIndex(index);
    //this handles records that should be deleted instead of its fields being truncated
    let recordDeleted = false;
    async.series({
      addNewRows: (callback) => {
        //ensure that this is not the primary resource and has multiple tag, otherwise return
        if(!orderedResource.hasOwnProperty('linkElement') || !multiple) {
          return callback(null)
        }
        let query = {
          query: {
            bool: {
              must: [{
                terms: body.query.terms
              }]
            }
          }
        }
        query.query.bool.must = query.query.bool.must.concat(extraTerms)
        this.getESDocument(index, query, async(err, documents) => {
          if(err) {
            logger.error('Req Data: ' + JSON.stringify(query,0,2));
            return callback(null)
          }
          //if field values for this record needs to be truncated and there are multiple records of the parent, then delete the one we are truncating instead of updating
          if(documents.length > 1 && tryDeleting) {
            let recordFields = Object.keys(record)
            let idField = recordFields[recordFields.length - 1]
            let termField = Object.keys(body.query.terms)[0]
            let delQry = {
              query: {
                bool: {
                  must: []
                }
              }
            }
            let must1 = {
              terms: {}
            }
            must1.terms[termField] = body.query.terms[termField]
            delQry.query.bool.must.push(must1)
            let must2 = {
              terms: {}
            }
            must2.terms[idField + '.keyword'] = [record[idField]]
            delQry.query.bool.must.push(must2)
            delQry.query.bool.must = delQry.query.bool.must.concat(extraTerms)
            try {
              await this.deleteESDocument(delQry, index)
            } catch (error) {
              logger.error(error);
            }
            recordDeleted = true;
          }
          if(recordDeleted || tryDeleting) {
            return callback(null)
          }
          //because this resource supports multiple rows, then we are trying to add new rows
          let newRows = []
          // take the last field because it is the ID
          let recordFields = Object.keys(record)
          let checkField = recordFields[recordFields.length - 1]

          for(let linkField in allTerms) {
            let linkFieldWithoutKeyword = linkField.replace('.keyword', '')
            for(let index in allTerms[linkField]) {
              let newRowBody = {}
              // create new row only if there is no checkField or checkField exist but it is different
              let updateThis = documents.find((hit) => {
                return hit['_source'][linkFieldWithoutKeyword] === allTerms[linkField][index] && (!hit['_source'][checkField] || hit['_source'][checkField] === record[checkField])
              })
              if(!updateThis) {
                let hit = documents.find((hit) => {
                  return hit['_source'][linkFieldWithoutKeyword] === allTerms[linkField][index]
                })
                if(!hit) {
                  continue;
                }
                for(let field in hit['_source']) {
                  newRowBody[field] = hit['_source'][field]
                }
                for(let recField in record) {
                  newRowBody[recField] = record[recField]
                }
                let trmInd = body.query.terms[linkField].findIndex((trm) => {
                  return trm === allTerms[linkField][index]
                })
                body.query.terms[linkField].splice(trmInd, 1)
              }
              if(Object.keys(newRowBody).length > 0) {
                newRows.push(newRowBody)
              }
            }
          }
          if(newRows.length > 0) {
            async.eachSeries(newRows, (newRowBody, nxt) => {
              newRowBody.lastUpdated = moment().format('Y-MM-DDTHH:mm:ss');
              let url = URI(this.ESBaseURL).segment(index).segment('_doc').toString()
              this.sendESRequest({
                url,
                method: 'POST',
                data: newRowBody
              }).then(() => {
                return nxt()
              }).catch(() => {
                return nxt()
              })
            }, () => {
              return callback(null)
            })
          } else {
            return callback(null)
          }
        })
      },
      updateRow: (callback) => {
        if(recordDeleted) {
          return callback(null);
        }
        // for multiple rows, ensure that we dont update all rows but just one row
        let bodyData = {}
        let recordFields = Object.keys(record)
        let idField = recordFields[recordFields.length - 1]
        if(multiple) {
          let termField = Object.keys(body.query.terms)[0]
          bodyData = {
            query: {
              bool: {
                must: []
              }
            }
          }
          let must1 = {
            terms: {}
          }
          must1.terms[termField] = body.query.terms[termField]
          bodyData.query.bool.must.push(must1)
          let must2 = {
            terms: {}
          }
          must2.terms[idField + '.keyword'] = [record[idField]]
          bodyData.query.bool.must.push(must2)
          bodyData.query.bool.must = bodyData.query.bool.must.concat(extraTerms)
          bodyData.script = body.script
        } else {
          bodyData = body
        }
        let url = URI(this.ESBaseURL).segment(index).segment('_update_by_query').toString();
        async.series({
          updateDocMissingField: (callback) => {
            if(!multiple) {
              return callback(null)
            }
            let updBodyData = _.cloneDeep(bodyData)
            updBodyData.script.source += `ctx._source.lastUpdated='${moment().format("Y-MM-DDTHH:mm:ss")}';`
            updBodyData.query.bool.must.splice(1, 1)

            let must_not = {
              exists: {}
            }
            must_not.exists.field = idField
            updBodyData.query.bool.must_not = [must_not]
            this.sendESRequest({
              url,
              method: 'POST',
              data: updBodyData
            }).then(() => {
              return callback(null)
            }).catch(() => {
              return callback(null)
            })
          },
          updateDocHavingField: (callback) => {
            let updBodyData = _.cloneDeep(bodyData)
            updBodyData.script.source += `ctx._source.lastUpdated='${moment().format("Y-MM-DDTHH:mm:ss")}';`
            this.sendESRequest({
              url,
              method: 'POST',
              data: updBodyData
            }).then((response) => {
              // if nothing was updated and its from the primary (top) resource then create as new
              if (response.data.updated == 0 && !orderedResource.hasOwnProperty('linkElement')) {
                logger.info('No record with id ' + resourceData.id + ' found on elastic search, creating new');
                let id = record[orderedResource.name].split('/')[1]
                if(extraTerms.length > 0) {
                  let ids = [id]
                  for(let extraTerm of extraTerms) {
                    ids.push(Object.values(extraTerm.terms)[0][0].split('/')[1])
                  }
                  id = this.generateId(ids)
                }
                let url = URI(this.ESBaseURL)
                  .segment(index)
                  .segment('_doc')
                  .segment(id)
                  .toString();
                let recordData = _.cloneDeep(record)
                recordData.lastUpdated = moment().format("Y-MM-DDTHH:mm:ss");
                this.sendESRequest({
                  url,
                  method: 'POST',
                  data: recordData
                }).then(() => {
                  return callback(null)
                }).catch(() => {
                  return callback(null)
                })
              } else {
                return callback(null)
              }
            }).catch(() => {
              return callback(null)
            })
          }
        }, () => {
          return callback(null)
        })
      },
      cleanBrokenLinks: (callback) => {
        if(!orderedResource.hasOwnProperty('linkElement') || (resourceData.meta && resourceData.meta.versionId == '1')) {
          return callback(null)
        }
        // get all documents that doesnt meet the search terms but are linked to this resource and truncate
        let qry = {
          query: {
            bool: {
              must_not: [],
              must: []
            }
          }
        }
        qry.query.bool.must_not = [{
          terms: allTerms
        }]
        let recordFields = Object.keys(record)
        let idField = recordFields[recordFields.length - 1]
        let term = {}
        term[idField + '.keyword'] = record[idField]
        qry.query.bool.must = [{
          term
        }]
        //include extra terms
        qry.query.bool.must = qry.query.bool.must.concat(extraTerms)
        let childrenResources = this.getChildrenResources(orderedResource.name);
        childrenResources.unshift(orderedResource)
        let fields = this.getResourcesFields(childrenResources)
        let ctx = ''
        for(let field of fields) {
          ctx += `ctx._source['${field.field}']=null;`;
        }
        ctx += `ctx._source.lastUpdated='${moment().format('Y-MM-DDTHH:mm:ss')}';`
        this.getESDocument(index, qry, (err, documents) => {
          if(err) {
            logger.error(err);
          }
          let queryRelated = {
            query: {
              bool: {
                should: []
              }
            }
          }
          //save fields that are used to test if two docs are the same
          let compFieldsRelDocs = []
          let ids = []
          for(let hit of documents) {
            ids.push(hit._id)
            //if relationship supports multiple rows then construct a query that can get all other documents that has the same field as this,
            //if we find one then we delete instead of truncate
            if(orderedResource.multiple) {
              const name = orderedResource.name
              let link = '__' + name + '_link'
              let query = {
                bool: {
                  must: [],
                  must_not: []
                }
              }
              for(let field in hit._source) {
                let resourceField = orderedResource['http://ihris.org/fhir/StructureDefinition/iHRISReportElement'].find((elements) => {
                  return elements.find((element) => {
                    return element.url === 'name' && element.valueString === field
                  })
                })
                if(field === name || field === link || resourceField || field === 'lastUpdated') {
                  continue
                }
                let exist = compFieldsRelDocs.find((fld) => {
                  return fld === field
                })
                if(!exist) {
                  compFieldsRelDocs.push(field)
                }
                if(hit._source[field] === null) {
                  let must_not = {
                    exists: {
                      field
                    }
                  }
                  query.bool.must_not.push(must_not)
                } else {
                  let must = {
                    match: {}
                  }
                  must.match[field] = hit._source[field]
                  query.bool.must.push(must)
                }
              }
              queryRelated.query.bool.should.push(query)
            }
          }
          if(ids.length > 0) {
            let relatedDocs = []
            let getRelatedDocs = new Promise((resolve) => {
              if(!orderedResource.multiple) {
                return resolve()
              }
              this.getESDocument(index, queryRelated, (err, docs) => {
                relatedDocs = docs
                return resolve()
              })
            })
            getRelatedDocs.then(() => {
              //separate IDs whose docs should be truncated with those that should be deleted
              let deleteIDs = []
              let truncateIDs = []
              for(let doc1 of relatedDocs) {
                for(let doc2 of relatedDocs) {
                  if(doc1._id === doc2._id) {
                    continue
                  }
                  let same = true
                  for(let field of compFieldsRelDocs) {
                    if(doc1._source[field] !== doc2._source[field]) {
                      same = false
                      break
                    }
                  }
                  if(same) {
                    let totalDeletedRelDocs = 0
                    for(let deletedRelDoc of this.deletedRelatedDocs) {
                      let sameAsRelated = true
                      for(let field of compFieldsRelDocs) {
                        if(deletedRelDoc._source[field] != doc2._source[field]) {
                          sameAsRelated = false
                          break
                        }
                      }
                      if(sameAsRelated) {
                        totalDeletedRelDocs += 1
                      }
                    }
                    // total deleted should always be less by one to all related docs so that the remaining one should only be truncated
                    if(relatedDocs.length === totalDeletedRelDocs+1) {
                      continue
                    }
                  }
                  let pushed = deleteIDs.find((id) => {
                    return id === doc2._id
                  })
                  if(same && !pushed && doc2._source[orderedResource.name] === record[idField]) {
                    this.deletedRelatedDocs.push(doc2)
                    deleteIDs.push(doc2._id)
                  }
                }
              }
              truncateIDs = ids.filter((id) => {
                return !deleteIDs.includes(id)
              })
              async.parallel({
                truncate: (callback) => {
                  if(truncateIDs.length === 0) {
                    return callback(null)
                  }
                  //if relatedDocs is 2 then delete
                  let body = {
                    script: {
                      lang: 'painless',
                      source: ctx
                    },
                    query: {
                      terms: {
                        _id: truncateIDs
                      }
                    },
                  };
                  let url = URI(this.ESBaseURL).segment(index).segment('_update_by_query').addQuery('conflicts', 'proceed').toString();
                  this.sendESRequest({
                    url,
                    method: 'POST',
                    data: body
                  }).then(() => {
                    return callback(null)
                  }).catch(() => {
                    return callback(null)
                  })
                },
                delete: (callback) => {
                  if(deleteIDs.length === 0) {
                    return callback(null)
                  }
                  let query = {
                    query: {
                      terms: {
                        _id: deleteIDs
                      }
                    }
                  }
                  this.deleteESDocument(query, index).then(async() => {
                    await this.refreshIndex(index);
                    return callback(null)
                  }).catch((err) => {
                    logger.error(err);
                    return callback(null)
                  })
                }
              }, () => {
                return callback(null)
              })
            }).catch((err) => {
              logger.error(err);
              return callback(null);
            })
          } else {
            return callback(null)
          }
        })
      }
    }, () => {
      return callback()
    })
  }

  cache() {
    return new Promise(async(resolve) => {
      this.getReportRelationship((err, relationships) => {
        if (err) {
          return;
        }
        if ((!relationships.entry || !Array.isArray(relationships.entry)) && !relationships.resourceType === 'Bundle') {
          logger.error('invalid resource returned');
          return;
        }
        async.eachSeries(relationships.entry, (relationship, nxtRelationship) => {
          logger.info('processing relationship ID ' + relationship.resource.id);
          relationship = relationship.resource;
          let details = relationship.extension.find(ext => ext.url === 'http://ihris.org/fhir/StructureDefinition/iHRISReportDetails');
          let links = relationship.extension.filter(ext => ext.url === 'http://ihris.org/fhir/StructureDefinition/iHRISReportLink');
          let reportDetails = this.flattenComplex(details.extension);
          if(reportDetails.cachingDisabled === true) {
            if(reportDetails.externalCachingModule) {
              let mod = reportDetails.externalCachingModule.split(".")
              if(mod.length !== 2) {
                logger.error('invalid definition for external caching module' + reportDetails.externalCachingModule);
                return nxtRelationship()
              }
              let functionname = mod[1]
              let externalCachingModule
              try {
                externalCachingModule = require(this.ESModulesBasePath + "/" + mod[0])
              } catch (error) {
                logger.error(error);
                return nxtRelationship()
              }
              this.getLastIndexingTime(reportDetails.name).then(() => {
                let newLastBeganIndexingTime = moment().format('Y-MM-DDTHH:mm:ss');
                functionname = functionname.replace('(','')
                functionname = functionname.replace(')','')
                externalCachingModule[functionname](this.lastBeganIndexingTime).then(() => {
                  let newLastEndedIndexingTime = moment().format('Y-MM-DDTHH:mm:ss');
                  try {
                    this.updateLastIndexingTime(newLastBeganIndexingTime, newLastEndedIndexingTime, reportDetails.name)
                  } catch (err) {}
                  return nxtRelationship()
                }).catch(() => {
                  logger.error('An error occured calling an external caching module');
                  return nxtRelationship()
                })
              }).catch((err) => {
                return nxtRelationship()
              })
            } else {
              return nxtRelationship()
            }
          } else {
            let IDFields = [];
            if(reportDetails["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
              for(let element of reportDetails["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
                let type = element.find((el) => {
                  return el.url === 'type'
                })
                if(type) {
                  let name = element.find((el) => {
                    return el.url === 'name'
                  })
                  IDFields.push({
                    name: name.valueString,
                    type: type.valueString
                  })
                }
              }
            }
            for (let linkIndex1 in links) {
              let link1 = links[linkIndex1];
              let flattenedLink1 = this.flattenComplex(link1.extension);
              if(flattenedLink1["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
                for(let element of flattenedLink1["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
                  let type = element.find((el) => {
                    return el.url === 'type'
                  })
                  if(type) {
                    let name = element.find((el) => {
                      return el.url === 'name'
                    })
                    IDFields.push({
                      name: name.valueString,
                      type: type.valueString
                    })
                  }
                }
              }
              let linkTo1 = flattenedLink1.linkTo.split('.')
              let linkToResource1 = linkTo1[0]
              if (linkToResource1 === reportDetails.name) {
                let fhirpath
                if (linkTo1.length === 1) {
                  fhirpath = 'id'
                } else {
                  linkTo1.splice(0, 1)
                  fhirpath = linkTo1.join('.')
                }
                details.extension.push({
                  url: 'http://ihris.org/fhir/StructureDefinition/iHRISReportElement',
                  extension: [{
                      url: 'name',
                      valueString: '__' + flattenedLink1.name + '_link',
                    },
                    {
                      url: 'fhirpath',
                      valueString: fhirpath,
                    },
                    {
                      url: 'autoGenerated',
                      valueBoolean: true
                    }
                  ],
                });
                IDFields.push({
                  name: '__' + flattenedLink1.name + '_link',
                  type: "text"
                })
              }

              IDFields.push({
                name: flattenedLink1.name,
                type: "text"
              })
              for (let link2 of links) {
                let flattenedLink2 = this.flattenComplex(link2.extension);
                let linkTo2 = flattenedLink2.linkTo.split('.')
                let linkToResource2 = linkTo2[0]
                if (linkToResource2 === flattenedLink1.name) {
                  let fhirpath
                  if (linkTo2.length === 1) {
                    fhirpath = 'id'
                  } else {
                    linkTo2.splice(0, 1)
                    fhirpath = linkTo2.join('.')
                  }
                  links[linkIndex1].extension.push({
                    url: 'http://ihris.org/fhir/StructureDefinition/iHRISReportElement',
                    extension: [{
                        url: 'name',
                        valueString: '__' + flattenedLink2.name + '_link',
                      },
                      {
                        url: 'fhirpath',
                        valueString: fhirpath,
                      },
                      {
                        url: 'autoGenerated',
                        valueBoolean: true
                      }
                    ],
                  });
                  IDFields.push({
                    name: '__' + flattenedLink2.name + '_link',
                    type: "text"
                  })
                }
              }
            }
            reportDetails = this.flattenComplex(details.extension);
            this.orderedResources = [];
            // reportDetails.resource = subject._type;
            this.orderedResources.push(reportDetails);
            IDFields.push({
              name: reportDetails.name,
              type: "text"
            })
            this.getLastIndexingTime(reportDetails.name).then(() => {
              let newLastBeganIndexingTime = moment().format('Y-MM-DDTHH:mm:ss');
              this.updateESScrollContext().then(() => {
                this.updateESCompilationsRate(() => {
                  this.createESIndex(reportDetails.name, IDFields, err => {
                    if (err) {
                      logger.error('Stop creating report due to error in creating index');
                      return nxtRelationship();
                    }
                    logger.info('Done creating ES Index');
                    this.getImmediateLinks(links, () => {
                      async.eachSeries(this.orderedResources, (orderedResource, nxtResourceType) => {
                        (async () => {
                          let url = URI(this.FHIRBaseURL).segment(orderedResource.resource)
                          if(orderedResource.initialFilter && (this.reset || this.lastBeganIndexingTime === '1970-01-01T00:00:00')) {
                            let initFilter = orderedResource.initialFilter.split("=")
                            url.addQuery(initFilter[0], initFilter[1])
                          }
                          url.addQuery('_count', -1)
                          .addQuery('_total', 'accurate')
                          url = url.toString()
                          await axios.get(url).then((resp) => {
                            this.totalResources = resp.data.total
                          })
                        })()
                        this.deletedRelatedDocs = []
                        let processedRecords = []
                        this.count = 1;
                        let offset = 0
                        let url = URI(this.FHIRBaseURL).segment(orderedResource.resource)
                        if(!this.reset && this.lastBeganIndexingTime !== '1970-01-01T00:00:00') {
                          url.segment('_history')
                        }
                        if(orderedResource.initialFilter && (this.reset || this.lastBeganIndexingTime === '1970-01-01T00:00:00')) {
                          let initFilter = orderedResource.initialFilter.split("=")
                          url.addQuery(initFilter[0], initFilter[1])
                        }
                        url.addQuery('_since', this.lastBeganIndexingTime)
                          .addQuery('_count', 200)
                        url = url.toString();
                        logger.info(`Processing data for resource ${orderedResource.name}`);
                        async.whilst(
                          callback => {
                            return callback(null, url != false);
                          },
                          callback => {
                            axios.get(url, {
                              headers: {
                                'Cache-Control': 'no-cache',
                              },
                              withCredentials: true,
                              auth: {
                                username: this.FHIRUsername,
                                password: this.FHIRPassword,
                              },
                            }).then(response => {
                              url = false;
                              const next = response.data.link.find(
                                link => link.relation === 'next'
                              );
                              if (next) {
                                url = next.url
                              }
                              if (response.data.entry && response.data.entry.length > 0) {
                                //if hapi server doesnt have support for returning the next cursor then use _getpagesoffset
                                offset += 200
                                if(offset <= this.totalResources && !url) {
                                  url = URI(this.FHIRBaseURL).segment(orderedResource.resource)
                                  if(!this.reset && this.lastBeganIndexingTime !== '1970-01-01T00:00:00') {
                                    url.segment('_history')
                                  }
                                  url.addQuery('_since', this.lastBeganIndexingTime)
                                  .addQuery('_count', 200)
                                  .addQuery('_getpagesoffset', offset)
                                  url = url.toString();
                                }
                                this.processResource(response.data.entry, orderedResource, reportDetails, processedRecords, false, () => {
                                  return callback(null, url);
                                })
                              } else {
                                if(response.data.type) {
                                  url = false
                                  return callback(null, url);
                                } else {
                                  return callback(null, url);
                                }
                              }
                            }).catch(err => {
                              // Handle expired cursor
                              if(err && err.response && err.response.status === 410) {
                                let newurl = URI(url)
                                let queries = newurl.query().split('&')
                                let pageoffset
                                let count
                                for(let query of queries) {
                                  let qr = query.split('=')
                                  if(qr[0] === '_getpagesoffset') {
                                    pageoffset = qr[1]
                                  } else if(qr[0] === '_count') {
                                    count = qr[1]
                                  }
                                }
                                if(!pageoffset) {
                                  logger.error('Error occured while getting resource data');
                                  logger.error(err);
                                  return callback(null, false)
                                }
                                url = URI(this.FHIRBaseURL)
                                .segment(orderedResource.resource)
                                .segment('_history')
                                .addQuery('_since', this.lastBeganIndexingTime)
                                .addQuery('_count', count)
                                .addQuery('_getpagesoffset', pageoffset)
                                .toString();
                                return callback(null, url)
                              } else {
                                logger.error('Error occured while getting resource data');
                                logger.error(err);
                                return callback(null, false)
                              }
                            });
                          }, async() => {
                            try {
                              await this.refreshIndex(reportDetails.name);
                            } catch (error) {
                              logger.error(error);
                            }
                            logger.info('Done Writting resource data for resource ' + orderedResource.name + ' into elastic search');
                            this.fixDataInconsistency(reportDetails, orderedResource, () => {
                              return nxtResourceType()
                            })
                          }
                        );
                      }, () => {
                        if(reportDetails.postRun) {
                          logger.info("Executing postRun module")
                          let mod = reportDetails.postRun.split(".")
                          if(mod.length !== 2) {
                            logger.error('invalid definition for postRun module' + reportDetails.postRun);
                            return nxtRelationship();
                          }
                          let functionname = mod[1]
                          let postRun
                          try {
                            postRun = require(this.ESModulesBasePath + "/" + mod[0])
                          } catch (error) {
                            logger.error(error);
                            return nxtRelationship();
                          }
                          functionname = functionname.replace('(','')
                          functionname = functionname.replace(')','')
                          postRun[functionname](this.lastBeganIndexingTime).then(() => {
                            nxtRelationship();
                          }).catch(() => {
                            logger.error('An error occured calling postRun module');
                            nxtRelationship()
                          })
                        } else {
                          nxtRelationship();
                        }
                        try {
                          let newLastEndedIndexingTime = moment().format('Y-MM-DDTHH:mm:ss');
                          this.updateLastIndexingTime(newLastBeganIndexingTime, newLastEndedIndexingTime, reportDetails.name)
                        } catch (error) {
                          logger.error(error);
                        }
                      });
                    });
                  });
                })
              }).catch((err) => {
                logger.error(err);
                return nxtRelationship();
              })
            }).catch((err) => {
              logger.error(err);
              return nxtRelationship();
            })
          }
        }, () => {
          logger.info('Done processing all relationships');
          return resolve()
        });
      });
    })
  }

  processResource(resourceData, orderedResource, reportDetails, processedRecords, wait, callback) {
    async.eachSeries(resourceData, (data, nxtResource) => {
      logger.info('processing ' + this.count + '/' + this.totalResources + ' records of resource ' + orderedResource.resource);
      this.count++
      let deleteRecord = false;
      if (!data.resource || !data.resource.resourceType) {
        if(data.request && data.request.method === 'DELETE') {
          deleteRecord = true
        } else {
          return nxtResource()
        }
      }

      let id
      if(data.resource && data.resource.id) {
        id = orderedResource.resource + '/' + data.resource.id;
      } else if(data.request && data.request.url) {
        let urlArr = data.request.url.split(orderedResource.resource)
        let resId = urlArr[1].split('/')[1]
        id = orderedResource.resource + '/' + resId;
      } else {
        logger.error('Invalid FHIR data returned');
        return nxtResource()
      }
      let processed
      for(let k=0;k<processedRecords.length;k++) {
        if(processedRecords[k] === id) {
          processed = processedRecords[k]
          break
        }
      }
      if (!processed) {
        processedRecords.push(id)
      } else {
        return nxtResource()
      }
      let getDeletedResProm = new Promise((resolve) => {
        //if deleted resource is not the primary resource then get the resource in the state before deleted then truncate elasticsearch based on that state
        if(data.request && data.request.method === 'DELETE') {
          let resVersion = data.request.url.split('/').pop()
          let oldUrlArr = data.request.url.split('/')
          oldUrlArr[oldUrlArr.length - 1] = parseInt(resVersion) - 1
          let url = URI(this.FHIRBaseURL)
          for(let segment of oldUrlArr) {
            url.segment(segment.toString())
          }
          axios.get(url.toString(), {
            headers: {
              'Cache-Control': 'no-cache',
            },
            withCredentials: true,
            auth: {
              username: this.FHIRUsername,
              password: this.FHIRPassword,
            },
          }).then(response => {
            data.resource = response.data
            return resolve()
          }).catch((err) =>{
            logger.error('Error occured while getting deleted resource');
            logger.error(err);
            return resolve()
          })
        } else {
          return resolve()
        }
      })
      getDeletedResProm.then(async() => {
        if (orderedResource.query) {
          try {
            let queryResult = FHIRPath.evaluate(data.resource, orderedResource.query);
            if((Array.isArray(queryResult) && (queryResult.includes(false) || queryResult.length === 0)) || queryResult === false) {
              deleteRecord = true
            }
          } catch (error) {
            logger.error(`Invalid fhirpath supplied ${orderedResource.query}`)
            process.exit()
          }
        }
        //if this resource doesnt meet filter, and no changes made to it, then ignore processing it.
        if((deleteRecord && data.resource.meta && data.resource.meta.versionId == '1') || (deleteRecord && this.lastBeganIndexingTime === '1970-01-01T00:00:00')) {
          return nxtResource();
        }
        let match = {};
        if (orderedResource.hasOwnProperty('linkElement')) {
          let linkElement = orderedResource.linkElement.replace(orderedResource.resource + '.', '');
          let linkTo
          try {
            linkTo = FHIRPath.evaluate(data.resource, linkElement);
          } catch (error) {
            logger.error(`Invalid fhirpath supplied ${linkElement}`);
            process.exit()
          }
          if (linkElement === 'id') {
            linkTo = orderedResource.resource + '/' + linkTo
          }
          if(!Array.isArray(linkTo)) {
            if(!linkTo) {
              linkTo = []
            } else {
              linkTo = [linkTo]
            }
          }
          match['__' + orderedResource.name + '_link' + '.keyword'] = linkTo;
        } else {
          match[orderedResource.name + '.keyword'] = [data.resource.resourceType + '/' + data.resource.id];
        }
        let record = {};
        if(orderedResource["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
          for (let element of orderedResource["http://ihris.org/fhir/StructureDefinition/iHRISReportElement"]) {
            let fieldName
            let fhirpath
            let externalfunction
            let displayformat
            let fieldAutogenerated = false
            let valueModifier
            let isScripted = element.find((el) => {
              return el.url === 'script'
            })?.url
            if(isScripted) {
              continue
            }
            for (let el of element) {
              let value = '';
              for (let key of Object.keys(el)) {
                if (key !== 'url') {
                  value = el[key];
                }
              }
              if (el.url === "name") {
                let fleldChars = value.split(' ')
                //if name has space then format it
                if (fleldChars.length > 1) {
                  fieldName = value.toLowerCase().split(' ').map(word => word.replace(word[0], word[0].toUpperCase())).join('');
                } else {
                  fieldName = value
                }
              } else if (el.url === "fhirpath") {
                fhirpath = value
              } else if (el.url === "function") {
                externalfunction = value
              } else if (el.url === "displayformat") {
                displayformat = value
              } else if (el.url === "autoGenerated") {
                fieldAutogenerated = value
              } else if(el.url === 'valueModifier') {
                valueModifier = value
              }
            }
            let displayData
            try {
              if(fhirpath) {
                if(fhirpath.startsWith('concat(')) {
                  fhirpath = fhirpath.substring(7, fhirpath.length-1)
                }
                let fhirpathes = fhirpath.split(',')
                for(let path of fhirpathes) {
                  let value
                  try {
                    value = FHIRPath.evaluate(data.resource, path);
                  } catch (error) {
                    logger.error(`Invalid fhirpath supplied ${path}`)
                    process.exit()
                  }
                  if(Array.isArray(value)) {
                    for(let val of value) {
                      if(val.reference) {
                        let displayFormat = element.find((el) => {
                          return el.url === 'displayformat'
                        })
                        let refResource = await this.getResourceFromReference(val.reference)
                        value = await this.resourceDisplayName(refResource, displayFormat)
                        value = [value]
                      }
                    }
                    value = value.join(',')
                  }
                  if(!displayData) {
                    displayData = value
                  } else {
                    displayData += ' ' + value
                  }
                }
              } else if(externalfunction) {
                let fncn = externalfunction.split(".")
                if(fncn.length !== 2) {

                }
                let functionname = fncn[1]
                let params = this.getExtFuncParams(functionname)
                functionname = functionname.split("(")[0]
                let currentrow = {}
                //check if all params are available in record, otherwise fetch records from ES
                let missing = false
                if(params) {
                  params = params.split(",")
                  for(let param of params) {
                    param = param.trim()
                    if(!record.hasOwnProperty(param)) {
                      missing = true
                      break
                    }
                  }
                }
                if(missing) {
                  //get row data
                  let query = {
                    query: {
                      terms: match
                    }
                  }
                  let url = URI(this.ESBaseURL).segment(reportDetails.name).segment('_search').toString()
                  await this.sendESRequest({
                    url,
                    method: 'GET',
                    data: query
                  }).then((response) => {
                    currentrow = response.data?.hits.hits[0]?._source
                    currentrow = _.merge(currentrow, record)
                  }).catch(() => {
                    return callback(null)
                  })
                } else {
                  currentrow = record
                }
                try {
                  externalfunction = require(this.ESModulesBasePath + "/" + fncn[0])
                } catch (error) {
                  logger.error(this.ESModulesBasePath + "/" + fncn[0] + ' Not found');
                  logger.error(error);
                }
                try {
                  displayData = await externalfunction[functionname](currentrow).catch((err) => {
                    logger.error(err);
                  })
                } catch (error) {
                  logger.error(error);
                }
              } else {
                let displayFormat = element.find((el) => {
                  return el.url === 'displayformat'
                })
                let value = await this.resourceDisplayName(data.resource, displayFormat)
                if(!displayData) {
                  displayData = value
                } else {
                  displayData += ' ' + value
                }
              }
            } catch (error) {
              logger.error(error);
            }
            let value
            if (((!displayData && displayData != 0) || (Array.isArray(displayData) && displayData.length === 1 && displayData[0] === undefined)) && data.resource.extension) {
              try {
                value = await this.getElementValFromExtension(data.resource.extension, fhirpath)
              } catch (error) {
                logger.error(error);
              }
            } else if (Array.isArray(displayData) && displayData.length === 1 && displayData[0] === undefined) {
              value = undefined
            } else if (Array.isArray(displayData)) {
              if(fieldName.startsWith('__') && orderedResource.multiple) {
                // value = displayData
                value = displayData.pop();
              } else {
                value = displayData.pop();
              }
            } else {
              value = displayData;
            }
            if (value || value === 0 || value === false) {
              if (typeof value == 'object') {
                if (value.reference && fieldAutogenerated) {
                  value = value.reference
                } else if (value.reference && !fieldAutogenerated) {
                  let referencedResource
                  try {
                    referencedResource = await this.getResourceFromReference(value.reference);
                  } catch (error) {
                    logger.error(error);
                  }
                  if (referencedResource) {
                    value = referencedResource.name
                  }
                } else {
                  value = JSON.stringify(value)
                }
              }
              if (fhirpath === 'id') {
                value = data.resource.resourceType + '/' + value
              }
              if(valueModifier) {
                let modVal = this.modifyValue(value, valueModifier)
                if(modVal) {
                  value = modVal
                }
              }
              if(this.checkType(value) === 'integer') {
                value = parseInt(value)
              } else if(this.checkType(value) === 'decimal') {
                value = parseFloat(value)
              }
              record[fieldName] = value
            } else {
              record[fieldName] = null
            }
          }
        }
        record[orderedResource.name] = id
        let ctx = '';
        for (let field in record) {
          // cleaning to escape ' char
          if (record[field] && typeof record[field] === 'string') {
            let recordFieldArr = record[field].split('')
            for (let recordFieldIndex in recordFieldArr) {
              let char = recordFieldArr[recordFieldIndex]
              if (char === "'") {
                recordFieldArr[recordFieldIndex] = "\\'"
              }
            }
            record[field] = recordFieldArr.join('');
          }
          if(deleteRecord || !record[field]) {
            ctx += `ctx._source['${field}']=null;`;
            if(field.startsWith('__')) {
              let truncateResources = this.getChildrenResources(orderedResource.name)
              let truncateFields = this.getResourcesFields(truncateResources)
              for(let truncField of truncateFields) {
                ctx += `ctx._source['${truncField.field}']=null;`;
              }
            }
          } else {
            ctx += `ctx._source['${field}']='${record[field]}';`;
          }
        }
        // truncate fields of any other resources that are linked to this resource
        if(deleteRecord) {
          let childrenResources = this.getChildrenResources(orderedResource.name);
          let fields = this.getResourcesFields(childrenResources)
          for(let field of fields) {
            ctx += `ctx._source['${field.field}']=null;`;
          }
        }

        let body = {
          script: {
            lang: 'painless',
            source: ctx
          },
          query: {
            terms: match ,
          },
        };
        // check if linkTo (__linkname_link) has a cardinality of 1..* and dupplicate the request per linkTo
        let dupBasedOnfields = []
        for(let rec in record) {
          if(rec.startsWith('__') && rec.endsWith('_link') && record[rec] && record[rec].split(',').length > 1) {
            dupBasedOnfields.push(rec)
          }
        }
        let modifiedRecAndBody = []
        if(dupBasedOnfields.length > 0) {
          for(let index in dupBasedOnfields) {
            let dupBasedOnfield = dupBasedOnfields[index]
            if(modifiedRecAndBody.length > 0) {
              let partialMods = []
              for(let modIndex in modifiedRecAndBody) {
                modified = modifiedRecAndBody[modIndex]
                let partialMod = this.dupplicateRequest(modified.record, modified.body, dupBasedOnfield)
                partialMods = partialMods.concat(partialMod)
              }
              modifiedRecAndBody = partialMods
            } else {
              modifiedRecAndBody = this.dupplicateRequest(record, body, dupBasedOnfield)
            }
          }
        } else {
          modifiedRecAndBody = [{
            record,
            body
          }]
        }
        async.eachSeries(modifiedRecAndBody, (modified, nxtMod) => {
          let extraTerms = []
          if(dupBasedOnfields.length > 0) {
            for(let dupBasedOnfield of dupBasedOnfields) {
              let tmpTerm = {
                terms: {}
              }
              tmpTerm.terms[dupBasedOnfield + '.keyword'] = [modified.record[dupBasedOnfield]]
              extraTerms.push(tmpTerm)
            }
          }
          if(!deleteRecord) {
            this.updateESDocument(modified.body, modified.record, reportDetails.name, orderedResource, data.resource, deleteRecord, extraTerms, () => {
              //if this resource supports multiple rows i.e Group linked to Practitioner, then cache resources in series
              if(orderedResource.multiple || wait) {
                return nxtMod()
              }
            })
            if(!orderedResource.multiple && !wait) {
              return nxtMod()
            }
          } else {
            //if this is the primary resource then delete the whole document, otherwise delete respective fields data
            if(!orderedResource.hasOwnProperty('linkElement')) {
              let query = {
                query: {
                  bool: {
                    must: [{
                      terms: modified.body.query.terms
                    }]
                  }
                }
              }
              if(extraTerms.length > 0) {
                query.query.bool.must = query.query.bool.must.concat(extraTerms)
              }
              this.deleteESDocument(query, reportDetails.name).then(() => {
                return nxtMod()
              }).catch((err) => {
                logger.error(err);
                return nxtMod()
              })
            } else {
              this.updateESDocument(modified.body, modified.record, reportDetails.name, orderedResource, data.resource, deleteRecord, extraTerms, () => {
                //if this resource supports multiple rows i.e Group linked to Practitioner, then cache resources in series
                if(orderedResource.multiple || wait) {
                  return nxtMod()
                }
              })
              if(!orderedResource.multiple && !wait) {
                return nxtMod()
              }
            }
          }
        }, () => {
          return nxtResource();
        })
      }).catch((err) => {
        logger.error(err);
        return nxtResource();
      })
    }, () => {
      return callback()
    });
  }

  getExtFuncParams(fn) {
    //get anything inside({})
    let regex = /\{([^}]*)\}/;
    let match = fn.match(regex);
    //if not, try anything inside ()
    if(!match){
      regex = /\(([^)]*)\)/;
      match = fn.match(regex);
    }
    if (match) {
        return match[1];
    } else {
        return "";
    }
  }

  fixDataInconsistency(reportDetails, orderedResource, callback) {
    logger.info("Fixing data inconsistency for resource " + orderedResource.resource)
    //these must be run in series
    let fieldStillMissing = false
    async.series({
      /**
       * this fix missing data i.e __location_link is available but location is missing
       * Example: PractitionerRole didn't have a location, then later on a location get assigned to this PractitionerRole,
       * Location resource will not be pulled as it was not changed, it is the PractitionerRole alone that was updated, this piece of code will check and force an update.
       */
      fixMissing: (callback) => {
        //ignore reversed linked resources as it doesnt apply for them i.e role linked to practitioner, it doesnt ignore when practitioner is linked to role
        if((orderedResource.linkTo && orderedResource.linkTo.split('.').length === 1) || (orderedResource.linkTo && orderedResource.linkTo.split('.').length === 2 && orderedResource.linkTo.split('.')[1] === 'id')) {
          return callback(null)
        }
        let query = {
          query: {
            bool: {
              must_not: {
                exists: {
                  field: orderedResource.name
                }
              },
              must: {
                range: {
                  lastUpdated: {
                    gt: this.lastEndedIndexingTime
                  }
                }
              }
            }
          }
        }
        runCleaner(query, false, this, (missing) => {
          if(missing) {
            fieldStillMissing = true
          }
          return callback(null)
        })
      },
      //this fix invalid data i.e __location_link not equal to location, and location is always invalid, not __location_link
      differences: (callback) => {
        //ignore reversed linked resources as it doesnt apply for them i.e role linked to practitioner, it doesnt ignore when practitioner is linked to role
        if((orderedResource.linkTo && orderedResource.linkTo.split('.').length === 1) || (orderedResource.linkTo && orderedResource.linkTo.split('.').length === 2 && orderedResource.linkTo.split('.')[1] === 'id')) {
          return callback(null)
        }
        if(!orderedResource.linkElement || fieldStillMissing) {
          return callback(null)
        }
        let query = {
          query: {
            bool: {
              must: [{
                script: {
                  script: {
                    source: `if(doc['__${orderedResource.name}_link.keyword'].size() != 0 && doc['${orderedResource.name}.keyword'].size() != 0) {if(doc['__${orderedResource.name}_link.keyword'].value != doc['${orderedResource.name}.keyword'].value){return true}}`,
                    lang: "painless"
                  }
                }
              }, {
                range: {
                  lastUpdated: {
                    gt: this.lastEndedIndexingTime
                  }
                }
              }]
            }
          }
        }
        runCleaner(query, true, this, () => {
          return callback(null)
        })
      }
    }, () => {
      return callback()
    })

    function runCleaner(query, ignoreReverseLinked, me, callback) {
      try {
        me.getESDocument(reportDetails.name, query, (err, documents) => {
          if(documents.length === 0) {
            return callback(null)
          }
          /**
           * this is for reversed linked resources i.e Practitioner and PractitionerRole
           */
          let reverseLink = false
          // end of reversed linked resources
          let resIds = []
          async.eachOfSeries(documents, (doc, index, nxtDoc) => {
            if(doc._source['__' + orderedResource.name + '_link']) {
              if(resIds.length === 0) {
                let linkResType = doc._source['__' + orderedResource.name + '_link'].split('/')[0]
                if(linkResType !== orderedResource.resource) {
                  reverseLink = true
                  if(ignoreReverseLinked) {
                    return nxtDoc();
                  }
                }
              }
              resIds.push(doc._source['__' + orderedResource.name + '_link'])
            } else {
              //logger.error(JSON.stringify(doc,0,2));
              //logger.error('There is a serious data inconsistency that needs to be addressed on index ' + reportDetails.name + ' and index id ' + doc._id + ', field ' + '__' + orderedResource.name + '_link' + ' is missing');
              return nxtDoc();
            }
            let ids
            if(resIds.length === 100 || index === (documents.length - 1)) {
              ids = resIds.join(',')
              resIds = []
            } else {
              return nxtDoc()
            }

            if(!ids || ids == 'null' || (ignoreReverseLinked && reverseLink)) {
              return nxtDoc()
            }
            let processedRecords = []
            let url = URI(me.FHIRBaseURL)
              .segment(orderedResource.resource)
              .addQuery('_count', 200)
            if(!reverseLink) {
              url = url.addQuery('_id', ids)
            } else {
              if(!orderedResource.linkElementSearchParameter) {
                logger.error('linkElementSearchParameter is missing, cant fix data inconsistency');
                return callback()
              }
              url = url.addQuery(orderedResource.linkElementSearchParameter, ids)
            }
            url = url.toString()
            async.whilst(
              (callback) => {
                return callback(null, url !== null)
              },
              (callback) => {
                axios.get(url, {
                  headers: {
                    'Cache-Control': 'no-cache',
                  },
                  withCredentials: true,
                  auth: {
                    username: me.FHIRUsername,
                    password: me.FHIRPassword,
                  },
                }).then(response => {
                  me.totalResources = response.data.total;
                  url = null;
                  const next = response.data.link.find(
                    link => link.relation === 'next'
                  );
                  if (next) {
                    url = next.url
                  }
                  if (response.data.entry && response.data.entry.length > 0) {
                    me.count = 1;
                    me.processResource(response.data.entry, orderedResource, reportDetails, processedRecords, false, () => {
                      return callback(null, url);
                    })
                  } else {
                    return callback(null, url);
                  }
                }).catch((err) => {
                  logger.error('Error occured while getting resource data');
                  logger.error(err);
                  return callback(null, null)
                })
              },
              () => {
                return nxtDoc()
              }
            )
          }, async() => {
            try {
              await me.refreshIndex(reportDetails.name);
            } catch (error) {
              logger.error(error);
            }
            return callback()
          })
        })
      } catch (error) {
        logger.error(error);
        return callback()
      }
    }
  }

  modifyValue(value, modifier) {
    // let modifier = 'send_status==completed||send_status==wow?Sent:send_status==entered-in-error?Failed:Unknown'
    let steps = modifier.split(':')
    let modifiedValue = ''
    for(let step of steps) {
      let stepValueArr = step.split('?')
      if(stepValueArr.length === 1) {
        modifiedValue = step
        break
      }
      let stepValue = step.split('?')[1]
      step = step.split('?')
      step.pop()
      step = step.join()
      let opts = step.split('||')
      for(let opt of opts) {
        opt = opt.replace('===', '=')
        opt = opt.replace('==', '=')
        opt = opt.replace('!==', '!=')
        if(opt.includes('=') && value == opt.split('=')[1]) {
          modifiedValue = stepValue
          break;
        } else if(opt.includes('!=') && value != opt.split('=')[1]) {
          modifiedValue = stepValue
          break;
        }
      }
      if(modifiedValue) {
        break
      }
    }
    return modifiedValue
  }

  dupplicateRequest(record, body, dupBasedOnfield) {
    let modifiedData = []
    let links = record[dupBasedOnfield].split(',')
    for(let link of links) {
      let newRecord = _.cloneDeep(record)
      newRecord[dupBasedOnfield] = link
      let newBody = _.cloneDeep(body)
      let source = newBody.script.source
      let sources = source.split(';')
      for(let index in sources) {
        if(sources[index].startsWith(`ctx._source['${dupBasedOnfield}']`) || sources[index].startsWith(`ctx._source["${dupBasedOnfield}"]`) || sources[index].startsWith(`ctx._source.${dupBasedOnfield}`)) {
          sources[index] = `ctx._source.${dupBasedOnfield}='${link}'`
          break
        }
      }
      newBody.script.source = sources.join(';')
      modifiedData.push({
        record: newRecord,
        body: newBody
      })
    }
    return modifiedData
  }

  generateId(ids) {
    if(!ids || !Array.isArray(ids) || ids.length === 0) {
      return ids
    }
    if(ids.length < 2) {
      return ids[0]
    }
    return uuid5(ids.join(''), '8f84db7c-93f9-4800-8aa2-1c8913a1dc54')
  }

  dataTypeConversion(value) {
    let v = Number (value);
    return !isNaN(v) ? v :
          value === "undefined" ? undefined
        : value === "null" ? null
        : value === "true" ? true
        : value === "false" ? false
        : value
  }

  checkType(value) {
    let floor = Math.floor(value)
    if(isNaN(value)) {
      return 'string'
    } else if (value == floor) {
      return 'integer'
    } else {
      return 'decimal'
    }
  }


}
module.exports = {
  CacheFhirToES
}