Initial commit

smartapps/imbrianj/ready-for-rain.src/ready-for-rain.groovy

@@ -0,0 +1,134 @@
+/**
+ *  Ready for Rain
+ *
+ *  Author: brian@bevey.org
+ *  Date: 9/10/13
+ *
+ *  Warn if doors or windows are open when inclement weather is approaching.
+ */
+
+definition(
+  name: "Ready For Rain",
+  namespace: "imbrianj",
+  author: "brian@bevey.org",
+  description: "Warn if doors or windows are open when inclement weather is approaching.",
+  category: "Convenience",
+  iconUrl: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience.png",
+  iconX2Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience%402x.png"
+)
+
+preferences {
+  section("Zip code?") {
+    input "zipcode", "text", title: "Zipcode?"
+  }
+
+  section("Things to check?") {
+    input "sensors", "capability.contactSensor", multiple: true
+  }
+
+  section("Notifications?") {
+    input "sendPushMessage", "enum", title: "Send a push notification?", metadata: [values: ["Yes", "No"]], required: false
+    input "phone", "phone", title: "Send a Text Message?", required: false
+  }
+
+  section("Message interval?") {
+    input name: "messageDelay", type: "number", title: "Minutes (default to every message)", required: false
+  }
+}
+
+def installed() {
+  init()
+}
+
+def updated() {
+  unsubscribe()
+  unschedule()
+  init()
+}
+
+def init() {
+  state.lastMessage = 0
+  state.lastCheck = ["time": 0, "result": false]
+  schedule("0 0,30 * * * ?", scheduleCheck) // Check at top and half-past of every hour
+  subscribe(sensors, "contact.open", scheduleCheck)
+}
+
+def scheduleCheck(evt) {
+  def open = sensors.findAll { it?.latestValue("contact") == "open" }
+  def plural = open.size() > 1 ? "are" : "is"
+
+  // Only need to poll if we haven't checked in a while - and if something is left open.
+  if((now() - (30 * 60 * 1000) > state.lastCheck["time"]) && open) {
+    log.info("Something's open - let's check the weather.")
+    def response = getWeatherFeature("forecast", zipcode)
+    def weather  = isStormy(response)
+
+    if(weather) {
+      send("${open.join(', ')} ${plural} open and ${weather} coming.")
+    }
+  }
+
+  else if(((now() - (30 * 60 * 1000) <= state.lastCheck["time"]) && state.lastCheck["result"]) && open) {
+    log.info("We have fresh weather data, no need to poll.")
+    send("${open.join(', ')} ${plural} open and ${state.lastCheck["result"]} coming.")
+  }
+
+  else {
+    log.info("Everything looks closed, no reason to check weather.")
+  }
+}
+
+private send(msg) {
+  def delay = (messageDelay != null && messageDelay != "") ? messageDelay * 60 * 1000 : 0
+
+  if(now() - delay > state.lastMessage) {
+    state.lastMessage = now()
+    if(sendPushMessage == "Yes") {
+      log.debug("Sending push message.")
+      sendPush(msg)
+    }
+
+    if(phone) {
+      log.debug("Sending text message.")
+      sendSms(phone, msg)
+    }
+
+    log.debug(msg)
+  }
+
+  else {
+    log.info("Have a message to send, but user requested to not get it.")
+  }
+}
+
+private isStormy(json) {
+  def types    = ["rain", "snow", "showers", "sprinkles", "precipitation"]
+  def forecast = json?.forecast?.txt_forecast?.forecastday?.first()
+  def result   = false
+
+  if(forecast) {
+    def text = forecast?.fcttext?.toLowerCase()
+
+    log.debug(text)
+
+    if(text) {
+      for (int i = 0; i < types.size() && !result; i++) {
+        if(text.contains(types[i])) {
+          result = types[i]
+        }
+      }
+    }
+
+    else {
+      log.warn("Got forecast, couldn't parse.")
+    }
+  }
+
+  else {
+    log.warn("Did not get a forecast: ${json}")
+  }
+
+  state.lastCheck = ["time": now(), "result": result]
+
+  return result
+}