Skip to content

Commit 5b379eb

Browse files
authored
fixes bug where refreshed credentials gets deleted (#2879)
1 parent a9f170c commit 5b379eb

File tree

2 files changed

+3
-8
lines changed

2 files changed

+3
-8
lines changed

crates/chat-cli/src/mcp_client/client.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -346,7 +346,7 @@ impl McpClientService {
346346
);
347347

348348
let new_transport =
349-
get_http_transport(&os_clone, true, &url, Some(auth_client.auth_client.clone()), &*messenger_dup).await?;
349+
get_http_transport(&os_clone, &url, Some(auth_client.auth_client.clone()), &*messenger_dup).await?;
350350

351351
match new_transport {
352352
HttpTransport::WithAuth((new_transport, new_auth_client)) => {
@@ -363,7 +363,7 @@ impl McpClientService {
363363
// case we would need to have user go through the auth flow
364364
// again
365365
let new_transport =
366-
get_http_transport(&os_clone, true, &url, None, &*messenger_dup).await?;
366+
get_http_transport(&os_clone, &url, None, &*messenger_dup).await?;
367367

368368
match new_transport {
369369
HttpTransport::WithAuth((new_transport, new_auth_client)) => {
@@ -519,7 +519,7 @@ impl McpClientService {
519519
Ok(Transport::Stdio((tokio_child_process, child_stderr)))
520520
},
521521
TransportType::Http => {
522-
let http_transport = get_http_transport(os, false, url, None, messenger).await?;
522+
let http_transport = get_http_transport(os, url, None, messenger).await?;
523523

524524
Ok(Transport::Http(http_transport))
525525
},

crates/chat-cli/src/mcp_client/oauth_util.rs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,6 @@ fn get_scopes() -> &'static [&'static str] {
168168

169169
pub async fn get_http_transport(
170170
os: &Os,
171-
delete_cache: bool,
172171
url: &str,
173172
auth_client: Option<AuthClient<Client>>,
174173
messenger: &dyn Messenger,
@@ -179,10 +178,6 @@ pub async fn get_http_transport(
179178
let cred_full_path = cred_dir.join(format!("{key}.token.json"));
180179
let reg_full_path = cred_dir.join(format!("{key}.registration.json"));
181180

182-
if delete_cache && cred_full_path.is_file() {
183-
tokio::fs::remove_file(&cred_full_path).await?;
184-
}
185-
186181
let reqwest_client = reqwest::Client::default();
187182
let probe_resp = reqwest_client.get(url.clone()).send().await?;
188183
match probe_resp.status() {

0 commit comments

Comments
 (0)