node-red-contrib-mi-devices/node-red-contrib-xiaomi-ht/xiaomi-ht.js

module.exports = function(RED) {
    "use strict";
    var mustache = require("mustache");
    var dgram = require('dgram');
    var miDevicesUtils = require('../utils');

    function XiaomiHtNode(config) {
        RED.nodes.createNode(this, config);
        this.gateway = RED.nodes.getNode(config.gateway);
        this.sid = config.sid;
        this.output = config.output;
        this.temperature = config.temperature;
        this.humidity = config.humidity;
        this.divide = config.divide;

        var node = this;
        node.status({fill:"grey", shape:"ring", text:"battery - na"});

        if (this.gateway) {
            node.on('input', function(msg) {
                // var payload = JSON.parse(msg);
                var payload = msg.payload;
                node.log("Received message from: " + payload.model + " sid: " + payload.sid + " payload: " + payload.data);

                // Input from gateway
                if(payload.sid) {
                    if (payload.sid == node.sid && ["sensor_ht", "weather.v1"].indexOf(payload.model) >= 0) {
                        var data = payload.data;
                        miDevicesUtils.setStatus(node, data);

                        if (node.output == "0") {
                            node.send([msg]);
                        } else if (node.output == "1") {
                            var temp = null;
                            var humidity = null;
                            var pressure = null;

                            if (data.temperature) {
                                temp = {"payload": data.temperature};
                            }

                            if (data.humidity) {
                                humidity = {"payload": data.humidity};
                            }

                            if (data.pressure) {
                                pressure = {"payload": data.pressure};
                            }
                            node.send([temp, humidity, pressure]);
                        } else if (node.output == "2") {
                            var temp = null;
                            var humidity = null;
                            var pressure = null;

                            if (data.temperature) {
                                if (this.divide) {
                                    data.temperature = String(data.temperature / 100);
                                }
                                temp = {"payload": mustache.render(node.temperature, data)}
                            }

                            if (data.humidity) {
                                if (this.divide) {
                                    data.humidity = String(data.humidity / 100);
                                }
                                humidity = {"payload": mustache.render(node.humidity, data)}
                            }

                            if (data.pressure) {
                                if (this.divide) {
                                    data.pressure = String(data.pressure / 100);
                                }
                                pressure = {"payload": mustache.render(node.pressure, data)}
                            }
                            node.send([temp, humidity, pressure]);
                        }
                    }
                }
                // Prepare for request
                else {
                    miDevicesUtils.prepareForGatewayRequest(node, msg);
                    node.send(msg);
                }
            });

            node.on("close", function() {
            });

        } else {
            // no gateway configured
        }

    }

    RED.nodes.registerType("xiaomi-ht", XiaomiHtNode);

}