mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-16 05:10:50 +00:00
Compare commits
41 Commits
PROD_2016.
...
PROD_2016.
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9f5eb7b85a | ||
|
|
64e4ccc517 | ||
|
|
aa890ae3d5 | ||
|
|
8d701b9fea | ||
|
|
719b24ecd6 | ||
|
|
9d5ab3bfc8 | ||
|
|
aae7f23a22 | ||
|
|
218cc43520 | ||
|
|
5b0ca4b815 | ||
|
|
9ddc020f04 | ||
|
|
aab3b8d7f8 | ||
|
|
a0ccf35eaa | ||
|
|
9fbbaec8f6 | ||
|
|
e4c1824afd | ||
|
|
797a58cb68 | ||
|
|
c428267d63 | ||
|
|
02f30cf425 | ||
|
|
fea802ffce | ||
|
|
6400d26f4a | ||
|
|
5e3aaa3270 | ||
|
|
f5c3997679 | ||
|
|
81cf1179ef | ||
|
|
79d20b0edb | ||
|
|
b6d862fdd4 | ||
|
|
d58084c438 | ||
|
|
dbfaef3e69 | ||
|
|
40ed88e7fd | ||
|
|
1d6e22dc16 | ||
|
|
30993aa218 | ||
|
|
2f8ed277ff | ||
|
|
1d180ac487 | ||
|
|
230541a145 | ||
|
|
8c4f7edc83 | ||
|
|
4f188581df | ||
|
|
71880e2644 | ||
|
|
0b7bb40474 | ||
|
|
8d920ea072 | ||
|
|
ced03d746d | ||
|
|
5341d0d06f | ||
|
|
a6c7ab49b6 | ||
|
|
4ad0a6fd9d |
@@ -87,16 +87,27 @@ def beep() {
|
|||||||
up to this long from the time you send the message to the time you hear a sound.
|
up to this long from the time you send the message to the time you hear a sound.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
// Used source endpoint of 0x02 because we are using smartthings manufacturer specific cluster.
|
||||||
[
|
[
|
||||||
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
||||||
|
"delay 200",
|
||||||
|
"send 0x$zigbee.deviceNetworkId 0x02 0x$zigbee.endpointId",
|
||||||
"delay 7000",
|
"delay 7000",
|
||||||
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
||||||
|
"delay 200",
|
||||||
|
"send 0x$zigbee.deviceNetworkId 0x02 0x$zigbee.endpointId",
|
||||||
"delay 7000",
|
"delay 7000",
|
||||||
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
||||||
|
"delay 200",
|
||||||
|
"send 0x$zigbee.deviceNetworkId 0x02 0x$zigbee.endpointId",
|
||||||
"delay 7000",
|
"delay 7000",
|
||||||
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
||||||
|
"delay 200",
|
||||||
|
"send 0x$zigbee.deviceNetworkId 0x02 0x$zigbee.endpointId",
|
||||||
"delay 7000",
|
"delay 7000",
|
||||||
"raw 0xFC05 {15 0A 11 00 00 15 01}"
|
"raw 0xFC05 {15 0A 11 00 00 15 01}",
|
||||||
|
"delay 200",
|
||||||
|
"send 0x$zigbee.deviceNetworkId 0x02 0x$zigbee.endpointId",
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -105,11 +105,21 @@ def parseDescriptionAsMap(description) {
|
|||||||
|
|
||||||
// Commands to device
|
// Commands to device
|
||||||
def on() {
|
def on() {
|
||||||
'zcl on-off on'
|
[
|
||||||
|
'zcl on-off on',
|
||||||
|
'delay 200',
|
||||||
|
"send 0x${zigbee.deviceNetworkId} 0x01 0x${zigbee.endpointId}",
|
||||||
|
'delay 500'
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
def off() {
|
def off() {
|
||||||
'zcl on-off off'
|
[
|
||||||
|
'zcl on-off off',
|
||||||
|
'delay 200',
|
||||||
|
"send 0x${zigbee.deviceNetworkId} 0x01 0x${zigbee.endpointId}",
|
||||||
|
'delay 500'
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
def setLevel(value) {
|
def setLevel(value) {
|
||||||
|
|||||||
@@ -23,10 +23,8 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C6 Connected Cree LED Bulb with maxReportTime of 10 min.
|
A Category C6 Connected Cree LED Bulb with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval = 12 mins
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
|
||||||
Check-in interval = 2*10 = 20 min
|
|
||||||
|
|
||||||
## Troubleshooting
|
## Troubleshooting
|
||||||
|
|
||||||
|
|||||||
@@ -31,13 +31,13 @@ metadata {
|
|||||||
command "switchMode"
|
command "switchMode"
|
||||||
command "switchFanMode"
|
command "switchFanMode"
|
||||||
|
|
||||||
attribute "thermostatSetpoint","number"
|
attribute "thermostatSetpoint", "number"
|
||||||
attribute "thermostatStatus","string"
|
attribute "thermostatStatus", "string"
|
||||||
attribute "maxHeatingSetpoint", "number"
|
attribute "maxHeatingSetpoint", "number"
|
||||||
attribute "minHeatingSetpoint", "number"
|
attribute "minHeatingSetpoint", "number"
|
||||||
attribute "maxCoolingSetpoint", "number"
|
attribute "maxCoolingSetpoint", "number"
|
||||||
attribute "minCoolingSetpoint", "number"
|
attribute "minCoolingSetpoint", "number"
|
||||||
attribute "deviceTemperatureUnit", "number"
|
attribute "deviceTemperatureUnit", "string"
|
||||||
}
|
}
|
||||||
|
|
||||||
tiles {
|
tiles {
|
||||||
|
|||||||
@@ -7,9 +7,11 @@
|
|||||||
metadata {
|
metadata {
|
||||||
// Automatically generated. Make future change here.
|
// Automatically generated. Make future change here.
|
||||||
definition (name: "Hue Bridge", namespace: "smartthings", author: "SmartThings") {
|
definition (name: "Hue Bridge", namespace: "smartthings", author: "SmartThings") {
|
||||||
|
capability "Health Check"
|
||||||
|
|
||||||
attribute "networkAddress", "string"
|
attribute "networkAddress", "string"
|
||||||
// Used to indicate if bridge is reachable or not, i.e. is the bridge connected to the network
|
// Used to indicate if bridge is reachable or not, i.e. is the bridge connected to the network
|
||||||
// Possible values "Online" or "Offline"
|
// Possible values "Online" or "Offline"
|
||||||
attribute "status", "string"
|
attribute "status", "string"
|
||||||
// Id is the number on the back of the hub, Hue uses last six digits of Mac address
|
// Id is the number on the back of the hub, Hue uses last six digits of Mac address
|
||||||
// This is also used in the Hue application as ID
|
// This is also used in the Hue application as ID
|
||||||
@@ -42,6 +44,10 @@ metadata {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void installed() {
|
||||||
|
sendEvent(name: "checkInterval", value: 60 * 12, data: [protocol: "lan"], displayed: false)
|
||||||
|
}
|
||||||
|
|
||||||
// parse events into attributes
|
// parse events into attributes
|
||||||
def parse(description) {
|
def parse(description) {
|
||||||
log.debug "Parsing '${description}'"
|
log.debug "Parsing '${description}'"
|
||||||
@@ -70,13 +76,8 @@ def parse(description) {
|
|||||||
def bulbs = new groovy.json.JsonSlurper().parseText(msg.body)
|
def bulbs = new groovy.json.JsonSlurper().parseText(msg.body)
|
||||||
if (bulbs.state) {
|
if (bulbs.state) {
|
||||||
log.info "Bridge response: $msg.body"
|
log.info "Bridge response: $msg.body"
|
||||||
} else {
|
|
||||||
// Sending Bulbs List to parent"
|
|
||||||
if (parent.isInBulbDiscovery())
|
|
||||||
log.info parent.bulbListHandler(device.hub.id, msg.body)
|
|
||||||
}
|
}
|
||||||
}
|
} else if (contentType?.contains("xml")) {
|
||||||
else if (contentType?.contains("xml")) {
|
|
||||||
log.debug "HUE BRIDGE ALREADY PRESENT"
|
log.debug "HUE BRIDGE ALREADY PRESENT"
|
||||||
parent.hubVerification(device.hub.id, msg.body)
|
parent.hubVerification(device.hub.id, msg.body)
|
||||||
}
|
}
|
||||||
@@ -85,3 +86,7 @@ def parse(description) {
|
|||||||
}
|
}
|
||||||
results
|
results
|
||||||
}
|
}
|
||||||
|
|
||||||
|
def ping() {
|
||||||
|
log.debug "${parent.ping(this)}"
|
||||||
|
}
|
||||||
|
|||||||
@@ -174,7 +174,7 @@ void setColorTemperature(value) {
|
|||||||
|
|
||||||
void refresh() {
|
void refresh() {
|
||||||
log.debug "Executing 'refresh'"
|
log.debug "Executing 'refresh'"
|
||||||
parent.manualRefresh()
|
parent?.manualRefresh()
|
||||||
}
|
}
|
||||||
|
|
||||||
def verifyPercent(percent) {
|
def verifyPercent(percent) {
|
||||||
|
|||||||
@@ -47,9 +47,21 @@ def parse(String description) {
|
|||||||
|
|
||||||
// Commands to device
|
// Commands to device
|
||||||
def on() {
|
def on() {
|
||||||
'zcl on-off on'
|
[
|
||||||
|
'zcl on-off on',
|
||||||
|
'delay 200',
|
||||||
|
"send 0x${zigbee.deviceNetworkId} 0x01 0x${zigbee.endpointId}",
|
||||||
|
'delay 500'
|
||||||
|
|
||||||
|
]
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
def off() {
|
def off() {
|
||||||
'zcl on-off off'
|
[
|
||||||
|
'zcl on-off off',
|
||||||
|
'delay 200',
|
||||||
|
"send 0x${zigbee.deviceNetworkId} 0x01 0x${zigbee.endpointId}",
|
||||||
|
'delay 500'
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -23,10 +23,10 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C1 smart power outlet with maxReportTime of 10 min.
|
A Category C1 smart power outlet with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval is double the value of maxReportTime.
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
Check-in interval = 2*10 = 20 min
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
## Troubleshooting
|
## Troubleshooting
|
||||||
|
|
||||||
|
|||||||
@@ -23,10 +23,10 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C2 moisture sensor with maxReportTime of 1 hr.
|
A Category C2 moisture sensor with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval is double the value of maxReportTime.
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
Check-in interval = 2*60 = 120 min
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
## Battery Specification
|
## Battery Specification
|
||||||
|
|
||||||
|
|||||||
@@ -180,9 +180,9 @@ private Map parseIasMessage(String description) {
|
|||||||
def getTemperature(value) {
|
def getTemperature(value) {
|
||||||
def celsius = Integer.parseInt(value, 16).shortValue() / 100
|
def celsius = Integer.parseInt(value, 16).shortValue() / 100
|
||||||
if(getTemperatureScale() == "C"){
|
if(getTemperatureScale() == "C"){
|
||||||
return celsius
|
return Math.round(celsius)
|
||||||
} else {
|
} else {
|
||||||
return celsiusToFahrenheit(celsius) as Integer
|
return Math.round(celsiusToFahrenheit(celsius))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -22,10 +22,10 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C2 motion sensor with maxReportTime of 1 hr.
|
A Category C2 motion sensor with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval is double the value of maxReportTime.
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
Check-in interval = 2*60 = 120 min
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
## Battery Specification
|
## Battery Specification
|
||||||
|
|
||||||
|
|||||||
@@ -194,9 +194,9 @@ private Map parseIasMessage(String description) {
|
|||||||
def getTemperature(value) {
|
def getTemperature(value) {
|
||||||
def celsius = Integer.parseInt(value, 16).shortValue() / 100
|
def celsius = Integer.parseInt(value, 16).shortValue() / 100
|
||||||
if(getTemperatureScale() == "C"){
|
if(getTemperatureScale() == "C"){
|
||||||
return celsius
|
return Math.round(celsius)
|
||||||
} else {
|
} else {
|
||||||
return celsiusToFahrenheit(celsius) as Integer
|
return Math.round(celsiusToFahrenheit(celsius))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -26,10 +26,10 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C2 multi sensor with maxReportTime of 1 hr.
|
A Category C2 multi sensor with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval is double the value of maxReportTime.
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
Check-in interval = 2*60 = 120 min
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
## Battery Specification
|
## Battery Specification
|
||||||
|
|
||||||
|
|||||||
@@ -261,9 +261,9 @@ def updated() {
|
|||||||
def getTemperature(value) {
|
def getTemperature(value) {
|
||||||
def celsius = Integer.parseInt(value, 16).shortValue() / 100
|
def celsius = Integer.parseInt(value, 16).shortValue() / 100
|
||||||
if(getTemperatureScale() == "C"){
|
if(getTemperatureScale() == "C"){
|
||||||
return celsius
|
return Math.round(celsius)
|
||||||
} else {
|
} else {
|
||||||
return celsiusToFahrenheit(celsius) as Integer
|
return Math.round(celsiusToFahrenheit(celsius))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -24,10 +24,10 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C2 open/closed sensor with maxReportTime of 1 hr.
|
A Category C2 open/closed sensor with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval is double the value of maxReportTime.
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
Check-in interval = 2*60 = 120 min
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
## Battery Specification
|
## Battery Specification
|
||||||
|
|
||||||
|
|||||||
@@ -24,10 +24,10 @@ Works with:
|
|||||||
|
|
||||||
## Device Health
|
## Device Health
|
||||||
|
|
||||||
A Category C2 SmartSense Temp/Humidity Sensor with maxReportTime of 1 hr.
|
A Category C2 SmartSense Temp/Humidity Sensor with maxReportTime of 5 mins.
|
||||||
Check-in interval is double the value of maxReportTime for Zigbee device.
|
Check-in interval is double the value of maxReportTime.
|
||||||
This gives the device twice the amount of time to respond before it is marked as offline.
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
Check-in interval = 2*60 = 120 min
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
## Battery Specification
|
## Battery Specification
|
||||||
|
|
||||||
|
|||||||
2
devicetypes/smartthings/zigbee-dimmer.src/.st-ignore
Normal file
2
devicetypes/smartthings/zigbee-dimmer.src/.st-ignore
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
.st-ignore
|
||||||
|
README.md
|
||||||
36
devicetypes/smartthings/zigbee-dimmer.src/README.md
Normal file
36
devicetypes/smartthings/zigbee-dimmer.src/README.md
Normal file
@@ -0,0 +1,36 @@
|
|||||||
|
# OSRAM Lightify LED On/Off/Dim
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Works with:
|
||||||
|
|
||||||
|
* [OSRAM Lightify LED On/Off/Dim](https://shop.smartthings.com/#!/products/osram-led-smart-bulb-on-off-dim)
|
||||||
|
|
||||||
|
## Table of contents
|
||||||
|
|
||||||
|
* [Capabilities](#capabilities)
|
||||||
|
* [Health](#device-health)
|
||||||
|
* [Battery](#battery-specification)
|
||||||
|
|
||||||
|
## Capabilities
|
||||||
|
|
||||||
|
* **Actuator** - represents that a Device has commands
|
||||||
|
* **Configuration** - _configure()_ command called when device is installed or device preferences updated
|
||||||
|
* **Refresh** - _refresh()_ command for status updates
|
||||||
|
* **Switch** - can detect state (possible values: on/off)
|
||||||
|
* **Switch Level** - represents current light level, usually 0-100 in percent
|
||||||
|
* **Health Check** - indicates ability to get device health notifications
|
||||||
|
|
||||||
|
## Device Health
|
||||||
|
|
||||||
|
A Category C1 Zigbee dimmer with maxReportTime of 5 mins.
|
||||||
|
Check-in interval is double the value of maxReportTime.
|
||||||
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
|
## Troubleshooting
|
||||||
|
|
||||||
|
If the device doesn't pair when trying from the SmartThings mobile app, it is possible that the device is out of range.
|
||||||
|
Pairing needs to be tried again by placing the device closer to the hub.
|
||||||
|
Other troubleshooting tips are listed as follows:
|
||||||
|
* [Troubleshooting:](https://support.smartthings.com/hc/en-us/articles/207191763-OSRAM-LIGHTIFY-LED-Smart-Connected-Light-A19-On-Off-Dim)
|
||||||
@@ -13,7 +13,7 @@
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
metadata {
|
metadata {
|
||||||
definition (name: "ZigBee Dimmer", namespace: "smartthings", author: "SmartThings") {
|
definition (name: "ZigBee Dimmer", namespace: "smartthings", author: "SmartThings", category: "C1") {
|
||||||
capability "Actuator"
|
capability "Actuator"
|
||||||
capability "Configuration"
|
capability "Configuration"
|
||||||
capability "Refresh"
|
capability "Refresh"
|
||||||
|
|||||||
@@ -31,7 +31,8 @@
|
|||||||
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRD210 PB DB", deviceJoinName: "Yale Push Button Deadbolt Lock"
|
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRD210 PB DB", deviceJoinName: "Yale Push Button Deadbolt Lock"
|
||||||
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRD220/240 TSDB", deviceJoinName: "Yale Touch Screen Deadbolt Lock"
|
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRD220/240 TSDB", deviceJoinName: "Yale Touch Screen Deadbolt Lock"
|
||||||
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRL210 PB LL", deviceJoinName: "Yale Push Button Lever Lock"
|
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRL210 PB LL", deviceJoinName: "Yale Push Button Lever Lock"
|
||||||
}
|
fingerprint profileId: "0104", inClusters: "0000,0001,0003,0009,000A,0101,0020", outClusters: "000A,0019", manufacturer: "Yale", model: "YRD226/246 TSDB", deviceJoinName: "Yale Touch Screen Deadbolt Lock"
|
||||||
|
}
|
||||||
|
|
||||||
tiles(scale: 2) {
|
tiles(scale: 2) {
|
||||||
multiAttributeTile(name:"toggle", type:"generic", width:6, height:4){
|
multiAttributeTile(name:"toggle", type:"generic", width:6, height:4){
|
||||||
|
|||||||
2
devicetypes/smartthings/zigbee-rgbw-bulb.src/.st-ignore
Normal file
2
devicetypes/smartthings/zigbee-rgbw-bulb.src/.st-ignore
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
.st-ignore
|
||||||
|
README.md
|
||||||
42
devicetypes/smartthings/zigbee-rgbw-bulb.src/README.md
Normal file
42
devicetypes/smartthings/zigbee-rgbw-bulb.src/README.md
Normal file
@@ -0,0 +1,42 @@
|
|||||||
|
# OSRAM LIGHTIFY LED RGBW Bulb
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Works with:
|
||||||
|
|
||||||
|
* [OSRAM LIGHTIFY LED RGBW Bulb](https://support.smartthings.com/hc/en-us/articles/207728173-OSRAM-LIGHTIFY-LED-Smart-Connected-Light-A19-RGBW)
|
||||||
|
|
||||||
|
## Table of contents
|
||||||
|
|
||||||
|
* [Capabilities](#capabilities)
|
||||||
|
* [Health](#device-health)
|
||||||
|
* [Battery](#battery-specification)
|
||||||
|
|
||||||
|
## Capabilities
|
||||||
|
|
||||||
|
* **Actuator** - It represents that a device has commands.
|
||||||
|
* **Color Control** - It represents that the color attributes of a device can be controlled (hue, saturation, color value).
|
||||||
|
* **Color Temperature** - It represents color temperature capability measured in degree Kelvin.
|
||||||
|
* **Polling** - It represents that a device can be polled.
|
||||||
|
* **Switch** - can detect state (possible values: on/off)
|
||||||
|
* **Switch Level** - can detect current light level (0-100 in percent)
|
||||||
|
* **Configuration** - _configure()_ command called when device is installed or device preferences updated
|
||||||
|
* **Refresh** - _refresh()_ command for status updates
|
||||||
|
* **Health Check** - indicates ability to get device health notifications
|
||||||
|
|
||||||
|
|
||||||
|
## Device Health
|
||||||
|
|
||||||
|
A Category C6 OSRAM LIGHTIFY LED RGBW Bulb with maxReportTime of 5 mins.
|
||||||
|
Check-in interval is double the value of maxReportTime.
|
||||||
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
|
|
||||||
|
## Troubleshooting
|
||||||
|
|
||||||
|
If the device doesn't pair when trying from the SmartThings mobile app, it is possible that the device is out of range.
|
||||||
|
Pairing needs to be tried again by placing the device closer to the hub.
|
||||||
|
It may also happen that you need to reset the device.
|
||||||
|
Instructions related to pairing, resetting and removing the device from SmartThings can be found in the following link:
|
||||||
|
* [Troubleshooting Tips](https://support.smartthings.com/hc/en-us/articles/207728173-OSRAM-LIGHTIFY-LED-Smart-Connected-Light-A19-RGBW)
|
||||||
@@ -17,7 +17,7 @@
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
metadata {
|
metadata {
|
||||||
definition (name: "ZigBee RGBW Bulb", namespace: "smartthings", author: "SmartThings") {
|
definition (name: "ZigBee RGBW Bulb", namespace: "smartthings", author: "SmartThings", category: "C6") {
|
||||||
|
|
||||||
capability "Actuator"
|
capability "Actuator"
|
||||||
capability "Color Control"
|
capability "Color Control"
|
||||||
|
|||||||
@@ -0,0 +1,2 @@
|
|||||||
|
.st-ignore
|
||||||
|
README.md
|
||||||
@@ -0,0 +1,37 @@
|
|||||||
|
# OSRAM Lightify Tunable 60 White
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Works with:
|
||||||
|
|
||||||
|
* [OSRAM Lightify Tunable 60 White](http://www.osram.com/osram_com/tools-and-services/tools/lightify---smart-connected-light/lightify-for-home---what-is-light-to-you/lightify-products/lightify-classic-a60-tunable-white/index.jsp)
|
||||||
|
|
||||||
|
## Table of contents
|
||||||
|
|
||||||
|
* [Capabilities](#capabilities)
|
||||||
|
* [Health](#device-health)
|
||||||
|
* [Battery](#battery-specification)
|
||||||
|
|
||||||
|
## Capabilities
|
||||||
|
|
||||||
|
* **Actuator** - represents that a Device has commands
|
||||||
|
* **Color Temperature** - represents color temperature, measured in degrees Kelvin.
|
||||||
|
* **Configuration** - _configure()_ command called when device is installed or device preferences updated.
|
||||||
|
* **Refresh** - _refresh()_ command for status updates
|
||||||
|
* **Switch** - can detect state (possible values: on/off)
|
||||||
|
* **Switch Level** - represents current light level, usually 0-100 in percent
|
||||||
|
* **Health Check** - indicates ability to get device health notifications
|
||||||
|
|
||||||
|
## Device Health
|
||||||
|
|
||||||
|
A Category C1 OSRAM Lightify Tunable 60 White with maxReportTime of 5 mins.
|
||||||
|
Check-in interval is double the value of maxReportTime.
|
||||||
|
This gives the device twice the amount of time to respond before it is marked as offline.
|
||||||
|
Check-in interval = 12 mins
|
||||||
|
|
||||||
|
## Troubleshooting
|
||||||
|
|
||||||
|
If the device doesn't pair when trying from the SmartThings mobile app, it is possible that the device is out of range.
|
||||||
|
Pairing needs to be tried again by placing the device closer to the hub.
|
||||||
|
Other troubleshooting tips are listed as follows:
|
||||||
|
* [Troubleshooting:](https://support.smartthings.com/hc/en-us/articles/204576454-OSRAM-LIGHTIFY-Tunable-White-60-Bulb)
|
||||||
@@ -17,7 +17,7 @@
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
metadata {
|
metadata {
|
||||||
definition (name: "ZigBee White Color Temperature Bulb", namespace: "smartthings", author: "SmartThings") {
|
definition (name: "ZigBee White Color Temperature Bulb", namespace: "smartthings", author: "SmartThings", category: "C1") {
|
||||||
|
|
||||||
capability "Actuator"
|
capability "Actuator"
|
||||||
capability "Color Temperature"
|
capability "Color Temperature"
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
/**
|
/**
|
||||||
* Smart Windows
|
* Smart Windows
|
||||||
* Compares two temperatures – indoor vs outdoor, for example – then sends an alert if windows are open (or closed!).
|
* Compares two temperatures – indoor vs outdoor, for example – then sends an alert if windows are open (or closed!).
|
||||||
*
|
*
|
||||||
* Copyright 2014 Eric Gideon
|
* Copyright 2014 Eric Gideon
|
||||||
*
|
*
|
||||||
* Based in part on the "When it's going to rain" SmartApp by the SmartThings team,
|
* Based in part on the "When it's going to rain" SmartApp by the SmartThings team,
|
||||||
@@ -21,13 +21,18 @@ definition(
|
|||||||
name: "Smart Windows",
|
name: "Smart Windows",
|
||||||
namespace: "egid",
|
namespace: "egid",
|
||||||
author: "Eric Gideon",
|
author: "Eric Gideon",
|
||||||
description: "Compares two temperatures – indoor vs outdoor, for example – then sends an alert if windows are open (or closed!). If you don't use an external temperature device, your zipcode will be used instead.",
|
description: "Compares two temperatures – indoor vs outdoor, for example – then sends an alert if windows are open (or closed!). If you don't use an external temperature device, your location will be used instead.",
|
||||||
iconUrl: "https://s3.amazonaws.com/smartthings-device-icons/Home/home9-icn.png",
|
iconUrl: "https://s3.amazonaws.com/smartthings-device-icons/Home/home9-icn.png",
|
||||||
iconX2Url: "https://s3.amazonaws.com/smartthings-device-icons/Home/home9-icn@2x.png"
|
iconX2Url: "https://s3.amazonaws.com/smartthings-device-icons/Home/home9-icn@2x.png"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
preferences {
|
preferences {
|
||||||
|
|
||||||
|
if (!(location.zipCode || ( location.latitude && location.longitude )) && location.channelName == 'samsungtv') {
|
||||||
|
section { paragraph title: "Note:", "Location is required for this SmartApp. Go to 'Location Name' settings to setup your correct location." }
|
||||||
|
}
|
||||||
|
|
||||||
section( "Set the temperature range for your comfort zone..." ) {
|
section( "Set the temperature range for your comfort zone..." ) {
|
||||||
input "minTemp", "number", title: "Minimum temperature"
|
input "minTemp", "number", title: "Minimum temperature"
|
||||||
input "maxTemp", "number", title: "Maximum temperature"
|
input "maxTemp", "number", title: "Maximum temperature"
|
||||||
@@ -39,9 +44,11 @@ preferences {
|
|||||||
input "inTemp", "capability.temperatureMeasurement", title: "Indoor"
|
input "inTemp", "capability.temperatureMeasurement", title: "Indoor"
|
||||||
input "outTemp", "capability.temperatureMeasurement", title: "Outdoor (optional)", required: false
|
input "outTemp", "capability.temperatureMeasurement", title: "Outdoor (optional)", required: false
|
||||||
}
|
}
|
||||||
section( "Set your location" ) {
|
|
||||||
input "zipCode", "text", title: "Zip code"
|
if (location.channelName != 'samsungtv') {
|
||||||
}
|
section( "Set your location" ) { input "zipCode", "text", title: "Zip code" }
|
||||||
|
}
|
||||||
|
|
||||||
section( "Notifications" ) {
|
section( "Notifications" ) {
|
||||||
input "sendPushMessage", "enum", title: "Send a push notification?", metadata:[values:["Yes","No"]], required:false
|
input "sendPushMessage", "enum", title: "Send a push notification?", metadata:[values:["Yes","No"]], required:false
|
||||||
input "retryPeriod", "number", title: "Minutes between notifications:"
|
input "retryPeriod", "number", title: "Minutes between notifications:"
|
||||||
@@ -72,7 +79,7 @@ def temperatureHandler(evt) {
|
|||||||
|
|
||||||
def currentInTemp = evt.doubleValue
|
def currentInTemp = evt.doubleValue
|
||||||
def openWindows = sensors.findAll { it?.latestValue("contact") == 'open' }
|
def openWindows = sensors.findAll { it?.latestValue("contact") == 'open' }
|
||||||
|
|
||||||
log.trace "Temp event: $evt"
|
log.trace "Temp event: $evt"
|
||||||
log.info "In: $currentInTemp; Out: $currentOutTemp"
|
log.info "In: $currentInTemp; Out: $currentOutTemp"
|
||||||
|
|
||||||
@@ -98,7 +105,7 @@ def temperatureHandler(evt) {
|
|||||||
if ( currentOutTemp < maxTemp && !openWindows ) {
|
if ( currentOutTemp < maxTemp && !openWindows ) {
|
||||||
send( "Open some windows to cool down the house! Currently ${currentInTemp}°F inside and ${currentOutTemp}°F outside." )
|
send( "Open some windows to cool down the house! Currently ${currentInTemp}°F inside and ${currentOutTemp}°F outside." )
|
||||||
} else if ( currentOutTemp > maxTemp && openWindows ) {
|
} else if ( currentOutTemp > maxTemp && openWindows ) {
|
||||||
send( "It's gotten warmer outside! You should close these windows: ${openWindows.join(', ')}. Currently ${currentInTemp}°F inside and ${currentOutTemp}°F outside." )
|
send( "It's gotten warmer outside! You should close these windows: ${openWindows.join(', ')}. Currently ${currentInTemp}°F inside and ${currentOutTemp}°F outside." )
|
||||||
} else {
|
} else {
|
||||||
log.debug "No notifications sent. Everything is in the right place."
|
log.debug "No notifications sent. Everything is in the right place."
|
||||||
}
|
}
|
||||||
@@ -125,7 +132,11 @@ def temperatureHandler(evt) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
def weatherCheck() {
|
def weatherCheck() {
|
||||||
def json = getWeatherFeature("conditions", zipCode)
|
def json
|
||||||
|
if (location.channelName != 'samsungtv')
|
||||||
|
json = getWeatherFeature("conditions", zipCode)
|
||||||
|
else
|
||||||
|
json = getWeatherFeature("conditions")
|
||||||
def currentTemp = json?.current_observation?.temp_f
|
def currentTemp = json?.current_observation?.temp_f
|
||||||
|
|
||||||
if ( currentTemp ) {
|
if ( currentTemp ) {
|
||||||
@@ -150,4 +161,4 @@ private send(msg) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
log.info msg
|
log.info msg
|
||||||
}
|
}
|
||||||
|
|||||||
253
smartapps/gideon-api/gideon.src/gideon.groovy
Normal file
253
smartapps/gideon-api/gideon.src/gideon.groovy
Normal file
@@ -0,0 +1,253 @@
|
|||||||
|
/**
|
||||||
|
* Gideon
|
||||||
|
*
|
||||||
|
* Copyright 2016 Nicola Russo
|
||||||
|
*
|
||||||
|
* 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: "Gideon",
|
||||||
|
namespace: "gideon.api",
|
||||||
|
author: "Braindrain Solutions",
|
||||||
|
description: "Gideon AI Smart app allows you to connect and control all of your SmartThings devices through the Gideon AI app, making your SmartThings devices even smarter.",
|
||||||
|
category: "Family",
|
||||||
|
iconUrl: "http://s33.postimg.org/t77u7y7v3/logo.png",
|
||||||
|
iconX2Url: "http://s33.postimg.org/t77u7y7v3/logo.png",
|
||||||
|
iconX3Url: "http://s33.postimg.org/t77u7y7v3/logo.png",
|
||||||
|
oauth: [displayName: "Gideon AI API", displayLink: "gideon.ai"])
|
||||||
|
|
||||||
|
|
||||||
|
preferences {
|
||||||
|
section("Control these switches...") {
|
||||||
|
input "switches", "capability.switch", multiple:true
|
||||||
|
}
|
||||||
|
section("Control these motion sensors...") {
|
||||||
|
input "motions", "capability.motionSensor", multiple:true
|
||||||
|
}
|
||||||
|
section("Control these presence sensors...") {
|
||||||
|
input "presence_sensors", "capability.presenceSensor", multiple:true
|
||||||
|
}
|
||||||
|
section("Control these outlets...") {
|
||||||
|
input "outlets", "capability.switch", multiple:true
|
||||||
|
}
|
||||||
|
section("Control these locks...") {
|
||||||
|
input "locks", "capability.lock", multiple:true
|
||||||
|
}
|
||||||
|
section("Control these locks...") {
|
||||||
|
input "temperature_sensors", "capability.temperatureMeasurement"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def installed() {
|
||||||
|
log.debug "Installed with settings: ${settings}"
|
||||||
|
|
||||||
|
initialize()
|
||||||
|
}
|
||||||
|
|
||||||
|
def updated() {
|
||||||
|
log.debug "Updated with settings: ${settings}"
|
||||||
|
|
||||||
|
unsubscribe()
|
||||||
|
initialize()
|
||||||
|
}
|
||||||
|
|
||||||
|
def initialize() {
|
||||||
|
// TODO: subscribe to attributes, devices, locations, etc.
|
||||||
|
subscribe(outlet, "energy", outletHandler)
|
||||||
|
subscribe(outlet, "switch", outletHandler)
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO: implement event handlers
|
||||||
|
def outletHandler(evt) {
|
||||||
|
log.debug "$outlet.currentEnergy"
|
||||||
|
//TODO call G API
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private device(it, type) {
|
||||||
|
it ? [id: it.id, label: it.label, type: type] : null
|
||||||
|
}
|
||||||
|
|
||||||
|
//API Mapping
|
||||||
|
mappings {
|
||||||
|
path("/getalldevices") {
|
||||||
|
action: [
|
||||||
|
GET: "getAllDevices"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/doorlocks/:id/:command") {
|
||||||
|
action: [
|
||||||
|
GET: "updateDoorLock"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/doorlocks/:id") {
|
||||||
|
action: [
|
||||||
|
GET: "getDoorLockStatus"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/tempsensors/:id") {
|
||||||
|
action: [
|
||||||
|
GET: "getTempSensorsStatus"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/presences/:id") {
|
||||||
|
action: [
|
||||||
|
GET: "getPresenceStatus"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/motions/:id") {
|
||||||
|
action: [
|
||||||
|
GET: "getMotionStatus"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/outlets/:id") {
|
||||||
|
action: [
|
||||||
|
GET: "getOutletStatus"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/outlets/:id/:command") {
|
||||||
|
action: [
|
||||||
|
GET: "updateOutlet"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
path("/switches/:command") {
|
||||||
|
action: [
|
||||||
|
PUT: "updateSwitch"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//API Methods
|
||||||
|
def getAllDevices() {
|
||||||
|
def locks_list = locks.collect{device(it,"Lock")}
|
||||||
|
def presences_list = presence_sensors.collect{device(it,"Presence")}
|
||||||
|
def motions_list = motions.collect{device(it,"Motion")}
|
||||||
|
def outlets_list = outlets.collect{device(it,"Outlet")}
|
||||||
|
def switches_list = switches.collect{device(it,"Switch")}
|
||||||
|
def temp_list = temperature_sensors.collect{device(it,"Temperature")}
|
||||||
|
return [Locks: locks_list, Presences: presences_list, Motions: motions_list, Outlets: outlets_list, Switches: switches_list, Temperatures: temp_list]
|
||||||
|
}
|
||||||
|
|
||||||
|
//LOCKS
|
||||||
|
def getDoorLockStatus() {
|
||||||
|
def device = locks.find { it.id == params.id }
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
return [Device_state: device.currentValue('lock')]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def updateDoorLock() {
|
||||||
|
def command = params.command
|
||||||
|
def device = locks.find { it.id == params.id }
|
||||||
|
if (command){
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
if(command == "toggle")
|
||||||
|
{
|
||||||
|
if(device.currentValue('lock') == "locked")
|
||||||
|
device.unlock();
|
||||||
|
else
|
||||||
|
device.lock();
|
||||||
|
|
||||||
|
return [Device_id: params.id, result_action: "200"]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//PRESENCE
|
||||||
|
def getPresenceStatus() {
|
||||||
|
|
||||||
|
def device = presence_sensors.find { it.id == params.id }
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
return [Device_state: device.currentValue('presence')]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//MOTION
|
||||||
|
def getMotionStatus() {
|
||||||
|
|
||||||
|
def device = motions.find { it.id == params.id }
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
return [Device_state: device.currentValue('motion')]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//OUTLET
|
||||||
|
def getOutletStatus() {
|
||||||
|
|
||||||
|
def device = outlets.find { it.id == params.id }
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
return [Device_state: device.currentSwitch, Current_watt: device.currentValue("energy")]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def updateOutlet() {
|
||||||
|
|
||||||
|
def command = params.command
|
||||||
|
def device = outlets.find { it.id == params.id }
|
||||||
|
if (command){
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
if(command == "toggle")
|
||||||
|
{
|
||||||
|
if(device.currentSwitch == "on")
|
||||||
|
device.off();
|
||||||
|
else
|
||||||
|
device.on();
|
||||||
|
|
||||||
|
return [Device_id: params.id, result_action: "200"]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//SWITCH
|
||||||
|
def updateSwitch() {
|
||||||
|
def command = params.command
|
||||||
|
def device = switches.find { it.id == params.id }
|
||||||
|
if (command){
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
if(command == "toggle")
|
||||||
|
{
|
||||||
|
if(device.currentSwitch == "on")
|
||||||
|
device.off();
|
||||||
|
else
|
||||||
|
device.on();
|
||||||
|
|
||||||
|
return [Device_id: params.id, result_action: "200"]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//TEMPERATURE
|
||||||
|
def getTempSensorsStatus() {
|
||||||
|
|
||||||
|
def device = temperature_sensors.find { it.id == params.id }
|
||||||
|
if (!device) {
|
||||||
|
httpError(404, "Device not found")
|
||||||
|
} else {
|
||||||
|
return [Device_state: device.currentValue('temperature')]
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -18,8 +18,13 @@ definition(
|
|||||||
)
|
)
|
||||||
|
|
||||||
preferences {
|
preferences {
|
||||||
section("Zip code?") {
|
|
||||||
input "zipcode", "text", title: "Zipcode?"
|
if (!(location.zipCode || ( location.latitude && location.longitude )) && location.channelName == 'samsungtv') {
|
||||||
|
section { paragraph title: "Note:", "Location is required for this SmartApp. Go to 'Location Name' settings to setup your correct location." }
|
||||||
|
}
|
||||||
|
|
||||||
|
if (location.channelName != 'samsungtv') {
|
||||||
|
section( "Set your location" ) { input "zipCode", "text", title: "Zip code" }
|
||||||
}
|
}
|
||||||
|
|
||||||
section("Things to check?") {
|
section("Things to check?") {
|
||||||
@@ -60,7 +65,11 @@ def scheduleCheck(evt) {
|
|||||||
// Only need to poll if we haven't checked in a while - and if something is left open.
|
// Only need to poll if we haven't checked in a while - and if something is left open.
|
||||||
if((now() - (30 * 60 * 1000) > state.lastCheck["time"]) && open) {
|
if((now() - (30 * 60 * 1000) > state.lastCheck["time"]) && open) {
|
||||||
log.info("Something's open - let's check the weather.")
|
log.info("Something's open - let's check the weather.")
|
||||||
def response = getWeatherFeature("forecast", zipcode)
|
def response
|
||||||
|
if (location.channelName != 'samsungtv')
|
||||||
|
response = getWeatherFeature("forecast", zipCode)
|
||||||
|
else
|
||||||
|
response = getWeatherFeature("forecast")
|
||||||
def weather = isStormy(response)
|
def weather = isStormy(response)
|
||||||
|
|
||||||
if(weather) {
|
if(weather) {
|
||||||
|
|||||||
@@ -26,9 +26,9 @@ preferences {
|
|||||||
}
|
}
|
||||||
|
|
||||||
section("Temperature monitor?") {
|
section("Temperature monitor?") {
|
||||||
input "temp", "capability.temperatureMeasurement", title: "Temp Sensor", required: false
|
input "temp", "capability.temperatureMeasurement", title: "Temperature Sensor", required: false
|
||||||
input "maxTemp", "number", title: "Max Temp?", required: false
|
input "maxTemp", "number", title: "Max Temperature (°${location.temperatureScale})", required: false
|
||||||
input "minTemp", "number", title: "Min Temp?", required: false
|
input "minTemp", "number", title: "Min Temperature (°${location.temperatureScale})", required: false
|
||||||
}
|
}
|
||||||
|
|
||||||
section("When which people are away?") {
|
section("When which people are away?") {
|
||||||
|
|||||||
@@ -4,6 +4,9 @@
|
|||||||
* Author: Juan Risso
|
* Author: Juan Risso
|
||||||
* Date: 2013-12-19
|
* Date: 2013-12-19
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
include 'asynchttp_v1'
|
||||||
|
|
||||||
definition(
|
definition(
|
||||||
name: "Jawbone UP (Connect)",
|
name: "Jawbone UP (Connect)",
|
||||||
namespace: "juano2310",
|
namespace: "juano2310",
|
||||||
@@ -303,7 +306,8 @@ def setup() {
|
|||||||
def childDevice = addChildDevice('juano2310', "Jawbone User", "${app.id}.${member.xid}",null,[name:"Jawbone UP - " + member.first, completedSetup: true])
|
def childDevice = addChildDevice('juano2310', "Jawbone User", "${app.id}.${member.xid}",null,[name:"Jawbone UP - " + member.first, completedSetup: true])
|
||||||
if (childDevice) {
|
if (childDevice) {
|
||||||
log.debug "Child Device Successfully Created"
|
log.debug "Child Device Successfully Created"
|
||||||
generateInitialEvent (member, childDevice)
|
childDevice?.generateSleepingEvent(false)
|
||||||
|
pollChild(childDevice)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -349,67 +353,67 @@ def uninstalled() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
def pollChild(childDevice) {
|
def pollChild(childDevice) {
|
||||||
def member = state.member
|
def childMap = [ value: "$childDevice.device.deviceNetworkId}"]
|
||||||
generatePollingEvents (member, childDevice)
|
|
||||||
|
def params = [
|
||||||
|
uri: 'https://jawbone.com',
|
||||||
|
path: '/nudge/api/users/@me/goals',
|
||||||
|
headers: ["Authorization": "Bearer ${state.JawboneAccessToken}" ],
|
||||||
|
contentType: 'application/json'
|
||||||
|
]
|
||||||
|
|
||||||
|
asynchttp_v1.get('responseGoals', params, childMap)
|
||||||
|
|
||||||
|
def params2 = [
|
||||||
|
uri: 'https://jawbone.com',
|
||||||
|
path: '/nudge/api/users/@me/moves',
|
||||||
|
headers: ["Authorization": "Bearer ${state.JawboneAccessToken}" ],
|
||||||
|
contentType: 'application/json'
|
||||||
|
]
|
||||||
|
|
||||||
|
asynchttp_v1.get('responseMoves', params2, childMap)
|
||||||
}
|
}
|
||||||
|
|
||||||
def generatePollingEvents (member, childDevice) {
|
def responseGoals(response, dni) {
|
||||||
// lets figure out if the member is currently "home" (At the place)
|
if (response.hasError()) {
|
||||||
def urlgoals = "https://jawbone.com/nudge/api/users/@me/goals"
|
log.error "response has error: $response.errorMessage"
|
||||||
def urlmoves = "https://jawbone.com/nudge/api/users/@me/moves"
|
} else {
|
||||||
def urlsleeps = "https://jawbone.com/nudge/api/users/@me/sleeps"
|
def goals
|
||||||
def goals = null
|
try {
|
||||||
def moves = null
|
// json response already parsed into JSONElement object
|
||||||
def sleeps = null
|
goals = response.json.data
|
||||||
httpGet(uri: urlgoals, headers: ["Authorization": "Bearer ${state.JawboneAccessToken}" ]) {response ->
|
} catch (e) {
|
||||||
goals = response.data.data
|
log.error "error parsing json from response: $e"
|
||||||
}
|
}
|
||||||
httpGet(uri: urlmoves, headers: ["Authorization": "Bearer ${state.JawboneAccessToken}" ]) {response ->
|
if (goals) {
|
||||||
moves = response.data.data.items[0]
|
def childDevice = getChildDevice(dni.value)
|
||||||
}
|
log.debug "Goal = ${goals.move_steps} Steps"
|
||||||
|
childDevice?.sendEvent(name:"goal", value: goals.move_steps)
|
||||||
try { // we are going to just ignore any errors
|
} else {
|
||||||
log.debug "Member = ${member.first}"
|
log.debug "did not get json results from response body: $response.data"
|
||||||
log.debug "Moves Goal = ${goals.move_steps} Steps"
|
}
|
||||||
log.debug "Moves = ${moves.details.steps} Steps"
|
}
|
||||||
|
|
||||||
childDevice?.sendEvent(name:"steps", value: moves.details.steps)
|
|
||||||
childDevice?.sendEvent(name:"goal", value: goals.move_steps)
|
|
||||||
//setColor(moves.details.steps,goals.move_steps,childDevice)
|
|
||||||
}
|
|
||||||
catch (e) {
|
|
||||||
// eat it
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
def generateInitialEvent (member, childDevice) {
|
def responseMoves(response, dni) {
|
||||||
// lets figure out if the member is currently "home" (At the place)
|
if (response.hasError()) {
|
||||||
def urlgoals = "https://jawbone.com/nudge/api/users/@me/goals"
|
log.error "response has error: $response.errorMessage"
|
||||||
def urlmoves = "https://jawbone.com/nudge/api/users/@me/moves"
|
} else {
|
||||||
def urlsleeps = "https://jawbone.com/nudge/api/users/@me/sleeps"
|
def moves
|
||||||
def goals = null
|
try {
|
||||||
def moves = null
|
// json response already parsed into JSONElement object
|
||||||
def sleeps = null
|
moves = response.json.data.items[0]
|
||||||
httpGet(uri: urlgoals, headers: ["Authorization": "Bearer ${state.JawboneAccessToken}" ]) {response ->
|
} catch (e) {
|
||||||
goals = response.data.data
|
log.error "error parsing json from response: $e"
|
||||||
}
|
}
|
||||||
httpGet(uri: urlmoves, headers: ["Authorization": "Bearer ${state.JawboneAccessToken}" ]) {response ->
|
if (moves) {
|
||||||
moves = response.data.data.items[0]
|
def childDevice = getChildDevice(dni.value)
|
||||||
}
|
log.debug "Moves = ${moves.details.steps} Steps"
|
||||||
|
childDevice?.sendEvent(name:"steps", value: moves.details.steps)
|
||||||
try { // we are going to just ignore any errors
|
} else {
|
||||||
log.debug "Member = ${member.first}"
|
log.debug "did not get json results from response body: $response.data"
|
||||||
log.debug "Moves Goal = ${goals.move_steps} Steps"
|
}
|
||||||
log.debug "Moves = ${moves.details.steps} Steps"
|
}
|
||||||
log.debug "Sleeping state = false"
|
|
||||||
childDevice?.generateSleepingEvent(false)
|
|
||||||
childDevice?.sendEvent(name:"steps", value: moves.details.steps)
|
|
||||||
childDevice?.sendEvent(name:"goal", value: goals.move_steps)
|
|
||||||
//setColor(moves.details.steps,goals.move_steps,childDevice)
|
|
||||||
}
|
|
||||||
catch (e) {
|
|
||||||
// eat it
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
def setColor (steps,goal,childDevice) {
|
def setColor (steps,goal,childDevice) {
|
||||||
@@ -433,7 +437,7 @@ def hookEventHandler() {
|
|||||||
// get some stuff we need
|
// get some stuff we need
|
||||||
def userId = json.events.user_xid[0]
|
def userId = json.events.user_xid[0]
|
||||||
def json_type = json.events.type[0]
|
def json_type = json.events.type[0]
|
||||||
def json_action = json.events.action[0]
|
def json_action = json.events.action[0]
|
||||||
|
|
||||||
//log.debug json
|
//log.debug json
|
||||||
log.debug "Userid = ${userId}"
|
log.debug "Userid = ${userId}"
|
||||||
|
|||||||
@@ -454,17 +454,23 @@ def sendStopEvent(source) {
|
|||||||
eventData.value += "cancelled"
|
eventData.value += "cancelled"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// send 100% completion event
|
||||||
|
sendTimeRemainingEvent(100)
|
||||||
|
|
||||||
|
// send a non-displayed 0% completion to reset tiles
|
||||||
|
sendTimeRemainingEvent(0, false)
|
||||||
|
|
||||||
|
// send sessionStatus event last so the event feed is ordered properly
|
||||||
sendControllerEvent(eventData)
|
sendControllerEvent(eventData)
|
||||||
sendTimeRemainingEvent(0)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
def sendTimeRemainingEvent(percentComplete) {
|
def sendTimeRemainingEvent(percentComplete, displayed = true) {
|
||||||
log.trace "sendTimeRemainingEvent(${percentComplete})"
|
log.trace "sendTimeRemainingEvent(${percentComplete})"
|
||||||
|
|
||||||
def percentCompleteEventData = [
|
def percentCompleteEventData = [
|
||||||
name: "percentComplete",
|
name: "percentComplete",
|
||||||
value: percentComplete as int,
|
value: percentComplete as int,
|
||||||
displayed: true,
|
displayed: displayed,
|
||||||
isStateChange: true
|
isStateChange: true
|
||||||
]
|
]
|
||||||
sendControllerEvent(percentCompleteEventData)
|
sendControllerEvent(percentCompleteEventData)
|
||||||
@@ -474,7 +480,7 @@ def sendTimeRemainingEvent(percentComplete) {
|
|||||||
def timeRemainingEventData = [
|
def timeRemainingEventData = [
|
||||||
name: "timeRemaining",
|
name: "timeRemaining",
|
||||||
value: displayableTime(timeRemaining),
|
value: displayableTime(timeRemaining),
|
||||||
displayed: true,
|
displayed: displayed,
|
||||||
isStateChange: true
|
isStateChange: true
|
||||||
]
|
]
|
||||||
sendControllerEvent(timeRemainingEventData)
|
sendControllerEvent(timeRemainingEventData)
|
||||||
@@ -608,8 +614,6 @@ private completion() {
|
|||||||
handleCompletionMessaging()
|
handleCompletionMessaging()
|
||||||
|
|
||||||
handleCompletionModesAndPhrases()
|
handleCompletionModesAndPhrases()
|
||||||
|
|
||||||
sendTimeRemainingEvent(100)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private handleCompletionSwitches() {
|
private handleCompletionSwitches() {
|
||||||
|
|||||||
@@ -83,7 +83,7 @@ def bridgeDiscovery(params=[:])
|
|||||||
|
|
||||||
return dynamicPage(name:"bridgeDiscovery", title:"Discovery Started!", nextPage:"bridgeBtnPush", refreshInterval:refreshInterval, uninstall: true) {
|
return dynamicPage(name:"bridgeDiscovery", title:"Discovery Started!", nextPage:"bridgeBtnPush", refreshInterval:refreshInterval, uninstall: true) {
|
||||||
section("Please wait while we discover your Hue Bridge. Discovery can take five minutes or more, so sit back and relax! Select your device below once discovered.") {
|
section("Please wait while we discover your Hue Bridge. Discovery can take five minutes or more, so sit back and relax! Select your device below once discovered.") {
|
||||||
input "selectedHue", "enum", required:false, title:"Select Hue Bridge (${numFound} found)", multiple:false, options:options
|
input "selectedHue", "enum", required:false, title:"Select Hue Bridge (${numFound} found)", multiple:false, options:options, submitOnChange: true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -131,10 +131,7 @@ def bulbDiscovery() {
|
|||||||
def refreshInterval = 3
|
def refreshInterval = 3
|
||||||
state.inBulbDiscovery = true
|
state.inBulbDiscovery = true
|
||||||
def bridge = null
|
def bridge = null
|
||||||
if (selectedHue) {
|
|
||||||
bridge = getChildDevice(selectedHue)
|
|
||||||
subscribe(bridge, "bulbList", bulbListData)
|
|
||||||
}
|
|
||||||
state.bridgeRefreshCount = 0
|
state.bridgeRefreshCount = 0
|
||||||
def allLightsFound = bulbsDiscovered() ?: [:]
|
def allLightsFound = bulbsDiscovered() ?: [:]
|
||||||
|
|
||||||
@@ -259,10 +256,6 @@ Map bulbsDiscovered() {
|
|||||||
return bulbmap
|
return bulbmap
|
||||||
}
|
}
|
||||||
|
|
||||||
def bulbListData(evt) {
|
|
||||||
state.bulbs = evt.jsonData
|
|
||||||
}
|
|
||||||
|
|
||||||
Map getHueBulbs() {
|
Map getHueBulbs() {
|
||||||
state.bulbs = state.bulbs ?: [:]
|
state.bulbs = state.bulbs ?: [:]
|
||||||
}
|
}
|
||||||
@@ -316,29 +309,6 @@ def uninstalled(){
|
|||||||
state.username = null
|
state.username = null
|
||||||
}
|
}
|
||||||
|
|
||||||
// Handles events to add new bulbs
|
|
||||||
def bulbListHandler(hub, data = "") {
|
|
||||||
def msg = "Bulbs list not processed. Only while in settings menu."
|
|
||||||
def bulbs = [:]
|
|
||||||
if (state.inBulbDiscovery) {
|
|
||||||
def logg = ""
|
|
||||||
log.trace "Adding bulbs to state..."
|
|
||||||
state.bridgeProcessedLightList = true
|
|
||||||
def object = new groovy.json.JsonSlurper().parseText(data)
|
|
||||||
object.each { k,v ->
|
|
||||||
if (v instanceof Map)
|
|
||||||
bulbs[k] = [id: k, name: v.name, type: v.type, modelid: v.modelid, hub:hub, online: v.state?.reachable]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
def bridge = null
|
|
||||||
if (selectedHue) {
|
|
||||||
bridge = getChildDevice(selectedHue)
|
|
||||||
}
|
|
||||||
bridge.sendEvent(name: "bulbList", value: hub, data: bulbs, isStateChange: true, displayed: false)
|
|
||||||
msg = "${bulbs.size()} bulbs found. ${bulbs}"
|
|
||||||
return msg
|
|
||||||
}
|
|
||||||
|
|
||||||
private upgradeDeviceType(device, newHueType) {
|
private upgradeDeviceType(device, newHueType) {
|
||||||
def deviceType = getDeviceType(newHueType)
|
def deviceType = getDeviceType(newHueType)
|
||||||
|
|
||||||
@@ -490,24 +460,25 @@ def ssdpBridgeHandler(evt) {
|
|||||||
def host = ip + ":" + port
|
def host = ip + ":" + port
|
||||||
log.debug "Device ($parsedEvent.mac) was already found in state with ip = $host."
|
log.debug "Device ($parsedEvent.mac) was already found in state with ip = $host."
|
||||||
def dstate = bridges."${parsedEvent.ssdpUSN.toString()}"
|
def dstate = bridges."${parsedEvent.ssdpUSN.toString()}"
|
||||||
def dni = "${parsedEvent.mac}"
|
def dniReceived = "${parsedEvent.mac}"
|
||||||
def d = getChildDevice(dni)
|
def currentDni = dstate.mac
|
||||||
|
def d = getChildDevice(dniReceived)
|
||||||
def networkAddress = null
|
def networkAddress = null
|
||||||
if (!d) {
|
if (!d) {
|
||||||
childDevices.each {
|
// There might be a mismatch between bridge DNI and the actual bridge mac address, correct that
|
||||||
if (it.getDeviceDataByName("mac")) {
|
log.debug "Bridge with $dniReceived not found"
|
||||||
def newDNI = "${it.getDeviceDataByName("mac")}"
|
def bridge = childDevices.find { it.deviceNetworkId == currentDni }
|
||||||
d = it
|
if (bridge != null) {
|
||||||
if (newDNI != it.deviceNetworkId) {
|
log.warn "Bridge is set to ${bridge.deviceNetworkId}, updating to $dniReceived"
|
||||||
def oldDNI = it.deviceNetworkId
|
bridge.setDeviceNetworkId("${dniReceived}")
|
||||||
log.debug "updating dni for device ${it} with $newDNI - previous DNI = ${it.deviceNetworkId}"
|
dstate.mac = dniReceived
|
||||||
it.setDeviceNetworkId("${newDNI}")
|
// Check to see if selectedHue is a valid bridge, otherwise update it
|
||||||
if (oldDNI == selectedHue) {
|
def isSelectedValid = bridges?.find {it.value?.mac == selectedHue}
|
||||||
app.updateSetting("selectedHue", newDNI)
|
if (isSelectedValid == null) {
|
||||||
}
|
log.warn "Correcting selectedHue in state"
|
||||||
doDeviceSync()
|
app.updateSetting("selectedHue", dniReceived)
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
doDeviceSync()
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
updateBridgeStatus(d)
|
updateBridgeStatus(d)
|
||||||
@@ -525,6 +496,18 @@ def ssdpBridgeHandler(evt) {
|
|||||||
d.sendEvent(name:"networkAddress", value: host)
|
d.sendEvent(name:"networkAddress", value: host)
|
||||||
d.updateDataValue("networkAddress", host)
|
d.updateDataValue("networkAddress", host)
|
||||||
}
|
}
|
||||||
|
if (dstate.mac != dniReceived) {
|
||||||
|
log.warn "Correcting bridge mac address in state"
|
||||||
|
dstate.mac = dniReceived
|
||||||
|
}
|
||||||
|
if (selectedHue != dniReceived) {
|
||||||
|
// Check to see if selectedHue is a valid bridge, otherwise update it
|
||||||
|
def isSelectedValid = bridges?.find {it.value?.mac == selectedHue}
|
||||||
|
if (isSelectedValid == null) {
|
||||||
|
log.warn "Correcting selectedHue in state"
|
||||||
|
app.updateSetting("selectedHue", dniReceived)
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -557,11 +540,8 @@ void lightsHandler(physicalgraph.device.HubResponse hubResponse) {
|
|||||||
if (isValidSource(hubResponse.mac)) {
|
if (isValidSource(hubResponse.mac)) {
|
||||||
def body = hubResponse.json
|
def body = hubResponse.json
|
||||||
if (!body?.state?.on) { //check if first time poll made it here by mistake
|
if (!body?.state?.on) { //check if first time poll made it here by mistake
|
||||||
def bulbs = getHueBulbs()
|
|
||||||
log.debug "Adding bulbs to state!"
|
log.debug "Adding bulbs to state!"
|
||||||
body.each { k, v ->
|
updateBulbState(body, hubResponse.hubId)
|
||||||
bulbs[k] = [id: k, name: v.name, type: v.type, modelid: v.modelid, hub: hubResponse.hubId]
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -677,11 +657,8 @@ def locationHandler(evt) {
|
|||||||
} else {
|
} else {
|
||||||
//GET /api/${state.username}/lights response (application/json)
|
//GET /api/${state.username}/lights response (application/json)
|
||||||
if (!body?.state?.on) { //check if first time poll made it here by mistake
|
if (!body?.state?.on) { //check if first time poll made it here by mistake
|
||||||
def bulbs = getHueBulbs()
|
|
||||||
log.debug "Adding bulbs to state!"
|
log.debug "Adding bulbs to state!"
|
||||||
body.each { k,v ->
|
updateBulbState(body, parsedEvent.hub)
|
||||||
bulbs[k] = [id: k, name: v.name, type: v.type, modelid: v.modelid, hub:parsedEvent.hub]
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -741,7 +718,7 @@ private void checkBridgeStatus() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (it.value.lastActivity < time) { // it.value.lastActivity != null &&
|
if (it.value.lastActivity < time) { // it.value.lastActivity != null &&
|
||||||
log.warn "Bridge $it.key is Offline"
|
log.warn "Bridge $it.value.idNumber is Offline"
|
||||||
d.sendEvent(name: "status", value: "Offline")
|
d.sendEvent(name: "status", value: "Offline")
|
||||||
|
|
||||||
state.bulbs?.each {
|
state.bulbs?.each {
|
||||||
@@ -766,6 +743,31 @@ def isInBulbDiscovery() {
|
|||||||
return state.inBulbDiscovery
|
return state.inBulbDiscovery
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private updateBulbState(messageBody, hub) {
|
||||||
|
def bulbs = getHueBulbs()
|
||||||
|
|
||||||
|
// Copy of bulbs used to locate old lights in state that are no longer on bridge
|
||||||
|
def toRemove = [:]
|
||||||
|
toRemove << bulbs
|
||||||
|
|
||||||
|
messageBody.each { k,v ->
|
||||||
|
|
||||||
|
if (v instanceof Map) {
|
||||||
|
if (bulbs[k] == null) {
|
||||||
|
bulbs[k] = [:]
|
||||||
|
}
|
||||||
|
bulbs[k] << [id: k, name: v.name, type: v.type, modelid: v.modelid, hub:hub, remove: false]
|
||||||
|
toRemove.remove(k)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Remove bulbs from state that are no longer discovered
|
||||||
|
toRemove.each { k,v ->
|
||||||
|
log.warn "${bulbs[k].name} no longer exists on bridge, removing"
|
||||||
|
bulbs.remove(k)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/////////////////////////////////////
|
/////////////////////////////////////
|
||||||
//CHILD DEVICE METHODS
|
//CHILD DEVICE METHODS
|
||||||
/////////////////////////////////////
|
/////////////////////////////////////
|
||||||
@@ -950,6 +952,14 @@ private handleCommandResponse(body) {
|
|||||||
* @return empty array
|
* @return empty array
|
||||||
*/
|
*/
|
||||||
private handlePoll(body) {
|
private handlePoll(body) {
|
||||||
|
// Used to track "unreachable" time
|
||||||
|
// Device is considered "offline" if it has been in the "unreachable" state for
|
||||||
|
// 11 minutes (e.g. two poll intervals)
|
||||||
|
// Note, Hue Bridge marks devices as "unreachable" often even when they accept commands
|
||||||
|
Calendar time11 = Calendar.getInstance()
|
||||||
|
time11.add(Calendar.MINUTE, -11)
|
||||||
|
Calendar currentTime = Calendar.getInstance()
|
||||||
|
|
||||||
def bulbs = getChildDevices()
|
def bulbs = getChildDevices()
|
||||||
for (bulb in body) {
|
for (bulb in body) {
|
||||||
def device = bulbs.find{it.deviceNetworkId == "${app.id}/${bulb.key}"}
|
def device = bulbs.find{it.deviceNetworkId == "${app.id}/${bulb.key}"}
|
||||||
@@ -959,7 +969,10 @@ private handlePoll(body) {
|
|||||||
// light just came back online, notify device watch
|
// light just came back online, notify device watch
|
||||||
def lastActivity = now()
|
def lastActivity = now()
|
||||||
device.sendEvent(name: "deviceWatch-status", value: "ONLINE", description: "Last Activity is on ${new Date((long) lastActivity)}", displayed: false, isStateChange: true)
|
device.sendEvent(name: "deviceWatch-status", value: "ONLINE", description: "Last Activity is on ${new Date((long) lastActivity)}", displayed: false, isStateChange: true)
|
||||||
|
log.debug "$device is Online"
|
||||||
}
|
}
|
||||||
|
// Mark light as "online"
|
||||||
|
state.bulbs[bulb.key]?.unreachableSince = null
|
||||||
state.bulbs[bulb.key]?.online = true
|
state.bulbs[bulb.key]?.online = true
|
||||||
|
|
||||||
// If user just executed commands, then do not send events to avoid confusing the turning on/off state
|
// If user just executed commands, then do not send events to avoid confusing the turning on/off state
|
||||||
@@ -969,9 +982,18 @@ private handlePoll(body) {
|
|||||||
sendColorEvents(device, bulb.value?.state?.xy, bulb.value?.state?.hue, bulb.value?.state?.sat, bulb.value?.state?.ct, bulb.value?.state?.colormode)
|
sendColorEvents(device, bulb.value?.state?.xy, bulb.value?.state?.hue, bulb.value?.state?.sat, bulb.value?.state?.ct, bulb.value?.state?.colormode)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
state.bulbs[bulb.key]?.online = false
|
if (state.bulbs[bulb.key]?.unreachableSince == null) {
|
||||||
log.warn "$device is not reachable by Hue bridge"
|
// Store the first time where device was reported as "unreachable"
|
||||||
device.sendEvent(name: "DeviceWatch-DeviceOffline", value: "offline", displayed: false, isStateChange: true)
|
state.bulbs[bulb.key]?.unreachableSince = currentTime.getTimeInMillis()
|
||||||
|
} else if (state.bulbs[bulb.key]?.online) {
|
||||||
|
// Check if device was "unreachable" for more than 11 minutes and mark "offline" if necessary
|
||||||
|
if (state.bulbs[bulb.key]?.unreachableSince < time11.getTimeInMillis()) {
|
||||||
|
log.warn "$device went Offline"
|
||||||
|
state.bulbs[bulb.key]?.online = false
|
||||||
|
device.sendEvent(name: "DeviceWatch-DeviceOffline", value: "offline", displayed: false, isStateChange: true)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
log.warn "$device may not reachable by Hue bridge"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1006,9 +1028,6 @@ def hubVerification(bodytext) {
|
|||||||
def on(childDevice) {
|
def on(childDevice) {
|
||||||
log.debug "Executing 'on'"
|
log.debug "Executing 'on'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
createSwitchEvent(childDevice, "on")
|
createSwitchEvent(childDevice, "on")
|
||||||
put("lights/$id/state", [on: true])
|
put("lights/$id/state", [on: true])
|
||||||
@@ -1018,9 +1037,6 @@ def on(childDevice) {
|
|||||||
def off(childDevice) {
|
def off(childDevice) {
|
||||||
log.debug "Executing 'off'"
|
log.debug "Executing 'off'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
createSwitchEvent(childDevice, "off")
|
createSwitchEvent(childDevice, "off")
|
||||||
put("lights/$id/state", [on: false])
|
put("lights/$id/state", [on: false])
|
||||||
@@ -1030,9 +1046,6 @@ def off(childDevice) {
|
|||||||
def setLevel(childDevice, percent) {
|
def setLevel(childDevice, percent) {
|
||||||
log.debug "Executing 'setLevel'"
|
log.debug "Executing 'setLevel'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
// 1 - 254
|
// 1 - 254
|
||||||
def level
|
def level
|
||||||
@@ -1057,10 +1070,6 @@ def setLevel(childDevice, percent) {
|
|||||||
def setSaturation(childDevice, percent) {
|
def setSaturation(childDevice, percent) {
|
||||||
log.debug "Executing 'setSaturation($percent)'"
|
log.debug "Executing 'setSaturation($percent)'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
// 0 - 254
|
// 0 - 254
|
||||||
def level = Math.min(Math.round(percent * 254 / 100), 254)
|
def level = Math.min(Math.round(percent * 254 / 100), 254)
|
||||||
@@ -1073,9 +1082,6 @@ def setSaturation(childDevice, percent) {
|
|||||||
def setHue(childDevice, percent) {
|
def setHue(childDevice, percent) {
|
||||||
log.debug "Executing 'setHue($percent)'"
|
log.debug "Executing 'setHue($percent)'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
// 0 - 65535
|
// 0 - 65535
|
||||||
def level = Math.min(Math.round(percent * 65535 / 100), 65535)
|
def level = Math.min(Math.round(percent * 65535 / 100), 65535)
|
||||||
@@ -1088,9 +1094,6 @@ def setHue(childDevice, percent) {
|
|||||||
def setColorTemperature(childDevice, huesettings) {
|
def setColorTemperature(childDevice, huesettings) {
|
||||||
log.debug "Executing 'setColorTemperature($huesettings)'"
|
log.debug "Executing 'setColorTemperature($huesettings)'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
// 153 (6500K) to 500 (2000K)
|
// 153 (6500K) to 500 (2000K)
|
||||||
def ct = hueSettings == 6500 ? 153 : Math.round(1000000/huesettings)
|
def ct = hueSettings == 6500 ? 153 : Math.round(1000000/huesettings)
|
||||||
@@ -1102,9 +1105,6 @@ def setColorTemperature(childDevice, huesettings) {
|
|||||||
def setColor(childDevice, huesettings) {
|
def setColor(childDevice, huesettings) {
|
||||||
log.debug "Executing 'setColor($huesettings)'"
|
log.debug "Executing 'setColor($huesettings)'"
|
||||||
def id = getId(childDevice)
|
def id = getId(childDevice)
|
||||||
if (!isOnline(id)) {
|
|
||||||
return "Bulb is unreachable"
|
|
||||||
}
|
|
||||||
updateInProgress()
|
updateInProgress()
|
||||||
|
|
||||||
def value = [:]
|
def value = [:]
|
||||||
@@ -1120,7 +1120,7 @@ def setColor(childDevice, huesettings) {
|
|||||||
value.hue = Math.min(Math.round(huesettings.hue * 65535 / 100), 65535)
|
value.hue = Math.min(Math.round(huesettings.hue * 65535 / 100), 65535)
|
||||||
if (huesettings.saturation != null)
|
if (huesettings.saturation != null)
|
||||||
value.sat = Math.min(Math.round(huesettings.saturation * 254 / 100), 254)
|
value.sat = Math.min(Math.round(huesettings.saturation * 254 / 100), 254)
|
||||||
} else if (huesettings.hex != null && false) {
|
} else if (huesettings.hex != null) {
|
||||||
// For now ignore model to get a consistent color if same color is set across multiple devices
|
// For now ignore model to get a consistent color if same color is set across multiple devices
|
||||||
// def model = state.bulbs[getId(childDevice)]?.modelid
|
// def model = state.bulbs[getId(childDevice)]?.modelid
|
||||||
// value.xy = calculateXY(huesettings.hex, model)
|
// value.xy = calculateXY(huesettings.hex, model)
|
||||||
@@ -1162,7 +1162,14 @@ def setColor(childDevice, huesettings) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
def ping(childDevice) {
|
def ping(childDevice) {
|
||||||
if (isOnline(getId(childDevice))) {
|
if (childDevice.device?.deviceNetworkId?.equalsIgnoreCase(selectedHue)) {
|
||||||
|
if (childDevice.device?.currentValue("status")?.equalsIgnoreCase("Online")) {
|
||||||
|
childDevice.sendEvent(name: "deviceWatch-ping", value: "ONLINE", description: "Hue Bridge is reachable", displayed: false, isStateChange: true)
|
||||||
|
return "Bridge is Online"
|
||||||
|
} else {
|
||||||
|
return "Bridge is Offline"
|
||||||
|
}
|
||||||
|
} else if (isOnline(getId(childDevice))) {
|
||||||
childDevice.sendEvent(name: "deviceWatch-ping", value: "ONLINE", description: "Hue Light is reachable", displayed: false, isStateChange: true)
|
childDevice.sendEvent(name: "deviceWatch-ping", value: "ONLINE", description: "Hue Light is reachable", displayed: false, isStateChange: true)
|
||||||
return "Device is Online"
|
return "Device is Online"
|
||||||
} else {
|
} else {
|
||||||
@@ -1224,7 +1231,7 @@ private getBridgeIP() {
|
|||||||
if (d) {
|
if (d) {
|
||||||
if (d.getDeviceDataByName("networkAddress"))
|
if (d.getDeviceDataByName("networkAddress"))
|
||||||
host = d.getDeviceDataByName("networkAddress")
|
host = d.getDeviceDataByName("networkAddress")
|
||||||
else
|
else
|
||||||
host = d.latestState('networkAddress').stringValue
|
host = d.latestState('networkAddress').stringValue
|
||||||
}
|
}
|
||||||
if (host == null || host == "") {
|
if (host == null || host == "") {
|
||||||
@@ -1663,7 +1670,7 @@ private boolean checkPointInLampsReach(p, colorPoints) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Converts an RGB color in hex to HSV.
|
* Converts an RGB color in hex to HSV/HSB.
|
||||||
* Algorithm based on http://en.wikipedia.org/wiki/HSV_color_space.
|
* Algorithm based on http://en.wikipedia.org/wiki/HSV_color_space.
|
||||||
*
|
*
|
||||||
* @param colorStr color value in hex (#ff03d3)
|
* @param colorStr color value in hex (#ff03d3)
|
||||||
@@ -1673,32 +1680,32 @@ private boolean checkPointInLampsReach(p, colorPoints) {
|
|||||||
def hexToHsv(colorStr){
|
def hexToHsv(colorStr){
|
||||||
def r = Integer.valueOf( colorStr.substring( 1, 3 ), 16 ) / 255
|
def r = Integer.valueOf( colorStr.substring( 1, 3 ), 16 ) / 255
|
||||||
def g = Integer.valueOf( colorStr.substring( 3, 5 ), 16 ) / 255
|
def g = Integer.valueOf( colorStr.substring( 3, 5 ), 16 ) / 255
|
||||||
def b = Integer.valueOf( colorStr.substring( 5, 7 ), 16 ) / 255;
|
def b = Integer.valueOf( colorStr.substring( 5, 7 ), 16 ) / 255
|
||||||
|
|
||||||
def max = Math.max(Math.max(r, g), b)
|
def max = Math.max(Math.max(r, g), b)
|
||||||
def min = Math.min(Math.min(r, g), b)
|
def min = Math.min(Math.min(r, g), b)
|
||||||
|
|
||||||
def h, s, v = max;
|
def h, s, v = max
|
||||||
|
|
||||||
def d = max - min;
|
def d = max - min
|
||||||
s = max == 0 ? 0 : d / max;
|
s = max == 0 ? 0 : d / max
|
||||||
|
|
||||||
if(max == min){
|
if(max == min){
|
||||||
h = 0;
|
h = 0
|
||||||
}else{
|
}else{
|
||||||
switch(max){
|
switch(max){
|
||||||
case r: h = (g - b) / d + (g < b ? 6 : 0); break;
|
case r: h = (g - b) / d + (g < b ? 6 : 0); break
|
||||||
case g: h = (b - r) / d + 2; break;
|
case g: h = (b - r) / d + 2; break
|
||||||
case b: h = (r - g) / d + 4; break;
|
case b: h = (r - g) / d + 4; break
|
||||||
}
|
}
|
||||||
h /= 6;
|
h /= 6;
|
||||||
}
|
}
|
||||||
|
|
||||||
return [(h * 100).round(), (s * 100).round(), (v * 100).round()];
|
return [Math.round(h * 100), Math.round(s * 100), Math.round(v * 100)]
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Converts HSV color to RGB in hex.
|
* Converts HSV/HSB color to RGB in hex.
|
||||||
* Algorithm based on http://en.wikipedia.org/wiki/HSV_color_space.
|
* Algorithm based on http://en.wikipedia.org/wiki/HSV_color_space.
|
||||||
*
|
*
|
||||||
* @param hue hue 0-100
|
* @param hue hue 0-100
|
||||||
@@ -1713,11 +1720,11 @@ def hsvToHex(hue, sat, value = 100){
|
|||||||
def s = sat / 100
|
def s = sat / 100
|
||||||
def v = value / 100
|
def v = value / 100
|
||||||
|
|
||||||
def i = Math.floor(h * 6);
|
def i = Math.floor(h * 6)
|
||||||
def f = h * 6 - i;
|
def f = h * 6 - i
|
||||||
def p = v * (1 - s);
|
def p = v * (1 - s)
|
||||||
def q = v * (1 - f * s);
|
def q = v * (1 - f * s)
|
||||||
def t = v * (1 - (1 - f) * s);
|
def t = v * (1 - (1 - f) * s)
|
||||||
|
|
||||||
switch (i % 6) {
|
switch (i % 6) {
|
||||||
case 0:
|
case 0:
|
||||||
@@ -1753,9 +1760,9 @@ def hsvToHex(hue, sat, value = 100){
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Converting float components to int components.
|
// Converting float components to int components.
|
||||||
def r1 = String.format("%02X", (int) (r * 255.0f));
|
def r1 = String.format("%02X", (int) (r * 255.0f))
|
||||||
def g1 = String.format("%02X", (int) (g * 255.0f));
|
def g1 = String.format("%02X", (int) (g * 255.0f))
|
||||||
def b1 = String.format("%02X", (int) (b * 255.0f));
|
def b1 = String.format("%02X", (int) (b * 255.0f))
|
||||||
|
|
||||||
return "#$r1$g1$b1"
|
return "#$r1$g1$b1"
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -34,6 +34,7 @@
|
|||||||
* locks | lock | lock, unlock | locked, unlocked
|
* locks | lock | lock, unlock | locked, unlocked
|
||||||
* ---------------------+-------------------+-----------------------------+------------------------------------
|
* ---------------------+-------------------+-----------------------------+------------------------------------
|
||||||
*/
|
*/
|
||||||
|
include 'asynchttp_v1'
|
||||||
|
|
||||||
definition(
|
definition(
|
||||||
name: "Logitech Harmony (Connect)",
|
name: "Logitech Harmony (Connect)",
|
||||||
@@ -109,26 +110,28 @@ def authPage() {
|
|||||||
//device discovery request every 5 //25 seconds
|
//device discovery request every 5 //25 seconds
|
||||||
int deviceRefreshCount = !state.deviceRefreshCount ? 0 : state.deviceRefreshCount as int
|
int deviceRefreshCount = !state.deviceRefreshCount ? 0 : state.deviceRefreshCount as int
|
||||||
state.deviceRefreshCount = deviceRefreshCount + 1
|
state.deviceRefreshCount = deviceRefreshCount + 1
|
||||||
def refreshInterval = 3
|
def refreshInterval = 5
|
||||||
|
|
||||||
def huboptions = state.HarmonyHubs ?: []
|
def huboptions = state.HarmonyHubs ?: []
|
||||||
def actoptions = state.HarmonyActivities ?: []
|
def actoptions = state.HarmonyActivities ?: []
|
||||||
|
|
||||||
def numFoundHub = huboptions.size() ?: 0
|
def numFoundHub = huboptions.size() ?: 0
|
||||||
def numFoundAct = actoptions.size() ?: 0
|
def numFoundAct = actoptions.size() ?: 0
|
||||||
|
|
||||||
if((deviceRefreshCount % 5) == 0) {
|
if((deviceRefreshCount % 5) == 0) {
|
||||||
discoverDevices()
|
discoverDevices()
|
||||||
}
|
}
|
||||||
|
|
||||||
return dynamicPage(name:"Credentials", title:"Discovery Started!", nextPage:"", refreshInterval:refreshInterval, install:true, uninstall: true) {
|
return dynamicPage(name:"Credentials", title:"Discovery Started!", nextPage:"", refreshInterval:refreshInterval, install:true, uninstall: true) {
|
||||||
section("Please wait while we discover your Harmony Hubs and Activities. Discovery can take five minutes or more, so sit back and relax! Select your device below once discovered.") {
|
section("Please wait while we discover your Harmony Hubs and Activities. Discovery can take five minutes or more, so sit back and relax! Select your device below once discovered.") {
|
||||||
input "selectedhubs", "enum", required:false, title:"Select Harmony Hubs (${numFoundHub} found)", multiple:true, options:huboptions
|
input "selectedhubs", "enum", required:false, title:"Select Harmony Hubs (${numFoundHub} found)", multiple:true, submitOnChange: true, options:huboptions
|
||||||
}
|
}
|
||||||
// Virtual activity flag
|
// Virtual activity flag
|
||||||
if (numFoundHub > 0 && numFoundAct > 0 && true)
|
if (numFoundHub > 0 && numFoundAct > 0 && true)
|
||||||
section("You can also add activities as virtual switches for other convenient integrations") {
|
section("You can also add activities as virtual switches for other convenient integrations") {
|
||||||
input "selectedactivities", "enum", required:false, title:"Select Harmony Activities (${numFoundAct} found)", multiple:true, options:actoptions
|
input "selectedactivities", "enum", required:false, title:"Select Harmony Activities (${numFoundAct} found)", multiple:true, submitOnChange: true, options:actoptions
|
||||||
}
|
}
|
||||||
if (state.resethub)
|
if (state.resethub)
|
||||||
section("Connection to the hub timed out. Please restart the hub and try again.") {}
|
section("Connection to the hub timed out. Please restart the hub and try again.") {}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -380,8 +383,6 @@ def discovery() {
|
|||||||
log.debug "valid Token"
|
log.debug "valid Token"
|
||||||
state.Harmonydevices = response.data
|
state.Harmonydevices = response.data
|
||||||
state.resethub = false
|
state.resethub = false
|
||||||
getActivityList()
|
|
||||||
poll()
|
|
||||||
} else {
|
} else {
|
||||||
log.debug "Error: $response.status"
|
log.debug "Error: $response.status"
|
||||||
}
|
}
|
||||||
@@ -430,142 +431,182 @@ def addDevice() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
def activity(dni,mode) {
|
def activity(dni,mode) {
|
||||||
def Params = [auth: state.HarmonyAccessToken]
|
def tokenParam = [auth: state.HarmonyAccessToken]
|
||||||
def msg = "Command failed"
|
def url
|
||||||
def url = ''
|
|
||||||
if (dni == "all") {
|
if (dni == "all") {
|
||||||
url = "https://home.myharmony.com/cloudapi/activity/off?${toQueryString(Params)}"
|
url = "https://home.myharmony.com/cloudapi/activity/off?${toQueryString(tokenParam)}"
|
||||||
} else {
|
} else {
|
||||||
def aux = dni.split('-')
|
def aux = dni.split('-')
|
||||||
def hubId = aux[1]
|
def hubId = aux[1]
|
||||||
if (mode == "hub" || (aux.size() <= 2) || (aux[2] == "off")){
|
if (mode == "hub" || (aux.size() <= 2) || (aux[2] == "off")){
|
||||||
url = "https://home.myharmony.com/cloudapi/hub/${hubId}/activity/off?${toQueryString(Params)}"
|
url = "https://home.myharmony.com/cloudapi/hub/${hubId}/activity/off?${toQueryString(tokenParam)}"
|
||||||
} else {
|
} else {
|
||||||
def activityId = aux[2]
|
def activityId = aux[2]
|
||||||
url = "https://home.myharmony.com/cloudapi/hub/${hubId}/activity/${activityId}/${mode}?${toQueryString(Params)}"
|
url = "https://home.myharmony.com/cloudapi/hub/${hubId}/activity/${activityId}/${mode}?${toQueryString(tokenParam)}"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
try {
|
def params = [
|
||||||
httpPostJson(uri: url) { response ->
|
uri: url,
|
||||||
if (response.data.code == 200 || dni == "all") {
|
contentType: 'application/json'
|
||||||
msg = "Command sent succesfully"
|
]
|
||||||
state.aux = 0
|
asynchttp_v1.post('activityResponse', params)
|
||||||
} else {
|
return "Command Sent"
|
||||||
msg = "Command failed. Error: $response.data.code"
|
}
|
||||||
}
|
|
||||||
}
|
def activityResponse(response, data) {
|
||||||
} catch (groovyx.net.http.HttpResponseException ex) {
|
if (response.hasError()) {
|
||||||
log.error ex
|
log.error "Logitech Harmony - response has error: $response.errorMessage"
|
||||||
if (state.aux == 0) {
|
if (response.status == 401) { // token is expired
|
||||||
state.aux = 1
|
state.remove("HarmonyAccessToken")
|
||||||
activity(dni,mode)
|
log.warn "Logitech Harmony - Access token has expired"
|
||||||
} else {
|
|
||||||
msg = ex
|
|
||||||
state.aux = 0
|
|
||||||
}
|
|
||||||
} catch(Exception ex) {
|
|
||||||
msg = ex
|
|
||||||
}
|
}
|
||||||
runIn(10, "poll", [overwrite: true])
|
} else {
|
||||||
return msg
|
def ResponseValues
|
||||||
|
try {
|
||||||
|
// json response already parsed into JSONElement object
|
||||||
|
ResponseValues = response.json
|
||||||
|
} catch (e) {
|
||||||
|
log.error "Logitech Harmony - error parsing json from response: $e"
|
||||||
|
}
|
||||||
|
if (ResponseValues) {
|
||||||
|
if (ResponseValues.code == 200) {
|
||||||
|
log.trace "Command sent succesfully"
|
||||||
|
poll()
|
||||||
|
} else {
|
||||||
|
log.trace "Command failed. Error: $response.data.code"
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log.debug "Logitech Harmony - did not get json results from response body: $response.data"
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
def poll() {
|
def poll() {
|
||||||
// GET THE LIST OF ACTIVITIES
|
// GET THE LIST OF ACTIVITIES
|
||||||
if (state.HarmonyAccessToken) {
|
if (state.HarmonyAccessToken) {
|
||||||
getActivityList()
|
getActivityList()
|
||||||
def Params = [auth: state.HarmonyAccessToken]
|
def tokenParam = [auth: state.HarmonyAccessToken]
|
||||||
def url = "https://home.myharmony.com/cloudapi/state?${toQueryString(Params)}"
|
def params = [
|
||||||
try {
|
uri: "https://home.myharmony.com/cloudapi/state?${toQueryString(tokenParam)}",
|
||||||
httpGet(uri: url, headers: ["Accept": "application/json"]) {response ->
|
headers: ["Accept": "application/json"],
|
||||||
def map = [:]
|
contentType: 'application/json'
|
||||||
response.data.hubs.each {
|
]
|
||||||
if (it.value.message == "OK") {
|
asynchttp_v1.get('pollResponse', params)
|
||||||
map["${it.key}"] = "${it.value.response.data.currentAvActivity},${it.value.response.data.activityStatus}"
|
} else {
|
||||||
def hub = getChildDevice("harmony-${it.key}")
|
log.warn "Logitech Harmony - Access token has expired"
|
||||||
if (hub) {
|
}
|
||||||
if (it.value.response.data.currentAvActivity == "-1") {
|
}
|
||||||
hub.sendEvent(name: "currentActivity", value: "--", descriptionText: "There isn't any activity running", display: false)
|
|
||||||
} else {
|
def pollResponse(response, data) {
|
||||||
def currentActivity = getActivityName(it.value.response.data.currentAvActivity,it.key)
|
if (response.hasError()) {
|
||||||
hub.sendEvent(name: "currentActivity", value: currentActivity, descriptionText: "Current activity is ${currentActivity}", display: false)
|
log.error "Logitech Harmony - response has error: $response.errorMessage"
|
||||||
}
|
if (response.status == 401) { // token is expired
|
||||||
}
|
state.remove("HarmonyAccessToken")
|
||||||
} else {
|
log.warn "Logitech Harmony - Access token has expired"
|
||||||
log.trace it.value.message
|
}
|
||||||
}
|
} else {
|
||||||
}
|
def ResponseValues
|
||||||
def activities = getChildDevices()
|
try {
|
||||||
def activitynotrunning = true
|
// json response already parsed into JSONElement object
|
||||||
activities.each { activity ->
|
ResponseValues = response.json
|
||||||
def act = activity.deviceNetworkId.split('-')
|
} catch (e) {
|
||||||
if (act.size() > 2) {
|
log.error "Logitech Harmony - error parsing json from response: $e"
|
||||||
def aux = map.find { it.key == act[1] }
|
}
|
||||||
if (aux) {
|
if (ResponseValues) {
|
||||||
def aux2 = aux.value.split(',')
|
def map = [:]
|
||||||
def childDevice = getChildDevice(activity.deviceNetworkId)
|
ResponseValues.hubs.each {
|
||||||
if ((act[2] == aux2[0]) && (aux2[1] == "1" || aux2[1] == "2")) {
|
if (it.value.message == "OK") {
|
||||||
childDevice?.sendEvent(name: "switch", value: "on")
|
map["${it.key}"] = "${it.value.response.data.currentAvActivity},${it.value.response.data.activityStatus}"
|
||||||
if (aux2[1] == "1")
|
def hub = getChildDevice("harmony-${it.key}")
|
||||||
runIn(5, "poll", [overwrite: true])
|
if (hub) {
|
||||||
} else {
|
if (it.value.response.data.currentAvActivity == "-1") {
|
||||||
childDevice?.sendEvent(name: "switch", value: "off")
|
hub.sendEvent(name: "currentActivity", value: "--", descriptionText: "There isn't any activity running", display: false)
|
||||||
if (aux2[1] == "3")
|
} else {
|
||||||
runIn(5, "poll", [overwrite: true])
|
def currentActivity = getChildDevice("harmony-${it.key}-${it.value.response.data.currentAvActivity}").device.displayName
|
||||||
}
|
hub.sendEvent(name: "currentActivity", value: currentActivity, descriptionText: "Current activity is ${currentActivity}", display: false)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log.trace "Logitech Harmony - error response: $it.value.message"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
def activities = getChildDevices()
|
||||||
|
def activitynotrunning = true
|
||||||
|
activities.each { activity ->
|
||||||
|
def act = activity.deviceNetworkId.split('-')
|
||||||
|
if (act.size() > 2) {
|
||||||
|
def aux = map.find { it.key == act[1] }
|
||||||
|
if (aux) {
|
||||||
|
def aux2 = aux.value.split(',')
|
||||||
|
def childDevice = getChildDevice(activity.deviceNetworkId)
|
||||||
|
if ((act[2] == aux2[0]) && (aux2[1] == "1" || aux2[1] == "2")) {
|
||||||
|
childDevice?.sendEvent(name: "switch", value: "on")
|
||||||
|
if (aux2[1] == "1")
|
||||||
|
runIn(5, "poll", [overwrite: true])
|
||||||
|
} else {
|
||||||
|
childDevice?.sendEvent(name: "switch", value: "off")
|
||||||
|
if (aux2[1] == "3")
|
||||||
|
runIn(5, "poll", [overwrite: true])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return "Poll completed $map - $state.hubs"
|
|
||||||
}
|
}
|
||||||
} catch (groovyx.net.http.HttpResponseException e) {
|
|
||||||
if (e.statusCode == 401) { // token is expired
|
|
||||||
state.remove("HarmonyAccessToken")
|
|
||||||
log.warn "Harmony Access token has expired"
|
|
||||||
}
|
|
||||||
} catch (java.net.SocketTimeoutException e) {
|
|
||||||
log.warn "Connection to the hub timed out. Please restart the hub and try again."
|
|
||||||
state.resethub = true
|
|
||||||
} catch (e) {
|
|
||||||
log.info "Logitech Harmony - Error: $e"
|
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
log.debug "Logitech Harmony - did not get json results from response body: $response.data"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def getActivityList() {
|
||||||
|
if (state.HarmonyAccessToken) {
|
||||||
|
def tokenParam = [auth: state.HarmonyAccessToken]
|
||||||
|
def params = [
|
||||||
|
uri: "https://home.myharmony.com/cloudapi/activity/all?${toQueryString(tokenParam)}",
|
||||||
|
headers: ["Accept": "application/json"],
|
||||||
|
contentType: 'application/json'
|
||||||
|
]
|
||||||
|
asynchttp_v1.get('activityListResponse', params)
|
||||||
|
} else {
|
||||||
|
log.warn "Logitech Harmony - Access token has expired"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
def activityListResponse(response, data) {
|
||||||
def getActivityList() {
|
if (response.hasError()) {
|
||||||
// GET ACTIVITY'S NAME
|
log.error "Logitech Harmony - response has error: $response.errorMessage"
|
||||||
if (state.HarmonyAccessToken) {
|
if (response.status == 401) { // token is expired
|
||||||
def Params = [auth: state.HarmonyAccessToken]
|
state.remove("HarmonyAccessToken")
|
||||||
def url = "https://home.myharmony.com/cloudapi/activity/all?${toQueryString(Params)}"
|
log.warn "Logitech Harmony - Access token has expired"
|
||||||
try {
|
}
|
||||||
httpGet(uri: url, headers: ["Accept": "application/json"]) {response ->
|
} else {
|
||||||
response.data.hubs.each {
|
def ResponseValues
|
||||||
def hub = getChildDevice("harmony-${it.key}")
|
try {
|
||||||
if (hub) {
|
// json response already parsed into JSONElement object
|
||||||
def hubname = getHubName("${it.key}")
|
ResponseValues = response.json
|
||||||
def activities = []
|
} catch (e) {
|
||||||
def aux = it.value.response.data.activities.size()
|
log.error "Logitech Harmony - error parsing json from response: $e"
|
||||||
if (aux >= 1) {
|
}
|
||||||
activities = it.value.response.data.activities.collect {
|
if (ResponseValues) {
|
||||||
[id: it.key, name: it.value['name'], type: it.value['type']]
|
ResponseValues.hubs.each {
|
||||||
}
|
def hub = getChildDevice("harmony-${it.key}")
|
||||||
activities += [id: "off", name: "Activity OFF", type: "0"]
|
if (hub) {
|
||||||
log.trace activities
|
def hubname = getHubName("${it.key}")
|
||||||
}
|
def activities = []
|
||||||
hub.sendEvent(name: "activities", value: new groovy.json.JsonBuilder(activities).toString(), descriptionText: "Activities are ${activities.collect { it.name }?.join(', ')}", display: false)
|
def aux = it.value.response?.data.activities.size()
|
||||||
}
|
if (aux >= 1) {
|
||||||
}
|
activities = it.value.response.data.activities.collect {
|
||||||
}
|
[id: it.key, name: it.value['name'], type: it.value['type']]
|
||||||
} catch (groovyx.net.http.HttpResponseException e) {
|
}
|
||||||
log.trace e
|
activities += [id: "off", name: "Activity OFF", type: "0"]
|
||||||
} catch (java.net.SocketTimeoutException e) {
|
log.trace activities
|
||||||
log.trace e
|
}
|
||||||
} catch(Exception e) {
|
hub.sendEvent(name: "activities", value: new groovy.json.JsonBuilder(activities).toString(), descriptionText: "Activities are ${activities.collect { it.name }?.join(', ')}", display: false)
|
||||||
log.trace e
|
}
|
||||||
}
|
}
|
||||||
}
|
} else {
|
||||||
return activity
|
log.debug "Logitech Harmony - did not get json results from response body: $response.data"
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
def getActivityName(activity,hubId) {
|
def getActivityName(activity,hubId) {
|
||||||
@@ -746,7 +787,7 @@ def addSubscription() {
|
|||||||
def attribute = data.attributeName
|
def attribute = data.attributeName
|
||||||
def callbackUrl = data.callbackUrl
|
def callbackUrl = data.callbackUrl
|
||||||
|
|
||||||
log.debug "addSubscription, params: ${params}, request: ${data}"
|
log.debug "Logitech Harmony - addSubscription, params: ${params}, request: ${data}"
|
||||||
if (!attribute) {
|
if (!attribute) {
|
||||||
render status: 400, data: '{"msg": "attributeName is required"}'
|
render status: 400, data: '{"msg": "attributeName is required"}'
|
||||||
} else {
|
} else {
|
||||||
@@ -808,6 +849,7 @@ def deviceHandler(evt) {
|
|||||||
def deviceInfo = state[evt.deviceId]
|
def deviceInfo = state[evt.deviceId]
|
||||||
if (state.harmonyHubs) {
|
if (state.harmonyHubs) {
|
||||||
state.harmonyHubs.each { harmonyHub ->
|
state.harmonyHubs.each { harmonyHub ->
|
||||||
|
log.trace "Logitech Harmony - Sending data to $harmonyHub.name"
|
||||||
sendToHarmony(evt, harmonyHub.callbackUrl)
|
sendToHarmony(evt, harmonyHub.callbackUrl)
|
||||||
}
|
}
|
||||||
} else if (deviceInfo) {
|
} else if (deviceInfo) {
|
||||||
|
|||||||
@@ -26,17 +26,22 @@ definition(
|
|||||||
)
|
)
|
||||||
|
|
||||||
preferences {
|
preferences {
|
||||||
section ("In addition to push notifications, send text alerts to...") {
|
|
||||||
input("recipients", "contact", title: "Send notifications to") {
|
if (!(location.zipCode || ( location.latitude && location.longitude )) && location.channelName == 'samsungtv') {
|
||||||
input "phone1", "phone", title: "Phone Number 1", required: false
|
section { paragraph title: "Note:", "Location is required for this SmartApp. Go to 'Location Name' settings to setup your correct location." }
|
||||||
input "phone2", "phone", title: "Phone Number 2", required: false
|
|
||||||
input "phone3", "phone", title: "Phone Number 3", required: false
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
section ("Zip code (optional, defaults to location coordinates)...") {
|
if (location.channelName != 'samsungtv') {
|
||||||
input "zipcode", "text", title: "Zip Code", required: false
|
section( "Set your location" ) { input "zipCode", "text", title: "Zip code" }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
section ("In addition to push notifications, send text alerts to...") {
|
||||||
|
input("recipients", "contact", title: "Send notifications to") {
|
||||||
|
input "phone1", "phone", title: "Phone Number 1", required: false
|
||||||
|
input "phone2", "phone", title: "Phone Number 2", required: false
|
||||||
|
input "phone3", "phone", title: "Phone Number 3", required: false
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
def installed() {
|
def installed() {
|
||||||
@@ -61,7 +66,7 @@ def checkForSevereWeather() {
|
|||||||
def alerts
|
def alerts
|
||||||
if(locationIsDefined()) {
|
if(locationIsDefined()) {
|
||||||
if(zipcodeIsValid()) {
|
if(zipcodeIsValid()) {
|
||||||
alerts = getWeatherFeature("alerts", zipcode)?.alerts
|
alerts = getWeatherFeature("alerts", zipCode)?.alerts
|
||||||
} else {
|
} else {
|
||||||
log.warn "Severe Weather Alert: Invalid zipcode entered, defaulting to location's zipcode"
|
log.warn "Severe Weather Alert: Invalid zipcode entered, defaulting to location's zipcode"
|
||||||
alerts = getWeatherFeature("alerts")?.alerts
|
alerts = getWeatherFeature("alerts")?.alerts
|
||||||
|
|||||||
Reference in New Issue
Block a user