3 import sys, os, getopt, logging, collections
5 import ashd.scgi, ashd.serve
8 out.write("usage: scgi-wsgi3 [-hAL] [-p MODPATH] [-T [HOST:]PORT] HANDLER-MODULE [ARGS...]\n")
11 modwsgi_compat = False
13 opts, args = getopt.getopt(sys.argv[1:], "+hALp:T:")
23 sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
24 sk.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
27 bindhost = "localhost"
31 bindport = int(a[p + 1:])
32 sk.bind((bindhost, bindport))
40 logging.basicConfig(format="scgi-wsgi3(%(name)s): %(levelname)s: %(message)s")
43 # This is suboptimal, since the socket on stdin is not necessarily
44 # AF_UNIX, but Python does not seem to offer any way around it,
46 sk = socket.fromfd(0, socket.AF_UNIX, socket.SOCK_STREAM)
49 handlermod = __import__(args[0], fromlist = ["dummy"])
50 except ImportError as exc:
51 sys.stderr.write("scgi-wsgi3: handler %s not found: %s\n" % (args[0], exc.args[0]))
53 if not modwsgi_compat:
54 if not hasattr(handlermod, "wmain"):
55 sys.stderr.write("scgi-wsgi3: handler %s has no `wmain' function\n" % args[0])
57 handler = handlermod.wmain(*args[1:])
59 if not hasattr(handlermod, "application"):
60 sys.stderr.write("scgi-wsgi3: handler %s has no `application' object\n" % args[0])
62 handler = handlermod.application
66 env = ashd.scgi.decodehead(head, "utf-8")
67 env["wsgi.uri_encoding"] = "utf-8"
69 env = ashd.scgi.decodehead(head, "latin-1")
70 env["wsgi.uri_encoding"] = "latin-1"
71 env["wsgi.version"] = 1, 0
72 if "HTTP_X_ASH_PROTOCOL" in env:
73 env["wsgi.url_scheme"] = env["HTTP_X_ASH_PROTOCOL"]
75 env["wsgi.url_scheme"] = "https"
77 env["wsgi.url_scheme"] = "http"
78 env["wsgi.input"] = sk
79 env["wsgi.errors"] = sys.stderr
80 env["wsgi.multithread"] = True
81 env["wsgi.multiprocess"] = False
82 env["wsgi.run_once"] = False
86 if isinstance(thing, collections.ByteString):
89 return str(thing).encode("latin-1")
91 class reqthread(ashd.serve.wsgithread):
92 def __init__(self, sk):
95 self.sk = self.bsk.makefile("rwb")
98 return handler(self.env, self.startreq)
100 def writehead(self, status, headers):
102 buf += b"Status: " + recode(status) + b"\n"
103 for nm, val in headers:
104 buf += recode(nm) + b": " + recode(val) + b"\n"
109 raise ashd.serve.closed()
111 def writedata(self, data):
116 raise ashd.serve.closed()
119 head = ashd.scgi.readhead(self.sk)
120 self.env = mkenv(head, self.sk)
131 nsk, addr = sk.accept()
133 reqthread(nsk).start()