Cleanup lowercase

Signed-off-by: Anuraag Agrawal <anuraaga@gmail.com>

Author: anuraaga

src/connectrpc/_protocol_connect.py

@@ -54,7 +54,7 @@ def _normalize_content_type(content_type: str) -> str:
     # binary and JSON are always either non-text or utf-8 and the parameters are not
     # important for matching to a codec. A custom codec could conceivably need to
     # match on parameters, but we will reconsider that if it is ever asked for.
-    return content_type.partition(";")[0].strip()
+    return content_type.partition(";")[0].strip().lower()
 
 
 def codec_name_from_content_type(content_type: str, *, stream: bool) -> str:

src/connectrpc/_server_async.py

@@ -213,7 +213,7 @@ async def __call__(
                 codec_name = protocol.codec_name_from_content_type(
                     headers.get("content-type", ""), stream=not is_unary
                 )
-            codec = self._codecs.get(codec_name.lower())
+            codec = self._codecs.get(codec_name)
             if not codec:
                 raise HTTPException(
                     HTTPStatus.UNSUPPORTED_MEDIA_TYPE,

src/connectrpc/_server_sync.py

@@ -70,13 +70,12 @@
 )
 
 
-def _normalize_wsgi_headers(environ: WSGIEnvironment) -> dict:
-    """Extract and normalize HTTP headers from WSGI environment."""
-    headers = {}
+def _process_headers(environ: WSGIEnvironment) -> Headers:
+    headers = Headers()
     if "CONTENT_TYPE" in environ:
-        headers["content-type"] = environ["CONTENT_TYPE"].lower()
+        headers["content-type"] = environ["CONTENT_TYPE"]
     if "CONTENT_LENGTH" in environ:
-        headers["content-length"] = environ["CONTENT_LENGTH"].lower()
+        headers["content-length"] = environ["CONTENT_LENGTH"]
 
     for key, value in environ.items():
         if key.startswith("HTTP_"):
@@ -85,17 +84,6 @@ def _normalize_wsgi_headers(environ: WSGIEnvironment) -> dict:
     return headers
 
 
-def _process_headers(headers: dict) -> Headers:
-    result = Headers()
-    for key, value in headers.items():
-        if isinstance(value, list | tuple):
-            for v in value:
-                result.add(key, v)
-        else:
-            result.add(key, str(value))
-    return result
-
-
 def prepare_response_headers(
     base_headers: dict[str, list[str]], selected_encoding: str
 ) -> dict[str, list[str]]:
@@ -220,7 +208,7 @@ def __call__(
 
             http_method = environ["REQUEST_METHOD"]
             http_scheme = environ.get("wsgi.url_scheme", "http")
-            headers = _process_headers(_normalize_wsgi_headers(environ))
+            headers = _process_headers(environ)
             if ra := environ.get("REMOTE_ADDR"):
                 port = environ.get("REMOTE_PORT", "0")
                 client_address = f"{ra}:{port}"

test/test_http.py

@@ -19,6 +19,7 @@
     "application/json;charset=utf-8",
     "application/json;    charset=utf-8",
     "application/json; charset=utf-8; version=1",
+    "application/JSON",
 ]