QUIC: protocol: inhouse implementation of quic and h3 client server p…

…air using aioquic APIs

demo.py

@@ -0,0 +1,109 @@
+#
+# demo application for http3_server.py
+#
+
+import datetime
+import os
+from urllib.parse import urlencode
+
+import httpbin
+from asgiref.wsgi import WsgiToAsgi
+from starlette.applications import Starlette
+from starlette.responses import PlainTextResponse, Response
+from starlette.staticfiles import StaticFiles
+from starlette.templating import Jinja2Templates
+from starlette.websockets import WebSocketDisconnect
+
+ROOT = os.path.dirname(__file__)
+STATIC_ROOT = os.environ.get("STATIC_ROOT", os.path.join(ROOT, "htdocs"))
+STATIC_URL = "/"
+LOGS_PATH = os.path.join(STATIC_ROOT, "logs")
+QVIS_URL = "https://qvis.edm.uhasselt.be/"
+
+templates = Jinja2Templates(directory=os.path.join(ROOT, "templates"))
+app = Starlette()
+
+
+@app.route("/")
+async def homepage(request):
+    """
+    Simple homepage.
+    """
+    await request.send_push_promise("/style.css")
+    return templates.TemplateResponse("index.html", {"request": request})
+
+
+@app.route("/echo", methods=["POST"])
+async def echo(request):
+    """
+    HTTP echo endpoint.
+    """
+    content = await request.body()
+    media_type = request.headers.get("content-type")
+    return Response(content, media_type=media_type)
+
+
+@app.route("/logs/?")
+async def logs(request):
+    """
+    Browsable list of QLOG files.
+    """
+    logs = []
+    for name in os.listdir(LOGS_PATH):
+        if name.endswith(".qlog"):
+            s = os.stat(os.path.join(LOGS_PATH, name))
+            file_url = "https://" + request.headers["host"] + "/logs/" + name
+            logs.append(
+                {
+                    "date": datetime.datetime.utcfromtimestamp(s.st_mtime).strftime(
+                        "%Y-%m-%d %H:%M:%S"
+                    ),
+                    "file_url": file_url,
+                    "name": name[:-5],
+                    "qvis_url": QVIS_URL
+                    + "?"
+                    + urlencode({"file": file_url})
+                    + "#/sequence",
+                    "size": s.st_size,
+                }
+            )
+    return templates.TemplateResponse(
+        "logs.html",
+        {
+            "logs": sorted(logs, key=lambda x: x["date"], reverse=True),
+            "request": request,
+        },
+    )
+
+
+@app.route("/{size:int}")
+def padding(request):
+    """
+    Dynamically generated data, maximum 50MB.
+    """
+    size = min(50000000, request.path_params["size"])
+    return PlainTextResponse("Z" * size)
+
+
+@app.websocket_route("/ws")
+async def ws(websocket):
+    """
+    WebSocket echo endpoint.
+    """
+    if "chat" in websocket.scope["subprotocols"]:
+        subprotocol = "chat"
+    else:
+        subprotocol = None
+    await websocket.accept(subprotocol=subprotocol)
+
+    try:
+        while True:
+            message = await websocket.receive_text()
+            await websocket.send_text(message)
+    except WebSocketDisconnect:
+        pass
+
+
+app.mount("/httpbin", WsgiToAsgi(httpbin.app))
+
+app.mount(STATIC_URL, StaticFiles(directory=STATIC_ROOT, html=True))