def __call__(self, env, start_response):
status = '200 OK'
params = dict(parse_qsl(env.get('QUERY_STRING')))
ws = env.get('wsgi.websocket')
if ws and not params.get('ignore_ws'):
msg = 'WS Request Url: ' + env.get('REQUEST_URI', '')
msg += ' Echo: ' + ws.receive()
ws.send(msg)
return []
result = 'Requested Url: ' + env.get('REQUEST_URI', '')
if env['REQUEST_METHOD'] == 'POST':
result += ' Post Data: ' + env['wsgi.input'].read(int(env['CONTENT_LENGTH'])).decode('utf-8')
if params.get('addproxyhost') == 'true':
result += ' Proxy Host: ' + env.get('wsgiprox.proxy_host', '')
result = result.encode('iso-8859-1')
if params.get('chunked') == 'true':
headers = []
else:
headers = [('Content-Length', str(len(result)))]
write = start_response(status, headers)
if params.get('write') == 'true':
write(result)
return iter([])
else:
return iter([result])
# ============================================================================
评论列表
文章目录