main.js

"use strict";

/*
 * Created with @iobroker/create-adapter v1.20.0
 */

// The adapter-core module gives you access to the core ioBroker functions
// you need to create an adapter
const utils = require("@iobroker/adapter-core");
let pollingInterval;

// Load your modules here, e.g.:
var PalazzettiRequest = require('./lib/palazzettiRequest').PalazzettiRequest;

var setObjectStates = require('./lib/palazzettiObjectStateMap');
const { rejects } = require("assert");

class Palazzetti extends utils.Adapter {
    /**
     * @param {Partial<ioBroker.AdapterOptions>} [options={}]
     */
    constructor(options) {
        super({
            ...options,
            name: "palazzetti",
        });
        this.on("ready", this.onReady.bind(this));
        this.on("stateChange", this.onStateChange.bind(this));
        // this.on("message", this.onMessage.bind(this));
        this.on("unload", this.onUnload.bind(this));
    }

    /**
     * Is called when databases are connected and adapter received configuration.
     */
    async onReady() {
        // Initialize your adapter here

        // The adapters config (in the instance object everything under the attribute "native") is accessible via
        // this.config:
        this.log.info("config ip-address: " + this.config.ipAddress);
        this.log.info("config port: " + this.config.port);
        this.log.info("config poll time: " + this.config.polltime);

        this.palazzettiRequest = new PalazzettiRequest({
            ipaddress: this.config.ipAddress,
            port: this.config.port
        });

        this.subscribeStates("*");

        this.updateState();

        pollingInterval = setInterval(function() {
            this.updateState();
        }.bind(this), this.config.polltime * 1000 || 60000);

    }

    /**
     * Is called when adapter shuts down - callback has to be called under any circumstances!
     * @param {() => void} callback
     */
    onUnload(callback) {
        try {
            this.log.info("cleaned everything up...");
            clearInterval(pollingInterval);
            callback();
        } catch (e) {
            callback();
        }
    }

    /**
     * Is called if a subscribed state changes
     * @param {string} id
     * @param {ioBroker.State | null | undefined} state
     */
    onStateChange(id, state) {
        try {
            if (state) {
                let instanceName = this.name + "." + this.instance;
                // The state was changed
                //this.log.info(`state ${id} changed: ${state.val} (ack = ${state.ack})`);
                switch (id) {
                    case instanceName + ".control.f3l":
                        if(!state.ack && state.val >= 0 && state.val <= 5) {
                            this.palazzettiRequest.setCommand("FN3L+" + String(state.val)).then(function(result) {
                                this.log.info("set left fan level: " + JSON.stringify(result));
                                this.updateState(true);
                            }.bind(this)).catch(function(err) {
                                this.log.error(err);
                            }.bind(this));
                        }
                        break;
                    case instanceName + ".control.f4l":
                        if(!state.ack && state.val >= 0 && state.val <= 5) {
                            this.palazzettiRequest.setCommand("FN4L+" + String(state.val)).then(function(result) {
                                this.log.info("set right fan level: " + JSON.stringify(result));
                                this.updateState(true);
                            }.bind(this)).catch(function(err) {
                                this.log.error(err);
                            }.bind(this));
                        }
                        break;
                    case instanceName + ".control.f2l":
                        if (!state.ack && state.val >= 0 && state.val <= 7) {
                            this.palazzettiRequest.setCommand("RFAN+" + String(state.val)).then(function(result) {
                                this.log.info("set fan level: " + JSON.stringify(result));
                                this.updateState(true);
                            }.bind(this)).catch(function(err) {
                                this.log.error(err);
                            }.bind(this));
                        }
                        break;
                    case instanceName + ".control.setp":
                        if (!state.ack && state.val >= 0 && state.val <= 40) {
                            this.palazzettiRequest.setCommand("SETP+" + String(state.val)).then(function(result) {
                                this.log.info("set point: " + JSON.stringify(result));
                                this.updateState(true);
                            }.bind(this)).catch(function(err) {
                                this.log.error(err);
                            }.bind(this));
                        }
                        break;
                    case instanceName + ".control.pwr":
                        if (!state.ack && state.val >= 0 && state.val <= 5) {
                            this.palazzettiRequest.setCommand("POWR+" + String(state.val)).then(function(result) {
                                this.log.info("set power: " + JSON.stringify(result));
                                this.updateState(true);
                            }.bind(this)).catch(function(err) {
                                this.log.error(err);
                            }.bind(this));
                        }
                        break;
                    case instanceName + ".control.onoff":
                        if (!state.ack && state.val !== null) {
                            this.palazzettiRequest.powerCommand(state.val === false ? 'OFF' : 'ON').then(function(result) {
                                this.log.info("set on/off: " + JSON.stringify(result));
                                this.updateState(true);
                            }.bind(this)).catch(function(err) {
                                this.log.error(err);
                            }.bind(this));
                        }
                        break;
                    default:
                        break;
                }
            } else {
                // The state was deleted
                this.log.info(`state ${id} deleted`);
            }
        } catch (e) {
            this.log.error(e);
        }

    }
}

Palazzetti.prototype.updateState = function(onlyValues) {
    let aRequests = [];
    aRequests.push(this.palazzettiRequest.getAlls());

    if (!onlyValues) {
        aRequests.push(this.palazzettiRequest.getTimer());
        aRequests.push(this.palazzettiRequest.getLabel());
    }

    Promise.all(aRequests).then(
        function(result) {
            try {
                var setRequests = [];
                if (!!result[0]) {
                    setRequests.concat(setObjectStates.StateInfo(this, result[0]));
                    setRequests.concat(setObjectStates.StateGet(this, result[0]));
                    setRequests.concat(setObjectStates.StateControl(this, result[0]));
                }
                if (!!result[1]) setRequests.concat(setObjectStates.StateTimer(this, result[1]));
                if (!!result[2]) setRequests.concat(setObjectStates.StateLabel(this, result[2]));

                Promise.all(setRequests).catch(function(err) {
                    this.log.error(err);
                }.bind(this));

            } catch (err) {
                this.log.error(err);
            }
        }.bind(this)).catch(
        function(error) {
            this.log.error(error);
        }.bind(this));

}

// @ts-ignore parent is a valid property on module
if (module.parent) {
    // Export the constructor in compact mode
    /**
     * @param {Partial<ioBroker.AdapterOptions>} [options={}]
     */
    module.exports = (options) => new Palazzetti(options);
} else {
    // otherwise start the instance directly
    new Palazzetti();
};