X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=xsetbg-wsgi.py;h=161a2b5bd5bfaf3187cbc99e3c79a3e654da8e30;hb=3c346158f50cfb7e7995cc0176af52d88308529f;hp=869697deb2049f65c6c54907b5532a1f1e8f6dbc;hpb=9f11c26113add5270ade4da28c7a2adb84194b1b;p=xsetbg.git diff --git a/xsetbg-wsgi.py b/xsetbg-wsgi.py index 869697d..161a2b5 100755 --- a/xsetbg-wsgi.py +++ b/xsetbg-wsgi.py @@ -3,33 +3,45 @@ """ -__author__ = "Oleg Broytman " -__copyright__ = "Copyright (C) 2000-2012 PhiloSoft Design" -__license__ = "GNU GPL" - - from wsgiref import simple_server from wsgiref.handlers import SimpleHandler from wsgiref.simple_server import WSGIServer, make_server -simple_server.ServerHandler = SimpleHandler # Stop logging to stdout -from xsetbg import host, port, change as _change +from xsetbg_conf import xsetbg_conf +from xsetbg import change as _change + +simple_server.ServerHandler = SimpleHandler # Stop logging to stdout + +# get httpd settings from config +if xsetbg_conf.has_option("httpd", "host"): + host = xsetbg_conf.get("httpd", "host") +else: + host = 'localhost' + +if xsetbg_conf.has_option("httpd", "port"): + port = xsetbg_conf.getint("httpd", "port") +else: + error("Config must specify a port to listen. Abort.") commands = {} + def published(func): commands[func.__name__] = func return func + @published def change(force=False): _change() + @published def force(): _change(force=True) + @published def stop(): QuitWSGIServer._quit_flag = True @@ -42,8 +54,9 @@ class QuitWSGIServer(WSGIServer): while not self._quit_flag: self.handle_request() + def app(env, start_response): - command = env['PATH_INFO'][1:] # Remove the leading slash + command = env['PATH_INFO'][1:] # Remove the leading slash if command not in commands: status = '404 Not found' response_headers = [('Content-type', 'text/plain')] @@ -52,7 +65,7 @@ def app(env, start_response): try: commands[command]() - except: + except Exception: status = '500 Error' response_headers = [('Content-type', 'text/plain')] start_response(status, response_headers) @@ -63,6 +76,7 @@ def app(env, start_response): start_response(status, response_headers) return ['Ok\n'] + force() httpd = make_server(host, port, app, server_class=QuitWSGIServer) httpd.serve_forever()