mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-12 05:11:52 +00:00
Compare commits
4 Commits
MSA-2032-1
...
MSA-2038-2
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9e9370a612 | ||
|
|
d6b0f6a8ed | ||
|
|
62c810ba90 | ||
|
|
fb8e4a2416 |
@@ -56,6 +56,8 @@ metadata {
|
||||
def installed(){
|
||||
// Device-Watch simply pings if no device events received for 32min(checkInterval)
|
||||
sendEvent(name: "checkInterval", value: 2 * 15 * 60 + 2 * 60, displayed: false, data: [protocol: "zwave", hubHardwareId: device.hub.hardwareID])
|
||||
|
||||
response(refresh())
|
||||
}
|
||||
|
||||
def updated(){
|
||||
@@ -85,11 +87,17 @@ def zwaveEvent(physicalgraph.zwave.Command cmd) {
|
||||
}
|
||||
|
||||
def open() {
|
||||
zwave.switchBinaryV1.switchBinarySet(switchValue: 0x00).format()
|
||||
delayBetween([
|
||||
zwave.switchBinaryV1.switchBinarySet(switchValue: 0x00).format(),
|
||||
zwave.switchBinaryV1.switchBinaryGet().format()
|
||||
], 500)
|
||||
}
|
||||
|
||||
def close() {
|
||||
zwave.switchBinaryV1.switchBinarySet(switchValue: 0xFF).format()
|
||||
delayBetween([
|
||||
zwave.switchBinaryV1.switchBinarySet(switchValue: 0xFF).format(),
|
||||
zwave.switchBinaryV1.switchBinaryGet().format()
|
||||
], 500)
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -105,6 +113,6 @@ def refresh() {
|
||||
|
||||
def createEventWithDebug(eventMap) {
|
||||
def event = createEvent(eventMap)
|
||||
log.debug "Event created with ${event?.descriptionText}"
|
||||
log.debug "Event created with ${event?.name}:${event?.value} - ${event?.descriptionText}"
|
||||
return event
|
||||
}
|
||||
|
||||
@@ -1,317 +0,0 @@
|
||||
/**
|
||||
* RealApplication_CA
|
||||
*
|
||||
* Copyright 2017 Venkata Kishore Chilakala
|
||||
*
|
||||
* 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: "RealApplication_CA",
|
||||
namespace: "CA",
|
||||
author: "Venkata Kishore Chilakala",
|
||||
description: "myApp",
|
||||
category: "SmartThings Labs",
|
||||
iconUrl: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience.png",
|
||||
iconX2Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png",
|
||||
iconX3Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png")
|
||||
|
||||
|
||||
preferences {
|
||||
section("Allow External Service to Control These Things...")
|
||||
{
|
||||
|
||||
input "motions", "capability.motionSensor", title: "Which Motion Sensors?", multiple: true, required: false
|
||||
input "contacts", "capability.contactSensor",title: "Which Contact Sensor?", multiple: true, required: false
|
||||
input "presences", "capability.presenceSensor",title: "Which Presence Sensor?", multiple: true, required: false
|
||||
input "switches", "capability.switchLevel", title: "Which Switches?", multiple: true, required: false
|
||||
input "levelSwitches","capability.switchLevel",title: "Which Level Switch?",multiple: true, required:false
|
||||
input "relativeHumidity","capability.relativeHumidityMeasurement",title: "Humidity",multiple:true,required:false
|
||||
input "temperature","capability.temperatureMeasurement",title: "Temperature Measurement",multiple:true,required:false
|
||||
input "lock","capability.lock",title: "Door Lock", multiple:true,required:false
|
||||
input "hubs",title: "Hubs",multiple:false,required:false
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
def installed() {
|
||||
initialize()
|
||||
}
|
||||
|
||||
def updated() {
|
||||
initialize()
|
||||
}
|
||||
|
||||
mappings {
|
||||
|
||||
path("/devices")
|
||||
{
|
||||
action:[
|
||||
GET:"listDevices"
|
||||
]
|
||||
}
|
||||
|
||||
path("/hubs") {
|
||||
log.debug "list action"
|
||||
action: [
|
||||
GET: "listAll"
|
||||
]
|
||||
}
|
||||
|
||||
path("/switches") {
|
||||
action: [
|
||||
GET:"listSwitches",
|
||||
PUT:"updateSwitches"
|
||||
]
|
||||
}
|
||||
path("/switches/:id") {
|
||||
action: [
|
||||
GET:"showSwitch",
|
||||
PUT:"updateSwitch"
|
||||
]
|
||||
}
|
||||
path("/levelSwitches") {
|
||||
action: [
|
||||
GET:"listLevelSwitches",
|
||||
PUT:"updateLevelSwitches"
|
||||
]
|
||||
}
|
||||
path("/levelSwitches/:id") {
|
||||
action: [
|
||||
GET:"showLevelSwitch",
|
||||
PUT:"updateLevelSwitch"
|
||||
]
|
||||
}
|
||||
path("/motions") {
|
||||
|
||||
action: [
|
||||
GET:"listMotions",
|
||||
PUT:"updateMotions"
|
||||
]
|
||||
}
|
||||
path("/motions/:id"){
|
||||
action:[
|
||||
GET:"showMotion",
|
||||
PUT:"updateMotion"
|
||||
]
|
||||
}
|
||||
path("/presences")
|
||||
{
|
||||
action:[
|
||||
GET:"listPresenceSensor",
|
||||
PUT:"updatePresenceSensor"
|
||||
]
|
||||
}
|
||||
path("/presences/:id")
|
||||
{
|
||||
action:[
|
||||
GET:"showPresence",
|
||||
PUT:"updatePresence"
|
||||
]
|
||||
}
|
||||
path("/locks") {
|
||||
action: [
|
||||
GET:"listLocks",
|
||||
PUT:"updateLocks"
|
||||
]
|
||||
}
|
||||
|
||||
path("/locks/:id") {
|
||||
action: [
|
||||
GET:"showLock",
|
||||
PUT:"updateLock"
|
||||
]
|
||||
}
|
||||
path("/contacts")
|
||||
{
|
||||
action: [
|
||||
GET: "listContacts",
|
||||
PUP: "updateContacts"
|
||||
]
|
||||
}
|
||||
path ("/contacts/:id")
|
||||
{
|
||||
action:[
|
||||
GET:"showContact",
|
||||
PUT:"updateContact"
|
||||
]
|
||||
}
|
||||
}
|
||||
|
||||
def listAll()
|
||||
{
|
||||
[location_id :location.id,hub_id:location.hubs*.id,hub_type:location.hubs*.type,hub_name:location.hubs*.name,hub_firm_ver:location.hubs*.firmwareVersionString,hub_ip:location.hubs*.localIP,hub_port:location.hubs*.localSrvPortTCP]
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
def listSwitches() {
|
||||
switches.collect { device(it,"switch") }
|
||||
}
|
||||
void updateSwitches() {
|
||||
updateAll(switches)
|
||||
}
|
||||
def showSwitch() {
|
||||
show(switches, "switch")
|
||||
}
|
||||
void updateSwitch() {
|
||||
update(switches)
|
||||
}
|
||||
def listLevelSwitches() {
|
||||
|
||||
levelSwitches.collect { device(it,"level") }
|
||||
// motions.collect { device(it,"motion") }
|
||||
}
|
||||
void updateLevelSwitches() {
|
||||
updateAll(levelSwitches)
|
||||
}
|
||||
def showLevelSwitch() {
|
||||
show(levelSwitches, "level")
|
||||
}
|
||||
void updateLevelSwitch() {
|
||||
update(levelSwitches)
|
||||
}
|
||||
|
||||
def listLocks() {
|
||||
lock.collect { device(it,"lock") }
|
||||
}
|
||||
void updateLocks() {
|
||||
updateAll(lock)
|
||||
}
|
||||
def showLock() {
|
||||
show(lock, "lock")
|
||||
}
|
||||
void updateLock() {
|
||||
update(lock)
|
||||
}
|
||||
|
||||
def listMotions() {
|
||||
motions.collect { device(it,"motion") }
|
||||
}
|
||||
void updateMotions()
|
||||
{
|
||||
updateAll(motions)
|
||||
}
|
||||
def showMotion()
|
||||
{
|
||||
show(motions, "motion")
|
||||
}
|
||||
void updateMotion()
|
||||
{
|
||||
update(motions)
|
||||
}
|
||||
|
||||
def listPresenceSensor()
|
||||
{
|
||||
presences.collect{device(it,"presence")}
|
||||
}
|
||||
void updatePresenceSensor()
|
||||
{
|
||||
updateAll(presences)
|
||||
}
|
||||
def showPresence()
|
||||
{
|
||||
show(presences,"presence")
|
||||
}
|
||||
void updatePresence()
|
||||
{
|
||||
update(presences)
|
||||
}
|
||||
|
||||
def listContacts(){
|
||||
|
||||
contacts.collect{device(it,"contact")}
|
||||
}
|
||||
void updateContacts()
|
||||
{
|
||||
updateAll(contacts)
|
||||
}
|
||||
def showContact()
|
||||
{
|
||||
show(contacts,"contact")
|
||||
}
|
||||
void updateContact()
|
||||
{
|
||||
update(contacts)
|
||||
}
|
||||
|
||||
|
||||
|
||||
private device(it, name) {
|
||||
if (it) {
|
||||
def s = it.currentState(name)
|
||||
[
|
||||
id: it.id,
|
||||
name: it.displayName,
|
||||
label: it.displayName,
|
||||
hub_name: it.hub.name,
|
||||
hub_id: it.hub.id,
|
||||
hub_ip: it.hub.localIP,
|
||||
hub_port: it.hub.localSrvPortTCP,
|
||||
state: s
|
||||
]
|
||||
}
|
||||
}
|
||||
private void updateAll(devices) {
|
||||
def command = request.JSON?.command
|
||||
if (command) {
|
||||
devices."$command"()
|
||||
}
|
||||
}
|
||||
private show(devices, name) {
|
||||
def device = devices.find { it.id == params.id }
|
||||
if (!device) {
|
||||
httpError(404, "Device not found")
|
||||
}
|
||||
else {
|
||||
log.debug " state s :: ${s}"
|
||||
log.debug "devices :: ${devices}"
|
||||
log.debug "name :: ${name}"
|
||||
def s = device.currentState(name)
|
||||
[id: device.id, label: device.displayName, name: device.displayName,state:s]
|
||||
}
|
||||
}
|
||||
private void update(devices) {
|
||||
log.debug "update, request: ${request.JSON}, params: ${params}, devices: $devices.id"
|
||||
def command = request.JSON?.command
|
||||
def value = request.JSON?.value
|
||||
|
||||
log.debug "$value"
|
||||
log.debug "$command"
|
||||
|
||||
if (command) {
|
||||
def device = devices.find { it.id == params.id }
|
||||
if (!device) {
|
||||
httpError(404, "Device not found")
|
||||
} else {
|
||||
|
||||
if("$command"=="on")
|
||||
{
|
||||
device."$command"()
|
||||
}else if("$command"=="off")
|
||||
{
|
||||
device."$command"()
|
||||
}else if("$command"=="lock")
|
||||
{
|
||||
device."$command"()
|
||||
}else if("$command"=="unlock")
|
||||
{
|
||||
device."$command"()
|
||||
}else
|
||||
{
|
||||
device.setLevel("$command")
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
def initialize() {
|
||||
|
||||
}
|
||||
@@ -0,0 +1,447 @@
|
||||
/**
|
||||
* JSON Complete API
|
||||
*
|
||||
* Copyright 2017 Paul Lovelace
|
||||
*
|
||||
*/
|
||||
definition(
|
||||
name: "JSON Complete API",
|
||||
namespace: "smartthings",
|
||||
author: "Ashok Malhotra",
|
||||
description: "API for JSON with complete set of devices",
|
||||
category: "SmartThings Labs",
|
||||
iconUrl: "https://raw.githubusercontent.com/pdlove/homebridge-smartthings/master/smartapps/JSON%401.png",
|
||||
iconX2Url: "https://raw.githubusercontent.com/pdlove/homebridge-smartthings/master/smartapps/JSON%402.png",
|
||||
iconX3Url: "https://raw.githubusercontent.com/pdlove/homebridge-smartthings/master/smartapps/JSON%403.png",
|
||||
oauth: true)
|
||||
|
||||
|
||||
preferences {
|
||||
page(name: "copyConfig")
|
||||
}
|
||||
|
||||
//When adding device groups, need to add here
|
||||
def copyConfig() {
|
||||
if (!state.accessToken) {
|
||||
createAccessToken()
|
||||
}
|
||||
dynamicPage(name: "copyConfig", title: "Configure Devices", install:true, uninstall:true) {
|
||||
section("Select devices to include in the /devices API call") {
|
||||
paragraph "Version 0.5.5"
|
||||
input "deviceList", "capability.refresh", title: "Most Devices", multiple: true, required: false
|
||||
input "sensorList", "capability.sensor", title: "Sensor Devices", multiple: true, required: false
|
||||
input "switchList", "capability.switch", title: "All Switches", multiple: true, required: false
|
||||
//paragraph "Devices Selected: ${deviceList ? deviceList?.size() : 0}\nSensors Selected: ${sensorList ? sensorList?.size() : 0}\nSwitches Selected: ${switchList ? switchList?.size() : 0}"
|
||||
}
|
||||
section("Configure Pubnub") {
|
||||
input "pubnubSubscribeKey", "text", title: "PubNub Subscription Key", multiple: false, required: false
|
||||
input "pubnubPublishKey", "text", title: "PubNub Publish Key", multiple: false, required: false
|
||||
input "subChannel", "text", title: "Channel (Can be anything)", multiple: false, required: false
|
||||
}
|
||||
section() {
|
||||
paragraph "View this SmartApp's configuration to use it in other places."
|
||||
href url:"${apiServerUrl("/api/smartapps/installations/${app.id}/config?access_token=${state.accessToken}")}", style:"embedded", required:false, title:"Config", description:"Tap, select, copy, then click \"Done\""
|
||||
}
|
||||
|
||||
section() {
|
||||
paragraph "View the JSON generated from the installed devices."
|
||||
href url:"${apiServerUrl("/api/smartapps/installations/${app.id}/devices?access_token=${state.accessToken}")}", style:"embedded", required:false, title:"Device Results", description:"View accessories JSON"
|
||||
}
|
||||
section() {
|
||||
paragraph "Enter the name you would like shown in the smart app list"
|
||||
label title:"SmartApp Label (optional)", required: false
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
def renderDevices() {
|
||||
def deviceData = []
|
||||
deviceList.each {
|
||||
try {
|
||||
deviceData << [name: it.displayName,
|
||||
basename: it.name,
|
||||
deviceid: it.id,
|
||||
status: it.status,
|
||||
manufacturerName: it.getManufacturerName(),
|
||||
modelName: it.getModelName(),
|
||||
lastTime: it.getLastActivity(),
|
||||
capabilities: deviceCapabilityList(it),
|
||||
commands: deviceCommandList(it),
|
||||
attributes: deviceAttributeList(it)
|
||||
]
|
||||
} catch (e) {
|
||||
log.error("Error Occurred Parsing Device "+it.displayName+", Error " + e)
|
||||
}
|
||||
}
|
||||
sensorList.each {
|
||||
try {
|
||||
deviceData << [name: it.displayName,
|
||||
basename: it.name,
|
||||
deviceid: it.id,
|
||||
status: it.status,
|
||||
manufacturerName: it.getManufacturerName(),
|
||||
modelName: it.getModelName(),
|
||||
lastTime: it.getLastActivity(),
|
||||
capabilities: deviceCapabilityList(it),
|
||||
commands: deviceCommandList(it),
|
||||
attributes: deviceAttributeList(it)
|
||||
]
|
||||
} catch (e) {
|
||||
log.error("Error Occurred Parsing Device "+it.displayName+", Error " + e)
|
||||
}
|
||||
}
|
||||
switchList.each {
|
||||
try {
|
||||
deviceData << [name: it.displayName,
|
||||
basename: it.name,
|
||||
deviceid: it.id,
|
||||
status: it.status,
|
||||
manufacturerName: it.getManufacturerName(),
|
||||
modelName: it.getModelName(),
|
||||
lastTime: it.getLastActivity(),
|
||||
capabilities: deviceCapabilityList(it),
|
||||
commands: deviceCommandList(it),
|
||||
attributes: deviceAttributeList(it)
|
||||
]
|
||||
} catch (e) {
|
||||
log.error("Error Occurred Parsing Device "+it.displayName+", Error " + e)
|
||||
}
|
||||
}
|
||||
return deviceData
|
||||
}
|
||||
|
||||
def findDevice(paramid) {
|
||||
def device = deviceList.find { it.id == paramid }
|
||||
if (device) return device
|
||||
device = sensorList.find { it.id == paramid }
|
||||
if (device) return device
|
||||
device = switchList.find { it.id == paramid }
|
||||
|
||||
return device
|
||||
}
|
||||
//No more individual device group definitions after here.
|
||||
|
||||
|
||||
def installed() {
|
||||
log.debug "Installed with settings: ${settings}"
|
||||
initialize()
|
||||
}
|
||||
|
||||
def updated() {
|
||||
log.debug "Updated with settings: ${settings}"
|
||||
unsubscribe()
|
||||
initialize()
|
||||
}
|
||||
|
||||
def initialize() {
|
||||
if(!state.accessToken) {
|
||||
createAccessToken()
|
||||
}
|
||||
registerAll()
|
||||
state.subscriptionRenewed = 0
|
||||
subscribe(location, null, HubResponseEvent, [filterEvents:false])
|
||||
log.debug "0.5.5"
|
||||
}
|
||||
|
||||
def authError() {
|
||||
[error: "Permission denied"]
|
||||
}
|
||||
def renderConfig() {
|
||||
def configJson = new groovy.json.JsonOutput().toJson([
|
||||
description: "JSON API",
|
||||
platforms: [
|
||||
[
|
||||
platform: "SmartThings",
|
||||
name: "SmartThings",
|
||||
app_url: apiServerUrl("/api/smartapps/installations/"),
|
||||
app_id: app.id,
|
||||
access_token: state.accessToken
|
||||
]
|
||||
],
|
||||
])
|
||||
|
||||
def configString = new groovy.json.JsonOutput().prettyPrint(configJson)
|
||||
render contentType: "text/plain", data: configString
|
||||
}
|
||||
def renderLocation() {
|
||||
[
|
||||
latitude: location.latitude,
|
||||
longitude: location.longitude,
|
||||
mode: location.mode,
|
||||
name: location.name,
|
||||
temperature_scale: location.temperatureScale,
|
||||
zip_code: location.zipCode,
|
||||
hubIP: location.hubs[0].localIP,
|
||||
smartapp_version: '0.5.5'
|
||||
]
|
||||
}
|
||||
def CommandReply(statusOut, messageOut) {
|
||||
def replyData =
|
||||
[
|
||||
status: statusOut,
|
||||
message: messageOut
|
||||
]
|
||||
|
||||
def replyJson = new groovy.json.JsonOutput().toJson(replyData)
|
||||
render contentType: "application/json", data: replyJson
|
||||
}
|
||||
def deviceCommand() {
|
||||
log.info("Command Request")
|
||||
def device = findDevice(params.id)
|
||||
def command = params.command
|
||||
|
||||
if (!device) {
|
||||
log.error("Device Not Found")
|
||||
CommandReply("Failure", "Device Not Found")
|
||||
} else if (!device.hasCommand(command)) {
|
||||
log.error("Device "+device.displayName+" does not have the command "+command)
|
||||
CommandReply("Failure", "Device "+device.displayName+" does not have the command "+command)
|
||||
} else {
|
||||
def value1 = request.JSON?.value1
|
||||
def value2 = request.JSON?.value2
|
||||
try {
|
||||
if (value2) {
|
||||
device."$command"(value1,value2)
|
||||
} else if (value1) {
|
||||
device."$command"(value1)
|
||||
} else {
|
||||
device."$command"()
|
||||
}
|
||||
log.info("Command Successful for Device "+device.displayName+", Command "+command)
|
||||
CommandReply("Success", "Device "+device.displayName+", Command "+command)
|
||||
} catch (e) {
|
||||
log.error("Error Occurred For Device "+device.displayName+", Command "+command)
|
||||
CommandReply("Failure", "Error Occurred For Device "+device.displayName+", Command "+command)
|
||||
}
|
||||
}
|
||||
}
|
||||
def deviceAttribute() {
|
||||
def device = findDevice(params.id)
|
||||
def attribute = params.attribute
|
||||
if (!device) {
|
||||
httpError(404, "Device not found")
|
||||
} else {
|
||||
def currentValue = device.currentValue(attribute)
|
||||
[currentValue: currentValue]
|
||||
}
|
||||
}
|
||||
def deviceQuery() {
|
||||
def device = findDevice(params.id)
|
||||
if (!device) {
|
||||
device = null
|
||||
httpError(404, "Device not found")
|
||||
}
|
||||
|
||||
if (result) {
|
||||
def jsonData =
|
||||
[
|
||||
name: device.displayName,
|
||||
deviceid: device.id,
|
||||
capabilities: deviceCapabilityList(device),
|
||||
commands: deviceCommandList(device),
|
||||
attributes: deviceAttributeList(device)
|
||||
]
|
||||
def resultJson = new groovy.json.JsonOutput().toJson(jsonData)
|
||||
render contentType: "application/json", data: resultJson
|
||||
}
|
||||
}
|
||||
def deviceCapabilityList(device) {
|
||||
def i=0
|
||||
device.capabilities.collectEntries { capability->
|
||||
[
|
||||
(capability.name):1
|
||||
]
|
||||
}
|
||||
}
|
||||
def deviceCommandList(device) {
|
||||
def i=0
|
||||
device.supportedCommands.collectEntries { command->
|
||||
[
|
||||
(command.name): (command.arguments)
|
||||
]
|
||||
}
|
||||
}
|
||||
def deviceAttributeList(device) {
|
||||
device.supportedAttributes.collectEntries { attribute->
|
||||
try {
|
||||
[
|
||||
(attribute.name): device.currentValue(attribute.name)
|
||||
]
|
||||
} catch(e) {
|
||||
[
|
||||
(attribute.name): null
|
||||
]
|
||||
}
|
||||
}
|
||||
}
|
||||
def getAllData() {
|
||||
//Since we're about to send all of the data, we'll count this as a subscription renewal and clear out pending changes.
|
||||
state.subscriptionRenewed = now()
|
||||
state.devchanges = []
|
||||
|
||||
|
||||
def deviceData =
|
||||
[ location: renderLocation(),
|
||||
deviceList: renderDevices() ]
|
||||
def deviceJson = new groovy.json.JsonOutput().toJson(deviceData)
|
||||
render contentType: "application/json", data: deviceJson
|
||||
}
|
||||
def startSubscription() {
|
||||
//This simply registers the subscription.
|
||||
state.subscriptionRenewed = now()
|
||||
def deviceJson = new groovy.json.JsonOutput().toJson([status: "Success"])
|
||||
render contentType: "application/json", data: deviceJson
|
||||
}
|
||||
def endSubscription() {
|
||||
//Because it takes too long to register for an api command, we don't actually unregister.
|
||||
//We simply blank the devchanges and change the subscription renewal to two hours ago.
|
||||
state.devchanges = []
|
||||
state.subscriptionRenewed = 0
|
||||
def deviceJson = new groovy.json.JsonOutput().toJson([status: "Success"])
|
||||
render contentType: "application/json", data: deviceJson
|
||||
}
|
||||
def registerAll() {
|
||||
//This has to be done at startup because it takes too long for a normal command.
|
||||
log.debug "Registering All Events"
|
||||
state.devchanges = []
|
||||
registerChangeHandler(deviceList)
|
||||
registerChangeHandler(sensorList)
|
||||
registerChangeHandler(switchList)
|
||||
}
|
||||
def registerChangeHandler(myList) {
|
||||
myList.each { myDevice ->
|
||||
def theAtts = myDevice.supportedAttributes
|
||||
theAtts.each {att ->
|
||||
subscribe(myDevice, att.name, changeHandler)
|
||||
log.debug "Registering ${myDevice.displayName}.${att.name}"
|
||||
}
|
||||
}
|
||||
}
|
||||
def changeHandler(evt) {
|
||||
//Send to Pubnub if we need to.
|
||||
if (pubnubPublishKey!=null) {
|
||||
def deviceData = [device: evt.deviceId, attribute: evt.name, value: evt.value, date: evt.date]
|
||||
def changeJson = new groovy.json.JsonOutput().toJson(deviceData)
|
||||
def changeData = URLEncoder.encode(changeJson)
|
||||
def uri = "http://pubsub.pubnub.com/publish/${pubnubPublishKey}/${pubnubSubscribeKey}/0/${subChannel}/0/${changeData}"
|
||||
log.debug "${uri}"
|
||||
httpGet(uri)
|
||||
}
|
||||
|
||||
if (state.directIP!="") {
|
||||
//Send Using the Direct Mechanism
|
||||
def deviceData = [device: evt.deviceId, attribute: evt.name, value: evt.value, date: evt.date]
|
||||
//How do I control the port?!?
|
||||
log.debug "Sending Update to ${state.directIP}:${state.directPort}"
|
||||
def result = new physicalgraph.device.HubAction(
|
||||
method: "GET",
|
||||
path: "/update",
|
||||
headers: [
|
||||
HOST: "${state.directIP}:${state.directPort}",
|
||||
change_device: evt.deviceId,
|
||||
change_attribute: evt.name,
|
||||
change_value: evt.value,
|
||||
change_date: evt.date
|
||||
]
|
||||
)
|
||||
sendHubCommand(result)
|
||||
}
|
||||
|
||||
//Only add to the state's devchanges if the endpoint has renewed in the last 10 minutes.
|
||||
if (state.subscriptionRenewed>(now()-(1000*60*10))) {
|
||||
if (evt.isStateChange()) {
|
||||
state.devchanges << [device: evt.deviceId, attribute: evt.name, value: evt.value, date: evt.date]
|
||||
}
|
||||
} else if (state.subscriptionRenewed>0) { //Otherwise, clear it
|
||||
log.debug "Endpoint Subscription Expired. No longer storing changes for devices."
|
||||
state.devchanges=[]
|
||||
state.subscriptionRenewed=0
|
||||
}
|
||||
}
|
||||
def getChangeEvents() {
|
||||
//Store the changes so we can swap it out very quickly and eliminate the possibility of losing any.
|
||||
//This is mainly to make this thread safe because I'm willing to bet that a change event can fire
|
||||
//while generating/sending the JSON.
|
||||
def oldchanges = state.devchanges
|
||||
state.devchanges=[]
|
||||
state.subscriptionRenewed = now()
|
||||
if (oldchanges.size()==0) {
|
||||
def deviceJson = new groovy.json.JsonOutput().toJson([status: "None"])
|
||||
render contentType: "application/json", data: deviceJson
|
||||
} else {
|
||||
def changeJson = new groovy.json.JsonOutput().toJson([status: "Success", attributes:oldchanges])
|
||||
render contentType: "application/json", data: changeJson
|
||||
}
|
||||
}
|
||||
def enableDirectUpdates() {
|
||||
log.debug("Command Request")
|
||||
state.directIP = params.ip
|
||||
state.directPort = params.port
|
||||
log.debug("Trying ${state.directIP}:${state.directPort}")
|
||||
def result = new physicalgraph.device.HubAction(
|
||||
method: "GET",
|
||||
path: "/initial",
|
||||
headers: [
|
||||
HOST: "${state.directIP}:${state.directPort}"
|
||||
],
|
||||
query: deviceData
|
||||
)
|
||||
sendHubCommand(result)
|
||||
}
|
||||
|
||||
def HubResponseEvent(evt) {
|
||||
log.debug(evt.description)
|
||||
}
|
||||
|
||||
def locationHandler(evt) {
|
||||
def description = evt.description
|
||||
def hub = evt?.hubId
|
||||
|
||||
log.debug "cp desc: " + description
|
||||
if (description.count(",") > 4)
|
||||
{
|
||||
def bodyString = new String(description.split(',')[5].split(":")[1].decodeBase64())
|
||||
log.debug(bodyString)
|
||||
}
|
||||
}
|
||||
|
||||
def getSubscriptionService() {
|
||||
def replyData =
|
||||
[
|
||||
pubnub_publishkey: pubnubPublishKey,
|
||||
pubnub_subscribekey: pubnubSubscribeKey,
|
||||
pubnub_channel: subChannel
|
||||
]
|
||||
|
||||
def replyJson = new groovy.json.JsonOutput().toJson(replyData)
|
||||
render contentType: "application/json", data: replyJson
|
||||
}
|
||||
|
||||
mappings {
|
||||
if (!params.access_token || (params.access_token && params.access_token != state.accessToken)) {
|
||||
path("/devices") { action: [GET: "authError"] }
|
||||
path("/config") { action: [GET: "authError"] }
|
||||
path("/location") { action: [GET: "authError"] }
|
||||
path("/:id/command/:command") { action: [POST: "authError"] }
|
||||
path("/:id/query") { action: [GET: "authError"] }
|
||||
path("/:id/attribute/:attribute") { action: [GET: "authError"] }
|
||||
path("/subscribe") { action: [GET: "authError"] }
|
||||
path("/getUpdates") { action: [GET: "authError"] }
|
||||
path("/unsubscribe") { action: [GET: "authError"] }
|
||||
path("/startDirect/:ip/:port") { action: [GET: "authError"] }
|
||||
path("/getSubcriptionService") { action: [GET: "authError"] }
|
||||
|
||||
} else {
|
||||
path("/devices") { action: [GET: "getAllData"] }
|
||||
path("/config") { action: [GET: "renderConfig"] }
|
||||
path("/location") { action: [GET: "renderLocation"] }
|
||||
path("/:id/command/:command") { action: [POST: "deviceCommand"] }
|
||||
path("/:id/query") { action: [GET: "deviceQuery"] }
|
||||
path("/:id/attribute/:attribute") { action: [GET: "deviceAttribute"] }
|
||||
path("/subscribe") { action: [GET: "startSubscription"] }
|
||||
path("/getUpdates") { action: [GET: "getChangeEvents"] }
|
||||
path("/unsubscribe") { action: [GET: "endSubscription"] }
|
||||
path("/startDirect/:ip/:port") { action: [GET: "enableDirectUpdates"] }
|
||||
path("/getSubcriptionService") { action: [GET: "getSubscriptionService"] }
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user