X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=door_daemon.py;h=f17083b3093131dad2270af0d896cb57218ff0cb;hb=44da1f523dcdaf2fef158076f138ac8be5cb89fe;hp=8ff8435962d65ff2e039c8a8ec0ba1e65a7e5ccb;hpb=cd2f45daa92bf1390ff69a60729e45318ff8b9d6;p=svn42.git diff --git a/door_daemon.py b/door_daemon.py index 8ff8435..f17083b 100755 --- a/door_daemon.py +++ b/door_daemon.py @@ -9,111 +9,115 @@ import time import signal import re import socket +import serial -logging.basicConfig(level=logging.INFO,filename='/var/log/tuer.log',format="%(asctime)s %(message)s",datefmt="%Y-%m-%d %H:%M") +logging.basicConfig(level=logging.INFO,filename='/var/log/tmp/tuer.log',format="%(asctime)s %(message)s",datefmt="%Y-%m-%d %H:%M") class StatusDisplay(): def __init__(self): - self.url_open = 'https://www.realraum.at/cgi/status.cgi?pass=jako16&set=%3Chtml%3E%3Cbody%20bgcolor=%22lime%22%3E%3Ch3%3E%3Ccenter%3ETuer%20ist%20Offen%3C/center%3E%3C/h3%3E%3C/body%3E%3C/html%3E'; - self.url_closed = 'https://www.realraum.at/cgi/status.cgi?pass=jako16&set=%3Chtml%3E%3Cbody%20bgcolor=%22red%22%3E%3Ch3%3E%3Ccenter%3ETuer%20ist%20Geschlossen%3C/center%3E%3C/h3%3E%3C/body%3E%3C/html%3E'; + self.url_open = 'https://www.realraum.at/cgi/status.cgi?pass=jako16&set=%3Chtml%3E%3Cbody%20bgcolor=%22lime%22%3E%3Ccenter%3E%3Cb%3ET%26uuml%3Br%20ist%20Offen%3C/b%3E%3C/center%3E%3C/body%3E%3C/html%3E' + self.url_closed = 'https://www.realraum.at/cgi/status.cgi?pass=jako16&set=%3Chtml%3E%3Cbody%20bgcolor=%22red%22%3E%3Cb%3E%3Ccenter%3ET%26uuml%3Br%20ist%20Geschlossen%3C/center%3E%3C/b%3E%3C/body%3E%3C/html%3E' self.last_status_set="" #object.__init__(self) def display_open(self): if self.last_status_set != self.url_open: self.last_status_set=self.url_open - print "accessing %s\n" % self.last_status_set - f = urllib.urlopen(self.last_status_set) - f.read() - f.close() - + try: + #print "accessing %s\n" % self.last_status_set + f = urllib.urlopen(self.last_status_set) + f.read() + f.close() + except: + pass + def display_closed(self): if self.last_status_set != self.url_closed: self.last_status_set=self.url_closed - print "accessing %s\n" % self.last_status_set - f = urllib.urlopen(self.last_status_set) - f.read() - f.close() - + try: + #print "accessing %s\n" % self.last_status_set + f = urllib.urlopen(self.last_status_set) + f.read() + f.close() + except: + pass class ArduinoUSBThread ( threading.Thread ): def __init__(self, file_dev_ttyusb): self.re_isidle = re.compile(r'idle') - self.re_isopen = re.compile(r'open') - self.re_isclosed = re.compile(r'close|closing') + self.re_isopen = re.compile(r'Status: opened, idle') + self.re_isclosed = re.compile(r'Status: closed, idle') self.re_toolong = re.compile(r'took too long!') self.min_seconds_between_reset=10; self.timestamp_send_reset=0; self.running=True self.lastline="" self.last_status=None + self.shortsleep = 0 self.cv_updatestatus = threading.Condition(); #lock ist automatically created withing condition self.file_dev_ttyusb=file_dev_ttyusb - #self.fh = open(self.file_dev_ttyusb,"w+") - self.fh = os.fdopen(os.open(self.file_dev_ttyusb, os.O_RDWR | os.O_NONBLOCK ),"r+") + self.dev = serial.Serial(port=file_dev_ttyusb, baudrate=9600,timeout=60) + #pythons sucks just like perl: we need nonblock or we can't write to FileHandle while we block reading on same filehandle self.statusdisplay = StatusDisplay() threading.Thread.__init__(self) def stop(self): self.running=False - self.fh.close() - if (self.fh): - self.fh.close() + if (self.dev.isOpen()): + self.dev.close() def send_open(self): self.send_statusrequest() + self.cv_updatestatus.acquire() if self.re_isidle.search(self.lastline): logging.info("Opening Door") - print("\nSending o..") - self.fh.write("o"); - print("done\n") + self.dev.write("o"); + self.cv_updatestatus.release() def send_close(self): self.send_statusrequest() + self.cv_updatestatus.acquire() if self.re_isidle.search(self.lastline): logging.info("Closing Door") - print("\nSending c..") - self.fh.write("c"); - print("done\n") + self.dev.write("c"); + self.cv_updatestatus.release() def send_toggle(self): self.send_statusrequest() - if self.last_status == "open": - self.send_close() - elif self.last_status == "closed": - self.send_open() - + self.cv_updatestatus.acquire() + if self.re_isidle.search(self.lastline): + logging.info("Toggling Door") + self.dev.write("t"); + self.cv_updatestatus.release() + def send_reset(self): - logging.info("Resetting Door") - print("\nSending r..") - self.fh.write("r"); - print("done\n") + self.shortsleep = 20 + logging.info("Resetting Door") + self.dev.write("r"); def send_statusrequest(self): - print("\nSending s..") - self.fh.write("s"); - print("done\n") + self.shortsleep = 20 + self.dev.write("s"); self.cv_updatestatus.acquire() self.cv_updatestatus.wait(5.0) self.cv_updatestatus.release() def run (self): - while (self.running and self.fh): - try: - line = self.fh.readline(); - except IOError, e: - time.sleep(1.0) + if not self.dev.isOpen(): + self.dev.open() + while (self.running and self.dev.isOpen()): + line = self.dev.readline() + if len(line) == 0: continue - print "l" self.cv_updatestatus.acquire() - self.lastline=line + self.lastline=line.strip() logging.info(self.file_dev_ttyusb+": "+self.lastline) if self.re_isclosed.search(self.lastline): self.last_status="closed" - self.statusdisplay.display_open() + self.statusdisplay.display_closed() elif self.re_isopen.search(self.lastline): self.last_status="open" - self.statusdisplay.display_closed() + self.statusdisplay.display_open() elif self.re_toolong.search(self.lastline): self.last_status="error" if (time.time() - self.timestamp_send_reset) > self.min_seconds_between_reset: @@ -121,8 +125,8 @@ class ArduinoUSBThread ( threading.Thread ): self.send_reset() self.cv_updatestatus.notifyAll() self.cv_updatestatus.release() - if self.fh: - self.fh.close() + if self.dev.isOpen(): + self.dev.close() class ControlFIFOThread ( threading.Thread ): def __init__(self, file_fifo, arduino): @@ -134,7 +138,7 @@ class ControlFIFOThread ( threading.Thread ): def stop(self): self.running=False - self.fh.close() + self.dev.close() def run (self): self.socket = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) @@ -147,7 +151,6 @@ class ControlFIFOThread ( threading.Thread ): while (self.running): self.socketconn, addr = self.socket.accept() self.conn = os.fdopen(self.socketconn.fileno()) - print "a" while 1: #~ line="" #~ while 1: @@ -160,7 +163,6 @@ class ControlFIFOThread ( threading.Thread ): line=self.conn.readline() if not line: break - print "f" m = self.re_cmd.match(line) if not m is None: (cmd,who) = m.group(1,2) @@ -183,7 +185,6 @@ class ControlFIFOThread ( threading.Thread ): logging.info(who) else: logging.info("Invalid Command %s %s" % (cmd,who)) - print "c" self.conn.close() self.socketconn.close() if self.socket: @@ -193,13 +194,13 @@ class ControlFIFOThread ( threading.Thread ): fifofile = "/tmp/door_cmd.socket" -logging.info("Door Daemon started") - arduino = ArduinoUSBThread("/dev/ttyUSB0") arduino.start() ctrlfifo = ControlFIFOThread(fifofile,arduino) ctrlfifo.start() +arduino.send_statusrequest() + def exit_handler(signum, frame): global arduino, ctrlfifo logging.info("Door Daemon stopping") @@ -208,6 +209,11 @@ def exit_handler(signum, frame): arduino.stop() sys.exit(0) -signal.signal(signal.SIGTERM, exit_handler) +#signals proapbly don't work because of readline +#signal.signal(signal.SIGTERM, exit_handler) signal.signal(signal.SIGINT, exit_handler) signal.signal(signal.SIGQUIT, exit_handler) + +logging.info("Door Daemon started") +arduino.join() +ctrlfifo.join()