Some more info, here are some screenshots where you can see what’s going on, plus below is the code for my DTH. I’m pretty stumped now.
Nick
import groovy.json.JsonSlurper
metadata {
definition (name: "WiFi Fridge Monitor", namespace: "nickb512", author: "nickb512") {
capability "Refresh"
capability "Sensor"
capability "Polling"
capability "temperatureMeasurement"
capability "contactSensor"
}
preferences {
input "ip", "string", title: "IP Address", required: true
input "port", "number", title: "Port", required: true
}
tiles (scale: 2) {
valueTile("temperature", "device.temperature", width: 6, height: 4) {
state "temperature", label: '${currentValue}', unit:"dC",
backgroundColors:[
[value: 0, color: "#153591"],
[value: 7, color: "#1e9cbb"],
[value: 15, color: "#90d2a7"],
[value: 23, color: "#44b621"],
[value: 28, color: "#f1d801"],
[value: 35, color: "#d04e00"],
[value: 37, color: "#bc2323"]
]
}
standardTile("contact", "device.contact", width: 2, height: 2, decoration: "flat") {
state "closed", label: "", icon: "st.contact.contact.closed"
state "open", label: "", icon: "st.contact.contact.open"
}
standardTile("main", "device.temperature", decoration: "flat", width: 2, height: 2) {
state "temperature", label: '${currentValue}°C', icon: "st.alarm.temperature.normal"
}
standardTile("refresh", "device.refresh", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
state("default", label:'refresh', action:"polling.poll", icon:"st.secondary.refresh-icon")
}
main "main"
details (["temperature", "contact", "refresh"])
}
}
def installed() {
log.debug "installed()"
configure()
}
def configure() {
log.debug "configure()"
def iphex = convertIPtoHex(ip)
def porthex = convertPortToHex(port)
device.deviceNetworkId = "$iphex:$porthex"
log.debug "DNI set to $iphex:$porthex"
runEvery1Minute(refresh)
sendEvent(name: "temperature", value: 0)
sendEvent(name: "contact", value: "closed")
}
def updated() {
log.debug "updated()"
configure();
}
def parse(description) {
log.debug "Parsing: ${description}"
def descMap = parseDescriptionAsMap(description)
def body
//log.debug "descMap: ${descMap}"
if (descMap["body"]) body = new String(descMap["body"].decodeBase64())
if (body && body != "") {
if(body.startsWith("{") || body.startsWith("[")) {
def slurper = new JsonSlurper()
def result = slurper.parseText(body)
log.debug "result: ${result}"
if (result.contact == 1) {
sendEvent(name: "contact", value: "open")
} else {
sendEvent(name: "contact", value: "closed")
}
sendEvent(name: "temperature", value: result.temp)
} else {
log.debug "Response is not JSON: $body"
}
}
}
def parseDescriptionAsMap(description) {
description.split(",").inject([:]) { map, param ->
def nameAndValue = param.split(":")
if (nameAndValue.length == 2) map += [(nameAndValue[0].trim()):nameAndValue[1].trim()]
else map += [(nameAndValue[0].trim()):""]
}
}
def refresh() {
log.debug "refresh()"
def hubAction = new physicalgraph.device.HubAction(
method: "GET",
path: "/",
headers: [
host: getHostAddress()
]
)
sendHubCommand(hubAction)
return hubAction
}
def poll() {
log.debug "poll()"
refresh()
}
def ping() {
log.debug "ping()"
refresh()
}
private getHostAddress() {
def ip = getDataValue("ip")
def port = getDataValue("port")
def parts = device.deviceNetworkId.split(":")
log.debug "DNI: ${device.deviceNetworkId}"
if (parts.length == 2) {
ip = convertHexToIP(parts[0])
port = convertHexToInt(parts[1])
} else {
log.warn "Can't figure out ip and port for device: ${device.id}"
}
log.debug "Using IP: $ip and port: $port for device: ${device.id}"
return ip + ":" + port
}
private Integer convertHexToInt(hex) {
return Integer.parseInt(hex,16)
}
private String convertHexToIP(hex) {
return [convertHexToInt(hex[0..1]),convertHexToInt(hex[2..3]),convertHexToInt(hex[4..5]),convertHexToInt(hex[6..7])].join(".")
}
private String convertIPtoHex(ipAddress) {
try {
String hex = ipAddress.tokenize( '.' ).collect { String.format('%02x', it.toInteger() ) }.join() // thanks to @pstuart
return hex
} catch (Exception e) {
log.error "Invalid IP Address $ipAddress, check your settings! Error: $e"
}
}
private String convertPortToHex(port) {
try {
String hexport = port.toString().format('%04x', port.toInteger() ) // thanks to @pstuart
return hexport
} catch (Exception e) {
log.error "Invalid port $port, check your settings! Error: $e"
}
}
