mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-23 05:10:50 +00:00
Compare commits
8 Commits
MSA-1494-2
...
DEVC-489-1
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
22bbe08d0c | ||
|
|
218cc43520 | ||
|
|
9ddc020f04 | ||
|
|
9fbbaec8f6 | ||
|
|
e4c1824afd | ||
|
|
797a58cb68 | ||
|
|
c428267d63 | ||
|
|
230541a145 |
@@ -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) {
|
||||||
|
|||||||
@@ -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'
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,6 +21,7 @@ metadata {
|
|||||||
|
|
||||||
fingerprint profileId: "0104", inClusters: "0000, 0003, 0004, 0005, 0006"
|
fingerprint profileId: "0104", inClusters: "0000, 0003, 0004, 0005, 0006"
|
||||||
fingerprint profileId: "0104", inClusters: "0000, 0003, 0006", outClusters: "0003, 0006, 0019, 0406", manufacturer: "Leviton", model: "ZSS-10", deviceJoinName: "Leviton Switch"
|
fingerprint profileId: "0104", inClusters: "0000, 0003, 0006", outClusters: "0003, 0006, 0019, 0406", manufacturer: "Leviton", model: "ZSS-10", deviceJoinName: "Leviton Switch"
|
||||||
|
fingerprint profileId: "0104", inClusters: "0000, 0003, 0006", outClusters: "000A", manufacturer: "HAI", model: "65A21-1", deviceJoinName: "Leviton Wireless Load Control Module-30amp"
|
||||||
}
|
}
|
||||||
|
|
||||||
// simulator metadata
|
// simulator metadata
|
||||||
@@ -79,4 +80,4 @@ def refresh() {
|
|||||||
def configure() {
|
def configure() {
|
||||||
log.debug "Configuring Reporting and Bindings."
|
log.debug "Configuring Reporting and Bindings."
|
||||||
zigbee.onOffConfig() + zigbee.onOffRefresh()
|
zigbee.onOffConfig() + zigbee.onOffRefresh()
|
||||||
}
|
}
|
||||||
@@ -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() {
|
||||||
|
|||||||
@@ -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) {
|
||||||
|
|||||||
@@ -1,800 +0,0 @@
|
|||||||
/**
|
|
||||||
* Home Remote
|
|
||||||
*
|
|
||||||
* Copyright 2015 The Home Remote
|
|
||||||
*
|
|
||||||
* 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: "Home Remote",
|
|
||||||
namespace: "thehomeremote.homeremote",
|
|
||||||
author: "The Home Remote",
|
|
||||||
description: "Web service that enables communication between the Home Remote app and a SmartThings hub.",
|
|
||||||
category: "My Apps",
|
|
||||||
iconUrl: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience.png",
|
|
||||||
iconX2Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png",
|
|
||||||
iconX3Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png",
|
|
||||||
oauth: [displayName: "The Home Remote", displayLink: "http://thehomeremote.com/"])
|
|
||||||
|
|
||||||
|
|
||||||
preferences {
|
|
||||||
section() {
|
|
||||||
input "accelerationSensors", "capability.accelerationSensor",title: "Acceleration Sensors", multiple: true, required: false
|
|
||||||
input "alarms", "capability.alarm",title: "Alarms", multiple: true, required: false
|
|
||||||
input "batteries", "capability.battery",title: "Batteries", multiple: true, required: false
|
|
||||||
input "beacons", "capability.beacon",title: "Beacons", multiple: true, required: false
|
|
||||||
input "buttonGroup", "capability.button",title: "Buttons", multiple: true, required: false
|
|
||||||
input "carbonMonoxideDetectors", "capability.carbonMonoxideDetector",title: "CO Detectors", multiple: true, required: false
|
|
||||||
input "colorControls", "capability.colorControl",title: "Color Lights", multiple: true, required: false
|
|
||||||
input "contactSensors", "capability.contactSensor",title: "Contact Sensors", multiple: true, required: false
|
|
||||||
input "doorControls", "capability.doorControl",title: "Door Controllers", multiple: true, required: false
|
|
||||||
input "energyMeters", "capability.energyMeter",title: "Energy Meters", multiple: true, required: false
|
|
||||||
input "illuminanceMeasurements", "capability.illuminanceMeasurement",title: "Illuminance Sensors", multiple: true, required: false
|
|
||||||
input "imageCaptures", "capability.imageCapture",title: "Cameras", multiple: true, required: false
|
|
||||||
input "locks", "capability.lock",title: "Locks", multiple: true, required: false
|
|
||||||
input "mediaControllers", "capability.mediaController",title: "Media Controllers", multiple: true, required: false
|
|
||||||
input "momentaries", "capability.momentary",title: "Momentary Buttons", multiple: true, required: false
|
|
||||||
input "motionSensors", "capability.motionSensor",title: "Motion Sensors", multiple: true, required: false
|
|
||||||
input "musicPlayers", "capability.musicPlayer",title: "Music Players", multiple: true, required: false
|
|
||||||
input "powerMeters", "capability.powerMeter",title: "Power Meters", multiple: true, required: false
|
|
||||||
input "presenceSensors", "capability.presenceSensor",title: "Presence Sensors", multiple: true, required: false
|
|
||||||
input "relativeHumidityMeasurements", "capability.relativeHumidityMeasurement",title: "Humidity Sensors", multiple: true, required: false
|
|
||||||
input "relaySwitches", "capability.relaySwitch",title: "Relays", multiple: true, required: false
|
|
||||||
input "signalStrengths", "capability.signalStrength",title: "Signal Strengths", multiple: true, required: false
|
|
||||||
input "sleepSensors", "capability.sleepSensor",title: "Sleep Sensors", multiple: true, required: false
|
|
||||||
input "smokeDetectors", "capability.smokeDetector",title: "Smoke Detectors", multiple: true, required: false
|
|
||||||
input "speechSyntheses", "capability.speechSynthesis",title: "Speech Syntheses", multiple: true, required: false
|
|
||||||
input "stepSensors", "capability.stepSensor",title: "Step Sensors", multiple: true, required: false
|
|
||||||
input "switches", "capability.switch",title: "Switches", multiple: true, required: false
|
|
||||||
input "switchLevels", "capability.switchLevel",title: "Dimmers", multiple: true, required: false
|
|
||||||
input "temperatureMeasurements", "capability.temperatureMeasurement",title: "Temperature Sensors", multiple: true, required: false
|
|
||||||
input "thermostats", "capability.thermostat",title: "Thermostats", multiple: true, required: false
|
|
||||||
input "threeAxes", "capability.threeAxis",title: "Three axis Sensors", multiple: true, required: false
|
|
||||||
input "tones", "capability.tone",title: "Tones", multiple: true, required: false
|
|
||||||
input "touchSensors", "capability.touchSensor",title: "Touch Sensors", multiple: true, required: false
|
|
||||||
input "valves", "capability.valve",title: "Valves", multiple: true, required: false
|
|
||||||
input "waterSensors", "capability.waterSensor",title: "Water Sensors", multiple: true, required: false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
mappings {
|
|
||||||
path("/GetCurrentValues") {
|
|
||||||
action: [
|
|
||||||
GET: "getCurrentValues"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
path("/GetCurrentValuesWithDisplayName") {
|
|
||||||
action: [
|
|
||||||
GET: "getCurrentValuesWithDisplayName"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
path("/GetRoutines") {
|
|
||||||
action: [
|
|
||||||
GET: "getRoutines"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
path("/ExecuteCommand") {
|
|
||||||
action: [
|
|
||||||
PUT: "executeCommand"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
path("/ExecuteRoutine") {
|
|
||||||
action: [
|
|
||||||
PUT: "executeRoutine"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def getCurrentValues() {
|
|
||||||
def resp = []
|
|
||||||
|
|
||||||
accelerationSensors.each {
|
|
||||||
resp << [id: it.id, capability: "AccelerationSensor", attribute: "acceleration", value: it.currentValue("acceleration")]
|
|
||||||
}
|
|
||||||
|
|
||||||
alarms.each {
|
|
||||||
resp << [id: it.id, capability: "Alarm", attribute: "alarm", value: it.currentValue("alarm")]
|
|
||||||
}
|
|
||||||
|
|
||||||
batteries.each {
|
|
||||||
resp << [id: it.id, capability: "Battery", attribute: "battery", value: it.currentValue("battery")]
|
|
||||||
}
|
|
||||||
|
|
||||||
beacons.each {
|
|
||||||
resp << [id: it.id, capability: "Beacon", attribute: "presence", value: it.currentValue("presence")]
|
|
||||||
}
|
|
||||||
|
|
||||||
buttonGroup.each {
|
|
||||||
resp << [id: it.id, capability: "Button", attribute: "button", value: it.currentValue("button")]
|
|
||||||
}
|
|
||||||
|
|
||||||
carbonMonoxideDetectors.each {
|
|
||||||
resp << [id: it.id, capability: "CarbonMonoxideDetector", attribute: "carbonMonoxide", value: it.currentValue("carbonMonoxide")]
|
|
||||||
}
|
|
||||||
|
|
||||||
colorControls.each {
|
|
||||||
resp << [id: it.id, capability: "ColorControl", attribute: "hue", value: it.currentValue("hue")]
|
|
||||||
}
|
|
||||||
|
|
||||||
colorControls.each {
|
|
||||||
resp << [id: it.id, capability: "ColorControl", attribute: "saturation", value: it.currentValue("saturation")]
|
|
||||||
}
|
|
||||||
|
|
||||||
colorControls.each {
|
|
||||||
resp << [id: it.id, capability: "ColorControl", attribute: "color", value: it.currentValue("color")]
|
|
||||||
}
|
|
||||||
|
|
||||||
contactSensors.each {
|
|
||||||
resp << [id: it.id, capability: "ContactSensor", attribute: "contact", value: it.currentValue("contact")]
|
|
||||||
}
|
|
||||||
|
|
||||||
doorControls.each {
|
|
||||||
resp << [id: it.id, capability: "DoorControl", attribute: "door", value: it.currentValue("door")]
|
|
||||||
}
|
|
||||||
|
|
||||||
energyMeters.each {
|
|
||||||
resp << [id: it.id, capability: "EnergyMeter", attribute: "energy", value: it.currentValue("energy")]
|
|
||||||
}
|
|
||||||
|
|
||||||
illuminanceMeasurements.each {
|
|
||||||
resp << [id: it.id, capability: "IlluminanceMeasurement", attribute: "illuminance", value: it.currentValue("illuminance")]
|
|
||||||
}
|
|
||||||
|
|
||||||
imageCaptures.each {
|
|
||||||
resp << [id: it.id, capability: "ImageCapture", attribute: "image", value: it.currentValue("image")]
|
|
||||||
}
|
|
||||||
|
|
||||||
locks.each {
|
|
||||||
resp << [id: it.id, capability: "Lock", attribute: "lock", value: it.currentValue("lock")]
|
|
||||||
}
|
|
||||||
|
|
||||||
mediaControllers.each {
|
|
||||||
resp << [id: it.id, capability: "MediaController", attribute: "activities", value: it.currentValue("activities")]
|
|
||||||
}
|
|
||||||
|
|
||||||
mediaControllers.each {
|
|
||||||
resp << [id: it.id, capability: "MediaController", attribute: "currentActivity", value: it.currentValue("currentActivity")]
|
|
||||||
}
|
|
||||||
|
|
||||||
motionSensors.each {
|
|
||||||
resp << [id: it.id, capability: "MotionSensor", attribute: "motion", value: it.currentValue("motion")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, capability: "MusicPlayer", attribute: "status", value: it.currentValue("status")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, capability: "MusicPlayer", attribute: "level", value: it.currentValue("level")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, capability: "MusicPlayer", attribute: "trackDescription", value: it.currentValue("trackDescription")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, capability: "MusicPlayer", attribute: "trackData", value: it.currentValue("trackData")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, capability: "MusicPlayer", attribute: "mute", value: it.currentValue("mute")]
|
|
||||||
}
|
|
||||||
|
|
||||||
powerMeters.each {
|
|
||||||
resp << [id: it.id, capability: "PowerMeter", attribute: "power", value: it.currentValue("power")]
|
|
||||||
}
|
|
||||||
|
|
||||||
presenceSensors.each {
|
|
||||||
resp << [id: it.id, capability: "PresenceSensor", attribute: "presence", value: it.currentValue("presence")]
|
|
||||||
}
|
|
||||||
|
|
||||||
relativeHumidityMeasurements.each {
|
|
||||||
resp << [id: it.id, capability: "RelativeHumidityMeasurement", attribute: "humidity", value: it.currentValue("humidity")]
|
|
||||||
}
|
|
||||||
|
|
||||||
relaySwitches.each {
|
|
||||||
resp << [id: it.id, capability: "RelaySwitch", attribute: "switch", value: it.currentValue("switch")]
|
|
||||||
}
|
|
||||||
|
|
||||||
signalStrengths.each {
|
|
||||||
resp << [id: it.id, capability: "SignalStrength", attribute: "lqi", value: it.currentValue("lqi")]
|
|
||||||
}
|
|
||||||
|
|
||||||
signalStrengths.each {
|
|
||||||
resp << [id: it.id, capability: "SignalStrength", attribute: "rssi", value: it.currentValue("rssi")]
|
|
||||||
}
|
|
||||||
|
|
||||||
sleepSensors.each {
|
|
||||||
resp << [id: it.id, capability: "SleepSensor", attribute: "sleeping", value: it.currentValue("sleeping")]
|
|
||||||
}
|
|
||||||
|
|
||||||
smokeDetectors.each {
|
|
||||||
resp << [id: it.id, capability: "SmokeDetector", attribute: "smoke", value: it.currentValue("smoke")]
|
|
||||||
}
|
|
||||||
|
|
||||||
stepSensors.each {
|
|
||||||
resp << [id: it.id, capability: "StepSensor", attribute: "steps", value: it.currentValue("steps")]
|
|
||||||
}
|
|
||||||
|
|
||||||
stepSensors.each {
|
|
||||||
resp << [id: it.id, capability: "StepSensor", attribute: "goal", value: it.currentValue("goal")]
|
|
||||||
}
|
|
||||||
|
|
||||||
switches.each {
|
|
||||||
resp << [id: it.id, capability: "Switch", attribute: "switch", value: it.currentValue("switch")]
|
|
||||||
}
|
|
||||||
|
|
||||||
switchLevels.each {
|
|
||||||
resp << [id: it.id, capability: "SwitchLevel", attribute: "level", value: it.currentValue("level")]
|
|
||||||
}
|
|
||||||
|
|
||||||
temperatureMeasurements.each {
|
|
||||||
resp << [id: it.id, capability: "TemperatureMeasurement", attribute: "temperature", value: it.currentValue("temperature")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, capability: "Thermostat", attribute: "temperature", value: it.currentValue("temperature")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, capability: "Thermostat", attribute: "heatingSetpoint", value: it.currentValue("heatingSetpoint")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, capability: "Thermostat", attribute: "coolingSetpoint", value: it.currentValue("coolingSetpoint")]
|
|
||||||
}
|
|
||||||
|
|
||||||
//Commented out on 7/23/2016. This randomly started throwing number format exceptions with either my ecobee or Lyric thermostat.
|
|
||||||
//thermostats.each {
|
|
||||||
// resp << [id: it.id, capability: "Thermostat", attribute: "thermostatSetpoint", value: it.currentValue("thermostatSetpoint")]
|
|
||||||
//}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, capability: "Thermostat", attribute: "thermostatMode", value: it.currentValue("thermostatMode")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, capability: "Thermostat", attribute: "thermostatFanMode", value: it.currentValue("thermostatFanMode")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, capability: "Thermostat", attribute: "thermostatOperatingState", value: it.currentValue("thermostatOperatingState")]
|
|
||||||
}
|
|
||||||
|
|
||||||
threeAxes.each {
|
|
||||||
resp << [id: it.id, capability: "ThreeAxis", attribute: "threeAxis", value: it.currentValue("threeAxis")]
|
|
||||||
}
|
|
||||||
|
|
||||||
touchSensors.each {
|
|
||||||
resp << [id: it.id, capability: "TouchSensor", attribute: "touch", value: it.currentValue("touch")]
|
|
||||||
}
|
|
||||||
|
|
||||||
valves.each {
|
|
||||||
resp << [id: it.id, capability: "Valve", attribute: "contact", value: it.currentValue("contact")]
|
|
||||||
}
|
|
||||||
|
|
||||||
waterSensors.each {
|
|
||||||
resp << [id: it.id, capability: "WaterSensor", attribute: "water", value: it.currentValue("water")]
|
|
||||||
}
|
|
||||||
|
|
||||||
//resp << [id: 0, capability: "Heartbeat", attribute: "heartbeat", value: String.valueOf(state.heartbeat)]
|
|
||||||
|
|
||||||
state.heartbeat = !state.heartbeat
|
|
||||||
|
|
||||||
return resp
|
|
||||||
}
|
|
||||||
|
|
||||||
def getCurrentValuesWithDisplayName() {
|
|
||||||
def resp = []
|
|
||||||
|
|
||||||
accelerationSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "AccelerationSensor", attribute: "acceleration", value: it.currentValue("acceleration")]
|
|
||||||
}
|
|
||||||
|
|
||||||
alarms.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Alarm", attribute: "alarm", value: it.currentValue("alarm")]
|
|
||||||
}
|
|
||||||
|
|
||||||
batteries.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Battery", attribute: "battery", value: it.currentValue("battery")]
|
|
||||||
}
|
|
||||||
|
|
||||||
beacons.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Beacon", attribute: "presence", value: it.currentValue("presence")]
|
|
||||||
}
|
|
||||||
|
|
||||||
buttonGroup.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Button", attribute: "button", value: it.currentValue("button")]
|
|
||||||
}
|
|
||||||
|
|
||||||
carbonMonoxideDetectors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "CarbonMonoxideDetector", attribute: "carbonMonoxide", value: it.currentValue("carbonMonoxide")]
|
|
||||||
}
|
|
||||||
|
|
||||||
colorControls.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "ColorControl", attribute: "hue", value: it.currentValue("hue")]
|
|
||||||
}
|
|
||||||
|
|
||||||
colorControls.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "ColorControl", attribute: "saturation", value: it.currentValue("saturation")]
|
|
||||||
}
|
|
||||||
|
|
||||||
colorControls.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "ColorControl", attribute: "color", value: it.currentValue("color")]
|
|
||||||
}
|
|
||||||
|
|
||||||
contactSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "ContactSensor", attribute: "contact", value: it.currentValue("contact")]
|
|
||||||
}
|
|
||||||
|
|
||||||
doorControls.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "DoorControl", attribute: "door", value: it.currentValue("door")]
|
|
||||||
}
|
|
||||||
|
|
||||||
energyMeters.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "EnergyMeter", attribute: "energy", value: it.currentValue("energy")]
|
|
||||||
}
|
|
||||||
|
|
||||||
illuminanceMeasurements.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "IlluminanceMeasurement", attribute: "illuminance", value: it.currentValue("illuminance")]
|
|
||||||
}
|
|
||||||
|
|
||||||
imageCaptures.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "ImageCapture", attribute: "image", value: it.currentValue("image")]
|
|
||||||
}
|
|
||||||
|
|
||||||
locks.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Lock", attribute: "lock", value: it.currentValue("lock")]
|
|
||||||
}
|
|
||||||
|
|
||||||
mediaControllers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MediaController", attribute: "activities", value: it.currentValue("activities")]
|
|
||||||
}
|
|
||||||
|
|
||||||
mediaControllers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MediaController", attribute: "currentActivity", value: it.currentValue("currentActivity")]
|
|
||||||
}
|
|
||||||
|
|
||||||
motionSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MotionSensor", attribute: "motion", value: it.currentValue("motion")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MusicPlayer", attribute: "status", value: it.currentValue("status")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MusicPlayer", attribute: "level", value: it.currentValue("level")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MusicPlayer", attribute: "trackDescription", value: it.currentValue("trackDescription")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MusicPlayer", attribute: "trackData", value: it.currentValue("trackData")]
|
|
||||||
}
|
|
||||||
|
|
||||||
musicPlayers.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "MusicPlayer", attribute: "mute", value: it.currentValue("mute")]
|
|
||||||
}
|
|
||||||
|
|
||||||
powerMeters.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "PowerMeter", attribute: "power", value: it.currentValue("power")]
|
|
||||||
}
|
|
||||||
|
|
||||||
presenceSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "PresenceSensor", attribute: "presence", value: it.currentValue("presence")]
|
|
||||||
}
|
|
||||||
|
|
||||||
relativeHumidityMeasurements.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "RelativeHumidityMeasurement", attribute: "humidity", value: it.currentValue("humidity")]
|
|
||||||
}
|
|
||||||
|
|
||||||
relaySwitches.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "RelaySwitch", attribute: "switch", value: it.currentValue("switch")]
|
|
||||||
}
|
|
||||||
|
|
||||||
signalStrengths.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "SignalStrength", attribute: "lqi", value: it.currentValue("lqi")]
|
|
||||||
}
|
|
||||||
|
|
||||||
signalStrengths.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "SignalStrength", attribute: "rssi", value: it.currentValue("rssi")]
|
|
||||||
}
|
|
||||||
|
|
||||||
sleepSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "SleepSensor", attribute: "sleeping", value: it.currentValue("sleeping")]
|
|
||||||
}
|
|
||||||
|
|
||||||
smokeDetectors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "SmokeDetector", attribute: "smoke", value: it.currentValue("smoke")]
|
|
||||||
}
|
|
||||||
|
|
||||||
stepSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "StepSensor", attribute: "steps", value: it.currentValue("steps")]
|
|
||||||
}
|
|
||||||
|
|
||||||
stepSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "StepSensor", attribute: "goal", value: it.currentValue("goal")]
|
|
||||||
}
|
|
||||||
|
|
||||||
switches.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Switch", attribute: "switch", value: it.currentValue("switch")]
|
|
||||||
}
|
|
||||||
|
|
||||||
switchLevels.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "SwitchLevel", attribute: "level", value: it.currentValue("level")]
|
|
||||||
}
|
|
||||||
|
|
||||||
temperatureMeasurements.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "TemperatureMeasurement", attribute: "temperature", value: it.currentValue("temperature")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "temperature", value: it.currentValue("temperature")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "heatingSetpoint", value: it.currentValue("heatingSetpoint")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "coolingSetpoint", value: it.currentValue("coolingSetpoint")]
|
|
||||||
}
|
|
||||||
|
|
||||||
//Commented out on 7/23/2016. This randomly started throwing number format exceptions with either my ecobee or Lyric thermostat.
|
|
||||||
//thermostats.each {
|
|
||||||
// resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "thermostatSetpoint", value: it.currentValue("thermostatSetpoint")]
|
|
||||||
//}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "thermostatMode", value: it.currentValue("thermostatMode")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "thermostatFanMode", value: it.currentValue("thermostatFanMode")]
|
|
||||||
}
|
|
||||||
|
|
||||||
thermostats.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Thermostat", attribute: "thermostatOperatingState", value: it.currentValue("thermostatOperatingState")]
|
|
||||||
}
|
|
||||||
|
|
||||||
threeAxes.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "ThreeAxis", attribute: "threeAxis", value: it.currentValue("threeAxis")]
|
|
||||||
}
|
|
||||||
|
|
||||||
touchSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "TouchSensor", attribute: "touch", value: it.currentValue("touch")]
|
|
||||||
}
|
|
||||||
|
|
||||||
valves.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Valve", attribute: "contact", value: it.currentValue("contact")]
|
|
||||||
}
|
|
||||||
|
|
||||||
waterSensors.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "WaterSensor", attribute: "water", value: it.currentValue("water")]
|
|
||||||
}
|
|
||||||
|
|
||||||
momentaries.each {
|
|
||||||
resp << [id: it.id, displayName: it.displayName, capability: "Momentary", attribute: "", value: ""]
|
|
||||||
}
|
|
||||||
|
|
||||||
//resp << [id: 0, displayName: "Heartbeat", capability: "Heartbeat", attribute: "heartbeat", value: state.heartbeat]
|
|
||||||
|
|
||||||
return resp
|
|
||||||
}
|
|
||||||
|
|
||||||
def getDevices(capability){
|
|
||||||
|
|
||||||
def result
|
|
||||||
|
|
||||||
switch (capability) {
|
|
||||||
case "Alarm":
|
|
||||||
result = alarms
|
|
||||||
break
|
|
||||||
case "ColorControl":
|
|
||||||
result = colorControls
|
|
||||||
break
|
|
||||||
case "DoorControl":
|
|
||||||
result = doorControls
|
|
||||||
break
|
|
||||||
case "ImageCapture":
|
|
||||||
result = imageCaptures
|
|
||||||
break
|
|
||||||
case "Lock":
|
|
||||||
result = locks
|
|
||||||
break
|
|
||||||
case "MediaController":
|
|
||||||
result = mediaControllers
|
|
||||||
break
|
|
||||||
case "Momentary":
|
|
||||||
result = momentaries
|
|
||||||
break
|
|
||||||
case "MusicPlayer":
|
|
||||||
result = musicPlayers
|
|
||||||
break
|
|
||||||
case "RelaySwitch":
|
|
||||||
result = relaySwitches
|
|
||||||
break
|
|
||||||
case "SpeechSynthesis":
|
|
||||||
result = speechSyntheses
|
|
||||||
break
|
|
||||||
case "Switch":
|
|
||||||
result = switches
|
|
||||||
break
|
|
||||||
case "SwitchLevel":
|
|
||||||
result = switchLevels
|
|
||||||
break
|
|
||||||
case "Thermostat":
|
|
||||||
result = thermostats
|
|
||||||
break
|
|
||||||
case "ThermostatCoolingSetpoint":
|
|
||||||
result = thermostatCoolingSetpoints
|
|
||||||
break
|
|
||||||
case "ThermostatFanMode":
|
|
||||||
result = thermostatFanModes
|
|
||||||
break
|
|
||||||
case "ThermostatHeatingSetpoint":
|
|
||||||
result = thermostatHeatingSetpoints
|
|
||||||
break
|
|
||||||
case "ThermostatMode":
|
|
||||||
result = thermostatModes
|
|
||||||
break
|
|
||||||
case "Tone":
|
|
||||||
result = tones
|
|
||||||
break
|
|
||||||
case "Valve":
|
|
||||||
result = valves
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
result = valves
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
|
|
||||||
def getDoorControlCommand(value){
|
|
||||||
def result
|
|
||||||
switch (value) {
|
|
||||||
case "closed":
|
|
||||||
result = "close"
|
|
||||||
break
|
|
||||||
case "open":
|
|
||||||
result = "open"
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
result = value
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
|
|
||||||
def getLockCommand(value){
|
|
||||||
def result
|
|
||||||
switch (value) {
|
|
||||||
case "locked":
|
|
||||||
result = "lock"
|
|
||||||
break
|
|
||||||
case "unlocked":
|
|
||||||
result = "unlock"
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
result = value
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
|
|
||||||
def getMuteCommand(value){
|
|
||||||
def result
|
|
||||||
switch (value) {
|
|
||||||
case "muted":
|
|
||||||
result = "mute"
|
|
||||||
break
|
|
||||||
case "unmuted":
|
|
||||||
result = "unmute"
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
result = value
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
|
|
||||||
def getContactCommand(value){
|
|
||||||
def result
|
|
||||||
switch (value) {
|
|
||||||
case "closed":
|
|
||||||
result = "close"
|
|
||||||
break
|
|
||||||
case "open":
|
|
||||||
result = "open"
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
result = value
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
|
|
||||||
def getRoutines() {
|
|
||||||
return location.helloHome?.getPhrases()*.label
|
|
||||||
}
|
|
||||||
|
|
||||||
def getThermostatFanModeCommand(value){
|
|
||||||
def result
|
|
||||||
switch (value) {
|
|
||||||
case "on":
|
|
||||||
result = "fanOn"
|
|
||||||
break
|
|
||||||
case "auto":
|
|
||||||
result = "fanAuto"
|
|
||||||
break
|
|
||||||
case "circulate":
|
|
||||||
result = "fanCirculate"
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
result = value
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
|
|
||||||
void executeCommand() {
|
|
||||||
def deviceId = request.JSON?.deviceId
|
|
||||||
def capability = request.JSON?.capability
|
|
||||||
def attribute = request.JSON?.attribute
|
|
||||||
def value = request.JSON?.value
|
|
||||||
if (deviceId) {
|
|
||||||
def devices = getDevices(capability)
|
|
||||||
def command
|
|
||||||
def valueIsParameter = false
|
|
||||||
def valueIsInteger = false
|
|
||||||
switch (attribute) {
|
|
||||||
case "hue":
|
|
||||||
command = "setHue"
|
|
||||||
valueIsParameter = true
|
|
||||||
valueIsInteger = true
|
|
||||||
break
|
|
||||||
case "saturation":
|
|
||||||
command = "setSaturation"
|
|
||||||
valueIsParameter = true
|
|
||||||
valueIsInteger = true
|
|
||||||
break
|
|
||||||
case "color":
|
|
||||||
command = "setColor"
|
|
||||||
def rgb = hexToRgb(value)
|
|
||||||
def hsl = rgbToHSL(rgb)
|
|
||||||
value = [hue:hsl.h.toInteger(), saturation:hsl.s.toInteger()]
|
|
||||||
valueIsParameter = true
|
|
||||||
break
|
|
||||||
case "level":
|
|
||||||
command = "setLevel"
|
|
||||||
valueIsParameter = true
|
|
||||||
valueIsInteger = true
|
|
||||||
break
|
|
||||||
case "heatingSetpoint":
|
|
||||||
command = "setHeatingSetpoint"
|
|
||||||
valueIsParameter = true
|
|
||||||
break
|
|
||||||
case "coolingSetpoint":
|
|
||||||
command = "setCoolingSetpoint"
|
|
||||||
valueIsParameter = true
|
|
||||||
break
|
|
||||||
case "currentActivity":
|
|
||||||
command = "startActivity"
|
|
||||||
valueIsParameter = true
|
|
||||||
break
|
|
||||||
case "door":
|
|
||||||
command = getDoorControlCommand(value)
|
|
||||||
break
|
|
||||||
case "lock":
|
|
||||||
command = getLockCommand(value)
|
|
||||||
break
|
|
||||||
case "mute":
|
|
||||||
command = getMuteCommand(value)
|
|
||||||
break
|
|
||||||
case "thermostatFanMode":
|
|
||||||
command = getThermostatFanModeCommand(value)
|
|
||||||
break
|
|
||||||
case "thermostatMode":
|
|
||||||
if (value == "emergency heat") {
|
|
||||||
command = "emergencyHeat"
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
command = value
|
|
||||||
}
|
|
||||||
break
|
|
||||||
case "contact":
|
|
||||||
command = getContactCommand(value)
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
command = value
|
|
||||||
}
|
|
||||||
devices.each {
|
|
||||||
if (it.id == deviceId) {
|
|
||||||
// check that the device supports the specified command
|
|
||||||
// If not, return an error using httpError, providing a HTTP status code.
|
|
||||||
if (!it.hasCommand(command)) {
|
|
||||||
httpError(501, "$command is not a valid command for the device")
|
|
||||||
}
|
|
||||||
if(valueIsParameter){
|
|
||||||
if(valueIsInteger){
|
|
||||||
it."$command"(value as int)
|
|
||||||
}
|
|
||||||
else{
|
|
||||||
it."$command"(value)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else{
|
|
||||||
it."$command"()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void executeRoutine() {
|
|
||||||
def routine = request.JSON?.routine
|
|
||||||
location.helloHome?.execute(routine)
|
|
||||||
}
|
|
||||||
|
|
||||||
def rgbToHSL(rgb) {
|
|
||||||
def r = rgb.r / 255
|
|
||||||
def g = rgb.g / 255
|
|
||||||
def b = rgb.b / 255
|
|
||||||
def h = 0
|
|
||||||
def s = 0
|
|
||||||
def l = 0
|
|
||||||
|
|
||||||
def var_min = [r,g,b].min()
|
|
||||||
def var_max = [r,g,b].max()
|
|
||||||
def del_max = var_max - var_min
|
|
||||||
|
|
||||||
l = (var_max + var_min) / 2
|
|
||||||
|
|
||||||
if (del_max == 0) {
|
|
||||||
h = 0
|
|
||||||
s = 0
|
|
||||||
} else {
|
|
||||||
if (l < 0.5) { s = del_max / (var_max + var_min) }
|
|
||||||
else { s = del_max / (2 - var_max - var_min) }
|
|
||||||
|
|
||||||
def del_r = (((var_max - r) / 6) + (del_max / 2)) / del_max
|
|
||||||
def del_g = (((var_max - g) / 6) + (del_max / 2)) / del_max
|
|
||||||
def del_b = (((var_max - b) / 6) + (del_max / 2)) / del_max
|
|
||||||
|
|
||||||
if (r == var_max) { h = del_b - del_g }
|
|
||||||
else if (g == var_max) { h = (1 / 3) + del_r - del_b }
|
|
||||||
else if (b == var_max) { h = (2 / 3) + del_g - del_r }
|
|
||||||
|
|
||||||
if (h < 0) { h += 1 }
|
|
||||||
if (h > 1) { h -= 1 }
|
|
||||||
}
|
|
||||||
def hsl = [:]
|
|
||||||
hsl = [h: h * 100, s: s * 100, l: l]
|
|
||||||
|
|
||||||
hsl
|
|
||||||
}
|
|
||||||
|
|
||||||
def hexToRgb(colorHex) {
|
|
||||||
def rrInt = Integer.parseInt(colorHex.substring(1,3),16)
|
|
||||||
def ggInt = Integer.parseInt(colorHex.substring(3,5),16)
|
|
||||||
def bbInt = Integer.parseInt(colorHex.substring(5,7),16)
|
|
||||||
|
|
||||||
def colorData = [:]
|
|
||||||
colorData = [r: rrInt, g: ggInt, b: bbInt]
|
|
||||||
colorData
|
|
||||||
}
|
|
||||||
|
|
||||||
def installed() {
|
|
||||||
state.heartbeat = false
|
|
||||||
}
|
|
||||||
|
|
||||||
def updated() {
|
|
||||||
state.heartbeat = false
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user