move all server-related files into /wsgiasgi/server package

add top-level setup.py to install the wsgiasgi server package
use top-level run.py to start up a test server with a test app

Author: mleue

app.py renamed to run.py

@@ -1,4 +1,5 @@
 from flask import Flask, request
+from wsgi.server import WSGIServer
 
 
 app = Flask(__name__)
@@ -14,3 +15,8 @@ def root():
 def create():
     print(f"Called create endpoint with data {request.data}.")
     return "hello from /create"
+
+
+if __name__ == "__main__":
+    server = WSGIServer("127.0.0.1", 5000, app)
+    server.serve_forever()

setup.py

@@ -0,0 +1,9 @@
+from setuptools import setup, find_packages
+
+
+setup(
+    name="wsgi",
+    description="A tutorial implementation of a WSGI server and application.",
+    version="0.0.1",
+    packages=find_packages(),
+)

wsgi/__init__.py

@@ -0,0 +1 @@
+from .server import WSGIServer

wsgi/server/__init__.py

@@ -1,4 +1,4 @@
-from splitbuffer import SplitBuffer
+from .splitbuffer import SplitBuffer
 
 
 class HttpRequestParser:

http_parse.py renamed to wsgi/server/http_parse.py

@@ -2,15 +2,15 @@
 import socket
 import threading
 from io import BytesIO
-from http_parse import HttpRequestParser
-from wsgi import WSGIRequest, WSGIResponse
-from app import app
+from .http_parse import HttpRequestParser
+from .wsgi import WSGIRequest, WSGIResponse
 
 
 class Session:
-    def __init__(self, client_socket, address):
+    def __init__(self, client_socket, address, app):
         self.client_socket = client_socket
         self.address = address
+        self.app = app
         self.parser = HttpRequestParser(self)
         self.request = WSGIRequest()
         self.response = WSGIResponse()
@@ -45,24 +45,26 @@ def on_body(self, body: bytes):
     def on_message_complete(self):
         print("Received request completely.")
         environ = self.request.to_environ()
-        body_chunks = app(environ, self.response.start_response)
+        body_chunks = self.app(environ, self.response.start_response)
         print("App callable has returned.")
         self.response.body = b"".join(body_chunks)
         self.client_socket.send(self.response.to_http())
 
 
-def serve_forever(host: str, port: int):
-    server_socket = socket.socket()
-    server_socket.bind((host, port))
-    server_socket.listen(1)
+class WSGIServer:
+    def __init__(self, host: str, port: int, app):
+        self.host = host
+        self.port = port
+        self.app = app
 
-    while True:
-        client_socket, address = server_socket.accept()
-        print(f"Socket established with {address}.")
-        session = Session(client_socket, address)
-        t = threading.Thread(target=session.run)
-        t.start()
+    def serve_forever(self):
+        server_socket = socket.socket()
+        server_socket.bind((self.host, self.port))
+        server_socket.listen(1)
 
-
-if __name__ == "__main__":
-    serve_forever("127.0.0.1", 5000)
+        while True:
+            client_socket, address = server_socket.accept()
+            print(f"Socket established with {address}.")
+            session = Session(client_socket, address, self.app)
+            t = threading.Thread(target=session.run)
+            t.start()

http_response.py renamed to wsgi/server/http_response.py

@@ -1,5 +1,5 @@
 import pytest
-from http_parse import HttpRequestParser
+from .http_parse import HttpRequestParser
 
 
 class TestParserProtocol:

server.py renamed to wsgi/server/server.py

@@ -1,4 +1,4 @@
-from splitbuffer import SplitBuffer
+from .splitbuffer import SplitBuffer
 
 def test_splitbuffer():
     buffer = SplitBuffer()