mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-19 05:10:51 +00:00
Compare commits
4 Commits
MSA-2140-2
...
PROD_2017.
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f6e99745ce | ||
|
|
fc70b5ce55 | ||
|
|
6996a07969 | ||
|
|
728b169a08 |
@@ -133,8 +133,8 @@ def updated() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
def initialize() {
|
def initialize() {
|
||||||
// Device only goes OFFLINE when Hub is off
|
// Arrival sensors only goes OFFLINE when Hub is off
|
||||||
sendEvent(name: "DeviceWatch-Enroll", value: JsonOutput.toJson([protocol: "zwave", scheme:"untracked"]), displayed: false)
|
sendEvent(name: "DeviceWatch-Enroll", value: JsonOutput.toJson([protocol: "zigbee", scheme:"untracked"]), displayed: false)
|
||||||
|
|
||||||
def zwMap = getZwaveInfo()
|
def zwMap = getZwaveInfo()
|
||||||
def buttons = 4 // Default for Key Fob
|
def buttons = 4 // Default for Key Fob
|
||||||
|
|||||||
@@ -111,6 +111,7 @@ def configure() {
|
|||||||
return cmds
|
return cmds
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
def installed() {
|
def installed() {
|
||||||
initialize()
|
initialize()
|
||||||
}
|
}
|
||||||
@@ -120,7 +121,7 @@ def updated() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
def initialize() {
|
def initialize() {
|
||||||
// Device only goes OFFLINE when Hub is off
|
// Arrival sensors only goes OFFLINE when Hub is off
|
||||||
sendEvent(name: "DeviceWatch-Enroll", value: JsonOutput.toJson([protocol: "zwave", scheme:"untracked"]), displayed: false)
|
sendEvent(name: "DeviceWatch-Enroll", value: JsonOutput.toJson([protocol: "zigbee", scheme:"untracked"]), displayed: false)
|
||||||
sendEvent(name: "numberOfButtons", value: 4)
|
sendEvent(name: "numberOfButtons", value: 4)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -72,7 +72,7 @@ def createEvents(physicalgraph.zwave.commands.batteryv1.BatteryReport cmd) {
|
|||||||
|
|
||||||
def poll() {
|
def poll() {
|
||||||
if (secondsPast(state.lastbatt, 36*60*60)) {
|
if (secondsPast(state.lastbatt, 36*60*60)) {
|
||||||
return zwave.batteryV1.batteryGet().format()
|
return zwave.batteryV1.batteryGet().format
|
||||||
} else {
|
} else {
|
||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,108 +0,0 @@
|
|||||||
/**
|
|
||||||
* MQTT Bridge
|
|
||||||
*
|
|
||||||
* Authors
|
|
||||||
* - st.john.johnson@gmail.com
|
|
||||||
* - jeremiah.wuenschel@gmail.com
|
|
||||||
*
|
|
||||||
* Copyright 2016
|
|
||||||
*
|
|
||||||
* 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.
|
|
||||||
*/
|
|
||||||
|
|
||||||
import groovy.json.JsonSlurper
|
|
||||||
import groovy.json.JsonOutput
|
|
||||||
|
|
||||||
metadata {
|
|
||||||
definition (name: "MQTT Bridge", namespace: "stj", author: "St. John Johnson and Jeremiah Wuenschel") {
|
|
||||||
capability "Notification"
|
|
||||||
}
|
|
||||||
|
|
||||||
preferences {
|
|
||||||
input("ip", "string",
|
|
||||||
title: "MQTT Bridge IP Address",
|
|
||||||
description: "MQTT Bridge IP Address",
|
|
||||||
required: true,
|
|
||||||
displayDuringSetup: true
|
|
||||||
)
|
|
||||||
input("port", "string",
|
|
||||||
title: "MQTT Bridge Port",
|
|
||||||
description: "MQTT Bridge Port",
|
|
||||||
required: true,
|
|
||||||
displayDuringSetup: true
|
|
||||||
)
|
|
||||||
input("mac", "string",
|
|
||||||
title: "MQTT Bridge MAC Address",
|
|
||||||
description: "MQTT Bridge MAC Address",
|
|
||||||
required: true,
|
|
||||||
displayDuringSetup: true
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
simulator {}
|
|
||||||
|
|
||||||
tiles {
|
|
||||||
valueTile("basic", "device.ip", width: 3, height: 2) {
|
|
||||||
state("basic", label:'OK')
|
|
||||||
}
|
|
||||||
main "basic"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Store the MAC address as the device ID so that it can talk to SmartThings
|
|
||||||
def setNetworkAddress() {
|
|
||||||
// Setting Network Device Id
|
|
||||||
def hex = "$settings.mac".toUpperCase().replaceAll(':', '')
|
|
||||||
if (device.deviceNetworkId != "$hex") {
|
|
||||||
device.deviceNetworkId = "$hex"
|
|
||||||
log.debug "Device Network Id set to ${device.deviceNetworkId}"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Parse events from the Bridge
|
|
||||||
def parse(String description) {
|
|
||||||
setNetworkAddress()
|
|
||||||
|
|
||||||
log.debug "Parsing '${description}'"
|
|
||||||
def msg = parseLanMessage(description)
|
|
||||||
|
|
||||||
return createEvent(name: "message", value: new JsonOutput().toJson(msg.data))
|
|
||||||
}
|
|
||||||
|
|
||||||
// Send message to the Bridge
|
|
||||||
def deviceNotification(message) {
|
|
||||||
if (device.hub == null)
|
|
||||||
{
|
|
||||||
log.error "Hub is null, must set the hub in the device settings so we can get local hub IP and port"
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
log.debug "Sending '${message}' to device"
|
|
||||||
setNetworkAddress()
|
|
||||||
|
|
||||||
def slurper = new JsonSlurper()
|
|
||||||
def parsed = slurper.parseText(message)
|
|
||||||
|
|
||||||
if (parsed.path == '/subscribe') {
|
|
||||||
parsed.body.callback = device.hub.getDataValue("localIP") + ":" + device.hub.getDataValue("localSrvPortTCP")
|
|
||||||
}
|
|
||||||
|
|
||||||
def headers = [:]
|
|
||||||
headers.put("HOST", "$ip:$port")
|
|
||||||
headers.put("Content-Type", "application/json")
|
|
||||||
|
|
||||||
def hubAction = new physicalgraph.device.HubAction(
|
|
||||||
method: "POST",
|
|
||||||
path: parsed.path,
|
|
||||||
headers: headers,
|
|
||||||
body: parsed.body
|
|
||||||
)
|
|
||||||
hubAction
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user