3 class headdict(object):
7 def __getitem__(self, key):
8 return self.dict[key.lower()][1]
10 def __setitem__(self, key, val):
11 self.dict[key.lower()] = [key, val]
13 def __contains__(self, key):
14 return key.lower() in self.dict
16 def __delitem__(self, key):
17 del self.dict[key.lower()]
20 return iter((list[0] for list in self.dict.itervalues()))
22 def get(self, key, default = ""):
23 if key.lower() in self.dict:
24 return self.dict[key.lower()][1]
27 def getlist(self, key):
28 return self.dict.setdefault(key.lower(), [key])[1:]
30 def add(self, key, val):
31 self.dict.setdefault(key.lower(), [key]).append(val)
34 return repr(self.dict)
45 str = str[:i] + str[i].upper() + str[i + 1:]
52 class request(object):
54 return copyrequest(self)
58 new.uriname = self.uriname + self.pathinfo[:n]
59 new.pathinfo = self.pathinfo[n:]
62 class origrequest(request):
63 def __init__(self, env):
65 self.method = env["REQUEST_METHOD"].upper()
66 self.uriname = env["SCRIPT_NAME"]
67 self.filename = env.get("SCRIPT_FILENAME")
68 self.uri = env["REQUEST_URI"]
69 self.pathinfo = env["PATH_INFO"]
70 self.query = env["QUERY_STRING"]
71 self.remoteaddr = env["REMOTE_ADDR"]
72 self.serverport = env["SERVER_PORT"]
73 self.servername = env["SERVER_NAME"]
74 self.https = "HTTPS" in env
75 self.ihead = headdict()
76 if "CONTENT_TYPE" in env:
77 self.ihead["Content-Type"] = env["CONTENT_TYPE"]
78 if "CONTENT_LENGTH" in env:
79 self.ihead["Content-Length"] = env["CONTENT_LENGTH"]
80 self.ohead = headdict()
81 for k, v in env.items():
83 self.ihead.add(fixcase(k[5:].replace("_", "-")), v)
85 self.statuscode = (200, "OK")
86 self.ohead["Content-Type"] = "text/html"
87 self.resources = set()
91 def status(self, code, msg):
92 self.statuscode = code, msg
97 self.items[id] = new = id(self)
98 if hasattr(new, "__enter__") and hasattr(new, "__exit__"):
102 def withres(self, res):
103 if res not in self.resources:
107 self.resources.add(res)
108 self.clean.add(res.__exit__)
112 res.__exit__(None, None, None)
113 self.resources.discard(res)
122 clean1(list(self.clean))
124 def oncommit(self, fn):
125 if fn not in self.commitfuns:
126 self.commitfuns.append(fn)
128 def commit(self, startreq):
129 for fun in reversed(self.commitfuns):
132 for nm in self.ohead:
133 for val in self.ohead.getlist(nm):
134 hdrs.append((nm, val))
135 startreq("%s %s" % self.statuscode, hdrs)
140 class copyrequest(request):
141 def __init__(self, p):
143 self.top = p.topreq()
145 self.method = p.method
146 self.uriname = p.uriname
147 self.filename = p.filename
149 self.pathinfo = p.pathinfo
151 self.remoteaddr = p.remoteaddr
152 self.serverport = p.serverport
157 def status(self, code, msg):
158 return self.parent.status(code, msg)
161 return self.top.item(id)
163 def withres(self, res):
164 return self.top.withres(res)
166 def oncommit(self, fn):
167 return self.top.oncommit(fn)
170 return self.parent.topreq()