hpos-data/cloud-functions/nodejs/functions/index.js

const { onRequest } = require("firebase-functions/v2/https");
const logger = require("firebase-functions/logger");
const functions = require("firebase-functions");
const admin = require("firebase-admin");
const moment = require('moment');
const fs = require('fs');
const csv = require('csv-parser');
const html_to_pdf = require('html-pdf-node');

admin.initializeApp();

exports.registerUser = functions.region("asia-south1").https.onRequest(async (req, res) => {
    res.set('Access-Control-Allow-Origin', "*")
    res.set('Access-Control-Allow-Methods', 'GET, POST');

    if (req.method === "OPTIONS") {
        // stop preflight requests here
        res.set("Access-Control-Allow-Headers", "Content-Type, x-client");
        res.status(204).send('');
        return;
    }

    try {
        const token = "e16a1bd15af2ee640f5a7a18c8d8333f5f01f7c66e003bbc21ee52870f1bce27";
        logger.info(`User-Agent ${req.get("User-Agent")}`);
        logger.info(`token ${req.get("x-client")}`);
        if (req.get("x-client") !== token) {
            res.json({ status: "403", message: "auth error", result: "true" });
        }
        else {
            const { body } = req;
            const { _id } = body;
            logger.info(`_id ${_id}`);
            await admin
                .firestore()
                .collection("patientData")
                .add(Object.assign(Object.assign({}, body), { createdAt: moment().utcOffset("+05:30").format("YYYY-MM-DD HH:mm:ss") }))
            res.json({ status: "200" });
        }
    }
    catch (err) {
        logger.info(`error ${err}`);
        res.json({ status: "400", message: "some error.", result: "true" });
    }
});

exports.addBloodTest = functions.region("asia-south1").https.onRequest(async (req, res) => {
    res.set('Access-Control-Allow-Origin', "*")
    res.set('Access-Control-Allow-Methods', 'GET, POST');

    if (req.method === "OPTIONS") {
        // stop preflight requests here
        res.set("Access-Control-Allow-Headers", "Content-Type, x-client");
        res.status(204).send('');
        return;
    }

    try {
        const token = "e16a1bd15af2ee640f5a7a18c8d8333f5f01f7c66e003bbc21ee52870f1bce27";
        logger.info(`User-Agent ${req.get("User-Agent")}`);
        logger.info(`token ${req.get("x-client")}`);
        if (req.get("x-client") !== token) {
            res.json({ status: "403", message: "auth error", result: "true" });
        }
        else {
            const { body } = req;
            const { _id } = body;
            logger.info(`_id ${_id}`);
            await admin
                .firestore()
                .collection("testData")
                .add(Object.assign(Object.assign({}, body), { testTime: moment().utcOffset("+05:30").format("YYYY-MM-DD HH:mm:ss") }))
            res.json({ status: "200" });
        }
    }
    catch (err) {
        logger.info(`error ${err}`);
        res.json({ status: "400", message: "some error.", result: "true" });
    }
});

exports.reportDownload = functions.region("asia-south1").https.onRequest(async (req, res) => {
    res.set('Access-Control-Allow-Origin', "*")
    res.set('Access-Control-Allow-Methods', 'GET, POST');

    if (req.method === "OPTIONS") {
        // stop preflight requests here
        res.set("Access-Control-Allow-Headers", "Content-Type, x-client");
        res.status(204).send('');
        return;
    }

    try {
        const token = "e16a1bd15af2ee640f5a7a18c8d8333f5f01f7c66e003bbc21ee52870f1bce27";
        logger.info(`User-Agent ${req.get("User-Agent")}`);
        logger.info(`token ${req.get("x-client")}`);
        if (req.get("x-client") !== token) {
            res.json({ status: "403", message: "auth error", result: "true" });
        }
        else {
            const { body } = req;
            const { data } = body;
            logger.info(`_id ${_id}`);
            const fileName = `${data["_id"]}.pdf`;
            // await makePdf();
            res.sendFile(fileName, options, function (err) {
                if (err) {
                    next(err);
                } else {
                    console.log('Sent:', fileName);
                }
            });
        }
    }
    catch (err) {
        logger.info(`error ${err}`);
        res.json({ status: "400", message: "some error.", result: "true" });
    }
});

