fix ipv6 issue

qwj · qwj · commit 2efed7eeadaf · 2019-02-08T23:25:43.000+08:00
diff --git a/pproxy/__doc__.py b/pproxy/__doc__.py
@@ -1,5 +1,5 @@
 __title__       = "pproxy"
-__version__     = "2.0.7"
+__version__     = "2.0.8"
 __license__     = "MIT"
 __description__ = "Proxy server that can tunnel among remote servers by regex rules."
 __keywords__    = "proxy socks http shadowsocks shadowsocksr ssr redirect pf tunnel cipher ssl udp"
diff --git a/pproxy/server.py b/pproxy/server.py
@@ -321,14 +321,16 @@ async def open_connection(self, host, port, local_addr, lbind):
                 if host == 'tunnel':
                     raise Exception('Unknown tunnel endpoint')
                 local_addr = local_addr if lbind == 'in' else (lbind, 0) if lbind else None
-                wait = asyncio.open_connection(host=host, port=port, local_addr=local_addr)
+                family = 0 if local_addr is None else 30 if ':' in local_addr[0] else 2
+                wait = asyncio.open_connection(host=host, port=port, local_addr=local_addr, family=family)
             elif self.backward:
                 wait = self.backward.open_connection()
             elif self.unix:
                 wait = asyncio.open_unix_connection(path=self.bind, ssl=self.sslclient, server_hostname='' if self.sslclient else None)
             else:
                 local_addr = local_addr if self.lbind == 'in' else (self.lbind, 0) if self.lbind else None
-                wait = asyncio.open_connection(host=self.host_name, port=self.port, ssl=self.sslclient, local_addr=local_addr)
+                family = 0 if local_addr is None else 30 if ':' in local_addr[0] else 2
+                wait = asyncio.open_connection(host=self.host_name, port=self.port, ssl=self.sslclient, local_addr=local_addr, family=family)
             reader, writer = await asyncio.wait_for(wait, timeout=SOCKET_TIMEOUT)
         except Exception as ex:
             if self.reuse:
