WSGI Content-Length and Transfer-Encoding

.gitignore

@@ -5,4 +5,5 @@ __pycache__
 *.o
 node_modules/
 yarn.lock
-.vscode
+.vscode
+/venv

bench/asgi_wsgi/falcon-wsgi.py

@@ -8,11 +8,10 @@ def on_get(self, req, resp):
         resp.content_type = falcon.MEDIA_TEXT  # Default is JSON, so override
         resp.text = "Hello, World!"
     def on_post(self, req, resp):
-        raw_data = req.stream.getvalue()
-        print("data", raw_data)
+        raw_data = req.stream.read()
         resp.status = falcon.HTTP_200  # This is the default status
         resp.content_type = falcon.MEDIA_TEXT  # Default is JSON, so override
-        resp.text = raw_data
+        resp.text = 'Ok'
 
 
 
@@ -23,4 +22,4 @@ def on_post(self, req, resp):
 app.add_route("/", home)
 
 if __name__ == "__main__":
-    WSGI(app).listen(8000, lambda config: print(f"Listening on port http://localhost:{config.port} now\n")).run(workers=8)
+    WSGI(app).listen(8000, lambda config: print(f"Listening on port http://localhost:{config.port} now\n")).run(workers=1)

bench/asgi_wsgi/raw-wsgi.py

@@ -1,8 +1,42 @@
-from socketify import WSGI
+from io import BytesIO
 
+payload = None
+with open("xml.zip", "rb") as file:
+    payload = file.read()
+
+
+stream = BytesIO()
+stream.write(payload)
+
+chunk_size = 64 * 1024
+content_length = len(payload)
+
+def app_chunked(environ, start_response):
+    start_response('200 OK', [('Content-Type', 'application/zip'), ('Transfer-Encoding', 'chunked')])
+
+    sended = 0
+    while content_length > sended:
+        end = sended + chunk_size
+        yield payload[sended:end]
+        sended = end
+
+
 def app(environ, start_response):
-    start_response('200 OK', [('Content-Type', 'text/plain')])
-    yield b'Hello, World!\n'
+    start_response('200 OK', [('Content-Type', 'application/zip'), ('Content-Length', str(content_length))])
+
+    sended = 0
+    while content_length > sended:
+        end = sended + chunk_size
+        yield payload[sended:end]
+        sended = end
+
+def app_hello(environ, start_response):
+    start_response('200 OK', [('Content-Type', 'text/plain'), ('Content-Length', '13')])
+
+    yield b'Hello, World!'
 
 if __name__ == "__main__":
-    WSGI(app).listen(8000, lambda config: print(f"Listening on port http://localhost:{config.port} now\n")).run(8)
+    from socketify import WSGI
+    WSGI(app_hello).listen(8000, lambda config: print(f"Listening on port http://localhost:{config.port} now\n")).run(1)
+    # import fastwsgi
+    # fastwsgi.run(wsgi_app=app_hello, host='127.0.0.1', port=8000)

src/socketify/helpers.py

@@ -222,7 +222,7 @@ async def middleware_route(res, req, data=None):
 class DecoratorRouter:
     def __init__(self, app, prefix: str = "", *middlewares):
         self.app = app
-        self.middlewares = list(*middlewares)
+        self.middlewares = list(middlewares)
         self.prefix = prefix
 
     def get(self, path):