Do not look for a port in a Unix socket domain path

Contributes to #419

Signed-off-by: Sylvain Hellegouarch <sh@defuze.org>

Author: Lawouach

asyncpg/connect_utils.py

@@ -179,9 +179,13 @@ def _parse_hostlist(hostlist, port):
         port = _validate_port_spec(hostspecs, port)
 
     for i, hostspec in enumerate(hostspecs):
-        addr, _, hostspec_port = hostspec.partition(':')
-        hosts.append(addr)
+        if not hostspec.startswith('/'):
+            addr, _, hostspec_port = hostspec.partition(':')
+        else:
+            addr = hostspec
+            hostspec_port = ''
 
+        hosts.append(addr)
         if not port:
             if hostspec_port:
                 hostlist_ports.append(int(hostspec_port))

tests/test_connect.py

@@ -475,6 +475,36 @@ class TestConnectParams(tb.TestCase):
                 }
             )
         },
+        {
+            'dsn': 'postgres:///db?host=/cloudsql/'
+                   'project:region:instance-name&user=spam',
+            'result': (
+                [os.path.join(
+                    '/cloudsql/project:region:instance-name',
+                    '.s.PGSQL.5432'
+                )], {
+                    'user': 'spam',
+                    'database': 'db'
+                }
+            )
+        },
+        {
+            'dsn': 'postgres:///db?host=127.0.0.1:5432,/cloudsql/'
+                   'project:region:instance-name,localhost:5433&user=spam',
+            'result': (
+                [
+                    ('127.0.0.1', 5432),
+                    os.path.join(
+                        '/cloudsql/project:region:instance-name',
+                        '.s.PGSQL.5432'
+                    ),
+                    ('localhost', 5433)
+                ], {
+                    'user': 'spam',
+                    'database': 'db'
+                }
+            )
+        },
     ]
 
     @contextlib.contextmanager