moved the http client to more accessible for integrations (#59)

port-labs · Aug 9, 2023 · 5f2d466 · 5f2d466
1 parent bf0c21b
commit 5f2d466
Show file tree

Hide file tree

Showing 7 changed files with 8 additions and 7 deletions.
diff --git a/changelog/improvement.md b/changelog/improvement.md
@@ -0,0 +1 @@
+Moved the ocean httpx client so it will be more accessible to integrations
diff --git a/port_ocean/clients/port/authentication.py b/port_ocean/clients/port/authentication.py
@@ -5,7 +5,7 @@
 from pydantic import BaseModel, Field, PrivateAttr
 
 from port_ocean.clients.port.types import UserAgentType
-from port_ocean.clients.port.utils import handle_status_code
+from port_ocean.clients.utils import handle_status_code
 from port_ocean.utils import get_time
 
 

diff --git a/port_ocean/clients/port/client.py b/port_ocean/clients/port/client.py
@@ -7,7 +7,7 @@
 from port_ocean.clients.port.types import (
     KafkaCreds,
 )
-from port_ocean.clients.port.utils import handle_status_code, http
+from port_ocean.clients.utils import handle_status_code, async_client
 from port_ocean.exceptions.clients import KafkaCredentialsNotFound
 
 
@@ -21,7 +21,7 @@ def __init__(
         integration_type: str,
     ):
         self.api_url = f"{base_url}/v1"
-        self.client = http
+        self.client = async_client
         self.auth = PortAuthentication(
             self.client,
             client_id,

diff --git a/port_ocean/clients/port/mixins/blueprints.py b/port_ocean/clients/port/mixins/blueprints.py
@@ -4,7 +4,7 @@
 from loguru import logger
 
 from port_ocean.clients.port.authentication import PortAuthentication
-from port_ocean.clients.port.utils import handle_status_code
+from port_ocean.clients.utils import handle_status_code
 from port_ocean.core.models import Blueprint
 
 

diff --git a/port_ocean/clients/port/mixins/entities.py b/port_ocean/clients/port/mixins/entities.py
@@ -5,7 +5,7 @@
 
 from port_ocean.clients.port.authentication import PortAuthentication
 from port_ocean.clients.port.types import RequestOptions, UserAgentType
-from port_ocean.clients.port.utils import handle_status_code
+from port_ocean.clients.utils import handle_status_code
 from port_ocean.core.models import Entity
 
 

diff --git a/port_ocean/clients/port/mixins/integrations.py b/port_ocean/clients/port/mixins/integrations.py
@@ -5,7 +5,7 @@
 from starlette import status
 
 from port_ocean.clients.port.authentication import PortAuthentication
-from port_ocean.clients.port.utils import handle_status_code
+from port_ocean.clients.utils import handle_status_code
 
 if TYPE_CHECKING:
     from port_ocean.core.handlers.port_app_config.models import PortAppConfig

diff --git a/port_ocean/clients/port/utils.py → port_ocean/clients/utils.py b/port_ocean/clients/port/utils.py → port_ocean/clients/utils.py
@@ -14,7 +14,7 @@ def _get_http_client_context() -> httpx.AsyncClient:
     return client
 
 
-http: httpx.AsyncClient = LocalProxy(lambda: _get_http_client_context())  # type: ignore
+async_client: httpx.AsyncClient = LocalProxy(lambda: _get_http_client_context())  # type: ignore
 
 
 def handle_status_code(