From 12cf076118570eebbff08c6b3090e0d4798447a1 Mon Sep 17 00:00:00 2001
From: cyfraeviolae <cyfraeviolae>
Date: Wed, 3 Apr 2024 03:17:55 -0400
Subject: no venv

---
 .../litestar/middleware/response_cache.py          | 58 ----------------------
 1 file changed, 58 deletions(-)
 delete mode 100644 venv/lib/python3.11/site-packages/litestar/middleware/response_cache.py

(limited to 'venv/lib/python3.11/site-packages/litestar/middleware/response_cache.py')

diff --git a/venv/lib/python3.11/site-packages/litestar/middleware/response_cache.py b/venv/lib/python3.11/site-packages/litestar/middleware/response_cache.py
deleted file mode 100644
index 62dcde6..0000000
--- a/venv/lib/python3.11/site-packages/litestar/middleware/response_cache.py
+++ /dev/null
@@ -1,58 +0,0 @@
-from __future__ import annotations
-
-from typing import TYPE_CHECKING, cast
-
-from msgspec.msgpack import encode as encode_msgpack
-
-from litestar import Request
-from litestar.constants import HTTP_RESPONSE_BODY, HTTP_RESPONSE_START
-from litestar.enums import ScopeType
-from litestar.utils.empty import value_or_default
-from litestar.utils.scope.state import ScopeState
-
-from .base import AbstractMiddleware
-
-if TYPE_CHECKING:
-    from litestar.config.response_cache import ResponseCacheConfig
-    from litestar.handlers import HTTPRouteHandler
-    from litestar.types import ASGIApp, HTTPScope, Message, Receive, Scope, Send
-
-__all__ = ["ResponseCacheMiddleware"]
-
-
-class ResponseCacheMiddleware(AbstractMiddleware):
-    def __init__(self, app: ASGIApp, config: ResponseCacheConfig) -> None:
-        self.config = config
-        super().__init__(app=app, scopes={ScopeType.HTTP})
-
-    async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
-        route_handler = cast("HTTPRouteHandler", scope["route_handler"])
-
-        expires_in: int | None = None
-        if route_handler.cache is True:
-            expires_in = self.config.default_expiration
-        elif route_handler.cache is not False and isinstance(route_handler.cache, int):
-            expires_in = route_handler.cache
-
-        connection_state = ScopeState.from_scope(scope)
-
-        messages: list[Message] = []
-
-        async def wrapped_send(message: Message) -> None:
-            if not value_or_default(connection_state.is_cached, False):
-                if message["type"] == HTTP_RESPONSE_START:
-                    do_cache = connection_state.do_cache = self.config.cache_response_filter(
-                        cast("HTTPScope", scope), message["status"]
-                    )
-                    if do_cache:
-                        messages.append(message)
-                elif value_or_default(connection_state.do_cache, False):
-                    messages.append(message)
-
-                if messages and message["type"] == HTTP_RESPONSE_BODY and not message["more_body"]:
-                    key = (route_handler.cache_key_builder or self.config.key_builder)(Request(scope))
-                    store = self.config.get_store_from_app(scope["app"])
-                    await store.set(key, encode_msgpack(messages), expires_in=expires_in)
-            await send(message)
-
-        await self.app(scope, receive, wrapped_send)
-- 
cgit v1.2.3