Skip to content
Snippets Groups Projects
Commit 79ebe650 authored by jkerdreu's avatar jkerdreu
Browse files

New run_package API

git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/trunk@2072 b32b6428-25c9-4566-ad07-03861ab6144f
parent eac528a8
No related branches found
No related tags found
No related merge requests found
from xaal.lib import Engine
from . import gw from . import gw
from xaal.lib import helpers
def main(): helpers.run_package(gw.PACKAGE_NAME,gw.setup)
eng = Engine()
gw.setup(eng)
eng.run()
if __name__ == '__main__':
try:
main()
except KeyboardInterrupt:
print("bye bye")
...@@ -7,10 +7,10 @@ from . import devices ...@@ -7,10 +7,10 @@ from . import devices
import inspect import inspect
import atexit import atexit
import logging
PACKAGE_NAME = 'xaal.aqara' PACKAGE_NAME = 'xaal.aqara'
logger = tools.get_logger(PACKAGE_NAME,'DEBUG') logger = logging.getLogger(PACKAGE_NAME)
def find_device_class(model): def find_device_class(model):
if model in ['sensor_switch.aq3','sensor_switch.aq2','switch','86sw1']: if model in ['sensor_switch.aq3','sensor_switch.aq2','switch','86sw1']:
...@@ -39,7 +39,7 @@ class GW(gevent.Greenlet): ...@@ -39,7 +39,7 @@ class GW(gevent.Greenlet):
atexit.register(self._exit) atexit.register(self._exit)
self.config() self.config()
self.setup() self.setup()
def config(self): def config(self):
cfg = tools.load_cfg(PACKAGE_NAME) cfg = tools.load_cfg(PACKAGE_NAME)
if not cfg: if not cfg:
......
from . import gw from . import gw
gw.main() from xaal.lib import helpers
helpers.run_package(gw.PACKAGE_NAME,gw.setup)
...@@ -4,9 +4,10 @@ from xaal.lib import tools,Engine,Device ...@@ -4,9 +4,10 @@ from xaal.lib import tools,Engine,Device
import platform import platform
import serial import serial
import logging
PACKAGE_NAME = "xaal.hq433" PACKAGE_NAME = "xaal.hq433"
logger = tools.get_logger(PACKAGE_NAME,'DEBUG') logger = logging.getLogger(PACKAGE_NAME)
def new_dev(gw,key,channel,addr,dtype): def new_dev(gw,key,channel,addr,dtype):
...@@ -51,7 +52,11 @@ class GW(object): ...@@ -51,7 +52,11 @@ class GW(object):
""" connect to serial port, and load configuration file""" """ connect to serial port, and load configuration file"""
# connect to serial port # connect to serial port
port = self.cfg['config']['port'] port = self.cfg['config']['port']
self.ser = serial.Serial(port,19200,timeout=0.5) try:
self.ser = serial.Serial(port,19200,timeout=0.5)
except:
logger.critical('Unable to open serial port')
return
# load devices from # load devices from
devices = [] devices = []
...@@ -82,16 +87,6 @@ class GW(object): ...@@ -82,16 +87,6 @@ class GW(object):
return True return True
def run(): def setup(engine):
eng = Engine() GW(engine)
gw = GW(eng) return True
eng.run() \ No newline at end of file
def main():
try:
run()
except KeyboardInterrupt:
print("Bye Bye...")
if __name__ == '__main__':
main()
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment