--- /dev/null
+/**
+ * Simple Sync Connect
+ *
+ * Copyright 2015 Roomie Remote, Inc.
+ *
+ * Date: 2015-09-22
+ */
+
+definition(
+ name: "Simple Sync Connect",
+ namespace: "roomieremote-raconnect",
+ author: "Roomie Remote, Inc.",
+ description: "Integrate SmartThings with your Simple Control activities via Simple Sync.",
+ category: "My Apps",
+ iconUrl: "https://s3.amazonaws.com/roomieuser/remotes/simplesync-60.png",
+ iconX2Url: "https://s3.amazonaws.com/roomieuser/remotes/simplesync-120.png",
+ iconX3Url: "https://s3.amazonaws.com/roomieuser/remotes/simplesync-120.png")
+
+preferences()
+{
+ page(name: "mainPage", title: "Simple Sync Setup", content: "mainPage", refreshTimeout: 5)
+ page(name:"agentDiscovery", title:"Simple Sync Discovery", content:"agentDiscovery", refreshTimeout:5)
+ page(name:"manualAgentEntry")
+ page(name:"verifyManualEntry")
+}
+
+def mainPage()
+{
+ if (canInstallLabs())
+ {
+ return agentDiscovery()
+ }
+ else
+ {
+ def upgradeNeeded = """To use SmartThings Labs, your Hub should be completely up to date.
+
+To update your Hub, access Location Settings in the Main Menu (tap the gear next to your location name), select your Hub, and choose "Update Hub"."""
+
+ return dynamicPage(name:"mainPage", title:"Upgrade needed!", nextPage:"", install:false, uninstall: true) {
+ section("Upgrade")
+ {
+ paragraph "$upgradeNeeded"
+ }
+ }
+ }
+}
+
+def agentDiscovery(params=[:])
+{
+ int refreshCount = !state.refreshCount ? 0 : state.refreshCount as int
+ state.refreshCount = refreshCount + 1
+ def refreshInterval = refreshCount == 0 ? 2 : 5
+
+ if (!state.subscribe)
+ {
+ subscribe(location, null, locationHandler, [filterEvents:false])
+ state.subscribe = true
+ }
+
+ //ssdp request every fifth refresh
+ if ((refreshCount % 5) == 0)
+ {
+ discoverAgents()
+ }
+
+ def agentsDiscovered = agentsDiscovered()
+
+ return dynamicPage(name:"agentDiscovery", title:"Pair with Simple Sync", nextPage:"", refreshInterval: refreshInterval, install:true, uninstall: true) {
+ section("Pair with Simple Sync")
+ {
+ input "selectedAgent", "enum", required:true, title:"Select Simple Sync\n(${agentsDiscovered.size() ?: 0} found)", multiple:false, options:agentsDiscovered
+ href(name:"manualAgentEntry",
+ title:"Manually Configure Simple Sync",
+ required:false,
+ page:"manualAgentEntry")
+ }
+ }
+}
+
+def manualAgentEntry()
+{
+ dynamicPage(name:"manualAgentEntry", title:"Manually Configure Simple Sync", nextPage:"verifyManualEntry", install:false, uninstall:true) {
+ section("Manually Configure Simple Sync")
+ {
+ paragraph "In the event that Simple Sync cannot be automatically discovered by your SmartThings hub, you may enter Simple Sync's IP address here."
+ input(name: "manualIPAddress", type: "text", title: "IP Address", required: true)
+ }
+ }
+}
+
+def verifyManualEntry()
+{
+ def hexIP = convertIPToHexString(manualIPAddress)
+ def hexPort = convertToHexString(47147)
+ def uuid = "593C03D2-1DA9-4CDB-A335-6C6DC98E56C3"
+ def hubId = ""
+
+ for (hub in location.hubs)
+ {
+ if (hub.localIP != null)
+ {
+ hubId = hub.id
+ break
+ }
+ }
+
+ def manualAgent = [deviceType: "04",
+ mac: "unknown",
+ ip: hexIP,
+ port: hexPort,
+ ssdpPath: "/upnp/Roomie.xml",
+ ssdpUSN: "uuid:$uuid::urn:roomieremote-com:device:roomie:1",
+ hub: hubId,
+ verified: true,
+ name: "Simple Sync $manualIPAddress"]
+
+ state.agents[uuid] = manualAgent
+
+ addOrUpdateAgent(state.agents[uuid])
+
+ dynamicPage(name: "verifyManualEntry", title: "Manual Configuration Complete", nextPage: "", install:true, uninstall:true) {
+ section("")
+ {
+ paragraph("Tap Done to complete the installation process.")
+ }
+ }
+}
+
+def discoverAgents()
+{
+ def urn = getURN()
+
+ sendHubCommand(new physicalgraph.device.HubAction("lan discovery $urn", physicalgraph.device.Protocol.LAN))
+}
+
+def agentsDiscovered()
+{
+ def gAgents = getAgents()
+ def agents = gAgents.findAll { it?.value?.verified == true }
+ def map = [:]
+ agents.each
+ {
+ map["${it.value.uuid}"] = it.value.name
+ }
+ map
+}
+
+def getAgents()
+{
+ if (!state.agents)
+ {
+ state.agents = [:]
+ }
+
+ state.agents
+}
+
+def installed()
+{
+ initialize()
+}
+
+def updated()
+{
+ initialize()
+}
+
+def initialize()
+{
+ if (state.subscribe)
+ {
+ unsubscribe()
+ state.subscribe = false
+ }
+
+ if (selectedAgent)
+ {
+ addOrUpdateAgent(state.agents[selectedAgent])
+ }
+}
+
+def addOrUpdateAgent(agent)
+{
+ def children = getChildDevices()
+ def dni = agent.ip + ":" + agent.port
+ def found = false
+
+ children.each
+ {
+ if ((it.getDeviceDataByName("mac") == agent.mac))
+ {
+ found = true
+
+ if (it.getDeviceNetworkId() != dni)
+ {
+ it.setDeviceNetworkId(dni)
+ }
+ }
+ else if (it.getDeviceNetworkId() == dni)
+ {
+ found = true
+ }
+ }
+
+ if (!found)
+ {
+ addChildDevice("roomieremote-agent", "Simple Sync", dni, agent.hub, [label: "Simple Sync"])
+ }
+}
+
+def locationHandler(evt)
+{
+ def description = evt?.description
+ def urn = getURN()
+ def hub = evt?.hubId
+ def parsedEvent = parseEventMessage(description)
+
+ parsedEvent?.putAt("hub", hub)
+
+ //SSDP DISCOVERY EVENTS
+ if (parsedEvent?.ssdpTerm?.contains(urn))
+ {
+ def agent = parsedEvent
+ def ip = convertHexToIP(agent.ip)
+ def agents = getAgents()
+
+ agent.verified = true
+ agent.name = "Simple Sync $ip"
+
+ if (!agents[agent.uuid])
+ {
+ state.agents[agent.uuid] = agent
+ }
+ }
+}
+
+private def parseEventMessage(String description)
+{
+ def event = [:]
+ def parts = description.split(',')
+
+ parts.each
+ { part ->
+ part = part.trim()
+ if (part.startsWith('devicetype:'))
+ {
+ def valueString = part.split(":")[1].trim()
+ event.devicetype = valueString
+ }
+ else if (part.startsWith('mac:'))
+ {
+ def valueString = part.split(":")[1].trim()
+ if (valueString)
+ {
+ event.mac = valueString
+ }
+ }
+ else if (part.startsWith('networkAddress:'))
+ {
+ def valueString = part.split(":")[1].trim()
+ if (valueString)
+ {
+ event.ip = valueString
+ }
+ }
+ else if (part.startsWith('deviceAddress:'))
+ {
+ def valueString = part.split(":")[1].trim()
+ if (valueString)
+ {
+ event.port = valueString
+ }
+ }
+ else if (part.startsWith('ssdpPath:'))
+ {
+ def valueString = part.split(":")[1].trim()
+ if (valueString)
+ {
+ event.ssdpPath = valueString
+ }
+ }
+ else if (part.startsWith('ssdpUSN:'))
+ {
+ part -= "ssdpUSN:"
+ def valueString = part.trim()
+ if (valueString)
+ {
+ event.ssdpUSN = valueString
+
+ def uuid = getUUIDFromUSN(valueString)
+
+ if (uuid)
+ {
+ event.uuid = uuid
+ }
+ }
+ }
+ else if (part.startsWith('ssdpTerm:'))
+ {
+ part -= "ssdpTerm:"
+ def valueString = part.trim()
+ if (valueString)
+ {
+ event.ssdpTerm = valueString
+ }
+ }
+ else if (part.startsWith('headers'))
+ {
+ part -= "headers:"
+ def valueString = part.trim()
+ if (valueString)
+ {
+ event.headers = valueString
+ }
+ }
+ else if (part.startsWith('body'))
+ {
+ part -= "body:"
+ def valueString = part.trim()
+ if (valueString)
+ {
+ event.body = valueString
+ }
+ }
+ }
+
+ event
+}
+
+def getURN()
+{
+ return "urn:roomieremote-com:device:roomie:1"
+}
+
+def getUUIDFromUSN(usn)
+{
+ def parts = usn.split(":")
+
+ for (int i = 0; i < parts.size(); ++i)
+ {
+ if (parts[i] == "uuid")
+ {
+ return parts[i + 1]
+ }
+ }
+}
+
+def String convertHexToIP(hex)
+{
+ [convertHexToInt(hex[0..1]),convertHexToInt(hex[2..3]),convertHexToInt(hex[4..5]),convertHexToInt(hex[6..7])].join(".")
+}
+
+def Integer convertHexToInt(hex)
+{
+ Integer.parseInt(hex,16)
+}
+
+def String convertToHexString(n)
+{
+ String hex = String.format("%X", n.toInteger())
+}
+
+def String convertIPToHexString(ipString)
+{
+ String hex = ipString.tokenize(".").collect {
+ String.format("%02X", it.toInteger())
+ }.join()
+}
+
+def Boolean canInstallLabs()
+{
+ return hasAllHubsOver("000.011.00603")
+}
+
+def Boolean hasAllHubsOver(String desiredFirmware)
+{
+ return realHubFirmwareVersions.every { fw -> fw >= desiredFirmware }
+}
+
+def List getRealHubFirmwareVersions()
+{
+ return location.hubs*.firmwareVersionString.findAll { it }
+}
\ No newline at end of file
projects / smartapps.git / blobdiff