raspberrypi_nodejs_projects/modules/water.js

const http = require('http')
const globalVars = require('../libs/globalVars')
const led = require('../libs/led')
const common = require('../libs/common')
const lcd = require('../libs/lcd')
const logger = require('perfect-logger');


module.exports = {

    getStatus: () => {
        var rest_options = {
            host: '192.168.4.5',
            port: 2020,
            path: '/water/status',
            method: 'GET'
        };
        logger.info('water request')
        var request = http.request(rest_options, function (response) {
            var content = "";

            // Handle data chunks
            response.on('data', function (chunk) {
                content += chunk;
            });

            // Once we're done streaming the response, parse it as json.
            response.on('end', async function () {
                var data = JSON.parse(content);
                let waterdata = {
                    "waterOn": data.waterOn,
                    "time": await common.nextEvent(data.nextScheduleEventUtcTime),
                }
                globalVars.waterNextEvent = waterdata.time

                // let m = await common.time(data.nextScheduleEventUtcTime)
                async function updateWater() {
                    if (globalVars.waterOn === "" || globalVars.waterOn === "error") {
                        if (waterdata.waterOn === 'true') {
                            globalVars.waterOn = waterdata.waterOn
                            lcd.waterPageOne('Heating', globalVars.waterNextEvent)
                            led.set('red')
                        } else {
                            globalVars.waterOn = waterdata.waterOn
                            lcd.waterPageOne('Not Heating', globalVars.waterNextEvent)
                            led.set('blue')
                        }
                    } else {
                        if (waterdata.waterOn === 'true') {
                            globalVars.waterOn = waterdata.waterOn
                            lcd.waterPageOne('Heating', globalVars.waterNextEvent)
                            led.set('red')
                        } else {
                            globalVars.waterOn = waterdata.waterOn
                            lcd.waterPageOne('Not Heating', globalVars.waterNextEvent)
                            led.set('blue')
                        }
                    }
                }

                if (globalVars.lastWaterRequest === "") {
                    logger.info('initial load')
                    globalVars.lastWaterRequest = waterdata
                    updateWater()
                } else if (JSON.stringify(globalVars.lastWaterRequest) == JSON.stringify(waterdata)) {
                    logger.info('no update')
                } else {
                    updateWater()
                }
            });
        });

        // Report errors
        request.on('error', function (error) {
            lcd.waterStatus('Error')
            led.set('green')
            lcd.waterStatus('Error No Data')
            globalVars.waterOn = 'error'
        });

        request.end();
    }
}