no venv

10 files changed, 0 insertions, 371 deletions

diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/__init__.py b/venv/lib/python3.11/site-packages/uvicorn/middleware/__init__.py
deleted file mode 100644
index e69de29..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/__init__.py
+++ /dev/null
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/__init__.cpython-311.pyc b/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/__init__.cpython-311.pyc
deleted file mode 100644
index 5f70c5b..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/__init__.cpython-311.pyc
+++ /dev/null
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/asgi2.cpython-311.pyc b/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/asgi2.cpython-311.pyc
deleted file mode 100644
index 905a366..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/asgi2.cpython-311.pyc
+++ /dev/null
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/message_logger.cpython-311.pyc b/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/message_logger.cpython-311.pyc
deleted file mode 100644
index 87303e2..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/message_logger.cpython-311.pyc
+++ /dev/null
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/proxy_headers.cpython-311.pyc b/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/proxy_headers.cpython-311.pyc
deleted file mode 100644
index 5f8e2c9..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/proxy_headers.cpython-311.pyc
+++ /dev/null
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/wsgi.cpython-311.pyc b/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/wsgi.cpython-311.pyc
deleted file mode 100644
index 2dfa1f9..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/__pycache__/wsgi.cpython-311.pyc
+++ /dev/null
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/asgi2.py b/venv/lib/python3.11/site-packages/uvicorn/middleware/asgi2.py
deleted file mode 100644
index 4e15d15..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/asgi2.py
+++ /dev/null
@@ -1,15 +0,0 @@
-from uvicorn._types import (
-    ASGI2Application,
-    ASGIReceiveCallable,
-    ASGISendCallable,
-    Scope,
-)
-
-
-class ASGI2Middleware:
-    def __init__(self, app: "ASGI2Application"):
-        self.app = app
-
-    async def __call__(self, scope: "Scope", receive: "ASGIReceiveCallable", send: "ASGISendCallable") -> None:
-        instance = self.app(scope)
-        await instance(receive, send)
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/message_logger.py b/venv/lib/python3.11/site-packages/uvicorn/middleware/message_logger.py
deleted file mode 100644
index 0174bcc..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/message_logger.py
+++ /dev/null
@@ -1,87 +0,0 @@
-import logging
-from typing import Any
-
-from uvicorn._types import (
-    ASGI3Application,
-    ASGIReceiveCallable,
-    ASGIReceiveEvent,
-    ASGISendCallable,
-    ASGISendEvent,
-    WWWScope,
-)
-from uvicorn.logging import TRACE_LOG_LEVEL
-
-PLACEHOLDER_FORMAT = {
-    "body": "<{length} bytes>",
-    "bytes": "<{length} bytes>",
-    "text": "<{length} chars>",
-    "headers": "<...>",
-}
-
-
-def message_with_placeholders(message: Any) -> Any:
-    """
-    Return an ASGI message, with any body-type content omitted and replaced
-    with a placeholder.
-    """
-    new_message = message.copy()
-    for attr in PLACEHOLDER_FORMAT.keys():
-        if message.get(attr) is not None:
-            content = message[attr]
-            placeholder = PLACEHOLDER_FORMAT[attr].format(length=len(content))
-            new_message[attr] = placeholder
-    return new_message
-
-
-class MessageLoggerMiddleware:
-    def __init__(self, app: "ASGI3Application"):
-        self.task_counter = 0
-        self.app = app
-        self.logger = logging.getLogger("uvicorn.asgi")
-
-        def trace(message: Any, *args: Any, **kwargs: Any) -> None:
-            self.logger.log(TRACE_LOG_LEVEL, message, *args, **kwargs)
-
-        self.logger.trace = trace  # type: ignore
-
-    async def __call__(
-        self,
-        scope: "WWWScope",
-        receive: "ASGIReceiveCallable",
-        send: "ASGISendCallable",
-    ) -> None:
-        self.task_counter += 1
-
-        task_counter = self.task_counter
-        client = scope.get("client")
-        prefix = "%s:%d - ASGI" % (client[0], client[1]) if client else "ASGI"
-
-        async def inner_receive() -> "ASGIReceiveEvent":
-            message = await receive()
-            logged_message = message_with_placeholders(message)
-            log_text = "%s [%d] Receive %s"
-            self.logger.trace(  # type: ignore
-                log_text, prefix, task_counter, logged_message
-            )
-            return message
-
-        async def inner_send(message: "ASGISendEvent") -> None:
-            logged_message = message_with_placeholders(message)
-            log_text = "%s [%d] Send %s"
-            self.logger.trace(  # type: ignore
-                log_text, prefix, task_counter, logged_message
-            )
-            await send(message)
-
-        logged_scope = message_with_placeholders(scope)
-        log_text = "%s [%d] Started scope=%s"
-        self.logger.trace(log_text, prefix, task_counter, logged_scope)  # type: ignore
-        try:
-            await self.app(scope, inner_receive, inner_send)
-        except BaseException as exc:
-            log_text = "%s [%d] Raised exception"
-            self.logger.trace(log_text, prefix, task_counter)  # type: ignore
-            raise exc from None
-        else:
-            log_text = "%s [%d] Completed"
-            self.logger.trace(log_text, prefix, task_counter)  # type: ignore
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/proxy_headers.py b/venv/lib/python3.11/site-packages/uvicorn/middleware/proxy_headers.py
deleted file mode 100644
index 8f987ab..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/proxy_headers.py
+++ /dev/null
@@ -1,69 +0,0 @@
-"""
-This middleware can be used when a known proxy is fronting the application,
-and is trusted to be properly setting the `X-Forwarded-Proto` and
-`X-Forwarded-For` headers with the connecting client information.
-
-Modifies the `client` and `scheme` information so that they reference
-the connecting client, rather that the connecting proxy.
-
-https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers#Proxies
-"""
-from __future__ import annotations
-
-from typing import Union, cast
-
-from uvicorn._types import ASGI3Application, ASGIReceiveCallable, ASGISendCallable, HTTPScope, Scope, WebSocketScope
-
-
-class ProxyHeadersMiddleware:
-    def __init__(
-        self,
-        app: ASGI3Application,
-        trusted_hosts: list[str] | str = "127.0.0.1",
-    ) -> None:
-        self.app = app
-        if isinstance(trusted_hosts, str):
-            self.trusted_hosts = {item.strip() for item in trusted_hosts.split(",")}
-        else:
-            self.trusted_hosts = set(trusted_hosts)
-        self.always_trust = "*" in self.trusted_hosts
-
-    def get_trusted_client_host(self, x_forwarded_for_hosts: list[str]) -> str | None:
-        if self.always_trust:
-            return x_forwarded_for_hosts[0]
-
-        for host in reversed(x_forwarded_for_hosts):
-            if host not in self.trusted_hosts:
-                return host
-
-        return None
-
-    async def __call__(self, scope: Scope, receive: ASGIReceiveCallable, send: ASGISendCallable) -> None:
-        if scope["type"] in ("http", "websocket"):
-            scope = cast(Union["HTTPScope", "WebSocketScope"], scope)
-            client_addr: tuple[str, int] | None = scope.get("client")
-            client_host = client_addr[0] if client_addr else None
-
-            if self.always_trust or client_host in self.trusted_hosts:
-                headers = dict(scope["headers"])
-
-                if b"x-forwarded-proto" in headers:
-                    # Determine if the incoming request was http or https based on
-                    # the X-Forwarded-Proto header.
-                    x_forwarded_proto = headers[b"x-forwarded-proto"].decode("latin1").strip()
-                    if scope["type"] == "websocket":
-                        scope["scheme"] = x_forwarded_proto.replace("http", "ws")
-                    else:
-                        scope["scheme"] = x_forwarded_proto
-
-                if b"x-forwarded-for" in headers:
-                    # Determine the client address from the last trusted IP in the
-                    # X-Forwarded-For header. We've lost the connecting client's port
-                    # information by now, so only include the host.
-                    x_forwarded_for = headers[b"x-forwarded-for"].decode("latin1")
-                    x_forwarded_for_hosts = [item.strip() for item in x_forwarded_for.split(",")]
-                    host = self.get_trusted_client_host(x_forwarded_for_hosts)
-                    port = 0
-                    scope["client"] = (host, port)  # type: ignore[arg-type]
-
-        return await self.app(scope, receive, send)
diff --git a/venv/lib/python3.11/site-packages/uvicorn/middleware/wsgi.py b/venv/lib/python3.11/site-packages/uvicorn/middleware/wsgi.py
deleted file mode 100644
index 078de1a..0000000
--- a/venv/lib/python3.11/site-packages/uvicorn/middleware/wsgi.py
+++ /dev/null
@@ -1,200 +0,0 @@
-from __future__ import annotations
-
-import asyncio
-import concurrent.futures
-import io
-import sys
-import warnings
-from collections import deque
-from typing import Iterable
-
-from uvicorn._types import (
-    ASGIReceiveCallable,
-    ASGIReceiveEvent,
-    ASGISendCallable,
-    ASGISendEvent,
-    Environ,
-    ExcInfo,
-    HTTPRequestEvent,
-    HTTPResponseBodyEvent,
-    HTTPResponseStartEvent,
-    HTTPScope,
-    StartResponse,
-    WSGIApp,
-)
-
-
-def build_environ(scope: HTTPScope, message: ASGIReceiveEvent, body: io.BytesIO) -> Environ:
-    """
-    Builds a scope and request message into a WSGI environ object.
-    """
-    script_name = scope.get("root_path", "").encode("utf8").decode("latin1")
-    path_info = scope["path"].encode("utf8").decode("latin1")
-    if path_info.startswith(script_name):
-        path_info = path_info[len(script_name) :]
-    environ = {
-        "REQUEST_METHOD": scope["method"],
-        "SCRIPT_NAME": script_name,
-        "PATH_INFO": path_info,
-        "QUERY_STRING": scope["query_string"].decode("ascii"),
-        "SERVER_PROTOCOL": "HTTP/%s" % scope["http_version"],
-        "wsgi.version": (1, 0),
-        "wsgi.url_scheme": scope.get("scheme", "http"),
-        "wsgi.input": body,
-        "wsgi.errors": sys.stdout,
-        "wsgi.multithread": True,
-        "wsgi.multiprocess": True,
-        "wsgi.run_once": False,
-    }
-
-    # Get server name and port - required in WSGI, not in ASGI
-    server = scope.get("server")
-    if server is None:
-        server = ("localhost", 80)
-    environ["SERVER_NAME"] = server[0]
-    environ["SERVER_PORT"] = server[1]
-
-    # Get client IP address
-    client = scope.get("client")
-    if client is not None:
-        environ["REMOTE_ADDR"] = client[0]
-
-    # Go through headers and make them into environ entries
-    for name, value in scope.get("headers", []):
-        name_str: str = name.decode("latin1")
-        if name_str == "content-length":
-            corrected_name = "CONTENT_LENGTH"
-        elif name_str == "content-type":
-            corrected_name = "CONTENT_TYPE"
-        else:
-            corrected_name = "HTTP_%s" % name_str.upper().replace("-", "_")
-        # HTTPbis say only ASCII chars are allowed in headers, but we latin1
-        # just in case
-        value_str: str = value.decode("latin1")
-        if corrected_name in environ:
-            corrected_name_environ = environ[corrected_name]
-            assert isinstance(corrected_name_environ, str)
-            value_str = corrected_name_environ + "," + value_str
-        environ[corrected_name] = value_str
-    return environ
-
-
-class _WSGIMiddleware:
-    def __init__(self, app: WSGIApp, workers: int = 10):
-        warnings.warn(
-            "Uvicorn's native WSGI implementation is deprecated, you "
-            "should switch to a2wsgi (`pip install a2wsgi`).",
-            DeprecationWarning,
-        )
-        self.app = app
-        self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=workers)
-
-    async def __call__(
-        self,
-        scope: HTTPScope,
-        receive: ASGIReceiveCallable,
-        send: ASGISendCallable,
-    ) -> None:
-        assert scope["type"] == "http"
-        instance = WSGIResponder(self.app, self.executor, scope)
-        await instance(receive, send)
-
-
-class WSGIResponder:
-    def __init__(
-        self,
-        app: WSGIApp,
-        executor: concurrent.futures.ThreadPoolExecutor,
-        scope: HTTPScope,
-    ):
-        self.app = app
-        self.executor = executor
-        self.scope = scope
-        self.status = None
-        self.response_headers = None
-        self.send_event = asyncio.Event()
-        self.send_queue: deque[ASGISendEvent | None] = deque()
-        self.loop: asyncio.AbstractEventLoop = asyncio.get_event_loop()
-        self.response_started = False
-        self.exc_info: ExcInfo | None = None
-
-    async def __call__(self, receive: ASGIReceiveCallable, send: ASGISendCallable) -> None:
-        message: HTTPRequestEvent = await receive()  # type: ignore[assignment]
-        body = io.BytesIO(message.get("body", b""))
-        more_body = message.get("more_body", False)
-        if more_body:
-            body.seek(0, io.SEEK_END)
-            while more_body:
-                body_message: HTTPRequestEvent = (
-                    await receive()  # type: ignore[assignment]
-                )
-                body.write(body_message.get("body", b""))
-                more_body = body_message.get("more_body", False)
-            body.seek(0)
-        environ = build_environ(self.scope, message, body)
-        self.loop = asyncio.get_event_loop()
-        wsgi = self.loop.run_in_executor(self.executor, self.wsgi, environ, self.start_response)
-        sender = self.loop.create_task(self.sender(send))
-        try:
-            await asyncio.wait_for(wsgi, None)
-        finally:
-            self.send_queue.append(None)
-            self.send_event.set()
-            await asyncio.wait_for(sender, None)
-        if self.exc_info is not None:
-            raise self.exc_info[0].with_traceback(self.exc_info[1], self.exc_info[2])
-
-    async def sender(self, send: ASGISendCallable) -> None:
-        while True:
-            if self.send_queue:
-                message = self.send_queue.popleft()
-                if message is None:
-                    return
-                await send(message)
-            else:
-                await self.send_event.wait()
-                self.send_event.clear()
-
-    def start_response(
-        self,
-        status: str,
-        response_headers: Iterable[tuple[str, str]],
-        exc_info: ExcInfo | None = None,
-    ) -> None:
-        self.exc_info = exc_info
-        if not self.response_started:
-            self.response_started = True
-            status_code_str, _ = status.split(" ", 1)
-            status_code = int(status_code_str)
-            headers = [(name.encode("ascii"), value.encode("ascii")) for name, value in response_headers]
-            http_response_start_event: HTTPResponseStartEvent = {
-                "type": "http.response.start",
-                "status": status_code,
-                "headers": headers,
-            }
-            self.send_queue.append(http_response_start_event)
-            self.loop.call_soon_threadsafe(self.send_event.set)
-
-    def wsgi(self, environ: Environ, start_response: StartResponse) -> None:
-        for chunk in self.app(environ, start_response):  # type: ignore
-            response_body: HTTPResponseBodyEvent = {
-                "type": "http.response.body",
-                "body": chunk,
-                "more_body": True,
-            }
-            self.send_queue.append(response_body)
-            self.loop.call_soon_threadsafe(self.send_event.set)
-
-        empty_body: HTTPResponseBodyEvent = {
-            "type": "http.response.body",
-            "body": b"",
-            "more_body": False,
-        }
-        self.send_queue.append(empty_body)
-        self.loop.call_soon_threadsafe(self.send_event.set)
-
-
-try:
-    from a2wsgi import WSGIMiddleware
-except ModuleNotFoundError:  # pragma: no cover
-    WSGIMiddleware = _WSGIMiddleware  # type: ignore[misc, assignment]