mirror of
https://github.com/openai/codex.git
synced 2026-11-01 19:33:35 +00:00
codex: address MCP file transfer self-review
This commit is contained in:
@@ -807,7 +807,7 @@ impl McpConnectionManager {
|
||||
let params = serde_json::to_value(params).context("failed to serialize file request")?;
|
||||
let result = client
|
||||
.client
|
||||
.send_custom_request(method, Some(params))
|
||||
.send_custom_request(method, Some(params), client.tool_timeout)
|
||||
.await
|
||||
.with_context(|| format!("MCP file request `{method}` failed for `{server}`"))?;
|
||||
let ServerResult::CustomResult(result) = result else {
|
||||
|
||||
@@ -669,15 +669,20 @@ impl RmcpClient {
|
||||
&self,
|
||||
method: &str,
|
||||
params: Option<serde_json::Value>,
|
||||
timeout: Option<Duration>,
|
||||
) -> Result<ServerResult> {
|
||||
self.refresh_oauth_if_needed().await;
|
||||
let operation = method.to_string();
|
||||
let request_method = operation.clone();
|
||||
let response = self
|
||||
.run_service_operation("requests/custom", /*timeout*/ None, move |service| {
|
||||
.run_service_operation(&operation, timeout, move |service| {
|
||||
let params = params.clone();
|
||||
let request_method = request_method.clone();
|
||||
async move {
|
||||
service
|
||||
.send_request(ClientRequest::CustomRequest(CustomRequest::new(
|
||||
method, params,
|
||||
request_method,
|
||||
params,
|
||||
)))
|
||||
.await
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user