Respect trust_env on AsyncHttpConnection

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

Author: rsmeral

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,15 @@ 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 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.trust_env