httpx_3672

{"status": "ok", "stdout": "src/httpx/_parsers.py:5:__all__ = ['HTTPParser', 'Mode', 'ProtocolError']\nsrc/httpx/_parsers.py:72:class HTTPParser:\nsrc/httpx/_parsers.py:76:    client = HTTPParser(writer, reader)\nsrc/httpx/_parsers.py:426:        return f'<HTTPParser [{detail}]>'\nsrc/httpx/_server.py:6:from ._parsers import HTTPParser\nsrc/httpx/_server.py:27:        self._parser = HTTPParser(stream, mode='SERVER')\n", "stderr": "", "exit_code": 0}

{"status": "error", "error_type": "FileReadError", "error_message": "'>' not supported between instances of 'int' and 'str'"}

{"status": "ok", "filepath": "src/httpx/_parsers.py", "content": "import enum\n\nfrom ._streams import Stream\n\n__all__ = ['HTTPParser', 'Mode', 'ProtocolError']\n\n\n# TODO...\n\n# * Upgrade\n# * CONNECT\n\n#\u00a0* Support 'Expect: 100 Continue'\n# * Add 'Error' state transitions\n# * Add tests to trickle data\n# * Add type annotations\n\n# * Optional... HTTP/1.0 support\n# * Read trailing headers on Transfer-Encoding: chunked. Not just '\\r\\n'.\n# * When writing Transfer-Encoding: chunked, split large writes into buffer size.\n# * When reading Transfer-Encoding: chunked, handle incomplete reads from large chunk sizes.\n# * .read() doesn't document if will always return maximum available.\n\n# * validate method, target, protocol in request line\n# * validate protocol, status_code, reason_phrase in response line\n# * validate name, value on headers\n\n\nclass State(enum.Enum):\n    WAIT = 0\n    SEND_METHOD_LINE = 1\n    SEND_STATUS_LINE = 2\n    SEND_HEADERS = 3\n    SEND_BODY = 4\n    RECV_METHOD_LINE = 5\n    RECV_STATUS_LINE = 6\n    RECV_HEADERS = 7\n    RECV_BODY = 8\n    DONE = 9\n    CLOSED = 10\n\n\nclass Mode(enum.Enum):\n    CLIENT = 0\n    SERVER = 1\n\n\n# The usual transitions will be...\n\n# IDLE, IDLE\n# SEND_HEADERS, IDLE\n# SEND_BODY, IDLE\n# DONE, IDLE\n# DONE, SEND_HEADERS\n# DONE, SEND_BODY\n# DONE, DONE\n\n# Then either back to IDLE, IDLE\n# or move to CLOSED, CLOSED\n\n# 1. It is also valid for the server to start\n#    sending the response without waiting for the\n#    complete request.\n# 2. 1xx status codes are interim states, and\n#    transition from SEND_HEADERS back to IDLE\n# 3. ...\n\nclass ProtocolError(Exception):\n    pass\n\n\nclass HTTPParser:\n    \"\"\"\n    Usage...\n\n    client = HTTPParser(writer, reader)\n    client.send_method_line()\n    client.send_headers()\n    client.send_body()\n    client.recv_status_line()\n    client.recv_headers()\n    client.recv_body()\n    client.complete()\n    client.close()\n    \"\"\"\

{"status": "error", "error_type": "FileReadError", "error_message": "'>' not supported between instances of 'int' and 'str'"}

{"status": "ok", "stdout": "import enum\n\nfrom ._streams import Stream\n\n__all__ = ['HTTPParser', 'Mode', 'ProtocolError']\n\n\n# TODO...\n\n# * Upgrade\n# * CONNECT\n\n#\u00a0* Support 'Expect: 100 Continue'\n# * Add 'Error' state transitions\n# * Add tests to trickle data\n# * Add type annotations\n\n# * Optional... HTTP/1.0 support\n# * Read trailing headers on Transfer-Encoding: chunked. Not just '\\r\\n'.\n# * When writing Transfer-Encoding: chunked, split large writes into buffer size.\n# * When reading Transfer-Encoding: chunked, handle incomplete reads from large chunk sizes.\n# * .read() doesn't document if will always return maximum available.\n\n# * validate method, target, protocol in request line\n# * validate protocol, status_code, reason_phrase in response line\n# * validate name, value on headers\n\n\nclass State(enum.Enum):\n    WAIT = 0\n    SEND_METHOD_LINE = 1\n    SEND_STATUS_LINE = 2\n    SEND_HEADERS = 3\n    SEND_BODY = 4\n    RECV_METHOD_LINE = 5\n    RECV_STATUS_LINE = 6\n    RECV_HEADERS = 7\n    RECV_BODY = 8\n    DONE = 9\n    CLOSED = 10\n\n\nclass Mode(enum.Enum):\n    CLIENT = 0\n    SERVER = 1\n\n\n# The usual transitions will be...\n\n# IDLE, IDLE\n# SEND_HEADERS, IDLE\n# SEND_BODY, IDLE\n# DONE, IDLE\n# DONE, SEND_HEADERS\n# DONE, SEND_BODY\n# DONE, DONE\n\n# Then either back to IDLE, IDLE\n# or move to CLOSED, CLOSED\n\n# 1. It is also valid for the server to start\n#    sending the response without waiting for the\n#    complete request.\n# 2. 1xx status codes are interim states, and\n#    transition from SEND_HEADERS back to IDLE\n# 3. ...\n\nclass ProtocolError(Exception):\n    pass\n\n\nclass HTTPParser:\n    \"\"\"\n    Usage...\n\n    client = HTTPParser(writer, reader)\n    client.send_method_line()\n    client.send_headers()\n    client.send_body()\n    client.recv_status_line()\n    client.recv_headers()\n    client.recv_body()\n    client.complete()\n    client.close()\n    \"\"\"\n    def __init__(self, stream: Stream

{"status": "ok", "stdout": "378:    def complete(self):\n", "stderr": "", "exit_code": 0}

{"status": "error", "error_type": "CommandError", "error_message": "", "details": {"stdout": "", "stderr": "", "exit_code": 1}}

{"status": "error", "error_type": "FileReadError", "error_message": "'>' not supported between instances of 'int' and 'str'"}

{"status": "ok", "stdout": "                msg = 'Not enough data received for declared Content-Length'\n                raise ProtocolError(msg)\n\n        if body == b'':\n            # Handle body close\n            self.recv_state = State.DONE\n        return body\n\n    def complete(self):\n        is_fully_complete = self.send_state == State.DONE and self.recv_state == State.DONE\n        is_keepalive = self.send_keep_alive and self.recv_keep_alive\n\n        if not (is_fully_complete and is_keepalive):\n            self.close()\n            return\n\n        if self.mode == Mode.CLIENT:\n            self.send_state = State.SEND_METHOD_LINE\n            self.recv_state = State.WAIT\n        else:\n            self.recv_state = State.RECV_METHOD_LINE\n            self.send_state = State.WAIT\n\n        self.send_content_length = 0\n        self.recv_content_length = 0\n        self.send_seen_length = 0\n        self.recv_seen_length = 0\n        self.send_keep_alive = True\n        self.recv_keep_alive = True\n        self.processing_1xx = False\n\n", "stderr": "", "exit_code": 0}

{"status": "ok", "filepath": "src/httpx/_server.py", "content": "import contextlib\nimport logging\nimport time\n\nfrom ._content import Text\nfrom ._parsers import HTTPParser\nfrom ._request import Request\nfrom ._response import Response\nfrom ._network import NetworkBackend, sleep\nfrom ._streams import HTTPStream\n\n__all__ = [\n    \"serve_http\", \"run\"\n]\n\nlogger = logging.getLogger(\"httpx.server\")\n\n\nclass ConnectionClosed(Exception):\n    pass\n\n\nclass HTTPConnection:\n    def __init__(self, stream, endpoint):\n        self._stream = stream\n        self._endpoint = endpoint\n        self._parser = HTTPParser(stream, mode='SERVER')\n        self._keepalive_duration = 5.0\n        self._idle_expiry = time.monotonic() + self._keepalive_duration\n\n    # API entry points...\n    def handle_requests(self):\n        try:\n            while not self._parser.is_closed():\n                method, url, headers = self._recv_head()\n                stream = HTTPStream(self._recv_body, self._complete)\n                # TODO: Handle endpoint exceptions\n                with Request(method, url, headers=headers, content=stream) as request:\n                    try:\n                        response = self._endpoint(request)\n                        status_line = f\"{request.method} {request.url.target} [{response.status_code} {response.reason_phrase}]\"\n                        logger.info(status_line)\n                    except Exception:\n                        logger.error(\"Internal Server Error\", exc_info=True)\n                        content = Text(\"Internal Server Error\")\n                        err = Response(code=500, content=content)\n                        self._send_head(err)\n                        self._send_body(err)\n                    else:\n                        self._send_head(response)\n                        self._send_body(response)\n        except Exception:\n            logger.error(\"Internal Server Error\", exc_info=True)\

{"status": "ok", "stdout": "331:    def recv_body(self) -> bytes:\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "    def recv_body(self) -> bytes:\n        \"\"\"\n        Receive the response body. An empty byte string indicates the end of the stream:\n\n        >>> buffer = bytearray()\n        >>> while body := p.recv_body()\n        >>>     buffer.extend(body)\n\n        The server will switch to DONE.\n        \"\"\"\n        if self.recv_state != State.RECV_BODY:\n            msg = f\"Called 'recv_body' in invalid state {self.recv_state}\"\n            raise ProtocolError(msg)\n\n        if self.recv_content_length is None:\n            # Transfer-Encoding: chunked\n            exc_text = 'reading chunk size'\n            line = self.parser.read_until(b\"\\r\\n\", max_size=4096, exc_text=exc_text)\n            sizestr, _, _ = line.partition(b\";\")\n\n            exc_text = \"Received invalid chunk size\"\n            size = bounded_hex(sizestr, max_digits=8, exc_text=exc_text)\n            if size > 0:\n                body = self.parser.read(size=size)\n                exc_text = 'reading chunk data'\n                self.parser.read_until(b\"\\r\\n\", max_size=2, exc_text=exc_text)\n                self.recv_seen_length += len(body)\n            else:\n                body = b''\n                exc_text = 'reading chunk termination'\n                self.parser.read_until(b\"\\r\\n\", max_size=2, exc_text=exc_text)\n\n        else:\n            # Content-Length: xxx\n            remaining = self.recv_content_length - self.recv_seen_length\n            size = min(remaining, 4096)\n            body = self.parser.read(size=size)\n            self.recv_seen_length += len(body)\n            if self.recv_seen_length < self.recv_content_length and body == b'':\n                msg = 'Not enough data received for declared Content-Length'\n", "stderr": "", "exit_code": 0}

{"status": "ok", "filepath": "src/httpx/_parsers.py", "occurrences": 1, "strategy": "exact", "diff": "--- a/src/httpx/_parsers.py\n+++ b/src/httpx/_parsers.py\n@@ -375,7 +375,7 @@\n             self.recv_state = State.DONE\n         return body\n \n-    def complete(self):\n+    def reset(self):\n         is_fully_complete = self.send_state == State.DONE and self.recv_state == State.DONE\n         is_keepalive = self.send_keep_alive and self.recv_keep_alive\n \n", "is_truncated": false}

{"status": "ok", "filepath": "src/httpx/_server.py", "occurrences": 1, "strategy": "exact", "diff": "--- a/src/httpx/_server.py\n+++ b/src/httpx/_server.py\n@@ -89,7 +89,7 @@\n \n     # Start it all over again...\n     def _complete(self):\n-        self._parser.complete\n+        self._parser.reset()\n         self._idle_expiry = time.monotonic() + self._keepalive_duration\n \n \n", "is_truncated": false}

{"status": "error", "error_type": "FileEditError", "error_message": "Failed to replace: old_string not found. Ensure you're not escaping content incorrectly and check whitespace, indentation, and context."}

{"status": "error", "error_type": "FileReadError", "error_message": "'>' not supported between instances of 'int' and 'str'"}

{"status": "ok", "stdout": "\n    # API entry points...\n    def handle_requests(self):\n        try:\n            while not self._parser.is_closed():\n                method, url, headers = self._recv_head()\n                stream = HTTPStream(self._recv_body, self._complete)\n                # TODO: Handle endpoint exceptions\n                with Request(method, url, headers=headers, content=stream) as request:\n                    try:\n                        response = self._endpoint(request)\n                        status_line = f\"{request.method} {request.url.target} [{response.status_code} {response.reason_phrase}]\"\n                        logger.info(status_line)\n                    except Exception:\n                        logger.error(\"Internal Server Error\", exc_info=True)\n                        content = Text(\"Internal Server Error\")\n                        err = Response(code=500, content=content)\n                        self._send_head(err)\n                        self._send_body(err)\n                    else:\n                        self._send_head(response)\n                        self._send_body(response)\n        except Exception:\n            logger.error(\"Internal Server Error\", exc_info=True)\n\n    def close(self):\n        self._parser.close()\n\n    # Receive the request...\n    def _recv_head(self) -> tuple[str, str, list[tuple[str, str]]]:\n        method, target, _ = self._parser.recv_method_line()\n", "stderr": "", "exit_code": 0}

{"status": "ok", "filepath": "src/httpx/_server.py", "occurrences": 1, "strategy": "exact", "diff": "--- a/src/httpx/_server.py\n+++ b/src/httpx/_server.py\n@@ -49,8 +49,10 @@\n                     else:\n                         self._send_head(response)\n                         self._send_body(response)\n-        except Exception:\n+        except (Exception, KeyboardInterrupt):\n             logger.error(\"Internal Server Error\", exc_info=True)\n+        finally:\n+            self.close()\n \n     def close(self):\n         self._parser.close()\n", "is_truncated": false}

{"status": "ok", "stdout": "331:    def recv_body(self) -> bytes:\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "    def recv_body(self) -> bytes:\n        \"\"\"\n        Receive the response body. An empty byte string indicates the end of the stream:\n\n        >>> buffer = bytearray()\n        >>> while body := p.recv_body()\n        >>>     buffer.extend(body)\n\n        The server will switch to DONE.\n        \"\"\"\n        if self.recv_state != State.RECV_BODY:\n            msg = f\"Called 'recv_body' in invalid state {self.recv_state}\"\n            raise ProtocolError(msg)\n\n        if self.recv_content_length is None:\n            # Transfer-Encoding: chunked\n            exc_text = 'reading chunk size'\n            line = self.parser.read_until(b\"\\r\\n\", max_size=4096, exc_text=exc_text)\n            sizestr, _, _ = line.partition(b\";\")\n\n            exc_text = \"Received invalid chunk size\"\n            size = bounded_hex(sizestr, max_digits=8, exc_text=exc_text)\n            if size > 0:\n                body = self.parser.read(size=size)\n                exc_text = 'reading chunk data'\n                self.parser.read_until(b\"\\r\\n\", max_size=2, exc_text=exc_text)\n                self.recv_seen_length += len(body)\n            else:\n                body = b''\n                exc_text = 'reading chunk termination'\n                self.parser.read_until(b\"\\r\\n\", max_size=2, exc_text=exc_text)\n\n        else:\n            # Content-Length: xxx\n            remaining = self.recv_content_length - self.recv_seen_length\n            size = min(remaining, 4096)\n            body = self.parser.read(size=size)\n            self.recv_seen_length += len(body)\n            if self.recv_seen_length < self.recv_content_length and body == b'':\n                msg = 'Not enough data received for declared Content-Length'\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "                raise ProtocolError(msg)\n\n        if body == b'':\n            # Handle body close\n            self.recv_state = State.DONE\n        return body\n\n    def reset(self):\n        is_fully_complete = self.send_state == State.DONE and self.recv_state == State.DONE\n        is_keepalive = self.send_keep_alive and self.recv_keep_alive\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "282:    def recv_headers(self) -> list[tuple[bytes, bytes]]:\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "    def recv_headers(self) -> list[tuple[bytes, bytes]]:\n        \"\"\"\n        Receive the response headers:\n\n        >>> headers = p.recv_status_line()\n\n        Receive state will switch to RECV_BODY by default.\n        Receive state will revert to RECV_STATUS_CODE for interim 1xx responses.\n        \"\"\"\n        if self.recv_state != State.RECV_HEADERS:\n            msg = f\"Called 'recv_headers' in invalid state {self.recv_state}\"\n            raise ProtocolError(msg)\n\n        # Read response headers\n        headers = []\n        exc_text = \"reading response headers\"\n        while line := self.parser.read_until(b\"\\r\\n\", max_size=4096, exc_text=exc_text):\n            name, value = line.split(b\":\", 1)\n            value = value.strip(b\" \")\n            headers.append((name, value))\n\n        # Update header state\n        seen_host = False\n        for name, value in headers:\n            lname = name.lower()\n            if lname == b'host':\n                seen_host = True\n            elif lname == b'content-length':\n                self.recv_content_length = bounded_int(\n                    value,\n                    max_digits=20,\n                    exc_text=\"Received invalid Content-Length\"\n                )\n            elif lname == b'connection' and value == b'close':\n                self.recv_keep_alive = False\n            elif lname == b'transfer-encoding' and value == b'chunked':\n                self.recv_content_length = None\n\n        if self.mode == Mode.SERVER and not seen_host:\n            raise ProtocolError(\"Request missing 'Host' header\")\n\n        if self.processing_1xx:\n            # 1xx status codes preceed the final response status code\n            self.processing_1xx = False\n            self.recv_state = State.RECV_STATUS_LINE\n        else:\n            self.recv_state = State.RECV_BODY\n        return headers\n\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "227:    def recv_method_line(self) -> tuple[bytes, bytes, bytes]:\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "    def recv_method_line(self) -> tuple[bytes, bytes, bytes]:\n        \"\"\"\n        Receive the initial request method line:\n\n        >>> method, target, protocol = p.recv_status_line()\n\n        Receive state will switch to RECV_HEADERS.\n        \"\"\"\n        if self.recv_state != State.RECV_METHOD_LINE:\n            msg = f\"Called 'recv_method_line' in invalid state {self.recv_state}\"\n            raise ProtocolError(msg)\n\n        # Read initial response line, eg. \"GET / HTTP/1.1\"\n        exc_text = \"reading request method line\"\n        line = self.parser.read_until(b\"\\r\\n\", max_size=4096, exc_text=exc_text)\n        method, target, protocol = line.split(b\" \", 2)\n        if protocol != b'HTTP/1.1':\n            raise ProtocolError(\"Received unsupported protocol version\")\n\n        self.recv_state = State.RECV_HEADERS\n        self.send_state = State.SEND_STATUS_LINE\n        return method, target, protocol\n\n    def recv_status_line(self) -> tuple[bytes, int, bytes]:\n        \"\"\"\n        Receive the initial response status line:\n\n        >>> protocol, status_code, reason_phrase = p.recv_status_line()\n\n        Receive state will switch to RECV_HEADERS.\n        \"\"\"\n        if self.recv_state != State.RECV_STATUS_LINE:\n            msg = f\"Called 'recv_status_line' in invalid state {self.recv_state}\"\n            raise ProtocolError(msg)\n\n        # Read initial response line, eg. \"HTTP/1.1 200 OK\"\n        exc_text = \"reading response status line\"\n        line = self.parser.read_until(b\"\\r\\n\", max_size=4096, exc_text=exc_text)\n        protocol, status_code_str, reason_phrase = line.split(b\" \", 2)\n        if protocol != b'HTTP/1.1':\n            raise ProtocolError(\"Received unsupported protocol version\")\n\n        status_code = bounded_int(\n            status_code_str,\n            max_digits=3,\n            exc_text=\"Received invalid status code\"\n        )\n        if stat

{"status": "ok", "stdout": "413:    def is_closed(self) -> bool:\n", "stderr": "", "exit_code": 0}

{"status": "ok", "stdout": "    def is_closed(self) -> bool:\n        return self.send_state == State.CLOSED\n\n    def description(self) -> str:\n        return {\n            State.SEND_METHOD_LINE: \"idle\",\n            State.CLOSED: \"closed\",\n        }.get(self.send_state, \"active\")\n", "stderr": "", "exit_code": 0}