From c78bdd21c285af3ce948c8a46d1fd3f6bd104916 Mon Sep 17 00:00:00 2001
From: johannes walcher <johannes.walcher@stusta.de>
Date: Thu, 26 Jul 2018 23:15:53 +0200
Subject: [PATCH] running fixes
---
hauptbahnhof/hauptbahnhof.py | 5 +++--
rupprecht/rupprecht.py | 17 +++++++++++------
2 files changed, 14 insertions(+), 8 deletions(-)
diff --git a/hauptbahnhof/hauptbahnhof.py b/hauptbahnhof/hauptbahnhof.py
index f668b48..d5639ce 100644
--- a/hauptbahnhof/hauptbahnhof.py
+++ b/hauptbahnhof/hauptbahnhof.py
@@ -75,15 +75,16 @@ class Hauptbahnhof:
self.loop.cancel()
raise
await self.connected.wait()
- self.log.info("Successfully connected to %s", self._config['host'])
+ self.log.info("Successfully connected to %s", self._config['host'])
for topic in self._subscriptions:
mqtt.subscribe(topic)
+ self._mqtt = mqtt
while self._mqtt_queue:
topic, msg = self._mqtt_queue.pop(0)
self.log.debug("Topic: %s", topic)
- await self._mqtt.publish(topic, msg)
+ self._mqtt.publish(topic, msg)
# Now we have mqtt available!
self._mqtt = mqtt
diff --git a/rupprecht/rupprecht.py b/rupprecht/rupprecht.py
index 9fd94fc..07768d3 100644
--- a/rupprecht/rupprecht.py
+++ b/rupprecht/rupprecht.py
@@ -34,16 +34,19 @@ class Rupprecht:
self.space_is_open = False
try:
- r = RupprechtInterface("/dev/ttyACM0")
+ self.rupprecht = RupprechtInterface("/dev/ttyACM0")
except serial.SerialException:
- r = RupprechtInterface("/tmp/rupprechtemulator")
+ self.rupprecht = RupprechtInterface("/tmp/rupprechtemulator")
- r.subscribe_button(self.button_message)
+ self.rupprecht.subscribe_button(self.button_message)
self.imposed_ids = {
- 'rupprecht-table': rcswitch.Quigg1000(code=1337, subaddr=1, rupprecht=r),
- 'rupprecht-alarm': rcswitch.Quigg1000(code=1337, subaddr=2, rupprecht=r),
- 'rupprecht-fan': rcswitch.Quigg1000(code=1337, subaddr=3, rupprecht=r)
+ 'rupprecht-table': rcswitch.Quigg1000(code=1337, subaddr=1,
+ rupprecht=self.rupprecht),
+ 'rupprecht-alarm': rcswitch.Quigg1000(code=1337, subaddr=2,
+ rupprecht=self.rupprecht),
+ 'rupprecht-fan': rcswitch.Quigg1000(code=1337, subaddr=3,
+ rupprecht=self.rupprecht)
}
async def teardown(self):
@@ -65,9 +68,11 @@ class Rupprecht:
if msg['open'] and not self.space_is_open:
self.space_is_open = True
await self.hbf.publish('/haspa/status', json.dumps({'haspa':'open'}))
+ self.rupprecht.text("Status: Open")
elif not msg['open'] and self.space_is_open:
self.space_is_open = False
await self.hbf.publish('/haspa/status', json.dumps({'haspa':'closed'}))
+ self.rupprecht.text("Status: Closed")
class RupprechtInterface:
class SerialProtocol(asyncio.Protocol):
--
GitLab