fix(base): add json= parameter support to _request_json and _request
This commit is contained in:
@@ -25,6 +25,7 @@ class BaseHTTPClient:
|
|||||||
headers: dict[str, str] | None = None,
|
headers: dict[str, str] | None = None,
|
||||||
params: dict[str, Any] | None = None,
|
params: dict[str, Any] | None = None,
|
||||||
auth: tuple[str, str] | None = None,
|
auth: tuple[str, str] | None = None,
|
||||||
|
json: Any | None = None,
|
||||||
) -> Any | None:
|
) -> Any | None:
|
||||||
response = await self._request(
|
response = await self._request(
|
||||||
method,
|
method,
|
||||||
@@ -32,6 +33,7 @@ class BaseHTTPClient:
|
|||||||
headers=headers,
|
headers=headers,
|
||||||
params=params,
|
params=params,
|
||||||
auth=auth,
|
auth=auth,
|
||||||
|
json=json,
|
||||||
)
|
)
|
||||||
if response is None:
|
if response is None:
|
||||||
return None
|
return None
|
||||||
@@ -70,6 +72,7 @@ class BaseHTTPClient:
|
|||||||
headers: dict[str, str] | None = None,
|
headers: dict[str, str] | None = None,
|
||||||
params: dict[str, Any] | None = None,
|
params: dict[str, Any] | None = None,
|
||||||
auth: tuple[str, str] | None = None,
|
auth: tuple[str, str] | None = None,
|
||||||
|
json: Any | None = None,
|
||||||
) -> httpx.Response | None:
|
) -> httpx.Response | None:
|
||||||
if not self.base_url:
|
if not self.base_url:
|
||||||
logger.info("%s client skipped because base URL is not configured", self.name)
|
logger.info("%s client skipped because base URL is not configured", self.name)
|
||||||
@@ -88,6 +91,7 @@ class BaseHTTPClient:
|
|||||||
headers=headers,
|
headers=headers,
|
||||||
params=params,
|
params=params,
|
||||||
auth=auth,
|
auth=auth,
|
||||||
|
json=json,
|
||||||
)
|
)
|
||||||
response.raise_for_status()
|
response.raise_for_status()
|
||||||
return response
|
return response
|
||||||
|
|||||||
Reference in New Issue
Block a user