added the for param to the conditions as well

homeassistant/components/automation/state.py

@@ -24,6 +24,31 @@ CONF_STATE = "state"
 CONF_FOR = "for"
 
 
+def get_time_config(config):
+    """ Helper function to extract the time specified in the config """
+    if CONF_FOR in config:
+        hours = config[CONF_FOR].get(CONF_HOURS)
+        minutes = config[CONF_FOR].get(CONF_MINUTES)
+        seconds = config[CONF_FOR].get(CONF_SECONDS)
+
+        if hours is None and minutes is None and seconds is None:
+            logging.getLogger(__name__).error(
+                "Received invalid value for '%s': %s",
+                config[CONF_FOR], CONF_FOR)
+            return False
+
+        if config.get(CONF_TO) is None and config.get(CONF_STATE) is None:
+            logging.getLogger(__name__).error(
+                "For: requires a to: value'%s': %s",
+                config[CONF_FOR], CONF_FOR)
+            return False
+
+        return timedelta(hours=(hours or 0.0),
+                         minutes=(minutes or 0.0),
+                         seconds=(seconds or 0.0))
+    return False
+
+
 def trigger(hass, config, action):
     """ Listen for state changes based on `config`. """
     entity_id = config.get(CONF_ENTITY_ID)
@@ -42,20 +67,8 @@ def trigger(hass, config, action):
         return False
 
     if CONF_FOR in config:
-        hours = config[CONF_FOR].get(CONF_HOURS)
+        time_delta = get_time_config(config)
-        minutes = config[CONF_FOR].get(CONF_MINUTES)
+        if time_delta is False:
-        seconds = config[CONF_FOR].get(CONF_SECONDS)
-
-        if hours is None and minutes is None and seconds is None:
-            logging.getLogger(__name__).error(
-                "Received invalid value for '%s': %s",
-                config[CONF_FOR], CONF_FOR)
-            return False
-
-        if config.get(CONF_TO) is None and config.get(CONF_STATE) is None:
-            logging.getLogger(__name__).error(
-                "For: requires a to: value'%s': %s",
-                config[CONF_FOR], CONF_FOR)
             return False
 
     def state_automation_listener(entity, from_s, to_s):
@@ -77,11 +90,7 @@ def trigger(hass, config, action):
                 EVENT_STATE_CHANGED, for_state_listener)
 
         if CONF_FOR in config:
-            now = dt_util.now()
+            target_tm = dt_util.now() + time_delta
-            target_tm = now + timedelta(
-                hours=(hours or 0.0),
-                minutes=(minutes or 0.0),
-                seconds=(seconds or 0.0))
             for_time_listener = track_point_in_time(
                 hass, state_for_listener, target_tm)
             for_state_listener = track_state_change(
@@ -101,6 +110,11 @@ def if_action(hass, config):
     entity_id = config.get(CONF_ENTITY_ID)
     state = config.get(CONF_STATE)
 
+    if CONF_FOR in config:
+        time_delta = get_time_config(config)
+        if time_delta is False:
+            return False
+
     if entity_id is None or state is None:
         logging.getLogger(__name__).error(
             "Missing if-condition configuration key %s or %s", CONF_ENTITY_ID,
@@ -111,6 +125,13 @@ def if_action(hass, config):
 
     def if_state():
         """ Test if condition. """
-        return hass.states.is_state(entity_id, state)
+        if hass.states.is_state(entity_id, state):
+            if CONF_FOR in config:
+                target_tm = dt_util.now() - time_delta
+                return target_tm > hass.states.get(entity_id).last_changed
+            else:
+                return True
+        else:
+            return False
 
     return if_state

tests/components/automation/test_state.py

@@ -6,7 +6,7 @@ Tests state automation.
 """
 import unittest
 from datetime import timedelta
-
+import time
 import homeassistant.util.dt as dt_util
 import homeassistant.components.automation as automation
 import homeassistant.components.automation.state as state
@@ -423,3 +423,37 @@ class TestAutomationState(unittest.TestCase):
         fire_time_changed(self.hass, dt_util.utcnow() + timedelta(seconds=10))
         self.hass.pool.block_till_done()
         self.assertEqual(1, len(self.calls))
+
+    def test_if_fires_on_for_condition(self):
+        self.hass.states.set('test.entity', 'on')
+        self.assertTrue(automation.setup(self.hass, {
+            automation.DOMAIN: {
+                'trigger': {
+                    'platform': 'event',
+                    'event_type': 'test_event',
+                },
+                'condition': {
+                    'platform': 'state',
+                    'entity_id': 'test.entity',
+                    'state': 'on',
+                    'for': {
+                        'seconds': 3
+                    },
+                },
+
+                'action': {
+                    'service': 'test.automation'
+                }
+            }
+        }))
+
+        # not enough time has passed
+        self.hass.bus.fire('test_event')
+        self.hass.pool.block_till_done()
+        self.assertEqual(0, len(self.calls))
+
+        # wait until we have passed the condition
+        time.sleep(4)
+        self.hass.bus.fire('test_event')
+        self.hass.pool.block_till_done()
+        self.assertEqual(1, len(self.calls))