1
mirror of https://github.com/home-assistant/core synced 2024-10-04 07:58:43 +02:00

Addressed the comments in the issue. pep8+pylint seem fine now. (still works, too.)

This commit is contained in:
Markus Stenberg 2014-04-24 17:13:57 +03:00
parent 39d1fad8cc
commit 88fd75b4c7
2 changed files with 18 additions and 26 deletions

View File

@ -150,8 +150,8 @@ def from_config_file(config_path, enable_logging=True):
if has_section("process"):
process = load_module('process')
kwargs = dict(config.items('process'))
add_status("process", process.setup(bus, statemachine, **kwargs))
processes = dict(config.items('process'))
add_status("process", process.setup(hass, processes))
# Light control
if has_section("light.hue"):

View File

@ -9,8 +9,8 @@
# Copyright (c) 2014 Markus Stenberg
#
# Created: Wed Apr 23 23:33:26 2014 mstenber
# Last modified: Wed Apr 23 23:48:13 2014 mstenber
# Edit time: 13 min
# Last modified: Thu Apr 24 17:13:04 2014 mstenber
# Edit time: 19 min
#
"""
@ -20,40 +20,32 @@ The arguments are <subentityname>=<substring to find in process list>
"""
import homeassistant as ha
from homeassistant.components import (STATE_ON, STATE_OFF)
import os
DOMAIN = 'process'
ENTITY_ID_FORMAT = DOMAIN + '.{}'
PS_STRING = 'ps awx'
PS_STRING='ps awx'
INTERVAL=30
def setup(hass, processes):
""" Track local processes. """
def setup(bus, statemachine, **processes):
_states = {}
def _update_process_state(t, force_reload=False):
with os.popen(PS_STRING, 'r') as f:
lines = list(iter(f))
for e, s in processes.items():
# pylint: disable=unused-argument
def _update_process_state(time):
""" Check ps for currently running processes. """
with os.popen(PS_STRING, 'r') as psfile:
lines = list(iter(psfile))
for pname, pstring in processes.items():
found = False
for line in lines:
if s in line:
if pstring in line:
found = True
break
if _states.get(e, None) == found:
continue
_states[e] = found
entity_id = ENTITY_ID_FORMAT.format(e)
entity_id = ENTITY_ID_FORMAT.format(pname)
state = found and STATE_ON or STATE_OFF
statemachine.set_state(entity_id, state)
hass.states.set(entity_id, state)
_update_process_state(None, True)
kwargs = {}
if INTERVAL != ha.TIMER_INTERVAL:
kwargs['second'] = [0, INTERVAL]
assert INTERVAL > ha.TIMER_INTERVAL
ha.track_time_change(bus, _update_process_state)
_update_process_state(None)
hass.track_time_change(_update_process_state, second=[0, 30])
return True