f9db920
From 92da9e010f506cdd2408f6915ff87926f907c927 Mon Sep 17 00:00:00 2001
f9db920
From: Lukas Slebodnik <lslebodn@fedoraproject.org>
f9db920
Date: Thu, 12 Apr 2018 00:34:07 +0200
f9db920
Subject: [PATCH 1] Do not lowercase hostnames with custom-protocol(#1267)
f9db920
f9db920
Unix sockets are are case sensitive the same as other files
f9db920
on standard unix file systems.
f9db920
---
f9db920
 urllib3/connectionpool.py | 11 +++++++----
f9db920
 1 file changed, 7 insertions(+), 4 deletions(-)
f9db920
f9db920
diff --git a/test/test_connectionpool.py b/test/test_connectionpool.py
f9db920
index d8b8a83..4b74ab4 100644
f9db920
--- a/test/test_connectionpool.py
f9db920
+++ b/test/test_connectionpool.py
f9db920
@@ -32,6 +32,19 @@ from ssl import SSLError as BaseSSLError
f9db920
 from dummyserver.server import DEFAULT_CA
f9db920
 
f9db920
 
f9db920
+class HTTPUnixConnection(HTTPConnection):
f9db920
+    def __init__(self, host, timeout=60, **kwargs):
f9db920
+        super(HTTPUnixConnection, self).__init__('localhost')
f9db920
+        self.unix_socket = host
f9db920
+        self.timeout = timeout
f9db920
+        self.sock = None
f9db920
+
f9db920
+
f9db920
+class HTTPUnixConnectionPool(HTTPConnectionPool):
f9db920
+    scheme = 'http+unix'
f9db920
+    ConnectionCls = HTTPUnixConnection
f9db920
+
f9db920
+
f9db920
 class TestConnectionPool(object):
f9db920
     """
f9db920
     Tests in this suite should exercise the ConnectionPool functionality
f9db920
@@ -138,6 +151,31 @@ class TestConnectionPool(object):
f9db920
         with HTTPSConnectionPool(b) as c:
f9db920
             assert not c.is_same_host(a)
f9db920
 
f9db920
+    @pytest.mark.parametrize('a, b', [
f9db920
+        ('%2Fvar%2Frun%2Fdocker.sock',
f9db920
+         'http+unix://%2Fvar%2Frun%2Fdocker.sock'),
f9db920
+        ('%2Fvar%2Frun%2Fdocker.sock',
f9db920
+         'http+unix://%2Fvar%2Frun%2Fdocker.sock/'),
f9db920
+        ('%2Fvar%2Frun%2Fdocker.sock',
f9db920
+         'http+unix://%2Fvar%2Frun%2Fdocker.sock/abracadabra'),
f9db920
+        ('%2Ftmp%2FTEST.sock', 'http+unix://%2Ftmp%2FTEST.sock'),
f9db920
+        ('%2Ftmp%2FTEST.sock', 'http+unix://%2Ftmp%2FTEST.sock/'),
f9db920
+        ('%2Ftmp%2FTEST.sock', 'http+unix://%2Ftmp%2FTEST.sock/abracadabra'),
f9db920
+    ])
f9db920
+    def test_same_host_custom_protocol(self, a, b):
f9db920
+        with HTTPUnixConnectionPool(a) as c:
f9db920
+            assert c.is_same_host(b)
f9db920
+
f9db920
+    @pytest.mark.parametrize('a, b', [
f9db920
+        ('%2Ftmp%2Ftest.sock', 'http+unix://%2Ftmp%2FTEST.sock'),
f9db920
+        ('%2Ftmp%2Ftest.sock', 'http+unix://%2Ftmp%2FTEST.sock/'),
f9db920
+        ('%2Ftmp%2Ftest.sock', 'http+unix://%2Ftmp%2FTEST.sock/abracadabra'),
f9db920
+        ('%2Fvar%2Frun%2Fdocker.sock', 'http+unix://%2Ftmp%2FTEST.sock'),
f9db920
+    ])
f9db920
+    def test_not_same_host_custom_protocol(self, a, b):
f9db920
+        with HTTPUnixConnectionPool(a) as c:
f9db920
+            assert not c.is_same_host(b)
f9db920
+
f9db920
     def test_max_connections(self):
f9db920
         with HTTPConnectionPool(host='localhost', maxsize=1, block=True) as pool:
f9db920
             pool._get_conn(timeout=0.01)
f9db920
diff --git a/urllib3/connectionpool.py b/urllib3/connectionpool.py
f9db920
index ec9600f..2d7a26b 100644
f9db920
--- a/urllib3/connectionpool.py
f9db920
+++ b/urllib3/connectionpool.py
f9db920
@@ -40,7 +40,7 @@ from .util.request import set_file_position
f9db920
 from .util.response import assert_header_parsing
f9db920
 from .util.retry import Retry
f9db920
 from .util.timeout import Timeout
f9db920
-from .util.url import get_host, Url
f9db920
+from .util.url import get_host, Url, NORMALIZABLE_SCHEMES
f9db920
 
f9db920
 
f9db920
 if six.PY2:
f9db920
@@ -68,7 +68,7 @@ class ConnectionPool(object):
f9db920
         if not host:
f9db920
             raise LocationValueError("No host specified.")
f9db920
 
f9db920
-        self.host = _ipv6_host(host).lower()
f9db920
+        self.host = _ipv6_host(host, self.scheme)
f9db920
         self._proxy_host = host.lower()
f9db920
         self.port = port
f9db920
 
f9db920
@@ -434,7 +434,7 @@ class HTTPConnectionPool(ConnectionPool, RequestMethods):
f9db920
         # TODO: Add optional support for socket.gethostbyname checking.
f9db920
         scheme, host, port = get_host(url)
f9db920
 
f9db920
-        host = _ipv6_host(host).lower()
f9db920
+        host = _ipv6_host(host, self.scheme)
f9db920
 
f9db920
         # Use explicit default port for comparison when none is given
f9db920
         if self.port and not port:
f9db920
@@ -886,7 +886,7 @@ def connection_from_url(url, **kw):
f9db920
         return HTTPConnectionPool(host, port=port, **kw)
f9db920
 
f9db920
 
f9db920
-def _ipv6_host(host):
f9db920
+def _ipv6_host(host, scheme):
f9db920
     """
f9db920
     Process IPv6 address literals
f9db920
     """
f9db920
@@ -902,4 +902,6 @@ def _ipv6_host(host):
f9db920
     # percent sign might be URIencoded, convert it back into ASCII
f9db920
     if host.startswith('[') and host.endswith(']'):
f9db920
         host = host.replace('%25', '%').strip('[]')
f9db920
+    if scheme in NORMALIZABLE_SCHEMES:
f9db920
+        host = host.lower()
f9db920
     return host