etl-routes.js

/*jshint -W003, -W098, -W117, -W026 */
'use strict';
// var dao = require('./etl-dao');
var dao = require('./etl-dao');
var patientList = require('./dao/patient-list/patient-list-dao');
var patientReferralDao = require('./dao/patient-referral/patient-referral-dao');
var preRequest = require('./pre-request-processing');
var pack = require('./package');
var winston = require('winston');
var path = require('path');
var _ = require('lodash');
var Joi = require('joi');
var eidLabData = require('./eid-data-synchronization/eid-lab-results');
var eidService = require('./service/eid.service');
var patientListCompare = require('./service/patient-list-compare.service.js');
var Boom = require('boom');
var authorizer = require('./authorization/etl-authorizer');
var config = require('./conf/config');
var privileges = authorizer.getAllPrivileges();
var etlHelpers = require('./etl-helpers.js');
var crypto = require('crypto');
var moment = require('moment');
var motd = require('./dao/motd_notification/motd_notification-dao');
var patientProgramService = require('./programs/patient-program-base.service.js');
var resolveClinicDashboardFilterParams = require('./resolve-program-visit-encounter-Ids/resolve-program-visit-encounter-Ids');
var departmentProgramsService = require('./departments/departments-programs.service');
var enrollmentService = require('./service/enrollment.service');
var resolveLocationUuidToId = require('./location/resolve-location-uuid-to-id');
var resolveProgramEnrollmentFilterParams = require('./resolve-program-visit-encounter-Ids/resolve-program-visit-encounter-idsv2');
var programVisitEncounterResolver = require('./resolve-program-visit-encounter-Ids/resolve-program-visit-encounter-idsv2');
var imagingService = require('./service/radilogy-imaging.service');
var oncologyReportsService = require('./oncology-reports/oncology-reports-service');
var pocEidPayloadHelper = require('./app/lab-integration/utils/poc-eid-payload-helper.js');
import { LabSyncService } from './app/lab-integration/lab-sync-service';
import { LabClient } from './app/lab-integration/utils/lab-client';
import { MonthlyScheduleService } from './service/monthly-schedule-service';
import { PatientStatusChangeTrackerService } from './service/patient-status-change-tracker-service';
import { clinicalArtOverviewService } from './service/clinical-art-overview.service';
import { labOrdersService } from './service/lab-orders.service';

import { hivComparativeOverviewService } from './service/hiv-comparative-overview.service';
import { clinicalPatientCareStatusOverviewService } from './service/clinical-patient-care-status-overview';
import { SlackService } from './service/slack-service';
import { PatientRegisterReportService } from './service/patient-register-report.service';
import { HivSummaryIndicatorsService } from './app/reporting-framework/hiv/hiv-summary-indicators.service';
import { HivSummaryMonthlyIndicatorsService } from './app/reporting-framework/hiv/hiv-summary-monthly-indicators.service';
import { PatientMonthlyStatusHistory } from './service/patient-monthly-status-history';
import { cohortUserService } from './service/cohort-user.service.js';
import { patientsRequiringVLService } from './service/patients-requiring-viral-load.service';
import { patientCareCascadeService } from './service/patient-care-cascade-report.service';
import { patientMedicationHistService } from './service/patient-medication-history.service';
import { PatientMedicalHistoryService } from './service/patient-medical-history.service';

import { Moh731Report } from './app/reporting-framework/hiv/moh-731.report';
import { BreastCancerMonthlySummaryService } from './service/breast-cancer-monthly-summary.service';
import { CervicalCancerMonthlySummaryService } from './service/cervical-cancer-monthly-summary.service';

import { LungCancerMonthlySummaryService } from './service/lung-cancer-monthly-summary.service';
import { PatientlistMysqlReport } from './app/reporting-framework/patientlist-mysql.report';
import { BaseMysqlReport } from './app/reporting-framework/base-mysql.report';
import { CDMReportingService } from './service/cdm/cdm-reporting.service';
import { PatientReferralService } from './service/patient-referral.service';
import { CombinedBreastCervicalCancerMonthlySummary } from './service/combined-breast-cervical-cancer-monthly-summary.service';
import { LungCancerTreatmentSummary } from './service/lung-cancer-treatment-summary.service';
import { SurgeService } from './service/surge-reports/surge-report.service';

var patientReminderService = require('./service/patient-reminder.service.js');
var kibanaService = require('./service/kibana.service');
import { HeiSummaryService } from './service/moh-408-service';

import { RetentionAppointmentTracingService } from './service/retention-appointment-tracing-service';
import { PatientGainLosesService } from './service/patient-gain-loses.service';
import { PrepReminderService } from './service/prep-reminder/prep-reminder.service';
import { HIVGainsAndLossesService } from './service/gains-and-losses/hiv-gains-losses-service';
const cervicalCancerScreeningService = require('./service/cervical-cancer-screening-service');
import { MOH412Service } from './service/moh-412/moh-412';
const syncPreproc = require('./app/lab-integration/lab-sync-pre-processor.service');
import { DefaulterListService } from './service/defaulter-list-service';
import { ClinicFlowService } from './service/clinic-flow-service';
import { getPatientCovidVaccinationStatus } from './service/covid-19/covid-19-vaccination-summary';
import { Covid19MonthlyReport } from './service/covid-19/covid-19-monthly-report';

