X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=update-web-status.py;h=78e3d71e33a5de4b072a9ed68e230cc9c5da8a23;hb=afc46eeb3d8e74c06d4b5a47e81e89548333a6fc;hp=437021ae6e174863f87d3a2d56427ea0a15b0cff;hpb=c1d7c8e5da9de7a9be6d6c565f7273a216de7ed7;p=svn42.git
diff --git a/update-web-status.py b/update-web-status.py
index 437021a..78e3d71 100755
--- a/update-web-status.py
+++ b/update-web-status.py
@@ -1,9 +1,11 @@
#!/usr/bin/python
# -*- coding: utf-8 -*-
import os
+import os.path
import sys
#import threading
import logging
+import logging.handlers
import urllib
import time
import signal
@@ -11,84 +13,165 @@ import re
import socket
import subprocess
import types
+import ConfigParser
-#logging.basicConfig(level=logging.INFO,filename='/var/log/tmp/tuer.log',format="%(asctime)s %(message)s",datefmt="%Y-%m-%d %H:%M")
-logging.basicConfig(
- level=logging.ERROR,
- format="%(asctime)s %(message)s",
- datefmt="%Y-%m-%d %H:%M"
- )
+logger = logging.getLogger()
+logger.setLevel(logging.INFO)
+lh_syslog = logging.handlers.SysLogHandler(address="/dev/log",facility=logging.handlers.SysLogHandler.LOG_LOCAL2)
+lh_syslog.setFormatter(logging.Formatter('update-web-status.py: %(levelname)s %(message)s'))
+logger.addHandler(lh_syslog)
+lh_stderr = logging.StreamHandler()
+logger.addHandler(lh_stderr)
-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'
-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'
-SENDXMPP_RECIPIENTS_DEBUG = 'xro@jabber.tittelbach.at'
-SENDXMPP_RECIPIENTS_NORMAL = ['xro@jabber.tittelbach.at', 'otti@wirdorange.org']
-SENDXMPP_RECIPIENTS_NOOFFLINE = 'the-equinox@jabber.org'
-SENDXMPP_MSG_OPENED = "Realraum Tür wurde%s geöffnet"
-SENDXMPP_MSG_CLOSED = "Realraum Tür wurde%s geschlossen"
-sendxmpp_msg_lastmsg = ""
-action_by = ""
-sendxmpp_firstmsg = True
+class UWSConfig:
+ def __init__(self,configfile=None):
+ self.configfile=configfile
+ self.config_parser=ConfigParser.ConfigParser()
+ self.config_parser.add_section('web')
+ self.config_parser.set('web','cgiuri','https://www.realraum.at/cgi/status.cgi?pass=jako16&set=')
+ #~ self.config_parser.set('web','htmlopen','
Tür ist Offen')
+ #~ self.config_parser.set('web','htmlclosed','Tür ist Geschlossen')
+ self.config_parser.set('web','htmlbored','Panic! Present&Bored')
+ self.config_parser.set('web','htmlopen','Leute Anwesend')
+ self.config_parser.set('web','htmlclosed','Keiner Da')
+ self.config_parser.add_section('debug')
+ self.config_parser.set('debug','enabled',"False")
+ self.config_parser.add_section('tracker')
+ self.config_parser.set('tracker','socket',"/var/run/tuer/presence.socket")
+ self.config_mtime=0
+ if not self.configfile is None:
+ try:
+ cf_handle = open(self.configfile,"r")
+ cf_handle.close()
+ except IOError:
+ self.writeConfigFile()
+ else:
+ self.checkConfigUpdates()
+
+ def checkConfigUpdates(self):
+ global logger
+ if self.configfile is None:
+ return
+ logging.debug("Checking Configfile mtime: "+self.configfile)
+ try:
+ mtime = os.path.getmtime(self.configfile)
+ except (IOError,OSError):
+ return
+ if self.config_mtime < mtime:
+ logging.debug("Reading Configfile")
+ try:
+ self.config_parser.read(self.configfile)
+ self.config_mtime=os.path.getmtime(self.configfile)
+ except (ConfigParser.ParsingError, IOError), pe_ex:
+ logging.error("Error parsing Configfile: "+str(pe_ex))
+ if self.config_parser.get('debug','enabled') == "True":
+ logger.setLevel(logging.DEBUG)
+ else:
+ logger.setLevel(logging.INFO)
-def sendXmppMsg(recipients, msg, resource = "torwaechter", addtimestamp = True, noofflinemsg = False):
- if type(recipients) == types.ListType:
- recipients = " ".join(recipients)
- if type(recipients) == types.UnicodeType:
- recipients = recipients.decode("utf-8")
- if type(recipients) != types.StringType:
- raise Exception("list of recipients in unknown format, can't send message")
- if recipients == "" or msg == "":
- return
-
- sendxmpp_cmd = "sendxmpp -u realrauminfo -p 5SPjTdub -j jabber.tittelbach.at -t "
- if resource:
- sendxmpp_cmd += "-r %s " % resource
- if noofflinemsg:
- sendxmpp_cmd += "--headline "
- sendxmpp_cmd += recipients
-
- if addtimestamp:
- msg += time.strftime(" (%Y-%m-%d %T)")
+ def writeConfigFile(self):
+ if self.configfile is None:
+ return
+ logging.debug("Writing Configfile "+self.configfile)
+ try:
+ cf_handle = open(self.configfile,"w")
+ self.config_parser.write(cf_handle)
+ cf_handle.close()
+ self.config_mtime=os.path.getmtime(self.configfile)
+ except IOError, io_ex:
+ logging.error("Error writing Configfile: "+str(io_ex))
+ self.configfile=None
+
+ def __getattr__(self, name):
+ underscore_pos=name.find('_')
+ if underscore_pos < 0:
+ raise AttributeError
+ try:
+ return self.config_parser.get(name[0:underscore_pos], name[underscore_pos+1:])
+ except (ConfigParser.NoOptionError, ConfigParser.NoSectionError):
+ raise AttributeError
+
+def popenTimeout1(cmd, pinput, returncode_ok=[0], ptimeout = 20.0, pcheckint = 0.25):
+ logging.debug("popenTimeout1: starting: " + cmd)
+ try:
+ sppoo = subprocess.Popen(cmd, stdin=subprocess.PIPE, shell=True)
+ sppoo.communicate(input=pinput)
+ timeout_counter=ptimeout
+ while timeout_counter > 0:
+ time.sleep(pcheckint)
+ timeout_counter -= pcheckint
+ if not sppoo.poll() is None:
+ logging.debug("popenTimeout2: subprocess %d finished, returncode: %d" % (sppoo.pid,sppoo.returncode))
+ return (sppoo.returncode in returncode_ok)
+ #timeout reached
+ logging.error("popenTimeout1: subprocess took too long (>%fs), sending SIGTERM to pid %d" % (ptimeout,sppoo.pid))
+ if sys.hexversion >= 0x020600F0:
+ sppoo.terminate()
+ else:
+ subprocess.call(["kill",str(sppoo.pid)])
+ time.sleep(1.0)
+ if sppoo.poll() is None:
+ logging.error("popenTimeout1: subprocess still alive, sending SIGKILL to pid %d" % (sppoo.pid))
+ if sys.hexversion >= 0x020600F0:
+ sppoo.kill()
+ else:
+ subprocess.call(["kill","-9",str(sppoo.pid)])
+ return False
+ except Exception, e:
+ logging.error("popenTimeout1: "+str(e))
+ return False
- logging.debug("Starting " + sendxmpp_cmd)
+def popenTimeout2(cmd, pinput, returncode_ok=[0], ptimeout=21):
+ logging.debug("popenTimeout2: starting: " + cmd)
try:
- sppoo = subprocess.Popen(sendxmpp_cmd, stdin=subprocess.PIPE, shell=True)
- sppoo.communicate(input=msg)
+ sppoo = subprocess.Popen(cmd, stdin=subprocess.PIPE, shell=True)
+ if sys.hexversion >= 0x020600F0:
+ old_shandler = signal.signal(signal.SIGALRM,lambda sn,sf: sppoo.kill())
+ else:
+ old_shandler = signal.signal(signal.SIGALRM,lambda sn,sf: os.system("kill -9 %d" % sppoo.pid))
+ signal.alarm(ptimeout) #schedule alarm
+ sppoo.communicate(input=pinput)
sppoo.wait()
+ signal.alarm(0) #disable pending alarms
+ signal.signal(signal.SIGALRM, old_shandler)
+ logging.debug("popenTimeout2: subprocess %d finished, returncode: %d" % (sppoo.pid,sppoo.returncode))
+ if sppoo.returncode < 0:
+ logging.error("popenTimeout2: subprocess took too long (>%ds) and pid %d was killed" % (ptimeout,sppoo.pid))
+ return (sppoo.returncode in returncode_ok)
except Exception, e:
- logging.error(str(e))
- logging.debug("XMPPmessage sent: '%s'" % msg)
-
-def distributeXmppMsg(msg):
- global sendxmpp_firstmsg, sendxmpp_msg_lastmsg
- if sendxmpp_firstmsg:
- sendxmpp_msg_lastmsg = msg
- sendxmpp_firstmsg = False
- if msg != sendxmpp_msg_lastmsg:
- sendXmppMsg(SENDXMPP_RECIPIENTS_NORMAL, msg)
- sendXmppMsg(SENDXMPP_RECIPIENTS_NOOFFLINE, msg, noofflinemsg=True)
- else:
- sendXmppMsg(SENDXMPP_RECIPIENTS_DEBUG, "D: " + msg)
- sendxmpp_msg_lastmsg = msg
-
+ logging.error("popenTimeout2: "+str(e))
+ try:
+ signal.signal(signal.SIGALRM, old_shandler)
+ except:
+ pass
+ return False
+
def touchURL(url):
try:
f = urllib.urlopen(url)
- f.read()
+ rq_response = f.read()
+ logging.debug("touchURL: Response "+rq_response)
f.close()
+ return rq_response
except Exception, e:
- logging.error(str(e))
+ logging.error("touchURL: "+str(e))
+
+def setRealraumHtmlStatus(htmlcode):
+ htmlcode_escaped = re.sub(r'[^\x30-\x39\x41-\x7E]',lambda m:"%%%x"%ord(m.group(0)),htmlcode)
+ if touchURL(uwscfg.web_cgiuri + htmlcode_escaped) != htmlcode:
+ logging.error("setRealraumHtmlStatus: Error setting Status, Output does not match Input")
def displayOpen():
- touchURL(URL_OPEN)
- distributeXmppMsg(SENDXMPP_MSG_OPENED % action_by)
+ setRealraumHtmlStatus(uwscfg.web_htmlopen)
def displayClosed():
- touchURL(URL_CLOSED)
- distributeXmppMsg(SENDXMPP_MSG_CLOSED % action_by)
-
+ setRealraumHtmlStatus(uwscfg.web_htmlclosed)
+
+def displayPanic():
+ setRealraumHtmlStatus(uwscfg.web_htmlbored)
+
def exitHandler(signum, frame):
- logging.info("Door Status Listener stopping")
+ logging.info("Update-Web-Status stopping")
try:
conn.close()
except:
@@ -107,57 +190,66 @@ signal.signal(signal.SIGQUIT, exitHandler)
logging.info("Door Status Listener started")
if len(sys.argv) > 1:
- socketfile = sys.argv[1]
+ uwscfg = UWSConfig(sys.argv[1])
else:
- socketfile = "/var/run/tuer/door_cmd.socket"
-
-if len(sys.argv) > 2:
- SENDXMPP_RECIPIENTS_NORMAL = sys.argv[2:]
-
-sendXmppMsg(SENDXMPP_RECIPIENTS_DEBUG,"D: update-web-status.py started")
+ uwscfg = UWSConfig()
-sockhandle = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
-RE_STATUS = re.compile(r'Status: (\w+), idle')
-RE_REQUEST = re.compile(r'Request: (\w+) (?:Card )?(.+)')
-RE_ERROR = re.compile(r'Error: (.+)')
+#socket.setdefaulttimeout(10.0) #affects all new Socket Connections (urllib as well)
+RE_PRESENCE = re.compile(r'Presence: (yes|no)(?:, (opened|closed), (.+))?')
+RE_BUTTON = re.compile(r'PanicButton|button\d?')
while True:
try:
- sockhandle.connect(socketfile)
+ if not os.path.exists(uwscfg.tracker_socket):
+ logging.debug("Socketfile '%s' not found, waiting 5 secs" % uwscfg.tracker_socket)
+ time.sleep(5)
+ continue
+ sockhandle = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
+ sockhandle.connect(uwscfg.tracker_socket)
conn = os.fdopen(sockhandle.fileno())
- sockhandle.send("listen\n")
- sockhandle.send("status\n")
+ #sockhandle.send("listen\n")
+ #sockhandle.send("status\n")
+ last_status=None
+ unixts_panic_button=None
while True:
line = conn.readline()
- logging.info("Got Line: " + line)
- m = RE_STATUS.match(line)
+ logging.debug("Got Line: " + line)
+
+ uwscfg.checkConfigUpdates()
+
+ if line == "":
+ raise Exception("EOF on Socket, daemon seems to have quit")
+
+ m = RE_PRESENCE.match(line)
if not m is None:
status = m.group(1)
- if status == "opened":
+ last_status=(status == "yes")
+ unixts_panic_button=None
+ if last_status:
displayOpen()
- if status == "closed":
+ else:
displayClosed()
- m = RE_REQUEST.match(line)
- if not m is None:
- #(rq_action,rq_by) = m.group(1,2)
- action_by = " von " + m.group(2)
- else:
- action_by = ""
- m = RE_ERROR.match(line)
+ continue
+
+ m = RE_BUTTON.match(line)
if not m is None:
- errorstr = m.group(1)
- if "too long!" in errorstr:
- distributeXmppMsg(SENDXMPP_RECIPIENTS_DEBUG, "Door Error: "+errorstr)
+ displayPanic()
+ unixts_panic_button=time.time()
+ continue
+
+ if not last_status is None and not unixts_panic_button is None and time.time() - unixts_panic_button > 3600:
+ unixts_panic_button=None
+ if last_status:
+ displayOpen()
else:
- sendXmppMsg(SENDXMPP_RECIPIENTS_DEBUG, "D: Error: "+errorstr)
+ displayClosed()
+ continue
+
except Exception, ex:
- logging.error(str(ex))
- try:
- conn.close()
- except:
- pass
+ logging.error("main: "+str(ex))
try:
sockhandle.close()
except:
pass
+ conn=None
+ sockhandle=None
time.sleep(5)
-