global sshp, tracksensor_running
RE_TEMP = re.compile(r'temp(\d): (\d+\.\d+)')
RE_PHOTO = re.compile(r'photo(\d): [^0-9]*?(\d+)',re.I)
- RE_MOVEMENT = re.compile(r'movement|button\d?|PanicButton',re.I)
+ RE_MOVEMENT = re.compile(r'movement',re.I)
+ RE_BUTTON = re.compile(r'button\d?|PanicButton',re.I)
RE_ERROR = re.compile(r'Error: (.+)',re.I)
while tracksensor_running:
uwscfg.checkConfigUpdates()
if len(line) < 1:
raise Exception("EOF on Subprocess, daemon seems to have quit, returncode: %d",sshp.returncode)
logging.debug("trackSensorStatus: Got Line: " + line)
+ m = RE_BUTTON.match(line)
+ if not m is None:
+ sendR3Message(zmqsocket, "BoreDoomButtonPressEvent", {"Ts":int(time.time())})
+ continue
m = RE_MOVEMENT.match(line)
if not m is None:
sendR3Message(zmqsocket, "MovementSensorUpdate", {"Sensorindex":0, "Ts":int(time.time())})
pass
time.sleep(0.1)
try:
- zmqsub.close()
+ zmqpub.close()
zmqctx.destroy()
except:
pass
zmqctx = zmq.Context()
zmqctx.linger = 0
zmqpub = zmqctx.socket(zmq.PUB)
-zmqpub.connect("tcp://wuzzler.realraum.at:4243")
+zmqpub.connect("tcp://torwaechter.realraum.at:4243")
#listen for sensor data and forward them
trackSensorStatus(uwscfg, zmqpub)
-zmqsub.close()
+zmqpub.close()
zmqctx.destroy()