Skip to content

Commit 5da3150

Browse files
fix(client): preserve hardcoded query params when merging with user params
1 parent c5752fb commit 5da3150

File tree

2 files changed

+52
-0
lines changed

2 files changed

+52
-0
lines changed

src/oz_agent_sdk/_base_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -558,6 +558,10 @@ def _build_request(
558558
files = cast(HttpxRequestFiles, ForceMultipartDict())
559559

560560
prepared_url = self._prepare_url(options.url)
561+
# preserve hard-coded query params from the url
562+
if params and prepared_url.query:
563+
params = {**dict(prepared_url.params.items()), **params}
564+
prepared_url = prepared_url.copy_with(raw_path=prepared_url.raw_path.split(b"?", 1)[0])
561565
if "_" in prepared_url.host:
562566
# work around https://github.com/encode/httpx/discussions/2880
563567
kwargs["extensions"] = {"sni_hostname": prepared_url.host.replace("_", "-")}

tests/test_client.py

Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -427,6 +427,30 @@ def test_default_query_option(self) -> None:
427427

428428
client.close()
429429

430+
def test_hardcoded_query_params_in_url(self, client: OzAPI) -> None:
431+
request = client._build_request(FinalRequestOptions(method="get", url="/foo?beta=true"))
432+
url = httpx.URL(request.url)
433+
assert dict(url.params) == {"beta": "true"}
434+
435+
request = client._build_request(
436+
FinalRequestOptions(
437+
method="get",
438+
url="/foo?beta=true",
439+
params={"limit": "10", "page": "abc"},
440+
)
441+
)
442+
url = httpx.URL(request.url)
443+
assert dict(url.params) == {"beta": "true", "limit": "10", "page": "abc"}
444+
445+
request = client._build_request(
446+
FinalRequestOptions(
447+
method="get",
448+
url="/files/a%2Fb?beta=true",
449+
params={"limit": "10"},
450+
)
451+
)
452+
assert request.url.raw_path == b"/files/a%2Fb?beta=true&limit=10"
453+
430454
def test_request_extra_json(self, client: OzAPI) -> None:
431455
request = client._build_request(
432456
FinalRequestOptions(
@@ -1316,6 +1340,30 @@ async def test_default_query_option(self) -> None:
13161340

13171341
await client.close()
13181342

1343+
async def test_hardcoded_query_params_in_url(self, async_client: AsyncOzAPI) -> None:
1344+
request = async_client._build_request(FinalRequestOptions(method="get", url="/foo?beta=true"))
1345+
url = httpx.URL(request.url)
1346+
assert dict(url.params) == {"beta": "true"}
1347+
1348+
request = async_client._build_request(
1349+
FinalRequestOptions(
1350+
method="get",
1351+
url="/foo?beta=true",
1352+
params={"limit": "10", "page": "abc"},
1353+
)
1354+
)
1355+
url = httpx.URL(request.url)
1356+
assert dict(url.params) == {"beta": "true", "limit": "10", "page": "abc"}
1357+
1358+
request = async_client._build_request(
1359+
FinalRequestOptions(
1360+
method="get",
1361+
url="/files/a%2Fb?beta=true",
1362+
params={"limit": "10"},
1363+
)
1364+
)
1365+
assert request.url.raw_path == b"/files/a%2Fb?beta=true&limit=10"
1366+
13191367
def test_request_extra_json(self, client: OzAPI) -> None:
13201368
request = client._build_request(
13211369
FinalRequestOptions(

0 commit comments

Comments
 (0)