Respect trust_env on AsyncHttpConnection

Signed-off-by: Ron Smeral <[email protected]>

Author: rsmeral

CHANGELOG.md

@@ -5,6 +5,8 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ### Added
 - Added option to pass custom headers to 'AWSV4SignerAsyncAuth' ([863](https://github.com/opensearch-project/opensearch-py/pull/863))
 - Added sync and async sample that uses `search_after` parameter ([859](https://github.com/opensearch-project/opensearch-py/pull/859))
+- Added support for `trust_env` to `AsyncHttpConnection` ([886](https://github.com/opensearch-project/opensearch-py/pull/886))
+
 ### Updated APIs
 ### Changed
 - Small refactor of AWS Signer classes for both sync and async clients ([866](https://github.com/opensearch-project/opensearch-py/pull/866))

opensearchpy/connection/http_async.py

@@ -54,6 +54,7 @@ def __init__(
         http_compress: Optional[bool] = None,
         opaque_id: Optional[str] = None,
         loop: Any = None,
+        trust_env: Optional[bool] = False,
         **kwargs: Any,
     ) -> None:
         self.headers = {}
@@ -65,6 +66,7 @@ def __init__(
             headers=headers,
             http_compress=http_compress,
             opaque_id=opaque_id,
+            trust_env=trust_env,
             **kwargs,
         )
 
@@ -290,6 +292,7 @@ async def _create_aiohttp_session(self) -> Any:
             connector=aiohttp.TCPConnector(
                 limit=self._limit, use_dns_cache=True, ssl=self._ssl_context
             ),
+            trust_env=self._trust_env,
         )
 
 

test_opensearchpy/test_async/test_http_connection.py

@@ -135,3 +135,17 @@ def auth_fn(*args: Any, **kwargs: Any) -> Any:
             ),
             fingerprint=None,
         )
+
+    @pytest.mark.asyncio  # type: ignore
+    async def test_trust_env_default_off(self) -> None:
+        conn = AsyncHttpConnection(loop=get_running_loop())
+        await conn._create_aiohttp_session()
+        assert conn.session
+        assert not conn.session.trust_env
+
+    @pytest.mark.asyncio  # type: ignore
+    async def test_trust_env_on(self) -> None:
+        conn = AsyncHttpConnection(loop=get_running_loop(), trust_env=True)
+        await conn._create_aiohttp_session()
+        assert conn.session
+        assert conn.session.trust_env