index.js

var Service, Characteristic;
var request = require("request");
var pollingtoevent = require("polling-to-event");


module.exports = function (homebridge) {
    Service = homebridge.hap.Service;
    Characteristic = homebridge.hap.Characteristic;
    homebridge.registerAccessory("homebridge-http", "Http", HttpAccessory);
};


function HttpAccessory(log, config) {
    this.log = log;

    // url info
    this.on_url = config["on_url"];
    this.on_body = config["on_body"];
    this.off_url = config["off_url"];
    this.off_body = config["off_body"];
    this.status_url = config["status_url"];
    this.status_on = config["status_on"];
    this.status_off = config["status_off"];
    this.brightness_url = config["brightness_url"];
    this.brightnesslvl_url = config["brightnesslvl_url"];
    this.http_method = config["http_method"] || "GET";
    this.http_brightness_method = config["http_brightness_method"] || this.http_method;
    this.username = config["username"] || "";
    this.password = config["password"] || "";
    this.sendimmediately = config["sendimmediately"] || "";
    this.service = config["service"] || "Switch";
    this.name = config["name"];
    this.brightnessHandling = config["brightnessHandling"] || "no";
    this.switchHandling = config["switchHandling"] || "no";
    this.statusPollingInterval = config["statusPollingInterval"] || 300;


    //realtime polling info
    this.state = false;
    this.currentlevel = 0;
    this.enableSet = true;
    var that = this;

    // Status Polling, if you want to add additional services that don't use switch handling you can add something like this || (this.service=="Smoke" || this.service=="Motion"))
    if (this.status_url && this.switchHandling === "realtime") {
        var powerurl = this.status_url;
        var statusemitter = pollingtoevent(function (done) {
            that.httpRequest(powerurl, "", "GET", that.username, that.password, that.sendimmediately, function (error, response, body) {
                if (error) {
                    that.log("HTTP get power function failed: %s", error.message);
                    try {
                        done(new Error("Network failure that must not stop homebridge!"));
                    } catch (err) {
                        that.log(err.message);
                    }
                } else {
                    done(null, body);
                }
            })
        }, { longpolling: true, interval: this.statusPollingInterval, longpollEventName: "statuspoll" });

        statusemitter.on("statuspoll", function (responseBody) {
            var binaryState;
            if (that.status_on && that.status_off) {	//Check if custom status checks are set
                var customStatusOn = that.status_on;
                var customStatusOff = that.status_off;
                var statusOn, statusOff;

                // Check to see if custom states are a json object and if so compare to see if either one matches the state response
                if (responseBody.startsWith("{")) {
                    statusOn = this.compareStates(customStatusOn, JSON.parse(responseBody));
                    statusOff = this.compareStates(customStatusOff, JSON.parse(responseBody));
                } else {
                    statusOn = responseBody.includes(customStatusOn);
                    statusOff = responseBody.includes(customStatusOff);
                }
                that.log("Status On Status Poll", statusOn);
                if (statusOn) binaryState = 1;
                // else binaryState = 0;
                if (statusOff) binaryState = 0;
            } else {
                binaryState = parseInt(responseBody.replace(/\D/g, ""));
            }
            that.state = binaryState > 0;
            that.log(that.service, "received power", that.status_url, "state is currently", binaryState);
            // switch used to easily add additonal services
            that.enableSet = false;
            switch (that.service) {
                case "Switch":
                    if (that.switchService) {
                        that.switchService.getCharacteristic(Characteristic.On)
                        .setValue(that.state);
                    }
                    break;
                case "Light":
                    if (that.lightbulbService) {
                        that.lightbulbService.getCharacteristic(Characteristic.On)
                        .setValue(that.state);
                    }
                    break;
            }
            that.enableSet = true;
        });

    }
    // Brightness Polling
    if (this.brightnesslvl_url && this.brightnessHandling === "realtime") {
        var brightnessurl = this.brightnesslvl_url;
        var levelemitter = pollingtoevent(function (done) {
            that.httpRequest(brightnessurl, "", "GET", that.username, that.password, that.sendimmediately, function (error, response, responseBody) {
                if (error) {
                    that.log("HTTP get power function failed: %s", error.message);
                    return;
                } else {
                    done(null, responseBody);
                }
            }) // set longer polling as slider takes longer to set value
        }, { longpolling: true, interval: 300, longpollEventName: "levelpoll" });

        levelemitter.on("levelpoll", function (responseBody) {
            that.currentlevel = parseInt(responseBody);

            that.enableSet = false;
            if (that.lightbulbService) {
                that.log(that.service, "received brightness", that.brightnesslvl_url, "level is currently", that.currentlevel);
                that.lightbulbService.getCharacteristic(Characteristic.Brightness)
                .setValue(that.currentlevel);
            }
            that.enableSet = true;
        });
    }
}

