Convert HTTP method to upper case

Author: kracekumar

hyper/common/connection.py

@@ -99,8 +99,9 @@ def request(self, method, url, body=None, headers=None):
         headers = headers or {}
 
         try:
+            upcased_method = method.upper()
             return self._conn.request(
-                method=method, url=url, body=body, headers=headers
+                method=upcased_method, url=url, body=body, headers=headers
             )
         except TLSUpgrade as e:
             # We upgraded in the NPN/ALPN handshake. We can just go straight to

hyper/http11/connection.py

@@ -153,6 +153,7 @@ def request(self, method, url, body=None, headers=None):
         headers = headers or {}
 
         method = to_bytestring(method)
+        upcased_method = method.upper()
         url = to_bytestring(url)
 
         if not isinstance(headers, HTTPHeaderMap):
@@ -180,7 +181,7 @@ def request(self, method, url, body=None, headers=None):
             headers[b'host'] = self.host
 
         # Begin by emitting the header block.
-        self._send_headers(method, url, headers)
+        self._send_headers(upcased_method, url, headers)
 
         # Next, send the request body.
         if body:

hyper/http20/connection.py

@@ -235,7 +235,7 @@ def request(self, method, url, body=None, headers=None):
         :returns: A stream ID for the request.
         """
         headers = headers or {}
-
+        upcased_method = method.upper()
         # Concurrency
         #
         # It's necessary to hold a lock while this method runs to satisfy H2
@@ -248,7 +248,7 @@ def request(self, method, url, body=None, headers=None):
         # being sent in the wrong order, which can lead to the out-of-order
         # messages with lower stream IDs being closed prematurely.
         with self._write_lock:
-            stream_id = self.putrequest(method, url)
+            stream_id = self.putrequest(upcased_method, url)
 
             default_headers = (':method', ':scheme', ':authority', ':path')
             for name, value in headers.items():

test/test_abstraction.py

@@ -38,6 +38,13 @@ def test_h2_kwargs(self):
             'other_kwarg': True,
         }
 
+    def test_get_method_with_lower_case(self):
+        conn = HTTPConnection('http2bin.org:443')
+        conn.request('get', '/get')
+        resp = conn.get_response()
+
+        assert resp.status == 200
+
     def test_tls_upgrade(self, monkeypatch):
         monkeypatch.setattr(
             hyper.common.connection, 'HTTP11Connection', DummyH1Connection

test/test_http11.py

@@ -128,6 +128,25 @@ def test_basic_request(self):
 
         assert received == expected
 
+    def test_basic_request_with_lower_case_method(self):
+        c = HTTP11Connection('httpbin.org')
+        c._sock = sock = DummySocket()
+
+        c.request('get', '/get', headers={'User-Agent': 'hyper'})
+
+        expected = (
+            b"GET /get HTTP/1.1\r\n"
+            b"User-Agent: hyper\r\n"
+            b"connection: Upgrade, HTTP2-Settings\r\n"
+            b"upgrade: h2c\r\n"
+            b"HTTP2-Settings: AAQAAP__\r\n"
+            b"host: httpbin.org\r\n"
+            b"\r\n"
+        )
+        received = b''.join(sock.queue)
+
+        assert received == expected
+
     def test_iterable_header(self):
         c = HTTP11Connection('httpbin.org')
         c._sock = sock = DummySocket()

test/test_hyper.py

@@ -89,6 +89,15 @@ def test_putrequest_establishes_new_stream(self):
         assert len(c.streams) == 1
         assert c.recent_stream is stream
 
+    def test_putrequest_establishes_new_stream_with_lower_case_method(self):
+        c = HTTP20Connection("www.google.com")
+
+        stream_id = c.putrequest('get', '/')
+        stream = c.streams[stream_id]
+
+        assert len(c.streams) == 1
+        assert c.recent_stream is stream
+
     def test_putrequest_autosets_headers(self):
         c = HTTP20Connection("www.google.com")