revil-O/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Lazy initialization of WeMo environment

Browse source
This commit is contained in:
Fabio Manganiello 2019-01-11 19:58:40 +01:00
parent 33fd226fa1
commit 212cfb63c4
1 changed files with 17 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
platypush/plugins/switch/wemo/__init__.py
View file

@ -1,6 +1,5 @@
import json import json
from ouimeaux.environment import Environment, UnknownDevice
from platypush.plugins import action from platypush.plugins import action
from platypush.plugins.switch import SwitchPlugin from platypush.plugins.switch import SwitchPlugin
@ -23,16 +22,22 @@ class SwitchWemoPlugin(SwitchPlugin):
super().__init__(*args, **kwargs) super().__init__(*args, **kwargs)
self.discovery_seconds = discovery_seconds self.discovery_seconds = discovery_seconds
self.env = Environment() self.env = None
self.env.start()
self.refresh_devices()
def refresh_devices(self): def _refresh_devices(self):
""" Update the list of available devices """ """ Update the list of available devices """
self.logger.info('Starting WeMo discovery') self.logger.info('Starting WeMo discovery')
self._get_environment()
self.env.discover(seconds=self.discovery_seconds) self.env.discover(seconds=self.discovery_seconds)
self.devices = self.env.devices self.devices = self.env.devices
def _get_environment(self):
if not self.env:
from ouimeaux.environment import Environment
self.env = Environment()
self.env.start()
self._refresh_devices()
@action @action
def get_devices(self): def get_devices(self):
""" """
@ -57,7 +62,7 @@ class SwitchWemoPlugin(SwitchPlugin):
] ]
} }
""" """
self.refresh_devices() self._refresh_devices()
return { return {
'devices': [ 'devices': [
{ {
@ -72,13 +77,16 @@ class SwitchWemoPlugin(SwitchPlugin):
} }
def _exec(self, method, device, *args, **kwargs): def _exec(self, method, device, *args, **kwargs):
self._get_environment()
if device not in self.devices: if device not in self.devices:
self.refresh_devices() self._refresh_devices()
if device not in self.devices: if device not in self.devices:
raise RuntimeError('Device {} not found'.format(device)) raise RuntimeError('Device {} not found'.format(device))
self.logger.info('{} -> {}'.format(device, method)) self.logger.info('Executing {} on WeMo device {}'.
format(method, device))
dev = self.devices[device] dev = self.devices[device]
getattr(dev, method)(*args, **kwargs) getattr(dev, method)(*args, **kwargs)