276 lines
8.2 KiB
Python
276 lines
8.2 KiB
Python
#!/usr/bin/python
|
|
|
|
from change_password import change_password #@UnusedImport
|
|
from db_helper import Db, getAuthTuple
|
|
from hscException import HscException
|
|
from loader_personal_statistics import loader_personal_statistics #@UnusedImport
|
|
from logger import Logger
|
|
from mandant import add_mandant, loader_change_mandant, change_mandant, change_mandant2, delete_really #@UnusedImport
|
|
from params import Params
|
|
from person import person #@UnusedImport
|
|
from session import Session, SessionContainer
|
|
|
|
import BaseHTTPServer
|
|
import Cheetah.Template
|
|
import Cookie
|
|
import SocketServer
|
|
import StringIO
|
|
import cgi
|
|
import getopt
|
|
import os
|
|
|
|
|
|
import sys
|
|
import uuid
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
pidfile_name = "/tmp/hsc.pid"
|
|
foreGround = False
|
|
templateDir = "./templates"
|
|
port = 8000
|
|
DSN = "host=127.0.0.1 dbname=radius user=webapp password=webapp123"
|
|
|
|
|
|
|
|
|
|
|
|
class HscWebApp(object):
|
|
def __init__(self, sid):
|
|
self.buf = StringIO.StringIO()
|
|
self.params = None
|
|
self.session = sessionContainer.get(sid)
|
|
self.error_msg = None
|
|
self.msg = None
|
|
self.sid = sid
|
|
|
|
def finish(self):
|
|
pass
|
|
|
|
def log(self, msg):
|
|
Logger.log(msg)
|
|
|
|
def setParams(self, p):
|
|
self.params = p
|
|
|
|
def showPage(self, forcePage=''):
|
|
if self.session:
|
|
if forcePage != '':
|
|
page = forcePage
|
|
else:
|
|
page = self.session.redirectTarget
|
|
else:
|
|
page = 'login'
|
|
|
|
if page == 'logout':
|
|
sessionContainer.delete(self.sid)
|
|
self.session = None
|
|
page = 'login'
|
|
|
|
templateFile = page + '.tmpl'
|
|
|
|
try:
|
|
if self.session:
|
|
self.log("showPage, session: %s" % str(self.session))
|
|
self.log("showPage, params: %s" % str(self.session.params))
|
|
self.session.setShownPage(page)
|
|
|
|
try:
|
|
loaderObjectClass = eval("loader_" + page)
|
|
loaderObject = loaderObjectClass(self.session)
|
|
loaderObject.mergeAdditionalData()
|
|
except NameError, e:
|
|
self.log("loader class for %s not found: %s" % (page, str(e)))
|
|
except HscException, e:
|
|
s = "HSC Failure loading data: %s" % str(e)
|
|
self.log(s)
|
|
raise Exception(s)
|
|
|
|
tmpl = Cheetah.Template.Template(file=templateDir + '/' + templateFile,
|
|
searchList=[self])
|
|
#self.log("OUTPUT: %s" % str(tmpl))
|
|
self.buf.write(str(tmpl))
|
|
|
|
if self.session:
|
|
self.session.clearMsgs()
|
|
except Exception, e:
|
|
sessionContainer.delete(self.sid)
|
|
self.buf.write("Problems to show this page: %s %s" % (e.__class__.__name__, str(e)))
|
|
finally:
|
|
pass
|
|
|
|
|
|
|
|
def processAction(self):
|
|
if self.params.action == "Login":
|
|
authTuple = getAuthTuple(self.params.username, self.params.password)
|
|
if authTuple:
|
|
self.params = Params({})
|
|
self.sid = str(uuid.uuid1())
|
|
session = Session(self.sid, self.params)
|
|
|
|
session.setAuthTuple(authTuple)
|
|
session.setGoodMsg("Welcome")
|
|
session.setRedirectTarget("menu")
|
|
sessionContainer.add(session)
|
|
else:
|
|
self.sid = 0
|
|
else:
|
|
if self.session == None:
|
|
self.sid = 0
|
|
else:
|
|
shownPage = self.session.getShownPage()
|
|
self.session.setParams(self.params)
|
|
self.log("shownPage: %s" % shownPage)
|
|
try:
|
|
dataObjectClass = eval(shownPage)
|
|
dataObject = dataObjectClass(self.session)
|
|
dataObject.process()
|
|
self.session.setGoodMsg("Action on %s performed successfully" % shownPage)
|
|
self.session.setRedirectTarget(dataObject.getNextPage())
|
|
except NameError, e:
|
|
self.log("processAction, NameError PARAMS: %s" % str(self.session.params))
|
|
s = "Internal program error: %s" % str(e)
|
|
self.session.setBadMsg(s)
|
|
self.log(s)
|
|
self.session.setRedirectTarget("menu")
|
|
except HscException, e:
|
|
self.log("processAction, HscException PARAMS: %s" % str(self.session.params))
|
|
s = "HSC Failure: %s" % str(e)
|
|
self.session.setBadMsg(s)
|
|
self.log(s)
|
|
self.session.setRedirectTarget(shownPage)
|
|
|
|
|
|
def __str__(self):
|
|
return self.buf.getvalue()
|
|
|
|
|
|
class MyHandler(BaseHTTPServer.BaseHTTPRequestHandler):
|
|
server_version = "MyHscWebAppHTTP/1.0"
|
|
|
|
def log_message(self, format, *args):
|
|
Logger.log(format%args)
|
|
|
|
def getSidFromCookie(self):
|
|
try:
|
|
cookie = Cookie.SimpleCookie(self.headers.get('Cookie'))
|
|
sid = cookie['sid'].value
|
|
except KeyError:
|
|
sid = None
|
|
return sid
|
|
|
|
def setSidInCookie(self, sid):
|
|
cookie = Cookie.SimpleCookie()
|
|
cookie['sid'] = sid
|
|
cookie['sid']['Max-Age'] = 10*60
|
|
self.wfile.write(str(cookie) + '\r\n')
|
|
|
|
|
|
|
|
def do_POST(self):
|
|
self.log_message("Request: %s", self.path)
|
|
sid = self.getSidFromCookie()
|
|
self.log_message("Cookie: %s" % self.headers.get('Cookie'))
|
|
|
|
d = HscWebApp(sid)
|
|
|
|
l = int(self.headers.get('Content-Length', '0'))
|
|
q = self.rfile.read(l)
|
|
e = cgi.parse_qs(q)
|
|
self.log_message("QUERY: %s" % str(e))
|
|
d.setParams(Params(e))
|
|
|
|
d.processAction()
|
|
|
|
self.send_response(303, "See Other")
|
|
self.setSidInCookie(d.sid)
|
|
self.send_header("Location", "/")
|
|
self.end_headers()
|
|
|
|
d.finish()
|
|
|
|
def do_GET(self):
|
|
self.log_message("Request: %s", self.path)
|
|
sid = self.getSidFromCookie()
|
|
self.log_message("SID: %s" % sid)
|
|
|
|
d = HscWebApp(sid)
|
|
|
|
d.showPage(self.path.split('/')[1])
|
|
|
|
self.send_response(200, "OK")
|
|
|
|
self.send_header("Content-Type", "text/html")
|
|
self.end_headers()
|
|
self.wfile.write(str(d))
|
|
|
|
d.finish()
|
|
|
|
|
|
|
|
class MyServer(SocketServer.ThreadingTCPServer):
|
|
def __init__(self, server_address, RequestHandlerClass):
|
|
self.allow_reuse_address = True
|
|
SocketServer.ThreadingTCPServer.__init__(self, server_address, RequestHandlerClass)
|
|
|
|
|
|
|
|
|
|
|
|
def usage():
|
|
print "Usage"
|
|
|
|
|
|
|
|
Logger.openlog()
|
|
|
|
try:
|
|
opts, args = getopt.getopt(sys.argv[1:], "hp:dFD:", ["help", "port=", "debug" "ForeGround", "DSN="])
|
|
except getopt.GetoptError:
|
|
usage()
|
|
sys.exit(2)
|
|
|
|
|
|
for o, a in opts:
|
|
if o in ("-h", "--help"):
|
|
usage()
|
|
sys.exit()
|
|
if o in ("-F", "--ForeGround"):
|
|
foreGround = True
|
|
if o in ("-p", "--port"):
|
|
port = int(a)
|
|
if o in ("-d", "--debug"):
|
|
foreGround = True
|
|
Logger.debugEnable()
|
|
if o in ("-D", "--DSN"):
|
|
DSN=a
|
|
|
|
Db.setDSN(DSN)
|
|
|
|
if foreGround:
|
|
pid = 0
|
|
else:
|
|
pid = os.fork()
|
|
|
|
|
|
if pid:
|
|
pidFile = file(pidfile_name, mode='w')
|
|
pidFile.write("%i\n" % pid)
|
|
pidFile.close()
|
|
print "daemon started with pid ", pid
|
|
sys.exit(0)
|
|
else:
|
|
Logger.log("Daemon started")
|
|
|
|
sessionContainer = SessionContainer(60, 600)
|
|
sessionContainer.setDaemon(True)
|
|
sessionContainer.start()
|
|
|
|
MyServer(('', port), MyHandler).serve_forever()
|
|
|