log-to-graphite.smartapp.groovy

/**
 *  Log to Graphite
 *
 *  Copyright 2014 Brian Keifer
 *
 *  Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
 *  in compliance with the License. You may obtain a copy of the License at:
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software distributed under the License is distributed
 *  on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License
 *  for the specific language governing permissions and limitations under the License.
 *
 */
definition(
    name: "Log to Graphite",
    namespace: "bkeifer",
    author: "Brian Keifer",
    description: "Log various things to a Graphite instance",
    category: "Convenience",
    iconUrl: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience.png",
    iconX2Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png",
    iconX3Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png")


preferences {

	section("Log devices...") {
        input "temperatures", "capability.temperatureMeasurement", title: "Temperatures", required:false, multiple: true
        input "humidities", "capability.relativeHumidityMeasurement", title: "Humidities", required:false, multiple: true
        input "contacts", "capability.contactSensor", title: "Contacts", required: false, multiple: true
        input "illuminances", "capability.illuminanceMeasurement", title: "Illuminances", required: false, multiple: true
        input "motions", "capability.motionSensor", title: "Motions", required: false, multiple: true
        input "switches", "capability.switch", title: "Switches", required: false, multiple: true
        input "batteries", "capability.battery", title: "Batteries", required:false, multiple: true
        input "thermostats", "capability.thermostat", title: "Thermostat Setpoints", required: false, multiple: true
        input "energymeters", "capability.energyMeter", title: "Energy Meters", required: false, multiple: true
    }
    section ("Graphite Server") {
    	input "graphite_host", "text", title: "Graphite Hostname/IP"
        input "graphite_port", "number", title: "Graphite Port"
    }
}

def installed() {
	log.debug "Installed with settings: ${settings}"
	initialize()
}

def updated() {
	log.debug "Updated with settings: ${settings}"
	unsubscribe()
	initialize()
}

def initialize() {

	state.clear()
    unschedule(checkSensors)
    schedule("0 * * * * ?", "checkSensors")
    subscribe(app, appTouch)
}


def appTouch(evt) {
	log.debug "Manually triggered: $evt"
    checkSensors()

}


def checkSensors() {

    def logitems = []

    for (t in settings.temperatures) {
        logitems.add([t.displayName, "temperature", Double.parseDouble(t.latestValue("temperature").toString())] )
        state[t.displayName + ".temp"] = t.latestValue("temperature")
        log.debug("[temp]     " + t.displayName + ": " + t.latestValue("temperature"))
    }
    for (t in settings.humidities) {
        logitems.add([t.displayName, "humidity", Double.parseDouble(t.latestValue("humidity").toString())] )
        state[t.displayName + ".humidity"] = t.latestValue("humidity")
		log.debug("[humidity] " + t.displayName + ": " + t.latestValue("humidity"))
	}
    for (t in settings.batteries) {
        logitems.add([t.displayName, "battery", Double.parseDouble(t.latestValue("battery").toString())] )
        state[t.displayName + ".battery"] = t.latestValue("battery")
		log.debug("[battery]  " + t.displayName + ": " + t.latestValue("battery"))
	}

    for (t in settings.contacts) {
        logitems.add([t.displayName, "contact", t.latestValue("contact")] )
        state[t.displayName + ".contact"] = t.latestValue("contact")
    }

    for (t in settings.motions) {
        logitems.add([t.displayName, "motion", t.latestValue("motion")] )
        state[t.displayName + ".motion"] = t.latestValue("motion")
    }

    for (t in settings.illuminances) {
        def x = new BigDecimal(t.latestValue("illuminance") ) // instanceof Double)
        logitems.add([t.displayName, "illuminance", x] )
        state[t.displayName + ".illuminance"] = x
		log.debug("[luminance] " + t.displayName + ": " + t.latestValue("illuminance"))
	}

    for (t in settings.switches) {
        logitems.add([t.displayName, "switch", (t.latestValue("switch") == "on" ? 1 : 0)] )
        state[t.displayName + ".switch"] = (t.latestValue("switch") == "on" ? 1 : 0)
        log.debug("[switch] " + t.displayName + ": " + (t.latestValue("switch") == "on" ? 1 : 0))
    }

    for (t in settings.thermostats) {
        logitems.add([t.displayName, "thermostat", t.latestValue("setPoint")] )
        state[t.displayName + ".setPoint"] = t.latestValue("setPoint")
        log.debug("[thermostat] " + t.displayName + ": " + t.latestValue("setPoint"))
    }

    for (t in settings.energymeters) {
        logitems.add([t.displayName + ".power", "energy", t.latestValue("power")])
        state[t.displayName + ".Watts"] = t.latestValue("power")
        log.debug("[energy] " + t.displayName + ": " + t.latestValue("power"))

        logitems.add([t.displayName + ".amps", "energy", t.latestValue("amps")])
        state[t.displayName + ".Amps"] = t.latestValue("amps")
        log.debug("[energy] " + t.displayName + ": " + t.latestValue("amps"))

		logitems.add([t.displayName + ".volts", "energy", t.latestValue("volts")])
        state[t.displayName + ".Volts"] = t.latestValue("volts")
        log.debug("[energy] " + t.displayName + ": " + t.latestValue("volts"))
    }

	logField2(logitems)

}


private logField2(logItems) {
    def fieldvalues = ""
    def timeNow = now()
    timeNow = (timeNow/1000).toInteger()

    logItems.eachWithIndex() { item, i ->
		def path = item[0].replace(" ","")
		def value = item[2]

		def json = "{\"metric\":\"${path}\",\"value\":\"${value}\",\"measure_time\":\"${timeNow}\"}"
		log.debug json

		def params = [
        	uri: "http://${graphite_host}:${graphite_port}/publish/${item[1]}",
            body: json
        ]
        try {
        	httpPostJson(params)// {response -> parseHttpResponse(response)}
            log.debug "Success!"
        }
		catch ( groovyx.net.http.HttpResponseException ex ) {
        	log.debug "Unexpected response error: ${ex.statusCode}"
        }
	}
}