Skip to content

Commit a1dc57a

Browse files
fix(client): preserve hardcoded query params when merging with user params
1 parent f036b60 commit a1dc57a

2 files changed

Lines changed: 52 additions & 0 deletions

File tree

src/conductor/_base_client.py

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

542542
prepared_url = self._prepare_url(options.url)
543+
# preserve hard-coded query params from the url
544+
if params and prepared_url.query:
545+
params = {**dict(prepared_url.params.items()), **params}
546+
prepared_url = prepared_url.copy_with(raw_path=prepared_url.raw_path.split(b"?", 1)[0])
543547
if "_" in prepared_url.host:
544548
# work around https://github.com/encode/httpx/discussions/2880
545549
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
@@ -421,6 +421,30 @@ def test_default_query_option(self) -> None:
421421

422422
client.close()
423423

424+
def test_hardcoded_query_params_in_url(self, client: Conductor) -> None:
425+
request = client._build_request(FinalRequestOptions(method="get", url="/foo?beta=true"))
426+
url = httpx.URL(request.url)
427+
assert dict(url.params) == {"beta": "true"}
428+
429+
request = client._build_request(
430+
FinalRequestOptions(
431+
method="get",
432+
url="/foo?beta=true",
433+
params={"limit": "10", "page": "abc"},
434+
)
435+
)
436+
url = httpx.URL(request.url)
437+
assert dict(url.params) == {"beta": "true", "limit": "10", "page": "abc"}
438+
439+
request = client._build_request(
440+
FinalRequestOptions(
441+
method="get",
442+
url="/files/a%2Fb?beta=true",
443+
params={"limit": "10"},
444+
)
445+
)
446+
assert request.url.raw_path == b"/files/a%2Fb?beta=true&limit=10"
447+
424448
def test_request_extra_json(self, client: Conductor) -> None:
425449
request = client._build_request(
426450
FinalRequestOptions(
@@ -1297,6 +1321,30 @@ async def test_default_query_option(self) -> None:
12971321

12981322
await client.close()
12991323

1324+
async def test_hardcoded_query_params_in_url(self, async_client: AsyncConductor) -> None:
1325+
request = async_client._build_request(FinalRequestOptions(method="get", url="/foo?beta=true"))
1326+
url = httpx.URL(request.url)
1327+
assert dict(url.params) == {"beta": "true"}
1328+
1329+
request = async_client._build_request(
1330+
FinalRequestOptions(
1331+
method="get",
1332+
url="/foo?beta=true",
1333+
params={"limit": "10", "page": "abc"},
1334+
)
1335+
)
1336+
url = httpx.URL(request.url)
1337+
assert dict(url.params) == {"beta": "true", "limit": "10", "page": "abc"}
1338+
1339+
request = async_client._build_request(
1340+
FinalRequestOptions(
1341+
method="get",
1342+
url="/files/a%2Fb?beta=true",
1343+
params={"limit": "10"},
1344+
)
1345+
)
1346+
assert request.url.raw_path == b"/files/a%2Fb?beta=true&limit=10"
1347+
13001348
def test_request_extra_json(self, client: Conductor) -> None:
13011349
request = client._build_request(
13021350
FinalRequestOptions(

0 commit comments

Comments
 (0)