HttpAccessory.prototype = {

    httpRequest: function (url, body, method, username, password, sendimmediately, callback) {
        request({
                url: url,
                body: body,
                method: method,
                rejectUnauthorized: false,
                auth: {
                    user: username,
                    pass: password,
                    sendImmediately: sendimmediately
                }
            },
            function (error, response, body) {
                callback(error, response, body)
            })
    },

    setPowerState: function (powerState, callback) {
        this.log("Power On", powerState);
        this.log("Enable Set", this.enableSet);
        this.log("Current Level", this.currentlevel);
        if (this.enableSet === true) {

            var url;
            var body;

            if (!this.on_url || !this.off_url) {
                this.log.warn("Ignoring request; No power url defined.");
                callback(new Error("No power url defined."));
                return;
            }

            if (powerState) {
                url = this.on_url;
                body = this.on_body;
                this.log("Setting power state to on");
            } else {
                url = this.off_url;
                body = this.off_body;
                this.log("Setting power state to off");
            }

            this.httpRequest(url, body, this.http_method, this.username, this.password, this.sendimmediately, function (error, response, responseBody) {
                if (error) {
                    this.log("HTTP set power function failed: %s", error.message);
                    callback(error);
                } else {
                    this.log("HTTP set power function succeeded!");
                    callback();
                }
            }.bind(this));
        } else {
            callback();
        }
    },

    getPowerState: function (callback) {
        if (!this.status_url) {
            this.log.warn("Ignoring request; No status url defined.");
            callback(new Error("No status url defined."));
            return;
        }

        var url = this.status_url;
        this.log("Getting power state");

        this.httpRequest(url, "", "GET", this.username, this.password, this.sendimmediately, function (error, response, responseBody) {
            if (error) {
                this.log("HTTP get power function failed: %s", error.message);
                callback(error);
            } else {
                var binaryState;
                this.log("Status Config On", this.status_on);
                if (this.status_on && this.status_off) {	//Check if custom status checks are set
                    var customStatusOn = this.status_on;
                    var customStatusOff = this.status_off;
                    var statusOn, statusOff;

                    // Check to see if custom states are a json object and if so compare to see if either one matches the state response
                    if (responseBody.startsWith("{")) {
                        statusOn = this.compareStates(customStatusOn, JSON.parse(responseBody));
                        statusOff = this.compareStates(customStatusOff, JSON.parse(responseBody));
                    } else {
                        statusOn = responseBody.includes(customStatusOn);
                        statusOff = responseBody.includes(customStatusOff);
                    }
                    this.log("Status On Get Power State", statusOn);
                    if (statusOn) binaryState = 1;
                    // else binaryState = 0;
                    if (statusOff) binaryState = 0;
                } else {
                    binaryState = parseInt(responseBody.replace(/\D/g, ""));
                }
                var powerOn = binaryState > 0;
                this.log("Power state is currently %s", binaryState);
                callback(null, powerOn);
            }
        }.bind(this));
    },

    getBrightness: function (callback) {
        if (!this.brightnesslvl_url) {
            this.log.warn("Ignoring request; No brightness level url defined.");
            callback(new Error("No brightness level url defined."));
            return;
        }
        var url = this.brightnesslvl_url;
        this.log("Getting Brightness level");

        this.httpRequest(url, "", "GET", this.username, this.password, this.sendimmediately, function (error, response, responseBody) {
            if (error) {
                this.log("HTTP get brightness function failed: %s", error.message);
                callback(error);
            } else {
                var binaryState = parseInt(responseBody.replace(/\D/g, ""));
                var level = binaryState;
                this.log("brightness state is currently %s", binaryState);
                callback(null, level);
            }
        }.bind(this));
    },

    setBrightness: function (level, callback) {
        if (this.enableSet === true) {
            if (!this.brightness_url) {
                this.log.warn("Ignoring request; No brightness url defined.");
                callback(new Error("No brightness url defined."));
                return;
            }

            var url = this.brightness_url.replace("%b", level);

            this.log("Setting brightness to %s", level);

            this.httpRequest(url, "", this.http_brightness_method, this.username, this.password, this.sendimmediately, function (error, response, body) {
                if (error) {
                    this.log("HTTP brightness function failed: %s", error);
                    callback(error);
                } else {
                    this.log("HTTP brightness function succeeded!");
                    callback();
                }
            }.bind(this));
        } else {
            callback();
        }
    },

    identify: function (callback) {
        this.log("Identify requested!");
        callback(); // success
    },

    getServices: function () {

        var that = this;

        // you can OPTIONALLY create an information service if you wish to override
        // the default values for things like serial number, model, etc.
        var informationService = new Service.AccessoryInformation();

        informationService
        .setCharacteristic(Characteristic.Manufacturer, "HTTP Manufacturer")
        .setCharacteristic(Characteristic.Model, "HTTP Model")
        .setCharacteristic(Characteristic.SerialNumber, "HTTP Serial Number");

        switch (this.service) {
            case "Switch":
                this.switchService = new Service.Switch(this.name);
                switch (this.switchHandling) {
                    //Power Polling
                    case "yes":
                        this.switchService
                        .getCharacteristic(Characteristic.On)
                        .on("get", this.getPowerState.bind(this))
                        .on("set", this.setPowerState.bind(this));
                        break;
                    case "realtime":
                        this.switchService
                        .getCharacteristic(Characteristic.On)
                        .on("get", function (callback) {
                            callback(null, that.state)
                        })
                        .on("set", this.setPowerState.bind(this));
                        break;
                    default    :
                        this.switchService
                        .getCharacteristic(Characteristic.On)
                        .on("set", this.setPowerState.bind(this));
                        break;
                }
                return [this.switchService];
            case "Light":
                this.lightbulbService = new Service.Lightbulb(this.name);
                switch (this.switchHandling) {
                    //Power Polling
                    case "yes" :
                        this.lightbulbService
                        .getCharacteristic(Characteristic.On)
                        .on("get", this.getPowerState.bind(this))
                        .on("set", this.setPowerState.bind(this));
                        break;
                    case "realtime":
                        this.lightbulbService
                        .getCharacteristic(Characteristic.On)
                        .on("get", function (callback) {
                            callback(null, that.state)
                        })
                        .on("set", this.setPowerState.bind(this));
                        break;
                    default:
                        this.lightbulbService
                        .getCharacteristic(Characteristic.On)
                        .on("set", this.setPowerState.bind(this));
                        break;
                }
                // Brightness Polling
                if (this.brightnessHandling === "realtime") {
                    this.lightbulbService
                    .addCharacteristic(new Characteristic.Brightness())
                    .on("get", function (callback) {
                        callback(null, that.currentlevel)
                    })
                    .on("set", this.setBrightness.bind(this));
                } else if (this.brightnessHandling === "yes") {
                    this.lightbulbService
                    .addCharacteristic(new Characteristic.Brightness())
                    .on("get", this.getBrightness.bind(this))
                    .on("set", this.setBrightness.bind(this));
                }

                return [informationService, this.lightbulbService];
                break;
        }
    },
    compareStates: function (customStatus, stateData) {
        var objectsEqual = true;
        for (var param in customStatus) {
            if (!stateData.hasOwnProperty(param) || customStatus[param] !== stateData[param]) {
                objectsEqual = false;
                break;
            }
        }
        // that.log("Equal", objectsEqual);
        return objectsEqual;
    }

};