wip: dependency injection for httpx

Author: silentworks

Makefile

@@ -37,6 +37,7 @@ remove_pytest_asyncio_from_sync:
 	sed -i 's/@pytest.mark.asyncio//g' tests/_sync/test_client.py
 	sed -i 's/_async/_sync/g' tests/_sync/test_client.py
 	sed -i 's/Async/Sync/g' tests/_sync/test_client.py
+	sed -i 's/Async/Sync/g' postgrest/_sync/request_builder.py
 
 sleep:
 	sleep 2

postgrest/_async/client.py

@@ -30,6 +30,7 @@ def __init__(
         timeout: Union[int, float, Timeout] = DEFAULT_POSTGREST_CLIENT_TIMEOUT,
         verify: bool = True,
         proxy: Optional[str] = None,
+        client: Union[AsyncClient, None] = None,
     ) -> None:
         BasePostgrestClient.__init__(
             self,
@@ -39,6 +40,7 @@ def __init__(
             timeout=timeout,
             verify=verify,
             proxy=proxy,
+            client=client,
         )
         self.session = cast(AsyncClient, self.session)
 
@@ -49,7 +51,11 @@ def create_session(
         timeout: Union[int, float, Timeout],
         verify: bool = True,
         proxy: Optional[str] = None,
+        client: Union[AsyncClient, None] = None,
     ) -> AsyncClient:
+        if client is not None:
+            return client
+
         return AsyncClient(
             base_url=base_url,
             headers=headers,

postgrest/_sync/client.py

@@ -30,6 +30,7 @@ def __init__(
         timeout: Union[int, float, Timeout] = DEFAULT_POSTGREST_CLIENT_TIMEOUT,
         verify: bool = True,
         proxy: Optional[str] = None,
+        client: Union[SyncClient, None] = None,
     ) -> None:
         BasePostgrestClient.__init__(
             self,
@@ -39,6 +40,7 @@ def __init__(
             timeout=timeout,
             verify=verify,
             proxy=proxy,
+            client=client,
         )
         self.session = cast(SyncClient, self.session)
 
@@ -49,7 +51,11 @@ def create_session(
         timeout: Union[int, float, Timeout],
         verify: bool = True,
         proxy: Optional[str] = None,
+        client: Union[SyncClient, None] = None,
     ) -> SyncClient:
+        if client is not None:
+            return client
+
         return SyncClient(
             base_url=base_url,
             headers=headers,

postgrest/base_client.py

@@ -45,6 +45,7 @@ def create_session(
         timeout: Union[int, float, Timeout],
         verify: bool = True,
         proxy: Optional[str] = None,
+        client: Union[SyncClient, AsyncClient, None] = None,
     ) -> Union[SyncClient, AsyncClient]:
         raise NotImplementedError()