Add some deprecation warnings

Author: romis2012

python_socks/async_/anyio/_proxy.py

@@ -1,5 +1,6 @@
 import ssl
 from typing import Any, Optional
+import warnings
 
 import anyio
 
@@ -52,6 +53,12 @@ async def connect(
             timeout = DEFAULT_TIMEOUT
 
         _stream = kwargs.get('_stream')
+        if _stream is not None:
+            warnings.warn(
+                "The '_stream' argument is deprecated and will be removed in the future",
+                DeprecationWarning,
+                stacklevel=2,
+            )
 
         try:
             with anyio.fail_after(timeout):

python_socks/async_/asyncio/_proxy.py

@@ -2,6 +2,7 @@
 import socket
 import sys
 from typing import Any, Optional
+import warnings
 
 from ..._types import ProxyType
 from ..._helpers import parse_proxy_url
@@ -58,6 +59,13 @@ async def connect(
             timeout = DEFAULT_TIMEOUT
 
         _socket = kwargs.get('_socket')
+        if _socket is not None:
+            warnings.warn(
+                "The '_socket' argument is deprecated and will be removed in the future",
+                DeprecationWarning,
+                stacklevel=2,
+            )
+
         try:
             async with async_timeout.timeout(timeout):
                 return await self._connect(
@@ -131,11 +139,7 @@ def is_uvloop_event_loop():
                 return False
             return isinstance(self._loop, Loop)
 
-        return (
-            sys.version_info[:2] >= (3, 8)
-            or is_proactor_event_loop()
-            or is_uvloop_event_loop()
-        )
+        return sys.version_info[:2] >= (3, 8) or is_proactor_event_loop() or is_uvloop_event_loop()
 
     @property
     def proxy_host(self):

python_socks/async_/curio/_proxy.py

@@ -1,4 +1,5 @@
 from typing import Any, Optional
+import warnings
 import curio
 import curio.io
 
@@ -47,6 +48,12 @@ async def connect(
             timeout = DEFAULT_TIMEOUT
 
         _socket = kwargs.get('_socket')
+        if _socket is not None:
+            warnings.warn(
+                "The '_socket' argument is deprecated and will be removed in the future",
+                DeprecationWarning,
+                stacklevel=2,
+            )
 
         try:
             return await curio.timeout_after(

python_socks/async_/trio/_proxy.py

@@ -1,4 +1,5 @@
 from typing import Any, Optional
+import warnings
 import trio
 
 from ..._types import ProxyType
@@ -46,6 +47,12 @@ async def connect(
             timeout = DEFAULT_TIMEOUT
 
         _socket = kwargs.get('_socket')
+        if _socket is not None:
+            warnings.warn(
+                "The '_socket' argument is deprecated and will be removed in the future",
+                DeprecationWarning,
+                stacklevel=2,
+            )
 
         try:
             with trio.fail_after(timeout):
@@ -55,9 +62,7 @@ async def connect(
                     _socket=_socket,
                 )
         except trio.TooSlowError as e:
-            raise ProxyTimeoutError(
-                'Proxy connection timed out: {}'.format(timeout)
-            ) from e
+            raise ProxyTimeoutError('Proxy connection timed out: {}'.format(timeout)) from e
 
     async def _connect(
         self,

python_socks/sync/_proxy.py

@@ -1,5 +1,6 @@
 import socket
 from typing import Optional, Any
+import warnings
 
 from .._errors import ProxyConnectionError, ProxyTimeoutError, ProxyError
 
@@ -46,6 +47,12 @@ def connect(
             timeout = DEFAULT_TIMEOUT
 
         _socket = kwargs.get('_socket')
+        if _socket is not None:
+            warnings.warn(
+                "The '_socket' argument is deprecated and will be removed in the future",
+                DeprecationWarning,
+                stacklevel=2,
+            )
 
         if _socket is None:
             try:
@@ -81,9 +88,7 @@ def connect(
             return _socket
         except socket.timeout as e:
             stream.close()
-            raise ProxyTimeoutError(
-                'Proxy connection timed out: {}'.format(timeout)
-            ) from e
+            raise ProxyTimeoutError('Proxy connection timed out: {}'.format(timeout)) from e
         except ReplyError as e:
             stream.close()
             raise ProxyError(e, error_code=e.error_code)