/**
 * Triggered by a change to a Firestore document.
 *
 * @param {!Object} event Event payload.
 * @param {!Object} context Metadata for the event.
 */

// const functions = require("firebase-functions");
// const admin = require("firebase-admin");
// const moment = require('moment');

// admin.initializeApp();

exports.kitAlert = async (event, context) => {
    const resource = context.resource;
    // log out the resource string that triggered the function
    console.log('Function triggered by change to: ' + resource);
    // now log the full event object
    console.log(JSON.stringify(event));
    const { kitSerial, classificationResult, _id, led1Average, led3Average, deviceRatio } = event.value.fields;
    console.log('kitSerial', kitSerial);
    console.log('classificationResult', classificationResult);
    // if (classificationResult?.stringValue?.includes("Trait")) {
    //     const currentKitTests = await admin.firestore().collection("testData").where("kitSerial", "==", kitSerial.stringValue).get();
    //     let traitCount = 0;
    //     currentKitTests?.docs.forEach((x) => {
    //         if (x.data().classificationResult?.includes("Trait")) {
    //             traitCount++;
    //         }
    //     });
    //     console.log("traitCount", traitCount);
    //     if (traitCount > 2) {
    //         await admin.firestore().collection("alerts").add({
    //             name: 'Kit Alert',
    //             traitCount: traitCount,
    //             message: `${kitSerial.stringValue} has ${traitCount} traits`
    //         });
    //     }
    //     const sgMail = require('@sendgrid/mail');
    //     sgMail.setApiKey('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');
    //     const msg = {
    //     to: ['hpos.smi@gmail.com', 'pritimay@sminnovations.in'],
    //     from: 'pritimay@sminnovations.in',
    //     subject: `Kit Alert: ${kitSerial.stringValue}`,
    //     text: `${kitSerial.stringValue} has ${traitCount} traits`,
    //     html: `<p>${kitSerial.stringValue} has ${traitCount} traits</p>`,
    //     };
    //     sgMail.send(msg);
    // }

    const led1Intercept = -0.85965;
    const led3Slope = 0.184991;
    const led3Intercept = 0.001704;

    console.log('_id', _id?.stringValue);
    console.log('led1Average', led1Average?.doubleValue);
    console.log('led3Average', led3Average?.doubleValue);
    const LED1Average = led1Average?.doubleValue;
    const LED3Average = led3Average?.doubleValue;

    const Abs427 = LED1Average * 1.2648 - 0.85965;
    const Abs555 = LED3Average * 0.184991 + 0.001704;
    const pdr = Abs555 / Abs427;
    // const pdr = 0.239;
    console.log(pdr);
    let classification = "NA";
    if (pdr > 0 && pdr <= 0.16) {
        classification = "Normal";
    }

    if (pdr > 0.16 && pdr <= 0.165) {
        classification = "Negative Borderline";
    }

    if (pdr > 0.165 && pdr <= 0.235) {
        classification = "Sickle Cell Trait";
    }

    if (pdr > 0.235 && pdr <= 0.24) {
        classification = "Positive Borderline";
    }

    if (pdr > 0.24 && pdr <= 1) {
        classification = "Sickle Cell Disease";
    }

    // device ratio class
    const devRatio = deviceRatio?.doubleValue;
    let devRatioClass = "INVALID";
    if (devRatio > 0 && devRatio <= 0.55) {
        devRatioClass = "Normal";
    }
    if (devRatio > 0.55 && devRatio <= 0.575) {
        devRatioClass = "Negative Borderline";
    }
    if (devRatio > 0.575 && devRatio <= 0.85) {
        devRatioClass = "Sickle Cell Trait";
    }
    if (devRatio > 0.85 && devRatio <= 0.9) {
        devRatioClass = "Positive Borderline";
    }
    if (devRatio > 0.9 && devRatio <= 1) {
        devRatioClass = "Sickle Cell Disease";
    }

    console.log(classification);

    const docs = await admin.firestore().collection("testData").where("_id", "==", _id.stringValue).get();
    docs?.forEach(async (doc) => {
        await admin.firestore().collection("testData").doc(doc.id).update({
        // abs427: Abs427,
        // abs555: Abs555,
        // predictedDenovixRatio: pdr,
        // prdClassification: classification
        // incubationTime: admin.firestore.FieldValue.delete()
            deviceRatioClass: devRatioClass,
        });
    })
};


