diff --git a/babel/babel.py b/babel/babel.py
index 3db702268ebb88e1d25989606d0d1b6c0a1a32a6..b7c77236456cb6014049d6374e3101a1eeb7f3cf 100644
--- a/babel/babel.py
+++ b/babel/babel.py
@@ -16,17 +16,17 @@ class Babel:
self.hbf.subscribe('/haspa/power/requestinfo', self.command_requestinfo)
self.hbf.subscribe('/haspa/power/status', self.command_requeststatus)
- self.ledstrip_states = [[0, 0, 0, 0], [0, 0, 0, 0]]
- self.espids = ['a9495a00', 'c14e5a00']
+ self.ledstrip_states = [[0] * 8, [0] * 8]
+ #self.espids = ['a9495a00', 'c14e5a00']
+ # new 4 channel ESPs
+ self.espids = ['f97c7300', 'dfd80b00']
# mapps from (color, id) ==> (self.ledstrip indexes)
self.idxpair = {
- # The first one has cold and warm swapped...
- ('w', 2):(0, 0),
- ('c', 2):(0, 1),
- ('w', 1):(0, 2),
- ('c', 1):(0, 3),
- # This one has cold and warm right
+ ('c', 2):(0, 0),
+ ('w', 2):(0, 1),
+ ('c', 1):(0, 6),
+ ('w', 1):(0, 7),
('c', 3):(1, 0),
('w', 3):(1, 1),
('c', 4):(1, 2),
@@ -55,7 +55,7 @@ class Babel:
## The lamp is managed by rupprecht
if lamp in self.rupprecht_map:
msg[self.rupprecht_map[lamp][0]] = int(value)
- self.rupprecht_map[lamp][1] = int(value)
+ self.rupprecht_map[lamp] = (self.rupprecht_map[lamp][0], int(value))
## The lamp is a led strip and needs to be aggregated
if lamp.startswith('ledstrip'):
diff --git a/hackerman/hackerman.py b/hackerman/hackerman.py
index b623d51ed76a56da311c0c081bdcbd9043f177be..415c38bfcfd4fa02dba4f363a6bc4f0f2ec52431 100644
--- a/hackerman/hackerman.py
+++ b/hackerman/hackerman.py
@@ -54,12 +54,26 @@ class Hackerman:
async def command_action(self, client, message, _):
""" Handle actions like alarm or party """
del client
+ print(message)
if 'action' in message:
if message['action'] == 'alarm':
+ print("Performing alarm...")
await self.hbf.publish('/haspa/power', {'alarm':1023})
await asyncio.sleep(2)
await self.hbf.publish('/haspa/power', {'alarm':0})
+ elif message['action'] == 'strobo':
+ for i in range(100):
+ await self.hbf.publish('/haspa/power', {
+ 'ledstrip-c': 0
+ })
+ await asyncio.sleep(0.05)
+ await self.hbf.publish('/haspa/power', {
+ 'ledstrip-c': 1023
+ })
+ await asyncio.sleep(0.03)
+
+
elif message['action'] == 'party':
await self.hbf.publish('/haspa/power', {
'alarm':0,
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000000000000000000000000000000000000..37f6209b733de0942424d05cfb2b007e02fa1d10
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,4 @@
+libconf==1.0.1
+paho-mqtt==1.3.1
+pyserial==3.4
+pyserial-asyncio==0.4
diff --git a/rupprecht/rcswitch.py b/rupprecht/rcswitch.py
index 9851d526838562ecdd1c70f0c04d50e19fd5e090..44b3512ffaf7690635a3c702a461c400af86e4c8 100644
--- a/rupprecht/rcswitch.py
+++ b/rupprecht/rcswitch.py
@@ -92,10 +92,14 @@ class Quigg1000:
async def __send_msg(self, msg):
if self.rupprecht:
+ print("sending via rupprecht message", msg)
await self.rupprecht.light(msg)
+ await asyncio.sleep(1)
if self.serial:
+ print("sending via raw message", msg)
try:
- self.ser.write(str.encode(msg))
+ self.serial.write(str.encode(msg))
+ await asyncio.sleep(1)
except serial.SerialException:
print('Serial communication failed.')
@@ -113,6 +117,7 @@ def main():
default=False, action='store_true')
args = parser.parse_args()
+ loop=asyncio.get_event_loop()
try:
s = serial.Serial(args.device, 9600)
@@ -121,7 +126,6 @@ def main():
exit()
r = Quigg1000(serial=s, loop=loop, code=args.set_code, subaddr=args.addr)
- loop=asyncio.get_event_loop()
loop.run_until_complete(r.state(args.state, args.debug))
if __name__ == '__main__':
diff --git a/rupprecht/rupprecht.py b/rupprecht/rupprecht.py
index c55709cec742dccd7cd3d3aec76e9b515dcf7e8a..bb31da69902b7585a9759b6adea2c4c670816a59 100644
--- a/rupprecht/rupprecht.py
+++ b/rupprecht/rupprecht.py
@@ -52,9 +52,9 @@ class Rupprecht:
async def teardown(self):
await self.hbf.teardown()
- async def command_led(self, source, payload, mqttmsg):
- del source, payload
- msg = json.loads(mqttmsg.payload.decode('utf-8'))
+ async def command_led(self, source, msg, mqttmsg):
+ print("having LED command", msg)
+ del source, mqttmsg
for devid, value in msg.items():
try:
if value == 0:
@@ -68,17 +68,16 @@ class Rupprecht:
if msg['open'] and not self.space_is_open:
self.space_is_open = True
await self.hbf.publish('/haspa/status', {'haspa':'open'})
- self.rupprecht.text("Status:Open... StuStaNet.e.V....")
+ await self.rupprecht.text("Status:Open... StuStaNet.e.V....")
elif not msg['open'] and self.space_is_open:
self.space_is_open = False
await self.hbf.publish('/haspa/status', {'haspa':'closed'})
- self.rupprecht.text("Status:Closed... StuStaNet.e.V....")
+ await self.rupprecht.text("Status:Closed... StuStaNet.e.V....")
class RupprechtInterface:
def __init__(self, serial_port, baudrate=115200, loop=None):
self.loop = loop or asyncio.get_event_loop()
-
self.button_callbacks = [];
coro = serial_asyncio.open_serial_connection(loop=self.loop, url=serial_port,
@@ -106,17 +105,31 @@ class RupprechtInterface:
async def receive_messages(self):
while True:
- line = await self.reader.readline()
- line = line.strip()
+ try:
+ print("Waiting for input:")
+ line = await self.reader.readline()
+ except serial.SerialException:
+ print("SerialException, will terminate")
+ self.loop.cancel()
+ return
+ print("Received: ", line)
+ line = line.decode('ascii').strip()
if str.startswith(line, "BUTTON"):
+ print("Button message")
await self.button_queue.put(line[len("BUTTON"):])
else:
+ print("Into data queue")
await self.data_queue.put(line)
+ print("done")
async def handlecallbacks(self):
- await self.send_raw("CONFIG ECHO OFF")
# filter out the last echo
- await self.data_queue.get()
+ #await self.data_queue.get()
+ #print("Waiting for message")
+ #while "READY" != self.data_queue.get():
+ # pass
+ #await self.send_raw("CONFIG ECHO OFF", expect_response=False)
+ print("Rupprecht finally there")
while True:
button_msg = await self.button_queue.get()
@@ -128,7 +141,7 @@ class RupprechtInterface:
for callback in self.button_callbacks:
try:
- callback(buttons)
+ await callback(buttons)
except Exception as e:
print("Exception while executing callback for", button_msg , e)
@@ -141,8 +154,10 @@ class RupprechtInterface:
This will wait, until the preceding message has been processed.
"""
-
+ print("Sending RUPPRECHT message: ", msg)
self.writer.write(msg.encode('ascii'))
+ if msg[-1] != "\n":
+ self.writer.write(b"\n")
await self.writer.drain()
if expect_response:
return await self.data_queue.get()
diff --git a/systemd/hauptbahnhof-module@.service b/systemd/hauptbahnhof-module@.service
index 7eeeb8364269b41747ffc83ed72a3ed561b84c55..98f491e5b0755c28bb489f9b61e6e1868b5c1005 100644
--- a/systemd/hauptbahnhof-module@.service
+++ b/systemd/hauptbahnhof-module@.service
@@ -1,6 +1,7 @@
[Unit]
Description=Hauptbahnhof %i-Module
-After=network.target
+After=network-online.target
+Requires=mosquitto.service
Before=hauptbahnhof.service
[Service]
diff --git a/systemd/hauptbahnhof.target b/systemd/hauptbahnhof.target
index 44225145bdfee9c2e87a300f5264781f09ec376a..f59839516d9692ceae5806ba9f6b8d5b87804bd0 100644
--- a/systemd/hauptbahnhof.target
+++ b/systemd/hauptbahnhof.target
@@ -1,5 +1,6 @@
[Unit]
Description=Hauptbahnhof Hackerspace Control System
+Wants=mosquitto.service
[Install]
-WantedBy=multi-user.target
\ No newline at end of file
+WantedBy=multi-user.target