dsi-icl/optimise

import SelectorUtils from '../utils/selector-utils';
import { v4 as uuid } from 'uuid';
import { getEntry, createEntry, updateEntry, deleteEntry, searchEntry } from '../utils/controller-utils';
import ErrorHelper from '../utils/error_helper';
import message from '../utils/message-utils';

const patientModel = {
    aliasId: ''
};

/**
 * @description Patient Core allow to get, search, create and delete a patient
 */
class Patient {
    static getPatient(whereObj, selectedObj, deleted) {
        return new Promise((resolve, reject) => {
            if (deleted !== true)
                whereObj.deleted = '-';
            return getEntry('PATIENTS', whereObj, selectedObj).then((result) => resolve(result)).catch((error) => reject(ErrorHelper(message.errorMessages.GETFAIL, error)));
        });
    }

    /**
     * @function getPatientProfile
     * @description Return patient information (demographic / visit / etc... )
     * @param {Object} whereObj where closure for query
     * @param {Boolean} deleted True to look for not deleted entries. False for also deleted ones.
     * @param {string} getOnly Filtering return.
     */
    static getPatientProfile(whereObj, deleted, getOnly) {
        return new Promise((resolve, reject) => Patient.getPatient(whereObj, { patientId: 'id', alias: 'aliasId', optimiseConsent: 'optimiseConsent', pregnancySubStudyConsent: 'pregnancySubStudyConsent', participation: 'participation' }, deleted)
            .then((Patientresult) => {
                let patientId;
                if (Patientresult.length === 1) {
                    patientId = Patientresult[0].patientId;
                } else {
                    return reject(ErrorHelper(message.errorMessages.NOTFOUND));
                }
                const promiseArr = [];

                let availableFunctions = ['getComorbidities', 'getDemographicData', 'getImmunisations', 'getMedicalHistory', 'getVisits', 'getTests', 'getTreatments', 'getClinicalEvents', 'getPregnancy', 'getPregnancyEntries', 'getPregnancyImages', 'getDiagnosis', 'getConcomitantMeds'];

                if (getOnly && typeof getOnly === 'string')
                    availableFunctions = getOnly.split(',').filter((func) => availableFunctions.includes(func));

                for (let i = 0; i < availableFunctions.length; i++) {
                    promiseArr.push(SelectorUtils[availableFunctions[i]](patientId, deleted));
                }
                const selectorPromises = Promise.all(promiseArr);
                selectorPromises.then((result) => {
                    const responseObj = {};
                    responseObj.patientId = Patientresult[0].alias;
                    responseObj.id = patientId;
                    responseObj.optimiseConsent = Patientresult[0].optimiseConsent;
                    responseObj.pregnancySubStudyConsent = Patientresult[0].pregnancySubStudyConsent;
                    responseObj.participation = Boolean(Patientresult[0].participation);
                    for (let i = 0; i < result.length; i++) {
                        responseObj[Object.keys(result[i])[0]] = result[i][Object.keys(result[i])[0]];
                    }
                    return resolve(responseObj);
                }).catch((error) => reject(ErrorHelper(message.errorMessages.NOTFOUND, error)));
                return true;
            }).catch((error) => reject(ErrorHelper(message.errorMessages.NOTFOUND, error))));
    }

    /**
     * @description Search a patient from a 'like' query.
     * @returns Promise that contains the patient in the success callback and the error stack in the error callback
     * @param {string} query The aliasId of the patient seeking for
     */
    static searchPatients(queryfield, queryvalue) {
        return new Promise((resolve, reject) => searchEntry(queryfield, queryvalue).then((success) => resolve(success)).catch((error) => reject(ErrorHelper(message.errorMessages.SEARCHFAIL, error))));
    }

    /**
     * @description Create a new patient
     * @param {*} patient The new created patient
     */
    static createPatient(patient) {
        return new Promise((resolve, reject) => {
            const entryObj = Object.assign({}, patientModel, patient);
            entryObj.uuid = uuid();
            return createEntry('PATIENTS', entryObj).then((result) => resolve(result)).catch((error) => reject(ErrorHelper(message.errorMessages.CREATIONFAIL, error)));
        });
    }

    /**
     * @description Update a new patient
     * @param {*} user Information about the user
     * @param {*} patient The new created patient
     */
    static updatePatient(user, patientObj) {
        return new Promise((resolve, reject) => updateEntry('PATIENTS', user, '*', { id: patientObj.id }, patientObj).then((result) => resolve(result)).catch((error) => reject(ErrorHelper(message.errorMessages.CREATIONFAIL, error))));
    }

    /**
     * @function deletePatient delete an entry of Patient from an ID.
     *
     * @param {*} user Information about the user
     * @param {*} idObj ID of the entry that is going to be deleted
     */
    static deletePatient(user, idObj) {
        return new Promise((resolve, reject) => deleteEntry('PATIENTS', user, idObj).then((success) => resolve(success)).catch((error) => reject(ErrorHelper(message.errorMessages.DELETEFAIL, error))));
    }
}

export default Patient;