meadsteve / lagom

        return HTTPEndpointProxy

    @staticmethod

    def create_websocket_endpoint_proxy(

        endpoint_cls: Type[WebSocketEndpoint],

        partial_provider: Callable,

        request_singletons: List[Type],

    ) -> Type[WebSocketEndpoint]:

        """Create a subclass of Starlette's WebSocketEndpoint which injects dependencies

        into relevant methods on the user's `endpoint_cls` subclass of WebSocketEndpoint

        :param endpoint_cls:

        :param partial_provider:

        :param request_singletons:

        """

        class WebSocketEndpointProxy(WebSocketEndpoint):

            def __init__(self, scope, receive, send):

                super().__init__(scope, receive, send)

                self.endpoint = endpoint_cls(scope, receive, send)

            def __getattribute__(self, name: str):

                if name in OVERRIDE_WEBSOCKET_METHODS:

                    endpoint_instance = object.__getattribute__(self, "endpoint")

                    endpoint_method = getattr(endpoint_instance, name)

                    return partial_provider(endpoint_method, shared=request_singletons)

                return object.__getattribute__(self, name)

        return WebSocketEndpointProxy

                endpoint, partial_provider, self._request_singletons

            )

    @staticmethod

    def create_http_endpoint_proxy(

        endpoint_cls: Type[HTTPEndpoint],

        partial_provider: Callable,

        request_singletons: List[Type],

    ) -> Type[HTTPEndpoint]:

        """Create a subclass of Starlette's HTTPEndpoint which injects dependencies

        into HTTP-method-named methods on the user's `endpoint_cls` subclass of HTTPEndpoint

        :param endpoint_cls:

        :param partial_provider:

        :param request_singletons:

        """

        class HTTPEndpointProxy(HTTPEndpoint):

            def __init__(self, scope, receive, send):

                super().__init__(scope, receive, send)

                self.endpoint = endpoint_cls(scope, receive, send)

            def __getattribute__(self, name: str):

                if name in OVERRIDE_HTTP_METHODS:

                    endpoint_instance = object.__getattribute__(self, "endpoint")

                    endpoint_method = getattr(endpoint_instance, name)

                    return partial_provider(endpoint_method, shared=request_singletons)

                return object.__getattribute__(self, name)

        return HTTPEndpointProxy

    @staticmethod

    def create_websocket_endpoint_proxy(