/**
 * Triggered by a change to a Firestore document.
 *
 * @param {!Object} event Event payload.
 * @param {!Object} context Metadata for the event.
 */

// const functions = require("firebase-functions");
// const admin = require("firebase-admin");
// const moment = require('moment');

// admin.initializeApp();

exports.dataRegularity = async (event, context) => {
    const resource = context.resource;
    // log out the resource string that triggered the function
    console.log('Function triggered by change to: ' + resource);
    // now log the full event object
    console.log(JSON.stringify(event));
    const { kitSerial, classificationResult, _id, deviceId, led1Buffer, led2Buffer, led1Sample, led2Sample } = event.value.fields;
    console.log('_id', _id?.stringValue);
    if (led1Buffer?.stringValue > 27000 || led2Buffer?.stringValue > 28000 || led1Sample?.stringValue) {
        const currentKitTests = await admin.firestore().collection("testData").where("kitSerial", "==", kitSerial.stringValue).get();
        let traitCount = 0;
        currentKitTests?.docs.forEach((x) => {
            if (x.data().classificationResult?.includes("Trait")) {
                traitCount++;
            }
        });
        await admin.firestore().collection("alerts").add({
            name: 'Data Regularity',
            kit: kitSerial.stringValue,
            deviceId: deviceId,
            message: `${_id.stringValue} has some irregularity in data`,
            createdAt: moment().utcOffset("+05:30").format("YYYY-MM-DD HH:mm:ss")
        });
    }
};



const axios = require('axios');
const admin = require("firebase-admin");
const moment = require('moment');

admin.initializeApp();

exports.migrateUsers = async (event, context) => {
    const resource = context.resource;
    // log out the resource string that triggered the function
    console.log('Function triggered by change to: ' + resource);
    // now log the full event object
    console.log(JSON.stringify(event));
    const { _id, name } = event.value.fields;
    const { _idSearch, abhaIdSearch, aadharIdSearch } = event.value.fields;
    if (!_idSearch?.stringValue) {
        const docs = await admin.firestore().collection("patientData").where("_id", "==", _id.stringValue).get();
        docs?.forEach(async (doc) => {
            await admin.firestore().collection("patientData").doc(doc.id).update({
                _idSearch: `${moment().format('YYYYMMDD')}${doc.data()._id}`,
                abhaIdSearch: `${moment().format('YYYYMMDD')}${doc.data().abhaId}`,
                aadharIdSearch: `${moment().format('YYYYMMDD')}${doc.data().aadharId}`,
            });
            console.log('search logic', _id.stringValue);
        })
    }
    const NO_OF_COPIES = 3;
    for (let i = 0; i < NO_OF_COPIES; i++) {
        await axios.post("https://asia-south1-hpos-preprod.cloudfunctions.net/registerUser",
            {
                "_id": `${_id.stringValue}${i}`,
                "aadharId": "2808202300001",
                "abhaId": "12434949797979",
                "birthYear": "2000",
                "bloodGroup": "",
                "careOf": "",
                "caste": "",
                "city": "Bengaluru",
                "district": "Bengaluru",
                "gender": "Male",
                "house": "42",
                "maritalStatus": "Single",
                "name": name.stringValue,
                "phoneNumber": "9123456789",
                "pinCode": "560060",
                "registeredBy": "admin",
                "registrationCenterName": "SMI",
                "sickleCellHistory": null,
                "state": "Karnataka",
                "subCaste": "",
                "testStatus": false,
                "underMedication": false,
                "underTransfusion": false,
                "userImageURL": "https://hpos-prod.web.app/logo.png"
            }, {
            headers: {
                "Content-Type": "application/json",
                "x-client": "e16a1bd15af2ee640f5a7a18c8d8333f5f01f7c66e003bbc21ee52870f1bce27"
            }
        })
    }
};


