feat: support for plain HTTP client connection with no length

For those connection it's expected to have the data processed at the connection closed (EOF).
The final solution was to create the `parse_closed()` HTTPParser operation which bring semantics to the closing of a connection.

Author: joamag

CHANGELOG.md

@@ -9,7 +9,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
-*
+* Support for HTTP client handling of plain HTTP message with no content length defined - finished at connection closed
 
 ### Changed
 

src/netius/clients/http.py

@@ -247,6 +247,7 @@ def close_c(self, *args, **kwargs):
         netius.StreamProtocol.close_c(self, *args, **kwargs)
 
         if self.parser:
+            self.parser.parse_closed()
             self.parser.destroy()
         if self.parsed:
             self.parsed = None

src/netius/common/http.py

@@ -459,6 +459,20 @@ def get_encodings(self):
         self.encodings = [value.strip() for value in accept_encoding_s.split(",")]
         return self.encodings
 
+    def parse_closed(self):
+        """
+        "Parses" the closed event, which may trigger a changed in state
+        for very specific conditions, which is the case of a plain encoded
+        connection with no explicit content length defined.
+
+        In these situations the closing of a connection should be seen as
+        the sending of a EOF character (with semantic value).
+        """
+
+        if not self.chunked and self.content_l == -1 and self.state == MESSAGE_STATE:
+            self.state = FINISH_STATE
+            self.trigger("on_data")
+
     def parse(self, data):
         """
         Parses the provided data chunk, changing the current

src/netius/servers/wsgi.py

@@ -243,7 +243,7 @@ def _start_response(self, connection, status, headers):
 
         # tries to determine if the accept ranges value is set and if
         # that's the case forces the uncompressed encoding to avoid possible
-        # range missmatch due to re-encoding of the content
+        # range mismatch due to re-encoding of the content
         ranges = headers.get("Accept-Ranges", None)
         if ranges == "bytes":
             connection.set_uncompressed()