indoor.js

module.exports = function(RED) {
    function nibeIndoor(config) {
        RED.nodes.createNode(this,config);
        let node = this;
        const server = RED.nodes.getNode(config.server);
        async function startUp() {
            let system = config.system.replace('s','S');
            let conf = server.nibe.getConfig();
            node.status({ fill: 'yellow', shape: 'dot', text: `System ${system}` });
            let arr = [
                //{topic:"inside_"+config.system,source:"nibe"},
                {topic:"inside_set_"+config.system,source:"nibe"},
                {topic:"inside_enable_"+config.system,source:"nibe"},
                {topic:"inside_factor_"+config.system,source:"nibe"},
                {topic:"exhaust",source:"nibe"},
                {topic:"outside",source:"nibe"}
            ];
            if(conf.system.pump!=="F370" && conf.system.pump!=="F470") {
                arr.push({topic:"dM",source:"nibe"});
                arr.push({topic:"dMstart",source:"nibe"})
            }
            if(conf.indoor===undefined) {
                conf.indoor = {};
                server.nibe.setConfig(conf);
            }
            if(conf.home.inside_sensors===undefined) {
                conf.home.inside_sensors = [];
                server.nibe.setConfig(conf);
            }
            if(conf.indoor['sensor_'+config.system]===undefined || conf.indoor['sensor_'+config.system]=="Ingen") {
                arr.push({topic:"inside_"+config.system,source:"nibe"});
            } else {
                let index = conf.home.inside_sensors.findIndex(i => i.name == conf.indoor['sensor_'+config.system]);
                if(index!==-1) {
                    var insideSensor = Object.assign({}, conf.home.inside_sensors[index]);
                    
                    
                    arr.push(insideSensor);
                }
            }
            let nibe_enabled = await server.nibe.reqData(server.hP()["inside_enable_"+config.system]).catch();
            if(nibe_enabled===undefined || nibe_enabled.data===undefined || nibe_enabled.data!==1 && conf.indoor['enable_'+config.system]!==true){ arr = [];}
                server.initiatePlugin(arr,'indoor',config.system).then(data => {
                    node.status({ fill: 'green', shape: 'dot', text: `System ${system}` });
                    node.send({enabled:true});
                },(reject => {
                    node.status({ fill: 'red', shape: 'dot', text: `System ${system}` });
                    node.send({enabled:false});
                }));
        }
        node.on('input', function(msg) {
            let conf = server.nibe.getConfig();
            if(msg.topic=="update") {
                server.updateData();
                return;
            }
            if(msg.payload!==undefined && msg.topic!==undefined && msg.topic!=="") {
                let req = msg.topic.split('/');
                if(conf[req[0]]===undefined) conf[req[0]] = {};
                if(conf[req[0]][req[1]+'_'+config.system]!==msg.payload) {
                    conf[req[0]][req[1]+'_'+config.system] = msg.payload;
                    server.nibe.setConfig(conf);
                }
                startUp();
            }
            
        });
        if(server.nibe.core!==undefined && server.nibe.core.connected!==undefined && server.nibe.core.connected===true) {
            startUp();
        } else {
            server.nibeData.on('ready', (data) => {
                startUp();
            })
        }
        server.nibeData.on(node.id, (data) => {
            if(data.changed===true) {
                config.system = data.system;
                if(server.nibe.core!==undefined && server.nibe.core.connected!==undefined && server.nibe.core.connected===true) {
                    startUp();
                }
            }
        })
        server.nibeData.on('pluginIndoor', (data) => {
            if(data.system===config.system) {
                let outside = data['outside'];
                let inside = data.indoorSensor;
                
                if(inside===undefined) inside = data['inside_'+data.system];
                if(inside!==undefined && inside.data>-3276) {
                    node.send({topic:"Inomhustemperatur",payload:inside.data});
                }
                if(data.indoorOffset!==undefined) {
                    node.send({topic:"Kurvjustering",payload:data.indoorOffset});
                }
                node.send({topic:"Tid",payload:outside.timestamp});
                node.send({topic:"Avvikelse",payload:data.accuracy});
            }
        })

        node.on('close', function() {
            let system = config.system.replace('s','S');
            server.nibeData.removeAllListeners();
            node.status({ fill: 'yellow', shape: 'dot', text: `System ${system}` });
        });
    }
    RED.nodes.registerType("nibe-indoor",nibeIndoor);
}