/**
 * Triggered by a change to a Firestore document.
 *
 * @param {!Object} event Event payload.
 * @param {!Object} context Metadata for the event.
 */

const admin = require("firebase-admin");
const moment = require('moment');

admin.initializeApp();

exports.retestMarking = async (event, context) => {
    const resource = context.resource;
    // log out the resource string that triggered the function
    console.log('Function triggered by change to: ' + resource);
    // now log the full event object
    console.log(JSON.stringify(event));
    const { _id, classificationResult } = event.value.fields;
    console.log("classificationResult", classificationResult.stringValue);
    if (classificationResult?.stringValue?.includes("Positive Borderline") || classificationResult?.stringValue?.includes("Inconclusive") || classificationResult?.stringValue?.includes("Trait")) {
        const docs = await admin.firestore().collection("patientData").where("_id", "==", _id.stringValue).get();
        docs?.forEach(async (doc) => {
            await admin.firestore().collection("patientData").doc(doc.id).update({
                testStatus: false,
                retested: true
                // incubationTime: admin.firestore.FieldValue.delete()
            });
        })
    }

    const { _idSearch, abhaIdSearch, aadharIdSearch } = event.value.fields;
    if (!_idSearch?.stringValue) {
        const docs = await admin.firestore().collection("patientData").where("_id", "==", _id.stringValue).get();
        docs?.forEach(async (doc) => {
            await admin.firestore().collection("patientData").doc(doc.id).update({
                _idSearch: `${moment().format('YYYYMMDD')}${_id}`,
                abhaIdSearch: `${moment().format('YYYYMMDD')}${abhaId}`,
                aadharIdSearch: `${moment().format('YYYYMMDD')}${aadharId}`,
            });
            console.log('search logic', _id.stringValue);
        })
    }
};

/**
 * Triggered by a change to a Firestore document.
 *
 * @param {!Object} event Event payload.
 * @param {!Object} context Metadata for the event.
 */
const axios = require('axios');
const admin = require("firebase-admin");
const moment = require('moment');

admin.initializeApp();

exports.sampleClassification = async (event, context) => {
    const resource = context.resource;
    // log out the resource string that triggered the function
    console.log('Function triggered by change to: ' + resource);
    // now log the full event object
    console.log(JSON.stringify(event));

    const { _id, calculatedRatio, deviceRatio, led1Buffer, led2Buffer, led1Sample, led2Sample} = event.value.fields;
    const predictionResponse = await axios.post("https://asia-south1-hpos-af3cc.cloudfunctions.net/prediction",
        {
            "_id": `${_id.stringValue}`,
            "calculatedRatio": calculatedRatio.stringValue || calculatedRatio.doubleValue,
            "deviceRatio": deviceRatio.stringValue || deviceRatio.doubleValue || deviceRatio.integerValue,
            "led1Buffer": led1Buffer.stringValue || led1Buffer.doubleValue || led1Buffer.integerValue,
            "led2Buffer": led2Buffer.stringValue || led2Buffer.doubleValue || led2Buffer.integerValue,
            "led1Sample": led1Sample.stringValue || led1Sample.doubleValue || led1Sample.integerValue,
            "led2Sample": led2Sample.stringValue || led2Sample.doubleValue || led2Sample.integerValue
        }, {
        headers: {
            "Content-Type": "application/json",
            "x-client": "e16a1bd15af2ee640f5a7a18c8d8333f5f01f7c66e003bbc21ee52870f1bce27"
        }
    });
    const { predictedClass } = predictionResponse.data;
    console.log("predictedClass", predictedClass);
    const docs = await admin.firestore().collection("testData").where("_id", "==", _id.stringValue).get();
    docs?.forEach(async (doc) => {
        await admin.firestore().collection("testData").doc(doc.id).update({
            predictedClass: predictedClass,
            modelId: "1",
            modelVersion: "1.0.1"
        });
    })
};