Skip to content

Commit bcce9f2

Browse files
zicklagmorenol
andauthored
fix: use proxy for requests that previously were not using it. (#4597)
Co-authored-by: morenol <[email protected]>
1 parent fdb45ed commit bcce9f2

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

crates/fluvio-hub-util/src/htclient.rs

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,15 @@ where
103103
T: Into<Vec<u8>> + std::fmt::Debug,
104104
{
105105
let (parts, body) = request.into_parts();
106-
let ureq_request: ureq::Request = parts.into();
106+
let agent = configure_ureq_proxy()?; // Create agent with proxy
107+
let mut ureq_request = agent.request(parts.method.as_ref(), &parts.uri.to_string());
108+
for (name, value) in parts.headers {
109+
let Some(name) = name else {
110+
continue;
111+
};
112+
ureq_request = ureq_request.set(name.as_ref(), value.to_str().unwrap());
113+
}
114+
107115
let body_u8: Vec<u8> = body.into();
108116
let response = ureq_request
109117
.send_bytes(&body_u8)

0 commit comments

Comments
 (0)