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

const miDevicesUtils = require('../src/utils');

module.exports = (RED) => {
    /*********************************************
     Read data from Gateway
     *********************************************/
    function XiaomiActionRead(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            if(msg.sid) {
                msg.payload = { cmd: "read", sid: msg.sid };
                this.send(msg);
            }
        });
    }
    RED.nodes.registerType("xiaomi-actions read", XiaomiActionRead);

    /*********************************************
     Get registred ids of devices on gateway
     *********************************************/
    function XiaomiActionGetIdList(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            msg.payload = { cmd: "get_id_list" };
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions get_id_list", XiaomiActionGetIdList);

    /*********************************************
     Virtual single click on a button
     *********************************************/
    function XiaomiActionSingleClick(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            msg.payload = {
                cmd: "write",
                data: { status: "click", sid: msg.sid }
            };
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions click", XiaomiActionSingleClick);

    /*********************************************
     Virtual Double click on a button
     *********************************************/
    function XiaomiActionDoubleClick(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            msg.payload = {
                cmd: "write",
                data: { status: "double_click", sid: msg.sid }
            };
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions double_click", XiaomiActionDoubleClick);

    /*********************************************
     Set the gateway light
     *********************************************/
    function XiaomiActionGatewayLight(config) {
        RED.nodes.createNode(this, config);
        this.color = config.color;
        this.brightness = config.brightness;

        this.on('input', (msg) => {
            let color = msg.color || this.color;
            let brightness = msg.brightness || this.brightness;
            if(msg.sid) {
                let rgb = miDevicesUtils.computeColorValue(color.red, color.green, color.blue, brightness);
                msg.payload = {
                    cmd: "write",
                    data: { rgb: rgb, sid: msg.sid }
                };
            }
            else {
                msg.payload = {
                    color: miDevicesUtils.computeColorValue(color.red, color.green, color.blue),
                    brightness: brightness
                };
            }
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions gateway_light", XiaomiActionGatewayLight);

    /*********************************************
     Play a sound on the gateway
     *********************************************/
    function XiaomiActionGatewaySound(config) {
        RED.nodes.createNode(this, config);
        this.mid = config.mid;
        this.volume = config.volume;

        this.on('input', (msg) => {
            msg.payload = {
                cmd: "write",
                data: {
                    mid: parseInt(msg.mid || this.mid),
                    volume: parseInt(msg.volume || this.volume),
                    sid: msg.sid
                }
            };
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions gateway_sound", XiaomiActionGatewaySound);

    /*********************************************
     Stop playing a sound on the gateway
     *********************************************/
    function XiaomiActionGatewayStopSound(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            msg.payload = {
                cmd: "write",
                data: { mid: 1000, sid: msg.sid }
            };
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions gateway_stop_sound", XiaomiActionGatewayStopSound);

    /*********************************************
     Turn device on
     *********************************************/
    function XiaomiActionPowerOn(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            if(msg.sid){
                msg.payload = {
                    cmd: "write",
                    data: { status: "on", sid: msg.sid }
                };
            }
            else {
                msg.payload = "on";
            }
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions on", XiaomiActionPowerOn);

    /*********************************************
     Turn device off
     *********************************************/
    function XiaomiActionPowerOff(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            if(msg.sid){
                msg.payload = {
                    cmd: "write",
                    data: { status: "off", sid: msg.sid }
                };
            }
            else {
                msg.payload = "off";
            }
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions off", XiaomiActionPowerOff);

    /*********************************************
     Toggle device
     *********************************************/
    function XiaomiActionToggle(config) {
        RED.nodes.createNode(this, config);

        this.on('input', (msg) => {
            msg.payload = "toggle";
            this.send(msg);
        });
    }
    RED.nodes.registerType("xiaomi-actions toggle", XiaomiActionToggle);
}