Skip to content

Commit c9e5769

Browse files
authored
Merge pull request #499 from stakpak/fix/warden-tls-platform-verifier
fix: use platform TLS verifier for all HTTP clients
2 parents cdd92e8 + 47edb32 commit c9e5769

5 files changed

Lines changed: 10 additions & 10 deletions

File tree

cli/src/apikey_auth.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,10 +18,12 @@ fn open_browser(url: &str) -> bool {
1818
async fn listen_for_callback(url: &str) -> String {
1919
let start_time = std::time::Instant::now();
2020
while start_time.elapsed() < std::time::Duration::from_secs(120) {
21-
let client = stakpak_shared::tls_client::create_tls_client(
21+
let client = match stakpak_shared::tls_client::create_tls_client(
2222
stakpak_shared::tls_client::TlsClientConfig::default(),
23-
)
24-
.unwrap_or_else(|_| reqwest::Client::new());
23+
) {
24+
Ok(c) => c,
25+
Err(_) => return "ERROR".to_string(),
26+
};
2527
let response = client.get(url).send().await;
2628

2729
match response {

libs/ai/src/registry/models_dev.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -109,9 +109,7 @@ struct CacheFile {
109109
/// Makes an HTTP request to models.dev and returns parsed provider data.
110110
/// Models are filtered to only include those with tool calling support.
111111
pub async fn fetch_models_dev() -> Result<HashMap<String, ProviderInfo>> {
112-
let client = reqwest::Client::builder()
113-
.timeout(std::time::Duration::from_secs(10))
114-
.build()
112+
let client = crate::providers::tls::create_platform_tls_client()
115113
.map_err(|e| Error::NetworkError(format!("Failed to create HTTP client: {}", e)))?;
116114

117115
let response = client

libs/shared/src/models/integrations/search_service.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ impl SearchClient {
126126
let retry_policy = ExponentialBackoff::builder().build_with_max_retries(MAX_RETRIES);
127127
let base_client =
128128
crate::tls_client::create_tls_client(crate::tls_client::TlsClientConfig::default())
129-
.unwrap_or_else(|_| reqwest::Client::new());
129+
.expect("Failed to create TLS client for search service");
130130
let client = ClientBuilder::new(base_client)
131131
.with(RetryTransientMiddleware::new_with_policy(retry_policy))
132132
.build();

libs/shared/src/oauth/flow.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ impl OAuthFlow {
7070

7171
let client =
7272
crate::tls_client::create_tls_client(crate::tls_client::TlsClientConfig::default())
73-
.unwrap_or_else(|_| reqwest::Client::new());
73+
.expect("Failed to create TLS client for OAuth token exchange");
7474
let response = client
7575
.post(&self.config.token_url)
7676
.json(&serde_json::json!({
@@ -102,7 +102,7 @@ impl OAuthFlow {
102102
pub async fn refresh_token(&self, refresh_token: &str) -> OAuthResult<TokenResponse> {
103103
let client =
104104
crate::tls_client::create_tls_client(crate::tls_client::TlsClientConfig::default())
105-
.unwrap_or_else(|_| reqwest::Client::new());
105+
.expect("Failed to create TLS client for OAuth token refresh");
106106
let response = client
107107
.post(&self.config.token_url)
108108
.json(&serde_json::json!({

libs/shared/src/oauth/providers/anthropic.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ impl AnthropicProvider {
4545
async fn create_api_key(&self, access_token: &str) -> OAuthResult<String> {
4646
let client =
4747
crate::tls_client::create_tls_client(crate::tls_client::TlsClientConfig::default())
48-
.unwrap_or_else(|_| reqwest::Client::new());
48+
.expect("Failed to create TLS client for Anthropic API key creation");
4949
let response = client
5050
.post("https://api.anthropic.com/api/oauth/claude_cli/create_api_key")
5151
.header("authorization", format!("Bearer {}", access_token))

0 commit comments

Comments
 (0)