module.exports = (function () {
  var routes = [
    {
      method: 'GET',
      path: '/',
      config: {
        plugins: {
          hapiAuthorization: false
        },
        handler: function (request, reply) {
          console.log('default rote', request.path);

          reply('Welcome to Ampath ETL service.');
          //return reply(Boom.forbidden('Not this end point bruh'));
        },
        description: 'Home',
        notes: 'Returns a message that shows ETL service is running.',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/user-feedback',
      config: {
        plugins: {
          hapiAuthorization: false
        },
        auth: false,
        handler: function (request, reply) {
          var message = request.payload;
          let service = new SlackService();
          service
            .postFeedbackToPoc(message)
            .then((success) => {
              reply(success);
            })
            .catch((err) => {
              reply(Boom.badData(error));
            });
        },
        description: 'Endpoint that receives feedback from a private channel',
        notes:
          'Specify the private channel name,message  count and oldest timestamp in the url parameters',
        tags: ['api', 'feedback']
      }
    },
    {
      method: 'GET',
      path: '/etl/clinic-lab-orders',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              request.query.groupBy = 'groupByPerson,groupByd';
              let compineRequestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                'clinic-lab-orders-report',
                ['startDate', 'endDate', 'locations', 'groupBy'],
                compineRequestParams
              );

              dao
                .runReport(reportParams)
                .then((result) => {
                  _.each(result.result, (row) => {
                    row.order_type = etlHelpers.getTestsOrderedNames(
                      row.order_type
                    );
                    row.cur_meds = etlHelpers.getARVNames(row.cur_meds);
                  });
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description:
          'Get a list of patients who made lab orders on a selected date',
        notes:
          'Returns a list of patients patients who made lab orders through selected clinics on a selected date',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/poc-user-feedback/{count*2}',
      config: {
        auth: false,
        handler: function (request, reply) {
          let service = new SlackService();
          const urlparts = request.params.count.split('/');
          service
            .getPocMessages(
              encodeURIComponent(urlparts[0]),
              encodeURIComponent(urlparts[1])
            )
            .then((res) => {
              reply(res);
            })
            .catch((error) => {
              reply(Boom.badData(error));
            });
        },
        description: 'Endpoint that gets user feedback from poc',
        notes:
          'Specify message count and oldest timestamp in the url parameters',
        tags: ['api', 'feedback']
      }
    },
    {
      method: 'POST',
      path: '/etl/posttochannel',
      config: {
        plugins: {
          hapiAuthorization: false
        },
        auth: false,
        handler: function (request, reply) {
          var message = request.payload;
          var channel = request.payload.channel;
          let service = new SlackService();
          service
            .postToChannels(message, channel)
            .then(function (success) {
              reply(success);
            })
            .catch((err) => {
              reply(Boom.badData(error));
            });
        },
        description:
          'Endpoint that post user feedback from client to  a public slack channel',
        notes: 'Specify the public channel name in the payload',
        tags: ['api', 'feedback']
      }
    },
    {
      method: 'POST',
      path: '/etl/posttogroup',
      config: {
        plugins: {
          hapiAuthorization: false
        },
        auth: false,
        handler: function (request, reply) {
          var message = request.payload;
          var channel = request.payload.group;
          let service = new SlackService();
          service
            .postToGroups(message, channel)
            .then(function (success) {
              reply(success);
            })
            .catch((err) => {
              reply(Boom.badData(error));
            });
        },
        description:
          'Endpoint that post user feedback from client to  a private slack channel',
        notes: 'Specify the private channel name in the payload',
        tags: ['api', 'feedback']
      }
    },

    {
      method: 'GET',
      path: '/etl/channel-user-feedback/{count*2}',
      /*  /etl/channel-user-feedback/10/1504081732.000145   */
      config: {
        auth: false,
        handler: function (request, reply) {
          let service = new SlackService();
          const urlparts = request.params.count.split('/');
          service
            .getChannelMessages(
              encodeURIComponent(urlparts[0]),
              encodeURIComponent(urlparts[1])
            )
            .then((res) => {
              reply(res);
            })
            .catch((error) => {
              reply(Boom.badData(error));
            });
        },
        description: 'Endpoint that receives feedback from a public channel',
        notes:
          'Specify message  count and oldest timestamp in the url parameters',
        tags: ['api', 'feedback']
      }
    },
    {
      method: 'GET',
      path: '/etl/channel-user-feedback/{count*3}',
      /*  /etl/channel-user-feedback/poc-user-feedback/10/1504081732.000145   */
      config: {
        auth: false,
        handler: function (request, reply) {
          let service = new SlackService();
          const urlparts = request.params.count.split('/');
          service
            .getFromChannel(
              encodeURIComponent(urlparts[0]),
              encodeURIComponent(urlparts[1]),
              encodeURIComponent(urlparts[2])
            )
            .then((res) => {
              reply(res);
            })
            .catch((error) => {
              reply(Boom.badData(error));
            });
        },
        description: 'Endpoint that receives feedback from a public channel',
        notes:
          'Specify the public channel name,message  count and oldest timestamp in the url parameters',
        tags: ['api', 'feedback']
      }
    },
    {
      method: 'GET',
      path: '/etl/group-user-feedback/{count*3}',
      /*  /etl/channel-user-feedback/poc-user-feedback/10/1504081732.000145   */
      config: {
        auth: false,
        handler: function (request, reply) {
          let service = new SlackService();
          const urlparts = request.params.count.split('/');
          service
            .getFromGroup(
              encodeURIComponent(urlparts[0]),
              encodeURIComponent(urlparts[1]),
              encodeURIComponent(urlparts[2])
            )
            .then((res) => {
              reply(JSON.parse(res));
            })
            .catch((error) => {
              reply(Boom.badData(error));
            });
        },
        description: 'Endpoint that receives feedback from a private channel',
        notes:
          'Specify the private channel name,message  count and oldest timestamp in the url parameters',
        tags: ['api', 'feedback']
      }
    },
    {
      method: 'GET',
      path: '/etl/get-monthly-schedule',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            programVisitEncounterResolver
              .resolveProgramVisitTypeEncounterUuidsParamsToIds(request.query)
              .then((resolve) => {
                let encounterIds = resolve.encounterTypeIds;
                let visitTypeIds = resolve.visitTypesIds;
                let programTypeIds = resolve.programTypeIds;
                if (encounterIds.length > 0) {
                  request.query.encounterIds = encounterIds;
                }
                if (visitTypeIds.length > 0) {
                  request.query.visitTypeIds = visitTypeIds;
                }
                if (programTypeIds.length > 0) {
                  request.query.programTypeIds = programTypeIds;
                }

                return resolveLocationUuidToId.resolveLocationUuidsParamsToIds(
                  request.query
                );
              })
              .then((result) => {
                let locationIds = result;
                request.query.locations = locationIds;
                let combineRequestParams = Object.assign(
                  {},
                  request.query,
                  request.params
                );
                let service = new MonthlyScheduleService();
                service
                  .getMonthlyScheduled(combineRequestParams)
                  .then((result) => {
                    reply(result);
                  })
                  .catch((error) => {
                    reply(error);
                  });
              })
              .then((error) => {
                console.log(error);
              });
          }
        },
        description: 'Get monthly schedule',
        notes: 'Returns a list of appointments,visits and has not returned',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/daily-appointments/{startDate}',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              request.query.groupBy = 'groupByPerson,groupByd';
              programVisitEncounterResolver
                .resolveProgramVisitTypeEncounterUuidsParamsToIds(request.query)
                .then((resolve) => {
                  // console.log('Daily appointments', resolve);
                  let encounterIds = resolve.encounterTypeIds;
                  let visitTypeIds = resolve.visitTypesIds;
                  let programTypeIds = resolve.programTypeIds;
                  if (programTypeIds.length > 0) {
                    request.query.programTypeIds = programTypeIds;
                  }
                  if (visitTypeIds.length > 0) {
                    request.query.visitTypeIds = visitTypeIds;
                  }
                  if (encounterIds.length > 0) {
                    request.query.encounterIds = encounterIds;
                  }

                  let combineRequestParams = Object.assign(
                    {},
                    request.query,
                    request.params
                  );
                  // let reportParams = etlHelpers.getReportParams('daily-appointments', ['startDate', 'locations', 'encounterIds', 'visitTypeIds', 'programTypeIds', 'groupBy'], compineRequestParams);
                  combineRequestParams.limitParam = combineRequestParams.limit;
                  combineRequestParams.offSetParam =
                    combineRequestParams.startIndex;
                  combineRequestParams.endDate = combineRequestParams.startDate;
                  let service = new PatientlistMysqlReport(
                    'dailyAppointmentsAggregate',
                    combineRequestParams
                  );
                  service
                    .generatePatientListReport(['patients'])
                    .then((result) => {
                      let returnedResult = {};
                      returnedResult.schemas = result.schemas;
                      returnedResult.sqlQuery = result.sqlQuery;
                      returnedResult.result = result.results.results;
                      _.each(returnedResult.result, (item) => {
                        item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                      });
                      reply(returnedResult);
                    })
                    .catch((error) => {
                      reply(error);
                    });
                })
                .catch((error) => {
                  console.log(error);
                });
            });
          }
        },
        description: 'Get daily appointments list',
        notes: 'Returns a list of patients with appointments',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/daily-visits/{startDate}',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              request.query.groupBy = 'groupByPerson,groupByd';
              programVisitEncounterResolver
                .resolveProgramVisitTypeEncounterUuidsParamsToIds(request.query)
                .then((resolve) => {
                  let encounterIds = resolve.encounterTypeIds;
                  let visitTypeIds = resolve.visitTypesIds;
                  let programTypeIds = resolve.programTypeIds;
                  if (programTypeIds.length > 0) {
                    request.query.programTypeIds = programTypeIds;
                  }
                  if (visitTypeIds.length > 0) {
                    request.query.visitTypeIds = visitTypeIds;
                  }
                  if (encounterIds.length > 0) {
                    request.query.encounterIds = encounterIds;
                  }
                  let compineRequestParams = Object.assign(
                    {},
                    request.query,
                    request.params
                  );
                  compineRequestParams.limitParam = compineRequestParams.limit;
                  compineRequestParams.offSetParam =
                    compineRequestParams.startIndex;
                  let service = new PatientlistMysqlReport(
                    'dailyAttendanceAggregate',
                    compineRequestParams
                  );
                  service
                    .generatePatientListReport(['patients'])
                    .then((result) => {
                      let returnedResult = {};
                      returnedResult.schemas = result.schemas;
                      returnedResult.sqlQuery = result.sqlQuery;
                      returnedResult.result = result.results.results;
                      _.each(returnedResult.result, (item) => {
                        item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                      });
                      reply(returnedResult);
                    })
                    .catch((error) => {
                      reply(error);
                    });
                })
                .catch((error) => {
                  console.log(error);
                });
            });
          }
        },
        description: 'Get daily attendance list',
        notes: 'Returns a facility daily attendance list',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/daily-has-not-returned/{startDate}',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              request.query.groupBy = 'groupByPerson,groupByd';
              programVisitEncounterResolver
                .resolveProgramVisitTypeEncounterUuidsParamsToIds(request.query)
                .then((resolve) => {
                  let encounterIds = resolve.encounterTypeIds;
                  let visitTypeIds = resolve.visitTypesIds;
                  let programTypeIds = resolve.programTypeIds;
                  if (programTypeIds.length > 0) {
                    request.query.programTypeIds = programTypeIds;
                  }
                  if (visitTypeIds.length > 0) {
                    request.query.visitTypeIds = visitTypeIds;
                  }
                  if (encounterIds.length > 0) {
                    request.query.encounterIds = encounterIds;
                  }
                  let combineRequestParams = Object.assign(
                    {},
                    request.query,
                    request.params
                  );
                  combineRequestParams.limitParam = combineRequestParams.limit;
                  combineRequestParams.offSetParam =
                    combineRequestParams.startIndex;
                  combineRequestParams.endDate = combineRequestParams.startDate;
                  //let reportParams = etlHelpers.getReportParams('daily-has-not-returned', ['startDate', 'locations', 'encounterIds', 'visitTypeIds', 'programTypeIds', 'groupBy'], compineRequestParams);
                  //reportParams.limit = 100000;
                  let service = new PatientlistMysqlReport(
                    'dailyHasNotReturnedAggregate',
                    combineRequestParams
                  );
                  service
                    .generatePatientListReport(['patients'])
                    .then((result) => {
                      let returnedResult = {};
                      returnedResult.schemas = result.schemas;
                      returnedResult.sqlQuery = result.sqlQuery;
                      returnedResult.result = result.results.results;
                      _.each(returnedResult.result, (item) => {
                        item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                      });
                      reply(returnedResult);
                    })
                    .catch((error) => {
                      reply(error);
                    });
                })
                .catch((error) => {
                  console.log('Error', error);
                  reply(error);
                });
            });
          }
        },
        description:
          'Get a list of patients who did not attend a scheduled visit',
        notes:
          'Returns a list of patients who did not attend their scheduled visits on the selected date',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/clinic-lab-orders/{dateActivated}',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              request.query.groupBy = 'groupByPerson,groupByd';
              let compineRequestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                'clinic-lab-orders-report',
                ['dateActivated', 'locations', 'groupBy'],
                compineRequestParams
              );
              let report = new BaseMysqlReport(
                'clinicLabOrdersReport',
                reportParams.requestParams
              );
              report
                .generateReport()
                .then((results) => {
                  _.each(results.results.results, (row) => {
                    row.order_type = etlHelpers.getTestsOrderedNames(
                      row.order_type
                    );
                  });
                  results.result = results.results.results;
                  delete results['results'];
                  reply(results);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description:
          'Get a list of patients who made lab orders on a selected date',
        notes:
          'Returns a list of patients patients who made lab orders through selected clinics on a selected date',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/defaulter-list',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            request.query.reportName = 'defaulter-list';
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );

              let requestCopy = _.cloneDeep(requestParams);
              let reportParams = etlHelpers.getReportParams(
                request.query.reportName,
                ['locationUuids', 'locations'],
                requestParams
              );

              const defaulterService = new DefaulterListService();

              defaulterService
                .getPatientListReport(requestParams)
                .then((results) => {
                  _.each(results.result, (item) => {
                    item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                  });
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            });
          }
        },
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        description: "Get a location's defaulter list",
        notes: "Returns a location's defaulter list.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{patientUuids}/cdm-summary',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          let requestParams = Object.assign({}, request.query, request.params);
          let service = new CDMReportingService();
          service
            .getPatientSummaryReport(requestParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get patient CDM summary',
        notes:
          "Returns a list of historical patient's HIV summary with the given patient uuid. " +
          "A patient's CDM summary includes details such as last visit date, " +
          "current medication regimen etc. as at that encounter's date. ",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            patientUuids: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{patientUuids}/medication-change',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          let requestParams = Object.assign({}, request.query, request.params);
          let service = new CDMReportingService();
          service
            .getPatientMedicationHistoryReport(requestParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get patient medication history',
        notes:
          "Returns a list of historical patient's HIV summary with the given patient uuid. " +
          "A patient's medication history details such as medication by encounter, " +
          "current medication  etc. as at that encounter's date. ",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            patientUuids: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{patientUuid}/hiv-clinical-reminder/{referenceDate}',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          let combineRequestParams = Object.assign(
            {},
            request.query,
            request.params
          );
          combineRequestParams.limitParam = 1;
          let prepReminder = new PrepReminderService();
          prepReminder.isPatientEnrolledInPrep(request.params).then((b) => {
            if (b) {
              let reportParams = etlHelpers.getReportParams(
                'prepClinicalReminder',
                ['referenceDate', 'patientUuid', 'offSetParam', 'limitParam'],
                combineRequestParams
              );
              let report = new BaseMysqlReport(
                'prepClinicalReminderReport',
                reportParams.requestParams
              );
              report
                .generateReport()
                .then((results) => {
                  try {
                    if (results.results.results.length > 0) {
                      let processedResults = prepReminder.generateReminders(
                        results.results.results
                      );
                      results.result = {
                        person_id: results.results.results[0].person_id,
                        person_uuid: results.results.results[0].uuid,
                        reminders: processedResults
                      };
                    } else {
                      results.result = {
                        person_uuid: combineRequestParams.patientUuid,
                        reminders: []
                      };
                    }
                    reply(results);
                  } catch (error) {
                    console.log('Error generating prep reminders', error);
                    reply(Boom.badImplementation('An internal error occurred'));
                  }
                })
                .catch((error) => {
                  console.log('Error generating prep reminders', error);
                  reply(Boom.badImplementation('An internal error occurred'));
                });
            } else {
              let EIDLabReminderService = require('./service/eid/eid-lab-reminder.service');
              EIDLabReminderService.pendingEIDReminders(
                request.params,
                config.hivLabSystem
              )
                .then((eidReminders) => {
                  combineRequestParams.referenceDate =
                    combineRequestParams.referenceDate + ' 23:59:59';
                  let reportParams = etlHelpers.getReportParams(
                    'clinical-reminder-report',
                    [
                      'referenceDate',
                      'patientUuid',
                      'offSetParam',
                      'limitParam'
                    ],
                    combineRequestParams
                  );
                  let report = new BaseMysqlReport(
                    'clinicalReminderReport',
                    reportParams.requestParams
                  );
                  report
                    .generateReport()
                    .then((results) => {
                      try {
                        if (
                          results.results.results.length > 0 &&
                          results.results.results[0].hide_patient_reminder === 0
                        ) {
                          patientReminderService
                            .generateReminders(
                              results.results.results,
                              eidReminders
                            )
                            .then((res) => {
                              results.result = res;
                              reply(results);
                            });
                        } else {
                          results.result = {
                            person_uuid: combineRequestParams.person_uuid,
                            reminders: []
                          };
                          reply(results);
                        }
                      } catch (error) {
                        console.log('Error generating reminders', error);
                        reply(
                          Boom.badImplementation('An internal error occurred')
                        );
                      }
                    })
                    .catch((error) => {
                      console.log('Error generating reminders', error);
                      reply(
                        Boom.badImplementation('An internal error occurred')
                      );
                    });
                })
                .catch((err) => {
                  console.log('EID lab results err', err);
                  reply(err);
                });
            }
          });
        },
        description:
          'Get a list of reminders for selected patient and indicators',
        notes:
          'Returns a  list of reminders for selected patient and indicators on a given reference date',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/forms/error',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          dao.logError(request, reply);
        }
      }
    },
    {
      method: 'POST',
      path: '/javascript-errors',
      config: {
        handler: function (request, reply) {
          if (request.payload) {
            var logger = new winston.Logger({
              transports: [
                new winston.transports.File({
                  level: 'info',
                  filename: 'client-logs.log',
                  handleExceptions: true,
                  json: true,
                  colorize: false
                })
              ],
              exitOnError: false
            });
            logger.add(require('winston-daily-rotate-file'), {
              filename: path.join(__dirname, 'logs', 'client-logs.log')
            });
            logger.info(request.payload);
          }

          reply({
            message: 'ok'
          });
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getPatient(request, reply);
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/program-visit-configs',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          // var requestParams = Object.assign({}, request.query, request.params);
          reply(patientProgramService.getAllProgramsConfig());
        },
        description: 'Get a list of programs ',
        notes: 'Returns a  list of programs',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            // patientUuid: Joi.string()
            //     .required()
            //     .description("The patient's uuid(universally unique identifier)."),
          }
        }
      }
    },
    {
      method: 'GET',
      path:
        '/etl/patient/{patientUuid}/program/{programUuid}/enrollment/{enrollmentUuid}',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          const requestParams = Object.assign(
            {},
            request.query,
            request.params
          );

          const patientUuid = requestParams.patientUuid;
          const programUuid = requestParams.programUuid;
          const enrollment = requestParams.enrollmentUuid;
          const locationUuid = requestParams.intendedLocationUuid || '';
          const retroSpective = requestParams.retroSpective;
          const visitDate = requestParams.visitDate;

          patientProgramService
            .getPatientProgramVisits(
              patientUuid,
              programUuid,
              enrollment,
              locationUuid,
              retroSpective,
              visitDate
            )
            .then((programVisits) => {
              reply(programVisits);
            })
            .catch((error) => {
              reply(Boom.badImplementation('An internal error occurred'));
            });
        },
        description: 'Get program config of a patient',
        notes: 'Returns program config  of a patient',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            patientUuid: Joi.string()
              .required()
              .description(
                "The patient's uuid(universally unique identifier)."
              ),
            programUuid: Joi.string()
              .required()
              .description('program Uuid (universally unique identifier).'),
            enrollmentUuid: Joi.string()
              .required()
              .description(
                'program enrollment Uuid (universally unique identifier).'
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/clinical-notes',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getClinicalNotes(request, reply);
        },
        description: 'Get patient clinical notes',
        notes:
          'Returns a list of notes constructed from several ' +
          'patient information sources, particularly encounters',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/hiv-patient-clinical-summary',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewPatient, privileges.canViewDataAnalytics]
          }
        },
        handler: function (request, reply) {
          dao.getHivPatientClinicalSummary(request, reply);
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{id}/hiv-patient-clinical-summary',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewPatient, privileges.canViewDataAnalytics]
          }
        },
        handler: function (request, reply) {
          dao.getHivPatientClinicalSummary(request, reply);
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/vitals',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getPatientVitals(request, reply);
        },
        description: 'Get patient vitals',
        notes:
          "Returns a list of historical patient's vitals with the given patient uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/data',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getPatientData(request, reply);
        },
        description: 'Get patient lab test data',
        notes:
          'Returns a list of historical lab tests data of a patient with the given patient uuid.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/hiv-summary',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getPatientHivSummary(request).then((summary) => {
            // console.log('Summary', summary);
            if (summary.result && summary.result.length > 0) {
              const transformed = etlHelpers.transformMedicalRefillToClinical(
                summary.result
              );
              summary.result = transformed;
            }
            reply(summary);
          });
        },
        description: 'Get patient HIV summary',
        notes:
          "Returns a list of historical patient's HIV summary with the given patient uuid. " +
          "A patient's HIV summary includes details such as last appointment date, " +
          "current ARV regimen etc. as at that encounter's date. ",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/oncology/summary',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getPatientOncologySummary(request, reply);
        },
        description: 'Get patient Oncology summary',
        notes:
          "Returns a list of patient's Oncology summary with the given patient uuid. " +
          "A patient's Oncology summary includes details such as last appointment date, " +
          "most recent diagnosis etc. as at that encounter's date. ",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{uuid}/patient-summary',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          dao.getHivNegativesPatientSummary(request).then((summary) => {
            reply(summary);
          });
        },
        description: 'Get patient summary',
        notes:
          "Returns a list of historical patient's summary with the given patient uuid. " +
          "A patient's summary includes details such as last appointment date, " +
          "current ARV regimen etc. as at that encounter's date. ",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description("The patient's uuid(universally unique identifier).")
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/clinic-encounter-data',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicEncounterData(request, reply);
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-program-config',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          var requestParams = Object.assign({}, request.query);
          if (!requestParams.patientUuid) {
            reply(
              Boom.badImplementation(
                "The patient's uuid(universally unique " +
                  'identifier must be provided as a query param'
              )
            );
          }
          patientProgramService
            .validateEnrollmentOptions(requestParams.patientUuid)
            .then(function (programConfigs) {
              reply(programConfigs);
            })
            .catch(function (err) {
              console.log('there is an error', err);
              reply(Boom.badImplementation(err));
            });
        },
        description: 'Get a list of programs ',
        notes: 'Returns a  list of programs',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/monthly-appointment-visits',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicMonthlySummary(request, reply);
        },
        description: "Get a location's monthly appointment visits",
        notes:
          "Returns a location's monthly appointment visits with the given location uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/hiv-summary-indicators',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicHivSummayIndicators(request, reply);
        },
        description: "Get a location's HIV summary indicators",
        notes: "Returns a location's HIV summary indicators.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/clinical-hiv-comparative-overview',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'clinical-hiv-comparative-overview-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let compineRequestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'clinical-hiv-comparative-overview-report',
              [
                'startDate',
                'endDate',
                'indicator',
                'locationUuids',
                'locations',
                'order',
                'gender'
              ],
              compineRequestParams
            );
            console.log('Params', compineRequestParams);
            let service = new hivComparativeOverviewService();
            service
              .getAggregateReport(compineRequestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Get the clinical hiv comparative overview summary',
        notes:
          'Returns a comparative summary of various indicator eg enrollement, on_art,and vl suppression',
        tags: ['api'],
        validate: {}
      }
    },
    {
      method: 'GET',
      path: '/etl/clinical-hiv-comparative-overview/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'clinical-hiv-comparative-overview-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            requestParams.limitParam = requestParams.limit;
            requestParams.offSetParam = requestParams.startIndex;
            let service = new hivComparativeOverviewService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                _.each(result.result, (item) => {
                  item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                });
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Get the clinical hiv comparative overview patient',
        notes:
          'Returns the patient list for various indicators in the clinical hiv comparative summary',
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            reportName: Joi.string()
              .optional()
              .description('the name of the report you want patient list'),
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-referrals',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'patient-referral-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          request.query.reportName = 'patient-referral-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new PatientReferralService();
            // remove gender filter
            delete requestParams['gender'];
            service
              .getAggregateReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Get patient referral for selected clinic',
        notes:
          'Returns a list of patient referral for the selected clinic(s),start date, end date',
        tags: ['api'],
        validate: {
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by'),
            programUuids: Joi.string()
              .optional()
              .description('The program to filter by'),
            department: Joi.string()
              .optional()
              .description('The department to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/referral-patient-list',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'patient-referral-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          request.query.reportName = 'patient-referral-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          let requestParams = Object.assign({}, request.query, request.params);
          requestParams.reportName = 'referralAggregate';
          let service = new PatientReferralService();
          service
            .getReferralPatientListReport(requestParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get patient referral for selected clinic',
        notes:
          'Returns patient referral for the selected clinic(s),start date, end date',
        tags: ['api'],
        validate: {
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by'),
            programUuids: Joi.string()
              .optional()
              .description('The program to filter by'),
            limit: Joi.string()
              .optional()
              .description('The limit to indicate number of rows'),
            department: Joi.string()
              .optional()
              .description('The department to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-referral-details/{locationUuid}/{enrollmentUuid}',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientReferralDao
            .getPatientReferralByEnrollmentUuid(
              request.params['locationUuid'],
              request.params['enrollmentUuid']
            )
            .then(function (referralLocation) {
              reply(referralLocation);
            })
            .catch(function (error) {
              reply(new Boom(500, 'Internal server error.', '', '', error));
            });
        },
        description: 'Get patient referral details by program enrollment uuid',
        notes:
          'Api endpoint that returns additional patient referral details by program enrollement uuid',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/patient-referral',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientReferralDao
            .createPatientReferral(request.payload)
            .then(function (newCohortReferral) {
              reply(newCohortReferral);
            })
            .catch(function (error) {
              if (error && error.isValid === false) {
                reply(
                  Boom.badRequest('Validation errors:' + JSON.stringify(error))
                );
              } else {
                console.error(error);
                reply(new Boom(500, 'Internal server error.', '', '', error));
              }
            });
        },
        description: 'Post patient referrals for a given referral',
        notes: 'Api endpoint that posts patient referrals',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/patient-referral/{patientReferralId}',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          // console.log('xxxxxxxxxxxx', request)
          patientReferralDao
            .updatePatientReferralNotification(
              request.params['patientReferralId'],
              request.payload
            )
            .then(function (updatedPatientReferral) {
              reply(updatedPatientReferral);
            })
            .catch(function (error) {
              if (error && error.isValid === false) {
                reply(
                  Boom.badRequest('Validation errors:' + JSON.stringify(error))
                );
              } else {
                reply(new Boom(500, 'Internal server error.', '', '', error));
              }
            });
        },
        description: 'Update patient referral notification status',
        notes:
          'Api endpoint that updates patient referral of by the provided id',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/clinical-patient-care-status-overview',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName =
            'clinical-patient-care-status-overview-report';
          let compineRequestParams = Object.assign(
            {},
            request.query,
            request.params
          );
          let reportParams = etlHelpers.getReportParams(
            'clinical-patient-care-status-overview-report',
            [
              'startDate',
              'endDate',
              'indicator',
              'locationUuids',
              'order',
              'gender'
            ],
            compineRequestParams
          );

          let service = new clinicalPatientCareStatusOverviewService();
          service
            .getAggregateReport(reportParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get the clinical patint care status patient list',
        notes:
          'Returns a comparative summary of all patient status indicators eg on_art,out_of_care,in_care,transferred_out.....',
        tags: ['api'],
        validate: {}
      }
    },
    {
      method: 'GET',
      path: '/etl/clinical-patient-care-status-overview/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName =
            'clinical-patient-care-status-overview-report';
          let requestParams = Object.assign({}, request.query, request.params);
          let service = new PatientStatusChangeTrackerService();
          service
            .getPatientListReport(requestParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description:
          'Get the clinical-patient-care-status-overview patient list',
        notes:
          'Returns the patient list for various indicators in the clinical-patient-care-status-overview',
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination'),
            analysis: Joi.string().optional().description('analysis type')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/clinical-art-overview',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'clinical-art-overview-report';
          let compineRequestParams = Object.assign(
            {},
            request.query,
            request.params
          );
          let reportParams = etlHelpers.getReportParams(
            'clinical-art-overview-report',
            [
              'startDate',
              'endDate',
              'indicator',
              'locationUuids',
              'order',
              'gender'
            ],
            compineRequestParams
          );

          let service = new clinicalArtOverviewService();
          service
            .getAggregateReport(reportParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get the clinical art  overview summary',
        notes:
          'Returns the a comparative summary of art drugs used by patients',
        tags: ['api'],
        validate: {}
      }
    },
    {
      method: 'GET',
      path: '/etl/clinical-art-overview/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'clinical-art-overview-report';
          let requestParams = Object.assign({}, request.query, request.params);
          let service = new clinicalArtOverviewService();
          service
            .getPatientListReport(requestParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get the  clinical art overview patient list',
        notes: 'Returns the patient list for clinical-art-overview report',
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            reportName: Joi.string()
              .optional()
              .description('the name of the report you want patient list'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/appointment-schedule',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicAppointmentSchedule(request, reply);
        },
        description: "Get a location's appointment schedule",
        notes:
          "Returns a location's appointment-schedule with the given location uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-flow-data',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            dao.getPatientFlowData(request, reply);
          });
        },
        description: "Get a location's patient movement and waiting time data",
        notes:
          "Returns a location's patient flow with the given location uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/clinic-flow-provider-statistics/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          }
        },
        handler: function (request, reply) {
          let requestParams = Object.assign({}, request.query, request.params);
          requestParams.reportName = 'clinic-flow-provider-statistics-report';
          const clinicFlowService = new ClinicFlowService();
          clinicFlowService
            .getPatientListReport(requestParams)
            .then((results) => {
              reply(results);
            })
            .catch((error) => {
              console.error(error);
              reply(error);
            });
        },
        description:
          'Get patient list for the provider statistics in clinic flow',
        notes:
          'Returns a patient list for the provider statistics in clinic flow.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/clinic-lab-orders-data',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            dao.getClinicLabOrdersData(request, reply);
          });
        },
        description: "Get a location's lab orders data",
        notes:
          "Returns a location's lab orders data with the given location uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{patient_uuid}/monthly-care-status',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          let history = new PatientMonthlyStatusHistory();
          history
            .getPatientMonthlyStatusHistory(
              request.params.patient_uuid,
              request.query.startDate,
              request.query.endDate
            )
            .then((result) => {
              reply(result);
            });
        },
        description: 'Get the the care status of patient on a monthly basis',
        notes:
          'Returns a list showing care status of a patient at the end of every month in a given period',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{patient_uuid}/daily-care-status',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          let requestParams = Object.assign({}, request.query, request.params);
          // let reportParams = etlHelpers.getReportParams('patient-daily-care-status', ['referenceDate', 'patient_uuid'],
          //     requestParams);
          reportParams.limitParam = reportParams.limit;
          reportParams.offSetParam = reportParams.startIndex;
          let report = new BaseMysqlReport(
            'patientDailyCareStatus',
            reportParams
          );
          report
            .generateReport()
            .then((results) => {
              results.result = results.results.results;
              delete results['results'];
              reply(results);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get the the care status of patient on a given date',
        notes: 'Returns the care status of a patient on a given day',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/daily-visits',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicDailyVisits(request, reply);
        },
        description: "Get a location's daily visits",
        notes:
          "Returns a location's daily visits with the given parameter uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/has-not-returned',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getHasNotReturned(request, reply);
        },
        description: "Get a location's not returned visits",
        notes:
          "Returns a location's not returned visits with the given parameter uuid.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/monthly-appointment-schedule',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicMonthlyAppointmentSchedule(request, reply);
        },
        description: "Get a location's monthly appointment schedule",
        notes: "Returns a location's monthly appointment schedule.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/monthly-visits',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getClinicMonthlyVisits(request, reply);
        },
        description: "Get a location's monthly visits",
        notes:
          'Returns the actual number of patient visits for each day in a given month and location.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{uuid}/defaulter-list',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          dao.getClinicDefaulterList(request, reply);
        },
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        description: "Get a location's defaulter list",
        notes: "Returns a location's defaulter list.",
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            uuid: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      method: 'OPTIONS',
      path: '/{param*}',
      handler: function (request, reply) {
        // echo request headers back to caller (allow any requested)
        var additionalHeaders = [];
        if (request.headers['access-control-request-headers']) {
          additionalHeaders = request.headers[
            'access-control-request-headers'
          ].split(', ');
        }
        var headers = _.union(
          'Authorization, Content-Type, If-None-Match'.split(', '),
          additionalHeaders
        );

        reply()
          .type('text/plain')
          .header('Access-Control-Allow-Headers', headers.join(', '));
      }
    },
    {
      method: 'GET',
      path: '/etl/custom_data/{userParams*3}',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          dao.getCustomData(request, reply);
        }
        /*
                     the rest request and query expression should be
                     /table/filter_column/filter/filter_value or
                     /table/filter_column/filter/filter_value?fields=(field1,field2,fieldn) or

                     */
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/creation/statistics',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewDataEntryStats, privileges.canViewPatient]
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          dao.getPatientCountGroupedByLocation(request, reply);
        },
        description: 'Get patients created by period',
        notes:
          'Returns a list of patients created within a specified time period in all locations.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{location}/patient/creation/statistics',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewDataEntryStats, privileges.canViewPatient]
          }
        },
        handler: function (request, reply) {
          dao.getPatientDetailsGroupedByLocation(request, reply);
        },
        description: 'Get details of patient created in a location',
        notes: 'Returns details of patient created in a location',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            location: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          }
        }
      }
    },
    {
      /**
                 endpoint  to  get  Reports
                 @todo Rename  to get-report-by-name,count by{patient/encounters},filter-params{location/starting date/ end date}
                 @todo ,groupby params{location/monthly}
                 **/

      method: 'GET',
      path: '/etl/get-report-by-report-name',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            exemptedParameter: [
              //set this if you want to prevent validation checks for certain reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'clinical-reminder-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'patient-register-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'medical-history-report' //parameter value
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'hiv-summary-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'hiv-summary-monthly-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'MOH-731-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'MOH-731-allsites-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'clinic-comparator-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'clinical-hiv-comparative-overview-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'clinical-art-overview-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'report', //name of the parameter
                value: 'clinical-patient-care-status-overview-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          if (!authorizer.hasReportAccess(request.query.report)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              request.query.report,
              [
                'startDate',
                'endDate',
                'indicator',
                'locationUuids',
                'locations',
                'referenceDate',
                'patientUuid',
                'startAge',
                'endAge',
                'age',
                'order',
                'gender'
              ],
              requestParams
            );

            dao
              .runReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Get report ',
        notes:
          'General api endpoint that returns a report by passing ' +
          'the report name parameter and a list of custom parameters ' +
          'depending on the report e.g start date, end date for MOH-731 report.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            report: Joi.string()
              .required()
              .description('The name of the report to get indicators')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/MOH-731-report',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'MOH-731-report' //parameter value
              },
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'MOH-731-report-2017' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            // console.log('requestParams', requestParams);
            let reportParams = etlHelpers.getReportParams(
              request.query.reportName,
              [
                'startDate',
                'endDate',
                'locationUuids',
                'locations',
                'isAggregated'
              ],
              requestParams
            );
            console.log('report params=>>', reportParams);

            if (request.query.reportName === 'MOH-731-report-2017') {
              let moh731 = new Moh731Report(
                'MOH-731-greencard',
                reportParams.requestParams
              );

              moh731
                .generateReport()
                .then((results) => {
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            } else {
              let moh731 = new Moh731Report(
                'MOH-731-bluecard',
                reportParams.requestParams
              );

              moh731
                .generateReport()
                .then((results) => {
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            }
          });
        },
        description: 'Get the MOH 731 report',
        notes:
          'Api endpoint that returns MOH 731 report. It includes both MOH versions (legacy and 2017).',
        tags: ['api'],
        validate: {
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            reportName: Joi.string()
              .required()
              .description('the name of the report you want patient list'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            isAggregated: Joi.boolean()
              .optional()
              .description('Boolean checking if report is aggregated'),
            exclude: Joi.string()
              .optional()
              .description('Validates which report should be returned')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/MOH-731-report/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }

          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );

            let requestCopy = _.cloneDeep(requestParams);
            // console.log('requestParams', requestParams);
            let reportParams = etlHelpers.getReportParams(
              request.query.reportName,
              [
                'startDate',
                'endDate',
                'locationUuids',
                'locations',
                'isAggregated'
              ],
              requestParams
            );
            requestCopy.locations = reportParams.requestParams.locations;
            // console.log('report params', reportParams)
            requestCopy.limitParam = requestParams.limit;
            requestCopy.offSetParam = requestParams.startIndex;
            if (request.query.reportName === 'MOH-731-report-2017') {
              let moh731 = new Moh731Report('MOH-731-greencard', requestCopy);

              moh731
                .generatePatientListReport(requestParams.indicator.split(','))
                .then((results) => {
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            } else {
              let moh731 = new Moh731Report('MOH-731-bluecard', requestCopy);

              moh731
                .generatePatientListReport(requestParams.indicator.split(','))
                .then((results) => {
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            }
          });
        },
        description: 'Get the MOH 731 patient list',
        notes: 'Returns the patient list for MOH 731',
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            reportName: Joi.string()
              .required()
              .description('the name of the report you want patient list'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-status-change-tracking',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'patient-status-change-tracker-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'patient-status-change-tracker-report';
          //security check
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                request.query.reportName,
                [
                  'startDate',
                  'endDate',
                  'locationUuids',
                  'locations',
                  'analysis'
                ],
                requestParams
              );

              let service = new PatientStatusChangeTrackerService();
              service
                .getAggregateReport(reportParams)
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description: 'Get the Patient Status report',
        notes: 'Api endpoint that returns Patient Status Change Tracker Report',
        tags: ['api'],
        validate: {
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            analysis: Joi.string()
              .optional()
              .description('analysis type report')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-status-change-tracking/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'patient-status-change-tracker-report';
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let service = new PatientStatusChangeTrackerService();
              service
                .getPatientListReport(requestParams)
                .then((result) => {
                  _.each(result.result, (item) => {
                    item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                  });
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description: 'Get Patient Status report patient list',
        notes: 'Returns the patient list for Patient Status report',
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            analysis: Joi.string()
              .optional()
              .description('analysis type report'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/user-cohorts',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          request.query.reportName = 'cohort-report';
          //security check
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          request.params.limit = 1000;
          let requestParams = Object.assign({}, request.query, request.params);
          let reportParams = etlHelpers.getReportParams(
            'cohort-report',
            ['userUuid'],
            requestParams
          );

          let service = new cohortUserService();
          service
            .getAggregateReport(reportParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get cohort(s) based on user uuid',
        notes: 'Api endpoint that returns cohort(s) based on the user uuid',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/cohort-user/{cohortUserId}',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientList
            .getCohortUser(request.params['cohortUserId'])
            .then(function (cohortUser) {
              if (cohortUser === null) {
                reply(Boom.notFound('Resource does not exist'));
              } else {
                reply(cohortUser);
              }
            })
            .catch(function (error) {
              reply(new Boom(500, 'Internal server error.', '', '', error));
            });
        },
        description: 'Get cohort users for a certain cohort',
        notes:
          'Api endpoint that returns cohort users based on the cohort uuid',
        tags: ['api']
      }
    },
    {
      method: 'DELETE',
      path: '/etl/cohort-user/{cohortUserId}',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientList
            .voidCohortUser(request.params['cohortUserId'])
            .then(function (message) {
              reply(message);
            })
            .catch(function (error) {
              reply(new Boom(500, 'Internal server error.', '', '', error));
            });
        },
        description: 'Get cohort users for a certain cohort',
        notes:
          'Api endpoint that returns cohort users based on the cohort uuid',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/cohort-user/{cohortUserId}',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientList
            .updateCohortUser(request.params['cohortUserId'], request.payload)
            .then(function (updatedCohortUser) {
              reply(updatedCohortUser);
            })
            .catch(function (error) {
              if (error && error.isValid === false) {
                reply(
                  Boom.badRequest('Validation errors:' + JSON.stringify(error))
                );
              } else {
                reply(new Boom(500, 'Internal server error.', '', '', error));
              }
            });
        },
        description: 'Get cohort users for a certain cohort',
        notes:
          'Api endpoint that returns cohort users based on the cohort uuid',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/cohort-user',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientList
            .createCohortUser(request.payload)
            .then(function (newCohortUser) {
              reply(newCohortUser);
            })
            .catch(function (error) {
              if (error && error.isValid === false) {
                reply(
                  Boom.badRequest('Validation errors:' + JSON.stringify(error))
                );
              } else {
                console.error(error);
                reply(new Boom(500, 'Internal server error.', '', '', error));
              }
            });
        },
        description: 'Get cohort users for a certain cohort',
        notes:
          'Api endpoint that returns cohort users based on the cohort uuid',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/cohort/{cohortUuid}/cohort-users',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          patientList
            .getCohortUsersByCohortUuid(request.params['cohortUuid'])
            .then(function (cohortUsers) {
              reply(cohortUsers);
            })
            .catch(function (error) {
              reply(new Boom(500, 'Internal server error.', '', '', error));
            });
        },
        description: 'Get cohort users for a certain cohort',
        notes:
          'Api endpoint that returns cohort users based on the cohort uuid',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-register-report',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'params', //can be in either query or params so you have to specify
                name: 'uuid' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                request.query.reportName,
                [
                  'startDate',
                  'endDate',
                  'indicators',
                  'locationUuids',
                  'groupBy',
                  'limit',
                  'startAge',
                  'endAge',
                  'order',
                  'gender',
                  'countBy'
                ],
                requestParams
              );

              let service = new PatientRegisterReportService();
              service
                .getAggregateReport(reportParams)
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description: 'Get the Patient Register report',
        notes: 'Api endpoint that returns Patient Register report.',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/hiv-summary-indicators',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'hiv-summary-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          request.query.reportName = 'hiv-summary-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'hiv-summary-report',
              [
                'startDate',
                'endDate',
                'locationUuids',
                'locations',
                'indicators',
                'gender',
                'startAge',
                'endAge'
              ],
              requestParams
            );

            let service = new HivSummaryIndicatorsService();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error loading HIV Summary:', error);
                reply(error);
              });
          });
        },
        description: 'Get hiv summary indicators for selected clinic',
        notes:
          'Returns hiv summary indicators for the selected clinic(s),start date, end date',
        tags: ['api'],
        validate: {
          query: {
            indicators: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .required()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            gender: Joi.string()
              .optional()
              .description('The gender to filter by'),
            startAge: Joi.string()
              .optional()
              .description('The start age to filter by'),
            endAge: Joi.string()
              .optional()
              .description('The end age to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/hiv-summary-indicators/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'hiv-summary-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let locations = [];
            if (request.query.locations) {
              _.each(request.query.locations.split(','), function (loc) {
                locations.push(Number(loc));
              });
              request.query.locations = locations;
            }
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new HivSummaryIndicatorsService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                _.each(result.result, (item) => {
                  item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                });
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description:
          "Get hiv summary indicator's patient list for selected clinic",
        notes:
          "Returns hiv summary indicator's patient list for the selected clinic,start date, end date",
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .required()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination'),
            startAge: Joi.string()
              .optional()
              .description('The start age to filter by'),
            endAge: Joi.string()
              .optional()
              .description('The end age to filter by'),
            gender: Joi.string()
              .optional()
              .description('The gender to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/hiv-summary-monthly-indicators',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'hiv-summary-monthly-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          request.query.reportName = 'hiv-summary-monthly-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'hiv-summary-monthly-report',
              [
                'startDate',
                'endDate',
                'locationUuids',
                'indicators',
                'gender',
                'startAge',
                'endAge'
              ],
              requestParams
            );

            let service = new HivSummaryMonthlyIndicatorsService();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error fetching HIV summary', error);
                reply(Boom.badImplementation('An error occured', error));
              });
          });
        },
        description: 'Get hiv summary monthly indicators for  selected clinic',
        notes:
          'Returns hiv summary monthly indicators for the selected clinic(s),start date, end date',
        tags: ['api'],
        validate: {
          query: {
            indicators: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .required()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            gender: Joi.string()
              .optional()
              .description('The gender to filter by'),
            startAge: Joi.string()
              .optional()
              .description('The start age to filter by'),
            endAge: Joi.string()
              .optional()
              .description('The end age to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/hiv-summary-monthly-indicators/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'hiv-summary-monthly-report';
          let requestParams = Object.assign({}, request.query, request.params);
          let service = new HivSummaryMonthlyIndicatorsService();
          service
            .getPatientListReport(requestParams)
            .then((result) => {
              console.log('result', result);
              reply(result);
            })
            .catch((error) => {
              console.error('Error fetching HIV summary', error);
              reply(Boom.badImplementation('An error occured', error));
            });
        },
        description:
          "Get hiv summary monthly indicator's patient list for selected clinic",
        notes:
          "Returns hiv summary monthly indicator's patient list for the selected clinic,start date, end date",
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .required()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination'),
            startAge: Joi.string()
              .optional()
              .description('The start age to filter by'),
            endAge: Joi.string()
              .optional()
              .description('The end age to filter by'),
            gender: Joi.string()
              .optional()
              .description('The gender to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/location/{locationUuids}/patient-by-indicator',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewPatient, privileges.canViewDataAnalytics]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'hiv-summary-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            dao
              .getPatientListReport(
                Object.assign({}, request.query, request.params)
              )
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(Boom.badRequest(error.toString()));
              });
          });
        },
        description: 'Get patient list by indicator',
        notes: 'Returns a patient list by indicator for a given location.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {
            locationUuids: Joi.string()
              .required()
              .description(
                "The location's uuid(universally unique identifier)."
              )
          },
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-by-indicator',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewPatient, privileges.canViewDataAnalytics]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'hiv-summary-monthly-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            dao
              .getPatientListReport(
                Object.assign({}, request.query, request.params)
              )
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(Boom.badRequest(error.toString()));
              });
          });
        },
        description: 'Get patient',
        notes: 'Returns a patient by passing a given indicator and location.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .required()
              .description('A list of comma separated location uuids')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/data-entry-statistics/{sub}',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataEntryStats
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          if (
            request.params.sub === 'patientList' &&
            !authorizer.hasPrivilege(privileges.canViewPatient)
          ) {
            return reply(Boom.forbidden('Unauthorized'));
          }

          var asyncRequests = 0; //this should be the number of async requests needed before they are triggered

          var onResolvedPromise = function (promise) {
            asyncRequests--;
            if (asyncRequests <= 0) {
              //voting process to ensure all pre-processing of request async operations are complete
              dao.getDataEntryIndicators(request.params.sub, request, reply);
            }
          };

          //establish the number of asyncRequests
          //this is done prior to avoid any race conditions
          if (request.query.formUuids) {
            asyncRequests++;
          }
          if (request.query.encounterTypeUuids) {
            asyncRequests++;
          }
          if (request.query.locationUuids) {
            asyncRequests++;
          }

          if (asyncRequests === 0)
            dao.getDataEntryIndicators(request.params.sub, request, reply);

          if (request.query.formUuids) {
            dao.getIdsByUuidAsyc(
              'amrs.form',
              'form_id',
              'uuid',
              request.query.formUuids,
              function (results) {
                request.query.formIds = results;
              }
            ).onResolved = onResolvedPromise;
          }
          if (request.query.encounterTypeUuids) {
            dao.getIdsByUuidAsyc(
              'amrs.encounter_type',
              'encounter_type_id',
              'uuid',
              request.query.encounterTypeUuids,
              function (results) {
                request.query.encounterTypeIds = results;
              }
            ).onResolved = onResolvedPromise;
          }
          if (request.query.visitTypeUuids) {
            dao.getIdsByUuidAsyc(
              'amrs.visit_type',
              'visit_type_id',
              'uuid',
              request.query.visitTypeUuids,
              function (results) {
                request.query.visitTypeIds = results;
              }
            ).onResolved = onResolvedPromise;
          }
          if (request.query.locationUuids) {
            dao.getIdsByUuidAsyc(
              'amrs.location',
              'location_id',
              'uuid',
              request.query.locationUuids,
              function (results) {
                request.query.locationIds = results;
              }
            ).onResolved = onResolvedPromise;
          }
        }
      }
    },
    {
      /**
                 endpoint  to  get  Reports Indicators
                 @todo Rename  to get-report-indicators by  report  name
                 **/

      method: 'GET',
      path: '/etl/indicators-schema',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          }
        },
        handler: function (request, reply) {
          //security check
          if (!authorizer.hasReportAccess(request.query.report)) {
            return reply(Boom.forbidden('Unauthorized'));
          }

          dao.getIndicatorsSchema(request, reply);
        },
        description: 'Get HIV monthly summary indicator schema',
        notes: 'Returns HIV monthly summary indicator schema. ',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            report: Joi.string()
              .required()
              .description('The name of the report to get indicators')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/indicators-schema-with-sections',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          }
        },
        handler: function (request, reply) {
          dao.getIndicatorsSchemaWithSections(request, reply);
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/hiv-summary-data',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewPatient, privileges.canViewDataAnalytics]
          }
        },
        handler: function (request, reply) {
          dao.getHivSummaryData(request, reply);
        }
      }
    },
    {
      method: 'POST',
      path: '/etl/compare-patient-lists',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          var r = request;
          var handler;
          _.each(routes, function (route) {
            if (route.path === request.payload.path) {
              handler = route.config.handler;
            }
          });

          var requestObject = {
            query: request.payload.query,
            params: request.payload.params
          };

          if (handler) {
            patientListCompare
              .fetchAndCompareList(
                request.payload.patientList,
                requestObject,
                handler
              )
              .then(function (comparison) {
                if (
                  request.query.includeBoth === true ||
                  request.query.includeBoth === 'true'
                ) {
                  reply(comparison);
                } else {
                  delete comparison.both;
                  reply(comparison);
                }
              })
              .catch(function (error) {
                reply(Boom.badImplementation('An internal error occured'));
              });
          } else {
            reply(Boom.badRequest('Unknown patient list etl path'));
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-list-by-indicator',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [privileges.canViewPatient, privileges.canViewDataAnalytics]
          }
        },
        handler: function (request, reply) {
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            dao
              .getPatientListReport(
                Object.assign({}, request.query, request.params)
              )
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(Boom.badRequest(JSON.stringify(error)));
              });
          });
        },
        description: 'Get patient list',
        notes:
          'Returns a patient by passing a given indicator, report and location.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .required()
              .description('A list of comma separated location uuids'),
            reportName: Joi.string()
              .required()
              .description('the name of the report you want patient list'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-lab-orders',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          if (config.eidSyncOn === true) {
            const labSyncService = new LabSyncService();
            syncPreproc
              .processLabSyncReqest(request.query)
              .then((validRequest) => {
                if (validRequest) {
                  labSyncService.syncAllLabsByPatientUuid(
                    request.query.patientUuId,
                    reply
                  );
                } else {
                  reply(validRequest);
                }
              })
              .catch((error) => {
                console.error('ERROR: ', error);
                reply(error);
              });
          } else {
            reply(
              Boom.notImplemented(
                'Sorry, sync service temporarily unavailable.'
              )
            );
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/sync-patient-labs',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          if (config.eidSyncOn === true) {
            const labSyncService = new LabSyncService();
            labSyncService.syncAllLabsByPatientUuid(
              request.query.patientUuid,
              reply
            );
          } else
            reply(
              Boom.notImplemented(
                'Sorry, sync service temporarily unavailable.'
              )
            );
        }
      }
    },
    {
      method: 'POST',
      path: '/etl/eid/order/{lab}',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          if (request.params.lab !== '') {
            var rawPayload = JSON.parse(JSON.stringify(request.payload));
            var labName = request.params.lab;
            pocEidPayloadHelper
              .generatePocToEidPayLoad(rawPayload)
              .then((eidPayLoad) => {
                let configObj = config.hivLabSystem[labName];
                if (typeof configObj !== 'undefined') {
                  let client = new LabClient(configObj);
                  return client.postLabPayload(eidPayLoad);
                } else {
                  console.error('Undefined Lab Configuration');
                }
              })
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                try {
                  let errorObject = JSON.parse(error.error);
                  console.error('Error', errorObject);
                  reply(errorObject.error).code(error.statusCode);
                } catch (err) {
                  console.error('Error', error);
                  throw Boom.badImplementation(error);
                }
              });
          } else {
            console.error('No Lab Specified');
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/session/invalidate',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          dao.invalidateUserSession(request, reply);
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/lab-cohorts',
      config: {
        auth: false,
        plugins: {
          hapiAuthorization: false
        },
        handler: function (request, reply) {
          var eidSyncApiKey = config.eidSyncApiKey;
          var headers = request.headers;

          var h_eidSyncApiKey = request.headers.eidsyncapikey;

          if (eidSyncApiKey === h_eidSyncApiKey) {
            dao.loadLabCohorts(request, reply);
          } else {
            reply(Boom.unauthorized('invalid api key'));
          }
        },
        description: 'Home',
        notes: 'Returns a message that shows ETL service is running.',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            startDate: Joi.string()
              .required()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .required()
              .description('The end date to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/lab-cohorts-sync',
      config: {
        auth: false,
        plugins: {
          hapiAuthorization: false
        },
        handler: function (request, reply) {
          var eidSyncApiKey = config.eidSyncApiKey;
          var headers = request.headers;

          var h_eidSyncApiKey = request.headers.eidsyncapikey;

          if (eidSyncApiKey === h_eidSyncApiKey) {
            dao.syncLabCohorts(request, reply);
          } else {
            reply(Boom.unauthorized('invalid api key'));
          }
        },
        description: 'Home',
        notes: 'Returns a message that shows ETL service is running.',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/eid/load-order-justifications',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          dao.loadOrderJustifications(request, reply);
        },
        description: 'Justifications',
        notes: 'Returns order justification(s)',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/fileupload',
      config: {
        auth: 'simple',
        payload: {
          maxBytes: 5000000
        },
        handler: function (request, reply) {
          let replyPayload = {};
          let data;
          if (request.payload.data) {
            data = request.payload.data;
          } else if (request.payload._imageAsDataUrl) {
            data = request.payload._imageAsDataUrl;
          }
          const image = etlHelpers.decodeBase64Image(data);
          const imageTypeRegularExpression = /\/(.*?)$/;
          const imageTypeDetected = image.type.match(
            imageTypeRegularExpression
          );
          const seed = crypto.randomBytes(20);
          var uniqueSHA1String = crypto
            .createHash('sha1')
            .update(seed)
            .digest('hex');
          var userUploadedImagePath =
            config.etl.uploadsDirectory +
            uniqueSHA1String +
            '.' +
            imageTypeDetected[1];
          try {
            require('fs').writeFile(
              userUploadedImagePath,
              image.data,
              function () {
                replyPayload = {
                  image: uniqueSHA1String + '.' + imageTypeDetected[1]
                };
                reply(replyPayload);
                console.log(
                  'DEBUG - feed:message: Saved to disk image attached by user:',
                  userUploadedImagePath
                );
              }
            );
          } catch (error) {
            console.log('ERROR:', error);
            replyPayload = {
              error: 'Error Uploading image'
            };
            reply(replyPayload);
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/files/{param*}',
      config: {
        auth: 'simple',
        handler: {
          directory: {
            path: config.etl.uploadsDirectory,
            redirectToSlash: true,
            index: true
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/eid/patients-with-results',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: false
        },
        handler: function (request, reply) {
          if (request.query.startDate && request.query.endDate) {
            eidService
              .getPatientIdentifiersFromEIDResults(
                request.query.startDate,
                request.query.endDate
              )
              .then(function (response) {
                reply(response);
              })
              .catch(function (error) {
                reply(Boom.badImplementation('A server error occured'));
              });
          } else {
            reply(Boom.badRequest('startDate and endDate required'));
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/motdNotifications',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: false
        },
        handler: function (request, reply) {
          motd
            .getMotdNotifications()
            .then(function (motdNotifications) {
              if (motdNotifications === null) {
                reply(Boom.notFound('Resource does not exist'));
              } else {
                reply(motdNotifications);
              }
            })
            .catch(function (error) {
              reply(new Boom(500, 'Internal server error.', '', '', error));
            });
        },
        description: 'Daily Message Alerts',
        notes: 'Returns Messages to be shown to users on login'
      }
    },
    {
      method: 'GET',
      path: '/etl/patients-requiring-viral-load-order',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.indicator = 'needs_vl_in_period';
          request.query.reportName = 'labs-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new patientsRequiringVLService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                _.each(result.result, (item) => {
                  item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                });
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Gets patients Requiring VL list', //patientsRequiringVLService
        notes:
          'Returns the patient list for various indicators in the labs report',
        tags: ['api'],
        validate: {
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-care-cascade-analysis',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewDataAnalytics
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'patient-care-cascade-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let compineRequestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              request.query.reportName,
              [
                'startDate',
                'endDate',
                'indicator',
                'locationUuids',
                'locations',
                'order',
                'gender'
              ],
              compineRequestParams
            );

            let service = new patientCareCascadeService();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Gets patient-care-cascade-report',
        notes:
          'Returns a comparative summary of various indicator eg ltfu, on_art,and vl suppression',
        tags: ['api'],
        validate: {}
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-care-cascade-analysis/patient-list',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'patient-care-cascade-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new patientCareCascadeService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description: 'Get the clinical hiv comparative overview patient',
        notes:
          'Returns the patient list for various indicators in the clinical hiv comparative summary',
        tags: ['api'],
        validate: {
          query: {
            indicator: Joi.string()
              .required()
              .description('A list of comma separated indicators'),
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by'),
            startIndex: Joi.number()
              .required()
              .description('The startIndex to control pagination'),
            limit: Joi.number()
              .required()
              .description('The offset to control pagination')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/indicator-disaggregation-filter-options',
      config: {
        auth: 'simple',
        handler: function (request, reply) {
          reply(
            require('./service/indicator-processor/indicator-filter-options.json')
          );
        },
        description: 'Get indicator disaggregation options',
        notes: 'Returns an array of filter options',
        tags: ['api'],
        validate: {
          query: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient/{patientUuid}/medical-history-report',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          request.query.groupBy = 'groupByCurArvMeds,groupByPrevArvMeds';
          let requestParams = Object.assign({}, request.query, request.params);
          let reportParams = etlHelpers.getReportParams(
            'medical-history-report',
            ['patientUuid'],
            requestParams
          );
          let report = new PatientMedicalHistoryService(
            'medicalHistoryReport',
            reportParams.requestParams
          );
          report
            .generateReport()
            .then((result) => {
              let medicalHist = new patientMedicationHistService();
              let processedResults = medicalHist.processMedicationHistory(
                result
              );
              reply(processedResults);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get the medical history report',
        notes: 'Returns the the medical history of the selected patient',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/departments-programs-config',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          reply(departmentProgramsService.getAllDepartmentsConfig());
        },
        description: 'Get a list of Departments and their programs ',
        notes: 'Returns a  list of Departments and their programs',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/department-programs',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          let department = request.query.department;
          let departmentPrograms = departmentProgramsService
            .getDepartmentPrograms(department)
            .then((response) => {
              reply(response);
            })
            .catch((error) => {
              console.error('ERROR : DepartmentPrograms Error', error);
              reply(error);
            });
        },
        description: 'Get a list of Programs for a Department',
        notes: 'Returns a  list of Programs for a Departments',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-program-enrollments',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          resolveLocationUuidToId
            .resolveLocationUuidsParamsToIds(request.query)
            .then((result) => {
              let locationIds = result;
              request.query.locations = locationIds;

              resolveProgramEnrollmentFilterParams
                .resolveProgramVisitTypeEncounterUuidsParamsToIds(request.query)
                .then((resolve) => {
                  let programTypeIds = resolve.programTypeIds;
                  request.query.programTypeIds = programTypeIds;
                  enrollmentService
                    .getActiveProgramEnrollmentSummary(request.query)
                    .then((result) => {
                      reply(result);
                    })
                    .catch((error) => {
                      reply(error);
                    });
                })
                .catch((error) => {
                  console.log(error);
                });
            })
            .catch((error) => {
              console.log(error);
            });
        },
        description:
          'Get enrollment summary details based on location and time filters',
        notes: 'Returns a list of active patients enrolled',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/lab-orders-by-patient',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            roles: [
              privileges.canViewPatient,
              privileges.canViewClinicDashBoard
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'clinic-lab-orders-report';
          //security check
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          request.params.limit = 1000;
          let requestParams = Object.assign({}, request.query, request.params);
          let reportParams = etlHelpers.getReportParams(
            'clinic-lab-orders-report',
            ['patientUuid'],
            requestParams
          );

          let service = new labOrdersService();
          service
            .getAggregateReport(reportParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get lab orders based on patient uuid',
        notes:
          'Api endpoint that returns lab order(s) based on the patient uuid',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            patientUuid: Joi.string()
              .optional()
              .description('A list of comma separated patient uuids')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/program-enrollment/patient-list',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          resolveLocationUuidToId
            .resolveLocationUuidsParamsToIds(request.query)
            .then((result) => {
              let locationIds = result;
              request.query.locations = locationIds;

              resolveProgramEnrollmentFilterParams
                .resolveProgramVisitTypeEncounterUuidsParamsToIds(request.query)
                .then((resolve) => {
                  let programTypeIds = resolve.programTypeIds;
                  request.query.programTypeIds = programTypeIds;
                  enrollmentService
                    .getActiveProgramEnrollmentsPatientList(request.query)
                    .then((result) => {
                      _.each(result.result, (item) => {
                        item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                      });
                      reply(result);
                    })
                    .catch((error) => {
                      reply(error);
                    });
                })
                .catch((error) => {
                  console.log(error);
                });
            })
            .catch((error) => {
              console.log(error);
            });
        },
        description:
          'Get a list of patients enrolled in a program in a location in a certain period',
        notes: 'Returns a list of active patients enrolled',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/radiology-diagnostic-report',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          var requestParams = request.query;
          console.log('requestParams', requestParams);
          imagingService
            .getImagingResultsByPatientIdentifier(requestParams)
            .then(function (results) {
              if (results === null) {
                reply(Boom.notFound('Resource does not exist'));
              } else {
                reply(results);
              }
            })
            .catch(function (error) {
              console.error(error);
              reply(error);
            });
        },
        description: 'Get particular patient imaging report',
        notes:
          'Api endpoint that returns patient imaging report based on the patient identifier',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/radiology-images',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          var requestParams = request.query;
          //  console.log('requestParams=====>>>',requestParams);
          imagingService
            .getPatientImagesByPatientIdentifier(requestParams)
            .then(function (results) {
              //        console.log('results',results);
              imagingService.constructWadoUrl(results).then(function (res) {
                reply(res);
              });
            })
            .catch(function (error) {
              reply(error);
            });
        },
        description: 'Get particular radiology patient images',
        notes:
          'Api endpoint that returns patient images based on the patient identifier',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/radiology-all-patient-images',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          var requestParams = request.query;
          imagingService
            .getAllPatientImages(requestParams)
            .then(function (results) {
              reply(results);
            })
            .catch(function (error) {
              reply(error);
            });
        },
        description: 'Get particular radiology patient images',
        notes:
          'Api endpoint that returns patient images based on the patient identifier',
        tags: ['api']
      }
    },
    {
      method: 'POST',
      path: '/etl/radiology-comments',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          var payload = request.payload;
          imagingService
            .postRadiologyImagingComments(payload)
            .then(function (results) {
              reply(results);
            })
            .catch(function (error) {
              reply(error);
            });
        },
        description: 'Post Radiology imaging comments',
        notes: 'Api endpoint that post comments on a particular image',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/oncology-reports',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          oncologyReportsService
            .getOncologyReports()
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get a list of Oncology reports ',
        notes: 'Returns a  list of Oncology program reports',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/oncology-report',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.reportUuid) {
            let reportUuid = request.query.reportUuid;
            oncologyReportsService
              .getSpecificOncologyReport(reportUuid)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          } else {
            reply('ERROR:Report uuid Undefined');
            console.error('ERROR:Report uuid Undefined');
          }
        },
        description: 'Get a specific Oncology report',
        notes: 'Returns a specific Oncology program report',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/breast-cancer-screening-numbers',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'breast-cancer-monthly-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'breast-cancer-summary-dataset',
              [
                'startDate',
                'endDate',
                'period',
                'locationUuids',
                'indicators',
                'genders',
                'startAge',
                'endAge'
              ],
              requestParams
            );
            let service = new BreastCancerMonthlySummaryService();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description:
          'Get breast cancer monthly screening summary details based on location and time filters',
        notes: 'Returns aggregates of breast cancer screening',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/breast-cancer-screening-numbers-patient-list',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'breast-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new BreastCancerMonthlySummaryService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description:
          'Get breast cancer monthly screening summary patient list based on location and time filters',
        notes:
          'Returns details of patients who underwent breast cancer screenings',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/combined-breast-cervical-cancer-screening-numbers',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName =
            'combined-breast-cervical-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'breast-cancer-summary-dataset',
              [
                'startDate',
                'endDate',
                'period',
                'locationUuids',
                'indicators',
                'genders',
                'startAge',
                'endAge'
              ],
              requestParams
            );
            let service = new CombinedBreastCervicalCancerMonthlySummary();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description:
          'Get combined breast & cervical cancer monthly screening summary details based on location and time filters',
        notes:
          'Returns aggregates of combined breast & cervical cancer screening',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path:
        '/etl/combined-breast-cervical-cancer-screening-numbers-patient-list',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName =
            'combined-breast-cervical-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new CombinedBreastCervicalCancerMonthlySummary();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description:
          'Get combined breast & cervical cancer monthly summary patient list based on location and time filters',
        notes:
          'Returns details of patients who underwent both breast & cervical cancer screenings',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/cervical-cancer-screening-numbers',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName =
            'cervical-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'cervical-cancer-monthly-summary',
              [
                'startDate',
                'endDate',
                'period',
                'locationUuids',
                'indicators',
                'genders',
                'startAge',
                'endAge'
              ],
              requestParams
            );
            let service = new CervicalCancerMonthlySummaryService();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description:
          'Get cervical cancer monthly screening summary based on location and time filters',
        notes: 'Returns aggregates of cervical cancer screenings',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/cervical-cancer-screening-numbers-patient-list',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName =
            'cervical-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new CervicalCancerMonthlySummaryService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description:
          'Get cervical cancer monthly screening patient list based on location and time filters',
        notes:
          'Returns details of patients who underwent cervical cancer screenings',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/lung-cancer-screening-numbers',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'lung-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'lung-cancer-monthly-summary',
              [
                'startDate',
                'endDate',
                'period',
                'locationUuids',
                'indicators',
                'genders',
                'startAge',
                'endAge'
              ],
              requestParams
            );
            let service = new LungCancerMonthlySummaryService();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description:
          'Get lung cancer monthly screening summary based on location and time filters',
        notes: 'Returns aggregates of lung cancer screenings',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/lung-cancer-screening-numbers-patient-list',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'lung-cancer-monthly-screening-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new LungCancerMonthlySummaryService();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description:
          'Get lung cancer monthly screening patient list based on location and time filters',
        notes:
          'Returns details of patients who underwent lung cancer screenings',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/lung-cancer-treatment-numbers',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          },
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'lung-cancer-treatment-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'breast-cancer-summary-dataset',
              [
                'startDate',
                'endDate',
                'period',
                'locationUuids',
                'indicators',
                'genders',
                'startAge',
                'endAge'
              ],
              requestParams
            );

            let service = new LungCancerTreatmentSummary();
            service
              .getAggregateReport(reportParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description:
          'Get lung cancer treatment summary details based on location and time filters',
        notes: 'Returns aggregates of lung cancer treatment',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/lung-cancer-treatment-numbers-patient-list',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ]
          }
        },
        handler: function (request, reply) {
          request.query.reportName = 'lung-cancer-treatment-summary';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let service = new LungCancerTreatmentSummary();
            service
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                reply(error);
              });
          });
        },
        description:
          'Get Lung cancer treatment monthly patient list based on location and time filters',
        notes:
          'Returns details of patients who underwent lung cancer treatment',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/kibana-dashboards',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          }
        },
        handler: function (request, reply) {
          let kibanaDashboard = kibanaService
            .getKibanaDashboards()
            .then((result) => {
              console.log('Kibana Dashboard', result);
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get a list of Kibana Dashboards',
        notes: 'Returns a list of links for Kibana Dashboards',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/differentiated-care-program/patient-list',
      config: {
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewPatient
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            resolveLocationUuidToId
              .resolveLocationUuidsParamsToIds(request.query)
              .then((result) => {
                let requestParams = Object.assign(
                  {},
                  request.query,
                  request.params
                );
                let locationUuids = request.query.locationUuids.split(',');
                requestParams.startDate = requestParams.startDate.split('T')[0];
                requestParams.endDate = requestParams.endDate.split('T')[0];
                requestParams.limitParam = requestParams.limit;
                requestParams.offSetParam = requestParams.startIndex;
                let indicators = [];
                if (requestParams.indicators) {
                  indicators = requestParams.indicators.split(',');
                }
                requestParams.locationUuids = locationUuids;
                requestParams.locationIds = result;

                let report = new PatientlistMysqlReport(
                  'differentiatedCareProgramAggregate',
                  requestParams
                );
                report
                  .generatePatientListReport(indicators)
                  .then((result) => {
                    if (result.results.results.length > 0) {
                      _.each(result.results.results, (item) => {
                        item.cur_meds = etlHelpers.getARVNames(item.cur_meds);
                        item.vl_1_date = moment(item.vl_1_date).format(
                          'DD-MM-YYYY'
                        );
                      });
                      reply(result);
                    } else {
                      reply(result);
                    }
                  })
                  .catch((error) => {
                    reply(error);
                  });
              });
          }
        },
        description: 'Get the medical history report',
        notes: 'Returns the the medical history of the selected patient',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-referrals-peer-navigator',
      config: {
        auth: 'simple',
        plugins: {
          openmrsLocationAuthorizer: {
            locationParameter: [
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'locationUuids' //name of the location parameter
              }
            ],
            aggregateReport: [
              //set this if you want to  validation checks for certain aggregate reports
              {
                type: 'query', //can be in either query or params so you have to specify
                name: 'reportName', //name of the parameter
                value: 'patient-peer-navigator-referral-report' //parameter value
              }
            ]
          }
        },
        handler: function (request, reply) {
          //security check
          request.query.reportName = 'patient-referral-report';
          if (!authorizer.hasReportAccess(request.query.reportName)) {
            return reply(Boom.forbidden('Unauthorized'));
          }
          let requestParams = Object.assign({}, request.query, request.params);
          requestParams.reportName = 'referral-patient-peer-navigator-list';
          let service = new PatientReferralService();

          service
            .getPeerNavigatorReferralPatientList(requestParams)
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get the patient list for CDM strengths study',
        notes:
          'Returns the normal referral patient list plus some additional columns for front end processing',
        tags: ['api'],
        validate: {
          query: {
            locationUuids: Joi.string()
              .optional()
              .description('A list of comma separated location uuids'),
            startDate: Joi.string()
              .optional()
              .description('The start date to filter by'),
            endDate: Joi.string()
              .optional()
              .description('The end date to filter by'),
            programUuids: Joi.string()
              .optional()
              .description('The program to filter by'),
            limit: Joi.string()
              .optional()
              .description('The limit to indicate number of rows'),
            department: Joi.string()
              .optional()
              .description('The department to filter by')
          }
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/surge-report',
      config: {
        plugins: {
          hapiAuthorization: {}
        },
        handler: function (request, reply) {
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'surge',
              ['startDate', 'endDate', 'locationUuids'],
              requestParams
            );
            let surgeService = new SurgeService(
              'surge',
              reportParams.requestParams
            );
            surgeService
              .generateReport()
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description: 'Get the week surge report',
        notes: 'Returns weekly surge report',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/surge-report-patient-list',
      config: {
        plugins: {
          hapiAuthorization: {}
        },
        handler: function (request, reply) {
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );

            let surgeService = new SurgeService('', requestParams);

            surgeService
              .getPatientListReport(requestParams)
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description: 'Get the week surge report patient list',
        notes: 'Returns weekly surge report patient list',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/retention-summary-report',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          }
        },
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              // console.log('requestParams', requestParams);
              let reportParams = etlHelpers.getReportParams(
                'retention-summary-report',
                [
                  'startDate',
                  'endDate',
                  'period',
                  'locations',
                  'indicators',
                  'genders',
                  'startAge',
                  'endAge'
                ],
                requestParams
              );
              let retentionService = new RetentionAppointmentTracingService(
                'retention-report',
                reportParams.requestParams
              );
              retentionService
                .generateReport()
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  console.error('Error: ', error);
                  reply(error);
                });
            });
          }
        },
        description: 'Get Retention report aggregate data',
        notes: 'Returns Retention summary aggregate',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/retention-summary-report/patient-list',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          request.query.reportName = 'retention-summary-report';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );

            let requestCopy = _.cloneDeep(requestParams);
            let reportParams = etlHelpers.getReportParams(
              request.query.reportName,
              ['startDate', 'endDate', 'locationUuids', 'locations'],
              requestParams
            );
            requestCopy.locations = reportParams.requestParams.locations;

            let retentionService = new RetentionAppointmentTracingService(
              'retention-report',
              requestCopy
            );

            retentionService
              .generatePatientListReport(requestParams.indicators.split(','))
              .then((results) => {
                reply(results);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description: 'Get Retention report Patient list',
        notes: 'Returns Retention Report Patient List',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/retention-summary-report/indicator-definitions',
      config: {
        auth: 'simple',
        plugins: {
          hapiAuthorization: {
            role: privileges.canViewClinicDashBoard
          }
        },
        handler: function (request, reply) {
          let service = new RetentionAppointmentTracingService();
          service
            .getIndicatorDefinitions()
            .then((result) => {
              reply(result);
            })
            .catch((error) => {
              reply(error);
            });
        },
        description: 'Get Retention report Patient list',
        notes: 'Returns Retention Report Patient List',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/hei-monthly-summary',
      config: {
        plugins: {
          hapiAuthorization: {}
        },
        handler: function (request, reply) {
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );
            let reportParams = etlHelpers.getReportParams(
              'hei-monthly-summary',
              ['startDate', 'endDate', 'locationUuids'],
              requestParams
            );

            let heiSummaryService = new HeiSummaryService(
              'MOH-408',
              reportParams.requestParams
            );
            heiSummaryService
              .generateReport()
              .then((result) => {
                reply(result);
              })
              .catch((error) => {
                console.error('Error: ', error);
                reply(error);
              });
          });
        },
        description: 'Get the monthly hei monthly summary report',
        notes: 'Returns the the monthly hei summary report',
        tags: ['api'],
        validate: {
          options: {
            allowUnknown: true
          },
          params: {}
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/hei-monthly-summary/patient-list',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          request.query.reportName = 'hei-summary-patient-list';
          preRequest.resolveLocationIdsToLocationUuids(request, function () {
            let requestParams = Object.assign(
              {},
              request.query,
              request.params
            );

            let requestCopy = _.cloneDeep(requestParams);
            let reportParams = etlHelpers.getReportParams(
              request.query.reportName,
              ['startDate', 'endDate', 'locationUuids', 'locations'],
              requestParams
            );
            const moh408Service = new HeiSummaryService('MOH-408', requestCopy);

            moh408Service
              .generatePatientListReport(requestParams.indicators.split(','))
              .then((results) => {
                reply(results);
              })
              .catch((err) => {
                reply(Boom.internal('An error occured', err));
              });
          });
        },
        description: 'HEI summary Patient list',
        notes: 'Returns HEI summary patient list',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-gain-loses-numbers',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.locationUuid) {
            request.query.locationUuids = request.query.locationUuid;
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                'monthly-gains-and-losses',
                ['startDate', 'endDate', 'locations'],
                requestParams
              );
              let hivGainsLossesService = new HIVGainsAndLossesService(
                'monthly-gains-and-losses',
                reportParams.requestParams
              );
              hivGainsLossesService
                .generateReport()
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  console.error('Error: ', error);
                  reply(error);
                });
            });
          }
        },
        description: 'HIV Gains annd losses report',
        notes: 'HIV Gains annd losses report',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-gain-loses-patient-list',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.locationUuid) {
            request.query.locationUuids = request.query.locationUuid;
            request.query.reportName = 'monthly-gains-and-losses';
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              console.log('requestParams', requestParams);
              let requestCopy = _.cloneDeep(requestParams);
              let reportParams = etlHelpers.getReportParams(
                request.query.reportName,
                ['startDate', 'endDate', 'locationUuids', 'genders'],
                requestParams
              );
              requestCopy.locations = reportParams.requestParams.locations;

              let hivGainsLossesService = new HIVGainsAndLossesService(
                'monthly-gains-and-losses',
                requestCopy
              );

              hivGainsLossesService
                .generatePatientListReport(requestParams.indicators.split(','))
                .then((results) => {
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            });
          }
        },
        description: 'HIV Gains annd losses Patient list',
        notes: 'Returns HIV Gains annd losses Patient List',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/patient-cervical-cancer-screening-summary',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          const patientUuid = request.query.uuid;
          cervicalCancerScreeningService
            .getPatientCervicalCancerScreeningSummary(patientUuid)
            .then((results) => {
              reply(results);
            })
            .catch((error) => {
              reply(Boom.internal('An error occured', error));
            });
        }
      }
    },
    {
      method: 'GET',
      path: '/etl/moh-412-report',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                'hiv-cervical-cancer-screening-monthly-report',
                ['startDate', 'endDate', 'locationUuids'],
                requestParams
              );
              let report = 'MOH-412-report';
              if (request.query.locationType === 'primary_care_facility') {
                reportParams.requestParams['primaryCareLocations'] =
                  reportParams.requestParams.locations;
                delete reportParams.requestParams.locations;
                report = 'MOH-412-PCF-report';
              }

              const moh412Service = new MOH412Service(
                report,
                reportParams.requestParams
              );
              moh412Service
                .generateReport()
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description: 'MOH-412 Report',
        notes: 'Returns Report for HIV Cervical Cancer Screening',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/moh-412-report/patient-list',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            request.query.reportName =
              'hiv-cervical-cancer-screening-monthly-report';
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );

              let requestCopy = _.cloneDeep(requestParams);
              let reportParams = etlHelpers.getReportParams(
                request.query.reportName,
                ['startDate', 'endDate', 'locationUuids', 'locations'],
                requestParams
              );
              let report = 'MOH-412-report';
              if (request.query.locationType === 'primary_care_facility') {
                requestCopy['primaryCareLocations'] =
                  reportParams.requestParams.locations;
                delete requestCopy.locations;
                report = 'MOH-412-PCF-report';
              } else {
                requestCopy.locations = reportParams.requestParams.locations;
              }
              let moh412Service = new MOH412Service(report, requestCopy);

              moh412Service
                .getPatientListReport(requestParams)
                .then((results) => {
                  reply(results);
                })
                .catch((err) => {
                  reply(Boom.internal('An error occured', err));
                });
            });
          }
        },
        description: 'MOH-412 Report',
        notes: 'Returns Report for HIV Cervical Cancer Screening',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/covid-vaccination-status',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.patientUuid) {
            const patientUuid = request.query.patientUuid;
            getPatientCovidVaccinationStatus(patientUuid)
              .then((results) => {
                reply(results);
              })
              .catch((error) => {
                reply(Boom.internal('An error occured', error));
              });
          } else {
            reply(Boom.internal('Request misssing patient uuid'));
          }
        },
        description: 'COVID-19 Vaccination Status',
        notes: 'Returns the patients covid 19 vaccination status',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/covid-19-monthly-vaccination-report',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                'covid-19-monthly-report',
                ['endingMonth', 'locationUuids', 'locations'],
                requestParams
              );
              const covid19MonthlyReport = new Covid19MonthlyReport(
                'covid-19-monthly-report',
                reportParams.requestParams
              );
              covid19MonthlyReport
                .generateReport(reportParams.requestParams)
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description: 'COVID-19 Monthly Report',
        notes:
          'Returns summary of vaccinated i.e fully,partial and not vaccinated',
        tags: ['api']
      }
    },
    {
      method: 'GET',
      path: '/etl/covid-19-monthly-vaccination-report/patient-list',
      config: {
        auth: 'simple',
        plugins: {},
        handler: function (request, reply) {
          if (request.query.locationUuids) {
            preRequest.resolveLocationIdsToLocationUuids(request, function () {
              let requestParams = Object.assign(
                {},
                request.query,
                request.params
              );
              let reportParams = etlHelpers.getReportParams(
                'covid-19-monthly-report',
                ['endingMonth', 'locationUuids', 'locations'],
                requestParams
              );
              delete reportParams.requestParams['gender'];
              const covid19MonthlyReport = new Covid19MonthlyReport(
                'covid-19-monthly-report',
                reportParams.requestParams
              );
              covid19MonthlyReport
                .generatePatientListReport(reportParams.requestParams)
                .then((result) => {
                  reply(result);
                })
                .catch((error) => {
                  reply(error);
                });
            });
          }
        },
        description: 'COVID-19 Monthly Report Patient List',
        notes:
          'Returns patient list of vaccinated i.e fully,partial and not vaccinated',
        tags: ['api']
      }
    }
  ];

  return routes;
})();