mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-29 06:13:07 +01:00
Compare commits
3 Commits
MSA-1985-1
...
MSA-1989-1
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0f6aa6b1a4 | ||
|
|
01c2968f91 | ||
|
|
12bb6c0492 |
@@ -23,8 +23,8 @@ 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"
|
fingerprint profileId: "0104", inClusters: "0000, 0003, 0006", outClusters: "000A", manufacturer: "HAI", model: "65A21-1", deviceJoinName: "Leviton Wireless Load Control Module-30amp"
|
||||||
fingerprint profileId: "0104", inClusters: "0000, 0003, 0004, 0005, 0006", outClusters: "0003, 0006, 0008, 0019, 0406", manufacturer: "Leviton", model: "DL15A", deviceJoinName: "Leviton Lumina RF Plug-In Appliance Module"
|
fingerprint profileId: "0104", inClusters: "0000, 0003, 0004, 0005, 0006", outClusters: "0003, 0006, 0008, 0019, 0406", manufacturer: "Lumi", model: "DL15A", deviceJoinName: "LM-Z3"
|
||||||
fingerprint profileId: "0104", inClusters: "0000, 0003, 0004, 0005, 0006", outClusters: "0003, 0006, 0008, 0019, 0406", manufacturer: "Leviton", model: "DL15S", deviceJoinName: "Leviton Lumina RF Switch"
|
fingerprint profileId: "0104", inClusters: "0000, 0003, 0004, 0005, 0006", outClusters: "0003, 0006, 0008, 0019, 0406", manufacturer: "Lumi", model: "DL15S", deviceJoinName: "LM-Z3"
|
||||||
}
|
}
|
||||||
|
|
||||||
// simulator metadata
|
// simulator metadata
|
||||||
@@ -41,9 +41,9 @@ metadata {
|
|||||||
tiles(scale: 2) {
|
tiles(scale: 2) {
|
||||||
multiAttributeTile(name:"switch", type: "lighting", width: 6, height: 4, canChangeIcon: true){
|
multiAttributeTile(name:"switch", type: "lighting", width: 6, height: 4, canChangeIcon: true){
|
||||||
tileAttribute ("device.switch", key: "PRIMARY_CONTROL") {
|
tileAttribute ("device.switch", key: "PRIMARY_CONTROL") {
|
||||||
attributeState "on", label:'${name}', action:"switch.off", icon:"st.switches.light.on", backgroundColor:"#00A0DC", nextState:"turningOff"
|
attributeState "on", label:'${name}', action:"switch.off", icon:"st.switches.light.on", backgroundColor:"#79b821", nextState:"turningOff"
|
||||||
attributeState "off", label:'${name}', action:"switch.on", icon:"st.switches.light.off", backgroundColor:"#ffffff", nextState:"turningOn"
|
attributeState "off", label:'${name}', action:"switch.on", icon:"st.switches.light.off", backgroundColor:"#ffffff", nextState:"turningOn"
|
||||||
attributeState "turningOn", label:'${name}', action:"switch.off", icon:"st.switches.light.on", backgroundColor:"#00A0DC", nextState:"turningOff"
|
attributeState "turningOn", label:'${name}', action:"switch.off", icon:"st.switches.light.on", backgroundColor:"#79b821", nextState:"turningOff"
|
||||||
attributeState "turningOff", label:'${name}', action:"switch.on", icon:"st.switches.light.off", backgroundColor:"#ffffff", nextState:"turningOn"
|
attributeState "turningOff", label:'${name}', action:"switch.on", icon:"st.switches.light.off", backgroundColor:"#ffffff", nextState:"turningOn"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -92,4 +92,4 @@ def configure() {
|
|||||||
sendEvent(name: "checkInterval", value: 2 * 10 * 60 + 2 * 60, displayed: false, data: [protocol: "zigbee", hubHardwareId: device.hub.hardwareID])
|
sendEvent(name: "checkInterval", value: 2 * 10 * 60 + 2 * 60, displayed: false, data: [protocol: "zigbee", hubHardwareId: device.hub.hardwareID])
|
||||||
log.debug "Configuring Reporting and Bindings."
|
log.debug "Configuring Reporting and Bindings."
|
||||||
zigbee.onOffRefresh() + zigbee.onOffConfig()
|
zigbee.onOffRefresh() + zigbee.onOffConfig()
|
||||||
}
|
}
|
||||||
2
devicetypes/smartthings/zwave-water-valve.src/.st-ignore
Normal file
2
devicetypes/smartthings/zwave-water-valve.src/.st-ignore
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
.st-ignore
|
||||||
|
README.md
|
||||||
38
devicetypes/smartthings/zwave-water-valve.src/README.md
Normal file
38
devicetypes/smartthings/zwave-water-valve.src/README.md
Normal file
@@ -0,0 +1,38 @@
|
|||||||
|
# Z-Wave Water Valve
|
||||||
|
|
||||||
|
Cloud Execution
|
||||||
|
|
||||||
|
Works with:
|
||||||
|
|
||||||
|
* [Leak Intelligence Leak Gopher Water Shutoff Valve](https://www.smartthings.com/works-with-smartthings/other/leak-intelligence-leak-gopher-water-shutoff-valve)
|
||||||
|
|
||||||
|
|
||||||
|
## Table of contents
|
||||||
|
|
||||||
|
* [Capabilities](#capabilities)
|
||||||
|
* [Health](#device-health)
|
||||||
|
* [Troubleshooting](#Troubleshooting)
|
||||||
|
|
||||||
|
## Capabilities
|
||||||
|
|
||||||
|
* **Actuator** - represents that a Device has commands
|
||||||
|
* **Health Check** - indicates ability to get device health notifications
|
||||||
|
* **Valve** - allows for the control of a valve device
|
||||||
|
* **Polling** - represents that poll() can be implemented for the device
|
||||||
|
* **Refresh** - _refresh()_ command for status updates
|
||||||
|
* **Sensor** - detects sensor events
|
||||||
|
|
||||||
|
## Device Health
|
||||||
|
|
||||||
|
SmartThings platform will ping the device after `checkInterval` seconds of inactivity in last attempt to reach the device before marking it `OFFLINE`
|
||||||
|
|
||||||
|
* __32min__ checkInterval
|
||||||
|
|
||||||
|
## 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.
|
||||||
|
Instructions related to pairing, resetting and removing the device from SmartThings can be found in the following link:
|
||||||
|
* [Leak Intelligence Leak Gopher Water Shutoff Valve Troubleshooting Tips](https://support.smartthings.com/hc/en-us/articles/209631423-Leak-Gopher-Z-Wave-Valve-Control)
|
||||||
|
|
||||||
|
|
||||||
@@ -14,12 +14,14 @@
|
|||||||
metadata {
|
metadata {
|
||||||
definition (name: "Z-Wave Water Valve", namespace: "smartthings", author: "SmartThings") {
|
definition (name: "Z-Wave Water Valve", namespace: "smartthings", author: "SmartThings") {
|
||||||
capability "Actuator"
|
capability "Actuator"
|
||||||
|
capability "Health Check"
|
||||||
capability "Valve"
|
capability "Valve"
|
||||||
capability "Polling"
|
capability "Polling"
|
||||||
capability "Refresh"
|
capability "Refresh"
|
||||||
capability "Sensor"
|
capability "Sensor"
|
||||||
|
|
||||||
fingerprint deviceId: "0x1006", inClusters: "0x25"
|
fingerprint deviceId: "0x1006", inClusters: "0x25"
|
||||||
|
fingerprint mfr:"0173", prod:"0003", model:"0002", deviceJoinName: "Leak Intelligence Leak Gopher Water Shutoff Valve"
|
||||||
}
|
}
|
||||||
|
|
||||||
// simulator metadata
|
// simulator metadata
|
||||||
@@ -53,7 +55,14 @@ 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])
|
||||||
|
}
|
||||||
|
|
||||||
def updated() {
|
def updated() {
|
||||||
|
// 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())
|
response(refresh())
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -114,6 +123,13 @@ def poll() {
|
|||||||
zwave.switchBinaryV1.switchBinaryGet().format()
|
zwave.switchBinaryV1.switchBinaryGet().format()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* PING is used by Device-Watch in attempt to reach the Device
|
||||||
|
* */
|
||||||
|
def ping() {
|
||||||
|
refresh()
|
||||||
|
}
|
||||||
|
|
||||||
def refresh() {
|
def refresh() {
|
||||||
log.debug "refresh() is called"
|
log.debug "refresh() is called"
|
||||||
def commands = [zwave.switchBinaryV1.switchBinaryGet().format()]
|
def commands = [zwave.switchBinaryV1.switchBinaryGet().format()]
|
||||||
|
|||||||
@@ -1,373 +0,0 @@
|
|||||||
/**
|
|
||||||
* SmartThingsToStart REST Api
|
|
||||||
*
|
|
||||||
* Copyright 2017 Dr1rrb
|
|
||||||
*
|
|
||||||
* 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: "SmartThingsToStart",
|
|
||||||
namespace: "torick.net",
|
|
||||||
author: "Dr1rrb",
|
|
||||||
description: "SmartThingsToStart REST Api",
|
|
||||||
category: "My Apps",
|
|
||||||
iconUrl: "http://smartthingstostartproxy.azurewebsites.net/Assets/AppLogo.png",
|
|
||||||
iconX2Url: "http://smartthingstostartproxy.azurewebsites.net/Assets/AppLogo@2X.png",
|
|
||||||
iconX3Url: "http://smartthingstostartproxy.azurewebsites.net/Assets/AppLogo@3X.png",
|
|
||||||
oauth: true)
|
|
||||||
|
|
||||||
|
|
||||||
preferences {
|
|
||||||
section("Control these devices") {
|
|
||||||
input "switches", "capability.switch", title: "Select switches", multiple: true, required: false
|
|
||||||
input "bubls", "capability.bulb", title: "Select bubls", hideWhenEmpty: true, multiple: true, required: false
|
|
||||||
input "lights", "capability.light", title: "Select lights", hideWhenEmpty: true, multiple: true, required: false
|
|
||||||
input "outlets", "capability.outlet", title: "Select outlets", hideWhenEmpty: true, multiple: true, required: false
|
|
||||||
input "relaySwitches", "capability.relaySwitch", title: "Select relay switches", hideWhenEmpty: true, multiple: true, required: false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
mappings {
|
|
||||||
path("/infos") {
|
|
||||||
action: [GET: "retreiveServerInfos"]
|
|
||||||
}
|
|
||||||
path("/items") {
|
|
||||||
action: [GET: "retreiveDevicesAndRoutines"]
|
|
||||||
}
|
|
||||||
path("/device/:id") {
|
|
||||||
action: [GET: "retreiveDevice"]
|
|
||||||
}
|
|
||||||
path("/device/:id/subscription/:subscriptionId") {
|
|
||||||
action: [
|
|
||||||
PUT: "updateOrCreateSubscription",
|
|
||||||
POST: "updateOrCreateSubscription",
|
|
||||||
]
|
|
||||||
}
|
|
||||||
// TODO
|
|
||||||
//path("/device/:id/unsubscribe") {
|
|
||||||
// action: [POST: "unsubscribeFromDevice"]
|
|
||||||
//}
|
|
||||||
path("/device/:id/:command") {
|
|
||||||
action: [ PUT: "updateDevice" ]
|
|
||||||
}
|
|
||||||
path("/routine/:id/execute") {
|
|
||||||
action: [PUT: "executeRoutine"]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Region: App lifecycle
|
|
||||||
def installed() {
|
|
||||||
log.debug "Installed with settings: ${settings}"
|
|
||||||
|
|
||||||
initialize()
|
|
||||||
}
|
|
||||||
|
|
||||||
def updated() {
|
|
||||||
log.debug "Updated with settings: ${settings}"
|
|
||||||
|
|
||||||
unsubscribe()
|
|
||||||
//state.pushChannels = [:]
|
|
||||||
initialize()
|
|
||||||
}
|
|
||||||
|
|
||||||
def initialize() {
|
|
||||||
def channels = state.pushChannels = state.pushChannels ?: [:];
|
|
||||||
channels.each
|
|
||||||
{
|
|
||||||
def device = findDevice(it.key);
|
|
||||||
if (device != null)
|
|
||||||
{
|
|
||||||
subscribeToDevice(device);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// Region: Http request handlers
|
|
||||||
def retreiveServerInfos()
|
|
||||||
{
|
|
||||||
return [version: 1]
|
|
||||||
}
|
|
||||||
|
|
||||||
def retreiveDevicesAndRoutines() {
|
|
||||||
def details = params.details == "true" ? true : false;
|
|
||||||
|
|
||||||
return [
|
|
||||||
devices: getDevices().collect { getDeviceInfos(it, details) },
|
|
||||||
routines: location.helloHome?.getPhrases().collect { getRoutineInfos(it, details) }
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
def retreiveDevice() {
|
|
||||||
def device = getDevice(params.id);
|
|
||||||
def details = params.details == "true" ? true : false;
|
|
||||||
|
|
||||||
return getDeviceInfos(device, details);
|
|
||||||
}
|
|
||||||
|
|
||||||
def updateOrCreateSubscription() {
|
|
||||||
def device = getDevice(params.id);
|
|
||||||
def channelUri = notNull("channelUri", request.JSON?.channelUri);
|
|
||||||
def token = notNull("token", request.JSON?.token);
|
|
||||||
|
|
||||||
log.debug "Subscribing to device '${device.id}' (target: '${channelUri}' / token: '${token}')"
|
|
||||||
|
|
||||||
// Get or create the push notification channel from / into the local state
|
|
||||||
def subscriptionId = params.subscriptionId ?: UUID.randomUUID().toString() ;
|
|
||||||
def allSubscriptions = state.pushChannels ?: (state.pushChannels = [:]);
|
|
||||||
def deviceSubscriptions = allSubscriptions[device.id] ?: (allSubscriptions[device.id] = []);
|
|
||||||
def subscription = deviceSubscriptions.find { it.id == subscriptionId };
|
|
||||||
if (subscription == null)
|
|
||||||
{
|
|
||||||
deviceSubscriptions << [
|
|
||||||
id: subscriptionId,
|
|
||||||
deviceId: device.id,
|
|
||||||
channelUri: channelUri,
|
|
||||||
token: token
|
|
||||||
];
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
subscription["channelUri"] = channelUri;
|
|
||||||
subscription["token"] = token;
|
|
||||||
}
|
|
||||||
|
|
||||||
log.debug "Active subscriptions: \n" + state.pushChannels.collect { "** Device ${it.key} **\n" + it.value.collect{c -> "- - - > ${c.channelUri} : ${c.token.substring(0, 10)}..."}.join('\n') + "\n***************************" }.join('\n\n')
|
|
||||||
|
|
||||||
// (Re)create the subscription(s)
|
|
||||||
subscribeToDevice(device)
|
|
||||||
|
|
||||||
return [subscriptionId: subscriptionId];
|
|
||||||
}
|
|
||||||
|
|
||||||
def subscribeToDevice(device)
|
|
||||||
{
|
|
||||||
log.debug "Subscribing to device '${device.id}'"
|
|
||||||
|
|
||||||
unsubscribe(device);
|
|
||||||
subscribe(device, "switch", switchStateChanged)
|
|
||||||
|
|
||||||
if (device.hasCapability("Color Control"))
|
|
||||||
{
|
|
||||||
log.debug "Device '${device.id}' has also the color capability. Subscribe to it."
|
|
||||||
subscribe(device, "color", colorStateChanged)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def switchStateChanged(eventArgs) { sendPushNotification("switch", eventArgs) }
|
|
||||||
def colorStateChanged(eventArgs) { sendPushNotification("color", eventArgs) }
|
|
||||||
|
|
||||||
def updateDevice() {
|
|
||||||
def device = getDevice(params.id)
|
|
||||||
def command = notNull("command", params.command)
|
|
||||||
|
|
||||||
log.debug "Executing '${command}' on device '${device.id}'."
|
|
||||||
|
|
||||||
switch(command) {
|
|
||||||
case "on":
|
|
||||||
case "On":
|
|
||||||
device.on()
|
|
||||||
break
|
|
||||||
|
|
||||||
case "off":
|
|
||||||
case "Off":
|
|
||||||
device.off()
|
|
||||||
break
|
|
||||||
|
|
||||||
case "toggle":
|
|
||||||
case "Toggle":
|
|
||||||
if (device.currentSwitch == "on")
|
|
||||||
device.off();
|
|
||||||
else
|
|
||||||
device.on();
|
|
||||||
break;
|
|
||||||
|
|
||||||
default:
|
|
||||||
httpError(501, "'${command}' is not a valid command for '${device.id}'")
|
|
||||||
}
|
|
||||||
|
|
||||||
return getDeviceInfos(device);
|
|
||||||
}
|
|
||||||
|
|
||||||
def executeRoutine() {
|
|
||||||
def routine = getRoutine(params.id);
|
|
||||||
log.debug "Executing routine '${routine.id}' (${routine.label})"
|
|
||||||
|
|
||||||
location.helloHome?.execute(routine.id)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Region: Get device
|
|
||||||
def getDevices()
|
|
||||||
{
|
|
||||||
return switches
|
|
||||||
+ bubls
|
|
||||||
+ lights
|
|
||||||
+ outlets
|
|
||||||
+ relaySwitches;
|
|
||||||
}
|
|
||||||
|
|
||||||
def findDevice(deviceId)
|
|
||||||
{
|
|
||||||
notNull("deviceId", deviceId);
|
|
||||||
|
|
||||||
return getDevices().find { it.id == deviceId };
|
|
||||||
}
|
|
||||||
|
|
||||||
def getDevice(deviceId)
|
|
||||||
{
|
|
||||||
def device = findDevice(deviceId);
|
|
||||||
if (device == null)
|
|
||||||
{
|
|
||||||
httpError(404, "Device '${deviceId}' not found.")
|
|
||||||
}
|
|
||||||
return device;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Region: Get routine
|
|
||||||
def findRoutine(routineId)
|
|
||||||
{
|
|
||||||
return location.helloHome?.getPhrases().find{ it.id == routineId};
|
|
||||||
}
|
|
||||||
|
|
||||||
def getRoutine(routineId)
|
|
||||||
{
|
|
||||||
def routine = findRoutine(routineId);
|
|
||||||
if (routine == null)
|
|
||||||
{
|
|
||||||
httpError(404, "Routine '${routineId}' not found.")
|
|
||||||
}
|
|
||||||
return routine;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Region: Parameters assertion helpers
|
|
||||||
def notNull(parameterName, value)
|
|
||||||
{
|
|
||||||
if(value == null || value == "")
|
|
||||||
{
|
|
||||||
httpError(404, "Missing parameter '${parameterName}'.")
|
|
||||||
}
|
|
||||||
return value;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Region: Get infos
|
|
||||||
def getDeviceInfos(device, details = false)
|
|
||||||
{
|
|
||||||
def infos = [
|
|
||||||
id: device.id,
|
|
||||||
name: device.displayName,
|
|
||||||
state: device.currentValue("switch"),
|
|
||||||
color: device.currentValue("color"),
|
|
||||||
hue: device.currentValue("hue"),
|
|
||||||
saturation: device.currentValue("saturation"),
|
|
||||||
capabilities: device.capabilities.collect { getCapabilityInfos(it, details) }
|
|
||||||
]
|
|
||||||
|
|
||||||
if (details)
|
|
||||||
{
|
|
||||||
infos["attributes"] = device.supportedAttributes.collect { getAttributeInfos(it, details) }
|
|
||||||
infos["commands"] = device.supportedCommands.collect { getCommandInfos(it, details) }
|
|
||||||
}
|
|
||||||
|
|
||||||
return infos;
|
|
||||||
}
|
|
||||||
|
|
||||||
def getCapabilityInfos(capablity, details = false)
|
|
||||||
{
|
|
||||||
def infos = [name: capablity.name]
|
|
||||||
|
|
||||||
if(details)
|
|
||||||
{
|
|
||||||
infos["attributes"] = capablity.attributes.collect { getAttributeInfos(it, details) }
|
|
||||||
infos["commands"] = capablity.commands.collect { getCommandInfos(it, details) }
|
|
||||||
}
|
|
||||||
|
|
||||||
return infos;
|
|
||||||
}
|
|
||||||
|
|
||||||
def getCommandInfos(command, details = false)
|
|
||||||
{
|
|
||||||
return [
|
|
||||||
name: command.name,
|
|
||||||
arguments: command.arguments
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|
||||||
def getAttributeInfos(attribute, details = false)
|
|
||||||
{
|
|
||||||
return [
|
|
||||||
name: attribute.name,
|
|
||||||
arguments: attribute.dataType,
|
|
||||||
values: attribute.values
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|
||||||
def getRoutineInfos(routine, details = false)
|
|
||||||
{
|
|
||||||
def infos = [
|
|
||||||
id: routine.id,
|
|
||||||
name: routine.label
|
|
||||||
];
|
|
||||||
|
|
||||||
if (details)
|
|
||||||
{
|
|
||||||
infos["hasSecureActions"] = routine.hasSecureActions;
|
|
||||||
infos["action"] = routine.action;
|
|
||||||
}
|
|
||||||
|
|
||||||
return infos;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Region: Push notification
|
|
||||||
def sendPushNotification(capability, eventArgs)
|
|
||||||
{
|
|
||||||
def deviceId = eventArgs.deviceId;
|
|
||||||
log.debug "Received notification for '${capability}' for device '${deviceId}'.";
|
|
||||||
|
|
||||||
def subscriptions = state.pushChannels.get(deviceId);
|
|
||||||
if (subscriptions == null || subscriptions.empty)
|
|
||||||
{
|
|
||||||
log.error "No subscription found for device ${deviceId}, unsubscribing!";
|
|
||||||
unsubscribe(eventArgs.device);
|
|
||||||
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
subscriptions.groupBy { it.channelUri }.each { sendPushNotification(capability, eventArgs, it.key, it.value) }
|
|
||||||
}
|
|
||||||
|
|
||||||
def sendPushNotification(capability, eventArgs, channelUri, subscriptions)
|
|
||||||
{
|
|
||||||
try {
|
|
||||||
def request = [
|
|
||||||
uri: channelUri,
|
|
||||||
//headers: [name: "Authorization", value: "Bearer ${subscription.token}"],
|
|
||||||
body: [
|
|
||||||
location: [
|
|
||||||
id: eventArgs.locationId,
|
|
||||||
],
|
|
||||||
device: getDeviceInfos(eventArgs.device),
|
|
||||||
event: [
|
|
||||||
source: capability,
|
|
||||||
date: eventArgs.isoDate,
|
|
||||||
value: eventArgs.value,
|
|
||||||
name: eventArgs.name,
|
|
||||||
],
|
|
||||||
subscriptions: subscriptions.collect { [id: it.id, token: it.token] }
|
|
||||||
]
|
|
||||||
]
|
|
||||||
|
|
||||||
// Async post is still in beta stage ...
|
|
||||||
httpPostJson(request) { resp -> log.debug "response: ${resp.status}." }
|
|
||||||
|
|
||||||
} catch (e) {
|
|
||||||
log.error "Failed to push notification: ${e}"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user